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

check ring state for ensemble_remove_node

Browse Source
This commit is contained in:
Andrew J. Stone 2014-04-23 15:47:43 -04:00
parent f171095ad2
commit 0cb1bd4357
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/ensemble_remove_node2.erl
View File

@ -70,15 +70,20 @@ confirm() ->
%% TODO: How do we wait indefinitely for nodes to never exit here? A 30s
%% sleep?
timer:sleep(30000),
%% Nodes should still be in leaving state
{ok, Ring} = rpc:call(Node, riak_core_ring_manager, get_raw_ring, []),
Leaving = lists:usort(riak_core_ring:members(Ring, [leaving])),
?assertEqual(Leaving, [Node2, Node3]),
%% We should still be able to read from k/v ensembles, but the nodes should
%% never exit
lager:info("Reading From SC Bucket"),
Val2 = rt:pbc_read(PBC, Bucket, Key),
?assertEqual(element(1, Val2), riakc_obj),
%%ok = rt:wait_until_unpingable(Node2),
%%ok = rt:wait_until_unpingable(Node3),
lager:info("Read value from the root ensemble"),
{ok, _Obj} = riak_ensemble_client:kget(Node, root, testerooni, 1000),
Members3 = rpc:call(Node, riak_ensemble_manager, get_members, [root]),