Skip to content

Commit ecd7d3b

Browse files
committed
removes unnecessary DeltaRam change
1 parent f448e0b commit ecd7d3b

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

src/rabbit_variable_queue.erl

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1243,7 +1243,12 @@ stats0({DeltaReady, DeltaUnacked, ReadyMsgPaged},
12431243
persistent_bytes = PersistentBytes}) ->
12441244
S = msg_size(MsgStatus),
12451245
DeltaTotal = DeltaReady + DeltaUnacked,
1246-
DeltaRam = delta_ram(InRamBefore, InRamAfter),
1246+
DeltaRam = case {InRamBefore, InRamAfter} of
1247+
{false, false} -> 0;
1248+
{false, true} -> 1;
1249+
{true, false} -> -1;
1250+
{true, true} -> 0
1251+
end,
12471252
DeltaRamReady = case DeltaReady of
12481253
1 -> one_if(InRamAfter);
12491254
-1 -> -one_if(InRamBefore);
@@ -1263,12 +1268,6 @@ msg_size(#msg_status{msg_props = #message_properties{size = Size}}) -> Size.
12631268

12641269
msg_in_ram(#msg_status{msg = Msg}) -> Msg =/= undefined.
12651270

1266-
%% delta_ram(InRamBefore, InRamAfter)
1267-
delta_ram(false, false) -> 0;
1268-
delta_ram(false, true) -> 1;
1269-
delta_ram(true, false) -> -1;
1270-
delta_ram(true, true) -> 0.
1271-
12721271
remove(AckRequired, MsgStatus = #msg_status {
12731272
seq_id = SeqId,
12741273
msg_id = MsgId,

0 commit comments

Comments
 (0)