diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2017-03-13 21:13:52 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2017-03-13 21:13:52 +0300 |
| commit | c87f3acd4fd23e1204e30ad021c65aa8655e3dd3 (patch) | |
| tree | 17641851081e7d90e3ca8451dcdb82ec48f301b9 | |
| parent | 5efbb8907d8681422a66239cb4a5d14e1585a9a1 (diff) | |
| parent | 78545e1e4683add09c7e0c88d026c24eee5783e4 (diff) | |
| download | rabbitmq-server-git-c87f3acd4fd23e1204e30ad021c65aa8655e3dd3.tar.gz | |
Merge branch 'master' into rabbitmq-cli-178
| -rw-r--r-- | CONTRIBUTING.md | 25 | ||||
| -rw-r--r-- | src/rabbit_mnesia.erl | 15 |
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 -> |
