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

Merge pull request #716 from basho/bugfix/ensemble_basic3

Browse Source 
Use result of fold in ensemble_basic3
This commit is contained in:
Andrew J. Stone 2014-12-24 12:57:52 -05:00
commit 1addf5207f
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/ensemble_basic3.erl
View File

@ -78,10 +78,7 @@ confirm() ->
end || VN={VIdx, VNode} <- MajorityVN],
L2 = orddict:from_list(L),
lager:info("Sleeping for 5s"),
timer:sleep(5000),
lists:foldl(fun({VN={VIdx, VNode}, Pid}, Suspended) ->
L3 = lists:foldl(fun({VN={VIdx, VNode}, Pid}, Suspended) ->
lager:info("Resuming vnode: ~p", [VIdx]),
vnode_util:resume_vnode(Pid),
ensemble_util:wait_until_stable(Node, Quorum),
@ -90,10 +87,10 @@ confirm() ->
lager:info("Suspending vnode: ~p", [VIdx]),
Pid2 = vnode_util:suspend_vnode(VNode, VIdx),
orddict:store(VN, Pid2, Suspended)
end, L2, L2),
end, orddict:new(), L2),
lager:info("Resuming all vnodes"),
[vnode_util:resume_vnode(Pid) || {_, Pid} <- L2],
[vnode_util:resume_vnode(Pid) || {_, Pid} <- L3],
ensemble_util:wait_until_stable(Node, NVal),
lager:info("Re-reading keys"),
[rt:pbc_read(PBC, Bucket, Key) || Key <- Keys],