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 | 8376163b97b5228c46cbd2322894a265729ff829 (patch) | |
| tree | 27eb60d4e2a6073ba3e8cf76d07f5836fe314aa0 /src | |
| parent | a21745ecc4d397fc51f3be3e0d1a7e8f49b27467 (diff) | |
| download | rabbitmq-server-git-8376163b97b5228c46cbd2322894a265729ff829.tar.gz | |
Detect discnodeishness prior to suffering disclessness
Diffstat (limited to 'src')
| -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 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, |
