Synnefo » snf-ganeti

    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

      # and make sure the new node will not have old files around

      if not new_node.master_candidate:

        result = self.rpc.call_node_demote_from_mc(new_node.name)

        if msg:

          self.LogWarning("Node failed to demote itself from master"

                          " candidate status: %s" % msg)

          changed_mc = True

          result.append(("master_candidate", "auto-demotion due to drain"))

          rrc = self.rpc.call_node_demote_from_mc(node.name)

          if msg:

            self.LogWarning("Node failed to demote itself: %s" % msg)

        if node.offline:

        if result.offline:

          # offline nodes will be in both lists

          off_nodes.append(name)

          bad_nodes.append(name)

        else:

          if result.payload: