diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-10-10 16:22:27 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-10-10 16:22:27 +0100 |
| commit | d30e9b269cec365f19e24496f0a6cc293be7ae82 (patch) | |
| tree | 5fb724547714120c1a1c416cf7108ee8e69ef95f | |
| parent | 2cb7a0389c023a632e46fb30d3f0dcd044c47e01 (diff) | |
| download | rabbitmq-server-git-d30e9b269cec365f19e24496f0a6cc293be7ae82.tar.gz | |
Use a new function introduced on default
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index d1ef5f30b9..7683b15ad0 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -164,9 +164,8 @@ syncer(Ref, Log, MPid, SPids) -> end. await_slaves(Ref, SPids) -> - Nodes = rabbit_mnesia:cluster_nodes(running), [SPid || SPid <- SPids, - lists:member(node(SPid), Nodes) andalso %% [0] + rabbit_mnesia:on_running_node(SPid) andalso %% [0] receive {sync_ready, Ref, SPid} -> true; {sync_deny, Ref, SPid} -> false; |