This commit is contained in:
Martin Sumner 2018-11-01 19:58:32 +00:00
parent 71fa1447e0
commit 2b57ff831c
2 changed files with 3 additions and 1 deletions

View file

@ -956,7 +956,8 @@ book_headfold(Pid, Tag, {range, Bucket, KeyRange}, FoldAccT, JournalCheck, SnapP
book_returnfolder(Pid, RunnerType); book_returnfolder(Pid, RunnerType);
book_headfold(Pid, Tag, all, FoldAccT, JournalCheck, SnapPreFold, book_headfold(Pid, Tag, all, FoldAccT, JournalCheck, SnapPreFold,
SegmentList, LastModRange, MaxObjectCount) -> SegmentList, LastModRange, MaxObjectCount) ->
RunnerType = {foldheads_allkeys, Tag, FoldAccT, RunnerType =
{foldheads_allkeys, Tag, FoldAccT,
JournalCheck, SnapPreFold, JournalCheck, SnapPreFold,
SegmentList, LastModRange, MaxObjectCount}, SegmentList, LastModRange, MaxObjectCount},
book_returnfolder(Pid, RunnerType). book_returnfolder(Pid, RunnerType).

View file

@ -1517,6 +1517,7 @@ maybe_accumulate(LK, LV, Acc, AccFun, MaxKeys, {LowLastMod, HighLastMod}) ->
{_SQN, _SH, LMD} = leveled_codec:strip_to_indexdetails({LK, LV}), {_SQN, _SH, LMD} = leveled_codec:strip_to_indexdetails({LK, LV}),
RunAcc = RunAcc =
(LMD == undefined) or ((LMD >= LowLastMod) and (LMD =< HighLastMod)), (LMD == undefined) or ((LMD >= LowLastMod) and (LMD =< HighLastMod)),
io:format("Checking ~w to see if between ~w and ~w", [LMD, LowLastMod, HighLastMod]),
case RunAcc of case RunAcc of
true -> true ->
{AccFun(LK, LV, Acc), MaxKeys - 1}; {AccFun(LK, LV, Acc), MaxKeys - 1};