diff options
author | antirez <antirez@gmail.com> | 2018-07-12 13:35:17 +0200 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2018-07-12 13:35:17 +0200 |
commit | 8d6b7861a702b9f8fb2eceb76750c393a79e4c40 (patch) | |
tree | 4bca7b0fe2fb5232b4ee6905c2204da8c3701fdc /tests | |
parent | b6260a027026d1a5a6fa4fa0d8527de86066de8e (diff) | |
download | redis-8d6b7861a702b9f8fb2eceb76750c393a79e4c40.tar.gz |
Add regression test for #5111.
Diffstat (limited to 'tests')
-rw-r--r-- | tests/unit/type/stream-cgroups.tcl | 15 |
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} + } } |