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

Cleanup los processos

Browse Source
This commit is contained in:
Joe DeVivo 2012-12-04 14:47:32 -07:00
parent 95475cda0d
commit 81d6f89f6a
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/loaded_upgrade.erl
View File

@ -59,8 +59,9 @@ verify_upgrade() ->
rt:systest_write(Node1, 100, 3),
?assertEqual([], rt:systest_read(Node1, 100, 1)),
lager:info("Checking list_keys count periodically throughout this test. No news is good news :)"),
spawn_link(?MODULE, check_list_keys, [Node1]),
lager:info("Checking list_keys count periodically throughout this test."),
spawn_link(?MODULE, check_list_keys, [rt:pbc(Node1)]),
Conns = rt:connection_info(Nodes),
NodeConn = proplists:get_value(Node1, Conns),
lager:info("NodeConn: ~p", [NodeConn]),
@ -102,13 +103,17 @@ verify_upgrade() ->
%% ===================================================================
%% List Keys Tester
%% ===================================================================
check_list_keys(Node) ->
Pid = rt:pbc(Node),
check_list_keys(Pid) ->
check_list_keys(Pid, 0).
check_list_keys(Pid, Attempt) ->
case Attempt rem 1000 of
0 -> lager:debug("Performing list_keys check #~p", [Attempt]);
_ -> nothing
end,
{ok, Keys} = riakc_pb_socket:list_keys(Pid, <<"systest">>),
riakc_pb_socket:stop(Pid),
?assertEqual(100, length(Keys)),
timer:sleep(3000),
check_list_keys(Node).
check_list_keys(Pid, Attempt + 1).
%% ===================================================================
%% K/V Tester