diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-26 12:06:20 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-26 12:06:20 +0000 |
| commit | fc09df6b4b12e10020ebb2a78235ffd15d7c0cbe (patch) | |
| tree | eec467262cb29e3e83f50bd71d38a5bc39593312 | |
| parent | 49a8392111d5ce1e1b87e4d831a4f61f114ed9a5 (diff) | |
| download | rabbitmq-server-git-fc09df6b4b12e10020ebb2a78235ffd15d7c0cbe.tar.gz | |
Cosmetic
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 19872d8d0c..7b167a9a66 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1176,14 +1176,12 @@ handle_call(sync_mirrors, From, backing_queue = rabbit_mirror_queue_master = BQ, backing_queue_state = BQS}) -> case BQ:depth(BQS) - BQ:len(BQS) of - 0 -> - {ok, #amqqueue{slave_pids = SPids, sync_slave_pids = SSPids}} = - rabbit_amqqueue:lookup(Name), - gen_server2:reply(From, ok), - noreply(rabbit_mirror_queue_master:sync_mirrors( - SPids -- SSPids, Name, BQS)); - _ -> - reply({error, queue_has_pending_acks}, State) + 0 -> {ok, #amqqueue{slave_pids = SPids, sync_slave_pids = SSPids}} = + rabbit_amqqueue:lookup(Name), + gen_server2:reply(From, ok), + noreply(rabbit_mirror_queue_master:sync_mirrors( + SPids -- SSPids, Name, BQS)); + _ -> reply({error, queue_has_pending_acks}, State) end; handle_call(sync_mirrors, _From, State) -> |
