diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2017-06-26 19:19:00 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2017-06-26 19:19:00 +0200 |
| commit | dce3829a9c116f566554aaf1f2772b27333529b4 (patch) | |
| tree | 8f499f83403cbb80df27c7ced863b56823abb7f0 /src | |
| parent | e1a032742e8759bed01be88ce6275796680c2914 (diff) | |
| download | rabbitmq-server-git-dce3829a9c116f566554aaf1f2772b27333529b4.tar.gz | |
rabbit_nodes_common: Move ensure_epmd() from rabbitmq-server
In `master`, it is used by the new CLI.
[#147436507]
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_nodes.erl | 16 |
1 files changed, 1 insertions, 15 deletions
diff --git a/src/rabbit_nodes.erl b/src/rabbit_nodes.erl index cb7f181121..6bb6d3488f 100644 --- a/src/rabbit_nodes.erl +++ b/src/rabbit_nodes.erl @@ -40,7 +40,6 @@ -spec is_process_running(node(), atom()) -> boolean(). -spec cluster_name() -> binary(). -spec set_cluster_name(binary()) -> 'ok'. --spec ensure_epmd() -> 'ok'. -spec all_running() -> [node()]. %%---------------------------------------------------------------------------- @@ -212,19 +211,6 @@ set_cluster_name(Name) -> rabbit_runtime_parameters:set_global(cluster_name, Name). ensure_epmd() -> - {ok, Prog} = init:get_argument(progname), - ID = rabbit_misc:random(1000000000), - Port = open_port( - {spawn_executable, os:find_executable(Prog)}, - [{args, ["-sname", rabbit_misc:format("epmd-starter-~b", [ID]), - "-noshell", "-eval", "halt()."]}, - exit_status, stderr_to_stdout, use_stdio]), - port_shutdown_loop(Port). - -port_shutdown_loop(Port) -> - receive - {Port, {exit_status, _Rc}} -> ok; - {Port, _} -> port_shutdown_loop(Port) - end. + rabbit_nodes_common:ensure_epmd(). all_running() -> rabbit_mnesia:cluster_nodes(running). |