projects
/
srvx.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Remove "wants_reads" field from struct io_fd.
[srvx.git]
/
src
/
ioset.c
diff --git
a/src/ioset.c
b/src/ioset.c
index 72204135e8388589bfc7094ca2ec2f9bf47e8eb0..6013232653b3839f3909361c97787651e2c32dbf 100644
(file)
--- a/
src/ioset.c
+++ b/
src/ioset.c
@@
-142,9
+142,9
@@
ioset_add(int fd) {
res->fd = fd;
ioq_init(&res->send, 1024);
ioq_init(&res->recv, 1024);
res->fd = fd;
ioq_init(&res->send, 1024);
ioq_init(&res->recv, 1024);
- engine->add(res);
flags = fcntl(fd, F_GETFL);
fcntl(fd, F_SETFL, flags|O_NONBLOCK);
flags = fcntl(fd, F_GETFL);
fcntl(fd, F_SETFL, flags|O_NONBLOCK);
+ engine->add(res);
return res;
}
return res;
}
@@
-406,7
+406,7
@@
ioset_buffered_read(struct io_fd *fd) {
if (fd->recv.put == fd->recv.size)
fd->recv.put = 0;
fdnum = fd->fd;
if (fd->recv.put == fd->recv.size)
fd->recv.put = 0;
fdnum = fd->fd;
- while (fd->
wants_reads && (fd->line_len > 0)
) {
+ while (fd->
line_len > 0
) {
struct io_fd *old_active;
int died = 0;
struct io_fd *old_active;
int died = 0;