diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 3423295a1a..9ee020d123 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -920,11 +920,9 @@ set_synchronised(PendingDelta, Length, backing_queue_state = BQS, unknown_pending = ExtPending }) -> ExtPending1 = ExtPending + PendingDelta, - State1 = State #state { unknown_pending = ExtPending1 }, - case ExtPending1 =:= 0 andalso Length =:= BQ:len(BQS) of - true -> set_synchronised1(true, State1); - false when ExtPending1 >= 0 -> set_synchronised1(false, State1) - end. + true = ExtPending1 >= 0, + set_synchronised1(ExtPending1 =:= 0 andalso Length =:= BQ:len(BQS), + State #state { unknown_pending = ExtPending1 }). set_synchronised(Length, State) -> set_synchronised(0, Length, State). |