diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-06-26 06:52:35 -0700 |
|---|---|---|
| committer | Luke Bakken <luke@bakken.io> | 2017-06-28 08:19:45 -0700 |
| commit | 09805ae0a4d6ddb35459c619351c13158e9f7938 (patch) | |
| tree | e57240cf90875de5560d24ac8896143a9ca53536 /test | |
| parent | 5864443b10b26b7f6b7eec652ffa1e1f43c26bcb (diff) | |
| download | rabbitmq-server-git-09805ae0a4d6ddb35459c619351c13158e9f7938.tar.gz | |
Force some GC
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_core_metrics_gc_SUITE.erl | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/test/rabbit_core_metrics_gc_SUITE.erl b/test/rabbit_core_metrics_gc_SUITE.erl index 92f0ff3cbe..dc3f8dc8eb 100644 --- a/test/rabbit_core_metrics_gc_SUITE.erl +++ b/test/rabbit_core_metrics_gc_SUITE.erl @@ -341,6 +341,13 @@ cluster_queue_metrics(Config) -> PolicyAppliesTo = <<"queues">>, Node0 = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), + Node1 = rabbit_ct_broker_helpers:get_node_config(Config, 1, nodename), + + rabbit_ct_broker_helpers:rpc(Config, Node0, erlang, send, [rabbit_core_metrics_gc, start_gc]), + rabbit_ct_broker_helpers:rpc(Config, Node0, gen_server, call, [rabbit_core_metrics_gc, test]), + rabbit_ct_broker_helpers:rpc(Config, Node1, erlang, send, [rabbit_core_metrics_gc, start_gc]), + rabbit_ct_broker_helpers:rpc(Config, Node1, gen_server, call, [rabbit_core_metrics_gc, test]), + Ch = rabbit_ct_client_helpers:open_channel(Config, Node0), Node0Name = rabbit_data_coercion:to_binary(Node0), @@ -354,7 +361,6 @@ cluster_queue_metrics(Config) -> #amqp_msg{payload = <<"hello">>}), % Update policy to point to other node - Node1 = rabbit_ct_broker_helpers:get_node_config(Config, 1, nodename), Node1Name = rabbit_data_coercion:to_binary(Node1), Definition1 = [{<<"ha-mode">>, <<"nodes">>}, {<<"ha-params">>, [Node1Name]}], ok = rabbit_ct_broker_helpers:set_policy(Config, 0, @@ -374,6 +380,13 @@ cluster_queue_metrics(Config) -> rabbit_ct_broker_helpers:rpc(Config, Node1, erlang, send, [rabbit_core_metrics_gc, start_gc]), rabbit_ct_broker_helpers:rpc(Config, Node1, gen_server, call, [rabbit_core_metrics_gc, test]), + timer:sleep(1000), + + rabbit_ct_broker_helpers:rpc(Config, Node0, erlang, send, [rabbit_core_metrics_gc, start_gc]), + rabbit_ct_broker_helpers:rpc(Config, Node0, gen_server, call, [rabbit_core_metrics_gc, test]), + rabbit_ct_broker_helpers:rpc(Config, Node1, erlang, send, [rabbit_core_metrics_gc, start_gc]), + rabbit_ct_broker_helpers:rpc(Config, Node1, gen_server, call, [rabbit_core_metrics_gc, test]), + % Check ETS table for data % rabbit_core_metrics:queue_stats % {Name, MessagesReady, MessagesUnacknowledge, Messages, Reductions} |