gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Test: more MIGRATE tests.

Browse Source
This commit is contained in:
antirez 2012-11-14 12:12:52 +01:00
parent 2feef47aa1
commit 989a7820ca
2 changed files with 24 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/test_helper.tcl
View File

@ -11,6 +11,7 @@ source tests/support/util.tcl
set ::all_tests { set ::all_tests {
unit/printver unit/printver
unit/dump
unit/auth unit/auth
unit/protocol unit/protocol
unit/basic unit/basic
@ -40,7 +41,6 @@ set ::all_tests {
unit/introspection unit/introspection
unit/limits unit/limits
unit/obuf-limits unit/obuf-limits
unit/dump
unit/bitops unit/bitops
} }
# Index to the next test to run in the ::all_tests list. # Index to the next test to run in the ::all_tests list.

44
tests/unit/dump.tcl
View File

@ -43,6 +43,27 @@ start_server {tags {"dump"}} {
r dump nonexisting_key r dump nonexisting_key
} {} } {}
test {MIGRATE is caching connections} {
# Note, we run this as first test so that the connection cache
# is empty.
set first [srv 0 client]
r set key "Some Value"
start_server {tags {"repl"}} {
set second [srv 0 client]
set second_host [srv 0 host]
set second_port [srv 0 port]
assert_match {*migrate_cached_sockets:0*} [r -1 info]
r -1 migrate $second_host $second_port key 9 1000
assert_match {*migrate_cached_sockets:1*} [r -1 info]
}
}
test {MIGRATE cached connections are released after some time} {
after 15000
assert_match {*migrate_cached_sockets:0*} [r info]
}
test {MIGRATE is able to migrate a key between two instances} { test {MIGRATE is able to migrate a key between two instances} {
set first [srv 0 client] set first [srv 0 client]
r set key "Some Value" r set key "Some Value"
@ -180,28 +201,9 @@ start_server {tags {"dump"}} {
assert {[$second exists key] == 0} assert {[$second exists key] == 0}
set rd [redis_deferring_client] set rd [redis_deferring_client]
$rd debug sleep 5.0 ; # Make second server unable to reply. $rd debug sleep 1.0 ; # Make second server unable to reply.
set e {} set e {}
catch {r -1 migrate $second_host $second_port key 9 1000} e catch {r -1 migrate $second_host $second_port key 9 500} e
assert_match {IOERR*} $e
}
}
test {MIGRATE is caching connections} {
set first [srv 0 client]
r set key "Some Value"
start_server {tags {"repl"}} {
set second [srv 0 client]
set second_host [srv 0 host]
set second_port [srv 0 port]
assert {[$first exists key] == 1}
assert {[$second exists key] == 0}
set rd [redis_deferring_client]
$rd debug sleep 5.0 ; # Make second server unable to reply.
set e {}
catch {r -1 migrate $second_host $second_port key 9 1000} e
assert_match {IOERR*} $e assert_match {IOERR*} $e
} }
} }