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 | 8f9c5c2a0428a9dac54e3b0ff0a514cf740316b4 (patch) | |
| tree | 7a8db30869d57969676fad99ce3a2f21f989597a /src/rabbit_mirror_queue_sync.erl | |
| parent | e6e360d8d76c2cc38e38b824d9ba35af2ac5f0e8 (diff) | |
| download | rabbitmq-server-8f9c5c2a0428a9dac54e3b0ff0a514cf740316b4.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/rabbit_mirror_queue_sync.erl')
| -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 8d0407f2..6626ee2e 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}} -> |