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

Wait for crdt epoch caps before proceeding

Browse Source
This commit is contained in:
Russell Brown 2016-06-13 16:49:58 +01:00
parent 598dfd0f55
commit 68f1f15fe4
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/riak667_mixed.erl
View File

@ -118,7 +118,7 @@ confirm() ->
riakc_pb_socket:stop(N1C1),
N1C2 = rt:pbc(Node1),
%% upgrade 2.0.4 to 2.0.5
%% upgrade 2.0.4 to current
riakc_pb_socket:stop(N2C2),
upgrade(Node2, current),
@ -147,7 +147,7 @@ confirm() ->
ok = riakc_pb_socket:update_type(N2C3, ?BUCKET, ?KEY, riakc_map:to_op(K1OU)),
lager:notice("Updated 2.0.2 map on ~s", [CurrentVer]),
%% read 2.0.2 map from 2.0.2 node ?KEY Pid
{ok, K1OR} = riakc_pb_socket:fetch_type(N1C2, ?BUCKET, ?KEY),
lager:notice("Read 2.0.2 map from 2.0.2 node: ~p", [K1OR]),
@ -189,6 +189,8 @@ confirm() ->
upgrade(Node1, current),
lager:notice("Upgraded 2.0.2 node to ~s", [CurrentVer]),
rt:wait_until_capability_contains(Node1, {riak_kv,crdt_epoch_versions}, {riak_dt_map,2}),
%% read and write maps
N1C3 = rt:pbc(Node1),