summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrancesco Mazzoli <francesco@rabbitmq.com>2012-10-24 16:44:15 +0100
committerFrancesco Mazzoli <francesco@rabbitmq.com>2012-10-24 16:44:15 +0100
commit7e2a8111e6cb62b84e80df3eef2e34cc1737bc8e (patch)
tree101550e6b98f618b8435e6255e2071ebf8f527ef
parent02877b21dfbc818e90f1a970d2fa5c451a420f6c (diff)
downloadrabbitmq-server-git-7e2a8111e6cb62b84e80df3eef2e34cc1737bc8e.tar.gz
remove the `leave_cluster' refactor
-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 db4c58caa2..d6c6f360d1 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -676,10 +676,12 @@ remove_node_if_mnesia_running(Node) ->
end.
leave_cluster() ->
- AllNodes = cluster_nodes(all) -- [node()],
- case not is_clustered() orelse lists:any(fun leave_cluster/1, AllNodes) of
- true -> ok;
- false -> e(no_running_cluster_nodes)
+ case nodes_excl_me(cluster_nodes(all)) of
+ [] -> ok;
+ AllNodes -> case lists:any(fun leave_cluster/1, AllNodes) of
+ true -> ok;
+ false -> e(no_running_cluster_nodes)
+ end
end.
leave_cluster(Node) ->