Synnefo » snf-ganeti

        for t_dsk, a_dsk in zip(tmp_disks, self.disks):

          rename_to.append(t_dsk.logical_id)

          t_dsk.logical_id = (t_dsk.logical_id[0], a_dsk[constants.IDISK_ADOPT])

        result = self.rpc.call_blockdev_rename(self.pnode.uuid,

                                               zip(tmp_disks, rename_to))

        result.Raise("Failed to rename adoped LVs")

    ReleaseLocks(self, locking.LEVEL_NODE_RES)

    if iobj.disk_template != constants.DT_DISKLESS and not self.adopt_disks:

      if self.op.mode == constants.INSTANCE_CREATE:

        if not self.op.no_install:

          pause_sync = (iobj.disk_template in constants.DTS_INT_MIRROR and

    info = GetInstanceInfoText(renamed_inst)

    for (idx, disk) in enumerate(renamed_inst.disks):

      for node_uuid in renamed_inst.all_nodes:

        result = self.rpc.call_blockdev_setinfo(node_uuid,

                                                (disk, renamed_inst), info)

        result.Warn("Error setting info on node %s for disk %s" %

    except errors.GenericError, e:

      feedback_fn("Initializing of DRBD devices failed;"

                  " renaming back original volumes...")

      rename_back_list = [(n.children[0], o.logical_id)

                          for (n, o) in zip(new_disks, self.instance.disks)]

      result = self.rpc.call_blockdev_rename(pnode_uuid, rename_back_list)

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

    for disk in old_disks:

      result = self.rpc.call_blockdev_remove(snode_uuid, (disk, self.instance))

      result.Warn("Could not remove block device %s on node %s,"

                  " continuing anyway" %

    feedback_fn("Removing unneeded volumes on the primary node...")

    for idx, disk in enumerate(old_disks):

      meta = disk.children[1]

      result = self.rpc.call_blockdev_remove(pnode_uuid, (meta, self.instance))

      result.Warn("Could not remove metadata for disk %d on node %s,"

                  " continuing anyway" %

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

    for node_uuid, disk in anno_disk.ComputeNodeTree(

                             self.instance.primary_node):

      msg = self.rpc.call_blockdev_remove(node_uuid, (disk, self.instance)) \

              .fail_msg

      if msg: