[ONOS-4170] [ONOS-4163] PCE APP side changes : PceManager (code + UT)
Change-Id: I43db98b2fa3c5930b989d4fa3e2c00f7fa65c5ca
diff --git a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/BasicPceccHandlerTest.java b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/BasicPceccHandlerTest.java
index a5ea175..8c3de14 100644
--- a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/BasicPceccHandlerTest.java
+++ b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/BasicPceccHandlerTest.java
@@ -31,6 +31,8 @@
import org.junit.Test;
import org.onlab.packet.IpAddress;
+import org.onosproject.core.ApplicationId;
+import org.onosproject.core.CoreService;
import org.onosproject.core.DefaultGroupId;
import org.onosproject.incubator.net.tunnel.Tunnel;
import org.onosproject.incubator.net.tunnel.TunnelEndPoint;
@@ -45,11 +47,11 @@
import org.onosproject.net.DefaultPath;
import org.onosproject.net.DeviceId;
import org.onosproject.net.PortNumber;
+import org.onosproject.net.flowobjective.FlowObjectiveService;
import org.onosproject.net.Path;
import org.onosproject.pce.pcestore.api.LspLocalLabelInfo;
import org.onosproject.pce.pcestore.api.PceStore;
import org.onosproject.pce.pcestore.PceccTunnelInfo;
-import org.onosproject.pce.pcestore.DefaultLspLocalLabelInfo;
import org.onosproject.net.provider.ProviderId;
import org.onosproject.pce.util.LabelResourceAdapter;
import org.onosproject.pce.util.PceStoreAdapter;
@@ -67,6 +69,9 @@
private BasicPceccHandler pceccHandler;
protected LabelResourceService labelRsrcService;
protected PceStore pceStore;
+ private FlowObjectiveService flowObjectiveService;
+ private CoreService coreService;
+ private ApplicationId appId;
private TunnelEndPoint src = IpTunnelEndPoint.ipTunnelPoint(IpAddress.valueOf(23423));
private TunnelEndPoint dst = IpTunnelEndPoint.ipTunnelPoint(IpAddress.valueOf(32421));
private DefaultGroupId groupId = new DefaultGroupId(92034);
@@ -92,7 +97,10 @@
pceccHandler = BasicPceccHandler.getInstance();
labelRsrcService = new LabelResourceAdapter();
pceStore = new PceStoreAdapter();
- pceccHandler.initialize(labelRsrcService, pceStore);
+ flowObjectiveService = new PceManagerTest.MockFlowObjService();
+ coreService = new PceManagerTest.MockCoreService();
+ appId = coreService.registerApplication("org.onosproject.pce");
+ pceccHandler.initialize(labelRsrcService, flowObjectiveService, appId, pceStore);
// Cretae tunnel test
// Link
@@ -190,7 +198,7 @@
iterator = lspLocalLabelInfoList.iterator();
// Retrieve values and check device5
- lspLocalLabelInfo = (DefaultLspLocalLabelInfo) iterator.next();
+ lspLocalLabelInfo = iterator.next();
deviceId = lspLocalLabelInfo.deviceId();
inLabelId = lspLocalLabelInfo.inLabelId();
outLabelId = lspLocalLabelInfo.outLabelId();
@@ -205,7 +213,7 @@
// Next element check
// Retrieve values and check device4
- lspLocalLabelInfo = (DefaultLspLocalLabelInfo) iterator.next();
+ lspLocalLabelInfo = iterator.next();
deviceId = lspLocalLabelInfo.deviceId();
inLabelId = lspLocalLabelInfo.inLabelId();
outLabelId = lspLocalLabelInfo.outLabelId();
@@ -220,7 +228,7 @@
// Next element check
// Retrieve values and check device3
- lspLocalLabelInfo = (DefaultLspLocalLabelInfo) iterator.next();
+ lspLocalLabelInfo = iterator.next();
deviceId = lspLocalLabelInfo.deviceId();
inLabelId = lspLocalLabelInfo.inLabelId();
outLabelId = lspLocalLabelInfo.outLabelId();
@@ -235,7 +243,7 @@
// Next element check
// Retrieve values and check device2
- lspLocalLabelInfo = (DefaultLspLocalLabelInfo) iterator.next();
+ lspLocalLabelInfo = iterator.next();
deviceId = lspLocalLabelInfo.deviceId();
inLabelId = lspLocalLabelInfo.inLabelId();
outLabelId = lspLocalLabelInfo.outLabelId();
@@ -250,7 +258,7 @@
// Next element check
// Retrieve values and check device1
- lspLocalLabelInfo = (DefaultLspLocalLabelInfo) iterator.next();
+ lspLocalLabelInfo = iterator.next();
deviceId = lspLocalLabelInfo.deviceId();
inLabelId = lspLocalLabelInfo.inLabelId();
outLabelId = lspLocalLabelInfo.outLabelId();
diff --git a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PathComputationTest.java b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PathComputationTest.java
index 446aea2..c4040ed 100644
--- a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PathComputationTest.java
+++ b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PathComputationTest.java
@@ -96,20 +96,20 @@
private final MockDeviceService deviceService = new MockDeviceService();
private PceManager pceManager = new PceManager();
public static ProviderId providerId = new ProviderId("pce", "foo");
- private static final String DEVICE1 = "D001";
- private static final String DEVICE2 = "D002";
- private static final String DEVICE3 = "D003";
- private static final String DEVICE4 = "D004";
- private static final String DEVICE5 = "D005";
+ public static final String DEVICE1 = "D001";
+ public static final String DEVICE2 = "D002";
+ public static final String DEVICE3 = "D003";
+ public static final String DEVICE4 = "D004";
+ public static final String DEVICE5 = "D005";
public static final String PCEPDEVICE1 = "PD001";
public static final String PCEPDEVICE2 = "PD002";
public static final String PCEPDEVICE3 = "PD003";
public static final String PCEPDEVICE4 = "PD004";
- private static final TopologyVertex D1 = new DefaultTopologyVertex(DeviceId.deviceId("D001"));
- private static final TopologyVertex D2 = new DefaultTopologyVertex(DeviceId.deviceId("D002"));
- private static final TopologyVertex D3 = new DefaultTopologyVertex(DeviceId.deviceId("D003"));
- private static final TopologyVertex D4 = new DefaultTopologyVertex(DeviceId.deviceId("D004"));
- private static final TopologyVertex D5 = new DefaultTopologyVertex(DeviceId.deviceId("D005"));
+ public static final TopologyVertex D1 = new DefaultTopologyVertex(DeviceId.deviceId("D001"));
+ public static final TopologyVertex D2 = new DefaultTopologyVertex(DeviceId.deviceId("D002"));
+ public static final TopologyVertex D3 = new DefaultTopologyVertex(DeviceId.deviceId("D003"));
+ public static final TopologyVertex D4 = new DefaultTopologyVertex(DeviceId.deviceId("D004"));
+ public static final TopologyVertex D5 = new DefaultTopologyVertex(DeviceId.deviceId("D005"));
private static final String ANNOTATION_COST = "cost";
private static final String ANNOTATION_TE_COST = "teCost";
private static final String UNKNOWN = "unknown";
@@ -130,7 +130,7 @@
*
* @return graph path search algorithm
*/
- private AbstractGraphPathSearch<TopologyVertex, TopologyEdge> graphSearch() {
+ public static AbstractGraphPathSearch<TopologyVertex, TopologyEdge> graphSearch() {
return new DijkstraGraphSearch<>();
}
@@ -143,7 +143,7 @@
* @param port2 destination port
* @return link
*/
- private Link addLink(String device, long port, String device2, long port2, boolean setCost, int value) {
+ public static Link addLink(String device, long port, String device2, long port2, boolean setCost, int value) {
ConnectPoint src = new ConnectPoint(DeviceId.deviceId(device), PortNumber.portNumber(port));
ConnectPoint dst = new ConnectPoint(DeviceId.deviceId(device2), PortNumber.portNumber(port2));
Link curLink;
@@ -256,19 +256,37 @@
}
}
- private Path networkPath(org.onlab.graph.Path<TopologyVertex, TopologyEdge> path) {
+ /**
+ * Returns the path in Path object format.
+ */
+ public static Path networkPath(org.onlab.graph.Path<TopologyVertex, TopologyEdge> path) {
List<Link> links = path.edges().stream().map(TopologyEdge::link).collect(Collectors.toList());
return new DefaultPath(CORE_PROVIDER_ID, links, path.cost());
}
/**
- * Test Resource service for path computation.
+ * Tests Resource service for path computation.
*/
- private class MockPathResourceService extends ResourceServiceAdapter {
+ public class MockPathResourceService extends ResourceServiceAdapter {
private final Map<Resource, ResourceConsumer> assignment = new HashMap<>();
private Map<ResourceId, List<ResourceAllocation>> resourcesAllocations = new HashMap<>();
@Override
+ public Optional<ResourceAllocation> allocate(ResourceConsumer consumer, Resource resources) {
+ List<ResourceAllocation> allocations = allocate(consumer, ImmutableList.of(resources));
+ if (allocations.isEmpty()) {
+ return Optional.empty();
+ }
+
+ assert allocations.size() == 1;
+ ResourceAllocation allocation = allocations.get(0);
+ assert allocation.resource().equals(resources);
+
+ // cast is ensured by the assertions above
+ return Optional.of(allocation);
+ }
+
+ @Override
public List<ResourceAllocation> allocate(ResourceConsumer consumer, List<Resource> resources) {
for (Resource resource: resources) {
if (resource instanceof ContinuousResource) {
diff --git a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceManagerTest.java b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceManagerTest.java
new file mode 100644
index 0000000..5b0d869
--- /dev/null
+++ b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceManagerTest.java
@@ -0,0 +1,1026 @@
+package org.onosproject.pce.pceservice;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.core.Is.is;
+import static org.onlab.graph.GraphPathSearch.ALL_PATHS;
+import static org.onosproject.net.Link.State.ACTIVE;
+import static org.onosproject.net.Link.Type.DIRECT;
+import static org.onosproject.pce.pceservice.constraint.CostConstraint.Type.COST;
+import static org.onosproject.pce.pceservice.constraint.CostConstraint.Type.TE_COST;
+import static org.onosproject.net.resource.Resources.continuous;
+import static org.onosproject.pce.pceservice.LspType.SR_WITHOUT_SIGNALLING;
+import static org.onosproject.pce.pceservice.LspType.WITHOUT_SIGNALLING_AND_WITHOUT_SR;
+import static org.onosproject.pce.pceservice.LspType.WITH_SIGNALLING;
+import static org.onosproject.pce.pceservice.PathComputationTest.D1;
+import static org.onosproject.pce.pceservice.PathComputationTest.D2;
+import static org.onosproject.pce.pceservice.PathComputationTest.D3;
+import static org.onosproject.pce.pceservice.PathComputationTest.D4;
+import static org.onosproject.pce.pceservice.PcepAnnotationKeys.LOCAL_LSP_ID;
+import static org.onosproject.pce.pceservice.PcepAnnotationKeys.PLSP_ID;
+import static org.onosproject.incubator.net.tunnel.Tunnel.State.UNSTABLE;
+import static org.onosproject.incubator.net.tunnel.Tunnel.State.ESTABLISHED;
+
+import java.net.URISyntaxException;
+import java.nio.ByteBuffer;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
+import java.util.concurrent.atomic.AtomicLong;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.onlab.graph.GraphPathSearch;
+import org.onlab.packet.Ethernet;
+import org.onlab.packet.IPv4;
+import org.onlab.util.Bandwidth;
+import org.onosproject.common.DefaultTopologyGraph;
+import org.onosproject.core.ApplicationId;
+import org.onosproject.core.CoreServiceAdapter;
+import org.onosproject.core.DefaultApplicationId;
+import org.onosproject.core.IdGenerator;
+import org.onosproject.incubator.net.resource.label.LabelResourceId;
+import org.onosproject.incubator.net.resource.label.LabelResourceService;
+import org.onosproject.incubator.net.tunnel.DefaultTunnel;
+import org.onosproject.incubator.net.tunnel.Tunnel;
+import org.onosproject.incubator.net.tunnel.Tunnel.State;
+import org.onosproject.incubator.net.tunnel.TunnelEndPoint;
+import org.onosproject.incubator.net.tunnel.TunnelEvent;
+import org.onosproject.incubator.net.tunnel.TunnelId;
+import org.onosproject.incubator.net.tunnel.TunnelListener;
+import org.onosproject.net.AnnotationKeys;
+import org.onosproject.net.Annotations;
+import org.onosproject.net.ConnectPoint;
+import org.onosproject.net.DefaultAnnotations;
+import org.onosproject.net.DefaultDevice;
+import org.onosproject.net.DefaultLink;
+import org.onosproject.net.Device;
+import org.onosproject.net.DefaultAnnotations.Builder;
+import org.onosproject.net.device.DeviceServiceAdapter;
+import org.onosproject.net.flowobjective.ForwardingObjective;
+import org.onosproject.net.DeviceId;
+import org.onosproject.net.ElementId;
+import org.onosproject.net.Link;
+import org.onosproject.net.Path;
+import org.onosproject.net.PortNumber;
+import org.onosproject.net.SparseAnnotations;
+import org.onosproject.net.intent.Constraint;
+import org.onosproject.net.intent.IntentId;
+import org.onosproject.net.intent.constraint.BandwidthConstraint;
+import org.onosproject.net.packet.DefaultInboundPacket;
+import org.onosproject.net.packet.DefaultPacketContext;
+import org.onosproject.net.packet.InboundPacket;
+import org.onosproject.net.packet.OutboundPacket;
+import org.onosproject.net.packet.PacketProcessor;
+import org.onosproject.net.packet.PacketService;
+import org.onosproject.net.packet.PacketServiceAdapter;
+import org.onosproject.net.provider.ProviderId;
+import org.onosproject.net.resource.Resource;
+import org.onosproject.net.topology.DefaultTopologyEdge;
+import org.onosproject.net.topology.DefaultTopologyVertex;
+import org.onosproject.net.topology.LinkWeight;
+import org.onosproject.net.topology.PathServiceAdapter;
+import org.onosproject.net.topology.Topology;
+import org.onosproject.net.topology.TopologyEdge;
+import org.onosproject.net.topology.TopologyGraph;
+import org.onosproject.net.topology.TopologyServiceAdapter;
+import org.onosproject.net.topology.TopologyVertex;
+import org.onosproject.pce.pceservice.PathComputationTest.MockPathResourceService;
+import org.onosproject.pce.pceservice.constraint.CostConstraint;
+import org.onosproject.pce.pcestore.api.PceStore;
+import org.onosproject.pce.util.LabelResourceAdapter;
+import org.onosproject.pce.util.PceStoreAdapter;
+import org.onosproject.pce.util.TunnelServiceAdapter;
+import org.onosproject.pce.util.FlowObjServiceAdapter;
+import org.onosproject.store.service.TestStorageService;
+import com.google.common.collect.ImmutableSet;
+
+/**
+ * Tests the functions of PceManager.
+ */
+public class PceManagerTest {
+
+ private PathComputationTest pathCompTest = new PathComputationTest();
+ private MockPathResourceService resourceService = pathCompTest.new MockPathResourceService();
+ private MockTopologyService topologyService = new MockTopologyService();
+ private MockPathService pathService = new MockPathService();
+ private PceManager pceManager = new PceManager();
+ private MockCoreService coreService = new MockCoreService();
+ private MockTunnelServiceAdapter tunnelService = new MockTunnelServiceAdapter();
+ private TestStorageService storageService = new TestStorageService();
+ private PacketService packetService = new MockPacketService();
+ private MockDeviceService deviceService = new MockDeviceService();
+ private MockFlowObjService flowObjectiveService = new MockFlowObjService();
+ private PceStore pceStore = new PceStoreAdapter();
+ private LabelResourceService labelResourceService = new LabelResourceAdapter();
+
+ public static ProviderId providerId = new ProviderId("pce", "foo");
+ private static final String L3 = "L3";
+ private static final String LSRID = "lsrId";
+ private static final String PCECC_CAPABILITY = "pceccCapability";
+ private static final String SR_CAPABILITY = "srCapability";
+ private static final String LABEL_STACK_CAPABILITY = "labelStackCapability";
+
+ private TopologyGraph graph = null;
+ private Device deviceD1, deviceD2, deviceD3, deviceD4;
+ private Device pcepDeviceD1, pcepDeviceD2, pcepDeviceD3, pcepDeviceD4;
+ private Link link1, link2, link3, link4;
+ private static int flowsDownloaded;
+ private TunnelListener tunnelListener;
+
+ @Before
+ public void startUp() {
+ pceManager.pathService = pathService;
+ pceManager.resourceService = resourceService;
+ pceManager.tunnelService = tunnelService;
+ pceManager.coreService = coreService;
+ pceManager.storageService = storageService;
+ pceManager.packetService = packetService;
+ pceManager.deviceService = deviceService;
+ pceManager.labelRsrcService = labelResourceService;
+ pceManager.flowObjectiveService = flowObjectiveService;
+ pceManager.pceStore = pceStore;
+ pceManager.activate();
+ }
+
+ private void build4RouterTopo(boolean setCost, boolean setPceccCap, boolean setSrCap,
+ boolean setLabelStackCap, int bandwidth) {
+ Set<TopologyVertex> vertexes = new HashSet<TopologyVertex>();
+ vertexes.add(D1);
+ vertexes.add(D2);
+ vertexes.add(D3);
+ vertexes.add(D4);
+
+ Set<TopologyEdge> edges = new HashSet<TopologyEdge>();
+ link1 = PathComputationTest.addLink(D1.deviceId().toString(), 10, D2.deviceId().toString(), 20, setCost, 50);
+ TopologyEdge edge1 = new DefaultTopologyEdge(D1, D2, link1);
+ edges.add(edge1);
+
+ link2 = PathComputationTest.addLink(D2.deviceId().toString(), 30, D4.deviceId().toString(), 40, setCost, 20);
+ TopologyEdge edge2 = new DefaultTopologyEdge(D2, D4, link2);
+ edges.add(edge2);
+
+ link3 = PathComputationTest.addLink(D1.deviceId().toString(), 80, D3.deviceId().toString(), 70, setCost, 100);
+ TopologyEdge edge3 = new DefaultTopologyEdge(D1, D3, link3);
+ edges.add(edge3);
+
+ link4 = PathComputationTest.addLink(D3.deviceId().toString(), 60, D4.deviceId().toString(), 50, setCost, 80);
+ TopologyEdge edge4 = new DefaultTopologyEdge(D3, D4, link4);
+ edges.add(edge4);
+
+ graph = new DefaultTopologyGraph(vertexes, edges);
+
+ DefaultAnnotations.Builder builderDev1 = DefaultAnnotations.builder();
+ DefaultAnnotations.Builder builderDev2 = DefaultAnnotations.builder();
+ DefaultAnnotations.Builder builderDev3 = DefaultAnnotations.builder();
+ DefaultAnnotations.Builder builderDev4 = DefaultAnnotations.builder();
+
+ builderDev1.set(AnnotationKeys.TYPE, L3);
+ builderDev1.set(LSRID, "1.1.1.1");
+
+ builderDev2.set(AnnotationKeys.TYPE, L3);
+ builderDev2.set(LSRID, "2.2.2.2");
+
+ builderDev3.set(AnnotationKeys.TYPE, L3);
+ builderDev3.set(LSRID, "3.3.3.3");
+
+ builderDev4.set(AnnotationKeys.TYPE, L3);
+ builderDev4.set(LSRID, "4.4.4.4");
+
+ if (setSrCap) {
+ builderDev1.set(SR_CAPABILITY, "true");
+ builderDev2.set(SR_CAPABILITY, "true");
+ builderDev3.set(SR_CAPABILITY, "true");
+ builderDev4.set(SR_CAPABILITY, "true");
+ }
+
+ if (setPceccCap) {
+ builderDev1.set(PCECC_CAPABILITY, "true");
+ builderDev2.set(PCECC_CAPABILITY, "true");
+ builderDev3.set(PCECC_CAPABILITY, "true");
+ builderDev4.set(PCECC_CAPABILITY, "true");
+ }
+
+ if (setLabelStackCap) {
+ builderDev1.set(LABEL_STACK_CAPABILITY, "true");
+ builderDev2.set(LABEL_STACK_CAPABILITY, "true");
+ builderDev3.set(LABEL_STACK_CAPABILITY, "true");
+ builderDev4.set(LABEL_STACK_CAPABILITY, "true");
+ }
+
+ deviceD1 = new MockDevice(D1.deviceId(), builderDev1.build());
+ deviceD2 = new MockDevice(D2.deviceId(), builderDev2.build());
+ deviceD3 = new MockDevice(D3.deviceId(), builderDev3.build());
+ deviceD4 = new MockDevice(D4.deviceId(), builderDev4.build());
+
+ deviceService.addDevice(deviceD1);
+ deviceService.addDevice(deviceD2);
+ deviceService.addDevice(deviceD3);
+ deviceService.addDevice(deviceD4);
+
+ pcepDeviceD1 = new MockDevice(DeviceId.deviceId(PathComputationTest.PCEPDEVICE1), builderDev1.build());
+ deviceService.addDevice(pcepDeviceD1);
+
+ pcepDeviceD2 = new MockDevice(DeviceId.deviceId(PathComputationTest.PCEPDEVICE2), builderDev1.build());
+ deviceService.addDevice(pcepDeviceD2);
+
+ pcepDeviceD3 = new MockDevice(DeviceId.deviceId(PathComputationTest.PCEPDEVICE3), builderDev1.build());
+ deviceService.addDevice(pcepDeviceD3);
+
+ pcepDeviceD4 = new MockDevice(DeviceId.deviceId(PathComputationTest.PCEPDEVICE4), builderDev1.build());
+ deviceService.addDevice(pcepDeviceD4);
+
+ if (bandwidth != 0) {
+ List<Resource> resources = new LinkedList<>();
+ resources.add(continuous(link1.src().deviceId(), link1.src().port(), Bandwidth.class).resource(bandwidth));
+ resources.add(continuous(link2.src().deviceId(), link2.src().port(), Bandwidth.class).resource(bandwidth));
+ resources.add(continuous(link3.src().deviceId(), link3.src().port(), Bandwidth.class).resource(bandwidth));
+ resources.add(continuous(link4.src().deviceId(), link4.src().port(), Bandwidth.class).resource(bandwidth));
+
+ resources.add(continuous(link1.dst().deviceId(), link1.dst().port(), Bandwidth.class).resource(bandwidth));
+ resources.add(continuous(link2.dst().deviceId(), link2.dst().port(), Bandwidth.class).resource(bandwidth));
+ resources.add(continuous(link3.dst().deviceId(), link3.dst().port(), Bandwidth.class).resource(bandwidth));
+ resources.add(continuous(link4.dst().deviceId(), link4.dst().port(), Bandwidth.class).resource(bandwidth));
+
+ resourceService.allocate(IntentId.valueOf(bandwidth), resources);
+ }
+ }
+
+ /**
+ * Tests path success with (IGP) cost constraint for signalled LSP.
+ */
+ @Test
+ public void setupPathTest1() {
+ build4RouterTopo(true, false, false, false, 0); // IGP cost is set here.
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(true));
+ }
+
+ /**
+ * Tests path failure with (IGP) cost constraint for signalled LSP.
+ */
+ @Test
+ public void setupPathTest2() {
+ build4RouterTopo(false, false, false, false, 0); // TE cost is set here, not IGP.
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path success with TE-cost constraint for signalled LSP.
+ */
+ @Test
+ public void setupPathTest3() {
+ build4RouterTopo(false, false, false, false, 0); // TE cost is set here.
+
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(true));
+ }
+
+ /**
+ * Tests path failure with TE-cost constraint for signalled LSP.
+ */
+ @Test
+ public void setupPathTest4() {
+ build4RouterTopo(true, false, false, false, 0); // IGP cost is set here, not TE.
+
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path success with (IGP) cost constraint for non-SR non-signalled LSP.
+ */
+ @Test
+ public void setupPathTest5() {
+ build4RouterTopo(true, true, false, false, 0);
+
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints,
+ WITHOUT_SIGNALLING_AND_WITHOUT_SR);
+ assertThat(result, is(true));
+ }
+
+ /**
+ * Tests path success with TE-cost constraint for non-SR non-sgnalled LSP.
+ */
+ @Test
+ public void setupPathTest6() {
+ build4RouterTopo(false, true, false, false, 0);
+
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints,
+ WITHOUT_SIGNALLING_AND_WITHOUT_SR);
+ assertThat(result, is(true));
+ }
+
+ /**
+ * Tests path failure with TE-cost constraint for non-SR non-signalled LSP(CR). Label capability not registered.
+ */
+ @Test
+ public void setupPathTest7() {
+ build4RouterTopo(true, false, false, false, 0);
+
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints,
+ WITHOUT_SIGNALLING_AND_WITHOUT_SR);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path failure as bandwidth is requested but is not registered.
+ */
+ @Test
+ public void setupPathTest8() {
+ build4RouterTopo(true, false, false, false, 0);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path failure as bandwidth requested is more than registered.
+ */
+ @Test
+ public void setupPathTest9() {
+ build4RouterTopo(false, false, false, false, 5);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path setup failure(without signalling). Label capability is not present.
+ */
+ @Test
+ public void setupPathTest10() {
+ build4RouterTopo(false, false, false, false, 0);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, SR_WITHOUT_SIGNALLING);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path setup without failure for LSP with signalling and with bandwidth reservation.
+ */
+ @Test
+ public void setupPathTest11() {
+ build4RouterTopo(false, true, true, true, 15);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ LabelResourceId node1Label = LabelResourceId.labelResourceId(5200);
+ LabelResourceId node2Label = LabelResourceId.labelResourceId(5201);
+
+ pceManager.pceStore.addGlobalNodeLabel(D1.deviceId(), node1Label);
+ pceManager.pceStore.addGlobalNodeLabel(D2.deviceId(), node2Label);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, SR_WITHOUT_SIGNALLING);
+ assertThat(result, is(false));
+ }
+
+ /**
+ * Tests path setup without signalling and with bandwidth reservation.
+ */
+ @Test
+ public void setupPathTest12() {
+ build4RouterTopo(false, true, true, true, 15);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ LabelResourceId node1Label = LabelResourceId.labelResourceId(5200);
+ LabelResourceId node2Label = LabelResourceId.labelResourceId(5201);
+
+ pceManager.pceStore.addGlobalNodeLabel(D1.deviceId(), node1Label);
+ pceManager.pceStore.addGlobalNodeLabel(D2.deviceId(), node2Label);
+
+ LabelResourceId link1Label = LabelResourceId.labelResourceId(5202);
+ pceManager.pceStore.addAdjLabel(link1, link1Label);
+
+ LabelResourceId link2Label = LabelResourceId.labelResourceId(5203);
+ pceManager.pceStore.addAdjLabel(link2, link2Label);
+
+ LabelResourceId link3Label = LabelResourceId.labelResourceId(5204);
+ pceManager.pceStore.addAdjLabel(link3, link3Label);
+
+ LabelResourceId link4Label = LabelResourceId.labelResourceId(5205);
+ pceManager.pceStore.addAdjLabel(link4, link4Label);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, SR_WITHOUT_SIGNALLING);
+ assertThat(result, is(true));
+ }
+
+ /**
+ * Tests path setup without cost/bandwidth constraints.
+ */
+ @Test
+ public void setupPathTest13() {
+ build4RouterTopo(false, false, false, false, 0);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", null, WITH_SIGNALLING);
+ assertThat(result, is(true));
+ }
+
+ /**
+ * Tests path update with increase in bandwidth.
+ */
+ @Test
+ public void updatePathTest1() {
+ build4RouterTopo(false, true, true, true, 100);
+
+ // Setup tunnel.
+ List<Constraint> constraints = new LinkedList<>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(60.0));
+ constraints.add(bwConstraint);
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D4.deviceId(), "T123", constraints, WITH_SIGNALLING);
+ assertThat(result, is(true));
+
+ // Change constraint and update it.
+ constraints = new LinkedList<>();
+ bwConstraint = new BandwidthConstraint(Bandwidth.bps(50.0));
+ constraints.add(bwConstraint);
+ constraints.add(costConstraint);
+
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(1));
+
+ Tunnel tunnel = tunnels.iterator().next();
+
+ // Stimulate the effect of LSP ids from protocol msg.
+ tunnelService.updateTunnelWithLspIds(tunnel, "123", "1", State.ACTIVE);
+
+ result = pceManager.updatePath(tunnel.tunnelId(), constraints);
+ assertThat(result, is(true));
+
+ tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(2));
+ }
+
+ /**
+ * Tests path update with decrease in bandwidth.
+ */
+ @Test
+ public void updatePathTest2() {
+ build4RouterTopo(false, true, true, true, 100);
+
+ // Setup tunnel.
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(60.0));
+ constraints.add(bwConstraint);
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ LabelResourceId node1Label = LabelResourceId.labelResourceId(5200);
+ LabelResourceId node2Label = LabelResourceId.labelResourceId(5201);
+
+ pceManager.pceStore.addGlobalNodeLabel(D1.deviceId(), node1Label);
+ pceManager.pceStore.addGlobalNodeLabel(D2.deviceId(), node2Label);
+
+ LabelResourceId link1Label = LabelResourceId.labelResourceId(5202);
+ pceManager.pceStore.addAdjLabel(link1, link1Label);
+
+ LabelResourceId link2Label = LabelResourceId.labelResourceId(5203);
+ pceManager.pceStore.addAdjLabel(link2, link2Label);
+
+ LabelResourceId link3Label = LabelResourceId.labelResourceId(5204);
+ pceManager.pceStore.addAdjLabel(link3, link3Label);
+
+ LabelResourceId link4Label = LabelResourceId.labelResourceId(5205);
+ pceManager.pceStore.addAdjLabel(link4, link4Label);
+
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, SR_WITHOUT_SIGNALLING);
+ assertThat(result, is(true));
+
+ // Change constraint and update it.
+ constraints.remove(bwConstraint);
+ bwConstraint = new BandwidthConstraint(Bandwidth.bps(70.0));
+ constraints.add(bwConstraint);
+
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(1));
+
+ for (Tunnel tunnel : tunnels) {
+ result = pceManager.updatePath(tunnel.tunnelId(), constraints);
+ assertThat(result, is(true));
+ }
+
+ tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(2));
+ }
+
+ /**
+ * Tests path update without cost/bandwidth constraints.
+ */
+ @Test
+ public void updatePathTest3() {
+ build4RouterTopo(false, true, true, true, 100);
+
+ // Setup tunnel.
+ boolean result = pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", null, WITH_SIGNALLING);
+ assertThat(result, is(true));
+
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(1));
+
+ for (Tunnel tunnel : tunnels) {
+ result = pceManager.updatePath(tunnel.tunnelId(), null);
+ assertThat(result, is(true));
+ }
+
+ Iterable<Tunnel> queryTunnelResult = pceManager.queryAllPath();
+ assertThat((int) queryTunnelResult.spliterator().getExactSizeIfKnown(), is(2));
+ }
+
+ /**
+ * Tests path release.
+ */
+ @Test
+ public void releasePathTest1() {
+ build4RouterTopo(false, false, false, false, 5);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(1));
+ boolean result;
+ for (Tunnel tunnel : tunnels) {
+ result = pceManager.releasePath(tunnel.tunnelId());
+ assertThat(result, is(true));
+ }
+ tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(0));
+ }
+
+ /**
+ * Tests path release failure.
+ */
+ @Test
+ public void releasePathTest2() {
+ build4RouterTopo(false, false, false, false, 5);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+ constraints.add(costConstraint);
+
+ pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T123", constraints, WITH_SIGNALLING);
+
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(1));
+
+ // Random tunnel id.
+ boolean result = pceManager.releasePath(TunnelId.valueOf("111"));
+ assertThat(result, is(false));
+
+ tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ assertThat(tunnels.size(), is(1));
+ }
+
+ /**
+ * Tests packet in to trigger label DB sync.
+ */
+ @Test
+ public void packetProcessingTest() throws URISyntaxException {
+
+ build4RouterTopo(false, true, true, true, 0); // This also initializes devices etc.
+
+ final int srcHost = 2;
+ final int dstHost = 5;
+
+ LabelResourceId node1Label = LabelResourceId.labelResourceId(5200);
+ LabelResourceId node2Label = LabelResourceId.labelResourceId(5201);
+
+ pceManager.pceStore.addGlobalNodeLabel(D1.deviceId(), node1Label);
+ pceManager.pceStore.addGlobalNodeLabel(D2.deviceId(), node2Label);
+
+ ConnectPoint src = new ConnectPoint(D1.deviceId(), PortNumber.portNumber(srcHost));
+ ConnectPoint dst = new ConnectPoint(D2.deviceId(), PortNumber.portNumber(dstHost));
+
+ Link link1 = DefaultLink.builder().src(src).dst(dst).state(ACTIVE).type(DIRECT)
+ .providerId(new ProviderId("eth", "1")).build();
+
+ LabelResourceId link1Label = LabelResourceId.labelResourceId(5204);
+ pceManager.pceStore.addAdjLabel(link1, link1Label);
+
+ Ethernet eth;
+ IPv4 ipv4;
+
+ ipv4 = new IPv4();
+ eth = new Ethernet();
+ eth.setEtherType(Ethernet.TYPE_IPV4);
+ eth.setPayload(ipv4);
+
+ eth.setSourceMACAddress("00:00:00:10:00:0" + srcHost).setDestinationMACAddress("00:00:00:10:00:0" + dstHost);
+
+ InboundPacket inPkt = new DefaultInboundPacket(new ConnectPoint(D1.deviceId(), PortNumber.portNumber(srcHost)),
+ eth, ByteBuffer.wrap(eth.serialize()));
+
+ pktProcessor.process(new MockPcepPacketContext(inPkt, null));
+ assertThat(flowsDownloaded, is(4));
+ }
+
+ /**
+ * Tests tunnel events added and removed.
+ */
+ @Test
+ public void tunnelEventTest1() {
+ build4RouterTopo(false, true, true, true, 15);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ LabelResourceId node1Label = LabelResourceId.labelResourceId(5200);
+ LabelResourceId node2Label = LabelResourceId.labelResourceId(5201);
+
+ pceManager.pceStore.addGlobalNodeLabel(D1.deviceId(), node1Label);
+ pceManager.pceStore.addGlobalNodeLabel(D2.deviceId(), node2Label);
+
+ LabelResourceId link1Label = LabelResourceId.labelResourceId(5202);
+ pceManager.pceStore.addAdjLabel(link1, link1Label);
+
+ LabelResourceId link2Label = LabelResourceId.labelResourceId(5203);
+ pceManager.pceStore.addAdjLabel(link2, link2Label);
+
+ LabelResourceId link3Label = LabelResourceId.labelResourceId(5204);
+ pceManager.pceStore.addAdjLabel(link3, link3Label);
+
+ LabelResourceId link4Label = LabelResourceId.labelResourceId(5205);
+ pceManager.pceStore.addAdjLabel(link4, link4Label);
+
+ pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T1", constraints, SR_WITHOUT_SIGNALLING);
+ assertThat(pceStore.getTunnelInfoCount(), is(1));
+
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+
+ for (Tunnel tunnel : tunnels) {
+ TunnelEvent event = new TunnelEvent(TunnelEvent.Type.TUNNEL_ADDED, tunnel);
+ tunnelListener.event(event);
+
+ pceManager.releasePath(tunnel.tunnelId());
+
+ event = new TunnelEvent(TunnelEvent.Type.TUNNEL_REMOVED, tunnel);
+ tunnelListener.event(event);
+ }
+
+ assertThat(pceStore.getTunnelInfoCount(), is(0));
+ }
+
+ /**
+ * Tests label allocation/removal in CR case based on tunnel event.
+ */
+ @Test
+ public void tunnelEventTest2() {
+ build4RouterTopo(false, true, true, true, 15);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T2", constraints, WITHOUT_SIGNALLING_AND_WITHOUT_SR);
+ assertThat(pceStore.getTunnelInfoCount(), is(1));
+
+ TunnelEvent event;
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ for (Tunnel tunnel : tunnels) {
+ event = new TunnelEvent(TunnelEvent.Type.TUNNEL_ADDED, tunnel);
+ tunnelListener.event(event);
+
+ // Stimulate the effect of LSP ids from protocol msg.
+ tunnelService.updateTunnelWithLspIds(tunnel, "123", "1", ESTABLISHED);
+ }
+
+ tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ for (Tunnel tunnel : tunnels) {
+ event = new TunnelEvent(TunnelEvent.Type.TUNNEL_UPDATED, tunnel);
+ tunnelListener.event(event);
+
+ pceManager.releasePath(tunnel.tunnelId());
+
+ event = new TunnelEvent(TunnelEvent.Type.TUNNEL_REMOVED, tunnel);
+ tunnelListener.event(event);
+ }
+
+ assertThat(pceStore.getTunnelInfoCount(), is(0));
+ }
+
+ /**
+ * Tests handling UNSTABLE state based on tunnel event.
+ */
+ @Test
+ public void tunnelEventTest3() {
+ build4RouterTopo(false, true, true, true, 15);
+ List<Constraint> constraints = new LinkedList<Constraint>();
+ BandwidthConstraint bwConstraint = new BandwidthConstraint(Bandwidth.bps(10.0));
+ CostConstraint costConstraint = new CostConstraint(TE_COST);
+
+ constraints.add(costConstraint);
+ constraints.add(bwConstraint);
+
+ pceManager.setupPath(D1.deviceId(), D2.deviceId(), "T2", constraints, WITHOUT_SIGNALLING_AND_WITHOUT_SR);
+ assertThat(pceStore.getTunnelInfoCount(), is(1));
+ assertThat(pceStore.getFailedPathInfoCount(), is(0));
+
+ TunnelEvent event;
+ Collection<Tunnel> tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ for (Tunnel tunnel : tunnels) {
+ event = new TunnelEvent(TunnelEvent.Type.TUNNEL_ADDED, tunnel);
+ tunnelListener.event(event);
+
+ // Stimulate the effect of LSP ids from protocol msg.
+ tunnelService.updateTunnelWithLspIds(tunnel, "123", "1", UNSTABLE);
+ }
+
+ tunnels = (Collection<Tunnel>) pceManager.queryAllPath();
+ for (Tunnel tunnel : tunnels) {
+ event = new TunnelEvent(TunnelEvent.Type.TUNNEL_UPDATED, tunnel);
+ tunnelListener.event(event);
+ }
+ assertThat(pceStore.getTunnelInfoCount(), is(1));
+ assertThat(pceStore.getFailedPathInfoCount(), is(1));
+ }
+
+ @After
+ public void tearDown() {
+ pceManager.deactivate();
+ pceManager.pathService = null;
+ pceManager.resourceService = null;
+ pceManager.tunnelService = null;
+ pceManager.coreService = null;
+ pceManager.storageService = null;
+ pceManager.packetService = null;
+ pceManager.deviceService = null;
+ pceManager.labelRsrcService = null;
+ pceManager.flowObjectiveService = null;
+ pceManager.pceStore = null;
+ flowsDownloaded = 0;
+ }
+
+ private class MockTopologyService extends TopologyServiceAdapter {
+ @Override
+ public Set<Path> getPaths(Topology topology, DeviceId src, DeviceId dst, LinkWeight weight) {
+ DefaultTopologyVertex srcV = new DefaultTopologyVertex(src);
+ DefaultTopologyVertex dstV = new DefaultTopologyVertex(dst);
+ Set<TopologyVertex> vertices = graph.getVertexes();
+ if (!vertices.contains(srcV) || !vertices.contains(dstV)) {
+ // src or dst not part of the current graph
+ return ImmutableSet.of();
+ }
+
+ GraphPathSearch.Result<TopologyVertex, TopologyEdge> result = PathComputationTest.graphSearch()
+ .search(graph, srcV, dstV, weight, ALL_PATHS);
+ ImmutableSet.Builder<Path> builder = ImmutableSet.builder();
+ for (org.onlab.graph.Path<TopologyVertex, TopologyEdge> path : result.paths()) {
+ builder.add(PathComputationTest.networkPath(path));
+ }
+ return builder.build();
+ }
+ }
+
+ private class MockPathService extends PathServiceAdapter {
+
+ @Override
+ public Set<Path> getPaths(ElementId src, ElementId dst, LinkWeight weight) {
+ // If either edge is null, bail with no paths.
+ if (src == null || dst == null) {
+ return ImmutableSet.of();
+ }
+
+ // Otherwise get all paths between the source and destination edge
+ // devices.
+ return topologyService.getPaths(null, (DeviceId) src, (DeviceId) dst, weight);
+ }
+ }
+
+ private class MockTunnelServiceAdapter extends TunnelServiceAdapter {
+ private HashMap<TunnelId, Tunnel> tunnelIdAsKeyStore = new HashMap<TunnelId, Tunnel>();
+ private int tunnelIdCounter = 0;
+
+ @Override
+ public TunnelId setupTunnel(ApplicationId producerId, ElementId srcElementId, Tunnel tunnel, Path path) {
+ TunnelId tunnelId = TunnelId.valueOf(String.valueOf(++tunnelIdCounter));
+ Tunnel tunnelToInsert = new DefaultTunnel(tunnel.providerId(), tunnel.src(), tunnel.dst(), tunnel.type(),
+ tunnel.state(), tunnel.groupId(), tunnelId, tunnel.tunnelName(),
+ path, tunnel.annotations());
+ tunnelIdAsKeyStore.put(tunnelId, tunnelToInsert);
+ return tunnelId;
+ }
+
+ @Override
+ public void addListener(TunnelListener listener) {
+ tunnelListener = listener;
+ }
+
+ /**
+ * Stimulates the effect of receiving PLSP id and LSP id from protocol PCRpt msg.
+ */
+ public TunnelId updateTunnelWithLspIds(Tunnel tunnel, String pLspId, String localLspId, State state) {
+ TunnelId tunnelId = tunnel.tunnelId();
+ Builder annotationBuilder = DefaultAnnotations.builder();
+ annotationBuilder.putAll(tunnel.annotations());
+
+ // PCRpt in response to PCInitate msg will carry PLSP id allocated by PCC.
+ if (tunnel.annotations().value(PLSP_ID) == null) {
+ annotationBuilder.set(PLSP_ID, pLspId);
+ }
+
+ // Signalled LSPs will carry local LSP id allocated by signalling protocol(PCC).
+ if (tunnel.annotations().value(LOCAL_LSP_ID) == null) {
+ annotationBuilder.set(LOCAL_LSP_ID, localLspId);
+ }
+ SparseAnnotations annotations = annotationBuilder.build();
+ tunnelIdAsKeyStore.remove(tunnelId, tunnel);
+
+ Tunnel tunnelToInsert = new DefaultTunnel(tunnel.providerId(), tunnel.src(), tunnel.dst(), tunnel.type(),
+ state, tunnel.groupId(), tunnelId, tunnel.tunnelName(),
+ tunnel.path(), annotations);
+
+ tunnelIdAsKeyStore.put(tunnelId, tunnelToInsert);
+
+ return tunnelId;
+ }
+
+ @Override
+ public boolean downTunnel(ApplicationId producerId, TunnelId tunnelId) {
+ for (TunnelId tunnelIdKey : tunnelIdAsKeyStore.keySet()) {
+ if (tunnelIdKey.equals(tunnelId)) {
+ tunnelIdAsKeyStore.remove(tunnelId);
+ return true;
+ }
+ }
+ return false;
+ }
+
+ @Override
+ public Tunnel queryTunnel(TunnelId tunnelId) {
+ for (TunnelId tunnelIdKey : tunnelIdAsKeyStore.keySet()) {
+ if (tunnelIdKey.equals(tunnelId)) {
+ return tunnelIdAsKeyStore.get(tunnelId);
+ }
+ }
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> queryTunnel(TunnelEndPoint src, TunnelEndPoint dst) {
+ Collection<Tunnel> result = new HashSet<Tunnel>();
+ Tunnel tunnel = null;
+ for (TunnelId tunnelId : tunnelIdAsKeyStore.keySet()) {
+ tunnel = tunnelIdAsKeyStore.get(tunnelId);
+
+ if ((null != tunnel) && (src.equals(tunnel.src())) && (dst.equals(tunnel.dst()))) {
+ result.add(tunnel);
+ }
+ }
+
+ return result.size() == 0 ? Collections.emptySet() : ImmutableSet.copyOf(result);
+ }
+
+ @Override
+ public Collection<Tunnel> queryTunnel(Tunnel.Type type) {
+ Collection<Tunnel> result = new HashSet<Tunnel>();
+
+ for (TunnelId tunnelId : tunnelIdAsKeyStore.keySet()) {
+ result.add(tunnelIdAsKeyStore.get(tunnelId));
+ }
+
+ return result.size() == 0 ? Collections.emptySet() : ImmutableSet.copyOf(result);
+ }
+ }
+
+ public static class MockCoreService extends CoreServiceAdapter {
+
+ @Override
+ public ApplicationId registerApplication(String name) {
+ return new DefaultApplicationId(1, name);
+ }
+
+ @Override
+ public IdGenerator getIdGenerator(String topic) {
+ return new IdGenerator() {
+ private AtomicLong counter = new AtomicLong(0);
+
+ @Override
+ public long getNewId() {
+ return counter.getAndIncrement();
+ }
+ };
+ }
+ }
+
+ private class MockDevice extends DefaultDevice {
+ MockDevice(DeviceId id, Annotations annotations) {
+ super(null, id, null, null, null, null, null, null, annotations);
+ }
+ }
+
+ private class MockDeviceService extends DeviceServiceAdapter {
+ List<Device> devices = new LinkedList<>();
+
+ private void addDevice(Device dev) {
+ devices.add(dev);
+ }
+
+ @Override
+ public Device getDevice(DeviceId deviceId) {
+ for (Device dev : devices) {
+ if (dev.id().equals(deviceId)) {
+ return dev;
+ }
+ }
+ return null;
+ }
+
+ @Override
+ public Iterable<Device> getAvailableDevices() {
+ return devices;
+ }
+ }
+
+ private PacketProcessor pktProcessor = null;
+
+ private class MockPacketService extends PacketServiceAdapter {
+ @Override
+ public void addProcessor(PacketProcessor processor, int priority) {
+ pktProcessor = processor;
+ }
+ }
+
+ // Minimal PacketContext to make core and applications happy.
+ final class MockPcepPacketContext extends DefaultPacketContext {
+ private MockPcepPacketContext(InboundPacket inPkt, OutboundPacket outPkt) {
+ super(System.currentTimeMillis(), inPkt, outPkt, false);
+ }
+
+ @Override
+ public void send() {
+ }
+ }
+
+ public static class MockFlowObjService extends FlowObjServiceAdapter {
+ @Override
+ public void forward(DeviceId deviceId, ForwardingObjective forwardingObjective) {
+ ++flowsDownloaded;
+ }
+ }
+}
diff --git a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceccSrTeBeHandlerTest.java b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceccSrTeBeHandlerTest.java
index 93f7c69..2a419b5 100644
--- a/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceccSrTeBeHandlerTest.java
+++ b/apps/pce/app/src/test/java/org/onosproject/pce/pceservice/PceccSrTeBeHandlerTest.java
@@ -33,6 +33,8 @@
import org.junit.Test;
import org.onosproject.incubator.net.resource.label.LabelResourceId;
+import org.onosproject.core.ApplicationId;
+import org.onosproject.core.CoreService;
import org.onosproject.incubator.net.resource.label.LabelResourceAdminService;
import org.onosproject.incubator.net.resource.label.LabelResourceService;
import org.onosproject.incubator.net.tunnel.LabelStack;
@@ -41,6 +43,7 @@
import org.onosproject.net.DefaultPath;
import org.onosproject.net.DeviceId;
import org.onosproject.net.PortNumber;
+import org.onosproject.net.flowobjective.FlowObjectiveService;
import org.onosproject.net.Path;
import org.onosproject.pce.pcestore.api.PceStore;
import org.onosproject.net.provider.ProviderId;
@@ -61,6 +64,9 @@
protected LabelResourceAdminService labelRsrcAdminService;
protected LabelResourceService labelRsrcService;
protected PceStore pceStore;
+ private FlowObjectiveService flowObjectiveService;
+ private CoreService coreService;
+ private ApplicationId appId;
private ProviderId providerId;
private DeviceId deviceId1;
private DeviceId deviceId2;
@@ -88,8 +94,11 @@
srTeHandler = PceccSrTeBeHandler.getInstance();
labelRsrcService = new LabelResourceAdapter();
labelRsrcAdminService = new LabelResourceAdapter();
+ flowObjectiveService = new PceManagerTest.MockFlowObjService();
+ coreService = new PceManagerTest.MockCoreService();
+ appId = coreService.registerApplication("org.onosproject.pce");
pceStore = new PceStoreAdapter();
- srTeHandler.initialize(labelRsrcAdminService, labelRsrcService, pceStore);
+ srTeHandler.initialize(labelRsrcAdminService, labelRsrcService, flowObjectiveService, appId, pceStore);
// Creates path
// Creates list of links
@@ -446,39 +455,39 @@
// check node-label of deviceId1
List<LabelResourceId> labelList = labelStack.labelResources();
Iterator<LabelResourceId> iterator = labelList.iterator();
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(4097)));
// check adjacency label of deviceId1
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(5122)));
// check node-label of deviceId2
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(4098)));
// check adjacency label of deviceId2
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(5123)));
// check node-label of deviceId3
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(4099)));
// check adjacency label of deviceId3
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(5124)));
// check node-label of deviceId4
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(4100)));
// check adjacency label of deviceId4
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(5125)));
// check node-label of deviceId5
- labelId = (LabelResourceId) iterator.next();
+ labelId = iterator.next();
assertThat(labelId, is(LabelResourceId.labelResourceId(4101)));
}
}
diff --git a/apps/pce/app/src/test/java/org/onosproject/pce/util/FlowObjServiceAdapter.java b/apps/pce/app/src/test/java/org/onosproject/pce/util/FlowObjServiceAdapter.java
new file mode 100644
index 0000000..a7a7e2b
--- /dev/null
+++ b/apps/pce/app/src/test/java/org/onosproject/pce/util/FlowObjServiceAdapter.java
@@ -0,0 +1,65 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.pce.util;
+
+import java.util.List;
+
+import org.onosproject.net.DeviceId;
+import org.onosproject.net.flowobjective.FilteringObjective;
+import org.onosproject.net.flowobjective.FlowObjectiveService;
+import org.onosproject.net.flowobjective.ForwardingObjective;
+import org.onosproject.net.flowobjective.NextObjective;
+
+/**
+ * Test implementation of FlowObjectiveService.
+ */
+public class FlowObjServiceAdapter implements FlowObjectiveService {
+
+ private ForwardingObjective forwardingObjective;
+ @Override
+ public void filter(DeviceId deviceId, FilteringObjective filteringObjective) {
+
+ }
+
+ @Override
+ public void forward(DeviceId deviceId, ForwardingObjective forwardingObjective) {
+ this.forwardingObjective = forwardingObjective;
+ }
+
+ @Override
+ public void next(DeviceId deviceId, NextObjective nextObjective) {
+
+ }
+
+ @Override
+ public int allocateNextId() {
+ return 0;
+ }
+
+ @Override
+ public void initPolicy(String policy) {
+
+ }
+
+ public ForwardingObjective forwardingObjective() {
+ return forwardingObjective;
+ }
+
+ @Override
+ public List<String> getNextMappings() {
+ return null;
+ }
+}
diff --git a/apps/pce/app/src/test/java/org/onosproject/pce/util/TunnelServiceAdapter.java b/apps/pce/app/src/test/java/org/onosproject/pce/util/TunnelServiceAdapter.java
new file mode 100644
index 0000000..2a75eaf
--- /dev/null
+++ b/apps/pce/app/src/test/java/org/onosproject/pce/util/TunnelServiceAdapter.java
@@ -0,0 +1,158 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.pce.util;
+
+import java.util.Collection;
+
+import org.onosproject.core.ApplicationId;
+import org.onosproject.incubator.net.tunnel.Tunnel;
+import org.onosproject.incubator.net.tunnel.Tunnel.Type;
+import org.onosproject.incubator.net.tunnel.TunnelEndPoint;
+import org.onosproject.incubator.net.tunnel.TunnelId;
+import org.onosproject.incubator.net.tunnel.TunnelListener;
+import org.onosproject.incubator.net.tunnel.TunnelName;
+import org.onosproject.incubator.net.tunnel.TunnelService;
+import org.onosproject.incubator.net.tunnel.TunnelSubscription;
+import org.onosproject.net.Annotations;
+import org.onosproject.net.DeviceId;
+import org.onosproject.net.ElementId;
+import org.onosproject.net.Path;
+
+/**
+ * Provides test implementation of class TunnelService.
+ */
+public class TunnelServiceAdapter implements TunnelService {
+
+ @Override
+ public void addListener(TunnelListener listener) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public void removeListener(TunnelListener listener) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public Tunnel borrowTunnel(ApplicationId consumerId, TunnelId tunnelId, Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> borrowTunnel(ApplicationId consumerId, TunnelName tunnelName,
+ Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> borrowTunnel(ApplicationId consumerId, TunnelEndPoint src, TunnelEndPoint dst,
+ Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> borrowTunnel(ApplicationId consumerId, TunnelEndPoint src, TunnelEndPoint dst, Type type,
+ Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public TunnelId setupTunnel(ApplicationId producerId, ElementId srcElementId, Tunnel tunnel, Path path) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public boolean downTunnel(ApplicationId producerId, TunnelId tunnelId) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public boolean returnTunnel(ApplicationId consumerId, TunnelId tunnelId, Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public boolean returnTunnel(ApplicationId consumerId, TunnelName tunnelName, Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public boolean returnTunnel(ApplicationId consumerId, TunnelEndPoint src, TunnelEndPoint dst, Type type,
+ Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public boolean returnTunnel(ApplicationId consumerId, TunnelEndPoint src, TunnelEndPoint dst,
+ Annotations... annotations) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public Tunnel queryTunnel(TunnelId tunnelId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<TunnelSubscription> queryTunnelSubscription(ApplicationId consumerId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> queryTunnel(Type type) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> queryTunnel(TunnelEndPoint src, TunnelEndPoint dst) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Collection<Tunnel> queryAllTunnels() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public int tunnelCount() {
+ // TODO Auto-generated method stub
+ return 0;
+ }
+
+ @Override
+ public Iterable<Tunnel> getTunnels(DeviceId deviceId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+}