diff options
| author | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-06-29 14:22:00 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-06-29 14:22:00 +0100 |
| commit | c72afe6bc1794ef85515743bf53400c6ea4e6dfb (patch) | |
| tree | 97debef878aa38d20e16350cf861b94488397f9c /src | |
| parent | b9d7e4d7e4699e927e978ea3bb7393da11491655 (diff) | |
| download | rabbitmq-server-git-c72afe6bc1794ef85515743bf53400c6ea4e6dfb.tar.gz | |
Report reductions and garbage collection options in queue processes
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index cd21aa62b8..cf90f1cac2 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -116,7 +116,9 @@ slave_pids, synchronised_slave_pids, recoverable_slaves, - state + state, + reductions, + garbage_collection ]). -define(CREATION_EVENT_KEYS, @@ -925,6 +927,12 @@ i(recoverable_slaves, #q{q = #amqqueue{name = Name, end; i(state, #q{status = running}) -> credit_flow:state(); i(state, #q{status = State}) -> State; +i(garbage_collection, _State) -> + {garbage_collection, GC} = erlang:process_info(self(), garbage_collection), + GC; +i(reductions, _State) -> + {reductions, Reductions} = erlang:process_info(self(), reductions), + Reductions; i(Item, #q{backing_queue_state = BQS, backing_queue = BQ}) -> BQ:info(Item, BQS). |