diff options
| author | antirez <antirez@gmail.com> | 2018-01-29 18:32:38 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
| commit | e76fb4ab2546a6febc361d3b9dc4e76711f47f6b (patch) | |
| tree | b72cb9d84ae33373def22410b0fd1119289ac066 /src/blocked.c | |
| parent | f3708af7f9ea6b3a097d2b33ee7c28624b753215 (diff) | |
| download | redis-e76fb4ab2546a6febc361d3b9dc4e76711f47f6b.tar.gz | |
CG: XPENDING should not create consumers and obey to count.
Diffstat (limited to 'src/blocked.c')
| -rw-r--r-- | src/blocked.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/blocked.c b/src/blocked.c index 8f472f2b8..2de798378 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -331,7 +331,8 @@ void handleClientsBlockedOnKeys(void) { } if (group) { consumer = streamLookupConsumer(group, - receiver->bpop.xread_consumer->ptr); + receiver->bpop.xread_consumer->ptr, + 1); } /* Note that after we unblock the client, 'gt' |