diff options
| author | Michael Klishin <klishinm@vmware.com> | 2020-10-07 22:49:41 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-10-07 22:49:41 +0300 |
| commit | 424d3158fb0b176b1f3a018c0a7d779531616416 (patch) | |
| tree | 1dfddccbea65a3b70f24ef56f92f4d59e97ea081 /test | |
| parent | b460ea1b4f41c5547f03c316e758be61bdcd0f2e (diff) | |
| parent | d639042e0dba20c3eed093a08b0fb0cfa18f1e6c (diff) | |
| download | rabbitmq-server-git-424d3158fb0b176b1f3a018c0a7d779531616416.tar.gz | |
Merge pull request #2462 from rabbitmq/rabbitmq-management-844
Several new functions for rabbit_alarms
Diffstat (limited to 'test')
| -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), |