summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2009-08-10 15:50:50 +0100
committerMatthew Sackman <matthew@lshift.net>2009-08-10 15:50:50 +0100
commit31c9a6fa23b285268dd6d886b14bb0b1f1a42cbf (patch)
tree1ba06374697e4208c9482a7f50c57acfe0f63877 /src
parente92691cee2acdb0a6ce1072457998a5e7a56011b (diff)
downloadrabbitmq-server-git-31c9a6fa23b285268dd6d886b14bb0b1f1a42cbf.tar.gz
tidying
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_channel.erl2
-rw-r--r--src/rabbit_reader.erl2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index c30024a6eb..16b7c938ca 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -159,7 +159,7 @@ handle_cast({conserve_memory, Conserve}, State) ->
handle_info({'EXIT', WriterPid, Reason = {writer, send_failed, _Error}},
State = #ch{writer_pid = WriterPid}) ->
- State#ch.reader_pid ! {channel_unexpected_exit, Reason},
+ State#ch.reader_pid ! {channel_exit, State#ch.channel, Reason},
{stop, normal, State};
handle_info({'EXIT', _Pid, Reason}, State) ->
{stop, Reason, State};
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl
index 91732e0da7..7be9281258 100644
--- a/src/rabbit_reader.erl
+++ b/src/rabbit_reader.erl
@@ -286,7 +286,7 @@ mainloop(Parent, Deb, State = #v1{sock= Sock, recv_ref = Ref}) ->
%% since this termination is initiated by our parent it is
%% probably more important to exit quickly.
exit(Reason);
- {channel_unexpected_exit, E = {writer, send_failed, _Error}} ->
+ {channel_exit, _Chan, E = {writer, send_failed, _Error}} ->
throw(E);
{channel_exit, Channel, Reason} ->
mainloop(Parent, Deb, handle_channel_exit(Channel, Reason, State));