Skip to content

Commit

Permalink
update comment and indentation
Browse files Browse the repository at this point in the history
Signed-off-by: Binbin <[email protected]>
  • Loading branch information
enjoy-binbin committed Jul 16, 2024
1 parent d26fefd commit 5dd825d
Show file tree
Hide file tree
Showing 2 changed files with 43 additions and 43 deletions.
2 changes: 1 addition & 1 deletion src/cluster_legacy.c
Original file line number Diff line number Diff line change
Expand Up @@ -4096,7 +4096,7 @@ void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request) {
* multiple replicas may have the same rank, in case they have the same offset.
*
* If the replication offsets are the same, the one with the lexicographically
* smaller Node id * will have a better ranking to avoid simultaneous elections
* smaller node id will have a lower rank to avoid simultaneous elections
* of replicas.
*
* The replica rank is used to add a delay to start an election in order to
Expand Down
84 changes: 42 additions & 42 deletions tests/unit/cluster/failover.tcl
Original file line number Diff line number Diff line change
Expand Up @@ -73,61 +73,61 @@ test "Instance #0 gets converted into a slave" {

start_cluster 3 6 {tags {external:skip cluster}} {

test "Cluster is up" {
wait_for_cluster_state ok
}
test "Cluster is up" {
wait_for_cluster_state ok
}

test "Cluster is writable" {
cluster_write_test [srv 0 port]
}
test "Cluster is writable" {
cluster_write_test [srv 0 port]
}

set current_epoch [CI 1 cluster_current_epoch]
set current_epoch [CI 1 cluster_current_epoch]

set paused_pid [srv 0 pid]
test "Killing the first primary node" {
pause_process $paused_pid
}

test "Wait for failover" {
wait_for_condition 1000 50 {
[CI 1 cluster_current_epoch] > $current_epoch
} else {
fail "No failover detected"
set paused_pid [srv 0 pid]
test "Killing the first primary node" {
pause_process $paused_pid
}
}

test "Cluster should eventually be up again" {
for {set j 0} {$j < [llength $::servers]} {incr j} {
if {[process_is_paused [srv -$j pid]]} continue
test "Wait for failover" {
wait_for_condition 1000 50 {
[CI $j cluster_state] eq "ok"
[CI 1 cluster_current_epoch] > $current_epoch
} else {
fail "Cluster node $j cluster_state:[CI $j cluster_state]"
fail "No failover detected"
}
}
}

test "Restarting the previously killed primary node" {
resume_process $paused_pid
}
test "Cluster should eventually be up again" {
for {set j 0} {$j < [llength $::servers]} {incr j} {
if {[process_is_paused [srv -$j pid]]} continue
wait_for_condition 1000 50 {
[CI $j cluster_state] eq "ok"
} else {
fail "Cluster node $j cluster_state:[CI $j cluster_state]"
}
}
}

test "Instance #0 gets converted into a replica" {
wait_for_condition 1000 50 {
[s 0 role] eq {slave}
} else {
fail "Old primary was not converted into replica"
test "Restarting the previously killed primary node" {
resume_process $paused_pid
}
wait_for_cluster_propagation
}

test "Make sure the replicas always get the different ranks" {
if {[s -3 role] == "master"} {
verify_log_message -3 "*Start of election*rank #0*" 0
verify_log_message -6 "*Start of election*rank #1*" 0
} else {
verify_log_message -3 "*Start of election*rank #1*" 0
verify_log_message -6 "*Start of election*rank #0*" 0
test "Instance #0 gets converted into a replica" {
wait_for_condition 1000 50 {
[s 0 role] eq {slave}
} else {
fail "Old primary was not converted into replica"
}
wait_for_cluster_propagation
}

test "Make sure the replicas always get the different ranks" {
if {[s -3 role] == "master"} {
verify_log_message -3 "*Start of election*rank #0*" 0
verify_log_message -6 "*Start of election*rank #1*" 0
} else {
verify_log_message -3 "*Start of election*rank #1*" 0
verify_log_message -6 "*Start of election*rank #0*" 0
}
}
}

} ;# start_cluster

0 comments on commit 5dd825d

Please sign in to comment.