diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2011-08-05 15:53:50 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-08-05 15:53:50 +0100 |
commit | 07d790f4a1f2a0bde69bf144ac2d6063f55c25c4 (patch) | |
tree | a34aba5dca181064a75737993d8c0add0a27da8e | |
parent | 51c8e02239abcb2f8a9a80db8ed2385e0ce67d10 (diff) | |
download | rabbitmq-server-07d790f4a1f2a0bde69bf144ac2d6063f55c25c4.tar.gz |
minor simplifying refactor
-rw-r--r-- | src/rabbit_queue_index.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index bf89cdb2..6388da8f 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -569,13 +569,13 @@ add_to_journal(SeqId, Action, State = #qistate { dirty_count = DCount, add_to_journal(RelSeq, Action, Segment = #segment { journal_entries = JEntries, unacked = UnackedCount }) -> - Segment1 = Segment #segment { - journal_entries = add_to_journal(RelSeq, Action, JEntries) }, - case Action of - del -> Segment1; - ack -> Segment1 #segment { unacked = UnackedCount - 1 }; - ?PUB -> Segment1 #segment { unacked = UnackedCount + 1 } - end; + Segment #segment { + journal_entries = add_to_journal(RelSeq, Action, JEntries), + unacked = UnackedCount + case Action of + ?PUB -> +1; + del -> 0; + ack -> -1 + end}; add_to_journal(RelSeq, Action, JEntries) -> Val = case array:get(RelSeq, JEntries) of |