diff options
| -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; |