Synnefo » snf-ganeti » ganeti-local

  @return: List of L{objects.BlockDevStatus}, one for each disk

def BlockdevGetmirrorstatusMulti(disks):

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

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

  @param disks: the list of disks which we should query

  @rtype: disk

  @return: List of tuples, (bool, status), one for each disk; bool denotes

    success/failure, status is L{objects.BlockDevStatus} on success, string

    otherwise

  """

  result = []

  for disk in disks:

    try:

      rbd = _RecursiveFindBD(disk)

      if rbd is None:

        result.append((False, "Can't find device %s" % disk))

        continue

      status = rbd.CombinedSyncStatus()

    except errors.BlockDeviceError, err:

      logging.exception("Error while getting disk status")

      result.append((False, str(err)))

    else:

      result.append((True, status))

  assert len(disks) == len(result)

  return result

    diskdata = [(nname, success, status, idx)

                for idx, (success, status) in enumerate(disks)]

    for nname, success, bdev_status, idx in diskdata:

      _ErrorIf(instanceconfig.admin_up and not success,

               "couldn't retrieve status for disk/%s on %s: %s",

               idx, nname, bdev_status)

      _ErrorIf((instanceconfig.admin_up and success and

                bdev_status.ldisk_status == constants.LDS_FAULTY),

      if nres.fail_msg:

        continue

      for idx, (success, status) in enumerate(nres.payload):

        if success:

          nres.payload[idx] = (success, objects.BlockDevStatus.FromDict(status))

    result = []

    for (success, status) in backend.BlockdevGetmirrorstatusMulti(disks):

      if success:

        result.append((success, status.ToDict()))

      else:

        result.append((success, status))

    return result