Alexis Campailla
3895a7d148
Conflicts: src/anet.c src/aof.c src/bitops.c src/config.c src/db.c src/debug.c src/dict.c src/migrate.c src/object.c src/redis.c src/redis.h src/sentinel.c src/t_list.c src/t_set.c src/t_zset.c src/util.c tests/instances.tcl
92 lines
3.1 KiB
Tcl
92 lines
3.1 KiB
Tcl
start_server {tags {"repl"}} {
|
|
start_server {} {
|
|
test {First server should have role slave after SLAVEOF} {
|
|
r -1 slaveof [srv 0 host] [srv 0 port]
|
|
after 1000
|
|
s -1 role
|
|
} {slave}
|
|
|
|
test {If min-slaves-to-write is honored, write is accepted} {
|
|
r config set min-slaves-to-write 1
|
|
r config set min-slaves-max-lag 10
|
|
r set foo 12345
|
|
wait_for_condition 50 100 {
|
|
[r -1 get foo] eq {12345}
|
|
} else {
|
|
fail "Write did not reached slave"
|
|
}
|
|
}
|
|
|
|
test {No write if min-slaves-to-write is < attached slaves} {
|
|
r config set min-slaves-to-write 2
|
|
r config set min-slaves-max-lag 10
|
|
catch {r set foo 12345} err
|
|
set err
|
|
} {NOREPLICAS*}
|
|
|
|
test {If min-slaves-to-write is honored, write is accepted (again)} {
|
|
r config set min-slaves-to-write 1
|
|
r config set min-slaves-max-lag 10
|
|
r set foo 12345
|
|
wait_for_condition 50 100 {
|
|
[r -1 get foo] eq {12345}
|
|
} else {
|
|
fail "Write did not reached slave"
|
|
}
|
|
}
|
|
|
|
test {No write if min-slaves-max-lag is > of the slave lag} {
|
|
r -1 deferred 1
|
|
r config set min-slaves-to-write 1
|
|
r config set min-slaves-max-lag 2
|
|
r -1 debug sleep 6
|
|
assert {[r set foo 12345] eq {OK}}
|
|
after 4000
|
|
catch {r set foo 12345} err
|
|
assert {[r -1 read] eq {OK}}
|
|
r -1 deferred 0
|
|
set err
|
|
} {NOREPLICAS*}
|
|
|
|
test {min-slaves-to-write is ignored by slaves} {
|
|
r config set min-slaves-to-write 1
|
|
r config set min-slaves-max-lag 10
|
|
r -1 config set min-slaves-to-write 1
|
|
r -1 config set min-slaves-max-lag 10
|
|
r set foo aaabbb
|
|
wait_for_condition 50 100 {
|
|
[r -1 get foo] eq {aaabbb}
|
|
} else {
|
|
fail "Write did not reached slave"
|
|
}
|
|
}
|
|
|
|
# Fix parameters for the next test to work
|
|
r config set min-slaves-to-write 0
|
|
r -1 config set min-slaves-to-write 0
|
|
r flushall
|
|
|
|
test {MASTER and SLAVE dataset should be identical after complex ops} {
|
|
createComplexDataset r 10000
|
|
after 500
|
|
wait_for_condition 50 100 {
|
|
[r debug digest] eq [r -1 debug digest]
|
|
} else {
|
|
if {[r debug digest] ne [r -1 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]
|
|
}
|
|
}
|
|
}
|