summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2012-08-31 18:55:44 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2012-08-31 18:55:44 +0100
commit5cb13a8445ac522bf201118bbbfe9054be7be4fb (patch)
tree0b73b855ccc45c264f20518584b1e265589eb3cd
parent890f46c149ef227d203ef6de7d05666235101fcd (diff)
downloadrabbitmq-server-5cb13a8445ac522bf201118bbbfe9054be7be4fb.tar.gz
cosmetic
-rw-r--r--src/rabbit_mirror_queue_slave.erl5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index 9ee020d1..54546f75 100644
--- a/src/rabbit_mirror_queue_slave.erl
+++ b/src/rabbit_mirror_queue_slave.erl
@@ -913,6 +913,8 @@ maybe_store_ack(true, MsgId, AckTag, State = #state { msg_id_ack = MA,
State #state { msg_id_ack = dict:store(MsgId, {Num, AckTag}, MA),
ack_num = Num + 1 }.
+set_synchronised(Length, State) -> set_synchronised(0, Length, State).
+
set_synchronised(_, _, State = #state { unknown_pending = undefined }) ->
State;
set_synchronised(PendingDelta, Length,
@@ -924,9 +926,6 @@ set_synchronised(PendingDelta, Length,
set_synchronised1(ExtPending1 =:= 0 andalso Length =:= BQ:len(BQS),
State #state { unknown_pending = ExtPending1 }).
-set_synchronised(Length, State) ->
- set_synchronised(0, Length, State).
-
%% We intentionally leave out the head where a slave becomes
%% unsynchronised: we assert that can never happen.
set_synchronised1(true, State = #state { q = #amqqueue { name = QName },