diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 4d57304cb1..4e120a9471 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -755,11 +755,6 @@ store_tx(Txn, Tx) -> put({txn, Txn}, Tx). erase_tx(Txn) -> erase({txn, Txn}). -update_rate(Now, Then, Count, {OThen, OCount}) -> - %% form the avg over the current period and the previous - Avg = 1000000 * ((Count + OCount) / timer:now_diff(Now, OThen)), - {Avg, {Then, Count}}. - persistent_guids(Pubs) -> [Guid || #basic_message { guid = Guid, is_persistent = true } <- Pubs]. @@ -820,6 +815,11 @@ combine_deltas(#delta { start_seq_id = StartLow, beta_fold(Fun, Init, Q) -> bpqueue:foldr(fun (_Prefix, Value, Acc) -> Fun(Value, Acc) end, Init, Q). +update_rate(Now, Then, Count, {OThen, OCount}) -> + %% form the avg over the current period and the previous + Avg = 1000000 * ((Count + OCount) / timer:now_diff(Now, OThen)), + {Avg, {Then, Count}}. + %%---------------------------------------------------------------------------- %% Internal major helpers for Public API %%---------------------------------------------------------------------------- |