diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-08-26 06:27:55 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-08-26 06:27:55 +0100 |
| commit | d18bfa1b6704542f2c6ab379a75b4bfd918a1d14 (patch) | |
| tree | d5d57caa39448f945703421b599f105df34e39de /src | |
| parent | 8ba75b2767bb24396dbc9e5707b110f3c382aa08 (diff) | |
| download | rabbitmq-server-git-d18bfa1b6704542f2c6ab379a75b4bfd918a1d14.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_disk_queue.erl | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index fea0092ee5..cba84ed706 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -993,11 +993,11 @@ internal_tx_publish(Message = #basic_message { is_persistent = IsPersistent, %% New message, lots to do {ok, TotalSize} = append_message(CurHdl, MsgId, msg_to_bin(Message), IsPersistent), - true = dets_ets_insert_new - (State, #message_store_entry - { msg_id = MsgId, ref_count = 1, file = CurName, - offset = CurOffset, total_size = TotalSize, - is_persistent = IsPersistent }), + true = dets_ets_insert_new( + State, #message_store_entry + { msg_id = MsgId, ref_count = 1, file = CurName, + offset = CurOffset, total_size = TotalSize, + is_persistent = IsPersistent }), [{CurName, ValidTotalSize, ContiguousTop, Left, undefined}] = ets:lookup(FileSummary, CurName), ValidTotalSize1 = ValidTotalSize + TotalSize + @@ -1414,9 +1414,9 @@ copy_messages(WorkList, InitOffset, FinalOffset, SourceHdl, DestinationHdl, %% Offset, BlockStart and BlockEnd are in the SourceFile Size = TotalSize + ?FILE_PACKING_ADJUSTMENT, %% update MsgLocationDets to reflect change of file and offset - ok = dets_ets_insert (State, StoreEntry #message_store_entry - { file = Destination, - offset = CurOffset }), + ok = dets_ets_insert(State, StoreEntry #message_store_entry + { file = Destination, + offset = CurOffset }), NextOffset = CurOffset + Size, if BlockStart =:= undefined -> %% base case, called only for the first list elem @@ -1653,12 +1653,12 @@ load_messages(Left, [File|Files], msg_id)) of 0 -> {VMAcc, VTSAcc}; RefCount -> - true = dets_ets_insert_new - (State, #message_store_entry - { msg_id = MsgId, ref_count = RefCount, - file = File, offset = Offset, - total_size = TotalSize, - is_persistent = IsPersistent }), + true = dets_ets_insert_new( + State, #message_store_entry + { msg_id = MsgId, ref_count = RefCount, + file = File, offset = Offset, + total_size = TotalSize, + is_persistent = IsPersistent }), {[Obj | VMAcc], VTSAcc + TotalSize + ?FILE_PACKING_ADJUSTMENT } @@ -1686,10 +1686,10 @@ recover_crashed_compactions(Files, TmpFiles) -> verify_messages_in_mnesia(MsgIds) -> lists:foreach( fun (MsgId) -> - true = 0 < length(mnesia:dirty_index_match_object - (rabbit_disk_queue, - #dq_msg_loc { msg_id = MsgId, _ = '_' }, - msg_id)) + true = 0 < length(mnesia:dirty_index_match_object( + rabbit_disk_queue, + #dq_msg_loc { msg_id = MsgId, _ = '_' }, + msg_id)) end, MsgIds). grab_msg_id({MsgId, _IsPersistent, _TotalSize, _FileOffset}) -> |