util: Remove a bunch of unused methods
And move some to the only files they are used in.
This commit is contained in:
parent
b3779eec7d
commit
a07c81e92a
|
@ -35,6 +35,13 @@ import virtconv.vmcfg as vmcfg
|
|||
import virtconv.diskcfg as diskcfg
|
||||
|
||||
|
||||
def get_default_arch():
|
||||
arch = os.uname()[4]
|
||||
if arch == "x86_64":
|
||||
return "x86_64"
|
||||
return "i686"
|
||||
|
||||
|
||||
def parse_args():
|
||||
"""Parse and verify command line."""
|
||||
usage = "%prog [options] inputdir|input.vmx [outputdir|output.xml]"
|
||||
|
@ -59,7 +66,7 @@ def parse_args():
|
|||
|
||||
cfgg = OptionGroup(opts, "Guest Configuration Options")
|
||||
cfgg.add_option("-a", "--arch", dest="arch",
|
||||
default=util.get_default_arch(),
|
||||
default=get_default_arch(),
|
||||
help=_("Machine Architecture Type (i686/x86_64/ppc)"))
|
||||
cfgg.add_option("", "--os-type", dest="os_type",
|
||||
help=_("The OS type for fully virtualized guests, e.g. "
|
||||
|
|
|
@ -23,6 +23,16 @@ import util
|
|||
import XMLBuilderDomain
|
||||
from XMLBuilderDomain import _xml_property
|
||||
|
||||
|
||||
def get_phy_cpus(conn):
|
||||
"""
|
||||
Get number of physical CPUs.
|
||||
"""
|
||||
hostinfo = conn.getInfo()
|
||||
pcpus = hostinfo[4] * hostinfo[5] * hostinfo[6] * hostinfo[7]
|
||||
return pcpus
|
||||
|
||||
|
||||
class DomainNumatune(XMLBuilderDomain.XMLBuilderDomain):
|
||||
"""
|
||||
Class for generating <numatune> XML
|
||||
|
@ -39,7 +49,7 @@ class DomainNumatune(XMLBuilderDomain.XMLBuilderDomain):
|
|||
raise ValueError(_("cpuset can only contain numeric, ',', '^', or "
|
||||
"'-' characters"))
|
||||
|
||||
pcpus = util.get_phy_cpus(conn)
|
||||
pcpus = get_phy_cpus(conn)
|
||||
for c in val.split(','):
|
||||
# Redundant commas
|
||||
if not c:
|
||||
|
@ -66,7 +76,7 @@ class DomainNumatune(XMLBuilderDomain.XMLBuilderDomain):
|
|||
@staticmethod
|
||||
def cpuset_str_to_tuple(conn, cpuset):
|
||||
DomainNumatune.validate_cpuset(conn, cpuset)
|
||||
pinlist = [False] * util.get_phy_cpus(conn)
|
||||
pinlist = [False] * get_phy_cpus(conn)
|
||||
|
||||
entries = cpuset.split(",")
|
||||
for e in entries:
|
||||
|
|
|
@ -37,6 +37,28 @@ from Boot import Boot
|
|||
XEN_SCRATCH = "/var/lib/xen"
|
||||
LIBVIRT_SCRATCH = "/var/lib/libvirt/boot"
|
||||
|
||||
|
||||
def _pygrub_path(conn=None):
|
||||
"""
|
||||
Return the pygrub path for the current host, or connection if
|
||||
available.
|
||||
"""
|
||||
# FIXME: This should be removed/deprecated when capabilities are
|
||||
# fixed to provide bootloader info
|
||||
from virtinst import CapabilitiesParser
|
||||
|
||||
if conn:
|
||||
cap = CapabilitiesParser.parse(conn.getCapabilities())
|
||||
if (cap.host.arch == "i86pc"):
|
||||
return "/usr/lib/xen/bin/pygrub"
|
||||
else:
|
||||
return "/usr/bin/pygrub"
|
||||
|
||||
if platform.system() == "SunOS":
|
||||
return "/usr/lib/xen/bin/pygrub"
|
||||
return "/usr/bin/pygrub"
|
||||
|
||||
|
||||
class Installer(XMLBuilderDomain.XMLBuilderDomain):
|
||||
"""
|
||||
Installer classes attempt to encapsulate all the parameters needed
|
||||
|
@ -333,7 +355,7 @@ class Installer(XMLBuilderDomain.XMLBuilderDomain):
|
|||
if (not isinstall and
|
||||
self.is_xenpv() and
|
||||
not self.bootconfig.kernel):
|
||||
return "<bootloader>%s</bootloader>" % util.pygrub_path(conn)
|
||||
return "<bootloader>%s</bootloader>" % _pygrub_path(conn)
|
||||
|
||||
osblob = "<os>"
|
||||
|
||||
|
|
|
@ -25,6 +25,26 @@ import VirtualDevice
|
|||
import XMLBuilderDomain
|
||||
from XMLBuilderDomain import _xml_property
|
||||
|
||||
|
||||
def _compareMAC(p, q):
|
||||
"""Compare two MAC addresses"""
|
||||
pa = p.split(":")
|
||||
qa = q.split(":")
|
||||
|
||||
if len(pa) != len(qa):
|
||||
if p > q:
|
||||
return 1
|
||||
else:
|
||||
return -1
|
||||
|
||||
for i in xrange(len(pa)):
|
||||
n = int(pa[i], 0x10) - int(qa[i], 0x10)
|
||||
if n > 0:
|
||||
return 1
|
||||
elif n < 0:
|
||||
return -1
|
||||
return 0
|
||||
|
||||
def _countMACaddr(vms, searchmac):
|
||||
if not searchmac:
|
||||
return
|
||||
|
@ -34,7 +54,7 @@ def _countMACaddr(vms, searchmac):
|
|||
|
||||
for mac in ctx.xpathEval("/domain/devices/interface/mac"):
|
||||
macaddr = mac.xpathEval("attribute::address")[0].content
|
||||
if macaddr and util.compareMAC(searchmac, macaddr) == 0:
|
||||
if macaddr and _compareMAC(searchmac, macaddr) == 0:
|
||||
c += 1
|
||||
return c
|
||||
|
||||
|
|
|
@ -596,46 +596,6 @@ def default_connection():
|
|||
return "qemu:///session"
|
||||
return None
|
||||
|
||||
def get_cpu_flags():
|
||||
if platform.system() == 'SunOS':
|
||||
raise OSError('CPU flags not available')
|
||||
|
||||
f = open("/proc/cpuinfo")
|
||||
lines = f.readlines()
|
||||
f.close()
|
||||
for line in lines:
|
||||
if not line.startswith("flags"):
|
||||
continue
|
||||
# get the actual flags
|
||||
flags = line[:-1].split(":", 1)[1]
|
||||
# and split them
|
||||
flst = flags.split(" ")
|
||||
return flst
|
||||
return []
|
||||
|
||||
def is_pae_capable(conn=None):
|
||||
"""Determine if a machine is PAE capable or not."""
|
||||
if not conn:
|
||||
conn = libvirt.open('')
|
||||
return "pae" in conn.getCapabilities()
|
||||
|
||||
def is_hvm_capable():
|
||||
"""Determine if a machine is HVM capable or not."""
|
||||
if platform.system() == 'SunOS':
|
||||
raise OSError('HVM capability not determinible')
|
||||
|
||||
caps = ""
|
||||
if os.path.exists("/sys/hypervisor/properties/capabilities"):
|
||||
caps = open("/sys/hypervisor/properties/capabilities").read()
|
||||
if caps.find("hvm") != -1:
|
||||
return True
|
||||
return False
|
||||
|
||||
def is_kqemu_capable():
|
||||
return os.path.exists("/dev/kqemu")
|
||||
|
||||
def is_kvm_capable():
|
||||
return os.path.exists("/dev/kvm")
|
||||
|
||||
def is_blktap_capable():
|
||||
if platform.system() == 'SunOS':
|
||||
|
@ -650,11 +610,6 @@ def is_blktap_capable():
|
|||
return True
|
||||
return False
|
||||
|
||||
def get_default_arch():
|
||||
arch = os.uname()[4]
|
||||
if arch == "x86_64":
|
||||
return "x86_64"
|
||||
return "i686"
|
||||
|
||||
# this function is directly from xend/server/netif.py and is thus
|
||||
# available under the LGPL,
|
||||
|
@ -699,6 +654,7 @@ def randomMAC(type="xen", conn=None):
|
|||
random.randint(0x00, 0xff)]
|
||||
return ':'.join(map(lambda x: "%02x" % x, mac))
|
||||
|
||||
|
||||
# the following three functions are from xend/uuid.py and are thus
|
||||
# available under the LGPL,
|
||||
# Copyright 2005 Mike Wray <mike.wray@hp.com>
|
||||
|
@ -716,11 +672,6 @@ def uuidToString(u, conn=None):
|
|||
return "-".join(["%02x" * 4, "%02x" * 2, "%02x" * 2, "%02x" * 2,
|
||||
"%02x" * 6]) % tuple(u)
|
||||
|
||||
def uuidFromString(s):
|
||||
s = s.replace('-', '')
|
||||
return [ int(s[i : i + 2], 16) for i in range(0, 32, 2) ]
|
||||
|
||||
# the following function quotes from python2.5/uuid.py
|
||||
def get_host_network_devices():
|
||||
device = []
|
||||
for dirname in ['', '/sbin/', '/usr/sbin']:
|
||||
|
@ -751,17 +702,6 @@ def get_max_vcpus(conn, type=None):
|
|||
m = 32
|
||||
return m
|
||||
|
||||
def get_phy_cpus(conn):
|
||||
"""Get number of physical CPUs."""
|
||||
hostinfo = conn.getInfo()
|
||||
pcpus = hostinfo[4] * hostinfo[5] * hostinfo[6] * hostinfo[7]
|
||||
return pcpus
|
||||
|
||||
def system(cmd):
|
||||
st = os.system(cmd)
|
||||
if os.WIFEXITED(st) and os.WEXITSTATUS(st) != 0:
|
||||
raise OSError("Failed to run %s, exited with %d" %
|
||||
(cmd, os.WEXITSTATUS(st)))
|
||||
|
||||
def xml_escape(str):
|
||||
"""Replaces chars ' " < > & with xml safe counterparts"""
|
||||
|
@ -775,24 +715,6 @@ def xml_escape(str):
|
|||
str = str.replace(">", ">")
|
||||
return str
|
||||
|
||||
def compareMAC(p, q):
|
||||
"""Compare two MAC addresses"""
|
||||
pa = p.split(":")
|
||||
qa = q.split(":")
|
||||
|
||||
if len(pa) != len(qa):
|
||||
if p > q:
|
||||
return 1
|
||||
else:
|
||||
return -1
|
||||
|
||||
for i in xrange(len(pa)):
|
||||
n = int(pa[i], 0x10) - int(qa[i], 0x10)
|
||||
if n > 0:
|
||||
return 1
|
||||
elif n < 0:
|
||||
return -1
|
||||
return 0
|
||||
|
||||
def _xorg_keymap():
|
||||
"""Look in /etc/X11/xorg.conf for the host machine's keymap, and attempt to
|
||||
|
@ -867,25 +789,6 @@ def default_keymap():
|
|||
|
||||
return keymap
|
||||
|
||||
def pygrub_path(conn=None):
|
||||
"""
|
||||
Return the pygrub path for the current host, or connection if
|
||||
available.
|
||||
"""
|
||||
# FIXME: This should be removed/deprecated when capabilities are
|
||||
# fixed to provide bootloader info
|
||||
from virtinst import CapabilitiesParser
|
||||
|
||||
if conn:
|
||||
cap = CapabilitiesParser.parse(conn.getCapabilities())
|
||||
if (cap.host.arch == "i86pc"):
|
||||
return "/usr/lib/xen/bin/pygrub"
|
||||
else:
|
||||
return "/usr/bin/pygrub"
|
||||
|
||||
if platform.system() == "SunOS":
|
||||
return "/usr/lib/xen/bin/pygrub"
|
||||
return "/usr/bin/pygrub"
|
||||
|
||||
def uri_split(uri):
|
||||
"""
|
||||
|
|
Loading…
Reference in New Issue