[ONOS-4166] Add the capabilities for links and devices in the resource manager. Also update the resource information from BGP-LS update.
Change-Id: I3ac50941c2841c104393fc543107496bffe92bbc
diff --git a/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/LinkStateAttributes.java b/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/LinkStateAttributes.java
index 0367f24..e6ba8b7 100644
--- a/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/LinkStateAttributes.java
+++ b/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/LinkStateAttributes.java
@@ -106,7 +106,7 @@
*
* @param linkStateAttribList Linked list of Link, Node and Prefix TLVs
*/
- LinkStateAttributes(List<BgpValueType> linkStateAttribList) {
+ public LinkStateAttributes(List<BgpValueType> linkStateAttribList) {
this.linkStateAttribList = linkStateAttribList;
this.isLinkStateAttribute = true;
}
diff --git a/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/attr/BgpLinkAttrMaxLinkBandwidth.java b/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/attr/BgpLinkAttrMaxLinkBandwidth.java
index 4d74702..3cc4bc6 100644
--- a/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/attr/BgpLinkAttrMaxLinkBandwidth.java
+++ b/protocols/bgp/bgpio/src/main/java/org/onosproject/bgpio/types/attr/BgpLinkAttrMaxLinkBandwidth.java
@@ -96,7 +96,7 @@
*
* @return Maximum link bandwidth
*/
- float linkAttrMaxLinkBandwidth() {
+ public float linkAttrMaxLinkBandwidth() {
return maxBandwidth;
}
diff --git a/providers/bgp/pom.xml b/providers/bgp/pom.xml
old mode 100755
new mode 100644
index 08431e0..0841b91
--- a/providers/bgp/pom.xml
+++ b/providers/bgp/pom.xml
@@ -41,6 +41,11 @@
</dependency>
<dependency>
<groupId>org.onosproject</groupId>
+ <artifactId>onos-incubator-api</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.onosproject</groupId>
<artifactId>onos-api</artifactId>
<classifier>tests</classifier>
<scope>test</scope>
diff --git a/providers/bgp/topology/BUCK b/providers/bgp/topology/BUCK
index 657ed56..ee79b20 100644
--- a/providers/bgp/topology/BUCK
+++ b/providers/bgp/topology/BUCK
@@ -3,6 +3,7 @@
'//protocols/bgp/api:onos-protocols-bgp-api',
'//protocols/bgp/bgpio:onos-protocols-bgp-bgpio',
'//incubator/store:onos-incubator-store',
+ '//incubator/api:onos-incubator-api',
]
TEST_DEPS = [
diff --git a/providers/bgp/topology/src/main/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProvider.java b/providers/bgp/topology/src/main/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProvider.java
index 0ac494c..0d1d1ea 100644
--- a/providers/bgp/topology/src/main/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProvider.java
+++ b/providers/bgp/topology/src/main/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProvider.java
@@ -17,11 +17,16 @@
import static org.onosproject.net.DeviceId.deviceId;
import static org.onosproject.net.Device.Type.ROUTER;
import static org.onosproject.net.Device.Type.VIRTUAL;
+import static org.onosproject.incubator.net.resource.label.LabelResourceId.labelResourceId;
+import static java.util.stream.Collectors.toList;
+import java.util.LinkedList;
import java.util.List;
import java.util.Set;
import org.onlab.packet.ChassisId;
+import org.onlab.packet.Ip4Address;
+import org.onlab.util.Bandwidth;
import org.apache.felix.scr.annotations.Activate;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Deactivate;
@@ -45,9 +50,21 @@
import org.onosproject.bgpio.types.IsIsNonPseudonode;
import org.onosproject.bgpio.types.IsIsPseudonode;
import org.onosproject.bgpio.types.LinkLocalRemoteIdentifiersTlv;
+import org.onosproject.bgpio.types.LinkStateAttributes;
import org.onosproject.bgpio.types.OspfNonPseudonode;
import org.onosproject.bgpio.types.OspfPseudonode;
+import org.onosproject.bgpio.types.attr.BgpAttrNodeFlagBitTlv;
+import org.onosproject.bgpio.types.attr.BgpAttrNodeIsIsAreaId;
+import org.onosproject.bgpio.types.attr.BgpAttrRouterIdV4;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrIgpMetric;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrMaxLinkBandwidth;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrTeDefaultMetric;
import org.onosproject.core.CoreService;
+import org.onosproject.incubator.net.resource.label.LabelResourceAdminService;
+import org.onosproject.incubator.net.resource.label.LabelResourceId;
+import org.onosproject.mastership.MastershipEvent;
+import org.onosproject.mastership.MastershipListener;
+import org.onosproject.mastership.MastershipService;
import org.onosproject.net.AnnotationKeys;
import org.onosproject.net.ConnectPoint;
import org.onosproject.net.DefaultAnnotations;
@@ -56,12 +73,15 @@
import org.onosproject.net.Link;
import org.onosproject.net.MastershipRole;
import org.onosproject.net.PortNumber;
+import org.onosproject.net.config.NetworkConfigService;
import org.onosproject.net.device.DefaultDeviceDescription;
+import org.onosproject.net.device.DefaultPortDescription;
import org.onosproject.net.device.DeviceDescription;
import org.onosproject.net.device.DeviceProvider;
import org.onosproject.net.device.DeviceProviderRegistry;
import org.onosproject.net.device.DeviceProviderService;
import org.onosproject.net.device.DeviceService;
+import org.onosproject.net.device.PortDescription;
import org.onosproject.net.link.DefaultLinkDescription;
import org.onosproject.net.link.LinkDescription;
import org.onosproject.net.link.LinkProvider;
@@ -70,6 +90,7 @@
import org.onosproject.net.link.LinkService;
import org.onosproject.net.provider.AbstractProvider;
import org.onosproject.net.provider.ProviderId;
+import org.onosproject.net.resource.BandwidthCapacity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -106,16 +127,39 @@
@Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
protected CoreService coreService;
+ @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+ protected MastershipService mastershipService;
+
+ @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+ protected LabelResourceAdminService labelResourceAdminService;
+
+ @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+ protected NetworkConfigService networkConfigService;
+
private DeviceProviderService deviceProviderService;
private LinkProviderService linkProviderService;
+ private InternalMastershipListener masterListener = new InternalMastershipListener();
private InternalBgpProvider listener = new InternalBgpProvider();
private static final String UNKNOWN = "unknown";
public static final long IDENTIFIER_SET = 0x100000000L;
public static final String AS_NUMBER = "asNumber";
public static final String DOMAIN_IDENTIFIER = "domainIdentifier";
public static final String ROUTING_UNIVERSE = "routingUniverse";
+
+ public static final String EXTERNAL_BIT = "externalBit";
+ public static final String ABR_BIT = "abrBit";
+ public static final String INTERNAL_BIT = "internalBit";
+ public static final String PSEUDO = "psuedo";
+ public static final String AREAID = "areaId";
+ public static final String LSRID = "lsrId";
+ public static final String COST = "cost";
+ public static final String TE_COST = "teCost";
+
public static final long PSEUDO_PORT = 0xffffffff;
+ public static final int DELAY = 2;
+ private LabelResourceId beginLabel = labelResourceId(5122);
+ private LabelResourceId endLabel = labelResourceId(9217);
@Activate
public void activate() {
@@ -123,6 +167,7 @@
deviceProviderService = deviceProviderRegistry.register(this);
linkProviderService = linkProviderRegistry.register(this);
controller.addListener(listener);
+ mastershipService.addListener(masterListener);
controller.addLinkListener(listener);
}
@@ -135,6 +180,27 @@
linkProviderService = null;
controller.removeListener(listener);
controller.removeLinkListener(listener);
+ mastershipService.removeListener(masterListener);
+ }
+
+ private class InternalMastershipListener implements MastershipListener {
+ @Override
+ public void event(MastershipEvent event) {
+ if (event.type() == MastershipEvent.Type.MASTER_CHANGED) {
+ if (mastershipService.getMasterFor(event.subject()) != null) {
+ //Only for L3 device create label pool for that device
+ Device device = deviceService.getDevice(event.subject());
+ if (device == null) {
+ log.debug("Device {} doesn't exist", event.subject());
+ return;
+ }
+ //Reserve device label pool for L3 devices
+ if (device.annotations().value(LSRID) != null) {
+ createDevicePool(event.subject());
+ }
+ }
+ }
+ }
}
/*
@@ -146,7 +212,7 @@
public void addNode(BgpNodeLSNlriVer4 nodeNlri, PathAttrNlriDetails details) {
log.debug("Add node {}", nodeNlri.toString());
- if (deviceProviderService == null) {
+ if (deviceProviderService == null || deviceService == null) {
return;
}
Device.Type deviceType = ROUTER;
@@ -154,6 +220,13 @@
DeviceId deviceId = deviceId(uri(nodeUri.toString()));
ChassisId cId = new ChassisId();
+ /*
+ * Check if device is already there (available) , if yes not updating to core.
+ */
+ if (deviceService.isAvailable(deviceId)) {
+ return;
+ }
+
DefaultAnnotations.Builder newBuilder = DefaultAnnotations.builder();
newBuilder.set(AnnotationKeys.TYPE, "L3");
@@ -183,11 +256,13 @@
}
}
}
+ DefaultAnnotations.Builder anntotations = DefaultAnnotations.builder();
+ anntotations = getAnnotations(newBuilder, true, details);
DeviceDescription description = new DefaultDeviceDescription(uri(nodeUri.toString()), deviceType, UNKNOWN,
- UNKNOWN, UNKNOWN, UNKNOWN, cId, newBuilder.build());
- deviceProviderService.deviceConnected(deviceId, description);
+ UNKNOWN, UNKNOWN, UNKNOWN, cId, anntotations.build());
+ deviceProviderService.deviceConnected(deviceId, description);
}
@Override
@@ -200,6 +275,12 @@
BgpDpid deviceUri = new BgpDpid(nodeNlri);
DeviceId deviceId = deviceId(uri(deviceUri.toString()));
+
+ if (labelResourceAdminService != null) {
+ //Destroy local device label pool reserved for that device
+ labelResourceAdminService.destroyDevicePool(deviceId);
+ }
+
deviceProviderService.deviceDisconnected(deviceId);
}
@@ -211,6 +292,24 @@
return;
}
LinkDescription linkDes = buildLinkDes(linkNlri, details, true);
+
+ /*
+ * Update link ports and configure bandwidth on source and destination port using networkConfig service
+ * Only master of source link registers for bandwidth
+ */
+ if (mastershipService.isLocalMaster(linkDes.src().deviceId())) {
+ registerBandwidth(linkDes, details);
+ }
+
+ //Updating ports of the link
+ List<PortDescription> srcPortDescriptions = new LinkedList<>();
+ srcPortDescriptions.add(new DefaultPortDescription(linkDes.src().port(), true));
+ deviceProviderService.updatePorts(linkDes.src().deviceId(), srcPortDescriptions);
+
+ List<PortDescription> dstPortDescriptions = new LinkedList<>();
+ dstPortDescriptions.add(new DefaultPortDescription(linkDes.dst().port(), true));
+ deviceProviderService.updatePorts(linkDes.dst().deviceId(), dstPortDescriptions);
+
linkProviderService.linkDetected(linkDes);
}
@@ -273,7 +372,12 @@
addOrDeletePseudoNode(isAddLink, localPseduo, remotePseduo, srcNodeNlri,
dstNodeNlri, srcId, dstId, details);
- return new DefaultLinkDescription(src, dst, Link.Type.DIRECT, false);
+ DefaultAnnotations.Builder annotationBuilder = DefaultAnnotations.builder();
+ if (details != null) {
+ annotationBuilder = getAnnotations(annotationBuilder, false, details);
+ }
+
+ return new DefaultLinkDescription(src, dst, Link.Type.DIRECT, false, annotationBuilder.build());
}
private void addOrDeletePseudoNode(boolean isAddLink, boolean localPseduo, boolean remotePseduo,
@@ -322,10 +426,140 @@
}
LinkDescription linkDes = buildLinkDes(linkNlri, null, false);
+
+ /*
+ * Only master for the link src will release the bandwidth resource.
+ */
+ if (networkConfigService != null && mastershipService.isLocalMaster(linkDes.src().deviceId())) {
+ // Releases registered resource for this link
+ networkConfigService.removeConfig(linkDes.src(), BandwidthCapacity.class);
+ networkConfigService.removeConfig(linkDes.dst(), BandwidthCapacity.class);
+ }
+
linkProviderService.linkVanished(linkDes);
}
}
+ // Creates label resource pool for the specific device. For all devices label range is 5122-9217
+ private void createDevicePool(DeviceId deviceId) {
+ if (labelResourceAdminService == null) {
+ return;
+ }
+
+ labelResourceAdminService.createDevicePool(deviceId, beginLabel, endLabel);
+ }
+
+ private void registerBandwidth(LinkDescription linkDes, PathAttrNlriDetails details) {
+ if (details == null) {
+ log.error("Couldnot able to register bandwidth ");
+ return;
+ }
+
+ List<BgpValueType> attribute = details.pathAttributes().stream()
+ .filter(attr -> attr instanceof LinkStateAttributes).collect(toList());
+ if (attribute.isEmpty()) {
+ return;
+ }
+
+ List<BgpValueType> tlvs = ((LinkStateAttributes) attribute.iterator().next()).linkStateAttributes();
+ float maxReservableBw = 0;
+
+ for (BgpValueType tlv : tlvs) {
+ switch (tlv.getType()) {
+ case LinkStateAttributes.ATTR_LINK_MAX_RES_BANDWIDTH:
+ maxReservableBw = ((BgpLinkAttrMaxLinkBandwidth) tlv).linkAttrMaxLinkBandwidth();
+ break;
+ default: // do nothing
+ }
+ }
+
+ if (maxReservableBw == 0.0) {
+ return;
+ }
+
+ //Configure bandwidth for src and dst port
+ BandwidthCapacity config = networkConfigService.addConfig(linkDes.src(), BandwidthCapacity.class);
+ config.capacity(Bandwidth.bps(maxReservableBw)).apply();
+
+ config = networkConfigService.addConfig(linkDes.dst(), BandwidthCapacity.class);
+ config.capacity(Bandwidth.bps(maxReservableBw)).apply();
+ }
+
+ private DefaultAnnotations.Builder getAnnotations(DefaultAnnotations.Builder annotationBuilder, boolean isNode,
+ PathAttrNlriDetails details) {
+
+ List<BgpValueType> attribute = details.pathAttributes().stream()
+ .filter(attr -> attr instanceof LinkStateAttributes).collect(toList());
+ if (attribute.isEmpty()) {
+ return annotationBuilder;
+ }
+ List<BgpValueType> tlvs = ((LinkStateAttributes) attribute.iterator().next()).linkStateAttributes();
+ boolean abrBit = false;
+ boolean externalBit = false;
+ boolean pseudo = false;
+ int igpMetric = 0;
+ int teMetric = 0;
+ byte[] areaId = null;
+ Ip4Address routerId = null;
+ for (BgpValueType tlv : tlvs) {
+ switch (tlv.getType()) {
+ case LinkStateAttributes.ATTR_NODE_FLAG_BITS:
+ abrBit = ((BgpAttrNodeFlagBitTlv) tlv).abrBit();
+ externalBit = ((BgpAttrNodeFlagBitTlv) tlv).externalBit();
+ break;
+ case NodeDescriptors.IGP_ROUTERID_TYPE:
+ if (tlv instanceof IsIsPseudonode || tlv instanceof OspfPseudonode) {
+ pseudo = true;
+ }
+ break;
+ case LinkStateAttributes.ATTR_NODE_ISIS_AREA_ID:
+ areaId = ((BgpAttrNodeIsIsAreaId) tlv).attrNodeIsIsAreaId();
+ break;
+ case LinkStateAttributes.ATTR_NODE_IPV4_LOCAL_ROUTER_ID:
+ routerId = ((BgpAttrRouterIdV4) tlv).attrRouterId();
+ break;
+ case LinkStateAttributes.ATTR_LINK_IGP_METRIC:
+ igpMetric = ((BgpLinkAttrIgpMetric) tlv).attrLinkIgpMetric();
+ break;
+ case LinkStateAttributes.ATTR_LINK_TE_DEFAULT_METRIC:
+ teMetric = ((BgpLinkAttrTeDefaultMetric) tlv).attrLinkDefTeMetric();
+ break;
+ default: // do nothing
+ }
+ }
+
+ // Annotations for device
+ if (isNode) {
+ boolean internalBit = false;
+ if (!abrBit && !externalBit) {
+ internalBit = true;
+ }
+
+ annotationBuilder.set(EXTERNAL_BIT, String.valueOf(externalBit));
+ annotationBuilder.set(ABR_BIT, String.valueOf(abrBit));
+ annotationBuilder.set(INTERNAL_BIT, String.valueOf(internalBit));
+ annotationBuilder.set(PSEUDO, String.valueOf(pseudo));
+
+ if (areaId != null) {
+ annotationBuilder.set(AREAID, new String(areaId));
+ }
+ if (routerId != null) {
+ // LsrID
+ annotationBuilder.set(LSRID, String.valueOf(routerId));
+ }
+ } else {
+ // Annotations for link
+ if (igpMetric != 0) {
+ annotationBuilder.set(COST, String.valueOf(igpMetric));
+ }
+
+ if (teMetric != 0) {
+ annotationBuilder.set(TE_COST, String.valueOf(teMetric));
+ }
+ }
+ return annotationBuilder;
+ }
+
@Override
public void triggerProbe(DeviceId deviceId) {
// TODO Auto-generated method stub
diff --git a/providers/bgp/topology/src/test/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProviderTest.java b/providers/bgp/topology/src/test/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProviderTest.java
index 7401fa5..6206ac1 100644
--- a/providers/bgp/topology/src/test/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProviderTest.java
+++ b/providers/bgp/topology/src/test/java/org/onosproject/provider/bgp/topology/impl/BgpTopologyProviderTest.java
@@ -16,6 +16,8 @@
import static org.hamcrest.core.Is.is;
import static org.hamcrest.core.IsNot.not;
import static org.onosproject.net.Link.State.ACTIVE;
+import static org.onosproject.net.MastershipRole.MASTER;
+import static org.hamcrest.Matchers.nullValue;
import java.util.Collection;
import java.util.HashMap;
@@ -29,7 +31,11 @@
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
+import org.onlab.junit.TestUtils;
+import org.onlab.junit.TestUtils.TestUtilsException;
import org.onlab.packet.ChassisId;
+import org.onlab.packet.Ip4Address;
+import org.onlab.util.Bandwidth;
import org.onosproject.bgp.controller.BgpLinkListener;
import org.onosproject.bgp.controller.BgpNodeListener;
import org.onosproject.bgpio.exceptions.BgpParseException;
@@ -43,9 +49,26 @@
import org.onosproject.bgpio.types.AutonomousSystemTlv;
import org.onosproject.bgpio.types.BgpValueType;
import org.onosproject.bgpio.types.IsIsNonPseudonode;
+import org.onosproject.bgpio.types.LinkStateAttributes;
+import org.onosproject.incubator.net.resource.label.LabelResourceAdminService;
+import org.onosproject.incubator.net.resource.label.LabelResourceId;
+import org.onosproject.incubator.net.resource.label.LabelResourcePool;
+import org.onosproject.mastership.MastershipEvent;
+import org.onosproject.mastership.MastershipListener;
+import org.onosproject.mastership.MastershipServiceAdapter;
+import org.onosproject.mastership.MastershipEvent.Type;
+import org.onosproject.net.link.LinkServiceAdapter;
import org.onosproject.bgpio.types.LinkLocalRemoteIdentifiersTlv;
import org.onosproject.bgpio.types.RouteDistinguisher;
+import org.onosproject.bgpio.types.attr.BgpAttrNodeFlagBitTlv;
+import org.onosproject.bgpio.types.attr.BgpAttrNodeIsIsAreaId;
+import org.onosproject.bgpio.types.attr.BgpAttrRouterIdV4;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrIgpMetric;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrMaxLinkBandwidth;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrTeDefaultMetric;
import org.onosproject.bgpio.util.Constants;
+import org.onosproject.cluster.NodeId;
+import org.onosproject.cluster.RoleInfo;
import org.onosproject.net.ConnectPoint;
import org.onosproject.net.DefaultDevice;
import org.onosproject.net.DefaultLink;
@@ -53,6 +76,11 @@
import org.onosproject.net.DeviceId;
import org.onosproject.net.Link;
import org.onosproject.net.MastershipRole;
+import org.onosproject.net.PortNumber;
+import org.onosproject.net.config.Config;
+import org.onosproject.net.config.ConfigApplyDelegate;
+import org.onosproject.net.config.ConfigFactory;
+import org.onosproject.net.config.NetworkConfigRegistryAdapter;
import org.onosproject.net.device.DeviceDescription;
import org.onosproject.net.device.DeviceProvider;
import org.onosproject.net.device.DeviceProviderRegistry;
@@ -65,6 +93,15 @@
import org.onosproject.net.link.LinkProviderRegistry;
import org.onosproject.net.link.LinkProviderService;
import org.onosproject.net.provider.ProviderId;
+import org.onosproject.net.resource.BandwidthCapacity;
+import org.onosproject.net.resource.Resource;
+import org.onosproject.net.resource.ResourceAdminService;
+import org.onosproject.net.resource.ResourceId;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.JsonNodeFactory;
+import com.fasterxml.jackson.databind.node.ObjectNode;
/**
* Test for BGP topology provider.
@@ -73,21 +110,31 @@
private static final DeviceId DID2 = DeviceId.deviceId("l3:rd=0::routinguniverse=0:asn=10");
private static final String UNKNOWN = new String("unknown");
public static ProviderId providerId = new ProviderId("l3", "foo");
+ private static final NodeId NODE1 = new NodeId("Master1");
private final BgpTopologyProvider provider = new BgpTopologyProvider();
private final TestDeviceRegistry nodeRegistry = new TestDeviceRegistry();
private final TestLinkRegistry linkRegistry = new TestLinkRegistry();
private final MockBgpController controller = new MockBgpController();
private MockDeviceService deviceService = new MockDeviceService();
+ private MockLinkService linkService = new MockLinkService();
+ private MockMastershipService mastershipService = new MockMastershipService();
+ private MockNetConfigRegistryAdapter networkConfigService = new MockNetConfigRegistryAdapter();
+ private MockLabelResourceService labelResourceAdminService = new MockLabelResourceService();
private Map<DeviceId, Device> deviceMap = new HashMap<>();
-
+ private MastershipListener listener;
@Before
- public void startUp() {
+ public void startUp() throws TestUtilsException {
provider.deviceProviderRegistry = nodeRegistry;
provider.linkProviderRegistry = linkRegistry;
provider.controller = controller;
provider.deviceService = deviceService;
+ provider.linkService = linkService;
+ provider.labelResourceAdminService = labelResourceAdminService;
+ provider.mastershipService = mastershipService;
+ provider.networkConfigService = networkConfigService;
+ listener = TestUtils.getField(provider, "masterListener");
provider.activate();
assertThat("device provider should be registered", not(nodeRegistry.provider));
assertThat("link provider should be registered", not(linkRegistry.linkProvider));
@@ -101,15 +148,177 @@
provider.controller = null;
provider.deviceService = null;
provider.deviceProviderRegistry = null;
+ provider.linkService = null;
+ provider.mastershipService = null;
+ provider.networkConfigService = null;
+ provider.labelResourceAdminService = null;
assertThat(controller.nodeListener, is(new HashSet<BgpNodeListener>()));
assertThat(controller.linkListener, is(new HashSet<BgpLinkListener>()));
}
+ private class MockLabelResourceService implements LabelResourceAdminService {
+
+ Map<DeviceId, LabelResourcePool> resourcePool = new HashMap<>();
+
+ @Override
+ public boolean createDevicePool(DeviceId deviceId, LabelResourceId beginLabel, LabelResourceId endLabel) {
+ LabelResourcePool labelResource = new LabelResourcePool(deviceId.toString(),
+ beginLabel.labelId(),
+ endLabel.labelId());
+ if (resourcePool.containsValue(labelResource)) {
+ return false;
+ }
+
+ resourcePool.put(deviceId, labelResource);
+ return true;
+ }
+
+ @Override
+ public boolean createGlobalPool(LabelResourceId beginLabel, LabelResourceId endLabel) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ @Override
+ public boolean destroyDevicePool(DeviceId deviceId) {
+ LabelResourcePool devicePool = resourcePool.get(deviceId);
+
+ if (devicePool == null) {
+ return false;
+ }
+
+ resourcePool.remove(deviceId);
+ return true;
+ }
+
+ @Override
+ public boolean destroyGlobalPool() {
+ // TODO Auto-generated method stub
+ return false;
+ }
+ }
+
+ /* Mock test for device service */
+ private class MockNetConfigRegistryAdapter extends NetworkConfigRegistryAdapter {
+ private ConfigFactory cfgFactory;
+ private Map<ConnectPoint, BandwidthCapacity> classConfig = new HashMap<>();
+
+ @Override
+ public void registerConfigFactory(ConfigFactory configFactory) {
+ cfgFactory = configFactory;
+ }
+
+ @Override
+ public void unregisterConfigFactory(ConfigFactory configFactory) {
+ cfgFactory = null;
+ }
+
+ @Override
+ public <S, C extends Config<S>> C addConfig(S subject, Class<C> configClass) {
+ if (configClass == BandwidthCapacity.class) {
+ BandwidthCapacity devCap = new BandwidthCapacity();
+ classConfig.put((ConnectPoint) subject, devCap);
+
+ JsonNode node = new ObjectNode(new MockJsonNode());
+ ObjectMapper mapper = new ObjectMapper();
+ ConfigApplyDelegate delegate = new InternalApplyDelegate();
+ devCap.init((ConnectPoint) subject, null, node, mapper, delegate);
+ return (C) devCap;
+ }
+
+ return null;
+ }
+
+ @Override
+ public <S, C extends Config<S>> void removeConfig(S subject, Class<C> configClass) {
+ classConfig.remove(subject);
+ }
+
+ @Override
+ public <S, C extends Config<S>> C getConfig(S subject, Class<C> configClass) {
+ if (configClass == BandwidthCapacity.class) {
+ return (C) classConfig.get(subject);
+ }
+ return null;
+ }
+
+ private class MockJsonNode extends JsonNodeFactory {
+ }
+
+ // Auxiliary delegate to receive notifications about changes applied to
+ // the network configuration - by the apps.
+ private class InternalApplyDelegate implements ConfigApplyDelegate {
+ @Override
+ public void onApply(Config config) {
+ }
+ }
+ }
+
+ private class MockMastershipService extends MastershipServiceAdapter {
+ @Override
+ public MastershipRole getLocalRole(DeviceId deviceId) {
+ return MASTER;
+ }
+
+ @Override
+ public boolean isLocalMaster(DeviceId deviceId) {
+ return getLocalRole(deviceId) == MASTER;
+ }
+
+ @Override
+ public NodeId getMasterFor(DeviceId deviceId) {
+ return NODE1;
+ }
+ }
+
+ private class MockResourceAdminService implements ResourceAdminService {
+ Map<ResourceId, List<Resource>> registeredRes = new HashMap<>();
+
+ @Override
+ public boolean register(List<Resource> resources) {
+ for (Resource res : resources) {
+ List<Resource> resource = new LinkedList<>();
+ resource.add(res);
+ if (registeredRes.containsKey(res.id())) {
+ resource.addAll(registeredRes.get(res.id()));
+ }
+ registeredRes.put(res.id(), resource);
+ }
+ return true;
+ }
+
+ @Override
+ public boolean unregister(List<ResourceId> ids) {
+ for (ResourceId id : ids) {
+ if (registeredRes.containsKey(id)) {
+ registeredRes.remove(id);
+ } else {
+ return false;
+ }
+ }
+ return true;
+ }
+ }
+
+ private class MockLinkService extends LinkServiceAdapter {
+
+ @Override
+ public Link getLink(ConnectPoint src, ConnectPoint dst) {
+ for (Link link : linkRegistry.links) {
+ if (link.src().equals(src) && link.dst().equals(dst)) {
+ return link;
+ }
+ }
+ return null;
+ }
+ }
+
/* Class implement device test registry */
private class TestDeviceRegistry implements DeviceProviderRegistry {
DeviceProvider provider;
Set<DeviceId> connected = new HashSet<>();
+ Map<DeviceId, List<PortDescription>> portUpdated = new HashMap<>();
@Override
public DeviceProviderService register(DeviceProvider provider) {
@@ -138,7 +347,7 @@
if (!deviceId.equals(DID2)) {
connected.add(deviceId);
Device device = new DefaultDevice(BgpTopologyProviderTest.providerId, deviceId, Device.Type.ROUTER,
- UNKNOWN, UNKNOWN, UNKNOWN, UNKNOWN, new ChassisId());
+ UNKNOWN, UNKNOWN, UNKNOWN, UNKNOWN, new ChassisId(), deviceDescription.annotations());
deviceMap.put(deviceId, device);
}
}
@@ -153,8 +362,7 @@
@Override
public void updatePorts(DeviceId deviceId, List<PortDescription> portDescriptions) {
- // TODO Auto-generated method stub
-
+ portUpdated.put(deviceId, portDescriptions);
}
@Override
@@ -202,9 +410,14 @@
@Override
public void linkDetected(LinkDescription linkDescription) {
- links.add(DefaultLink.builder().src(linkDescription.src())
- .dst(linkDescription.dst()).state(ACTIVE).type(linkDescription.type())
- .providerId(BgpTopologyProviderTest.providerId).build());
+ links.add(DefaultLink.builder()
+ .src(linkDescription.src())
+ .dst(linkDescription.dst())
+ .state(ACTIVE)
+ .type(linkDescription.type())
+ .providerId(BgpTopologyProviderTest.providerId)
+ .annotations(linkDescription.annotations())
+ .build());
}
@Override
@@ -349,6 +562,59 @@
}
}
+
+ /**
+ * Validate node is added to the device with all device annotations.
+ */
+ @Test
+ public void bgpTopologyProviderTestAddDevice4() {
+ LinkedList<BgpValueType> subTlvs = new LinkedList<>();
+ BgpValueType tlv = new AutonomousSystemTlv(100);
+ short deslength = AutonomousSystemTlv.LENGTH;
+ short desType = AutonomousSystemTlv.TYPE;
+
+ subTlvs.add(tlv);
+ BgpNodeLSIdentifier localNodeDescriptors = new BgpNodeLSIdentifier(new NodeDescriptors(subTlvs, deslength,
+ desType));
+ BgpNodeLSNlriVer4 nodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, localNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ PathAttrNlriDetails details = new PathAttrNlriDetails();
+ details.setIdentifier(0);
+ details.setProtocolID(ProtocolType.DIRECT);
+ List<BgpValueType> pathAttributes = new LinkedList<>();
+ List<BgpValueType> linkStateAttr = new LinkedList<>();
+ tlv = BgpAttrNodeFlagBitTlv.of(true, true, true, false);
+ linkStateAttr.add(tlv);
+ tlv = BgpAttrNodeIsIsAreaId.of(new byte[] {01, 01, 01, 01});
+ linkStateAttr.add(tlv);
+ tlv = BgpAttrRouterIdV4.of(Ip4Address.valueOf("1.1.1.1"), LinkStateAttributes.ATTR_NODE_IPV4_LOCAL_ROUTER_ID);
+ linkStateAttr.add(tlv);
+ pathAttributes.add(new LinkStateAttributes(linkStateAttr));
+ details.setPathAttribute(pathAttributes);
+
+ for (BgpNodeListener l : controller.nodeListener) {
+ l.addNode(nodeNlri, details);
+
+ assertThat(deviceMap.values().iterator().next().annotations().value(BgpTopologyProvider.ABR_BIT),
+ is("false"));
+ assertThat(deviceMap.values().iterator().next().annotations().value(BgpTopologyProvider.EXTERNAL_BIT),
+ is("true"));
+ assertThat(deviceMap.values().iterator().next().annotations().value(BgpTopologyProvider.INTERNAL_BIT),
+ is("false"));
+ assertThat(deviceMap.values().iterator().next().annotations().value(BgpTopologyProvider.PSEUDO),
+ is("false"));
+ assertThat(deviceMap.values().iterator().next().annotations().value(BgpTopologyProvider.AREAID).getBytes(),
+ is(new byte[] {01, 01, 01, 01}));
+ assertThat(deviceMap.values().iterator().next().annotations().value(BgpTopologyProvider.LSRID),
+ is("1.1.1.1"));
+
+ assertThat(nodeRegistry.connected.size(), is(1));
+ l.deleteNode(nodeNlri);
+ assertThat(nodeRegistry.connected.size(), is(0));
+ }
+ }
+
/**
* Add a link and two devices.
*
@@ -460,6 +726,82 @@
}
/**
+ * Add a link and delete a link with registering/unregistering bandwidth.
+ *
+ * @throws BgpParseException while adding or removing the link
+ * @throws InterruptedException while registering for bandwidth
+ */
+ @Test
+ public void bgpTopologyProviderTestAddLink3() throws BgpParseException, InterruptedException {
+ LinkedList<BgpValueType> localTlvs = new LinkedList<>();
+ LinkedList<BgpValueType> remoteTlvs = new LinkedList<>();
+ LinkedList<BgpValueType> linkdes = new LinkedList<>();
+ BgpValueType tlv = new AutonomousSystemTlv(10);
+ short deslength = AutonomousSystemTlv.LENGTH;
+ short desType = AutonomousSystemTlv.TYPE;
+
+ localTlvs.add(tlv);
+ remoteTlvs.add(tlv);
+ tlv = IsIsNonPseudonode.of(new byte[] {20, 20, 20, 20, 00, 20});
+ localTlvs.add(tlv);
+ tlv = IsIsNonPseudonode.of(new byte[] {30, 30, 30, 30, 00, 30});
+ remoteTlvs.add(tlv);
+ NodeDescriptors localNode = new NodeDescriptors(localTlvs, deslength, desType);
+ NodeDescriptors remoteNode = new NodeDescriptors(remoteTlvs, deslength, desType);
+ BgpNodeLSIdentifier localNodeDescriptors = new BgpNodeLSIdentifier(localNode);
+ BgpNodeLSNlriVer4 nodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, localNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ BgpNodeLSIdentifier remoteNodeDescriptors = new BgpNodeLSIdentifier(remoteNode);
+ BgpNodeLSNlriVer4 remNodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, remoteNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ PathAttrNlriDetails details = new PathAttrNlriDetails();
+ details.setIdentifier(0);
+ details.setProtocolID(ProtocolType.DIRECT);
+ List<BgpValueType> pathAttributes = new LinkedList<>();
+ details.setPathAttribute(pathAttributes);
+
+ tlv = LinkLocalRemoteIdentifiersTlv.of(99, 100);
+ linkdes.add(tlv);
+ BgpLinkLSIdentifier linkId = new BgpLinkLSIdentifier(localNode, remoteNode, linkdes);
+ BgpLinkLsNlriVer4 linkNlri = new BgpLinkLsNlriVer4((byte) Constants.DIRECT, 0, linkId,
+ new RouteDistinguisher(), false);
+
+ for (BgpNodeListener l : controller.nodeListener) {
+ l.addNode(nodeNlri, details);
+ assertThat(nodeRegistry.connected.size(), is(1));
+ l.addNode(remNodeNlri, details);
+ assertThat(nodeRegistry.connected.size(), is(2));
+ l.deleteNode(remNodeNlri);
+ assertThat(nodeRegistry.connected.size(), is(1));
+ }
+
+ List<BgpValueType> linkPathAttributes = new LinkedList<>();
+ List<BgpValueType> linkStateAttr = new LinkedList<>();
+ tlv = BgpLinkAttrIgpMetric.of(10, 4);
+ linkStateAttr.add(tlv);
+ tlv = BgpLinkAttrTeDefaultMetric.of(20);
+ linkStateAttr.add(tlv);
+ tlv = BgpLinkAttrMaxLinkBandwidth.of(30, LinkStateAttributes.ATTR_LINK_MAX_RES_BANDWIDTH);
+ linkStateAttr.add(tlv);
+ linkPathAttributes.add(new LinkStateAttributes(linkStateAttr));
+ details.setPathAttribute(linkPathAttributes);
+
+ for (BgpLinkListener l : controller.linkListener) {
+ l.addLink(linkNlri, details);
+ assertThat(linkRegistry.links.size(), is(1));
+ assertThat(linkRegistry.links.iterator().next().annotations().value(BgpTopologyProvider.COST),
+ is("10"));
+ assertThat(linkRegistry.links.iterator().next().annotations().value(BgpTopologyProvider.TE_COST),
+ is("20"));
+
+ l.deleteLink(linkNlri);
+ assertThat(linkRegistry.links.size(), is(0));
+ }
+ }
+
+ /**
* Invalid link.
*
* @throws BgpParseException while adding or deleting a link
@@ -512,4 +854,188 @@
assertThat(linkRegistry.links.size(), is(0));
}
}
+
+ /**
+ * Add device check label registration is done.
+ *
+ * @throws BgpParseException while adding a device
+ */
+ @Test
+ public void bgpTopologyProviderDeviceTestLabel1() throws BgpParseException {
+ LinkedList<BgpValueType> subTlvs = new LinkedList<>();
+ BgpValueType tlv = new AutonomousSystemTlv(100);
+ short deslength = AutonomousSystemTlv.LENGTH;
+ short desType = AutonomousSystemTlv.TYPE;
+
+ subTlvs.add(tlv);
+ BgpNodeLSIdentifier localNodeDescriptors = new BgpNodeLSIdentifier(new NodeDescriptors(subTlvs, deslength,
+ desType));
+ BgpNodeLSNlriVer4 nodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, localNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ PathAttrNlriDetails details = new PathAttrNlriDetails();
+ details.setIdentifier(0);
+ details.setProtocolID(ProtocolType.DIRECT);
+ List<BgpValueType> pathAttributes = new LinkedList<>();
+ List<BgpValueType> linkStateAttributes = new LinkedList<>();
+ tlv = BgpAttrRouterIdV4.of(Ip4Address.valueOf("1.1.1.1"), LinkStateAttributes.ATTR_NODE_IPV4_LOCAL_ROUTER_ID);
+ linkStateAttributes.add(tlv);
+ pathAttributes.add(new LinkStateAttributes(linkStateAttributes));
+ details.setPathAttribute(pathAttributes);
+
+ for (BgpNodeListener l : controller.nodeListener) {
+ l.addNode(nodeNlri, details);
+ assertThat(nodeRegistry.connected.size(), is(1));
+ }
+
+ MastershipEvent event = new MastershipEvent(Type.MASTER_CHANGED, nodeRegistry.connected.iterator().next(),
+ new RoleInfo(NodeId.nodeId("Node1"), new LinkedList<>()));
+
+ listener.event(event);
+ assertThat(labelResourceAdminService.resourcePool.keySet().size(), is(1));
+ }
+
+ /**
+ * Add device check label registration is done and delete node destroy label pool.
+ *
+ * @throws BgpParseException while adding a device
+ */
+ @Test
+ public void bgpTopologyProviderDeviceTestLabel2() throws BgpParseException {
+ LinkedList<BgpValueType> subTlvs = new LinkedList<>();
+ BgpValueType tlv = new AutonomousSystemTlv(100);
+ short deslength = AutonomousSystemTlv.LENGTH;
+ short desType = AutonomousSystemTlv.TYPE;
+
+ subTlvs.add(tlv);
+ BgpNodeLSIdentifier localNodeDescriptors = new BgpNodeLSIdentifier(new NodeDescriptors(subTlvs, deslength,
+ desType));
+ BgpNodeLSNlriVer4 nodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, localNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ PathAttrNlriDetails details = new PathAttrNlriDetails();
+ details.setIdentifier(0);
+ details.setProtocolID(ProtocolType.DIRECT);
+ List<BgpValueType> pathAttributes = new LinkedList<>();
+ List<BgpValueType> linkStateAttributes = new LinkedList<>();
+ tlv = BgpAttrRouterIdV4.of(Ip4Address.valueOf("1.1.1.1"), LinkStateAttributes.ATTR_NODE_IPV4_LOCAL_ROUTER_ID);
+ linkStateAttributes.add(tlv);
+ pathAttributes.add(new LinkStateAttributes(linkStateAttributes));
+ details.setPathAttribute(pathAttributes);
+
+ for (BgpNodeListener l : controller.nodeListener) {
+ l.addNode(nodeNlri, details);
+ assertThat(nodeRegistry.connected.size(), is(1));
+ // Check label resource reserved for that device
+ MastershipEvent event = new MastershipEvent(Type.MASTER_CHANGED, nodeRegistry.connected.iterator().next(),
+ new RoleInfo(NodeId.nodeId("Node1"), new LinkedList<>()));
+ listener.event(event);
+ assertThat(labelResourceAdminService.resourcePool.keySet().size(), is(1));
+
+ l.deleteNode(nodeNlri);
+ assertThat(nodeRegistry.connected.size(), is(0));
+ assertThat(labelResourceAdminService.resourcePool.keySet().size(), is(0));
+ }
+ }
+
+ /**
+ * Add a link register bandwidth and remove link unregister bandwidth.
+ *
+ * @throws BgpParseException while registering/unregistering bandwidth
+ */
+ @Test
+ public void bgpTopologyProviderDeviceTestLabel3() throws BgpParseException {
+ LinkedList<BgpValueType> localTlvs = new LinkedList<>();
+ LinkedList<BgpValueType> remoteTlvs = new LinkedList<>();
+ LinkedList<BgpValueType> linkdes = new LinkedList<>();
+ BgpValueType tlv = new AutonomousSystemTlv(10);
+ short deslength = AutonomousSystemTlv.LENGTH;
+ short desType = AutonomousSystemTlv.TYPE;
+
+ localTlvs.add(tlv);
+ remoteTlvs.add(tlv);
+ tlv = IsIsNonPseudonode.of(new byte[] {20, 20, 20, 20, 00, 20});
+ localTlvs.add(tlv);
+ tlv = IsIsNonPseudonode.of(new byte[] {30, 30, 30, 30, 00, 30});
+ remoteTlvs.add(tlv);
+ NodeDescriptors localNode = new NodeDescriptors(localTlvs, deslength, desType);
+ NodeDescriptors remoteNode = new NodeDescriptors(remoteTlvs, deslength, desType);
+ BgpNodeLSIdentifier localNodeDescriptors = new BgpNodeLSIdentifier(localNode);
+ BgpNodeLSNlriVer4 nodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, localNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ BgpNodeLSIdentifier remoteNodeDescriptors = new BgpNodeLSIdentifier(remoteNode);
+ BgpNodeLSNlriVer4 remNodeNlri = new BgpNodeLSNlriVer4(0, (byte) Constants.DIRECT, remoteNodeDescriptors, false,
+ new RouteDistinguisher());
+
+ PathAttrNlriDetails details = new PathAttrNlriDetails();
+ details.setIdentifier(0);
+ details.setProtocolID(ProtocolType.DIRECT);
+ List<BgpValueType> pathAttributes = new LinkedList<>();
+ List<BgpValueType> linkStateAttributes = new LinkedList<>();
+ tlv = BgpAttrRouterIdV4.of(Ip4Address.valueOf("1.1.1.1"), LinkStateAttributes.ATTR_NODE_IPV4_LOCAL_ROUTER_ID);
+ linkStateAttributes.add(tlv);
+ pathAttributes.add(new LinkStateAttributes(linkStateAttributes));
+ details.setPathAttribute(pathAttributes);
+
+ tlv = LinkLocalRemoteIdentifiersTlv.of(99, 100);
+ linkdes.add(tlv);
+ BgpLinkLSIdentifier linkId = new BgpLinkLSIdentifier(localNode, remoteNode, linkdes);
+ BgpLinkLsNlriVer4 linkNlri = new BgpLinkLsNlriVer4((byte) Constants.DIRECT, 0, linkId,
+ new RouteDistinguisher(), false);
+
+ for (BgpNodeListener l : controller.nodeListener) {
+ l.addNode(nodeNlri, details);
+ assertThat(nodeRegistry.connected.size(), is(1));
+ //Check label resource reserved for that device
+ MastershipEvent event = new MastershipEvent(Type.MASTER_CHANGED, nodeRegistry.connected.iterator().next(),
+ new RoleInfo(NodeId.nodeId("Node1"), new LinkedList<>()));
+ listener.event(event);
+ assertThat(labelResourceAdminService.resourcePool.keySet().size(), is(1));
+ l.addNode(remNodeNlri, details);
+ assertThat(nodeRegistry.connected.size(), is(2));
+ l.deleteNode(remNodeNlri);
+ assertThat(nodeRegistry.connected.size(), is(1));
+ assertThat(labelResourceAdminService.resourcePool.keySet().size(), is(1));
+ }
+
+ List<BgpValueType> linkPathAttributes = new LinkedList<>();
+ List<BgpValueType> linkStateAttr = new LinkedList<>();
+ tlv = BgpLinkAttrIgpMetric.of(10, 4);
+ linkStateAttr.add(tlv);
+ tlv = BgpLinkAttrTeDefaultMetric.of(20);
+ linkStateAttr.add(tlv);
+ tlv = BgpLinkAttrMaxLinkBandwidth.of(70, LinkStateAttributes.ATTR_LINK_MAX_RES_BANDWIDTH);
+ linkStateAttr.add(tlv);
+ linkPathAttributes.add(new LinkStateAttributes(linkStateAttr));
+ details.setPathAttribute(linkPathAttributes);
+
+ for (BgpLinkListener l : controller.linkListener) {
+ l.addLink(linkNlri, details);
+ assertThat(linkRegistry.links.size(), is(1));
+ assertThat(linkRegistry.links.iterator().next().annotations().value(BgpTopologyProvider.COST),
+ is("10"));
+ assertThat(linkRegistry.links.iterator().next().annotations().value(BgpTopologyProvider.TE_COST),
+ is("20"));
+
+ ConnectPoint src = new ConnectPoint(
+ DeviceId.deviceId("l3:rd=0::routinguniverse=0:asn=10:isoid=1414.1414.0014"),
+ PortNumber.portNumber(4294967395L));
+ ConnectPoint dst = new ConnectPoint(
+ DeviceId.deviceId("l3:rd=0::routinguniverse=0:asn=10:isoid=1e1e.1e1e.001e"),
+ PortNumber.portNumber(4294967396L));
+ BandwidthCapacity bandwidth = networkConfigService.getConfig(src, BandwidthCapacity.class);
+ assertThat(bandwidth.capacity().bps(), is(70.0 * 1_000_000L));
+
+ bandwidth = networkConfigService.getConfig(dst, BandwidthCapacity.class);
+ assertThat(bandwidth.capacity(), is(Bandwidth.bps(70.0 * 1_000_000L)));
+
+ l.deleteLink(linkNlri);
+ assertThat(linkRegistry.links.size(), is(0));
+ bandwidth = networkConfigService.getConfig(src, BandwidthCapacity.class);
+ assertThat(bandwidth, is(nullValue()));
+ bandwidth = networkConfigService.getConfig(dst, BandwidthCapacity.class);
+ assertThat(bandwidth, is(nullValue()));
+ }
+ }
}