]> git.netwichtig.de Git - user/henk/code/inspircd.git/blobdiff - src/threadengines/threadengine_pthread.cpp
Call DelFd() and SetFd(-1) from SocketEngine::Close(EventHandler*)
[user/henk/code/inspircd.git] / src / threadengines / threadengine_pthread.cpp
index e16e401f3387927773777c952e18617ce69f2aa1..8527907c491ca249dc40693e7e371ee5ac912e10 100644 (file)
@@ -75,13 +75,12 @@ class ThreadSignalSocket : public EventHandler
        ThreadSignalSocket(SocketThread* p, int newfd) : parent(p)
        {
                SetFd(newfd);
-               ServerInstance->SE->AddFd(this, FD_WANT_FAST_READ | FD_WANT_NO_WRITE);
+               SocketEngine::AddFd(this, FD_WANT_FAST_READ | FD_WANT_NO_WRITE);
        }
 
        ~ThreadSignalSocket()
        {
-               ServerInstance->SE->DelFd(this);
-               ServerInstance->SE->Close(GetFd());
+               SocketEngine::Close(this);
        }
 
        void Notify()
@@ -123,15 +122,14 @@ class ThreadSignalSocket : public EventHandler
                parent(p), send_fd(sendfd)
        {
                SetFd(recvfd);
-               ServerInstance->SE->NonBlocking(fd);
-               ServerInstance->SE->AddFd(this, FD_WANT_FAST_READ | FD_WANT_NO_WRITE);
+               SocketEngine::NonBlocking(fd);
+               SocketEngine::AddFd(this, FD_WANT_FAST_READ | FD_WANT_NO_WRITE);
        }
 
        ~ThreadSignalSocket()
        {
                close(send_fd);
-               ServerInstance->SE->DelFd(this);
-               ServerInstance->SE->Close(GetFd());
+               SocketEngine::Close(this);
        }
 
        void Notify()