summaryrefslogtreecommitdiff
path: root/src/gm.erl
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-06-25 15:45:41 +0100
committerSimon MacMullen <simon@rabbitmq.com>2012-06-25 15:45:41 +0100
commitc652c08dc32b963d8ea1a24aaa92db7f14d989b6 (patch)
treec991d3039ff5d75cb586965fb298d4f939be115b /src/gm.erl
parentbab700b30c7780e328762fce77da82dc0529117c (diff)
downloadrabbitmq-server-git-c652c08dc32b963d8ea1a24aaa92db7f14d989b6.tar.gz
Ignore normal exits; do not try to change the ring topology as it shuts down.
Diffstat (limited to 'src/gm.erl')
-rw-r--r--src/gm.erl8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 30fcdc5d86..a046d3ef78 100644
--- a/src/gm.erl
+++ b/src/gm.erl
@@ -647,7 +647,7 @@ handle_info(flush, State) ->
noreply(
flush_broadcast_buffer(State #state { broadcast_timer = undefined }));
-handle_info({'DOWN', MRef, process, _Pid, _Reason},
+handle_info({'DOWN', MRef, process, _Pid, Reason},
State = #state { self = Self,
left = Left,
right = Right,
@@ -661,8 +661,10 @@ handle_info({'DOWN', MRef, process, _Pid, _Reason},
{_, {Member1, MRef}} -> Member1;
_ -> undefined
end,
- case Member of
- undefined ->
+ case {Member, Reason} of
+ {undefined, _} ->
+ noreply(State);
+ {_, normal} ->
noreply(State);
_ ->
View1 =