summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2021-01-16 01:45:12 +0500
committerMichael Klishin <michael@clojurewerkz.org>2021-01-16 01:45:12 +0500
commit075ee099966cb18a3b7b09c80f0d26e87d733318 (patch)
treedc1cc9f35e890c13365202dbcfc8a8c4fb215b79
parent19d28f260a563a52a616c97e7c7d9cdee1b2c11d (diff)
downloadrabbitmq-server-git-rabbitmq_epmd_wait.tar.gz
Naming, wordingrabbitmq_epmd_wait
-rw-r--r--deps/rabbit_common/src/rabbit_nodes_common.erl18
1 files changed, 9 insertions, 9 deletions
diff --git a/deps/rabbit_common/src/rabbit_nodes_common.erl b/deps/rabbit_common/src/rabbit_nodes_common.erl
index 01e368635a..71fe6b3b07 100644
--- a/deps/rabbit_common/src/rabbit_nodes_common.erl
+++ b/deps/rabbit_common/src/rabbit_nodes_common.erl
@@ -7,8 +7,8 @@
-module(rabbit_nodes_common).
--define(EPMD_TIMEOUT, 6000).
--define(EPMD_ATTEMPT, 10).
+-define(EPMD_OPERATION_TIMEOUT, 6000).
+-define(NAME_LOOKUP_ATTEMPTS, 10).
-define(TCP_DIAGNOSTIC_TIMEOUT, 5000).
-define(ERROR_LOGGER_HANDLER, rabbit_error_logger_handler).
@@ -44,17 +44,17 @@
%% In K8s for example *.nodes.default needs some second.
names(Hostname) ->
- names(Hostname, ?EPMD_ATTEMPT).
+ names(Hostname, ?NAME_LOOKUP_ATTEMPTS).
names(Hostname, 0) ->
epmd_names(Hostname);
-names(Hostname, Attempt) ->
- rabbit_log:info("Getting the epmd names for ~s hostname, ~b retries left",
- [Hostname, Attempt]),
+names(Hostname, RetriesLeft) ->
+ rabbit_log:debug("Getting epmd names for hostname '~s', ~b retries left",
+ [Hostname, RetriesLeft]),
case catch epmd_names(Hostname) of
- {ok, R } -> {ok, R };
+ {ok, R } -> {ok, R};
{error, _} ->
- names(Hostname, Attempt - 1)
+ names(Hostname, RetriesLeft - 1)
end.
epmd_names(Hostname) ->
@@ -62,7 +62,7 @@ epmd_names(Hostname) ->
Ref = make_ref(),
{Pid, MRef} = spawn_monitor(
fun () -> Self ! {Ref, net_adm:names(Hostname)} end),
- _ = timer:exit_after(?EPMD_TIMEOUT, Pid, timeout),
+ _ = timer:exit_after(?EPMD_OPERATION_TIMEOUT, Pid, timeout),
receive
{Ref, Names} -> erlang:demonitor(MRef, [flush]),
Names;