Synnefo » snf-ganeti » ganeti-local

  @classmethod

  def _VerifyFiles(cls, errorif, nodeinfo, master_node, all_nvinfo,

    """Verifies file checksums collected from all nodes.

    @param errorif: Callback for reporting errors

    @param all_nvinfo: RPC results

    """

    # Define functions determining which nodes to consider for a file

    files2nodefn = [

      (files_all, None),

      (files_mc, lambda node: (node.master_candidate or

                               node.name == master_node)),

      (files_vm, lambda node: node.vm_capable),

                        frozenset(map(operator.attrgetter("name"), filenodes)))

                       for filename in files)

    fileinfo = dict((filename, {}) for filename in nodefiles)

    ignore_nodes = set()

      # Nodes missing file

      missing_file = expected_nodes - with_file

        # All or no nodes

        errorif(missing_file and missing_file != expected_nodes,

                cls.ECLUSTERFILECHECK, None,

    constants.SSH_KNOWN_HOSTS_FILE,

    constants.CONFD_HMAC_KEY,

    constants.CLUSTER_DOMAIN_SECRET_FILE,

    ])

  if not redist:

  if cluster.modify_etc_hosts:

    files_all.add(constants.ETC_HOSTS)

    constants.RAPI_USERS_FILE,

    ])

    for hv_name in cluster.enabled_hypervisors

    for filename in hypervisor.GetHypervisor(hv_name).GetAncillaryFiles()[0])

         "Found file listed in more than one file list"

def _RedistributeAncillaryFiles(lu, additional_nodes=None, additional_vm=True):

      nodelist.remove(master_info.name)

  # Gather file lists

    _ComputeAncillaryFiles(cluster, True)

  # Never re-distribute configuration file from here

  filemap = [

    (online_nodes, files_all),

    (vm_nodes, files_vm),

    ]