summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorJean-Sébastien Pédron <jean-sebastien@rabbitmq.com>2015-03-03 17:33:07 +0100
committerJean-Sébastien Pédron <jean-sebastien@rabbitmq.com>2015-03-03 17:33:07 +0100
commite03e7da3115c54e8a7ca54ad3cc2c4c74f7ed417 (patch)
tree5b56551036f942314a389fdc1d893231c7796fd8 /src
parent280de0c58d388b1eb21a153f8dc8e94aa0a2c3f6 (diff)
parent3b3aa4872af7c7baa7d07f22edcadecf7b0a144d (diff)
downloadrabbitmq-server-git-e03e7da3115c54e8a7ca54ad3cc2c4c74f7ed417.tar.gz
Merge branch 'bug26622' into stable
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_node_monitor.erl22
1 files changed, 12 insertions, 10 deletions
diff --git a/src/rabbit_node_monitor.erl b/src/rabbit_node_monitor.erl
index 82a7a89be9..2fab29996b 100644
--- a/src/rabbit_node_monitor.erl
+++ b/src/rabbit_node_monitor.erl
@@ -216,22 +216,24 @@ pause_minority_guard() ->
undefined ->
{ok, M} = application:get_env(rabbit, cluster_partition_handling),
case M of
- pause_minority -> pause_minority_guard([]);
+ pause_minority -> pause_minority_guard([], ok);
_ -> put(pause_minority_guard, not_minority_mode),
ok
end;
- {minority_mode, Nodes} ->
- pause_minority_guard(Nodes)
+ {minority_mode, Nodes, LastState} ->
+ pause_minority_guard(Nodes, LastState)
end.
-pause_minority_guard(LastNodes) ->
+pause_minority_guard(LastNodes, LastState) ->
case nodes() of
- LastNodes -> ok;
- _ -> put(pause_minority_guard, {minority_mode, nodes()}),
- case majority() of
- false -> pausing;
- true -> ok
- end
+ LastNodes -> LastState;
+ _ -> NewState = case majority() of
+ false -> pausing;
+ true -> ok
+ end,
+ put(pause_minority_guard,
+ {minority_mode, nodes(), NewState}),
+ NewState
end.
%%----------------------------------------------------------------------------