diff options
| author | Michael Klishin <michael@novemberain.com> | 2017-08-24 04:41:14 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-08-24 04:41:14 -0400 |
| commit | 677f22a87560d83745f5bd4d5df0c60ee550a38d (patch) | |
| tree | daf9d25cf4df4af64acfbbd78876cc2c315be479 /src | |
| parent | 4e94918a957bfee5905e75c89c14e2e7e9b74600 (diff) | |
| parent | 249cf662ccb1914633e0493b8356420b6a3ec726 (diff) | |
| download | rabbitmq-server-git-677f22a87560d83745f5bd4d5df0c60ee550a38d.tar.gz | |
Merge pull request #1341 from rabbitmq/rabbitmq-server-1340
Do not GC channel-queue metrics on mirror migration
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_core_metrics_gc.erl | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/rabbit_core_metrics_gc.erl b/src/rabbit_core_metrics_gc.erl index 3321f2b5de..9396368348 100644 --- a/src/rabbit_core_metrics_gc.erl +++ b/src/rabbit_core_metrics_gc.erl @@ -70,10 +70,17 @@ gc_channels() -> ok. gc_queues() -> + gc_local_queues(), + gc_global_queues(). + +gc_local_queues() -> Queues = rabbit_amqqueue:list_local_names(), GbSet = gb_sets:from_list(Queues), gc_entity(queue_metrics, GbSet), - gc_entity(queue_coarse_metrics, GbSet), + gc_entity(queue_coarse_metrics, GbSet). + +gc_global_queues() -> + GbSet = gb_sets:from_list(rabbit_amqqueue:list_names()), gc_process_and_entity(channel_queue_metrics, GbSet), gc_process_and_entity(consumer_created, GbSet), ExchangeGbSet = gb_sets:from_list(rabbit_exchange:list_names()), |