summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorDaniil Fedotov <dfedotov@pivotal.io>2016-06-14 11:09:16 +0100
committerDaniil Fedotov <dfedotov@pivotal.io>2016-06-14 11:09:16 +0100
commit8fc07bedef4a0d0409696107d415f55846b2ca62 (patch)
tree8e9102cc224d29e596547a6d2308c701682f889f /src
parent6b7fc63a5530e5efcd8001aa50a366ab9b23d780 (diff)
downloadrabbitmq-server-git-8fc07bedef4a0d0409696107d415f55846b2ca62.tar.gz
Do not run on_node_down
Diffstat (limited to 'src')
-rw-r--r--src/rabbit.erl26
1 files changed, 1 insertions, 25 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl
index b7fe0fb455..84f979e9ad 100644
--- a/src/rabbit.erl
+++ b/src/rabbit.erl
@@ -595,37 +595,13 @@ start(normal, []) ->
prep_stop(_State) ->
ok = rabbit_alarm:stop(),
ok = case rabbit_mnesia:is_clustered() of
- true ->
- %% We are starting on_node_down in separate process to
- %% avoid blocking application_master and application_controller
- %% This process will be executed normally whithin Timeout or
- %% will be considered deadlocked and killed by exit signal
- run_in_process_with_timeout(
- fun() -> rabbit_amqqueue:on_node_down(node()) end,
- ?LEAVE_CLUSTER_TIMEOUT),
- ok;
+ true -> ok;
false -> rabbit_table:clear_ram_only_tables()
end,
ok.
stop(_) -> ok.
-run_in_process_with_timeout(Fun, Timeout) ->
- Self = self(),
- Ref = make_ref(),
- Worker = spawn_link(fun () ->
- put(worker_pool_worker, true),
- Self ! {Ref, Fun()},
- unlink(Self)
- end),
- receive
- {Ref, Res} -> Res
- after Timeout ->
- unlink(Worker),
- exit(Worker, kill),
- killed
- end.
-
-ifdef(use_specs).
-spec(boot_error/2 :: (term(), not_available | [tuple()]) -> no_return()).
-endif.