diff options
author | Emile Joubert <emile@rabbitmq.com> | 2011-11-02 11:19:49 +0000 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2011-11-02 11:19:49 +0000 |
commit | 22644449a77e4e082dd627e217e3f79536e18e35 (patch) | |
tree | 376b75cd48c0c9b22040fee98f4eb76a6f053328 | |
parent | 90e503913273ac1ee2ae61994313eb9da1555e34 (diff) | |
download | rabbitmq-server-22644449a77e4e082dd627e217e3f79536e18e35.tar.gz |
Indent correctly
-rw-r--r-- | src/supervisor2.erl | 52 |
1 files changed, 28 insertions, 24 deletions
diff --git a/src/supervisor2.erl b/src/supervisor2.erl index 3b66d4b8..44f3bb76 100644 --- a/src/supervisor2.erl +++ b/src/supervisor2.erl @@ -649,7 +649,6 @@ terminate_children([], _SupName, Res) -> Res. terminate_simple_children(Child, Dynamics, SupName) -> - ReportError = shutdown_error_reporter(SupName), {ExitReason, Timeout} = case Child#child.shutdown of brutal_kill -> {kill, infinity}; Time -> {shutdown, Time} @@ -668,7 +667,7 @@ terminate_simple_children(Child, Dynamics, SupName) -> receive {timeout, Ref} -> [exit(P, kill) || P <- Pids -- dict:fetch_keys(Replies)], - receive {'DOWN', _, process, Pid, Reason} -> + receive {'DOWN', _MRef, process, Pid, Reason} -> {dict:append(Pid, {error, Reason}, Replies), true} end; {'DOWN', _MRef, process, Pid, Reason} -> @@ -681,28 +680,33 @@ terminate_simple_children(Child, Dynamics, SupName) -> end end end, {dict:new(), false}, Pids), - timer:cancel(TRef), - RestartPerm = restart_permanent(Child#child.restart_type), - ReportAcc = fun (NormalErrorFun) -> - fun (Pid, ok, Acc) -> - Acc; - (Pid, {error, normal}, Acc) -> - NormalErrorFun(Pid), - Acc; - (Pid, {error, Reason}, Acc) -> - ReportError(Reason, Child#child{pid = Pid}), - Acc - end - end, - dict:fold(case RestartPerm of - true -> - ReportAcc(fun (Pid) -> - ReportError(normal, Child#child{pid = Pid}) - end); - false -> - ReportAcc(fun rabbit_misc:const_ok/0) - end, ok, Replies), - ok. + timer:cancel(TRef), + receive + {timeout, Ref} -> ok + after + 0 -> ok + end, + ReportError = shutdown_error_reporter(SupName), + ReportAcc = fun (NormalErrorFun) -> + fun (Pid, ok, Acc) -> + Acc; + (Pid, {error, normal}, Acc) -> + NormalErrorFun(Pid), + Acc; + (Pid, {error, Reason}, Acc) -> + ReportError(Reason, Child#child{pid = Pid}), + Acc + end + end, + dict:fold(case restart_permanent(Child#child.restart_type) of + true -> + ReportAcc(fun (Pid) -> + ReportError(normal, Child#child{pid = Pid}) + end); + false -> + ReportAcc(fun (_Pid) -> ok end) + end, ok, Replies), + ok. child_tally(Shutdown, Reason, Timedout) when Shutdown == brutal_kill andalso Reason == killed andalso |