diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-01-30 11:23:36 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-01-30 11:23:36 +0000 |
| commit | cd2404133611a62457de590e0d3c033af125cd76 (patch) | |
| tree | 7a66f7514e6795ced686d2223c6fee8ed97a17d6 | |
| parent | 5be76fe68466b8bde658f4446ef420f5a5aa1d97 (diff) | |
| download | rabbitmq-server-bug22470.tar.gz | |
produce only one log entry for abnormal connection closurebug22470
instead of two
| -rw-r--r-- | src/rabbit_reader.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 864d7795..e642c20d 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -225,15 +225,15 @@ start_connection(Parent, ChannelSupSupPid, Collector, StartHeartbeatFun, Deb, try recvloop(Deb, switch_callback(rabbit_event:init_stats_timer( State, #v1.stats_timer), - handshake, 8)) + handshake, 8)), + log(info, "closing AMQP connection ~p (~s)~n", [self(), ConnStr]) catch Ex -> log(case Ex of connection_closed_abruptly -> warning; _ -> error - end, "exception on AMQP connection ~p (~s)~n~p~n", + end, "closing AMQP connection ~p (~s):~n~p~n", [self(), ConnStr, Ex]) after - log(info, "closing AMQP connection ~p (~s)~n", [self(), ConnStr]), %% We don't close the socket explicitly. The reader is the %% controlling process and hence its termination will close %% the socket. Furthermore, gen_tcp:close/1 waits for pending |