diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2012-02-05 09:48:11 +0000 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-02-05 09:48:11 +0000 |
commit | 34f23d8e5f42591e5748f7244c448819b6ab62be (patch) | |
tree | fd7fc801ccf2eee7587cc8269a3ad547c169ce5c | |
parent | 8c5bc5236bc78f2cb97bee664c00bf27524316c6 (diff) | |
download | rabbitmq-server-34f23d8e5f42591e5748f7244c448819b6ab62be.tar.gz |
shrink
-rw-r--r-- | src/rabbit_reader.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index fcdbdb6a..1602cc2b 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -265,10 +265,9 @@ mainloop(Deb, State = #v1{sock = Sock, buf = Buf, buf_len = BufLen}) -> {data, Data} -> recvloop(Deb, State#v1{buf = [Data | Buf], buf_len = BufLen + size(Data), pending_recv = false}); - closed -> if State#v1.connection_state =:= closed -> - State; - true -> - throw(connection_closed_abruptly) + closed -> case State#v1.connection_state of + closed -> State; + _ -> throw(connection_closed_abruptly) end; {error, Reason} -> throw({inet_error, Reason}); {other, Other} -> handle_other(Other, Deb, State) |