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 | 067c3175dd84bd6b401ae6c818918746f2c48162 (patch) | |
| tree | 5fb724547714120c1a1c416cf7108ee8e69ef95f | |
| parent | d1a4b8ebebcc981b790163d66cc1478d53cbf7ca (diff) | |
| download | rabbitmq-server-067c3175dd84bd6b401ae6c818918746f2c48162.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 d1ef5f30..7683b15a 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; |