summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-03-07 18:21:36 +0000
committerSimon MacMullen <simon@rabbitmq.com>2011-03-07 18:21:36 +0000
commit165c1d3f25a44c91650556a68ba725239f1f8d12 (patch)
tree03c8f1fedaffb84f173db9a7ea8cbdda5936b7b1
parent4d806324368f812c4831724f868079f3a2835892 (diff)
downloadrabbitmq-server-165c1d3f25a44c91650556a68ba725239f1f8d12.tar.gz
Spec, rename functions.
-rw-r--r--src/rabbit_mnesia.erl13
-rw-r--r--src/rabbit_upgrade.erl4
2 files changed, 9 insertions, 8 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 30083cc0..eb92e9fe 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -22,8 +22,8 @@
is_clustered/0, running_clustered_nodes/0, all_clustered_nodes/0,
empty_ram_only_tables/0, copy_db/1, wait_for_tables/1,
create_cluster_nodes_config/1, read_cluster_nodes_config/0,
- record_running_disc_nodes/0, read_previous_run_disc_nodes/0,
- delete_previous_run_disc_nodes/0, running_nodes_filename/0]).
+ record_running_disc_nodes/0, read_previously_running_disc_nodes/0,
+ delete_previously_running_disc_nodes/0, running_nodes_filename/0]).
-export([table_names/0]).
@@ -45,6 +45,7 @@
-spec(dir/0 :: () -> file:filename()).
-spec(ensure_mnesia_dir/0 :: () -> 'ok').
-spec(init/0 :: () -> 'ok').
+-spec(init_db/2 :: ([node()], boolean()) -> 'ok').
-spec(is_db_empty/0 :: () -> boolean()).
-spec(cluster/1 :: ([node()]) -> 'ok').
-spec(force_cluster/1 :: ([node()]) -> 'ok').
@@ -61,8 +62,8 @@
-spec(create_cluster_nodes_config/1 :: ([node()]) -> 'ok').
-spec(read_cluster_nodes_config/0 :: () -> [node()]).
-spec(record_running_disc_nodes/0 :: () -> 'ok').
--spec(read_previous_run_disc_nodes/0 :: () -> [node()]).
--spec(delete_previous_run_disc_nodes/0 :: () -> 'ok').
+-spec(read_previously_running_disc_nodes/0 :: () -> [node()]).
+-spec(delete_previously_running_disc_nodes/0 :: () -> 'ok').
-spec(running_nodes_filename/0 :: () -> file:filename()).
-endif.
@@ -390,7 +391,7 @@ record_running_disc_nodes() ->
rabbit_misc:write_term_file(FileName, [Nodes]),
ok.
-read_previous_run_disc_nodes() ->
+read_previously_running_disc_nodes() ->
FileName = running_nodes_filename(),
case rabbit_misc:read_term_file(FileName) of
{ok, [Nodes]} -> Nodes;
@@ -399,7 +400,7 @@ read_previous_run_disc_nodes() ->
FileName, Reason}})
end.
-delete_previous_run_disc_nodes() ->
+delete_previously_running_disc_nodes() ->
FileName = running_nodes_filename(),
case file:delete(FileName) of
ok -> ok;
diff --git a/src/rabbit_upgrade.erl b/src/rabbit_upgrade.erl
index e466eb87..0a821878 100644
--- a/src/rabbit_upgrade.erl
+++ b/src/rabbit_upgrade.erl
@@ -122,12 +122,12 @@ maybe_upgrade_mnesia() ->
secondary -> secondary_upgrade(AllNodes)
end
end,
- ok = rabbit_mnesia:delete_previous_run_disc_nodes().
+ ok = rabbit_mnesia:delete_previously_running_disc_nodes().
upgrade_mode(AllNodes) ->
case nodes_running(AllNodes) of
[] ->
- AfterUs = rabbit_mnesia:read_previous_run_disc_nodes(),
+ AfterUs = rabbit_mnesia:read_previously_running_disc_nodes(),
case {is_disc_node(), AfterUs} of
{true, []} ->
primary;