diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-12-03 17:55:38 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-12-03 17:55:38 +0000 |
| commit | 2b3c37e243009a5261a7710b5ca21e906bb48fc7 (patch) | |
| tree | d529754e398ca3afcde725c0131f9cba2bb8f786 | |
| parent | d1fd1f4acd9f852b2a1779a4008809f3bd32d292 (diff) | |
| download | rabbitmq-server-git-2b3c37e243009a5261a7710b5ca21e906bb48fc7.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_queue_index.erl | 24 |
1 files changed, 11 insertions, 13 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 908a711a4b..136ff82995 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -260,18 +260,16 @@ flush_journal(State = #qistate { segments = Segments, dir = Dir }) -> SegmentsN; false -> Segment1 = - case 0 == array:sparse_size(JEntries) of - true -> - Segment; - false -> - {Hdl, Segment2} = - get_segment_handle(Segment), - array:sparse_foldl( - fun write_entry_to_segment/3, Hdl, - JEntries), - ok = file_handle_cache:sync(Hdl), - Segment2 #segment { journal_entries = - journal_new() } + case array:sparse_size(JEntries) of + 0 -> Segment; + _ -> {Hdl, Segment2} = + get_segment_handle(Segment), + array:sparse_foldl( + fun write_entry_to_segment/3, Hdl, + JEntries), + ok = file_handle_cache:sync(Hdl), + Segment2 #segment { journal_entries = + journal_new() } end, segment_store(Segment1, SegmentsN) end @@ -318,7 +316,7 @@ find_lowest_seq_id_seg_and_next_seq_id(State) -> %% SegNums is sorted, ascending. {LowSeqIdSeg, NextSeqId} = case SegNums of - [] -> {0, 0}; + [] -> {0, 0}; [MinSeg|_] -> {reconstruct_seq_id(MinSeg, 0), reconstruct_seq_id(1 + lists:last(SegNums), 0)} end, |