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 | 64334c8177b37edb2f83e7516f1d8067f1f6f07c (patch) | |
| tree | a34aba5dca181064a75737993d8c0add0a27da8e | |
| parent | 36d6750b0f984a105c448609cb29f9037193d8b0 (diff) | |
| download | rabbitmq-server-git-64334c8177b37edb2f83e7516f1d8067f1f6f07c.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 bf89cdb26e..6388da8f79 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 |
