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 | 89f14ce3f48e8c47cc2407bfb0c50d8d784d69fe (patch) | |
| tree | 77b1f86067709619ce29f89039b23bd73dba203e | |
| parent | b4ce991122d79a1b25de0f5bdd3f50af6fa0b032 (diff) | |
| download | rabbitmq-server-89f14ce3f48e8c47cc2407bfb0c50d8d784d69fe.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 6f8fd3bc..4b57779b 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]). |