Synnefo » snf-ganeti

  def _UnlockedDettachInstDisk(self, disk):

    """Dettach a disk from an instance.

    This function is for internal use, when the config lock is already held.

    The `_WriteConfig' function has to be called afterwards (so we can

    dettach a disk from an instance and remove it from config at once).

    @type disk: L{objects.Disk}

    @param disk: the disk object

    """

    if not isinstance(disk, objects.Disk):

      raise errors.ProgrammerError(

        "Invalid type passed to _UnlockedDettachInstDisk")

    if not disk.instance:

      raise errors.ProgrammerError("Disk %s is not attached to an instance"

                                   % disk.uuid)

    instance = self._UnlockedGetInstanceInfo(disk.instance)

    # Update disk

    disk.instance = ""

    disk.serial_no += 1

    disk.mtime = time.time()

    # Update instance

    idx = instance.disks.index(disk.uuid)

    instance.disks.remove(disk.uuid)

    inst_disks = self._UnlockedGetInstanceDisks(instance)

    self._UpdateIvNames(idx, inst_disks)

    instance.serial_no += 1

    instance.mtime = time.time()

  def _UnlockedRemoveDisk(self, disk_uuid):

    """Remove the disk from the configuration.

    This function is for internal use, when the config lock is already held.

    The `_WriteConfig' function has to be called afterwards (so we can

    remove many disks at once).

    """

    if disk_uuid not in self._config_data.disks:

      raise errors.ConfigurationError("Unknown disk '%s'" % disk_uuid)

    # Remove disk from config file

    del self._config_data.disks[disk_uuid]

    self._config_data.cluster.serial_no += 1

  @locking.ssynchronized(_config_lock)

  def RemoveInstDisk(self, disk_uuid):

    """Dettach a disk from an instance and remove it from the config.

    @type disk_uuid: string

    @param disk_uuid: the uuid of the disk we want to remove

    """

    if disk_uuid not in self._config_data.disks:

      raise errors.ConfigurationError("Unknown disk '%s'" % disk_uuid)

    disk = self._config_data.disks[disk_uuid]

    self._UnlockedDettachInstDisk(disk)

    self._UnlockedRemoveDisk(disk_uuid)

    self._WriteConfig()