diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 11:57:16 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 11:57:16 +0000 |
| commit | 808120d5aac49dd26cc67168313f4903e7fadd3e (patch) | |
| tree | c083f55216ab301cf63541b1d9381f68309bc5cb | |
| parent | 12c1faf6b58fd9b51ff51c4ed26e2472ed6d2803 (diff) | |
| download | rabbitmq-server-git-808120d5aac49dd26cc67168313f4903e7fadd3e.tar.gz | |
refactor: simplify and reduce distance to 'default'
| -rw-r--r-- | src/rabbit_reader.erl | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 7fac4f80a0..d4ae9655d4 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -488,16 +488,15 @@ close_connection(State = #v1{queue_collector = Collector, State#v1{connection_state = closed}. handle_dependent_exit(ChPid, Reason, State) -> - case {channel_cleanup(ChPid, State), termination_kind(Reason)} of - {{undefined, State1}, controlled} -> - State1; - {{undefined, _}, uncontrolled} -> - exit({abnormal_dependent_exit, ChPid, Reason}); - {{_, State1}, controlled} -> - maybe_close(control_throttle(State1)); - {{Channel, State1}, uncontrolled} -> - State2 = handle_exception(State1, Channel, Reason), - maybe_close(control_throttle(State2)) + {Channel, State1} = channel_cleanup(ChPid, State), + case {Channel, termination_kind(Reason)} of + {undefined, controlled} -> State1; + {undefined, uncontrolled} -> exit({abnormal_dependent_exit, + ChPid, Reason}); + {_, controlled} -> maybe_close(control_throttle(State1)); + {_, uncontrolled} -> State2 = handle_exception( + State1, Channel, Reason), + maybe_close(control_throttle(State2)) end. terminate_channels(State) -> |
