diff options
Diffstat (limited to 'examples/redis-unstable/tests/unit/cluster/internal-secret.tcl')
| -rw-r--r-- | examples/redis-unstable/tests/unit/cluster/internal-secret.tcl | 71 |
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 @@ | |||
| 1 | proc 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 | |||
| 10 | proc 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 | |||
| 18 | start_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 | } | ||
