diff options
| author | Michael Klishin <michael@rabbitmq.com> | 2013-12-12 13:01:55 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@rabbitmq.com> | 2013-12-12 13:01:55 +0400 |
| commit | 9f23f517d3d0a377a9e6c7d0c875d6d41e8ba636 (patch) | |
| tree | d5d90aa0de59391a51ba673b4d02051b31f3467c | |
| parent | d3b1edbc7880d4e0aca6b222615ef6bc97eaa516 (diff) | |
| download | rabbitmq-server-git-9f23f517d3d0a377a9e6c7d0c875d6d41e8ba636.tar.gz | |
Decrement channel counter here, too
| -rw-r--r-- | src/rabbit_reader.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index dbae0db51a..8a3e001512 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -712,7 +712,7 @@ post_process_frame({method, 'channel.close_ok', _}, ChPid, State) -> %% This is not strictly necessary, but more obviously %% correct. Also note that we do not need to call maybe_close/1 %% since we cannot possibly be in the 'closing' state. - control_throttle(State); + control_throttle(State#v1{channel_count = (ChannelCount - 1)}); post_process_frame({content_header, _, _, _, _}, _ChPid, State) -> maybe_block(State); post_process_frame({content_body, _}, _ChPid, State) -> |