diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2017-03-13 20:52:24 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2017-03-13 20:53:24 +0300 |
| commit | 78545e1e4683add09c7e0c88d026c24eee5783e4 (patch) | |
| tree | ce4a5c66e0f383ca2b7f2f5a43fa8d3813d5ef06 /src | |
| parent | c49d63ce36df698128df2679c6a4acf754f5a061 (diff) | |
| download | rabbitmq-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.erl | 15 |
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 -> |
