Synnefo » snf-ganeti

  def ExpandNames(self):

    self._ExpandAndLockInstance()

    self.needed_locks[locking.LEVEL_NODE] = []

    self.recalculate_locks[locking.LEVEL_NODE] = constants.LOCKS_REPLACE

  def DeclareLocks(self, level):

      if self.op.disk_template and self.op.remote_node:

        self.op.remote_node = _ExpandNodeName(self.cfg, self.op.remote_node)

        self.needed_locks[locking.LEVEL_NODE].append(self.op.remote_node)

  def BuildHooksEnv(self):

    """Build hooks env.

                                     (disk_op, len(instance.disks)),

                                     errors.ECODE_INVAL)

  def _ConvertPlainToDrbd(self, feedback_fn):

    """Converts an instance from plain to drbd.

    pnode = instance.primary_node

    snode = self.op.remote_node

    # create a fake disk info for _GenerateDiskTemplate

    disk_info = [{constants.IDISK_SIZE: d.size, constants.IDISK_MODE: d.mode,

                  constants.IDISK_VG: d.logical_id[0]}

    instance.disks = new_disks

    self.cfg.Update(instance, feedback_fn)

    # disks are created, waiting for sync

    disk_abort = not _WaitForSync(self, instance,

                                  oneshot=not self.op.wait_for_sync)

      raise errors.OpExecError("There are some degraded disks for"

                               " this instance, please cleanup manually")

  def _ConvertDrbdToPlain(self, feedback_fn):

    """Converts an instance from drbd to plain.

    """

    instance = self.instance

    assert len(instance.secondary_nodes) == 1

    pnode = instance.primary_node

    snode = instance.secondary_nodes[0]

    feedback_fn("Converting template to plain")

    instance.disk_template = constants.DT_PLAIN

    self.cfg.Update(instance, feedback_fn)

    feedback_fn("Removing volumes on the secondary node...")

    for disk in old_disks:

      self.cfg.SetDiskID(disk, snode)

        self.LogWarning("Could not remove metadata for disk %d on node %s,"

                        " continuing anyway: %s", idx, pnode, msg)

  def Exec(self, feedback_fn):

    """Modifies an instance.

    for warn in self.warn:

      feedback_fn("WARNING: %s" % warn)

    result = []

    instance = self.instance

    # disk changes

                       disk_dict[constants.IDISK_MODE]))

    if self.op.disk_template:

      r_shut = _ShutdownInstanceDisks(self, instance)

      if not r_shut:

        raise errors.OpExecError("Cannot shutdown instance disks, unable to"

        raise

      result.append(("disk_template", self.op.disk_template))

    # NIC changes

    for nic_op, nic_dict in self.op.nics:

      if nic_op == constants.DDM_REMOVE:

    self.cfg.Update(instance, feedback_fn)

    return result

  _DISK_CONVERSIONS = {