diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-11-06 11:43:11 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-11-06 11:43:11 +0000 |
| commit | 81a46584d294ae6c1bbb834939d61f3c266c300d (patch) | |
| tree | 43277fb77460b8c30bcf519eabb4f46b4951b064 | |
| parent | 902275142718816646ec4bdd4ef20c6b5743a8bd (diff) | |
| download | rabbitmq-server-git-81a46584d294ae6c1bbb834939d61f3c266c300d.tar.gz | |
Explain
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index ca36e0db07..e6559841dd 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -98,6 +98,9 @@ remove_from_queue(QueueName, Self, LiveGMPids) -> slave_pids = SPids1, gm_pids = GMPids1}, store_updated_slaves(Q1), + %% If we add and remove nodes at the same time + %% it's possible we need to sync after removing + %% the master. Let's check. maybe_auto_sync(Q1), {ok, QPid1, [QPid | SPids] -- Alive}; _ -> |