Skip to content

Commit 2f34158

Browse files
committed
Explain the IoBatchSize role in push_betas_to_deltas
1 parent 07b85f6 commit 2f34158

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/rabbit_variable_queue.erl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2384,6 +2384,9 @@ reduce_memory_use(State = #vqstate {
23842384
end,
23852385

23862386
State3 =
2387+
%% If there are more messages with their queue position held in RAM,
2388+
%% a.k.a. betas, in Q2 & Q3 than IoBatchSize,
2389+
%% write their queue position to disk, a.k.a. push_betas_to_deltas
23872390
case chunk_size(?QUEUE:len(Q2) + ?QUEUE:len(Q3),
23882391
permitted_beta_count(State1)) of
23892392
S2 when S2 >= IoBatchSize ->

0 commit comments

Comments
 (0)