diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-10-15 15:56:35 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-10-15 15:56:35 +0100 |
| commit | c73f8e1e885ae7d4d09a4bac9afc5810abd80ee8 (patch) | |
| tree | c3a321862f585ba0d65922c3b82c1447d65ebf81 | |
| parent | ca5bdaaeef2bd3e4a3a9db820381de7d6aeac15a (diff) | |
| download | rabbitmq-server-c73f8e1e885ae7d4d09a4bac9afc5810abd80ee8.tar.gz | |
oops
| -rw-r--r-- | src/rabbit_variable_queue.erl | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c6a2f27a..131d90cb 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -944,18 +944,14 @@ betas_from_index_entries(List, TransientThreshold, PA, IndexState) -> expand_delta(SeqId, ?BLANK_DELTA_PATTERN(X)) -> d(#delta { start_seq_id = SeqId, count = 1, end_seq_id = SeqId + 1 }); expand_delta(SeqId, #delta { start_seq_id = StartSeqId, - count = Count, - end_seq_id = EndSeqId } = Delta) + count = Count } = Delta) when SeqId < StartSeqId -> d(Delta #delta { start_seq_id = SeqId, count = Count + 1 }); -expand_delta(SeqId, #delta { start_seq_id = StartSeqId, - count = Count, +expand_delta(SeqId, #delta { count = Count, end_seq_id = EndSeqId } = Delta) when SeqId >= EndSeqId -> d(Delta #delta { count = Count + 1, end_seq_id = SeqId + 1 }); -expand_delta(_SeqId, #delta { start_seq_id = StartSeqId, - count = Count, - end_seq_id = EndSeqId } = Delta) -> +expand_delta(_SeqId, #delta { count = Count } = Delta) -> d(Delta #delta { count = Count + 1 }). update_rate(Now, Then, Count, {OThen, OCount}) -> |