Synnefo » snf-ganeti » ganeti-local

    bdev = objects.Disk.FromDict(bdev_s)

    if bdev is None:

      raise ValueError("can't unserialize data!")

  @staticmethod

  def perspective_blockdev_remove(params):

    """

    bdev_s = params[0]

    bdev = objects.Disk.FromDict(bdev_s)

  @staticmethod

  def perspective_blockdev_rename(params):

    """

    devlist = [(objects.Disk.FromDict(ds), uid) for ds, uid in params]

  @staticmethod

  def perspective_blockdev_assemble(params):

    bdev = objects.Disk.FromDict(bdev_s)

    if bdev is None:

      raise ValueError("can't unserialize data!")

  @staticmethod

  def perspective_blockdev_shutdown(params):

    bdev = objects.Disk.FromDict(bdev_s)

    if bdev is None:

      raise ValueError("can't unserialize data!")

  @staticmethod

  def perspective_blockdev_addchildren(params):

    ndevs = [objects.Disk.FromDict(disk_s) for disk_s in ndev_s]

    if bdev is None or ndevs.count(None) > 0:

      raise ValueError("can't unserialize data!")

  @staticmethod

  def perspective_blockdev_removechildren(params):

    ndevs = [objects.Disk.FromDict(disk_s) for disk_s in ndev_s]

    if bdev is None or ndevs.count(None) > 0:

      raise ValueError("can't unserialize data!")

  @staticmethod

  def perspective_blockdev_getmirrorstatus(params):

    """

    disks = [objects.Disk.FromDict(dsk_s)

            for dsk_s in params]

  @staticmethod

  def perspective_blockdev_find(params):

    """

    disk = objects.Disk.FromDict(params[0])

  @staticmethod

  def perspective_blockdev_snapshot(params):

    """

    cfbd = objects.Disk.FromDict(params[0])

  @staticmethod

  def perspective_blockdev_grow(params):

    """

    cfbd = objects.Disk.FromDict(params[0])

    amount = params[1]

  @staticmethod

  def perspective_blockdev_close(params):

    """

    disks = [objects.Disk.FromDict(cf) for cf in params[1]]

  # blockdev/drbd specific methods ----------

    """

    nodes_ip, disks, instance_name, multimaster = params

    disks = [objects.Disk.FromDict(cf) for cf in disks]

  @staticmethod

  def perspective_drbd_wait_sync(params):

    """Query detailed information about existing OSes.

    """

  @staticmethod

  def perspective_os_get(params):

  return (True, "Migration successfull")

  """Creates a block device for an instance.

  @type disk: L{objects.Disk}

  return True, physical_id

  """Remove a block device.

  @note: This is intended to be called recursively.

    result = True

  if disk.children:

    for child in disk.children:

  return result

        if children.count(None) >= mcn:

          raise

        cdev = None

      children.append(cdev)

  if as_primary or disk.AssembleOnSecondary():

  return result

  """Activate a block device for an instance.

  This is a wrapper over _RecursiveAssembleBD.

  return result

  """Shut down a block device.

  First, if the device is assembled (Attach() is successfull), then

    result = True

  if disk.children:

    for child in disk.children:

  return result

  """Extend a mirrored block device.

  @type parent_cdev: L{objects.Disk}

  return True

  """Shrink a mirrored block device.

  @type parent_cdev: L{objects.Disk}

  return True

  """Get the mirroring status of a list of devices.

  @type disks: list of L{objects.Disk}

  return bdev.FindDevice(disk.dev_type, disk.physical_id, children)

  """Check if a device is activated.

  If it is, return informations about the real device.

  return result

  """Grow a stack of block devices.

  This function is called recursively, with the childrens being the

  return True, None

  """Create a snapshot copy of a block device.

  This function is called recursively, and the snapshot is actually created

  if disk.children:

    if len(disk.children) == 1:

      # only one child, let's recurse on it

    else:

      # more than one child, choose one that matches

      for child in disk.children:

        if child.size == disk.size:

          # return implies breaking the loop

  elif disk.dev_type == constants.LD_LV:

    r_dev = _RecursiveFindBD(disk)

    if r_dev is not None:

  return True

  """Rename a list of block devices.

  @type devlist: list of tuples

  return True

  """Closes the given block devices.

  This means they will be switched to secondary mode (in case of

      (this will be represented as a LVM tag)

  @type force_open: boolean

  @param force_open: this parameter will be passes to the

      whether we run on primary or not, and it affects both

      the child assembly and the device own Open() execution

      (this will be represented as a LVM tag)

  @type force_open: boolean

  @param force_open: this parameter will be passes to the

      whether we run on primary or not, and it affects both

      the child assembly and the device own Open() execution