From 95a2f0b92f054d947b1f7de343c970ff7d7a1ba7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BA=91=E9=A3=8E?= Date: Mon, 13 Aug 2012 22:23:05 +0800 Subject: [PATCH] connection bugfix --- connection/connection.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/connection/connection.c b/connection/connection.c index abaa7afb..3be7dd1e 100644 --- a/connection/connection.c +++ b/connection/connection.c @@ -367,10 +367,11 @@ connection_poll(struct connection_pool * pool, int timeout, int *phandle, size_t *phandle = 0; return NULL; } - if (c->read_request == 0) { + if (c->read_complete) { assert(c->in_epoll); epoll_ctl(pool->epoll_fd, EPOLL_CTL_DEL, c->fd , NULL); c->in_epoll = 0; + continue; } int result = _read_request(pool, c, id); switch (result) {