summaryrefslogtreecommitdiff
path: root/src/t_stream.c
diff options
context:
space:
mode:
authorantirez <antirez@gmail.com>2020-04-23 16:13:45 +0200
committerantirez <antirez@gmail.com>2020-04-23 16:13:45 +0200
commit12cd67b7cac9cfbcef4e339fd51027b1afbff86b (patch)
tree97963bd5c72e36e413f10e1adcb69c48e23dddc4 /src/t_stream.c
parent2a3d933cc6232c9bdfb7ccf63b0c5ffe776c10ef (diff)
downloadredis-12cd67b7cac9cfbcef4e339fd51027b1afbff86b.tar.gz
Minor aesthetic changes to #7135.
Diffstat (limited to 'src/t_stream.c')
-rw-r--r--src/t_stream.c12
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);