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

WIP

Browse Source
This commit is contained in:
Russell Brown 2014-10-15 09:59:54 +01:00
parent a1af1140f0
commit d86d122308
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/kv679_dataloss.erl
View File

@ -109,7 +109,6 @@ write_object(Client, Object, Opts) ->
riakc_pb_socket:put(Client, Object, Opts).
delete_datadir({{Idx, Node}, Type}) ->
%% stop node
lager:info("deleting backend data dir for ~p ~p on ~p",
[Idx, Node, Type]),
%% Get default backend
@ -127,9 +126,9 @@ delete_datadir({{Idx, Node}, Type}) ->
integer_to_list(Idx)]),
lager:info("Path ~p~n", [Path]),
%% stop node
rt:stop_and_wait(Node),
%% vnode_util:kill_vnode({Idx, Node}),
del_dir(Path),
rt:start_and_wait(Node).

16
tests/kv679_dataloss_fb.erl
View File

@ -57,9 +57,9 @@ confirm() ->
{vnode_inactivity_timeout, 1000}]}]},
{bitcask, [{sync_strategy, o_sync}, {io_mode, nif}]}],
%% 5 'cos I want a perfect preflist when 2 primaries are down.
%% i.e. I want to kill the fallbacks before they can handoff
%% without effecting the primaries
%% Such nodes 'cos I want a perfect preflist when 2 primaries are
%% down. i.e. I want to kill the fallbacks before they can
%% handoff without effecting the primaries
Nodes = rt:build_cluster(6, Conf),
Clients = kv679_tombstone:create_pb_clients(Nodes),
@ -90,7 +90,7 @@ confirm() ->
lager:info("Got a preflist with coord and 2 fbs ~p~n", [FBPL]),
%% Write key twice at C1
%% Write key twice at remaining, coordinating primary
kv679_tombstone:write_key(CoordClient, [<<"bob">>, <<"jim">>]),
kv679_tombstone2:dump_clock(CoordClient),
@ -118,7 +118,7 @@ confirm() ->
kv679_tombstone2:dump_clock(CoordClient),
%% Kill those primaries with there frontier clocks
%% Kill those primaries with their frontier clocks
[rt:brutal_kill(P) || P <- OtherPrimaries],
lager:info("killed primaries again"),
@ -148,8 +148,8 @@ confirm() ->
kv679_tombstone2:dump_clock(CoordClient),
%% Time start up those primaries, let handoff happen, and see what
%% happens to that last write
%% Time to start up those primaries, let handoff happen, and see
%% what happened to that last write
[rt:start_and_wait(P) || P <- OtherPrimaries],
@ -174,6 +174,8 @@ confirm() ->
?assertMatch({ok, _}, Res),
{ok, O} = Res,
%% A nice riak would have somehow managed to make a sibling of the
%% last write
?assertEqual([<<"anne">>, <<"joe">>], riakc_obj:get_values(O)),
pass.