diff options
author | antirez <antirez@gmail.com> | 2018-05-15 17:33:21 +0200 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2018-05-15 17:33:29 +0200 |
commit | 8327ccef0e2775b243a5d22dfcf1e45c08ddf47e (patch) | |
tree | ea12b600667b0c056aeeb814e58b9f073d5bb2d7 /tests/integration | |
parent | 25f017e563c0e1ef9837604a96e4655b021bad32 (diff) | |
download | redis-8327ccef0e2775b243a5d22dfcf1e45c08ddf47e.tar.gz |
Test: replication test blocking lists/zsets ops.
Diffstat (limited to 'tests/integration')
-rw-r--r-- | tests/integration/block-repl.tcl | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/tests/integration/block-repl.tcl b/tests/integration/block-repl.tcl new file mode 100644 index 000000000..21015bbad --- /dev/null +++ b/tests/integration/block-repl.tcl @@ -0,0 +1,58 @@ +# Test replication of blocking lists and zset operations. +# Unlike stream operations such operations are "pop" style, so they consume +# the list or sorted set, and must be replicated correctly. + +proc start_bg_block_op {host port db ops} { + set tclsh [info nameofexecutable] + exec $tclsh tests/helpers/bg_block_op.tcl $host $port $db $ops & +} + +proc stop_bg_block_op {handle} { + catch {exec /bin/kill -9 $handle} +} + +start_server {tags {"repl"}} { + start_server {} { + set master [srv -1 client] + set master_host [srv -1 host] + set master_port [srv -1 port] + set slave [srv 0 client] + + set load_handle0 [start_bg_block_op $master_host $master_port 9 100000] + set load_handle1 [start_bg_block_op $master_host $master_port 11 100000] + set load_handle2 [start_bg_block_op $master_host $master_port 12 100000] + + test {First server should have role slave after SLAVEOF} { + $slave slaveof $master_host $master_port + after 1000 + s 0 role + } {slave} + + test {Test replication with parallel clients writing in differnet DBs} { + after 25000 + stop_bg_block_op $load_handle0 + stop_bg_block_op $load_handle1 + stop_bg_block_op $load_handle2 + set retry 10 + while {$retry && ([$master debug digest] ne [$slave debug digest])}\ + { + after 1000 + incr retry -1 + } + + if {[$master debug digest] ne [$slave debug digest]} { + set csv1 [csvdump r] + set csv2 [csvdump {r -1}] + set fd [open /tmp/repldump1.txt w] + puts -nonewline $fd $csv1 + close $fd + set fd [open /tmp/repldump2.txt w] + puts -nonewline $fd $csv2 + close $fd + puts "Master - Slave inconsistency" + puts "Run diff -u against /tmp/repldump*.txt for more info" + } + assert_equal [r debug digest] [r -1 debug digest] + } + } +} |