Synnefo » snf-ganeti

    _RedistributeAncillaryFiles(self)

  """Sleep and poll for an instance's disk to sync.

  """

    return True

  if not oneshot:

    lu.proc.LogInfo("Waiting for instance %s to sync disks." % instance.name)

  node = instance.primary_node

    lu.cfg.SetDiskID(dev, node)

  # TODO: Convert to utils.Retry

    max_time = 0

    done = True

    cumul_degraded = False

    msg = rstats.fail_msg

    if msg:

      lu.LogWarning("Can't get any data from node %s: %s", node, msg)

    for i, mstat in enumerate(rstats):

      if mstat is None:

        lu.LogWarning("Can't compute data for node %s/%s",

        continue

      cumul_degraded = (cumul_degraded or

        else:

          rem_time = "no time estimate"

        lu.proc.LogInfo("- device %s: %5.2f%% done, %s" %

    # if we're done but degraded, let's do a few small retries, to

    # make sure we see a stable and not transient situation; therefore

    return disks_info

                           ignore_size=False):

  """Prepare the block devices for an instance.

  @param lu: the logical unit on whose behalf we execute

  @type instance: L{objects.Instance}

  @param instance: the instance for whose disks we assemble

  @type ignore_secondaries: boolean

  @param ignore_secondaries: if true, errors on secondary nodes

      won't result in an error return from the function

  device_info = []

  disks_ok = True

  iname = instance.name

  # With the two passes mechanism we try to reduce the window of

  # opportunity for the race condition of switching DRBD to primary

  # before handshaking occured, but we do not eliminate it

  # SyncSource, etc.)

  # 1st pass, assemble on all nodes in secondary mode

    for node, node_disk in inst_disk.ComputeNodeTree(instance.primary_node):

      if ignore_size:

        node_disk = node_disk.Copy()

  # FIXME: race condition on drbd migration to primary

  # 2nd pass, do only the primary node

    dev_path = None

    for node, node_disk in inst_disk.ComputeNodeTree(instance.primary_node):

  # leave the disks configured for the primary node

  # this is a workaround that would be fixed better by

  # improving the logical/physical id handling

    lu.cfg.SetDiskID(disk, instance.primary_node)

  return disks_ok, device_info

    _SafeShutdownInstanceDisks(self, instance)

  """Shutdown block devices of an instance.

  This function checks if an instance is running, before calling

  """

  _CheckInstanceDown(lu, instance, "cannot shutdown disks")

  """Shutdown block devices of an instance.

  This does the shutdown on all nodes of the instance.

  """

  all_result = True

    for node, top_disk in disk.ComputeNodeTree(instance.primary_node):

      lu.cfg.SetDiskID(top_disk, node)

      result = lu.rpc.call_blockdev_shutdown(node, top_disk)