]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/threadengines/threadengine_win32.cpp
Fix modules/extra symlinks when calculating dependencies
[user/henk/code/inspircd.git] / src / threadengines / threadengine_win32.cpp
index 5c62b5081b89c5ad8d9fdc4cd3baa461e15b2c68..e880d597f71b367f16cf8ed4548923c8bdf5363a 100644 (file)
@@ -14,7 +14,7 @@
 #include "inspircd.h"
 #include "threadengines/threadengine_win32.h"
 
-ThreadEngine::ThreadEngine(InspIRCd* Instance)
+ThreadEngine::ThreadEngine()
 {
 }
 
@@ -55,24 +55,19 @@ 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();
        }
 };
 
-SocketThread::SocketThread(InspIRCd* SI)
+SocketThread::SocketThread()
 {
        int listenFD = socket(AF_INET, SOCK_STREAM, 0);
        if (listenFD == -1)
@@ -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);