diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2020-05-03 16:49:45 +0300 |
|---|---|---|
| committer | Guy Benoish <guy.benoish@redislabs.com> | 2020-05-04 11:40:42 +0300 |
| commit | bce3d08c66a1bf22ea852295a57b92a8024d4a1b (patch) | |
| tree | 1933c0486e47afa4724bc1cfcf4e16aeaa12a735 /src/blocked.c | |
| parent | 365316aa59545d90de4e105cec57f22aa5b52ff9 (diff) | |
| download | redis-bce3d08c66a1bf22ea852295a57b92a8024d4a1b.tar.gz | |
XPENDING should not update consumer's seen-time
Same goes for XGROUP DELCONSUMER (But in this case, it doesn't
have any visible effect)
Diffstat (limited to 'src/blocked.c')
| -rw-r--r-- | src/blocked.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/blocked.c b/src/blocked.c index 045369e93..92f1cee65 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -371,9 +371,10 @@ void serveClientsBlockedOnStreamKey(robj *o, readyList *rl) { int noack = 0; if (group) { - consumer = streamLookupConsumer(group, - receiver->bpop.xread_consumer->ptr, - 1); + consumer = + streamLookupConsumer(group, + receiver->bpop.xread_consumer->ptr, + SLC_NONE); noack = receiver->bpop.xread_group_noack; } |