diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-09-28 18:40:16 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-09-28 18:40:16 +0100 |
| commit | ec542c0d8ec041bdef27f2ffdd728d3dfd74c559 (patch) | |
| tree | ee1a010b4d3af0ffa96cebca9649a20facf97038 | |
| parent | 3349c31b004d0b4e9d5085c5bba14558102c722a (diff) | |
| download | rabbitmq-server-git-ec542c0d8ec041bdef27f2ffdd728d3dfd74c559.tar.gz | |
Count properly
| -rw-r--r-- | src/rabbit_variable_queue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 0272002bc3..e5e0313359 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1617,17 +1617,17 @@ push_betas_to_deltas(Generator, Limit, Quota, Q, Count, RamIndexCount, IndexStat when SeqId < Limit -> {Count, Q, RamIndexCount, IndexState}; {{value, MsgStatus = #msg_status { index_on_disk = IndexOnDisk }}, Qa} -> - {RamIndexCount1, IndexState1} = + {Quota1, RamIndexCount1, IndexState1} = case IndexOnDisk of - true -> {RamIndexCount, IndexState}; + true -> {Quota, RamIndexCount, IndexState}; false -> {#msg_status { index_on_disk = true }, IndexState2} = maybe_write_index_to_disk(true, MsgStatus, IndexState), - {RamIndexCount - 1, IndexState2} + {Quota - 1, RamIndexCount - 1, IndexState2} end, push_betas_to_deltas( - Generator, Limit, Quota, Qa, Count + 1, RamIndexCount1, IndexState1) + Generator, Limit, Quota1, Qa, Count + 1, RamIndexCount1, IndexState1) end. %%---------------------------------------------------------------------------- |