valitydev/riak_test
14
0
Fork 0
mirror of https://github.com/valitydev/riak_test.git synced 2024-11-06 16:45:29 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add secondary check that all data located with each quantum matches that quantum

Browse Source
This commit is contained in:
John R. Daily 2015-12-31 15:41:07 -05:00
parent 2b4fdaceb5
commit 479c249b44
1 changed files with 32 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
tests/ts_coverage.erl
View File

@ -61,10 +61,17 @@ test_quanta_range(Table, ExpectedData, Nodes, NumQuanta, QuantumMS) ->
?debugFmt("Found ~B coverage entries~n", [length(CoverageEntries)]), ?debugFmt("Found ~B coverage entries~n", [length(CoverageEntries)]),
Results = Results =
lists:foldl(fun(#tscoverageentry{ip=IP, port=Port, cover_context=C}, Acc) -> lists:foldl(fun(#tscoverageentry{ip=IP, port=Port, cover_context=C,
range=TsRange}, Acc) ->
{ok, Pid} = riakc_pb_socket:start_link(binary_to_list(IP), {ok, Pid} = riakc_pb_socket:start_link(binary_to_list(IP),
Port), Port),
{_Headers, ThisQuantum} = riakc_ts:query(Pid, Qry, [], C), {_Headers, ThisQuantum} = riakc_ts:query(Pid, Qry, [], C),
%% Let's compare the range data with the
%% query results to make sure the latter
%% fall within the former
check_data_against_range(ThisQuantum, TsRange),
%% Now add to the pile and continue
ThisQuantum ++ Acc ThisQuantum ++ Acc
end, end,
[], [],
@ -81,3 +88,27 @@ test_quanta_range(Table, ExpectedData, Nodes, NumQuanta, QuantumMS) ->
?assertEqual(lists:sort(ExpectedData), lists:sort(StraightQueryResults)) ?assertEqual(lists:sort(ExpectedData), lists:sort(StraightQueryResults))
end. end.
time_within_range(Time, Lower, LowerIncl, Upper, UpperIncl) ->
if
Lower > Time ->
false;
Upper < Time ->
false;
Lower < Time andalso Time < Upper ->
true;
Lower == Time ->
LowerIncl;
Upper == Time ->
UpperIncl
end.
check_data_against_range(Data, #tsrange{lower_bound=Lower,
lower_bound_inclusive=LowerIncl,
upper_bound=Upper,
upper_bound_inclusive=UpperIncl}) ->
?assertEqual([], lists:filter(fun({_, _, Time, _, _}) ->
not time_within_range(Time, Lower, LowerIncl,
Upper, UpperIncl)
end,
Data)).