aboutsummaryrefslogtreecommitdiff
path: root/examples/redis-unstable/tests/unit/cluster/internal-secret.tcl
diff options
context:
space:
mode:
Diffstat (limited to 'examples/redis-unstable/tests/unit/cluster/internal-secret.tcl')
-rw-r--r--examples/redis-unstable/tests/unit/cluster/internal-secret.tcl71
1 files changed, 0 insertions, 71 deletions
diff --git a/examples/redis-unstable/tests/unit/cluster/internal-secret.tcl b/examples/redis-unstable/tests/unit/cluster/internal-secret.tcl
deleted file mode 100644
index f310b74..0000000
--- a/examples/redis-unstable/tests/unit/cluster/internal-secret.tcl
+++ /dev/null
@@ -1,71 +0,0 @@
1proc num_unique_secrets {num_nodes} {
2 set secrets [list]
3 for {set i 0} {$i < $num_nodes} {incr i} {
4 lappend secrets [R $i debug internal_secret]
5 }
6 set num_secrets [llength [lsort -unique $secrets]]
7 return $num_secrets
8}
9
10proc wait_for_secret_sync {maxtries delay num_nodes} {
11 wait_for_condition $maxtries $delay {
12 [num_unique_secrets $num_nodes] eq 1
13 } else {
14 fail "Failed waiting for secrets to sync"
15 }
16}
17
18start_cluster 3 3 {tags {external:skip cluster}} {
19 test "Test internal secret sync" {
20 wait_for_secret_sync 50 100 6
21 }
22
23
24 set first_shard_host [srv 0 host]
25 set first_shard_port [srv 0 port]
26
27 if {$::verbose} {
28 puts {cluster internal secret:}
29 puts [R 1 debug internal_secret]
30 }
31
32 test "Join a node to the cluster and make sure it gets the same secret" {
33 start_server {tags {"external:skip"} overrides {cluster-enabled {yes}}} {
34 r cluster meet $first_shard_host $first_shard_port
35 wait_for_condition 50 100 {
36 [r debug internal_secret] eq [R 1 debug internal_secret]
37 } else {
38 puts [r debug internal_secret]
39 puts [R 1 debug internal_secret]
40 fail "Secrets not match"
41 }
42 }
43 }
44
45 test "Join another cluster, make sure clusters sync on the internal secret" {
46 start_server {tags {"external:skip"} overrides {cluster-enabled {yes}}} {
47 set new_shard_host [srv 0 host]
48 set new_shard_port [srv 0 port]
49 start_server {tags {"external:skip"} overrides {cluster-enabled {yes}}} {
50 r cluster meet $new_shard_host $new_shard_port
51 wait_for_condition 50 100 {
52 [r debug internal_secret] eq [r -1 debug internal_secret]
53 } else {
54 puts [r debug internal_secret]
55 puts [r -1 debug internal_secret]
56 fail "Secrets not match"
57 }
58 if {$::verbose} {
59 puts {new cluster internal secret:}
60 puts [r -1 debug internal_secret]
61 }
62 r cluster meet $first_shard_host $first_shard_port
63 wait_for_secret_sync 50 100 8
64 if {$::verbose} {
65 puts {internal secret after join to bigger cluster:}
66 puts [r -1 debug internal_secret]
67 }
68 }
69 }
70 }
71}