diff options
author | antirez <antirez@gmail.com> | 2018-03-19 14:16:13 +0100 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2018-03-19 18:02:19 +0100 |
commit | 0b58ad301ef2ef4ecad8e962020f9b676c64e440 (patch) | |
tree | 31b42eaad28c0738b8f688002a06ce32276e7716 /src/blocked.c | |
parent | 3c2a952912c8d1ffb732008cb9ee49b45a567c21 (diff) | |
download | redis-0b58ad301ef2ef4ecad8e962020f9b676c64e440.tar.gz |
CG: Replication WIP 1: XREADGROUP and XCLAIM propagated as XCLAIM.
Diffstat (limited to 'src/blocked.c')
-rw-r--r-- | src/blocked.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/blocked.c b/src/blocked.c index 2de798378..23142d1d1 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -348,9 +348,14 @@ void handleClientsBlockedOnKeys(void) { addReplyMultiBulkLen(receiver,1); addReplyMultiBulkLen(receiver,2); addReplyBulk(receiver,rl->key); + + streamPropInfo pi = { + rl->key, + receiver->bpop.xread_group + }; streamReplyWithRange(receiver,s,&start,NULL, receiver->bpop.xread_count, - 0, group, consumer, 0); + 0, group, consumer, 0, &pi); } } } |