summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@lshift.net>2009-02-17 14:12:12 +0000
committerMatthias Radestock <matthias@lshift.net>2009-02-17 14:12:12 +0000
commit3f5c0fce99c119abbe27ca1dd05e4bf57f27db3e (patch)
treec27f9653ea685fa8419a6fbfe5d391e3f9ed5e63 /src
parent7637fbde4cae03f534dc53a6deb9bc3589b57229 (diff)
parentdf8eb5505a9822b6d085765b67fd118e9727dae2 (diff)
downloadrabbitmq-server-git-3f5c0fce99c119abbe27ca1dd05e4bf57f27db3e.tar.gz
merge bug20374 into default
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_reader.erl8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl
index 12ee299ea5..9f642e3540 100644
--- a/src/rabbit_reader.erl
+++ b/src/rabbit_reader.erl
@@ -231,8 +231,12 @@ start_connection(Parent, Deb, ClientSock) ->
connection_state = pre_init},
handshake, 8))
catch
- Ex -> rabbit_log:error("error on TCP connection ~p from ~s:~p~n~p~n",
- [self(), PeerAddressS, PeerPort, Ex])
+ Ex -> (if Ex == connection_closed_abruptly ->
+ fun rabbit_log:warning/2;
+ true ->
+ fun rabbit_log:error/2
+ end)("exception on TCP connection ~p from ~s:~p~n~p~n",
+ [self(), PeerAddressS, PeerPort, Ex])
after
rabbit_log:info("closing TCP connection ~p from ~s:~p~n",
[self(), PeerAddressS, PeerPort]),