fail("Member(s) " + otherMembersSet + " are not Up");
}
+ public void waitForMemberDown(String member) {
+ Stopwatch sw = Stopwatch.createStarted();
+ while(sw.elapsed(TimeUnit.SECONDS) <= 10) {
+ CurrentClusterState state = Cluster.get(kit.getSystem()).state();
+ for(Member m: state.getUnreachable()) {
+ if(member.equals(m.getRoles().iterator().next())) {
+ return;
+ }
+ }
+
+ for(Member m: state.getMembers()) {
+ if(m.status() != MemberStatus.up() && member.equals(m.getRoles().iterator().next())) {
+ return;
+ }
+ }
+
+ Uninterruptibles.sleepUninterruptibly(100, TimeUnit.MILLISECONDS);
+ }
+
+ fail("Member " + member + " is now down");
+ }
+
public void cleanup() {
if(!cleanedUp) {
cleanedUp = true;
final Set<String> peerIds = Sets.newHashSet();
for(String p: peerMemberNames) {
peerIds.add(ShardIdentifier.builder().memberName(p).shardName(shardName).
- type(datastore.getActorContext().getDataStoreType()).build().toString());
+ type(datastore.getActorContext().getDataStoreName()).build().toString());
}
verifyRaftState(datastore, shardName, new RaftStateVerifier() {