File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change 34
34
-include_lib (" proper/include/proper.hrl" ).
35
35
-include_lib (" eunit/include/eunit.hrl" ).
36
36
-include_lib (" amqp_client/include/amqp_client.hrl" ).
37
+ -include_lib (" rabbitmq_ct_helpers/include/rabbit_assert.hrl" ).
37
38
38
39
-compile (export_all ).
39
40
@@ -436,8 +437,10 @@ nodes_policy_should_pick_master_from_its_params(Config) ->
436
437
[all ])),
437
438
% % --> Master: A
438
439
% % Slaves: [B, C] or [C, B]
439
- Info = find_queue (? QNAME , A ),
440
- SSPids = proplists :get_value (synchronised_follower_pids , Info ),
440
+ SSPids = ? awaitMatch (SSPids when is_list (SSPids ),
441
+ proplists :get_value (synchronized_slave_pids ,
442
+ find_queue (? QNAME , A )),
443
+ 5000 ),
441
444
442
445
% % Choose mirror that isn't the first sync mirror. Cover a bug that always
443
446
% % chose the first, even if it was not part of the policy
You can’t perform that action at this time.
0 commit comments