summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-08-05 15:53:50 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2011-08-05 15:53:50 +0100
commit07d790f4a1f2a0bde69bf144ac2d6063f55c25c4 (patch)
treea34aba5dca181064a75737993d8c0add0a27da8e
parent51c8e02239abcb2f8a9a80db8ed2385e0ce67d10 (diff)
downloadrabbitmq-server-07d790f4a1f2a0bde69bf144ac2d6063f55c25c4.tar.gz
minor simplifying refactor
-rw-r--r--src/rabbit_queue_index.erl14
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