diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-08-27 11:08:43 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-08-27 11:08:43 +0100 |
| commit | 6ac9ab5f7d6ae13b1aacca6e26f92429bcd2e024 (patch) | |
| tree | 5269c16807e0837fb4618637f388f6a649a9e1d1 /src | |
| parent | a12101207fd9b8a33e4d25f6edf9ce92df235a39 (diff) | |
| download | rabbitmq-server-git-6ac9ab5f7d6ae13b1aacca6e26f92429bcd2e024.tar.gz | |
Tiny cosmetic, but also, we shouldn't include the size of the marker message in the inital size calculation.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index fcd966e939..355fb1fc04 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -110,8 +110,8 @@ init(Queue, IsDurable) -> SizeAcc1 = SizeAcc + size_of_message(Msg), case {MFound, is_magic_marker_message(Msg)} of {false, false} -> {SizeAcc1, false, MCount + 1}; - {false, true} -> {SizeAcc1, true, MCount}; - {true, false} -> {SizeAcc1, true, MCount} + {false, true} -> {SizeAcc, true, MCount}; + {true, false} -> {SizeAcc1, true, MCount} end end, {0, false, 0}, Queue), Len1 = case MarkerFound of |