Skip to content

Commit

Permalink
Trigger batch correctly at each size (#4)
Browse files Browse the repository at this point in the history
  • Loading branch information
martinsumner committed Nov 14, 2023
1 parent b02f24e commit 1f14db7
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/riak_kv_vnode.erl
Original file line number Diff line number Diff line change
Expand Up @@ -2001,7 +2001,7 @@ handle_aaefold({reap_tombs,
case TombHashAcc of
{BatchList, Count, local} ->
NewCount = Count + 1,
case NewCount div ?REAPER_BATCH_SIZE of
case NewCount rem ?REAPER_BATCH_SIZE of
0 ->
riak_kv_reaper:bulk_request_reap(
[{{BF, KF}, DH}|BatchList]
Expand Down Expand Up @@ -2057,7 +2057,7 @@ handle_aaefold({erase_keys,
case EraseKeyAcc of
{BatchList, Count, local} ->
NewCount = Count + 1,
case NewCount div ?ERASER_BATCH_SIZE of
case NewCount rem ?ERASER_BATCH_SIZE of
0 ->
riak_kv_eraser:bulk_request_delete(
[{{BF, KF}, VV}|BatchList]),
Expand Down

0 comments on commit 1f14db7

Please sign in to comment.