fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-03 08:11:03 +00:00
Code Issues Projects Releases Wiki Activity

Cluster test: better failover detection in unit 03.

Browse Source
This commit is contained in:
antirez 2014-06-10 15:33:53 +02:00
parent 92dcae8fe4
commit 4fd35a28d3
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
tests/cluster/tests/03-failover-loop.tcl
View File

@ -22,8 +22,19 @@ while {[incr iterations -1]} {
set key [randstring 20 20 alpha] set key [randstring 20 20 alpha]
set val [randstring 20 20 alpha] set val [randstring 20 20 alpha]
set role [RI $tokill role] set role [RI $tokill role]
if {$role eq {master}} {
set current_epoch [CI $other cluster_current_epoch] set slave {}
set myid [dict get [get_myself $tokill] id]
foreach_redis_id id {
if {$id == $tokill} continue
if {[dict get [get_myself $id] slaveof] eq $myid} {
set slave $id
}
}
if {$slave eq {}} {
fail "Unable to retrieve slave's ID for master #$tokill"
}
}
puts "--- Iteration $iterations ---" puts "--- Iteration $iterations ---"
@ -35,6 +46,7 @@ while {[incr iterations -1]} {
fail "Slave of node #$tokill is not ok" fail "Slave of node #$tokill is not ok"
} }
} }
set slave_config_epoch [CI $slave cluster_my_epoch]
} }
test "Killing node #$tokill" { test "Killing node #$tokill" {
@ -42,11 +54,11 @@ while {[incr iterations -1]} {
} }
if {$role eq {master}} { if {$role eq {master}} {
test "Wait failover" { test "Wait failover by #$slave with old epoch $slave_config_epoch" {
wait_for_condition 1000 50 { wait_for_condition 1000 50 {
[CI $other cluster_current_epoch] > $current_epoch [CI $slave cluster_my_epoch] > $slave_config_epoch
} else { } else {
fail "No failover detected" fail "No failover detected, epoch is still [CI $slave cluster_my_epoch]"
} }
} }
} }