ISIS protocol manual merge from 1.6 due to cherry pick merge conflict
Change-Id: I6c3abf6a83ddaeba76293dc7864fcec88e9b4e7e
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLink.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLink.java
new file mode 100644
index 0000000..2df4276
--- /dev/null
+++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLink.java
@@ -0,0 +1,118 @@
+/*
+ * Copyright 2015 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.isis.controller.impl.topology;
+
+import com.google.common.base.MoreObjects;
+import com.google.common.base.Objects;
+import org.onlab.packet.Ip4Address;
+import org.onosproject.isis.controller.topology.IsisLink;
+import org.onosproject.isis.controller.topology.IsisLinkTed;
+
+/**
+ * Representation of an ISIS Link.
+ */
+public class DefaultIsisLink implements IsisLink {
+
+ private String remoteSystemId;
+ private String localSystemId;
+ private Ip4Address interfaceIp;
+ private Ip4Address neighborIp;
+ private IsisLinkTed linkTed;
+
+ @Override
+ public String remoteSystemId() {
+ return this.remoteSystemId;
+ }
+
+ @Override
+ public String localSystemId() {
+ return this.localSystemId;
+ }
+
+ @Override
+ public Ip4Address interfaceIp() {
+ return this.interfaceIp;
+ }
+
+ @Override
+ public Ip4Address neighborIp() {
+ return this.neighborIp;
+ }
+
+ @Override
+ public IsisLinkTed linkTed() {
+ return this.linkTed;
+ }
+
+ @Override
+ public void setRemoteSystemId(String remoteSystemId) {
+ this.remoteSystemId = remoteSystemId;
+ }
+
+ @Override
+ public void setLocalSystemId(String localSystemId) {
+ this.localSystemId = localSystemId;
+ }
+
+ @Override
+ public void setInterfaceIp(Ip4Address interfaceIp) {
+ this.interfaceIp = interfaceIp;
+ }
+
+ @Override
+ public void setNeighborIp(Ip4Address neighborIp) {
+ this.neighborIp = neighborIp;
+ }
+
+ @Override
+ public void setLinkTed(IsisLinkTed linkTed) {
+ this.linkTed = linkTed;
+ }
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(getClass())
+ .omitNullValues()
+ .add("remoteSystemId", remoteSystemId)
+ .add("localSystemId", localSystemId)
+ .add("interfaceIp", interfaceIp)
+ .add("neighborIp", neighborIp)
+ .add("linkTed", linkTed)
+ .toString();
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ DefaultIsisLink that = (DefaultIsisLink) o;
+ return Objects.equal(remoteSystemId, that.remoteSystemId) &&
+ Objects.equal(localSystemId, that.localSystemId) &&
+ Objects.equal(interfaceIp, that.interfaceIp) &&
+ Objects.equal(neighborIp, that.neighborIp) &&
+ Objects.equal(linkTed, that.linkTed);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hashCode(remoteSystemId, localSystemId, interfaceIp, neighborIp, linkTed);
+ }
+}
\ No newline at end of file
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLinkInformation.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLinkInformation.java
new file mode 100644
index 0000000..574f440
--- /dev/null
+++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLinkInformation.java
@@ -0,0 +1,166 @@
+/*
+ * 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.isis.controller.impl.topology;
+
+import com.google.common.base.MoreObjects;
+import com.google.common.base.Objects;
+import org.onlab.packet.Ip4Address;
+import org.onosproject.isis.controller.topology.LinkInformation;
+
+/**
+ * Representation of an ISIS link information..
+ */
+public class DefaultIsisLinkInformation implements LinkInformation {
+
+ String linkId;
+ String linkSourceId;
+ String linkDestinationId;
+ Ip4Address interfaceIp;
+ Ip4Address neighborIp;
+ boolean alreadyCreated;
+
+ /**
+ * Gets link id.
+ *
+ * @return link id
+ */
+ public String linkId() {
+ return linkId;
+ }
+
+ /**
+ * Sets link id.DefaultIsisDeviceInformation.
+ *
+ * @param linkId link id
+ */
+ public void setLinkId(String linkId) {
+ this.linkId = linkId;
+ }
+
+ /**
+ * Gets is already created or not.
+ *
+ * @return true if already created else false
+ */
+ public boolean isAlreadyCreated() {
+ return alreadyCreated;
+ }
+
+ /**
+ * Sets is already created or not.
+ *
+ * @param alreadyCreated true or false
+ */
+ public void setAlreadyCreated(boolean alreadyCreated) {
+ this.alreadyCreated = alreadyCreated;
+ }
+
+ /**
+ * Gets link destination id.
+ *
+ * @return link destination id
+ */
+ public String linkDestinationId() {
+ return linkDestinationId;
+ }
+
+ /**
+ * Sets link destination id.
+ *
+ * @param linkDestinationId link destination id
+ */
+ public void setLinkDestinationId(String linkDestinationId) {
+ this.linkDestinationId = linkDestinationId;
+ }
+
+ /**
+ * Gets link source id.
+ *
+ * @return link source id
+ */
+ public String linkSourceId() {
+ return linkSourceId;
+ }
+
+ /**
+ * Sets link source id.
+ *
+ * @param linkSourceId link source id
+ */
+ public void setLinkSourceId(String linkSourceId) {
+ this.linkSourceId = linkSourceId;
+ }
+
+ /**
+ * Gets interface IP address.
+ *
+ * @return interface IP address
+ */
+ public Ip4Address interfaceIp() {
+ return interfaceIp;
+ }
+
+ /**
+ * Sets interface IP address.
+ *
+ * @param interfaceIp interface IP address
+ */
+ public void setInterfaceIp(Ip4Address interfaceIp) {
+ this.interfaceIp = interfaceIp;
+ }
+
+ @Override
+ public Ip4Address neighborIp() {
+ return this.neighborIp;
+ }
+
+ @Override
+ public void setNeighborIp(Ip4Address neighborIp) {
+ this.neighborIp = neighborIp;
+ }
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(getClass())
+ .omitNullValues()
+ .add("linkId", linkId)
+ .add("linkSourceId", linkSourceId)
+ .add("linkDestinationId", linkDestinationId)
+ .add("interfaceIp", interfaceIp)
+ .toString();
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ DefaultIsisLinkInformation that = (DefaultIsisLinkInformation) o;
+ return Objects.equal(linkId, that.linkId) &&
+ Objects.equal(linkSourceId, that.linkSourceId) &&
+ Objects.equal(linkDestinationId, that.linkDestinationId) &&
+ Objects.equal(interfaceIp, that.interfaceIp);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hashCode(linkId, linkSourceId, linkDestinationId,
+ interfaceIp);
+ }
+}
\ No newline at end of file
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLinkTed.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLinkTed.java
new file mode 100644
index 0000000..6122c9a
--- /dev/null
+++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisLinkTed.java
@@ -0,0 +1,145 @@
+/*
+ * Copyright 2016 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.isis.controller.impl.topology;
+
+import com.google.common.base.MoreObjects;
+import com.google.common.base.Objects;
+import org.onlab.packet.Ip4Address;
+import org.onlab.util.Bandwidth;
+import org.onosproject.isis.controller.topology.IsisLinkTed;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Representation of an ISIS device information.
+ */
+public class DefaultIsisLinkTed implements IsisLinkTed {
+ private int administrativeGroup;
+ private Ip4Address ipv4InterfaceAddress;
+ private Ip4Address ipv4NeighborAddress;
+ private Bandwidth maximumLinkBandwidth;
+ private Bandwidth maximumReservableLinkBandwidth;
+ private List<Bandwidth> unreservedBandwidth = new ArrayList<>();
+ private long teDefaultMetric;
+
+ @Override
+ public int administrativeGroup() {
+ return administrativeGroup;
+ }
+
+ @Override
+ public void setAdministrativeGroup(int administrativeGroup) {
+ this.administrativeGroup = administrativeGroup;
+ }
+
+ @Override
+ public Ip4Address ipv4InterfaceAddress() {
+ return ipv4InterfaceAddress;
+ }
+
+ @Override
+ public void setIpv4InterfaceAddress(Ip4Address interfaceAddress) {
+ this.ipv4InterfaceAddress = interfaceAddress;
+ }
+
+ @Override
+ public Ip4Address ipv4NeighborAddress() {
+ return ipv4NeighborAddress;
+ }
+
+ @Override
+ public void setIpv4NeighborAddress(Ip4Address neighborAddress) {
+ this.ipv4NeighborAddress = neighborAddress;
+ }
+
+ @Override
+ public Bandwidth maximumLinkBandwidth() {
+ return maximumLinkBandwidth;
+ }
+
+ @Override
+ public void setMaximumLinkBandwidth(Bandwidth bandwidth) {
+ this.maximumLinkBandwidth = bandwidth;
+ }
+
+ @Override
+ public Bandwidth maximumReservableLinkBandwidth() {
+ return maximumReservableLinkBandwidth;
+ }
+
+ @Override
+ public void setMaximumReservableLinkBandwidth(Bandwidth bandwidth) {
+ this.maximumReservableLinkBandwidth = bandwidth;
+ }
+
+ @Override
+ public List<Bandwidth> unreservedBandwidth() {
+ return this.unreservedBandwidth;
+ }
+
+ @Override
+ public void setUnreservedBandwidth(List<Bandwidth> bandwidth) {
+ this.unreservedBandwidth.addAll(bandwidth);
+ }
+
+ @Override
+ public long teDefaultMetric() {
+ return teDefaultMetric;
+ }
+
+ @Override
+ public void setTeDefaultMetric(long teMetric) {
+ this.teDefaultMetric = teMetric;
+ }
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(getClass())
+ .omitNullValues()
+ .add("administrativeGroup", administrativeGroup)
+ .add("ipv4InterfaceAddress", ipv4InterfaceAddress)
+ .add("ipv4NeighborAddress", ipv4NeighborAddress)
+ .add("maximumLinkBandwidth", maximumLinkBandwidth)
+ .add("maximumReservableLinkBandwidth", maximumReservableLinkBandwidth)
+ .add("teDefaultMetric", teDefaultMetric)
+ .toString();
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ DefaultIsisLinkTed that = (DefaultIsisLinkTed) o;
+ return Objects.equal(administrativeGroup, that.administrativeGroup) &&
+ Objects.equal(ipv4InterfaceAddress, that.ipv4InterfaceAddress) &&
+ Objects.equal(ipv4NeighborAddress, that.ipv4NeighborAddress) &&
+ Objects.equal(maximumLinkBandwidth, that.maximumLinkBandwidth) &&
+ Objects.equal(maximumReservableLinkBandwidth,
+ that.maximumReservableLinkBandwidth) &&
+ Objects.equal(teDefaultMetric, that.teDefaultMetric);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hashCode(administrativeGroup, ipv4InterfaceAddress,
+ ipv4NeighborAddress, maximumLinkBandwidth, teDefaultMetric);
+ }
+}
\ No newline at end of file
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisRouter.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisRouter.java
new file mode 100644
index 0000000..216ce37
--- /dev/null
+++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/DefaultIsisRouter.java
@@ -0,0 +1,132 @@
+/*
+ * Copyright 2015 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.isis.controller.impl.topology;
+
+import com.google.common.base.MoreObjects;
+import com.google.common.base.Objects;
+import org.onlab.packet.Ip4Address;
+import org.onosproject.isis.controller.topology.IsisRouter;
+
+/**
+ * Representation of an ISIS Router.
+ */
+public class DefaultIsisRouter implements IsisRouter {
+
+ private String systemId;
+ private Ip4Address neighborRouterId;
+ private Ip4Address interfaceId;
+ private boolean isDis;
+
+ /**
+ * Gets the system ID.
+ *
+ * @return systemId system ID
+ */
+ public String systemId() {
+ return systemId;
+ }
+
+ /**
+ * Sets IP address of the Router.
+ */
+ public void setSystemId(String systemId) {
+ this.systemId = systemId;
+ }
+
+ /**
+ * Gets IP address of the interface.
+ *
+ * @return IP address of the interface
+ */
+ public Ip4Address interfaceId() {
+ return interfaceId;
+ }
+
+ /**
+ * Gets IP address of the interface.
+ *
+ * @param interfaceId IP address of the interface
+ */
+ public void setInterfaceId(Ip4Address interfaceId) {
+ this.interfaceId = interfaceId;
+ }
+
+ /**
+ * Gets neighbor's Router id.
+ *
+ * @return neighbor's Router id
+ */
+ public Ip4Address neighborRouterId() {
+ return neighborRouterId;
+ }
+
+ /**
+ * Sets neighbor's Router id.
+ *
+ * @param advertisingRouterId neighbor's Router id
+ */
+ public void setNeighborRouterId(Ip4Address advertisingRouterId) {
+ this.neighborRouterId = advertisingRouterId;
+ }
+
+ /**
+ * Gets if DR or not.
+ *
+ * @return true if DR else false
+ */
+ public boolean isDis() {
+ return isDis;
+ }
+
+ /**
+ * Sets dis or not.
+ *
+ * @param dis true if DIS else false
+ */
+ public void setDis(boolean dis) {
+ isDis = dis;
+ }
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(getClass())
+ .omitNullValues()
+ .add("systemId", systemId)
+ .add("neighborRouterId", neighborRouterId)
+ .add("interfaceId", interfaceId)
+ .toString();
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ DefaultIsisRouter that = (DefaultIsisRouter) o;
+ return Objects.equal(systemId, that.systemId) &&
+ Objects.equal(neighborRouterId, that.neighborRouterId) &&
+ Objects.equal(interfaceId, that.interfaceId);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hashCode(systemId, neighborRouterId, interfaceId);
+ }
+}
\ No newline at end of file
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/TopologyForDeviceAndLinkImpl.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/TopologyForDeviceAndLinkImpl.java
new file mode 100644
index 0000000..8682a4a
--- /dev/null
+++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/TopologyForDeviceAndLinkImpl.java
@@ -0,0 +1,490 @@
+/*
+* Copyright 2016 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.isis.controller.impl.topology;
+
+import org.onlab.util.Bandwidth;
+import org.onosproject.isis.controller.topology.DeviceInformation;
+import org.onosproject.isis.controller.topology.IsisRouter;
+import org.onosproject.isis.controller.topology.LinkInformation;
+import org.onosproject.isis.controller.topology.TopologyForDeviceAndLink;
+import org.onosproject.isis.controller.topology.IsisLinkTed;
+import org.onosproject.isis.io.isispacket.pdu.LsPdu;
+import org.onosproject.isis.io.isispacket.tlv.IsExtendedReachability;
+import org.onosproject.isis.io.isispacket.tlv.IsisTlv;
+import org.onosproject.isis.io.isispacket.tlv.NeighborForExtendedIs;
+
+import org.onosproject.isis.io.isispacket.tlv.subtlv.TrafficEngineeringSubTlv;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.InterfaceIpAddress;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.NeighborIpAddress;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.AdministrativeGroup;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.TrafficEngineeringMetric;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.UnreservedBandwidth;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.MaximumReservableBandwidth;
+import org.onosproject.isis.io.isispacket.tlv.subtlv.MaximumBandwidth;
+import org.onosproject.isis.io.util.IsisConstants;
+import org.onosproject.isis.io.util.IsisUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Represents device and link topology information.
+ */
+public class TopologyForDeviceAndLinkImpl implements TopologyForDeviceAndLink {
+
+ private static final Logger log = LoggerFactory.getLogger(TopologyForDeviceAndLinkImpl.class);
+ private Map<String, DeviceInformation> deviceInformationMap = new LinkedHashMap<>();
+ private Map<String, IsisRouter> isisRouterDetails = new LinkedHashMap<>();
+ private Map<String, DeviceInformation> deviceInformationMapForPointToPoint = new LinkedHashMap<>();
+ private Map<String, DeviceInformation> deviceInformationMapToDelete = new LinkedHashMap<>();
+ private Map<String, LinkInformation> addedLinkInformationMap = new LinkedHashMap<>();
+
+ /**
+ * Gets device information.
+ *
+ * @return device information
+ */
+ public Map<String, DeviceInformation> deviceInformationMap() {
+ return deviceInformationMap;
+ }
+
+ /**
+ * Gets ISIS router list information.
+ *
+ * @return router information
+ */
+ public Map<String, IsisRouter> isisDeviceList() {
+ return isisRouterDetails;
+ }
+
+ /**
+ * Sets device information.
+ *
+ * @param key key used to add in map
+ * @param deviceInformationMap device information instance
+ */
+ public void setDeviceInformationMap(String key, DeviceInformation deviceInformationMap) {
+ if (deviceInformationMap != null) {
+ this.deviceInformationMap.put(key, deviceInformationMap);
+ }
+
+ }
+
+ /**
+ * Gets deviceInformation as map for Point-To-Point.
+ *
+ * @return deviceInformationMap
+ */
+ public Map<String, DeviceInformation> deviceInformationMapForPointToPoint() {
+ return deviceInformationMapForPointToPoint;
+ }
+
+ /**
+ * Sets deviceInformation as map for Point-To-Point..
+ *
+ * @param key key used to add in map
+ * @param deviceInformationMap device information instance
+ */
+ public void setDeviceInformationMapForPointToPoint(String key, DeviceInformation deviceInformationMap) {
+ if (deviceInformationMap != null) {
+ this.deviceInformationMapForPointToPoint.put(key, deviceInformationMap);
+ }
+
+ }
+
+ /**
+ * Gets deviceInformation as map.
+ *
+ * @return deviceInformationMap to delete from core
+ */
+ public Map<String, DeviceInformation> deviceInformationMapToDelete() {
+ return deviceInformationMapToDelete;
+ }
+
+ /**
+ * Sets device information for removal.
+ *
+ * @param key ket used to add in map
+ * @param deviceInformationMapToDelete map from device information to remove
+ */
+ public void setDeviceInformationMapToDelete(String key, DeviceInformation deviceInformationMapToDelete) {
+ if (deviceInformationMapToDelete != null) {
+ this.deviceInformationMapToDelete.put(key, deviceInformationMapToDelete);
+ }
+ }
+
+ /**
+ * Removes Device Information.
+ *
+ * @param key ket used to remove from map
+ */
+ public void removeDeviceInformationMapFromDeleteMap(String key) {
+ removeDeviceInformationMap(key);
+ if (this.deviceInformationMapToDelete.containsKey(key)) {
+ this.deviceInformationMapToDelete.remove(key);
+ }
+ }
+
+ /**
+ * Gets Device Information.
+ *
+ * @param key system id as key to store in map
+ * @return Device Information
+ */
+ public DeviceInformation deviceInformation(String key) {
+ DeviceInformation deviceInformation = this.deviceInformationMap.get(key);
+ return deviceInformation;
+ }
+
+ /**
+ * Removes Device Information from map.
+ *
+ * @param key key used to remove from map
+ */
+ public void removeDeviceInformationMap(String key) {
+ if (this.deviceInformationMap.containsKey(key)) {
+ this.deviceInformationMap.remove(key);
+ }
+ }
+
+ @Override
+ public void removeLinks(String linkId) {
+ this.addedLinkInformationMap.remove(linkId);
+ }
+
+ /**
+ * Gets link information as map.
+ *
+ * @return link information as map
+ */
+ public Map<String, LinkInformation> linkInformationMap() {
+ return addedLinkInformationMap;
+ }
+
+ private LinkInformation getLinkInformation(String key) {
+ LinkInformation linkInformation = this.addedLinkInformationMap.get(key);
+ return linkInformation;
+ }
+
+ /**
+ * Sets link information in map.
+ *
+ * @param key key used to add in map
+ * @param linkInformationMap link information instance
+ */
+ public void setLinkInformationMap(String key, LinkInformation linkInformationMap) {
+ if (!this.addedLinkInformationMap.containsKey(key)) {
+ this.addedLinkInformationMap.put(key, linkInformationMap);
+ }
+ }
+
+ /**
+ * Gets linkInformation as map for PointToPoint.
+ *
+ * @return linkInformationMap
+ */
+ public Map<String, LinkInformation> linkInformationMapForPointToPoint() {
+ return addedLinkInformationMap;
+ }
+
+ /**
+ * Sets linkInformation as map for PointToPoint.
+ *
+ * @param key key used to add in map
+ * @param linkInformationMap link information instance
+ */
+ public void setLinkInformationMapForPointToPoint(String key, LinkInformation linkInformationMap) {
+ if (!this.addedLinkInformationMap.containsKey(key)) {
+ this.addedLinkInformationMap.put(key, linkInformationMap);
+ }
+ }
+
+ /**
+ * Removes Link Information from linkInformationMap.
+ *
+ * @param key key used to remove in map
+ */
+ public void removeLinkInformationMap(String key) {
+ if (this.addedLinkInformationMap.containsKey(key)) {
+ this.addedLinkInformationMap.remove(key);
+ }
+ }
+
+ /**
+ * Returns the ISIS router instance.
+ *
+ * @param systemId system ID to get router details
+ * @return ISIS router instance
+ */
+ public IsisRouter isisRouter(String systemId) {
+ String routerId = IsisUtil.removeTailingZeros(systemId);
+ IsisRouter isisRouter = isisRouterDetails.get(routerId);
+ if (isisRouter != null) {
+ return isisRouter;
+ } else {
+ log.debug("IsisRouter is not available");
+ IsisRouter isisRouterCheck = new DefaultIsisRouter();
+ isisRouterCheck.setSystemId(routerId);
+ return isisRouterCheck;
+ }
+ }
+
+ /**
+ * Removes the ISIS router instance from map.
+ *
+ * @param systemId system ID to remove router details
+ */
+ public void removeRouter(String systemId) {
+ String routerId = IsisUtil.removeTailingZeros(systemId);
+ isisRouterDetails.remove(systemId);
+ }
+
+ /**
+ * Creates Device instance.
+ *
+ * @param lsPdu ISIS LSPDU instance
+ * @return isisRouter isisRouter instance
+ */
+ public IsisRouter createDeviceInfo(LsPdu lsPdu) {
+ IsisRouter isisRouter = createIsisRouter(lsPdu);
+
+ if (isisRouter.systemId() != null) {
+ if (isisRouter.interfaceId() == null && isisRouter.neighborRouterId() == null) {
+ isisRouter.setInterfaceId(IsisConstants.DEFAULTIP);
+ isisRouter.setNeighborRouterId(IsisConstants.DEFAULTIP);
+ isisRouterDetails.put(isisRouter.systemId(), isisRouter);
+ }
+ }
+ return isisRouter;
+ }/*
+
+ *//**
+ * Removes Device and Link instance.
+ *
+ * @param lsPdu ISIS LSPDU instance
+ * @return isisRouter isisRouter instance
+ *//*
+ public IsisRouter removeDeviceAndLinkInfo(LsPdu lsPdu) {
+ IsisRouter isisRouter = createIsisRouter(lsPdu);
+ return isisRouter;
+ }*/
+
+ /**
+ * Creates link information.
+ *
+ * @param lsPdu ls pdu instance
+ * @param ownSystemId system ID
+ * @return link information
+ */
+ public Map<String, LinkInformation> createLinkInfo(LsPdu lsPdu, String ownSystemId) {
+ for (IsisTlv isisTlv : lsPdu.tlvs()) {
+ if (isisTlv instanceof IsExtendedReachability) {
+ IsExtendedReachability isExtendedReachability = (IsExtendedReachability) isisTlv;
+ List<NeighborForExtendedIs> neighborForExtendedIsList = isExtendedReachability.neighbours();
+ for (NeighborForExtendedIs neighbor : neighborForExtendedIsList) {
+ String neighbourId = neighbor.neighborId();
+ String routerId = IsisUtil.removeTailingZeros(lsPdu.lspId());
+ if (!(neighbourId.equals(ownSystemId))) {
+ IsisRouter isisRouter = isisRouterDetails.get(neighbourId);
+ if (isisRouter != null) {
+ String linkId = "link:" + routerId + "-" + neighbourId;
+ addedLinkInformationMap.put(linkId, createLinkInformation(lsPdu, linkId,
+ routerId, neighbourId));
+ } else {
+ createIsisRouterDummy(neighbourId);
+ String linkId = "link:" + routerId + "-" + neighbourId;
+ LinkInformation linkInformation = createLinkInformation(lsPdu, linkId,
+ routerId, neighbourId);
+ linkInformation.setAlreadyCreated(true);
+ addedLinkInformationMap.put(linkId, linkInformation);
+ }
+ }
+
+ }
+ }
+ }
+ return addedLinkInformationMap;
+ }
+
+ /**
+ * Removes link information.
+ *
+ * @param systemId system ID to remove link information
+ * @return updated link information
+ */
+ public Map<String, LinkInformation> removeLinkInfo(String systemId) {
+ String routerId = IsisUtil.removeTailingZeros(systemId);
+ Map<String, LinkInformation> removeLinkInformationMap = new LinkedHashMap<>();
+ for (String key : addedLinkInformationMap.keySet()) {
+ if (key.contains(routerId)) {
+ removeLinkInformationMap.put(key, addedLinkInformationMap.get(key));
+ }
+ }
+ return removeLinkInformationMap;
+ }
+
+ /**
+ * Creates link information.
+ *
+ * @param lsPdu link state pdu
+ * @param linkId link id
+ * @param localRouter local router system id
+ * @param neighborId destination router system id
+ * @return linkInformation instance
+ */
+ private LinkInformation createLinkInformation(LsPdu lsPdu, String linkId, String localRouter, String neighborId) {
+ LinkInformation linkInformation = new DefaultIsisLinkInformation();
+ IsisRouter isisRouter = isisRouterDetails.get(neighborId);
+ for (IsisTlv isisTlv : lsPdu.tlvs()) {
+ if (isisTlv instanceof IsExtendedReachability) {
+ IsExtendedReachability isExtendedReachability = (IsExtendedReachability) isisTlv;
+ List<NeighborForExtendedIs> neighbours = isExtendedReachability.neighbours();
+ for (NeighborForExtendedIs teTlv : neighbours) {
+ List<TrafficEngineeringSubTlv> teSubTlvs = teTlv.teSubTlv();
+ for (TrafficEngineeringSubTlv teSubTlv : teSubTlvs) {
+ if (teSubTlv instanceof InterfaceIpAddress) {
+ InterfaceIpAddress localIpAddress = (InterfaceIpAddress) teSubTlv;
+ linkInformation.setInterfaceIp(localIpAddress.localInterfaceIPAddress());
+ } else if (teSubTlv instanceof NeighborIpAddress) {
+ NeighborIpAddress neighborIpAddress = (NeighborIpAddress) teSubTlv;
+ linkInformation.setNeighborIp(neighborIpAddress.neighborIPAddress());
+ }
+
+ }
+ }
+ }
+ }
+ linkInformation.setLinkId(linkId);
+ linkInformation.setAlreadyCreated(false);
+ linkInformation.setLinkDestinationId(neighborId);
+ linkInformation.setLinkSourceId(localRouter);
+ return linkInformation;
+ }
+
+ /**
+ * Creates ISIS router instance.
+ *
+ * @param lsPdu lsp instance
+ * @return isisRouter instance
+ */
+ private IsisRouter createIsisRouter(LsPdu lsPdu) {
+ IsisRouter isisRouter = new DefaultIsisRouter();
+ if (IsisUtil.checkIsDis(lsPdu.lspId())) {
+ isisRouter.setDis(true);
+ } else {
+ isisRouter.setDis(false);
+ }
+ isisRouter.setSystemId(IsisUtil.removeTailingZeros(lsPdu.lspId()));
+ for (IsisTlv isisTlv : lsPdu.tlvs()) {
+ if (isisTlv instanceof IsExtendedReachability) {
+ IsExtendedReachability isExtendedReachability = (IsExtendedReachability) isisTlv;
+ List<NeighborForExtendedIs> neighbours = isExtendedReachability.neighbours();
+ for (NeighborForExtendedIs teTlv : neighbours) {
+ List<TrafficEngineeringSubTlv> teSubTlvs = teTlv.teSubTlv();
+ for (TrafficEngineeringSubTlv teSubTlv : teSubTlvs) {
+ if (teSubTlv instanceof InterfaceIpAddress) {
+ InterfaceIpAddress localIpAddress = (InterfaceIpAddress) teSubTlv;
+ isisRouter.setInterfaceId(localIpAddress.localInterfaceIPAddress());
+ } else if (teSubTlv instanceof NeighborIpAddress) {
+ NeighborIpAddress neighborIpAddress = (NeighborIpAddress) teSubTlv;
+ isisRouter.setNeighborRouterId(neighborIpAddress.neighborIPAddress());
+ }
+
+ }
+ }
+ }
+ }
+ return isisRouter;
+ }
+
+ /**
+ * Creates ISIS router instance.
+ *
+ * @param systemId system ID
+ * @return isisRouter instance
+ */
+ private IsisRouter createIsisRouterDummy(String systemId) {
+ IsisRouter isisRouter = new DefaultIsisRouter();
+ isisRouter.setSystemId(systemId);
+ isisRouter.setDis(false);
+ isisRouter.setInterfaceId(IsisConstants.DEFAULTIP);
+ isisRouter.setNeighborRouterId(IsisConstants.DEFAULTIP);
+
+ return isisRouter;
+ }
+
+ /**
+ * Creates the ISIS link TED information.
+ *
+ * @param lsPdu link state PDU
+ * @return isisLinkTed
+ */
+ public IsisLinkTed createIsisLinkTedInfo(LsPdu lsPdu) {
+ IsisLinkTed isisLinkTed = new DefaultIsisLinkTed();
+ for (IsisTlv isisTlv : lsPdu.tlvs()) {
+ if (isisTlv instanceof IsExtendedReachability) {
+ IsExtendedReachability isExtendedReachability = (IsExtendedReachability) isisTlv;
+ List<NeighborForExtendedIs> neighbours = isExtendedReachability.neighbours();
+ for (NeighborForExtendedIs teTlv : neighbours) {
+ List<TrafficEngineeringSubTlv> teSubTlvs = teTlv.teSubTlv();
+ for (TrafficEngineeringSubTlv teSubTlv : teSubTlvs) {
+ if (teSubTlv instanceof AdministrativeGroup) {
+ AdministrativeGroup ag = (AdministrativeGroup) teSubTlv;
+ isisLinkTed.setAdministrativeGroup(ag.administrativeGroup());
+ }
+ if (teSubTlv instanceof InterfaceIpAddress) {
+ InterfaceIpAddress localIpAddress = (InterfaceIpAddress) teSubTlv;
+ isisLinkTed.setIpv4InterfaceAddress(localIpAddress.localInterfaceIPAddress());
+ }
+ if (teSubTlv instanceof NeighborIpAddress) {
+ NeighborIpAddress neighborIpAddress = (NeighborIpAddress) teSubTlv;
+ isisLinkTed.setIpv4NeighborAddress(neighborIpAddress.neighborIPAddress());
+ }
+ if (teSubTlv instanceof TrafficEngineeringMetric) {
+ TrafficEngineeringMetric teM = (TrafficEngineeringMetric) teSubTlv;
+ isisLinkTed.setTeDefaultMetric(teM.getTrafficEngineeringMetricValue());
+ }
+ if (teSubTlv instanceof MaximumBandwidth) {
+ MaximumBandwidth maxLinkBandwidth = (MaximumBandwidth) teSubTlv;
+ isisLinkTed.setMaximumLinkBandwidth(
+ Bandwidth.bps(maxLinkBandwidth.getMaximumBandwidthValue()));
+ }
+ if (teSubTlv instanceof MaximumReservableBandwidth) {
+ MaximumReservableBandwidth maxReservableBw = (MaximumReservableBandwidth) teSubTlv;
+ isisLinkTed.setMaximumReservableLinkBandwidth(
+ Bandwidth.bps(maxReservableBw.getMaximumBandwidthValue()));
+ }
+ if (teSubTlv instanceof UnreservedBandwidth) {
+ UnreservedBandwidth unReservedBandwidth = (UnreservedBandwidth) teSubTlv;
+ List<Bandwidth> bandwidthList = new ArrayList<>();
+ List<Float> unReservedBandwidthList = unReservedBandwidth.unReservedBandwidthValue();
+ for (Float unReservedBandwidthFloatValue : unReservedBandwidthList) {
+ Bandwidth bandwidth = Bandwidth.bps(unReservedBandwidthFloatValue);
+ bandwidthList.add(bandwidth);
+ }
+ isisLinkTed.setUnreservedBandwidth(bandwidthList);
+ }
+ }
+ }
+ }
+ }
+ return isisLinkTed;
+ }
+}
\ No newline at end of file
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/package-info.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/package-info.java
new file mode 100644
index 0000000..f9b4c0c
--- /dev/null
+++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/topology/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * 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.
+ */
+
+/**
+ * Implementation of the ISIS controller topology.
+ */
+package org.onosproject.isis.controller.impl.topology;
\ No newline at end of file