private void switchBehavior(SwitchBehavior message) {
if (!getRaftActorContext().getRaftPolicy().automaticElectionsEnabled()) {
RaftState newState = message.getNewState();
- if ( newState == RaftState.Leader || newState == RaftState.Follower) {
+ if (newState == RaftState.Leader || newState == RaftState.Follower) {
switchBehavior(behaviorStateTracker.capture(getCurrentBehavior()),
AbstractRaftActorBehavior.createBehavior(context, message.getNewState()));
getRaftActorContext().getTermInformation().updateAndPersist(message.getNewTerm(), "");
}
boolean handleSnapshotMessage(Object message, ActorRef sender) {
- if (message instanceof ApplySnapshot ) {
+ if (message instanceof ApplySnapshot) {
onApplySnapshot((ApplySnapshot) message);
} else if (message instanceof SaveSnapshotSuccess) {
onSaveSnapshotSuccess((SaveSnapshotSuccess) message);
mockRaftActor.waitForRecoveryComplete();
RaftActorRecoverySupport mockSupport = mock(RaftActorRecoverySupport.class);
- mockRaftActor.setRaftActorRecoverySupport(mockSupport );
+ mockRaftActor.setRaftActorRecoverySupport(mockSupport);
Snapshot snapshot = Snapshot.create(ByteState.of(new byte[]{1}),
Collections.<ReplicatedLogEntry>emptyList(), 3, 1, 3, 1, -1, null, null);
@Override
protected MockRaftActorContext createActorContext(ActorRef actorRef) {
MockRaftActorContext context = new MockRaftActorContext("follower", getSystem(), actorRef);
- context.setPayloadVersion(payloadVersion );
+ context.setPayloadVersion(payloadVersion);
return context;
}
newBehavior = isolatedLeader.handleMessage(senderActor,
new AppendEntriesReply("follower-2", isolatedLeader.lastTerm() - 1, true,
- isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short)0 ));
+ isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short) 0));
assertEquals("Raft state", RaftState.Leader, newBehavior.state());
}
// in a 5 member cluster, atleast 2 followers need to be active and return a reply
RaftActorBehavior newBehavior = isolatedLeader.handleMessage(senderActor,
new AppendEntriesReply("follower-1", isolatedLeader.lastTerm() - 1, true,
- isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short)0 ));
+ isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short) 0));
assertEquals("Raft state", RaftState.IsolatedLeader, newBehavior.state());
newBehavior = isolatedLeader.handleMessage(senderActor,
new AppendEntriesReply("follower-2", isolatedLeader.lastTerm() - 1, true,
- isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short)0 ));
+ isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short) 0));
assertEquals("Raft state", RaftState.Leader, newBehavior.state());
newBehavior = isolatedLeader.handleMessage(senderActor,
new AppendEntriesReply("follower-3", isolatedLeader.lastTerm() - 1, true,
- isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short)0 ));
+ isolatedLeader.lastIndex() - 1, isolatedLeader.lastTerm() - 1, (short) 0));
assertEquals("Raft state", RaftState.Leader, newBehavior.state());
}
leaderActor, ApplyState.class);
assertEquals("ApplyState count", newLogIndex, applyStateList.size());
- for (int i = 0; i <= newLogIndex - 1; i++ ) {
+ for (int i = 0; i <= newLogIndex - 1; i++) {
ApplyState applyState = applyStateList.get(i);
assertEquals("getIndex", i + 1, applyState.getReplicatedLogEntry().getIndex());
assertEquals("getTerm", term, applyState.getReplicatedLogEntry().getTerm());
public void testAddShardReplica() throws Exception {
String name = "testAddShardReplica";
String moduleShardsConfig = "module-shards-cars-member-1.conf";
- MemberNode leaderNode1 = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name )
+ MemberNode leaderNode1 = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name)
.moduleShardsConfig(moduleShardsConfig).waitForShardLeader("cars").build();
MemberNode newReplicaNode2 = MemberNode.builder(memberNodes).akkaConfig("Member2").testName(name)
public void testAddReplicasForAllShards() throws Exception {
String name = "testAddReplicasForAllShards";
String moduleShardsConfig = "module-shards-member1.conf";
- MemberNode leaderNode1 = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name )
+ MemberNode leaderNode1 = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name)
.moduleShardsConfig(moduleShardsConfig).waitForShardLeader("cars", "people").build();
ModuleShardConfiguration petsModuleConfig = new ModuleShardConfiguration(URI.create("pets-ns"), "pets-module",
}
}
- private static Gauge<Integer> getQueueSizeGuage(final MeteredMessageQueue monitoredQueue ) {
+ private static Gauge<Integer> getQueueSizeGuage(final MeteredMessageQueue monitoredQueue) {
return () -> monitoredQueue.size();
}
break;
default :
throw new IllegalStateException("Unknown node identifier type is found : "
- + pathArgument.getClass().toString() );
+ + pathArgument.getClass().toString());
}
}
QName expected = TestModel.AUG_NAME_QNAME;
QName created = QNameFactory.create(expected.toString());
- assertFalse( expected == created);
+ assertFalse(expected == created);
assertEquals(expected, created);
assertEquals(expected, cached);
- assertTrue( cached == created );
+ assertTrue(cached == created);
}
}
@Test
public void testWithSerializable() {
NormalizedNode<?, ?> input = TestModel.createTestContainer();
- SampleNormalizedNodeSerializable serializable = new SampleNormalizedNodeSerializable(input );
+ SampleNormalizedNodeSerializable serializable = new SampleNormalizedNodeSerializable(input);
SampleNormalizedNodeSerializable clone =
(SampleNormalizedNodeSerializable)SerializationUtils.clone(serializable);
try {
this.listener.onDataChanged(change);
} catch (RuntimeException e) {
- LOG.error( String.format( "Error notifying listener %s", this.listener ), e );
+ LOG.error(String.format("Error notifying listener %s", this.listener), e);
}
if (isValidSender(getSender())) {
OnDemandRaftState raftState = (OnDemandRaftState) response;
Map<String, Boolean> serverVotingStatusMap = new HashMap<>();
- for ( Entry<String, Boolean> e: raftState.getPeerVotingStates().entrySet()) {
+ for (Entry<String, Boolean> e: raftState.getPeerVotingStates().entrySet()) {
serverVotingStatusMap.put(e.getKey(), !e.getValue());
}
*
* @param shardName the name of the local shard that needs to be found
*/
- public Future<ActorRef> findLocalShardAsync( final String shardName) {
+ public Future<ActorRef> findLocalShardAsync(final String shardName) {
Future<Object> future = executeOperationAsync(shardManager,
new FindLocalShard(shardName, true), shardInitializationTimeout);
}
@SuppressWarnings("unchecked")
- private <T> FutureCallback<T> mockFutureCallback(final FutureCallback<T> actual ) {
+ private <T> FutureCallback<T> mockFutureCallback(final FutureCallback<T> actual) {
FutureCallback<T> mock = mock(FutureCallback.class);
doAnswer(invocation -> {
actual.onFailure(invocation.getArgumentAt(0, Throwable.class));
@Override
public Set<YangInstanceIdentifier> getRemovedPaths() {
Set<YangInstanceIdentifier> ids = new HashSet<>();
- ids.add( CompositeModel.TEST_PATH);
+ ids.add(CompositeModel.TEST_PATH);
return ids;
}
public void testUpdate() {
DatastoreContext context = DatastoreContext.newBuilder()
.logicalStoreType(LogicalDatastoreType.OPERATIONAL).build();
- DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(context );
+ DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(context);
Dictionary<String, Object> properties = new Hashtable<>();
properties.put("shard-transaction-idle-timeout-in-minutes", "31");
public void testUpdateWithInvalidValues() {
DatastoreContext context = DatastoreContext.newBuilder()
.logicalStoreType(LogicalDatastoreType.OPERATIONAL).build();
- DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(context );
+ DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(context);
Dictionary<String, Object> properties = new Hashtable<>();
properties.put("shard-transaction-idle-timeout-in-minutes", "0"); // bad - must be > 0
List<ShardSnapshot> shardSnapshots = new ArrayList<>();
shardSnapshots.add(new ShardSnapshot("cars", new byte[]{1,2}));
shardSnapshots.add(new ShardSnapshot("people", new byte[]{3,4}));
- final DatastoreSnapshot configSnapshot = new DatastoreSnapshot("config", null, shardSnapshots );
+ final DatastoreSnapshot configSnapshot = new DatastoreSnapshot("config", null, shardSnapshots);
shardSnapshots = new ArrayList<>();
shardSnapshots.add(new ShardSnapshot("cars", new byte[]{5,6}));
shardSnapshots.add(new ShardSnapshot("people", new byte[]{7,8}));
shardSnapshots.add(new ShardSnapshot("bikes", new byte[]{9,0}));
- DatastoreSnapshot operSnapshot = new DatastoreSnapshot("oper", null, shardSnapshots );
+ DatastoreSnapshot operSnapshot = new DatastoreSnapshot("oper", null, shardSnapshots);
DatastoreSnapshotList snapshotList = new DatastoreSnapshotList();
snapshotList.add(configSnapshot);
initDatastoresWithCars(testName);
String followerCarShardName = "member-2-shard-cars-" + testName;
- InMemoryJournal.addWriteMessagesCompleteLatch(followerCarShardName, 2, ApplyJournalEntries.class );
+ InMemoryJournal.addWriteMessagesCompleteLatch(followerCarShardName, 2, ApplyJournalEntries.class);
DOMStoreWriteTransaction writeTx = followerDistributedDataStore.newWriteOnlyTransaction();
assertNotNull("newWriteOnlyTransaction returned null", writeTx);
initDatastoresWithCars(testName);
String followerCarShardName = "member-2-shard-cars-" + testName;
- InMemoryJournal.addWriteMessagesCompleteLatch(followerCarShardName, 1, ApplyJournalEntries.class );
+ InMemoryJournal.addWriteMessagesCompleteLatch(followerCarShardName, 1, ApplyJournalEntries.class);
// Write top-level car container from the follower so it uses a remote Tx.
}
private static Props props(final boolean found, final ActorRef actorRef) {
- return Props.create(new MockShardManagerCreator(found, actorRef) );
+ return Props.create(new MockShardManagerCreator(found, actorRef));
}
private static Props props() {
- return Props.create(new MockShardManagerCreator() );
+ return Props.create(new MockShardManagerCreator());
}
@SuppressWarnings("serial")
bucketStore = new BucketStoreAccess(getContext(), config.getAskDuration());
- if (provider instanceof ClusterActorRefProvider ) {
+ if (provider instanceof ClusterActorRefProvider) {
cluster = Cluster.get(getContext().system());
cluster.subscribe(getSelf(),
ClusterEvent.initialStateAsEvents(),