df5db0627f
This includes comments used for module API documentation.
* Strategy for replacement: Regex search: `(//|/\*| \*|#).* ("|\()?(r|R)edis( |\.
|'|\n|,|-|\)|")(?!nor the names of its contributors)(?!Ltd.)(?!Labs)(?!Contributors.)`
* Don't edit copyright comments
* Replace "Redis version X.X" -> "Redis OSS version X.X" to distinguish
from newly licensed repository
* Replace "Redis Object" -> "Object"
* Exclude markdown for now
* Don't edit Lua scripting comments referring to redis.X API
* Replace "Redis Protocol" -> "RESP"
* Replace redis-benchmark, -cli, -server, -check-aof/rdb with "valkey-"
prefix
* Most other places, I use best judgement to either remove "Redis", or
replace with "the server" or "server"
Fixes #148
---------
Signed-off-by: Jacob Murphy <jkmurphy@google.com>
Signed-off-by: Viktor Söderqvist <viktor.soderqvist@est.tech>
83 lines
2.8 KiB
Tcl
83 lines
2.8 KiB
Tcl
# Issue 3899 regression test.
|
|
# We create a chain of three instances: master -> slave -> slave2
|
|
# and continuously break the link while traffic is generated by
|
|
# valkey-benchmark. At the end we check that the data is the same
|
|
# everywhere.
|
|
|
|
start_server {tags {"psync2 external:skip"}} {
|
|
start_server {} {
|
|
start_server {} {
|
|
# Config
|
|
set debug_msg 0 ; # Enable additional debug messages
|
|
|
|
set no_exit 0 ; # Do not exit at end of the test
|
|
|
|
set duration 20 ; # Total test seconds
|
|
|
|
for {set j 0} {$j < 3} {incr j} {
|
|
set R($j) [srv [expr 0-$j] client]
|
|
set R_host($j) [srv [expr 0-$j] host]
|
|
set R_port($j) [srv [expr 0-$j] port]
|
|
set R_unixsocket($j) [srv [expr 0-$j] unixsocket]
|
|
if {$debug_msg} {puts "Log file: [srv [expr 0-$j] stdout]"}
|
|
}
|
|
|
|
# Setup the replication and backlog parameters
|
|
test "PSYNC2 #3899 regression: setup" {
|
|
$R(1) slaveof $R_host(0) $R_port(0)
|
|
$R(2) slaveof $R_host(0) $R_port(0)
|
|
$R(0) set foo bar
|
|
wait_for_condition 50 1000 {
|
|
[status $R(1) master_link_status] == "up" &&
|
|
[status $R(2) master_link_status] == "up" &&
|
|
[$R(1) dbsize] == 1 &&
|
|
[$R(2) dbsize] == 1
|
|
} else {
|
|
fail "Replicas not replicating from master"
|
|
}
|
|
$R(0) config set repl-backlog-size 10mb
|
|
$R(1) config set repl-backlog-size 10mb
|
|
}
|
|
|
|
set cycle_start_time [clock milliseconds]
|
|
set bench_pid [exec src/valkey-benchmark -s $R_unixsocket(0) -n 10000000 -r 1000 incr __rand_int__ > /dev/null &]
|
|
while 1 {
|
|
set elapsed [expr {[clock milliseconds]-$cycle_start_time}]
|
|
if {$elapsed > $duration*1000} break
|
|
if {rand() < .05} {
|
|
test "PSYNC2 #3899 regression: kill first replica" {
|
|
$R(1) client kill type master
|
|
}
|
|
}
|
|
if {rand() < .05} {
|
|
test "PSYNC2 #3899 regression: kill chained replica" {
|
|
$R(2) client kill type master
|
|
}
|
|
}
|
|
after 100
|
|
}
|
|
exec kill -9 $bench_pid
|
|
|
|
if {$debug_msg} {
|
|
for {set j 0} {$j < 100} {incr j} {
|
|
if {
|
|
[$R(0) debug digest] == [$R(1) debug digest] &&
|
|
[$R(1) debug digest] == [$R(2) debug digest]
|
|
} break
|
|
puts [$R(0) debug digest]
|
|
puts [$R(1) debug digest]
|
|
puts [$R(2) debug digest]
|
|
after 1000
|
|
}
|
|
}
|
|
|
|
test "PSYNC2 #3899 regression: verify consistency" {
|
|
wait_for_condition 50 1000 {
|
|
([$R(0) debug digest] eq [$R(1) debug digest]) &&
|
|
([$R(1) debug digest] eq [$R(2) debug digest])
|
|
} else {
|
|
fail "The three instances have different data sets"
|
|
}
|
|
}
|
|
}}}
|