mirror of
https://github.com/virt-manager/virt-manager.git
synced 2024-10-27 01:55:20 +03:00
acfb988945
We have a lot of functions that are just wrappers around these, so make it public for future use.
269 lines
7.8 KiB
Python
269 lines
7.8 KiB
Python
#
|
|
# Copyright 2013 Red Hat, Inc.
|
|
# Cole Robinson <crobinso@redhat.com>
|
|
#
|
|
# This program is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation; either version 2 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
|
|
# MA 02110-1301 USA.
|
|
"""
|
|
Classes for building and installing libvirt <network> XML
|
|
"""
|
|
|
|
import logging
|
|
|
|
import libvirt
|
|
|
|
from . import util
|
|
from .xmlbuilder import XMLBuilder, XMLChildProperty, XMLProperty
|
|
|
|
|
|
class _NetworkDHCPRange(XMLBuilder):
|
|
_XML_ROOT_NAME = "range"
|
|
start = XMLProperty("./@start")
|
|
end = XMLProperty("./@end")
|
|
|
|
|
|
class _NetworkDHCPHost(XMLBuilder):
|
|
_XML_ROOT_NAME = "host"
|
|
macaddr = XMLProperty("./@mac")
|
|
name = XMLProperty("./@name")
|
|
ip = XMLProperty("./@ip")
|
|
|
|
|
|
class _NetworkIP(XMLBuilder):
|
|
_XML_ROOT_NAME = "ip"
|
|
|
|
family = XMLProperty("./@family")
|
|
address = XMLProperty("./@address")
|
|
prefix = XMLProperty("./@prefix", is_int=True)
|
|
netmask = XMLProperty("./@netmask")
|
|
|
|
tftp = XMLProperty("./tftp/@root")
|
|
bootp_file = XMLProperty("./dhcp/bootp/@file")
|
|
bootp_server = XMLProperty("./dhcp/bootp/@server")
|
|
|
|
ranges = XMLChildProperty(_NetworkDHCPRange, relative_xpath="./dhcp")
|
|
hosts = XMLChildProperty(_NetworkDHCPHost, relative_xpath="./dhcp")
|
|
|
|
def add_range(self):
|
|
r = _NetworkDHCPRange(self.conn)
|
|
self.add_child(r)
|
|
return r
|
|
|
|
|
|
class _NetworkRoute(XMLBuilder):
|
|
_XML_ROOT_NAME = "route"
|
|
|
|
family = XMLProperty("./@family")
|
|
address = XMLProperty("./@address")
|
|
prefix = XMLProperty("./@prefix", is_int=True)
|
|
gateway = XMLProperty("./@gateway")
|
|
netmask = XMLProperty("./@netmask")
|
|
|
|
|
|
class _NetworkForward(XMLBuilder):
|
|
_XML_ROOT_NAME = "forward"
|
|
|
|
mode = XMLProperty("./@mode")
|
|
dev = XMLProperty("./@dev")
|
|
|
|
def pretty_desc(self):
|
|
return Network.pretty_forward_desc(self.mode, self.dev)
|
|
|
|
|
|
class _NetworkBandwidth(XMLBuilder):
|
|
_XML_ROOT_NAME = "bandwidth"
|
|
|
|
inbound_average = XMLProperty("./inbound/@average")
|
|
inbound_peak = XMLProperty("./inbound/@peak")
|
|
inbound_burst = XMLProperty("./inbound/@burst")
|
|
inbound_floor = XMLProperty("./inbound/@floor")
|
|
|
|
outbound_average = XMLProperty("./outbound/@average")
|
|
outbound_peak = XMLProperty("./outbound/@peak")
|
|
outbound_burst = XMLProperty("./outbound/@burst")
|
|
|
|
def is_inbound(self):
|
|
return bool(self.inbound_average or self.inbound_peak or
|
|
self.inbound_burst or self.inbound_floor)
|
|
|
|
def is_outbound(self):
|
|
return bool(self.outbound_average or self.outbound_peak or
|
|
self.outbound_burst)
|
|
|
|
def pretty_desc(self, inbound=True, outbound=True):
|
|
items_in = [(self.inbound_average, _("Average"), "KiB/s"),
|
|
(self.inbound_peak, _("Peak"), "KiB"),
|
|
(self.inbound_burst, _("Burst"), "KiB/s"),
|
|
(self.inbound_floor, _("Floor"), "KiB/s")]
|
|
|
|
items_out = [(self.outbound_average, _("Average"), "KiB/s"),
|
|
(self.outbound_peak, _("Peak"), "KiB"),
|
|
(self.outbound_burst, _("Burst"), "KiB/s")]
|
|
|
|
def stringify_items(items):
|
|
return ", ".join(["%s: %s %s" % (desc, val, unit)
|
|
for val, desc, unit in items if val])
|
|
|
|
ret = ""
|
|
show_name = inbound and outbound
|
|
|
|
if inbound:
|
|
if show_name:
|
|
ret += _("Inbound: ")
|
|
ret += stringify_items(items_in)
|
|
|
|
if outbound:
|
|
if ret:
|
|
ret += "\n"
|
|
if show_name:
|
|
ret += _("Outbound: ")
|
|
ret += stringify_items(items_out)
|
|
|
|
return ret
|
|
|
|
|
|
class _NetworkPortgroup(XMLBuilder):
|
|
_XML_ROOT_NAME = "portgroup"
|
|
|
|
name = XMLProperty("./@name")
|
|
default = XMLProperty("./@default", is_yesno=True)
|
|
|
|
|
|
class Network(XMLBuilder):
|
|
"""
|
|
Top level class for <network> object XML
|
|
"""
|
|
@staticmethod
|
|
def pretty_forward_desc(mode, dev):
|
|
if mode or dev:
|
|
if not mode or mode == "nat":
|
|
if dev:
|
|
desc = _("NAT to %s") % dev
|
|
else:
|
|
desc = _("NAT")
|
|
elif mode == "route":
|
|
if dev:
|
|
desc = _("Route to %s") % dev
|
|
else:
|
|
desc = _("Routed network")
|
|
else:
|
|
if dev:
|
|
desc = "%s to %s" % (mode, dev)
|
|
else:
|
|
desc = "%s network" % mode.capitalize()
|
|
else:
|
|
desc = _("Isolated network, internal and host routing only")
|
|
|
|
return desc
|
|
|
|
def __init__(self, *args, **kwargs):
|
|
XMLBuilder.__init__(self, *args, **kwargs)
|
|
self._random_uuid = None
|
|
|
|
|
|
###################
|
|
# Helper routines #
|
|
###################
|
|
|
|
def can_pxe(self):
|
|
forward = self.forward.mode
|
|
if forward and forward != "nat":
|
|
return True
|
|
for ip in self.ips:
|
|
if ip.bootp_file:
|
|
return True
|
|
return False
|
|
|
|
######################
|
|
# Validation helpers #
|
|
######################
|
|
|
|
def _validate_name(self, name):
|
|
util.validate_name(_("Network"), name)
|
|
|
|
try:
|
|
self.conn.networkLookupByName(name)
|
|
except libvirt.libvirtError:
|
|
return
|
|
raise ValueError(_("Name '%s' already in use by another network." %
|
|
name))
|
|
|
|
def _get_default_uuid(self):
|
|
if self._random_uuid is None:
|
|
self._random_uuid = util.generate_uuid(self.conn)
|
|
return self._random_uuid
|
|
|
|
|
|
##################
|
|
# XML properties #
|
|
##################
|
|
|
|
_XML_ROOT_NAME = "network"
|
|
_XML_PROP_ORDER = ["ipv6", "name", "uuid", "forward",
|
|
"bridge", "stp", "delay", "domain_name",
|
|
"macaddr", "ips", "routes", "bandwidth"]
|
|
|
|
ipv6 = XMLProperty("./@ipv6", is_yesno=True)
|
|
name = XMLProperty("./name", validate_cb=_validate_name)
|
|
uuid = XMLProperty("./uuid",
|
|
validate_cb=lambda s, v: util.validate_uuid(v),
|
|
default_cb=_get_default_uuid)
|
|
|
|
# Not entirely correct, there can be multiple routes
|
|
forward = XMLChildProperty(_NetworkForward, is_single=True)
|
|
|
|
domain_name = XMLProperty("./domain/@name")
|
|
|
|
bridge = XMLProperty("./bridge/@name")
|
|
stp = XMLProperty("./bridge/@stp", is_onoff=True)
|
|
delay = XMLProperty("./bridge/@delay", is_int=True)
|
|
macaddr = XMLProperty("./mac/@address")
|
|
|
|
portgroups = XMLChildProperty(_NetworkPortgroup)
|
|
ips = XMLChildProperty(_NetworkIP)
|
|
routes = XMLChildProperty(_NetworkRoute)
|
|
bandwidth = XMLChildProperty(_NetworkBandwidth, is_single=True)
|
|
|
|
def add_ip(self):
|
|
ip = _NetworkIP(self.conn)
|
|
self.add_child(ip)
|
|
return ip
|
|
def add_route(self):
|
|
route = _NetworkRoute(self.conn)
|
|
self.add_child(route)
|
|
return route
|
|
|
|
|
|
##################
|
|
# build routines #
|
|
##################
|
|
|
|
def install(self, start=True, autostart=True):
|
|
xml = self.get_xml_config()
|
|
logging.debug("Creating virtual network '%s' with xml:\n%s",
|
|
self.name, xml)
|
|
|
|
net = self.conn.networkDefineXML(xml)
|
|
try:
|
|
if start:
|
|
net.create()
|
|
if autostart:
|
|
net.setAutostart(autostart)
|
|
except:
|
|
net.undefine()
|
|
raise
|
|
|
|
return net
|