diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-04-05 23:07:12 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-04-05 23:07:12 +0100 |
| commit | dde6c60b61ce3cf371f76b4422fe991085ed6504 (patch) | |
| tree | 932e55673ecb4a7d2ae657adcc424209032b1842 | |
| parent | e81e10507bb4fbfcf2fdedb971ffe52d99cc6712 (diff) | |
| download | rabbitmq-server-git-dde6c60b61ce3cf371f76b4422fe991085ed6504.tar.gz | |
Corrected comment
| -rw-r--r-- | src/rabbit_variable_queue.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 56a79f4724..8585e1392c 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1151,8 +1151,9 @@ maybe_deltas_to_betas( {List, IndexState1, Delta1SeqId} = read_index_segment(DeltaSeqId, IndexState), State1 = State #vqstate { index_state = IndexState1 }, - %% length(List) may be < segment_size because of acks. But - %% it can't be [] + %% length(List) may be < segment_size because of acks. It + %% could be [] if we ignored every message in the segment + %% due to it being transient and below the threshold Q3a = betas_from_segment_entries(List, DeltaSeqIdEnd, TransientThreshold), Q3b = bpqueue:join(Q3, Q3a), case DeltaCount - bpqueue:len(Q3a) of |