diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2019-12-16 15:25:02 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-12-16 15:25:02 +0000 |
| commit | cd4dcca2a9f6e2fbddb9be7e19e9f618f123be46 (patch) | |
| tree | 70c848c2b57bd81b33d558a934fe2f2870974e9b /src | |
| parent | 592644dd827ae20bffeef700e37e31c47018de4a (diff) | |
| parent | d1d2567e13e881dded9b378836882f88ea88aba5 (diff) | |
| download | rabbitmq-server-git-cd4dcca2a9f6e2fbddb9be7e19e9f618f123be46.tar.gz | |
Merge pull request #2185 from rabbitmq/qq-aux-eval-changes
Update rabbit_fifo with Ra aux changes
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 0f77c2726f..2131585dc4 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -601,7 +601,7 @@ tick(_Ts, #?MODULE{cfg = #cfg{name = Name, EnqueueBytes, CheckoutBytes}, [{mod_call, rabbit_quorum_queue, - handle_tick, [QName, Metrics, all_nodes(State)]}, {aux, emit}]. + handle_tick, [QName, Metrics, all_nodes(State)]}]. -spec overview(state()) -> map(). overview(#?MODULE{consumers = Cons, @@ -643,9 +643,11 @@ handle_aux(_, cast, Cmd, {Name, Use0}, Log, _) -> Use = case Cmd of _ when Cmd == active orelse Cmd == inactive -> update_use(Use0, Cmd); - emit -> + tick -> true = ets:insert(rabbit_fifo_usage, {Name, utilisation(Use0)}), + Use0; + eval -> Use0 end, {no_reply, {Name, Use}, Log}. |