summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-07-02 15:47:43 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-07-02 15:47:43 +0100
commitf4b7a1380468081f0b5baa58dba0049111df2c5e (patch)
treef048b7571235b54834b5e883ac55ad88150a64b5 /src
parent654ceb7ac2260ba5fb6b36827764a06ff88568bd (diff)
downloadrabbitmq-server-git-f4b7a1380468081f0b5baa58dba0049111df2c5e.tar.gz
cosmetic
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_reader.erl6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl
index f2a903dcca..de8ebfb4e4 100644
--- a/src/rabbit_reader.erl
+++ b/src/rabbit_reader.erl
@@ -678,11 +678,13 @@ handle_method0(#'connection.close'{},
State = #v1{connection_state = running}) ->
lists:foreach(fun rabbit_framing_channel:shutdown/1, all_channels()),
maybe_close(State#v1{connection_state = closing});
-handle_method0(#'connection.close'{}, State = #v1{connection_state = CS})
+handle_method0(#'connection.close'{},
+ State = #v1{connection_state = CS,
+ sock = Sock})
when CS =:= closing; CS =:= closed ->
%% We're already closed or closing, so we don't need to cleanup
%% anything.
- ok = send_on_channel0(State#v1.sock, #'connection.close_ok'{}),
+ ok = send_on_channel0(Sock, #'connection.close_ok'{}),
State;
handle_method0(#'connection.close_ok'{},
State = #v1{connection_state = closed}) ->