diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-06-27 11:49:06 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-06-27 11:49:06 +0100 |
| commit | a77becc83e0f9265b1f2d8ef2d3eb04dfc93c879 (patch) | |
| tree | 4eb776ecd0b016e9893a4bae9f751bcee6bbbf0f /src | |
| parent | 3ef67c915ebf0f516826f42ff758bc57fea9bcca (diff) | |
| download | rabbitmq-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.erl | 10 |
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(), |
