summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2017-03-13 20:52:24 +0300
committerMichael Klishin <mklishin@pivotal.io>2017-03-13 20:53:24 +0300
commit78545e1e4683add09c7e0c88d026c24eee5783e4 (patch)
treece4a5c66e0f383ca2b7f2f5a43fa8d3813d5ef06 /src
parentc49d63ce36df698128df2679c6a4acf754f5a061 (diff)
downloadrabbitmq-server-git-78545e1e4683add09c7e0c88d026c24eee5783e4.tar.gz
rabbit_mnesia: rename a couple of functions
to be more to the point and not too attached to the classic config-driven "automatic clustering" feature.
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mnesia.erl15
1 files changed, 9 insertions, 6 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 9d1282b936..eea9349dbc 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -146,11 +146,14 @@ init_from_config() ->
_ ->
rabbit_log:info("Discovered peer nodes: ~s~n",
[rabbit_peer_discovery:format_discovered_nodes(DiscoveredNodes)]),
- auto_cluster(DiscoveredNodes, NodeType)
+ join_discovered_peers(DiscoveredNodes, NodeType)
end.
-auto_cluster(TryNodes, NodeType) ->
- case find_auto_cluster_node(nodes_excl_me(TryNodes)) of
+%% Attempts to join discovered,
+%% reachable and compatible (in terms of Mnesia internal protocol version and such)
+%% cluster peers in order.
+join_discovered_peers(TryNodes, NodeType) ->
+ case find_reachable_peer_to_cluster_with(nodes_excl_me(TryNodes)) of
{ok, Node} ->
rabbit_log:info("Node '~p' selected for auto-clustering~n", [Node]),
{ok, {_, DiscNodes, _}} = discover_cluster0(Node),
@@ -894,13 +897,13 @@ is_virgin_node() ->
false
end.
-find_auto_cluster_node([]) ->
+find_reachable_peer_to_cluster_with([]) ->
none;
-find_auto_cluster_node([Node | Nodes]) ->
+find_reachable_peer_to_cluster_with([Node | Nodes]) ->
Fail = fun (Fmt, Args) ->
rabbit_log:warning(
"Could not auto-cluster with node ~s: " ++ Fmt, [Node | Args]),
- find_auto_cluster_node(Nodes)
+ find_reachable_peer_to_cluster_with(Nodes)
end,
case remote_node_info(Node) of
{badrpc, _} = Reason ->