summaryrefslogtreecommitdiff
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
commit6889a6b02c7820b9bcd0e89c6606d7474c569131 (patch)
treec991d3039ff5d75cb586965fb298d4f939be115b
parentd17b23652ce8d164e7bd86d0185474b2798d5764 (diff)
downloadrabbitmq-server-6889a6b02c7820b9bcd0e89c6606d7474c569131.tar.gz
Ignore normal exits; do not try to change the ring topology as it shuts down.
-rw-r--r--src/gm.erl8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 30fcdc5d..a046d3ef 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 =