summaryrefslogtreecommitdiff
path: root/src/rabbit_upgrade.erl
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-03-17 09:17:27 +0000
committerMatthew Sackman <matthew@rabbitmq.com>2011-03-17 09:17:27 +0000
commit5a390fde517e6f8539f75199b357d064d8c11541 (patch)
treef62a8ab97ae09629e0163793b7675939d7fc9019 /src/rabbit_upgrade.erl
parent221433535cd1551a83132d0a8d46440dd12ea433 (diff)
downloadrabbitmq-server-5a390fde517e6f8539f75199b357d064d8c11541.tar.gz
renamings
Diffstat (limited to 'src/rabbit_upgrade.erl')
-rw-r--r--src/rabbit_upgrade.erl8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_upgrade.erl b/src/rabbit_upgrade.erl
index 9347cc53..b4e1191e 100644
--- a/src/rabbit_upgrade.erl
+++ b/src/rabbit_upgrade.erl
@@ -141,13 +141,13 @@ upgrade_mode(AllNodes) ->
end;
[Another|_] ->
ClusterVersion =
- case rpc:call(Another, rabbit_version, desired_scope_version,
+ case rpc:call(Another, rabbit_version, desired_for_scope,
[mnesia]) of
{badrpc, {'EXIT', {undef, _}}} -> unknown_old_version;
{badrpc, Reason} -> {unknown, Reason};
V -> V
end,
- MyVersion = rabbit_version:desired_scope_version(mnesia),
+ MyVersion = rabbit_version:desired_for_scope(mnesia),
case rabbit_version:'=~='(ClusterVersion, MyVersion) of
true ->
%% The other node(s) have upgraded already, I am not the
@@ -208,7 +208,7 @@ secondary_upgrade(AllNodes) ->
end,
rabbit_misc:ensure_ok(mnesia:start(), cannot_start_mnesia),
ok = rabbit_mnesia:init_db(ClusterNodes, true),
- ok = rabbit_version:write_desired_scope_version(mnesia),
+ ok = rabbit_version:record_desired_for_scope(mnesia),
ok.
nodes_running(Nodes) ->
@@ -253,7 +253,7 @@ apply_upgrades(Scope, Upgrades, Fun) ->
[apply_upgrade(Scope, Upgrade) || Upgrade <- Upgrades],
info("~s upgrades: All upgrades applied successfully~n",
[Scope]),
- ok = rabbit_version:write_desired_scope_version(Scope),
+ ok = rabbit_version:record_desired_for_scope(Scope),
ok = rabbit_misc:recursive_delete([BackupDir]),
info("~s upgrades: Mnesia backup removed~n", [Scope]),
ok = file:delete(LockFile);