Compare commits

...
2 changed files with 8 additions and 0 deletions

No files matched your search

+1
View File
@@ -732,6 +732,7 @@ void unblockClientWaitingData(client *c) {
c->bpop.xread_group = NULL;
c->bpop.xread_consumer = NULL;
}
c->bpop.timeout = 0;
}
static int getBlockedTypeByType(int type) {
+7
View File
@@ -1069,6 +1069,13 @@ start_server {
r ping
} {PONG}
test "Regression for bug 659 - chaining BRPOP with async blocking cmds" {
r flushall
r brpop foo 1
r keys *
r ping
} {PONG}
test "client unblock tests" {
r del l
set rd [redis_deferring_client]