diff options
| author | antirez <antirez@gmail.com> | 2017-11-17 13:24:20 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2017-12-01 10:24:25 +0100 |
| commit | ee3490ec481c7f1ef89fe685b03c2b5f171d335b (patch) | |
| tree | 9b5121006eb613090b3f7e2b4f8e227679d5f1ee /src/blocked.c | |
| parent | 3c5d773f82eede4497cb3695d2cd32eec3e10382 (diff) | |
| download | redis-ee3490ec481c7f1ef89fe685b03c2b5f171d335b.tar.gz | |
Streams: state machine for reverse iteration WIP 1.
Diffstat (limited to 'src/blocked.c')
| -rw-r--r-- | src/blocked.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/blocked.c b/src/blocked.c index 734e6ffd6..f438c3353 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -326,7 +326,7 @@ void handleClientsBlockedOnKeys(void) { addReplyMultiBulkLen(receiver,2); addReplyBulk(receiver,rl->key); streamReplyWithRange(receiver,s,&start,NULL, - receiver->bpop.xread_count); + receiver->bpop.xread_count,0); } } } |