diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-06 16:19:36 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-06 16:19:36 +0100 |
| commit | a180a8c1e56d5c249e16495b914240fa8701b862 (patch) | |
| tree | 6a6385e46881dacfa1703ca75b91fbe7d9f7cc52 | |
| parent | 83ba15267b71ed0ffa1a72b3b37ea598a05db837 (diff) | |
| download | rabbitmq-server-git-a180a8c1e56d5c249e16495b914240fa8701b862.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_variable_queue.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 2ca1a639d2..b7d2460bfd 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1121,7 +1121,7 @@ reduce_memory_use(State = #vqstate { ram_msg_count = RamMsgCount, target_ram_msg_count = TargetRamMsgCount }) -> Reduction = lists:min([RamMsgCount - TargetRamMsgCount, ?IO_BATCH_SIZE]), - {Reduction1, State1} = maybe_push_q1_to_betas(Reduction, State), + { Reduction1, State1} = maybe_push_q1_to_betas(Reduction, State), {_Reduction2, State2} = maybe_push_q4_to_betas(Reduction1, State1), case TargetRamMsgCount of 0 -> push_betas_to_deltas(State2); @@ -1131,8 +1131,7 @@ reduce_memory_use(State = #vqstate { limit_ram_index(State = #vqstate { ram_index_count = RamIndexCount }) -> Permitted = permitted_ram_index_count(State), if Permitted =/= infinity andalso RamIndexCount > Permitted -> - Reduction = lists:min([RamIndexCount - Permitted, - ?IO_BATCH_SIZE]), + Reduction = lists:min([RamIndexCount - Permitted, ?IO_BATCH_SIZE]), case Reduction < ?IO_BATCH_SIZE of true -> State; false -> #vqstate { q2 = Q2, q3 = Q3, |
