summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-09-26 18:24:18 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2013-09-26 18:24:18 +0100
commiteb7fd23916133584ee6d93e612e80972a48406ae (patch)
treef04674543d3d4617d4c931550423523947ddfb30
parent13c9c3f4ffc0592a91e7d1f75df015ea42902205 (diff)
downloadrabbitmq-server-bug25726.tar.gz
minor refactorbug25726
-rw-r--r--src/rabbit_memory_monitor.erl12
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;