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 /src | |
| 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 'src')
| -rw-r--r-- | src/rabbit_core_metrics_gc.erl | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/rabbit_core_metrics_gc.erl b/src/rabbit_core_metrics_gc.erl index ee03e8f00f..3321f2b5de 100644 --- a/src/rabbit_core_metrics_gc.erl +++ b/src/rabbit_core_metrics_gc.erl @@ -25,8 +25,6 @@ -export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). --include_lib("rabbit_common/include/rabbit.hrl"). - start_link() -> gen_server:start_link({local, ?MODULE}, ?MODULE, [], []). @@ -72,10 +70,7 @@ gc_channels() -> ok. gc_queues() -> - % Queues will contain pids, we want to filter - Queues = lists:filter(fun(#amqqueue{pid = Pid}) -> - node(Pid) =:= node() - end, rabbit_amqqueue:list()), + Queues = rabbit_amqqueue:list_local_names(), GbSet = gb_sets:from_list(Queues), gc_entity(queue_metrics, GbSet), gc_entity(queue_coarse_metrics, GbSet), |