Synnefo » snf-ganeti

  if constants.NV_DRBDLIST in what and vm_capable:

    try:

    except errors.BlockDeviceError, err:

      logging.warning("Can't get used minors list", exc_info=True)

      used_minors = str(err)

  if constants.NV_DRBDHELPER in what and vm_capable:

    status = True

    try:

    except errors.BlockDeviceError, err:

      logging.error("Can't get DRBD usermode helper: %s", str(err))

      status = False

  """

  try:

  except errors.BlockDeviceError, err:

    _Fail(str(err))

DEV_MAP = {

  constants.LD_LV: LogicalVolume,

  constants.LD_BLOCKDEV: PersistentBlockDevice,

  constants.LD_RBD: RADOSBlockDevice,

  constants.LD_EXT: ExtStorageDevice,

_DEVICE_READ_SIZE = 128 * 1024

  """DRBD v8.x block device.

  This implements the local host part of the DRBD device, i.e. it

      if not _CanReadDevice(children[1].dev_path):

        logging.info("drbd%s: Ignoring unreadable meta device", self._aminor)

        children = []

    self.major = self._DRBD_MAJOR

    drbd_info = DRBD8Info.CreateFromFile()

      logging.info(err)

      return [err]

    children_result.extend(self._SetMinorSyncParams(self.minor, params))

    return children_result

      logging.info("Not attached during PauseSync")

      return False

    if pause:

      cmd = self._cmd_gen.GenPauseSyncCmd(self.minor)

      - anyway, set the device parameters

    """

    self.Attach()

    if self.minor is None:

    This returns, if available, the local backing device (as a path)

    and the local and remote (ip, port) information from a string

    containing the output of the `drbdsetup show` command as returned

    This will return a dict with keys:

      - local_dev

  if drbd_helper is not None:

    try:

    except errors.BlockDeviceError, err:

      raise errors.OpPrereqError("Error while checking drbd helper"

                                 " (specify --no-drbd-storage if you are not"

      self.op.remote_node = _ExpandNodeName(self.cfg, self.op.remote_node)

      # Warning: do not remove the locking of the new secondary here

      # currently it doesn't since parallel invocations of

      # FindUnusedMinor will conflict

      self.needed_locks[locking.LEVEL_NODE] = [self.op.remote_node]

    """Get list of used DRBD minors.

    """

  @classmethod

  def DoMaintenance(cls, role):

        # pylint: disable=W0212

        # using the private method as is, pending enhancements to the DRBD

        # interface

  def Exec(self):

    """Check node status versus cluster desired state.

class TestDRBD8Runner(testutils.GanetiTestCase):

  @staticmethod

  def _has_disk(data, dname, mname):

class TestDRBD8Status(testutils.GanetiTestCase):

  def setUp(self):

    """Read in txt data"""

  def testHelper(self):

    """Test reading usermode_helper in /sys."""

    sys_drbd_helper = testutils.TestDataFilename("sys_drbd_usermode_helper.txt")

    self.failUnlessEqual(drbd_helper, "/bin/true")

  def testHelperIOErrors(self):

    temp_file = self._CreateTempFile()

    os.unlink(temp_file)

    self.failUnlessRaises(errors.BlockDeviceError,

  def testMinorNotFound(self):

    """Test not-found-minor in /proc"""

  def testConstructionWith80Data(self, mock_create_from_file):

    mock_create_from_file.return_value = self.proc80_info

    self.assertEqual(inst._show_info_cls, drbd_info.DRBD83ShowInfo)

    self.assertTrue(isinstance(inst._cmd_gen, drbd_cmdgen.DRBD83CmdGenerator))

  def testConstructionWith83Data(self, mock_create_from_file):

    mock_create_from_file.return_value = self.proc83_info

    self.assertEqual(inst._show_info_cls, drbd_info.DRBD83ShowInfo)

    self.assertTrue(isinstance(inst._cmd_gen, drbd_cmdgen.DRBD83CmdGenerator))

  def testConstructionWith84Data(self, mock_create_from_file):

    mock_create_from_file.return_value = self.proc84_info

    self.assertEqual(inst._show_info_cls, drbd_info.DRBD84ShowInfo)

    self.assertTrue(isinstance(inst._cmd_gen, drbd_cmdgen.DRBD84CmdGenerator))