Synnefo » snf-ganeti

    STATUS_ONLINE: "online",

    }

  def __init__(self, unique_id, children):

    self._children = children

    self.dev_path = None

    self.major = None

    self.minor = None

  def Assemble(self):

    """Assemble the device from its components.

        child.Shutdown()

    return status

  def Attach(self):

    """Find a device which matches our config and attach to it.

    """

    raise NotImplementedError

  def Close(self):

    """Notifies that the device will no longer be used for I/O.

    """

    raise NotImplementedError

  @classmethod

  def Create(cls, unique_id, children, size):

    """Create the device.

    """

    raise NotImplementedError

  def Remove(self):

    """Remove this device.

    """

    raise NotImplementedError

  def Rename(self, new_id):

    """Rename this device.

    """

    raise NotImplementedError

  def GetStatus(self):

    """Return the status of the device.

    """

    raise NotImplementedError

  def Open(self, force=False):

    """Make the device ready for use.

    """

    raise NotImplementedError

  def Shutdown(self):

    """Shut down the device, freeing its children.

    """

    raise NotImplementedError

  def SetSyncSpeed(self, speed):

    """Adjust the sync speed of the mirror.

        result = result and child.SetSyncSpeed(speed)

    return result

  def GetSyncStatus(self):

    """Returns the sync status of the device.

        return True

    return False

  def Assemble(self):

    """Assemble the device.

    """

    return True

  def Shutdown(self):

    """Shutdown the device.

    """

    return True

  def GetStatus(self):

    """Return the status of the device.

    return retval

  def Open(self, force=False):

    """Make the device ready for I/O.

    """

    return True

  def Close(self):

    """Notifies that the device will no longer be used for I/O.

    """

    return True

  def Snapshot(self, size):

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

    return snap_name

  def SetInfo(self, text):

    """Update metadata with info text.

    self.major = 9

    self.Attach()

  def Attach(self):

    """Find an array which matches our config and attach to it.

    return (minor is not None)

  @staticmethod

  def _GetUsedDevs():

    """Compute the list of in-use MD devices.

    return used_md

  @staticmethod

  def _GetDevInfo(minor):

    """Get info about a MD device.

          retval["state"] = kv[1].split(", ")

    return retval

  @staticmethod

  def _FindUnusedMinor():

    """Compute an unused MD minor.

      raise errors.BlockDeviceError("Can't find a free MD minor")

    return i

  @classmethod

  def _FindMDByUUID(cls, uuid):

    """Find the minor of an MD array with a given UUID.

        return minor

    return None

  @staticmethod

  def _ZeroSuperblock(dev_path):

    """Zero the possible locations for an MD superblock.

      return None

    return MDRaid1(info["uuid"], children)

  def Remove(self):

    """Stub remove function for MD RAID 1 arrays.

                                    result.output)

    self._children.extend(devices)

  def RemoveChildren(self, devices):

    """Remove member(s) from the md raid1.

    for dev in orig_devs:

      self._children.remove(dev)

  def GetStatus(self):

    """Return the status of the device.

      retval = self.STATUS_ONLINE

    return retval

  def _SetFromMinor(self, minor):

    """Set our parameters based on the given minor.

    self.minor = minor

    self.dev_path = "/dev/md%d" % minor

  def Assemble(self):

    """Assemble the MD device.

      self.minor = free_minor

    return not result.failed

  def Shutdown(self):

    """Tear down the MD array.

    self.dev_path = None

    return True

  def SetSyncSpeed(self, kbytes):

    """Set the maximum sync speed for the MD array.

      f.close()

    return result

  def GetSyncStatus(self):

    """Returns the sync status of the device.

      time_est = (sync_total - sync_done) / 2 / sync_speed_k

    return sync_percent, time_est, not is_clean

  def Open(self, force=False):

    """Make the device ready for I/O.

    """

    return True

  def Close(self):

    """Notifies that the device will no longer be used for I/O.

          continue

    return data

  def _MatchesLocal(self, info):

    """Test if our local config matches with an existing device.

                           info["meta_index"] == -1)

    return retval

  def _MatchesNet(self, info):

    """Test if our network config matches with an existing device.

              info["remote_addr"] == (self._rhost, self._rport))

    return retval

  @classmethod

  def _AssembleLocal(cls, minor, backend, meta):

    """Configure the local part of a DRBD device.

      logger.Error("Can't attach local disk: %s" % result.output)

    return not result.failed

  @classmethod

  def _ShutdownLocal(cls, minor):

    """Detach from the local device.

      logger.Error("Can't detach local device: %s" % result.output)

    return not result.failed

  @staticmethod

  def _ShutdownAll(minor):

    """Deactivate the device.

      logger.Error("Can't shutdown drbd device: %s" % result.output)

    return not result.failed

  @classmethod

  def _AssembleNet(cls, minor, net_info, protocol):

    """Configure the network part of the device.

      return False

    return True

  @classmethod

  def _ShutdownNet(cls, minor):

    """Disconnect from the remote peer.

    logger.Error("Can't shutdown network: %s" % result.output)

    return not result.failed

  def Assemble(self):

    """Assemble the drbd.

    self._SetFromMinor(minor)

    return True

  def Shutdown(self):

    """Shutdown the DRBD device.

    self.dev_path = None

    return True

  def Attach(self):

    """Find a DRBD device which matches our config and attach to it.

    self._SetFromMinor(minor)

    return minor is not None

  def Open(self, force=False):

    """Make the local state primary.

      return False

    return True

  def Close(self):

    """Make the local state secondary.

      logger.Error("Can't switch drbd device to secondary: %s" % result.output)

      raise errors.BlockDeviceError("Can't switch drbd device to secondary")

  def SetSyncSpeed(self, kbytes):

    """Set the speed of the DRBD syncer.

      logger.Error("Can't change syncer rate: %s " % result.fail_reason)

    return not result.failed and children_result

  def GetSyncStatus(self):

    """Returns the sync status of the device.

    is_degraded = client_state != "Connected"

    return sync_percent, est_time, is_degraded

  def GetStatus(self):

    """Compute the status of the DRBD device

    return result

  @staticmethod

  def _ZeroDevice(device):

    """Zero a device.

      if err.errno != errno.ENOSPC:

        raise

  @classmethod

  def Create(cls, unique_id, children, size):

    """Create a new DRBD device.

    logger.Info("Done zeroing device %s" % meta.dev_path)

    return cls(unique_id, children)

  def Remove(self):

    """Stub remove for DRBD devices.