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 tests for replication of deletes for fullsync

Browse Source
This commit is contained in:
Nick Marino 2016-05-04 15:44:05 -04:00
parent 8daebc1663
commit ffd45d0009
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/repl_aae_fullsync.erl
View File

@ -371,6 +371,7 @@ difference_test() ->
[LeaderA, "B"]),
lager:info("Fullsync completed in ~p seconds", [Time1/1000/1000]),
lager:info("Checking that object was replicated to cluster B"),
%% Read key from after fullsync.
{ok, O1} = riakc_pb_socket:get(BPBC, <<"foo">>, <<"bar">>,
[{timeout, 4000}]),
@ -388,11 +389,22 @@ difference_test() ->
[LeaderA, "B"]),
lager:info("Fullsync completed in ~p seconds", [Time2/1000/1000]),
lager:info("Checking that sibling data was replicated to cluster B"),
%% Read key from after fullsync.
{ok, O2} = riakc_pb_socket:get(BPBC, <<"foo">>, <<"bar">>,
[{timeout, 4000}]),
?assertEqual([<<"baz">>, <<"baz2">>], lists:sort(riakc_obj:get_values(O2))),
ok = riakc_pb_socket:delete(APBC, <<"foo">>, <<"bar">>, [{timeout, 4000}]),
{Time3, _} = timer:tc(repl_util,
start_and_wait_until_fullsync_complete,
[LeaderA, "B"]),
lager:info("Fullsync completed in ~p seconds", [Time3/1000/1000]),
lager:info("Checking that deletion was replicated to cluster B"),
{error, notfound} = riakc_pb_socket:get(BPBC, <<"foo">>, <<"bar">>, [{timeout, 4000}]),
rt:clean_cluster(Nodes),
pass.