summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-03-23 14:40:57 +0000
committerMatthew Sackman <matthew@rabbitmq.com>2011-03-23 14:40:57 +0000
commit02a4098c915add7c5f9b9002cf5ff0d6783e091d (patch)
tree27eb60d4e2a6073ba3e8cf76d07f5836fe314aa0
parent2a4f51d39b3f291a7cd7e8e9f084cee8386a8712 (diff)
downloadrabbitmq-server-02a4098c915add7c5f9b9002cf5ff0d6783e091d.tar.gz
Detect discnodeishness prior to suffering disclessness
-rw-r--r--src/rabbit_upgrade.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_upgrade.erl b/src/rabbit_upgrade.erl
index f2d38a93..85f6e88c 100644
--- a/src/rabbit_upgrade.erl
+++ b/src/rabbit_upgrade.erl
@@ -220,12 +220,14 @@ force_tables() ->
[mnesia:force_load_table(T) || T <- rabbit_mnesia:table_names()].
secondary_upgrade(AllNodes) ->
+ %% must do this before we wipe out schema
+ IsDiscNode = is_disc_node(),
rabbit_misc:ensure_ok(mnesia:delete_schema([node()]),
cannot_delete_schema),
%% Note that we cluster with all nodes, rather than all disc nodes
%% (as we can't know all disc nodes at this point). This is safe as
%% we're not writing the cluster config, just setting up Mnesia.
- ClusterNodes = case is_disc_node() of
+ ClusterNodes = case IsDiscNode of
true -> AllNodes;
false -> AllNodes -- [node()]
end,