diff options
author | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2010-12-06 16:39:39 +0100 |
---|---|---|
committer | Pieter Noordhuis <pcnoordhuis@gmail.com> | 2010-12-06 16:39:39 +0100 |
commit | a4ce7581553b1f4e29a7ed2141add788e56142c5 (patch) | |
tree | 593c36f74e1cf7bc95a3007ab31c037d9f12b3ce /src/t_list.c | |
parent | ecf940141501e47dcc8dfecbc84a4e3f6ee7b0d3 (diff) | |
download | redis-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.c | 7 |
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. |