summaryrefslogtreecommitdiff
path: root/src/t_list.c
diff options
context:
space:
mode:
authorPieter Noordhuis <pcnoordhuis@gmail.com>2010-12-06 16:39:39 +0100
committerPieter Noordhuis <pcnoordhuis@gmail.com>2010-12-06 16:39:39 +0100
commita4ce7581553b1f4e29a7ed2141add788e56142c5 (patch)
tree593c36f74e1cf7bc95a3007ab31c037d9f12b3ce /src/t_list.c
parentecf940141501e47dcc8dfecbc84a4e3f6ee7b0d3 (diff)
downloadredis-a4ce7581553b1f4e29a7ed2141add788e56142c5.tar.gz
Don't execute commands for clients when they are unblocked
Diffstat (limited to 'src/t_list.c')
-rw-r--r--src/t_list.c7
1 files changed, 1 insertions, 6 deletions
diff --git a/src/t_list.c b/src/t_list.c
index 867e258a1..7dc3f1393 100644
--- a/src/t_list.c
+++ b/src/t_list.c
@@ -759,12 +759,7 @@ void unblockClientWaitingData(redisClient *c) {
c->bpop.target = NULL;
c->flags &= (~REDIS_BLOCKED);
server.bpop_blocked_clients--;
- /* We want to process data if there is some command waiting
- * in the input buffer. Note that this is safe even if
- * unblockClientWaitingData() gets called from freeClient() because
- * freeClient() will be smart enough to call this function
- * *after* c->querybuf was set to NULL. */
- if (c->querybuf && sdslen(c->querybuf) > 0) processInputBuffer(c);
+ listAddNodeTail(server.unblocked_clients,c);
}
/* This should be called from any function PUSHing into lists.