diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-25 18:47:13 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-25 18:47:13 +0100 |
| commit | c1f2e81ec9029fcd289d48c600cf71bf2d0713df (patch) | |
| tree | 95e6e702a57452d691ee80acf13a3efc318631bc | |
| parent | 536ba1882a89473af6cf0d59a4963f7ef0409167 (diff) | |
| download | rabbitmq-server-git-c1f2e81ec9029fcd289d48c600cf71bf2d0713df.tar.gz | |
improve correctness
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 7c3aef7a76..e52c570e09 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -888,8 +888,8 @@ update_delta_from_master(NewDelta, State = #state{depth_delta = undefined}) -> State #state { depth_delta = 0 }; N when N > 0 -> State #state { depth_delta = N } end; -update_delta_from_master(DeltaChange, State) -> - update_delta(DeltaChange, State). +update_delta_from_master(NewDelta, State = #state { depth_delta = Delta }) -> + update_delta(NewDelta - Delta, State). update_delta(_DeltaChange, State = #state { depth_delta = undefined }) -> State; |