# 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
+import functest.utils.functest_utils as functest_utils
+import time
from Sfc_fun import Sfc_fun
"""Script to Test the SFC scenarios in ONOS."""
logger = ft_logger.Logger("sfc").getLogger()
Sfc_obj = Sfc_fun()
+ start_time = time.time()
+ status = "PASS"
print("################################################################")
print(" OPNFV SFC Script ")
print("################################################################")
if (Sfc_obj.getToken() == 200):
logger.info("\t\tCreation of Token is successfull")
else:
+ status = "FAIL"
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:
+ status = "FAIL"
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:
+ status = "FAIL"
logger.error("\t\t : Creation of Subnetwork is NOT successfull")
print ("\n###########################################################\n")
########################################################################
if (Sfc_obj.createPorts() == 201):
logger.info("\t\tCreation of Port is successfull")
else:
+ status = "FAIL"
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:
+ status = "FAIL"
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:
+ status = "FAIL"
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:
+ status = "FAIL"
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:
+ status = "FAIL"
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:
+ status = "FAIL"
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(
+ "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:
+ status = "FAIL"
logger.error("\t\t : Creation of Port pair is NOT successful")
#########################################################################
if (Sfc_obj.getPortPair() == 200):
logger.info("\t\tSuccessfully got Port Pair ID")
else:
+ status = "FAIL"
logger.error("\t\t : UnSuccessfully got Port Pair ID")
#########################################################################
if (Sfc_obj.createPortGroup() == 201):
logger.info("\t\tPort Pair Group successfully Created")
else:
+ status = "FAIL"
logger.error("\t\t : Port Pair Group NOT successfully Created")
#########################################################################
if (Sfc_obj.getPortGroup() == 200):
logger.info("\t\tPort Pair Group ID successfully received")
else:
+ status = "FAIL"
logger.error("\t\t : Port Pair Group ID NOT successfully received")
#########################################################################
if (Sfc_obj.createFlowClassifier() == 201):
logger.info("\t\tFlow Classifier successfully Created")
else:
+ status = "FAIL"
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(
+ "TestCase 4 : Configure Port Chain and verify flows are added")
#########################################################################
logger.info("\t4.1 Creation of PortChain")
if (Sfc_obj.createPortChain() == 201):
logger.info("\t\tPortChain successfully Created")
else:
+ status = "FAIL"
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:
+ status = "FAIL"
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")
else:
+ status = "FAIL"
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")
+ logger.info(
+ "\t\tSFC configuration is deleted successfully")
else:
+ status = "FAIL"
logger.error("\t\t : Port pair configuration is NOT\
deleted successfully")
else:
+ status = "FAIL"
logger.error("\t\t : Port Group configuration is NOT \
deleted successfully")
else:
+ status = "FAIL"
logger.error("\t\t : Flow classifier configuration is NOT \
deleted successfully")
else:
+ status = "FAIL"
logger.error("\t\t:PortChain configuration is NOT deleted \
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:
+ status = "FAIL"
logger.error("\t\t : CleanUp is NOT successfull")
print ("###############################################################")
+ logger.info("Summary :")
+ try:
+ logger.debug("Push ONOS SFC results into DB")
+ stop_time = time.time()
+
+ # ONOS SFC success criteria = all tests OK
+ duration = round(stop_time - start_time, 1)
+ logger.info("Result is " + status)
+ functest_utils.push_results_to_db("functest",
+ "onos_sfc",
+ logger,
+ start_time,
+ stop_time,
+ status,
+ details={'timestart': start_time,
+ 'duration': duration,
+ 'status': status})
+ except:
+ logger.error("Error pushing results into Database")
print("############################END OF SCRIPT ######################")
Code Review / functest.git / blobdiff