summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-07-06 16:19:36 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-07-06 16:19:36 +0100
commita180a8c1e56d5c249e16495b914240fa8701b862 (patch)
tree6a6385e46881dacfa1703ca75b91fbe7d9f7cc52
parent83ba15267b71ed0ffa1a72b3b37ea598a05db837 (diff)
downloadrabbitmq-server-git-a180a8c1e56d5c249e16495b914240fa8701b862.tar.gz
cosmetic
-rw-r--r--src/rabbit_variable_queue.erl5
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,