Synnefo » snf-ganeti » ganeti-local

    ourselves in the post-run node list.

    """

    env = {"CLUSTER": self.op.cluster_name,

           "MASTER": self.hostname['hostname_full']}

    return env, [], [self.hostname['hostname_full']]

      node: name of the node to check

      file_list: required list of files

      local_cksum: dictionary of local files and their checksums

    """

    # compares ganeti version

    local_version = constants.PROTOCOL_VERSION

  """Check that mirrors are not degraded.

  """

  cfgw.SetDiskID(dev, node)

  result = True

    Any errors are signalled by raising errors.OpPrereqError.

    """

    node = self.cfg.GetNodeInfo(self.cfg.ExpandNodeName(self.op.node_name))

    if node is None:

      logger.Error("Error: Node '%s' is unknown." % self.op.node_name)

    master.

    """

    #TODO: do not rely on gethostname returning the FQDN

    logger.Info("setting master to %s, old master: %s" %

                (self.new_master, self.old_master))

    """Computes the list of nodes and their attributes.

    """

    instance_names = utils.NiceSort(self.cfg.GetInstanceList())

    instance_list = [self.cfg.GetInstanceInfo(iname) for iname

                     in instance_names]

  This always creates all devices.

  """

  if device.children:

    for child in device.children:

      if not _CreateBlockDevOnPrimary(cfg, node, child):

  def Exec(self, feedback_fn):

    """Gather and return data"""

    result = {}

    for instance in self.wanted_instances:

      remote_info = rpc.call_instance_info(instance.primary_node,

    """Compute and return the list of nodes.

    """

    ilist = [self.cfg.GetInstanceInfo(iname) for iname

             in self.cfg.GetInstanceList()]

    result = []