blob: 0f3e3cc4f773aa6fc795fe25a8d63894382e22ba (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
start_cluster 2 2 {tags {external:skip cluster}} {
test "Verify that slot ownership transfer through gossip propagates deletes to replicas" {
assert {[s -2 role] eq {slave}}
wait_for_condition 1000 50 {
[s -2 master_link_status] eq {up}
} else {
fail "Instance #2 master link status is not up"
}
assert {[s -3 role] eq {slave}}
wait_for_condition 1000 50 {
[s -3 master_link_status] eq {up}
} else {
fail "Instance #3 master link status is not up"
}
# Set a single key that will be used to test deletion
set key "FOO"
R 0 SET $key TEST
set key_slot [R 0 cluster keyslot $key]
set slot_keys_num [R 0 cluster countkeysinslot $key_slot]
assert {$slot_keys_num > 0}
# Wait for replica to have the key
R 2 readonly
wait_for_condition 1000 50 {
[R 2 exists $key] eq "1"
} else {
fail "Test key was not replicated"
}
assert_equal [R 2 cluster countkeysinslot $key_slot] $slot_keys_num
# Assert other shards in cluster doesn't have the key
assert_equal [R 1 cluster countkeysinslot $key_slot] "0"
assert_equal [R 3 cluster countkeysinslot $key_slot] "0"
set nodeid [R 1 cluster myid]
R 1 cluster bumpepoch
# Move $key_slot to node 1
assert_equal [R 1 cluster setslot $key_slot node $nodeid] "OK"
wait_for_cluster_propagation
# src master will delete keys in the slot
wait_for_condition 50 100 {
[R 0 cluster countkeysinslot $key_slot] eq 0
} else {
fail "master 'countkeysinslot $key_slot' did not eq 0"
}
# src replica will delete keys in the slot
wait_for_condition 50 100 {
[R 2 cluster countkeysinslot $key_slot] eq 0
} else {
fail "replica 'countkeysinslot $key_slot' did not eq 0"
}
}
}
|
