shaba/virt-manager
1
0
Fork 0
mirror of https://github.com/virt-manager/virt-manager.git synced 2024-12-24 21:34:47 +03:00
Code Issues Projects Releases Wiki Activity
7e34b022af
virt-manager/virtManager/create.py
Cole Robinson f4dfb6de9d Fix recent pylint/pep8 output
2016-04-18 16:42:12 -04:00

2355 lines
80 KiB
Python
Raw Blame History

#
# Copyright (C) 2008, 2013, 2014, 2015 Red Hat, Inc.
# Copyright (C) 2008 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.
#
import logging
import threading
import time
from gi.repository import GObject
from gi.repository import Gtk
from gi.repository import Gdk
from gi.repository import Pango
import virtinst
from virtinst import util
from . import uiutil
from .baseclass import vmmGObjectUI
from .asyncjob import vmmAsyncJob
from .storagebrowse import vmmStorageBrowser
from .details import vmmDetails
from .domain import vmmDomainVirtinst
from .netlist import vmmNetworkList
from .mediacombo import vmmMediaCombo
from .addstorage import vmmAddStorage
# Number of seconds to wait for media detection
DETECT_TIMEOUT = 20
DEFAULT_MEM = 1024
(PAGE_NAME,
PAGE_INSTALL,
PAGE_MEM,
PAGE_STORAGE,
PAGE_FINISH) = range(5)
(INSTALL_PAGE_ISO,
INSTALL_PAGE_URL,
INSTALL_PAGE_PXE,
INSTALL_PAGE_IMPORT,
INSTALL_PAGE_CONTAINER_APP,
INSTALL_PAGE_CONTAINER_OS) = range(6)
# Column numbers for os type/version list models
(OS_COL_ID,
OS_COL_LABEL,
OS_COL_IS_SEP,
OS_COL_IS_SHOW_ALL) = range(4)
#####################
# Pretty UI helpers #
#####################
def _pretty_arch(_a):
if _a == "armv7l":
return "arm"
return _a
def _pretty_storage(size):
return "%.1f GiB" % float(size)
def _pretty_memory(mem):
return "%d MiB" % (mem / 1024.0)
###########################################################
# Helpers for tracking devices we create from this wizard #
###########################################################
def _mark_vmm_device(dev):
setattr(dev, "vmm_create_wizard_device", True)
def _get_vmm_device(guest, devkey):
for dev in guest.get_devices(devkey):
if hasattr(dev, "vmm_create_wizard_device"):
return dev
def _remove_vmm_device(guest, devkey):
dev = _get_vmm_device(guest, devkey)
if dev:
guest.remove_device(dev)
##############
# Main class #
##############
class vmmCreate(vmmGObjectUI):
__gsignals__ = {
"action-show-domain": (GObject.SignalFlags.RUN_FIRST, None, [str, str]),
}
def __init__(self, engine):
vmmGObjectUI.__init__(self, "create.ui", "vmm-create")
self.engine = engine
self.conn = None
self._capsinfo = None
self._guest = None
self._failed_guest = None
# Distro detection state variables
self._detect_os_in_progress = False
self._os_already_detected_for_media = False
self._show_all_os_was_selected = False
self._customize_window = None
self._storage_browser = None
self._netlist = None
self._mediacombo = None
self._addstorage = vmmAddStorage(self.conn, self.builder, self.topwin)
self.widget("storage-align").add(self._addstorage.top_box)
def _browse_file_cb(ignore, widget):
self._browse_file(widget)
self._addstorage.connect("browse-clicked", _browse_file_cb)
self.builder.connect_signals({
"on_vmm_newcreate_delete_event" : self._close_requested,
"on_create_cancel_clicked": self._close_requested,
"on_create_back_clicked" : self._back_clicked,
"on_create_forward_clicked" : self._forward_clicked,
"on_create_finish_clicked" : self._finish_clicked,
"on_create_pages_switch_page": self._page_changed,
"on_create_conn_changed": self._conn_changed,
"on_method_changed": self._method_changed,
"on_xen_type_changed": self._xen_type_changed,
"on_arch_changed": self._arch_changed,
"on_virt_type_changed": self._virt_type_changed,
"on_machine_changed": self._machine_changed,
"on_install_cdrom_radio_toggled": self._local_media_toggled,
"on_install_iso_entry_changed": self._iso_changed,
"on_install_iso_entry_activate": self._iso_activated,
"on_install_iso_browse_clicked": self._browse_iso,
"on_install_url_entry_changed": self._url_changed,
"on_install_url_entry_activate": self._url_activated,
"on_install_import_browse_clicked": self._browse_import,
"on_install_app_browse_clicked": self._browse_app,
"on_install_oscontainer_browse_clicked": self._browse_oscontainer,
"on_install_detect_os_toggled": self._toggle_detect_os,
"on_install_os_type_changed": self._change_os_type,
"on_install_os_version_changed": self._change_os_version,
"on_install_detect_os_box_show": self._os_detect_visibility_changed,
"on_install_detect_os_box_hide": self._os_detect_visibility_changed,
"on_kernel_browse_clicked": self._browse_kernel,
"on_initrd_browse_clicked": self._browse_initrd,
"on_dtb_browse_clicked": self._browse_dtb,
"on_enable_storage_toggled": self._toggle_enable_storage,
"on_create_vm_name_changed": self._name_changed,
})
self.bind_escape_key_close()
self._init_state()
###########################
# Standard window methods #
###########################
def is_visible(self):
return self.topwin.get_visible()
def show(self, parent, uri=None):
logging.debug("Showing new vm wizard")
if not self.is_visible():
self._reset_state(uri)
self.topwin.set_transient_for(parent)
self.topwin.present()
def _close(self, ignore1=None, ignore2=None):
if self.is_visible():
logging.debug("Closing new vm wizard")
self.topwin.hide()
self._cleanup_customize_window()
if self._storage_browser:
self._storage_browser.close()
def _cleanup(self):
self.conn = None
self._capsinfo = None
self._guest = None
if self._storage_browser:
self._storage_browser.cleanup()
self._storage_browser = None
if self._netlist:
self._netlist.cleanup()
self._netlist = None
if self._netlist:
self._netlist.cleanup()
self._netlist = None
if self._mediacombo:
self._mediacombo.cleanup()
self._mediacombo = None
if self._addstorage:
self._addstorage.cleanup()
self._addstorage = None
##########################
# Initial state handling #
##########################
def _show_startup_error(self, error, hideinstall=True):
self.widget("startup-error-box").show()
self.widget("create-forward").set_sensitive(False)
if hideinstall:
self.widget("install-box").hide()
self.widget("arch-expander").hide()
self.widget("startup-error").set_text("%s: %s" % (_("Error"), error))
return False
def _show_startup_warning(self, error):
self.widget("startup-error-box").show()
self.widget("startup-error").set_markup(
"<span size='small'>%s: %s</span>" % (_("Warning"), error))
def _show_arch_warning(self, error):
self.widget("arch-warning-box").show()
self.widget("arch-warning").set_markup(
"<span size='small'>%s: %s</span>" % (_("Warning"), error))
def _init_state(self):
self.widget("create-pages").set_show_tabs(False)
self.widget("install-method-pages").set_show_tabs(False)
blue = Gdk.Color.parse("#0072A8")[1]
self.widget("header").modify_bg(Gtk.StateType.NORMAL, blue)
# Connection list
self.widget("create-conn-label").set_text("")
self.widget("startup-error").set_text("")
conn_list = self.widget("create-conn")
conn_model = Gtk.ListStore(str, str)
conn_list.set_model(conn_model)
text = uiutil.init_combo_text_column(conn_list, 1)
text.set_property("ellipsize", Pango.EllipsizeMode.MIDDLE)
# ISO media list
iso_list = self.widget("install-iso-combo")
iso_model = Gtk.ListStore(str)
iso_list.set_model(iso_model)
iso_list.set_entry_text_column(0)
# Lists for the install urls
media_url_list = self.widget("install-url-combo")
media_url_model = Gtk.ListStore(str)
media_url_list.set_model(media_url_model)
media_url_list.set_entry_text_column(0)
def sep_func(model, it, combo):
ignore = combo
return model[it][OS_COL_IS_SEP]
def make_os_model():
# [os value, os label, is seperator, is 'show all']
cols = []
cols.insert(OS_COL_ID, str)
cols.insert(OS_COL_LABEL, str)
cols.insert(OS_COL_IS_SEP, bool)
cols.insert(OS_COL_IS_SHOW_ALL, bool)
return Gtk.ListStore(*cols)
# Lists for distro type + variant
os_type_list = self.widget("install-os-type")
os_type_model = make_os_model()
os_type_list.set_model(os_type_model)
uiutil.init_combo_text_column(os_type_list, 1)
os_type_list.set_row_separator_func(sep_func, os_type_list)
os_variant_list = self.widget("install-os-version")
os_variant_model = make_os_model()
os_variant_list.set_model(os_variant_model)
uiutil.init_combo_text_column(os_variant_list, 1)
os_variant_list.set_row_separator_func(sep_func, os_variant_list)
entry = self.widget("install-os-version-entry")
completion = Gtk.EntryCompletion()
entry.set_completion(completion)
completion.set_text_column(1)
completion.set_inline_completion(True)
completion.set_model(os_variant_model)
# Archtecture
archList = self.widget("arch")
# [label, guest.os.arch value]
archModel = Gtk.ListStore(str, str)
archList.set_model(archModel)
uiutil.init_combo_text_column(archList, 0)
archList.set_row_separator_func(
lambda m, i, ignore: m[i][0] is None, None)
# guest.os.type value for xen (hvm vs. xen)
hyperList = self.widget("xen-type")
# [label, guest.os_type value]
hyperModel = Gtk.ListStore(str, str)
hyperList.set_model(hyperModel)
uiutil.init_combo_text_column(hyperList, 0)
# guest.os.machine value
lst = self.widget("machine")
# [machine ID]
model = Gtk.ListStore(str)
lst.set_model(model)
uiutil.init_combo_text_column(lst, 0)
lst.set_row_separator_func(lambda m, i, ignore: m[i][0] is None, None)
# guest.type value for xen (qemu vs kvm)
lst = self.widget("virt-type")
# [label, guest.type value]
model = Gtk.ListStore(str, str)
lst.set_model(model)
uiutil.init_combo_text_column(lst, 0)
def _reset_state(self, urihint=None):
"""
Reset all UI state to default values. Conn specific state is
populated in _populate_conn_state
"""
self._failed_guest = None
self._guest = None
self._show_all_os_was_selected = False
self._undo_finish_cursor(self.topwin)
self.widget("create-pages").set_current_page(PAGE_NAME)
self._page_changed(None, None, PAGE_NAME)
# Name page state
self.widget("create-vm-name").set_text("")
self.widget("method-local").set_active(True)
self.widget("create-conn").set_active(-1)
activeconn = self._populate_conn_list(urihint)
self.widget("arch-expander").set_expanded(False)
if self._set_conn(activeconn) is False:
return False
# Everything from this point forward should be connection independent
# Distro/Variant
self._toggle_detect_os(self.widget("install-detect-os"))
self._populate_os_type_model()
self.widget("install-os-type").set_active(0)
def _populate_media_model(media_model, urls):
media_model.clear()
if urls is None:
return
for url in urls:
media_model.append([url])
self.widget("install-iso-entry").set_text("")
iso_model = self.widget("install-iso-combo").get_model()
_populate_media_model(iso_model, self.config.get_iso_paths())
# Install URL
self.widget("install-urlopts-entry").set_text("")
self.widget("install-url-entry").set_text("")
self.widget("install-url-options").set_expanded(False)
urlmodel = self.widget("install-url-combo").get_model()
_populate_media_model(urlmodel, self.config.get_media_urls())
self._set_distro_labels("-", "-")
# Install import
self.widget("install-import-entry").set_text("")
self.widget("kernel").set_text("")
self.widget("initrd").set_text("")
self.widget("dtb").set_text("")
# Install container app
self.widget("install-app-entry").set_text("/bin/sh")
# Install container OS
self.widget("install-oscontainer-fs").set_text("")
# Storage
self.widget("enable-storage").set_active(True)
self._addstorage.reset_state()
self._addstorage.widget("storage-create").set_active(True)
self._addstorage.widget("storage-entry").set_text("")
# Final page
self.widget("summary-customize").set_active(False)
def _set_caps_state(self):
"""
Set state that is dependent on when capsinfo changes
"""
self._populate_machine()
self.widget("arch-warning-box").hide()
# Helper state
is_local = not self.conn.is_remote()
is_storage_capable = self.conn.is_storage_capable()
can_storage = (is_local or is_storage_capable)
is_pv = (self._capsinfo.os_type == "xen")
is_container = self.conn.is_container()
can_remote_url = self.conn.get_backend().support_remote_url_install()
installable_arch = (self._capsinfo.arch in
["i686", "x86_64", "ppc64", "ppc64le", "ia64", "s390x"])
if self._capsinfo.arch == "aarch64":
try:
guest = self.conn.caps.build_virtinst_guest(self._capsinfo)
guest.set_uefi_default()
installable_arch = True
logging.debug("UEFI found for aarch64, setting it as default.")
except Exception, e:
installable_arch = False
logging.debug("Error checking for aarch64 UEFI default",
exc_info=True)
msg = _("Failed to setup UEFI for AArch64: %s\n"
"Install options are limited.") % e
self._show_arch_warning(msg)
# Install Options
method_tree = self.widget("method-tree")
method_pxe = self.widget("method-pxe")
method_local = self.widget("method-local")
method_import = self.widget("method-import")
method_container_app = self.widget("method-container-app")
method_tree.set_sensitive((is_local or can_remote_url) and
installable_arch)
method_local.set_sensitive(not is_pv and can_storage and
installable_arch)
method_pxe.set_sensitive(not is_pv and installable_arch)
method_import.set_sensitive(can_storage)
virt_methods = [method_local, method_tree, method_pxe, method_import]
pxe_tt = None
local_tt = None
tree_tt = None
import_tt = None
if not is_local:
if not can_remote_url:
tree_tt = _("Libvirt version does not "
"support remote URL installs.")
if not is_storage_capable:
local_tt = _("Connection does not support storage management.")
import_tt = local_tt
if is_pv:
base = _("%s installs not available for paravirt guests.")
pxe_tt = base % "PXE"
local_tt = base % "CDROM/ISO"
if not installable_arch:
msg = (_("Architecture '%s' is not installable") %
self._capsinfo.arch)
tree_tt = msg
local_tt = msg
pxe_tt = msg
if not any([w.get_active() and w.get_sensitive()
for w in virt_methods]):
for w in virt_methods:
if w.get_sensitive():
w.set_active(True)
break
if not (is_container or
[w for w in virt_methods if w.get_sensitive()]):
return self._show_startup_error(
_("No install methods available for this connection."),
hideinstall=False)
method_tree.set_tooltip_text(tree_tt or "")
method_local.set_tooltip_text(local_tt or "")
method_pxe.set_tooltip_text(pxe_tt or "")
method_import.set_tooltip_text(import_tt or "")
# Container install options
method_container_app.set_active(True)
self.widget("virt-install-box").set_visible(not is_container)
self.widget("container-install-box").set_visible(is_container)
show_dtb = ("arm" in self._capsinfo.arch or
"microblaze" in self._capsinfo.arch or
"ppc" in self._capsinfo.arch)
self.widget("kernel-box").set_visible(not installable_arch)
uiutil.set_grid_row_visible(self.widget("dtb"), show_dtb)
def _populate_conn_state(self):
"""
Update all state that has some dependency on the current connection
"""
self.conn.schedule_priority_tick(pollnet=True,
pollpool=True, polliface=True,
pollnodedev=True)
self.widget("install-box").show()
self.widget("create-forward").set_sensitive(True)
self._capsinfo = None
self.conn.invalidate_caps()
self._change_caps()
if not self._capsinfo.guest.has_install_options():
error = _("No hypervisor options were found for this "
"connection.")
if self.conn.is_qemu():
error += "\n\n"
error += _("This usually means that QEMU or KVM is not "
"installed on your machine, or the KVM kernel "
"modules are not loaded.")
return self._show_startup_error(error)
# A bit out of order, but populate the xen/virt/arch/machine lists
# so we can work with a default.
self._populate_xen_type()
self._populate_arch()
self._populate_virt_type()
show_arch = (self.widget("xen-type").get_visible() or
self.widget("virt-type").get_visible() or
self.widget("arch").get_visible() or
self.widget("machine").get_visible())
uiutil.set_grid_row_visible(self.widget("arch-expander"), show_arch)
if self.conn.is_xen():
has_hvm_guests = False
for g in self.conn.caps.guests:
if g.os_type == "hvm":
has_hvm_guests = True
if not has_hvm_guests:
error = _("Host is not advertising support for full "
"virtualization. Install options may be limited.")
self._show_startup_warning(error)
elif self.conn.is_qemu():
if not self._capsinfo.guest.is_kvm_available():
error = _("KVM is not available. This may mean the KVM "
"package is not installed, or the KVM kernel modules "
"are not loaded. Your virtual machines may perform poorly.")
self._show_startup_warning(error)
# Install local
iso_option = self.widget("install-iso-radio")
cdrom_option = self.widget("install-cdrom-radio")
if self._mediacombo:
self.widget("install-cdrom-align").remove(
self._mediacombo.top_box)
self._mediacombo.cleanup()
self._mediacombo = None
self._mediacombo = vmmMediaCombo(self.conn, self.builder, self.topwin,
vmmMediaCombo.MEDIA_CDROM)
self._mediacombo.combo.connect("changed", self._cdrom_changed)
self._mediacombo.reset_state()
self.widget("install-cdrom-align").add(
self._mediacombo.top_box)
# Don't select physical CDROM if no valid media is present
cdrom_option.set_active(self._mediacombo.has_media())
iso_option.set_active(not self._mediacombo.has_media())
enable_phys = not self._stable_defaults()
cdrom_option.set_sensitive(enable_phys)
cdrom_option.set_tooltip_text("" if enable_phys else
_("Physical CDROM passthrough not supported with this hypervisor"))
# Only allow ISO option for remote VM
is_local = not self.conn.is_remote()
if not is_local or not enable_phys:
iso_option.set_active(True)
self._local_media_toggled(cdrom_option)
# Memory
memory = int(self.conn.host_memory_size())
mem_label = (_("Up to %(maxmem)s available on the host") %
{'maxmem': _pretty_memory(memory)})
mem_label = ("<span size='small' color='#484848'>%s</span>" %
mem_label)
self.widget("mem").set_range(50, memory / 1024)
self.widget("phys-mem-label").set_markup(mem_label)
# CPU
phys_cpus = int(self.conn.host_active_processor_count())
cmax = phys_cpus
if cmax <= 0:
cmax = 1
cpu_label = (_("Up to %(numcpus)d available") %
{'numcpus': int(phys_cpus)})
cpu_label = ("<span size='small' color='#484848'>%s</span>" %
cpu_label)
self.widget("cpus").set_range(1, cmax)
self.widget("phys-cpu-label").set_markup(cpu_label)
# Storage
self._addstorage.conn = self.conn
self._addstorage.reset_state()
# Networking
self.widget("advanced-expander").set_expanded(False)
if self._netlist:
self.widget("netdev-ui-align").remove(self._netlist.top_box)
self._netlist.cleanup()
self._netlist = None
self._netlist = vmmNetworkList(self.conn, self.builder, self.topwin)
self.widget("netdev-ui-align").add(self._netlist.top_box)
self._netlist.connect("changed", self._netdev_changed)
self._netlist.reset_state()
def _set_conn(self, newconn):
self.widget("startup-error-box").hide()
self.widget("arch-warning-box").hide()
self.conn = newconn
if not self.conn:
return self._show_startup_error(
_("No active connection to install on."))
try:
self._populate_conn_state()
except Exception, e:
logging.exception("Error setting create wizard conn state.")
return self._show_startup_error(str(e))
def _change_caps(self, gtype=None, arch=None, domtype=None):
"""
Change the cached capsinfo for the passed values, and trigger
all needed UI refreshing
"""
if gtype is None:
# If none specified, prefer HVM so install options aren't limited
# with a default PV choice.
for g in self.conn.caps.guests:
if g.os_type == "hvm":
gtype = "hvm"
break
capsinfo = self.conn.caps.guest_lookup(os_type=gtype,
arch=arch,
typ=domtype)
if self._capsinfo:
if (self._capsinfo.guest == capsinfo.guest and
self._capsinfo.domain == capsinfo.domain):
return
self._capsinfo = capsinfo
logging.debug("Guest type set to os_type=%s, arch=%s, dom_type=%s",
self._capsinfo.os_type,
self._capsinfo.arch,
self._capsinfo.hypervisor_type)
self._set_caps_state()
##################################################
# Helpers for populating hv/arch/machine/conn UI #
##################################################
def _populate_xen_type(self):
model = self.widget("xen-type").get_model()
model.clear()
default = 0
guests = []
if self.conn.is_xen() or self.conn.is_test_conn():
guests = self.conn.caps.guests[:]
for guest in guests:
if not guest.domains:
continue
gtype = guest.os_type
dom = guest.domains[0]
domtype = dom.hypervisor_type
label = self.conn.pretty_hv(gtype, domtype)
# Don't add multiple rows for each arch
for m in model:
if m[0] == label:
label = None
break
if label is None:
continue
# Determine if this is the default given by guest_lookup
if (gtype == self._capsinfo.os_type and
domtype == self._capsinfo.hypervisor_type):
default = len(model)
model.append([label, gtype])
show = bool(len(model))
uiutil.set_grid_row_visible(self.widget("xen-type"), show)
if show:
self.widget("xen-type").set_active(default)
def _populate_arch(self):
model = self.widget("arch").get_model()
model.clear()
default = 0
archs = []
for guest in self.conn.caps.guests:
if guest.os_type == self._capsinfo.os_type:
archs.append(guest.arch)
# Combine x86/i686 to avoid confusion
if (self.conn.caps.host.cpu.arch == "x86_64" and
"x86_64" in archs and "i686" in archs):
archs.remove("i686")
archs.sort()
prios = ["x86_64", "i686", "aarch64", "armv7l", "ppc64", "ppc64le",
"s390x"]
if self.conn.caps.host.cpu.arch not in prios:
prios = []
else:
for p in prios[:]:
if p not in archs:
prios.remove(p)
else:
archs.remove(p)
if prios:
if archs:
prios += [None]
archs = prios + archs
default = 0
if self._capsinfo.arch in archs:
default = archs.index(self._capsinfo.arch)
for arch in archs:
model.append([_pretty_arch(arch), arch])
show = not (len(archs) < 2)
uiutil.set_grid_row_visible(self.widget("arch"), show)
self.widget("arch").set_active(default)
def _populate_virt_type(self):
model = self.widget("virt-type").get_model()
model.clear()
# Allow choosing between qemu and kvm for archs that traditionally
# have a decent amount of TCG usage, like armv7l. Also include
# aarch64 which can be used for arm32 VMs as well
domains = [d.hypervisor_type for d in self._capsinfo.guest.domains[:]]
if not self.conn.is_qemu():
domains = []
elif self._capsinfo.arch in ["i686", "x86_64", "ppc64", "ppc64le"]:
domains = []
default = 0
if self._capsinfo.hypervisor_type in domains:
default = domains.index(self._capsinfo.hypervisor_type)
prios = ["kvm"]
for domain in prios:
if domain not in domains:
continue
domains.remove(domain)
domains.insert(0, domain)
for domain in domains:
label = self.conn.pretty_hv(self._capsinfo.os_type, domain)
model.append([label, domain])
show = bool(len(model) > 1)
uiutil.set_grid_row_visible(self.widget("virt-type"), show)
self.widget("virt-type").set_active(default)
def _populate_machine(self):
model = self.widget("machine").get_model()
model.clear()
machines = self._capsinfo.machines[:]
if self._capsinfo.arch in ["i686", "x86_64"]:
machines = []
machines.sort()
defmachine = None
prios = []
recommended_machine = self._capsinfo.get_recommended_machine()
if recommended_machine:
defmachine = recommended_machine
prios = [defmachine]
for p in prios[:]:
if p not in machines:
prios.remove(p)
else:
machines.remove(p)
if prios:
machines = prios + [None] + machines
default = 0
if defmachine and defmachine in machines:
default = machines.index(defmachine)
for m in machines:
model.append([m])
show = (len(machines) > 1)
uiutil.set_grid_row_visible(self.widget("machine"), show)
if show:
self.widget("machine").set_active(default)
else:
self.widget("machine").emit("changed")
def _populate_conn_list(self, urihint=None):
conn_list = self.widget("create-conn")
model = conn_list.get_model()
model.clear()
default = -1
for c in self.engine.conns.values():
connobj = c["conn"]
if not connobj.is_active():
continue
if connobj.get_uri() == urihint:
default = len(model)
elif default < 0 and not connobj.is_remote():
# Favor local connections over remote connections
default = len(model)
model.append([connobj.get_uri(), connobj.get_pretty_desc()])
no_conns = (len(model) == 0)
if default < 0 and not no_conns:
default = 0
activeuri = ""
activedesc = ""
activeconn = None
if not no_conns:
conn_list.set_active(default)
activeuri, activedesc = model[default]
activeconn = self.engine.conns[activeuri]["conn"]
self.widget("create-conn-label").set_text(activedesc)
if len(model) <= 1:
self.widget("create-conn").hide()
self.widget("create-conn-label").show()
else:
self.widget("create-conn").show()
self.widget("create-conn-label").hide()
return activeconn
#############################################
# Helpers for populating OS type/variant UI #
#############################################
def _add_os_row(self, model, name="", label="", supported=False,
sep=False, action=False):
"""
Helper for building an os type/version row and adding it to
the list model if necessary
"""
visible = self._show_all_os_was_selected or supported
if sep or action:
visible = not self._show_all_os_was_selected
if not visible:
return
row = []
row.insert(OS_COL_ID, name)
row.insert(OS_COL_LABEL, label)
row.insert(OS_COL_IS_SEP, sep)
row.insert(OS_COL_IS_SHOW_ALL, action)
model.append(row)
def _populate_os_type_model(self):
widget = self.widget("install-os-type")
model = widget.get_model()
model.clear()
# Kind of a hack, just show linux + windows by default since
# that's all 98% of people care about
supportl = ["generic", "linux", "windows"]
# Move 'generic' to the front of the list
types = virtinst.OSDB.list_types()
types.remove("generic")
types.insert(0, "generic")
for typename in types:
supported = (typename in supportl)
typelabel = typename.capitalize()
if typename in ["unix"]:
typelabel = typename.upper()
self._add_os_row(model, typename, typelabel, supported)
self._add_os_row(model, sep=True)
self._add_os_row(model, label=_("Show all OS options"), action=True)
# Select 'generic' by default
widget.set_active(0)
def _populate_os_variant_model(self, _type):
widget = self.widget("install-os-version")
model = widget.get_model()
model.clear()
preferred = self.config.preferred_distros
variants = virtinst.OSDB.list_os(typename=_type, sortpref=preferred)
supportl = virtinst.OSDB.list_os(typename=_type, sortpref=preferred,
only_supported=True)
for v in variants:
supported = v in supportl or v.name == "generic"
self._add_os_row(model, v.name, v.label, supported)
self._add_os_row(model, sep=True)
self._add_os_row(model, label=_("Show all OS options"), action=True)
widget.set_active(0)
def _set_distro_labels(self, distro, ver):
self.widget("install-os-type-label").set_text(distro)
self.widget("install-os-version-label").set_text(ver)
def _set_os_id_in_ui(self, os_widget, os_id):
"""
Helper method to set the os type/version widgets to the passed
OS ID value
"""
model = os_widget.get_model()
def find_row():
for idx, row in enumerate(model):
if os_id and row[OS_COL_ID] == os_id:
os_widget.set_active(idx)
return row[OS_COL_LABEL]
os_widget.set_active(0)
label = None
if os_id:
label = find_row()
if not label and not self._show_all_os_was_selected:
# We didn't find the OS in the variant UI, but we are only
# showing the reduced OS list. Trigger the _show_all_os option,
# and try again.
os_widget.set_active(len(model) - 1)
label = find_row()
return label or _("Unknown")
def _set_distro_selection(self, variant):
"""
Update the UI with the distro that was detected from the detection
thread.
"""
if not self._is_os_detect_active():
# If the user changed the OS detect checkbox inbetween, don't
# update the UI
return
distro_type = None
distro_var = None
if variant:
osclass = virtinst.OSDB.lookup_os(variant)
distro_type = osclass.get_typename()
distro_var = osclass.name
dl = self._set_os_id_in_ui(
self.widget("install-os-type"), distro_type)
vl = self._set_os_id_in_ui(
self.widget("install-os-version"), distro_var)
self._set_distro_labels(dl, vl)
###############################
# Misc UI populating routines #
###############################
def _populate_summary_storage(self, path=None):
storagetmpl = "<span size='small' color='#484848'>%s</span>"
storagesize = ""
storagepath = ""
disk = _get_vmm_device(self._guest, "disk")
if disk:
if disk.wants_storage_creation():
storagesize = "%s" % _pretty_storage(disk.get_size())
if not path:
path = disk.path
storagepath = (storagetmpl % path)
elif len(self._guest.get_devices("filesystem")):
fs = self._guest.get_devices("filesystem")[0]
storagepath = storagetmpl % fs.source
elif self._guest.os.is_container():
storagepath = _("Host filesystem")
else:
storagepath = _("None")
self.widget("summary-storage").set_markup(storagesize)
self.widget("summary-storage").set_visible(bool(storagesize))
self.widget("summary-storage-path").set_markup(storagepath)
def _populate_summary(self):
distro, version, ignore1, dlabel, vlabel = self._get_config_os_info()
mem = _pretty_memory(int(self._guest.memory))
cpu = str(int(self._guest.vcpus))
instmethod = self._get_config_install_page()
install = ""
if instmethod == INSTALL_PAGE_ISO:
install = _("Local CDROM/ISO")
elif instmethod == INSTALL_PAGE_URL:
install = _("URL Install Tree")
elif instmethod == INSTALL_PAGE_PXE:
install = _("PXE Install")
elif instmethod == INSTALL_PAGE_IMPORT:
install = _("Import existing OS image")
elif instmethod == INSTALL_PAGE_CONTAINER_APP:
install = _("Application container")
elif instmethod == INSTALL_PAGE_CONTAINER_OS:
install = _("Operating system container")
osstr = ""
have_os = True
if self._guest.os.is_container():
osstr = _("Linux")
elif not distro:
osstr = _("Generic")
have_os = False
elif not version:
osstr = _("Generic") + " " + dlabel
have_os = False
else:
osstr = vlabel
self.widget("finish-warn-os").set_visible(not have_os)
self.widget("summary-os").set_text(osstr)
self.widget("summary-install").set_text(install)
self.widget("summary-mem").set_text(mem)
self.widget("summary-cpu").set_text(cpu)
self._populate_summary_storage()
self._netdev_changed(None)
################################
# UI state getters and helpers #
################################
def _get_config_name(self):
return self.widget("create-vm-name").get_text()
def _get_config_machine(self):
return uiutil.get_list_selection(self.widget("machine"),
check_visible=True)
def _get_config_install_page(self):
if self.widget("virt-install-box").get_visible():
if self.widget("method-local").get_active():
return INSTALL_PAGE_ISO
elif self.widget("method-tree").get_active():
return INSTALL_PAGE_URL
elif self.widget("method-pxe").get_active():
return INSTALL_PAGE_PXE
elif self.widget("method-import").get_active():
return INSTALL_PAGE_IMPORT
else:
if self.widget("method-container-app").get_active():
return INSTALL_PAGE_CONTAINER_APP
if self.widget("method-container-os").get_active():
return INSTALL_PAGE_CONTAINER_OS
def _is_container_install(self):
return self._get_config_install_page() in [INSTALL_PAGE_CONTAINER_APP,
INSTALL_PAGE_CONTAINER_OS]
def _should_skip_disk_page(self):
return self._get_config_install_page() in [INSTALL_PAGE_IMPORT,
INSTALL_PAGE_CONTAINER_APP,
INSTALL_PAGE_CONTAINER_OS]
def _get_config_os_info(self):
drow = uiutil.get_list_selected_row(self.widget("install-os-type"))
vrow = uiutil.get_list_selected_row(self.widget("install-os-version"))
distro = None
dlabel = None
variant = None
variant_found = False
vlabel = self.widget("install-os-version-entry").get_text()
for row in self.widget("install-os-version").get_model():
if (not row[OS_COL_IS_SEP] and
not row[OS_COL_IS_SHOW_ALL] and
row[OS_COL_LABEL] == vlabel):
variant = row[OS_COL_ID]
variant_found = True
break
if vlabel and not variant_found:
return (None, None, False, None, None)
if drow:
distro = drow[OS_COL_ID]
dlabel = drow[OS_COL_LABEL]
if vrow:
variant = vrow[OS_COL_ID]
vlabel = vrow[OS_COL_LABEL]
return (distro and str(distro),
variant and str(variant),
True,
str(dlabel), str(vlabel))
def _get_config_local_media(self, store_media=False):
if self.widget("install-cdrom-radio").get_active():
return self._mediacombo.get_path()
else:
ret = self.widget("install-iso-entry").get_text()
if ret and store_media:
self.config.add_iso_path(ret)
return ret
def _get_config_detectable_media(self):
instpage = self._get_config_install_page()
media = ""
if instpage == INSTALL_PAGE_ISO:
media = self._get_config_local_media()
elif instpage == INSTALL_PAGE_URL:
media = self.widget("install-url-entry").get_text()
elif instpage == INSTALL_PAGE_IMPORT:
media = self.widget("install-import-entry").get_text()
return media
def _get_config_url_info(self, store_media=False):
media = self.widget("install-url-entry").get_text().strip()
extra = self.widget("install-urlopts-entry").get_text().strip()
if media and store_media:
self.config.add_media_url(media)
return (media.strip(), extra.strip())
def _get_config_import_path(self):
return self.widget("install-import-entry").get_text()
def _is_default_storage(self):
return (self._addstorage.is_default_storage() and
not self._should_skip_disk_page())
def _is_os_detect_active(self):
return self.widget("install-detect-os").get_active()
################
# UI Listeners #
################
def _close_requested(self, *ignore1, **ignore2):
"""
When user tries to close the dialog, check for any disks that
we should auto cleanup
"""
if (self._failed_guest and
self._failed_guest.get_created_disks()):
def _cleanup_disks(asyncjob):
meter = asyncjob.get_meter()
self._failed_guest.cleanup_created_disks(meter)
def _cleanup_disks_finished(error, details):
if error:
logging.debug("Error cleaning up disk images:"
"\nerror=%s\ndetails=%s", error, details)
self.idle_add(self._close)
progWin = vmmAsyncJob(
_cleanup_disks, [],
_cleanup_disks_finished, [],
_("Removing disk images"),
_("Removing disk images we created for this virtual machine."),
self.topwin)
progWin.run()
else:
self._close()
return 1
# Intro page listeners
def _conn_changed(self, src):
uri = uiutil.get_list_selection(src)
newconn = None
if uri:
newconn = self.engine.conns[uri]["conn"]
# If we aren't visible, let reset_state handle this for us, which
# has a better chance of reporting error
if not self.is_visible():
return
if self.conn is not newconn:
self._set_conn(newconn)
def _method_changed(self, src):
ignore = src
# Reset the page number, since the total page numbers depend
# on the chosen install method
self._set_page_num_text(0)
def _machine_changed(self, ignore):
machine = self._get_config_machine()
show_dtb_virtio = (self._capsinfo.arch == "armv7l" and
machine in ["vexpress-a9", "vexpress-15"])
uiutil.set_grid_row_visible(
self.widget("dtb-warn-virtio"), show_dtb_virtio)
def _xen_type_changed(self, ignore):
os_type = uiutil.get_list_selection(self.widget("xen-type"), column=1)
if not os_type:
return
self._change_caps(os_type)
self._populate_arch()
def _arch_changed(self, ignore):
arch = uiutil.get_list_selection(self.widget("arch"), column=1)
if not arch:
return
self._change_caps(self._capsinfo.os_type, arch)
self._populate_virt_type()
def _virt_type_changed(self, ignore):
domtype = uiutil.get_list_selection(self.widget("virt-type"), column=1)
if not domtype:
return
self._change_caps(self._capsinfo.os_type, self._capsinfo.arch, domtype)
# Install page listeners
def _detectable_media_widget_changed(self, widget, checkfocus=True):
self._os_already_detected_for_media = False
# If the text entry widget has focus, don't fire detect_media_os,
# it means the user is probably typing. It will be detected
# when the user activates the widget, or we try to switch pages
if (checkfocus and
hasattr(widget, "get_text") and widget.has_focus()):
return
self._start_detect_os_if_needed()
def _url_changed(self, src):
self._detectable_media_widget_changed(src)
def _url_activated(self, src):
self._detectable_media_widget_changed(src, checkfocus=False)
def _iso_changed(self, src):
self._detectable_media_widget_changed(src)
def _iso_activated(self, src):
self._detectable_media_widget_changed(src, checkfocus=False)
def _cdrom_changed(self, src):
self._detectable_media_widget_changed(src)
def _toggle_detect_os(self, src):
dodetect = src.get_active()
self.widget("install-os-type-label").set_visible(dodetect)
self.widget("install-os-version-label").set_visible(dodetect)
self.widget("install-os-type").set_visible(not dodetect)
self.widget("install-os-version").set_visible(not dodetect)
if dodetect:
self.widget("install-os-version-entry").set_text("")
self._os_already_detected_for_media = False
self._start_detect_os_if_needed()
def _selected_os_row(self):
return uiutil.get_list_selected_row(self.widget("install-os-type"))
def _change_os_type(self, box):
ignore = box
row = self._selected_os_row()
if not row:
return
_type = row[OS_COL_ID]
self._populate_os_variant_model(_type)
if not row[OS_COL_IS_SHOW_ALL]:
return
self._show_all_os_was_selected = True
self._populate_os_type_model()
def _change_os_version(self, box):
show_all = uiutil.get_list_selection(box,
column=OS_COL_IS_SHOW_ALL, check_entry=False)
if not show_all:
return
# 'show all OS' was clicked
# Get previous type to reselect it later
type_row = self._selected_os_row()
if not type_row:
return
old_type = type_row[OS_COL_ID]
self._show_all_os_was_selected = True
self._populate_os_type_model()
# Reselect previous type row
os_type_list = self.widget("install-os-type")
os_type_model = os_type_list.get_model()
for idx, row in enumerate(os_type_model):
if row[OS_COL_ID] == old_type:
os_type_list.set_active(idx)
break
def _local_media_toggled(self, src):
usecdrom = src.get_active()
self.widget("install-cdrom-align").set_sensitive(usecdrom)
self.widget("install-iso-combo").set_sensitive(not usecdrom)
self.widget("install-iso-browse").set_sensitive(not usecdrom)
if usecdrom:
self._cdrom_changed(self._mediacombo.combo)
else:
self._iso_changed(self.widget("install-iso-entry"))
def _os_detect_visibility_changed(self, src, ignore=None):
is_visible = src.get_visible()
detect_chkbox = self.widget("install-detect-os")
nodetect_label = self.widget("install-nodetect-label")
detect_chkbox.set_active(is_visible)
detect_chkbox.toggled()
if is_visible:
nodetect_label.hide()
else:
nodetect_label.show()
def _browse_oscontainer(self, ignore):
self._browse_file("install-oscontainer-fs", is_dir=True)
def _browse_app(self, ignore):
self._browse_file("install-app-entry")
def _browse_import(self, ignore):
self._browse_file("install-import-entry")
def _browse_iso(self, ignore):
def set_path(ignore, path):
self.widget("install-iso-entry").set_text(path)
self._browse_file(None, cb=set_path, is_media=True)
def _browse_kernel(self, ignore):
self._browse_file("kernel")
def _browse_initrd(self, ignore):
self._browse_file("initrd")
def _browse_dtb(self, ignore):
self._browse_file("dtb")
# Storage page listeners
def _toggle_enable_storage(self, src):
self.widget("storage-align").set_sensitive(src.get_active())
# Summary page listeners
def _name_changed(self, src):
newname = src.get_text()
if not src.is_visible():
return
if not newname:
return
try:
path, ignore = self._get_storage_path(newname, do_log=False)
self._populate_summary_storage(path=path)
except:
logging.debug("Error generating storage path on name change "
"for name=%s", newname, exc_info=True)
def _netdev_changed(self, ignore):
row = self._netlist.get_network_row()
pxe_install = (self._get_config_install_page() == INSTALL_PAGE_PXE)
ntype = row[0]
connkey = row[6]
expand = (ntype != "network" and ntype != "bridge")
no_network = ntype is None
if (no_network or ntype == virtinst.VirtualNetworkInterface.TYPE_USER):
can_pxe = False
elif ntype != virtinst.VirtualNetworkInterface.TYPE_VIRTUAL:
can_pxe = True
else:
can_pxe = self.conn.get_net(connkey).can_pxe()
if expand:
self.widget("advanced-expander").set_expanded(True)
self.widget("netdev-warn-box").set_visible(False)
def _show_netdev_warn(msg):
self.widget("advanced-expander").set_expanded(True)
self.widget("netdev-warn-box").set_visible(True)
self.widget("netdev-warn-label").set_markup(
"<small>%s</small>" % msg)
if no_network:
_show_netdev_warn(_("No network selected"))
elif not can_pxe and pxe_install:
_show_netdev_warn(_("Network selection does not support PXE"))
########################
# Misc helper routines #
########################
def _stable_defaults(self):
emu = None
if self._guest:
emu = self._guest.emulator
elif self._capsinfo:
emu = self._capsinfo.emulator
ret = self.conn.stable_defaults(emu)
return ret
def _browse_file(self, cbwidget, cb=None, is_media=False, is_dir=False):
if is_media:
reason = self.config.CONFIG_DIR_ISO_MEDIA
elif is_dir:
reason = self.config.CONFIG_DIR_FS
else:
reason = self.config.CONFIG_DIR_IMAGE
if cb:
callback = cb
else:
def callback(ignore, text):
widget = cbwidget
if type(cbwidget) is str:
widget = self.widget(cbwidget)
widget.set_text(text)
if self._storage_browser and self._storage_browser.conn != self.conn:
self._storage_browser.cleanup()
self._storage_browser = None
if self._storage_browser is None:
self._storage_browser = vmmStorageBrowser(self.conn)
self._storage_browser.set_stable_defaults(self._stable_defaults())
self._storage_browser.set_vm_name(self._get_config_name())
self._storage_browser.set_finish_cb(callback)
self._storage_browser.set_browse_reason(reason)
self._storage_browser.show(self.topwin)
######################
# Navigation methods #
######################
def _set_page_num_text(self, cur):
"""
Set the 'page 1 of 4' style text in the wizard header
"""
cur += 1
final = PAGE_FINISH + 1
if self._should_skip_disk_page():
final -= 1
cur = min(cur, final)
page_lbl = ("<span color='#59B0E2'>%s</span>" %
_("Step %(current_page)d of %(max_page)d") %
{'current_page': cur, 'max_page': final})
self.widget("header-pagenum").set_markup(page_lbl)
def _set_install_page(self):
instnotebook = self.widget("install-method-pages")
detectbox = self.widget("install-detect-os-box")
osbox = self.widget("install-os-distro-box")
instpage = self._get_config_install_page()
# Setting OS value for a container guest doesn't really matter
# at the moment
iscontainer = instpage in [INSTALL_PAGE_CONTAINER_APP,
INSTALL_PAGE_CONTAINER_OS]
osbox.set_visible(iscontainer)
enabledetect = (instpage == INSTALL_PAGE_ISO and
self.conn and
not self.conn.is_remote() or
self._get_config_install_page() == INSTALL_PAGE_URL)
detectbox.set_visible(enabledetect)
if instpage == INSTALL_PAGE_PXE:
# Hide the install notebook for pxe, since there isn't anything
# to ask for
instnotebook.hide()
else:
instnotebook.show()
instnotebook.set_current_page(instpage)
def _back_clicked(self, src_ignore):
notebook = self.widget("create-pages")
curpage = notebook.get_current_page()
next_page = curpage - 1
if curpage == PAGE_FINISH and self._should_skip_disk_page():
# Skip over storage page
next_page -= 1
notebook.set_current_page(next_page)
def _get_next_pagenum(self, curpage):
next_page = curpage + 1
if next_page == PAGE_STORAGE and self._should_skip_disk_page():
# Skip storage page for import installs
next_page += 1
return next_page
def _forward_clicked(self, src_ignore=None):
notebook = self.widget("create-pages")
curpage = notebook.get_current_page()
if curpage == PAGE_INSTALL:
# Make sure we have detected the OS before validating the page
did_start = self._start_detect_os_if_needed(
forward_after_finish=True)
if did_start:
return
if self._validate(curpage) is not True:
return
if curpage == PAGE_NAME:
self._set_install_page()
next_page = self._get_next_pagenum(curpage)
self.widget("create-forward").grab_focus()
notebook.set_current_page(next_page)
def _page_changed(self, ignore1, ignore2, pagenum):
if pagenum == PAGE_INSTALL:
self.widget("install-os-distro-box").set_visible(
not self._is_container_install())
# Kick off distro detection when we switch to the install
# page, to detect the default selected media
self._start_detect_os_if_needed(check_install_page=False)
elif pagenum == PAGE_FINISH:
try:
self._populate_summary()
except Exception, e:
self.err.show_err(_("Error populating summary page: %s") %
str(e))
return
self.widget("create-finish").grab_focus()
self._set_page_num_text(pagenum)
self.widget("create-back").set_sensitive(pagenum != PAGE_NAME)
self.widget("create-forward").set_visible(pagenum != PAGE_FINISH)
self.widget("create-finish").set_visible(pagenum == PAGE_FINISH)
# Hide all other pages, so the dialog isn't all stretched out
# because of one large page.
for nr in range(self.widget("create-pages").get_n_pages()):
page = self.widget("create-pages").get_nth_page(nr)
page.set_visible(nr == pagenum)
############################
# Page validation routines #
############################
def _build_guest(self, variant):
guest = self.conn.caps.build_virtinst_guest(self._capsinfo)
guest.os.machine = self._get_config_machine()
# Generate UUID (makes customize dialog happy)
try:
guest.uuid = util.randomUUID(guest.conn)
except Exception, e:
self.err.show_err(_("Error setting UUID: %s") % str(e))
return None
# OS distro/variant validation
try:
if variant:
guest.os_variant = variant
except ValueError, e:
self.err.val_err(_("Error setting OS information."), str(e))
return None
if guest.os.is_arm64():
try:
guest.set_uefi_default()
except:
# If this errors we will have already informed the user
# on page 1.
pass
# Set up default devices
try:
guest.default_graphics_type = self.config.get_graphics_type()
guest.skip_default_sound = not self.config.get_new_vm_sound()
guest.skip_default_usbredir = (
self.config.get_add_spice_usbredir() == "no")
guest.x86_cpu_default = self.config.get_default_cpu_setting(
for_cpu=True)
guest.add_default_devices()
except Exception, e:
self.err.show_err(_("Error setting up default devices:") + str(e))
return None
return guest
def _validate(self, pagenum):
try:
if pagenum == PAGE_NAME:
return self._validate_intro_page()
elif pagenum == PAGE_INSTALL:
return self._validate_install_page()
elif pagenum == PAGE_MEM:
return self._validate_mem_page()
elif pagenum == PAGE_STORAGE:
return self._validate_storage_page()
elif pagenum == PAGE_FINISH:
return self._validate_final_page()
except Exception, e:
self.err.show_err(_("Uncaught error validating install "
"parameters: %s") % str(e))
return
def _validate_intro_page(self):
# We just set this here because it's needed soon after for distro
# detection. But the 'real' self._guest is created in validate_install,
# and it just uses _build_guest, so don't ever add any other guest
# altering here.
self._guest = self._build_guest(None)
if not self._guest:
return False
return True
def _generate_default_name(self, distro, variant):
force_num = False
if self._guest.os.is_container():
basename = "container"
force_num = True
elif not distro:
basename = "vm"
force_num = True
elif not variant:
basename = distro
else:
basename = variant
if self._guest.os.arch != self.conn.caps.host.cpu.arch:
basename += "-%s" % _pretty_arch(self._guest.os.arch)
force_num = False
return util.generate_name(basename,
self.conn.get_backend().lookupByName,
start_num=force_num and 1 or 2, force_num=force_num,
sep=not force_num and "-" or "",
collidelist=[vm.get_name() for vm in self.conn.list_vms()])
def _validate_install_page(self):
instmethod = self._get_config_install_page()
installer = None
location = None
extra = None
cdrom = False
is_import = False
init = None
fs = None
distro, variant, valid, ignore1, ignore2 = self._get_config_os_info()
if not valid:
return self.err.val_err(_("Please specify a valid OS variant."))
if instmethod == INSTALL_PAGE_ISO:
instclass = virtinst.DistroInstaller
media = self._get_config_local_media()
if not media:
return self.err.val_err(
_("An install media selection is required."))
location = media
cdrom = True
elif instmethod == INSTALL_PAGE_URL:
instclass = virtinst.DistroInstaller
media, extra = self._get_config_url_info()
if not media:
return self.err.val_err(_("An install tree is required."))
location = media
elif instmethod == INSTALL_PAGE_PXE:
instclass = virtinst.PXEInstaller
elif instmethod == INSTALL_PAGE_IMPORT:
instclass = virtinst.ImportInstaller
is_import = True
import_path = self._get_config_import_path()
if not import_path:
return self.err.val_err(
_("A storage path to import is required."))
elif instmethod == INSTALL_PAGE_CONTAINER_APP:
instclass = virtinst.ContainerInstaller
init = self.widget("install-app-entry").get_text()
if not init:
return self.err.val_err(_("An application path is required."))
elif instmethod == INSTALL_PAGE_CONTAINER_OS:
instclass = virtinst.ContainerInstaller
fs = self.widget("install-oscontainer-fs").get_text()
if not fs:
return self.err.val_err(_("An OS directory path is required."))
# Build the installer and Guest instance
try:
# Overwrite the guest
installer = instclass(self.conn.get_backend())
self._guest = self._build_guest(variant or distro)
if not self._guest:
return False
self._guest.installer = installer
except Exception, e:
return self.err.val_err(
_("Error setting installer parameters."), e)
# Validate media location
try:
if location is not None:
self._guest.installer.location = location
if cdrom:
self._guest.installer.cdrom = True
if extra:
self._guest.installer.extraargs = [extra]
if init:
self._guest.os.init = init
if fs:
fsdev = virtinst.VirtualFilesystem(self._guest.conn)
fsdev.target = "/"
fsdev.source = fs
self._guest.add_device(fsdev)
except Exception, e:
return self.err.val_err(
_("Error setting install media location."), e)
# Setting kernel
if instmethod == INSTALL_PAGE_IMPORT:
kernel = self.widget("kernel").get_text() or None
kargs = self.widget("kernel-args").get_text() or None
initrd = self.widget("initrd").get_text() or None
dtb = self.widget("dtb").get_text() or None
if not self.widget("dtb").get_visible():
dtb = None
if not self.widget("kernel").get_visible():
kernel = None
initrd = None
kargs = None
self._guest.os.kernel = kernel
self._guest.os.initrd = initrd
self._guest.os.dtb = dtb
self._guest.os.kernel_args = kargs
require_kernel = ("arm" in self._capsinfo.arch)
if require_kernel and not kernel:
return self.err.val_err(
_("A kernel is required for %s guests.") %
self._capsinfo.arch)
try:
name = self._generate_default_name(distro, variant)
self.widget("create-vm-name").set_text(name)
self._guest.name = name
except Exception, e:
return self.err.val_err(_("Error setting default name."), e)
# Kind of wonky, run storage validation now, which will assign
# the import path. Import installer skips the storage page.
if is_import:
if not self._validate_storage_page():
return False
if self._guest.installer.scratchdir_required():
path = util.make_scratchdir(self._guest.conn, self._guest.type)
elif instmethod == INSTALL_PAGE_ISO:
path = self._guest.installer.location
else:
path = None
if path:
self._addstorage.check_path_search(
self, self.conn, path)
res = None
osobj = virtinst.OSDB.lookup_os(variant)
if osobj:
res = osobj.get_recommended_resources(self._guest)
logging.debug("Recommended resources for variant=%s: %s",
variant, res)
# Change the default values suggested to the user.
ram_size = DEFAULT_MEM
if res and res.get("ram") > 0:
ram_size = res["ram"] / (1024 ** 2)
self.widget("mem").set_value(ram_size)
n_cpus = 1
if res and res.get("n-cpus") > 0:
n_cpus = res["n-cpus"]
self.widget("cpus").set_value(n_cpus)
if res and res.get("storage"):
storage_size = int(res["storage"]) / (1024 ** 3)
self._addstorage.widget("storage-size").set_value(storage_size)
# Validation passed, store the install path (if there is one) in
# gsettings
self._get_config_local_media(store_media=True)
self._get_config_url_info(store_media=True)
return True
def _validate_mem_page(self):
cpus = self.widget("cpus").get_value()
mem = self.widget("mem").get_value()
# VCPUS
try:
self._guest.vcpus = int(cpus)
except Exception, e:
return self.err.val_err(_("Error setting CPUs."), e)
# Memory
try:
self._guest.memory = int(mem) * 1024
self._guest.maxmemory = int(mem) * 1024
except Exception, e:
return self.err.val_err(_("Error setting guest memory."), e)
return True
def _get_storage_path(self, vmname, do_log):
failed_disk = None
if self._failed_guest:
failed_disk = _get_vmm_device(self._failed_guest, "disk")
path = None
path_already_created = False
if self._get_config_install_page() == INSTALL_PAGE_IMPORT:
path = self._get_config_import_path()
elif self._is_default_storage():
if failed_disk:
# Don't generate a new path if the install failed
path = failed_disk.path
path_already_created = failed_disk.storage_was_created
if do_log:
logging.debug("Reusing failed disk path=%s "
"already_created=%s", path, path_already_created)
else:
path = self._addstorage.get_default_path(vmname)
if do_log:
logging.debug("Default storage path is: %s", path)
return path, path_already_created
def _validate_storage_page(self):
path, path_already_created = self._get_storage_path(
self._guest.name, do_log=True)
disk = None
storage_enabled = self.widget("enable-storage").get_active()
try:
if storage_enabled:
disk = self._addstorage.validate_storage(self._guest.name,
path=path)
except Exception, e:
return self.err.val_err(_("Storage parameter error."), e)
if disk is False:
return False
if self._get_config_install_page() == INSTALL_PAGE_ISO:
# CD/ISO install and no disks implies LiveCD
self._guest.installer.livecd = not storage_enabled
if disk and self._addstorage.validate_disk_object(disk) is False:
return False
_remove_vmm_device(self._guest, "disk")
if not storage_enabled:
return True
disk.storage_was_created = path_already_created
_mark_vmm_device(disk)
self._guest.add_device(disk)
return True
def _validate_final_page(self):
# HV + Arch selection
name = self._get_config_name()
if name != self._guest.name:
try:
self._guest.name = name
except Exception, e:
return self.err.val_err(_("Invalid guest name"), str(e))
if self._is_default_storage():
logging.debug("User changed VM name and using default "
"storage, re-validating with new default storage path.")
# User changed the name and we are using default storage
# which depends on the VM name. Revalidate things
if not self._validate_storage_page():
return False
nettype = self._netlist.get_network_selection()[0]
if nettype is None:
# No network device available
instmethod = self._get_config_install_page()
methname = None
if instmethod == INSTALL_PAGE_PXE:
methname = "PXE"
elif instmethod == INSTALL_PAGE_URL:
methname = "URL"
if methname:
return self.err.val_err(
_("Network device required for %s install.") %
methname)
macaddr = virtinst.VirtualNetworkInterface.generate_mac(
self.conn.get_backend())
nic = self._netlist.validate_network(macaddr)
if nic is False:
return False
_remove_vmm_device(self._guest, "interface")
if nic:
_mark_vmm_device(nic)
self._guest.add_device(nic)
return True
#############################
# Distro detection handling #
#############################
def _start_detect_os_if_needed(self,
forward_after_finish=False, check_install_page=True):
"""
Will kick off the OS detection thread if all conditions are met,
like we actually have media to detect, detection isn't already
in progress, etc.
Returns True if we actually start the detection process
"""
is_install_page = (self.widget("create-pages").get_current_page() ==
PAGE_INSTALL)
media = self._get_config_detectable_media()
if self._detect_os_in_progress:
return
if check_install_page and not is_install_page:
return
if not media:
return
if not self._is_os_detect_active():
return
if self._os_already_detected_for_media:
return
self._do_start_detect_os(media, forward_after_finish)
return True
def _do_start_detect_os(self, media, forward_after_finish):
self._detect_os_in_progress = False
logging.debug("Starting OS detection thread for media=%s", media)
self.widget("create-forward").set_sensitive(False)
class ThreadResults(object):
"""
Helper object to track results from the detection thread
"""
_DETECT_FAILED = 1
_DETECT_INPROGRESS = 2
def __init__(self):
self._results = self._DETECT_INPROGRESS
def in_progress(self):
return self._results == self._DETECT_INPROGRESS
def set_failed(self):
self._results = self._DETECT_FAILED
def set_distro(self, distro):
self._results = distro
def get_distro(self):
if self._results == self._DETECT_FAILED:
return None
return self._results
thread_results = ThreadResults()
detectThread = threading.Thread(target=self._detect_thread_cb,
name="Actual media detection",
args=(media, thread_results))
detectThread.setDaemon(True)
detectThread.start()
self._report_detect_os_progress(0, thread_results,
forward_after_finish)
def _detect_thread_cb(self, media, thread_results):
"""
Thread callback that does the actual detection
"""
try:
installer = virtinst.DistroInstaller(self.conn.get_backend())
installer.location = media
distro = installer.detect_distro(self._guest)
thread_results.set_distro(distro)
except:
logging.exception("Error detecting distro.")
thread_results.set_failed()
def _report_detect_os_progress(self, idx, thread_results,
forward_after_finish):
"""
Checks detection progress via the _detect_os_results variable
and updates the UI labels, counts the number of iterations,
etc.
We set a hard time limit on the distro detection to avoid the
chance of the detection hanging (like slow URL lookup)
"""
try:
base = _("Detecting")
if (thread_results.in_progress() and
(idx < (DETECT_TIMEOUT * 2))):
# Thread is still going and we haven't hit the timeout yet,
# so update the UI labels and reschedule this function
detect_str = base + ("." * ((idx % 3) + 1))
self._set_distro_labels(detect_str, detect_str)
self.timeout_add(500, self._report_detect_os_progress,
idx + 1, thread_results, forward_after_finish)
return
distro = thread_results.get_distro()
except:
distro = None
logging.exception("Error in distro detect timeout")
logging.debug("Finished UI OS detection.")
self.widget("create-forward").set_sensitive(True)
self._os_already_detected_for_media = True
self._detect_os_in_progress = False
self._set_distro_selection(distro)
if forward_after_finish:
self.idle_add(self._forward_clicked, ())
##########################
# Guest install routines #
##########################
def _set_finish_cursor(self, topwin):
topwin.set_sensitive(False)
topwin.get_window().set_cursor(
Gdk.Cursor.new(Gdk.CursorType.WATCH))
def _undo_finish_cursor(self, topwin):
topwin.set_sensitive(True)
if not topwin.get_window():
return
topwin.get_window().set_cursor(
Gdk.Cursor.new(Gdk.CursorType.TOP_LEFT_ARROW))
def _finish_clicked(self, src_ignore):
# Validate the final page
page = self.widget("create-pages").get_current_page()
if self._validate(page) is not True:
return False
logging.debug("Starting create finish() sequence")
guest = self._guest
# Start the install
self._failed_guest = None
self._set_finish_cursor(self.topwin)
if not self.widget("summary-customize").get_active():
self._start_install(guest)
return
logging.debug("User requested 'customize', launching dialog")
try:
self._show_customize_dialog(guest)
except Exception, e:
self._undo_finish_cursor(self.topwin)
self.err.show_err(_("Error starting installation: ") + str(e))
return
def _cleanup_customize_window(self):
if not self._customize_window:
return
# We can re-enter this: cleanup() -> close() -> "details-closed"
window = self._customize_window
self._customize_window = None
window.cleanup()
def _show_customize_dialog(self, guest):
virtinst_guest = vmmDomainVirtinst(self.conn, guest, self._guest.uuid)
def start_install_wrapper(ignore, guest):
if not self.is_visible():
return
logging.debug("User finished customize dialog, starting install")
guest.update_defaults()
self._start_install(guest)
def config_canceled(ignore):
logging.debug("User closed customize window, closing wizard")
self._close_requested()
self._cleanup_customize_window()
self._customize_window = vmmDetails(virtinst_guest, self.topwin)
self._customize_window.connect(
"customize-finished", start_install_wrapper, guest)
self._customize_window.connect("details-closed", config_canceled)
self._customize_window.show()
def _install_finished_cb(self, error, details, parentobj):
self._undo_finish_cursor(parentobj.topwin)
if error:
error = (_("Unable to complete install: '%s'") % error)
parentobj.err.show_err(error, details=details)
self._failed_guest = self._guest
return
self._close()
# Launch details dialog for new VM
self.emit("action-show-domain", self.conn.get_uri(), self._guest.name)
def _start_install(self, guest):
"""
Launch the async job to start the install
"""
parentobj = self._customize_window or self
progWin = vmmAsyncJob(self._do_async_install, [guest],
self._install_finished_cb, [parentobj],
_("Creating Virtual Machine"),
_("The virtual machine is now being "
"created. Allocation of disk storage "
"and retrieval of the installation "
"images may take a few minutes to "
"complete."),
parentobj.topwin)
progWin.run()
def _do_async_install(self, asyncjob, guest):
"""
Kick off the actual install
"""
meter = asyncjob.get_meter()
# Build a list of pools we should refresh, if we are creating storage
refresh_pools = []
for disk in guest.get_devices("disk"):
if not disk.wants_storage_creation():
continue
pool = disk.get_parent_pool()
if not pool:
continue
poolname = pool.name()
if poolname not in refresh_pools:
refresh_pools.append(poolname)
logging.debug("Starting background install process")
guest.start_install(meter=meter)
logging.debug("Install completed")
# Wait for VM to show up
self.conn.schedule_priority_tick(pollvm=True)
count = 0
foundvm = None
while count < 100:
for vm in self.conn.list_vms():
if vm.get_uuid() == guest.uuid:
foundvm = vm
if foundvm:
break
count += 1
time.sleep(.1)
if not foundvm:
raise RuntimeError(
_("VM '%s' didn't show up after expected time.") % guest.name)
vm = foundvm
if vm.is_shutoff():
# Domain is already shutdown, but no error was raised.
# Probably means guest had no 'install' phase, as in
# for live cds. Try to restart the domain.
vm.startup()
elif guest.installer.has_install_phase():
# Register a status listener, which will restart the
# guest after the install has finished
def cb():
vm.connect_opt_out("state-changed",
self._check_install_status, guest)
return False
self.idle_add(cb)
# Kick off pool updates
for poolname in refresh_pools:
try:
pool = self.conn.get_pool(poolname)
self.idle_add(pool.refresh)
except:
logging.debug("Error looking up pool=%s for refresh after "
"VM creation.", poolname, exc_info=True)
def _check_install_status(self, vm, virtinst_guest):
"""
Watch the domain that we are installing, waiting for the state
to change, so we can restart it as needed
"""
if vm.is_crashed():
logging.debug("VM crashed, cancelling install plans.")
return True
if not vm.is_shutoff():
return
try:
if virtinst_guest:
continue_inst = virtinst_guest.get_continue_inst()
if continue_inst:
logging.debug("VM needs a 2 stage install, continuing.")
# Continue the install, then reconnect this opt
# out handler, removing the virtinst_guest which
# will force one final restart.
virtinst_guest.continue_install()
vm.connect_opt_out("state-changed",
self._check_install_status, None)
return True
if vm.get_install_abort():
logging.debug("User manually shutdown VM, not restarting "
"guest after install.")
return True
logging.debug("Install should be completed, starting VM.")
vm.startup()
except Exception, e:
self.err.show_err(_("Error continue install: %s") % str(e))
return True
Reference in New Issue View Git Blame Copy Permalink