summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorFrancesco Mazzoli <francesco@rabbitmq.com>2012-06-01 15:51:25 +0100
committerFrancesco Mazzoli <francesco@rabbitmq.com>2012-06-01 15:51:25 +0100
commit6e8ef1d7853f3b3e4438f56d6999a348dd4412fe (patch)
tree7a6bb3d1d108202d70425074540c03db55a16ef9 /src
parent2c02a3ced57402e72cb645b5e460151b972c5462 (diff)
downloadrabbitmq-server-git-6e8ef1d7853f3b3e4438f56d6999a348dd4412fe.tar.gz
stop mnesia after cluster operation
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mnesia.erl4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 5e7907af7d..7aac7f3f63 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -210,6 +210,7 @@ join_cluster(DiscoveryNode, WantDiscNode) ->
%% Join the cluster
ok = init_db_and_upgrade(DiscNodes, WantDiscNode, false),
+ stop_mnesia(),
ok.
@@ -289,6 +290,7 @@ change_node_type(Type) ->
end,
ok = init_db_and_upgrade(ClusterNodes, WantDiscNode, false),
+ stop_mnesia(),
ok.
@@ -313,6 +315,7 @@ recluster(DiscoveryNode) ->
"The nodes provided do not have this node as part of "
"the cluster"}})
end,
+ stop_mnesia(),
ok.
@@ -1007,6 +1010,7 @@ remove_node_if_mnesia_running(Node) ->
case mnesia:del_table_copy(schema, Node) of
{atomic, ok} ->
update_cluster_nodes_status(),
+ io:format("nodes: ~p~n", [running_clustered_disc_nodes()]),
{_, []} = rpc:multicall(running_clustered_nodes(),
rabbit_mnesia,
update_cluster_nodes_status, []),