Synnefo » snf-ganeti

    # If the instance's disk template is `rbd' and there was a successfull

    # migration, unmap the device from the source node.

    if self.instance.disk_template == constants.DT_RBD:

      disks = _ExpandCheckDisks(instance, instance.disks)

      self.feedback_fn("* unmapping instance's disks from %s" % source_node)

      for disk in disks:

        result = self.rpc.call_blockdev_shutdown(source_node, disk)

        msg = result.fail_msg

        if msg:

          self.LogWarning("Migration was successfull, but couldn't unmap the"

                          "block device %s on source node %s: %s",

                          disk.iv_name, source_node, msg)

          self.LogWarning("Try to unmap the device %s manually on %s",

                          disk.iv_name, source_node)

  elif template_name == constants.DT_RBD:

    if len(secondary_nodes) != 0:

      raise errors.ProgrammerError("Wrong template configuration")

    names = _GenerateUniqueNames(lu, [".rbd.disk%d" % (base_index + i)

                                      for i in range(disk_count)])

    for idx, disk in enumerate(disk_info):

      disk_index = idx + base_index

      disk_dev = objects.Disk(dev_type=constants.LD_RBD, size=disk["size"],

                              logical_id=(constants.RBD_POOL, names[idx]),

                              iv_name="disk/%d" % disk_index,

                              mode=disk["mode"])

      disks.append(disk_dev)

    constants.DT_RBD: 0,

      if self.op.disk_template == constants.DT_RBD:

        # Check if there is enough space on the RADOS cluster

        _CheckRADOSFreeSpace(self.op.instance_name, self.disks)

      else:

        # Check lv size requirements, if not adopting

        req_sizes = _ComputeDiskSizePerVG(self.op.disk_template, self.disks)

        _CheckNodesFreeDiskPerVG(self, nodenames, req_sizes)

def _CheckRADOSFreeSpace(name, disks):

  """Compute disk size requirements inside the RADOS cluster

  """

  # For the RADOS cluster we assume there is always enough space

  enough_space = True

  if not enough_space:

    raise errors.OpPrereqError("Not enough disk space inside the RADOS"

                               "cluster to allocate disks for instance: %s" %

                               (name), errors.ECODE_NORES)

                                      constants.DT_SHARED_FILE,

                                      constants.DT_RBD):