diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-10-06 20:23:58 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-10-06 20:24:40 +0300 |
| commit | d639042e0dba20c3eed093a08b0fb0cfa18f1e6c (patch) | |
| tree | 5535bbba1a89e83c9250c40263d47662a0456d60 | |
| parent | 34a2677bcf38815036a4d5b74650435352d7087f (diff) | |
| download | rabbitmq-server-git-rabbitmq-management-844.tar.gz | |
Switch to new CT helpersrabbitmq-management-844
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index 16042b71e8..d428cb0701 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -2105,15 +2105,19 @@ memory_alarm_rolls_wal(Config) -> [Server | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), WalDataDir = rpc:call(Server, ra_env, wal_data_dir, []), [Wal0] = filelib:wildcard(WalDataDir ++ "/*.wal"), - ok = rpc:call(Server, rabbit_alarm, set_alarm, - [{{resource_limit, memory, Server}, []}]), + rabbit_ct_broker_helpers:set_alarm(Config, Server, memory), + rabbit_ct_helpers:await_condition( + fun() -> rabbit_ct_broker_helpers:get_alarms(Config, Server) =/= [] end + ), timer:sleep(1000), [Wal1] = filelib:wildcard(WalDataDir ++ "/*.wal"), ?assert(Wal0 =/= Wal1), %% roll over shouldn't happen if we trigger a new alarm in less than %% min_wal_roll_over_interval - ok = rpc:call(Server, rabbit_alarm, set_alarm, - [{{resource_limit, memory, Server}, []}]), + rabbit_ct_broker_helpers:set_alarm(Config, Server, memory), + rabbit_ct_helpers:await_condition( + fun() -> rabbit_ct_broker_helpers:get_alarms(Config, Server) =/= [] end + ), timer:sleep(1000), [Wal2] = filelib:wildcard(WalDataDir ++ "/*.wal"), ?assert(Wal1 == Wal2), |