Chetan Gaonker | cb122cc | 2016-05-10 10:58:34 -0700 | [diff] [blame] | 1 | #!/usr/bin/env python |
Chetan Gaonker | cfcce78 | 2016-05-10 10:10:42 -0700 | [diff] [blame] | 2 | # |
| 3 | # Copyright 2016-present Ciena Corporation |
| 4 | # |
| 5 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| 6 | # you may not use this file except in compliance with the License. |
| 7 | # You may obtain a copy of the License at |
| 8 | # |
| 9 | # http://www.apache.org/licenses/LICENSE-2.0 |
| 10 | # |
| 11 | # Unless required by applicable law or agreed to in writing, software |
| 12 | # distributed under the License is distributed on an "AS IS" BASIS, |
| 13 | # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 14 | # See the License for the specific language governing permissions and |
| 15 | # limitations under the License. |
| 16 | # |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 17 | from argparse import ArgumentParser |
| 18 | import os,sys,time |
Chetan Gaonker | 4d842ad | 2016-04-26 10:04:24 -0700 | [diff] [blame] | 19 | utils_dir = os.path.join( os.path.dirname(os.path.realpath(__file__)), '../utils') |
Chetan Gaonker | 7142a34 | 2016-04-07 14:53:12 -0700 | [diff] [blame] | 20 | sys.path.append(utils_dir) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 21 | from OnosCtrl import OnosCtrl |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 22 | from OltConfig import OltConfig |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 23 | from threadPool import ThreadPool |
Chetan Gaonker | 3533faa | 2016-04-25 17:50:14 -0700 | [diff] [blame] | 24 | from CordContainer import * |
| 25 | from CordTestServer import cord_test_server_start, cord_test_server_stop |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 26 | |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 27 | class CordTester(Container): |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 28 | sandbox = '/root/test' |
Chetan Gaonker | 7142a34 | 2016-04-07 14:53:12 -0700 | [diff] [blame] | 29 | sandbox_setup = '/root/test/src/test/setup' |
Chetan Gaonker | 4d842ad | 2016-04-26 10:04:24 -0700 | [diff] [blame] | 30 | tester_base = os.path.dirname(os.path.realpath(__file__)) |
| 31 | tester_paths = os.path.realpath(__file__).split(os.path.sep) |
A R Karthick | b7e8090 | 2016-05-17 09:38:31 -0700 | [diff] [blame] | 32 | tester_path_index = tester_paths.index('src') - 1 |
Chetan Gaonker | 7142a34 | 2016-04-07 14:53:12 -0700 | [diff] [blame] | 33 | sandbox_host = os.path.sep.join(tester_paths[:tester_path_index+1]) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 34 | |
| 35 | host_guest_map = ( (sandbox_host, sandbox), |
Chetan Gaonker | 85b7bd5 | 2016-04-20 10:29:12 -0700 | [diff] [blame] | 36 | ('/lib/modules', '/lib/modules'), |
| 37 | ('/var/run/docker.sock', '/var/run/docker.sock') |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 38 | ) |
| 39 | basename = 'cord-tester' |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 40 | IMAGE = 'cord-test/nose' |
| 41 | ALL_TESTS = ('tls', 'dhcp', 'igmp', 'subscriber', 'vrouter', 'flows') |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 42 | |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 43 | def __init__(self, tests, instance = 0, num_instances = 1, ctlr_ip = None, image = IMAGE, tag = 'latest', |
Chetan Gaonker | 85b7bd5 | 2016-04-20 10:29:12 -0700 | [diff] [blame] | 44 | env = None, rm = False, update = False): |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 45 | self.tests = tests |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 46 | self.ctlr_ip = ctlr_ip |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 47 | self.rm = rm |
| 48 | self.name = self.get_name() |
| 49 | super(CordTester, self).__init__(self.name, image = image, tag = tag) |
| 50 | host_config = self.create_host_config(host_guest_map = self.host_guest_map, privileged = True) |
| 51 | volumes = [] |
Chetan Gaonker | b84835f | 2016-04-19 15:12:10 -0700 | [diff] [blame] | 52 | for _, g in self.host_guest_map: |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 53 | volumes.append(g) |
Chetan Gaonker | 85b7bd5 | 2016-04-20 10:29:12 -0700 | [diff] [blame] | 54 | if update is True or not self.img_exists(): |
Chetan Gaonker | b84835f | 2016-04-19 15:12:10 -0700 | [diff] [blame] | 55 | self.build_image(image) |
Chetan Gaonker | 7142a34 | 2016-04-07 14:53:12 -0700 | [diff] [blame] | 56 | ##Remove test container if any |
| 57 | self.remove_container(self.name, force=True) |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 58 | if env is not None and env.has_key('OLT_CONFIG'): |
| 59 | self.olt = True |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 60 | olt_conf_file = os.path.join(self.tester_base, 'olt_config.json') |
| 61 | olt_config = OltConfig(olt_conf_file) |
| 62 | self.port_map = olt_config.olt_port_map() |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 63 | else: |
| 64 | self.olt = False |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 65 | self.port_map = None |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 66 | if env is not None: |
| 67 | env['TEST_HOST'] = self.name |
| 68 | env['TEST_INSTANCE'] = instance |
| 69 | env['TEST_INSTANCES'] = num_instances |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 70 | print('Starting test container %s, image %s, tag %s' %(self.name, self.image, self.tag)) |
| 71 | self.start(rm = False, volumes = volumes, environment = env, |
| 72 | host_config = host_config, tty = True) |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 73 | |
| 74 | def execute_switch(self, cmd, shell = False): |
| 75 | if self.olt: |
| 76 | return os.system(cmd) |
| 77 | return self.execute(cmd, shell = shell) |
| 78 | |
| 79 | def start_switch(self, bridge = 'ovsbr0', boot_delay = 2): |
| 80 | """Start OVS""" |
| 81 | ##Determine if OVS has to be started locally or not |
| 82 | s_file,s_sandbox = ('of-bridge-local.sh',self.tester_base) if self.olt else ('of-bridge.sh',self.sandbox_setup) |
| 83 | ovs_cmd = os.path.join(s_sandbox, '{0}'.format(s_file)) + ' {0}'.format(bridge) |
| 84 | if self.olt: |
| 85 | ovs_cmd += ' {0}'.format(self.ctlr_ip) |
| 86 | print('Starting OVS on the host') |
| 87 | else: |
| 88 | print('Starting OVS on test container %s' %self.name) |
| 89 | self.execute_switch(ovs_cmd) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 90 | status = 1 |
| 91 | ## Wait for the LLDP flows to be added to the switch |
| 92 | tries = 0 |
Chetan Gaonker | a52016e | 2016-05-05 15:19:59 -0700 | [diff] [blame] | 93 | while status != 0 and tries < 200: |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 94 | cmd = 'sudo ovs-ofctl dump-flows {0} | grep \"type=0x8942\"'.format(bridge) |
| 95 | status = self.execute_switch(cmd, shell = True) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 96 | tries += 1 |
| 97 | if tries % 10 == 0: |
| 98 | print('Waiting for test switch to be connected to ONOS controller ...') |
| 99 | |
| 100 | if status != 0: |
| 101 | print('Test Switch not connected to ONOS container.' |
| 102 | 'Please remove ONOS container and restart the test') |
| 103 | if self.rm: |
| 104 | self.kill() |
| 105 | sys.exit(1) |
| 106 | |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 107 | if boot_delay: |
| 108 | time.sleep(boot_delay) |
| 109 | |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 110 | def setup_intfs(self, port_num = 0): |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 111 | tester_intf_subnet = '192.168.100' |
| 112 | res = 0 |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 113 | host_intf = self.port_map['host'] |
| 114 | start_vlan = self.port_map['start_vlan'] |
| 115 | for port in self.port_map['ports']: |
| 116 | guest_if = port |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 117 | local_if = '{0}_{1}'.format(guest_if, port_num+1) |
| 118 | guest_ip = '{0}.{1}/24'.format(tester_intf_subnet, port_num+1) |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 119 | ##Use pipeworks to configure container interfaces on host/bridge interfaces |
| 120 | pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(host_intf, guest_if, local_if, self.name, guest_ip) |
| 121 | if start_vlan != 0: |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 122 | pipework_cmd += ' @{}'.format(start_vlan + port_num) |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 123 | |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 124 | res += os.system(pipework_cmd) |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 125 | port_num += 1 |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 126 | |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 127 | return res, port_num |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 128 | |
| 129 | @classmethod |
| 130 | def get_name(cls): |
| 131 | cnt_name = '/{0}'.format(cls.basename) |
| 132 | cnt_name_len = len(cnt_name) |
| 133 | names = list(flatten(n['Names'] for n in cls.dckr.containers(all=True))) |
| 134 | test_names = filter(lambda n: n.startswith(cnt_name), names) |
| 135 | last_cnt_number = 0 |
| 136 | if test_names: |
| 137 | last_cnt_name = reduce(lambda n1, n2: n1 if int(n1[cnt_name_len:]) > \ |
| 138 | int(n2[cnt_name_len:]) else n2, |
| 139 | test_names) |
| 140 | last_cnt_number = int(last_cnt_name[cnt_name_len:]) |
| 141 | test_cnt_name = cls.basename + str(last_cnt_number+1) |
| 142 | return test_cnt_name |
| 143 | |
| 144 | @classmethod |
| 145 | def build_image(cls, image): |
| 146 | print('Building test container docker image %s' %image) |
Chetan Gaonker | b6064fa | 2016-05-02 16:29:57 -0700 | [diff] [blame] | 147 | ovs_version = '2.5.0' |
| 148 | image_format = (ovs_version,)*4 |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 149 | dockerfile = ''' |
| 150 | FROM ubuntu:14.04 |
| 151 | MAINTAINER chetan@ciena.com |
| 152 | RUN apt-get update |
| 153 | RUN apt-get -y install git python python-pip python-setuptools python-scapy tcpdump doxygen doxypy wget |
| 154 | RUN easy_install nose |
| 155 | RUN apt-get -y install openvswitch-common openvswitch-switch |
| 156 | RUN mkdir -p /root/ovs |
| 157 | WORKDIR /root |
Chetan Gaonker | b6064fa | 2016-05-02 16:29:57 -0700 | [diff] [blame] | 158 | RUN wget http://openvswitch.org/releases/openvswitch-{}.tar.gz -O /root/ovs/openvswitch-{}.tar.gz && \ |
| 159 | (cd /root/ovs && tar zxpvf openvswitch-{}.tar.gz && \ |
| 160 | cd openvswitch-{} && \ |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 161 | ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && make && make install) |
| 162 | RUN service openvswitch-switch restart || /bin/true |
Chetan Gaonker | c170f3f | 2016-04-19 17:24:45 -0700 | [diff] [blame] | 163 | RUN apt-get -y install python-twisted python-sqlite sqlite3 python-pexpect telnet |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 164 | RUN pip install scapy-ssl_tls |
| 165 | RUN pip install -U scapy |
| 166 | RUN pip install monotonic |
Chetan Gaonker | 3ff8eae | 2016-04-12 14:50:26 -0700 | [diff] [blame] | 167 | RUN pip install configObj |
Chetan Gaonker | c170f3f | 2016-04-19 17:24:45 -0700 | [diff] [blame] | 168 | RUN pip install -U docker-py |
| 169 | RUN pip install -U pyyaml |
| 170 | RUN pip install -U nsenter |
| 171 | RUN pip install -U pyroute2 |
| 172 | RUN pip install -U netaddr |
Chetan Gaonker | 3533faa | 2016-04-25 17:50:14 -0700 | [diff] [blame] | 173 | RUN apt-get -y install arping |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 174 | RUN mv /usr/sbin/tcpdump /sbin/ |
| 175 | RUN ln -sf /sbin/tcpdump /usr/sbin/tcpdump |
A R Karthick | b7e8090 | 2016-05-17 09:38:31 -0700 | [diff] [blame] | 176 | RUN apt-get install -y git-core autoconf automake autotools-dev pkg-config \ |
| 177 | make gcc g++ libtool libc6-dev cmake libpcap-dev libxerces-c2-dev \ |
| 178 | unzip libpcre3-dev flex bison libboost-dev |
| 179 | WORKDIR /root |
| 180 | RUN wget -nc http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/bison_2.5.dfsg-2.1_amd64.deb \ |
| 181 | http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/libbison-dev_2.5.dfsg-2.1_amd64.deb |
| 182 | RUN sudo dpkg -i bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb |
| 183 | RUN rm bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb |
| 184 | RUN wget -nc http://www.nbee.org/download/nbeesrc-jan-10-2013.zip && \ |
| 185 | unzip nbeesrc-jan-10-2013.zip && \ |
| 186 | cd nbeesrc-jan-10-2013/src && cmake . && make && \ |
| 187 | cp ../bin/libn*.so /usr/local/lib && ldconfig && \ |
| 188 | cp -R ../include/* /usr/include/ |
| 189 | WORKDIR /root |
| 190 | RUN git clone https://github.com/CPqD/ofsoftswitch13.git && \ |
| 191 | cd ofsoftswitch13 && \ |
A R Karthick | b7e8090 | 2016-05-17 09:38:31 -0700 | [diff] [blame] | 192 | ./boot.sh && \ |
| 193 | ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && \ |
| 194 | make && make install |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 195 | CMD ["/bin/bash"] |
Chetan Gaonker | b6064fa | 2016-05-02 16:29:57 -0700 | [diff] [blame] | 196 | '''.format(*image_format) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 197 | super(CordTester, cls).build_image(dockerfile, image) |
| 198 | print('Done building docker image %s' %image) |
| 199 | |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 200 | def run_tests(self): |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 201 | '''Run the list of tests''' |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 202 | print('Running tests: %s' %self.tests) |
| 203 | for t in self.tests: |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 204 | test = t.split(':')[0] |
A R Karthick | 24f1de6 | 2016-05-12 15:16:38 -0700 | [diff] [blame] | 205 | test_file = '{}Test.py'.format(test) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 206 | if t.find(':') >= 0: |
A R Karthick | 24f1de6 | 2016-05-12 15:16:38 -0700 | [diff] [blame] | 207 | test_case = '{0}:{1}'.format(test_file, t.split(':')[1]) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 208 | else: |
| 209 | test_case = test_file |
Chetan Gaonker | 7142a34 | 2016-04-07 14:53:12 -0700 | [diff] [blame] | 210 | cmd = 'nosetests -v {0}/src/test/{1}/{2}'.format(self.sandbox, test, test_case) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 211 | status = self.execute(cmd, shell = True) |
| 212 | print('Test %s %s' %(test_case, 'Success' if status == 0 else 'Failure')) |
| 213 | print('Done running tests') |
| 214 | if self.rm: |
| 215 | print('Removing test container %s' %self.name) |
| 216 | self.kill(remove=True) |
| 217 | |
Chetan Gaonker | fb3cb5e | 2016-05-06 11:55:44 -0700 | [diff] [blame] | 218 | @classmethod |
| 219 | def list_tests(cls, tests): |
| 220 | print('Listing test cases') |
| 221 | for test in tests: |
A R Karthick | 24f1de6 | 2016-05-12 15:16:38 -0700 | [diff] [blame] | 222 | test_file = '{}Test.py'.format(test) |
Chetan Gaonker | fb3cb5e | 2016-05-06 11:55:44 -0700 | [diff] [blame] | 223 | cmd = 'nosetests -v --collect-only {0}/../{1}/{2}'.format(cls.tester_base, test, test_file) |
| 224 | os.system(cmd) |
| 225 | |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 226 | ##default onos/radius/test container images and names |
| 227 | onos_image_default='onosproject/onos:latest' |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 228 | nose_image_default= '{}:latest'.format(CordTester.IMAGE) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 229 | test_type_default='dhcp' |
| 230 | onos_app_version = '1.0-SNAPSHOT' |
Chetan Gaonker | 4d842ad | 2016-04-26 10:04:24 -0700 | [diff] [blame] | 231 | cord_tester_base = os.path.dirname(os.path.realpath(__file__)) |
Chetan Gaonker | 4ca5cca | 2016-04-11 13:59:35 -0700 | [diff] [blame] | 232 | onos_app_file = os.path.abspath('{0}/../apps/ciena-cordigmp-'.format(cord_tester_base) + onos_app_version + '.oar') |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 233 | |
| 234 | def runTest(args): |
Chetan Gaonker | 823cdc5 | 2016-05-09 15:51:23 -0700 | [diff] [blame] | 235 | #Start the cord test tcp server |
| 236 | test_server = cord_test_server_start() |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 237 | test_containers = [] |
| 238 | #These tests end up restarting ONOS/quagga/radius |
| 239 | tests_exempt = ('vrouter',) |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 240 | if args.test_type.lower() == 'all': |
| 241 | tests = CordTester.ALL_TESTS |
| 242 | args.radius = True |
| 243 | args.quagga = True |
| 244 | else: |
A R Karthick | acae3b4 | 2016-05-12 15:27:24 -0700 | [diff] [blame] | 245 | tests = args.test_type.split('-') |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 246 | |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 247 | tests_parallel = [ t for t in tests if t.split(':')[0] not in tests_exempt ] |
| 248 | tests_not_parallel = [ t for t in tests if t.split(':')[0] in tests_exempt ] |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 249 | onos_cnt = {'tag':'latest'} |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 250 | nose_cnt = {'image': CordTester.IMAGE, 'tag': 'latest'} |
| 251 | update_map = { 'quagga' : False, 'test' : False, 'radius' : False } |
| 252 | update_map[args.update.lower()] = True |
| 253 | |
| 254 | if args.update.lower() == 'all': |
| 255 | for c in update_map.keys(): |
| 256 | update_map[c] = True |
| 257 | |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 258 | radius_ip = None |
Chetan Gaonker | c170f3f | 2016-04-19 17:24:45 -0700 | [diff] [blame] | 259 | quagga_ip = None |
Chetan Gaonker | fb3cb5e | 2016-05-06 11:55:44 -0700 | [diff] [blame] | 260 | |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 261 | #don't spawn onos if the user has specified external test controller with test interface config |
| 262 | if args.test_controller: |
| 263 | ips = args.test_controller.split('/') |
| 264 | onos_ip = ips[0] |
| 265 | if len(ips) > 1: |
| 266 | radius_ip = ips[1] |
| 267 | else: |
| 268 | radius_ip = None |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 269 | else: |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 270 | onos_cnt['image'] = args.onos.split(':')[0] |
| 271 | if args.onos.find(':') >= 0: |
| 272 | onos_cnt['tag'] = args.onos.split(':')[1] |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 273 | |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 274 | onos = Onos(image = onos_cnt['image'], tag = onos_cnt['tag'], boot_delay = 60) |
| 275 | onos_ip = onos.ip() |
| 276 | |
| 277 | ##Start Radius container if specified |
Chetan Gaonker | 7f4bf74 | 2016-05-04 15:56:08 -0700 | [diff] [blame] | 278 | if args.radius == True: |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 279 | radius = Radius( update = update_map['radius']) |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 280 | radius_ip = radius.ip() |
Chetan Gaonker | 7f4bf74 | 2016-05-04 15:56:08 -0700 | [diff] [blame] | 281 | print('Radius server running with IP %s' %radius_ip) |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 282 | else: |
| 283 | radius_ip = None |
| 284 | |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 285 | print('Onos IP %s, Test type %s' %(onos_ip, args.test_type)) |
| 286 | print('Installing ONOS app %s' %onos_app_file) |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 287 | OnosCtrl.install_app(args.app, onos_ip = onos_ip) |
Chetan Gaonker | b84835f | 2016-04-19 15:12:10 -0700 | [diff] [blame] | 288 | |
| 289 | if args.quagga == True: |
| 290 | #Start quagga. Builds container if required |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 291 | quagga = Quagga(update = update_map['quagga']) |
Chetan Gaonker | c170f3f | 2016-04-19 17:24:45 -0700 | [diff] [blame] | 292 | quagga_ip = quagga.ip() |
Chetan Gaonker | b84835f | 2016-04-19 15:12:10 -0700 | [diff] [blame] | 293 | |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 294 | test_cnt_env = { 'ONOS_CONTROLLER_IP' : onos_ip, |
Chetan Gaonker | c170f3f | 2016-04-19 17:24:45 -0700 | [diff] [blame] | 295 | 'ONOS_AAA_IP' : radius_ip if radius_ip is not None else '', |
| 296 | 'QUAGGA_IP': quagga_ip if quagga_ip is not None else '', |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 297 | } |
| 298 | if args.olt: |
Chetan Gaonker | 7142a34 | 2016-04-07 14:53:12 -0700 | [diff] [blame] | 299 | olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, 'olt_config.json') |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 300 | test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc |
| 301 | |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 302 | port_num = 0 |
| 303 | num_tests = len(tests_parallel) |
| 304 | tests_per_container = max(1, num_tests/args.num_containers) |
| 305 | test_slice_start = 0 |
| 306 | test_slice_end = test_slice_start + tests_per_container |
| 307 | num_test_containers = min(num_tests, args.num_containers) |
| 308 | if tests_parallel: |
| 309 | print('Running %s tests across %d containers in parallel' %(tests_parallel, num_test_containers)) |
| 310 | for container in range(num_test_containers): |
| 311 | test_cnt = CordTester(tests_parallel[test_slice_start:test_slice_end], |
| 312 | instance = container, num_instances = num_test_containers, |
| 313 | ctlr_ip = onos_ip, image = nose_cnt['image'], tag = nose_cnt['tag'], |
| 314 | env = test_cnt_env, |
| 315 | rm = False if args.keep else True, |
| 316 | update = update_map['test']) |
| 317 | test_slice_start = test_slice_end |
| 318 | test_slice_end = test_slice_start + tests_per_container |
| 319 | update_map['test'] = False |
| 320 | test_containers.append(test_cnt) |
| 321 | if args.start_switch or not args.olt: |
| 322 | test_cnt.start_switch() |
| 323 | if test_cnt.olt: |
| 324 | _, port_num = test_cnt.setup_intfs(port_num = port_num) |
| 325 | |
| 326 | thread_pool = ThreadPool(len(test_containers), queue_size = 1, wait_timeout=1) |
| 327 | for test_cnt in test_containers: |
| 328 | thread_pool.addTask(test_cnt.run_tests) |
| 329 | thread_pool.cleanUpThreads() |
| 330 | |
| 331 | ##Run the linear tests |
| 332 | if tests_not_parallel: |
| 333 | test_cnt = CordTester(tests_not_parallel, |
| 334 | ctlr_ip = onos_ip, image = nose_cnt['image'], tag = nose_cnt['tag'], |
| 335 | env = test_cnt_env, |
| 336 | rm = False if args.keep else True, |
| 337 | update = update_map['test']) |
| 338 | if args.start_switch or not args.olt: |
| 339 | test_cnt.start_switch() |
| 340 | if test_cnt.olt: |
| 341 | test_cnt.setup_intfs(port_num = port_num) |
| 342 | test_cnt.run_tests() |
| 343 | |
Chetan Gaonker | 3533faa | 2016-04-25 17:50:14 -0700 | [diff] [blame] | 344 | cord_test_server_stop(test_server) |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 345 | |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 346 | def cleanupTests(args): |
| 347 | test_container = '{}:latest'.format(CordTester.IMAGE) |
| 348 | print('Cleaning up Test containers ...') |
| 349 | Container.cleanup(test_container) |
| 350 | |
| 351 | def listTests(args): |
| 352 | if args.test == 'all': |
| 353 | tests = CordTester.ALL_TESTS |
| 354 | else: |
A R Karthick | acae3b4 | 2016-05-12 15:27:24 -0700 | [diff] [blame] | 355 | tests = args.test.split('-') |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 356 | CordTester.list_tests(tests) |
| 357 | |
| 358 | def buildImages(args): |
| 359 | if args.image == 'all' or args.image == 'quagga': |
| 360 | Quagga.build_image(Quagga.IMAGE) |
| 361 | |
| 362 | if args.image == 'all' or args.image == 'radius': |
| 363 | Radius.build_image(Radius.IMAGE) |
| 364 | |
| 365 | if args.image == 'all' or args.image == 'test': |
| 366 | CordTester.build_image(CordTester.IMAGE) |
| 367 | |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 368 | if __name__ == '__main__': |
Chetan Gaonker | 678743f | 2016-04-26 09:54:31 -0700 | [diff] [blame] | 369 | parser = ArgumentParser(description='Cord Tester') |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 370 | subparser = parser.add_subparsers() |
| 371 | parser_run = subparser.add_parser('run', help='Run cord tester') |
| 372 | parser_run.add_argument('-t', '--test-type', default=test_type_default, help='Specify test type or test case to run') |
| 373 | parser_run.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image') |
| 374 | parser_run.add_argument('-r', '--radius',action='store_true', help='Start Radius service') |
| 375 | parser_run.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter') |
| 376 | parser_run.add_argument('-a', '--app', default=onos_app_file, type=str, help='Cord ONOS app filename') |
| 377 | parser_run.add_argument('-p', '--olt', action='store_true', help='Use OLT config') |
| 378 | parser_run.add_argument('-e', '--test-controller', default='', type=str, help='External test controller ip for Onos and/or radius server. ' |
Chetan Gaonker | 5209fe8 | 2016-04-19 10:09:53 -0700 | [diff] [blame] | 379 | 'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip to connect') |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 380 | parser_run.add_argument('-k', '--keep', action='store_true', help='Keep test container after tests') |
| 381 | parser_run.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config') |
| 382 | parser_run.add_argument('-u', '--update', default='none', choices=['test','quagga','radius', 'all'], type=str, help='Update cord tester container images. ' |
| 383 | 'Eg: --update=quagga to rebuild quagga image.' |
| 384 | ' --update=radius to rebuild radius server image.' |
| 385 | ' --update=test to rebuild cord test image.(Default)' |
| 386 | ' --update=all to rebuild all cord tester images.') |
A R Karthick | 1f03e91 | 2016-05-18 11:39:22 -0700 | [diff] [blame] | 387 | parser_run.add_argument('-n', '--num-containers', default=1, type=int, |
| 388 | help='Specify number of test containers to spawn for tests') |
Chetan Gaonker | 503032a | 2016-05-12 12:06:29 -0700 | [diff] [blame] | 389 | parser_run.set_defaults(func=runTest) |
| 390 | |
| 391 | parser_list = subparser.add_parser('list', help='List test cases') |
| 392 | parser_list.add_argument('-t', '--test', default='all', help='Specify test type to list test cases. ' |
| 393 | 'Eg: -t tls to list tls test cases.' |
| 394 | ' -t tls-dhcp-vrouter to list tls,dhcp and vrouter test cases.' |
| 395 | ' -t all to list all test cases.') |
| 396 | parser_list.set_defaults(func=listTests) |
| 397 | |
| 398 | parser_build = subparser.add_parser('build', help='Build cord test container images') |
| 399 | parser_build.add_argument('image', choices=['quagga', 'radius', 'test', 'all']) |
| 400 | parser_build.set_defaults(func=buildImages) |
| 401 | |
| 402 | parser_cleanup = subparser.add_parser('cleanup', help='Cleanup test containers') |
| 403 | parser_cleanup.set_defaults(func=cleanupTests) |
| 404 | |
Chetan Gaonker | 93e302d | 2016-04-05 10:51:07 -0700 | [diff] [blame] | 405 | args = parser.parse_args() |
| 406 | args.func(args) |