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

Use wait_for and actually check the results of riak-admin cluster join

Browse Source 
to ensure we've really joined the cluster before we continue the test.
This commit is contained in:
Doug Rohrer 2015-08-26 13:36:30 -04:00
parent c00dabd443
commit 9c2db4b148
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/verify_staged_clustering.erl
View File

@ -121,7 +121,11 @@ n(Atom) ->
stage_join(Node, OtherNode) -> stage_join(Node, OtherNode) ->
%% rpc:call(Node, riak_kv_console, staged_join, [[n(OtherNode)]]). %% rpc:call(Node, riak_kv_console, staged_join, [[n(OtherNode)]]).
rt:admin(Node, ["cluster", "join", n(OtherNode)]). JoinFun = fun() ->
{ok, Result} = rt:admin(Node, ["cluster", "join", n(OtherNode)]),
lists:prefix("Success:", Result)
end,
rt:wait_until(JoinFun, 5, 1000).
stage_leave(Node, OtherNode) -> stage_leave(Node, OtherNode) ->
%% rpc:call(Node, riak_core_console, stage_leave, [[n(OtherNode)]]). %% rpc:call(Node, riak_core_console, stage_leave, [[n(OtherNode)]]).