Merge pull request #16 from Adam-/insp20

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

diff --git a/src/socketengines/socketengine_select.cpp b/src/socketengines/socketengine_select.cpp
index 6965ee771f3b40114129d0d2f04dc35d54b7f0a1..acc8f8f09dc7f158c69eacffbf685dbac3f91dc1 100644 (file)
--- a/src/socketengines/socketengine_select.cpp
+++ b/src/socketengines/socketengine_select.cpp
@@ -2,7 +2,7 @@
  *       | Inspire Internet Relay Chat Daemon |
  *       +------------------------------------+
  *
- *  InspIRCd: (C) 2002-2009 InspIRCd Development Team
+ *  InspIRCd: (C) 2002-2010 InspIRCd Development Team
  * See: http://wiki.inspircd.org/Credits
  *
  * This program is free but copyrighted software; see
@@ -12,7 +12,6 @@
  */
 
 #include "inspircd_config.h"
-#ifndef CONFIG_USE_IOCP
 
 #include "inspircd.h"
 #include "socketengine.h"
@@ -33,7 +32,7 @@ public:
         */
        virtual ~SelectEngine();
        virtual bool AddFd(EventHandler* eh, int event_mask);
-       virtual bool DelFd(EventHandler* eh, bool force = false);
+       virtual void DelFd(EventHandler* eh);
        void OnSetEvent(EventHandler* eh, int, int);
        virtual int DispatchEvents();
        virtual std::string GetName();
@@ -70,18 +69,17 @@ bool SelectEngine::AddFd(EventHandler* eh, int event_mask)
        return true;
 }
 
-bool SelectEngine::DelFd(EventHandler* eh, bool force)
+void SelectEngine::DelFd(EventHandler* eh)
 {
        int fd = eh->GetFd();
 
        if ((fd < 0) || (fd > GetMaxFds() - 1))
-               return false;
+               return;
 
        CurrentSetSize--;
        ref[fd] = NULL;
 
        ServerInstance->Logs->Log("SOCKET",DEBUG,"Remove file descriptor: %d", fd);
-       return true;
 }
 
 void SelectEngine::OnSetEvent(EventHandler* eh, int old_mask, int new_mask)
@@ -101,7 +99,7 @@ int SelectEngine::DispatchEvents()
        FD_ZERO(&rfdset);
        FD_ZERO(&errfdset);
 
-       /* Populate the select FD sets (this is why select sucks compared to epoll, kqueue, IOCP) */
+       /* Populate the select FD sets (this is why select sucks compared to epoll, kqueue) */
        for (unsigned int i = 0; i < FD_SETSIZE; i++)
        {
                EventHandler* eh = ref[i];
@@ -120,6 +118,7 @@ int SelectEngine::DispatchEvents()
        tval.tv_usec = 0;
 
        sresult = select(FD_SETSIZE, &rfdset, &wfdset, &errfdset, &tval);
+       ServerInstance->UpdateTime();
 
        /* Nothing to process this time around */
        if (sresult < 1)
@@ -151,6 +150,8 @@ int SelectEngine::DispatchEvents()
                                        ReadEvents++;
                                        SetEventMask(ev, ev->GetEventMask() & ~FD_READ_WILL_BLOCK);
                                        ev->HandleEvent(EVENT_READ);
+                                       if (ev != ref[i])
+                                               continue;
                                }
                                if (FD_ISSET (i, &wfdset))
                                {
@@ -174,4 +175,3 @@ SocketEngine* CreateSocketEngine()
 {
        return new SelectEngine;
 }
-#endif