diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-03-31 19:14:57 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-03-31 19:14:57 +0300 |
| commit | d3adb5252c989ff9deb7b3a6c300f782e62ae323 (patch) | |
| tree | 208c2a3683279323bccedcc7779a4acc6fef2036 | |
| parent | 5591af3d641628442d1ea6e9e1ce53c9de7449d5 (diff) | |
| download | rabbitmq-server-git-d3adb5252c989ff9deb7b3a6c300f782e62ae323.tar.gz | |
peer_discovery_classic_config_SUITE: re-evaluate cluster formation condition for up to N seconds
Depends on rabbitmq/rabbitmq-ct-helpers@98f1c4a8012c006965257f2875873bf9d08416bc
| -rw-r--r-- | test/peer_discovery_classic_config_SUITE.erl | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/test/peer_discovery_classic_config_SUITE.erl b/test/peer_discovery_classic_config_SUITE.erl index 9e51139e69..40c516d20b 100644 --- a/test/peer_discovery_classic_config_SUITE.erl +++ b/test/peer_discovery_classic_config_SUITE.erl @@ -147,14 +147,20 @@ end_per_testcase(Testcase, Config) -> %% successful_discovery(Config) -> - ?assertEqual(3, length(cluster_members_online(Config, 0))), - ?assertEqual(3, length(cluster_members_online(Config, 1))). + Condition = fun() -> + 3 =:= length(cluster_members_online(Config, 0)) andalso + 3 =:= length(cluster_members_online(Config, 1)) + end, + rabbit_ct_helpers:await_condition(Condition, 10000). successful_discovery_with_a_subset_of_nodes_coming_online(Config) -> - ?assertEqual(2, length(cluster_members_online(Config, 0))), - ?assertEqual(2, length(cluster_members_online(Config, 1))). + Condition = fun() -> + 2 =:= length(cluster_members_online(Config, 0)) andalso + 2 =:= length(cluster_members_online(Config, 1)) + end, + rabbit_ct_helpers:await_condition(Condition, 10000). no_nodes_configured(Config) -> - ct:pal("Cluster members online: ~p", [cluster_members_online(Config, 0)]), - ?assert(length(cluster_members_online(Config, 0)) < 2). + Condition = fun() -> length(cluster_members_online(Config, 0)) < 2 end, + rabbit_ct_helpers:await_condition(Condition, 7000). |