Expand segment lists when matches are produced form smaller trees
Let us say a store has precalculated segments based on large tree size, but mismatched segmentIDs are found on a small tree size (for query efficiency). the list of segment IDs need to be expanded out for matching. This may be more efficient that running match_segment for each check (expand out once and uses lists:member/2). Also this is necessary for leveled_so AAE stores (segment-ordered stores)
This commit is contained in:
parent
5cbda7c2f7
commit
4981cdfc07
1 changed files with 55 additions and 4 deletions
|
@ -73,6 +73,7 @@
|
||||||
keyto_segment32/1,
|
keyto_segment32/1,
|
||||||
keyto_segment48/1,
|
keyto_segment48/1,
|
||||||
generate_segmentfilter_list/2,
|
generate_segmentfilter_list/2,
|
||||||
|
adjust_segmentmatch_list/3,
|
||||||
merge_binaries/2,
|
merge_binaries/2,
|
||||||
join_segment/2,
|
join_segment/2,
|
||||||
match_segment/2
|
match_segment/2
|
||||||
|
@ -383,6 +384,31 @@ generate_segmentfilter_list(SegmentList, Size) ->
|
||||||
SegmentList
|
SegmentList
|
||||||
end.
|
end.
|
||||||
|
|
||||||
|
-spec adjust_segmentmatch_list(list(integer()), tree_size(), tree_size())
|
||||||
|
-> list(integer()).
|
||||||
|
%% @doc
|
||||||
|
%% If we have dirty segments discovered by comparing trees of size CompareSize,
|
||||||
|
%% and we want to see if it matches a segment for a key which was created for a
|
||||||
|
%% tree of size Store Size, then we need to alter the segment list
|
||||||
|
adjust_segmentmatch_list(SegmentList, CompareSize, StoreSize) ->
|
||||||
|
CompareSizeI = get_size(CompareSize),
|
||||||
|
StoreSizeI = get_size(StoreSize),
|
||||||
|
if CompareSizeI =< StoreSizeI ->
|
||||||
|
ExpItems = StoreSizeI div CompareSizeI - 1,
|
||||||
|
ShiftFactor = trunc(math:log2(CompareSizeI * ?L2_CHUNKSIZE)),
|
||||||
|
ExpList =
|
||||||
|
lists:map(fun(X) -> X bsl ShiftFactor end, lists:seq(1, ExpItems)),
|
||||||
|
UpdSegmentList =
|
||||||
|
lists:foldl(fun(S, Acc) ->
|
||||||
|
L = lists:map(fun(F) -> F + S end, ExpList),
|
||||||
|
L ++ Acc
|
||||||
|
end,
|
||||||
|
[],
|
||||||
|
SegmentList),
|
||||||
|
lists:usort(UpdSegmentList ++ SegmentList)
|
||||||
|
end.
|
||||||
|
|
||||||
|
|
||||||
-spec match_segment({integer(), tree_size()}, {integer(), tree_size()})
|
-spec match_segment({integer(), tree_size()}, {integer(), tree_size()})
|
||||||
-> boolean().
|
-> boolean().
|
||||||
%% @doc
|
%% @doc
|
||||||
|
@ -696,15 +722,40 @@ compare_trees_maxonedelta(Tree0, Tree1) ->
|
||||||
end.
|
end.
|
||||||
|
|
||||||
segment_match_test() ->
|
segment_match_test() ->
|
||||||
segment_match_tester(small, large),
|
segment_match_tester(small, large, <<"K0">>),
|
||||||
segment_match_tester(xlarge, medium).
|
segment_match_tester(xlarge, medium, <<"K1">>),
|
||||||
|
expand_membershiplist_tester(small, large, <<"K0">>),
|
||||||
|
expand_membershiplist_tester(xsmall, large, <<"K1">>),
|
||||||
|
expand_membershiplist_tester(large, xlarge, <<"K2">>).
|
||||||
|
|
||||||
segment_match_tester(Size1, Size2) ->
|
segment_match_tester(Size1, Size2, Key) ->
|
||||||
HashKey = keyto_segment32(<<"K0">>),
|
HashKey = keyto_segment32(Key),
|
||||||
Segment1 = get_segment(HashKey, Size1),
|
Segment1 = get_segment(HashKey, Size1),
|
||||||
Segment2 = get_segment(HashKey, Size2),
|
Segment2 = get_segment(HashKey, Size2),
|
||||||
?assertMatch(true, match_segment({Segment1, Size1}, {Segment2, Size2})).
|
?assertMatch(true, match_segment({Segment1, Size1}, {Segment2, Size2})).
|
||||||
|
|
||||||
|
expand_membershiplist_tester(SmallSize, LargeSize, Key) ->
|
||||||
|
HashKey = keyto_segment32(Key),
|
||||||
|
Segment1 = get_segment(HashKey, SmallSize),
|
||||||
|
Segment2 = get_segment(HashKey, LargeSize),
|
||||||
|
AdjList = adjust_segmentmatch_list([Segment1], SmallSize, LargeSize),
|
||||||
|
?assertMatch(true, lists:member(Segment2, AdjList)).
|
||||||
|
|
||||||
|
|
||||||
|
segment_expandsimple_test() ->
|
||||||
|
AdjList = adjust_segmentmatch_list([1, 100], small, medium),
|
||||||
|
io:format("List adjusted to ~w~n", [AdjList]),
|
||||||
|
?assertMatch(true, lists:member(1, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(100, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(65537, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(131073, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(196609, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(65636, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(131172, AdjList)),
|
||||||
|
?assertMatch(true, lists:member(196708, AdjList)),
|
||||||
|
?assertMatch(8, length(AdjList)),
|
||||||
|
OrigList = adjust_segmentmatch_list([1, 100], medium, medium),
|
||||||
|
?assertMatch([1, 100], OrigList).
|
||||||
|
|
||||||
-endif.
|
-endif.
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue