connection bugfix

This commit is contained in:
云风
2012-08-13 22:23:05 +08:00
parent 3ab068905e
commit 95a2f0b92f

View File

@@ -367,10 +367,11 @@ connection_poll(struct connection_pool * pool, int timeout, int *phandle, size_t
*phandle = 0; *phandle = 0;
return NULL; return NULL;
} }
if (c->read_request == 0) { if (c->read_complete) {
assert(c->in_epoll); assert(c->in_epoll);
epoll_ctl(pool->epoll_fd, EPOLL_CTL_DEL, c->fd , NULL); epoll_ctl(pool->epoll_fd, EPOLL_CTL_DEL, c->fd , NULL);
c->in_epoll = 0; c->in_epoll = 0;
continue;
} }
int result = _read_request(pool, c, id); int result = _read_request(pool, c, id);
switch (result) { switch (result) {