diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-29 12:35:00 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-29 12:35:00 +0000 |
| commit | 3f7332481753ef93e37ef768747e30fa89fc66ff (patch) | |
| tree | 06177a4b4ccae868cea028666d0d04bf8c5a54ff /src/rabbit_mirror_queue_master.erl | |
| parent | 0675c23b66b5f8804cee5d20ce586aa7082471f3 (diff) | |
| download | rabbitmq-server-3f7332481753ef93e37ef768747e30fa89fc66ff.tar.gz | |
Make sure newly-started slaves don't respond and confuse things.
Diffstat (limited to 'src/rabbit_mirror_queue_master.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 2f9f4c02..d8737938 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -136,7 +136,7 @@ sync_mirrors(State = #state { name = QName, {ok, #amqqueue{slave_pids = SPids}} = rabbit_amqqueue:lookup(QName), Ref = make_ref(), Syncer = rabbit_mirror_queue_sync:master_prepare(Ref, QName, SPids), - gm:broadcast(GM, {sync_start, Ref, Syncer}), + gm:broadcast(GM, {sync_start, Ref, Syncer, SPids}), S = fun(BQSN) -> State#state{backing_queue_state = BQSN} end, case rabbit_mirror_queue_sync:master_go(Syncer, Ref, QName, BQ, BQS) of {shutdown, R, BQS1} -> {stop, R, S(BQS1)}; |