37 #include <sys/socket.h>
50 if (socketpair(PF_UNIX, SOCK_STREAM, 0, pipefd) < 0)
67 ssize_t ret = write(pipefd[1], &c,
sizeof(c));
71 perror(
"the socket cannot be woken up");
86 total -= read(pipefd[0], &c,
sizeof(c));
91 int pipefd[2] = {-1, -1};
127 ts.tv_sec = timeout / 1000;
128 ts.tv_usec = (timeout % 1000) * 1000;
void setReadEvent(SocketFileDescriptor fd)
void setReadWriteExceptionEvent(SocketFileDescriptor fd)
void setWriteEvent(SocketFileDescriptor fd)
bool isWriteEvent(SocketFileDescriptor fd) const
void setTimeout(int timeout)
void setReadWriteEvent(SocketFileDescriptor fd)
bool isExceptionEvent(SocketFileDescriptor fd) const
void setExceptionEvent(SocketFileDescriptor fd)
SocketFileDescriptor fdMax
bool isReadEvent(SocketFileDescriptor fd) const