X-Git-Url: https://git.saurik.com/redis.git/blobdiff_plain/c0875a77a14d417f76b4419127733929ace587ee..4b8c966140df6df57c47b9a81f7d9f20f8aef34e:/tests/integration/replication.tcl diff --git a/tests/integration/replication.tcl b/tests/integration/replication.tcl index 49408ac0..2c7d98de 100644 --- a/tests/integration/replication.tcl +++ b/tests/integration/replication.tcl @@ -65,3 +65,75 @@ start_server {tags {"repl"}} { } {0 0} } } + +proc start_write_load {host port seconds} { + exec tclsh8.5 tests/helpers/gen_write_load.tcl $host $port $seconds & +} + +proc stop_write_load {handle} { + catch {exec /bin/kill -9 $handle} +} + +start_server {tags {"repl"}} { + set master [srv 0 client] + set master_host [srv 0 host] + set master_port [srv 0 port] + set slaves {} + set load_handle0 [start_write_load $master_host $master_port 20] + set load_handle1 [start_write_load $master_host $master_port 20] + set load_handle2 [start_write_load $master_host $master_port 20] + set load_handle3 [start_write_load $master_host $master_port 20] + set load_handle4 [start_write_load $master_host $master_port 20] + after 2000 + start_server {} { + lappend slaves [srv 0 client] + start_server {} { + lappend slaves [srv 0 client] + start_server {} { + lappend slaves [srv 0 client] + test "Connect multiple slaves at the same time (issue #141)" { + [lindex $slaves 0] slaveof $master_host $master_port + [lindex $slaves 1] slaveof $master_host $master_port + [lindex $slaves 2] slaveof $master_host $master_port + + # Wait for all the three slaves to reach the "online" state + set retry 100 + while {$retry} { + set info [r -3 info] + if {[string match {*slave0:*,online*slave1:*,online*slave2:*,online*} $info]} { + break + } else { + incr retry -1 + after 100 + } + } + if {$retry == 0} { + error "assertion:Slaves not correctly synchronized" + } + stop_write_load $load_handle0 + stop_write_load $load_handle1 + stop_write_load $load_handle2 + stop_write_load $load_handle3 + stop_write_load $load_handle4 + set retry 10 + while {$retry && ([$master debug digest] ne [[lindex $slaves 0] debug digest])} { + after 1000 + incr retry -1 + } + set digest [$master debug digest] + set digest0 [[lindex $slaves 0] debug digest] + set digest1 [[lindex $slaves 1] debug digest] + set digest2 [[lindex $slaves 2] debug digest] + assert {$digest ne 0000000000000000000000000000000000000000} + assert {$digest eq $digest0} + assert {$digest eq $digest1} + assert {$digest eq $digest2} + #puts [$master dbsize] + #puts [[lindex $slaves 0] dbsize] + #puts [[lindex $slaves 1] dbsize] + #puts [[lindex $slaves 2] dbsize] + } + } + } + } +}