caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 00:28:26 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Test: cgroup propagation test also for NOACK variant.

Browse Source 
Related to #5433.
This commit is contained in:
antirez 2018-10-10 17:37:37 +02:00
parent cfad5e4587
commit fbfd61b471
1 changed files with 39 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
tests/unit/type/stream-cgroups.tcl
View File

@ -103,36 +103,46 @@ start_server {
set master_port [srv -1 port] set master_port [srv -1 port]
set slave [srv 0 client] set slave [srv 0 client]
test {Consumer group last ID propagation to slave} { foreach noack {0 1} {
$slave slaveof $master_host $master_port test "Consumer group last ID propagation to slave (NOACK=$noack)" {
wait_for_condition 50 100 { $slave slaveof $master_host $master_port
[s 0 master_link_status] eq {up} wait_for_condition 50 100 {
} else { [s 0 master_link_status] eq {up}
fail "Replication not started." } else {
fail "Replication not started."
}
$master del stream
$master xadd stream * a 1
$master xadd stream * a 2
$master xadd stream * a 3
$master xgroup create stream mygroup 0
# Consume the first two items on the master
for {set j 0} {$j < 2} {incr j} {
if {$noack} {
set item [$master xreadgroup group mygroup \
myconsumer COUNT 1 NOACK STREAMS stream >]
} else {
set item [$master xreadgroup group mygroup \
myconsumer COUNT 1 STREAMS stream >]
}
set id [lindex $item 0 1 0 0]
if {$noack == 0} {
assert {[$master xack stream mygroup $id] eq "1"}
}
}
# Turn slave into master
$slave slaveof no one
set item [$slave xreadgroup group mygroup myconsumer \
COUNT 1 STREAMS stream >]
# The consumed enty should be the third
set myentry [lindex $item 0 1 0 1]
assert {$myentry eq {a 3}}
} }
$master del stream
$master xadd stream * a 1
$master xadd stream * a 2
$master xadd stream * a 3
$master xgroup create stream mygroup 0
# Consume the first two items on the master
for {set j 0} {$j < 2} {incr j} {
set item [$master xreadgroup group mygroup myconsumer COUNT 1 STREAMS stream >]
set id [lindex $item 0 1 0 0]
assert {[$master xack stream mygroup $id] eq "1"}
}
# Turn slave into master
$slave slaveof no one
set master $slave
set item [$master xreadgroup group mygroup myconsumer COUNT 1 STREAMS stream >]
# The consumed enty should be the third
set myentry [lindex $item 0 1 0 1]
assert {$myentry eq {a 3}}
} }
} }
} }