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 | a56b5d96e1b36ed3d384dcd58b971edd654d9729 (patch) | |
| tree | 51148a5301d5c34ccee473388a2c84d0db9c8e15 | |
| parent | 1d1a9f7ab565d606f341374ed1d557d5693625b0 (diff) | |
| download | rabbitmq-server-git-a56b5d96e1b36ed3d384dcd58b971edd654d9729.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 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). |