summaryrefslogtreecommitdiff
path: root/src
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
commit8376163b97b5228c46cbd2322894a265729ff829 (patch)
tree27eb60d4e2a6073ba3e8cf76d07f5836fe314aa0 /src
parenta21745ecc4d397fc51f3be3e0d1a7e8f49b27467 (diff)
downloadrabbitmq-server-git-8376163b97b5228c46cbd2322894a265729ff829.tar.gz
Detect discnodeishness prior to suffering disclessness
Diffstat (limited to 'src')
-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 f2d38a931d..85f6e88ce4 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,