summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2017-03-22 13:49:30 +0300
committerMichael Klishin <mklishin@pivotal.io>2017-03-22 13:49:30 +0300
commit14e2906bf37a3b87ab54021a5e40cbee796994b2 (patch)
tree9a4673142a3efbe5621782b397c05a82bc29ea5b
parentc0ad88e6c2ad34a216733eb9f766911ff9669f80 (diff)
downloadrabbitmq-server-git-14e2906bf37a3b87ab54021a5e40cbee796994b2.tar.gz
Filter current node from the list of peers we're logging
References #1143, #486.
-rw-r--r--src/rabbit_mnesia.erl7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index eea9349dbc..ac125b0fb0 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -139,14 +139,15 @@ init_from_config() ->
{ok, _} ->
e(invalid_cluster_nodes_conf)
end,
- case DiscoveredNodes of
+ Peers = nodes_excl_me(DiscoveredNodes),
+ case Peers of
[] ->
rabbit_log:info("Discovered no peer nodes to cluster with"),
init_db_and_upgrade([node()], disc, false, _Retry = true);
_ ->
rabbit_log:info("Discovered peer nodes: ~s~n",
- [rabbit_peer_discovery:format_discovered_nodes(DiscoveredNodes)]),
- join_discovered_peers(DiscoveredNodes, NodeType)
+ [rabbit_peer_discovery:format_discovered_nodes(Peers)]),
+ join_discovered_peers(Peers, NodeType)
end.
%% Attempts to join discovered,