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 | cca9049a46797ad6c2694957726caebefc7e184b (patch) | |
| tree | c3a321862f585ba0d65922c3b82c1447d65ebf81 | |
| parent | 2a4e7bbc33b268ddd0113295fdbb39d6e416239d (diff) | |
| download | rabbitmq-server-git-cca9049a46797ad6c2694957726caebefc7e184b.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 c6a2f27ad3..131d90cb30 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}) -> |