diff options
| author | Daniil Fedotov <dfedotov@pivotal.io> | 2016-06-14 11:09:16 +0100 |
|---|---|---|
| committer | Daniil Fedotov <dfedotov@pivotal.io> | 2016-06-14 11:09:16 +0100 |
| commit | 8fc07bedef4a0d0409696107d415f55846b2ca62 (patch) | |
| tree | 8e9102cc224d29e596547a6d2308c701682f889f /src | |
| parent | 6b7fc63a5530e5efcd8001aa50a366ab9b23d780 (diff) | |
| download | rabbitmq-server-git-8fc07bedef4a0d0409696107d415f55846b2ca62.tar.gz | |
Do not run on_node_down
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit.erl | 26 |
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. |
