diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-05-30 12:07:13 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-05-30 12:07:13 +0100 |
| commit | aa95db63256cc36ad7dba3a89a8b3e7aef55c5bf (patch) | |
| tree | c63538c4334f66be7993aaae54da0a8849921ee5 /src/rabbit.erl | |
| parent | 5d79c28282569b430b0ff90f7bafeacf3127d6c3 (diff) | |
| parent | 0f6800c6c2a0d06db4c31bffb423e3d56085403f (diff) | |
| download | rabbitmq-server-git-aa95db63256cc36ad7dba3a89a8b3e7aef55c5bf.tar.gz | |
merge default
Diffstat (limited to 'src/rabbit.erl')
| -rw-r--r-- | src/rabbit.erl | 10 |
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} |
