diff --git a/include/empio.h b/include/empio.h index 53a6ee1b..36050477 100644 --- a/include/empio.h +++ b/include/empio.h @@ -37,7 +37,6 @@ #define IO_READ 0x1 #define IO_WRITE 0x2 -#define IO_NEWSOCK 0x4 #define IO_NBLOCK 0x8 #define IO_EOF 0x10 #define IO_ERROR 0x40 diff --git a/src/lib/empthread/io.c b/src/lib/empthread/io.c index 32aa9a02..13d75ad7 100644 --- a/src/lib/empthread/io.c +++ b/src/lib/empthread/io.c @@ -75,7 +75,7 @@ io_open(int fd, int flags, int bufsize, struct timeval timeout) { struct iop *iop; - flags = flags & (IO_READ | IO_WRITE | IO_NBLOCK | IO_NEWSOCK); + flags = flags & (IO_READ | IO_WRITE | IO_NBLOCK); if ((flags & (IO_READ | IO_WRITE)) == 0) return NULL; iop = malloc(sizeof(struct iop)); @@ -87,9 +87,9 @@ io_open(int fd, int flags, int bufsize, struct timeval timeout) iop->flags = 0; iop->input_timeout = timeout; iop->bufsize = bufsize; - if ((flags & IO_READ) && (flags & IO_NEWSOCK) == 0) + if (flags & IO_READ) iop->input = ioq_create(bufsize); - if ((flags & IO_WRITE) && (flags & IO_NEWSOCK) == 0) + if (flags & IO_WRITE) iop->output = ioq_create(bufsize); if (flags & IO_NBLOCK) io_noblocking(iop, 1); /* FIXME check success */