diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-06-26 09:27:43 -0700 |
|---|---|---|
| committer | Luke Bakken <luke@bakken.io> | 2017-06-28 08:19:46 -0700 |
| commit | dbeb08a20446d72ff69e1c7b49095f2d27d12b45 (patch) | |
| tree | ecd5a88f374ee713dc291cd0f9141636e7f95fd5 /test | |
| parent | b5d85b581fd45eb4bf36a367fd106cbbf521a1b3 (diff) | |
| download | rabbitmq-server-git-dbeb08a20446d72ff69e1c7b49095f2d27d12b45.tar.gz | |
Only GC local queue metrics
Previously, GC would not clear out metrics for non-local queues,
so stale data remained in the metrics tables.
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_core_metrics_gc_SUITE.erl | 15 |
1 files changed, 1 insertions, 14 deletions
diff --git a/test/rabbit_core_metrics_gc_SUITE.erl b/test/rabbit_core_metrics_gc_SUITE.erl index f60a74c315..2540e5cd3e 100644 --- a/test/rabbit_core_metrics_gc_SUITE.erl +++ b/test/rabbit_core_metrics_gc_SUITE.erl @@ -380,26 +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} % [{{resource,<<"/">>,queue,<<"cluster_queue_metrics">>}, 1,0,1,10524}] - EtsData0_0 = rabbit_ct_broker_helpers:rpc(Config, Node0, ets, tab2list, [queue_coarse_metrics]), - [] = EtsData0_0, - - EtsData0_1 = rabbit_ct_broker_helpers:rpc(Config, Node0, ets, tab2list, [queue_coarse_metrics]), - ct:pal("Node 0 ETS: ~p~n", [EtsData0_1]), - [{Name, 1, 0, 1, _}] = EtsData0_1, + [] = rabbit_ct_broker_helpers:rpc(Config, Node0, ets, tab2list, [queue_coarse_metrics]), EtsData1_0 = rabbit_ct_broker_helpers:rpc(Config, Node1, ets, tab2list, [queue_coarse_metrics]), - ct:pal("Node 1 ETS: ~p~n", [EtsData1_0]), [{Name, 1, 0, 1, _}] = EtsData1_0, amqp_channel:call(Ch, #'queue.delete'{queue=QueueName}), |