Synnefo » snf-ganeti

                        idx, result.fail_msg)

        errs.append(result.fail_msg)

        break

      result = self.rpc.call_blockdev_export(source_node, (disk, instance),

                                             target_node, dev_path,

                                             cluster_name)

      # Operate on copies as this is still in prereq

      nics = [nic.Copy() for nic in instance.nics]

      _ApplyContainerMods("NIC", nics, self._nic_chgdesc, self.nicmod,

      # Verify that NIC names are unique and valid

      utils.ValidateDeviceNames("NIC", nics)

      self._new_nics = nics

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

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

  def _CreateNewDisk(self, idx, params, _):

    """Creates a new disk.

                         disks=[(idx, disk, 0)],

                         cleanup=new_disks)

    return (disk, [

      ("disk/%d" % idx, "add:size=%s,mode=%s" % (disk.size, disk.mode)),

      ])

    """Removes a disk.

    """

    (anno_disk,) = AnnotateDiskParams(self.instance, [root], self.cfg)

    for node, disk in anno_disk.ComputeNodeTree(self.instance.primary_node):

      self.cfg.SetDiskID(disk, node)

                       nicparams=nicparams)

    nobj.uuid = self.cfg.GenerateUniqueID(self.proc.GetECId())

      ("nic.%d" % idx,

       "add:mac=%s,ip=%s,mode=%s,link=%s,network=%s" %

       (mac, ip, private.filled[constants.NIC_MODE],

  def _ApplyNicMods(self, idx, nic, params, private):

    """Modifies a network interface.

      for (key, val) in nic.nicparams.items():

        changes.append(("nic.%s/%d" % (key, idx), val))

    return changes

  def Exec(self, feedback_fn):

    """Modifies an instance.

  ignored.

  """

  all_result = True

  disks = ExpandCheckDisks(instance, disks)

  for disk in disks:

def AssembleInstanceDisks(lu, instance, disks=None, ignore_secondaries=False,

  """Prepare the block devices for an instance.

  This sets up the block devices on all nodes.

  device_info = []

  disks_ok = True

  iname = instance.name

  disks = ExpandCheckDisks(instance, disks)

  # With the two passes mechanism we try to reduce the window of

  # into any other network-connected state (Connected, SyncTarget,

  # SyncSource, etc.)

  # 1st pass, assemble on all nodes in secondary mode

  for idx, inst_disk in enumerate(disks):

    for node, node_disk in inst_disk.ComputeNodeTree(instance.primary_node):

                      inst_disk.iv_name, node, msg)

        disks_ok = False

      else:

    device_info.append((instance.primary_node, inst_disk.iv_name, dev_path))