Skip to content

Commit cb0ef00

Browse files
committed
quorum_queue_member_reconciliation_SUITE
1 parent a8c6388 commit cb0ef00

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

deps/rabbit/test/quorum_queue_member_reconciliation_SUITE.erl

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,14 +147,22 @@ auto_grow_drained_node(Config) ->
147147
?assertEqual(1, length(Members)),
148148

149149
add_server_to_cluster(Server1, Server0),
150+
clustering_utils:assert_cluster_status(
151+
{[Server0, Server1], [Server0, Server1], [Server0, Server1]},
152+
[Server0, Server1]),
153+
150154
%% mark server1 as drained, which should mean the node is not a candiate
151155
%% for qq membership
152156
rabbit_ct_broker_helpers:mark_as_being_drained(Config, Server1),
153157
rabbit_ct_helpers:await_condition(
154158
fun () -> rabbit_ct_broker_helpers:is_being_drained_local_read(Config, Server1) end,
155159
10000),
156160
add_server_to_cluster(Server2, Server0),
157-
timer:sleep(5000),
161+
clustering_utils:assert_cluster_status(
162+
{[Server0, Server1, Server2],
163+
[Server0, Server1, Server2],
164+
[Server0, Server1, Server2]},
165+
[Server0, Server1, Server2]),
158166
%% We have 3 nodes, but one is drained, so it will not be concidered.
159167
{ok, Members1, _} = ra:members({queue_utils:ra_name(QQ), Server0}),
160168
?assertEqual(1, length(Members1)),

0 commit comments

Comments
 (0)