diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-08-01 04:22:19 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-08-01 04:22:19 +0300 |
| commit | 7c3a12dc9f61583611a3d1179308b8b16627bdb8 (patch) | |
| tree | d4d7feeeb50c33be1a561a5b76d2d7c05643e34b /test | |
| parent | 733d5ef8b27318f923ec4966fd84e32d83464ecb (diff) | |
| download | rabbitmq-server-git-7c3a12dc9f61583611a3d1179308b8b16627bdb8.tar.gz | |
Test suite updates
Diffstat (limited to 'test')
| -rw-r--r-- | test/dynamic_ha_SUITE.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/test/dynamic_ha_SUITE.erl b/test/dynamic_ha_SUITE.erl index 61fd0b3cb7..f969474918 100644 --- a/test/dynamic_ha_SUITE.erl +++ b/test/dynamic_ha_SUITE.erl @@ -332,7 +332,7 @@ slave_recovers_after_vhost_failure(Config) -> assert_slaves(A, QName, {A, [B]}, [{A, []}]), %% Crash vhost on a node hosting a mirror - {ok, Sup} = rabbit_ct_broker_helpers:rpc(Config, B, rabbit_vhost_sup_sup, vhost_sup, [<<"/">>]), + {ok, Sup} = rabbit_ct_broker_helpers:rpc(Config, B, rabbit_vhost_sup_sup, get_vhost_sup, [<<"/">>]), exit(Sup, foo), assert_slaves(A, QName, {A, [B]}, [{A, []}]). @@ -350,8 +350,9 @@ slave_recovers_after_vhost_down_an_up(Config) -> rabbit_ct_broker_helpers:force_vhost_failure(Config, B, <<"/">>), %% Vhost is down now false = rabbit_ct_broker_helpers:rpc(Config, B, rabbit_vhost_sup_sup, is_vhost_alive, [<<"/">>]), + timer:sleep(300), %% Vhost is back up - {ok, _Sup} = rabbit_ct_broker_helpers:rpc(Config, B, rabbit_vhost_sup_sup, vhost_sup, [<<"/">>]), + {ok, _Sup} = rabbit_ct_broker_helpers:rpc(Config, B, rabbit_vhost_sup_sup, get_vhost_sup, [<<"/">>]), assert_slaves(A, QName, {A, [B]}, [{A, []}]). @@ -383,7 +384,7 @@ slave_recovers_after_vhost_down_and_master_migrated(Config) -> assert_slaves(B, QName, {B, []}), %% Restart the vhost on the node (previously) hosting queue master - {ok, _Sup} = rabbit_ct_broker_helpers:rpc(Config, A, rabbit_vhost_sup_sup, vhost_sup, [<<"/">>]), + {ok, _Sup} = rabbit_ct_broker_helpers:rpc(Config, A, rabbit_vhost_sup_sup, get_vhost_sup, [<<"/">>]), timer:sleep(300), assert_slaves(B, QName, {B, [A]}, [{B, []}]). |