summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-11-26 12:06:20 +0000
committerSimon MacMullen <simon@rabbitmq.com>2012-11-26 12:06:20 +0000
commitfc09df6b4b12e10020ebb2a78235ffd15d7c0cbe (patch)
treeeec467262cb29e3e83f50bd71d38a5bc39593312
parent49a8392111d5ce1e1b87e4d831a4f61f114ed9a5 (diff)
downloadrabbitmq-server-git-fc09df6b4b12e10020ebb2a78235ffd15d7c0cbe.tar.gz
Cosmetic
-rw-r--r--src/rabbit_amqqueue_process.erl14
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) ->