sigaddset(&set, SIGPIPE);
pthread_sigmask(SIG_BLOCK, &set, NULL);
- Thread* pt = reinterpret_cast<Thread*>(parameter);
+ Thread* pt = static_cast<Thread*>(parameter);
pt->Run();
return parameter;
}
void Notify()
{
char dummy = '*';
- send(send_fd, &dummy, 1, 0);
+ write(send_fd, &dummy, 1);
}
virtual bool OnDataReady()
{
char data;
- if (ServerInstance->SE->Recv(this, &data, 1, 0) <= 0)
+ if (read(this->fd, &data, 1) <= 0)
return false;
parent->OnNotify();
return true;
SocketThread::~SocketThread()
{
- delete signal.sock;
}