Synnefo » snf-ganeti

  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

  # The proper fix would be to wait (with some limits) until the

  # connection has been made and drbd transitions from WFConnection

  # into any other network-connected state (Connected, SyncTarget,

  # SyncSource, etc.)

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

      result = rpc.call_blockdev_assemble(node, node_disk, iname, False)

                     " (is_primary=False, pass=1)" % (inst_disk.iv_name, node))

        if not ignore_secondaries:

  # FIXME: race condition on drbd migration to primary

  # 2nd pass, do only the primary node

  for inst_disk in instance.disks:

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

      if node != instance.primary_node:

        continue

      cfg.SetDiskID(node_disk, node)

      result = rpc.call_blockdev_assemble(node, node_disk, iname, True)

      if not result:

        logger.Error("could not prepare block device %s on node %s"

                     " (is_primary=True, pass=2)" % (inst_disk.iv_name, node))

        disks_ok = False

    device_info.append((instance.primary_node, inst_disk.iv_name, result))