summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2012-09-18 13:18:20 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2012-09-18 13:18:20 +0100
commit8e9ccd21664774346cebb2901e3d67f34334e6cf (patch)
treeebf5c4156c312269ab7127377bd60995b4cc86f1
parent84dac81cbf3c5f23d06da456382651b68fab52bc (diff)
downloadrabbitmq-server-git-8e9ccd21664774346cebb2901e3d67f34334e6cf.tar.gz
cosmetic(ish)
-rw-r--r--src/rabbit_mnesia.erl33
1 files changed, 16 insertions, 17 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index b3de0d163a..735a744b66 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -1065,20 +1065,6 @@ is_running_remote() ->
{proplists:is_defined(rabbit, application:which_applications(infinity)),
node()}.
-is_only_node(Node, Nodes) -> ordsets:to_list(Nodes) == [Node].
-
-is_only_node(Nodes) -> is_only_node(node(), Nodes).
-
-is_only_disc_node() -> is_only_node(clustered_disc_nodes()).
-
-me_in_nodes(Nodes) -> ordsets:is_element(node(), Nodes).
-
-nodes_incl_me(Nodes) -> ordsets:add_element(node(), Nodes).
-
-nodes_excl_me(Nodes) -> ordsets:del_element(node(), Nodes).
-
-empty_set(Set) -> ordsets:size(Set) =:= 0.
-
check_consistency(OTP, Rabbit) ->
rabbit_misc:sequence_error(
[check_otp_consistency(OTP), check_rabbit_consistency(Rabbit)]).
@@ -1090,15 +1076,14 @@ check_consistency(OTP, Rabbit, Node, Status) ->
check_nodes_consistency(Node, Status)]).
check_nodes_consistency(Node, RemoteStatus = {RemoteAllNodes, _, _}) ->
- ThisNode = node(),
- case ordsets:is_element(ThisNode, RemoteAllNodes) of
+ case me_in_nodes(RemoteAllNodes) of
true ->
{ok, RemoteStatus};
false ->
{error, {inconsistent_cluster,
rabbit_misc:format("Node ~p thinks it's clustered "
"with node ~p, but ~p disagrees",
- [ThisNode, Node, Node])}}
+ [node(), Node, Node])}}
end.
check_version_consistency(This, Remote, _) when This =:= Remote ->
@@ -1142,6 +1127,20 @@ find_good_node([Node | Nodes]) ->
end
end.
+is_only_node(Node, Nodes) -> ordsets:to_list(Nodes) == [Node].
+
+is_only_node(Nodes) -> is_only_node(node(), Nodes).
+
+is_only_disc_node() -> is_only_node(clustered_disc_nodes()).
+
+me_in_nodes(Nodes) -> ordsets:is_element(node(), Nodes).
+
+nodes_incl_me(Nodes) -> ordsets:add_element(node(), Nodes).
+
+nodes_excl_me(Nodes) -> ordsets:del_element(node(), Nodes).
+
+empty_set(Set) -> ordsets:size(Set) =:= 0.
+
e(Tag) -> throw({error, {Tag, error_description(Tag)}}).
error_description(clustering_only_disc_node) ->