greg/machi
1
0
Fork 0
Code Issues 11 Pull requests 1 Projects Releases Packages Wiki Activity Actions

Test refactoring 2

Browse source
This commit is contained in:
Scott Lystig Fritchie 2014-08-24 22:46:21 +09:00
parent 9d2f494db0
commit c311a187ac
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
prototype/tango-prototype/test/tango_test.erl
View file

@ -88,19 +88,29 @@ write_forward_test_int(PageSize, _Seq, P1) ->
Pages = [term_to_binary({smoke, X}) || X <- lists:seq(1, NumPages)], Pages = [term_to_binary({smoke, X}) || X <- lists:seq(1, NumPages)],
BackPs0 = [{StreamNum, []}], BackPs0 = [{StreamNum, []}],
{P2, BackPs1} = write_stream_pages(P1, Pages, PageSize, BackPs0, StreamNum), {P2, BackPs1} = write_stream_pages(P1, Pages, PageSize, BackPs0, StreamNum),
{_P3, _BackPs2} = write_stream_pages(P2, Pages, PageSize, BackPs1, StreamNum), {_P3, _BackPs2} = write_stream_pages(P2, Pages, PageSize, BackPs1, StreamNum, 3),
ok. ok.
write_stream_pages(Proj0, Pages, PageSize, InitialBackPs, StreamNum) -> write_stream_pages(Proj0, Pages, PageSize, InitialBackPs, StreamNum) ->
write_stream_pages(Proj0, Pages, PageSize, InitialBackPs, StreamNum, 0).
write_stream_pages(Proj0, Pages, PageSize, InitialBackPs, StreamNum, Junk) ->
WriteJunk = fun() -> JP0 = tango:pack_v1([], <<>>, PageSize),
{{ok, _}, _} = corfurl_client:append_page(Proj0, JP0)
end,
F = fun(Page, {Proj1, BackPs}) -> F = fun(Page, {Proj1, BackPs}) ->
if Junk band 1 /= 0 -> WriteJunk();
true -> ok end,
FullPage = tango:pack_v1(BackPs, Page, PageSize), FullPage = tango:pack_v1(BackPs, Page, PageSize),
{{ok, LPN}, Proj2} = {{ok, LPN}, Proj2} =
corfurl_client:append_page(Proj1, FullPage), corfurl_client:append_page(Proj1, FullPage),
if Junk band 1 /= 0 -> WriteJunk();
true -> ok end,
{Proj2, tango:add_back_pointer(StreamNum, BackPs, LPN)} {Proj2, tango:add_back_pointer(StreamNum, BackPs, LPN)}
end, end,
{_Px, BackPs} = Res = lists:foldl(F, {Proj0, InitialBackPs}, Pages), {_Px, BackPs} = Res = lists:foldl(F, {Proj0, InitialBackPs}, Pages),
io:format(user, "BackPs ~p\n", [BackPs]), io:format(user, "BackPs ~w\n", [BackPs]),
Res. Res.
scan_backward_test() -> scan_backward_test() ->