diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-25 22:19:52 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-25 22:19:52 +0100 |
| commit | dd8b5390d61f07a9b8a2da89533831a881f3e1f5 (patch) | |
| tree | ac43029c3f9d0dd8e0613cbc55e7b152e40e1a5a | |
| parent | b151d6930710aea7ae7220678208cea69c968a8c (diff) | |
| download | rabbitmq-server-dd8b5390d61f07a9b8a2da89533831a881f3e1f5.tar.gz | |
another assertion
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 07a1d9e5..039b2749 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -897,6 +897,7 @@ update_delta( DeltaChange, State = #state { depth_delta = 0 }) -> 0 = DeltaChange, %% assertion: we cannot become unsync'ed State; update_delta( DeltaChange, State = #state { depth_delta = Delta }) -> + true = DeltaChange =< 0, %% assertion: we cannot become 'less' sync'ed set_delta(Delta + DeltaChange, State #state { depth_delta = undefined }). record_synchronised(#amqqueue { name = QName }) -> |