Bgp and Pcep maintaiability
Change-Id: I2c14cc29d4900ef2f0fbffd4761b0d78e282910f
diff --git a/providers/bgp/cli/BUCK b/providers/bgp/cli/BUCK
new file mode 100644
index 0000000..64ae7f9
--- /dev/null
+++ b/providers/bgp/cli/BUCK
@@ -0,0 +1,16 @@
+COMPILE_DEPS = [
+ '//lib:CORE_DEPS',
+ '//incubator/api:onos-incubator-api',
+ '//providers/bgp/cfg:onos-providers-bgp-cfg',
+ '//providers/bgp/topology:onos-providers-bgp-topology',
+ '//protocols/bgp/api:onos-protocols-bgp-api',
+ '//protocols/bgp/ctl:onos-protocols-bgp-ctl',
+ '//protocols/bgp/bgpio:onos-protocols-bgp-bgpio',
+ '//lib:org.apache.karaf.shell.console',
+ '//cli:onos-cli',
+]
+
+osgi_jar_with_tests (
+ deps = COMPILE_DEPS,
+)
+
diff --git a/providers/bgp/cli/pom.xml b/providers/bgp/cli/pom.xml
new file mode 100644
index 0000000..76b92b7
--- /dev/null
+++ b/providers/bgp/cli/pom.xml
@@ -0,0 +1,82 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ 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.
+ -->
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns="http://maven.apache.org/POM/4.0.0"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.onosproject</groupId>
+ <artifactId>onos-bgp-providers</artifactId>
+ <version>1.9.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>onos-bgp-provider-cli</artifactId>
+ <packaging>bundle</packaging>
+
+ <description>BGP cli implementation</description>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.onosproject</groupId>
+ <artifactId>onos-cli</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.onosproject</groupId>
+ <artifactId>onos-bgp-api</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.onosproject</groupId>
+ <artifactId>onos-bgp-provider-cfg</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.osgi</groupId>
+ <artifactId>org.osgi.compendium</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.karaf.shell</groupId>
+ <artifactId>org.apache.karaf.shell.console</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>org.apache.felix.scr.annotations</artifactId>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.onosproject</groupId>
+ <artifactId>onos-bgp-ctl</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+<build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>maven-bundle-plugin</artifactId>
+ <extensions>true</extensions>
+ <configuration>
+ <instructions>
+ <Export-Package>org.onosproject.bgp.*</Export-Package>
+ </instructions>
+ </configuration>
+ </plugin>
+</plugins>
+</build>
+</project>
diff --git a/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpConfiguration.java b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpConfiguration.java
new file mode 100644
index 0000000..d34c80e
--- /dev/null
+++ b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpConfiguration.java
@@ -0,0 +1,123 @@
+/*
+ * 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.bgp.cli;
+
+import org.apache.karaf.shell.commands.Argument;
+import org.apache.karaf.shell.commands.Command;
+import org.onosproject.bgp.controller.BgpCfg;
+import org.onosproject.bgp.controller.BgpConnectPeer;
+import org.onosproject.bgp.controller.BgpController;
+import org.onosproject.bgp.controller.BgpPeerCfg;
+import org.onosproject.cli.AbstractShellCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Set;
+import java.util.TreeMap;
+
+
+@Command(scope = "onos", name = "bgp", description = "lists configuration")
+public class BgpConfiguration extends AbstractShellCommand {
+ private static final Logger log = LoggerFactory.getLogger(BgpConfiguration.class);
+ private static final String CONFIGURATION = "configuration";
+ private static final String PEER = "peer";
+ protected BgpController bgpController;
+ protected BgpConnectPeer bgpConnectPeer;
+ protected BgpPeerCfg bgpPeerCfg;
+ protected BgpCfg bgpCfg;
+ @Argument(index = 0, name = "name",
+ description = "configuration" + "\n" + "peer",
+ required = true, multiValued = false)
+ String name = null;
+ @Argument(index = 1, name = "peer",
+ description = "peerIp",
+ required = false, multiValued = false)
+ String peer = null;
+
+ @Override
+ protected void execute() {
+ switch (name) {
+ case CONFIGURATION:
+ displayBgpConfiguration();
+ break;
+ case PEER:
+ displayBgpPeerConfiguration();
+ break;
+ default:
+ System.out.print("Unknown command...!!");
+ break;
+ }
+ }
+
+ private void displayBgpConfiguration() {
+ try {
+
+ this.bgpController = get(BgpController.class);
+ bgpCfg = bgpController.getConfig();
+ print("RouterID = %s, ASNumber = %s, MaxSession = %s, HoldingTime = %s, LsCapabality = %s," +
+ " LargeAsCapabality = %s, FlowSpecCapabality = %s", bgpCfg.getRouterId(),
+ bgpCfg.getAsNumber(), bgpCfg.getMaxSession(), bgpCfg.getHoldTime(),
+ bgpCfg.getLsCapability(), bgpCfg.getLargeASCapability(), bgpCfg.flowSpecCapability());
+
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP configuration: {}", e.getMessage());
+ }
+ }
+
+ private void displayBgpPeerConfiguration() {
+ try {
+ this.bgpController = get(BgpController.class);
+ BgpCfg bgpCfg = bgpController.getConfig();
+ if (bgpCfg == null) {
+ return;
+ }
+ TreeMap<String, BgpPeerCfg> displayPeerTree = bgpCfg.getPeerTree();
+ Set<String> peerKey = displayPeerTree.keySet();
+ if (peer != null) {
+ if (peerKey.size() > 0) {
+ for (String peerIdKey : peerKey) {
+ bgpPeerCfg = displayPeerTree.get(peerIdKey);
+ bgpConnectPeer = bgpPeerCfg.connectPeer();
+ if (peerIdKey.equals(peer)) {
+ print("PeerRouterID = %s, PeerHoldingTime = %s, ASNumber = %s, PeerState = %s," +
+ " PeerPort = %s, ConnectRetryCounter = %s",
+ peer, bgpPeerCfg.getHoldtime(), bgpPeerCfg.getAsNumber(),
+ bgpPeerCfg.getState(), bgpConnectPeer.getPeerPort(),
+ bgpConnectPeer.getConnectRetryCounter());
+ }
+ }
+ }
+ } else {
+ if (peerKey.size() > 0) {
+ for (String peerIdKey : peerKey) {
+ bgpPeerCfg = displayPeerTree.get(peerIdKey);
+ bgpConnectPeer = bgpPeerCfg.connectPeer();
+ print("PeerRouterID = %s, PeerHoldingTime = %s, ASNumber = %s, PeerState = %s, PeerPort = %s," +
+ " ConnectRetryCounter = %s",
+ bgpPeerCfg.getPeerRouterId(), bgpPeerCfg.getHoldtime(), bgpPeerCfg.getAsNumber(),
+ bgpPeerCfg.getState(), bgpConnectPeer.getPeerPort(),
+ bgpConnectPeer.getConnectRetryCounter());
+ }
+ }
+
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP peer configuration: {}", e.getMessage());
+ }
+ }
+
+
+}
\ No newline at end of file
diff --git a/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpExceptions.java b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpExceptions.java
new file mode 100644
index 0000000..2f129ba
--- /dev/null
+++ b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpExceptions.java
@@ -0,0 +1,123 @@
+/*
+ * 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.bgp.cli;
+
+import org.apache.karaf.shell.commands.Argument;
+import org.apache.karaf.shell.commands.Command;
+import org.onosproject.bgp.controller.BgpController;
+import org.onosproject.cli.AbstractShellCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+
+@Command(scope = "onos", name = "bgp-exception", description = "Displays Exceptions")
+public class BgpExceptions extends AbstractShellCommand {
+ public static final String ACTIVESESSION = "activesession";
+ public static final String CLOSEDSESSION = "closedsession";
+ private static final Logger log = LoggerFactory.getLogger(BgpExceptions.class);
+ protected BgpController bgpController;
+ @Argument(index = 0, name = "name",
+ description = "activesession" + "\n" + "closedsession",
+ required = true, multiValued = false)
+ String name = null;
+ @Argument(index = 1, name = "peerIp",
+ description = "peerId",
+ required = false, multiValued = false)
+ String peerId = null;
+ private Set<String> activeSessionExceptionkeySet;
+ private Set<String> closedSessionExceptionKeySet;
+
+ @Override
+ protected void execute() {
+ switch (name) {
+ case ACTIVESESSION:
+ displayActiveSessionException();
+ break;
+ case CLOSEDSESSION:
+ displayClosedSessionException();
+ break;
+ default:
+ System.out.print("Unknown Command");
+ break;
+ }
+ }
+
+ private void displayActiveSessionException() {
+ try {
+ this.bgpController = get(BgpController.class);
+ Map<String, List<String>> activeSessionExceptionMap = bgpController.activeSessionMap();
+ activeSessionExceptionkeySet = activeSessionExceptionMap.keySet();
+ if (activeSessionExceptionkeySet.size() > 0) {
+ if (peerId != null) {
+ if (activeSessionExceptionkeySet.contains(peerId)) {
+ for (String peerIdKey : activeSessionExceptionkeySet) {
+ List activeSessionExceptionlist = activeSessionExceptionMap.get(peerIdKey);
+ System.out.println(activeSessionExceptionlist);
+ }
+ } else {
+ System.out.print("Wrong argument");
+ }
+ } else {
+ activeSessionExceptionkeySet = activeSessionExceptionMap.keySet();
+ if (activeSessionExceptionkeySet.size() > 0) {
+ for (String peerId : activeSessionExceptionkeySet) {
+ print("PeerId = %s, Exception = %s ", peerId, activeSessionExceptionMap.get(peerId));
+ }
+ }
+ }
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP exceptions: {}", e.getMessage());
+ }
+ }
+
+ private void displayClosedSessionException() {
+ try {
+ this.bgpController = get(BgpController.class);
+ Map<String, List<String>> closedSessionExceptionMap = bgpController.closedSessionMap();
+ closedSessionExceptionKeySet = closedSessionExceptionMap.keySet();
+ if (closedSessionExceptionKeySet.size() > 0) {
+ if (peerId != null) {
+ if (closedSessionExceptionKeySet.contains(peerId)) {
+ for (String peerIdKey : closedSessionExceptionKeySet) {
+ List closedSessionExceptionlist = closedSessionExceptionMap.get(peerIdKey);
+ print("Exceptions = %s", closedSessionExceptionlist);
+ }
+ } else {
+ System.out.print("Wrong argument");
+ }
+ } else {
+ closedSessionExceptionKeySet = closedSessionExceptionMap.keySet();
+ if (closedSessionExceptionKeySet.size() > 0) {
+ for (String peerId : closedSessionExceptionKeySet) {
+ print("PeerId = %s, Exception = %s", peerId, closedSessionExceptionMap.get(peerId));
+ }
+ }
+ }
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying resons for session closure: {}", e.getMessage());
+ }
+ }
+
+
+}
+
+
diff --git a/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpLocalRibDisplay.java b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpLocalRibDisplay.java
new file mode 100644
index 0000000..3e5fb68
--- /dev/null
+++ b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/BgpLocalRibDisplay.java
@@ -0,0 +1,406 @@
+/*
+ * 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.bgp.cli;
+
+import org.apache.karaf.shell.commands.Argument;
+import org.apache.karaf.shell.commands.Command;
+import org.onosproject.bgp.controller.BgpController;
+import org.onosproject.bgp.controller.BgpLocalRib;
+import org.onosproject.bgpio.protocol.BgpLSNlri;
+
+import org.onosproject.bgpio.protocol.linkstate.BgpNodeLSIdentifier;
+import org.onosproject.bgpio.protocol.linkstate.BgpNodeLSNlriVer4;
+import org.onosproject.bgpio.protocol.linkstate.PathAttrNlriDetails;
+import org.onosproject.bgpio.protocol.linkstate.PathAttrNlriDetailsLocalRib;
+import org.onosproject.bgpio.protocol.linkstate.BgpLinkLSIdentifier;
+import org.onosproject.bgpio.protocol.linkstate.BgpPrefixLSIdentifier;
+import org.onosproject.bgpio.protocol.linkstate.NodeDescriptors;
+import org.onosproject.bgpio.protocol.linkstate.BgpLinkLsNlriVer4;
+import org.onosproject.bgpio.types.IPv4AddressTlv;
+import org.onosproject.bgpio.types.RouteDistinguisher;
+import org.onosproject.bgpio.types.BgpValueType;
+import org.onosproject.bgpio.types.LinkStateAttributes;
+import org.onosproject.bgpio.types.MpReachNlri;
+import org.onosproject.bgpio.types.AutonomousSystemTlv;
+import org.onosproject.bgpio.types.IsIsNonPseudonode;
+import org.onosproject.bgpio.types.LocalPref;
+import org.onosproject.bgpio.types.Origin;
+import org.onosproject.bgpio.types.attr.BgpAttrRouterIdV4;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrMaxLinkBandwidth;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrUnRsrvdLinkBandwidth;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrTeDefaultMetric;
+import org.onosproject.bgpio.types.attr.BgpLinkAttrIgpMetric;
+import org.onosproject.cli.AbstractShellCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Map;
+import java.util.Set;
+import java.util.List;
+import java.util.Iterator;
+import java.util.Arrays;
+
+
+
+@Command(scope = "onos", name = "bgp-rib", description = "lists RIB configuration")
+public class BgpLocalRibDisplay extends AbstractShellCommand {
+ private static final Logger log = LoggerFactory.getLogger(BgpLocalRibDisplay.class);
+ private static final String NODETREE = "nodes";
+ private static final String LINKTREE = "links";
+ private static final String PREFIXTREE = "prefix";
+ private static final String VPNNODETREE = "vpnnodes";
+ private static final String VPNLINKTREE = "vpnlinkS";
+ private static final String VPNPREFIXTREE = "vpnprefix";
+ protected Origin origin;
+ protected LocalPref localPref;
+ protected BgpAttrRouterIdV4 bgpAttrRouterIdV4;
+ protected IsIsNonPseudonode isIsNonPseudonode;
+ protected AutonomousSystemTlv autonomousSystemTlv;
+ protected IPv4AddressTlv iPv4AddressTlv;
+ protected BgpLinkAttrMaxLinkBandwidth bgpLinkAttrMaxLinkBandwidth;
+ protected BgpLinkAttrUnRsrvdLinkBandwidth bgpLinkAttrUnRsrvdLinkBandwidth;
+ protected BgpLinkAttrTeDefaultMetric bgpLinkAttrTeDefaultMetric;
+ protected BgpLinkAttrIgpMetric bgpLinkAttrIgpMetric;
+ protected PathAttrNlriDetailsLocalRib pathAttrNlriDetailsLocalRib;
+ protected MpReachNlri mpReachNlri;
+ protected PathAttrNlriDetails pathAttrNlriDetails;
+ protected BgpNodeLSNlriVer4.ProtocolType protocolType;
+ protected BgpController bgpController = get(BgpController.class);
+ protected BgpLocalRib bgpLocalRib = bgpController.bgpLocalRib();
+ Map<BgpNodeLSIdentifier, PathAttrNlriDetailsLocalRib> nodeTreeMap = bgpLocalRib.nodeTree();
+ Set<BgpNodeLSIdentifier> nodekeySet = nodeTreeMap.keySet();
+ Map<BgpLinkLSIdentifier, PathAttrNlriDetailsLocalRib> linkTreeMap = bgpLocalRib.linkTree();
+ Set<BgpLinkLSIdentifier> linkkeySet = linkTreeMap.keySet();
+ @Argument(index = 0, name = "name",
+ description = "nodetree" + "\n" + "linktree" + "\n" + "prefixtree" + "\n" + "vpnnodetree" + "\n" +
+ "vpnlinktree" + "\n" + "vpnprefixtree", required = true, multiValued = false)
+ String name = null;
+ @Argument(index = 1, name = "numberofentries",
+ description = "numberofentries", required = false, multiValued = false)
+ int numberofentries;
+ @Argument(index = 2, name = "vpnId",
+ description = "vpnId", required = false, multiValued = false)
+ String vpnId = null;
+ private int count = 0;
+
+ @Override
+ protected void execute() {
+ switch (name) {
+ case NODETREE:
+ displayNodes();
+ break;
+ case LINKTREE:
+ displayLinks();
+ break;
+ case PREFIXTREE:
+ displayPrefix();
+ break;
+ case VPNNODETREE:
+ displayVpnNodes();
+ break;
+ case VPNLINKTREE:
+ displayVpnLinks();
+ break;
+ case VPNPREFIXTREE:
+ displayVpnPrefix();
+ break;
+ default:
+ System.out.print("Unknown Command");
+ break;
+ }
+
+ }
+
+ private void displayNodes() {
+ try {
+ int counter = 0;
+ print("Total number of entries = %s", nodeTreeMap.size());
+ for (BgpNodeLSIdentifier nodes : nodekeySet) {
+ if (numberofentries > nodeTreeMap.size() || numberofentries < 0) {
+ System.out.print("Wrong Argument");
+ break;
+ } else if (counter < numberofentries) {
+ pathAttrNlriDetailsLocalRib = nodeTreeMap.get(nodes);
+ displayNode();
+ counter++;
+ } else if (counter == 0) {
+ pathAttrNlriDetailsLocalRib = nodeTreeMap.get(nodes);
+ displayNode();
+
+
+ }
+
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP nodes: {}", e.getMessage());
+ }
+
+ }
+
+
+ private void displayLinks() {
+ try {
+ int counter = 0;
+ print("Total Number of entries = %d", linkTreeMap.size());
+ for (BgpLinkLSIdentifier links : linkkeySet) {
+ if (numberofentries > linkTreeMap.size() || numberofentries < 0) {
+ System.out.print("Wrong Argument");
+ break;
+ } else if (counter < numberofentries) {
+ pathAttrNlriDetailsLocalRib = linkTreeMap.get(links);
+ print("Total number of entries = %d", linkTreeMap.size());
+ displayLink();
+ counter++;
+ } else if (counter == 0) {
+ pathAttrNlriDetailsLocalRib = linkTreeMap.get(links);
+ displayLink();
+ }
+
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP links: {}", e.getMessage());
+ }
+ }
+
+ private void displayPrefix() {
+ try {
+ this.bgpController = get(BgpController.class);
+ bgpLocalRib = bgpController.bgpLocalRib();
+ Map<BgpPrefixLSIdentifier, PathAttrNlriDetailsLocalRib> prefixmap = bgpLocalRib.prefixTree();
+ Set<BgpPrefixLSIdentifier> prefixkeySet = prefixmap.keySet();
+ for (BgpPrefixLSIdentifier prefix : prefixkeySet) {
+ pathAttrNlriDetailsLocalRib = prefixmap.get(prefix);
+ pathAttrNlriDetails = pathAttrNlriDetailsLocalRib.localRibNlridetails();
+ print("No of entries = %d", prefixmap.size());
+ System.out.print(pathAttrNlriDetailsLocalRib.toString());
+
+ }
+
+
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP prefixes: {}", e.getMessage());
+
+ }
+ }
+
+ private void displayVpnNodes() {
+ try {
+ this.bgpController = get(BgpController.class);
+ bgpLocalRib = bgpController.bgpLocalRib();
+ Map<RouteDistinguisher, Map<BgpNodeLSIdentifier, PathAttrNlriDetailsLocalRib>> vpnNode =
+ bgpLocalRib.vpnNodeTree();
+ Set<RouteDistinguisher> vpnNodekeySet = vpnNode.keySet();
+ for (RouteDistinguisher vpnNodes : vpnNodekeySet) {
+ boolean invalidProcess = true;
+ if (vpnId != null && vpnId.trim().equals(vpnNodes.hashCode())) {
+ invalidProcess = false;
+ displayNodes();
+ }
+ if (invalidProcess) {
+ print("%s\n", "Id " + vpnId + "does not exist...!!!");
+ }
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP nodes based on VPN : {}", e.getMessage());
+ }
+
+ }
+
+ private void displayVpnLinks() {
+ try {
+ this.bgpController = get(BgpController.class);
+ bgpLocalRib = bgpController.bgpLocalRib();
+ Map<RouteDistinguisher, Map<BgpLinkLSIdentifier, PathAttrNlriDetailsLocalRib>> vpnLink =
+ bgpLocalRib.vpnLinkTree();
+ Set<RouteDistinguisher> vpnLinkkeySet = vpnLink.keySet();
+ for (RouteDistinguisher vpnLinks : vpnLinkkeySet) {
+ boolean invalidProcess = true;
+ if (vpnId != null && vpnId.trim().equals(vpnLinks.hashCode())) {
+ invalidProcess = false;
+ displayLinks();
+ }
+ if (invalidProcess) {
+ print("%s\n", "Id " + vpnId + "does not exist...!!!");
+ }
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP links based on VPN : {}", e.getMessage());
+ }
+ }
+
+ private void displayVpnPrefix() {
+ try {
+ this.bgpController = get(BgpController.class);
+ bgpLocalRib = bgpController.bgpLocalRib();
+ Map<RouteDistinguisher, Map<BgpPrefixLSIdentifier, PathAttrNlriDetailsLocalRib>> vpnPrefix =
+ bgpLocalRib.vpnPrefixTree();
+ Set<RouteDistinguisher> vpnPrefixkeySet = vpnPrefix.keySet();
+ for (RouteDistinguisher vpnprefixId : vpnPrefixkeySet) {
+ boolean invalidProcess = true;
+ if (vpnId != null && vpnId.trim().equals(vpnprefixId.hashCode())) {
+ invalidProcess = false;
+ displayPrefix();
+ }
+ if (invalidProcess) {
+ print("%s\n", "Id " + vpnId + "does not exist...!!!");
+ }
+ }
+ } catch (Exception e) {
+ log.debug("Error occurred while displaying BGP prefixes based on VPN : {}", e.getMessage());
+ }
+ }
+
+ private void displayNode() {
+
+
+ pathAttrNlriDetails = pathAttrNlriDetailsLocalRib.localRibNlridetails();
+ List<BgpValueType> bgpValueTypeList = pathAttrNlriDetails.pathAttributes();
+ protocolType = pathAttrNlriDetails.protocolID();
+ Iterator<BgpValueType> itrBgpValueType = bgpValueTypeList.iterator();
+ while (itrBgpValueType.hasNext()) {
+ BgpValueType bgpValueType = itrBgpValueType.next();
+ if (bgpValueType instanceof Origin) {
+ origin = (Origin) bgpValueType;
+ } else if (bgpValueType instanceof LocalPref) {
+ localPref = (LocalPref) bgpValueType;
+ } else if (bgpValueType instanceof LinkStateAttributes) {
+ LinkStateAttributes linkStateAttributes = (LinkStateAttributes) bgpValueType;
+ List linkStateAttribiuteList = linkStateAttributes.linkStateAttributes();
+ Iterator<BgpValueType> linkStateAttribiteIterator = linkStateAttribiuteList.iterator();
+ while (linkStateAttribiteIterator.hasNext()) {
+ BgpValueType bgpValueType1 = linkStateAttribiteIterator.next();
+ if (bgpValueType1 instanceof BgpAttrRouterIdV4) {
+ bgpAttrRouterIdV4 = (BgpAttrRouterIdV4) bgpValueType1;
+ }
+ }
+ } else if (bgpValueType instanceof MpReachNlri) {
+ mpReachNlri = (MpReachNlri) bgpValueType;
+ List<BgpLSNlri> bgpLSNlris = mpReachNlri.mpReachNlri();
+ Iterator<BgpLSNlri> bgpLsnlrisIterator = bgpLSNlris.iterator();
+ while (bgpLsnlrisIterator.hasNext()) {
+ BgpLSNlri bgpLSNlri = bgpLsnlrisIterator.next();
+ if (bgpLSNlri instanceof BgpNodeLSNlriVer4) {
+ BgpNodeLSNlriVer4 bgpNodeLSNlriVer4 = (BgpNodeLSNlriVer4) bgpLSNlri;
+ BgpNodeLSIdentifier bgpNodeLSIdentifier = bgpNodeLSNlriVer4.getLocalNodeDescriptors();
+ NodeDescriptors nodeDescriptors = bgpNodeLSIdentifier.getNodedescriptors();
+ List<BgpValueType> bgpvalueTypesList = nodeDescriptors.getSubTlvs();
+ Iterator<BgpValueType> bgpValueTypeIterator = bgpvalueTypesList.iterator();
+ while (bgpValueTypeIterator.hasNext()) {
+ BgpValueType valueType = bgpValueTypeIterator.next();
+ if (valueType instanceof IsIsNonPseudonode) {
+ isIsNonPseudonode = (IsIsNonPseudonode) valueType;
+
+ }
+ }
+ }
+ }
+ }
+ }
+ print("RibAsNumber = %s,PeerIdentifier = %s,RibIpAddress = %s,ProtocolType = %s,Origin = %s,LocalPref = %s," +
+ "RouterID = %s,IsoNodeID = %s,NextHop = %s", pathAttrNlriDetailsLocalRib.localRibAsNum(),
+ pathAttrNlriDetailsLocalRib.localRibIdentifier(), pathAttrNlriDetailsLocalRib.localRibIpAddress(),
+ protocolType.toString(), origin.origin(), localPref.localPref(), bgpAttrRouterIdV4.attrRouterId(),
+ Arrays.toString(isIsNonPseudonode.getIsoNodeId()), mpReachNlri.nexthop4());
+ }
+
+ private void displayLink() {
+
+ pathAttrNlriDetails = pathAttrNlriDetailsLocalRib.localRibNlridetails();
+ List<BgpValueType> valueTypes = pathAttrNlriDetails.pathAttributes();
+ Iterator<BgpValueType> itrBgpValueType = valueTypes.iterator();
+ while (itrBgpValueType.hasNext()) {
+ BgpValueType bgpValueType = itrBgpValueType.next();
+ if (bgpValueType instanceof Origin) {
+ origin = (Origin) bgpValueType;
+ } else if (bgpValueType instanceof LocalPref) {
+ localPref = (LocalPref) bgpValueType;
+ } else if (bgpValueType instanceof LinkStateAttributes) {
+ LinkStateAttributes linkStateAttributes = (LinkStateAttributes) bgpValueType;
+ List linkStateAttributelist = linkStateAttributes.linkStateAttributes();
+ Iterator<BgpValueType> linkStateAttributeIterator = linkStateAttributelist.iterator();
+ while (linkStateAttributeIterator.hasNext()) {
+ BgpValueType bgpValueType1 = linkStateAttributeIterator.next();
+ if (bgpValueType1 instanceof BgpAttrRouterIdV4) {
+ bgpAttrRouterIdV4 = (BgpAttrRouterIdV4) bgpValueType1;
+ } else if (bgpValueType1 instanceof BgpLinkAttrMaxLinkBandwidth) {
+ bgpLinkAttrMaxLinkBandwidth = (BgpLinkAttrMaxLinkBandwidth) bgpValueType1;
+ } else if (bgpValueType1 instanceof BgpLinkAttrUnRsrvdLinkBandwidth) {
+ bgpLinkAttrUnRsrvdLinkBandwidth = (BgpLinkAttrUnRsrvdLinkBandwidth) bgpValueType1;
+ } else if (bgpValueType1 instanceof BgpLinkAttrTeDefaultMetric) {
+ bgpLinkAttrTeDefaultMetric = (BgpLinkAttrTeDefaultMetric) bgpValueType1;
+ } else if (bgpValueType1 instanceof BgpLinkAttrIgpMetric) {
+ bgpLinkAttrIgpMetric = (BgpLinkAttrIgpMetric) bgpValueType1;
+ }
+
+ }
+ } else if (bgpValueType instanceof MpReachNlri) {
+ mpReachNlri = (MpReachNlri) bgpValueType;
+ List<BgpLSNlri> bgpLSNlris = mpReachNlri.mpReachNlri();
+ Iterator<BgpLSNlri> bgpLsnlrisIterator = bgpLSNlris.iterator();
+ while (bgpLsnlrisIterator.hasNext()) {
+ BgpLSNlri bgpLSNlri = bgpLsnlrisIterator.next();
+ if (bgpLSNlri instanceof BgpLinkLsNlriVer4) {
+ BgpLinkLsNlriVer4 bgpLinkLsNlriVer4 = (BgpLinkLsNlriVer4) bgpLSNlri;
+ BgpLinkLSIdentifier bgpLinkLSIdentifier = bgpLinkLsNlriVer4.getLinkIdentifier();
+ NodeDescriptors localnodeDescriptors = bgpLinkLSIdentifier.localNodeDescriptors();
+ NodeDescriptors remotenodeDescriptors = bgpLinkLSIdentifier.remoteNodeDescriptors();
+ List<BgpValueType> linkDescriptors = bgpLinkLSIdentifier.linkDescriptors();
+ List<BgpValueType> subTlvList = localnodeDescriptors.getSubTlvs();
+ Iterator<BgpValueType> subTlvIterator = subTlvList.iterator();
+ while (subTlvIterator.hasNext()) {
+ BgpValueType valueType = subTlvIterator.next();
+ if (valueType instanceof IsIsNonPseudonode) {
+ isIsNonPseudonode = (IsIsNonPseudonode) valueType;
+ } else if (valueType instanceof AutonomousSystemTlv) {
+ autonomousSystemTlv = (AutonomousSystemTlv) valueType;
+ }
+ }
+ List<BgpValueType> remotevalueTypes = remotenodeDescriptors.getSubTlvs();
+ Iterator<BgpValueType> remoteValueTypesIterator = remotevalueTypes.iterator();
+ while (remoteValueTypesIterator.hasNext()) {
+ BgpValueType valueType = remoteValueTypesIterator.next();
+ if (valueType instanceof IsIsNonPseudonode) {
+ isIsNonPseudonode = (IsIsNonPseudonode) valueType;
+ } else if (valueType instanceof AutonomousSystemTlv) {
+ autonomousSystemTlv = (AutonomousSystemTlv) valueType;
+ }
+ }
+ Iterator<BgpValueType> listIterator = linkDescriptors.iterator();
+ while (listIterator.hasNext()) {
+ BgpValueType valueType = listIterator.next();
+ if (valueType instanceof IPv4AddressTlv) {
+ iPv4AddressTlv = (IPv4AddressTlv) valueType;
+ }
+
+ }
+ }
+ }
+ }
+ }
+ print("PeerIdentifier = %s,Origin = %s,LocalPref = %s,RouterID = %s,MaxBandwidth = %s," +
+ "UnreservedBandwidth = %s,DefaultMetric = %s,IGPMetric = %s,IsoNodeID = %s,ASNum = %s," +
+ "IPAddress = %s,NextHop = %s", pathAttrNlriDetailsLocalRib.localRibIdentifier(),
+ origin.origin(), localPref.localPref(), bgpAttrRouterIdV4.attrRouterId(),
+ bgpLinkAttrMaxLinkBandwidth.linkAttrMaxLinkBandwidth(),
+ bgpLinkAttrUnRsrvdLinkBandwidth.getLinkAttrUnRsrvdLinkBandwidth().toString(),
+ bgpLinkAttrTeDefaultMetric.attrLinkDefTeMetric(), bgpLinkAttrIgpMetric.attrLinkIgpMetric(),
+ Arrays.toString(isIsNonPseudonode.getIsoNodeId()), autonomousSystemTlv.getAsNum(),
+ iPv4AddressTlv.address(), mpReachNlri.nexthop4().toString(),
+ pathAttrNlriDetailsLocalRib.localRibIpAddress(), origin.origin(), localPref.localPref(),
+ bgpAttrRouterIdV4.attrRouterId());
+
+ }
+}
\ No newline at end of file
diff --git a/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/package-info.java b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/package-info.java
new file mode 100644
index 0000000..10d3b8c
--- /dev/null
+++ b/providers/bgp/cli/src/main/java/org/onosproject/bgp/cli/package-info.java
@@ -0,0 +1,4 @@
+/**
+ * Created by root1 on 23/8/16.
+ */
+package org.onosproject.bgp.cli;
\ No newline at end of file
diff --git a/providers/bgp/cli/src/main/resources/OSGI-INF/blueprint/shell-config.xml b/providers/bgp/cli/src/main/resources/OSGI-INF/blueprint/shell-config.xml
new file mode 100644
index 0000000..6695a01
--- /dev/null
+++ b/providers/bgp/cli/src/main/resources/OSGI-INF/blueprint/shell-config.xml
@@ -0,0 +1,15 @@
+<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0">
+
+ <command-bundle xmlns="http://karaf.apache.org/xmlns/shell/v1.1.0">
+ <command>
+ <action class="org.onosproject.bgp.cli.BgpConfiguration"/>
+ </command>
+ <command>
+ <action class="org.onosproject.bgp.cli.BgpLocalRibDisplay"/>
+ </command>
+ <command>
+ <action class="org.onosproject.bgp.cli.BgpExceptions"/>
+ </command>
+ </command-bundle>
+
+</blueprint>