diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-18 13:18:20 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-18 13:18:20 +0100 |
| commit | 8e9ccd21664774346cebb2901e3d67f34334e6cf (patch) | |
| tree | ebf5c4156c312269ab7127377bd60995b4cc86f1 /src | |
| parent | 84dac81cbf3c5f23d06da456382651b68fab52bc (diff) | |
| download | rabbitmq-server-git-8e9ccd21664774346cebb2901e3d67f34334e6cf.tar.gz | |
cosmetic(ish)
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mnesia.erl | 33 |
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) -> |
