Synnefo » snf-ganeti

    hvp_result = nresult.get(constants.NV_HVPARAMS, None)

    if ninfo.vm_capable and isinstance(hvp_result, list):

      for item, hv_name, hv_result in hvp_result:

        _ErrorIf(True, self.ENODEHV, node,

                 "hypervisor %s parameter verify failure (source %s): %s",

                 hv_name, item, hv_result)

  def _VerifyHVP(self, hvp_data):

    """Verifies locally the syntax of the hypervisor parameters.

    """

    for item, hv_name, hv_params in hvp_data:

      msg = ("hypervisor %s parameters syntax check (source %s): %%s" %

             (item, hv_name))

      try:

        hv_class = hypervisor.GetHypervisor(hv_name)

        utils.ForceDictType(hv_params, constants.HVS_PARAMETER_TYPES)

        hv_class.CheckParameterSyntax(hv_params)

      except errors.GenericError, err:

        self._ErrorIf(True, self.ECLUSTERCFG, None, msg % str(err))

    # Compute the set of hypervisor parameters

    hvp_data = []

    for hv_name in hypervisors:

      hvp_data.append(("cluster", hv_name, cluster.GetHVDefaults(hv_name)))

    for os_name, os_hvp in cluster.os_hvp.items():

      for hv_name, hv_params in os_hvp.items():

        if not hv_params:

          continue

        full_params = cluster.GetHVDefaults(hv_name, os_name=os_name)

        hvp_data.append(("os %s" % os_name, hv_name, full_params))

    # TODO: collapse identical parameter values in a single one

    for instance in instanceinfo.values():

      if not instance.hvparams:

        continue

      hvp_data.append(("instance %s" % instance.name, instance.hypervisor,

                       cluster.FillHV(instance)))

    # and verify them locally

    self._VerifyHVP(hvp_data)

      constants.NV_HVPARAMS: hvp_data,