diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-16 12:31:30 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-16 12:31:30 +0100 |
| commit | e13235921c44b37bba3f6f855f97d1e68f4558f8 (patch) | |
| tree | 2c62a85c0de524cb2693059542b0a0656ae17349 | |
| parent | 7026badd5b0b2f2b4a454d0042418e1159134310 (diff) | |
| download | rabbitmq-server-e13235921c44b37bba3f6f855f97d1e68f4558f8.tar.gz | |
simplify
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index ae1004c3..d1de7861 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -74,10 +74,7 @@ remove_from_queue(QueueName, DeadGMPids) -> lists:member(GM, DeadGMPids) end, GMPids), DeadPids = [Pid || {_GM, Pid} <- Dead, Pid =/= existing], - {_, Alive} = lists:partition( - fun (Pid) -> - lists:member(Pid, DeadPids) - end, [QPid | SPids]), + Alive = [QPid | SPids] -- DeadPids, {QPid1, SPids1} = promote_slave(Alive), case {{QPid, SPids, GMPids}, {QPid1, SPids1, GMPids1}} of |