diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2010-11-11 18:45:22 +0000 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2010-11-11 18:45:22 +0000 |
| commit | 8fca28fcc4fbbe70c44d47abfeab11f91b30f7e0 (patch) | |
| tree | 77b1f86067709619ce29f89039b23bd73dba203e | |
| parent | fe630f2e0e3512489c65ecd1aae853e509885490 (diff) | |
| download | rabbitmq-server-git-8fca28fcc4fbbe70c44d47abfeab11f91b30f7e0.tar.gz | |
Reinstated the infinity check for chunk_size
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 6f8fd3bcc7..4b57779bdb 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1498,7 +1498,7 @@ permitted_ram_index_count(#vqstate { len = Len, BetaLen - trunc(BetaLen * BetaLen / (Len - DeltaCount)). chunk_size(Current, Permitted) - when Permitted >= Current -> + when Permitted =:= infinity orelse Permitted >= Current -> 0; chunk_size(Current, Permitted) -> lists:min([Current - Permitted, ?IO_BATCH_SIZE]). |