diff options
| author | Michael Klishin <michael@rabbitmq.com> | 2013-12-12 13:03:21 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@rabbitmq.com> | 2013-12-12 13:03:21 +0400 |
| commit | 781437b173a46ec4b00027b416c3a607e84ed849 (patch) | |
| tree | dc4e7a709124ddee93c1906b8bf56ffb074ef0bf | |
| parent | 559a25853cf79020bb2cb4146f8b854346a68e8d (diff) | |
| download | rabbitmq-server-781437b173a46ec4b00027b416c3a607e84ed849.tar.gz | |
Compile
| -rw-r--r-- | src/rabbit_reader.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 8a3e0015..d4acc697 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -327,7 +327,7 @@ handle_other({conserve_resources, Source, Conserve}, end, Throttle1 = Throttle#throttle{alarmed_by = CR1}, control_throttle(State#v1{throttle = Throttle1}); -handle_other({channel_closing, ChPid}, State) -> +handle_other({channel_closing, ChPid}, State = #v1{channel_count = ChannelCount}) -> ok = rabbit_channel:ready_for_close(ChPid), channel_cleanup(ChPid), maybe_close(control_throttle(State#v1{channel_count = (ChannelCount - 1)})); @@ -707,7 +707,8 @@ process_frame(Frame, Channel, State) -> end end. -post_process_frame({method, 'channel.close_ok', _}, ChPid, State) -> +post_process_frame({method, 'channel.close_ok', _}, ChPid, + State = #v1{channel_count = ChannelCount}) -> channel_cleanup(ChPid), %% This is not strictly necessary, but more obviously %% correct. Also note that we do not need to call maybe_close/1 |