# -*- coding: utf-8 -*-
##
-# Copyright 2015 Telefónica Investigación y Desarrollo, S.A.U.
+# Copyright 2015 Telefonica Investigacion y Desarrollo, S.A.U.
# This file is part of openvim
# All Rights Reserved.
#
class host_thread(threading.Thread):
lvirt_module = None
- def __init__(self, name, host, user, db, db_lock, test, image_path, host_id, version, develop_mode,
- develop_bridge_iface, password=None, keyfile = None, logger_name=None, debug=None):
+ def __init__(self, name, host, user, db, test, image_path, host_id, version, develop_mode,
+ develop_bridge_iface, password=None, keyfile = None, logger_name=None, debug=None, hypervisors=None):
"""Init a thread to communicate with compute node or ovs_controller.
:param host_id: host identity
:param name: name of the thread
:param host: host ip or name to manage and user
:param user, password, keyfile: user and credentials to connect to host
- :param db, db_lock': database class and lock to use it in exclusion
+ :param db: database class, threading safe
"""
threading.Thread.__init__(self)
self.name = name
self.host = host
self.user = user
self.db = db
- self.db_lock = db_lock
self.test = test
self.password = password
self.keyfile = keyfile
self.localinfo_dirty = False
+ self.connectivity = True
if not test and not host_thread.lvirt_module:
try:
self.pending_terminate_server =[] #list with pairs (time,server_uuid) time to send a terminate for a server being destroyed
self.next_update_server_status = 0 #time when must be check servers status
+####### self.hypervisor = "kvm" #hypervisor flag (default: kvm)
+ if hypervisors:
+ self.hypervisors = hypervisors
+ else:
+ self.hypervisors = "kvm"
+
+ self.xen_hyp = True if "xen" in self.hypervisors else False
+
self.hostinfo = None
self.queueLock = threading.Lock()
self.run_command_session = None
self.error = None
self.localhost = True if host == 'localhost' else False
- self.lvirt_conn_uri = "qemu+ssh://{user}@{host}/system?no_tty=1&no_verify=1".format(
- user=self.user, host=self.host)
+
+ if self.xen_hyp:
+ self.lvirt_conn_uri = "xen+ssh://{user}@{host}/?no_tty=1&no_verify=1".format(
+ user=self.user, host=self.host)
+ else:
+ self.lvirt_conn_uri = "qemu+ssh://{user}@{host}/system?no_tty=1&no_verify=1".format(
+ user=self.user, host=self.host)
if keyfile:
self.lvirt_conn_uri += "&keyfile=" + keyfile
+
self.remote_ip = None
self.local_ip = None
- def run_command(self, command, keep_session=False):
+ def run_command(self, command, keep_session=False, ignore_exit_status=False):
"""Run a command passed as a str on a localhost or at remote machine.
:param command: text with the command to execute.
:param keep_session: if True it returns a <stdin> for sending input with '<stdin>.write("text\n")'.
A command with keep_session=True MUST be followed by a command with keep_session=False in order to
close the session and get the output
+ :param ignore_exit_status: Return stdout and not raise an exepction in case of error.
:return: the output of the command if 'keep_session=False' or the <stdin> object if 'keep_session=True'
:raises: RunCommandException if command fails
"""
self.run_command_session = p
return p.stdin
else:
- output = subprocess.check_output(('bash', "-c", command))
- returncode = 0
+ if not ignore_exit_status:
+ output = subprocess.check_output(('bash', "-c", command))
+ returncode = 0
+ else:
+ out = None
+ p = subprocess.Popen(('bash', "-c", command), stdout=subprocess.PIPE)
+ out, err = p.communicate()
+ return out
else:
if self.run_command_session:
(i, o, e) = self.run_command_session
returncode = o.channel.recv_exit_status()
output = o.read()
outerror = e.read()
- if returncode != 0:
+ if returncode != 0 and not ignore_exit_status:
text = "run_command='{}' Error='{}'".format(command, outerror)
self.logger.error(text)
raise RunCommandException(text)
def check_connectivity(self):
if not self.test:
- # TODO change to run_command
try:
- if not self.ssh_conn:
- self.ssh_connect()
-
command = 'sudo brctl show'
- (_, stdout, stderr) = self.ssh_conn.exec_command(command, timeout=10)
- content = stderr.read()
- if len(content) > 0:
- self.connectivity = False
- self.logger.error("ssh conection error")
- except paramiko.ssh_exception.SSHException as e:
- text = e.args[0]
- self.connectivity = False
- self.logger.error("ssh_connect ssh Exception: " + text)
- raise paramiko.ssh_exception.SSHException("ssh error conection")
- except Exception as e:
+ self.run_command(command)
+ except RunCommandException as e:
self.connectivity = False
- raise paramiko.ssh_exception.SSHException("ssh error conection")
+ self.logger.error("check_connectivity Exception: " + str(e))
def load_localinfo(self):
if not self.test:
self.logger.error("save_localinfo Exception: " + text)
def load_servers_from_db(self):
- self.db_lock.acquire()
r,c = self.db.get_table(SELECT=('uuid','status', 'image_id'), FROM='instances', WHERE={'host_id': self.host_id})
- self.db_lock.release()
self.server_status = {}
if r<0:
bus_ide = True if bus=='ide' else False
self.xml_level = 0
+ hypervisor = server.get('hypervisor', 'kvm')
+ os_type_img = server.get('os_image_type', 'other')
- text = "<domain type='kvm'>"
+ if hypervisor[:3] == 'xen':
+ text = "<domain type='xen'>"
+ else:
+ text = "<domain type='kvm'>"
#get topology
topo = server_metadata.get('topology', None)
if topo == None and 'metadata' in dev_list[0]:
if dev['type']=='cdrom' :
boot_cdrom = True
break
- text += self.tab()+ '<os>' + \
- self.inc_tab() + "<type arch='x86_64' machine='pc'>hvm</type>"
- if boot_cdrom:
- text += self.tab() + "<boot dev='cdrom'/>"
- text += self.tab() + "<boot dev='hd'/>" + \
- self.dec_tab()+'</os>'
+ if hypervisor == 'xenhvm':
+ text += self.tab()+ '<os>' + \
+ self.inc_tab() + "<type arch='x86_64' machine='xenfv'>hvm</type>"
+ text += self.tab() + "<loader type='rom'>/usr/lib/xen/boot/hvmloader</loader>"
+ if boot_cdrom:
+ text += self.tab() + "<boot dev='cdrom'/>"
+ text += self.tab() + "<boot dev='hd'/>" + \
+ self.dec_tab()+'</os>'
+ elif hypervisor == 'xen-unik':
+ text += self.tab()+ '<os>' + \
+ self.inc_tab() + "<type arch='x86_64' machine='xenpv'>xen</type>"
+ text += self.tab() + "<kernel>" + str(dev_list[0]['source file']) + "</kernel>" + \
+ self.dec_tab()+'</os>'
+ else:
+ text += self.tab()+ '<os>' + \
+ self.inc_tab() + "<type arch='x86_64' machine='pc'>hvm</type>"
+ if boot_cdrom:
+ text += self.tab() + "<boot dev='cdrom'/>"
+ text += self.tab() + "<boot dev='hd'/>" + \
+ self.dec_tab()+'</os>'
#features
text += self.tab()+'<features>'+\
self.inc_tab()+'<acpi/>' +\
self.tab() + "<on_poweroff>preserve</on_poweroff>" + \
self.tab() + "<on_reboot>restart</on_reboot>" + \
self.tab() + "<on_crash>restart</on_crash>"
- text += self.tab() + "<devices>" + \
- self.inc_tab() + "<emulator>/usr/libexec/qemu-kvm</emulator>" + \
- self.tab() + "<serial type='pty'>" +\
- self.inc_tab() + "<target port='0'/>" + \
- self.dec_tab() + "</serial>" +\
- self.tab() + "<console type='pty'>" + \
- self.inc_tab()+ "<target type='serial' port='0'/>" + \
- self.dec_tab()+'</console>'
+ if hypervisor == 'xenhvm':
+ text += self.tab() + "<devices>" + \
+ self.inc_tab() + "<emulator>/usr/bin/qemu-system-i386</emulator>" + \
+ self.tab() + "<serial type='pty'>" +\
+ self.inc_tab() + "<target port='0'/>" + \
+ self.dec_tab() + "</serial>" +\
+ self.tab() + "<console type='pty'>" + \
+ self.inc_tab()+ "<target type='serial' port='0'/>" + \
+ self.dec_tab()+'</console>' #In some libvirt version may be: <emulator>/usr/lib64/xen/bin/qemu-dm</emulator> (depends on distro)
+ elif hypervisor == 'xen-unik':
+ text += self.tab() + "<devices>" + \
+ self.tab() + "<console type='pty'>" + \
+ self.inc_tab()+ "<target type='xen' port='0'/>" + \
+ self.dec_tab()+'</console>'
+ else:
+ text += self.tab() + "<devices>" + \
+ self.inc_tab() + "<emulator>/usr/libexec/qemu-kvm</emulator>" + \
+ self.tab() + "<serial type='pty'>" +\
+ self.inc_tab() + "<target port='0'/>" + \
+ self.dec_tab() + "</serial>" +\
+ self.tab() + "<console type='pty'>" + \
+ self.inc_tab()+ "<target type='serial' port='0'/>" + \
+ self.dec_tab()+'</console>'
if windows_os:
text += self.tab() + "<controller type='usb' index='0'/>" + \
self.tab() + "<controller type='ide' index='0'/>" + \
self.dec_tab() + "</video>" + \
self.tab() + "<memballoon model='virtio'/>" + \
self.tab() + "<input type='tablet' bus='usb'/>" #TODO revisar
+ elif hypervisor == 'xen-unik':
+ pass
+ else:
+ text += self.tab() + "<controller type='ide' index='0'/>" + \
+ self.tab() + "<input type='mouse' bus='ps2'/>" + \
+ self.tab() + "<input type='keyboard' bus='ps2'/>" + \
+ self.tab() + "<video>" + \
+ self.inc_tab() + "<model type='cirrus' vram='9216' heads='1'/>" + \
+ self.dec_tab() + "</video>"
#> self.tab()+'<alias name=\'hostdev0\'/>\n' +\
#> self.dec_tab()+'</hostdev>\n' +\
vd_index = 'a'
for dev in dev_list:
bus_ide_dev = bus_ide
- if dev['type']=='cdrom' or dev['type']=='disk':
+ if (dev['type']=='cdrom' or dev['type']=='disk') and hypervisor != 'xen-unik':
if dev['type']=='cdrom':
bus_ide_dev = True
text += self.tab() + "<disk type='file' device='"+dev['type']+"'>"
dev_text = dev_text.replace('__dev__', vd_index)
vd_index = chr(ord(vd_index)+1)
text += dev_text
+ elif hypervisor == 'xen-unik':
+ pass
else:
return -1, 'Unknown device type ' + dev['type']
bridge_interfaces = server.get('networks', [])
for v in bridge_interfaces:
#Get the brifge name
- self.db_lock.acquire()
result, content = self.db.get_table(FROM='nets', SELECT=('provider',),WHERE={'uuid':v['net_id']} )
- self.db_lock.release()
if result <= 0:
self.logger.error("create_xml_server ERROR %d getting nets %s", result, content)
return -1, content
vlan = content[0]['provider'].replace('OVS:', '')
text += self.tab() + "<interface type='bridge'>" + \
self.inc_tab() + "<source bridge='ovim-" + str(vlan) + "'/>"
+ if hypervisor == 'xenhvm' or hypervisor == 'xen-unik':
+ text += self.tab() + "<script path='vif-openvswitch'/>"
else:
return -1, 'Unknown Bridge net provider ' + content[0]['provider']
if model!=None:
if self.test or not self.connectivity:
return True
-
try:
- self.run_command('sudo', 'ovs-vsctl', '--may-exist', 'add-br', 'br-int', '--', 'set', 'Bridge', 'br-int',
- 'stp_enable=true')
+ self.run_command('sudo ovs-vsctl --may-exist add-br br-int -- set Bridge br-int stp_enable=true')
+
return True
except RunCommandException as e:
self.logger.error("create_ovs_bridge ssh Exception: " + str(e))
if self.test or not self.connectivity:
return True
try:
- port_name = 'ovim-' + str(vlan)
- command = 'sudo ovs-vsctl del-port br-int ' + port_name
+ port_name = 'ovim-{}'.format(str(vlan))
+ command = 'sudo ovs-vsctl del-port br-int {}'.format(port_name)
self.run_command(command)
return True
except RunCommandException as e:
- self.logger.error("delete_port_to_ovs_bridge ssh Exception: " + str(e))
+ self.logger.error("delete_port_to_ovs_bridge ssh Exception: {}".format(str(e)))
return False
def delete_dhcp_server(self, vlan, net_uuid, dhcp_path):
if not self.is_dhcp_port_free(vlan, net_uuid):
return True
try:
- dhcp_namespace = str(vlan) + '-dnsmasq'
+ dhcp_namespace = '{}-dnsmasq'.format(str(vlan))
dhcp_path = os.path.join(dhcp_path, dhcp_namespace)
pid_file = os.path.join(dhcp_path, 'dnsmasq.pid')
- command = 'sudo ip netns exec ' + dhcp_namespace + ' cat ' + pid_file
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip netns exec {} cat {}'.format(dhcp_namespace, pid_file)
+ content = self.run_command(command, ignore_exit_status=True)
+ dns_pid = content.replace('\n', '')
+ command = 'sudo ip netns exec {} kill -9 {}'.format(dhcp_namespace, dns_pid)
+ self.run_command(command, ignore_exit_status=True)
- command = 'sudo ip netns exec ' + dhcp_namespace + ' kill -9 ' + content
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # if len(content) == 0:
- # return True
- # else:
- # return False
- except paramiko.ssh_exception.SSHException as e:
+ except RunCommandException as e:
self.logger.error("delete_dhcp_server ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
return False
def is_dhcp_port_free(self, host_id, net_uuid):
:param net_uuid: network id
:return: True if is not free
"""
- self.db_lock.acquire()
result, content = self.db.get_table(
FROM='ports',
WHERE={'type': 'instance:ovs', 'net_id': net_uuid}
)
- self.db_lock.release()
if len(content) > 0:
return False
:return: True if is not free
"""
- self.db_lock.acquire()
result, content = self.db.get_table(
FROM='ports as p join instances as i on p.instance_id=i.uuid',
WHERE={"i.host_id": self.host_id, 'p.type': 'instance:ovs', 'p.net_id': net_uuid}
)
- self.db_lock.release()
if len(content) > 0:
return False
if self.test:
return True
try:
- port_name = 'ovim-' + str(vlan)
- command = 'sudo ovs-vsctl add-port br-int ' + port_name + ' tag=' + str(vlan)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("add_port_to_ovs_bridge ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ port_name = 'ovim-{}'.format(str(vlan))
+ command = 'sudo ovs-vsctl add-port br-int {} tag={}'.format(port_name, str(vlan))
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("add_port_to_ovs_bridge Exception: " + str(e))
return False
- def delete_dhcp_port(self, vlan, net_uuid):
+ def delete_dhcp_port(self, vlan, net_uuid, dhcp_path):
"""
Delete from an existing OVS bridge a linux bridge port attached and the linux bridge itself.
:param vlan: segmentation id
if not self.is_dhcp_port_free(vlan, net_uuid):
return True
- self.delete_dhcp_interfaces(vlan)
+ self.delete_dhcp_interfaces(vlan, dhcp_path)
return True
def delete_bridge_port_attached_to_ovs(self, vlan, net_uuid):
if self.test:
return True
try:
- port_name = 'ovim-' + str(vlan)
- command = 'sudo ip link set dev ovim-' + str(vlan) + ' down'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- # content = stdout.read()
- #
- # if len(content) != 0:
- # return False
- command = 'sudo ifconfig ' + port_name + ' down && sudo brctl delbr ' + port_name
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("delete_linux_bridge ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ port_name = 'ovim-{}'.format(str(vlan))
+ command = 'sudo ip link set dev ovim-{} down'.format(str(vlan))
+ self.run_command(command)
+
+ command = 'sudo ip link delete {} && sudo brctl delbr {}'.format(port_name, port_name)
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("delete_linux_bridge Exception: {}".format(str(e)))
return False
def remove_link_bridge_to_ovs(self, vlan, link):
if self.test:
return True
try:
- br_tap_name = str(vlan) + '-vethBO'
- br_ovs_name = str(vlan) + '-vethOB'
+ br_tap_name = '{}-vethBO'.format(str(vlan))
+ br_ovs_name = '{}-vethOB'.format(str(vlan))
# Delete ovs veth pair
command = 'sudo ip link set dev {} down'.format(br_ovs_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command, ignore_exit_status=True)
command = 'sudo ovs-vsctl del-port br-int {}'.format(br_ovs_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command)
# Delete br veth pair
command = 'sudo ip link set dev {} down'.format(br_tap_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command, ignore_exit_status=True)
# Delete br veth interface form bridge
command = 'sudo brctl delif {} {}'.format(link, br_tap_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command)
# Delete br veth pair
command = 'sudo ip link set dev {} down'.format(link)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command, ignore_exit_status=True)
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("delete_linux_bridge ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ return True
+ except RunCommandException as e:
+ self.logger.error("remove_link_bridge_to_ovs Exception: {}".format(str(e)))
return False
def create_ovs_bridge_port(self, vlan):
if self.test:
return True
try:
- port_name = 'ovim-' + str(vlan)
- command = 'sudo brctl show | grep ' + port_name
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # if exist nothing to create
- # if len(content) == 0:
- # return False
-
- command = 'sudo brctl addbr ' + port_name
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # if len(content) == 0:
- # return True
- # else:
- # return False
-
- command = 'sudo brctl stp ' + port_name + ' on'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # if len(content) == 0:
- # return True
- # else:
- # return False
- command = 'sudo ip link set dev ' + port_name + ' up'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("create_linux_bridge ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ port_name = 'ovim-{}'.format(str(vlan))
+ command = 'sudo brctl show | grep {}'.format(port_name)
+ result = self.run_command(command, ignore_exit_status=True)
+ if not result:
+ command = 'sudo brctl addbr {}'.format(port_name)
+ self.run_command(command)
+
+ command = 'sudo brctl stp {} on'.format(port_name)
+ self.run_command(command)
+
+ command = 'sudo ip link set dev {} up'.format(port_name)
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("create_linux_bridge ssh Exception: {}".format(str(e)))
return False
def set_mac_dhcp_server(self, ip, mac, vlan, netmask, first_ip, dhcp_path):
if self.test:
return True
- dhcp_namespace = str(vlan) + '-dnsmasq'
+ dhcp_namespace = '{}-dnsmasq'.format(str(vlan))
dhcp_path = os.path.join(dhcp_path, dhcp_namespace)
dhcp_hostsdir = os.path.join(dhcp_path, dhcp_namespace)
+ ns_interface = '{}-vethDO'.format(str(vlan))
if not ip:
return False
try:
-
- ns_interface = str(vlan) + '-vethDO'
- command = 'sudo ip netns exec ' + dhcp_namespace + ' cat /sys/class/net/{}/address'.format(ns_interface)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- iface_listen_mac = stdout.read()
+ command = 'sudo ip netns exec {} cat /sys/class/net/{}/address'.format(dhcp_namespace, ns_interface)
+ iface_listen_mac = self.run_command(command, ignore_exit_status=True)
if iface_listen_mac > 0:
- command = 'sudo ip netns exec ' + dhcp_namespace + ' cat {} | grep {}'.format(dhcp_hostsdir, dhcp_hostsdir)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- if content > 0:
+ command = 'sudo ip netns exec {} cat {} | grep -i {}'.format(dhcp_namespace,
+ dhcp_hostsdir,
+ iface_listen_mac)
+ content = self.run_command(command, ignore_exit_status=True)
+ if content == '':
ip_data = iface_listen_mac.upper().replace('\n', '') + ',' + first_ip
dhcp_hostsdir = os.path.join(dhcp_path, dhcp_namespace)
- command = 'sudo ip netns exec ' + dhcp_namespace + ' sudo bash -ec "echo ' + ip_data + ' >> ' + dhcp_hostsdir + '"'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
-
- ip_data = mac.upper() + ',' + ip
-
- command = 'sudo ip netns exec ' + dhcp_namespace + ' touch ' + dhcp_hostsdir
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip netns exec ' + dhcp_namespace + ' sudo bash -ec "echo ' + ip_data + ' >> ' + dhcp_hostsdir + '"'
+ command = 'sudo ip netns exec {} sudo bash -ec "echo {} >> {}"'.format(dhcp_namespace,
+ ip_data,
+ dhcp_hostsdir)
+ self.run_command(command)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ ip_data = mac.upper() + ',' + ip
+ command = 'sudo ip netns exec {} sudo bash -ec "echo {} >> {}"'.format(dhcp_namespace,
+ ip_data,
+ dhcp_hostsdir)
+ self.run_command(command, ignore_exit_status=False)
- if len(content) == 0:
return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
+
+ return False
+ except RunCommandException as e:
self.logger.error("set_mac_dhcp_server ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
return False
def delete_mac_dhcp_server(self, ip, mac, vlan, dhcp_path):
ip_data = mac.upper() + ',' + ip
command = 'sudo ip netns exec ' + dhcp_namespace + ' sudo sed -i \'/' + ip_data + '/d\' ' + dhcp_hostsdir
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- if len(content) == 0:
- return True
- else:
- return False
+ self.run_command(command)
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("set_mac_dhcp_server ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ return True
+ except RunCommandException as e:
+ self.logger.error("delete_mac_dhcp_server Exception: " + str(e))
return False
def launch_dhcp_server(self, vlan, ip_range, netmask, dhcp_path, gateway, dns_list=None, routes=None):
leases_path = os.path.join(dhcp_path, "dnsmasq.leases")
pid_file = os.path.join(dhcp_path, 'dnsmasq.pid')
-
dhcp_range = ip_range[0] + ',' + ip_range[1] + ',' + netmask
- command = 'sudo ip netns exec ' + dhcp_namespace + ' mkdir -p ' + dhcp_path
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip netns exec {} mkdir -p {}'.format(dhcp_namespace, dhcp_path)
+ self.run_command(command)
+ # check if dnsmasq process is running
+ dnsmasq_is_runing = False
pid_path = os.path.join(dhcp_path, 'dnsmasq.pid')
- command = 'sudo ip netns exec ' + dhcp_namespace + ' cat ' + pid_path
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip netns exec ' + dhcp_namespace + ' ls ' + pid_path
+ content = self.run_command(command, ignore_exit_status=True)
# check if pid is runing
- pid_status_path = content
if content:
- command = "ps aux | awk '{print $2 }' | grep " + pid_status_path
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ pid_path = content.replace('\n', '')
+ command = "ps aux | awk '{print $2 }' | grep {}" + pid_path
+ dnsmasq_is_runing = self.run_command(command, ignore_exit_status=True)
gateway_option = ' --dhcp-option=3,' + gateway
for dns in dns_list:
dns_data += ',' + dns
- if not content:
+ if not dnsmasq_is_runing:
command = 'sudo ip netns exec ' + dhcp_namespace + ' /usr/sbin/dnsmasq --strict-order --except-interface=lo ' \
'--interface=' + ns_interface + \
' --bind-interfaces --dhcp-hostsdir=' + dhcp_path + \
dhcp_route_option + \
dns_data
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.readline()
-
- if len(content) == 0:
+ self.run_command(command)
return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
+ except RunCommandException as e:
self.logger.error("launch_dhcp_server ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
return False
- def delete_dhcp_interfaces(self, vlan):
+ def delete_dhcp_interfaces(self, vlan, dhcp_path):
"""
- Create a linux bridge with STP active
+ Delete a linux dnsmasq bridge and namespace
:param vlan: netowrk vlan id
+ :param dhcp_path:
:return:
"""
-
if self.test:
return True
try:
- br_veth_name = str(vlan) + '-vethDO'
- ovs_veth_name = str(vlan) + '-vethOD'
- dhcp_namespace = str(vlan) + '-dnsmasq'
+ br_veth_name ='{}-vethDO'.format(str(vlan))
+ ovs_veth_name = '{}-vethOD'.format(str(vlan))
+ dhcp_namespace = '{}-dnsmasq'.format(str(vlan))
- command = 'sudo ovs-vsctl del-port br-int ' + ovs_veth_name
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ dhcp_path = os.path.join(dhcp_path, dhcp_namespace)
+ command = 'sudo ovs-vsctl del-port br-int {}'.format(ovs_veth_name)
+ self.run_command(command, ignore_exit_status=True) # to end session
- command = 'sudo ip netns exec ' + dhcp_namespace + ' ip link set dev ' + br_veth_name + ' down'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip link set dev {} down'.format(ovs_veth_name)
+ self.run_command(command, ignore_exit_status=True) # to end session
- command = 'sudo ip link set dev ' + dhcp_namespace + ' down'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip link delete {} '.format(ovs_veth_name)
+ self.run_command(command, ignore_exit_status=True)
- command = 'sudo brctl delbr ' + dhcp_namespace
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip netns exec {} ip link set dev {} down'.format(dhcp_namespace, br_veth_name)
+ self.run_command(command, ignore_exit_status=True)
- command = 'sudo ip netns del ' + dhcp_namespace
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo rm -rf {}'.format(dhcp_path)
+ self.run_command(command)
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("delete_dhcp_interfaces ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ command = 'sudo ip netns del {}'.format(dhcp_namespace)
+ self.run_command(command)
+
+ return True
+ except RunCommandException as e:
+ self.logger.error("delete_dhcp_interfaces ssh Exception: {}".format(str(e)))
return False
def create_dhcp_interfaces(self, vlan, ip_listen_address, netmask):
:param netmask: dhcp net CIDR
:return: True if success
"""
-
if self.test:
return True
try:
- ovs_veth_name = str(vlan) + '-vethOD'
- ns_veth = str(vlan) + '-vethDO'
- dhcp_namespace = str(vlan) + '-dnsmasq'
+ ovs_veth_name = '{}-vethOD'.format(str(vlan))
+ ns_veth = '{}-vethDO'.format(str(vlan))
+ dhcp_namespace = '{}-dnsmasq'.format(str(vlan))
- command = 'sudo ip netns add ' + dhcp_namespace
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip link add ' + ns_veth + ' type veth peer name ' + ovs_veth_name
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip link set ' + ns_veth + ' netns ' + dhcp_namespace
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip netns exec ' + dhcp_namespace + ' ip link set dev ' + ns_veth + ' up'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ovs-vsctl add-port br-int ' + ovs_veth_name + ' tag=' + str(vlan)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip link set dev ' + ovs_veth_name + ' up'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip netns exec ' + dhcp_namespace + ' ip link set dev lo up'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip netns exec ' + dhcp_namespace + ' ' + ' ifconfig ' + ns_veth \
- + ' ' + ip_listen_address + ' netmask ' + netmask
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("create_dhcp_interfaces ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ command = 'sudo ip netns add {}'.format(dhcp_namespace)
+ self.run_command(command)
+
+ command = 'sudo ip link add {} type veth peer name {}'.format(ns_veth, ovs_veth_name)
+ self.run_command(command)
+
+ command = 'sudo ip link set {} netns {}'.format(ns_veth, dhcp_namespace)
+ self.run_command(command)
+
+ command = 'sudo ip netns exec {} ip link set dev {} up'.format(dhcp_namespace, ns_veth)
+ self.run_command(command)
+
+ command = 'sudo ovs-vsctl add-port br-int {} tag={}'.format(ovs_veth_name, str(vlan))
+ self.run_command(command, ignore_exit_status=True)
+
+ command = 'sudo ip link set dev {} up'.format(ovs_veth_name)
+ self.run_command(command)
+
+ command = 'sudo ip netns exec {} ip link set dev lo up'.format(dhcp_namespace)
+ self.run_command(command)
+
+ command = 'sudo ip netns exec {} ifconfig {} {} netmask {}'.format(dhcp_namespace,
+ ns_veth,
+ ip_listen_address,
+ netmask)
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("create_dhcp_interfaces ssh Exception: {}".format(str(e)))
return False
def delete_qrouter_connection(self, vlan, link):
:return:
"""
- ns_qouter = str(vlan) + '-qrouter'
- qrouter_ovs_veth = str(vlan) + '-vethOQ'
- qrouter_ns_veth = str(vlan) + '-vethQO'
-
- qrouter_br_veth = str(vlan) + '-vethBQ'
- qrouter_ns_router_veth = str(vlan) + '-vethQB'
-
- # delete ovs veth to ovs br-int
- command = 'sudo ovs-vsctl del-port br-int {}'.format(qrouter_ovs_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # down ns veth
- command = 'sudo ip netns exec {} ip link set dev {} down'.format(ns_qouter, qrouter_ns_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # down ovs veth interface
- command = 'sudo ip link set dev {} down'.format(qrouter_br_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # down br veth interface
- command = 'sudo ip link set dev {} down'.format(qrouter_ovs_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # down br veth interface
- command = 'sudo ip link set dev {} down'.format(qrouter_ns_router_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # down br veth interface
- command = 'sudo brctl delif {} {}'.format(link, qrouter_br_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
-
- # delete NS
- command = 'sudo ip netns del ' + ns_qouter
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ if self.test:
+ return True
+ try:
+ ns_qouter = '{}-qrouter'.format(str(vlan))
+ qrouter_ovs_veth = '{}-vethOQ'.format(str(vlan))
+ qrouter_ns_veth = '{}-vethQO'.format(str(vlan))
+ qrouter_br_veth = '{}-vethBQ'.format(str(vlan))
+ qrouter_ns_router_veth = '{}-vethQB'.format(str(vlan))
+
+ command = 'sudo ovs-vsctl del-port br-int {}'.format(qrouter_ovs_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # down ns veth
+ command = 'sudo ip netns exec {} ip link set dev {} down'.format(ns_qouter, qrouter_ns_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ command = 'sudo ip netns exec {} ip link delete {} '.format(ns_qouter, qrouter_ns_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ command = 'sudo ip netns del ' + ns_qouter
+ self.run_command(command)
+
+ # down ovs veth interface
+ command = 'sudo ip link set dev {} down'.format(qrouter_br_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # down br veth interface
+ command = 'sudo ip link set dev {} down'.format(qrouter_ovs_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # delete veth interface
+ command = 'sudo ip link delete {} '.format(link, qrouter_ovs_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # down br veth interface
+ command = 'sudo ip link set dev {} down'.format(qrouter_ns_router_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # delete veth interface
+ command = 'sudo ip link delete {} '.format(link, qrouter_ns_router_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # down br veth interface
+ command = 'sudo brctl delif {} {}'.format(link, qrouter_br_veth)
+ self.run_command(command)
+
+ # delete NS
+ return True
+ except RunCommandException as e:
+ self.logger.error("delete_qrouter_connection ssh Exception: {}".format(str(e)))
+ return False
def create_qrouter_ovs_connection(self, vlan, gateway, dhcp_cidr):
"""
:return:
"""
- ns_qouter = str(vlan) + '-qrouter'
- qrouter_ovs_veth = str(vlan) + '-vethOQ'
- qrouter_ns_veth = str(vlan) + '-vethQO'
-
- # Create NS
- command = 'sudo ip netns add ' + ns_qouter
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # Create pait veth
- command = 'sudo ip link add {} type veth peer name {}'.format(qrouter_ns_veth, qrouter_ovs_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # up ovs veth interface
- command = 'sudo ip link set dev {} up'.format(qrouter_ovs_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # add ovs veth to ovs br-int
- command = 'sudo ovs-vsctl add-port br-int {} tag={}'.format(qrouter_ovs_veth, vlan)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # add veth to ns
- command = 'sudo ip link set {} netns {}'.format(qrouter_ns_veth, ns_qouter)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # up ns loopback
- command = 'sudo ip netns exec {} ip link set dev lo up'.format(ns_qouter)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # up ns veth
- command = 'sudo ip netns exec {} ip link set dev {} up'.format(ns_qouter, qrouter_ns_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- from netaddr import IPNetwork
- ip_tools = IPNetwork(dhcp_cidr)
- cidr_len = ip_tools.prefixlen
-
- # set gw to ns veth
- command = 'sudo ip netns exec {} ip address add {}/{} dev {}'.format(ns_qouter, gateway, cidr_len, qrouter_ns_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ if self.test:
+ return True
- def add_ns_routes(self, vlan, routes):
+ try:
+ ns_qouter = '{}-qrouter'.format(str(vlan))
+ qrouter_ovs_veth ='{}-vethOQ'.format(str(vlan))
+ qrouter_ns_veth = '{}-vethQO'.format(str(vlan))
+
+ # Create NS
+ command = 'sudo ip netns add {}'.format(ns_qouter)
+ self.run_command(command)
+
+ # Create pait veth
+ command = 'sudo ip link add {} type veth peer name {}'.format(qrouter_ns_veth, qrouter_ovs_veth)
+ self.run_command(command, ignore_exit_status=True)
+
+ # up ovs veth interface
+ command = 'sudo ip link set dev {} up'.format(qrouter_ovs_veth)
+ self.run_command(command)
+
+ # add ovs veth to ovs br-int
+ command = 'sudo ovs-vsctl add-port br-int {} tag={}'.format(qrouter_ovs_veth, vlan)
+ self.run_command(command)
+
+ # add veth to ns
+ command = 'sudo ip link set {} netns {}'.format(qrouter_ns_veth, ns_qouter)
+ self.run_command(command)
+
+ # up ns loopback
+ command = 'sudo ip netns exec {} ip link set dev lo up'.format(ns_qouter)
+ self.run_command(command)
- for key, value in routes.iteritems():
- ns_qouter = str(vlan) + '-qrouter'
- qrouter_ns_router_veth = str(vlan) + '-vethQB'
# up ns veth
- if key == 'default':
- command = 'sudo ip netns exec {} ip route add {} via {} '.format(ns_qouter, key, value)
- else:
- command = 'sudo ip netns exec {} ip route add {} via {} dev {}'.format(ns_qouter, key, value,
- qrouter_ns_router_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ command = 'sudo ip netns exec {} ip link set dev {} up'.format(ns_qouter, qrouter_ns_veth)
+ self.run_command(command)
+
+ from netaddr import IPNetwork
+ ip_tools = IPNetwork(dhcp_cidr)
+ cidr_len = ip_tools.prefixlen
+
+ # set gw to ns veth
+ command = 'sudo ip netns exec {} ip address add {}/{} dev {}'.format(ns_qouter, gateway, cidr_len, qrouter_ns_veth)
+ self.run_command(command)
+
+ return True
+
+ except RunCommandException as e:
+ self.logger.error("Create_dhcp_interfaces ssh Exception: {}".format(str(e)))
+ return False
+
+ def add_ns_routes(self, vlan, routes):
+ """
+
+ :param vlan:
+ :param routes:
+ :return:
+ """
+
+ if self.test:
+ return True
+
+ try:
+ ns_qouter = '{}-qrouter'.format(str(vlan))
+ qrouter_ns_router_veth = '{}-vethQB'.format(str(vlan))
+
+ for key, value in routes.iteritems():
+ # up ns veth
+ if key == 'default':
+ command = 'sudo ip netns exec {} ip route add {} via {} '.format(ns_qouter, key, value)
+ else:
+ command = 'sudo ip netns exec {} ip route add {} via {} dev {}'.format(ns_qouter, key, value,
+ qrouter_ns_router_veth)
+
+ self.run_command(command)
+
+ return True
+
+ except RunCommandException as e:
+ self.logger.error("add_ns_routes, error adding routes to namesapce, {}".format(str(e)))
+ return False
def create_qrouter_br_connection(self, vlan, cidr, link):
"""
:return:
"""
- ns_qouter = str(vlan) + '-qrouter'
- qrouter_ns_router_veth = str(vlan) + '-vethQB'
- qrouter_br_veth = str(vlan) + '-vethBQ'
-
- # Create pait veth
- command = 'sudo ip link add {} type veth peer name {}'.format(qrouter_br_veth, qrouter_ns_router_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # up ovs veth interface
- command = 'sudo ip link set dev {} up'.format(qrouter_br_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # add veth to ns
- command = 'sudo ip link set {} netns {}'.format(qrouter_ns_router_veth, ns_qouter)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- # up ns veth
- command = 'sudo ip netns exec {} ip link set dev {} up'.format(ns_qouter, qrouter_ns_router_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo ip netns exec {} ip address add {} dev {}'.format(ns_qouter, link['nat'], qrouter_ns_router_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- command = 'sudo brctl show | grep {}'.format(link['iface'])
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- if content > '':
- # up ns veth
- command = 'sudo brctl addif {} {}'.format(link['iface'], qrouter_br_veth)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ if self.test:
+ return True
- # up ns veth
- command = 'sudo ip netns exec {} iptables -t nat -A POSTROUTING -o {} -s {} -d {} -j MASQUERADE' \
- .format(ns_qouter, qrouter_ns_router_veth, link['nat'], cidr)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ try:
+ ns_qouter = '{}-qrouter'.format(str(vlan))
+ qrouter_ns_router_veth = '{}-vethQB'.format(str(vlan))
+ qrouter_br_veth = '{}-vethBQ'.format(str(vlan))
+ command = 'sudo brctl show | grep {}'.format(link['iface'])
+ content = self.run_command(command, ignore_exit_status=True)
- else:
- self.logger.error('Bridge {} given by user not exist'.format(qrouter_br_veth))
+ if content > '':
+ # Create pait veth
+ command = 'sudo ip link add {} type veth peer name {}'.format(qrouter_br_veth, qrouter_ns_router_veth)
+ self.run_command(command)
+
+ # up ovs veth interface
+ command = 'sudo ip link set dev {} up'.format(qrouter_br_veth)
+ self.run_command(command)
+ # add veth to ns
+ command = 'sudo ip link set {} netns {}'.format(qrouter_ns_router_veth, ns_qouter)
+ self.run_command(command)
+ # up ns veth
+ command = 'sudo ip netns exec {} ip link set dev {} up'.format(ns_qouter, qrouter_ns_router_veth)
+ self.run_command(command)
+
+ command = 'sudo ip netns exec {} ip address add {} dev {}'.format(ns_qouter,
+ link['nat'],
+ qrouter_ns_router_veth)
+ self.run_command(command)
+
+ # up ns veth
+ command = 'sudo brctl addif {} {}'.format(link['iface'], qrouter_br_veth)
+ self.run_command(command)
+
+ # up ns veth
+ command = 'sudo ip netns exec {} iptables -t nat -A POSTROUTING -o {} -s {} -d {} -j MASQUERADE' \
+ .format(ns_qouter, qrouter_ns_router_veth, link['nat'], cidr)
+ self.run_command(command)
+
+ return True
+ else:
+
+ self.logger.error('create_qrouter_br_connection, Bridge {} given by user not exist'.format(qrouter_br_veth))
+ return False
+
+ except RunCommandException as e:
+ self.logger.error("Error creating qrouter, {}".format(str(e)))
+ return False
def create_link_bridge_to_ovs(self, vlan, link):
"""
return True
try:
- br_tap_name = str(vlan) + '-vethBO'
- br_ovs_name = str(vlan) + '-vethOB'
+ br_tap_name = '{}-vethBO'.format(str(vlan))
+ br_ovs_name = '{}-vethOB'.format(str(vlan))
# is a bridge or a interface
command = 'sudo brctl show | grep {}'.format(link)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
+ content = self.run_command(command, ignore_exit_status=True)
if content > '':
command = 'sudo ip link add {} type veth peer name {}'.format(br_tap_name, br_ovs_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command)
command = 'sudo ip link set dev {} up'.format(br_tap_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command)
command = 'sudo ip link set dev {} up'.format(br_ovs_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command)
command = 'sudo ovs-vsctl add-port br-int {} tag={}'.format(br_ovs_name, str(vlan))
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
+ self.run_command(command)
command = 'sudo brctl addif ' + link + ' {}'.format(br_tap_name)
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
-
- if len(content) == 0:
- return True
- else:
- return False
+ self.run_command(command)
+ return True
else:
self.logger.error('Link is not present, please check {}'.format(link))
return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("create_dhcp_interfaces ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+
+ except RunCommandException as e:
+ self.logger.error("create_link_bridge_to_ovs, Error creating link to ovs, {}".format(str(e)))
return False
def create_ovs_vxlan_tunnel(self, vxlan_interface, remote_ip):
return True
if remote_ip == 'localhost':
if self.localhost:
- return # TODO: Cannot create a vxlan between localhost and localhost
+ return True # TODO: Cannot create a vxlan between localhost and localhost
remote_ip = self.local_ip
try:
- command = 'sudo ovs-vsctl add-port br-int ' + vxlan_interface + \
- ' -- set Interface ' + vxlan_interface + ' type=vxlan options:remote_ip=' + remote_ip + \
- ' -- set Port ' + vxlan_interface + ' other_config:stp-path-cost=10'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- # print content
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("create_ovs_vxlan_tunnel ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+
+ command = 'sudo ovs-vsctl add-port br-int {} -- set Interface {} type=vxlan options:remote_ip={} ' \
+ '-- set Port {} other_config:stp-path-cost=10'.format(vxlan_interface,
+ vxlan_interface,
+ remote_ip,
+ vxlan_interface)
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("create_ovs_vxlan_tunnel, error creating vxlan tunnel, {}".format(str(e)))
return False
def delete_ovs_vxlan_tunnel(self, vxlan_interface):
if self.test or not self.connectivity:
return True
try:
- command = 'sudo ovs-vsctl del-port br-int ' + vxlan_interface
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- # print content
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("delete_ovs_vxlan_tunnel ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ command = 'sudo ovs-vsctl del-port br-int {}'.format(vxlan_interface)
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("delete_ovs_vxlan_tunnel, error deleting vxlan tunenl, {}".format(str(e)))
return False
def delete_ovs_bridge(self):
return True
try:
command = 'sudo ovs-vsctl del-br br-int'
- self.logger.debug("command: " + command)
- (_, stdout, _) = self.ssh_conn.exec_command(command)
- content = stdout.read()
- if len(content) == 0:
- return True
- else:
- return False
- except paramiko.ssh_exception.SSHException as e:
- self.logger.error("delete_ovs_bridge ssh Exception: " + str(e))
- if "SSH session not active" in str(e):
- self.ssh_connect()
+ self.run_command(command)
+ return True
+ except RunCommandException as e:
+ self.logger.error("delete_ovs_bridge ssh Exception: {}".format(str(e)))
return False
def get_file_info(self, path):
#self.server_status[server_id] = 'ACTIVE'
return 0, 'Success'
- self.db_lock.acquire()
result, server_data = self.db.get_instance(server_id)
- self.db_lock.release()
if result <= 0:
self.logger.error("launch_server ERROR getting server from DB %d %s", result, server_data)
return result, server_data
+ self.hypervisor = str(server_data['hypervisor'])
+
#0: get image metadata
server_metadata = server.get('metadata', {})
use_incremental = None
if "use_incremental" in server_metadata:
use_incremental = False if server_metadata["use_incremental"] == "no" else True
+ if self.xen_hyp == True:
+ use_incremental = False
server_host_files = self.localinfo['server_files'].get( server['uuid'], {})
if rebuild:
continue
else:
- self.db_lock.acquire()
result, content = self.db.get_table(FROM='images', SELECT=('path', 'metadata'),
WHERE={'uuid': image_id})
- self.db_lock.release()
if result <= 0:
error_text = "ERROR", result, content, "when getting image", dev['image_id']
self.logger.error("launch_server " + error_text)
STATUS={'progress':100, 'status':new_status}
if new_status == 'ERROR':
STATUS['last_error'] = 'machine has crashed'
- self.db_lock.acquire()
r,_ = self.db.update_rows('instances', STATUS, {'uuid':server_id}, log=False)
- self.db_lock.release()
if r>=0:
self.server_status[server_id] = new_status
elif 'terminate' in req['action']:
#PUT a log in the database
self.logger.error("PANIC deleting server id='%s' %s", server_id, last_error)
- self.db_lock.acquire()
- self.db.new_row('logs',
+ self.db.new_row('logs',
{'uuid':server_id, 'tenant_id':req['tenant_id'], 'related':'instances','level':'panic',
'description':'PANIC deleting server from host '+self.name+': '+last_error}
)
- self.db_lock.release()
if server_id in self.server_status:
del self.server_status[server_id]
return -1
else:
UPDATE['last_error'] = last_error
if new_status != 'deleted' and (new_status != old_status or new_status == 'ERROR') :
- self.db_lock.acquire()
self.db.update_rows('instances', UPDATE, {'uuid':server_id}, log=True)
self.server_status[server_id] = new_status
- self.db_lock.release()
if new_status == 'ERROR':
return -1
return 1
self.logger.error("create_image id='%s' Exception: %s", server_id, error_text)
#TODO insert a last_error at database
- self.db_lock.acquire()
- self.db.update_rows('images', {'status':image_status, 'progress': 100, 'path':file_dst},
+ self.db.update_rows('images', {'status':image_status, 'progress': 100, 'path':file_dst},
{'uuid':req['new_image']['uuid']}, log=True)
- self.db_lock.release()
-
+
def edit_iface(self, port_id, old_net, new_net):
#This action imply remove and insert interface to put proper parameters
if self.test:
time.sleep(1)
else:
#get iface details
- self.db_lock.acquire()
r,c = self.db.get_table(FROM='ports as p join resources_port as rp on p.uuid=rp.port_id',
WHERE={'port_id': port_id})
- self.db_lock.release()
if r<0:
self.logger.error("edit_iface %s DDBB error: %s", port_id, c)
return
if conn is not None: conn.close()
-def create_server(server, db, db_lock, only_of_ports):
+def create_server(server, db, only_of_ports):
extended = server.get('extended', None)
requirements={}
requirements['numa']={'memory':0, 'proc_req_type': 'threads', 'proc_req_nb':0, 'port_list':[], 'sriov_list':[]}
elif requirements['vcpus']==0:
return (-1, "Processor information not set neither at extended field not at vcpus")
+ if 'hypervisor' in server: requirements['hypervisor'] = server['hypervisor'] #Unikernels extension
- db_lock.acquire()
result, content = db.get_numas(requirements, server.get('host_id', None), only_of_ports)
- db_lock.release()
-
+
if result == -1:
return (-1, content)
cpu_pinning = []
reserved_threads=[]
if requirements['numa']['proc_req_nb']>0:
- db_lock.acquire()
- result, content = db.get_table(FROM='resources_core',
+ result, content = db.get_table(FROM='resources_core',
SELECT=('id','core_id','thread_id'),
WHERE={'numa_id':numa_id,'instance_id': None, 'status':'ok'} )
- db_lock.release()
if result <= 0:
#print content
return -1, content
#Get the source pci addresses for the selected numa
used_sriov_ports = []
for port in requirements['numa']['sriov_list']:
- db_lock.acquire()
result, content = db.get_table(FROM='resources_port', SELECT=('id', 'pci', 'mac'),WHERE={'numa_id':numa_id,'root_id': port['port_id'], 'port_id': None, 'Mbps_used': 0} )
- db_lock.release()
if result <= 0:
#print content
return -1, content
port['mac_address'] = port['mac']
del port['mac']
continue
- db_lock.acquire()
result, content = db.get_table(FROM='resources_port', SELECT=('id', 'pci', 'mac', 'Mbps'),WHERE={'numa_id':numa_id,'root_id': port['port_id'], 'port_id': None, 'Mbps_used': 0} )
- db_lock.release()
if result <= 0:
#print content
return -1, content
for control_iface in server.get('networks', []):
control_iface['net_id']=control_iface.pop('uuid')
#Get the brifge name
- db_lock.acquire()
result, content = db.get_table(FROM='nets',
SELECT=('name', 'type', 'vlan', 'provider', 'enable_dhcp','dhcp_first_ip',
'dhcp_last_ip', 'cidr', 'gateway_ip', 'dns', 'links', 'routes'),
WHERE={'uuid': control_iface['net_id']})
- db_lock.release()
- if result < 0:
+ if result < 0:
pass
elif result==0:
return -1, "Error at field netwoks: Not found any network wit uuid %s" % control_iface['net_id']
if 'description' in server: resources['description'] = server['description']
if 'name' in server: resources['name'] = server['name']
+ if 'hypervisor' in server: resources['hypervisor'] = server['hypervisor']
+ if 'os_image_type' in server: resources['os_image_type'] = server['os_image_type']
resources['extended'] = {} #optional
resources['extended']['numas'] = []
projects / osm / openvim.git / blobdiff