diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-08-31 18:55:31 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-08-31 18:55:31 +0100 |
| commit | 890f46c149ef227d203ef6de7d05666235101fcd (patch) | |
| tree | 51148a5301d5c34ccee473388a2c84d0db9c8e15 | |
| parent | 34d80b42b7845109439b231446b8fef03ee45b4c (diff) | |
| download | rabbitmq-server-890f46c149ef227d203ef6de7d05666235101fcd.tar.gz | |
style
| -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 3423295a..9ee020d1 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). |