diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-12-05 16:01:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-12-05 16:01:35 +0000 |
| commit | 160092e8eab3b9e7eca59cf9ce30ca9f25fc1d5b (patch) | |
| tree | ecf7f8b28c8c00c9aac8bc664512551ca40a4bd7 /src/rabbit.erl | |
| parent | 9e4a5706ab1abfdce9f2e3b84de4d17d5d4aef17 (diff) | |
| parent | 83fc59eae51889459dd53b5e4ebcff62e7bbb1c3 (diff) | |
| download | rabbitmq-server-git-160092e8eab3b9e7eca59cf9ce30ca9f25fc1d5b.tar.gz | |
Merge bug22525
Diffstat (limited to 'src/rabbit.erl')
| -rw-r--r-- | src/rabbit.erl | 32 |
1 files changed, 19 insertions, 13 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index 1b7fe6dada..045c5d587b 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -347,19 +347,25 @@ handle_app_error(App, Reason) -> start_it(StartFun) -> Marker = spawn_link(fun() -> receive stop -> ok end end), - register(rabbit_boot, Marker), - try - StartFun() - catch - throw:{could_not_start, _App, _Reason}=Err -> - boot_error(Err, not_available); - _:Reason -> - boot_error(Reason, erlang:get_stacktrace()) - after - unlink(Marker), - Marker ! stop, - %% give the error loggers some time to catch up - timer:sleep(100) + case catch register(rabbit_boot, Marker) of + true -> try + case is_running() of + true -> ok; + false -> StartFun() + end + catch + throw:{could_not_start, _App, _Reason}=Err -> + boot_error(Err, not_available); + _:Reason -> + boot_error(Reason, erlang:get_stacktrace()) + after + unlink(Marker), + Marker ! stop, + %% give the error loggers some time to catch up + timer:sleep(100) + end; + _ -> unlink(Marker), + Marker ! stop end. stop() -> |
