diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2013-09-26 18:24:18 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-09-26 18:24:18 +0100 |
commit | eb7fd23916133584ee6d93e612e80972a48406ae (patch) | |
tree | f04674543d3d4617d4c931550423523947ddfb30 | |
parent | 13c9c3f4ffc0592a91e7d1f75df015ea42902205 (diff) | |
download | rabbitmq-server-bug25726.tar.gz |
minor refactorbug25726
-rw-r--r-- | src/rabbit_memory_monitor.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_memory_monitor.erl b/src/rabbit_memory_monitor.erl index 62b464e0..4bd1a575 100644 --- a/src/rabbit_memory_monitor.erl +++ b/src/rabbit_memory_monitor.erl @@ -216,9 +216,11 @@ internal_update(State = #state{queue_durations = Durations, end, State#state{desired_duration = DesiredDurationAvg1}. -desired_duration_average(#state{queue_duration_sum = Sum, - queue_duration_count = Count, - disk_alarm = DiskAlarm}) -> +desired_duration_average(#state{disk_alarm = true}) -> + infinity; +desired_duration_average(#state{disk_alarm = false, + queue_duration_sum = Sum, + queue_duration_count = Count}) -> {ok, LimitThreshold} = application:get_env(rabbit, vm_memory_high_watermark_paging_ratio), MemoryLimit = vm_memory_monitor:get_memory_limit(), @@ -226,9 +228,7 @@ desired_duration_average(#state{queue_duration_sum = Sum, true -> erlang:memory(total) / MemoryLimit; false -> infinity end, - if DiskAlarm -> - infinity; - MemoryRatio =:= infinity -> + if MemoryRatio =:= infinity -> 0.0; MemoryRatio < LimitThreshold orelse Count == 0 -> infinity; |