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

Add test for crash recovery in riak_kv_sweeper

Browse Source
This commit is contained in:
Mikael Lixenstrand 2015-12-04 16:23:11 +01:00 committed by Nick Marino
parent 4afcbaf7cf
commit f2e3783f20
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tests/verify_sweep_reaper.erl
View File

@ -75,6 +75,11 @@ confirm() ->
KV3 = test_data(201, 201),
verify_manual_sweep(Nodes, KV3),
%% Verify recovery
kill_riak_kv_sweeper(Nodes),
KV16 = test_data(16001, 16100),
verify_manual_sweep(Nodes, KV16),
KV4 = test_data(301, 400),
verify_remove_add_participant(Nodes, KV4),
@ -96,6 +101,7 @@ confirm() ->
KV15 = test_data(15001, 16000),
test_status(Nodes, KV15),
pass.
%% No reaps with long grace period.
@ -279,6 +285,13 @@ disable_aae(Node) ->
lager:info("disable aae", []),
rpc:call(Node, riak_kv_entropy_manager, disable, []).
kill_riak_kv_sweeper(Nodes) ->
[begin
Pid = rpc:call(Node, erlang, whereis,[riak_kv_sweeper]),
?assert(rpc:call(Node, erlang, exit, [Pid, kill])),
rt:wait_until(Node, fun(N) -> not(rpc:call(N, erlang, is_process_alive, [Pid])) end),
rt:wait_until(Node, fun(N) -> is_pid(rpc:call(N, erlang, whereis,[riak_kv_sweeper])) end)
end || Node <- Nodes].
wait_for_sweep() ->
wait_for_sweep(?WAIT_FOR_SWEEP).