diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-10-10 13:57:49 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-10-10 13:57:49 +0100 |
| commit | 62dc3ebde75180415710d216b3bd16680b6bae2b (patch) | |
| tree | 6f7982a2359cedd0b08cbf6e85ac20ce29fe7b9e /src | |
| parent | 24086877b2130a053e4069726abb1ae47aac3e62 (diff) | |
| download | rabbitmq-server-git-62dc3ebde75180415710d216b3bd16680b6bae2b.tar.gz | |
Make sure we update Mnesia when only the gm_pids have changed (i.e. we are cleaning up a spare GM pid from when we found an existing slave at startup).
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 844f67ee5d..e7a608b6b0 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -80,7 +80,7 @@ remove_from_queue(QueueName, DeadGMPids) -> end, [QPid | SPids]), {QPid1, SPids1} = promote_slave(Alive), - case {{QPid, SPids}, {QPid1, SPids1}} of + case {{QPid, SPids, GMPids}, {QPid1, SPids1, GMPids1}} of {Same, Same} -> {ok, QPid1, []}; _ when QPid =:= QPid1 orelse node(QPid1) =:= node() -> |