diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-19 12:41:48 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-19 12:41:48 +0100 |
| commit | 53a7fa17dfa2c5dc4a6aa5266d76d69cae31628e (patch) | |
| tree | 336088aeee7b414e1321c2e7fafe5e8e25b100a0 /src | |
| parent | 667cf37e691c148e18e0d7a4cf6cd361e459c2c1 (diff) | |
| download | rabbitmq-server-git-53a7fa17dfa2c5dc4a6aa5266d76d69cae31628e.tar.gz | |
ordsets instead of lists in `rabbit_upgrade'
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_upgrade.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_upgrade.erl b/src/rabbit_upgrade.erl index 9c54eb7247..4f34504e99 100644 --- a/src/rabbit_upgrade.erl +++ b/src/rabbit_upgrade.erl @@ -126,11 +126,11 @@ maybe_upgrade_mnesia() -> {error, starting_from_scratch} -> ok; {error, version_not_available} -> - case AllNodes of - [_] -> ok; - _ -> die("Cluster upgrade needed but upgrading from " + case ordsets:size(AllNodes) of + 0 -> die("Cluster upgrade needed but upgrading from " "< 2.1.1.~nUnfortunately you will need to " - "rebuild the cluster.", []) + "rebuild the cluster.", []); + _ -> ok end; {error, _} = Err -> throw(Err); @@ -145,7 +145,7 @@ maybe_upgrade_mnesia() -> end. upgrade_mode(AllNodes) -> - case nodes_running(AllNodes) of + case nodes_running(ordsets:to_list(AllNodes)) of [] -> AfterUs = rabbit_mnesia:running_clustered_nodes() -- [node()], case {node_type_legacy(), AfterUs} of @@ -196,7 +196,7 @@ die(Msg, Args) -> halt(1). primary_upgrade(Upgrades, Nodes) -> - Others = Nodes -- [node()], + Others = ordsets:del_element(node(), Nodes), ok = apply_upgrades( mnesia, Upgrades, @@ -206,7 +206,7 @@ primary_upgrade(Upgrades, Nodes) -> [] -> ok; _ -> info("mnesia upgrades: Breaking cluster~n", []), [{atomic, ok} = mnesia:del_table_copy(schema, Node) - || Node <- Others] + || Node <- ordsets:to_list(Others)] end end), ok. |
