]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/threadengines/threadengine_win32.cpp
Run configure -update on all svn/git changes
[user/henk/code/inspircd.git] / src / threadengines / threadengine_win32.cpp
index 5c62b5081b89c5ad8d9fdc4cd3baa461e15b2c68..fab75699e4730707751bc8388d21d662d2a98638 100644 (file)
@@ -55,20 +55,15 @@ class ThreadSignalSocket : public BufferedSocket
 {
        SocketThread* parent;
  public:
-       ThreadSignalSocket(SocketThread* t, InspIRCd* SI, int newfd, const char* ip)
-               : BufferedSocket(SI, newfd, ip), parent(t)
+       ThreadSignalSocket(SocketThread* t, int newfd)
+               : BufferedSocket(newfd), parent(t)
        {
        }
 
-       virtual bool OnDataReady()
+       void OnDataReady()
        {
-               char data = 0;
-               if (ServerInstance->SE->Recv(this, &data, 1, 0) > 0)
-               {
-                       parent->OnNotify();
-                       return true;
-               }
-               return false;
+               recvq.clear();
+               parent->OnNotify();
        }
 };
 
@@ -92,7 +87,7 @@ SocketThread::SocketThread(InspIRCd* SI)
        int nfd = accept(listenFD);
        if (nfd < 0)
                throw CoreException("Could not create ITC pipe");
-       new ThreadSignalSocket(parent, ServerInstance, nfd, "127.0.0.1");
+       new ThreadSignalSocket(parent, nfd);
        closesocket(listenFD);
 
        SI->SE->Blocking(connFD);