diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-06-26 11:40:49 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-06-26 11:40:49 +0100 |
| commit | 8f03eeac35af88777f102e9a07e02077a747ec15 (patch) | |
| tree | facf3898a432dcfe20a79f5abf2240dd023266c7 /src | |
| parent | 78dea9b92973e60b72317902be40659f647af5ce (diff) | |
| download | rabbitmq-server-git-8f03eeac35af88777f102e9a07e02077a747ec15.tar.gz | |
Maybe better name?
Diffstat (limited to 'src')
| -rw-r--r-- | src/gm.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_coordinator.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/src/gm.erl b/src/gm.erl index 9d7bed8c99..f88ed18fbf 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -664,7 +664,7 @@ handle_info({'DOWN', MRef, process, _Pid, Reason}, case {Member, Reason} of {undefined, _} -> noreply(State); - {_, {shutdown, do_not_heal}} -> + {_, {shutdown, ring_shutdown}} -> noreply(State); _ -> View1 = diff --git a/src/rabbit_mirror_queue_coordinator.erl b/src/rabbit_mirror_queue_coordinator.erl index 8d2531e6cd..3e058793ec 100644 --- a/src/rabbit_mirror_queue_coordinator.erl +++ b/src/rabbit_mirror_queue_coordinator.erl @@ -407,7 +407,7 @@ handle_msg([CPid], _From, {ensure_monitoring, _Pids} = Msg) -> ok = gen_server2:cast(CPid, Msg); handle_msg([CPid], _From, {delete_and_terminate, _Reason} = Msg) -> ok = gen_server2:cast(CPid, Msg), - {stop, {shutdown, do_not_heal}}; + {stop, {shutdown, ring_shutdown}}; handle_msg([_CPid], _From, _Msg) -> ok. diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 4bef2b7d01..03fafc3e5a 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -353,7 +353,7 @@ handle_msg([SPid], _From, {process_death, Pid}) -> inform_deaths(SPid, [Pid]); handle_msg([CPid], _From, {delete_and_terminate, _Reason} = Msg) -> ok = gen_server2:cast(CPid, {gm, Msg}), - {stop, {shutdown, do_not_heal}}; + {stop, {shutdown, ring_shutdown}}; handle_msg([SPid], _From, Msg) -> ok = gen_server2:cast(SPid, {gm, Msg}). |