diff options
author | antirez <antirez@gmail.com> | 2020-04-23 16:13:45 +0200 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2020-04-23 16:13:45 +0200 |
commit | 12cd67b7cac9cfbcef4e339fd51027b1afbff86b (patch) | |
tree | 97963bd5c72e36e413f10e1adcb69c48e23dddc4 /src/t_stream.c | |
parent | 2a3d933cc6232c9bdfb7ccf63b0c5ffe776c10ef (diff) | |
download | redis-12cd67b7cac9cfbcef4e339fd51027b1afbff86b.tar.gz |
Minor aesthetic changes to #7135.
Diffstat (limited to 'src/t_stream.c')
-rw-r--r-- | src/t_stream.c | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 8abbee02f..596d8ad0d 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -955,11 +955,10 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end /* Update the group last_id if needed. */ if (group && streamCompareID(&id,&group->last_id) > 0) { group->last_id = id; - /* Group last id should be propagated only if NOACK was - * specified, otherwise the last id would be included - * in XCLAIM. */ - if (noack) - propagate_last_id = 1; + /* Group last ID should be propagated only if NOACK was + * specified, otherwise the last id will be included + * in the propagation of XCLAIM itself. */ + if (noack) propagate_last_id = 1; } /* Emit a two elements array for each item. The first is @@ -1030,9 +1029,8 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end if (count && count == arraylen) break; } - if (spi && propagate_last_id) { + if (spi && propagate_last_id) streamPropagateGroupID(c,spi->keyname,group,spi->groupname); - } streamIteratorStop(&si); if (arraylen_ptr) setDeferredArrayLen(c,arraylen_ptr,arraylen); |