diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-02-05 18:55:45 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-02-05 18:55:45 +0000 |
| commit | 08301a125c6c189a2cd74c013e7426f974557dc0 (patch) | |
| tree | 31d5c2578edb7712a878ef83bf236489e5b84cb1 | |
| parent | bb4ccbfbfda1efead3c2dbae3f0cf06d2697e7d0 (diff) | |
| download | rabbitmq-server-git-08301a125c6c189a2cd74c013e7426f974557dc0.tar.gz | |
preeeeeeetty
| -rw-r--r-- | src/rabbit_variable_queue.erl | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 9d2423161d..321af4ace3 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -755,20 +755,20 @@ set_ram_duration_target( false -> reduce_memory_use(State1) end). -update_rates(State = #vqstate{ in_counter = InCount, - out_counter = OutCount, - ack_in_counter = AckInCount, +update_rates(State = #vqstate{ in_counter = InCount, + out_counter = OutCount, + ack_in_counter = AckInCount, ack_out_counter = AckOutCount, - rates = #rates{ in = InRate, - out = OutRate, - ack_in = AckInRate, + rates = #rates{ in = InRate, + out = OutRate, + ack_in = AckInRate, ack_out = AckOutRate, timestamp = TS }}) -> Now = erlang:now(), - Rates = #rates { in = update_rate(Now, TS, InCount, InRate), - out = update_rate(Now, TS, OutCount, OutRate), - ack_in = update_rate(Now, TS, AckInCount, AckInRate), + Rates = #rates { in = update_rate(Now, TS, InCount, InRate), + out = update_rate(Now, TS, OutCount, OutRate), + ack_in = update_rate(Now, TS, AckInCount, AckInRate), ack_out = update_rate(Now, TS, AckOutCount, AckOutRate), timestamp = Now }, |