diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 12:07:01 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 12:07:01 +0000 |
| commit | f6565baabee42c64ea585047a7421ed837827e99 (patch) | |
| tree | e33cd2a30c88c13d694213dfe28723e6fc08e875 /src | |
| parent | 6dca0e6a6169eb346dcf6bf25fbf29aa5a48dc65 (diff) | |
| download | rabbitmq-server-git-f6565baabee42c64ea585047a7421ed837827e99.tar.gz | |
simplify (and stay below column limit)
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index bcf588f09a..687e638a69 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -634,12 +634,11 @@ create_channel(Channel, State) -> channel_cleanup(ChPid, State = #v1{channel_count = ChannelCount}) -> case get({ch_pid, ChPid}) of undefined -> {undefined, State}; - {Channel, MRef} -> State1 = State#v1{channel_count = (ChannelCount - 1)}, - credit_flow:peer_down(ChPid), + {Channel, MRef} -> credit_flow:peer_down(ChPid), erase({channel, Channel}), erase({ch_pid, ChPid}), erlang:demonitor(MRef, [flush]), - {Channel, State1} + {Channel, State#v1{channel_count = ChannelCount - 1}} end. all_channels() -> [ChPid || {{ch_pid, ChPid}, _ChannelMRef} <- get()]. |