andrewonlab | 4a5c447 | 2014-10-09 12:11:41 -0400 | [diff] [blame] | 1 | |
| 2 | #Testing the basic functionality of ONOS Next |
| 3 | #For sanity and driver functionality excercises only. |
| 4 | |
andrewonlab | 7735d85 | 2014-10-09 13:02:47 -0400 | [diff] [blame] | 5 | import time |
| 6 | import sys |
| 7 | import os |
andrewonlab | 2d35516 | 2014-10-10 00:43:59 -0400 | [diff] [blame] | 8 | import re |
| 9 | import time |
andrewonlab | 7735d85 | 2014-10-09 13:02:47 -0400 | [diff] [blame] | 10 | |
andrewonlab | 4a5c447 | 2014-10-09 12:11:41 -0400 | [diff] [blame] | 11 | class ONOSNextTest: |
| 12 | def __init__(self): |
| 13 | self.default = '' |
| 14 | |
| 15 | def CASE1(self, main): |
| 16 | ''' |
| 17 | Startup sequence: |
| 18 | git pull |
| 19 | mvn clean install |
| 20 | onos-package |
| 21 | cell <name> |
| 22 | onos-verify-cell |
| 23 | onos-install -f |
| 24 | onos-wait-for-start |
| 25 | ''' |
andrewonlab | 7735d85 | 2014-10-09 13:02:47 -0400 | [diff] [blame] | 26 | |
andrewonlab | 084307e | 2014-10-09 14:06:09 -0400 | [diff] [blame] | 27 | cell_name = main.params['ENV']['cellName'] |
| 28 | ONOS1_ip = main.params['CTRL']['ip1'] |
andrew@onlab.us | 59e8f69 | 2014-10-09 21:41:48 -0400 | [diff] [blame] | 29 | ONOS1_port = main.params['CTRL']['port1'] |
Jon Hall | ea7818b | 2014-10-09 14:30:59 -0400 | [diff] [blame] | 30 | |
andrewonlab | 8d0d7d7 | 2014-10-09 16:33:15 -0400 | [diff] [blame] | 31 | main.case("Setting up test environment") |
Jon Hall | 3be576e | 2014-10-09 22:23:03 -0400 | [diff] [blame] | 32 | |
| 33 | main.step("Git checkout and pull master") |
| 34 | main.ONOSbench.git_checkout("master") |
| 35 | git_pull_result = main.ONOSbench.git_pull() |
| 36 | |
andrewonlab | 8d0d7d7 | 2014-10-09 16:33:15 -0400 | [diff] [blame] | 37 | |
andrewonlab | 2b30bd3 | 2014-10-09 16:48:55 -0400 | [diff] [blame] | 38 | main.step("Using mvn clean & install") |
andrewonlab | f103e9f | 2014-10-10 00:59:07 -0400 | [diff] [blame^] | 39 | #clean_install_result = main.ONOSbench.clean_install() |
| 40 | clean_install_result = main.TRUE |
andrewonlab | 2b30bd3 | 2014-10-09 16:48:55 -0400 | [diff] [blame] | 41 | |
andrewonlab | 8d0d7d7 | 2014-10-09 16:33:15 -0400 | [diff] [blame] | 42 | main.step("Creating ONOS package") |
andrewonlab | 7735d85 | 2014-10-09 13:02:47 -0400 | [diff] [blame] | 43 | package_result = main.ONOSbench.onos_package() |
andrewonlab | 8d0d7d7 | 2014-10-09 16:33:15 -0400 | [diff] [blame] | 44 | |
| 45 | main.step("Applying cell variable to environment") |
andrewonlab | 084307e | 2014-10-09 14:06:09 -0400 | [diff] [blame] | 46 | cell_result = main.ONOSbench.set_cell(cell_name) |
andrewonlab | c03bf6c | 2014-10-09 14:56:18 -0400 | [diff] [blame] | 47 | verify_result = main.ONOSbench.verify_cell() |
andrewonlab | 2fe32ad | 2014-10-09 16:36:40 -0400 | [diff] [blame] | 48 | |
| 49 | main.step("Installing ONOS package") |
Jon Hall | 7993bfc | 2014-10-09 16:30:14 -0400 | [diff] [blame] | 50 | onos_install_result = main.ONOSbench.onos_install() |
| 51 | onos1_isup = main.ONOSbench.isup() |
andrewonlab | 8d0d7d7 | 2014-10-09 16:33:15 -0400 | [diff] [blame] | 52 | |
| 53 | main.step("Starting ONOS service") |
| 54 | start_result = main.ONOSbench.onos_start(ONOS1_ip) |
| 55 | |
Jon Hall | 7993bfc | 2014-10-09 16:30:14 -0400 | [diff] [blame] | 56 | case1_result = (clean_install_result and package_result and\ |
andrewonlab | 2b30bd3 | 2014-10-09 16:48:55 -0400 | [diff] [blame] | 57 | cell_result and verify_result and onos_install_result and\ |
andrewonlab | f103e9f | 2014-10-10 00:59:07 -0400 | [diff] [blame^] | 58 | onos1_isup and start_result ) |
andrewonlab | 0748d2a | 2014-10-09 13:24:17 -0400 | [diff] [blame] | 59 | utilities.assert_equals(expect=main.TRUE, actual=case1_result, |
| 60 | onpass="Test startup successful", |
| 61 | onfail="Test startup NOT successful") |
andrewonlab | 4a5c447 | 2014-10-09 12:11:41 -0400 | [diff] [blame] | 62 | |
andrewonlab | 05e362f | 2014-10-10 00:40:57 -0400 | [diff] [blame] | 63 | def CASE11(self, main): |
andrewonlab | 2b30bd3 | 2014-10-09 16:48:55 -0400 | [diff] [blame] | 64 | ''' |
| 65 | Cleanup sequence: |
| 66 | onos-service <node_ip> stop |
| 67 | onos-uninstall |
| 68 | |
| 69 | TODO: Define rest of cleanup |
| 70 | |
| 71 | ''' |
| 72 | |
| 73 | ONOS1_ip = main.params['CTRL']['ip1'] |
| 74 | |
| 75 | main.case("Cleaning up test environment") |
| 76 | |
andrewonlab | 057c06a | 2014-10-09 17:19:21 -0400 | [diff] [blame] | 77 | main.step("Testing ONOS kill function") |
| 78 | kill_result = main.ONOSbench.onos_kill(ONOS1_ip) |
| 79 | |
andrewonlab | 2b30bd3 | 2014-10-09 16:48:55 -0400 | [diff] [blame] | 80 | main.step("Stopping ONOS service") |
| 81 | stop_result = main.ONOSbench.onos_stop(ONOS1_ip) |
| 82 | |
| 83 | main.step("Uninstalling ONOS service") |
andrewonlab | 057c06a | 2014-10-09 17:19:21 -0400 | [diff] [blame] | 84 | uninstall_result = main.ONOSbench.onos_uninstall() |
andrewonlab | 4a5c447 | 2014-10-09 12:11:41 -0400 | [diff] [blame] | 85 | |
andrewonlab | 05e362f | 2014-10-10 00:40:57 -0400 | [diff] [blame] | 86 | def CASE3(self, main): |
| 87 | ''' |
| 88 | Test 'onos' command and its functionality in driver |
| 89 | ''' |
| 90 | |
| 91 | ONOS1_ip = main.params['CTRL']['ip1'] |
andrewonlab | 05e362f | 2014-10-10 00:40:57 -0400 | [diff] [blame] | 92 | |
| 93 | main.case("Testing 'onos' command") |
| 94 | |
andrewonlab | f103e9f | 2014-10-10 00:59:07 -0400 | [diff] [blame^] | 95 | main.step("Sending command 'onos -w <onos-ip> system:name'") |
| 96 | cmdstr1 = "system:name" |
| 97 | cmd_result1 = main.ONOSbench.onos_cli(ONOS1_ip, cmdstr1) |
| 98 | main.log.info("onos command returned: "+cmd_result1) |
| 99 | |
| 100 | main.step("Sending command 'onos -w <onos-ip> onos:topology'") |
| 101 | cmdstr2 = "onos:topology" |
| 102 | cmd_result2 = main.ONOSbench.onos_cli(ONOS1_ip, cmdstr2) |
| 103 | main.log.info("onos command returned: "+cmd_result2) |
| 104 | |
| 105 | |
| 106 | |
| 107 | def CASE4(self, main): |
| 108 | main.step("Assigning switches to controllers") |
| 109 | for i in range(1,29): |
| 110 | main.Mininet1.assign_sw_controller(sw=str(i), |
| 111 | ip1=ONOS1_ip, port1=ONOS1_port) |
| 112 | switch_mastership = main.TRUE |
| 113 | for i in range (1,29): |
| 114 | response = main.Mininet1.get_sw_controller("s"+str(i)) |
| 115 | print("Response is " + str(response)) |
| 116 | if re.search("tcp:"+ONOS1_ip,response): |
| 117 | switch_mastership = switch_mastership and main.TRUE |
| 118 | else: |
| 119 | switch_mastership = main.FALSE |
| 120 | |
| 121 | #REACTIVE FWD test |
| 122 | main.step("Pingall") |
| 123 | ping_result = main.FALSE |
| 124 | while ping_result == main.FALSE: |
| 125 | time1 = time.time() |
| 126 | ping_result = main.Mininet1.pingall() |
| 127 | time2 = time.time() |
| 128 | print "Time for pingall: %2f seconds" % (time2 - time1) |
| 129 | |
| 130 | case4_result = switch_mastership and ping_result |
| 131 | utilities.assert_equals(expect=main.TRUE, actual=case4_result, |
| 132 | onpass="Test successful", |
| 133 | onfail="Test NOT successful") |
| 134 | |
| 135 | |