import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;
+
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Address;
public void waitForMemberDown(String member) {
Stopwatch sw = Stopwatch.createStarted();
- while(sw.elapsed(TimeUnit.SECONDS) <= 10) {
+ 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())) {
+ 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())) {
+ for (Member m : state.getMembers()) {
+ if (m.status() != MemberStatus.up() && member.equals(m.getRoles().iterator().next())) {
return;
}
}
}
public void cleanup() {
- if(!cleanedUp) {
+ if (!cleanedUp) {
cleanedUp = true;
if (configDataStore != null) {
configDataStore.close();
AssertionError lastError = null;
Stopwatch sw = Stopwatch.createStarted();
- while(sw.elapsed(TimeUnit.SECONDS) <= 5) {
- OnDemandRaftState raftState = (OnDemandRaftState)actorContext.
- executeOperation(shardActor, GetOnDemandRaftState.INSTANCE);
+ while (sw.elapsed(TimeUnit.SECONDS) <= 5) {
+ OnDemandRaftState raftState = (OnDemandRaftState)actorContext
+ .executeOperation(shardActor, GetOnDemandRaftState.INSTANCE);
try {
verifier.verify(raftState);
public static void verifyRaftPeersPresent(DistributedDataStore datastore, final String shardName,
String... peerMemberNames) throws Exception {
final Set<String> peerIds = Sets.newHashSet();
- for(String p: peerMemberNames) {
+ for (String p: peerMemberNames) {
peerIds.add(ShardIdentifier.create(shardName, MemberName.forName(p),
datastore.getActorContext().getDataStoreName()).toString());
}
public static void verifyNoShardPresent(DistributedDataStore datastore, String shardName) {
Stopwatch sw = Stopwatch.createStarted();
- while(sw.elapsed(TimeUnit.SECONDS) <= 5) {
+ while (sw.elapsed(TimeUnit.SECONDS) <= 5) {
Optional<ActorRef> shardReply = datastore.getActorContext().findLocalShard(shardName);
- if(!shardReply.isPresent()) {
+ if (!shardReply.isPresent()) {
return;
}
private String testName;
private SchemaContext schemaContext;
private boolean createOperDatastore = true;
- private DatastoreContext.Builder datastoreContextBuilder = DatastoreContext.newBuilder().
- shardHeartbeatIntervalInMillis(300).shardElectionTimeoutFactor(30);
+ private DatastoreContext.Builder datastoreContextBuilder = DatastoreContext.newBuilder()
+ .shardHeartbeatIntervalInMillis(300).shardElectionTimeoutFactor(30);
Builder(List<MemberNode> members) {
this.members = members;
*
* @return this Builder
*/
- public Builder moduleShardsConfig(String moduleShardsConfig) {
- this.moduleShardsConfig = moduleShardsConfig;
+ public Builder moduleShardsConfig(String newModuleShardsConfig) {
+ this.moduleShardsConfig = newModuleShardsConfig;
return this;
}
*
* @return this Builder
*/
- public Builder akkaConfig(String akkaConfig) {
- this.akkaConfig = akkaConfig;
+ public Builder akkaConfig(String newAkkaConfig) {
+ this.akkaConfig = newAkkaConfig;
return this;
}
*
* @return this Builder
*/
- public Builder testName(String testName) {
- this.testName = testName;
+ public Builder testName(String newTestName) {
+ this.testName = newTestName;
return this;
}
*
* @return this Builder
*/
- public Builder schemaContext(SchemaContext schemaContext) {
- this.schemaContext = schemaContext;
+ public Builder schemaContext(SchemaContext newSchemaContext) {
+ this.schemaContext = newSchemaContext;
return this;
}
Preconditions.checkNotNull(akkaConfig, "akkaConfig must be specified");
Preconditions.checkNotNull(testName, "testName must be specified");
- if(schemaContext == null) {
+ if (schemaContext == null) {
schemaContext = SchemaContextHelper.full();
}
node.configDataStore = node.kit.setupDistributedDataStore("config_" + testName, moduleShardsConfig,
true, schemaContext, waitForshardLeader);
- if(createOperDatastore) {
+ if (createOperDatastore) {
node.kit.getDatastoreContextBuilder().shardManagerPersistenceId("shard-manager-oper-" + memberName);
node.operDataStore = node.kit.setupDistributedDataStore("oper_" + testName, moduleShardsConfig,
true, schemaContext, waitForshardLeader);
public interface RaftStateVerifier {
void verify(OnDemandRaftState raftState);
}
-}
\ No newline at end of file
+}