diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-01-20 06:29:03 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-01-20 06:29:03 +0300 |
| commit | 267755365ab4fa2fd2568d86399806c442c7fd61 (patch) | |
| tree | 0fb4b0eaecd1c47fb1e2aa3ac864711e5989ab14 | |
| parent | c5ae45e2c8f26393c061ebc647c7b7cb56d0917e (diff) | |
| download | rabbitmq-server-git-267755365ab4fa2fd2568d86399806c442c7fd61.tar.gz | |
Introduce rabbit:is_booted/0, is_booting/0
References rabbitmq/rabbitmq-cli#292.
| -rw-r--r-- | src/rabbit.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index c9266c3ea1..44a044a4dc 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -31,7 +31,7 @@ -export([start/2, stop/1, prep_stop/1]). -export([start_apps/1, start_apps/2, stop_apps/1]). -export([log_locations/0, config_files/0, decrypt_config/2]). %% for testing and mgmt-agent --export([is_booted/1, is_booting/1]). +-export([is_booted/1, is_booted/0, is_booting/1, is_booting/0]). -ifdef(TEST). @@ -696,6 +696,8 @@ await_startup(Node) -> end end. +is_booting() -> is_booting(node()). + is_booting(Node) -> case rpc:call(Node, erlang, whereis, [rabbit_boot]) of {badrpc, _} = Err -> Err; @@ -790,6 +792,8 @@ is_running() -> is_running(node()). is_running(Node) -> rabbit_nodes:is_process_running(Node, rabbit). +is_booted() -> is_booted(node()). + is_booted(Node) -> case is_booting(Node) of false -> |