diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-08-23 11:36:06 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-08-23 11:36:06 +0100 |
| commit | 6bc19d6d7e6ccd7305389335f88736719be3eb02 (patch) | |
| tree | 1fd0722aae0451fc01d56034b451d797dfc9ec5e | |
| parent | 37267bda71d777c8eb3919085f356819ee678617 (diff) | |
| download | rabbitmq-server-6bc19d6d7e6ccd7305389335f88736719be3eb02.tar.gz | |
Fix broken merge
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 203ad651..e4591cca 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -76,11 +76,11 @@ remove_from_queue0(QueueName, DeadGMPids) -> %% get here. case mnesia:read({rabbit_queue, QueueName}) of [] -> {error, not_found}; - [Q = #amqqueue { name = QName, - pid = QPid, + [Q = #amqqueue { pid = QPid, slave_pids = SPids }] -> Alive = [Pid || Pid <- [QPid | SPids], not lists:member(node(Pid), DeadNodes)], + {QPid1, SPids1} = promote_slave(Alive), case {{QPid, SPids}, {QPid1, SPids1}} of {Same, Same} -> {ok, QPid1, [], []}; |