blob: 3cba9f943715a423ee46f70fbab96666802506de [file] [log] [blame]
Chetan Gaonkercb122cc2016-05-10 10:58:34 -07001#!/usr/bin/env python
A.R Karthick95d044e2016-06-10 18:44:36 -07002#
Chetan Gaonkercfcce782016-05-10 10:10:42 -07003# 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
A.R Karthick95d044e2016-06-10 18:44:36 -07008#
Chetan Gaonkercfcce782016-05-10 10:10:42 -07009# http://www.apache.org/licenses/LICENSE-2.0
A.R Karthick95d044e2016-06-10 18:44:36 -070010#
Chetan Gaonkercfcce782016-05-10 10:10:42 -070011# 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 Gaonker93e302d2016-04-05 10:51:07 -070017from argparse import ArgumentParser
A R Karthick14118c62016-07-27 14:54:04 -070018import os,sys,time,socket,errno
ChetanGaonkereadad482016-08-26 01:21:47 -070019import shutil, platform, re
Chetan Gaonker4d842ad2016-04-26 10:04:24 -070020utils_dir = os.path.join( os.path.dirname(os.path.realpath(__file__)), '../utils')
Chetan Gaonker7142a342016-04-07 14:53:12 -070021sys.path.append(utils_dir)
ChetanGaonker68a047f2016-10-12 10:31:48 -070022sys.path.insert(1, '/usr/local/lib/python2.7/dist-packages')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070023from OnosCtrl import OnosCtrl
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070024from OltConfig import OltConfig
A R Karthick1f03e912016-05-18 11:39:22 -070025from threadPool import ThreadPool
Chetan Gaonker3533faa2016-04-25 17:50:14 -070026from CordContainer import *
A R Karthicke99ab5c2016-09-30 13:59:57 -070027from CordTestServer import cord_test_server_start,cord_test_server_stop,cord_test_server_shutdown,CORD_TEST_HOST,CORD_TEST_PORT
A R Karthick07608ef2016-08-23 16:51:19 -070028from TestManifest import TestManifest
ChetanGaonkereadad482016-08-26 01:21:47 -070029from docker import Client
30from docker.utils import kwargs_from_env
A R Karthickea8bfce2016-10-13 16:32:07 -070031from Xos import XosServiceProfile
A R Karthick07608ef2016-08-23 16:51:19 -070032try:
33 from Fabric import FabricMAAS
34except:
35 FabricMAAS = None
Chetan Gaonker93e302d2016-04-05 10:51:07 -070036
Chetan Gaonker93e302d2016-04-05 10:51:07 -070037class CordTester(Container):
Chetan Gaonker93e302d2016-04-05 10:51:07 -070038 sandbox = '/root/test'
Chetan Gaonker7142a342016-04-07 14:53:12 -070039 sandbox_setup = '/root/test/src/test/setup'
Chetan Gaonker4d842ad2016-04-26 10:04:24 -070040 tester_base = os.path.dirname(os.path.realpath(__file__))
41 tester_paths = os.path.realpath(__file__).split(os.path.sep)
A R Karthickb7e80902016-05-17 09:38:31 -070042 tester_path_index = tester_paths.index('src') - 1
Chetan Gaonker7142a342016-04-07 14:53:12 -070043 sandbox_host = os.path.sep.join(tester_paths[:tester_path_index+1])
Chetan Gaonker93e302d2016-04-05 10:51:07 -070044
45 host_guest_map = ( (sandbox_host, sandbox),
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070046 ('/lib/modules', '/lib/modules'),
47 ('/var/run/docker.sock', '/var/run/docker.sock')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070048 )
49 basename = 'cord-tester'
A R Karthick36cfcef2016-08-18 15:20:07 -070050 switch_on_olt = False
Chetan Gaonker503032a2016-05-12 12:06:29 -070051 IMAGE = 'cord-test/nose'
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -070052 ALL_TESTS = ('tls', 'dhcp', 'dhcprelay','igmp', 'subscriber',
53 'cordSubscriber', 'vrouter', 'flows', 'proxyarp', 'acl', 'xos', 'fabric',
Thangavelu K S7d5077f2016-12-09 22:33:15 +000054 'cbench', 'cluster', 'netCondition', 'cordvtn', 'iperf')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070055
A R Karthicka013a272016-08-16 16:40:19 -070056 def __init__(self, tests, instance = 0, num_instances = 1, ctlr_ip = None,
A R Karthick07608ef2016-08-23 16:51:19 -070057 name = '', image = IMAGE, prefix = '', tag = 'candidate',
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070058 env = None, rm = False, update = False):
A R Karthick1f03e912016-05-18 11:39:22 -070059 self.tests = tests
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070060 self.ctlr_ip = ctlr_ip
Chetan Gaonker93e302d2016-04-05 10:51:07 -070061 self.rm = rm
A R Karthicka013a272016-08-16 16:40:19 -070062 self.name = name or self.get_name()
A R Karthick07608ef2016-08-23 16:51:19 -070063 super(CordTester, self).__init__(self.name, image = image, prefix = prefix, tag = tag)
Chetan Gaonker93e302d2016-04-05 10:51:07 -070064 host_config = self.create_host_config(host_guest_map = self.host_guest_map, privileged = True)
65 volumes = []
Chetan Gaonkerb84835f2016-04-19 15:12:10 -070066 for _, g in self.host_guest_map:
Chetan Gaonker93e302d2016-04-05 10:51:07 -070067 volumes.append(g)
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070068 if update is True or not self.img_exists():
A R Karthick07608ef2016-08-23 16:51:19 -070069 self.build_image(self.image_name)
A R Karthicka013a272016-08-16 16:40:19 -070070 self.create = True
71 #check if are trying to run tests on existing container
72 if not name or not self.exists():
73 ##Remove test container if any
74 self.remove_container(self.name, force=True)
75 else:
76 self.create = False
A R Karthick078e63a2016-07-28 13:59:31 -070077 self.olt = False
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070078 if env is not None and env.has_key('OLT_CONFIG'):
79 self.olt = True
A R Karthick078e63a2016-07-28 13:59:31 -070080 olt_conf_file = os.path.join(self.tester_base, 'olt_config.json')
81 olt_config = OltConfig(olt_conf_file)
82 self.port_map, _ = olt_config.olt_port_map()
83 #Try using the host interface in olt conf to setup the switch
A.R Karthick88e80b92016-12-05 20:23:45 -080084 self.switches = self.port_map['switches']
A R Karthick1f03e912016-05-18 11:39:22 -070085 if env is not None:
A.R Karthick88e80b92016-12-05 20:23:45 -080086 env['TEST_SWITCH'] = self.switches[0]
87 env['TEST_SWITCHES'] = ','.join(self.switches)
A R Karthick1f03e912016-05-18 11:39:22 -070088 env['TEST_HOST'] = self.name
89 env['TEST_INSTANCE'] = instance
90 env['TEST_INSTANCES'] = num_instances
A R Karthicka013a272016-08-16 16:40:19 -070091 if self.create:
92 print('Starting test container %s, image %s, tag %s' %(self.name, self.image, self.tag))
93 self.start(rm = False, volumes = volumes, environment = env,
94 host_config = host_config, tty = True)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070095
A.R Karthicke4631062016-11-03 14:28:19 -070096 def execute_switch(self, cmd, shell = False):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070097 if self.olt:
98 return os.system(cmd)
99 return self.execute(cmd, shell = shell)
100
A R Karthick078e63a2016-07-28 13:59:31 -0700101 def start_switch(self, boot_delay = 2):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700102 """Start OVS"""
103 ##Determine if OVS has to be started locally or not
104 s_file,s_sandbox = ('of-bridge-local.sh',self.tester_base) if self.olt else ('of-bridge.sh',self.sandbox_setup)
A.R Karthick88e80b92016-12-05 20:23:45 -0800105 ovs_cmd = os.path.join(s_sandbox, s_file)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700106 if self.olt:
A R Karthick36cfcef2016-08-18 15:20:07 -0700107 if CordTester.switch_on_olt is True:
108 return
109 CordTester.switch_on_olt = True
A.R Karthick88e80b92016-12-05 20:23:45 -0800110 ovs_cmd += ' {} {}'.format(len(self.switches), self.ctlr_ip)
111 print('Starting OVS on the host with %d switches for controller: %s' %(len(self.switches), self.ctlr_ip))
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700112 else:
A.R Karthick88e80b92016-12-05 20:23:45 -0800113 ovs_cmd += ' {}'.format(self.switches[0])
114 print('Starting OVS on test container %s for controller: %s' %(self.name, self.ctlr_ip))
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700115 self.execute_switch(ovs_cmd)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700116 ## Wait for the LLDP flows to be added to the switch
A.R Karthick88e80b92016-12-05 20:23:45 -0800117 for switch in self.switches:
118 status = 1
119 tries = 0
120 while status != 0 and tries < 500:
121 cmd = 'sudo ovs-ofctl dump-flows {0} | grep \"type=0x8942\"'.format(switch)
122 status = self.execute_switch(cmd, shell = True)
123 tries += 1
124 if tries % 10 == 0:
125 print('Waiting for test switch %s to be connected to ONOS controller ...' %switch)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700126
A.R Karthick88e80b92016-12-05 20:23:45 -0800127 if status != 0:
128 print('Test Switch %s not connected to ONOS container.'
129 'Please remove ONOS container and restart the test' %switch)
130 if self.rm:
131 self.kill()
132 sys.exit(1)
133 else:
134 print('Test Switch %s connected to ONOS container.' %switch)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700135
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700136 if boot_delay:
137 time.sleep(boot_delay)
138
A R Karthick1f03e912016-05-18 11:39:22 -0700139 def setup_intfs(self, port_num = 0):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700140 tester_intf_subnet = '192.168.100'
141 res = 0
A.R Karthick88e80b92016-12-05 20:23:45 -0800142 switches = self.port_map['switches']
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700143 start_vlan = self.port_map['start_vlan']
A R Karthick07769362016-07-28 17:36:15 -0700144 start_vlan += port_num
145 uplink = self.port_map['uplink']
146 wan = self.port_map['wan']
A.R Karthick88e80b92016-12-05 20:23:45 -0800147 port_list = self.port_map['switch_port_list'] + self.port_map['switch_relay_port_list']
148 for host_intf, ports in port_list:
149 uplink = self.port_map[host_intf]['uplink']
150 for port in ports:
151 guest_if = port
A R Karthickca11f5c2017-01-11 18:01:50 -0800152 local_if = port #'{0}_{1}'.format(guest_if, port_num+1)
A.R Karthick88e80b92016-12-05 20:23:45 -0800153 guest_ip = '{0}.{1}/24'.format(tester_intf_subnet, port_num+1)
154 ##Use pipeworks to configure container interfaces on host/bridge interfaces
155 pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(host_intf, guest_if,
A R Karthick07769362016-07-28 17:36:15 -0700156 local_if, self.name, guest_ip)
A.R Karthick88e80b92016-12-05 20:23:45 -0800157 #if the wan interface is specified for uplink, then use it instead
158 if wan and port == self.port_map[uplink]:
159 pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(wan, guest_if,
160 local_if, self.name, guest_ip)
161 else:
162 if start_vlan != 0:
163 pipework_cmd += ' @{}'.format(start_vlan)
164 start_vlan += 1
165 #print('Running PIPEWORK cmd: %s' %pipework_cmd)
166 res += os.system(pipework_cmd)
167 port_num += 1
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700168
A R Karthick1f03e912016-05-18 11:39:22 -0700169 return res, port_num
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700170
171 @classmethod
A.R Karthick88e80b92016-12-05 20:23:45 -0800172 def get_intf_type(cls, intf):
173 intf_type = 0
174 if os.path.isdir('/sys/class/net/{}/bridge'.format(intf)):
175 intf_type = 1 ##linux bridge
176 else:
177 cmd = 'ovs-vsctl list-br | grep -q "^{0}$"'.format(intf)
178 res = os.system(cmd)
179 if res == 0: ##ovs bridge
180 intf_type = 2
181
182 return intf_type
183
184 @classmethod
A R Karthickb50f5592016-07-26 12:19:29 -0700185 def cleanup_intfs(cls):
186 olt_conf_file = os.path.join(cls.tester_base, 'olt_config.json')
187 olt_config = OltConfig(olt_conf_file)
A R Karthickb03cecd2016-07-27 10:27:55 -0700188 port_map, _ = olt_config.olt_port_map()
A R Karthickb50f5592016-07-26 12:19:29 -0700189 port_num = 0
A R Karthickb50f5592016-07-26 12:19:29 -0700190 start_vlan = port_map['start_vlan']
A R Karthick07769362016-07-28 17:36:15 -0700191 wan = port_map['wan']
A R Karthickb50f5592016-07-26 12:19:29 -0700192 cmds = ()
193 res = 0
A.R Karthick88e80b92016-12-05 20:23:45 -0800194 port_list = port_map['switch_port_list'] + port_map['switch_relay_port_list']
195 for intf_host, ports in port_list:
196 intf_type = cls.get_intf_type(intf_host)
197 for port in ports:
A R Karthickca11f5c2017-01-11 18:01:50 -0800198 local_if = port #'{0}_{1}'.format(port, port_num+1)
A.R Karthick88e80b92016-12-05 20:23:45 -0800199 if intf_type == 0:
200 if start_vlan != 0:
201 cmds = ('ip link del {}.{}'.format(intf_host, start_vlan),)
202 start_vlan += 1
A R Karthickb50f5592016-07-26 12:19:29 -0700203 else:
A.R Karthick88e80b92016-12-05 20:23:45 -0800204 if intf_type == 1:
205 cmds = ('brctl delif {} {}'.format(intf_host, local_if),
206 'ip link del {}'.format(local_if))
207 else:
208 cmds = ('ovs-vsctl del-port {} {}'.format(intf_host, local_if),
209 'ip link del {}'.format(local_if))
A R Karthickb50f5592016-07-26 12:19:29 -0700210
A.R Karthick88e80b92016-12-05 20:23:45 -0800211 for cmd in cmds:
212 res += os.system(cmd)
213 port_num += 1
A R Karthickb50f5592016-07-26 12:19:29 -0700214
215 @classmethod
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700216 def get_name(cls):
217 cnt_name = '/{0}'.format(cls.basename)
218 cnt_name_len = len(cnt_name)
219 names = list(flatten(n['Names'] for n in cls.dckr.containers(all=True)))
220 test_names = filter(lambda n: n.startswith(cnt_name), names)
221 last_cnt_number = 0
222 if test_names:
223 last_cnt_name = reduce(lambda n1, n2: n1 if int(n1[cnt_name_len:]) > \
224 int(n2[cnt_name_len:]) else n2,
225 test_names)
226 last_cnt_number = int(last_cnt_name[cnt_name_len:])
227 test_cnt_name = cls.basename + str(last_cnt_number+1)
228 return test_cnt_name
229
230 @classmethod
231 def build_image(cls, image):
232 print('Building test container docker image %s' %image)
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700233 ovs_version = '2.5.0'
234 image_format = (ovs_version,)*4
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700235 dockerfile = '''
236FROM ubuntu:14.04
237MAINTAINER chetan@ciena.com
A R Karthickc762df42016-05-25 10:09:21 -0700238RUN apt-get update && \
239 apt-get install -y git git-core autoconf automake autotools-dev pkg-config \
240 make gcc g++ libtool libc6-dev cmake libpcap-dev libxerces-c2-dev \
241 unzip libpcre3-dev flex bison libboost-dev \
242 python python-pip python-setuptools python-scapy tcpdump doxygen doxypy wget \
243 openvswitch-common openvswitch-switch \
A R Karthick07608ef2016-08-23 16:51:19 -0700244 python-twisted python-sqlite sqlite3 python-pexpect telnet arping isc-dhcp-server \
245 python-paramiko python-maas-client
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700246RUN easy_install nose
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700247RUN mkdir -p /root/ovs
248WORKDIR /root
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700249RUN wget http://openvswitch.org/releases/openvswitch-{}.tar.gz -O /root/ovs/openvswitch-{}.tar.gz && \
250(cd /root/ovs && tar zxpvf openvswitch-{}.tar.gz && \
251 cd openvswitch-{} && \
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700252 ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && make && make install)
253RUN service openvswitch-switch restart || /bin/true
A.R Karthickec5b72a2016-11-03 09:53:07 -0700254RUN pip install scapy==2.3.2 scapy-ssl_tls==1.2.2 monotonic configObj docker-py pyyaml nsenter pyroute2 netaddr python-daemon
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700255RUN mv /usr/sbin/tcpdump /sbin/
256RUN ln -sf /sbin/tcpdump /usr/sbin/tcpdump
A R Karthickf4999472016-07-01 16:42:13 -0700257RUN mv /usr/sbin/dhcpd /sbin/
258RUN ln -sf /sbin/dhcpd /usr/sbin/dhcpd
A R Karthickb7e80902016-05-17 09:38:31 -0700259WORKDIR /root
260RUN wget -nc http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/bison_2.5.dfsg-2.1_amd64.deb \
261 http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/libbison-dev_2.5.dfsg-2.1_amd64.deb
262RUN sudo dpkg -i bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb
263RUN rm bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb
264RUN wget -nc http://www.nbee.org/download/nbeesrc-jan-10-2013.zip && \
265 unzip nbeesrc-jan-10-2013.zip && \
266 cd nbeesrc-jan-10-2013/src && cmake . && make && \
267 cp ../bin/libn*.so /usr/local/lib && ldconfig && \
268 cp -R ../include/* /usr/include/
269WORKDIR /root
270RUN git clone https://github.com/CPqD/ofsoftswitch13.git && \
271 cd ofsoftswitch13 && \
A R Karthickb7e80902016-05-17 09:38:31 -0700272 ./boot.sh && \
273 ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && \
274 make && make install
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700275CMD ["/bin/bash"]
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700276'''.format(*image_format)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700277 super(CordTester, cls).build_image(dockerfile, image)
278 print('Done building docker image %s' %image)
279
A R Karthick1f03e912016-05-18 11:39:22 -0700280 def run_tests(self):
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700281 '''Run the list of tests'''
A R Karthick9a5edc42016-08-24 19:10:22 -0700282 res = 0
Thangavelu K Sef6f0a52016-12-14 19:57:05 +0000283 print('Modifying scapy tool files before running a test: %s' %self.tests)
284 self.modify_scapy_files_for_specific_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700285 print('Running tests: %s' %self.tests)
286 for t in self.tests:
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700287 test = t.split(':')[0]
A R Karthick24f1de62016-05-12 15:16:38 -0700288 test_file = '{}Test.py'.format(test)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700289 if t.find(':') >= 0:
A R Karthick24f1de62016-05-12 15:16:38 -0700290 test_case = '{0}:{1}'.format(test_file, t.split(':')[1])
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700291 else:
292 test_case = test_file
Chetan Gaonker7142a342016-04-07 14:53:12 -0700293 cmd = 'nosetests -v {0}/src/test/{1}/{2}'.format(self.sandbox, test, test_case)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700294 status = self.execute(cmd, shell = True)
A R Karthick9a5edc42016-08-24 19:10:22 -0700295 if status > 255:
296 status = 1
297 res |= status
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700298 print('Test %s %s' %(test_case, 'Success' if status == 0 else 'Failure'))
299 print('Done running tests')
300 if self.rm:
301 print('Removing test container %s' %self.name)
302 self.kill(remove=True)
303
A R Karthick9a5edc42016-08-24 19:10:22 -0700304 return res
305
Thangavelu K Sef6f0a52016-12-14 19:57:05 +0000306 def modify_scapy_files_for_specific_tests(self):
307 name = self.name
308 container_cmd_exec = Container(name = name, image = 'cord-test/nose')
309 tty = False
310 dckr = Client()
311 cmd = 'cp test/src/test/scapy/fields.py /usr/local/lib/python2.7/dist-packages/scapy/fields.py '
312 i = container_cmd_exec.execute(cmd = cmd, tty= tty, stream = True)
313
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700314 @classmethod
315 def list_tests(cls, tests):
316 print('Listing test cases')
317 for test in tests:
A R Karthick24f1de62016-05-12 15:16:38 -0700318 test_file = '{}Test.py'.format(test)
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700319 cmd = 'nosetests -v --collect-only {0}/../{1}/{2}'.format(cls.tester_base, test, test_file)
320 os.system(cmd)
321
A R Karthicka013a272016-08-16 16:40:19 -0700322
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700323##default onos/radius/test container images and names
324onos_image_default='onosproject/onos:latest'
A R Karthick07608ef2016-08-23 16:51:19 -0700325nose_image_default= '{}:candidate'.format(CordTester.IMAGE)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700326test_type_default='dhcp'
A.R Karthick95d044e2016-06-10 18:44:36 -0700327onos_app_version = '2.0-SNAPSHOT'
Chetan Gaonker4d842ad2016-04-26 10:04:24 -0700328cord_tester_base = os.path.dirname(os.path.realpath(__file__))
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700329onos_app_file = os.path.abspath('{0}/../apps/ciena-cordigmp-'.format(cord_tester_base) + onos_app_version + '.oar')
A R Karthick81acbff2016-06-17 14:45:16 -0700330cord_test_server_address = '{}:{}'.format(CORD_TEST_HOST, CORD_TEST_PORT)
A R Karthick07608ef2016-08-23 16:51:19 -0700331identity_file_default = '/etc/maas/ansible/id_rsa'
A R Karthicke14fc022016-12-08 14:50:29 -0800332onos_log_level = 'INFO'
A R Karthick07608ef2016-08-23 16:51:19 -0700333
334##sets up the ssh key file for the test container
335def set_ssh_key_file(identity_file):
336 ssh_key_file = None
337 if os.access(identity_file, os.F_OK):
338 ##copy it to setup directory
339 identity_dest = os.path.join(CordTester.tester_base, 'id_rsa')
340 if os.path.abspath(identity_file) != identity_dest:
341 try:
342 shutil.copy(identity_file, identity_dest)
343 ssh_key_file = os.path.join(CordTester.sandbox_setup, 'id_rsa')
344 except: pass
345
346 return ssh_key_file
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700347
348def runTest(args):
Chetan Gaonker823cdc52016-05-09 15:51:23 -0700349 #Start the cord test tcp server
A R Karthick81acbff2016-06-17 14:45:16 -0700350 test_server_params = args.server.split(':')
351 test_host = test_server_params[0]
352 test_port = CORD_TEST_PORT
A R Karthick65d950d2016-12-19 19:41:55 -0800353 test_manifest = TestManifest(args = args)
A R Karthick81acbff2016-06-17 14:45:16 -0700354 if len(test_server_params) > 1:
355 test_port = int(test_server_params[1])
356 try:
357 test_server = cord_test_server_start(daemonize = False, cord_test_host = test_host, cord_test_port = test_port)
358 except:
359 ##Most likely a server instance is already running (daemonized earlier)
360 test_server = None
361
A R Karthick1f03e912016-05-18 11:39:22 -0700362 test_containers = []
363 #These tests end up restarting ONOS/quagga/radius
A R Karthick4e0c0912016-08-17 16:57:42 -0700364 tests_exempt = ('vrouter', 'cordSubscriber', 'proxyarp', 'dhcprelay')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700365 if args.test_type.lower() == 'all':
366 tests = CordTester.ALL_TESTS
Chetan Gaonker503032a2016-05-12 12:06:29 -0700367 args.quagga = True
368 else:
A R Karthickacae3b42016-05-12 15:27:24 -0700369 tests = args.test_type.split('-')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700370
A R Karthick1f03e912016-05-18 11:39:22 -0700371 tests_parallel = [ t for t in tests if t.split(':')[0] not in tests_exempt ]
372 tests_not_parallel = [ t for t in tests if t.split(':')[0] in tests_exempt ]
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700373 onos_cnt = {'tag':'latest'}
A R Karthick07608ef2016-08-23 16:51:19 -0700374 nose_cnt = {'image': CordTester.IMAGE, 'tag': 'candidate'}
Chetan Gaonker503032a2016-05-12 12:06:29 -0700375 update_map = { 'quagga' : False, 'test' : False, 'radius' : False }
376 update_map[args.update.lower()] = True
A.R Karthick95d044e2016-06-10 18:44:36 -0700377
Chetan Gaonker503032a2016-05-12 12:06:29 -0700378 if args.update.lower() == 'all':
379 for c in update_map.keys():
380 update_map[c] = True
A.R Karthick95d044e2016-06-10 18:44:36 -0700381
A R Karthick07608ef2016-08-23 16:51:19 -0700382 use_manifest = False
383 if args.manifest:
384 if os.access(args.manifest, os.F_OK):
385 ##copy it to setup directory
386 dest = os.path.join(CordTester.tester_base, 'manifest.json')
387 if os.path.abspath(args.manifest) != dest:
388 try:
389 shutil.copy(args.manifest, dest)
390 except: pass
A R Karthick65d950d2016-12-19 19:41:55 -0800391 test_manifest = TestManifest(manifest = dest)
A R Karthick07608ef2016-08-23 16:51:19 -0700392 use_manifest = True
393 else:
394 print('Unable to access test manifest: %s' %args.manifest)
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700395
A R Karthick65d950d2016-12-19 19:41:55 -0800396 onos_ip = test_manifest.onos_ip
397 radius_ip = test_manifest.radius_ip
398 head_node = test_manifest.head_node
399
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700400 #don't spawn onos if the user has specified external test controller with test interface config
401 if args.test_controller:
402 ips = args.test_controller.split('/')
403 onos_ip = ips[0]
404 if len(ips) > 1:
405 radius_ip = ips[1]
406 else:
407 radius_ip = None
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700408
A R Karthick65d950d2016-12-19 19:41:55 -0800409 Container.IMAGE_PREFIX = test_manifest.image_prefix
410 Onos.MAX_INSTANCES = test_manifest.onos_instances
411 cluster_mode = True if test_manifest.onos_instances > 1 else False
412 async_mode = cluster_mode and test_manifest.async_mode
413 existing_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == test_manifest.onos_image ]
414 setup_cluster = False if len(existing_list) == test_manifest.onos_instances else True
A.R Karthickc4e474d2016-12-12 15:24:57 -0800415 onos_ips = []
A R Karthick65d950d2016-12-19 19:41:55 -0800416 if cluster_mode is True and len(existing_list) > 1:
417 ##don't setup cluster config again
418 cluster_mode = False
A R Karthick07608ef2016-08-23 16:51:19 -0700419 if onos_ip is None:
A R Karthick65d950d2016-12-19 19:41:55 -0800420 image_names = test_manifest.onos_image.rsplit(':', 1)
A R Karthick07608ef2016-08-23 16:51:19 -0700421 onos_cnt['image'] = image_names[0]
422 if len(image_names) > 1:
423 if image_names[1].find('/') < 0:
424 onos_cnt['tag'] = image_names[1]
425 else:
426 #tag cannot have slashes
A R Karthick65d950d2016-12-19 19:41:55 -0800427 onos_cnt['image'] = test_manifest.onos_image
A R Karthick07608ef2016-08-23 16:51:19 -0700428
429 Onos.IMAGE = onos_cnt['image']
A R Karthick65d950d2016-12-19 19:41:55 -0800430 Onos.PREFIX = test_manifest.image_prefix
A R Karthick07608ef2016-08-23 16:51:19 -0700431 Onos.TAG = onos_cnt['tag']
A R Karthick65d950d2016-12-19 19:41:55 -0800432 data_volume = '{}-data'.format(Onos.NAME) if test_manifest.shared_volume else None
A R Karthick07608ef2016-08-23 16:51:19 -0700433 onos = Onos(image = Onos.IMAGE,
A.R Karthickc4e474d2016-12-12 15:24:57 -0800434 tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthicka2492c12016-12-16 10:31:51 -0800435 data_volume = data_volume, async = async_mode)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800436 if onos.running:
A R Karthick65d950d2016-12-19 19:41:55 -0800437 onos_ips.append(onos.ipaddr)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800438 else:
439 onos_ips.append(onos_ip)
440
A R Karthick65d950d2016-12-19 19:41:55 -0800441 num_onos_instances = test_manifest.onos_instances
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700442 if num_onos_instances > 1 and onos is not None:
443 onos_instances = []
444 onos_instances.append(onos)
445 for i in range(1, num_onos_instances):
446 name = '{}-{}'.format(Onos.NAME, i+1)
A R Karthick65d950d2016-12-19 19:41:55 -0800447 data_volume = '{}-data'.format(name) if test_manifest.shared_volume else None
A.R Karthickc4e474d2016-12-12 15:24:57 -0800448 quagga_config = Onos.get_quagga_config(i)
A R Karthickec2db322016-11-17 15:06:01 -0800449 onos = Onos(name = name, image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthick3b811152016-12-15 10:24:24 -0800450 data_volume = data_volume, async = async_mode,
A R Karthicka2492c12016-12-16 10:31:51 -0800451 quagga_config = quagga_config)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700452 onos_instances.append(onos)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800453 if onos.running:
454 onos_ips.append(onos.ipaddr)
A R Karthick65d950d2016-12-19 19:41:55 -0800455 if async_mode is True and cluster_mode is True:
A.R Karthickc4e474d2016-12-12 15:24:57 -0800456 Onos.start_cluster_async(onos_instances)
457 if not onos_ips:
458 for onos in onos_instances:
459 onos_ips.append(onos.ipaddr)
A R Karthick65d950d2016-12-19 19:41:55 -0800460 if cluster_mode is True:
461 try:
462 for ip in onos_ips:
463 print('Installing cord tester ONOS app %s in ONOS instance %s' %(args.app,ip))
464 OnosCtrl.install_app(args.app, onos_ip = ip)
465 except: pass
A R Karthick1ef70552016-11-17 17:33:36 -0800466 if setup_cluster is True:
467 Onos.setup_cluster(onos_instances)
468 else:
469 print('ONOS instances already running. Skipping ONOS form cluster for %d instances' %num_onos_instances)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700470 ctlr_addr = ','.join(onos_ips)
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700471
A R Karthick65d950d2016-12-19 19:41:55 -0800472 print('Controller IP %s, Test type %s' %(onos_ips, args.test_type))
473 if onos_ip is not None:
A R Karthickbd9b8a32016-07-21 09:56:45 -0700474 print('Installing ONOS cord apps')
A R Karthick07608ef2016-08-23 16:51:19 -0700475 try:
476 Onos.install_cord_apps(onos_ip = onos_ip)
477 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700478
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700479 if not cluster_mode:
480 print('Installing cord tester ONOS app %s' %args.app)
481 try:
482 for ip in onos_ips:
A R Karthick65d950d2016-12-19 19:41:55 -0800483 OnosCtrl.install_app(args.app, onos_ip = ip)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700484 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700485
486 if radius_ip is None:
A R Karthicka661b552016-05-25 10:18:50 -0700487 ##Start Radius container
A R Karthick07608ef2016-08-23 16:51:19 -0700488 radius = Radius(prefix = Container.IMAGE_PREFIX, update = update_map['radius'])
A R Karthicka661b552016-05-25 10:18:50 -0700489 radius_ip = radius.ip()
A.R Karthick95d044e2016-06-10 18:44:36 -0700490
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700491 print('Radius server running with IP %s' %radius_ip)
A.R Karthick95d044e2016-06-10 18:44:36 -0700492
Chetan Gaonkerb84835f2016-04-19 15:12:10 -0700493 if args.quagga == True:
494 #Start quagga. Builds container if required
A R Karthick07608ef2016-08-23 16:51:19 -0700495 quagga = Quagga(prefix = Container.IMAGE_PREFIX, update = update_map['quagga'])
A R Karthick81acbff2016-06-17 14:45:16 -0700496
A R Karthick07608ef2016-08-23 16:51:19 -0700497 try:
498 maas_api_key = FabricMAAS.get_api_key()
499 except:
500 maas_api_key = 'UNKNOWN'
501
502 ssh_key_file = set_ssh_key_file(args.identity_file)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700503 test_cnt_env = { 'ONOS_CONTROLLER_IP' : ctlr_addr,
Chetan Gaonkerc170f3f2016-04-19 17:24:45 -0700504 'ONOS_AAA_IP' : radius_ip if radius_ip is not None else '',
A R Karthick8d03cc52016-06-28 14:51:59 -0700505 'QUAGGA_IP': test_host,
A R Karthick81acbff2016-06-17 14:45:16 -0700506 'CORD_TEST_HOST' : test_host,
507 'CORD_TEST_PORT' : test_port,
A R Karthick65d950d2016-12-19 19:41:55 -0800508 'ONOS_RESTART' : 0 if test_manifest.olt and args.test_controller else 1,
509 'LOG_LEVEL': test_manifest.log_level,
A R Karthick07608ef2016-08-23 16:51:19 -0700510 'MANIFEST': int(use_manifest),
511 'HEAD_NODE': head_node if head_node else CORD_TEST_HOST,
512 'MAAS_API_KEY': maas_api_key
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700513 }
A R Karthick07608ef2016-08-23 16:51:19 -0700514
515 if ssh_key_file:
516 test_cnt_env['SSH_KEY_FILE'] = ssh_key_file
517
A R Karthick65d950d2016-12-19 19:41:55 -0800518 if test_manifest.olt:
Chetan Gaonker7142a342016-04-07 14:53:12 -0700519 olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, 'olt_config.json')
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700520 test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
521
A R Karthicka013a272016-08-16 16:40:19 -0700522 if args.num_containers > 1 and args.container:
523 print('Cannot specify number of containers with container option')
524 sys.exit(1)
525 if args.container:
526 args.keep = True
A R Karthick1f03e912016-05-18 11:39:22 -0700527 port_num = 0
528 num_tests = len(tests_parallel)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700529 if num_tests > 0 and num_tests < args.num_containers:
530 tests_parallel *= args.num_containers/num_tests
531 num_tests = len(tests_parallel)
A R Karthick1f03e912016-05-18 11:39:22 -0700532 tests_per_container = max(1, num_tests/args.num_containers)
533 test_slice_start = 0
534 test_slice_end = test_slice_start + tests_per_container
535 num_test_containers = min(num_tests, args.num_containers)
536 if tests_parallel:
537 print('Running %s tests across %d containers in parallel' %(tests_parallel, num_test_containers))
538 for container in range(num_test_containers):
539 test_cnt = CordTester(tests_parallel[test_slice_start:test_slice_end],
540 instance = container, num_instances = num_test_containers,
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700541 ctlr_ip = ctlr_addr,
A R Karthick07608ef2016-08-23 16:51:19 -0700542 name = args.container,
543 image = nose_cnt['image'],
544 prefix = Container.IMAGE_PREFIX,
545 tag = nose_cnt['tag'],
A R Karthick1f03e912016-05-18 11:39:22 -0700546 env = test_cnt_env,
547 rm = False if args.keep else True,
548 update = update_map['test'])
549 test_slice_start = test_slice_end
550 test_slice_end = test_slice_start + tests_per_container
551 update_map['test'] = False
552 test_containers.append(test_cnt)
A R Karthicka013a272016-08-16 16:40:19 -0700553 if not test_cnt.create:
554 continue
A R Karthick65d950d2016-12-19 19:41:55 -0800555 if test_cnt.create and (test_manifest.start_switch or not test_manifest.olt):
A R Karthick07608ef2016-08-23 16:51:19 -0700556 if not args.no_switch:
557 test_cnt.start_switch()
A R Karthicka013a272016-08-16 16:40:19 -0700558 if test_cnt.create and test_cnt.olt:
A R Karthick1f03e912016-05-18 11:39:22 -0700559 _, port_num = test_cnt.setup_intfs(port_num = port_num)
560
A R Karthick9a5edc42016-08-24 19:10:22 -0700561 status = 0
562 if len(test_containers) > 1:
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700563 if True:
564 status = test_containers[0].run_tests()
565 else:
566 thread_pool = ThreadPool(len(test_containers), queue_size = 1, wait_timeout=1)
567 for test_cnt in test_containers:
568 thread_pool.addTask(test_cnt.run_tests)
569 thread_pool.cleanUpThreads()
A R Karthick9a5edc42016-08-24 19:10:22 -0700570 else:
A R Karthickcee37412016-08-29 10:10:56 -0700571 if test_containers:
572 status = test_containers[0].run_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700573
574 ##Run the linear tests
575 if tests_not_parallel:
576 test_cnt = CordTester(tests_not_parallel,
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700577 ctlr_ip = ctlr_addr,
A R Karthick07608ef2016-08-23 16:51:19 -0700578 name = args.container,
579 image = nose_cnt['image'],
580 prefix = Container.IMAGE_PREFIX,
581 tag = nose_cnt['tag'],
A R Karthick1f03e912016-05-18 11:39:22 -0700582 env = test_cnt_env,
583 rm = False if args.keep else True,
584 update = update_map['test'])
A R Karthick65d950d2016-12-19 19:41:55 -0800585 if test_cnt.create and (test_manifest.start_switch or not test_manifest.olt):
A R Karthick36cfcef2016-08-18 15:20:07 -0700586 #For non parallel tests, we just restart the switch also for OLT's
587 CordTester.switch_on_olt = False
A R Karthick07608ef2016-08-23 16:51:19 -0700588 if not args.no_switch:
589 test_cnt.start_switch()
A R Karthicka013a272016-08-16 16:40:19 -0700590 if test_cnt.create and test_cnt.olt:
A R Karthick1f03e912016-05-18 11:39:22 -0700591 test_cnt.setup_intfs(port_num = port_num)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700592 test_cnt.run_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700593
A R Karthick81acbff2016-06-17 14:45:16 -0700594 if test_server:
595 cord_test_server_stop(test_server)
596
A R Karthick9a5edc42016-08-24 19:10:22 -0700597 return status
598
A R Karthick81acbff2016-06-17 14:45:16 -0700599##Starts onos/radius/quagga containers as appropriate
600def setupCordTester(args):
601 onos_cnt = {'tag':'latest'}
A R Karthick07608ef2016-08-23 16:51:19 -0700602 nose_cnt = {'image': CordTester.IMAGE, 'tag': 'candidate'}
A R Karthick92a0e5a2016-06-22 17:11:05 -0700603 update_map = { 'quagga' : False, 'radius' : False, 'test': False }
A R Karthick81acbff2016-06-17 14:45:16 -0700604 update_map[args.update.lower()] = True
A R Karthick65d950d2016-12-19 19:41:55 -0800605 test_manifest = TestManifest(args = args)
606
A R Karthick81acbff2016-06-17 14:45:16 -0700607 if args.update.lower() == 'all':
608 for c in update_map.keys():
609 update_map[c] = True
610
A R Karthickd44cea12016-07-20 12:16:41 -0700611 onos_cord_loc = args.onos_cord
612 if onos_cord_loc:
613 if onos_cord_loc.find(os.path.sep) < 0:
614 onos_cord_loc = os.path.join(os.getenv('HOME'), onos_cord_loc)
615 if not os.access(onos_cord_loc, os.F_OK):
616 print('ONOS cord config location %s is not accessible' %onos_cord_loc)
617 sys.exit(1)
618 #Disable test container provisioning on the ONOS compute node
619 args.dont_provision = True
A R Karthick81acbff2016-06-17 14:45:16 -0700620
A R Karthick07608ef2016-08-23 16:51:19 -0700621 use_manifest = False
622 if args.manifest:
623 if os.access(args.manifest, os.F_OK):
624 ##copy it to setup directory
625 dest = os.path.join(CordTester.tester_base, 'manifest.json')
626 if os.path.abspath(args.manifest) != dest:
627 try:
628 shutil.copy(args.manifest, dest)
629 except: pass
A R Karthick65d950d2016-12-19 19:41:55 -0800630 test_manifest = TestManifest(manifest = dest)
A R Karthick07608ef2016-08-23 16:51:19 -0700631 use_manifest = True
632
A R Karthick65d950d2016-12-19 19:41:55 -0800633 onos_ip = test_manifest.onos_ip
634 radius_ip = test_manifest.radius_ip
635 head_node = test_manifest.head_node
A R Karthick81acbff2016-06-17 14:45:16 -0700636 ##If onos/radius was already started
637 if args.test_controller:
638 ips = args.test_controller.split('/')
639 onos_ip = ips[0]
640 if len(ips) > 1:
641 radius_ip = ips[1]
642 else:
643 radius_ip = None
644
A R Karthickd44cea12016-07-20 12:16:41 -0700645 onos_cord = None
646 if onos_cord_loc:
647 if not args.test_controller:
648 ##Unexpected case. Specify the external controller ip when running on cord node
649 print('Specify ONOS ip using \"-e\" option when running the cord-tester on cord node')
650 sys.exit(1)
A R Karthickbd9b8a32016-07-21 09:56:45 -0700651 onos_cord = OnosCord(onos_ip, onos_cord_loc)
A R Karthickd44cea12016-07-20 12:16:41 -0700652
A R Karthick65d950d2016-12-19 19:41:55 -0800653 Container.IMAGE_PREFIX = test_manifest.image_prefix
A R Karthick81acbff2016-06-17 14:45:16 -0700654 #don't spawn onos if the user had started it externally
A R Karthick65d950d2016-12-19 19:41:55 -0800655 image_names = test_manifest.onos_image.rsplit(':', 1)
A R Karthick07608ef2016-08-23 16:51:19 -0700656 onos_cnt['image'] = image_names[0]
657 if len(image_names) > 1:
658 if image_names[1].find('/') < 0:
659 onos_cnt['tag'] = image_names[1]
660 else:
661 #tag cannot have slashes
A R Karthick65d950d2016-12-19 19:41:55 -0800662 onos_cnt['image'] = test_manifest.onos_image
A R Karthick81acbff2016-06-17 14:45:16 -0700663
A R Karthick07608ef2016-08-23 16:51:19 -0700664 Onos.IMAGE = onos_cnt['image']
A R Karthick65d950d2016-12-19 19:41:55 -0800665 Onos.PREFIX = test_manifest.image_prefix
A R Karthick07608ef2016-08-23 16:51:19 -0700666 Onos.TAG = onos_cnt['tag']
A R Karthick65d950d2016-12-19 19:41:55 -0800667 Onos.MAX_INSTANCES = test_manifest.onos_instances
668 cluster_mode = True if test_manifest.onos_instances > 1 else False
669 async_mode = cluster_mode and test_manifest.async_mode
670 existing_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == test_manifest.onos_image ]
671 setup_cluster = False if len(existing_list) == test_manifest.onos_instances else True
A R Karthickc41c2422016-12-09 10:59:19 -0800672 #cleanup existing volumes before forming a new cluster
673 if setup_cluster is True:
674 print('Cleaning up existing cluster volumes')
675 data_dir = os.path.join(Onos.setup_dir, 'cord-onos*-data')
676 try:
677 os.system('rm -rf {}'.format(data_dir))
678 except: pass
679
A R Karthick2b93d6a2016-09-06 15:19:09 -0700680 onos = None
A.R Karthickc4e474d2016-12-12 15:24:57 -0800681 onos_ips = []
A R Karthick81acbff2016-06-17 14:45:16 -0700682 if onos_ip is None:
A R Karthick65d950d2016-12-19 19:41:55 -0800683 data_volume = '{}-data'.format(Onos.NAME) if test_manifest.shared_volume else None
A R Karthickec2db322016-11-17 15:06:01 -0800684 onos = Onos(image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthicka2492c12016-12-16 10:31:51 -0800685 data_volume = data_volume, async = async_mode)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800686 if onos.running:
A R Karthick65d950d2016-12-19 19:41:55 -0800687 onos_ips.append(onos.ipaddr)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800688 else:
689 onos_ips.append(onos_ip)
A R Karthick81acbff2016-06-17 14:45:16 -0700690
A R Karthick65d950d2016-12-19 19:41:55 -0800691 num_onos_instances = test_manifest.onos_instances
A R Karthick2b93d6a2016-09-06 15:19:09 -0700692 if num_onos_instances > 1 and onos is not None:
693 onos_instances = []
694 onos_instances.append(onos)
695 for i in range(1, num_onos_instances):
696 name = '{}-{}'.format(Onos.NAME, i+1)
A R Karthick65d950d2016-12-19 19:41:55 -0800697 data_volume = '{}-data'.format(name) if test_manifest.shared_volume else None
A.R Karthickc4e474d2016-12-12 15:24:57 -0800698 quagga_config = Onos.get_quagga_config(i)
A R Karthickec2db322016-11-17 15:06:01 -0800699 onos = Onos(name = name, image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthick3b811152016-12-15 10:24:24 -0800700 data_volume = data_volume, async = async_mode,
A R Karthicka2492c12016-12-16 10:31:51 -0800701 quagga_config = quagga_config)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700702 onos_instances.append(onos)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800703 if onos.running:
704 onos_ips.append(onos.ipaddr)
705 if async_mode is True:
706 Onos.start_cluster_async(onos_instances)
707 if not onos_ips:
708 for onos in onos_instances:
709 onos_ips.append(onos.ipaddr)
A R Karthick51e6fd82016-11-22 14:39:19 -0800710 if setup_cluster is True:
711 Onos.setup_cluster(onos_instances)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700712
713 ctlr_addr = ','.join(onos_ips)
714 print('Onos IP %s' %ctlr_addr)
A R Karthick65d950d2016-12-19 19:41:55 -0800715 if onos_ip is not None:
A R Karthickbd9b8a32016-07-21 09:56:45 -0700716 print('Installing ONOS cord apps')
A R Karthick07608ef2016-08-23 16:51:19 -0700717 try:
718 Onos.install_cord_apps(onos_ip = onos_ip)
719 except: pass
A R Karthickbd9b8a32016-07-21 09:56:45 -0700720
A R Karthickedab01c2016-09-08 14:05:44 -0700721 print('Installing cord tester ONOS app %s' %args.app)
A R Karthick07608ef2016-08-23 16:51:19 -0700722 try:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700723 for ip in onos_ips:
724 OnosCtrl.install_app(args.app, onos_ip = ip)
A R Karthick07608ef2016-08-23 16:51:19 -0700725 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700726
A R Karthick81acbff2016-06-17 14:45:16 -0700727 ##Start Radius container if not started
728 if radius_ip is None:
A R Karthick07608ef2016-08-23 16:51:19 -0700729 radius = Radius(prefix = Container.IMAGE_PREFIX, update = update_map['radius'])
A R Karthick81acbff2016-06-17 14:45:16 -0700730 radius_ip = radius.ip()
731
732 print('Radius server running with IP %s' %radius_ip)
A R Karthick81acbff2016-06-17 14:45:16 -0700733
734 if args.quagga == True:
735 #Start quagga. Builds container if required
A R Karthick07608ef2016-08-23 16:51:19 -0700736 quagga = Quagga(prefix = Container.IMAGE_PREFIX, update = update_map['quagga'])
A R Karthick8d03cc52016-06-28 14:51:59 -0700737 print('Quagga started')
A R Karthick81acbff2016-06-17 14:45:16 -0700738
A R Karthick81acbff2016-06-17 14:45:16 -0700739 params = args.server.split(':')
740 ip = params[0]
741 port = CORD_TEST_PORT
742 if len(params) > 1:
743 port = int(params[1])
A R Karthick92a0e5a2016-06-22 17:11:05 -0700744
A R Karthick07608ef2016-08-23 16:51:19 -0700745 try:
746 maas_api_key = FabricMAAS.get_api_key()
747 except:
748 maas_api_key = 'UNKNOWN'
749
750 ssh_key_file = set_ssh_key_file(args.identity_file)
751
A R Karthick92a0e5a2016-06-22 17:11:05 -0700752 #provision the test container
753 if not args.dont_provision:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700754 test_cnt_env = { 'ONOS_CONTROLLER_IP' : ctlr_addr,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700755 'ONOS_AAA_IP' : radius_ip,
A R Karthick8d03cc52016-06-28 14:51:59 -0700756 'QUAGGA_IP': ip,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700757 'CORD_TEST_HOST' : ip,
758 'CORD_TEST_PORT' : port,
A R Karthick65d950d2016-12-19 19:41:55 -0800759 'ONOS_RESTART' : 0 if test_manifest.olt and args.test_controller else 1,
760 'LOG_LEVEL': test_manifest.log_level,
A R Karthick07608ef2016-08-23 16:51:19 -0700761 'MANIFEST': int(use_manifest),
762 'HEAD_NODE': head_node if head_node else CORD_TEST_HOST,
763 'MAAS_API_KEY': maas_api_key
A R Karthick92a0e5a2016-06-22 17:11:05 -0700764 }
A R Karthick07608ef2016-08-23 16:51:19 -0700765
766 if ssh_key_file:
767 test_cnt_env['SSH_KEY_FILE'] = ssh_key_file
A R Karthick65d950d2016-12-19 19:41:55 -0800768 if test_manifest.olt:
A R Karthick92a0e5a2016-06-22 17:11:05 -0700769 olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, 'olt_config.json')
770 test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
771
772 test_cnt = CordTester((),
A R Karthick2b93d6a2016-09-06 15:19:09 -0700773 ctlr_ip = ctlr_addr,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700774 image = nose_cnt['image'],
A R Karthick07608ef2016-08-23 16:51:19 -0700775 prefix = Container.IMAGE_PREFIX,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700776 tag = nose_cnt['tag'],
777 env = test_cnt_env,
778 rm = False,
779 update = update_map['test'])
780
A R Karthick65d950d2016-12-19 19:41:55 -0800781 if test_manifest.start_switch or not test_manifest.olt:
A R Karthick92a0e5a2016-06-22 17:11:05 -0700782 test_cnt.start_switch()
783 if test_cnt.olt:
784 test_cnt.setup_intfs(port_num = 0)
785 print('Test container %s started and provisioned to run tests using nosetests' %(test_cnt.name))
786
787 #Finally start the test server and daemonize
A R Karthick14118c62016-07-27 14:54:04 -0700788 try:
A R Karthickbd82f362016-11-10 15:08:52 -0800789 cord_test_server_start(daemonize = not args.foreground, cord_test_host = ip, cord_test_port = port,
790 onos_cord = onos_cord, foreground = args.foreground)
A R Karthick14118c62016-07-27 14:54:04 -0700791 except socket.error, e:
792 #the test agent address could be remote or already running. Exit gracefully
793 sys.exit(0)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700794
A R Karthick9a5edc42016-08-24 19:10:22 -0700795 return 0
796
Chetan Gaonker503032a2016-05-12 12:06:29 -0700797def cleanupTests(args):
A R Karthick757eb4d2017-01-09 14:51:16 -0800798 if args.manifest and os.access(args.manifest, os.F_OK):
799 manifest = TestManifest(manifest = args.manifest)
800 args.prefix = manifest.image_prefix
801 args.olt = manifest.olt
802 args.onos = manifest.onos_image
803 args.server = manifest.server
804
A R Karthick2b93d6a2016-09-06 15:19:09 -0700805 image_name = args.onos
A R Karthick07608ef2016-08-23 16:51:19 -0700806 prefix = args.prefix
807 if prefix:
808 prefix += '/'
809 test_container = '{}{}:candidate'.format(prefix, CordTester.IMAGE)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700810 print('Cleaning up Test containers ...')
811 Container.cleanup(test_container)
A R Karthickb50f5592016-07-26 12:19:29 -0700812 if args.olt:
813 print('Cleaning up test container OLT configuration')
814 CordTester.cleanup_intfs()
A R Karthick2b93d6a2016-09-06 15:19:09 -0700815
816 onos_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == image_name ]
817 if len(onos_list) > 1:
818 for onos in onos_list:
819 Container.dckr.kill(onos)
820 Container.dckr.remove_container(onos, force=True)
A R Karthickec2db322016-11-17 15:06:01 -0800821 for index in range(len(onos_list)):
822 volume = '{}-data'.format(Onos.NAME) if index == 0 else '{}-{}-data'.format(Onos.NAME, index+1)
823 Onos.remove_data_map(volume, Onos.guest_data_dir)
A R Karthick9d48c652016-09-15 09:16:36 -0700824 Onos.cleanup_runtime()
A R Karthickec2db322016-11-17 15:06:01 -0800825
A.R Karthick842f0122016-09-28 14:48:47 -0700826 if args.xos:
827 ##cleanup XOS images
828 xos_images = ( '{}:{}'.format(XosServer.IMAGE,XosServer.TAG),
829 '{}:{}'.format(XosSynchronizerOpenstack.IMAGE,
830 XosSynchronizerOpenstack.TAG),
831 '{}:{}'.format(XosSynchronizerOnboarding.IMAGE,
832 XosSynchronizerOnboarding.TAG),
833 '{}:{}'.format(XosSynchronizerOpenvpn.IMAGE,
834 XosSynchronizerOpenvpn.TAG),
835 '{}:{}'.format(XosPostgresql.IMAGE,
836 XosPostgresql.TAG),
837 '{}:{}'.format(XosSyndicateMs.IMAGE,
838 XosSyndicateMs.TAG),
839 )
840 for img in xos_images:
841 print('Cleaning up XOS image: %s' %img)
842 Container.cleanup(img)
843
A R Karthicke99ab5c2016-09-30 13:59:57 -0700844 server_params = args.server.split(':')
845 server_host = server_params[0]
846 server_port = CORD_TEST_PORT
847 if len(server_params) > 1:
848 server_port = int(server_params[1])
849 cord_test_server_shutdown(server_host, server_port)
A R Karthick9a5edc42016-08-24 19:10:22 -0700850 return 0
Chetan Gaonker503032a2016-05-12 12:06:29 -0700851
852def listTests(args):
853 if args.test == 'all':
854 tests = CordTester.ALL_TESTS
855 else:
A R Karthickacae3b42016-05-12 15:27:24 -0700856 tests = args.test.split('-')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700857 CordTester.list_tests(tests)
A R Karthickcee37412016-08-29 10:10:56 -0700858 return 0
ChetanGaonkereadad482016-08-26 01:21:47 -0700859
860def getMetrics(args):
A R Karthickcee37412016-08-29 10:10:56 -0700861 try:
862 detail = c.inspect_container(args.container)
863 except:
864 print('Unknown container %s' %args.container)
865 return 0
866 user_hz = os.sysconf(os.sysconf_names['SC_CLK_TCK'])
ChetanGaonkereadad482016-08-26 01:21:47 -0700867 state = detail["State"]
868 if bool(state["Paused"]):
869 print("Container is in Paused State")
870 elif bool(state["Running"]):
871 print("Container is in Running State")
872 elif int(state["ExitCode"]) == 0:
873 print("Container is in Stopped State")
874 else:
875 print("Container is in Crashed State")
876
A R Karthickcee37412016-08-29 10:10:56 -0700877 print("Ip Address of the container: " +detail['NetworkSettings']['IPAddress'])
ChetanGaonkereadad482016-08-26 01:21:47 -0700878
879 if bool(detail["State"]["Running"]):
880 container_id = detail['Id']
881 cpu_usage = {}
A R Karthickcee37412016-08-29 10:10:56 -0700882 cur_usage = 0
883 last_usage = 0
884 for i in range(2):
885 with open('/sys/fs/cgroup/cpuacct/docker/' + container_id + '/cpuacct.stat', 'r') as f:
886 for line in f:
887 m = re.search(r"(system|user)\s+(\d+)", line)
888 if m:
889 cpu_usage[m.group(1)] = int(m.group(2))
890 cpu = cpu_usage["system"] + cpu_usage["user"]
891 last_usage = cur_usage
892 cur_usage = cpu
893 time.sleep(1)
894 cpu_percent = (cur_usage - last_usage)*100.0/user_hz
895 print("CPU Usage: %.2f %%" %(cpu_percent))
ChetanGaonkereadad482016-08-26 01:21:47 -0700896 else:
897 print(0)
898
899 if bool(detail["State"]["Running"]):
900 container_id = detail['Id']
A R Karthickcee37412016-08-29 10:10:56 -0700901 print("Docker Port Info:")
ChetanGaonkereadad482016-08-26 01:21:47 -0700902 cmd = "sudo docker port {}".format(container_id)
903 os.system(cmd)
904
905 if bool(detail["State"]["Running"]):
906 container_id = detail['Id']
907 with open('/sys/fs/cgroup/memory/docker/' + container_id + '/memory.stat', 'r') as f:
908 for line in f:
909 m = re.search(r"total_rss\s+(\d+)", line)
910 if m:
A R Karthickcee37412016-08-29 10:10:56 -0700911 mem = int(m.group(1))
912 print("Memory: %s KB "%(mem/1024.0))
ChetanGaonkereadad482016-08-26 01:21:47 -0700913 o = re.search(r"usage\s+(\d+)", line)
914 if o:
A R Karthickcee37412016-08-29 10:10:56 -0700915 print("Usage: %s "%(o.group(1)))
ChetanGaonkereadad482016-08-26 01:21:47 -0700916 p = re.search(r"max_usage\s+(\d+)", line)
917 if p:
A R Karthickcee37412016-08-29 10:10:56 -0700918 print("Max Usage: %s "%(p.group(1)))
ChetanGaonkereadad482016-08-26 01:21:47 -0700919
920 if bool(detail["State"]["Running"]):
921 container_id = detail['Id']
922 with open('/sys/fs/cgroup/cpuacct/docker/' + container_id + '/cpuacct.stat', 'r') as f:
923 for line in f:
924 m = re.search(r"user\s+(\d+)", line)
925 if m:
A R Karthickcee37412016-08-29 10:10:56 -0700926 user_ticks = int(m.group(1))
927 print("Time spent by running processes: %.2f ms"%(user_ticks*1000.0/user_hz))
928 print("List Networks:")
ChetanGaonkereadad482016-08-26 01:21:47 -0700929 cmd = "docker network ls"
930 os.system(cmd)
A R Karthick9a5edc42016-08-24 19:10:22 -0700931 return 0
Chetan Gaonker503032a2016-05-12 12:06:29 -0700932
933def buildImages(args):
A R Karthick07608ef2016-08-23 16:51:19 -0700934 tag = 'candidate'
935 prefix = args.prefix
936 if prefix:
937 prefix += '/'
Chetan Gaonker503032a2016-05-12 12:06:29 -0700938 if args.image == 'all' or args.image == 'quagga':
A R Karthick07608ef2016-08-23 16:51:19 -0700939 image_name = '{}{}:{}'.format(prefix, Quagga.IMAGE, tag)
940 Quagga.build_image(image_name)
A.R Karthick95d044e2016-06-10 18:44:36 -0700941
Chetan Gaonker503032a2016-05-12 12:06:29 -0700942 if args.image == 'all' or args.image == 'radius':
A R Karthick07608ef2016-08-23 16:51:19 -0700943 image_name = '{}{}:{}'.format(prefix, Radius.IMAGE, tag)
944 Radius.build_image(image_name)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700945
946 if args.image == 'all' or args.image == 'test':
A R Karthick07608ef2016-08-23 16:51:19 -0700947 image_name = '{}{}:{}'.format(prefix, CordTester.IMAGE, tag)
948 CordTester.build_image(image_name)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700949
A R Karthick9a5edc42016-08-24 19:10:22 -0700950 return 0
951
A R Karthickbec27762016-07-28 10:59:34 -0700952def startImages(args):
A R Karthickbec27762016-07-28 10:59:34 -0700953 ##starts the latest ONOS image
A R Karthick07608ef2016-08-23 16:51:19 -0700954 onos_cnt = {'tag': 'latest'}
955 image_names = args.onos.rsplit(':', 1)
956 onos_cnt['image'] = image_names[0]
957 if len(image_names) > 1:
958 if image_names[1].find('/') < 0:
959 onos_cnt['tag'] = image_names[1]
960 else:
961 #tag cannot have slashes
962 onos_cnt['image'] = args.onos
963
A R Karthickbec27762016-07-28 10:59:34 -0700964 if args.image == 'all' or args.image == 'onos':
A R Karthick07608ef2016-08-23 16:51:19 -0700965 onos = Onos(image = onos_cnt['image'], tag = onos_cnt['tag'])
A R Karthickbec27762016-07-28 10:59:34 -0700966 print('ONOS started with ip %s' %(onos.ip()))
967
968 if args.image == 'all' or args.image == 'quagga':
A R Karthick07608ef2016-08-23 16:51:19 -0700969 quagga = Quagga(prefix = args.prefix)
A R Karthickbec27762016-07-28 10:59:34 -0700970 print('Quagga started with ip %s' %(quagga.ip()))
971
972 if args.image == 'all' or args.image == 'radius':
A R Karthick07608ef2016-08-23 16:51:19 -0700973 radius = Radius(prefix = args.prefix)
A R Karthickbec27762016-07-28 10:59:34 -0700974 print('Radius started with ip %s' %(radius.ip()))
975
A R Karthick9a5edc42016-08-24 19:10:22 -0700976 return 0
977
A R Karthickea8bfce2016-10-13 16:32:07 -0700978def xosCommand(args):
979 update = False
980 profile = args.profile
981 if args.command == 'update':
982 update = True
983 xos = XosServiceProfile(profile = profile, update = update)
984 if args.command == 'build':
985 xos.build_images(force = True)
986 if args.command == 'start':
987 xos.start_services()
988 if args.command == 'stop':
989 xos.stop_services(rm = True)
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700990 return 0
991
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700992if __name__ == '__main__':
Chetan Gaonker678743f2016-04-26 09:54:31 -0700993 parser = ArgumentParser(description='Cord Tester')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700994 subparser = parser.add_subparsers()
995 parser_run = subparser.add_parser('run', help='Run cord tester')
996 parser_run.add_argument('-t', '--test-type', default=test_type_default, help='Specify test type or test case to run')
997 parser_run.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700998 parser_run.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
999 parser_run.add_argument('-a', '--app', default=onos_app_file, type=str, help='Cord ONOS app filename')
A R Karthick07608ef2016-08-23 16:51:19 -07001000 parser_run.add_argument('-l', '--olt', action='store_true', help='Use OLT config')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001001 parser_run.add_argument('-e', '--test-controller', default='', type=str, help='External test controller ip for Onos and/or radius server. '
Chetan Gaonker5209fe82016-04-19 10:09:53 -07001002 'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip to connect')
A R Karthick81acbff2016-06-17 14:45:16 -07001003 parser_run.add_argument('-r', '--server', default=cord_test_server_address, type=str,
1004 help='ip:port address to connect for cord test server for container requests')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001005 parser_run.add_argument('-k', '--keep', action='store_true', help='Keep test container after tests')
1006 parser_run.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config')
1007 parser_run.add_argument('-u', '--update', default='none', choices=['test','quagga','radius', 'all'], type=str, help='Update cord tester container images. '
1008 'Eg: --update=quagga to rebuild quagga image.'
1009 ' --update=radius to rebuild radius server image.'
1010 ' --update=test to rebuild cord test image.(Default)'
1011 ' --update=all to rebuild all cord tester images.')
A R Karthick1f03e912016-05-18 11:39:22 -07001012 parser_run.add_argument('-n', '--num-containers', default=1, type=int,
1013 help='Specify number of test containers to spawn for tests')
A R Karthicka013a272016-08-16 16:40:19 -07001014 parser_run.add_argument('-c', '--container', default='', type=str, help='Test container name for running tests')
A R Karthick07608ef2016-08-23 16:51:19 -07001015 parser_run.add_argument('-m', '--manifest', default='', type=str, help='Provide test configuration manifest')
1016 parser_run.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1017 parser_run.add_argument('-d', '--no-switch', action='store_true', help='Dont start test switch.')
1018 parser_run.add_argument('-i', '--identity-file', default=identity_file_default,
1019 type=str, help='ssh identity file to access compute nodes from test container')
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -07001020 parser_run.add_argument('-j', '--onos-instances', default=1, type=int,
1021 help='Specify number to test onos instances to form cluster')
A R Karthick09dbc6d2016-11-22 10:37:42 -08001022 parser_run.add_argument('-v', '--shared-volume', action='store_true', help='Start ONOS cluster instances with shared volume')
A.R Karthickc4e474d2016-12-12 15:24:57 -08001023 parser_run.add_argument('-async', '--async-mode', action='store_true',
1024 help='Start ONOS cluster instances in async mode')
A R Karthicke14fc022016-12-08 14:50:29 -08001025 parser_run.add_argument('-log', '--log-level', default=onos_log_level,
1026 choices=['DEBUG','TRACE','ERROR','WARN','INFO'],
1027 type=str,
1028 help='Specify the log level for the test cases')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001029 parser_run.set_defaults(func=runTest)
1030
A R Karthick81acbff2016-06-17 14:45:16 -07001031
1032 parser_setup = subparser.add_parser('setup', help='Setup cord tester environment')
1033 parser_setup.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
1034 parser_setup.add_argument('-r', '--server', default=cord_test_server_address, type=str,
1035 help='ip:port address for cord test server to listen for container restart requests')
1036 parser_setup.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
1037 parser_setup.add_argument('-a', '--app', default=onos_app_file, type=str, help='Cord ONOS app filename')
1038 parser_setup.add_argument('-e', '--test-controller', default='', type=str, help='External test controller ip for Onos and/or radius server. '
1039 'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip to connect')
1040 parser_setup.add_argument('-u', '--update', default='none', choices=['quagga','radius', 'all'], type=str, help='Update cord tester container images. '
1041 'Eg: --update=quagga to rebuild quagga image.'
1042 ' --update=radius to rebuild radius server image.'
1043 ' --update=all to rebuild all cord tester images.')
A R Karthick92a0e5a2016-06-22 17:11:05 -07001044 parser_setup.add_argument('-d', '--dont-provision', action='store_true', help='Dont start test container.')
A R Karthick07608ef2016-08-23 16:51:19 -07001045 parser_setup.add_argument('-l', '--olt', action='store_true', help='Use OLT config')
A R Karthicke14fc022016-12-08 14:50:29 -08001046 parser_setup.add_argument('-log', '--log-level', default=onos_log_level, type=str,
1047 choices=['DEBUG','TRACE','ERROR','WARN','INFO'],
1048 help='Specify the log level for the test cases')
A R Karthick92a0e5a2016-06-22 17:11:05 -07001049 parser_setup.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config')
A R Karthickd44cea12016-07-20 12:16:41 -07001050 parser_setup.add_argument('-c', '--onos-cord', default='', type=str,
1051 help='Specify cord location for ONOS cord when running on podd')
A R Karthick07608ef2016-08-23 16:51:19 -07001052 parser_setup.add_argument('-m', '--manifest', default='', type=str, help='Provide test configuration manifest')
1053 parser_setup.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1054 parser_setup.add_argument('-i', '--identity-file', default=identity_file_default,
1055 type=str, help='ssh identity file to access compute nodes from test container')
A R Karthick2b93d6a2016-09-06 15:19:09 -07001056 parser_setup.add_argument('-n', '--onos-instances', default=1, type=int,
A R Karthickbd82f362016-11-10 15:08:52 -08001057 help='Specify number of test onos instances to spawn')
A R Karthick09dbc6d2016-11-22 10:37:42 -08001058 parser_setup.add_argument('-v', '--shared-volume', action='store_true',
1059 help='Start ONOS cluster instances with shared volume')
A.R Karthickc4e474d2016-12-12 15:24:57 -08001060 parser_setup.add_argument('-async', '--async-mode', action='store_true',
1061 help='Start ONOS cluster instances in async mode')
A R Karthickbd82f362016-11-10 15:08:52 -08001062 parser_setup.add_argument('-f', '--foreground', action='store_true', help='Run in foreground')
A R Karthick81acbff2016-06-17 14:45:16 -07001063 parser_setup.set_defaults(func=setupCordTester)
1064
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001065 parser_xos = subparser.add_parser('xos', help='Building xos into cord tester environment')
A R Karthickea8bfce2016-10-13 16:32:07 -07001066 parser_xos.add_argument('command', choices=['build', 'update', 'start', 'stop'])
1067 parser_xos.add_argument('-p', '--profile', default='cord-pod', type=str, help='Provide service profile')
1068 parser_xos.set_defaults(func=xosCommand)
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001069
Chetan Gaonker503032a2016-05-12 12:06:29 -07001070 parser_list = subparser.add_parser('list', help='List test cases')
1071 parser_list.add_argument('-t', '--test', default='all', help='Specify test type to list test cases. '
1072 'Eg: -t tls to list tls test cases.'
1073 ' -t tls-dhcp-vrouter to list tls,dhcp and vrouter test cases.'
1074 ' -t all to list all test cases.')
1075 parser_list.set_defaults(func=listTests)
1076
1077 parser_build = subparser.add_parser('build', help='Build cord test container images')
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001078 parser_build.add_argument('image', choices=['quagga', 'radius', 'test','all'])
A.R Karthick842f0122016-09-28 14:48:47 -07001079 parser_build.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001080 parser_build.set_defaults(func=buildImages)
1081
ChetanGaonkereadad482016-08-26 01:21:47 -07001082 parser_metrics = subparser.add_parser('metrics', help='Info of container')
1083 parser_metrics.add_argument("container", help="Container name")
1084 parser_metrics.set_defaults(func=getMetrics)
1085
A R Karthickbec27762016-07-28 10:59:34 -07001086 parser_start = subparser.add_parser('start', help='Start cord tester containers')
A R Karthick07608ef2016-08-23 16:51:19 -07001087 parser_start.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1088 parser_start.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
A R Karthickbec27762016-07-28 10:59:34 -07001089 parser_start.add_argument('image', choices=['onos', 'quagga', 'radius', 'all'])
1090 parser_start.set_defaults(func=startImages)
1091
Chetan Gaonker503032a2016-05-12 12:06:29 -07001092 parser_cleanup = subparser.add_parser('cleanup', help='Cleanup test containers')
A R Karthick07608ef2016-08-23 16:51:19 -07001093 parser_cleanup.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1094 parser_cleanup.add_argument('-l', '--olt', action = 'store_true', help = 'Cleanup OLT config')
A R Karthick2b93d6a2016-09-06 15:19:09 -07001095 parser_cleanup.add_argument('-o', '--onos', default=onos_image_default, type=str,
1096 help='ONOS container image to cleanup')
A.R Karthick842f0122016-09-28 14:48:47 -07001097 parser_cleanup.add_argument('-x', '--xos', action='store_true',
1098 help='Cleanup XOS containers')
A R Karthicke99ab5c2016-09-30 13:59:57 -07001099 parser_cleanup.add_argument('-r', '--server', default=cord_test_server_address, type=str,
1100 help='ip:port address for cord test server to cleanup')
A R Karthick757eb4d2017-01-09 14:51:16 -08001101 parser_cleanup.add_argument('-m', '--manifest', default='', type=str, help='Provide test manifest')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001102 parser_cleanup.set_defaults(func=cleanupTests)
1103
ChetanGaonkereadad482016-08-26 01:21:47 -07001104 c = Client(**(kwargs_from_env()))
1105
Chetan Gaonker93e302d2016-04-05 10:51:07 -07001106 args = parser.parse_args()
A R Karthick9a5edc42016-08-24 19:10:22 -07001107 res = args.func(args)
1108 sys.exit(res)