blob: c2e8ebe38be065bab6d5e5771923ba0b969ef835 [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)
Chetan Gaonker93e302d2016-04-05 10:51:07 -070022from OnosCtrl import OnosCtrl
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070023from OltConfig import OltConfig
A R Karthick1f03e912016-05-18 11:39:22 -070024from threadPool import ThreadPool
Chetan Gaonker3533faa2016-04-25 17:50:14 -070025from CordContainer import *
A R Karthicke99ab5c2016-09-30 13:59:57 -070026from 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 -070027from TestManifest import TestManifest
ChetanGaonkereadad482016-08-26 01:21:47 -070028from docker import Client
29from docker.utils import kwargs_from_env
30
A R Karthick07608ef2016-08-23 16:51:19 -070031try:
32 from Fabric import FabricMAAS
33except:
34 FabricMAAS = None
Chetan Gaonker93e302d2016-04-05 10:51:07 -070035
Chetan Gaonker93e302d2016-04-05 10:51:07 -070036class CordTester(Container):
Chetan Gaonker93e302d2016-04-05 10:51:07 -070037 sandbox = '/root/test'
Chetan Gaonker7142a342016-04-07 14:53:12 -070038 sandbox_setup = '/root/test/src/test/setup'
Chetan Gaonker4d842ad2016-04-26 10:04:24 -070039 tester_base = os.path.dirname(os.path.realpath(__file__))
40 tester_paths = os.path.realpath(__file__).split(os.path.sep)
A R Karthickb7e80902016-05-17 09:38:31 -070041 tester_path_index = tester_paths.index('src') - 1
Chetan Gaonker7142a342016-04-07 14:53:12 -070042 sandbox_host = os.path.sep.join(tester_paths[:tester_path_index+1])
Chetan Gaonker93e302d2016-04-05 10:51:07 -070043
44 host_guest_map = ( (sandbox_host, sandbox),
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070045 ('/lib/modules', '/lib/modules'),
46 ('/var/run/docker.sock', '/var/run/docker.sock')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070047 )
48 basename = 'cord-tester'
A R Karthick36cfcef2016-08-18 15:20:07 -070049 switch_on_olt = False
Chetan Gaonker503032a2016-05-12 12:06:29 -070050 IMAGE = 'cord-test/nose'
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -070051 ALL_TESTS = ('tls', 'dhcp', 'dhcprelay','igmp', 'subscriber',
52 'cordSubscriber', 'vrouter', 'flows', 'proxyarp', 'acl', 'xos', 'fabric',
53 'cbench', 'cluster')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070054
A R Karthicka013a272016-08-16 16:40:19 -070055 def __init__(self, tests, instance = 0, num_instances = 1, ctlr_ip = None,
A R Karthick07608ef2016-08-23 16:51:19 -070056 name = '', image = IMAGE, prefix = '', tag = 'candidate',
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070057 env = None, rm = False, update = False):
A R Karthick1f03e912016-05-18 11:39:22 -070058 self.tests = tests
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070059 self.ctlr_ip = ctlr_ip
Chetan Gaonker93e302d2016-04-05 10:51:07 -070060 self.rm = rm
A R Karthicka013a272016-08-16 16:40:19 -070061 self.name = name or self.get_name()
A R Karthick07608ef2016-08-23 16:51:19 -070062 super(CordTester, self).__init__(self.name, image = image, prefix = prefix, tag = tag)
Chetan Gaonker93e302d2016-04-05 10:51:07 -070063 host_config = self.create_host_config(host_guest_map = self.host_guest_map, privileged = True)
64 volumes = []
Chetan Gaonkerb84835f2016-04-19 15:12:10 -070065 for _, g in self.host_guest_map:
Chetan Gaonker93e302d2016-04-05 10:51:07 -070066 volumes.append(g)
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070067 if update is True or not self.img_exists():
A R Karthick07608ef2016-08-23 16:51:19 -070068 self.build_image(self.image_name)
A R Karthicka013a272016-08-16 16:40:19 -070069 self.create = True
70 #check if are trying to run tests on existing container
71 if not name or not self.exists():
72 ##Remove test container if any
73 self.remove_container(self.name, force=True)
74 else:
75 self.create = False
A R Karthick078e63a2016-07-28 13:59:31 -070076 self.olt = False
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070077 if env is not None and env.has_key('OLT_CONFIG'):
78 self.olt = True
A R Karthick078e63a2016-07-28 13:59:31 -070079 olt_conf_file = os.path.join(self.tester_base, 'olt_config.json')
80 olt_config = OltConfig(olt_conf_file)
81 self.port_map, _ = olt_config.olt_port_map()
82 #Try using the host interface in olt conf to setup the switch
83 if self.port_map.has_key('host'):
84 self.switch = self.port_map['host']
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070085 else:
A R Karthick078e63a2016-07-28 13:59:31 -070086 self.switch = 'ovsbr0'
A R Karthick1f03e912016-05-18 11:39:22 -070087 if env is not None:
A R Karthick078e63a2016-07-28 13:59:31 -070088 env['TEST_SWITCH'] = self.switch
A R Karthick1f03e912016-05-18 11:39:22 -070089 env['TEST_HOST'] = self.name
90 env['TEST_INSTANCE'] = instance
91 env['TEST_INSTANCES'] = num_instances
A R Karthicka013a272016-08-16 16:40:19 -070092 if self.create:
93 print('Starting test container %s, image %s, tag %s' %(self.name, self.image, self.tag))
94 self.start(rm = False, volumes = volumes, environment = env,
95 host_config = host_config, tty = True)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070096
97 def execute_switch(self, cmd, shell = False):
98 if self.olt:
99 return os.system(cmd)
100 return self.execute(cmd, shell = shell)
101
A R Karthick078e63a2016-07-28 13:59:31 -0700102 def start_switch(self, boot_delay = 2):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700103 """Start OVS"""
104 ##Determine if OVS has to be started locally or not
105 s_file,s_sandbox = ('of-bridge-local.sh',self.tester_base) if self.olt else ('of-bridge.sh',self.sandbox_setup)
A R Karthick078e63a2016-07-28 13:59:31 -0700106 ovs_cmd = os.path.join(s_sandbox, s_file) + ' {0}'.format(self.switch)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700107 if self.olt:
A R Karthick36cfcef2016-08-18 15:20:07 -0700108 if CordTester.switch_on_olt is True:
109 return
110 CordTester.switch_on_olt = True
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700111 ovs_cmd += ' {0}'.format(self.ctlr_ip)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700112 print('Starting OVS on the host with controller: %s' %(self.ctlr_ip))
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700113 else:
114 print('Starting OVS on test container %s' %self.name)
115 self.execute_switch(ovs_cmd)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700116 status = 1
117 ## Wait for the LLDP flows to be added to the switch
118 tries = 0
Chetan Gaonkera52016e2016-05-05 15:19:59 -0700119 while status != 0 and tries < 200:
A R Karthick078e63a2016-07-28 13:59:31 -0700120 cmd = 'sudo ovs-ofctl dump-flows {0} | grep \"type=0x8942\"'.format(self.switch)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700121 status = self.execute_switch(cmd, shell = True)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700122 tries += 1
123 if tries % 10 == 0:
124 print('Waiting for test switch to be connected to ONOS controller ...')
125
126 if status != 0:
127 print('Test Switch not connected to ONOS container.'
128 'Please remove ONOS container and restart the test')
129 if self.rm:
130 self.kill()
131 sys.exit(1)
132
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700133 if boot_delay:
134 time.sleep(boot_delay)
135
A R Karthick1f03e912016-05-18 11:39:22 -0700136 def setup_intfs(self, port_num = 0):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700137 tester_intf_subnet = '192.168.100'
138 res = 0
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700139 host_intf = self.port_map['host']
140 start_vlan = self.port_map['start_vlan']
A R Karthick07769362016-07-28 17:36:15 -0700141 start_vlan += port_num
142 uplink = self.port_map['uplink']
143 wan = self.port_map['wan']
A R Karthick36cfcef2016-08-18 15:20:07 -0700144 port_list = self.port_map['ports'] + self.port_map['relay_ports']
145 for port in port_list:
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700146 guest_if = port
A R Karthick1f03e912016-05-18 11:39:22 -0700147 local_if = '{0}_{1}'.format(guest_if, port_num+1)
148 guest_ip = '{0}.{1}/24'.format(tester_intf_subnet, port_num+1)
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700149 ##Use pipeworks to configure container interfaces on host/bridge interfaces
A R Karthick07769362016-07-28 17:36:15 -0700150 pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(host_intf, guest_if,
151 local_if, self.name, guest_ip)
152 #if the wan interface is specified for uplink, then use it instead
153 if wan and port == self.port_map[uplink]:
154 pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(wan, guest_if,
155 local_if, self.name, guest_ip)
156 else:
157 if start_vlan != 0:
158 pipework_cmd += ' @{}'.format(start_vlan)
159 start_vlan += 1
A.R Karthick95d044e2016-06-10 18:44:36 -0700160
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700161 res += os.system(pipework_cmd)
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700162 port_num += 1
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700163
A R Karthick1f03e912016-05-18 11:39:22 -0700164 return res, port_num
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700165
166 @classmethod
A R Karthickb50f5592016-07-26 12:19:29 -0700167 def cleanup_intfs(cls):
168 olt_conf_file = os.path.join(cls.tester_base, 'olt_config.json')
169 olt_config = OltConfig(olt_conf_file)
A R Karthickb03cecd2016-07-27 10:27:55 -0700170 port_map, _ = olt_config.olt_port_map()
A R Karthickb50f5592016-07-26 12:19:29 -0700171 port_num = 0
172 intf_host = port_map['host']
173 start_vlan = port_map['start_vlan']
A R Karthick07769362016-07-28 17:36:15 -0700174 uplink = port_map['uplink']
175 wan = port_map['wan']
A R Karthickb50f5592016-07-26 12:19:29 -0700176 intf_type = 0
177 if os.path.isdir('/sys/class/net/{}/bridge'.format(intf_host)):
178 intf_type = 1 ##linux bridge
179 else:
180 cmd = 'ovs-vsctl list-br | grep -q "^{0}$"'.format(intf_host)
181 res = os.system(cmd)
182 if res == 0: ##ovs bridge
183 intf_type = 2
184 cmds = ()
185 res = 0
186 for port in port_map['ports']:
187 local_if = '{0}_{1}'.format(port, port_num+1)
A R Karthick07769362016-07-28 17:36:15 -0700188 if wan and port_map[uplink] == port:
189 continue
A R Karthickb50f5592016-07-26 12:19:29 -0700190 if intf_type == 0:
191 if start_vlan != 0:
A R Karthick07769362016-07-28 17:36:15 -0700192 cmds = ('ip link del {}.{}'.format(intf_host, start_vlan),)
193 start_vlan += 1
A R Karthickb50f5592016-07-26 12:19:29 -0700194 else:
195 if intf_type == 1:
196 cmds = ('brctl delif {} {}'.format(intf_host, local_if),
197 'ip link del {}'.format(local_if))
198 else:
199 cmds = ('ovs-vsctl del-port {} {}'.format(intf_host, local_if),)
200
201 for cmd in cmds:
202 res += os.system(cmd)
203
204 port_num += 1
205
206 @classmethod
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700207 def get_name(cls):
208 cnt_name = '/{0}'.format(cls.basename)
209 cnt_name_len = len(cnt_name)
210 names = list(flatten(n['Names'] for n in cls.dckr.containers(all=True)))
211 test_names = filter(lambda n: n.startswith(cnt_name), names)
212 last_cnt_number = 0
213 if test_names:
214 last_cnt_name = reduce(lambda n1, n2: n1 if int(n1[cnt_name_len:]) > \
215 int(n2[cnt_name_len:]) else n2,
216 test_names)
217 last_cnt_number = int(last_cnt_name[cnt_name_len:])
218 test_cnt_name = cls.basename + str(last_cnt_number+1)
219 return test_cnt_name
220
221 @classmethod
222 def build_image(cls, image):
223 print('Building test container docker image %s' %image)
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700224 ovs_version = '2.5.0'
225 image_format = (ovs_version,)*4
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700226 dockerfile = '''
227FROM ubuntu:14.04
228MAINTAINER chetan@ciena.com
A R Karthickc762df42016-05-25 10:09:21 -0700229RUN apt-get update && \
230 apt-get install -y git git-core autoconf automake autotools-dev pkg-config \
231 make gcc g++ libtool libc6-dev cmake libpcap-dev libxerces-c2-dev \
232 unzip libpcre3-dev flex bison libboost-dev \
233 python python-pip python-setuptools python-scapy tcpdump doxygen doxypy wget \
234 openvswitch-common openvswitch-switch \
A R Karthick07608ef2016-08-23 16:51:19 -0700235 python-twisted python-sqlite sqlite3 python-pexpect telnet arping isc-dhcp-server \
236 python-paramiko python-maas-client
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700237RUN easy_install nose
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700238RUN mkdir -p /root/ovs
239WORKDIR /root
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700240RUN wget http://openvswitch.org/releases/openvswitch-{}.tar.gz -O /root/ovs/openvswitch-{}.tar.gz && \
241(cd /root/ovs && tar zxpvf openvswitch-{}.tar.gz && \
242 cd openvswitch-{} && \
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700243 ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && make && make install)
244RUN service openvswitch-switch restart || /bin/true
A R Karthick81acbff2016-06-17 14:45:16 -0700245RUN pip install -U scapy scapy-ssl_tls monotonic configObj docker-py pyyaml nsenter pyroute2 netaddr python-daemon
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700246RUN mv /usr/sbin/tcpdump /sbin/
247RUN ln -sf /sbin/tcpdump /usr/sbin/tcpdump
A R Karthickf4999472016-07-01 16:42:13 -0700248RUN mv /usr/sbin/dhcpd /sbin/
249RUN ln -sf /sbin/dhcpd /usr/sbin/dhcpd
A R Karthickb7e80902016-05-17 09:38:31 -0700250WORKDIR /root
251RUN wget -nc http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/bison_2.5.dfsg-2.1_amd64.deb \
252 http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/libbison-dev_2.5.dfsg-2.1_amd64.deb
253RUN sudo dpkg -i bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb
254RUN rm bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb
255RUN wget -nc http://www.nbee.org/download/nbeesrc-jan-10-2013.zip && \
256 unzip nbeesrc-jan-10-2013.zip && \
257 cd nbeesrc-jan-10-2013/src && cmake . && make && \
258 cp ../bin/libn*.so /usr/local/lib && ldconfig && \
259 cp -R ../include/* /usr/include/
260WORKDIR /root
261RUN git clone https://github.com/CPqD/ofsoftswitch13.git && \
262 cd ofsoftswitch13 && \
A R Karthickb7e80902016-05-17 09:38:31 -0700263 ./boot.sh && \
264 ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && \
265 make && make install
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700266CMD ["/bin/bash"]
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700267'''.format(*image_format)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700268 super(CordTester, cls).build_image(dockerfile, image)
269 print('Done building docker image %s' %image)
270
A R Karthick1f03e912016-05-18 11:39:22 -0700271 def run_tests(self):
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700272 '''Run the list of tests'''
A R Karthick9a5edc42016-08-24 19:10:22 -0700273 res = 0
A R Karthick1f03e912016-05-18 11:39:22 -0700274 print('Running tests: %s' %self.tests)
275 for t in self.tests:
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700276 test = t.split(':')[0]
A R Karthick24f1de62016-05-12 15:16:38 -0700277 test_file = '{}Test.py'.format(test)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700278 if t.find(':') >= 0:
A R Karthick24f1de62016-05-12 15:16:38 -0700279 test_case = '{0}:{1}'.format(test_file, t.split(':')[1])
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700280 else:
281 test_case = test_file
Chetan Gaonker7142a342016-04-07 14:53:12 -0700282 cmd = 'nosetests -v {0}/src/test/{1}/{2}'.format(self.sandbox, test, test_case)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700283 status = self.execute(cmd, shell = True)
A R Karthick9a5edc42016-08-24 19:10:22 -0700284 if status > 255:
285 status = 1
286 res |= status
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700287 print('Test %s %s' %(test_case, 'Success' if status == 0 else 'Failure'))
288 print('Done running tests')
289 if self.rm:
290 print('Removing test container %s' %self.name)
291 self.kill(remove=True)
292
A R Karthick9a5edc42016-08-24 19:10:22 -0700293 return res
294
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700295 @classmethod
296 def list_tests(cls, tests):
297 print('Listing test cases')
298 for test in tests:
A R Karthick24f1de62016-05-12 15:16:38 -0700299 test_file = '{}Test.py'.format(test)
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700300 cmd = 'nosetests -v --collect-only {0}/../{1}/{2}'.format(cls.tester_base, test, test_file)
301 os.system(cmd)
302
A R Karthicka013a272016-08-16 16:40:19 -0700303
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700304##default onos/radius/test container images and names
305onos_image_default='onosproject/onos:latest'
A R Karthick07608ef2016-08-23 16:51:19 -0700306nose_image_default= '{}:candidate'.format(CordTester.IMAGE)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700307test_type_default='dhcp'
A.R Karthick95d044e2016-06-10 18:44:36 -0700308onos_app_version = '2.0-SNAPSHOT'
Chetan Gaonker4d842ad2016-04-26 10:04:24 -0700309cord_tester_base = os.path.dirname(os.path.realpath(__file__))
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700310onos_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 -0700311cord_test_server_address = '{}:{}'.format(CORD_TEST_HOST, CORD_TEST_PORT)
A R Karthick07608ef2016-08-23 16:51:19 -0700312identity_file_default = '/etc/maas/ansible/id_rsa'
313
314##sets up the ssh key file for the test container
315def set_ssh_key_file(identity_file):
316 ssh_key_file = None
317 if os.access(identity_file, os.F_OK):
318 ##copy it to setup directory
319 identity_dest = os.path.join(CordTester.tester_base, 'id_rsa')
320 if os.path.abspath(identity_file) != identity_dest:
321 try:
322 shutil.copy(identity_file, identity_dest)
323 ssh_key_file = os.path.join(CordTester.sandbox_setup, 'id_rsa')
324 except: pass
325
326 return ssh_key_file
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700327
328def runTest(args):
Chetan Gaonker823cdc52016-05-09 15:51:23 -0700329 #Start the cord test tcp server
A R Karthick81acbff2016-06-17 14:45:16 -0700330 test_server_params = args.server.split(':')
331 test_host = test_server_params[0]
332 test_port = CORD_TEST_PORT
333 if len(test_server_params) > 1:
334 test_port = int(test_server_params[1])
335 try:
336 test_server = cord_test_server_start(daemonize = False, cord_test_host = test_host, cord_test_port = test_port)
337 except:
338 ##Most likely a server instance is already running (daemonized earlier)
339 test_server = None
340
A R Karthick1f03e912016-05-18 11:39:22 -0700341 test_containers = []
342 #These tests end up restarting ONOS/quagga/radius
A R Karthick4e0c0912016-08-17 16:57:42 -0700343 tests_exempt = ('vrouter', 'cordSubscriber', 'proxyarp', 'dhcprelay')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700344 if args.test_type.lower() == 'all':
345 tests = CordTester.ALL_TESTS
Chetan Gaonker503032a2016-05-12 12:06:29 -0700346 args.quagga = True
347 else:
A R Karthickacae3b42016-05-12 15:27:24 -0700348 tests = args.test_type.split('-')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700349
A R Karthick1f03e912016-05-18 11:39:22 -0700350 tests_parallel = [ t for t in tests if t.split(':')[0] not in tests_exempt ]
351 tests_not_parallel = [ t for t in tests if t.split(':')[0] in tests_exempt ]
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700352 onos_cnt = {'tag':'latest'}
A R Karthick07608ef2016-08-23 16:51:19 -0700353 nose_cnt = {'image': CordTester.IMAGE, 'tag': 'candidate'}
Chetan Gaonker503032a2016-05-12 12:06:29 -0700354 update_map = { 'quagga' : False, 'test' : False, 'radius' : False }
355 update_map[args.update.lower()] = True
A.R Karthick95d044e2016-06-10 18:44:36 -0700356
Chetan Gaonker503032a2016-05-12 12:06:29 -0700357 if args.update.lower() == 'all':
358 for c in update_map.keys():
359 update_map[c] = True
A.R Karthick95d044e2016-06-10 18:44:36 -0700360
A R Karthick07608ef2016-08-23 16:51:19 -0700361 onos_ip = None
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700362 radius_ip = None
A R Karthick07608ef2016-08-23 16:51:19 -0700363 head_node = platform.node()
364 use_manifest = False
365 if args.manifest:
366 if os.access(args.manifest, os.F_OK):
367 ##copy it to setup directory
368 dest = os.path.join(CordTester.tester_base, 'manifest.json')
369 if os.path.abspath(args.manifest) != dest:
370 try:
371 shutil.copy(args.manifest, dest)
372 except: pass
373 test_manifest = TestManifest(dest)
374 onos_ip = test_manifest.onos_ip
375 radius_ip = test_manifest.radius_ip
376 head_node = test_manifest.head_node
377 use_manifest = True
378 else:
379 print('Unable to access test manifest: %s' %args.manifest)
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700380
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700381 #don't spawn onos if the user has specified external test controller with test interface config
382 if args.test_controller:
383 ips = args.test_controller.split('/')
384 onos_ip = ips[0]
385 if len(ips) > 1:
386 radius_ip = ips[1]
387 else:
388 radius_ip = None
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700389
A R Karthick07608ef2016-08-23 16:51:19 -0700390 Container.IMAGE_PREFIX = args.prefix
391 if onos_ip is None:
392 image_names = args.onos.rsplit(':', 1)
393 onos_cnt['image'] = image_names[0]
394 if len(image_names) > 1:
395 if image_names[1].find('/') < 0:
396 onos_cnt['tag'] = image_names[1]
397 else:
398 #tag cannot have slashes
399 onos_cnt['image'] = args.onos
400
401 Onos.IMAGE = onos_cnt['image']
402 Onos.PREFIX = args.prefix
403 Onos.TAG = onos_cnt['tag']
404 onos = Onos(image = Onos.IMAGE,
405 tag = Onos.TAG, boot_delay = 60)
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700406 onos_ip = onos.ip()
407
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700408 print('Onos IP %s, Test type %s' %(onos_ip, args.test_type))
A R Karthick07608ef2016-08-23 16:51:19 -0700409 if use_manifest or args.test_controller:
A R Karthickbd9b8a32016-07-21 09:56:45 -0700410 print('Installing ONOS cord apps')
A R Karthick07608ef2016-08-23 16:51:19 -0700411 try:
412 Onos.install_cord_apps(onos_ip = onos_ip)
413 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700414
A R Karthickedab01c2016-09-08 14:05:44 -0700415 print('Installing cord tester ONOS app %s' %args.app)
A R Karthick07608ef2016-08-23 16:51:19 -0700416 try:
417 OnosCtrl.install_app(args.app, onos_ip = onos_ip)
418 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700419
420 if radius_ip is None:
A R Karthicka661b552016-05-25 10:18:50 -0700421 ##Start Radius container
A R Karthick07608ef2016-08-23 16:51:19 -0700422 radius = Radius(prefix = Container.IMAGE_PREFIX, update = update_map['radius'])
A R Karthicka661b552016-05-25 10:18:50 -0700423 radius_ip = radius.ip()
A.R Karthick95d044e2016-06-10 18:44:36 -0700424
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700425 print('Radius server running with IP %s' %radius_ip)
A.R Karthick95d044e2016-06-10 18:44:36 -0700426
Chetan Gaonkerb84835f2016-04-19 15:12:10 -0700427 if args.quagga == True:
428 #Start quagga. Builds container if required
A R Karthick07608ef2016-08-23 16:51:19 -0700429 quagga = Quagga(prefix = Container.IMAGE_PREFIX, update = update_map['quagga'])
A R Karthick81acbff2016-06-17 14:45:16 -0700430
A R Karthick07608ef2016-08-23 16:51:19 -0700431 try:
432 maas_api_key = FabricMAAS.get_api_key()
433 except:
434 maas_api_key = 'UNKNOWN'
435
436 ssh_key_file = set_ssh_key_file(args.identity_file)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700437 test_cnt_env = { 'ONOS_CONTROLLER_IP' : onos_ip,
Chetan Gaonkerc170f3f2016-04-19 17:24:45 -0700438 'ONOS_AAA_IP' : radius_ip if radius_ip is not None else '',
A R Karthick8d03cc52016-06-28 14:51:59 -0700439 'QUAGGA_IP': test_host,
A R Karthick81acbff2016-06-17 14:45:16 -0700440 'CORD_TEST_HOST' : test_host,
441 'CORD_TEST_PORT' : test_port,
A R Karthick4e0c0912016-08-17 16:57:42 -0700442 'ONOS_RESTART' : 0 if args.olt and args.test_controller else 1,
A R Karthick07608ef2016-08-23 16:51:19 -0700443 'MANIFEST': int(use_manifest),
444 'HEAD_NODE': head_node if head_node else CORD_TEST_HOST,
445 'MAAS_API_KEY': maas_api_key
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700446 }
A R Karthick07608ef2016-08-23 16:51:19 -0700447
448 if ssh_key_file:
449 test_cnt_env['SSH_KEY_FILE'] = ssh_key_file
450
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700451 if args.olt:
Chetan Gaonker7142a342016-04-07 14:53:12 -0700452 olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, 'olt_config.json')
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700453 test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
454
A R Karthicka013a272016-08-16 16:40:19 -0700455 if args.num_containers > 1 and args.container:
456 print('Cannot specify number of containers with container option')
457 sys.exit(1)
458 if args.container:
459 args.keep = True
A R Karthick1f03e912016-05-18 11:39:22 -0700460 port_num = 0
461 num_tests = len(tests_parallel)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700462 if num_tests > 0 and num_tests < args.num_containers:
463 tests_parallel *= args.num_containers/num_tests
464 num_tests = len(tests_parallel)
A R Karthick1f03e912016-05-18 11:39:22 -0700465 tests_per_container = max(1, num_tests/args.num_containers)
466 test_slice_start = 0
467 test_slice_end = test_slice_start + tests_per_container
468 num_test_containers = min(num_tests, args.num_containers)
469 if tests_parallel:
470 print('Running %s tests across %d containers in parallel' %(tests_parallel, num_test_containers))
471 for container in range(num_test_containers):
472 test_cnt = CordTester(tests_parallel[test_slice_start:test_slice_end],
473 instance = container, num_instances = num_test_containers,
A R Karthicka013a272016-08-16 16:40:19 -0700474 ctlr_ip = onos_ip,
A R Karthick07608ef2016-08-23 16:51:19 -0700475 name = args.container,
476 image = nose_cnt['image'],
477 prefix = Container.IMAGE_PREFIX,
478 tag = nose_cnt['tag'],
A R Karthick1f03e912016-05-18 11:39:22 -0700479 env = test_cnt_env,
480 rm = False if args.keep else True,
481 update = update_map['test'])
482 test_slice_start = test_slice_end
483 test_slice_end = test_slice_start + tests_per_container
484 update_map['test'] = False
485 test_containers.append(test_cnt)
A R Karthicka013a272016-08-16 16:40:19 -0700486 if not test_cnt.create:
487 continue
488 if test_cnt.create and (args.start_switch or not args.olt):
A R Karthick07608ef2016-08-23 16:51:19 -0700489 if not args.no_switch:
490 test_cnt.start_switch()
A R Karthicka013a272016-08-16 16:40:19 -0700491 if test_cnt.create and test_cnt.olt:
A R Karthick1f03e912016-05-18 11:39:22 -0700492 _, port_num = test_cnt.setup_intfs(port_num = port_num)
493
A R Karthick9a5edc42016-08-24 19:10:22 -0700494 status = 0
495 if len(test_containers) > 1:
496 thread_pool = ThreadPool(len(test_containers), queue_size = 1, wait_timeout=1)
497 for test_cnt in test_containers:
498 thread_pool.addTask(test_cnt.run_tests)
499 thread_pool.cleanUpThreads()
500 else:
A R Karthickcee37412016-08-29 10:10:56 -0700501 if test_containers:
502 status = test_containers[0].run_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700503
504 ##Run the linear tests
505 if tests_not_parallel:
506 test_cnt = CordTester(tests_not_parallel,
A R Karthicka013a272016-08-16 16:40:19 -0700507 ctlr_ip = onos_ip,
A R Karthick07608ef2016-08-23 16:51:19 -0700508 name = args.container,
509 image = nose_cnt['image'],
510 prefix = Container.IMAGE_PREFIX,
511 tag = nose_cnt['tag'],
A R Karthick1f03e912016-05-18 11:39:22 -0700512 env = test_cnt_env,
513 rm = False if args.keep else True,
514 update = update_map['test'])
A R Karthicka013a272016-08-16 16:40:19 -0700515 if test_cnt.create and (args.start_switch or not args.olt):
A R Karthick36cfcef2016-08-18 15:20:07 -0700516 #For non parallel tests, we just restart the switch also for OLT's
517 CordTester.switch_on_olt = False
A R Karthick07608ef2016-08-23 16:51:19 -0700518 if not args.no_switch:
519 test_cnt.start_switch()
A R Karthicka013a272016-08-16 16:40:19 -0700520 if test_cnt.create and test_cnt.olt:
A R Karthick1f03e912016-05-18 11:39:22 -0700521 test_cnt.setup_intfs(port_num = port_num)
522 test_cnt.run_tests()
523
A R Karthick81acbff2016-06-17 14:45:16 -0700524 if test_server:
525 cord_test_server_stop(test_server)
526
A R Karthick9a5edc42016-08-24 19:10:22 -0700527 return status
528
A R Karthick81acbff2016-06-17 14:45:16 -0700529##Starts onos/radius/quagga containers as appropriate
530def setupCordTester(args):
531 onos_cnt = {'tag':'latest'}
A R Karthick07608ef2016-08-23 16:51:19 -0700532 nose_cnt = {'image': CordTester.IMAGE, 'tag': 'candidate'}
A R Karthick92a0e5a2016-06-22 17:11:05 -0700533 update_map = { 'quagga' : False, 'radius' : False, 'test': False }
A R Karthick81acbff2016-06-17 14:45:16 -0700534 update_map[args.update.lower()] = True
535
536 if args.update.lower() == 'all':
537 for c in update_map.keys():
538 update_map[c] = True
539
540 onos_ip = None
541 radius_ip = None
A R Karthickd44cea12016-07-20 12:16:41 -0700542 onos_cord_loc = args.onos_cord
543 if onos_cord_loc:
544 if onos_cord_loc.find(os.path.sep) < 0:
545 onos_cord_loc = os.path.join(os.getenv('HOME'), onos_cord_loc)
546 if not os.access(onos_cord_loc, os.F_OK):
547 print('ONOS cord config location %s is not accessible' %onos_cord_loc)
548 sys.exit(1)
549 #Disable test container provisioning on the ONOS compute node
550 args.dont_provision = True
A R Karthick81acbff2016-06-17 14:45:16 -0700551
A R Karthick07608ef2016-08-23 16:51:19 -0700552 head_node = platform.node()
553 use_manifest = False
554 if args.manifest:
555 if os.access(args.manifest, os.F_OK):
556 ##copy it to setup directory
557 dest = os.path.join(CordTester.tester_base, 'manifest.json')
558 if os.path.abspath(args.manifest) != dest:
559 try:
560 shutil.copy(args.manifest, dest)
561 except: pass
562 test_manifest = TestManifest(dest)
563 onos_ip = test_manifest.onos_ip
564 radius_ip = test_manifest.radius_ip
565 head_node = test_manifest.head_node
566 use_manifest = True
567
A R Karthick81acbff2016-06-17 14:45:16 -0700568 ##If onos/radius was already started
569 if args.test_controller:
570 ips = args.test_controller.split('/')
571 onos_ip = ips[0]
572 if len(ips) > 1:
573 radius_ip = ips[1]
574 else:
575 radius_ip = None
576
A R Karthickd44cea12016-07-20 12:16:41 -0700577 onos_cord = None
578 if onos_cord_loc:
579 if not args.test_controller:
580 ##Unexpected case. Specify the external controller ip when running on cord node
581 print('Specify ONOS ip using \"-e\" option when running the cord-tester on cord node')
582 sys.exit(1)
A R Karthickbd9b8a32016-07-21 09:56:45 -0700583 onos_cord = OnosCord(onos_ip, onos_cord_loc)
A R Karthickd44cea12016-07-20 12:16:41 -0700584
A R Karthick07608ef2016-08-23 16:51:19 -0700585 Container.IMAGE_PREFIX = args.prefix
A R Karthick81acbff2016-06-17 14:45:16 -0700586 #don't spawn onos if the user had started it externally
A R Karthick07608ef2016-08-23 16:51:19 -0700587 image_names = args.onos.rsplit(':', 1)
588 onos_cnt['image'] = image_names[0]
589 if len(image_names) > 1:
590 if image_names[1].find('/') < 0:
591 onos_cnt['tag'] = image_names[1]
592 else:
593 #tag cannot have slashes
594 onos_cnt['image'] = args.onos
A R Karthick81acbff2016-06-17 14:45:16 -0700595
A R Karthick07608ef2016-08-23 16:51:19 -0700596 Onos.IMAGE = onos_cnt['image']
597 Onos.PREFIX = args.prefix
598 Onos.TAG = onos_cnt['tag']
A R Karthick2b93d6a2016-09-06 15:19:09 -0700599 cluster_mode = True if args.onos_instances > 1 else False
600 onos = None
A R Karthick81acbff2016-06-17 14:45:16 -0700601 if onos_ip is None:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700602 onos = Onos(image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode)
A R Karthick81acbff2016-06-17 14:45:16 -0700603 onos_ip = onos.ip()
604
A R Karthick2b93d6a2016-09-06 15:19:09 -0700605 num_onos_instances = args.onos_instances
606 onos_ips = [ onos_ip ]
607 if num_onos_instances > 1 and onos is not None:
608 onos_instances = []
609 onos_instances.append(onos)
610 for i in range(1, num_onos_instances):
611 name = '{}-{}'.format(Onos.NAME, i+1)
612 onos = Onos(name = name, image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode)
613 onos_instances.append(onos)
614 onos_ips.append(onos.ipaddr)
615 Onos.setup_cluster(onos_instances)
616
617 ctlr_addr = ','.join(onos_ips)
618 print('Onos IP %s' %ctlr_addr)
A R Karthick07608ef2016-08-23 16:51:19 -0700619 if use_manifest or args.test_controller:
A R Karthickbd9b8a32016-07-21 09:56:45 -0700620 print('Installing ONOS cord apps')
A R Karthick07608ef2016-08-23 16:51:19 -0700621 try:
622 Onos.install_cord_apps(onos_ip = onos_ip)
623 except: pass
A R Karthickbd9b8a32016-07-21 09:56:45 -0700624
A R Karthickedab01c2016-09-08 14:05:44 -0700625 print('Installing cord tester ONOS app %s' %args.app)
A R Karthick07608ef2016-08-23 16:51:19 -0700626 try:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700627 for ip in onos_ips:
628 OnosCtrl.install_app(args.app, onos_ip = ip)
A R Karthick07608ef2016-08-23 16:51:19 -0700629 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700630
A R Karthick81acbff2016-06-17 14:45:16 -0700631 ##Start Radius container if not started
632 if radius_ip is None:
A R Karthick07608ef2016-08-23 16:51:19 -0700633 radius = Radius(prefix = Container.IMAGE_PREFIX, update = update_map['radius'])
A R Karthick81acbff2016-06-17 14:45:16 -0700634 radius_ip = radius.ip()
635
636 print('Radius server running with IP %s' %radius_ip)
A R Karthick81acbff2016-06-17 14:45:16 -0700637
638 if args.quagga == True:
639 #Start quagga. Builds container if required
A R Karthick07608ef2016-08-23 16:51:19 -0700640 quagga = Quagga(prefix = Container.IMAGE_PREFIX, update = update_map['quagga'])
A R Karthick8d03cc52016-06-28 14:51:59 -0700641 print('Quagga started')
A R Karthick81acbff2016-06-17 14:45:16 -0700642
A R Karthick81acbff2016-06-17 14:45:16 -0700643 params = args.server.split(':')
644 ip = params[0]
645 port = CORD_TEST_PORT
646 if len(params) > 1:
647 port = int(params[1])
A R Karthick92a0e5a2016-06-22 17:11:05 -0700648
A R Karthick07608ef2016-08-23 16:51:19 -0700649 try:
650 maas_api_key = FabricMAAS.get_api_key()
651 except:
652 maas_api_key = 'UNKNOWN'
653
654 ssh_key_file = set_ssh_key_file(args.identity_file)
655
A R Karthick92a0e5a2016-06-22 17:11:05 -0700656 #provision the test container
657 if not args.dont_provision:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700658 test_cnt_env = { 'ONOS_CONTROLLER_IP' : ctlr_addr,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700659 'ONOS_AAA_IP' : radius_ip,
A R Karthick8d03cc52016-06-28 14:51:59 -0700660 'QUAGGA_IP': ip,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700661 'CORD_TEST_HOST' : ip,
662 'CORD_TEST_PORT' : port,
A R Karthick4e0c0912016-08-17 16:57:42 -0700663 'ONOS_RESTART' : 0 if args.olt and args.test_controller else 1,
A R Karthick07608ef2016-08-23 16:51:19 -0700664 'MANIFEST': int(use_manifest),
665 'HEAD_NODE': head_node if head_node else CORD_TEST_HOST,
666 'MAAS_API_KEY': maas_api_key
A R Karthick92a0e5a2016-06-22 17:11:05 -0700667 }
A R Karthick07608ef2016-08-23 16:51:19 -0700668
669 if ssh_key_file:
670 test_cnt_env['SSH_KEY_FILE'] = ssh_key_file
A R Karthick92a0e5a2016-06-22 17:11:05 -0700671 if args.olt:
672 olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, 'olt_config.json')
673 test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
674
675 test_cnt = CordTester((),
A R Karthick2b93d6a2016-09-06 15:19:09 -0700676 ctlr_ip = ctlr_addr,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700677 image = nose_cnt['image'],
A R Karthick07608ef2016-08-23 16:51:19 -0700678 prefix = Container.IMAGE_PREFIX,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700679 tag = nose_cnt['tag'],
680 env = test_cnt_env,
681 rm = False,
682 update = update_map['test'])
683
684 if args.start_switch or not args.olt:
685 test_cnt.start_switch()
686 if test_cnt.olt:
687 test_cnt.setup_intfs(port_num = 0)
688 print('Test container %s started and provisioned to run tests using nosetests' %(test_cnt.name))
689
690 #Finally start the test server and daemonize
A R Karthick14118c62016-07-27 14:54:04 -0700691 try:
692 cord_test_server_start(daemonize = True, cord_test_host = ip, cord_test_port = port,
693 onos_cord = onos_cord)
694 except socket.error, e:
695 #the test agent address could be remote or already running. Exit gracefully
696 sys.exit(0)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700697
A R Karthick9a5edc42016-08-24 19:10:22 -0700698 return 0
699
Chetan Gaonker503032a2016-05-12 12:06:29 -0700700def cleanupTests(args):
A R Karthick2b93d6a2016-09-06 15:19:09 -0700701 image_name = args.onos
A R Karthick07608ef2016-08-23 16:51:19 -0700702 prefix = args.prefix
703 if prefix:
704 prefix += '/'
705 test_container = '{}{}:candidate'.format(prefix, CordTester.IMAGE)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700706 print('Cleaning up Test containers ...')
707 Container.cleanup(test_container)
A R Karthickb50f5592016-07-26 12:19:29 -0700708 if args.olt:
709 print('Cleaning up test container OLT configuration')
710 CordTester.cleanup_intfs()
A R Karthick2b93d6a2016-09-06 15:19:09 -0700711
712 onos_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == image_name ]
713 if len(onos_list) > 1:
714 for onos in onos_list:
715 Container.dckr.kill(onos)
716 Container.dckr.remove_container(onos, force=True)
A R Karthick9d48c652016-09-15 09:16:36 -0700717 Onos.cleanup_runtime()
A.R Karthick842f0122016-09-28 14:48:47 -0700718 if args.xos:
719 ##cleanup XOS images
720 xos_images = ( '{}:{}'.format(XosServer.IMAGE,XosServer.TAG),
721 '{}:{}'.format(XosSynchronizerOpenstack.IMAGE,
722 XosSynchronizerOpenstack.TAG),
723 '{}:{}'.format(XosSynchronizerOnboarding.IMAGE,
724 XosSynchronizerOnboarding.TAG),
725 '{}:{}'.format(XosSynchronizerOpenvpn.IMAGE,
726 XosSynchronizerOpenvpn.TAG),
727 '{}:{}'.format(XosPostgresql.IMAGE,
728 XosPostgresql.TAG),
729 '{}:{}'.format(XosSyndicateMs.IMAGE,
730 XosSyndicateMs.TAG),
731 )
732 for img in xos_images:
733 print('Cleaning up XOS image: %s' %img)
734 Container.cleanup(img)
735
A R Karthicke99ab5c2016-09-30 13:59:57 -0700736 server_params = args.server.split(':')
737 server_host = server_params[0]
738 server_port = CORD_TEST_PORT
739 if len(server_params) > 1:
740 server_port = int(server_params[1])
741 cord_test_server_shutdown(server_host, server_port)
A R Karthick9a5edc42016-08-24 19:10:22 -0700742 return 0
Chetan Gaonker503032a2016-05-12 12:06:29 -0700743
744def listTests(args):
745 if args.test == 'all':
746 tests = CordTester.ALL_TESTS
747 else:
A R Karthickacae3b42016-05-12 15:27:24 -0700748 tests = args.test.split('-')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700749 CordTester.list_tests(tests)
A R Karthickcee37412016-08-29 10:10:56 -0700750 return 0
ChetanGaonkereadad482016-08-26 01:21:47 -0700751
752def getMetrics(args):
A R Karthickcee37412016-08-29 10:10:56 -0700753 try:
754 detail = c.inspect_container(args.container)
755 except:
756 print('Unknown container %s' %args.container)
757 return 0
758 user_hz = os.sysconf(os.sysconf_names['SC_CLK_TCK'])
ChetanGaonkereadad482016-08-26 01:21:47 -0700759 state = detail["State"]
760 if bool(state["Paused"]):
761 print("Container is in Paused State")
762 elif bool(state["Running"]):
763 print("Container is in Running State")
764 elif int(state["ExitCode"]) == 0:
765 print("Container is in Stopped State")
766 else:
767 print("Container is in Crashed State")
768
A R Karthickcee37412016-08-29 10:10:56 -0700769 print("Ip Address of the container: " +detail['NetworkSettings']['IPAddress'])
ChetanGaonkereadad482016-08-26 01:21:47 -0700770
771 if bool(detail["State"]["Running"]):
772 container_id = detail['Id']
773 cpu_usage = {}
A R Karthickcee37412016-08-29 10:10:56 -0700774 cur_usage = 0
775 last_usage = 0
776 for i in range(2):
777 with open('/sys/fs/cgroup/cpuacct/docker/' + container_id + '/cpuacct.stat', 'r') as f:
778 for line in f:
779 m = re.search(r"(system|user)\s+(\d+)", line)
780 if m:
781 cpu_usage[m.group(1)] = int(m.group(2))
782 cpu = cpu_usage["system"] + cpu_usage["user"]
783 last_usage = cur_usage
784 cur_usage = cpu
785 time.sleep(1)
786 cpu_percent = (cur_usage - last_usage)*100.0/user_hz
787 print("CPU Usage: %.2f %%" %(cpu_percent))
ChetanGaonkereadad482016-08-26 01:21:47 -0700788 else:
789 print(0)
790
791 if bool(detail["State"]["Running"]):
792 container_id = detail['Id']
A R Karthickcee37412016-08-29 10:10:56 -0700793 print("Docker Port Info:")
ChetanGaonkereadad482016-08-26 01:21:47 -0700794 cmd = "sudo docker port {}".format(container_id)
795 os.system(cmd)
796
797 if bool(detail["State"]["Running"]):
798 container_id = detail['Id']
799 with open('/sys/fs/cgroup/memory/docker/' + container_id + '/memory.stat', 'r') as f:
800 for line in f:
801 m = re.search(r"total_rss\s+(\d+)", line)
802 if m:
A R Karthickcee37412016-08-29 10:10:56 -0700803 mem = int(m.group(1))
804 print("Memory: %s KB "%(mem/1024.0))
ChetanGaonkereadad482016-08-26 01:21:47 -0700805 o = re.search(r"usage\s+(\d+)", line)
806 if o:
A R Karthickcee37412016-08-29 10:10:56 -0700807 print("Usage: %s "%(o.group(1)))
ChetanGaonkereadad482016-08-26 01:21:47 -0700808 p = re.search(r"max_usage\s+(\d+)", line)
809 if p:
A R Karthickcee37412016-08-29 10:10:56 -0700810 print("Max Usage: %s "%(p.group(1)))
ChetanGaonkereadad482016-08-26 01:21:47 -0700811
812 if bool(detail["State"]["Running"]):
813 container_id = detail['Id']
814 with open('/sys/fs/cgroup/cpuacct/docker/' + container_id + '/cpuacct.stat', 'r') as f:
815 for line in f:
816 m = re.search(r"user\s+(\d+)", line)
817 if m:
A R Karthickcee37412016-08-29 10:10:56 -0700818 user_ticks = int(m.group(1))
819 print("Time spent by running processes: %.2f ms"%(user_ticks*1000.0/user_hz))
820 print("List Networks:")
ChetanGaonkereadad482016-08-26 01:21:47 -0700821 cmd = "docker network ls"
822 os.system(cmd)
A R Karthick9a5edc42016-08-24 19:10:22 -0700823 return 0
Chetan Gaonker503032a2016-05-12 12:06:29 -0700824
825def buildImages(args):
A R Karthick07608ef2016-08-23 16:51:19 -0700826 tag = 'candidate'
827 prefix = args.prefix
828 if prefix:
829 prefix += '/'
Chetan Gaonker503032a2016-05-12 12:06:29 -0700830 if args.image == 'all' or args.image == 'quagga':
A R Karthick07608ef2016-08-23 16:51:19 -0700831 image_name = '{}{}:{}'.format(prefix, Quagga.IMAGE, tag)
832 Quagga.build_image(image_name)
A.R Karthick95d044e2016-06-10 18:44:36 -0700833
Chetan Gaonker503032a2016-05-12 12:06:29 -0700834 if args.image == 'all' or args.image == 'radius':
A R Karthick07608ef2016-08-23 16:51:19 -0700835 image_name = '{}{}:{}'.format(prefix, Radius.IMAGE, tag)
836 Radius.build_image(image_name)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700837
838 if args.image == 'all' or args.image == 'test':
A R Karthick07608ef2016-08-23 16:51:19 -0700839 image_name = '{}{}:{}'.format(prefix, CordTester.IMAGE, tag)
840 CordTester.build_image(image_name)
Chetan Gaonker503032a2016-05-12 12:06:29 -0700841
A R Karthick9a5edc42016-08-24 19:10:22 -0700842 return 0
843
A R Karthickbec27762016-07-28 10:59:34 -0700844def startImages(args):
A R Karthickbec27762016-07-28 10:59:34 -0700845 ##starts the latest ONOS image
A R Karthick07608ef2016-08-23 16:51:19 -0700846 onos_cnt = {'tag': 'latest'}
847 image_names = args.onos.rsplit(':', 1)
848 onos_cnt['image'] = image_names[0]
849 if len(image_names) > 1:
850 if image_names[1].find('/') < 0:
851 onos_cnt['tag'] = image_names[1]
852 else:
853 #tag cannot have slashes
854 onos_cnt['image'] = args.onos
855
A R Karthickbec27762016-07-28 10:59:34 -0700856 if args.image == 'all' or args.image == 'onos':
A R Karthick07608ef2016-08-23 16:51:19 -0700857 onos = Onos(image = onos_cnt['image'], tag = onos_cnt['tag'])
A R Karthickbec27762016-07-28 10:59:34 -0700858 print('ONOS started with ip %s' %(onos.ip()))
859
860 if args.image == 'all' or args.image == 'quagga':
A R Karthick07608ef2016-08-23 16:51:19 -0700861 quagga = Quagga(prefix = args.prefix)
A R Karthickbec27762016-07-28 10:59:34 -0700862 print('Quagga started with ip %s' %(quagga.ip()))
863
864 if args.image == 'all' or args.image == 'radius':
A R Karthick07608ef2016-08-23 16:51:19 -0700865 radius = Radius(prefix = args.prefix)
A R Karthickbec27762016-07-28 10:59:34 -0700866 print('Radius started with ip %s' %(radius.ip()))
867
A R Karthick9a5edc42016-08-24 19:10:22 -0700868 return 0
869
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700870def xosContainers(args):
A R Karthicke3bde962016-09-27 15:06:35 -0700871 update_map = { 'xos-server' : False, 'xos-synchronizer-openstack' : False, 'openvpn' : False, 'postgresql' :False,
872 'syndicate-ms': False, 'xos-synchronizer-onboarding' : False }
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700873
A R Karthicke3bde962016-09-27 15:06:35 -0700874 if args.xosAllContainers == True or args.xosServer == True:
875 xosServer = XosServer(prefix = Container.IMAGE_PREFIX, update = update_map['xos-server'])
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700876
A R Karthicke3bde962016-09-27 15:06:35 -0700877 if args.xosAllContainers == True or args.xosSyncOpenstack == True:
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700878 #Start xos base container. Builds container if required
A R Karthicke3bde962016-09-27 15:06:35 -0700879 xosSyncOpenstack = XosSynchronizerOpenstack(prefix = Container.IMAGE_PREFIX,
880 update = update_map['xos-synchronizer-openstack'])
881
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700882 if args.xosAllContainers == True or args.xosOpenvpn == True:
A R Karthicke3bde962016-09-27 15:06:35 -0700883 xosOpenvpn = XosSynchronizerOpenvpn(prefix = Container.IMAGE_PREFIX, update = update_map['openvpn'])
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700884
885 if args.xosAllContainers == True or args.xosPostgresql == True:
A R Karthicke3bde962016-09-27 15:06:35 -0700886 xosPostgresql = XosPostgresql(prefix = Container.IMAGE_PREFIX, update = update_map['postgresql'])
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700887
888 if args.xosAllContainers == True or args.xosSyndicateMs == True:
889 #Start xos syndicateMs container. Builds container if required
A R Karthicke3bde962016-09-27 15:06:35 -0700890 xosSyndicateMs = XosSyndicateMs(prefix = Container.IMAGE_PREFIX, update = update_map['syndicate-ms'])
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700891
A R Karthicke3bde962016-09-27 15:06:35 -0700892 if args.xosAllContainers == True or args.xosSyncOnboarding == True:
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700893 #Start xos synchronizer Onboarding container. Builds container if required
A R Karthicke3bde962016-09-27 15:06:35 -0700894 xosSyncOnboarding = XosSynchronizerOnboarding(prefix = Container.IMAGE_PREFIX,
895 update = update_map['xos-synchronizer-onboarding'])
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700896
897 print('Done building xos containers')
898 return 0
899
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700900if __name__ == '__main__':
Chetan Gaonker678743f2016-04-26 09:54:31 -0700901 parser = ArgumentParser(description='Cord Tester')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700902 subparser = parser.add_subparsers()
903 parser_run = subparser.add_parser('run', help='Run cord tester')
904 parser_run.add_argument('-t', '--test-type', default=test_type_default, help='Specify test type or test case to run')
905 parser_run.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700906 parser_run.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
907 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 -0700908 parser_run.add_argument('-l', '--olt', action='store_true', help='Use OLT config')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700909 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 -0700910 '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 -0700911 parser_run.add_argument('-r', '--server', default=cord_test_server_address, type=str,
912 help='ip:port address to connect for cord test server for container requests')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700913 parser_run.add_argument('-k', '--keep', action='store_true', help='Keep test container after tests')
914 parser_run.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config')
915 parser_run.add_argument('-u', '--update', default='none', choices=['test','quagga','radius', 'all'], type=str, help='Update cord tester container images. '
916 'Eg: --update=quagga to rebuild quagga image.'
917 ' --update=radius to rebuild radius server image.'
918 ' --update=test to rebuild cord test image.(Default)'
919 ' --update=all to rebuild all cord tester images.')
A R Karthick1f03e912016-05-18 11:39:22 -0700920 parser_run.add_argument('-n', '--num-containers', default=1, type=int,
921 help='Specify number of test containers to spawn for tests')
A R Karthicka013a272016-08-16 16:40:19 -0700922 parser_run.add_argument('-c', '--container', default='', type=str, help='Test container name for running tests')
A R Karthick07608ef2016-08-23 16:51:19 -0700923 parser_run.add_argument('-m', '--manifest', default='', type=str, help='Provide test configuration manifest')
924 parser_run.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
925 parser_run.add_argument('-d', '--no-switch', action='store_true', help='Dont start test switch.')
926 parser_run.add_argument('-i', '--identity-file', default=identity_file_default,
927 type=str, help='ssh identity file to access compute nodes from test container')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700928 parser_run.set_defaults(func=runTest)
929
A R Karthick81acbff2016-06-17 14:45:16 -0700930
931 parser_setup = subparser.add_parser('setup', help='Setup cord tester environment')
932 parser_setup.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
933 parser_setup.add_argument('-r', '--server', default=cord_test_server_address, type=str,
934 help='ip:port address for cord test server to listen for container restart requests')
935 parser_setup.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
936 parser_setup.add_argument('-a', '--app', default=onos_app_file, type=str, help='Cord ONOS app filename')
937 parser_setup.add_argument('-e', '--test-controller', default='', type=str, help='External test controller ip for Onos and/or radius server. '
938 'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip to connect')
939 parser_setup.add_argument('-u', '--update', default='none', choices=['quagga','radius', 'all'], type=str, help='Update cord tester container images. '
940 'Eg: --update=quagga to rebuild quagga image.'
941 ' --update=radius to rebuild radius server image.'
942 ' --update=all to rebuild all cord tester images.')
A R Karthick92a0e5a2016-06-22 17:11:05 -0700943 parser_setup.add_argument('-d', '--dont-provision', action='store_true', help='Dont start test container.')
A R Karthick07608ef2016-08-23 16:51:19 -0700944 parser_setup.add_argument('-l', '--olt', action='store_true', help='Use OLT config')
A R Karthick92a0e5a2016-06-22 17:11:05 -0700945 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 -0700946 parser_setup.add_argument('-c', '--onos-cord', default='', type=str,
947 help='Specify cord location for ONOS cord when running on podd')
A R Karthick07608ef2016-08-23 16:51:19 -0700948 parser_setup.add_argument('-m', '--manifest', default='', type=str, help='Provide test configuration manifest')
949 parser_setup.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
950 parser_setup.add_argument('-i', '--identity-file', default=identity_file_default,
951 type=str, help='ssh identity file to access compute nodes from test container')
A R Karthick2b93d6a2016-09-06 15:19:09 -0700952 parser_setup.add_argument('-n', '--onos-instances', default=1, type=int,
953 help='Specify number of test onos instances to spawn')
A R Karthick81acbff2016-06-17 14:45:16 -0700954 parser_setup.set_defaults(func=setupCordTester)
955
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700956 parser_xos = subparser.add_parser('xos', help='Building xos into cord tester environment')
957 parser_xos.add_argument('-x', '--xosAllContainers', action='store_true',help='Provision all containers of XOS for CORD')
A R Karthicke3bde962016-09-27 15:06:35 -0700958 parser_xos.add_argument('-xserver', '--xosServer',action='store_true',help='Provision xos server container')
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700959 parser_xos.add_argument('-xsos', '--xosSyncOpenstack',action='store_true',help='Provision xos synchronizer openstack container')
960 parser_xos.add_argument('-xo', '--xosOpenvpn',action='store_true',help='Provision xos openvpn container')
961 parser_xos.add_argument('-xp', '--xosPostgresql',action='store_true',help='Provision xos postgresql')
962 parser_xos.add_argument('-xs', '--xosSynchronizer',action='store_true',help='Provision xos synchronizer')
963 parser_xos.add_argument('-xsm', '--xosSyndicateMs',action='store_true',help='Provision xos syndicate-ms')
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700964 parser_xos.add_argument('-xsonb', '--xosSyncOnboarding',action='store_true',help='Provision xos synchronizer onboarding container')
965 parser_xos.set_defaults(func=xosContainers)
966
Chetan Gaonker503032a2016-05-12 12:06:29 -0700967 parser_list = subparser.add_parser('list', help='List test cases')
968 parser_list.add_argument('-t', '--test', default='all', help='Specify test type to list test cases. '
969 'Eg: -t tls to list tls test cases.'
970 ' -t tls-dhcp-vrouter to list tls,dhcp and vrouter test cases.'
971 ' -t all to list all test cases.')
972 parser_list.set_defaults(func=listTests)
973
974 parser_build = subparser.add_parser('build', help='Build cord test container images')
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -0700975 parser_build.add_argument('image', choices=['quagga', 'radius', 'test','all'])
A.R Karthick842f0122016-09-28 14:48:47 -0700976 parser_build.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700977 parser_build.set_defaults(func=buildImages)
978
ChetanGaonkereadad482016-08-26 01:21:47 -0700979 parser_metrics = subparser.add_parser('metrics', help='Info of container')
980 parser_metrics.add_argument("container", help="Container name")
981 parser_metrics.set_defaults(func=getMetrics)
982
A R Karthickbec27762016-07-28 10:59:34 -0700983 parser_start = subparser.add_parser('start', help='Start cord tester containers')
A R Karthick07608ef2016-08-23 16:51:19 -0700984 parser_start.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
985 parser_start.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
A R Karthickbec27762016-07-28 10:59:34 -0700986 parser_start.add_argument('image', choices=['onos', 'quagga', 'radius', 'all'])
987 parser_start.set_defaults(func=startImages)
988
Chetan Gaonker503032a2016-05-12 12:06:29 -0700989 parser_cleanup = subparser.add_parser('cleanup', help='Cleanup test containers')
A R Karthick07608ef2016-08-23 16:51:19 -0700990 parser_cleanup.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
991 parser_cleanup.add_argument('-l', '--olt', action = 'store_true', help = 'Cleanup OLT config')
A R Karthick2b93d6a2016-09-06 15:19:09 -0700992 parser_cleanup.add_argument('-o', '--onos', default=onos_image_default, type=str,
993 help='ONOS container image to cleanup')
A.R Karthick842f0122016-09-28 14:48:47 -0700994 parser_cleanup.add_argument('-x', '--xos', action='store_true',
995 help='Cleanup XOS containers')
A R Karthicke99ab5c2016-09-30 13:59:57 -0700996 parser_cleanup.add_argument('-r', '--server', default=cord_test_server_address, type=str,
997 help='ip:port address for cord test server to cleanup')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700998 parser_cleanup.set_defaults(func=cleanupTests)
999
ChetanGaonkereadad482016-08-26 01:21:47 -07001000 c = Client(**(kwargs_from_env()))
1001
Chetan Gaonker93e302d2016-04-05 10:51:07 -07001002 args = parser.parse_args()
A R Karthick9a5edc42016-08-24 19:10:22 -07001003 res = args.func(args)
1004 sys.exit(res)