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 | 58046f0d23e868dc5dac86ba275cdf4e0be71661 (patch) | |
| tree | 2c62a85c0de524cb2693059542b0a0656ae17349 | |
| parent | bf30a77325d614eab5ea1964c8d2536c7f7c947f (diff) | |
| download | rabbitmq-server-git-58046f0d23e868dc5dac86ba275cdf4e0be71661.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 ae1004c3e2..d1de786103 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 |