Synnefo » snf-ganeti

  if iname not in hyper.ListInstances(instance.hvparams):

    _Fail("Instance %s is not running", iname)

    link_name = _GetBlockDevSymlinkPath(iname, idx)

    if not os.path.islink(link_name):

      logging.warning("Instance %s is missing symlink %s for disk %d",

  """

  block_devices = []

    device = _RecursiveFindBD(disk)

    if device is None:

      raise errors.BlockDeviceError("Block device '%s' is not set up." %

  except errors.BlockDeviceError, err:

    _Fail("Block device error: %s", err, exc=True)

  except errors.HypervisorError, err:

    _Fail("Hypervisor error: %s", err, exc=True)

  except errors.HypervisorError, err:

    logging.warning("Failed to execute post-shutdown cleanup step: %s", err)

def InstanceReboot(instance, reboot_type, shutdown_timeout, reason):

    hyper.AcceptInstance(instance, info, target)

  except errors.HypervisorError, err:

    if instance.disk_template in constants.DTS_EXT_MIRROR:

    _Fail("Failed to accept instance: %s", err, exc=True)

    result["INSTANCE_%s" % attr.upper()] = str(getattr(instance, attr))

  result["HYPERVISOR"] = instance.hypervisor

  result["NIC_COUNT"] = "%d" % len(instance.nics)

  result["INSTANCE_SECONDARY_NODES"] = \

      ("%s" % " ".join(instance.secondary_nodes))

  # Disks

    real_disk = _OpenRealBD(disk)

    result["DISK_%d_PATH" % idx] = real_disk.dev_path

    result["DISK_%d_ACCESS" % idx] = disk.mode

    "admin_state",

    "nics",

    "disks",

    "disk_template",

    "disks_active",

    "network_port",

    if _with_private:

      bo["osparams_private"] = self.osparams_private.Unprivate()

      alist = bo.get(attr, None)

      if alist:

        nlist = outils.ContainerToDicts(alist)

    obj = super(Instance, cls).FromDict(val)

    obj.nics = outils.ContainerFromDicts(obj.nics, list, NIC)

    obj.disks = outils.ContainerFromDicts(obj.disks, list, Disk)

    return obj

  def UpgradeConfig(self):

    idict["osparams"] = cluster.SimpleFillOS(instance.os, instance.osparams)

    if osp is not None:

      idict["osparams"].update(osp)

    for nic in idict["nics"]:

      nic["nicparams"] = objects.FillDict(

        cluster.nicparams[constants.PP_DEFAULT],

    self.assertEqual(result["hvparams"][constants.HT_KVM], {

      constants.HV_BOOT_ORDER: "xyz",

      })

      "dev_type": constants.DT_PLAIN,

      "dynamic_params": {},

      "size": 4096,