Synnefo » snf-ganeti

  def HasAnyDiskOfType(self, dev_type):

    """Check if in there is at disk of the given type in the configuration.

    @param dev_type: the type to look for

    @rtype: boolean

    @return: boolean indicating if a disk of the given type was found or not

      # To decide if we set an helper let's check if at least one instance has

      # a DRBD disk. This does not cover all the possible scenarios but it

      # gives a good approximation.

        self.cluster.drbd_usermode_helper = constants.DEFAULT_DRBD_HELPER

    if self.networks is None:

      self.networks = {}

  def CreateOnSecondary(self):

    """Test if this device needs to be created on a secondary node."""

  def AssembleOnSecondary(self):

    """Test if this device needs to be assembled on a secondary node."""

  def OpenOnSecondary(self):

    """Test if this device needs to be opened on a secondary node."""

  def StaticDevPath(self):

    """Return the device path if this device type has a static one.

        should check that it is a valid path.

    """

      return "/dev/%s/%s" % (self.logical_id[0], self.logical_id[1])

      return self.logical_id[1]

      return "/dev/%s/%s" % (self.logical_id[0], self.logical_id[1])

    return None

    -1.

    """

      return 0

    return -1

  def IsBasedOnDiskType(self, dev_type):

    """Check if the disk or its children are based on the given type.

    @param dev_type: the type to look for

    @rtype: boolean

    @return: boolean indicating if a device of the given type was found or not

    devices needs to (or can) be assembled.

    """

      result = [node_uuid]

    elif self.dev_type in constants.LDS_DRBD:

      result = [self.logical_id[0], self.logical_id[1]]

    @return: a dictionary of volume-groups and the required size

    """

      return {self.logical_id[0]: amount}

      if self.children:

        return self.children[0].ComputeGrowth(amount)

      else:

    actual algorithms from bdev.

    """

      self.size += amount

      if self.children:

        self.children[0].RecordGrow(amount)

      self.size += amount

    """Apply changes to size, spindles and mode.

    """

      if self.children:

        self.children[0].Update(size=size, mode=mode)

    else:

    """Custom str() formatter for disks.

    """

      val = "<LogicalVolume(/dev/%s/%s" % self.logical_id

    elif self.dev_type in constants.LDS_DRBD:

      node_a, node_b, port, minor_a, minor_b = self.logical_id[:5]

    result = list()

    dt_params = disk_params[disk_template]

    if disk_template == constants.DT_DRBD8:

        constants.LDP_RESYNC_RATE: dt_params[constants.DRBD_RESYNC_RATE],

        constants.LDP_BARRIERS: dt_params[constants.DRBD_DISK_BARRIERS],

        constants.LDP_NO_META_FLUSH: dt_params[constants.DRBD_META_BARRIERS],

        }))

      # data LV

        constants.LDP_STRIPES: dt_params[constants.DRBD_DATA_STRIPES],

        }))

      # metadata LV

        constants.LDP_STRIPES: dt_params[constants.DRBD_META_STRIPES],

        }))

    elif disk_template in (constants.DT_FILE, constants.DT_SHARED_FILE):

    elif disk_template == constants.DT_PLAIN:

        constants.LDP_STRIPES: dt_params[constants.LV_STRIPES],

        }))

    elif disk_template == constants.DT_BLOCK:

    elif disk_template == constants.DT_RBD:

        constants.LDP_POOL: dt_params[constants.RBD_POOL],

        }))

    elif disk_template == constants.DT_EXT:

    return result

      devs = self.disks

    for dev in devs:

        lvmap[node_uuid].append(dev.logical_id[0] + "/" + dev.logical_id[1])

      elif dev.dev_type in constants.LDS_DRBD: