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

Now even less code, thanks lists:foldl

Browse Source
This commit is contained in:
Joe DeVivo 2012-09-25 12:47:58 -07:00
parent 6297bd6acd
commit 839dbd2d4a
1 changed files with 14 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
tests/verify_listkeys.erl
View File

@ -35,38 +35,20 @@ confirm() ->
rt:stop(Node1),
rt:wait_until_unpingable(Node1),
lager:info("Stopping Node2"),
rt:stop(Node2),
rt:wait_until_unpingable(Node2),
lager:info("Starting Node1"),
rt:start(Node1),
rt:wait_until_pingable(Node1),
lager:info("Check keys and buckets"),
check_it_all([Node1, Node3, Node4]),
lager:info("Starting Node2"),
rt:start(Node2),
rt:wait_until_pingable(Node2),
lager:info("Stopping Node3"),
rt:stop(Node3),
rt:wait_until_unpingable(Node3),
lager:info("Check keys and buckets"),
check_it_all([Node1, Node2, Node4]),
lager:info("Starting Node3"),
rt:start(Node3),
rt:wait_until_pingable(Node3),
lager:info("Stopping Node4"),
rt:stop(Node4),
rt:wait_until_unpingable(Node4),
lager:info("Check keys and buckets"),
check_it_all([Node1, Node2, Node3]),
%% Stop current node, restart previous node, verify
lists:foldl(fun(Node, Prev) ->
lager:info("Stopping Node ~p", [Node]),
rt:stop(Node),
rt:wait_until_unpingable(Node),
lager:info("Starting Node ~p", [Prev]),
rt:start(Prev),
rt:wait_until_pingable(Prev),
lager:info("Check keys and buckets"),
check_it_all(Nodes -- [Node]),
Node
end, Node1, [Node2, Node3, Node4]),
lager:info("Stopping Node2"),
rt:stop(Node2),