summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorFrancesco Mazzoli <francesco@rabbitmq.com>2012-06-27 11:49:06 +0100
committerFrancesco Mazzoli <francesco@rabbitmq.com>2012-06-27 11:49:06 +0100
commita77becc83e0f9265b1f2d8ef2d3eb04dfc93c879 (patch)
tree4eb776ecd0b016e9893a4bae9f751bcee6bbbf0f /src
parent3ef67c915ebf0f516826f42ff758bc57fea9bcca (diff)
downloadrabbitmq-server-git-a77becc83e0f9265b1f2d8ef2d3eb04dfc93c879.tar.gz
check if only running disc node only in the required places
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mnesia.erl10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 350c737664..feb9b2874b 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -728,13 +728,13 @@ on_node_up(Node, IsDiscNode) ->
false -> DiscNodes
end,
ordsets:add_element(Node, RunningNodes)}),
- case is_only_disc_node(Node) of
+ case is_only_running_disc_node(Node) of
true -> rabbit_log:info("cluster contains disc nodes again~n");
false -> ok
end.
on_node_down(Node) ->
- case is_only_disc_node(Node) of
+ case is_only_running_disc_node(Node) of
true -> rabbit_log:info("only running disc node went down~n");
false -> ok
end,
@@ -1094,8 +1094,10 @@ wait_for(Condition) ->
timer:sleep(1000).
is_only_disc_node(Node) ->
- Nodes = running_clustered_disc_nodes(),
- [Node] =:= Nodes.
+ [Node] =:= all_clustered_disc_nodes().
+
+is_only_running_disc_node(Node) ->
+ [Node] =:= running_clustered_disc_nodes().
start_mnesia() ->
check_cluster_consistency(),