diff options
author | Matthew Sackman <matthew@rabbitmq.com> | 2011-03-23 14:40:57 +0000 |
---|---|---|
committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-03-23 14:40:57 +0000 |
commit | 02a4098c915add7c5f9b9002cf5ff0d6783e091d (patch) | |
tree | 27eb60d4e2a6073ba3e8cf76d07f5836fe314aa0 | |
parent | 2a4f51d39b3f291a7cd7e8e9f084cee8386a8712 (diff) | |
download | rabbitmq-server-02a4098c915add7c5f9b9002cf5ff0d6783e091d.tar.gz |
Detect discnodeishness prior to suffering disclessness
-rw-r--r-- | src/rabbit_upgrade.erl | 4 |
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, |