diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 10 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
2 files changed, 2 insertions, 11 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 1b9cd38218..c631f7a26b 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -427,7 +427,6 @@ init_dirty(CleanShutdown, ContainsCheckFun, State) -> %% find the number of unacked messages. lists:foldl( fun (Seg, {Segments2, CountAcc}) -> - io:format("Recovering: ~p~n", [Seg]), Segment = #segment { unacked = UnackedCount } = recover_segment(ContainsCheckFun, CleanShutdown, segment_find_or_new(Seg, Dir, Segments2)), @@ -585,7 +584,6 @@ maybe_flush_journal(State) -> State. flush_journal(State = #qistate { segments = Segments }) -> - io:format("Flushing journal~n"), Segments1 = segment_fold( fun (#segment { unacked = 0, path = Path }, SegmentsN) -> @@ -711,8 +709,7 @@ all_segment_nums(#qistate { dir = Dir, segments = Segments }) -> segment_find_or_new(Seg, Dir, Segments) -> case segment_find(Seg, Segments) of {ok, Segment} -> Segment; - error -> io:format("New Seg~n"), - SegName = integer_to_list(Seg) ++ ?SEGMENT_EXTENSION, + error -> SegName = integer_to_list(Seg) ++ ?SEGMENT_EXTENSION, Path = filename:join(Dir, SegName), #segment { num = Seg, path = Path, @@ -808,10 +805,8 @@ segment_entries_foldr(Fun, Init, %% %% Does not do any combining with the journal at all. load_segment(KeepAcked, #segment { path = Path }) -> - io:format("path: ~p~n", [Path]), case filelib:is_file(Path) of - false -> io:format("Creating new~n"), - {array_new(), 0}; + false -> {array_new(), 0}; true -> {ok, Hdl} = file_handle_cache:open(Path, ?READ_MODE, []), {ok, 0} = file_handle_cache:position(Hdl, bof), Res = load_segment_entries(KeepAcked, Hdl, array_new(), 0), @@ -820,7 +815,6 @@ load_segment(KeepAcked, #segment { path = Path }) -> end. load_segment_entries(KeepAcked, Hdl, SegEntries, UnackedCount) -> - io:format("Loading seg entries"), case file_handle_cache:read(Hdl, ?REL_SEQ_ONLY_ENTRY_LENGTH_BYTES) of {ok, <<?PUBLISH_PREFIX:?PUBLISH_PREFIX_BITS, IsPersistentNum:1, RelSeq:?REL_SEQ_BITS>>} -> diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c8d3c6e4e8..aee8d47b36 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -370,7 +370,6 @@ stop_msg_store() -> ok = rabbit_sup:stop_child(?TRANSIENT_MSG_STORE). init(QueueName, IsDurable, Recover) -> - io:format("Initing ~p ~p~n", [QueueName, Recover]), {DeltaCount, Terms, IndexState} = rabbit_queue_index:init( QueueName, Recover, @@ -378,7 +377,6 @@ init(QueueName, IsDurable, Recover) -> fun (Guid) -> rabbit_msg_store:contains(?PERSISTENT_MSG_STORE, Guid) end), - io:format("Inited: ~p~n", [DeltaCount]), {LowSeqId, NextSeqId, IndexState1} = rabbit_queue_index:bounds(IndexState), {PRef, TRef, Terms1} = @@ -958,7 +956,6 @@ tx_commit_index(State = #vqstate { on_sync = #sync { PAcks = lists:append(SPAcks), Acks = lists:append(SAcks), Pubs = lists:append(lists:reverse(SPubs)), - io:format("Committing: ~p~n", [length(Pubs)]), {SeqIds, State1 = #vqstate { index_state = IndexState }} = lists:foldl( fun ({Msg = #basic_message { is_persistent = IsPersistent }, MsgProperties}, |