m_dccallow Add config option to control max entries on a list

[user/henk/code/inspircd.git] / src / socketengines / socketengine_ports.cpp

diff --git a/src/socketengines/socketengine_ports.cpp b/src/socketengines/socketengine_ports.cpp
index 9a86c47d0cd915b6f597a35a026c41e91ec22ad3..f7c547d4510d79367297db443d3868db868dc579 100644 (file)
--- a/src/socketengines/socketengine_ports.cpp
+++ b/src/socketengines/socketengine_ports.cpp
@@ -46,6 +46,7 @@ private:
        /** These are used by epoll() to hold socket events
         */
        port_event_t* events;
+       int EngineHandle;
 public:
        /** Create a new PortsEngine
         */
@@ -54,11 +55,10 @@ public:
         */
        virtual ~PortsEngine();
        virtual bool AddFd(EventHandler* eh, int event_mask);
-       void OnSetEvent(EventHandler* eh, int old_event, int new_event);
+       virtual void OnSetEvent(EventHandler* eh, int old_mask, int new_mask);
        virtual void DelFd(EventHandler* eh);
        virtual int DispatchEvents();
        virtual std::string GetName();
-       virtual void WantWrite(EventHandler* eh);
 };
 
 #endif
@@ -77,7 +77,7 @@ PortsEngine::PortsEngine()
        {
                ServerInstance->Logs->Log("SOCKET", DEFAULT, "ERROR: Can't determine maximum number of open sockets!");
                std::cout << "ERROR: Can't determine maximum number of open sockets!" << std::endl;
-               ServerInstance->Exit(EXIT_STATUS_SOCKETENGINE);
+               ServerInstance->QuickExit(EXIT_STATUS_SOCKETENGINE);
        }
        EngineHandle = port_create();
 
@@ -87,7 +87,7 @@ PortsEngine::PortsEngine()
                ServerInstance->Logs->Log("SOCKET",SPARSE,"ERROR: This is a fatal error, exiting now.");
                std::cout << "ERROR: Could not initialize socket engine: " << strerror(errno) << std::endl;
                std::cout << "ERROR: This is a fatal error, exiting now." << std::endl;
-               ServerInstance->Exit(EXIT_STATUS_SOCKETENGINE);
+               ServerInstance->QuickExit(EXIT_STATUS_SOCKETENGINE);
        }
        CurrentSetSize = 0;
 
@@ -131,7 +131,7 @@ bool PortsEngine::AddFd(EventHandler* eh, int event_mask)
        return true;
 }
 
-void PortsEngine::WantWrite(EventHandler* eh, int old_mask, int new_mask)
+void PortsEngine::OnSetEvent(EventHandler* eh, int old_mask, int new_mask)
 {
        if (mask_to_events(new_mask) != mask_to_events(old_mask))
                port_associate(EngineHandle, PORT_SOURCE_FD, eh->GetFd(), mask_to_events(new_mask), eh);
@@ -149,7 +149,6 @@ void PortsEngine::DelFd(EventHandler* eh)
        ref[fd] = NULL;
 
        ServerInstance->Logs->Log("SOCKET",DEBUG,"Remove file descriptor: %d", fd);
-       return true;
 }
 
 int PortsEngine::DispatchEvents()
@@ -160,15 +159,16 @@ int PortsEngine::DispatchEvents()
        poll_time.tv_nsec = 0;
 
        unsigned int nget = 1; // used to denote a retrieve request.
-       int i = port_getn(EngineHandle, this->events, GetMaxFds() - 1, &nget, &poll_time);
+       int ret = port_getn(EngineHandle, this->events, GetMaxFds() - 1, &nget, &poll_time);
        ServerInstance->UpdateTime();
 
        // first handle an error condition
-       if (i == -1)
-               return i;
+       if (ret == -1)
+               return -1;
 
        TotalEvents += nget;
 
+       unsigned int i;
        for (i = 0; i < nget; i++)
        {
                switch (this->events[i].portev_source)
@@ -185,7 +185,7 @@ int PortsEngine::DispatchEvents()
                                        if (events[i].portev_events & POLLRDNORM)
                                                mask &= ~FD_READ_WILL_BLOCK;
                                        // reinsert port for next time around, pretending to be one-shot for writes
-                                       SetEventMask(ev, mask);
+                                       SetEventMask(eh, mask);
                                        port_associate(EngineHandle, PORT_SOURCE_FD, fd, mask_to_events(mask), eh);
                                        if (events[i].portev_events & POLLRDNORM)
                                        {
@@ -206,7 +206,7 @@ int PortsEngine::DispatchEvents()
                }
        }
 
-       return i;
+       return (int)i;
 }
 
 std::string PortsEngine::GetName()