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
commit89db71043a29dcdb8ef310403a14d8f4b493b407 (patch)
tree101550e6b98f618b8435e6255e2071ebf8f527ef
parentdeb3b4606d4d8e163b5a48ccf74cf399b5d70ffb (diff)
downloadrabbitmq-server-bug25167.tar.gz
remove the `leave_cluster' refactorbug25167
-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 db4c58ca..d6c6f360 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) ->