diff options
author | 2016-07-13 12:36:08 +0800 | |
---|---|---|
committer | 2016-07-13 08:12:48 +0000 | |
commit | 4dedc11a04e334acb8db2a54083613264325c90c (patch) | |
tree | 3f59d2c477d5bfc5dfbd771d2fed5e7dde435223 | |
parent | 048931191340429c2df2858db6d11035ae66325b (diff) |
Add sfc support for all installers.
JIRA:FUNCTEST-366
Verified in fuel and joid locally.
Change-Id: Ife0fd55361e22b9f2003e592b42558860431747a
Signed-off-by: wuwenbin2 <wuwenbin2@huawei.com>
-rw-r--r-- | testcases/Controllers/ONOS/Sfc/Sfc.py | 39 | ||||
-rw-r--r-- | testcases/Controllers/ONOS/Sfc/Sfc_fun.py | 83 | ||||
-rwxr-xr-x | testcases/Controllers/ONOS/Teston/onosfunctest.py | 35 |
3 files changed, 75 insertions, 82 deletions
diff --git a/testcases/Controllers/ONOS/Sfc/Sfc.py b/testcases/Controllers/ONOS/Sfc/Sfc.py index dd012edb..cba726c7 100644 --- a/testcases/Controllers/ONOS/Sfc/Sfc.py +++ b/testcases/Controllers/ONOS/Sfc/Sfc.py @@ -18,9 +18,8 @@ # 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 +# TestCase 6 : Remove the Port Chain and Verify the traffic. +# Testcase 7 : Cleanup # ########################################################################### # import functest.utils.functest_logger as ft_logger @@ -141,42 +140,16 @@ class Sfc: logger.info("\t\tPortChain successfully Created") else: logger.error("\t\tPortChain NOT successfully Created") + print ("\n###########################################################\n") ######################################################################### - 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") + ######################################################################### + logger.info("TestCase 6 : 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") @@ -201,7 +174,7 @@ class Sfc: successfully") print ("\n###########################################################n") ####################################################################### - logger.info("Testcase 8 : Cleanup") + logger.info("Testcase 7 : Cleanup") if (Sfc_obj.cleanup() == 204): logger.info("\t\tCleanUp is successfull") else: diff --git a/testcases/Controllers/ONOS/Sfc/Sfc_fun.py b/testcases/Controllers/ONOS/Sfc/Sfc_fun.py index 68929bf0..b386ddbc 100644 --- a/testcases/Controllers/ONOS/Sfc/Sfc_fun.py +++ b/testcases/Controllers/ONOS/Sfc/Sfc_fun.py @@ -20,7 +20,10 @@ class Sfc_fun: self.token_id = 0 self.net_id = 0 self.image_id = 0 - self.os_hostname = 'openstack_ip' + self.keystone_hostname = 'keystone_ip' + self.neutron_hostname = 'neutron_ip' + self.nova_hostname = 'nova_ip' + self.glance_hostname = 'glance_ip' self.onos_hostname = 'onos_ip' # Network variables ####### self.netname = "test_nw" @@ -98,9 +101,9 @@ class Sfc_fun: def getToken(self): """Get the keystone token value from Openstack .""" - url = 'http://'+self.os_hostname+':5000/'+self.osver+'/tokens' + url = 'http://'+self.keystone_hostname+':5000/'+self.osver+'/tokens' data = '{"auth": {"tenantName": "admin", "passwordCredentials":\ - { "username": "admin", "password": "admin"}}}' + { "username": "admin", "password": "console"}}}' headers = {"Accept": "application/json"} response = requests.post(url, headers=headers, data=data) if (response.status_code == 200): @@ -123,7 +126,7 @@ class Sfc_fun: 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' + url = 'http://'+self.neutron_hostname+':9696/'+self.osver+'/networks' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} response = requests.post(url, headers=headers, data=data) @@ -152,7 +155,7 @@ class Sfc_fun: Dicdata = {'subnet': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver+'/subnets' + url = 'http://'+self.neutron_hostname+':9696/'+self.osver+'/subnets' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} response = requests.post(url, headers=headers, data=data) @@ -179,12 +182,12 @@ class Sfc_fun: 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 + # 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' + url = 'http://'+self.neutron_hostname+':9696/'+self.osver+'/ports' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} response = requests.post(url, headers=headers, data=data) @@ -204,7 +207,7 @@ class Sfc_fun: def createVm(self): """Creation of Instance, using firewall image.""" - url = 'http://'+self.os_hostname+':9292/v2/images?name=TestSfcVm' + url = 'http://'+self.glance_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) @@ -237,7 +240,7 @@ class Sfc_fun: Dicdata = {'server': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':8774/v2.1/'+self.tenant_id + \ + url = 'http://'+self.nova_hostname+':8774/v2.1/'+self.tenant_id + \ '/servers' headers = {"Accept": "application/json", "Content-Type": "application/json", "X-Auth-Token": self.token_id} @@ -260,8 +263,8 @@ class Sfc_fun: """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) + url = 'http://' + \ + self.nova_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) @@ -297,7 +300,7 @@ class Sfc_fun: Dicdata = {'port_pair': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_pairs' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -313,7 +316,7 @@ class Sfc_fun: def getPortPair(self): """Query the Portpair id value.""" for p in range(0, 1): - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_pairs?name=PP1' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -342,7 +345,7 @@ class Sfc_fun: Dicdata = {'port_pair_group': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_pair_groups' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -358,7 +361,7 @@ class Sfc_fun: def getPortGroup(self): """Query the PortGroup id.""" for p in range(0, 1): - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_pair_groups?name=PG'+str(p) headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -390,7 +393,7 @@ class Sfc_fun: Dicdata = {'flow_classifier': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/flow_classifiers' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -420,7 +423,7 @@ class Sfc_fun: Dicdata = {'port_chain': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_chains' headers = {"Accept": "application/json", "Content-Type": "application/json", @@ -464,7 +467,8 @@ class Sfc_fun: Dicdata = {'router': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver+'/routers.json' + url = 'http://'+self.neutron_hostname+':9696/' + \ + self.osver+'/routers.json' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} response = requests.post(url, headers=headers, data=data) @@ -481,7 +485,7 @@ class Sfc_fun: def attachInterface(self): """Attachment of instance ports to the Router.""" - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/networks?name=admin_floating_net' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -504,7 +508,7 @@ class Sfc_fun: Dicdata['subnet_id'] = self.subnetId data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/routers/'+self.router_id+'/add_router_interface' headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -525,7 +529,7 @@ class Sfc_fun: Dicdata1 = {'external_gateway_info': Dicdata1} Dicdata1 = {'router': Dicdata1} data = json.dumps(Dicdata1, indent=4) - url = 'http://' + self.os_hostname+':9696/'+self.osver + \ + url = 'http://' + self.neutron_hostname+':9696/'+self.osver + \ '/routers/' + self.router_id headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -542,11 +546,10 @@ class Sfc_fun: """Attachment of Floating Ip to the Router.""" for ip_num in range(0, 2): Dicdata = {} - if self.ip_pool != '': - Dicdata['pool'] = "" + Dicdata['pool'] = "admin_floating_net" data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':8774/v2.1/os-floating-ips' + url = 'http://'+self.nova_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) @@ -567,8 +570,8 @@ class Sfc_fun: Dicdata1 = {'addFloatingIp': Dicdata1} data = json.dumps(Dicdata1, indent=4) - url = 'http://'+self.os_hostname + \ - ':8774/v2.1/servers/'+self.vm[ip_num]+'/action' + url = 'http://' + self.nova_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) @@ -618,7 +621,7 @@ class Sfc_fun: self.logger.info("\tPacket not received in Instance") queue1.put("0") - def ping(ip, timeout=300): + def ping(ip, timeout=120): while True: time.sleep(1) self.logger.debug("Pinging %s. Waiting for response..." % ip) @@ -635,7 +638,7 @@ class Sfc_fun: result0 = ping(self.vm_public_ip[0]) result1 = ping(self.vm_public_ip[1]) if result0 == 0 and result1 == 0: - time.sleep(300) + time.sleep(120) queue1 = Queue() p1 = Process(target=vm1, args=(queue1, )) p1.start() @@ -674,7 +677,7 @@ class Sfc_fun: def deletePortChain(self): """Deletion of PortChain.""" - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_chains/'+self.PC_id headers = {"Accept": "application/json", "Content-Type": "application/json", "X-Auth-Token": self.token_id} @@ -688,7 +691,7 @@ class Sfc_fun: def deleteFlowClassifier(self): """Deletion of Flow Classifier.""" - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/flow_classifiers/'+self.flow_class_if headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -703,7 +706,7 @@ class Sfc_fun: def deletePortGroup(self): """Deletion of PortGroup.""" for p in range(0, 1): - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_pair_groups/'+self.port_grp_id[p] headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -719,7 +722,7 @@ class Sfc_fun: def deletePortPair(self): """Deletion of Portpair.""" for p in range(1, 2): - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/sfc/port_pairs/'+self.port_pair_id[0] headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -735,7 +738,7 @@ class Sfc_fun: """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] + url = 'http://'+self.nova_hostname+':8774/v2.1/servers/'+self.vm[y] headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} response = requests.delete(url, headers=headers) @@ -748,7 +751,7 @@ class Sfc_fun: 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 + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/ports/'+self.port_num[x] headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -766,7 +769,7 @@ class Sfc_fun: Dicdata['external_gateway_info'] = {} Dicdata = {'router': Dicdata} data = json.dumps(Dicdata, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/routers/'+self.router_id headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -778,14 +781,14 @@ class Sfc_fun: if self.subnetId != '': Dicdata1['subnet_id'] = self.subnetId data = json.dumps(Dicdata1, indent=4) - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_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 + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/routers/'+self.router_id headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -802,7 +805,7 @@ class Sfc_fun: return(response.status_code) print ("\n\t\tDeletion of Network") - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/networks/'+self.net_id headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} @@ -816,7 +819,7 @@ class Sfc_fun: print ("\n\t\tDeletion of Floating ip") for ip_num in range(0, 2): - url = 'http://'+self.os_hostname+':9696/'+self.osver + \ + url = 'http://'+self.neutron_hostname+':9696/'+self.osver + \ '/floatingips/'+self.vm_public_id[ip_num] headers = {"Accept": "application/json", "X-Auth-Token": self.token_id} diff --git a/testcases/Controllers/ONOS/Teston/onosfunctest.py b/testcases/Controllers/ONOS/Teston/onosfunctest.py index b215b08a..23fb62d4 100755 --- a/testcases/Controllers/ONOS/Teston/onosfunctest.py +++ b/testcases/Controllers/ONOS/Teston/onosfunctest.py @@ -19,6 +19,8 @@ import os import re import time +from neutronclient.v2_0 import client as neutronclient + import functest.utils.functest_logger as ft_logger import functest.utils.functest_utils as functest_utils import functest.utils.openstack_utils as openstack_utils @@ -186,16 +188,31 @@ def SfcTest(): os.system(cmd) -def SetSfcIp(): - cmd = "openstack catalog show network | grep publicURL" +def GetIp(type): + cmd = "openstack catalog show " + type + " | grep publicURL" cmd_output = os.popen(cmd).read() ip = re.search(r"\d+\.\d+\.\d+\.\d+", cmd_output).group() - cmd_onos_ip = "sed -i 's/onos_ip/" + ip + "/g' " + SFC_PATH + "Sfc_fun.py" - cmd_openstack_ip = "sed -i 's/openstack_ip/" + ip\ - + "/g' " + SFC_PATH + "Sfc_fun.py" - logger.info("Modify ip for SFC") - os.system(cmd_onos_ip) - os.system(cmd_openstack_ip) + return ip + + +def Replace(before, after): + file = "Sfc_fun.py" + cmd = "sed -i 's/" + before + "/" + after + "/g' " + SFC_PATH + file + os.system(cmd) + + +def SetSfcConf(): + Replace("keystone_ip", GetIp("keystone")) + Replace("neutron_ip", GetIp("neutron")) + Replace("nova_ip", GetIp("nova")) + Replace("glance_ip", GetIp("glance")) + pwd = os.environ['OS_PASSWORD'] + Replace("console", pwd) + creds_neutron = openstack_utils.get_credentials("neutron") + neutron_client = neutronclient.Client(**creds_neutron) + ext_net = openstack_utils.get_external_net(neutron_client) + Replace("admin_floating_net", ext_net) + logger.info("Modify configuration for SFC") def main(): @@ -212,7 +229,7 @@ def main(): RunScript("FUNCvirNetNBL3") if DEPLOY_SCENARIO == "os-onos-sfc-ha": CreateImage() - SetSfcIp() + SetSfcConf() SfcTest() try: logger.debug("Push ONOS results into DB") |