diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-28 14:04:18 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-28 14:04:18 +0000 |
| commit | 5caf83928ae3c3a047297104cf454fd8bf6a26ac (patch) | |
| tree | 7a8db30869d57969676fad99ce3a2f21f989597a /src | |
| parent | 8e24822eb87de494ae875b4cfd8ee2eb25d6dde3 (diff) | |
| download | rabbitmq-server-git-5caf83928ae3c3a047297104cf454fd8bf6a26ac.tar.gz | |
We should flush here too, to not leave a junk 'DOWN' message when the syncer exits. Also there's no sync_complete_ok any more...
Diffstat (limited to 'src')
| -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 8d0407f27e..6626ee2ebc 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -163,8 +163,7 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDur}, TRef, BQS) -> credit_flow:handle_bump_msg(Msg), slave_sync_loop(Args, TRef, BQS); {sync_complete, Ref} -> - Syncer ! {sync_complete_ok, Ref, self()}, - erlang:demonitor(MRef), + erlang:demonitor(MRef, [flush]), credit_flow:peer_down(Syncer), {ok, {TRef, BQS}}; {'$gen_cast', {set_maximum_since_use, Age}} -> |