diff options
| author | Michael Klishin <michael@novemberain.com> | 2015-10-14 16:11:22 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@novemberain.com> | 2015-10-14 16:11:22 +0300 |
| commit | 9b2566d5e8f2b869a88cb8d9a1b9e9158c749587 (patch) | |
| tree | 4cbc115d465d7606d75f8281755eba3bbdfe4cbb /src | |
| parent | 6f02f3cb0e6e2d5669c4998e0eed21bcc72fc37b (diff) | |
| parent | 113054667dbb4177d60eebee067fe2afec89fd13 (diff) | |
| download | rabbitmq-server-git-9b2566d5e8f2b869a88cb8d9a1b9e9158c749587.tar.gz | |
Merge pull request #360 from rabbitmq/rabbitmq-server-84
Move rabbit_mirror_queue_misc:all_nodes/0 to rabbit_nodes:all_running/0
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_nodes.erl | 6 |
2 files changed, 7 insertions, 5 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index fee890476e..2ef1c73a75 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -284,10 +284,10 @@ promote_slave([SPid | SPids]) -> {SPid, SPids}. initial_queue_node(Q, DefNode) -> - {MNode, _SNodes} = suggested_queue_nodes(Q, DefNode, all_nodes()), + {MNode, _SNodes} = suggested_queue_nodes(Q, DefNode, rabbit_nodes:all_running()), MNode. -suggested_queue_nodes(Q) -> suggested_queue_nodes(Q, all_nodes()). +suggested_queue_nodes(Q) -> suggested_queue_nodes(Q, rabbit_nodes:all_running()). suggested_queue_nodes(Q, All) -> suggested_queue_nodes(Q, node(), All). %% The third argument exists so we can pull a call to @@ -309,8 +309,6 @@ suggested_queue_nodes(Q = #amqqueue{exclusive_owner = Owner}, DefNode, All) -> _ -> {MNode, []} end. -all_nodes() -> rabbit_mnesia:cluster_nodes(running). - policy(Policy, Q) -> case rabbit_policy:get(Policy, Q) of undefined -> none; diff --git a/src/rabbit_nodes.erl b/src/rabbit_nodes.erl index 090aacc63c..57d971715b 100644 --- a/src/rabbit_nodes.erl +++ b/src/rabbit_nodes.erl @@ -18,7 +18,8 @@ -export([names/1, diagnostics/1, make/1, parts/1, cookie_hash/0, is_running/2, is_process_running/2, - cluster_name/0, set_cluster_name/1, ensure_epmd/0]). + cluster_name/0, set_cluster_name/1, ensure_epmd/0, + all_running/0]). -include_lib("kernel/include/inet.hrl"). @@ -42,6 +43,7 @@ -spec(cluster_name/0 :: () -> binary()). -spec(set_cluster_name/1 :: (binary()) -> 'ok'). -spec(ensure_epmd/0 :: () -> 'ok'). +-spec(all_running/0 :: () -> [node()]). -endif. @@ -215,3 +217,5 @@ port_shutdown_loop(Port) -> {Port, {exit_status, _Rc}} -> ok; {Port, _} -> port_shutdown_loop(Port) end. + +all_running() -> rabbit_mnesia:cluster_nodes(running). |