summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorantirez <antirez@gmail.com>2018-07-12 13:35:17 +0200
committerantirez <antirez@gmail.com>2018-07-12 13:35:17 +0200
commit8d6b7861a702b9f8fb2eceb76750c393a79e4c40 (patch)
tree4bca7b0fe2fb5232b4ee6905c2204da8c3701fdc /tests
parentb6260a027026d1a5a6fa4fa0d8527de86066de8e (diff)
downloadredis-8d6b7861a702b9f8fb2eceb76750c393a79e4c40.tar.gz
Add regression test for #5111.
Diffstat (limited to 'tests')
-rw-r--r--tests/unit/type/stream-cgroups.tcl15
1 files changed, 15 insertions, 0 deletions
diff --git a/tests/unit/type/stream-cgroups.tcl b/tests/unit/type/stream-cgroups.tcl
index 3f72b3dbb..7c991a5da 100644
--- a/tests/unit/type/stream-cgroups.tcl
+++ b/tests/unit/type/stream-cgroups.tcl
@@ -81,4 +81,19 @@ start_server {
# just ID2.
assert {[r XACK mystream mygroup $id1 $id2] eq 1}
}
+
+ test {PEL NACK reassignment after XGROUP SETID event} {
+ r del events
+ r xadd events * f1 v1
+ r xadd events * f1 v1
+ r xadd events * f1 v1
+ r xadd events * f1 v1
+ r xgroup create events g1 $
+ r xadd events * f1 v1
+ set c [llength [lindex [r xreadgroup group g1 c1 streams events >] 0 1]]
+ assert {$c == 1}
+ r xgroup setid events g1 -
+ set c [llength [lindex [r xreadgroup group g1 c2 streams events >] 0 1]]
+ assert {$c == 5}
+ }
}