summaryrefslogtreecommitdiff
path: root/src/rabbit.erl
diff options
context:
space:
mode:
authorFrancesco Mazzoli <francesco@rabbitmq.com>2012-05-30 12:07:13 +0100
committerFrancesco Mazzoli <francesco@rabbitmq.com>2012-05-30 12:07:13 +0100
commitaa95db63256cc36ad7dba3a89a8b3e7aef55c5bf (patch)
treec63538c4334f66be7993aaae54da0a8849921ee5 /src/rabbit.erl
parent5d79c28282569b430b0ff90f7bafeacf3127d6c3 (diff)
parent0f6800c6c2a0d06db4c31bffb423e3d56085403f (diff)
downloadrabbitmq-server-git-aa95db63256cc36ad7dba3a89a8b3e7aef55c5bf.tar.gz
merge default
Diffstat (limited to 'src/rabbit.erl')
-rw-r--r--src/rabbit.erl10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl
index f69c8d1bb2..3f00f0007e 100644
--- a/src/rabbit.erl
+++ b/src/rabbit.erl
@@ -295,6 +295,8 @@ prepare() ->
ok -> ok;
{error, {already_loaded, rabbit}} -> ok
end,
+ ok = rabbit_mnesia:ensure_mnesia_dir(),
+ ok = rabbit_mnesia:prepare(),
ok = ensure_working_log_handlers(),
ok = rabbit_upgrade:maybe_upgrade_mnesia().
@@ -405,7 +407,7 @@ start(normal, []) ->
end.
stop(_State) ->
- ok = rabbit_mnesia:record_running_nodes(),
+ ok = rabbit_mnesia:update_cluster_nodes_status(),
terminated_ok = error_logger:delete_report_handler(rabbit_error_logger),
ok = rabbit_alarm:stop(),
ok = case rabbit_mnesia:is_clustered() of
@@ -502,12 +504,12 @@ sort_boot_steps(UnsortedSteps) ->
end.
boot_step_error({error, {timeout_waiting_for_tables, _}}, _Stacktrace) ->
+ AllNodes = rabbit_mnesia:all_clustered_nodes(),
{Err, Nodes} =
- case rabbit_mnesia:read_previously_running_nodes() of
+ case AllNodes -- [node()] of
[] -> {"Timeout contacting cluster nodes. Since RabbitMQ was"
" shut down forcefully~nit cannot determine which nodes"
- " are timing out. Details on all nodes will~nfollow.~n",
- rabbit_mnesia:all_clustered_nodes() -- [node()]};
+ " are timing out.~n", []};
Ns -> {rabbit_misc:format(
"Timeout contacting cluster nodes: ~p.~n", [Ns]),
Ns}