From 13398a08d96bc8f4ad3386391cb724f0b2b4207b Mon Sep 17 00:00:00 2001 From: Evgeniy Polyakov Date: Wed, 10 Oct 2012 12:08:33 +0400 Subject: [PATCH] Fixed pool growing policy --- library/pool.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/library/pool.c b/library/pool.c index 1a99fa6..80ab4bb 100644 --- a/library/pool.c +++ b/library/pool.c @@ -180,7 +180,7 @@ static void dnet_schedule_io(struct dnet_node *n, struct dnet_io_req *r) if (nonblocking) pool = io->recv_pool_nb; - if (list_empty(&pool->list) && (cmd->cmd == DNET_CMD_EXEC) && (cmd->size >= sizeof(struct sph))) { + if (!list_empty(&pool->list) && (cmd->cmd == DNET_CMD_EXEC) && (cmd->size >= sizeof(struct sph)) && !(cmd->trans & DNET_TRANS_REPLY)) { struct sph *sph = (struct sph *)r->data; if (sph->flags & DNET_SPH_FLAGS_SRC_BLOCK) { dnet_work_pool_grow(n, pool, pool->num/4+1, dnet_io_process); -- 2.11.4.GIT