diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-07-14 13:04:04 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-07-14 13:04:04 +0100 |
| commit | e039aa57fca1722680dc7334fc153b126b866d27 (patch) | |
| tree | 1c24847d55a97ba7166ff2251dd2cd33095a4619 | |
| parent | 6df92bb9eb2cf33771942f6a2d48ef24b480e9b8 (diff) | |
| download | rabbitmq-server-git-e039aa57fca1722680dc7334fc153b126b866d27.tar.gz | |
Make this more explicit. I *think* it's TRTTD.
| -rw-r--r-- | src/mirrored_supervisor.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/mirrored_supervisor.erl b/src/mirrored_supervisor.erl index 85dc398379..07c0ca0690 100644 --- a/src/mirrored_supervisor.erl +++ b/src/mirrored_supervisor.erl @@ -349,6 +349,7 @@ handle_info({'DOWN', _Ref, process, Pid, Reason}, Members = ?PG2:get_members(Group), demonitor_all(State), [gen_server2:call(P, demonitor_all) || P <- Members -- [self()]], + %% NB, no infinity here ----------^ because this could deadlock otherwise [gen_server2:cast(P, {die, Reason}) || P <- Members], {noreply, State}; |