diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2015-03-03 17:33:07 +0100 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2015-03-03 17:33:07 +0100 |
| commit | e03e7da3115c54e8a7ca54ad3cc2c4c74f7ed417 (patch) | |
| tree | 5b56551036f942314a389fdc1d893231c7796fd8 /src | |
| parent | 280de0c58d388b1eb21a153f8dc8e94aa0a2c3f6 (diff) | |
| parent | 3b3aa4872af7c7baa7d07f22edcadecf7b0a144d (diff) | |
| download | rabbitmq-server-git-e03e7da3115c54e8a7ca54ad3cc2c4c74f7ed417.tar.gz | |
Merge branch 'bug26622' into stable
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_node_monitor.erl | 22 |
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. %%---------------------------------------------------------------------------- |
