diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 12:52:57 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 12:52:57 +0000 |
| commit | ba27272b077f24c4ba3553fbe57ceb40b58d255b (patch) | |
| tree | 60d6c06653f1632a69ce150b71c6639063f0d48c /src | |
| parent | d59b178941c58619e487e252f8174f6884957a6c (diff) | |
| download | rabbitmq-server-git-ba27272b077f24c4ba3553fbe57ceb40b58d255b.tar.gz | |
correct another return
Diffstat (limited to 'src')
| -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 d4cd0586da..e33c6de2cb 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -507,14 +507,13 @@ terminate_channels(#v1{channel_count = ChannelCount} = State) -> TimerRef = erlang:send_after(Timeout, self(), cancel_wait), wait_for_channel_termination(ChannelCount, TimerRef, State). -wait_for_channel_termination(0, TimerRef, _State) -> +wait_for_channel_termination(0, TimerRef, State) -> case erlang:cancel_timer(TimerRef) of false -> receive - cancel_wait -> ok + cancel_wait -> State end; - _ -> ok + _ -> State end; - wait_for_channel_termination(N, TimerRef, State) -> receive {'DOWN', _MRef, process, ChPid, Reason} -> |