diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-15 13:54:08 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-15 13:54:08 +0100 |
| commit | 748697a7b73babf6f23d716d7ffd9deedb537465 (patch) | |
| tree | 446cf351ddbd0c15e9a2f4b86c7ce8b9cd3d2eb0 /src | |
| parent | c631dd6645ca3660e296d1c62d661704f8a675f6 (diff) | |
| download | rabbitmq-server-git-748697a7b73babf6f23d716d7ffd9deedb537465.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -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 %%---------------------------------------------------------------------------- |