blob: 773d155123c2c707727a51be5ab404466f70be98 [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')
A R Karthick03bd2812017-03-03 17:49:17 -080021cli_dir = os.path.join( os.path.dirname(os.path.realpath(__file__)), '../cli')
Chetan Gaonker7142a342016-04-07 14:53:12 -070022sys.path.append(utils_dir)
A R Karthick03bd2812017-03-03 17:49:17 -080023sys.path.append(cli_dir)
ChetanGaonker68a047f2016-10-12 10:31:48 -070024sys.path.insert(1, '/usr/local/lib/python2.7/dist-packages')
A.R Karthickbe7768c2017-03-17 11:39:41 -070025from CordTestUtils import get_mac
26from OnosCtrl import OnosCtrl
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070027from OltConfig import OltConfig
A R Karthick946141b2017-01-24 16:37:47 -080028from OnosFlowCtrl import OnosFlowCtrl
A R Karthick1f03e912016-05-18 11:39:22 -070029from threadPool import ThreadPool
Chetan Gaonker3533faa2016-04-25 17:50:14 -070030from CordContainer import *
A R Karthicke99ab5c2016-09-30 13:59:57 -070031from 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 -070032from TestManifest import TestManifest
A.R Karthick57fa9372017-05-24 12:47:03 -070033from VolthaCtrl import VolthaService
ChetanGaonkereadad482016-08-26 01:21:47 -070034from docker import Client
35from docker.utils import kwargs_from_env
A R Karthickea8bfce2016-10-13 16:32:07 -070036from Xos import XosServiceProfile
A R Karthick07608ef2016-08-23 16:51:19 -070037try:
38 from Fabric import FabricMAAS
39except:
40 FabricMAAS = None
Chetan Gaonker93e302d2016-04-05 10:51:07 -070041
Chetan Gaonker93e302d2016-04-05 10:51:07 -070042class CordTester(Container):
Chetan Gaonker93e302d2016-04-05 10:51:07 -070043 sandbox = '/root/test'
Chetan Gaonker7142a342016-04-07 14:53:12 -070044 sandbox_setup = '/root/test/src/test/setup'
Chetan Gaonker4d842ad2016-04-26 10:04:24 -070045 tester_base = os.path.dirname(os.path.realpath(__file__))
46 tester_paths = os.path.realpath(__file__).split(os.path.sep)
A R Karthickb7e80902016-05-17 09:38:31 -070047 tester_path_index = tester_paths.index('src') - 1
Chetan Gaonker7142a342016-04-07 14:53:12 -070048 sandbox_host = os.path.sep.join(tester_paths[:tester_path_index+1])
Chetan Gaonker93e302d2016-04-05 10:51:07 -070049
50 host_guest_map = ( (sandbox_host, sandbox),
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070051 ('/lib/modules', '/lib/modules'),
52 ('/var/run/docker.sock', '/var/run/docker.sock')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070053 )
54 basename = 'cord-tester'
A R Karthick36cfcef2016-08-18 15:20:07 -070055 switch_on_olt = False
A R Karthickf7a613b2017-02-24 09:36:44 -080056 IMAGE = 'cordtest/nose'
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -070057 ALL_TESTS = ('tls', 'dhcp', 'dhcprelay','igmp', 'subscriber',
58 'cordSubscriber', 'vrouter', 'flows', 'proxyarp', 'acl', 'xos', 'fabric',
Chetan Gaonkerefb55282017-01-27 23:07:41 +000059 'cbench', 'cluster', 'netCondition', 'cordvtn', 'iperf', 'mini', 'vsg')
Chetan Gaonker93e302d2016-04-05 10:51:07 -070060
A R Karthicka013a272016-08-16 16:40:19 -070061 def __init__(self, tests, instance = 0, num_instances = 1, ctlr_ip = None,
A R Karthick07608ef2016-08-23 16:51:19 -070062 name = '', image = IMAGE, prefix = '', tag = 'candidate',
A R Karthick85eb1862017-01-23 16:10:57 -080063 env = None, rm = False, update = False, network = None):
A R Karthick1f03e912016-05-18 11:39:22 -070064 self.tests = tests
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -070065 self.ctlr_ip = ctlr_ip
Chetan Gaonker93e302d2016-04-05 10:51:07 -070066 self.rm = rm
A R Karthicke4660f52017-02-23 12:08:41 -080067 self.name = name or self.get_name(num_instances)
A R Karthick07608ef2016-08-23 16:51:19 -070068 super(CordTester, self).__init__(self.name, image = image, prefix = prefix, tag = tag)
Chetan Gaonker93e302d2016-04-05 10:51:07 -070069 host_config = self.create_host_config(host_guest_map = self.host_guest_map, privileged = True)
70 volumes = []
Chetan Gaonkerb84835f2016-04-19 15:12:10 -070071 for _, g in self.host_guest_map:
Chetan Gaonker93e302d2016-04-05 10:51:07 -070072 volumes.append(g)
Chetan Gaonker85b7bd52016-04-20 10:29:12 -070073 if update is True or not self.img_exists():
A R Karthick07608ef2016-08-23 16:51:19 -070074 self.build_image(self.image_name)
A R Karthicka013a272016-08-16 16:40:19 -070075 self.create = True
76 #check if are trying to run tests on existing container
A R Karthicke4660f52017-02-23 12:08:41 -080077 if not self.exists():
A R Karthicka013a272016-08-16 16:40:19 -070078 ##Remove test container if any
79 self.remove_container(self.name, force=True)
80 else:
81 self.create = False
A R Karthicke4660f52017-02-23 12:08:41 -080082 self.rm = False
A R Karthick078e63a2016-07-28 13:59:31 -070083 self.olt = False
A.R Karthick5968e0d2017-05-16 14:50:46 -070084 olt_config_file = 'olt_config.json'
85 if env is not None:
86 if env.has_key('OLT_CONFIG'):
87 self.olt = True
88 if env.has_key('OLT_CONFIG_FILE'):
89 olt_config_file = os.path.basename(env['OLT_CONFIG_FILE'])
90
91 olt_conf_file = os.path.join(self.tester_base, olt_config_file)
A R Karthick078e63a2016-07-28 13:59:31 -070092 olt_config = OltConfig(olt_conf_file)
93 self.port_map, _ = olt_config.olt_port_map()
A.R Karthick369f89e2017-03-02 15:22:45 -080094 self.vcpes = olt_config.get_vcpes()
A R Karthick078e63a2016-07-28 13:59:31 -070095 #Try using the host interface in olt conf to setup the switch
A.R Karthick88e80b92016-12-05 20:23:45 -080096 self.switches = self.port_map['switches']
A R Karthick1f03e912016-05-18 11:39:22 -070097 if env is not None:
A.R Karthick88e80b92016-12-05 20:23:45 -080098 env['TEST_SWITCH'] = self.switches[0]
99 env['TEST_SWITCHES'] = ','.join(self.switches)
A R Karthick1f03e912016-05-18 11:39:22 -0700100 env['TEST_HOST'] = self.name
101 env['TEST_INSTANCE'] = instance
102 env['TEST_INSTANCES'] = num_instances
A R Karthicka013a272016-08-16 16:40:19 -0700103 if self.create:
104 print('Starting test container %s, image %s, tag %s' %(self.name, self.image, self.tag))
105 self.start(rm = False, volumes = volumes, environment = env,
106 host_config = host_config, tty = True)
A R Karthick85eb1862017-01-23 16:10:57 -0800107 if network is not None:
108 Container.connect_to_network(self.name, network)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700109
A.R Karthicke4631062016-11-03 14:28:19 -0700110 def execute_switch(self, cmd, shell = False):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700111 if self.olt:
112 return os.system(cmd)
113 return self.execute(cmd, shell = shell)
114
A R Karthick946141b2017-01-24 16:37:47 -0800115 def test_flow(self, switch):
116 if not self.olt:
117 return False
118 egress = 1
119 ingress = 2
120 egress_map = { 'ether': '00:00:00:00:00:03', 'ip': '192.168.30.1' }
121 ingress_map = { 'ether': '00:00:00:00:00:04', 'ip': '192.168.40.1' }
122 device_id = 'of:{}'.format(get_mac(switch))
A R Karthick973010f2017-02-06 16:41:51 -0800123 ctlr = self.ctlr_ip.split(',')[0]
A R Karthick946141b2017-01-24 16:37:47 -0800124 flow = OnosFlowCtrl(deviceId = device_id,
125 egressPort = egress,
126 ingressPort = ingress,
127 ethType = '0x800',
128 ipSrc = ('IPV4_SRC', ingress_map['ip']+'/32'),
129 ipDst = ('IPV4_DST', egress_map['ip']+'/32'),
A R Karthick973010f2017-02-06 16:41:51 -0800130 controller = ctlr
A R Karthick946141b2017-01-24 16:37:47 -0800131 )
132 result = flow.addFlow()
133 if result != True:
134 return result
135 time.sleep(1)
136 #find and remove the flow
137 flow_id = flow.findFlow(device_id, IN_PORT = ('port', ingress),
138 ETH_TYPE = ('ethType','0x800'), IPV4_SRC = ('ip', ingress_map['ip']+'/32'),
139 IPV4_DST = ('ip', egress_map['ip']+'/32'))
140 result = False
141 if flow_id:
142 result = True
143 flow.removeFlow(device_id, flow_id)
144 return result
145
146 def ctlr_switch_availability(self, switch):
147 '''Test Add and verify flows with IPv4 selectors'''
148 if not self.olt:
149 return False
150 device_id = 'of:{}'.format(get_mac(switch))
A R Karthick973010f2017-02-06 16:41:51 -0800151 ctlr = self.ctlr_ip.split(',')[0]
152 devices = OnosCtrl.get_devices(controller = ctlr)
A R Karthick946141b2017-01-24 16:37:47 -0800153 if devices:
154 device = filter(lambda d: d['id'] == device_id, devices)
155 return True
156 return False
157
A R Karthick078e63a2016-07-28 13:59:31 -0700158 def start_switch(self, boot_delay = 2):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700159 """Start OVS"""
160 ##Determine if OVS has to be started locally or not
161 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 -0800162 ovs_cmd = os.path.join(s_sandbox, s_file)
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700163 if self.olt:
A R Karthick36cfcef2016-08-18 15:20:07 -0700164 if CordTester.switch_on_olt is True:
165 return
166 CordTester.switch_on_olt = True
A.R Karthick88e80b92016-12-05 20:23:45 -0800167 ovs_cmd += ' {} {}'.format(len(self.switches), self.ctlr_ip)
168 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 -0700169 else:
A.R Karthick88e80b92016-12-05 20:23:45 -0800170 ovs_cmd += ' {}'.format(self.switches[0])
171 print('Starting OVS on test container %s for controller: %s' %(self.name, self.ctlr_ip))
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700172 self.execute_switch(ovs_cmd)
A R Karthick946141b2017-01-24 16:37:47 -0800173 time.sleep(5)
174 ## Wait for the controller to see the switch
A.R Karthick88e80b92016-12-05 20:23:45 -0800175 for switch in self.switches:
176 status = 1
177 tries = 0
A R Karthick946141b2017-01-24 16:37:47 -0800178 result = self.ctlr_switch_availability(switch) and self.test_flow(switch)
179 if result == True:
180 status = 0
A.R Karthick88e80b92016-12-05 20:23:45 -0800181 while status != 0 and tries < 500:
182 cmd = 'sudo ovs-ofctl dump-flows {0} | grep \"type=0x8942\"'.format(switch)
183 status = self.execute_switch(cmd, shell = True)
184 tries += 1
A R Karthick946141b2017-01-24 16:37:47 -0800185 if status != 0 and tries > 100:
186 if self.ctlr_switch_availability(switch):
187 status = 0
A.R Karthick88e80b92016-12-05 20:23:45 -0800188 if tries % 10 == 0:
189 print('Waiting for test switch %s to be connected to ONOS controller ...' %switch)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700190
A.R Karthick88e80b92016-12-05 20:23:45 -0800191 if status != 0:
192 print('Test Switch %s not connected to ONOS container.'
193 'Please remove ONOS container and restart the test' %switch)
194 if self.rm:
195 self.kill()
196 sys.exit(1)
197 else:
198 print('Test Switch %s connected to ONOS container.' %switch)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700199
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700200 if boot_delay:
201 time.sleep(boot_delay)
202
A.R Karthick369f89e2017-03-02 15:22:45 -0800203 def setup_vcpes(self, port_num = 0):
204 res = 0
205 for vcpe in self.vcpes:
206 port, s_tag, c_tag = vcpe['port'], vcpe['s_tag'], vcpe['c_tag']
207 if os.access('/sys/class/net/{}'.format(port), os.F_OK):
208 guest_port = 'vcpe{}'.format(port_num)
209 port_num += 1
A.R Karthick5968e0d2017-05-16 14:50:46 -0700210 print('Provisioning guest port %s for %s with host port: %s, s_tag: %d, c_tag: %d\n'
211 %(guest_port, self.name, port, s_tag, c_tag))
A.R Karthick369f89e2017-03-02 15:22:45 -0800212 cmd = 'pipework {} -i {} -l {} {} 0.0.0.0/24'.format(port, guest_port, guest_port, self.name)
213 res = os.system(cmd)
214 if res == 0:
215 vlan_outer_port = '{}.{}'.format(guest_port, s_tag)
216 vlan_inner_port = '{}.{}'.format(vlan_outer_port, c_tag)
217 #configure the s_tag/c_tag interfaces inside the guest container
218 cmds = ('ip link set {} up'.format(guest_port),
219 'ip link add link {} name {} type vlan id {}'.format(guest_port,
220 vlan_outer_port,
221 s_tag),
222 'ip link set {} up'.format(vlan_outer_port),
223 'ip link add link {} name {} type vlan id {}'.format(vlan_outer_port,
224 vlan_inner_port,
225 c_tag),
226 'ip link set {} up'.format(vlan_inner_port),
227 )
228 res += self.execute(cmds, shell = True)
229
230 @classmethod
231 def cleanup_vcpes(cls, vcpes):
232 port_num = 0
233 for vcpe in vcpes:
234 port = vcpe['port']
235 if os.access('/sys/class/net/{}'.format(port), os.F_OK):
236 local_port = 'vcpe{}'.format(port_num)
237 cmd = 'ip link del {}'.format(local_port)
238 os.system(cmd)
239 port_num += 1
240
A R Karthick1f03e912016-05-18 11:39:22 -0700241 def setup_intfs(self, port_num = 0):
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700242 tester_intf_subnet = '192.168.100'
243 res = 0
A.R Karthick88e80b92016-12-05 20:23:45 -0800244 switches = self.port_map['switches']
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700245 start_vlan = self.port_map['start_vlan']
A R Karthick07769362016-07-28 17:36:15 -0700246 start_vlan += port_num
247 uplink = self.port_map['uplink']
248 wan = self.port_map['wan']
A.R Karthick369f89e2017-03-02 15:22:45 -0800249 vcpe_port_num = port_num
A.R Karthick88e80b92016-12-05 20:23:45 -0800250 port_list = self.port_map['switch_port_list'] + self.port_map['switch_relay_port_list']
A R Karthick52414732017-01-31 09:59:47 -0800251 print('Provisioning the ports for the test container\n')
A.R Karthick88e80b92016-12-05 20:23:45 -0800252 for host_intf, ports in port_list:
A R Karthickf97ee132017-03-23 09:48:37 -0700253 #if the host interface/switch does not exist, just create a dummy ovs switch
254 #needed if we are running with no-switch option
255 if not os.access('/sys/class/net/{}'.format(host_intf), os.F_OK):
256 os.system('ovs-vsctl add-br {}'.format(host_intf))
A.R Karthick88e80b92016-12-05 20:23:45 -0800257 uplink = self.port_map[host_intf]['uplink']
258 for port in ports:
259 guest_if = port
A R Karthicke4660f52017-02-23 12:08:41 -0800260 local_if = 'l{}'.format(port_num+1) #port #'{0}_{1}'.format(guest_if, port_num+1)
A.R Karthick88e80b92016-12-05 20:23:45 -0800261 guest_ip = '{0}.{1}/24'.format(tester_intf_subnet, port_num+1)
262 ##Use pipeworks to configure container interfaces on host/bridge interfaces
263 pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(host_intf, guest_if,
A R Karthick07769362016-07-28 17:36:15 -0700264 local_if, self.name, guest_ip)
A.R Karthick88e80b92016-12-05 20:23:45 -0800265 #if the wan interface is specified for uplink, then use it instead
266 if wan and port == self.port_map[uplink]:
267 pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(wan, guest_if,
268 local_if, self.name, guest_ip)
269 else:
270 if start_vlan != 0:
271 pipework_cmd += ' @{}'.format(start_vlan)
272 start_vlan += 1
273 #print('Running PIPEWORK cmd: %s' %pipework_cmd)
274 res += os.system(pipework_cmd)
275 port_num += 1
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700276
A.R Karthick369f89e2017-03-02 15:22:45 -0800277 self.setup_vcpes(vcpe_port_num)
A R Karthick1f03e912016-05-18 11:39:22 -0700278 return res, port_num
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700279
280 @classmethod
A.R Karthick88e80b92016-12-05 20:23:45 -0800281 def get_intf_type(cls, intf):
282 intf_type = 0
283 if os.path.isdir('/sys/class/net/{}/bridge'.format(intf)):
284 intf_type = 1 ##linux bridge
285 else:
286 cmd = 'ovs-vsctl list-br | grep -q "^{0}$"'.format(intf)
287 res = os.system(cmd)
288 if res == 0: ##ovs bridge
289 intf_type = 2
290
291 return intf_type
292
293 @classmethod
A.R Karthick5968e0d2017-05-16 14:50:46 -0700294 def cleanup_intfs(cls, olt_conf_file):
295 if not os.access(olt_conf_file, os.F_OK):
296 olt_conf_file = os.path.join(cls.tester_base, os.path.basename(olt_conf_file))
A R Karthickb50f5592016-07-26 12:19:29 -0700297 olt_config = OltConfig(olt_conf_file)
A R Karthickb03cecd2016-07-27 10:27:55 -0700298 port_map, _ = olt_config.olt_port_map()
A.R Karthick369f89e2017-03-02 15:22:45 -0800299 vcpes = olt_config.get_vcpes()
A R Karthickb50f5592016-07-26 12:19:29 -0700300 port_num = 0
A R Karthickb50f5592016-07-26 12:19:29 -0700301 start_vlan = port_map['start_vlan']
A R Karthick07769362016-07-28 17:36:15 -0700302 wan = port_map['wan']
A R Karthickb50f5592016-07-26 12:19:29 -0700303 cmds = ()
304 res = 0
A.R Karthick88e80b92016-12-05 20:23:45 -0800305 port_list = port_map['switch_port_list'] + port_map['switch_relay_port_list']
306 for intf_host, ports in port_list:
307 intf_type = cls.get_intf_type(intf_host)
308 for port in ports:
A R Karthicke4660f52017-02-23 12:08:41 -0800309 local_if = 'l{}'.format(port_num+1) #port #'{0}_{1}'.format(port, port_num+1)
A.R Karthick88e80b92016-12-05 20:23:45 -0800310 if intf_type == 0:
311 if start_vlan != 0:
312 cmds = ('ip link del {}.{}'.format(intf_host, start_vlan),)
313 start_vlan += 1
A R Karthickb50f5592016-07-26 12:19:29 -0700314 else:
A.R Karthick88e80b92016-12-05 20:23:45 -0800315 if intf_type == 1:
316 cmds = ('brctl delif {} {}'.format(intf_host, local_if),
317 'ip link del {}'.format(local_if))
318 else:
319 cmds = ('ovs-vsctl del-port {} {}'.format(intf_host, local_if),
320 'ip link del {}'.format(local_if))
A R Karthickb50f5592016-07-26 12:19:29 -0700321
A.R Karthick88e80b92016-12-05 20:23:45 -0800322 for cmd in cmds:
323 res += os.system(cmd)
324 port_num += 1
A R Karthickb50f5592016-07-26 12:19:29 -0700325
A.R Karthick369f89e2017-03-02 15:22:45 -0800326 cls.cleanup_vcpes(vcpes)
327
A R Karthickb50f5592016-07-26 12:19:29 -0700328 @classmethod
A R Karthicke4660f52017-02-23 12:08:41 -0800329 def get_name(cls, num_instances):
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700330 cnt_name = '/{0}'.format(cls.basename)
331 cnt_name_len = len(cnt_name)
332 names = list(flatten(n['Names'] for n in cls.dckr.containers(all=True)))
333 test_names = filter(lambda n: n.startswith(cnt_name), names)
334 last_cnt_number = 0
335 if test_names:
336 last_cnt_name = reduce(lambda n1, n2: n1 if int(n1[cnt_name_len:]) > \
337 int(n2[cnt_name_len:]) else n2,
338 test_names)
339 last_cnt_number = int(last_cnt_name[cnt_name_len:])
A R Karthicke4660f52017-02-23 12:08:41 -0800340 if num_instances == 1:
341 last_cnt_number -= 1
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700342 test_cnt_name = cls.basename + str(last_cnt_number+1)
343 return test_cnt_name
344
345 @classmethod
346 def build_image(cls, image):
347 print('Building test container docker image %s' %image)
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700348 ovs_version = '2.5.0'
349 image_format = (ovs_version,)*4
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700350 dockerfile = '''
351FROM ubuntu:14.04
352MAINTAINER chetan@ciena.com
A R Karthickc762df42016-05-25 10:09:21 -0700353RUN apt-get update && \
354 apt-get install -y git git-core autoconf automake autotools-dev pkg-config \
355 make gcc g++ libtool libc6-dev cmake libpcap-dev libxerces-c2-dev \
356 unzip libpcre3-dev flex bison libboost-dev \
357 python python-pip python-setuptools python-scapy tcpdump doxygen doxypy wget \
358 openvswitch-common openvswitch-switch \
A R Karthick07608ef2016-08-23 16:51:19 -0700359 python-twisted python-sqlite sqlite3 python-pexpect telnet arping isc-dhcp-server \
Chetan Gaonker53f16382017-02-20 20:31:22 +0000360 python-paramiko python-maas-client python-keystoneclient python-neutronclient \
A R Karthickc28f6a92017-04-18 16:05:18 -0700361 python-glanceclient python-novaclient python-dev libffi-dev libssl-dev
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700362RUN easy_install nose
A R Karthickc28f6a92017-04-18 16:05:18 -0700363RUN python -m pip install --upgrade pip
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700364RUN mkdir -p /root/ovs
365WORKDIR /root
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700366RUN wget http://openvswitch.org/releases/openvswitch-{}.tar.gz -O /root/ovs/openvswitch-{}.tar.gz && \
367(cd /root/ovs && tar zxpvf openvswitch-{}.tar.gz && \
368 cd openvswitch-{} && \
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700369 ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && make && make install)
370RUN service openvswitch-switch restart || /bin/true
A.R Karthickec5b72a2016-11-03 09:53:07 -0700371RUN pip install scapy==2.3.2 scapy-ssl_tls==1.2.2 monotonic configObj docker-py pyyaml nsenter pyroute2 netaddr python-daemon
A R Karthickc28f6a92017-04-18 16:05:18 -0700372RUN pip install -U cryptography
373RUN pip install -U paramiko
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700374RUN mv /usr/sbin/tcpdump /sbin/
375RUN ln -sf /sbin/tcpdump /usr/sbin/tcpdump
A R Karthickf4999472016-07-01 16:42:13 -0700376RUN mv /usr/sbin/dhcpd /sbin/
377RUN ln -sf /sbin/dhcpd /usr/sbin/dhcpd
A.R Karthickcaf82ac2017-04-17 17:45:24 -0700378RUN mv /sbin/dhclient /usr/sbin/
379RUN ln -sf /usr/sbin/dhclient /sbin/dhclient
A R Karthickb7e80902016-05-17 09:38:31 -0700380WORKDIR /root
381RUN wget -nc http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/bison_2.5.dfsg-2.1_amd64.deb \
382 http://de.archive.ubuntu.com/ubuntu/pool/main/b/bison/libbison-dev_2.5.dfsg-2.1_amd64.deb
383RUN sudo dpkg -i bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb
384RUN rm bison_2.5.dfsg-2.1_amd64.deb libbison-dev_2.5.dfsg-2.1_amd64.deb
385RUN wget -nc http://www.nbee.org/download/nbeesrc-jan-10-2013.zip && \
386 unzip nbeesrc-jan-10-2013.zip && \
387 cd nbeesrc-jan-10-2013/src && cmake . && make && \
388 cp ../bin/libn*.so /usr/local/lib && ldconfig && \
389 cp -R ../include/* /usr/include/
390WORKDIR /root
391RUN git clone https://github.com/CPqD/ofsoftswitch13.git && \
392 cd ofsoftswitch13 && \
A R Karthickb7e80902016-05-17 09:38:31 -0700393 ./boot.sh && \
394 ./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && \
395 make && make install
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700396CMD ["/bin/bash"]
Chetan Gaonkerb6064fa2016-05-02 16:29:57 -0700397'''.format(*image_format)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700398 super(CordTester, cls).build_image(dockerfile, image)
399 print('Done building docker image %s' %image)
400
A R Karthick1f03e912016-05-18 11:39:22 -0700401 def run_tests(self):
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700402 '''Run the list of tests'''
A R Karthick9a5edc42016-08-24 19:10:22 -0700403 res = 0
Thangavelu K Sef6f0a52016-12-14 19:57:05 +0000404 print('Modifying scapy tool files before running a test: %s' %self.tests)
405 self.modify_scapy_files_for_specific_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700406 print('Running tests: %s' %self.tests)
407 for t in self.tests:
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700408 test = t.split(':')[0]
A R Karthick24f1de62016-05-12 15:16:38 -0700409 test_file = '{}Test.py'.format(test)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700410 if t.find(':') >= 0:
A R Karthick24f1de62016-05-12 15:16:38 -0700411 test_case = '{0}:{1}'.format(test_file, t.split(':')[1])
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700412 else:
413 test_case = test_file
Chetan Gaonker7142a342016-04-07 14:53:12 -0700414 cmd = 'nosetests -v {0}/src/test/{1}/{2}'.format(self.sandbox, test, test_case)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700415 status = self.execute(cmd, shell = True)
A R Karthick9a5edc42016-08-24 19:10:22 -0700416 if status > 255:
417 status = 1
418 res |= status
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700419 print('Test %s %s' %(test_case, 'Success' if status == 0 else 'Failure'))
420 print('Done running tests')
421 if self.rm:
422 print('Removing test container %s' %self.name)
423 self.kill(remove=True)
424
A R Karthick9a5edc42016-08-24 19:10:22 -0700425 return res
426
Thangavelu K Sef6f0a52016-12-14 19:57:05 +0000427 def modify_scapy_files_for_specific_tests(self):
428 name = self.name
A R Karthickf7a613b2017-02-24 09:36:44 -0800429 container_cmd_exec = Container(name = name, image = CordTester.IMAGE)
Thangavelu K Sef6f0a52016-12-14 19:57:05 +0000430 tty = False
431 dckr = Client()
432 cmd = 'cp test/src/test/scapy/fields.py /usr/local/lib/python2.7/dist-packages/scapy/fields.py '
433 i = container_cmd_exec.execute(cmd = cmd, tty= tty, stream = True)
434
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700435 @classmethod
436 def list_tests(cls, tests):
437 print('Listing test cases')
438 for test in tests:
A R Karthick24f1de62016-05-12 15:16:38 -0700439 test_file = '{}Test.py'.format(test)
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700440 cmd = 'nosetests -v --collect-only {0}/../{1}/{2}'.format(cls.tester_base, test, test_file)
441 os.system(cmd)
442
A R Karthicka013a272016-08-16 16:40:19 -0700443
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700444##default onos/radius/test container images and names
445onos_image_default='onosproject/onos:latest'
A R Karthick07608ef2016-08-23 16:51:19 -0700446nose_image_default= '{}:candidate'.format(CordTester.IMAGE)
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700447test_type_default='dhcp'
A R Karthickb608d402017-06-02 11:48:41 -0700448onos_app_version = '3.0-SNAPSHOT'
Chetan Gaonker4d842ad2016-04-26 10:04:24 -0700449cord_tester_base = os.path.dirname(os.path.realpath(__file__))
A.R Karthick5968e0d2017-05-16 14:50:46 -0700450olt_config_default = os.path.join(cord_tester_base, 'olt_config.json')
Chetan Gaonker4ca5cca2016-04-11 13:59:35 -0700451onos_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 -0700452cord_test_server_address = '{}:{}'.format(CORD_TEST_HOST, CORD_TEST_PORT)
A R Karthick07608ef2016-08-23 16:51:19 -0700453identity_file_default = '/etc/maas/ansible/id_rsa'
A R Karthicke14fc022016-12-08 14:50:29 -0800454onos_log_level = 'INFO'
A R Karthick07608ef2016-08-23 16:51:19 -0700455
456##sets up the ssh key file for the test container
457def set_ssh_key_file(identity_file):
458 ssh_key_file = None
459 if os.access(identity_file, os.F_OK):
460 ##copy it to setup directory
461 identity_dest = os.path.join(CordTester.tester_base, 'id_rsa')
462 if os.path.abspath(identity_file) != identity_dest:
463 try:
464 shutil.copy(identity_file, identity_dest)
465 ssh_key_file = os.path.join(CordTester.sandbox_setup, 'id_rsa')
466 except: pass
467
468 return ssh_key_file
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700469
A R Karthickcaac5542017-03-06 16:20:57 -0800470def openstack_setup(test_cnt_env):
471 admin_rc = os.path.join(os.getenv('HOME'), 'admin-openrc.sh')
472 if os.access(admin_rc, os.F_OK):
473 dest = os.path.join(CordTester.tester_base, 'admin-openrc.sh')
474 shutil.copy(admin_rc, dest)
475 with open(dest, 'r') as f:
476 cfg = {}
477 for data in f.read().splitlines():
478 try:
479 k, v = data.split('=')
480 except:
481 continue
482
483 k = k.split()[-1]
484 cfg[k] = v
485
486 if 'REQUESTS_CA_BUNDLE' in cfg:
487 #copy the certificate to setup directory
488 cert_src = cfg['REQUESTS_CA_BUNDLE']
489 shutil.copy(cert_src, CordTester.tester_base)
490 test_cert_loc = os.path.join(CordTester.sandbox_setup,
491 os.path.basename(cert_src))
492 cfg['REQUESTS_CA_BUNDLE'] = test_cert_loc
493
494 for key, value in cfg.iteritems():
495 test_cnt_env[key] = value
496
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700497def runTest(args):
Chetan Gaonker823cdc52016-05-09 15:51:23 -0700498 #Start the cord test tcp server
A.R Karthickb17e2022017-01-27 11:29:26 -0800499 test_manifest = TestManifest(args = args)
500 test_server_params = test_manifest.server.split(':')
A R Karthick81acbff2016-06-17 14:45:16 -0700501 test_host = test_server_params[0]
502 test_port = CORD_TEST_PORT
503 if len(test_server_params) > 1:
504 test_port = int(test_server_params[1])
A R Karthick81acbff2016-06-17 14:45:16 -0700505
A R Karthick1f03e912016-05-18 11:39:22 -0700506 test_containers = []
507 #These tests end up restarting ONOS/quagga/radius
A R Karthick4e0c0912016-08-17 16:57:42 -0700508 tests_exempt = ('vrouter', 'cordSubscriber', 'proxyarp', 'dhcprelay')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700509 if args.test_type.lower() == 'all':
510 tests = CordTester.ALL_TESTS
Chetan Gaonker503032a2016-05-12 12:06:29 -0700511 args.quagga = True
512 else:
A R Karthickacae3b42016-05-12 15:27:24 -0700513 tests = args.test_type.split('-')
Chetan Gaonker503032a2016-05-12 12:06:29 -0700514
A R Karthick1f03e912016-05-18 11:39:22 -0700515 tests_parallel = [ t for t in tests if t.split(':')[0] not in tests_exempt ]
516 tests_not_parallel = [ t for t in tests if t.split(':')[0] in tests_exempt ]
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700517 onos_cnt = {'tag':'latest'}
A R Karthick07608ef2016-08-23 16:51:19 -0700518 nose_cnt = {'image': CordTester.IMAGE, 'tag': 'candidate'}
Chetan Gaonker503032a2016-05-12 12:06:29 -0700519 update_map = { 'quagga' : False, 'test' : False, 'radius' : False }
520 update_map[args.update.lower()] = True
A.R Karthick95d044e2016-06-10 18:44:36 -0700521
Chetan Gaonker503032a2016-05-12 12:06:29 -0700522 if args.update.lower() == 'all':
523 for c in update_map.keys():
524 update_map[c] = True
A.R Karthick95d044e2016-06-10 18:44:36 -0700525
A R Karthick07608ef2016-08-23 16:51:19 -0700526 use_manifest = False
527 if args.manifest:
528 if os.access(args.manifest, os.F_OK):
529 ##copy it to setup directory
A.R Karthick8b2f1e32017-02-09 15:10:07 -0800530 dest = os.path.join(CordTester.tester_base,
531 os.path.basename(args.manifest))
A R Karthick07608ef2016-08-23 16:51:19 -0700532 if os.path.abspath(args.manifest) != dest:
533 try:
534 shutil.copy(args.manifest, dest)
535 except: pass
A R Karthick65d950d2016-12-19 19:41:55 -0800536 test_manifest = TestManifest(manifest = dest)
A R Karthick07608ef2016-08-23 16:51:19 -0700537 use_manifest = True
538 else:
539 print('Unable to access test manifest: %s' %args.manifest)
Chetan Gaonkerfb3cb5e2016-05-06 11:55:44 -0700540
A R Karthick65d950d2016-12-19 19:41:55 -0800541 onos_ip = test_manifest.onos_ip
542 radius_ip = test_manifest.radius_ip
543 head_node = test_manifest.head_node
A R Karthick5af23712017-01-20 09:49:24 -0800544 iterations = test_manifest.iterations
A.R Karthick263d3fc2017-01-27 12:52:53 -0800545 onos_cord_loc = test_manifest.onos_cord
A.R Karthickf184b342017-01-27 19:30:50 -0800546 service_profile = test_manifest.service_profile
547 synchronizer = test_manifest.synchronizer
A.R Karthick5968e0d2017-05-16 14:50:46 -0700548 olt_config_file = test_manifest.olt_config
A.R Karthick57fa9372017-05-24 12:47:03 -0700549 voltha_loc = test_manifest.voltha_loc
550 voltha_intf = test_manifest.voltha_intf
A.R Karthick5968e0d2017-05-16 14:50:46 -0700551 if not os.access(olt_config_file, os.F_OK):
552 olt_config_file = os.path.join(CordTester.tester_base, 'olt_config.json')
553 else:
554 dest = os.path.join(CordTester.tester_base,
555 os.path.basename(olt_config_file))
556 if os.path.abspath(olt_config_file) != dest:
557 try:
558 shutil.copy(olt_config_file, dest)
559 except: pass
560
A.R Karthickf184b342017-01-27 19:30:50 -0800561 onos_cord = None
A R Karthick973010f2017-02-06 16:41:51 -0800562 Onos.update_data_dir(test_manifest.karaf_version)
563
A.R Karthick263d3fc2017-01-27 12:52:53 -0800564 if onos_cord_loc:
565 if onos_cord_loc.find(os.path.sep) < 0:
566 onos_cord_loc = os.path.join(os.getenv('HOME'), onos_cord_loc)
A.R Karthickf184b342017-01-27 19:30:50 -0800567 if not os.access(onos_cord_loc, os.F_OK):
568 print('ONOS cord config location %s is not accessible' %onos_cord_loc)
569 sys.exit(1)
A.R Karthick263d3fc2017-01-27 12:52:53 -0800570 if not onos_ip:
571 ##Unexpected case. Specify the external controller ip when running on cord node
572 print('Specify ONOS ip using \"-e\" option when running the cord-tester on cord node')
573 sys.exit(1)
A.R Karthickf184b342017-01-27 19:30:50 -0800574 if not service_profile:
A R Karthick03bd2812017-03-03 17:49:17 -0800575 print('Specify service profile for the ONOS cord instance. Eg: rcord')
A.R Karthickf184b342017-01-27 19:30:50 -0800576 sys.exit(1)
577 if not synchronizer:
578 print('Specify synchronizer to use for the ONOS cord instance. Eg: vtn, fabric, cord')
579 sys.exit(1)
A.R Karthickf184b342017-01-27 19:30:50 -0800580 onos_cord = OnosCord(onos_ip, onos_cord_loc, service_profile, synchronizer)
A.R Karthick263d3fc2017-01-27 12:52:53 -0800581
582 try:
583 test_server = cord_test_server_start(daemonize = False, cord_test_host = test_host, cord_test_port = test_port,
584 onos_cord = onos_cord)
585 except:
586 ##Most likely a server instance is already running (daemonized earlier)
587 test_server = None
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700588
A R Karthick65d950d2016-12-19 19:41:55 -0800589 Container.IMAGE_PREFIX = test_manifest.image_prefix
590 Onos.MAX_INSTANCES = test_manifest.onos_instances
A R Karthickc69d73e2017-01-20 11:44:34 -0800591 Onos.JVM_HEAP_SIZE = test_manifest.jvm_heap_size
A R Karthick65d950d2016-12-19 19:41:55 -0800592 cluster_mode = True if test_manifest.onos_instances > 1 else False
593 async_mode = cluster_mode and test_manifest.async_mode
594 existing_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == test_manifest.onos_image ]
595 setup_cluster = False if len(existing_list) == test_manifest.onos_instances else True
A.R Karthickc4e474d2016-12-12 15:24:57 -0800596 onos_ips = []
A R Karthick65d950d2016-12-19 19:41:55 -0800597 if cluster_mode is True and len(existing_list) > 1:
598 ##don't setup cluster config again
599 cluster_mode = False
A R Karthick07608ef2016-08-23 16:51:19 -0700600 if onos_ip is None:
A R Karthick65d950d2016-12-19 19:41:55 -0800601 image_names = test_manifest.onos_image.rsplit(':', 1)
A R Karthick07608ef2016-08-23 16:51:19 -0700602 onos_cnt['image'] = image_names[0]
603 if len(image_names) > 1:
604 if image_names[1].find('/') < 0:
605 onos_cnt['tag'] = image_names[1]
606 else:
607 #tag cannot have slashes
A R Karthick65d950d2016-12-19 19:41:55 -0800608 onos_cnt['image'] = test_manifest.onos_image
A R Karthick07608ef2016-08-23 16:51:19 -0700609
610 Onos.IMAGE = onos_cnt['image']
A R Karthick65d950d2016-12-19 19:41:55 -0800611 Onos.PREFIX = test_manifest.image_prefix
A R Karthick07608ef2016-08-23 16:51:19 -0700612 Onos.TAG = onos_cnt['tag']
A R Karthick65d950d2016-12-19 19:41:55 -0800613 data_volume = '{}-data'.format(Onos.NAME) if test_manifest.shared_volume else None
A R Karthick07608ef2016-08-23 16:51:19 -0700614 onos = Onos(image = Onos.IMAGE,
A.R Karthickc4e474d2016-12-12 15:24:57 -0800615 tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthick85eb1862017-01-23 16:10:57 -0800616 data_volume = data_volume, async = async_mode, network = test_manifest.docker_network)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800617 if onos.running:
A R Karthick65d950d2016-12-19 19:41:55 -0800618 onos_ips.append(onos.ipaddr)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800619 else:
620 onos_ips.append(onos_ip)
621
A R Karthick65d950d2016-12-19 19:41:55 -0800622 num_onos_instances = test_manifest.onos_instances
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700623 if num_onos_instances > 1 and onos is not None:
624 onos_instances = []
625 onos_instances.append(onos)
626 for i in range(1, num_onos_instances):
627 name = '{}-{}'.format(Onos.NAME, i+1)
A R Karthick65d950d2016-12-19 19:41:55 -0800628 data_volume = '{}-data'.format(name) if test_manifest.shared_volume else None
A.R Karthickc4e474d2016-12-12 15:24:57 -0800629 quagga_config = Onos.get_quagga_config(i)
A R Karthickec2db322016-11-17 15:06:01 -0800630 onos = Onos(name = name, image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthick3b811152016-12-15 10:24:24 -0800631 data_volume = data_volume, async = async_mode,
A R Karthick85eb1862017-01-23 16:10:57 -0800632 quagga_config = quagga_config, network = test_manifest.docker_network)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700633 onos_instances.append(onos)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800634 if onos.running:
635 onos_ips.append(onos.ipaddr)
A R Karthick65d950d2016-12-19 19:41:55 -0800636 if async_mode is True and cluster_mode is True:
A.R Karthickc4e474d2016-12-12 15:24:57 -0800637 Onos.start_cluster_async(onos_instances)
638 if not onos_ips:
639 for onos in onos_instances:
640 onos_ips.append(onos.ipaddr)
A R Karthick65d950d2016-12-19 19:41:55 -0800641 if cluster_mode is True:
642 try:
643 for ip in onos_ips:
644 print('Installing cord tester ONOS app %s in ONOS instance %s' %(args.app,ip))
645 OnosCtrl.install_app(args.app, onos_ip = ip)
646 except: pass
A R Karthick1ef70552016-11-17 17:33:36 -0800647 if setup_cluster is True:
648 Onos.setup_cluster(onos_instances)
649 else:
650 print('ONOS instances already running. Skipping ONOS form cluster for %d instances' %num_onos_instances)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700651 ctlr_addr = ','.join(onos_ips)
Chetan Gaonker5209fe82016-04-19 10:09:53 -0700652
A R Karthick65d950d2016-12-19 19:41:55 -0800653 print('Controller IP %s, Test type %s' %(onos_ips, args.test_type))
654 if onos_ip is not None:
A R Karthickbd9b8a32016-07-21 09:56:45 -0700655 print('Installing ONOS cord apps')
A R Karthick07608ef2016-08-23 16:51:19 -0700656 try:
657 Onos.install_cord_apps(onos_ip = onos_ip)
658 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700659
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700660 if not cluster_mode:
661 print('Installing cord tester ONOS app %s' %args.app)
662 try:
663 for ip in onos_ips:
A R Karthick65d950d2016-12-19 19:41:55 -0800664 OnosCtrl.install_app(args.app, onos_ip = ip)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700665 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700666
A.R Karthick57fa9372017-05-24 12:47:03 -0700667 if voltha_loc:
668 #start voltha
669 voltha = VolthaService(voltha_loc, onos_ips[0], interface = voltha_intf)
670 voltha.start()
671
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700672 if radius_ip is None:
A R Karthicka661b552016-05-25 10:18:50 -0700673 ##Start Radius container
A R Karthick85eb1862017-01-23 16:10:57 -0800674 radius = Radius(prefix = Container.IMAGE_PREFIX, update = update_map['radius'],
675 network = test_manifest.docker_network)
A R Karthick75844572017-01-23 16:57:44 -0800676 radius_ip = radius.ip(network = test_manifest.docker_network)
A.R Karthick95d044e2016-06-10 18:44:36 -0700677
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700678 print('Radius server running with IP %s' %radius_ip)
A.R Karthick95d044e2016-06-10 18:44:36 -0700679
Chetan Gaonkerb84835f2016-04-19 15:12:10 -0700680 if args.quagga == True:
681 #Start quagga. Builds container if required
A R Karthick85eb1862017-01-23 16:10:57 -0800682 quagga = Quagga(prefix = Container.IMAGE_PREFIX, update = update_map['quagga'],
683 network = test_manifest.docker_network)
A R Karthick81acbff2016-06-17 14:45:16 -0700684
A R Karthick07608ef2016-08-23 16:51:19 -0700685 try:
686 maas_api_key = FabricMAAS.get_api_key()
687 except:
688 maas_api_key = 'UNKNOWN'
689
690 ssh_key_file = set_ssh_key_file(args.identity_file)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700691 test_cnt_env = { 'ONOS_CONTROLLER_IP' : ctlr_addr,
Chetan Gaonkerc170f3f2016-04-19 17:24:45 -0700692 'ONOS_AAA_IP' : radius_ip if radius_ip is not None else '',
A R Karthick8d03cc52016-06-28 14:51:59 -0700693 'QUAGGA_IP': test_host,
A R Karthick81acbff2016-06-17 14:45:16 -0700694 'CORD_TEST_HOST' : test_host,
695 'CORD_TEST_PORT' : test_port,
A R Karthick65d950d2016-12-19 19:41:55 -0800696 'ONOS_RESTART' : 0 if test_manifest.olt and args.test_controller else 1,
697 'LOG_LEVEL': test_manifest.log_level,
A R Karthick07608ef2016-08-23 16:51:19 -0700698 'HEAD_NODE': head_node if head_node else CORD_TEST_HOST,
A R Karthick973010f2017-02-06 16:41:51 -0800699 'MAAS_API_KEY': maas_api_key,
A.R Karthick57fa9372017-05-24 12:47:03 -0700700 'KARAF_VERSION' : test_manifest.karaf_version,
A.R Karthick4c4d0492017-05-26 19:23:05 -0700701 'VOLTHA_ENABLED' : 1 if voltha_loc else 0
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700702 }
A R Karthick07608ef2016-08-23 16:51:19 -0700703
704 if ssh_key_file:
705 test_cnt_env['SSH_KEY_FILE'] = ssh_key_file
706
A.R Karthick5968e0d2017-05-16 14:50:46 -0700707 olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, os.path.basename(olt_config_file))
708 test_cnt_env['OLT_CONFIG_FILE'] = olt_conf_test_loc
A R Karthick65d950d2016-12-19 19:41:55 -0800709 if test_manifest.olt:
Chetan Gaonker93e302d2016-04-05 10:51:07 -0700710 test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
711
A.R Karthick8b2f1e32017-02-09 15:10:07 -0800712 if use_manifest:
713 test_cnt_env['MANIFEST'] = os.path.join(CordTester.sandbox_setup,
714 os.path.basename(args.manifest))
715
A.R Karthick5968e0d2017-05-16 14:50:46 -0700716
A R Karthick5af23712017-01-20 09:49:24 -0800717 if iterations is not None:
718 test_cnt_env['ITERATIONS'] = iterations
719
A R Karthickcaac5542017-03-06 16:20:57 -0800720 openstack_setup(test_cnt_env)
721
A R Karthicka013a272016-08-16 16:40:19 -0700722 if args.num_containers > 1 and args.container:
723 print('Cannot specify number of containers with container option')
724 sys.exit(1)
725 if args.container:
726 args.keep = True
A R Karthick1f03e912016-05-18 11:39:22 -0700727 port_num = 0
728 num_tests = len(tests_parallel)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700729 if num_tests > 0 and num_tests < args.num_containers:
730 tests_parallel *= args.num_containers/num_tests
731 num_tests = len(tests_parallel)
A R Karthick1f03e912016-05-18 11:39:22 -0700732 tests_per_container = max(1, num_tests/args.num_containers)
A R Karthicke4660f52017-02-23 12:08:41 -0800733 last_batch = num_tests % args.num_containers
A R Karthick1f03e912016-05-18 11:39:22 -0700734 test_slice_start = 0
735 test_slice_end = test_slice_start + tests_per_container
736 num_test_containers = min(num_tests, args.num_containers)
737 if tests_parallel:
738 print('Running %s tests across %d containers in parallel' %(tests_parallel, num_test_containers))
A R Karthicke4660f52017-02-23 12:08:41 -0800739 for container in xrange(num_test_containers):
740 if container + 1 == num_test_containers:
741 test_slice_end += last_batch
A R Karthick1f03e912016-05-18 11:39:22 -0700742 test_cnt = CordTester(tests_parallel[test_slice_start:test_slice_end],
743 instance = container, num_instances = num_test_containers,
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700744 ctlr_ip = ctlr_addr,
A R Karthick07608ef2016-08-23 16:51:19 -0700745 name = args.container,
746 image = nose_cnt['image'],
747 prefix = Container.IMAGE_PREFIX,
748 tag = nose_cnt['tag'],
A R Karthick1f03e912016-05-18 11:39:22 -0700749 env = test_cnt_env,
750 rm = False if args.keep else True,
A R Karthick85eb1862017-01-23 16:10:57 -0800751 update = update_map['test'],
752 network = test_manifest.docker_network)
A R Karthick1f03e912016-05-18 11:39:22 -0700753 test_slice_start = test_slice_end
754 test_slice_end = test_slice_start + tests_per_container
755 update_map['test'] = False
756 test_containers.append(test_cnt)
A R Karthicka013a272016-08-16 16:40:19 -0700757 if not test_cnt.create:
758 continue
A R Karthick65d950d2016-12-19 19:41:55 -0800759 if test_cnt.create and (test_manifest.start_switch or not test_manifest.olt):
A R Karthick07608ef2016-08-23 16:51:19 -0700760 if not args.no_switch:
761 test_cnt.start_switch()
A R Karthicka013a272016-08-16 16:40:19 -0700762 if test_cnt.create and test_cnt.olt:
A R Karthick1f03e912016-05-18 11:39:22 -0700763 _, port_num = test_cnt.setup_intfs(port_num = port_num)
764
A R Karthick9a5edc42016-08-24 19:10:22 -0700765 status = 0
766 if len(test_containers) > 1:
A R Karthicke4660f52017-02-23 12:08:41 -0800767 thread_pool = ThreadPool(len(test_containers), queue_size = 1, wait_timeout=1)
768 for test_cnt in test_containers:
769 thread_pool.addTask(test_cnt.run_tests)
770 thread_pool.cleanUpThreads()
A R Karthick9a5edc42016-08-24 19:10:22 -0700771 else:
A R Karthickcee37412016-08-29 10:10:56 -0700772 if test_containers:
773 status = test_containers[0].run_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700774
775 ##Run the linear tests
776 if tests_not_parallel:
777 test_cnt = CordTester(tests_not_parallel,
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700778 ctlr_ip = ctlr_addr,
A R Karthick07608ef2016-08-23 16:51:19 -0700779 name = args.container,
780 image = nose_cnt['image'],
781 prefix = Container.IMAGE_PREFIX,
782 tag = nose_cnt['tag'],
A R Karthick1f03e912016-05-18 11:39:22 -0700783 env = test_cnt_env,
784 rm = False if args.keep else True,
A R Karthick85eb1862017-01-23 16:10:57 -0800785 update = update_map['test'],
786 network = test_manifest.docker_network)
A R Karthick65d950d2016-12-19 19:41:55 -0800787 if test_cnt.create and (test_manifest.start_switch or not test_manifest.olt):
A R Karthick36cfcef2016-08-18 15:20:07 -0700788 #For non parallel tests, we just restart the switch also for OLT's
789 CordTester.switch_on_olt = False
A R Karthick07608ef2016-08-23 16:51:19 -0700790 if not args.no_switch:
791 test_cnt.start_switch()
A R Karthicka013a272016-08-16 16:40:19 -0700792 if test_cnt.create and test_cnt.olt:
A R Karthick1f03e912016-05-18 11:39:22 -0700793 test_cnt.setup_intfs(port_num = port_num)
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -0700794 test_cnt.run_tests()
A R Karthick1f03e912016-05-18 11:39:22 -0700795
A R Karthick81acbff2016-06-17 14:45:16 -0700796 if test_server:
A.R Karthickf184b342017-01-27 19:30:50 -0800797 if onos_cord:
798 onos_cord.restore()
A R Karthick81acbff2016-06-17 14:45:16 -0700799 cord_test_server_stop(test_server)
800
A R Karthick9a5edc42016-08-24 19:10:22 -0700801 return status
802
A R Karthick81acbff2016-06-17 14:45:16 -0700803##Starts onos/radius/quagga containers as appropriate
804def setupCordTester(args):
805 onos_cnt = {'tag':'latest'}
A R Karthick07608ef2016-08-23 16:51:19 -0700806 nose_cnt = {'image': CordTester.IMAGE, 'tag': 'candidate'}
A R Karthick92a0e5a2016-06-22 17:11:05 -0700807 update_map = { 'quagga' : False, 'radius' : False, 'test': False }
A R Karthick81acbff2016-06-17 14:45:16 -0700808 update_map[args.update.lower()] = True
A R Karthick65d950d2016-12-19 19:41:55 -0800809 test_manifest = TestManifest(args = args)
810
A R Karthick81acbff2016-06-17 14:45:16 -0700811 if args.update.lower() == 'all':
812 for c in update_map.keys():
813 update_map[c] = True
814
A R Karthick07608ef2016-08-23 16:51:19 -0700815 use_manifest = False
816 if args.manifest:
817 if os.access(args.manifest, os.F_OK):
818 ##copy it to setup directory
A.R Karthick8b2f1e32017-02-09 15:10:07 -0800819 dest = os.path.join(CordTester.tester_base,
820 os.path.basename(args.manifest))
A R Karthick07608ef2016-08-23 16:51:19 -0700821 if os.path.abspath(args.manifest) != dest:
822 try:
823 shutil.copy(args.manifest, dest)
824 except: pass
A R Karthick65d950d2016-12-19 19:41:55 -0800825 test_manifest = TestManifest(manifest = dest)
A R Karthick07608ef2016-08-23 16:51:19 -0700826 use_manifest = True
827
A.R Karthickf184b342017-01-27 19:30:50 -0800828 onos_ip = test_manifest.onos_ip
829 radius_ip = test_manifest.radius_ip
830 head_node = test_manifest.head_node
831 iterations = test_manifest.iterations
832 service_profile = test_manifest.service_profile
833 synchronizer = test_manifest.synchronizer
A.R Karthick57fa9372017-05-24 12:47:03 -0700834 voltha_loc = test_manifest.voltha_loc
835 voltha_intf = test_manifest.voltha_intf
A.R Karthickf184b342017-01-27 19:30:50 -0800836 onos_cord = None
A.R Karthick263d3fc2017-01-27 12:52:53 -0800837 onos_cord_loc = test_manifest.onos_cord
A R Karthick973010f2017-02-06 16:41:51 -0800838 Onos.update_data_dir(test_manifest.karaf_version)
A.R Karthick5968e0d2017-05-16 14:50:46 -0700839 olt_config_file = test_manifest.olt_config
840 if not os.access(olt_config_file, os.F_OK):
841 olt_config_file = os.path.join(CordTester.tester_base, 'olt_config.json')
842 else:
843 dest = os.path.join(CordTester.tester_base,
844 os.path.basename(olt_config_file))
845 if os.path.abspath(olt_config_file) != dest:
846 try:
847 shutil.copy(olt_config_file, dest)
848 except: pass
A R Karthick973010f2017-02-06 16:41:51 -0800849
A.R Karthick263d3fc2017-01-27 12:52:53 -0800850 if onos_cord_loc:
851 if onos_cord_loc.find(os.path.sep) < 0:
852 onos_cord_loc = os.path.join(os.getenv('HOME'), onos_cord_loc)
853 if not os.access(onos_cord_loc, os.F_OK):
854 print('ONOS cord config location %s is not accessible' %onos_cord_loc)
855 sys.exit(1)
A.R Karthick263d3fc2017-01-27 12:52:53 -0800856 if not onos_ip:
A R Karthickd44cea12016-07-20 12:16:41 -0700857 ##Unexpected case. Specify the external controller ip when running on cord node
858 print('Specify ONOS ip using \"-e\" option when running the cord-tester on cord node')
859 sys.exit(1)
A.R Karthickf184b342017-01-27 19:30:50 -0800860 if not service_profile:
A R Karthick03bd2812017-03-03 17:49:17 -0800861 print('Specify service profile for the ONOS cord instance. Eg: rcord')
A.R Karthickf184b342017-01-27 19:30:50 -0800862 sys.exit(1)
863 if not synchronizer:
864 print('Specify synchronizer to use for the ONOS cord instance. Eg: vtn, fabric, cord')
865 sys.exit(1)
A.R Karthickf184b342017-01-27 19:30:50 -0800866 onos_cord = OnosCord(onos_ip, onos_cord_loc, service_profile, synchronizer)
A R Karthickd44cea12016-07-20 12:16:41 -0700867
A R Karthick65d950d2016-12-19 19:41:55 -0800868 Container.IMAGE_PREFIX = test_manifest.image_prefix
A R Karthick81acbff2016-06-17 14:45:16 -0700869 #don't spawn onos if the user had started it externally
A R Karthick65d950d2016-12-19 19:41:55 -0800870 image_names = test_manifest.onos_image.rsplit(':', 1)
A R Karthick07608ef2016-08-23 16:51:19 -0700871 onos_cnt['image'] = image_names[0]
872 if len(image_names) > 1:
873 if image_names[1].find('/') < 0:
874 onos_cnt['tag'] = image_names[1]
875 else:
876 #tag cannot have slashes
A R Karthick65d950d2016-12-19 19:41:55 -0800877 onos_cnt['image'] = test_manifest.onos_image
A R Karthick81acbff2016-06-17 14:45:16 -0700878
A R Karthick07608ef2016-08-23 16:51:19 -0700879 Onos.IMAGE = onos_cnt['image']
A R Karthick65d950d2016-12-19 19:41:55 -0800880 Onos.PREFIX = test_manifest.image_prefix
A R Karthick07608ef2016-08-23 16:51:19 -0700881 Onos.TAG = onos_cnt['tag']
A R Karthick65d950d2016-12-19 19:41:55 -0800882 Onos.MAX_INSTANCES = test_manifest.onos_instances
A R Karthickc69d73e2017-01-20 11:44:34 -0800883 Onos.JVM_HEAP_SIZE = test_manifest.jvm_heap_size
A R Karthick65d950d2016-12-19 19:41:55 -0800884 cluster_mode = True if test_manifest.onos_instances > 1 else False
885 async_mode = cluster_mode and test_manifest.async_mode
886 existing_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == test_manifest.onos_image ]
887 setup_cluster = False if len(existing_list) == test_manifest.onos_instances else True
A R Karthickc41c2422016-12-09 10:59:19 -0800888 #cleanup existing volumes before forming a new cluster
889 if setup_cluster is True:
890 print('Cleaning up existing cluster volumes')
891 data_dir = os.path.join(Onos.setup_dir, 'cord-onos*-data')
892 try:
893 os.system('rm -rf {}'.format(data_dir))
894 except: pass
895
A R Karthick2b93d6a2016-09-06 15:19:09 -0700896 onos = None
A.R Karthickc4e474d2016-12-12 15:24:57 -0800897 onos_ips = []
A R Karthick81acbff2016-06-17 14:45:16 -0700898 if onos_ip is None:
A R Karthick65d950d2016-12-19 19:41:55 -0800899 data_volume = '{}-data'.format(Onos.NAME) if test_manifest.shared_volume else None
A R Karthickec2db322016-11-17 15:06:01 -0800900 onos = Onos(image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthick85eb1862017-01-23 16:10:57 -0800901 data_volume = data_volume, async = async_mode, network = test_manifest.docker_network)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800902 if onos.running:
A R Karthick65d950d2016-12-19 19:41:55 -0800903 onos_ips.append(onos.ipaddr)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800904 else:
905 onos_ips.append(onos_ip)
A R Karthick81acbff2016-06-17 14:45:16 -0700906
A R Karthick65d950d2016-12-19 19:41:55 -0800907 num_onos_instances = test_manifest.onos_instances
A R Karthick2b93d6a2016-09-06 15:19:09 -0700908 if num_onos_instances > 1 and onos is not None:
909 onos_instances = []
910 onos_instances.append(onos)
911 for i in range(1, num_onos_instances):
912 name = '{}-{}'.format(Onos.NAME, i+1)
A R Karthick65d950d2016-12-19 19:41:55 -0800913 data_volume = '{}-data'.format(name) if test_manifest.shared_volume else None
A.R Karthickc4e474d2016-12-12 15:24:57 -0800914 quagga_config = Onos.get_quagga_config(i)
A R Karthickec2db322016-11-17 15:06:01 -0800915 onos = Onos(name = name, image = Onos.IMAGE, tag = Onos.TAG, boot_delay = 60, cluster = cluster_mode,
A R Karthick3b811152016-12-15 10:24:24 -0800916 data_volume = data_volume, async = async_mode,
A R Karthick85eb1862017-01-23 16:10:57 -0800917 quagga_config = quagga_config, network = test_manifest.docker_network)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700918 onos_instances.append(onos)
A.R Karthickc4e474d2016-12-12 15:24:57 -0800919 if onos.running:
920 onos_ips.append(onos.ipaddr)
921 if async_mode is True:
922 Onos.start_cluster_async(onos_instances)
923 if not onos_ips:
924 for onos in onos_instances:
925 onos_ips.append(onos.ipaddr)
A R Karthick51e6fd82016-11-22 14:39:19 -0800926 if setup_cluster is True:
927 Onos.setup_cluster(onos_instances)
A R Karthick2b93d6a2016-09-06 15:19:09 -0700928
929 ctlr_addr = ','.join(onos_ips)
930 print('Onos IP %s' %ctlr_addr)
A R Karthick65d950d2016-12-19 19:41:55 -0800931 if onos_ip is not None:
A R Karthickbd9b8a32016-07-21 09:56:45 -0700932 print('Installing ONOS cord apps')
A R Karthick07608ef2016-08-23 16:51:19 -0700933 try:
934 Onos.install_cord_apps(onos_ip = onos_ip)
935 except: pass
A R Karthickbd9b8a32016-07-21 09:56:45 -0700936
A R Karthickedab01c2016-09-08 14:05:44 -0700937 print('Installing cord tester ONOS app %s' %args.app)
A R Karthick07608ef2016-08-23 16:51:19 -0700938 try:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700939 for ip in onos_ips:
940 OnosCtrl.install_app(args.app, onos_ip = ip)
A R Karthick07608ef2016-08-23 16:51:19 -0700941 except: pass
A R Karthickeaf1c4e2016-07-19 12:22:35 -0700942
A.R Karthick57fa9372017-05-24 12:47:03 -0700943 if voltha_loc:
944 #start voltha
945 voltha = VolthaService(voltha_loc, onos_ips[0], interface = voltha_intf)
946 voltha.start()
947
A R Karthick81acbff2016-06-17 14:45:16 -0700948 ##Start Radius container if not started
949 if radius_ip is None:
A R Karthick85eb1862017-01-23 16:10:57 -0800950 radius = Radius(prefix = Container.IMAGE_PREFIX, update = update_map['radius'],
951 network = test_manifest.docker_network)
A R Karthick75844572017-01-23 16:57:44 -0800952 radius_ip = radius.ip(network = test_manifest.docker_network)
A R Karthick81acbff2016-06-17 14:45:16 -0700953
954 print('Radius server running with IP %s' %radius_ip)
A R Karthick81acbff2016-06-17 14:45:16 -0700955
956 if args.quagga == True:
957 #Start quagga. Builds container if required
A R Karthick85eb1862017-01-23 16:10:57 -0800958 quagga = Quagga(prefix = Container.IMAGE_PREFIX, update = update_map['quagga'],
959 network = test_manifest.docker_network)
A R Karthick8d03cc52016-06-28 14:51:59 -0700960 print('Quagga started')
A R Karthick81acbff2016-06-17 14:45:16 -0700961
A.R Karthickb17e2022017-01-27 11:29:26 -0800962 params = test_manifest.server.split(':')
A R Karthick81acbff2016-06-17 14:45:16 -0700963 ip = params[0]
964 port = CORD_TEST_PORT
965 if len(params) > 1:
966 port = int(params[1])
A R Karthick92a0e5a2016-06-22 17:11:05 -0700967
A R Karthick07608ef2016-08-23 16:51:19 -0700968 try:
969 maas_api_key = FabricMAAS.get_api_key()
970 except:
971 maas_api_key = 'UNKNOWN'
972
973 ssh_key_file = set_ssh_key_file(args.identity_file)
974
A R Karthick92a0e5a2016-06-22 17:11:05 -0700975 #provision the test container
976 if not args.dont_provision:
A R Karthick2b93d6a2016-09-06 15:19:09 -0700977 test_cnt_env = { 'ONOS_CONTROLLER_IP' : ctlr_addr,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700978 'ONOS_AAA_IP' : radius_ip,
A R Karthick8d03cc52016-06-28 14:51:59 -0700979 'QUAGGA_IP': ip,
A R Karthick92a0e5a2016-06-22 17:11:05 -0700980 'CORD_TEST_HOST' : ip,
981 'CORD_TEST_PORT' : port,
A R Karthick65d950d2016-12-19 19:41:55 -0800982 'ONOS_RESTART' : 0 if test_manifest.olt and args.test_controller else 1,
983 'LOG_LEVEL': test_manifest.log_level,
A R Karthick07608ef2016-08-23 16:51:19 -0700984 'HEAD_NODE': head_node if head_node else CORD_TEST_HOST,
A R Karthick973010f2017-02-06 16:41:51 -0800985 'MAAS_API_KEY': maas_api_key,
A.R Karthick57fa9372017-05-24 12:47:03 -0700986 'KARAF_VERSION' : test_manifest.karaf_version,
A.R Karthick4c4d0492017-05-26 19:23:05 -0700987 'VOLTHA_ENABLED' : 1 if voltha_loc else 0
A R Karthick92a0e5a2016-06-22 17:11:05 -0700988 }
A R Karthick07608ef2016-08-23 16:51:19 -0700989
990 if ssh_key_file:
991 test_cnt_env['SSH_KEY_FILE'] = ssh_key_file
A.R Karthick5968e0d2017-05-16 14:50:46 -0700992 olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, os.path.basename(olt_config_file))
993 test_cnt_env['OLT_CONFIG_FILE'] = olt_conf_test_loc
A R Karthick65d950d2016-12-19 19:41:55 -0800994 if test_manifest.olt:
A R Karthick92a0e5a2016-06-22 17:11:05 -0700995 test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
A R Karthick5af23712017-01-20 09:49:24 -0800996 if test_manifest.iterations is not None:
997 test_cnt_env['ITERATIONS'] = iterations
A.R Karthick8b2f1e32017-02-09 15:10:07 -0800998 if use_manifest:
999 test_cnt_env['MANIFEST'] = os.path.join(CordTester.sandbox_setup,
1000 os.path.basename(args.manifest))
A R Karthickcaac5542017-03-06 16:20:57 -08001001
1002 openstack_setup(test_cnt_env)
1003
A R Karthick92a0e5a2016-06-22 17:11:05 -07001004 test_cnt = CordTester((),
A R Karthick2b93d6a2016-09-06 15:19:09 -07001005 ctlr_ip = ctlr_addr,
A R Karthick92a0e5a2016-06-22 17:11:05 -07001006 image = nose_cnt['image'],
A R Karthick07608ef2016-08-23 16:51:19 -07001007 prefix = Container.IMAGE_PREFIX,
A R Karthick92a0e5a2016-06-22 17:11:05 -07001008 tag = nose_cnt['tag'],
1009 env = test_cnt_env,
1010 rm = False,
A R Karthick85eb1862017-01-23 16:10:57 -08001011 update = update_map['test'],
1012 network = test_manifest.docker_network)
A R Karthick92a0e5a2016-06-22 17:11:05 -07001013
A R Karthick65d950d2016-12-19 19:41:55 -08001014 if test_manifest.start_switch or not test_manifest.olt:
A R Karthick92a0e5a2016-06-22 17:11:05 -07001015 test_cnt.start_switch()
1016 if test_cnt.olt:
1017 test_cnt.setup_intfs(port_num = 0)
1018 print('Test container %s started and provisioned to run tests using nosetests' %(test_cnt.name))
1019
1020 #Finally start the test server and daemonize
A R Karthick14118c62016-07-27 14:54:04 -07001021 try:
A R Karthickbd82f362016-11-10 15:08:52 -08001022 cord_test_server_start(daemonize = not args.foreground, cord_test_host = ip, cord_test_port = port,
1023 onos_cord = onos_cord, foreground = args.foreground)
A R Karthick14118c62016-07-27 14:54:04 -07001024 except socket.error, e:
1025 #the test agent address could be remote or already running. Exit gracefully
1026 sys.exit(0)
Chetan Gaonker93e302d2016-04-05 10:51:07 -07001027
A R Karthick9a5edc42016-08-24 19:10:22 -07001028 return 0
1029
Chetan Gaonker503032a2016-05-12 12:06:29 -07001030def cleanupTests(args):
A R Karthick757eb4d2017-01-09 14:51:16 -08001031 if args.manifest and os.access(args.manifest, os.F_OK):
1032 manifest = TestManifest(manifest = args.manifest)
1033 args.prefix = manifest.image_prefix
1034 args.olt = manifest.olt
A.R Karthick5968e0d2017-05-16 14:50:46 -07001035 args.olt_config = manifest.olt_config
A R Karthick757eb4d2017-01-09 14:51:16 -08001036 args.onos = manifest.onos_image
1037 args.server = manifest.server
A.R Karthickb17e2022017-01-27 11:29:26 -08001038 args.onos_ip = manifest.onos_ip
1039 args.radius_ip = manifest.radius_ip
1040 args.onos_cord = manifest.onos_cord
A.R Karthickf184b342017-01-27 19:30:50 -08001041 args.service_profile = manifest.service_profile
1042 args.synchronizer = manifest.synchronizer
A.R Karthick57fa9372017-05-24 12:47:03 -07001043 args.voltha_loc = manifest.voltha_loc
A.R Karthickb17e2022017-01-27 11:29:26 -08001044 else:
1045 args.onos_ip = None
1046 args.radius_ip = None
1047 if args.test_controller:
1048 ips = args.test_controller.split('/')
1049 args.onos_ip = ips[0]
1050 if len(ips) > 1:
1051 args.radius_ip = ips[1]
A R Karthick757eb4d2017-01-09 14:51:16 -08001052
A R Karthick2b93d6a2016-09-06 15:19:09 -07001053 image_name = args.onos
A R Karthick07608ef2016-08-23 16:51:19 -07001054 prefix = args.prefix
1055 if prefix:
1056 prefix += '/'
1057 test_container = '{}{}:candidate'.format(prefix, CordTester.IMAGE)
Chetan Gaonker503032a2016-05-12 12:06:29 -07001058 print('Cleaning up Test containers ...')
1059 Container.cleanup(test_container)
A R Karthickb50f5592016-07-26 12:19:29 -07001060 if args.olt:
1061 print('Cleaning up test container OLT configuration')
A.R Karthick5968e0d2017-05-16 14:50:46 -07001062 CordTester.cleanup_intfs(args.olt_config)
A R Karthick2b93d6a2016-09-06 15:19:09 -07001063
1064 onos_list = [ c['Names'][0][1:] for c in Container.dckr.containers() if c['Image'] == image_name ]
1065 if len(onos_list) > 1:
1066 for onos in onos_list:
1067 Container.dckr.kill(onos)
1068 Container.dckr.remove_container(onos, force=True)
A R Karthickec2db322016-11-17 15:06:01 -08001069 for index in range(len(onos_list)):
1070 volume = '{}-data'.format(Onos.NAME) if index == 0 else '{}-{}-data'.format(Onos.NAME, index+1)
1071 Onos.remove_data_map(volume, Onos.guest_data_dir)
A R Karthick9d48c652016-09-15 09:16:36 -07001072 Onos.cleanup_runtime()
A R Karthickec2db322016-11-17 15:06:01 -08001073
A R Karthick394976f2017-01-31 14:25:16 -08001074 radius_container = '{}{}:candidate'.format(prefix, Radius.IMAGE)
1075 quagga_container = '{}{}:candidate'.format(prefix, Quagga.IMAGE)
1076 Container.cleanup(radius_container)
1077 Container.cleanup(quagga_container)
A.R Karthick57fa9372017-05-24 12:47:03 -07001078 if args.voltha_loc:
1079 voltha = VolthaService(args.voltha_loc, args.onos_ip)
1080 voltha.stop()
1081
A.R Karthickb17e2022017-01-27 11:29:26 -08001082 if args.onos_cord:
A.R Karthickf184b342017-01-27 19:30:50 -08001083 #try restoring the onos cord instance
1084 try:
1085 onos_cord = OnosCord(args.onos_ip, args.onos_cord, args.service_profile, args.synchronizer, start = False)
1086 onos_cord.restore(force = True)
1087 except Exception as e:
1088 print(e)
A.R Karthickb17e2022017-01-27 11:29:26 -08001089
A.R Karthick842f0122016-09-28 14:48:47 -07001090 if args.xos:
1091 ##cleanup XOS images
1092 xos_images = ( '{}:{}'.format(XosServer.IMAGE,XosServer.TAG),
1093 '{}:{}'.format(XosSynchronizerOpenstack.IMAGE,
1094 XosSynchronizerOpenstack.TAG),
1095 '{}:{}'.format(XosSynchronizerOnboarding.IMAGE,
1096 XosSynchronizerOnboarding.TAG),
1097 '{}:{}'.format(XosSynchronizerOpenvpn.IMAGE,
1098 XosSynchronizerOpenvpn.TAG),
1099 '{}:{}'.format(XosPostgresql.IMAGE,
1100 XosPostgresql.TAG),
1101 '{}:{}'.format(XosSyndicateMs.IMAGE,
1102 XosSyndicateMs.TAG),
1103 )
1104 for img in xos_images:
1105 print('Cleaning up XOS image: %s' %img)
1106 Container.cleanup(img)
1107
A R Karthicke99ab5c2016-09-30 13:59:57 -07001108 server_params = args.server.split(':')
1109 server_host = server_params[0]
1110 server_port = CORD_TEST_PORT
1111 if len(server_params) > 1:
1112 server_port = int(server_params[1])
1113 cord_test_server_shutdown(server_host, server_port)
A R Karthick9a5edc42016-08-24 19:10:22 -07001114 return 0
Chetan Gaonker503032a2016-05-12 12:06:29 -07001115
1116def listTests(args):
1117 if args.test == 'all':
1118 tests = CordTester.ALL_TESTS
1119 else:
A R Karthickacae3b42016-05-12 15:27:24 -07001120 tests = args.test.split('-')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001121 CordTester.list_tests(tests)
A R Karthickcee37412016-08-29 10:10:56 -07001122 return 0
ChetanGaonkereadad482016-08-26 01:21:47 -07001123
1124def getMetrics(args):
A R Karthickcee37412016-08-29 10:10:56 -07001125 try:
1126 detail = c.inspect_container(args.container)
1127 except:
1128 print('Unknown container %s' %args.container)
1129 return 0
1130 user_hz = os.sysconf(os.sysconf_names['SC_CLK_TCK'])
ChetanGaonkereadad482016-08-26 01:21:47 -07001131 state = detail["State"]
1132 if bool(state["Paused"]):
1133 print("Container is in Paused State")
1134 elif bool(state["Running"]):
1135 print("Container is in Running State")
1136 elif int(state["ExitCode"]) == 0:
1137 print("Container is in Stopped State")
1138 else:
1139 print("Container is in Crashed State")
1140
A R Karthickcee37412016-08-29 10:10:56 -07001141 print("Ip Address of the container: " +detail['NetworkSettings']['IPAddress'])
ChetanGaonkereadad482016-08-26 01:21:47 -07001142
1143 if bool(detail["State"]["Running"]):
1144 container_id = detail['Id']
1145 cpu_usage = {}
A R Karthickcee37412016-08-29 10:10:56 -07001146 cur_usage = 0
1147 last_usage = 0
1148 for i in range(2):
1149 with open('/sys/fs/cgroup/cpuacct/docker/' + container_id + '/cpuacct.stat', 'r') as f:
1150 for line in f:
1151 m = re.search(r"(system|user)\s+(\d+)", line)
1152 if m:
1153 cpu_usage[m.group(1)] = int(m.group(2))
1154 cpu = cpu_usage["system"] + cpu_usage["user"]
1155 last_usage = cur_usage
1156 cur_usage = cpu
1157 time.sleep(1)
1158 cpu_percent = (cur_usage - last_usage)*100.0/user_hz
1159 print("CPU Usage: %.2f %%" %(cpu_percent))
ChetanGaonkereadad482016-08-26 01:21:47 -07001160 else:
1161 print(0)
1162
1163 if bool(detail["State"]["Running"]):
1164 container_id = detail['Id']
A R Karthickcee37412016-08-29 10:10:56 -07001165 print("Docker Port Info:")
ChetanGaonkereadad482016-08-26 01:21:47 -07001166 cmd = "sudo docker port {}".format(container_id)
1167 os.system(cmd)
1168
1169 if bool(detail["State"]["Running"]):
1170 container_id = detail['Id']
1171 with open('/sys/fs/cgroup/memory/docker/' + container_id + '/memory.stat', 'r') as f:
1172 for line in f:
1173 m = re.search(r"total_rss\s+(\d+)", line)
1174 if m:
A R Karthickcee37412016-08-29 10:10:56 -07001175 mem = int(m.group(1))
1176 print("Memory: %s KB "%(mem/1024.0))
ChetanGaonkereadad482016-08-26 01:21:47 -07001177 o = re.search(r"usage\s+(\d+)", line)
1178 if o:
A R Karthickcee37412016-08-29 10:10:56 -07001179 print("Usage: %s "%(o.group(1)))
ChetanGaonkereadad482016-08-26 01:21:47 -07001180 p = re.search(r"max_usage\s+(\d+)", line)
1181 if p:
A R Karthickcee37412016-08-29 10:10:56 -07001182 print("Max Usage: %s "%(p.group(1)))
ChetanGaonkereadad482016-08-26 01:21:47 -07001183
1184 if bool(detail["State"]["Running"]):
1185 container_id = detail['Id']
1186 with open('/sys/fs/cgroup/cpuacct/docker/' + container_id + '/cpuacct.stat', 'r') as f:
1187 for line in f:
1188 m = re.search(r"user\s+(\d+)", line)
1189 if m:
A R Karthickcee37412016-08-29 10:10:56 -07001190 user_ticks = int(m.group(1))
1191 print("Time spent by running processes: %.2f ms"%(user_ticks*1000.0/user_hz))
1192 print("List Networks:")
ChetanGaonkereadad482016-08-26 01:21:47 -07001193 cmd = "docker network ls"
1194 os.system(cmd)
A R Karthick9a5edc42016-08-24 19:10:22 -07001195 return 0
Chetan Gaonker503032a2016-05-12 12:06:29 -07001196
1197def buildImages(args):
A R Karthick07608ef2016-08-23 16:51:19 -07001198 tag = 'candidate'
1199 prefix = args.prefix
1200 if prefix:
1201 prefix += '/'
Chetan Gaonker503032a2016-05-12 12:06:29 -07001202 if args.image == 'all' or args.image == 'quagga':
A R Karthick07608ef2016-08-23 16:51:19 -07001203 image_name = '{}{}:{}'.format(prefix, Quagga.IMAGE, tag)
1204 Quagga.build_image(image_name)
A.R Karthick95d044e2016-06-10 18:44:36 -07001205
Chetan Gaonker503032a2016-05-12 12:06:29 -07001206 if args.image == 'all' or args.image == 'radius':
A R Karthick07608ef2016-08-23 16:51:19 -07001207 image_name = '{}{}:{}'.format(prefix, Radius.IMAGE, tag)
1208 Radius.build_image(image_name)
Chetan Gaonker503032a2016-05-12 12:06:29 -07001209
1210 if args.image == 'all' or args.image == 'test':
A R Karthick07608ef2016-08-23 16:51:19 -07001211 image_name = '{}{}:{}'.format(prefix, CordTester.IMAGE, tag)
1212 CordTester.build_image(image_name)
Chetan Gaonker503032a2016-05-12 12:06:29 -07001213
A R Karthick9a5edc42016-08-24 19:10:22 -07001214 return 0
1215
A R Karthickbec27762016-07-28 10:59:34 -07001216def startImages(args):
A R Karthickbec27762016-07-28 10:59:34 -07001217 ##starts the latest ONOS image
A R Karthick07608ef2016-08-23 16:51:19 -07001218 onos_cnt = {'tag': 'latest'}
1219 image_names = args.onos.rsplit(':', 1)
1220 onos_cnt['image'] = image_names[0]
1221 if len(image_names) > 1:
1222 if image_names[1].find('/') < 0:
1223 onos_cnt['tag'] = image_names[1]
1224 else:
1225 #tag cannot have slashes
1226 onos_cnt['image'] = args.onos
1227
A R Karthickbec27762016-07-28 10:59:34 -07001228 if args.image == 'all' or args.image == 'onos':
A R Karthick07608ef2016-08-23 16:51:19 -07001229 onos = Onos(image = onos_cnt['image'], tag = onos_cnt['tag'])
A R Karthickbec27762016-07-28 10:59:34 -07001230 print('ONOS started with ip %s' %(onos.ip()))
1231
1232 if args.image == 'all' or args.image == 'quagga':
A R Karthick07608ef2016-08-23 16:51:19 -07001233 quagga = Quagga(prefix = args.prefix)
A R Karthickbec27762016-07-28 10:59:34 -07001234 print('Quagga started with ip %s' %(quagga.ip()))
1235
1236 if args.image == 'all' or args.image == 'radius':
A R Karthick07608ef2016-08-23 16:51:19 -07001237 radius = Radius(prefix = args.prefix)
A R Karthickbec27762016-07-28 10:59:34 -07001238 print('Radius started with ip %s' %(radius.ip()))
1239
A R Karthick9a5edc42016-08-24 19:10:22 -07001240 return 0
1241
A R Karthickea8bfce2016-10-13 16:32:07 -07001242def xosCommand(args):
1243 update = False
1244 profile = args.profile
1245 if args.command == 'update':
1246 update = True
1247 xos = XosServiceProfile(profile = profile, update = update)
1248 if args.command == 'build':
1249 xos.build_images(force = True)
1250 if args.command == 'start':
1251 xos.start_services()
1252 if args.command == 'stop':
1253 xos.stop_services(rm = True)
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001254 return 0
1255
Chetan Gaonker93e302d2016-04-05 10:51:07 -07001256if __name__ == '__main__':
Chetan Gaonker678743f2016-04-26 09:54:31 -07001257 parser = ArgumentParser(description='Cord Tester')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001258 subparser = parser.add_subparsers()
1259 parser_run = subparser.add_parser('run', help='Run cord tester')
1260 parser_run.add_argument('-t', '--test-type', default=test_type_default, help='Specify test type or test case to run')
1261 parser_run.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001262 parser_run.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
1263 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 -07001264 parser_run.add_argument('-l', '--olt', action='store_true', help='Use OLT config')
A.R Karthick5968e0d2017-05-16 14:50:46 -07001265 parser_run.add_argument('-olt-config', '--olt-config', default=olt_config_default, type=str, help='Provide OLT configuration')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001266 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 -07001267 '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 -07001268 parser_run.add_argument('-r', '--server', default=cord_test_server_address, type=str,
1269 help='ip:port address to connect for cord test server for container requests')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001270 parser_run.add_argument('-k', '--keep', action='store_true', help='Keep test container after tests')
1271 parser_run.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config')
1272 parser_run.add_argument('-u', '--update', default='none', choices=['test','quagga','radius', 'all'], type=str, help='Update cord tester container images. '
1273 'Eg: --update=quagga to rebuild quagga image.'
1274 ' --update=radius to rebuild radius server image.'
1275 ' --update=test to rebuild cord test image.(Default)'
1276 ' --update=all to rebuild all cord tester images.')
A R Karthick1f03e912016-05-18 11:39:22 -07001277 parser_run.add_argument('-n', '--num-containers', default=1, type=int,
1278 help='Specify number of test containers to spawn for tests')
A R Karthicka013a272016-08-16 16:40:19 -07001279 parser_run.add_argument('-c', '--container', default='', type=str, help='Test container name for running tests')
A R Karthick07608ef2016-08-23 16:51:19 -07001280 parser_run.add_argument('-m', '--manifest', default='', type=str, help='Provide test configuration manifest')
1281 parser_run.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1282 parser_run.add_argument('-d', '--no-switch', action='store_true', help='Dont start test switch.')
1283 parser_run.add_argument('-i', '--identity-file', default=identity_file_default,
1284 type=str, help='ssh identity file to access compute nodes from test container')
ChetanGaonkerdbd4e4b2016-10-28 17:40:11 -07001285 parser_run.add_argument('-j', '--onos-instances', default=1, type=int,
1286 help='Specify number to test onos instances to form cluster')
A R Karthick09dbc6d2016-11-22 10:37:42 -08001287 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 -08001288 parser_run.add_argument('-async', '--async-mode', action='store_true',
1289 help='Start ONOS cluster instances in async mode')
A R Karthicke14fc022016-12-08 14:50:29 -08001290 parser_run.add_argument('-log', '--log-level', default=onos_log_level,
1291 choices=['DEBUG','TRACE','ERROR','WARN','INFO'],
1292 type=str,
1293 help='Specify the log level for the test cases')
A R Karthickc69d73e2017-01-20 11:44:34 -08001294 parser_run.add_argument('-jvm-heap-size', '--jvm-heap-size', default='', type=str, help='ONOS JVM heap size')
A R Karthick44a95602017-01-23 16:17:16 -08001295 parser_run.add_argument('-network', '--network', default='', type=str, help='Docker network to attach')
A.R Karthickb17e2022017-01-27 11:29:26 -08001296 parser_run.add_argument('-onos-cord', '--onos-cord', default='', type=str,
1297 help='Specify config location for ONOS cord when running on podd')
A.R Karthickf184b342017-01-27 19:30:50 -08001298 parser_run.add_argument('-service-profile', '--service-profile', default='', type=str,
1299 help='Specify config location for ONOS cord service profile when running on podd.'
1300 'Eg: $HOME/service-profile/cord-pod')
1301 parser_run.add_argument('-synchronizer', '--synchronizer', default='', type=str,
1302 help='Specify the synchronizer to use for ONOS cord instance when running on podd.'
1303 'Eg: vtn,fabric,cord')
A.R Karthickdda22062017-02-09 14:39:20 -08001304 parser_run.add_argument('-karaf', '--karaf', default='3.0.8', type=str, help='Karaf version for ONOS')
A.R Karthick57fa9372017-05-24 12:47:03 -07001305 parser_run.add_argument('-voltha-loc', '--voltha-loc', default='', type=str,
1306 help='Specify the voltha location in order to start voltha')
1307 parser_run.add_argument('-voltha-intf', '--voltha-intf', default='eth0', type=str,
1308 help='Specify the voltha interface for voltha to listen')
1309
Chetan Gaonker503032a2016-05-12 12:06:29 -07001310 parser_run.set_defaults(func=runTest)
1311
A R Karthick81acbff2016-06-17 14:45:16 -07001312 parser_setup = subparser.add_parser('setup', help='Setup cord tester environment')
1313 parser_setup.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
1314 parser_setup.add_argument('-r', '--server', default=cord_test_server_address, type=str,
1315 help='ip:port address for cord test server to listen for container restart requests')
1316 parser_setup.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
1317 parser_setup.add_argument('-a', '--app', default=onos_app_file, type=str, help='Cord ONOS app filename')
1318 parser_setup.add_argument('-e', '--test-controller', default='', type=str, help='External test controller ip for Onos and/or radius server. '
1319 'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip to connect')
1320 parser_setup.add_argument('-u', '--update', default='none', choices=['quagga','radius', 'all'], type=str, help='Update cord tester container images. '
1321 'Eg: --update=quagga to rebuild quagga image.'
1322 ' --update=radius to rebuild radius server image.'
1323 ' --update=all to rebuild all cord tester images.')
A R Karthick92a0e5a2016-06-22 17:11:05 -07001324 parser_setup.add_argument('-d', '--dont-provision', action='store_true', help='Dont start test container.')
A R Karthick07608ef2016-08-23 16:51:19 -07001325 parser_setup.add_argument('-l', '--olt', action='store_true', help='Use OLT config')
A.R Karthick5968e0d2017-05-16 14:50:46 -07001326 parser_setup.add_argument('-olt-config', '--olt-config', default=olt_config_default, type=str, help='Provide OLT configuration')
A R Karthicke14fc022016-12-08 14:50:29 -08001327 parser_setup.add_argument('-log', '--log-level', default=onos_log_level, type=str,
1328 choices=['DEBUG','TRACE','ERROR','WARN','INFO'],
1329 help='Specify the log level for the test cases')
A R Karthick92a0e5a2016-06-22 17:11:05 -07001330 parser_setup.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config')
A.R Karthickb17e2022017-01-27 11:29:26 -08001331 parser_setup.add_argument('-onos-cord', '--onos-cord', default='', type=str,
1332 help='Specify config location for ONOS cord when running on podd')
A.R Karthickf184b342017-01-27 19:30:50 -08001333 parser_setup.add_argument('-service-profile', '--service-profile', default='', type=str,
1334 help='Specify config location for ONOS cord service profile when running on podd.'
1335 'Eg: $HOME/service-profile/cord-pod')
1336 parser_setup.add_argument('-synchronizer', '--synchronizer', default='', type=str,
1337 help='Specify the synchronizer to use for ONOS cord instance when running on podd.'
1338 'Eg: vtn,fabric,cord')
A R Karthick07608ef2016-08-23 16:51:19 -07001339 parser_setup.add_argument('-m', '--manifest', default='', type=str, help='Provide test configuration manifest')
1340 parser_setup.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1341 parser_setup.add_argument('-i', '--identity-file', default=identity_file_default,
1342 type=str, help='ssh identity file to access compute nodes from test container')
A R Karthick2b93d6a2016-09-06 15:19:09 -07001343 parser_setup.add_argument('-n', '--onos-instances', default=1, type=int,
A R Karthickbd82f362016-11-10 15:08:52 -08001344 help='Specify number of test onos instances to spawn')
A R Karthick09dbc6d2016-11-22 10:37:42 -08001345 parser_setup.add_argument('-v', '--shared-volume', action='store_true',
1346 help='Start ONOS cluster instances with shared volume')
A.R Karthickc4e474d2016-12-12 15:24:57 -08001347 parser_setup.add_argument('-async', '--async-mode', action='store_true',
1348 help='Start ONOS cluster instances in async mode')
A R Karthickbd82f362016-11-10 15:08:52 -08001349 parser_setup.add_argument('-f', '--foreground', action='store_true', help='Run in foreground')
A R Karthickc69d73e2017-01-20 11:44:34 -08001350 parser_setup.add_argument('-jvm-heap-size', '--jvm-heap-size', default='', type=str, help='ONOS JVM heap size')
A R Karthick44a95602017-01-23 16:17:16 -08001351 parser_setup.add_argument('-network', '--network', default='', type=str, help='Docker network to attach')
A.R Karthickdda22062017-02-09 14:39:20 -08001352 parser_setup.add_argument('-karaf', '--karaf', default='3.0.8', type=str, help='Karaf version for ONOS')
A.R Karthick57fa9372017-05-24 12:47:03 -07001353 parser_setup.add_argument('-voltha-loc', '--voltha-loc', default='', type=str,
1354 help='Specify the voltha location in order to start voltha')
1355 parser_setup.add_argument('-voltha-intf', '--voltha-intf', default='eth0', type=str,
1356 help='Specify the voltha interface for voltha to listen')
A R Karthick81acbff2016-06-17 14:45:16 -07001357 parser_setup.set_defaults(func=setupCordTester)
1358
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001359 parser_xos = subparser.add_parser('xos', help='Building xos into cord tester environment')
A R Karthickea8bfce2016-10-13 16:32:07 -07001360 parser_xos.add_argument('command', choices=['build', 'update', 'start', 'stop'])
1361 parser_xos.add_argument('-p', '--profile', default='cord-pod', type=str, help='Provide service profile')
1362 parser_xos.set_defaults(func=xosCommand)
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001363
Chetan Gaonker503032a2016-05-12 12:06:29 -07001364 parser_list = subparser.add_parser('list', help='List test cases')
1365 parser_list.add_argument('-t', '--test', default='all', help='Specify test type to list test cases. '
1366 'Eg: -t tls to list tls test cases.'
1367 ' -t tls-dhcp-vrouter to list tls,dhcp and vrouter test cases.'
1368 ' -t all to list all test cases.')
1369 parser_list.set_defaults(func=listTests)
1370
1371 parser_build = subparser.add_parser('build', help='Build cord test container images')
ChetanGaonker2c0e9bb2016-09-21 13:38:37 -07001372 parser_build.add_argument('image', choices=['quagga', 'radius', 'test','all'])
A.R Karthick842f0122016-09-28 14:48:47 -07001373 parser_build.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001374 parser_build.set_defaults(func=buildImages)
1375
ChetanGaonkereadad482016-08-26 01:21:47 -07001376 parser_metrics = subparser.add_parser('metrics', help='Info of container')
1377 parser_metrics.add_argument("container", help="Container name")
1378 parser_metrics.set_defaults(func=getMetrics)
1379
A R Karthickbec27762016-07-28 10:59:34 -07001380 parser_start = subparser.add_parser('start', help='Start cord tester containers')
A R Karthick07608ef2016-08-23 16:51:19 -07001381 parser_start.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1382 parser_start.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
A R Karthickbec27762016-07-28 10:59:34 -07001383 parser_start.add_argument('image', choices=['onos', 'quagga', 'radius', 'all'])
1384 parser_start.set_defaults(func=startImages)
1385
Chetan Gaonker503032a2016-05-12 12:06:29 -07001386 parser_cleanup = subparser.add_parser('cleanup', help='Cleanup test containers')
A R Karthick07608ef2016-08-23 16:51:19 -07001387 parser_cleanup.add_argument('-p', '--prefix', default='', type=str, help='Provide container image prefix')
1388 parser_cleanup.add_argument('-l', '--olt', action = 'store_true', help = 'Cleanup OLT config')
A.R Karthick5968e0d2017-05-16 14:50:46 -07001389 parser_cleanup.add_argument('-olt-config', '--olt-config', default=olt_config_default, type=str, help='Provide OLT configuration')
A R Karthick2b93d6a2016-09-06 15:19:09 -07001390 parser_cleanup.add_argument('-o', '--onos', default=onos_image_default, type=str,
1391 help='ONOS container image to cleanup')
A.R Karthick842f0122016-09-28 14:48:47 -07001392 parser_cleanup.add_argument('-x', '--xos', action='store_true',
1393 help='Cleanup XOS containers')
A R Karthicke99ab5c2016-09-30 13:59:57 -07001394 parser_cleanup.add_argument('-r', '--server', default=cord_test_server_address, type=str,
1395 help='ip:port address for cord test server to cleanup')
A.R Karthickb17e2022017-01-27 11:29:26 -08001396 parser_cleanup.add_argument('-e', '--test-controller', default='', type=str,
1397 help='External test controller ip for Onos and/or radius server. '
1398 'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip')
1399 parser_cleanup.add_argument('-onos-cord', '--onos-cord', default='', type=str,
1400 help='Specify config location for ONOS cord instance when running on podd to restore')
A.R Karthickf184b342017-01-27 19:30:50 -08001401 parser_cleanup.add_argument('-service-profile', '--service-profile', default='', type=str,
1402 help='Specify config location for ONOS cord service profile when running on podd.'
1403 'Eg: $HOME/service-profile/cord-pod')
1404 parser_cleanup.add_argument('-synchronizer', '--synchronizer', default='', type=str,
1405 help='Specify the synchronizer to use for ONOS cord instance when running on podd.'
1406 'Eg: vtn,fabric,cord')
A R Karthick757eb4d2017-01-09 14:51:16 -08001407 parser_cleanup.add_argument('-m', '--manifest', default='', type=str, help='Provide test manifest')
A.R Karthick57fa9372017-05-24 12:47:03 -07001408 parser_cleanup.add_argument('-voltha-loc', '--voltha-loc', default='', type=str,
1409 help='Specify the voltha location')
Chetan Gaonker503032a2016-05-12 12:06:29 -07001410 parser_cleanup.set_defaults(func=cleanupTests)
1411
ChetanGaonkereadad482016-08-26 01:21:47 -07001412 c = Client(**(kwargs_from_env()))
1413
Chetan Gaonker93e302d2016-04-05 10:51:07 -07001414 args = parser.parse_args()
A R Karthick9a5edc42016-08-24 19:10:22 -07001415 res = args.func(args)
1416 sys.exit(res)