diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-15 16:14:14 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-15 16:14:14 +0000 |
| commit | 6ed0fcc1dfa1b3bd0fd4149722fe08715aa050ed (patch) | |
| tree | 6bc9f17cac3a937af94f64a1c95c13794c5f8b0c /src | |
| parent | aca93ada1d1dbfe6e3c425640a226261963a872a (diff) | |
| download | rabbitmq-server-git-6ed0fcc1dfa1b3bd0fd4149722fe08715aa050ed.tar.gz | |
make reader's handle_dependent_exit clearer
- handle the no-op case (controlled exit of a channel we've forgotten
about already) explicitly
- better clause order and formatting.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index af7aac6f63..f249bc9b67 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -437,13 +437,13 @@ close_connection(State = #v1{queue_collector = Collector, handle_dependent_exit(ChPid, Reason, State) -> case {channel_cleanup(ChPid), termination_kind(Reason)} of - {undefined, uncontrolled} -> - exit({abnormal_dependent_exit, ChPid, Reason}); - {_Channel, controlled} -> - maybe_close(control_throttle(State)); - {Channel, uncontrolled} -> - maybe_close(handle_exception(control_throttle(State), - Channel, Reason)) + {undefined, controlled} -> State; + {undefined, uncontrolled} -> exit({abnormal_dependent_exit, + ChPid, Reason}); + {_Channel, controlled} -> maybe_close(control_throttle(State)); + {Channel, uncontrolled} -> maybe_close( + handle_exception(control_throttle(State), + Channel, Reason)) end. terminate_channels() -> |