| # from cupshelpers.config import prefix |
| |
| # Testing the basic functionality of SDN-IP |
| |
| class PeeringRouterTest: |
| |
| def __init__( self ): |
| self.default = '' |
| |
| |
| def CASE6 ( self, main): |
| |
| import time |
| import json |
| from operator import eq |
| # from datetime import datetime |
| from time import localtime, strftime |
| |
| TESTCASE_ROOT_PATH = main.params[ 'ENV' ][ 'home' ] |
| TESTCASE_MININET_ROOT_PATH = TESTCASE_ROOT_PATH + "/vlan/mininet" |
| # Launch mininet topology for this case |
| MININET_TOPO_FILE = TESTCASE_MININET_ROOT_PATH + "/PeeringRouterMininetVlan.py" |
| main.step( "Launch mininet" ) |
| main.Mininet.handle.sendline("sudo python " + MININET_TOPO_FILE + " " + TESTCASE_MININET_ROOT_PATH) |
| main.step("waiting 20 secs for all switches and quagga instances to comeup") |
| time.sleep(20) |
| main.step( "Test whether Mininet is started" ) |
| |
| #============================= Ping Test ======================== |
| main.log.info("Start ping test") |
| |
| for m in range( 3, 6 ): |
| for n in range( 1, 11 ): |
| hostIp = str( m ) + ".0." + str( n ) + ".1" |
| pingTestResults = main.Mininet.pingHost(SRC="as2host", TARGET=hostIp) |
| |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| |
| def CASE4( self, main): |
| import time |
| import json |
| from operator import eq |
| # from datetime import datetime |
| from time import localtime, strftime |
| |
| main.case("The test case is to help to setup the TestON environment \ |
| and test new drivers" ) |
| TESTCASE_ROOT_PATH = main.params[ 'ENV' ][ 'home' ] |
| TESTCASE_MININET_ROOT_PATH = TESTCASE_ROOT_PATH + "/mininet" |
| SDNIPJSONFILEPATH = TESTCASE_ROOT_PATH + "/sdnip.json" |
| main.log.info("sdnip.json file path: "+ SDNIPJSONFILEPATH) |
| |
| # Copy the json files to config dir |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/addresses.json ~/onos/tools/package/config/") |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/sdnip.json ~/onos/tools/package/config/") |
| |
| # Launch mininet topology for this case |
| MININET_TOPO_FILE = TESTCASE_MININET_ROOT_PATH + "/PeeringRouterMininet.py" |
| main.step( "Launch mininet" ) |
| main.Mininet.handle.sendline("sudo python " + MININET_TOPO_FILE + " " + TESTCASE_MININET_ROOT_PATH) |
| main.step("waiting 20 secs for all switches and quagga instances to comeup") |
| time.sleep(20) |
| main.step( "Test whether Mininet is started" ) |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| # all expected routes for all BGP peers |
| allRoutesExpected = [] |
| main.step( "Start to generate routes for all BGP peers" ) |
| |
| main.log.info( "Generate prefixes for host3" ) |
| prefixesHost3 = main.QuaggaCliHost3.generatePrefixes( 3, 10 ) |
| main.log.info( prefixesHost3 ) |
| # generate route with next hop |
| for prefix in prefixesHost3: |
| allRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| routeIntentsExpectedHost3 = \ |
| main.QuaggaCliHost3.generateExpectedOnePeerRouteIntents( |
| prefixesHost3, "192.168.20.1", "00:00:00:00:02:02", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host4" ) |
| prefixesHost4 = main.QuaggaCliHost4.generatePrefixes( 4, 10 ) |
| main.log.info( prefixesHost4 ) |
| # generate route with next hop |
| for prefix in prefixesHost4: |
| allRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| routeIntentsExpectedHost4 = \ |
| main.QuaggaCliHost4.generateExpectedOnePeerRouteIntents( |
| prefixesHost4, "192.168.30.1", "00:00:00:00:03:01", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host5" ) |
| prefixesHost5 = main.QuaggaCliHost5.generatePrefixes( 5, 10 ) |
| main.log.info( prefixesHost5 ) |
| for prefix in prefixesHost5: |
| allRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| routeIntentsExpectedHost5 = \ |
| main.QuaggaCliHost5.generateExpectedOnePeerRouteIntents( |
| prefixesHost5, "192.168.60.1", "00:00:00:00:06:02", |
| SDNIPJSONFILEPATH ) |
| |
| routeIntentsExpected = routeIntentsExpectedHost3 + \ |
| routeIntentsExpectedHost4 + routeIntentsExpectedHost5 |
| |
| cellName = main.params[ 'ENV' ][ 'cellName' ] |
| ONOS1Ip = main.params[ 'CTRL' ][ 'ip1' ] |
| main.step( "Set cell for ONOS-cli environment" ) |
| main.ONOScli.setCell( cellName ) |
| verifyResult = main.ONOSbench.verifyCell() |
| |
| main.log.report( "Removing raft logs" ) |
| main.ONOSbench.onosRemoveRaftLogs() |
| main.log.report( "Uninstalling ONOS" ) |
| main.ONOSbench.onosUninstall( ONOS1Ip ) |
| |
| main.step( "Installing ONOS package" ) |
| onos1InstallResult = main.ONOSbench.onosInstall( |
| options="-f", node=ONOS1Ip ) |
| |
| onos1Isup = main.ONOSbench.isup( ONOS1Ip ) |
| if not onos1Isup: |
| main.log.report( "ONOS1 didn't start!" ) |
| |
| main.step( "Start ONOS-cli" ) |
| |
| main.ONOScli.startOnosCli( ONOS1Ip ) |
| |
| main.step( "Get devices in the network" ) |
| listResult = main.ONOScli.devices( jsonFormat=False ) |
| main.log.info( listResult ) |
| time.sleep( 10 ) |
| main.log.info( "Installing bgprouter feature" ) |
| main.ONOScli.featureInstall( "onos-app-bgprouter" ) |
| time.sleep( 10 ) |
| main.step( "Login all BGP peers and add routes into peers" ) |
| |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host3" ) |
| main.QuaggaCliHost3.enterConfig( 64514 ) |
| main.log.info( "Add routes to Quagga on host3" ) |
| main.QuaggaCliHost3.addRoutes( prefixesHost3, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host4" ) |
| main.QuaggaCliHost4.loginQuagga( "1.168.30.3" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host4" ) |
| main.QuaggaCliHost4.enterConfig( 64516 ) |
| main.log.info( "Add routes to Quagga on host4" ) |
| main.QuaggaCliHost4.addRoutes( prefixesHost4, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host5" ) |
| main.QuaggaCliHost5.loginQuagga( "1.168.30.5" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host5" ) |
| main.QuaggaCliHost5.enterConfig( 64521 ) |
| main.log.info( "Add routes to Quagga on host5" ) |
| main.QuaggaCliHost5.addRoutes( prefixesHost5, 1 ) |
| |
| time.sleep( 30 ) |
| |
| # get routes inside SDN-IP |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| allRoutesStrExpected = str( sorted( allRoutesExpected ) ) |
| allRoutesStrActual = str( allRoutesActual ).replace( 'u', "" ) |
| main.step( "Check routes installed" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( allRoutesStrExpected ) |
| main.log.info( "Routes get from ONOS CLI:" ) |
| main.log.info( allRoutesStrActual ) |
| utilities.assertEquals( |
| expect=allRoutesStrExpected, actual=allRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct!***", |
| onfail="***Routes in SDN-IP are wrong!***" ) |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============================= Deleting Routes ================== |
| main.step( "Check deleting routes installed" ) |
| main.QuaggaCliHost3.deleteRoutes( prefixesHost3, 1 ) |
| main.QuaggaCliHost4.deleteRoutes( prefixesHost4, 1 ) |
| main.QuaggaCliHost5.deleteRoutes( prefixesHost5, 1 ) |
| |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| main.log.info( "allRoutes_actual = " ) |
| main.log.info( allRoutesActual ) |
| |
| utilities.assertEquals( |
| expect="[]", actual=str( allRoutesActual ), |
| onpass="***Route number in SDN-IP is 0, correct!***", |
| onfail="***Routes number in SDN-IP is not 0, wrong!***" ) |
| |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( "***Routes in SDN-IP after deleting correct!***" ) |
| else: |
| main.log.report( "***Routes in SDN-IP after deleting wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllFail( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="disconnect check PASS", |
| onfail="disconnect check FAIL") |
| |
| main.ONOScli.logout() |
| main.ONOSbench.onosStop(ONOS1Ip); |
| main.Mininet.stopNet() |
| time.sleep(10) |
| |
| def CASE5( self, main ): |
| import time |
| import json |
| from operator import eq |
| # from datetime import datetime |
| from time import localtime, strftime |
| |
| main.case("The test case is to help to setup the TestON environment \ |
| and test new drivers" ) |
| TESTCASE_ROOT_PATH = main.params[ 'ENV' ][ 'home' ] |
| TESTCASE_MININET_ROOT_PATH = TESTCASE_ROOT_PATH + "/vlan/mininet" |
| SDNIPJSONFILEPATH = TESTCASE_ROOT_PATH + "/sdnip.json" |
| main.log.info("sdnip.json file path: "+ SDNIPJSONFILEPATH) |
| |
| # Copy the json files to config dir |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/vlan/addresses.json ~/onos/tools/package/config/") |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/vlan/sdnip.json ~/onos/tools/package/config/") |
| |
| # Launch mininet topology for this case |
| MININET_TOPO_FILE = TESTCASE_MININET_ROOT_PATH + "/PeeringRouterMininetVlan.py" |
| main.step( "Launch mininet" ) |
| main.Mininet.handle.sendline("sudo python " + MININET_TOPO_FILE + " " + TESTCASE_MININET_ROOT_PATH) |
| main.step("waiting 20 secs for all switches and quagga instances to comeup") |
| time.sleep(20) |
| main.step( "Test whether Mininet is started" ) |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| # all expected routes for all BGP peers |
| allRoutesExpected = [] |
| main.step( "Start to generate routes for all BGP peers" ) |
| |
| main.log.info( "Generate prefixes for host3" ) |
| prefixesHost3 = main.QuaggaCliHost3.generatePrefixes( 3, 10 ) |
| main.log.info( prefixesHost3 ) |
| # generate route with next hop |
| for prefix in prefixesHost3: |
| allRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| routeIntentsExpectedHost3 = \ |
| main.QuaggaCliHost3.generateExpectedOnePeerRouteIntents( |
| prefixesHost3, "192.168.20.1", "00:00:00:00:02:02", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host4" ) |
| prefixesHost4 = main.QuaggaCliHost4.generatePrefixes( 4, 10 ) |
| main.log.info( prefixesHost4 ) |
| # generate route with next hop |
| for prefix in prefixesHost4: |
| allRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| routeIntentsExpectedHost4 = \ |
| main.QuaggaCliHost4.generateExpectedOnePeerRouteIntents( |
| prefixesHost4, "192.168.30.1", "00:00:00:00:03:01", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host5" ) |
| prefixesHost5 = main.QuaggaCliHost5.generatePrefixes( 5, 10 ) |
| main.log.info( prefixesHost5 ) |
| for prefix in prefixesHost5: |
| allRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| routeIntentsExpectedHost5 = \ |
| main.QuaggaCliHost5.generateExpectedOnePeerRouteIntents( |
| prefixesHost5, "192.168.60.1", "00:00:00:00:06:02", |
| SDNIPJSONFILEPATH ) |
| |
| routeIntentsExpected = routeIntentsExpectedHost3 + \ |
| routeIntentsExpectedHost4 + routeIntentsExpectedHost5 |
| |
| cellName = main.params[ 'ENV' ][ 'cellName' ] |
| ONOS1Ip = main.params[ 'CTRL' ][ 'ip1' ] |
| main.step( "Set cell for ONOS-cli environment" ) |
| main.ONOScli.setCell( cellName ) |
| verifyResult = main.ONOSbench.verifyCell() |
| |
| main.log.report( "Removing raft logs" ) |
| main.ONOSbench.onosRemoveRaftLogs() |
| main.log.report( "Uninstalling ONOS" ) |
| main.ONOSbench.onosUninstall( ONOS1Ip ) |
| |
| main.step( "Installing ONOS package" ) |
| onos1InstallResult = main.ONOSbench.onosInstall( |
| options="-f", node=ONOS1Ip ) |
| |
| onos1Isup = main.ONOSbench.isup( ONOS1Ip ) |
| if not onos1Isup: |
| main.log.report( "ONOS1 didn't start!" ) |
| |
| main.step( "Start ONOS-cli" ) |
| |
| main.ONOScli.startOnosCli( ONOS1Ip ) |
| main.step( "Get devices in the network" ) |
| listResult = main.ONOScli.devices( jsonFormat=False ) |
| main.log.info( listResult ) |
| time.sleep( 10 ) |
| main.log.info( "Installing bgprouter feature" ) |
| main.ONOScli.featureInstall( "onos-app-bgprouter" ) |
| time.sleep( 10 ) |
| main.step( "Login all BGP peers and add routes into peers" ) |
| |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host3" ) |
| main.QuaggaCliHost3.enterConfig( 64514 ) |
| main.log.info( "Add routes to Quagga on host3" ) |
| main.QuaggaCliHost3.addRoutes( prefixesHost3, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host4" ) |
| main.QuaggaCliHost4.loginQuagga( "1.168.30.3" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host4" ) |
| main.QuaggaCliHost4.enterConfig( 64516 ) |
| main.log.info( "Add routes to Quagga on host4" ) |
| main.QuaggaCliHost4.addRoutes( prefixesHost4, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host5" ) |
| main.QuaggaCliHost5.loginQuagga( "1.168.30.5" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host5" ) |
| main.QuaggaCliHost5.enterConfig( 64521 ) |
| main.log.info( "Add routes to Quagga on host5" ) |
| main.QuaggaCliHost5.addRoutes( prefixesHost5, 1 ) |
| |
| time.sleep( 30 ) |
| |
| # get routes inside SDN-IP |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| allRoutesStrExpected = str( sorted( allRoutesExpected ) ) |
| allRoutesStrActual = str( allRoutesActual ).replace( 'u', "" ) |
| main.step( "Check routes installed" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( allRoutesStrExpected ) |
| main.log.info( "Routes get from ONOS CLI:" ) |
| main.log.info( allRoutesStrActual ) |
| utilities.assertEquals( |
| expect=allRoutesStrExpected, actual=allRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct!***", |
| onfail="***Routes in SDN-IP are wrong!***" ) |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are wrong!***" ) |
| |
| time.sleep(20) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.TRUE |
| for m in range( 3, 6 ): |
| for n in range( 1, 10 ): |
| hostIp = str( m ) + ".0." + str( n ) + ".1" |
| r = main.Mininet.pingHost(SRC="as2host", TARGET=hostIp) |
| if r == main.FALSE: |
| pingTestResults = main.FALSE |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| time.sleep(20) |
| #============================= Deleting Routes ================== |
| main.step( "Check deleting routes installed" ) |
| main.QuaggaCliHost3.deleteRoutes( prefixesHost3, 1 ) |
| main.QuaggaCliHost4.deleteRoutes( prefixesHost4, 1 ) |
| main.QuaggaCliHost5.deleteRoutes( prefixesHost5, 1 ) |
| |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| main.log.info( "allRoutes_actual = " ) |
| main.log.info( allRoutesActual ) |
| |
| utilities.assertEquals( |
| expect="[]", actual=str( allRoutesActual ), |
| onpass="***Route number in SDN-IP is 0, correct!***", |
| onfail="***Routes number in SDN-IP is not 0, wrong!***" ) |
| |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( "***Routes in SDN-IP after deleting correct!***" ) |
| else: |
| main.log.report( "***Routes in SDN-IP after deleting wrong!***" ) |
| |
| time.sleep(10) |
| #============================= Ping Test ======================== |
| pingTestResults = main.TRUE |
| for m in range( 4, 6 ): |
| for n in range( 1, 10 ): |
| hostIp = str( m ) + ".0." + str( n ) + ".1" |
| r = main.Mininet.pingHost(SRC="as2host", TARGET=hostIp) |
| if r == main.TRUE: |
| pingTestResults = main.FALSE |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="disconnect check PASS", |
| onfail="disconnect check FAIL") |
| |
| main.ONOScli.logout() |
| main.ONOSbench.onosStop(ONOS1Ip); |
| main.Mininet.stopNet() |
| time.sleep(10) |
| |
| |
| def CASE7( self, main ): |
| import time |
| import json |
| from operator import eq |
| # from datetime import datetime |
| from time import localtime, strftime |
| |
| main.case("The test case is to help to setup the TestON environment \ |
| and test new drivers" ) |
| TESTCASE_ROOT_PATH = main.params[ 'ENV' ][ 'home' ] |
| TESTCASE_MININET_ROOT_PATH = TESTCASE_ROOT_PATH + "/vlan/mininet" |
| SDNIPJSONFILEPATH = TESTCASE_ROOT_PATH + "/sdnip.json" |
| main.log.info("sdnip.json file path: "+ SDNIPJSONFILEPATH) |
| |
| # Copy the json files to config dir |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/addresses.json ~/onos/tools/package/config/") |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/sdnip.json ~/onos/tools/package/config/") |
| |
| # Launch mininet topology for this case |
| MININET_TOPO_FILE = TESTCASE_MININET_ROOT_PATH + "/PeeringRouterMininetVlan.py" |
| main.step( "Launch mininet" ) |
| main.Mininet.handle.sendline("sudo python " + MININET_TOPO_FILE + " " + TESTCASE_MININET_ROOT_PATH) |
| main.step("waiting 20 secs for all switches and quagga instances to comeup") |
| time.sleep(20) |
| main.step( "Test whether Mininet is started" ) |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| # all expected routes for all BGP peers |
| allRoutesExpected = [] |
| main.step( "Start to generate routes for all BGP peers" ) |
| |
| main.log.info( "Generate prefixes for host3" ) |
| prefixesHost3 = main.QuaggaCliHost3.generatePrefixes( 3, 255 ) |
| main.log.info( prefixesHost3 ) |
| # generate route with next hop |
| for prefix in prefixesHost3: |
| allRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| routeIntentsExpectedHost3 = \ |
| main.QuaggaCliHost3.generateExpectedOnePeerRouteIntents( |
| prefixesHost3, "192.168.20.1", "00:00:00:00:02:02", |
| SDNIPJSONFILEPATH ) |
| main.log.info( "Generate prefixes for host4" ) |
| prefixesHost4 = main.QuaggaCliHost4.generatePrefixes( 4, 255 ) |
| main.log.info( prefixesHost4 ) |
| # generate route with next hop |
| for prefix in prefixesHost4: |
| allRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| routeIntentsExpectedHost4 = \ |
| main.QuaggaCliHost4.generateExpectedOnePeerRouteIntents( |
| prefixesHost4, "192.168.30.1", "00:00:00:00:03:01", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host5" ) |
| prefixesHost5 = main.QuaggaCliHost5.generatePrefixes( 5, 255 ) |
| main.log.info( prefixesHost5 ) |
| for prefix in prefixesHost5: |
| allRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| routeIntentsExpectedHost5 = \ |
| main.QuaggaCliHost5.generateExpectedOnePeerRouteIntents( |
| prefixesHost5, "192.168.60.1", "00:00:00:00:06:02", |
| SDNIPJSONFILEPATH ) |
| |
| routeIntentsExpected = routeIntentsExpectedHost3 + \ |
| routeIntentsExpectedHost4 + routeIntentsExpectedHost5 |
| |
| cellName = main.params[ 'ENV' ][ 'cellName' ] |
| ONOS1Ip = main.params[ 'CTRL' ][ 'ip1' ] |
| main.step( "Set cell for ONOS-cli environment" ) |
| main.ONOScli.setCell( cellName ) |
| verifyResult = main.ONOSbench.verifyCell() |
| |
| main.log.report( "Removing raft logs" ) |
| main.ONOSbench.onosRemoveRaftLogs() |
| main.log.report( "Uninstalling ONOS" ) |
| main.ONOSbench.onosUninstall( ONOS1Ip ) |
| |
| main.step( "Installing ONOS package" ) |
| onos1InstallResult = main.ONOSbench.onosInstall( |
| options="-f", node=ONOS1Ip ) |
| |
| onos1Isup = main.ONOSbench.isup( ONOS1Ip ) |
| if not onos1Isup: |
| main.log.report( "ONOS1 didn't start!" ) |
| |
| main.step( "Start ONOS-cli" ) |
| |
| main.ONOScli.startOnosCli( ONOS1Ip ) |
| main.step( "Get devices in the network" ) |
| listResult = main.ONOScli.devices( jsonFormat=False ) |
| main.log.info( listResult ) |
| time.sleep( 10 ) |
| main.log.info( "Installing bgprouter feature" ) |
| main.ONOScli.featureInstall( "onos-app-bgprouter" ) |
| time.sleep( 10 ) |
| main.step( "Login all BGP peers and add routes into peers" ) |
| |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host3" ) |
| main.QuaggaCliHost3.enterConfig( 64514 ) |
| main.log.info( "Add routes to Quagga on host3" ) |
| main.QuaggaCliHost3.addRoutes( prefixesHost3, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host4" ) |
| main.QuaggaCliHost4.loginQuagga( "1.168.30.3" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host4" ) |
| main.QuaggaCliHost4.enterConfig( 64516 ) |
| main.log.info( "Add routes to Quagga on host4" ) |
| main.QuaggaCliHost4.addRoutes( prefixesHost4, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host5" ) |
| main.QuaggaCliHost5.loginQuagga( "1.168.30.5" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host5" ) |
| main.QuaggaCliHost5.enterConfig( 64521 ) |
| main.log.info( "Add routes to Quagga on host5" ) |
| main.QuaggaCliHost5.addRoutes( prefixesHost5, 1 ) |
| |
| time.sleep( 30 ) |
| |
| # get routes inside SDN-IP |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| allRoutesStrExpected = str( sorted( allRoutesExpected ) ) |
| allRoutesStrActual = str( allRoutesActual ).replace( 'u', "" ) |
| main.step( "Check routes installed" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( allRoutesStrExpected ) |
| main.log.info( "Routes get from ONOS CLI:" ) |
| main.log.info( allRoutesStrActual ) |
| utilities.assertEquals( |
| expect=allRoutesStrExpected, actual=allRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct!***", |
| onfail="***Routes in SDN-IP are wrong!***" ) |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============================= Deleting Routes ================== |
| main.step( "Check deleting routes installed" ) |
| main.QuaggaCliHost3.deleteRoutes( prefixesHost3, 1 ) |
| main.QuaggaCliHost4.deleteRoutes( prefixesHost4, 1 ) |
| main.QuaggaCliHost5.deleteRoutes( prefixesHost5, 1 ) |
| |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| main.log.info( "allRoutes_actual = " ) |
| main.log.info( allRoutesActual ) |
| |
| utilities.assertEquals( |
| expect="[]", actual=str( allRoutesActual ), |
| onpass="***Route number in SDN-IP is 0, correct!***", |
| onfail="***Routes number in SDN-IP is not 0, wrong!***" ) |
| |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( "***Routes in SDN-IP after deleting correct!***" ) |
| else: |
| main.log.report( "***Routes in SDN-IP after deleting wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllFail( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="disconnect check PASS", |
| onfail="disconnect check FAIL") |
| |
| main.ONOScli.logout() |
| main.ONOSbench.onosStop(ONOS1Ip); |
| main.Mininet.stopNet() |
| time.sleep(10) |
| |
| |
| |
| # Route convergence and connectivity test |
| def CASE21( self, main): |
| import time |
| import json |
| from operator import eq |
| # from datetime import datetime |
| from time import localtime, strftime |
| |
| main.case("The test case is to help to setup the TestON environment \ |
| and test new drivers" ) |
| TESTCASE_ROOT_PATH = main.params[ 'ENV' ][ 'home' ] |
| TESTCASE_MININET_ROOT_PATH = TESTCASE_ROOT_PATH + "/routeconvergence/mininet" |
| SDNIPJSONFILEPATH = TESTCASE_ROOT_PATH + "/sdnip.json" |
| main.log.info("sdnip.json file path: "+ SDNIPJSONFILEPATH) |
| |
| # Copy the json files to config dir |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/addresses.json ~/onos/tools/package/config/") |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/sdnip.json ~/onos/tools/package/config/") |
| |
| # Launch mininet topology for this case |
| MININET_TOPO_FILE = TESTCASE_MININET_ROOT_PATH + "/PeeringRouterConvergenceMininet.py" |
| main.step( "Launch mininet" ) |
| main.Mininet.handle.sendline("sudo python " + MININET_TOPO_FILE + " " + TESTCASE_MININET_ROOT_PATH) |
| main.step("waiting 20 secs for all switches and quagga instances to comeup") |
| time.sleep(20) |
| main.step( "Test whether Mininet is started" ) |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| # all expected routes for all BGP peers |
| allRoutesExpected = [] |
| main.step( "Start to generate routes for all BGP peers" ) |
| main.log.info( "Generate prefixes for host3" ) |
| |
| prefixesHost3 = main.QuaggaCliHost3.generatePrefixes( 3, 10 ) |
| main.log.info( prefixesHost3 ) |
| # generate route with next hop |
| for prefix in prefixesHost3: |
| allRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| routeIntentsExpectedHost3 = \ |
| main.QuaggaCliHost3.generateExpectedOnePeerRouteIntents( |
| prefixesHost3, "192.168.20.1", "00:00:00:00:02:02", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host4" ) |
| prefixesHost4 = main.QuaggaCliHost4.generatePrefixes( 4, 10 ) |
| main.log.info( prefixesHost4 ) |
| # generate route with next hop |
| for prefix in prefixesHost4: |
| allRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| routeIntentsExpectedHost4 = \ |
| main.QuaggaCliHost4.generateExpectedOnePeerRouteIntents( |
| prefixesHost4, "192.168.30.1", "00:00:00:00:03:01", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host5" ) |
| prefixesHost5 = main.QuaggaCliHost5.generatePrefixes( 5, 10 ) |
| main.log.info( prefixesHost5 ) |
| for prefix in prefixesHost5: |
| allRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| routeIntentsExpectedHost5 = \ |
| main.QuaggaCliHost5.generateExpectedOnePeerRouteIntents( |
| prefixesHost5, "192.168.60.1", "00:00:00:00:06:02", |
| SDNIPJSONFILEPATH ) |
| |
| routeIntentsExpected = routeIntentsExpectedHost3 + \ |
| routeIntentsExpectedHost4 + routeIntentsExpectedHost5 |
| |
| cellName = main.params[ 'ENV' ][ 'cellName' ] |
| ONOS1Ip = main.params[ 'CTRL' ][ 'ip1' ] |
| main.step( "Set cell for ONOS-cli environment" ) |
| main.ONOScli.setCell( cellName ) |
| verifyResult = main.ONOSbench.verifyCell() |
| |
| main.log.report( "Removing raft logs" ) |
| main.ONOSbench.onosRemoveRaftLogs() |
| main.log.report( "Uninstalling ONOS" ) |
| main.ONOSbench.onosUninstall( ONOS1Ip ) |
| |
| main.step( "Installing ONOS package" ) |
| onos1InstallResult = main.ONOSbench.onosInstall( |
| options="-f", node=ONOS1Ip ) |
| |
| onos1Isup = main.ONOSbench.isup( ONOS1Ip ) |
| if not onos1Isup: |
| main.log.report( "ONOS1 didn't start!" ) |
| |
| main.step( "Start ONOS-cli" ) |
| |
| main.ONOScli.startOnosCli( ONOS1Ip ) |
| |
| main.step( "Get devices in the network" ) |
| listResult = main.ONOScli.devices( jsonFormat=False ) |
| main.log.info( listResult ) |
| time.sleep( 10 ) |
| main.log.info( "Installing gbprouter feature" ) |
| main.ONOScli.featureInstall( "onos-app-bgprouter" ) |
| time.sleep( 10 ) |
| main.step( "Login all BGP peers and add routes into peers" ) |
| |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host3" ) |
| main.QuaggaCliHost3.enterConfig( 64514 ) |
| main.log.info( "Add routes to Quagga on host3" ) |
| main.QuaggaCliHost3.addRoutes( prefixesHost3, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host4" ) |
| main.QuaggaCliHost4.loginQuagga( "1.168.30.3" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host4" ) |
| main.QuaggaCliHost4.enterConfig( 64516 ) |
| main.log.info( "Add routes to Quagga on host4" ) |
| main.QuaggaCliHost4.addRoutes( prefixesHost4, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host5" ) |
| main.QuaggaCliHost5.loginQuagga( "1.168.30.5" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host5" ) |
| main.QuaggaCliHost5.enterConfig( 64521 ) |
| main.log.info( "Add routes to Quagga on host5" ) |
| main.QuaggaCliHost5.addRoutes( prefixesHost5, 1 ) |
| |
| time.sleep( 30 ) |
| |
| # get routes inside SDN-IP |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| allRoutesStrExpected = str( sorted( allRoutesExpected ) ) |
| allRoutesStrActual = str( allRoutesActual ).replace( 'u', "" ) |
| main.step( "Check routes installed" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( allRoutesStrExpected ) |
| main.log.info( "Routes get from ONOS CLI:" ) |
| main.log.info( allRoutesStrActual ) |
| utilities.assertEquals( |
| expect=allRoutesStrExpected, actual=allRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct!***", |
| onfail="***Routes in SDN-IP are wrong!***" ) |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============= Disconnect the BGP session between QuaggaCliHost4 and ONOS ================== |
| main.log.info( "Disabling bgp session between QuaggaCliHost4 and 192.168.30.101:" ) |
| main.QuaggaCliHost4.disable_bgp_peer( "192.168.30.101", "64513" ) |
| main.log.info( "Sleeping for 150 seconds for network to converge" ) |
| time.sleep(150) |
| # get routes inside SDN-IP |
| main.log.info( "Getting Routes from ONOS CLI" ) |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| newAllRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| newAllRoutesStrActual = str( newAllRoutesActual ).replace( 'u', "" ) |
| |
| # Expected routes with changed next hop |
| newAllRoutesExpected = [] |
| for prefix in prefixesHost3: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| for prefix in prefixesHost4: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| for prefix in prefixesHost5: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| newAllRoutesStrExpected = str( sorted( newAllRoutesExpected ) ) |
| main.step( "Check routes installed after convergence-1" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( newAllRoutesStrExpected ) |
| main.log.info( "Routes got from ONOS CLI after convergence-1:" ) |
| main.log.info( newAllRoutesStrActual ) |
| utilities.assertEquals( |
| expect=newAllRoutesStrExpected, actual=newAllRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct after convergence!***", |
| onfail="***Routes in SDN-IP are wrong after convergence!***" ) |
| if( eq( newAllRoutesStrExpected, newAllRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after convergence are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after convergence are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============= Enabling the BGP session between QuaggaCliHost4 and ONOS ================== |
| main.log.info( "Enabling bgp session between QuaggaCliHost4 and 192.168.30.101:" ) |
| main.QuaggaCliHost4.enable_bgp_peer( "192.168.30.101", "64513" ) |
| main.log.info( "Sleeping for 150 seconds for network to converge" ) |
| time.sleep(150) |
| # get routes inside SDN-IP |
| main.log.info( "Getting Routes from ONOS CLI" ) |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| newAllRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| newAllRoutesStrActual = str( newAllRoutesActual ).replace( 'u', "" ) |
| |
| # Expected routes with changed next hop |
| newAllRoutesExpected = [] |
| for prefix in prefixesHost3: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| for prefix in prefixesHost4: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| for prefix in prefixesHost5: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| newAllRoutesStrExpected = str( sorted( newAllRoutesExpected ) ) |
| main.step( "Check routes installed after convergence-2" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( newAllRoutesStrExpected ) |
| main.log.info( "Routes got from ONOS CLI after convergence-2:" ) |
| main.log.info( newAllRoutesStrActual ) |
| utilities.assertEquals( |
| expect=newAllRoutesStrExpected, actual=newAllRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct after convergence!***", |
| onfail="***Routes in SDN-IP are wrong after convergence!***" ) |
| if( eq( newAllRoutesStrExpected, newAllRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after convergence are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after convergence are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============================= Deleting Routes ================== |
| main.step( "Check deleting routes installed" ) |
| main.QuaggaCliHost3.deleteRoutes( prefixesHost3, 1 ) |
| main.QuaggaCliHost4.deleteRoutes( prefixesHost4, 1 ) |
| main.QuaggaCliHost5.deleteRoutes( prefixesHost5, 1 ) |
| |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| main.log.info( "allRoutes_actual = " ) |
| main.log.info( allRoutesActual ) |
| |
| utilities.assertEquals( |
| expect="[]", actual=str( allRoutesActual ), |
| onpass="***Route number in SDN-IP is 0, correct!***", |
| onfail="***Routes number in SDN-IP is not 0, wrong!***" ) |
| |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( "***Routes in SDN-IP after deleting correct!***" ) |
| else: |
| main.log.report( "***Routes in SDN-IP after deleting wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllFail( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="disconnect check PASS", |
| onfail="disconnect check FAIL") |
| |
| main.ONOScli.logout() |
| main.ONOSbench.onosStop(ONOS1Ip); |
| main.Mininet.stopNet() |
| time.sleep(10) |
| |
| # Route convergence and connectivity test with Route Server |
| def CASE22( self, main): |
| import time |
| import json |
| from operator import eq |
| # from datetime import datetime |
| from time import localtime, strftime |
| |
| main.case("The test case is to help to setup the TestON environment \ |
| and test new drivers" ) |
| TESTCASE_ROOT_PATH = main.params[ 'ENV' ][ 'home' ] |
| TESTCASE_MININET_ROOT_PATH = TESTCASE_ROOT_PATH + "/routeserver/mininet" |
| SDNIPJSONFILEPATH = TESTCASE_ROOT_PATH + "/routeserver/sdnip.json" |
| main.log.info("sdnip.json file path: "+ SDNIPJSONFILEPATH) |
| |
| # Copy the json files to config dir |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/routeserver/addresses.json ~/onos/tools/package/config/") |
| main.ONOSbench.handle.sendline("cp " + TESTCASE_ROOT_PATH + "/routeserver/sdnip.json ~/onos/tools/package/config/") |
| |
| # Launch mininet topology for this case |
| MININET_TOPO_FILE = TESTCASE_MININET_ROOT_PATH + "/PeeringRouteServerMininet.py" |
| main.step( "Launch mininet" ) |
| main.Mininet.handle.sendline("sudo python " + MININET_TOPO_FILE + " " + TESTCASE_MININET_ROOT_PATH) |
| main.step("waiting 20 secs for all switches and quagga instances to comeup") |
| time.sleep(20) |
| main.step( "Test whether Mininet is started" ) |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| # all expected routes for all BGP peers |
| allRoutesExpected = [] |
| main.step( "Start to generate routes for all BGP peers" ) |
| main.log.info( "Generate prefixes for host3" ) |
| |
| prefixesHost3 = main.QuaggaCliHost3.generatePrefixes( 3, 10 ) |
| main.log.info( prefixesHost3 ) |
| # generate route with next hop |
| for prefix in prefixesHost3: |
| allRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| routeIntentsExpectedHost3 = \ |
| main.QuaggaCliHost3.generateExpectedOnePeerRouteIntents( |
| prefixesHost3, "192.168.20.1", "00:00:00:00:02:02", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host4" ) |
| prefixesHost4 = main.QuaggaCliHost4.generatePrefixes( 4, 10 ) |
| main.log.info( prefixesHost4 ) |
| # generate route with next hop |
| for prefix in prefixesHost4: |
| allRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| routeIntentsExpectedHost4 = \ |
| main.QuaggaCliHost4.generateExpectedOnePeerRouteIntents( |
| prefixesHost4, "192.168.30.1", "00:00:00:00:03:01", |
| SDNIPJSONFILEPATH ) |
| |
| main.log.info( "Generate prefixes for host5" ) |
| prefixesHost5 = main.QuaggaCliHost5.generatePrefixes( 5, 10 ) |
| main.log.info( prefixesHost5 ) |
| for prefix in prefixesHost5: |
| allRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| routeIntentsExpectedHost5 = \ |
| main.QuaggaCliHost5.generateExpectedOnePeerRouteIntents( |
| prefixesHost5, "192.168.60.1", "00:00:00:00:06:02", |
| SDNIPJSONFILEPATH ) |
| |
| routeIntentsExpected = routeIntentsExpectedHost3 + \ |
| routeIntentsExpectedHost4 + routeIntentsExpectedHost5 |
| |
| cellName = main.params[ 'ENV' ][ 'cellName' ] |
| ONOS1Ip = main.params[ 'CTRL' ][ 'ip1' ] |
| main.step( "Set cell for ONOS-cli environment" ) |
| main.ONOScli.setCell( cellName ) |
| verifyResult = main.ONOSbench.verifyCell() |
| |
| main.log.report( "Removing raft logs" ) |
| main.ONOSbench.onosRemoveRaftLogs() |
| main.log.report( "Uninstalling ONOS" ) |
| main.ONOSbench.onosUninstall( ONOS1Ip ) |
| |
| main.step( "Installing ONOS package" ) |
| onos1InstallResult = main.ONOSbench.onosInstall( |
| options="-f", node=ONOS1Ip ) |
| |
| onos1Isup = main.ONOSbench.isup( ONOS1Ip ) |
| if not onos1Isup: |
| main.log.report( "ONOS1 didn't start!" ) |
| |
| main.step( "Start ONOS-cli" ) |
| |
| main.ONOScli.startOnosCli( ONOS1Ip ) |
| |
| main.step( "Get devices in the network" ) |
| listResult = main.ONOScli.devices( jsonFormat=False ) |
| main.log.info( listResult ) |
| time.sleep( 10 ) |
| main.log.info( "Installing gbprouter feature" ) |
| main.ONOScli.featureInstall( "onos-app-bgprouter" ) |
| time.sleep( 10 ) |
| main.step( "Login all BGP peers and add routes into peers" ) |
| |
| main.log.info( "Login Quagga CLI on host3" ) |
| main.QuaggaCliHost3.loginQuagga( "1.168.30.2" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host3" ) |
| main.QuaggaCliHost3.enterConfig( 64514 ) |
| main.log.info( "Add routes to Quagga on host3" ) |
| main.QuaggaCliHost3.addRoutes( prefixesHost3, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host4" ) |
| main.QuaggaCliHost4.loginQuagga( "1.168.30.3" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host4" ) |
| main.QuaggaCliHost4.enterConfig( 64516 ) |
| main.log.info( "Add routes to Quagga on host4" ) |
| main.QuaggaCliHost4.addRoutes( prefixesHost4, 1 ) |
| |
| main.log.info( "Login Quagga CLI on host5" ) |
| main.QuaggaCliHost5.loginQuagga( "1.168.30.5" ) |
| main.log.info( "Enter configuration model of Quagga CLI on host5" ) |
| main.QuaggaCliHost5.enterConfig( 64521 ) |
| main.log.info( "Add routes to Quagga on host5" ) |
| main.QuaggaCliHost5.addRoutes( prefixesHost5, 1 ) |
| |
| time.sleep( 60 ) |
| |
| # get routes inside SDN-IP |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| allRoutesStrExpected = str( sorted( allRoutesExpected ) ) |
| allRoutesStrActual = str( allRoutesActual ).replace( 'u', "" ) |
| main.step( "Check routes installed" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( allRoutesStrExpected ) |
| main.log.info( "Routes get from ONOS CLI:" ) |
| main.log.info( allRoutesStrActual ) |
| utilities.assertEquals( |
| expect=allRoutesStrExpected, actual=allRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct!***", |
| onfail="***Routes in SDN-IP are wrong!***" ) |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after adding routes are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============= Disconnect the BGP session between QuaggaCliHost4 and ONOS ================== |
| main.log.info( "Disabling bgp session between QuaggaCliHost4 and 192.168.30.101:" ) |
| main.QuaggaCliHost4.disable_bgp_peer( "192.168.30.101", "64513" ) |
| main.log.info( "Sleeping for 150 seconds for network to converge" ) |
| time.sleep(150) |
| # get routes inside SDN-IP |
| main.log.info( "Getting Routes from ONOS CLI" ) |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| newAllRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| newAllRoutesStrActual = str( newAllRoutesActual ).replace( 'u', "" ) |
| |
| # Expected routes with changed next hop |
| newAllRoutesExpected = [] |
| for prefix in prefixesHost3: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| for prefix in prefixesHost4: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| for prefix in prefixesHost5: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| newAllRoutesStrExpected = str( sorted( newAllRoutesExpected ) ) |
| main.step( "Check routes installed after convergence-1" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( newAllRoutesStrExpected ) |
| main.log.info( "Routes got from ONOS CLI after convergence-1:" ) |
| main.log.info( newAllRoutesStrActual ) |
| utilities.assertEquals( |
| expect=newAllRoutesStrExpected, actual=newAllRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct after convergence!***", |
| onfail="***Routes in SDN-IP are wrong after convergence!***" ) |
| if( eq( newAllRoutesStrExpected, newAllRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after convergence are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after convergence are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============= Enabling the BGP session between QuaggaCliHost4 and ONOS ================== |
| main.log.info( "Enabling bgp session between QuaggaCliHost4 and 192.168.30.101:" ) |
| main.QuaggaCliHost4.enable_bgp_peer( "192.168.30.101", "64513" ) |
| main.log.info( "Sleeping for 150 seconds for network to converge" ) |
| time.sleep(150) |
| # get routes inside SDN-IP |
| main.log.info( "Getting Routes from ONOS CLI" ) |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| |
| # parse routes from ONOS CLI |
| newAllRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| newAllRoutesStrActual = str( newAllRoutesActual ).replace( 'u', "" ) |
| |
| # Expected routes with changed next hop |
| newAllRoutesExpected = [] |
| for prefix in prefixesHost3: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.20.1" ) |
| for prefix in prefixesHost4: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.30.1" ) |
| for prefix in prefixesHost5: |
| newAllRoutesExpected.append( prefix + "/" + "192.168.60.2" ) |
| newAllRoutesStrExpected = str( sorted( newAllRoutesExpected ) ) |
| main.step( "Check routes installed after convergence-2" ) |
| main.log.info( "Routes expected:" ) |
| main.log.info( newAllRoutesStrExpected ) |
| main.log.info( "Routes got from ONOS CLI after convergence-2:" ) |
| main.log.info( newAllRoutesStrActual ) |
| utilities.assertEquals( |
| expect=newAllRoutesStrExpected, actual=newAllRoutesStrActual, |
| onpass="***Routes in SDN-IP are correct after convergence!***", |
| onfail="***Routes in SDN-IP are wrong after convergence!***" ) |
| if( eq( newAllRoutesStrExpected, newAllRoutesStrActual ) ): |
| main.log.report( |
| "***Routes in SDN-IP after convergence are correct!***" ) |
| else: |
| main.log.report( |
| "***Routes in SDN-IP after convergence are wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllPass( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="Default connectivity check PASS", |
| onfail="Default connectivity check FAIL") |
| |
| #============================= Deleting Routes ================== |
| main.step( "Check deleting routes installed" ) |
| main.QuaggaCliHost3.deleteRoutes( prefixesHost3, 1 ) |
| main.QuaggaCliHost4.deleteRoutes( prefixesHost4, 1 ) |
| main.QuaggaCliHost5.deleteRoutes( prefixesHost5, 1 ) |
| |
| getRoutesResult = main.ONOScli.routes( jsonFormat=True ) |
| allRoutesActual = \ |
| main.QuaggaCliHost3.extractActualRoutes( getRoutesResult ) |
| |
| main.log.info( "allRoutes_actual = " ) |
| main.log.info( allRoutesActual ) |
| |
| utilities.assertEquals( |
| expect="[]", actual=str( allRoutesActual ), |
| onpass="***Route number in SDN-IP is 0, correct!***", |
| onfail="***Routes number in SDN-IP is not 0, wrong!***" ) |
| |
| if( eq( allRoutesStrExpected, allRoutesStrActual ) ): |
| main.log.report( "***Routes in SDN-IP after deleting correct!***" ) |
| else: |
| main.log.report( "***Routes in SDN-IP after deleting wrong!***" ) |
| |
| #============================= Ping Test ======================== |
| pingTestResults = main.QuaggaCliHost.pingTestAndCheckAllFail( "1.168.30.100" ) |
| main.log.info("Ping test result") |
| if pingTestResults: |
| main.log.info("Test succeeded") |
| else: |
| main.log.info("Test failed") |
| |
| utilities.assert_equals(expect=main.TRUE,actual=pingTestResults, |
| onpass="disconnect check PASS", |
| onfail="disconnect check FAIL") |
| |
| main.ONOScli.logout() |
| main.ONOSbench.onosStop(ONOS1Ip); |
| main.Mininet.stopNet() |
| time.sleep(10) |
| |