summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2017-03-13 21:13:52 +0300
committerMichael Klishin <mklishin@pivotal.io>2017-03-13 21:13:52 +0300
commitc87f3acd4fd23e1204e30ad021c65aa8655e3dd3 (patch)
tree17641851081e7d90e3ca8451dcdb82ec48f301b9
parent5efbb8907d8681422a66239cb4a5d14e1585a9a1 (diff)
parent78545e1e4683add09c7e0c88d026c24eee5783e4 (diff)
downloadrabbitmq-server-git-c87f3acd4fd23e1204e30ad021c65aa8655e3dd3.tar.gz
Merge branch 'master' into rabbitmq-cli-178
-rw-r--r--CONTRIBUTING.md25
-rw-r--r--src/rabbit_mnesia.erl15
2 files changed, 34 insertions, 6 deletions
diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md
index 45bbcbe62e..daaea42b18 100644
--- a/CONTRIBUTING.md
+++ b/CONTRIBUTING.md
@@ -25,6 +25,31 @@ of their opinion on [RabbitMQ mailing list](https://groups.google.com/forum/#!fo
See [CODE_OF_CONDUCT.md](./CODE_OF_CONDUCT.md).
+## Running Tests
+
+To run a "fast suite" (a subset of tests):
+
+ make ct-fast
+
+To run a "slow suite" (a subset of tests that take much longer to run):
+
+ make ct-slow
+
+To run a particular suite:
+
+ make ct-$suite_name
+
+for example, to run the `backing_queue` suite:
+
+ make ct-backing_queue
+
+Finally,
+
+ make tests
+
+will run all suites.
+
+
## Contributor Agreement
If you want to contribute a non-trivial change, please submit a signed copy of our
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 ->