Synnefo » snf-ganeti

    """Create a block device.

    """

    bdev = objects.Disk.FromDict(bdev_s)

    if bdev is None:

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

  @staticmethod

  def perspective_blockdev_remove(params):

    """Assemble a block device.

    """

    bdev = objects.Disk.FromDict(bdev_s)

    if bdev is None:

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

  @staticmethod

  def perspective_blockdev_shutdown(params):

  return True

  """Creates a block device for an instance.

  Args:

  clist = []

  if disk.children:

    for child in disk.children:

      if on_primary or disk.AssembleOnSecondary():

        # we need the children open in case the device itself has to

        # be assembled

    device.SetSyncSpeed(constants.SYNC_SPEED)

    if on_primary or disk.OpenOnSecondary():

      device.Open(force=True)

  device.SetInfo(info)

    logger.Info("Can't attach to device %s in remove" % disk)

    rdev = None

  if rdev is not None:

    result = rdev.Remove()

  else:

    result = True

  if disk.children:

  return result

  """Activate a block device for an instance.

  This is run on the primary and secondary nodes for an instance.

  children = []

  if disk.children:

    for chld_disk in disk.children:

  if as_primary or disk.AssembleOnSecondary():

    r_dev = bdev.AttachOrAssemble(disk.dev_type, disk.physical_id, children)

      r_dev.Open()

    else:

      r_dev.Close()

  else:

    result = True

  return result

  """Activate a block device for an instance.

  This is a wrapper over _RecursiveAssembleBD.

    True for secondary nodes

  """

  if isinstance(result, bdev.BlockDev):

    result = result.dev_path

  return result

  """

  r_dev = _RecursiveFindBD(disk)

  if r_dev is not None:

    result = r_dev.Shutdown()

  else:

    result = True

  if disk.children:

      result = False

      continue

    try:

      dev.Rename(unique_id)

    except errors.BlockDeviceError, err:

      logger.Error("Can't rename device '%s' to '%s': %s" %

                   (dev, unique_id, err))

      rr.append(("%s/%s" % (subdir, relname), rrval, output))

    return rr

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

      cfg.SetDiskID(node_disk, node)

      is_primary = node == instance.primary_node

      if not result:

        logger.Error("could not prepare block device %s on node %s (is_pri"

                     "mary=%s)" % (inst_disk.iv_name, node, is_primary))

                               (instance.name, target_node))

  """Create a tree of block devices on the primary node.

  This always creates all devices.

  """

  if device.children:

    for child in device.children:

        return False

  cfg.SetDiskID(device, node)

  if not new_id:

    return False

  if device.physical_id is None:

  return True

  """Create a tree of block devices on a secondary node.

  If this device type has to be created on secondaries, create it and

    force = True

  if device.children:

    for child in device.children:

        return False

  if not force:

    return True

  cfg.SetDiskID(device, node)

  if not new_id:

    return False

  if device.physical_id is None:

              (device.iv_name, instance.name))

    #HARDCODE

    for secondary_node in instance.secondary_nodes:

        logger.Error("failed to create volume %s (%s) on secondary node %s!" %

                     (device.iv_name, device, secondary_node))

        return False

    #HARDCODE

      logger.Error("failed to create volume %s on primary!" %

                   device.iv_name)

      return False

    logger.Info("adding new mirror component on secondary")

    #HARDCODE

                                      _GetInstanceInfoText(instance)):

      raise errors.OpExecError("Failed to create new component on secondary"

                               " node %s" % remote_node)

    logger.Info("adding new mirror component on primary")

    #HARDCODE

                                    _GetInstanceInfoText(instance)):

      # remove secondary dev

      self.cfg.SetDiskID(new_drbd, remote_node)

      logger.Info("adding new mirror component on secondary for %s" %

                  dev.iv_name)

      #HARDCODE

                                        _GetInstanceInfoText(instance)):

        raise errors.OpExecError("Failed to create new component on"

                                 " secondary node %s\n"

      logger.Info("adding new mirror component on primary")

      #HARDCODE

                                      _GetInstanceInfoText(instance)):

        # remove secondary dev

        cfg.SetDiskID(new_drbd, remote_node)

      # _Create...OnPrimary (which forces the creation), even if we

      # are talking about the secondary node

      for new_lv in new_lvs:

                                        _GetInstanceInfoText(instance)):

          raise errors.OpExecError("Failed to create new LV named '%s' on"

                                   " node '%s'" %

      # _Create...OnPrimary (which forces the creation), even if we

      # are talking about the secondary node

      for new_lv in dev.children:

                                        _GetInstanceInfoText(instance)):

          raise errors.OpExecError("Failed to create new LV named '%s' on"

                                   " node '%s'" %

                              logical_id=(pri_node, new_node,

                                          dev.logical_id[2]),

                              children=dev.children)

                                      _GetInstanceInfoText(instance)):

        raise errors.OpExecError("Failed to create new DRBD on"

                                 " node '%s'" % new_node)

# various versions

CONFIG_VERSION = 3

RELEASE_VERSION = _autoconf.PACKAGE_VERSION

OS_API_VERSION = 5

EXPORT_VERSION = 0

# file paths

DATA_DIR = _autoconf.LOCALSTATEDIR + "/lib/ganeti"

CLUSTER_CONF_FILE = DATA_DIR + "/config.data"

SSL_CERT_FILE = DATA_DIR + "/server.pem"

WATCHER_STATEFILE = DATA_DIR + "/watcher.data"

  return c.getresult()

  """Request creation of a given block device.

  This is a single-node call.

  """

  c = Client("blockdev_create", params)

  c.connect(node)

  c.run()

  return c.getresult().get(node, False)

  """Request assembling of a given block device.

  This is a single-node call.

  """

  c = Client("blockdev_assemble", params)

  c.connect(node)

  c.run()