diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2010-11-03 15:19:05 +0000 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2010-11-03 15:19:05 +0000 |
| commit | 1a45fb36b79da3c4c2531f36fd3647fd0e8b20ca (patch) | |
| tree | cf38d3c5e415684b060f8e7beef04405c2c0523a | |
| parent | a14752efdaac19e4f771673e06c26c7b2037db39 (diff) | |
| download | rabbitmq-server-1a45fb36b79da3c4c2531f36fd3647fd0e8b20ca.tar.gz | |
cleaned up some io:format
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
2 files changed, 1 insertions, 8 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 9699ac32..2cf7f268 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1026,9 +1026,6 @@ handle_info(Info, State) -> ?LOGDEBUG("Info in queue: ~p~n", [Info]), {stop, {unhandled_info, Info}, State}. -handle_post_hibernate(_) -> - io:format("hello~n"). - handle_pre_hibernate(State = #q{backing_queue_state = undefined}) -> {hibernate, State}; handle_pre_hibernate(State = #q{backing_queue = BQ, diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 491d4e38..3a8a913f 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -692,7 +692,6 @@ set_ram_duration_target(DurationTarget, #rates { avg_egress = AvgAckEgressRate, avg_ingress = AvgAckIngressRate }, target_ram_msg_count = TargetRamMsgCount }) -> - io:format("set:~p~n", [DurationTarget]), Rate = AvgEgressRate + AvgIngressRate + AvgAckEgressRate + AvgAckIngressRate, TargetRamMsgCount1 = @@ -705,7 +704,7 @@ set_ram_duration_target(DurationTarget, (TargetRamMsgCount =/= infinity andalso TargetRamMsgCount1 >= TargetRamMsgCount) of true -> State1; - false -> io:format("Reducing~n"), reduce_memory_use(State1) + false -> reduce_memory_use(State1) end). ram_duration(State = #vqstate { @@ -722,7 +721,6 @@ ram_duration(State = #vqstate { ram_msg_count_prev = RamMsgCountPrev, ram_ack_index = RamAckIndex, ram_ack_count_prev = RamAckCountPrev }) -> - io:format("Ram duration~n"), Now = now(), {AvgEgressRate, Egress1} = update_rate(Now, Timestamp, OutCount, Egress), {AvgIngressRate, Ingress1} = update_rate(Now, Timestamp, InCount, Ingress), @@ -744,7 +742,6 @@ ram_duration(State = #vqstate { AvgAckEgressRate + AvgAckIngressRate)) end, - io:format("Duration:~p~n", [Duration]), {Duration, State #vqstate { rates = Rates #rates { egress = Egress1, @@ -1372,7 +1369,6 @@ reduce_ack_memory_use(_AckFun, State = #vqstate { target_ram_msg_count = infinit reduce_ack_memory_use(AckFun, State = #vqstate {target_ram_msg_count = TargetRamMsgCount, ram_msg_count = RamMsgCount, ram_ack_index = RamAckIndex} ) -> - io:format("RAI:~p,TRMC:~p,RMC:~p~n", [gb_trees:size(RamAckIndex), TargetRamMsgCount, RamMsgCount]), PermittedAckCount = case TargetRamMsgCount > RamMsgCount of true -> TargetRamMsgCount - RamMsgCount; false -> 0 |