Synnefo » snf-ganeti

  REQ_BGL = False

  def ExpandNames(self):

    if not isinstance(self.op.instances, list):

      raise errors.OpPrereqError("Invalid argument type 'instances'")

    changed = []

    for node, dskl in per_node_disks.items():

      result = self.rpc.call_blockdev_getsizes(node, [v[2] for v in dskl])

        self.LogWarning("Failure in blockdev_getsizes call to node"

                        " %s, ignoring", node)

        continue

    else:

      self.data = data

      if not isinstance(self.data, (tuple, list)):

        self.fail_msg = ("RPC layer error: invalid result type (%s)" %

                         type(self.data))

      elif len(data) != 2:

        self.fail_msg = ("RPC layer error: invalid result length (%d), "

                         "expected 2" % len(self.data))

      elif not self.data[0]:

        self.fail_msg = self._EnsureErr(self.data[1])

      else:

        # finally success

    """

    result = self._SingleNodeCall(node, "blockdev_getmirrorstatus",

                                  [dsk.ToDict() for dsk in disks])

      result.payload = [objects.BlockDevStatus.FromDict(i)

                        for i in result.payload]

    return result