final String node1ID = "node1";
final String node2ID = "node2";
- PeerAddressResolver peerAddressResolver = new PeerAddressResolver() {
- @Override
- public String resolve(String peerId) {
- return peerId.equals(node1ID) ? actorFactory.createTestActorPath(node1ID) :
- peerId.equals(node2ID) ? actorFactory.createTestActorPath(node2ID) : null;
- }
- };
+ PeerAddressResolver peerAddressResolver = peerId -> peerId.equals(node1ID) ? actorFactory.createTestActorPath(node1ID) :
+ peerId.equals(node2ID) ? actorFactory.createTestActorPath(node2ID) : null;
ServerConfigurationPayload persistedServerConfig = new ServerConfigurationPayload(Arrays.asList(
new ServerInfo(node1ID, false), new ServerInfo(node2ID, true)));
final String node1ID = "node1";
final String node2ID = "node2";
- PeerAddressResolver peerAddressResolver = new PeerAddressResolver() {
- @Override
- public String resolve(String peerId) {
- return peerId.equals(node1ID) ? actorFactory.createTestActorPath(node1ID) :
- peerId.equals(node2ID) ? actorFactory.createTestActorPath(node2ID) : null;
- }
- };
+ PeerAddressResolver peerAddressResolver = peerId -> peerId.equals(node1ID) ? actorFactory.createTestActorPath(node1ID) :
+ peerId.equals(node2ID) ? actorFactory.createTestActorPath(node2ID) : null;
DefaultConfigParamsImpl configParams = new DefaultConfigParamsImpl();
configParams.setHeartBeatInterval(new FiniteDuration(100, TimeUnit.MILLISECONDS));
final String node1ID = "node1";
final String node2ID = "node2";
- configParams.setPeerAddressResolver(new PeerAddressResolver() {
- @Override
- public String resolve(String peerId) {
- return peerId.equals(node1ID) ? actorFactory.createTestActorPath(node1ID) :
- peerId.equals(node2ID) ? actorFactory.createTestActorPath(node2ID) : null;
- }
- });
+ configParams.setPeerAddressResolver(peerId -> peerId.equals(node1ID) ? actorFactory.createTestActorPath(node1ID) :
+ peerId.equals(node2ID) ? actorFactory.createTestActorPath(node2ID) : null);
ServerConfigurationPayload persistedServerConfig = new ServerConfigurationPayload(Arrays.asList(
new ServerInfo(node1ID, false), new ServerInfo(node2ID, true)));
LOG.info("testChangeToVotingWithNoLeaderAndOtherLeaderElected ending");
}
- private void verifyRaftState(RaftState expState, RaftActor... raftActors) {
+ private static void verifyRaftState(RaftState expState, RaftActor... raftActors) {
Stopwatch sw = Stopwatch.createStarted();
while(sw.elapsed(TimeUnit.SECONDS) <= 5) {
for(RaftActor raftActor: raftActors) {
import org.junit.Test;
import org.mockito.MockitoAnnotations;
import org.opendaylight.controller.cluster.datastore.node.utils.NormalizedNodeNavigator;
-import org.opendaylight.controller.cluster.datastore.node.utils.NormalizedNodeVisitor;
import org.opendaylight.controller.cluster.datastore.util.TestModel;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.AugmentationIdentifier;
MockitoAnnotations.initMocks(this);
}
- private NormalizedNodePruner prunerFullSchema(YangInstanceIdentifier path) {
+ private static NormalizedNodePruner prunerFullSchema(YangInstanceIdentifier path) {
return new NormalizedNodePruner(path, FULL_SCHEMA);
}
- private NormalizedNodePruner prunerNoAugSchema(YangInstanceIdentifier path) {
+ private static NormalizedNodePruner prunerNoAugSchema(YangInstanceIdentifier path) {
return new NormalizedNodePruner(path, NO_AUG_SCHEMA);
}
- private NormalizedNodePruner prunerNoTestSchema(YangInstanceIdentifier path) {
+ private static NormalizedNodePruner prunerNoTestSchema(YangInstanceIdentifier path) {
return new NormalizedNodePruner(path, NO_TEST_SCHEMA);
}
return 0;
}
final AtomicInteger count = new AtomicInteger();
- new NormalizedNodeNavigator(new NormalizedNodeVisitor() {
-
- @Override
- public void visitNode(int level, String parentPath, NormalizedNode<?, ?> normalizedNode) {
- if(!(normalizedNode.getIdentifier() instanceof AugmentationIdentifier)) {
- if (normalizedNode.getIdentifier().getNodeType().getNamespace().toString().contains(namespaceFilter)) {
- count.incrementAndGet();
- }
+ new NormalizedNodeNavigator((level, parentPath, normalizedNode1) -> {
+ if(!(normalizedNode1.getIdentifier() instanceof AugmentationIdentifier)) {
+ if (normalizedNode1.getIdentifier().getNodeType().getNamespace().toString().contains(namespaceFilter)) {
+ count.incrementAndGet();
}
}
}).navigate(YangInstanceIdentifier.EMPTY.toString(), normalizedNode);
cleanedUp = true;
kit.cleanup(configDataStore);
kit.cleanup(operDataStore);
- kit.shutdownActorSystem(kit.getSystem(), Boolean.TRUE);
+ IntegrationTestKit.shutdownActorSystem(kit.getSystem(), Boolean.TRUE);
}
}
type(datastore.getActorContext().getDataStoreName()).build().toString());
}
- verifyRaftState(datastore, shardName, new RaftStateVerifier() {
- @Override
- public void verify(OnDemandRaftState raftState) {
- assertEquals("Peers for shard " + shardName, peerIds, raftState.getPeerAddresses().keySet());
- }
- });
+ verifyRaftState(datastore, shardName, raftState -> assertEquals("Peers for shard " + shardName, peerIds, raftState.getPeerAddresses().keySet()));
}
public static void verifyNoShardPresent(DistributedDataStore datastore, String shardName) {