diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2012-08-31 18:55:44 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-08-31 18:55:44 +0100 |
commit | 5cb13a8445ac522bf201118bbbfe9054be7be4fb (patch) | |
tree | 0b73b855ccc45c264f20518584b1e265589eb3cd | |
parent | 890f46c149ef227d203ef6de7d05666235101fcd (diff) | |
download | rabbitmq-server-5cb13a8445ac522bf201118bbbfe9054be7be4fb.tar.gz |
cosmetic
-rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 5 |
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 }, |