blob: 2214584898541ff50822e102634f08a3b3187b4a [file] [log] [blame]
#!/usr/bin/env python
#
# Copyright 2016-present Ciena Corporation
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
from argparse import ArgumentParser
import os,sys,time
utils_dir = os.path.join( os.path.dirname(os.path.realpath(__file__)), '../utils')
sys.path.append(utils_dir)
from OnosCtrl import OnosCtrl
from OltConfig import OltConfig
from CordContainer import *
from CordTestServer import cord_test_server_start, cord_test_server_stop
class CordTester(Container):
sandbox = '/root/test'
sandbox_setup = '/root/test/src/test/setup'
tester_base = os.path.dirname(os.path.realpath(__file__))
tester_paths = os.path.realpath(__file__).split(os.path.sep)
tester_path_index = tester_paths.index('cord-tester')
sandbox_host = os.path.sep.join(tester_paths[:tester_path_index+1])
host_guest_map = ( (sandbox_host, sandbox),
('/lib/modules', '/lib/modules'),
('/var/run/docker.sock', '/var/run/docker.sock')
)
basename = 'cord-tester'
IMAGE = 'cord-test/nose'
ALL_TESTS = ('tls', 'dhcp', 'igmp', 'subscriber', 'vrouter', 'flows')
def __init__(self, ctlr_ip = None, image = IMAGE, tag = 'latest',
env = None, rm = False, update = False):
self.ctlr_ip = ctlr_ip
self.rm = rm
self.name = self.get_name()
super(CordTester, self).__init__(self.name, image = image, tag = tag)
host_config = self.create_host_config(host_guest_map = self.host_guest_map, privileged = True)
volumes = []
for _, g in self.host_guest_map:
volumes.append(g)
if update is True or not self.img_exists():
self.build_image(image)
##Remove test container if any
self.remove_container(self.name, force=True)
if env is not None and env.has_key('OLT_CONFIG'):
self.olt = True
olt_conf_file = os.path.join(self.tester_base, 'olt_config.json')
olt_config = OltConfig(olt_conf_file)
self.port_map = olt_config.olt_port_map()
else:
self.olt = False
self.port_map = None
print('Starting test container %s, image %s, tag %s' %(self.name, self.image, self.tag))
self.start(rm = False, volumes = volumes, environment = env,
host_config = host_config, tty = True)
def execute_switch(self, cmd, shell = False):
if self.olt:
return os.system(cmd)
return self.execute(cmd, shell = shell)
def start_switch(self, bridge = 'ovsbr0', boot_delay = 2):
"""Start OVS"""
##Determine if OVS has to be started locally or not
s_file,s_sandbox = ('of-bridge-local.sh',self.tester_base) if self.olt else ('of-bridge.sh',self.sandbox_setup)
ovs_cmd = os.path.join(s_sandbox, '{0}'.format(s_file)) + ' {0}'.format(bridge)
if self.olt:
ovs_cmd += ' {0}'.format(self.ctlr_ip)
print('Starting OVS on the host')
else:
print('Starting OVS on test container %s' %self.name)
self.execute_switch(ovs_cmd)
status = 1
## Wait for the LLDP flows to be added to the switch
tries = 0
while status != 0 and tries < 200:
cmd = 'sudo ovs-ofctl dump-flows {0} | grep \"type=0x8942\"'.format(bridge)
status = self.execute_switch(cmd, shell = True)
tries += 1
if tries % 10 == 0:
print('Waiting for test switch to be connected to ONOS controller ...')
if status != 0:
print('Test Switch not connected to ONOS container.'
'Please remove ONOS container and restart the test')
if self.rm:
self.kill()
sys.exit(1)
if boot_delay:
time.sleep(boot_delay)
def setup_intfs(self):
if not self.olt:
return 0
tester_intf_subnet = '192.168.100'
res = 0
port_num = 0
host_intf = self.port_map['host']
start_vlan = self.port_map['start_vlan']
for port in self.port_map['ports']:
guest_if = port
local_if = guest_if
guest_ip = '{0}.{1}/24'.format(tester_intf_subnet, str(port_num+1))
##Use pipeworks to configure container interfaces on host/bridge interfaces
pipework_cmd = 'pipework {0} -i {1} -l {2} {3} {4}'.format(host_intf, guest_if, local_if, self.name, guest_ip)
if start_vlan != 0:
pipework_cmd += ' @{}'.format(str(start_vlan + port_num))
res += os.system(pipework_cmd)
port_num += 1
return res
@classmethod
def get_name(cls):
cnt_name = '/{0}'.format(cls.basename)
cnt_name_len = len(cnt_name)
names = list(flatten(n['Names'] for n in cls.dckr.containers(all=True)))
test_names = filter(lambda n: n.startswith(cnt_name), names)
last_cnt_number = 0
if test_names:
last_cnt_name = reduce(lambda n1, n2: n1 if int(n1[cnt_name_len:]) > \
int(n2[cnt_name_len:]) else n2,
test_names)
last_cnt_number = int(last_cnt_name[cnt_name_len:])
test_cnt_name = cls.basename + str(last_cnt_number+1)
return test_cnt_name
@classmethod
def build_image(cls, image):
print('Building test container docker image %s' %image)
ovs_version = '2.5.0'
image_format = (ovs_version,)*4
dockerfile = '''
FROM ubuntu:14.04
MAINTAINER chetan@ciena.com
RUN apt-get update
RUN apt-get -y install git python python-pip python-setuptools python-scapy tcpdump doxygen doxypy wget
RUN easy_install nose
RUN apt-get -y install openvswitch-common openvswitch-switch
RUN mkdir -p /root/ovs
WORKDIR /root
RUN wget http://openvswitch.org/releases/openvswitch-{}.tar.gz -O /root/ovs/openvswitch-{}.tar.gz && \
(cd /root/ovs && tar zxpvf openvswitch-{}.tar.gz && \
cd openvswitch-{} && \
./configure --prefix=/usr --sysconfdir=/etc --localstatedir=/var --disable-ssl && make && make install)
RUN service openvswitch-switch restart || /bin/true
RUN apt-get -y install python-twisted python-sqlite sqlite3 python-pexpect telnet
RUN pip install scapy-ssl_tls
RUN pip install -U scapy
RUN pip install monotonic
RUN pip install configObj
RUN pip install -U docker-py
RUN pip install -U pyyaml
RUN pip install -U nsenter
RUN pip install -U pyroute2
RUN pip install -U netaddr
RUN apt-get -y install arping
RUN mv /usr/sbin/tcpdump /sbin/
RUN ln -sf /sbin/tcpdump /usr/sbin/tcpdump
CMD ["/bin/bash"]
'''.format(*image_format)
super(CordTester, cls).build_image(dockerfile, image)
print('Done building docker image %s' %image)
def run_tests(self, tests):
'''Run the list of tests'''
for t in tests:
test = t.split(':')[0]
test_file = '{}Test.py'.format(test)
if t.find(':') >= 0:
test_case = '{0}:{1}'.format(test_file, t.split(':')[1])
else:
test_case = test_file
cmd = 'nosetests -v {0}/src/test/{1}/{2}'.format(self.sandbox, test, test_case)
status = self.execute(cmd, shell = True)
print('Test %s %s' %(test_case, 'Success' if status == 0 else 'Failure'))
print('Done running tests')
if self.rm:
print('Removing test container %s' %self.name)
self.kill(remove=True)
@classmethod
def list_tests(cls, tests):
print('Listing test cases')
for test in tests:
test_file = '{}Test.py'.format(test)
cmd = 'nosetests -v --collect-only {0}/../{1}/{2}'.format(cls.tester_base, test, test_file)
os.system(cmd)
##default onos/radius/test container images and names
onos_image_default='onosproject/onos:latest'
nose_image_default= '{}:latest'.format(CordTester.IMAGE)
test_type_default='dhcp'
onos_app_version = '1.0-SNAPSHOT'
cord_tester_base = os.path.dirname(os.path.realpath(__file__))
onos_app_file = os.path.abspath('{0}/../apps/ciena-cordigmp-'.format(cord_tester_base) + onos_app_version + '.oar')
def runTest(args):
#Start the cord test tcp server
test_server = cord_test_server_start()
if args.test_type.lower() == 'all':
tests = CordTester.ALL_TESTS
args.radius = True
args.quagga = True
else:
tests = args.test_type.split('-')
onos_cnt = {'tag':'latest'}
nose_cnt = {'image': CordTester.IMAGE, 'tag': 'latest'}
update_map = { 'quagga' : False, 'test' : False, 'radius' : False }
update_map[args.update.lower()] = True
if args.update.lower() == 'all':
for c in update_map.keys():
update_map[c] = True
radius_ip = None
quagga_ip = None
#don't spawn onos if the user has specified external test controller with test interface config
if args.test_controller:
ips = args.test_controller.split('/')
onos_ip = ips[0]
if len(ips) > 1:
radius_ip = ips[1]
else:
radius_ip = None
else:
onos_cnt['image'] = args.onos.split(':')[0]
if args.onos.find(':') >= 0:
onos_cnt['tag'] = args.onos.split(':')[1]
onos = Onos(image = onos_cnt['image'], tag = onos_cnt['tag'], boot_delay = 60)
onos_ip = onos.ip()
##Start Radius container if specified
if args.radius == True:
radius = Radius( update = update_map['radius'])
radius_ip = radius.ip()
print('Radius server running with IP %s' %radius_ip)
else:
radius_ip = None
print('Onos IP %s, Test type %s' %(onos_ip, args.test_type))
print('Installing ONOS app %s' %onos_app_file)
OnosCtrl.install_app(args.app, onos_ip = onos_ip)
if args.quagga == True:
#Start quagga. Builds container if required
quagga = Quagga(update = update_map['quagga'])
quagga_ip = quagga.ip()
test_cnt_env = { 'ONOS_CONTROLLER_IP' : onos_ip,
'ONOS_AAA_IP' : radius_ip if radius_ip is not None else '',
'QUAGGA_IP': quagga_ip if quagga_ip is not None else '',
}
if args.olt:
olt_conf_test_loc = os.path.join(CordTester.sandbox_setup, 'olt_config.json')
test_cnt_env['OLT_CONFIG'] = olt_conf_test_loc
test_cnt = CordTester(ctlr_ip = onos_ip, image = nose_cnt['image'], tag = nose_cnt['tag'],
env = test_cnt_env,
rm = False if args.keep else True,
update = update_map['test'])
if args.start_switch or not args.olt:
test_cnt.start_switch()
test_cnt.setup_intfs()
test_cnt.run_tests(tests)
cord_test_server_stop(test_server)
def cleanupTests(args):
test_container = '{}:latest'.format(CordTester.IMAGE)
print('Cleaning up Test containers ...')
Container.cleanup(test_container)
def listTests(args):
if args.test == 'all':
tests = CordTester.ALL_TESTS
else:
tests = args.test.split('-')
CordTester.list_tests(tests)
def buildImages(args):
if args.image == 'all' or args.image == 'quagga':
Quagga.build_image(Quagga.IMAGE)
if args.image == 'all' or args.image == 'radius':
Radius.build_image(Radius.IMAGE)
if args.image == 'all' or args.image == 'test':
CordTester.build_image(CordTester.IMAGE)
if __name__ == '__main__':
parser = ArgumentParser(description='Cord Tester')
subparser = parser.add_subparsers()
parser_run = subparser.add_parser('run', help='Run cord tester')
parser_run.add_argument('-t', '--test-type', default=test_type_default, help='Specify test type or test case to run')
parser_run.add_argument('-o', '--onos', default=onos_image_default, type=str, help='ONOS container image')
parser_run.add_argument('-r', '--radius',action='store_true', help='Start Radius service')
parser_run.add_argument('-q', '--quagga',action='store_true',help='Provision quagga container for vrouter')
parser_run.add_argument('-a', '--app', default=onos_app_file, type=str, help='Cord ONOS app filename')
parser_run.add_argument('-p', '--olt', action='store_true', help='Use OLT config')
parser_run.add_argument('-e', '--test-controller', default='', type=str, help='External test controller ip for Onos and/or radius server. '
'Eg: 10.0.0.2/10.0.0.3 to specify ONOS and Radius ip to connect')
parser_run.add_argument('-k', '--keep', action='store_true', help='Keep test container after tests')
parser_run.add_argument('-s', '--start-switch', action='store_true', help='Start OVS when running under OLT config')
parser_run.add_argument('-u', '--update', default='none', choices=['test','quagga','radius', 'all'], type=str, help='Update cord tester container images. '
'Eg: --update=quagga to rebuild quagga image.'
' --update=radius to rebuild radius server image.'
' --update=test to rebuild cord test image.(Default)'
' --update=all to rebuild all cord tester images.')
parser_run.set_defaults(func=runTest)
parser_list = subparser.add_parser('list', help='List test cases')
parser_list.add_argument('-t', '--test', default='all', help='Specify test type to list test cases. '
'Eg: -t tls to list tls test cases.'
' -t tls-dhcp-vrouter to list tls,dhcp and vrouter test cases.'
' -t all to list all test cases.')
parser_list.set_defaults(func=listTests)
parser_build = subparser.add_parser('build', help='Build cord test container images')
parser_build.add_argument('image', choices=['quagga', 'radius', 'test', 'all'])
parser_build.set_defaults(func=buildImages)
parser_cleanup = subparser.add_parser('cleanup', help='Cleanup test containers')
parser_cleanup.set_defaults(func=cleanupTests)
args = parser.parse_args()
args.func(args)