Merge "ONOS sfc scripts"

3 files changed, 1043 insertions, 0 deletions

diff --git a/testcases/Controllers/ONOS/Sfc/README.md b/testcases/Controllers/ONOS/Sfc/README.md
new file mode 100644
index 000000000..ae63ee214
--- /dev/null
+++ b/testcases/Controllers/ONOS/Sfc/README.md
@@ -0,0 +1,21 @@
+SFC Script ReadMe File
+**********************
+
+Topology
+---------
+
+Validated with the Fuel Enviroment.
+
+
+Things to Remember :
+--------------------
+
+1] This Script basically Tests the SFC functionality with ONOS controller.
+2] Ip address of Openstack and ONOS are got dynamically.
+3] Initally this sfc script can be used for ONOS and on Request , if need will modify for other controllers.
+
+
+Contact Details :
+-----------------
+
+email-id : antonysilvester@gmail.com
diff --git a/testcases/Controllers/ONOS/Sfc/Sfc.py b/testcases/Controllers/ONOS/Sfc/Sfc.py
new file mode 100644
index 000000000..94b24e680
--- /dev/null
+++ b/testcases/Controllers/ONOS/Sfc/Sfc.py
@@ -0,0 +1,210 @@
+"""Script to Test the SFC scenarios in ONOS."""
+# !/usr/bin/python
+#
+# Copyright (c) 2015 All rights reserved
+# This program and the accompanying materials
+# are made available under the terms of the Apache License, Version 2.0
+# which accompanies this distribution, and is available at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# ###########################################################################
+#                          OPNFV SFC Script
+# **** Scripted by Antony Silvester  - antony.silvester@huawei.com ******
+# ###########################################################################
+
+# Testcase 1 : Prerequisites configuration for SFC
+# Testcase 2 : Creation of 3 VNF Nodes and Attaching Ports
+# TestCase 3 : Configure  SFC [Port pair,Port Group ,Flow classifer
+# TestCase 4 : Configure Port Chain and verify the flows are added.
+# TestCase 5 : Verify  traffic with VNF node.
+# TestCase 6 : Verify the Service Chain Statistics
+# TestCase 7 : Remove the Port Chain and Verify the traffic.
+# Testcase 8 : Cleanup
+# ###########################################################################
+#
+import functest.utils.functest_logger as ft_logger
+from Sfc_fun import Sfc_fun
+
+
+class Sfc:
+    """Script to Test the SFC scenarios in ONOS."""
+    logger = ft_logger.Logger("sfc").getLogger()
+    Sfc_obj = Sfc_fun()
+    print("################################################################")
+    print("                    OPNFV SFC Script             ")
+    print("################################################################")
+    logger.info("Testcase 1 : Prerequisites configuration for SFC")
+    #########################################################################
+    logger.info("\t1.1 Creation of Auth-Token")
+    if (Sfc_obj.getToken() == 200):
+        logger.info("\t\tCreation of Token is successfull")
+    else:
+        logger.error("\t\t  :  Creation of Token is NOT successfull")
+    #########################################################################
+    logger.info("\t1.2 Creation of Network")
+    if (Sfc_obj.createNetworks() == 201):
+        logger.info("\t\tCreation of network is successfull")
+    else:
+        logger.error("\t\t  :  Creation of network is NOT successfull")
+    #########################################################################
+    logger.info("\t1.3 Creation of Subnetwork")
+    if (Sfc_obj.createSubnets() == 201):
+        logger.info("\t\tCreation of Subnetwork is successfull")
+    else:
+        logger.error("\t\t  :  Creation of Subnetwork is NOT successfull")
+    print ("\n###########################################################\n")
+    ########################################################################
+    logger.info("Testcase 2 : Creation of 3 VNF Nodes and Attaching Ports")
+    #########################################################################
+    logger.info("\t2.1 Creation of Ports")
+    if (Sfc_obj.createPorts() == 201):
+        logger.info("\t\tCreation of Port is successfull")
+    else:
+        logger.error("\t\t  :  Creation of Port is NOT successfull")
+    #########################################################################
+    logger.info("\t2.2 Creation of VM-Compute-Node")
+    if (Sfc_obj.createVm() == 202):
+        logger.info("\t\tCreation of VM is successfull")
+    else:
+        logger.error("\t\t  :  Creation of VM is NOT successfull")
+    #########################################################################
+    logger.info("\t2.3 Check VM Status")
+    if (Sfc_obj.checkVmState() == 200):
+        logger.info("\t\tVM are in active state")
+    else:
+        logger.error("\t\t  :   VM is NOT Active")
+    #########################################################################
+    logger.info("\t\t2.4 Router Creation")
+    if (Sfc_obj.createRouter() == 201):
+        logger.info("\t\t Router Creation is Successful")
+    else:
+        logger.error("\t\t  :   Router Creation is NOT Successful")
+    #########################################################################
+    logger.info("\t\t2.5 Attachement of Interface to VM")
+    if (Sfc_obj.attachInterface() == 200):
+        logger.info("\t\t Interface attached to VM")
+    else:
+        logger.error("\t\t  :   Interface NOT attached to VM")
+    #########################################################################
+    logger.info("\t\t2.6 Attachement of FLoating Ip to VM")
+    if (Sfc_obj.addFloatingIp() == 202):
+        logger.info("\t\t Floating Ip attached to VM SUccessful")
+    else:
+        logger.error("\t\t  :   Floating Ip NOT attached to VM ")
+    print ("\n###########################################################\n")
+    ########################################################################
+    logger.info("TestCase 3 : Configure SFC [Portair,PortGroup,\
+                 Flow classifer")
+    #########################################################################
+    logger.info("\t3.1 Creation of Port Pair")
+    if (Sfc_obj.createPortPair() == 201):
+        logger.info("\t\tCreation of Port pair is successful")
+    else:
+        logger.error("\t\t  :  Creation of Port pair is NOT successful")
+
+    #########################################################################
+    logger.info("\t3.2 Getting the  Port Pair ID")
+    if (Sfc_obj.getPortPair() == 200):
+        logger.info("\t\tSuccessfully got Port Pair ID")
+    else:
+        logger.error("\t\t  :  UnSuccessfully got Port Pair ID")
+
+    #########################################################################
+    logger.info("\t3.3 Creation of Port Pair Group")
+    if (Sfc_obj.createPortGroup() == 201):
+        logger.info("\t\tPort Pair Group successfully Created")
+    else:
+        logger.error("\t\t  :  Port Pair Group NOT successfully Created")
+
+    #########################################################################
+    logger.info("\t3.4 Getting Port Pair Group ID ")
+
+    if (Sfc_obj.getPortGroup() == 200):
+        logger.info("\t\tPort Pair Group ID successfully received")
+    else:
+        logger.error("\t\t  :  Port Pair Group ID NOT successfully received")
+
+    #########################################################################
+    logger.info("\t3.5 Creation of Flow Classifier")
+    if (Sfc_obj.createFlowClassifier() == 201):
+        logger.info("\t\tFlow Classifier successfully Created")
+    else:
+        logger.error("\t\t  :  Flow Classifier NOT successfully Created")
+    print ("\n###########################################################\n")
+    ########################################################################
+    logger.info("TestCase 4 : Configure Port Chain and verify the flows are\
+                 added.")
+    #########################################################################
+    logger.info("\t4.1 Creation of PortChain")
+    if (Sfc_obj.createPortChain() == 201):
+        logger.info("\t\tPortChain successfully Created")
+    else:
+        logger.error("\t\tPortChain NOT successfully Created")
+    #########################################################################
+    logger.info("\t4.2 Verification of Flows Installed in OVS")
+    if (Sfc_obj.checkFlowAdded() == 200):
+        logger.info("\t\tFlows Installed successfully ")
+    else:
+        logger.error("\t\t  :  Flows NOT Installed successfully")
+
+    if (Sfc_obj.portChainDeviceMap() == 200):
+        logger.info("\t\t portChainDeviceMap successfully ")
+    else:
+        logger.error("\t\t:portChainDeviceMap NOT Installed successfully")
+
+    if (Sfc_obj.portChainSfMap() == 200):
+        logger.info("\t\tportChainSfMap successfully ")
+    else:
+        logger.error("\t\t  :  portChainSfMap NOT Installed successfully")
+    print ("\n############################################################n")
+    ########################################################################
+    logger.info("\tTestCase 5 : Verify  traffic with VNF node.")
+    if (Sfc_obj.loginToVM() == "1"):
+        logger.info("\t\tSFC function Working")
+    else:
+        logger.error("\t\t  :  SFC function not working")
+    print ("\n###########################################################\n")
+    logger.info("TestCase 6 : Verify the Service Chain Statistics")
+    if (Sfc_obj.portChainDeviceMap() == 200):
+        logger.info("\t\tportChainDeviceMap successfully ")
+    else:
+        logger.error("\t\t:portChainDeviceMap NOT Installed successfully")
+
+    if (Sfc_obj.portChainSfMap() == 200):
+        logger.info("\t\tportChainSfMap successfully ")
+    else:
+        logger.error("\t\t  :  portChainSfMap NOT Installed successfully")
+    print ("\n##########################################################\n")
+    logger.info("TestCase 7 : Remove the Port Chain and Verify the traffic")
+    if (Sfc_obj.deletePortChain() == 204):
+        if (Sfc_obj.loginToVM() == "0"):
+            logger.info("\t\tSFC function is removed Successfully")
+        else:
+            logger.error("\t\t:SFC function not Removed.Have some problem")
+        if (Sfc_obj.deleteFlowClassifier() == 204):
+            if (Sfc_obj.deletePortGroup() == 204):
+                if (Sfc_obj.deletePortPair() == 204):
+                    logger.info("\t\tSFC configuration is deleted \
+                                successfully")
+                else:
+                    logger.error("\t\t  :  Port pair configuration is NOT\
+                                  deleted successfully")
+            else:
+                logger.error("\t\t  :  Port Group configuration is NOT \
+                             deleted successfully")
+        else:
+                logger.error("\t\t  :  Flow classifier configuration is NOT \
+                             deleted successfully")
+    else:
+        logger.error("\t\t:PortChain configuration is NOT deleted \
+                     successfully")
+    print ("\n###########################################################n")
+    #######################################################################
+    logger.info("Testcase 8 : Cleanup")
+    if (Sfc_obj.cleanup() == 204):
+        logger.info("\t\tCleanUp is successfull")
+    else:
+        logger.error("\t\t  :  CleanUp is NOT successfull")
+    print ("###############################################################")
+    print("############################END OF SCRIPT ######################")
diff --git a/testcases/Controllers/ONOS/Sfc/Sfc_fun.py b/testcases/Controllers/ONOS/Sfc/Sfc_fun.py
new file mode 100644
index 000000000..6090e8866
--- /dev/null
+++ b/testcases/Controllers/ONOS/Sfc/Sfc_fun.py
@@ -0,0 +1,812 @@
+"""SFC functions."""
+import functest.utils.functest_logger as ft_logger
+import json
+from multiprocessing import Process
+from multiprocessing import Queue
+from pexpect import pxssh
+import re
+import requests
+import time
+
+
+class Sfc_fun:
+    """Defines all the def function of SFC."""
+
+    def __init__(self):
+        """Initialization of variables."""
+        self.logger = ft_logger.Logger("sfc_fun_log").getLogger()
+        self.osver = "v2.0"
+        self.token_id = 0
+        self.net_id = 0
+        self.image_id = 0
+        self.os_hostname = 'openstack_ip'
+        self.onos_hostname = 'onos_ip'
+        # Network variables #######
+        self.netname = "test_nw"
+        self.admin_state_up = True
+        self.tenant_id = 0
+        self.subnetId = 0
+        # #########################
+        # SubNet variables#########
+        self.ip_version = 4
+        self.cidr = "20.20.20.0/24"
+        self.subnetname = "test_nw_subnets"
+        # ###############################
+        # Port variable
+        self.port = "port"
+        self.port_num = []
+        self.vm_id = 0
+        self.port_ip = []
+        self.count = 0
+        self.i = 0
+        self.numTerms = 3
+        self.security_groups = []
+        self.port_security_enabled = False
+        # ###############################
+        # VM creation variable
+        self.container_format = "bare"
+        self.disk_format = "qcow2"
+        self.imagename = "TestSfcVm"
+        self.createImage = "/home/root1/devstack/files/images/\
+                            firewall_block_image.img"
+
+        self.vm_name = "vm"
+        self.imageRef = "test"
+        self.flavorRef = "1"
+        self.max_count = "1"
+        self.min_count = "1"
+        self.org_nw_port = []
+        self.image_id = 0
+        self.routername = "router1"
+        self.router_id = 0
+        # #####################################
+        # Port pair
+        self.port_pair_ingress = 0
+        self.port_pair_egress = 0
+        self.port_pair_name = "PP"
+        self.port_pair_id = []
+        # ####################################
+        # Port Group
+        self.port_group_name = "PG"
+        self.port_grp_id = []
+        # ####################################
+        # FlowClassifier
+        self.source_ip_prefix = "20.20.20.0/24"
+        self.destination_ip_prefix = "20.20.20.0/24"
+        self.logical_source_port = 0
+        self.fcname = "FC"
+        self.ethertype = "IPv4"
+        # #####################################
+        self.flow_class_if = 0
+        # #####################################
+        # Port Chain variables
+        self.pcname = 'PC'
+        self.PC_id = 0
+        # #####################################
+        # Port Chain variables
+        self.flowadd = ''
+        # #####################################
+        self.ip_pool = 0
+        self.vm_public_ip = []
+        self.vm_public_id = []
+        self.net_id1 = 0
+        self.vm = []
+        self.address = 0
+        self.value = 0
+        self.pub_net_id = 0
+
+    def getToken(self):
+        """Get the keystone token value from Openstack ."""
+        url = 'http://'+self.os_hostname+':5000/'+self.osver+'/tokens'
+        data = '{"auth": {"tenantName": "admin",  "passwordCredentials":\
+                { "username": "admin", "password": "admin"}}}'
+        headers = {"Accept": "application/json"}
+        response = requests.post(url, headers=headers,  data=data)
+        if (response.status_code == 200):
+            json1_data = json.loads(response.content)
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            self.logger.debug(json1_data)
+            self.token_id = json1_data['access']['token']['id']
+            self.tenant_id = json1_data['access']['token']['tenant']['id']
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def createNetworks(self):
+        """Creation of networks."""
+        Dicdata = {}
+        if self.netname != '':
+            Dicdata['name'] = self.netname
+        if self.admin_state_up != '':
+            Dicdata['admin_state_up'] = self.admin_state_up
+        Dicdata = {'network': Dicdata}
+        data = json.dumps(Dicdata,  indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver+'/networks'
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.post(url, headers=headers,  data=data)
+        if (response.status_code == 201):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+
+            json1_data = json.loads(response.content)
+            self.logger.debug(json1_data)
+            self.net_id = json1_data['network']['id']
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def createSubnets(self):
+        """Creation of SubNets."""
+        Dicdata = {}
+        if self.net_id != 0:
+            Dicdata['network_id'] = self.net_id
+        if self.ip_version != '':
+            Dicdata['ip_version'] = self.ip_version
+        if self.cidr != '':
+            Dicdata['cidr'] = self.cidr
+        if self.subnetname != '':
+            Dicdata['name'] = self.subnetname
+
+        Dicdata = {'subnet': Dicdata}
+        data = json.dumps(Dicdata, indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver+'/subnets'
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.post(url, headers=headers,  data=data)
+
+        if (response.status_code == 201):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            json1_data = json.loads(response.content)
+            self.logger.debug(json1_data)
+            self.subnetId = json1_data['subnet']['id']
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def createPorts(self):
+        """Creation of Ports."""
+        for x in range(self.i, self.numTerms):
+            Dicdata = {}
+            if self.net_id != '':
+                Dicdata['network_id'] = self.net_id
+            if self.port != '':
+                Dicdata['name'] = "port"+str(x)
+            if self.admin_state_up != '':
+                Dicdata['admin_state_up'] = self.admin_state_up
+            if self.security_groups != '':
+                Dicdata['security_groups'] = self.security_groups
+            if self.port_security_enabled != '':
+                Dicdata['port_security_enabled'] = self.port_security_enabled
+
+            Dicdata = {'port': Dicdata}
+            data = json.dumps(Dicdata, indent=4)
+            url = 'http://'+self.os_hostname+':9696/'+self.osver+'/ports'
+            headers = {"Accept": "application/json",
+                       "X-Auth-Token": self.token_id}
+            response = requests.post(url, headers=headers,  data=data)
+
+            if (response.status_code == 201):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+
+                json1_data = json.loads(response.content)
+                self.logger.debug(json1_data)
+                self.port_num.append(json1_data['port']['id'])
+                self.port_ip.append(json1_data['port']['fixed_ips'][0]
+                                    ['ip_address'])
+            else:
+                return(response.status_code)
+        return(response.status_code)
+
+    def createVm(self):
+        """Creation of Instance, using  firewall image."""
+        url = 'http://'+self.os_hostname+':9292/v2/images?name=TestSfcVm'
+        headers = {"Accept": "application/json", "Content-Type": "application/\
+                    octet-stream",  "X-Auth-Token": self.token_id}
+        response = requests.get(url, headers=headers)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            self.logger.info("\tFireWall Image is available")
+            json1_data = json.loads(response.content)
+            self.logger.debug(json1_data)
+            self.image_id = json1_data['images'][0]['id']
+        else:
+            return(response.status_code)
+
+        for y in range(0, 3):
+            Dicdata = {}
+            org_nw_port = []
+            org_nw_port.append({'port': self.port_num[y]})
+            if self.vm_name != '':
+                Dicdata['name'] = "vm"+str(y)
+            if self.imageRef != '':
+                Dicdata['imageRef'] = self.image_id
+            if self.flavorRef != '':
+                Dicdata['flavorRef'] = self.flavorRef
+            if self.max_count != '':
+                Dicdata['max_count'] = self.max_count
+            if self.min_count != '':
+                Dicdata['min_count'] = self.min_count
+            if self.org_nw_port != '':
+                Dicdata['networks'] = org_nw_port
+            Dicdata = {'server': Dicdata}
+            data = json.dumps(Dicdata, indent=4)
+
+            url = 'http://'+self.os_hostname+':8774/v2.1/'+self.tenant_id + \
+                  '/servers'
+            headers = {"Accept": "application/json", "Content-Type":
+                       "application/json", "X-Auth-Token": self.token_id}
+            response = requests.post(url, headers=headers,  data=data)
+            if (response.status_code == 202):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                self.logger.info("\tCreation of VM is successfull")
+
+                json1_data = json.loads(response.content)
+                self.logger.debug(json1_data)
+                self.vm_id = json1_data['server']['id']
+                self.vm.append(json1_data['server']['id'])
+            else:
+                return(response.status_code)
+
+        return(response.status_code)
+
+    def checkVmState(self):
+        """Checking the Status of the Instance."""
+        time.sleep(10)
+        for y in range(0, 3):
+            url = 'http://'+self.os_hostname + \
+                  ':8774/v2.1/servers/detail?name=vm'+str(y)
+            headers = {"Accept": "application/json",  "X-Auth-Token":
+                       self.token_id}
+            response = requests.get(url, headers=headers)
+            if (response.status_code == 200):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                json1_data = json.loads(response.content)
+                self.logger.debug(json1_data)
+                self.vm_active = json1_data['servers'][0]['status']
+                if (self.vm_active == "ACTIVE"):
+                    print ("\t\t\t\t\t\tVM"+str(y)+" is Active : "
+                           + self.vm_active)
+                else:
+                    print ("\t\t\t\t\t\tVM"+str(y)+" is NOT Active : "
+                           + self.vm_active)
+            else:
+                return(response.status_code)
+        return(response.status_code)
+        time.sleep(10)
+
+    def createPortPair(self):
+        """Creation of Port Pair."""
+        for p in range(1, 2):
+            Dicdata = {}
+            if self.port_pair_ingress != '':
+                Dicdata['ingress'] = self.port_num[p]
+            if self.port_pair_egress != '':
+                egress = p
+                Dicdata['egress'] = self.port_num[egress]
+            if self.port_pair_name != '':
+                Dicdata['name'] = "PP"+str(p)
+
+            Dicdata = {'port_pair': Dicdata}
+            data = json.dumps(Dicdata, indent=4)
+
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                '/sfc/port_pairs'
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.post(url, headers=headers,  data=data)
+            if (response.status_code == 201):
+                print ("\t\t\t\tCreation of Port Pair PP"+str(p) +
+                       "is successful")
+            else:
+                return(response.status_code)
+
+        return(response.status_code)
+
+    def getPortPair(self):
+        """Query the Portpair id value."""
+        for p in range(0, 1):
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/sfc/port_pairs?name=PP1'
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.get(url, headers=headers)
+
+            if (response.status_code == 200):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                json1_data = json.loads(response.content)
+                self.logger.debug(json1_data)
+                self.port_pair_id.append(json1_data['port_pairs'][0]['id'])
+            else:
+                return(response.status_code)
+        return(response.status_code)
+
+    def createPortGroup(self):
+        """Creation of PortGroup."""
+        for p in range(0, 1):
+            Dicdata = {}
+            port_pair_list = []
+            port_pair_list.append(self.port_pair_id[p])
+            if self.port_group_name != '':
+                Dicdata['name'] = "PG"+str(p)
+            if self.port_pair_id != '':
+                Dicdata['port_pairs'] = port_pair_list
+
+            Dicdata = {'port_pair_group': Dicdata}
+            data = json.dumps(Dicdata, indent=4)
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/sfc/port_pair_groups'
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.post(url, headers=headers,  data=data)
+            if (response.status_code == 201):
+                print ("\t\t\t\tCreation of Port Group PG"+str(p) +
+                       "is successful")
+            else:
+                return(response.status_code)
+
+        return(response.status_code)
+
+    def getPortGroup(self):
+        """Query the PortGroup id."""
+        for p in range(0, 1):
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/sfc/port_pair_groups?name=PG'+str(p)
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.get(url, headers=headers)
+
+            if (response.status_code == 200):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                json1_data = json.loads(response.content)
+                self.port_grp_id.append(json1_data['port_pair_groups']
+                                        [0]['id'])
+            else:
+                return(response.status_code)
+        return(response.status_code)
+
+    def createFlowClassifier(self):
+        """Creation of Flow Classifier."""
+        Dicdata = {}
+        if self.source_ip_prefix != '':
+            Dicdata['source_ip_prefix'] = self.source_ip_prefix
+        if self.destination_ip_prefix != '':
+            Dicdata['destination_ip_prefix'] = self.destination_ip_prefix
+        if self.logical_source_port != '':
+            Dicdata['logical_source_port'] = self.port_num[0]
+        if self.fcname != '':
+            Dicdata['name'] = "FC1"
+        if self.ethertype != '':
+            Dicdata['ethertype'] = self.ethertype
+
+        Dicdata = {'flow_classifier': Dicdata}
+        data = json.dumps(Dicdata, indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/sfc/flow_classifiers'
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.post(url, headers=headers,  data=data)
+        if (response.status_code == 201):
+            json1_data = json.loads(response.content)
+            self.flow_class_if = json1_data['flow_classifier']['id']
+            self.logger.info("\tCreation of Flow Classifier is successful")
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def createPortChain(self):
+        """Creation of PortChain."""
+        Dicdata = {}
+        flow_class_list = []
+        flow_class_list.append(self.flow_class_if)
+        port_pair_groups_list = []
+        port_pair_groups_list.append(self.port_grp_id[0])
+
+        if flow_class_list != '':
+            Dicdata['flow_classifiers'] = flow_class_list
+        if self.pcname != '':
+            Dicdata['name'] = "PC1"
+        if port_pair_groups_list != '':
+            Dicdata['port_pair_groups'] = port_pair_groups_list
+
+        Dicdata = {'port_chain': Dicdata}
+        data = json.dumps(Dicdata, indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/sfc/port_chains'
+        headers = {"Accept": "application/json",
+                   "Content-Type": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.post(url, headers=headers,  data=data)
+        if (response.status_code == 201):
+            self.logger.info("\tCreation of PORT CHAIN is successful")
+            json1_data = json.loads(response.content)
+            self.PC_id = json1_data['port_chain']['id']
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def checkFlowAdded(self):
+        """Check whether the Flows are downloaded successfully."""
+        time.sleep(5)
+        response = requests.get('http://' + self.onos_hostname +
+                                ':8181/onos/v1/flows',
+                                auth=("karaf",  "karaf"))
+        if (response.status_code == 200):
+            self.logger.info("\tFlow is successfully Queries")
+            json1_data = json.loads(response.content)
+            self.flowadd = json1_data['flows'][0]['state']
+
+            if (self.flowadd == "ADDED"):
+                self.logger.info("\tFlow is successfully added to OVS")
+                return(response.status_code)
+            else:
+                return(404)
+        else:
+            return(response.status_code)
+####################################################################
+
+    def createRouter(self):
+        """Creation of Router."""
+        Dicdata = {}
+        if self.routername != '':
+            Dicdata['name'] = "router1"
+        if self.admin_state_up != '':
+            Dicdata['admin_state_up'] = self.admin_state_up
+
+        Dicdata = {'router': Dicdata}
+        data = json.dumps(Dicdata, indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver+'/routers.json'
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.post(url, headers=headers,  data=data)
+        if (response.status_code == 201):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            self.logger.info("\tCreation of Router is successfull")
+            json1_data = json.loads(response.content)
+            self.logger.debug(json1_data)
+            self.router_id = json1_data['router']['id']
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def attachInterface(self):
+        """Attachment of instance ports to the Router."""
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/networks?name=admin_floating_net'
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.get(url, headers=headers)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            json1_data = json.loads(response.content)
+            self.logger.debug(json1_data)
+            self.net_name = json1_data['networks'][0]['name']
+            if (self.net_name == "admin_floating_net"):
+                self.pub_net_id = json1_data['networks'][0]['id']
+            else:
+                return(response.status_code)
+        ############################################################
+
+        self.logger.info("\tAttachment of Instance interface to Router")
+        Dicdata = {}
+        if self.subnetId != '':
+            Dicdata['subnet_id'] = self.subnetId
+
+        data = json.dumps(Dicdata, indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/routers/'+self.router_id+'/add_router_interface'
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.put(url, headers=headers,  data=data)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            self.logger.info("\tInterface attached successfull")
+        else:
+            return(response.status_code)
+        ############################################################
+        self.logger.info("\tAttachment of Gateway to Router")
+
+        Dicdata1 = {}
+        if self.pub_net_id != 0:
+            Dicdata1['network_id'] = self.pub_net_id
+
+        Dicdata1 = {'external_gateway_info': Dicdata1}
+        Dicdata1 = {'router': Dicdata1}
+        data = json.dumps(Dicdata1, indent=4)
+        url = 'http://' + self.os_hostname+':9696/'+self.osver + \
+              '/routers/' + self.router_id
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.put(url, headers=headers,  data=data)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            self.logger.info("\tGateway Interface attached successfull")
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def addFloatingIp(self):
+        """Attachment of Floating Ip to the Router."""
+        for ip_num in range(0, 2):
+            Dicdata = {}
+            if self.ip_pool != '':
+                Dicdata['pool'] = ""
+
+            data = json.dumps(Dicdata, indent=4)
+            url = 'http://'+self.os_hostname+':8774/v2.1/os-floating-ips'
+            headers = {"Accept": "application/json",
+                       "X-Auth-Token": self.token_id}
+            response = requests.post(url, headers=headers,  data=data)
+            if (response.status_code == 200):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                self.logger.info("\tFloating ip created successfully")
+                json1_data = json.loads(response.content)
+                self.logger.debug(json1_data)
+                self.vm_public_ip.append(json1_data['floating_ip']['ip'])
+                self.vm_public_id.append(json1_data['floating_ip']['id'])
+            else:
+                self.logger.error("\tFloating ip NOT created successfully")
+
+            Dicdata1 = {}
+            if self.address != '':
+                Dicdata1['address'] = self.vm_public_ip[ip_num]
+
+            Dicdata1 = {'addFloatingIp': Dicdata1}
+            data = json.dumps(Dicdata1, indent=4)
+            url = 'http://'+self.os_hostname + \
+                  ':8774/v2.1/servers/'+self.vm[ip_num]+'/action'
+            headers = {"Accept": "application/json",
+                       "X-Auth-Token": self.token_id}
+            response = requests.post(url, headers=headers,  data=data)
+            if(response.status_code == 202):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                self.logger.info("\tPublic Ip successfully added to VM")
+            else:
+                return(response.status_code)
+        return(response.status_code)
+
+    def loginToVM(self):
+        """Login to the VM to check NSH packets are received."""
+        queue1 = "0"
+
+        def vm0():
+
+            s = pxssh.pxssh()
+            hostname = self.vm_public_ip[0]
+            username = "cirros"
+            password = "cubswin:)"
+            s.login(hostname,  username,  password)
+            s.sendline("ping -c 5 "+str(self.port_ip[2]))
+            s.prompt()             # match the prompt
+
+            ping_re = re.search("transmitted.*received",  s.before).group()
+            x = re.split('\s+',  ping_re)
+            if (x[1] >= "1"):
+                self.logger.info("\tPing is Successfull")
+            else:
+                self.logger.info("\tPing is NOT Successfull")
+
+        def vm1(queue1):
+            s = pxssh.pxssh()
+            hostname = self.vm_public_ip[1]
+            username = "cirros"
+            password = "cubswin:)"
+            s.login(hostname,  username,  password)
+            s.sendline('sudo ./firewall')
+            s.prompt()
+            output_pack = s.before
+
+            if(output_pack.find("nshc") != -1):
+                self.logger.info("\tThe packet has reached VM2 Instance")
+                queue1.put("1")
+            else:
+                self.logger.info("\tPacket not received in Instance")
+                queue1.put("0")
+
+        if (self.value == 0):
+            time.sleep(10)
+            queue1 = Queue()
+            p1 = Process(target=vm1,  args=(queue1, ))
+            p1.start()
+            p2 = Process(target=vm0)
+            p2.start()
+            p1.join(10)
+            return (queue1.get())
+        else:
+            print("Thread didnt run")
+
+    """##################################################################"""
+    """ ########################  Stats Functions ################# #####"""
+    def portChainDeviceMap(self):
+        """Check the PC Device Stats in the ONOS."""
+        response = requests.get('http://' + self.onos_hostname +
+                                ':8181/onos/vtn/portChainDeviceMap/' +
+                                self.PC_id, auth=("karaf", "karaf"))
+        if (response.status_code == 200):
+            self.logger.info("\tPortChainDeviceMap is successfully Queries")
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def portChainSfMap(self):
+        """Check the PC SF Map Stats in the ONOS."""
+        response = requests.get('http://'+self.onos_hostname +
+                                ':8181/onos/vtn/portChainSfMap/' +
+                                self.PC_id, auth=("karaf",  "karaf"))
+        if (response.status_code == 200):
+            self.logger.info("\tportChainSfMap is successfully Queries")
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    """###################################################################"""
+
+    def deletePortChain(self):
+        """Deletion of PortChain."""
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/sfc/port_chains/'+self.PC_id
+        headers = {"Accept": "application/json", "Content-Type":
+                   "application/json", "X-Auth-Token": self.token_id}
+        response = requests.delete(url, headers=headers)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def deleteFlowClassifier(self):
+        """Deletion of Flow Classifier."""
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/sfc/flow_classifiers/'+self.flow_class_if
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.delete(url, headers=headers)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            return(response.status_code)
+        else:
+            return(response.status_code)
+
+    def deletePortGroup(self):
+        """Deletion of PortGroup."""
+        for p in range(0, 1):
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/sfc/port_pair_groups/'+self.port_grp_id[p]
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.delete(url, headers=headers)
+            if (response.status_code == 204):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                print ("\n\t\tPort " + self.port_grp_id[p] + "Deleted")
+            else:
+                return(response.status_code)
+        return(response.status_code)
+
+    def deletePortPair(self):
+        """Deletion of Portpair."""
+        for p in range(1,  2):
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/sfc/port_pairs/'+self.port_pair_id[0]
+            headers = {"Accept": "application/json",
+                       "X-Auth-Token": self.token_id}
+            response = requests.delete(url, headers=headers)
+            if (response.status_code == 204):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+            else:
+                return(response.status_code)
+        return(response.status_code)
+
+    def cleanup(self):
+        """Cleanup."""
+        print ("\n\t\tDeleting the VMs")
+        for y in range(0, 3):
+            url = 'http://'+self.os_hostname+':8774/v2.1/servers/'+self.vm[y]
+            headers = {"Accept": "application/json",
+                       "X-Auth-Token": self.token_id}
+            response = requests.delete(url, headers=headers)
+            if (response.status_code == 204):
+                    self.logger.debug(response.status_code)
+                    self.logger.debug(response.content)
+                    print ("\n\t\tVM"+str(y)+" is Deleted : ")
+                    time.sleep(10)
+            else:
+                return(response.status_code)
+        print ("\n\t\tDeletion of Ports")
+        for x in range(self.i, self.numTerms):
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/ports/'+self.port_num[x]
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.delete(url, headers=headers)
+
+            if (response.status_code == 204):
+                self.logger.debug(response.status_code)
+                self.logger.debug(response.content)
+                print ("\n\t\tPort" + str(x) + "  Deleted")
+            else:
+                return(response.status_code)
+        print ("\n\t\tDeleting Router")
+
+        Dicdata = {}
+        Dicdata['external_gateway_info'] = {}
+        Dicdata = {'router': Dicdata}
+        data = json.dumps(Dicdata, indent=4)
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/routers/'+self.router_id
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.put(url, headers=headers,  data=data)
+        if (response.status_code == 200):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            Dicdata1 = {}
+            if self.subnetId != '':
+                Dicdata1['subnet_id'] = self.subnetId
+            data = json.dumps(Dicdata1, indent=4)
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/routers/'+self.router_id + \
+                  '/remove_router_interface.json'
+            headers = {"Accept": "application/json",
+                       "X-Auth-Token": self.token_id}
+            response = requests.put(url, headers=headers,  data=data)
+            if (response.status_code == 200):
+                url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                      '/routers/'+self.router_id
+                headers = {"Accept": "application/json",  "X-Auth-Token":
+                           self.token_id}
+                response = requests.delete(url, headers=headers)
+                if (response.status_code == 204):
+                    self.logger.debug(response.status_code)
+                    self.logger.debug(response.content)
+                    print ("\n\t\tDeletion of Router is successfull")
+                else:
+                    return(response.status_code)
+            else:
+                return(response.status_code)
+        else:
+            return(response.status_code)
+
+        print ("\n\t\tDeletion of Network")
+        url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+              '/networks/'+self.net_id
+        headers = {"Accept": "application/json",
+                   "X-Auth-Token": self.token_id}
+        response = requests.delete(url, headers=headers)
+        if (response.status_code == 204):
+            self.logger.debug(response.status_code)
+            self.logger.debug(response.content)
+            print ("\n\t\tNetwork deleted Successfully")
+        else:
+            return(response.status_code)
+
+        print ("\n\t\t Deletion of Floating ip")
+        for ip_num in range(0, 2):
+            url = 'http://'+self.os_hostname+':9696/'+self.osver + \
+                  '/floatingips/'+self.vm_public_id[ip_num]
+            headers = {"Accept": "application/json", "X-Auth-Token":
+                       self.token_id}
+            response = requests.delete(url, headers=headers)
+            if (response.status_code == 204):
+                    self.logger.debug(response.status_code)
+                    self.logger.debug(response.content)
+            else:
+                    return(response.status_code)
+        return(response.status_code)