--- /dev/null
+#!/usr/bin/python
+
+"""
+Spin-up script for Opendaylight GBP and GBPSFC sample concept demonstrations.
+
+This script has to be run from the environment on which OVS switches and Docker
+containers are located. This script works together with infrastructure_config.py
+configuration script where the entire topology for specific scenario is configured. This
+file defines to which already existing switch docker containers have to be connected.
+OVS switch have to be created on the same hosting environment as this script is executed
+from. Local switch name should match one of the names specified in configuration file so that
+docker containers are created and connected to it.
+
+Updated: 22.10.2015
+
+"""
+
+import socket
+import os
+import sys
+import ipaddr
+from subprocess import call
+from subprocess import check_output
+from infrastructure_config import switches
+from infrastructure_config import hosts
+from infrastructure_config import defaultContainerImage
+
+
+def add_controller(sw, ip):
+ """Connects OVS switch to a controller. The switch is specified
+ by it's name and the controller by it's IP address.
+
+ Args:
+ :param sw: name of a switch on which controller is set
+
+ :param ip: IP address of controller
+
+ NOTE:
+ :Required controller should listen on TCP port 6653.
+ """
+
+ try:
+ socket.inet_aton(ip)
+ except socket.error:
+ print "Error: %s is not a valid IPv4 address of controller!" % ip
+ os.exit(2)
+
+ call(['sudo', 'ovs-vsctl', 'set-controller', sw, 'tcp:%s:6653' % ip])
+
+
+def add_manager(ip):
+ """Sets OVSDB manager for OVS instance.
+
+ Args:
+ :param ip: IP address of specified manager
+
+ NOTE:
+ :Required manager should listen on TCP port 6640.
+ """
+
+ try:
+ socket.inet_aton(ip)
+ except socket.error:
+ print "Error: %s is not a valid IPv4 address of manager!" % ip
+ os.exit(2)
+
+ cmd = ['sudo', 'ovs-vsctl', 'set-manager', 'tcp:%s:6640' % ip]
+ call(cmd)
+
+
+def add_switch(name, dpid=None):
+ """Adds switch to OVS instance and sets it's DataPath ID
+ if specified.
+
+ Args:
+ :param ip: name of new switch
+
+ :param dpid: DataPath ID of new switch
+ """
+
+ call(['sudo', 'ovs-vsctl', 'add-br', name]) # Add bridge
+ if dpid:
+ if len(dpid) < 16: # DPID must be 16-bytes in later versions of OVS
+ filler = '0000000000000000'
+ # prepending zeros to match 16-byt length, e.g. 123 -> 0000000000000123
+ dpid = filler[:len(filler) - len(dpid)] + dpid
+ elif len(dpid) > 16:
+ print 'DPID: %s is too long' % dpid
+ sys.exit(3)
+ call(['sudo', 'ovs-vsctl', 'set', 'bridge', name,
+ 'other-config:datapath-id=%s' % dpid])
+
+
+def set_of_version(sw, version='OpenFlow13,OpenFlow12,OpenFlow10'):
+ """Sets OpenFlow protocol versions on OVS switch
+
+ Args:
+ :param sw: name of switch
+
+ :param sw: OpenFlow versions to support on switch
+ """
+
+ call(['sudo', 'ovs-vsctl', 'set', 'bridge', sw, 'protocols={}'.format(version)])
+
+
+def add_vxlan_tunnel(sw):
+ """Adds VXLAN tunnel to OVS switch.
+
+ Args:
+ :param sw: name of switch
+
+ NOTE:
+ :Remote IP is read from flows.
+ """
+ ifaceName = '{}-vxlan-0'.format(sw)
+ cmd = ['sudo', 'ovs-vsctl', 'add-port', sw, ifaceName,
+ '--', 'set', 'Interface', ifaceName,
+ 'type=vxlan',
+ 'options:remote_ip=flow',
+ 'options:key=flow']
+ call(cmd)
+
+
+def add_gpe_tunnel(sw):
+ """Adds GPE tunnel to OVS switch.
+
+ Args:
+ :param sw: name of switch
+
+ :param dpid: DataPath ID of new switches
+
+ NOTE:
+ :Remote IP is read from flows.
+ """
+
+ ifaceName = '{}-vxlangpe-0'.format(sw)
+ cmd = ['sudo', 'ovs-vsctl', 'add-port', sw, ifaceName,
+ '--', 'set', 'Interface', ifaceName,
+ 'type=vxlan',
+ 'options:remote_ip=flow',
+ 'options:dst_port=6633',
+ 'options:nshc1=flow',
+ 'options:nshc2=flow',
+ 'options:nshc3=flow',
+ 'options:nshc4=flow',
+ 'options:nsp=flow',
+ 'options:nsi=flow',
+ 'options:key=flow']
+ call(cmd)
+
+
+def launch_container(host, containerImage):
+ # TODO use Docker.py
+ """Runs docker container in background.
+
+ Args:
+ :param host: container host name
+
+ :param dpid: DataPath ID of new switch
+
+ Returns:
+ :returns string: container ID
+
+ NOTE:
+ :No networking set.
+
+ """
+
+ containerID = check_output(['docker',
+ 'run',
+ '-d',
+ '--net=none',
+ '--name=%s' % host['name'],
+ '-h',
+ host['name'],
+ '-t',
+ '-i',
+ '--privileged=True',
+ containerImage,
+ '/bin/bash'])
+ return containerID[:-1] # Remove extraneous \n from output of above
+
+
+def connect_container_to_switch(sw, host, containerID):
+ """Connects docker to OVS switch.
+
+ Args:
+ :param sw: name of switch
+
+ :param host: host object to process.
+ Here is an example of such as object
+ {'name': 'h35_2',
+ 'mac': '00:00:00:00:35:02',
+ 'ip': '10.0.35.2/24',
+ 'switch': 'sw1'}
+ Note: 'switch' - name of OVS switch to
+ which the host will be connected
+
+ :param containerID: ID of docker container
+ """
+
+ hostIP = host['ip']
+ mac = host['mac']
+ nw = ipaddr.IPv4Network(hostIP)
+ broadcast = "{}".format(nw.broadcast)
+ router = "{}".format(nw.network + 1)
+ ovswork_path = os.path.dirname(os.path.realpath(__file__)) + '/ovswork.sh'
+ cmd = [ovswork_path,
+ sw,
+ containerID,
+ hostIP,
+ broadcast,
+ router,
+ mac,
+ host['name']]
+ if ('vlan') in host:
+ cmd.append(host['vlan'])
+ call(cmd)
+
+
+def launch(switches, hosts, odl_ip='127.0.0.1'):
+ """Connects hosts to switches. Arguments are
+ tied to underlying configuration file. Processing runs
+ for switch, that is present on local environment and
+ for hosts configured to be connected to the switch.
+
+ Args:
+ :param switches: switches to connect to
+ Example of switch object
+ {'name': 'sw1',
+ 'dpid': '1'}
+
+ :param hosts: hosts to connect
+ Example of host object
+ {'name': 'h35_2',
+ 'mac': '00:00:00:00:35:02',
+ 'ip': '10.0.35.2/24',
+ 'switch': 'sw1'}
+ Note: 'switch' - name of OVS switch to
+ which the host will be connected
+
+ :param odl_ip: IP address of ODL, acting as
+ both - manager and controller.
+ Default value is '127.0.0.1'
+ """
+
+ for sw in switches:
+ add_manager(odl_ip)
+ ports = 0
+ first_host = True
+ for host in hosts:
+ if host['switch'] == sw['name']:
+ if first_host:
+ add_switch(sw['name'], sw['dpid'])
+ set_of_version(sw['name'])
+ add_controller(sw['name'], odl_ip)
+ add_gpe_tunnel(sw['name'])
+ add_vxlan_tunnel(sw['name'])
+ first_host = False
+ containerImage = defaultContainerImage # from Config
+ if ('container_image') in host: # from Config
+ containerImage = host['container_image']
+ containerID = launch_container(host, containerImage)
+ ports += 1
+ connect_container_to_switch(
+ sw['name'], host, containerID)
+ host['port-name'] = 'vethl-' + host['name']
+ print "Created container: %s with IP: %s. Connect using docker attach %s," \
+ "disconnect with 'ctrl-p-q'." % (host['name'], host['ip'], host['name'])
+
+if __name__ == "__main__":
+ if len(sys.argv) < 2 or len(sys.argv) > 3:
+ print "Please, specify IP of ODL and switch index in arguments."
+ print "usage: ./infrastructure_launch.py ODL_IP SWITCH_INDEX"
+ sys.exit(2)
+
+ controller = sys.argv[1]
+ try:
+ socket.inet_aton(controller)
+ except socket.error:
+ print "Error: %s is not a valid IPv4 address!" % controller
+ sys.exit(2)
+
+ sw_index = int(sys.argv[2])
+ print sw_index
+ print switches[sw_index]
+ if sw_index not in range(0, len(switches) + 1):
+ print len(switches) + 1
+ print "Error: %s is not a valid switch index!" % sw_index
+ sys.exit(2)
+
+ sw_type = switches[sw_index]['type']
+ sw_name = switches[sw_index]['name']
+ if sw_type == 'gbp':
+ print "*****************************"
+ print "Configuring %s as a GBP node." % sw_name
+ print "*****************************"
+ print
+ launch([switches[sw_index]], hosts, controller)
+ print "*****************************"
+ print "OVS status:"
+ print "-----------"
+ print
+ call(['sudo', 'ovs-vsctl', 'show'])
+ print
+ print "Docker containers:"
+ print "------------------"
+ call(['docker', 'ps'])
+ print "*****************************"
+ elif sw_type == 'sff':
+ print "*****************************"
+ print "Configuring %s as an SFF." % sw_name
+ print "*****************************"
+ call(['sudo', 'ovs-vsctl', 'set-manager', 'tcp:%s:6640' % controller])
+ print
+ elif sw_type == 'sf':
+ print "*****************************"
+ print "Configuring %s as an SF." % sw_name
+ print "*****************************"
+ call(['%s/sf-config.sh' % os.path.dirname(os.path.realpath(__file__)), '%s' % sw_name])
Code Review / integration / test.git / blobdiff