diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-08-28 16:15:35 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-08-28 16:15:35 +0200 |
| commit | ecd7d3b129585ab1cec437f3fa52a8ab987da2c2 (patch) | |
| tree | f6d5f7673c831bf6fe365f7705bff3f9943bad29 /src | |
| parent | f448e0bbe29a0a9d294fbeff29e20d6eee718791 (diff) | |
| download | rabbitmq-server-git-ecd7d3b129585ab1cec437f3fa52a8ab987da2c2.tar.gz | |
removes unnecessary DeltaRam change
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 92c52629c9..c54be13640 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1243,7 +1243,12 @@ stats0({DeltaReady, DeltaUnacked, ReadyMsgPaged}, persistent_bytes = PersistentBytes}) -> S = msg_size(MsgStatus), DeltaTotal = DeltaReady + DeltaUnacked, - DeltaRam = delta_ram(InRamBefore, InRamAfter), + DeltaRam = case {InRamBefore, InRamAfter} of + {false, false} -> 0; + {false, true} -> 1; + {true, false} -> -1; + {true, true} -> 0 + end, DeltaRamReady = case DeltaReady of 1 -> one_if(InRamAfter); -1 -> -one_if(InRamBefore); @@ -1263,12 +1268,6 @@ msg_size(#msg_status{msg_props = #message_properties{size = Size}}) -> Size. msg_in_ram(#msg_status{msg = Msg}) -> Msg =/= undefined. -%% delta_ram(InRamBefore, InRamAfter) -delta_ram(false, false) -> 0; -delta_ram(false, true) -> 1; -delta_ram(true, false) -> -1; -delta_ram(true, true) -> 0. - remove(AckRequired, MsgStatus = #msg_status { seq_id = SeqId, msg_id = MsgId, |