diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-06-15 06:02:50 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-06-15 06:02:50 +0100 |
| commit | ccb2835c505c3f8be0ea7c7f8e2884de55b96208 (patch) | |
| tree | 5193317cd7c455168c59c8981ad183e19627cf02 /src | |
| parent | 36e971a26173b2436f435ce91cf68a642dcaee8c (diff) | |
| download | rabbitmq-server-git-ccb2835c505c3f8be0ea7c7f8e2884de55b96208.tar.gz | |
minor refactor: rename function
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index ca3be6d2b7..a5547f6bd8 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -466,7 +466,7 @@ fetch(AckRequired, State = #vqstate { q4 = Q4, pending_ack = PA }) -> case queue:out(Q4) of {empty, _Q4} -> - case fetch_from_q3_or_delta(State) of + case fetch_from_q3_to_q4(State) of {empty, _State1} = Result -> Result; {loaded, State1} -> fetch(AckRequired, State1) end; @@ -1002,15 +1002,15 @@ remove_queue_entries1( SeqId, IndexState), {Count + 1, GuidsByStore1, SeqIdsAcc1, IndexState1}. -fetch_from_q3_or_delta(State = #vqstate { - q1 = Q1, - q2 = Q2, - delta = #delta { count = DeltaCount }, - q3 = Q3, - q4 = Q4, - ram_msg_count = RamMsgCount, - ram_index_count = RamIndexCount, - msg_store_clients = MSCState }) -> +fetch_from_q3_to_q4(State = #vqstate { + q1 = Q1, + q2 = Q2, + delta = #delta { count = DeltaCount }, + q3 = Q3, + q4 = Q4, + ram_msg_count = RamMsgCount, + ram_index_count = RamIndexCount, + msg_store_clients = MSCState }) -> case bpqueue:out(Q3) of {empty, _Q3} -> 0 = DeltaCount, %% ASSERTION |