From bab14f0dd2345c9d7dcbc47c918563709e1ac094 Mon Sep 17 00:00:00 2001 From: peavey Date: Mon, 16 Jul 2007 17:14:45 +0000 Subject: 'svn propset -R svn:eol-style CR *' Set to UNIX-style always. Binaries are auto skipped by svn. git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@7454 e03df62e-2008-0410-955e-edbf42e46eb7 --- src/socketengine_ports.cpp | 130 +-------------------------------------------- 1 file changed, 1 insertion(+), 129 deletions(-) (limited to 'src/socketengine_ports.cpp') diff --git a/src/socketengine_ports.cpp b/src/socketengine_ports.cpp index 869e0a6fb..d3704f0a4 100644 --- a/src/socketengine_ports.cpp +++ b/src/socketengine_ports.cpp @@ -1,129 +1 @@ -/* +------------------------------------+ - * | Inspire Internet Relay Chat Daemon | - * +------------------------------------+ - * - * InspIRCd: (C) 2002-2007 InspIRCd Development Team - * See: http://www.inspircd.org/wiki/index.php/Credits - * - * This program is free but copyrighted software; see - * the file COPYING for details. - * - * --------------------------------------------------- - */ - -#include "inspircd.h" -#include "exitcodes.h" -#include -#include "socketengine_ports.h" - -PortsEngine::PortsEngine(InspIRCd* Instance) : SocketEngine(Instance) -{ - EngineHandle = port_create(); - - if (EngineHandle == -1) - { - ServerInstance->Log(SPARSE,"ERROR: Could not initialize socket engine: %s", strerror(errno)); - ServerInstance->Log(SPARSE,"ERROR: This is a fatal error, exiting now."); - printf("ERROR: Could not initialize socket engine: %s\n", strerror(errno)); - printf("ERROR: This is a fatal error, exiting now.\n"); - InspIRCd::Exit(EXIT_STATUS_SOCKETENGINE); - } - CurrentSetSize = 0; -} - -PortsEngine::~PortsEngine() -{ - close(EngineHandle); -} - -bool PortsEngine::AddFd(EventHandler* eh) -{ - int fd = eh->GetFd(); - if ((fd < 0) || (fd > MAX_DESCRIPTORS)) - return false; - - if (GetRemainingFds() <= 1) - return false; - - if (ref[fd]) - return false; - - ref[fd] = eh; - port_associate(EngineHandle, PORT_SOURCE_FD, fd, eh->Readable() ? POLLRDNORM : POLLWRNORM, eh); - - ServerInstance->Log(DEBUG,"New file descriptor: %d", fd); - CurrentSetSize++; - return true; -} - -void PortsEngine::WantWrite(EventHandler* eh) -{ - port_associate(EngineHandle, PORT_SOURCE_FD, eh->GetFd(), POLLWRNORM, eh); -} - -bool PortsEngine::DelFd(EventHandler* eh, bool force) -{ - int fd = eh->GetFd(); - if ((fd < 0) || (fd > MAX_DESCRIPTORS)) - return false; - - port_dissociate(EngineHandle, PORT_SOURCE_FD, fd); - - CurrentSetSize--; - ref[fd] = NULL; - - ServerInstance->Log(DEBUG,"Remove file descriptor: %d", fd); - return true; -} - -int PortsEngine::GetMaxFds() -{ - return MAX_DESCRIPTORS; -} - -int PortsEngine::GetRemainingFds() -{ - return MAX_DESCRIPTORS - CurrentSetSize; -} - -int PortsEngine::DispatchEvents() -{ - struct timespec poll_time; - - poll_time.tv_sec = 1; - poll_time.tv_nsec = 0; - - unsigned int nget = 1; // used to denote a retrieve request. - int i = port_getn(EngineHandle, this->events, MAX_DESCRIPTORS, &nget, &poll_time); - - // first handle an error condition - if (i == -1) - return i; - - for (i = 0; i < nget; i++) - { - switch (this->events[i].portev_source) - { - case PORT_SOURCE_FD: - { - int fd = this->events[i].portev_object; - if (ref[fd]) - { - // reinsert port for next time around - port_associate(EngineHandle, PORT_SOURCE_FD, fd, POLLRDNORM, ref[fd]); - ref[fd]->HandleEvent((this->events[i].portev_events & POLLRDNORM) ? EVENT_READ : EVENT_WRITE); - } - } - default: - break; - } - } - - return i; -} - -std::string PortsEngine::GetName() -{ - return "ports"; -} - +/* +------------------------------------+ * | Inspire Internet Relay Chat Daemon | * +------------------------------------+ * * InspIRCd: (C) 2002-2007 InspIRCd Development Team * See: http://www.inspircd.org/wiki/index.php/Credits * * This program is free but copyrighted software; see * the file COPYING for details. * * --------------------------------------------------- */ #include "inspircd.h" #include "exitcodes.h" #include #include "socketengine_ports.h" PortsEngine::PortsEngine(InspIRCd* Instance) : SocketEngine(Instance) { EngineHandle = port_create(); if (EngineHandle == -1) { ServerInstance->Log(SPARSE,"ERROR: Could not initialize socket engine: %s", strerror(errno)); ServerInstance->Log(SPARSE,"ERROR: This is a fatal error, exiting now."); printf("ERROR: Could not initialize socket engine: %s\n", strerror(errno)); printf("ERROR: This is a fatal error, exiting now.\n"); InspIRCd::Exit(EXIT_STATUS_SOCKETENGINE); } CurrentSetSize = 0; } PortsEngine::~PortsEngine() { close(EngineHandle); } bool PortsEngine::AddFd(EventHandler* eh) { int fd = eh->GetFd(); if ((fd < 0) || (fd > MAX_DESCRIPTORS)) return false; if (GetRemainingFds() <= 1) return false; if (ref[fd]) return false; ref[fd] = eh; port_associate(EngineHandle, PORT_SOURCE_FD, fd, eh->Readable() ? POLLRDNORM : POLLWRNORM, eh); ServerInstance->Log(DEBUG,"New file descriptor: %d", fd); CurrentSetSize++; return true; } void PortsEngine::WantWrite(EventHandler* eh) { port_associate(EngineHandle, PORT_SOURCE_FD, eh->GetFd(), POLLWRNORM, eh); } bool PortsEngine::DelFd(EventHandler* eh, bool force) { int fd = eh->GetFd(); if ((fd < 0) || (fd > MAX_DESCRIPTORS)) return false; port_dissociate(EngineHandle, PORT_SOURCE_FD, fd); CurrentSetSize--; ref[fd] = NULL; ServerInstance->Log(DEBUG,"Remove file descriptor: %d", fd); return true; } int PortsEngine::GetMaxFds() { return MAX_DESCRIPTORS; } int PortsEngine::GetRemainingFds() { return MAX_DESCRIPTORS - CurrentSetSize; } int PortsEngine::DispatchEvents() { struct timespec poll_time; poll_time.tv_sec = 1; poll_time.tv_nsec = 0; unsigned int nget = 1; // used to denote a retrieve request. int i = port_getn(EngineHandle, this->events, MAX_DESCRIPTORS, &nget, &poll_time); // first handle an error condition if (i == -1) return i; for (i = 0; i < nget; i++) { switch (this->events[i].portev_source) { case PORT_SOURCE_FD: { int fd = this->events[i].portev_object; if (ref[fd]) { // reinsert port for next time around port_associate(EngineHandle, PORT_SOURCE_FD, fd, POLLRDNORM, ref[fd]); ref[fd]->HandleEvent((this->events[i].portev_events & POLLRDNORM) ? EVENT_READ : EVENT_WRITE); } } default: break; } } return i; } std::string PortsEngine::GetName() { return "ports"; } \ No newline at end of file -- cgit v1.3.1-10-gc9f91