import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
import org.opendaylight.transportpce.common.fixedflex.SpectrumInformation;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.OpticalControlMode;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.degree.ConnectionPorts;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.degree.ConnectionPortsBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.org.openroadm.device.container.OrgOpenroadmDevice;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.org.openroadm.device.container.org.openroadm.device.RoadmConnections;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.org.openroadm.device.container.org.openroadm.device.RoadmConnectionsKey;
Mockito.when(deviceTransactionManager.getDeviceTransaction("deviceId"))
.thenReturn(CompletableFuture.completedFuture(Optional.of(mock(DeviceTransaction.class))));
- boolean res = crossConnectImpl121
- .setPowerLevel("deviceId", OpticalControlMode.Power, new BigDecimal(100), "1");
+ crossConnectImpl121.setPowerLevel("deviceId", OpticalControlMode.Power, new BigDecimal(100), "1");
Assert.assertTrue("set Level should be true", true);
}
-
- private ConnectionPorts getConnectionPorts(String c1, String p1) {
- return new ConnectionPortsBuilder().setCircuitPackName(c1).setPortName(p1).build();
- }
}
import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
import org.opendaylight.transportpce.common.fixedflex.SpectrumInformation;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.NodesBuilder;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.NodesKey;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.OpticalControlMode;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.degree.ConnectionPorts;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.degree.ConnectionPortsBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.OrgOpenroadmDevice;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.org.openroadm.device.RoadmConnections;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.org.openroadm.device.RoadmConnectionsKey;
Mockito.when(deviceTransactionManager.getDeviceTransaction("deviceId"))
.thenReturn(CompletableFuture.completedFuture(Optional.of(mock(DeviceTransaction.class))));
- boolean res = crossConnectImpl221
- .setPowerLevel("deviceId", OpticalControlMode.GainLoss, new BigDecimal(100), "1");
+ crossConnectImpl221.setPowerLevel("deviceId", OpticalControlMode.GainLoss, new BigDecimal(100), "1");
Assert.assertTrue("set Level should be true", true);
}
@Test(expected = NullPointerException.class)
public void postOtnCrossConnect() {
- NodesBuilder nodesBldr = new NodesBuilder().withKey(new NodesKey("nodeId")).setNodeId("nodeId");
Nodes nodes = Mockito.mock(Nodes.class);
Mockito.when(nodes.getNodeId()).thenReturn("nodeId");
Mockito.when(deviceTransactionManager.getDeviceTransaction(any()))
Optional<String> res = crossConnectImpl221.postOtnCrossConnect(List.of("src1", "src2"), nodes);
Assert.assertTrue("Optional value should have a value", res.isPresent());
}
-
-
- private ConnectionPorts getConnectionPorts(String c1, String p1) {
- return new ConnectionPortsBuilder().setCircuitPackName(c1).setPortName(p1).build();
- }
}
when(mappingUtils.getOpenRoadmVersion(any())).thenReturn(devV121);
when(crossConnectImpl121.setPowerLevel(any(), any(), any(), any()))
.thenReturn(true);
- res = crossConnectImpl.setPowerLevel("100", "srcTp", new BigDecimal(100), "power");
+ //FIXME: this part of the test needs to be reviewed
+ crossConnectImpl.setPowerLevel("100", "srcTp", new BigDecimal(100), "power");
Assert.assertTrue(true);
}
}
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.port.Interfaces;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.port.InterfacesBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.port.PartnerPortBuilder;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.interfaces.rev161014.OpenROADMOpticalMultiplex;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.interfaces.rev161014.OpticalTransport;
import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev161014.Protocols1Builder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev161014.lldp.container.LldpBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev161014.lldp.container.lldp.PortConfig;
Ports ports = getPortsWithInterfaces(interfacesList, "p1");
List<Ports> portsList = Arrays.asList(ports);
- // mock 2 bidirectional port for SRG
- Ports ports1 = getPortsWithInterfaces(interfacesList, "p2");
- List<Ports> portsList1 = Arrays.asList(ports1);
-
// mock 2 unidirectional ports for degree
Ports ports2 = getPorts("p2", Port.PortQual.RoadmExternal, "c3", "p3", Direction.Rx);
Ports ports3 = getPorts("p3", Port.PortQual.RoadmExternal, "c3", "p2", Direction.Tx);
when(deviceTransactionManager.getDataFromDevice("node", LogicalDatastoreType.OPERATIONAL, portID,
Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT)).thenReturn(Optional.of(ports));
+ // mock 2 bidirectional port for SRG
+ Ports ports1 = getPortsWithInterfaces(interfacesList, "p2");
InstanceIdentifier<Ports> portID1 = getChild("c2", "p1");
when(deviceTransactionManager.getDataFromDevice("node",
LogicalDatastoreType.OPERATIONAL, portID1,
Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT))
.thenReturn(Optional.of(ordmSrgObject6));
- Interface ifc1 = new InterfaceBuilder().withKey(new InterfaceKey("ifc1"))
- .setType(OpticalTransport.class).build();
- Interface ifc2 = new InterfaceBuilder().withKey(new InterfaceKey("ifc2"))
- .setType(OpenROADMOpticalMultiplex.class).build();
-
// test createMappingData with a node with 3 dgree + 3 srg + bidirectional & unidirectional ports
assertTrue("creating mappingdata for existed node returns true",
portMappingVersion121.createMappingData("node"));
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-import org.junit.Before;
import org.junit.Test;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.Port;
public class SortPort121ByNameTest {
- @Before
- public void setUp() throws Exception {
- }
-
@Test
public void compareTest() {
Port port1 = mock(Port.class);
when(port2.getPortName()).thenReturn("port2");
SortPort121ByName sortPort121ByName = new SortPort121ByName();
assertEquals(sortPort121ByName.compare(port2, port1), 1);
-
}
}
\ No newline at end of file
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-import org.junit.Before;
import org.junit.Test;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.Port;
public class SortPort221ByNameTest {
- @Before
- public void setUp() throws Exception {
- }
-
@Test
public void compareTest() {
Port port1 = mock(Port.class);
when(port2.getPortName()).thenReturn("port2");
SortPort221ByName sortPort221ByName = new SortPort221ByName();
assertEquals(sortPort221ByName.compare(port2, port1), 1);
-
}
}
\ No newline at end of file
assertEquals("service-type should be ODU4", "ODU4", serviceType);
serviceType = ServiceTypes.getOtnServiceType("ODU", Uint32.valueOf(400));
assertEquals("service-type should be ODUC4", "ODUC4", serviceType);
-
}
}
\ No newline at end of file
+++ /dev/null
-/*
- * Copyright © 2016 AT&T and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.transportpce.common.test;
-
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class TransportPCETest {
-
- private static final Logger LOG = LoggerFactory.getLogger(TransportPCETest.class);
-
- @Test
- public void test() {
- LOG.info("test");
- }
-
-}
}
private NodeInfoBuilder computeNodeInfoBuilder() {
- NodeInfoBuilder nodeBldr = new NodeInfoBuilder()
+ return new NodeInfoBuilder()
.setNodeClli("NodeClliId")
.setNodeModel("NodeModel")
.setNodeIpAddress(new IpAddress(new Ipv4Address("127.0.0.1")))
.setNodeType(NodeTypes.forValue(NodeTypes.Xpdr.getIntValue()))
.setNodeVendor("VendorA")
.setOpenroadmVersion(OpenroadmNodeVersion._121);
- return nodeBldr;
- }
-
- private NodeInfoBuilder computeNodeInfoBuilderWithoutClli() {
- NodeInfoBuilder nodeBldr = new NodeInfoBuilder()
- .setNodeModel("NodeModel")
- .setNodeIpAddress(new IpAddress(new Ipv4Address("127.0.0.1")))
- .setNodeType(NodeTypes.forValue(NodeTypes.Xpdr.getIntValue()))
- .setNodeVendor("VendorA")
- .setOpenroadmVersion(OpenroadmNodeVersion._121);
- return nodeBldr;
}
}
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
-
public final class JsonUtil {
private static final Logger LOG = LoggerFactory.getLogger(JsonUtil.class);
private static JsonUtil instance;
private EffectiveModelContext schemaCtx;
-
private BindingNormalizedNodeSerializer codecRegistry;
private JsonUtil() {
LOG.error("Cannot deserialize JSON ", e);
return null;
}
-
}
}
Map<MappingKey,Mapping> mappingList = new HashMap<>();
createDegreeMappings(mappingList, 1, degNb);
createSrgMappings(mappingList, 1, srgNb);
- Nodes mappingNode = new NodesBuilder()
+ return new NodesBuilder()
.setNodeId(nodeId)
.setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Rdm).setNodeClli(clli).build())
.setMapping(mappingList)
.build();
- return mappingNode;
}
public static Nodes createMappingForXpdr(String nodeId, String clli, int networkPortNb, int clientPortNb,
import org.opendaylight.transportpce.olm.util.OlmUtils;
import org.opendaylight.transportpce.test.AbstractTest;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupInput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.Network;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.OpenroadmNodeVersion;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.mapping.Mapping;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.mapping.MappingBuilder;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.mapping.MappingKey;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.Nodes;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.NodesBuilder;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.NodesKey;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.nodes.NodeInfoBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.OpticalControlMode;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.RatioDB;
import org.opendaylight.yang.gen.v1.http.org.openroadm.optical.transport.interfaces.rev161014.Interface1Builder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.optical.transport.interfaces.rev161014.ots.container.Ots;
import org.opendaylight.yang.gen.v1.http.org.openroadm.optical.transport.interfaces.rev161014.ots.container.OtsBuilder;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.powermock.api.mockito.PowerMockito;
import org.powermock.core.classloader.annotations.PowerMockIgnore;
import org.powermock.core.classloader.annotations.PrepareForTest;
}
private MappingBuilder getMappingBuilderDeg() {
- MappingBuilder mappingBuilder = new MappingBuilder();
- mappingBuilder.withKey(new MappingKey("deg"));
- mappingBuilder.setLogicalConnectionPoint("logicalConnPoint");
- mappingBuilder.setSupportingOts("OTS");
- mappingBuilder.setSupportingCircuitPackName("2/0");
- mappingBuilder.setSupportingOms("OMS");
- mappingBuilder.setSupportingPort("8080");
- mappingBuilder.setSupportingCircuitPackName("circuit1");
- InstanceIdentifier<Mapping> portMappingIID =
- InstanceIdentifier.builder(Network.class).child(Nodes.class, new NodesKey("node 1"))
- .child(Mapping.class, new MappingKey("deg")).build();
- return mappingBuilder;
+ return new MappingBuilder()
+ .withKey(new MappingKey("deg"))
+ .setLogicalConnectionPoint("logicalConnPoint")
+ .setSupportingOts("OTS")
+ .setSupportingCircuitPackName("2/0")
+ .setSupportingOms("OMS")
+ .setSupportingPort("8080")
+ .setSupportingCircuitPackName("circuit1");
}
private MappingBuilder getMappingBuilderNetWork() {
- MappingBuilder mappingBuilder = new MappingBuilder();
- mappingBuilder.withKey(new MappingKey("network"));
- mappingBuilder.setLogicalConnectionPoint("logicalConnPoint");
- mappingBuilder.setSupportingOts("OTS");
- mappingBuilder.setSupportingCircuitPackName("2/0");
- mappingBuilder.setSupportingOms("OMS");
- mappingBuilder.setSupportingPort("8080");
- mappingBuilder.setSupportingCircuitPackName("circuit1");
- InstanceIdentifier<Mapping> portMappingIID =
- InstanceIdentifier.builder(Network.class).child(Nodes.class, new NodesKey("node 1"))
- .child(Mapping.class, new MappingKey("network")).build();
- return mappingBuilder;
+ return new MappingBuilder()
+ .withKey(new MappingKey("network"))
+ .setLogicalConnectionPoint("logicalConnPoint")
+ .setSupportingOts("OTS")
+ .setSupportingCircuitPackName("2/0")
+ .setSupportingOms("OMS")
+ .setSupportingPort("8080")
+ .setSupportingCircuitPackName("circuit1");
}
-
}
dataBroker = this.getNewDataBroker();
this.mountPoint = new MountPointStub(dataBroker);
this.mountPointService = new MountPointServiceStub(mountPoint);
- // this.mappingUtils = new MappingUtilsImpl(getDataBroker());
this.mappingUtils = Mockito.spy(new MappingUtilsImpl(dataBroker));
Mockito.doReturn(StringConstants.OPENROADM_DEVICE_VERSION_1_2_1).when(mappingUtils)
.getOpenRoadmVersion(Mockito.anyString());
Assert.assertEquals(true, output);
}
/*
+ TODO: see if this test is always relevant
@Test
public void testSetPowerPresentNodes31() throws InterruptedException {
List<NodeId> nodes = TransactionUtils.getNodeIds();
}
/*
+ TODO: see if this test is always relevant
@Test
public void testSetPowerPresentNodes41() throws InterruptedException {
List<NodeId> nodes = TransactionUtils.getNodeIds();
import org.opendaylight.transportpce.olm.stub.MountPointServiceStub;
import org.opendaylight.transportpce.olm.stub.MountPointStub;
import org.opendaylight.transportpce.olm.util.OlmPowerServiceRpcImplUtil;
-import org.opendaylight.transportpce.olm.util.OtsPmHolder;
import org.opendaylight.transportpce.olm.util.TransactionUtils;
import org.opendaylight.transportpce.test.AbstractTest;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.CalculateSpanlossBaseInput;
private PowerMgmt powerMgmtMock;
@InjectMocks
private OlmPowerService olmPowerServiceMock;
- private OtsPmHolder otsPmHolder;
@Before
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupInputBuilder;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerTurndownInput;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerTurndownInputBuilder;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Link1;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Link1Builder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev161014.PmGranularity;
import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev210930.olm.get.pm.input.ResourceIdentifierBuilder;
}
public static CalculateSpanlossBaseInput getCalculateSpanlossBaseInput2() {
- Link1 link1 = new Link1Builder().build();
CalculateSpanlossBaseInput input = new CalculateSpanlossBaseInputBuilder()
.setLinkId(new LinkId("link 1"))
.setSrcType(CalculateSpanlossBaseInput.SrcType.All).build();
package org.opendaylight.transportpce.olm.util;
import java.math.BigDecimal;
-import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Optional;
.build();
amplifiedLinkValues.put(al.key(),al);
amplifiedLinkValues.put(al2.key(),al2);
- Map<Class<? extends Augmentation<Link>>, Augmentation<Link>> map = Collections.emptyMap();
Augmentation<Link> aug11 = new Link1Builder()
.setAmplified(true)
.setOMSAttributes(new OMSAttributesBuilder()
import java.math.BigDecimal;
import java.util.ArrayList;
-import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
.setSectionEltNumber(Uint16.valueOf(1)).build();
amplifiedLinkValues.put(al.key(),al);
amplifiedLinkValues.put(al2.key(),al2);
- Map<Class<? extends Augmentation<Link>>, Augmentation<Link>> map = Collections.emptyMap();
Augmentation<Link> aug1 = new Link1Builder()
.setAmplified(true)
.setOMSAttributes(new OMSAttributesBuilder()
.setSupportingPort("port")
.withKey(new MappingKey((mappingKey != null) ? mappingKey : "null"))
.build();
- Nodes nodes = new NodesBuilder()
+ return new NodesBuilder()
.setNodeId(nodeId)
.setNodeInfo(new NodeInfoBuilder()
.setNodeType(org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.NodeTypes.Xpdr)
.setCpToDegree(cpList)
.setMapping(Map.of(map1.key(),map1))
.build();
- return nodes;
}
public static Nodes getNodes2(String nodeId, String mappingKey) {
.setSupportingPort("port")
.withKey(new MappingKey((mappingKey != null) ? mappingKey : "null"))
.build();
- Nodes nodes = new NodesBuilder()
+ return new NodesBuilder()
.setNodeId(nodeId)
.setNodeInfo(new NodeInfoBuilder()
.setNodeType(null)
.setCpToDegree(cpList)
.setMapping(Map.of(map1.key(),map1))
.build();
- return nodes;
}
public static Nodes getNodes3(String nodeId, String mappingKey) {
.setSupportingPort("port")
.withKey(new MappingKey((mappingKey != null) ? mappingKey : "null"))
.build();
- Nodes nodes = new NodesBuilder()
+ return new NodesBuilder()
.setNodeId(nodeId)
.setNodeInfo(new NodeInfoBuilder()
.setNodeType(org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.NodeTypes.Rdm)
.setCpToDegree(cpList)
.setMapping(Map.of(map1.key(),map1))
.build();
- return nodes;
}
public static void writeNodeTransaction(String nodeId, DataBroker dataBroker, String mappingKey) {
import org.opendaylight.transportpce.test.AbstractTest;
public class PceConstraintsCalcTest extends AbstractTest {
- private static PceConstraintsCalc pceConstraintsCalc;
private static NetworkTransactionService networkTransactionService = null;
private DataBroker dataBroker = getDataBroker();
+ //TODO: review this test class. May be miss few assert.
@Before
public void setup() throws Exception {
// networkTransactionService = Mockito.mock(NetworkTransactionService.class);
PceTestUtils.writeNetworkIntoDataStore(dataBroker, getDataStoreContextUtil(),
TransactionUtils.getNetworkForSpanLoss());
networkTransactionService = new NetworkTransactionImpl(new RequestProcessor(dataBroker));
-
-
}
@Test
public void testNoHardOrSoftConstrainsExists() {
PceTestData.getPCE_test2_request_54().getSoftConstraints();
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .getEmptyPCERequest(), networkTransactionService);
+ new PceConstraintsCalc(PceTestData.getEmptyPCERequest(), networkTransactionService);
}
@Test()
public void testHardConstrainsExists() {
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .getPCE_simpletopology_test1_requestSetHardAndSoftConstrains(), networkTransactionService);
+ new PceConstraintsCalc(
+ PceTestData.getPCE_simpletopology_test1_requestSetHardAndSoftConstrains(),
+ networkTransactionService);
}
@Test()
public void testHardConstrainsExists1() {
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .getPathComputationRequestInputWithCoRoutingOrGeneral(), networkTransactionService);
+ new PceConstraintsCalc(
+ PceTestData.getPathComputationRequestInputWithCoRoutingOrGeneral(),
+ networkTransactionService);
}
@Test
public void testSoftConstrainsExists() {
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .getPCERequest(), networkTransactionService);
+ new PceConstraintsCalc(PceTestData.getPCERequest(), networkTransactionService);
}
@Test(expected = Exception.class)
public void testHardConstrainsExists2() {
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .build_diversity_from_request(PceTestData.getPCERequest()), networkTransactionService);
+ new PceConstraintsCalc(
+ PceTestData.build_diversity_from_request(PceTestData.getPCERequest()),
+ networkTransactionService);
}
@Test()
public void testHardConstrainsExists3() {
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .getEmptyPCERequestServiceNameWithRequestId(), networkTransactionService);
+ new PceConstraintsCalc(PceTestData.getEmptyPCERequestServiceNameWithRequestId(), networkTransactionService);
}
@Test(expected = Exception.class)
public void testHardConstrainsExists4() {
- pceConstraintsCalc = new PceConstraintsCalc(PceTestData
- .getPCE_test2_request_54(), networkTransactionService);
+ new PceConstraintsCalc(PceTestData.getPCE_test2_request_54(), networkTransactionService);
}
}
import org.opendaylight.transportpce.pce.networkanalyzer.PceOtnNode;
import org.opendaylight.transportpce.pce.networkanalyzer.PceResult;
import org.opendaylight.transportpce.pce.utils.NodeUtils;
-import org.opendaylight.transportpce.pce.utils.PceTestData;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev210701.PathComputationRequestInput;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmNodeType;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmTpType;
import org.opendaylight.yang.gen.v1.http.org.openroadm.service.format.rev190531.ServiceFormat;
private Node node = null;
private PceLink pceLink = null;
private PceGraph pceGraph = null;
- private PathComputationRequestInput requestInput = PceTestData.getPCE_test2_request_54();
private PceConstraints pceHardConstraints = null;
private PceResult rc = null;
private PceOpticalNode pceOpticalNode = null;
OpenroadmNodeType.SRG, StringConstants.OPENROADM_DEVICE_VERSION_2_2_1,
GridConstant.SLOT_WIDTH_50, GridConstant.SLOT_WIDTH_50);
pceLink = new PceLink(link, pceOpticalNode, pceOpticalNode);
-
}
@Test
Assert.assertNotNull(pceLink.getdestCLLI());
Assert.assertTrue(pceLink.toString().equals("PceLink type=" + pceLink.getlinkType()
+ " ID=" + pceLink.getLinkId().getValue() + " latency=" + pceLink.getLatency().intValue()));
-
}
@Test(expected = NullPointerException.class)
Node node = node1Builder.build();
Assert.assertNotNull(node.augmentation(Node1.class));
// OpenroadmNodeType nodeType = node.augmentation(Node1.class).;
-
- PceOtnNode pceOtnNode = new PceOtnNode(node, OpenroadmNodeType.SRG, node.getNodeId(), "otn", "serviceType",
- null);
-
+ new PceOtnNode(node, OpenroadmNodeType.SRG, node.getNodeId(), "otn", "serviceType", null);
}
private static LinkBuilder createOTNLink(String srcNode, String destNode, String srcTp, String destTp) {
.setLinkType(OpenroadmLinkType.OTNLINK)
.setOperationalState(State.InService)
.setAdministrativeState(AdminStates.InService);
-
//create source link
return createLinkBuilder(srcNode, destNode, srcTp, destTp, link1Builder);
-
}
private static LinkBuilder createXponderLink(String srcNode, String destNode, String srcTp, String destTp) {
.setLinkType(OpenroadmLinkType.XPONDERINPUT)
.setAdministrativeState(AdminStates.InService)
.setOperationalState(State.InService);
-
//create source link
return createLinkBuilder(srcNode, destNode, srcTp, destTp, link1Builder);
-
}
private static LinkBuilder createLinkBuilder(
.setOMSAttributes(omsAttributesBuilder
.build());
-
linkBuilder.addAugmentation(linkBuilderNetworkLink.build());
-
return linkBuilder;
}
.setOperationalState(State.InService)
.setLinkType(OpenroadmLinkType.ROADMTOROADM);
return createLinkBuilder(srcNode, destNode, srcTp, destTp, link1Builder);
-
}
private static LinkBuilder createRoadmToRoadmWithoutLinkLatency(
Link1Builder link1Builder = new Link1Builder()
.setLinkType(OpenroadmLinkType.ROADMTOROADM);
return createLinkBuilder(srcNode, destNode, srcTp, destTp, link1Builder);
-
}
private Map<SupportingNodeKey,SupportingNode> geSupportingNodes() {
}
private NodeBuilder getNodeBuilder(Map<SupportingNodeKey,SupportingNode> supportingNodes1) {
-
-
//update tp of nodes
TerminationPointBuilder xpdrTpBldr = new TerminationPointBuilder()
.withKey(new TerminationPointKey(new TpId("xpdr")));
org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 node11 =
new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
.setOperationalState(State.InService).setAdministrativeState(AdminStates.InService).build();
-
-
return new NodeBuilder()
.setNodeId(new NodeId("node 1"))
.withKey(new NodeKey(new NodeId("node 1")))
Assert.assertFalse("not valid otn service type", pceOtnNode.isValid());
Assert.assertTrue("this.nodeType isn'tOpenroadmNodeType.TPDR" ,
pceOtnNode.validateSwitchingPoolBandwidth(null,null,1L));
-
}
@Test
pceOtnNode.checkAvailableTribSlot();
Assert.assertFalse("not valid otn service type" , pceOtnNode.isValid());
Assert.assertFalse("checkTp returns false by default " , pceOtnNode.checkTP("tp"));
-
}
private Map<SupportingNodeKey, SupportingNode> geSupportingNodes() {
.setSupportingNode(supportingNodes1);
}
- private NodeBuilder getNodeBuilderEmpty(Map<SupportingNodeKey,SupportingNode> supportingNodes1,
- OpenroadmTpType openroadmTpType) {
-
- TerminationPoint1Builder tp1Bldr = getTerminationPoint1Builder(openroadmTpType);
- TerminationPointBuilder xpdrTpBldr = getTerminationPointBuilder(openroadmTpType);
- xpdrTpBldr.addAugmentation(tp1Bldr.build());
- xpdrTpBldr.addAugmentation(createAnotherTerminationPoint(openroadmTpType).build());
-
- org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Node1 node1 = getNode1Empty();
- TerminationPoint xpdr = xpdrTpBldr.build();
- org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 node1Rev180226 =
- new Node1Builder()
- .setTerminationPoint(Map.of(xpdr.key(),xpdr))
- .build();
- Node1 node11 = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
- .setOperationalState(State.InService).setAdministrativeState(AdminStates.InService).build();
-
-
- return new NodeBuilder()
- .setNodeId(new NodeId("node_test"))
- .withKey(new NodeKey(new NodeId("node 1")))
- .addAugmentation(node1Rev180226)
- .addAugmentation(node1)
- .addAugmentation(node11)
- .setSupportingNode(supportingNodes1);
- }
-
private org.opendaylight
.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Node1 getNode1() {
return new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Node1Builder()
.build();
}
- private org.opendaylight
- .yang.gen.v1.http.org.openroadm.network.topology.rev200529.Node1 getNode1Empty() {
- return new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Node1Builder()
- .setSrgAttributes(getEmptySrgAttributes())
- .setDegreeAttributes(getEmptyDegAttributes())
- .build();
- }
-
private DegreeAttributes getDegAttributes() {
return new DegreeAttributesBuilder()
.setAvailFreqMaps(GridUtils.initFreqMaps4FixedGrid2Available())
return new SrgAttributesBuilder().setAvailFreqMaps(GridUtils.initFreqMaps4FixedGrid2Available()).build();
}
- private DegreeAttributes getEmptyDegAttributes() {
- return (new DegreeAttributesBuilder())
- .setAvailFreqMaps(Map.of())
- .build();
- }
-
- private SrgAttributes getEmptySrgAttributes() {
- return new SrgAttributesBuilder().setAvailFreqMaps(Map.of()).build();
- }
-
private TerminationPointBuilder getTerminationPointBuilder(OpenroadmTpType openroadmTpType) {
return new TerminationPointBuilder()
.setTpId(new TpId("2"))
.setTpType(openroadmTpType).setOperationalState(State.InService)
.setAdministrativeState(AdminStates.InService);
}
-
}
import org.junit.Before;
import org.junit.Test;
import org.mockito.Mockito;
-import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.transportpce.common.network.NetworkTransactionService;
-import org.opendaylight.transportpce.pce.gnpy.GnpyResult;
-import org.opendaylight.transportpce.pce.gnpy.GnpyTopoImpl;
import org.opendaylight.transportpce.pce.utils.PceTestData;
import org.opendaylight.transportpce.test.AbstractTest;
-import org.opendaylight.transportpce.test.DataStoreContext;
import org.opendaylight.yang.gen.v1.gnpy.path.rev220221.PathBandwidth;
import org.opendaylight.yang.gen.v1.gnpy.path.rev220221.generic.path.properties.PathPropertiesBuilder;
import org.opendaylight.yang.gen.v1.gnpy.path.rev220221.generic.path.properties.path.properties.PathMetric;
private PathComputationServiceImpl pathComputationServiceImpl;
private static NetworkTransactionService networkTransactionService = null;
- private static GnpyTopoImpl gnpyTopoImpl = null;
- private static GnpyResult gnpyResult = null;
- private DataStoreContext dataStoreContext = getDataStoreContextUtil();
- private DataBroker dataBroker = getDataBroker();
@Before
public void setUp() {
networkTransactionService = Mockito.mock(NetworkTransactionService.class);
- gnpyTopoImpl = Mockito.mock(GnpyTopoImpl.class);
- gnpyResult = Mockito.mock(GnpyResult.class);
pathComputationServiceImpl = new PathComputationServiceImpl(
networkTransactionService,
this.getNotificationPublishService(), null, null);
import org.slf4j.LoggerFactory;
-
public final class JsonUtil {
private static final Logger LOG = LoggerFactory.getLogger(JsonUtil.class);
private static JsonUtil instance;
LOG.error("Cannot deserialize JSON ", e);
return null;
}
-
}
public BindingDOMCodecServices getBindingDOMCodecServices() {
package org.opendaylight.transportpce.pce.utils;
-import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.opendaylight.transportpce.common.NetworkUtils;
import org.opendaylight.transportpce.common.fixedflex.GridUtils;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.common.link.types.rev191129.FiberPmd;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.common.link.types.rev191129.RatioDB;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1Builder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes.AmplifiedLink;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes.AmplifiedLinkKey;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes.amplified.link.SectionElementBuilder;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.span.attributes.LinkConcatenation;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.span.attributes.LinkConcatenationBuilder;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.span.attributes.LinkConcatenationKey;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.networks.network.link.OMSAttributesBuilder;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.networks.network.link.oms.attributes.AmplifiedLinkBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.networks.network.link.oms.attributes.SpanBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.networks.network.node.DegreeAttributes;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.networks.network.node.DegreeAttributesBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
import org.opendaylight.yangtools.yang.binding.Augmentation;
-import org.opendaylight.yangtools.yang.common.Uint16;
import org.opendaylight.yangtools.yang.common.Uint32;
-public class NodeUtils {
+public final class NodeUtils {
private static final String LINK_ID_FORMAT = "%1$s-%2$sto%3$s-%4$s";
LinkId linkId = new LinkId(String.format(LINK_ID_FORMAT, srcNode, srcTp, destNode, destTp));
LinkId oppositeLinkId = new LinkId("OpenROADM-3-2-DEG1-to-OpenROADM-3-1-DEG1");
- //For setting up attributes for openRoadm augment
- OMSAttributesBuilder omsAttributesBuilder =
- new OMSAttributesBuilder();
-
// Augementation
Augmentation<Link> aug11 = new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529
.Link1Builder()
.setSpan(new SpanBuilder().build())
.build())
.build();
-
return new LinkBuilder()
.setSource(ietfSrcLinkBldr.build())
.setDestination(ietfDestLinkBldr.build())
Node1 node11 = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
.setAdministrativeState(AdminStates.InService)
.setOperationalState(State.InService).build();
-
-
return new NodeBuilder()
.setNodeId(new NodeId("node 1"))
.withKey(new NodeKey(new NodeId("node 1")))
.setSupportingNode(supportingNodes1);
}
- private Link genereateLinkBuilder() {
-
- Map<LinkConcatenationKey,LinkConcatenation> linkConcentationValues = new HashMap<>();
- LinkConcatenation linkConcatenation = new LinkConcatenationBuilder()
- .setFiberType(LinkConcatenation.FiberType.Truewave)
- .setPmd(new FiberPmd(BigDecimal.ONE))
- .setSRLGId(Uint32.valueOf(1))
- .setSRLGLength(Uint32.valueOf(1))
- .build();
- LinkConcatenation linkConcatenation2 = new LinkConcatenationBuilder()
- .setFiberType(LinkConcatenation.FiberType.Truewave)
- .setPmd(new FiberPmd(BigDecimal.ONE))
- .setSRLGId(Uint32.valueOf(1))
- .setSRLGLength(Uint32.valueOf(1))
- .build();
- linkConcentationValues.put(linkConcatenation.key(),linkConcatenation);
- linkConcentationValues.put(linkConcatenation2.key(),linkConcatenation2);
-
- Map<AmplifiedLinkKey,AmplifiedLink>
- amplifiedLinkValues = new HashMap<>();
- org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes.AmplifiedLink al =
- new org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes
- .AmplifiedLinkBuilder().setSectionElement(new SectionElementBuilder()
- .setSectionElement(new org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529
- .amplified.link.attributes.amplified.link.section.element.section.element
- .SpanBuilder()
- .setSpan(
- new org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified
- .link.attributes.amplified.link.section.element.section
- .element.span.SpanBuilder()
- .setAdministrativeState(AdminStates.InService)
- .setAutoSpanloss(true)
- .setEngineeredSpanloss(new RatioDB(BigDecimal.ONE))
- .setLinkConcatenation(linkConcentationValues)
- .setSpanlossBase(new RatioDB(BigDecimal.ONE))
- .setSpanlossCurrent(new RatioDB(BigDecimal.ONE))
- .build())
- .build())
- .build())
- .setSectionEltNumber(Uint16.valueOf(1)).build();
- org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes.AmplifiedLink al2 =
- new org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link.attributes
- .AmplifiedLinkBuilder().setSectionElement(new SectionElementBuilder()
- .setSectionElement(
- new org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529.amplified.link
- .attributes.amplified.link.section.element.section.element.SpanBuilder()
- .setSpan(
- new org.opendaylight.yang.gen.v1.http.org.openroadm.link.rev200529
- .amplified.link
- .attributes.amplified.link.section.element.section.element.span
- .SpanBuilder()
- .setAdministrativeState(AdminStates.InService)
- .setAutoSpanloss(true)
- .setEngineeredSpanloss(new RatioDB(BigDecimal.ONE))
- .setLinkConcatenation(linkConcentationValues)
- .setSpanlossBase(new RatioDB(BigDecimal.ONE))
- .setSpanlossCurrent(new RatioDB(BigDecimal.ONE))
- .build())
- .build())
- .build())
- .setSectionEltNumber(Uint16.valueOf(1)).build();
-
- amplifiedLinkValues.put(al.key(),al);
- amplifiedLinkValues.put(al2.key(),al2);
- Augmentation<Link> aug11 =
- new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev200529.Link1Builder()
- .setAmplified(true)
- .setOMSAttributes(new OMSAttributesBuilder()
- .setAmplifiedLink(new AmplifiedLinkBuilder()
- .setAmplifiedLink(amplifiedLinkValues)
- .build())
- .setSpan(new SpanBuilder().build())
- .build())
- .build();
- Augmentation<Link> aug111 = new Link1Builder().setAdministrativeState(AdminStates.InService)
- .setOperationalState(State.InService).build();
-
- TransactionUtils.getNetworkForSpanLoss();
- return new LinkBuilder()
- .setLinkId(new LinkId("OpenROADM-3-1-DEG1-to-OpenROADM-3-2-DEG1"))
- .setSource(
- new SourceBuilder()
- .setSourceNode(new NodeId("OpenROADM-3-2-DEG1"))
- .setSourceTp(new TpId("DEG1-TTP-TX")).build())
- .setDestination(
- new DestinationBuilder()
- .setDestNode(new NodeId("OpenROADM-3-1-DEG1"))
- .setDestTp(new TpId("DEG1-TTP-RX")).build())
- .addAugmentation(aug11)
- .addAugmentation(aug111)
- .build();
-
-
- }
-
// OTN network node
public static List<SupportingNode> getOTNSupportingNodes() {
List<SupportingNode> supportingNodes1 = new ArrayList<>();
new Node1Builder()
.setTerminationPoint(Map.of(xpdr.key(),xpdr))
.build();
-
-
return new NodeBuilder()
.setNodeId(new NodeId("node_test"))
.withKey(new NodeKey(new NodeId("node 1")))
.setTpType(openroadmTpType);
}
+ private NodeUtils() {
+ throw new IllegalStateException("Utility class");
+ }
}
ServiceHandlerHeader serviceHandlerHeader = new ServiceHandlerHeaderBuilder()
.setRequestId("request1")
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceHandlerHeader(serviceHandlerHeader)
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .build();
}
public static PathComputationRequestInput getEmptyPCERequestServiceNameWithRequestId() {
ServiceHandlerHeader serviceHandlerHeader = new ServiceHandlerHeaderBuilder()
.setRequestId("request1")
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceName("serviceName")
- .setServiceHandlerHeader(serviceHandlerHeader)
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceName("serviceName")
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .build();
}
public static PathComputationRequestInput getEmptyPCERequestServiceNameWithOutRequestId() {
ServiceHandlerHeader serviceHandlerHeader = new ServiceHandlerHeaderBuilder()
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceName("serviceName")
- .setServiceHandlerHeader(serviceHandlerHeader)
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceName("serviceName")
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .build();
}
public static PathComputationRequestInput getPathComputationRequestInputWithCoRoutingOrGeneral2() {
.build()
).build())
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceName("service1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setLocallyProtectedLinks(true)
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ return new PathComputationRequestInputBuilder()
+ .setServiceName("service1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setLocallyProtectedLinks(true)
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
-
- .build())
- .build())
- .build())
- .setSoftConstraints(new SoftConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .setSoftConstraints(new SoftConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
- .build())
- .build())
- .build())
- .build();
- return input;
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .build();
}
public static PathComputationRequestInput getPathComputationRequestInputWithCoRoutingOrGeneral() {
.build()
).build())
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceName("service1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setLocallyProtectedLinks(true)
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ return new PathComputationRequestInputBuilder()
+ .setServiceName("service1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setLocallyProtectedLinks(true)
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
-
- .build())
- .build())
- .build())
- .setSoftConstraints(new SoftConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .setSoftConstraints(new SoftConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
- .build())
- .build())
- .build())
- .build();
- return input;
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .build();
}
public static PathComputationRequestInput getPCERequest() {
.build()
).build())
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceName("service1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setLocallyProtectedLinks(true)
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ return new PathComputationRequestInputBuilder()
+ .setServiceName("service1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setLocallyProtectedLinks(true)
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
- .build())
- .build())
- .build())
- .setSoftConstraints(new SoftConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .setSoftConstraints(new SoftConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
- .build())
- .build())
- .build())
- .build();
- return input;
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .build();
}
public static PathComputationRequestOutput getFailedPCEResultYes() {
.setServiceRate(Uint32.valueOf(0))
.setNodeId("XPONDER-3-2")
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceName("service 1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceName("service 1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .build();
}
/**
.setHopType(new HopTypeBuilder()
.setHopType(new HopTypeBuilder().getHopType()).build())
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceName("service 1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCoRoutingOrGeneral(new GeneralBuilder()
- .setExclude(new ExcludeBuilder()
- .setNodeId(Arrays.asList("OpenROADM-2-2"))
- .build())
- .setLatency(new LatencyBuilder().setMaxLatency(Uint32.valueOf(3223)).build())
- .setInclude(new IncludeBuilder()
- .setOrderedHops(Map.of(orderedHops.key(),orderedHops))
- .build())
- .build())
- .build())
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceName("service 1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCoRoutingOrGeneral(new GeneralBuilder()
+ .setExclude(new ExcludeBuilder()
+ .setNodeId(Arrays.asList("OpenROADM-2-2"))
+ .build())
+ .setLatency(new LatencyBuilder().setMaxLatency(Uint32.valueOf(3223)).build())
+ .setInclude(new IncludeBuilder()
+ .setOrderedHops(Map.of(orderedHops.key(),orderedHops))
+ .build())
+ .build())
+ .build())
+ .build();
}
/**
.setServiceFormat(ServiceFormat.Ethernet)
.setNodeId("XPONDER-3-2")
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceName("service 1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCoRoutingOrGeneral(new GeneralBuilder()
- .setExclude(new ExcludeBuilder()
- .setNodeId(Arrays.asList("OpenROADM-2-1", "OpenROADM-2-2"))
- .build())
- .build())
- .build())
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceName("service 1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCoRoutingOrGeneral(new GeneralBuilder()
+ .setExclude(new ExcludeBuilder()
+ .setNodeId(Arrays.asList("OpenROADM-2-1", "OpenROADM-2-2"))
+ .build())
+ .build())
+ .build())
+ .build();
}
/**
.build();
HardConstraints hardConstrains = new HardConstraintsBuilder().build();
SoftConstraints softConstraints = new SoftConstraintsBuilder().build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceName("service 1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(hardConstrains)
- .setSoftConstraints(softConstraints)
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceName("service 1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(hardConstrains)
+ .setSoftConstraints(softConstraints)
+ .build();
}
public static PathComputationRequestInput getPCE_simpletopology_test1_request() {
.setServiceRate(Uint32.valueOf(0))
.setNodeId("XPONDER-3-2")
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceName("service 1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .build();
- return input;
+ return new PathComputationRequestInputBuilder()
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceName("service 1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .build();
}
public static PathComputationRequestOutput getPCE_simpletopology_test1_result(Long wl) {
.setRate(Uint32.valueOf(zaRate))
.setZToAWavelengthNumber(Uint32.valueOf(zaWaveLength))
.build();
- PathDescription pathDescription = new PathDescriptionBuilder()
- .setAToZDirection(atozDirection)
- .setZToADirection(ztoaDirection)
- .build();
- return pathDescription;
+ return new PathDescriptionBuilder()
+ .setAToZDirection(atozDirection)
+ .setZToADirection(ztoaDirection)
+ .build();
}
/**
.setServiceRate(Uint32.valueOf(0))
.setNodeId("XPONDER-3-1")
.build();
-
- PathComputationRequestInput input = new PathComputationRequestInputBuilder(base)
- .setServiceName("service 2")
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCoRoutingOrGeneral(new GeneralBuilder()
- .setLatency(new LatencyBuilder()
- .setMaxLatency(Uint32.valueOf(3223)).build())
- .setDiversity(new DiversityBuilder()
- .setExistingService(Arrays.asList(base.getServiceName()))
- .setExistingServiceApplicability(nodeTrue)
- .build())
- .build())
- .build())
- .build();
- return input;
+ return new PathComputationRequestInputBuilder(base)
+ .setServiceName("service 2")
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCoRoutingOrGeneral(new GeneralBuilder()
+ .setLatency(new LatencyBuilder()
+ .setMaxLatency(Uint32.valueOf(3223)).build())
+ .setDiversity(new DiversityBuilder()
+ .setExistingService(Arrays.asList(base.getServiceName()))
+ .setExistingServiceApplicability(nodeTrue)
+ .build())
+ .build())
+ .build())
+ .build();
}
public static ServiceCreateInput buildServiceCreateInput() {
.setServiceRate(Uint32.valueOf(0))
.setNodeId(new NodeIdType("XPONDER-1-2"))
.setTxDirection(new org.opendaylight.yang.gen.v1.http.org
- .openroadm.common.service.types.rev190531.service.endpoint.TxDirectionBuilder()
+ .openroadm.common.service.types.rev190531.service.endpoint.TxDirectionBuilder()
.setPort(new PortBuilder().build())
.build())
.setRxDirection(new org.opendaylight.yang.gen.v1.http.org
- .openroadm.common.service.types.rev190531.service.endpoint.RxDirectionBuilder()
+ .openroadm.common.service.types.rev190531.service.endpoint.RxDirectionBuilder()
.setPort(new PortBuilder().build())
.build())
.build();
org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev190531.service.create.input.ServiceZEnd serviceZEnd =
new org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev190531
- .service.create.input.ServiceZEndBuilder()
+ .service.create.input.ServiceZEndBuilder()
.setClli("clli")
.setServiceRate(Uint32.valueOf(0))
.setNodeId(new NodeIdType("XPONDER-3-2"))
.setTxDirection(new org.opendaylight.yang.gen.v1.http.org
- .openroadm.common.service.types.rev190531.service.endpoint.TxDirectionBuilder()
+ .openroadm.common.service.types.rev190531.service.endpoint.TxDirectionBuilder()
.setPort(new PortBuilder().build())
.build())
.setRxDirection(new org.opendaylight.yang.gen.v1.http.org
- .openroadm.common.service.types.rev190531.service.endpoint.RxDirectionBuilder()
+ .openroadm.common.service.types.rev190531.service.endpoint.RxDirectionBuilder()
.setPort(new PortBuilder().build())
.build())
.build();
-
- ServiceCreateInputBuilder builtInput = new ServiceCreateInputBuilder()
- .setCommonId("commonId")
- .setConnectionType(ConnectionType.Service)
- .setCustomer("Customer")
- .setServiceName("service 1")
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setSdncRequestHeader(new SdncRequestHeaderBuilder()
- .setRequestId("request 1")
- .build());
-
- return builtInput.build();
+ return new ServiceCreateInputBuilder()
+ .setCommonId("commonId")
+ .setConnectionType(ConnectionType.Service)
+ .setCustomer("Customer")
+ .setServiceName("service 1")
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setSdncRequestHeader(new SdncRequestHeaderBuilder()
+ .setRequestId("request 1")
+ .build())
+ .build();
}
public static PathComputationRequestInput getGnpyPCERequest(String nodeA, String nodeZ) {
.build()
).build())
.build();
- PathComputationRequestInput input = new PathComputationRequestInputBuilder()
- .setServiceName("service1")
- .setResourceReserve(true)
- .setPceMetric(PceMetric.HopCount)
- .setLocallyProtectedLinks(true)
- .setServiceHandlerHeader(serviceHandlerHeader)
- .setServiceAEnd(serviceAEnd)
- .setServiceZEnd(serviceZEnd)
- .setHardConstraints(new HardConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ return new PathComputationRequestInputBuilder()
+ .setServiceName("service1")
+ .setResourceReserve(true)
+ .setPceMetric(PceMetric.HopCount)
+ .setLocallyProtectedLinks(true)
+ .setServiceHandlerHeader(serviceHandlerHeader)
+ .setServiceAEnd(serviceAEnd)
+ .setServiceZEnd(serviceZEnd)
+ .setHardConstraints(new HardConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
- .build())
- .build())
- .build())
- .setSoftConstraints(new SoftConstraintsBuilder()
- .setCustomerCode(Arrays.asList("Some customer-code"))
- .setCoRoutingOrGeneral(new CoRoutingBuilder()
- .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .setSoftConstraints(new SoftConstraintsBuilder()
+ .setCustomerCode(Arrays.asList("Some customer-code"))
+ .setCoRoutingOrGeneral(new CoRoutingBuilder()
+ .setCoRouting(new org.opendaylight.yang.gen.v1.http.org
.transportpce.b.c._interface.routing.constraints.rev171017
.constraints.sp.co.routing.or.general.co.routing.CoRoutingBuilder()
- .setExistingService(Arrays.asList("Some existing-service"))
- .build())
- .build())
- .build())
- .build();
- return input;
+ .setExistingService(Arrays.asList("Some existing-service"))
+ .build())
+ .build())
+ .build())
+ .build();
}
}
package org.opendaylight.transportpce.pce.utils;
import java.math.BigDecimal;
-import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Optional;
.setSectionEltNumber(Uint16.valueOf(1)).build();
amplifiedLinkValues.put(al.key(),al);
amplifiedLinkValues.put(al2.key(),al2);
- Map<Class<? extends Augmentation<Link>>, Augmentation<Link>> map = Collections.emptyMap();
Augmentation<Link> aug11 = new Link1Builder()
.setAmplified(true)
.setOMSAttributes(new OMSAttributesBuilder()
import org.opendaylight.mdsal.binding.api.MountPoint;
import org.opendaylight.mdsal.binding.api.MountPointService;
import org.opendaylight.mdsal.binding.api.NotificationPublishService;
-import org.opendaylight.mdsal.binding.api.ReadTransaction;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.transportpce.common.ResponseCodes;
import org.opendaylight.transportpce.common.StringConstants;
private final OtnDeviceRendererService otnDeviceRendererService = Mockito.mock(OtnDeviceRendererService.class);
private final PortMapping portMapping = Mockito.mock(PortMapping.class);
private final CrossConnect crossConnect = Mockito.mock(CrossConnect.class);
- private final ReadTransaction readTransaction = Mockito.mock(ReadTransaction.class);
private TransportpceOlmService olmService;
private void setMountPoint(MountPoint mountPoint) {
public final class CreateOtsOmsDataUtils {
private CreateOtsOmsDataUtils() {
-
}
public static CreateOtsOmsInput buildCreateOtsOms() {
}
private MountPointUtils() {
-
}
}
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToABuilder;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToAKey;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.ResourceBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.Link;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.LinkBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.Node;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.NodeBuilder;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.TerminationPoint;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.TerminationPointBuilder;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev200128.service.endpoint.sp.RxDirectionBuilder;
public final class ServiceDataUtils {
private ServiceDataUtils() {
-
}
public static Nodes createNode(String nodeId, String srcTp, String dstTp) {
return builder.build();
}
- /*public static ServiceImplementationRequestInput buildServiceImplementationRequestInputInvalidResource() {
- ServiceImplementationRequestInputBuilder builder = new ServiceImplementationRequestInputBuilder()
- .setServiceName("service 1").setPathDescription(createPathDescriptionInvalidResource())
- .setServiceHandlerHeader(new ServiceHandlerHeaderBuilder().setRequestId("Request 1").build())
- .setServiceAEnd(getServiceAEndBuild().build())
- .setServiceZEnd(getServiceZEndBuild().build());
- return builder.build();
- }
-
- public static ServiceImplementationRequestInput buildServiceImplementationRequestInputLinkResource() {
- ServiceImplementationRequestInputBuilder builder = new ServiceImplementationRequestInputBuilder()
- .setServiceName("service 1").setPathDescription(createPathDescriptionLinkResource())
- .setServiceHandlerHeader(new ServiceHandlerHeaderBuilder().setRequestId("Request 1").build())
- .setServiceAEnd(getServiceAEndBuild().build())
- .setServiceZEnd(getServiceZEndBuild().build());
- return builder.build();
- }*/
-
- private static PathDescription createPathDescriptionInvalidResource() {
- Map<AToZKey,AToZ> atoZMap = new HashMap<>();
- Node node = new NodeBuilder().setNodeId("XPONDER-1-2").build();
- AToZ atoZ = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder()
- .setResource(node).build()).build();
- atoZMap.put(atoZ.key(),atoZ);
- AToZDirection atozDirection = new AToZDirectionBuilder()
- .setRate(Uint32.valueOf(20))
- .setAToZWavelengthNumber(Uint32.valueOf(32))
- .setAToZ(atoZMap)
- .build();
- Map<ZToAKey,ZToA> ztoAMap = new HashMap<>();
- ZToA ztoA = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder()
- .setResource(node).build()).build();
- ztoAMap.put(ztoA.key(),ztoA);
- ZToADirection ztoaDirection = new ZToADirectionBuilder()
- .setRate(Uint32.valueOf(20))
- .setZToAWavelengthNumber(Uint32.valueOf(20))
- .setZToA(ztoAMap)
- .build();
- PathDescriptionBuilder builder = new PathDescriptionBuilder()
- .setAToZDirection(atozDirection)
- .setZToADirection(ztoaDirection);
- return builder.build();
- }
-
public static PathDescription createPathDescriptionTerminationPointResource(String tpId) {
Map<AToZKey,AToZ> atoZMap = new HashMap<>();
TerminationPointBuilder terminationPointBuilder = new TerminationPointBuilder();
atoZMap.put(atoZ.key(),atoZ);
}
}
- FrequencyTHz value;
AToZDirection atozDirection = new AToZDirectionBuilder()
.setRate(Uint32.valueOf(20))
.setAToZWavelengthNumber(Uint32.valueOf(20))
return builder.build();
}
- private static PathDescription createPathDescriptionLinkResource() {
- Map<AToZKey,AToZ> atoZMap = new HashMap<>();
- Link link1 = new LinkBuilder().setLinkId("link 1").build();
- Link link2 = new LinkBuilder().setLinkId("link 2").build();
- AToZ atoZ = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder()
- .setResource(link1).build()).build();
- AToZ atoZ2 = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder()
- .setResource(link2).build()).build();
- atoZMap.put(atoZ.key(),atoZ);
- atoZMap.put(atoZ2.key(),atoZ2);
- AToZDirection atozDirection = new AToZDirectionBuilder()
- .setRate(Uint32.valueOf(20))
- .setAToZWavelengthNumber(Uint32.valueOf(20))
- .setAToZ(atoZMap)
- .build();
- Map<ZToAKey,ZToA> ztoAMap = new HashMap<>();
- ZToA ztoA = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder()
- .setResource(link1).build()).build();
- ZToA ztoA2 = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder()
- .setResource(link2).build()).build();
- ztoAMap.put(ztoA.key(),ztoA);
- ztoAMap.put(ztoA2.key(),ztoA2);
- ZToADirection ztoaDirection = new ZToADirectionBuilder()
- .setRate(Uint32.valueOf(20))
- .setZToAWavelengthNumber(Uint32.valueOf(20))
- .setZToA(ztoAMap)
- .build();
- PathDescriptionBuilder builder = new PathDescriptionBuilder()
- .setAToZDirection(atozDirection)
- .setZToADirection(ztoaDirection);
- return builder.build();
- }
-
public static ServiceAEndBuilder getServiceAEndBuild(String tpId) {
return new ServiceAEndBuilder()
.setClli("clli").setServiceFormat(ServiceFormat.OC)
.setPortSubSlot("port subslot").setPortType("port type").build())
.build());
}
-
}
public final class ServiceDeleteDataUtils {
private ServiceDeleteDataUtils() {
-
}
public static PathDescription createTransactionPathDescription(String tpId) {
}
- @SuppressWarnings({ "unchecked", "deprecation", "rawtypes" })
+ @SuppressWarnings({ "unchecked", "rawtypes" })
// deviceTx.put needs the "true" boolean parameter at the end in order to not compromise the Junit test suite
// FIXME check if the InstanceIdentifier raw type can be avoided
// Raw types use are discouraged since they lack type safety.
private ListeningExecutorService executorService;
private CountDownLatch endSignal;
private static final int NUM_THREADS = 5;
- private boolean callbackRan;
@Before
public void setUp() {
executorService = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(NUM_THREADS));
endSignal = new CountDownLatch(1);
- callbackRan = false;
}
@After
serviceDeleteOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceDeleteOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceCreatOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceCreatOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceCreatOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceCreatOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceCreatOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceCreatOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
serviceRestorationOutputF.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
private ListeningExecutorService executorService;
private CountDownLatch endSignal;
private static final int NUM_THREADS = 5;
- private boolean callbackRan;
@Before
public void setUp() {
executorService = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(NUM_THREADS));
endSignal = new CountDownLatch(1);
- callbackRan = false;
MockitoAnnotations.openMocks(this);
this.serviceDataStoreOperations = new ServiceDataStoreOperationsImpl(getNewDataBroker());
}
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
public final class MockedNotificationServiceWrapper {
private static final Logger LOG = LoggerFactory.getLogger(MockedNotificationServiceWrapper.class);
- private final Notification publishedNotification;
private final NotificationPublishService notificationPublishService;
private Boolean rendererFailed = false;
public MockedNotificationServiceWrapper(NotificationPublishService notificationPublishService) {
- this.publishedNotification = null;
this.notificationPublishService = notificationPublishService;
}
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsBuilder;
import org.opendaylight.yangtools.yang.common.RpcResult;
import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-public final class ModelMappingUtils {
- private static final Logger LOG = LoggerFactory.getLogger(ModelMappingUtils.class);
+public final class ModelMappingUtils {
private ModelMappingUtils() {
}
private ListeningExecutorService executorService;
private CountDownLatch endSignal;
private static final int NUM_THREADS = 5;
- private boolean callbackRan;
@Before
public void setUp() throws InterruptedException, ExecutionException {
TopologyDataUtils.writePortmappingFromFileToDatastore(getDataStoreContextUtil(),
TapiTopologyDataUtils.PORTMAPPING_FILE);
- callbackRan = false;
MockitoAnnotations.openMocks(this);
networkTransactionService = new NetworkTransactionImpl(
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
result.addListener(new Runnable() {
@Override
public void run() {
- callbackRan = true;
endSignal.countDown();
}
}, executorService);
private static final Logger LOG = LoggerFactory.getLogger(ConvertORTopoToFullTapiTopoTest.class);
private static Node otnMuxA;
- private static Node otnMuxC;
private static Node otnSwitch;
private static Node tpdr100G;
private static Node roadmA;
private static Node roadmC;
private static Network openroadmNet;
- private static Map<LinkKey, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
- .networks.network.Link> otnLinks;
private static Map<LinkKey, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
.networks.network.Link> ortopoLinks;
private static Uuid topologyUuid;
.child(Node.class, new NodeKey(new NodeId("SPDR-SC1-XPDR1")));
FluentFuture<Optional<Node>> muxCFuture = dataBroker.newReadOnlyTransaction()
.read(LogicalDatastoreType.CONFIGURATION, muxCIID);
- otnMuxC = muxCFuture.get().get();
+ muxCFuture.get().get();
KeyedInstanceIdentifier<Node, NodeKey> switchIID = InstanceIdentifier.create(Networks.class)
.child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
.class, new NetworkKey(new NetworkId("otn-topology")))
.augmentation(Network1.class);
FluentFuture<Optional<Network1>> linksFuture = dataBroker.newReadOnlyTransaction()
.read(LogicalDatastoreType.CONFIGURATION, linksIID);
- otnLinks = linksFuture.get().get().getLink();
+ linksFuture.get().get().getLink();
InstanceIdentifier<Network1> links1IID = InstanceIdentifier.create(Networks.class)
.child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
Code Review / transportpce.git / commitdiff