Synnefo » snf-ganeti » ganeti-local

    # extra beparams

    self.beparams = getattr(self.op, "beparams", {})

    if self.beparams:

      if not isinstance(self.beparams, dict):

        raise errors.OpPrereqError("Invalid beparams passed: %s, expected"

                                   " dict" % (type(self.beparams), ))

      # fill the beparams dict

      utils.ForceDictType(self.beparams, constants.BES_PARAMETER_TYPES)

      self.op.beparams = self.beparams

    # extra hvparams

    self.hvparams = getattr(self.op, "hvparams", {})

    if self.hvparams:

      if not isinstance(self.hvparams, dict):

        raise errors.OpPrereqError("Invalid hvparams passed: %s, expected"

                                   " dict" % (type(self.hvparams), ))

      # check hypervisor parameter syntax (locally)

      cluster = self.cfg.GetClusterInfo()

      utils.ForceDictType(self.hvparams, constants.HVS_PARAMETER_TYPES)

      filled_hvp = cluster.FillDict(cluster.hvparams[instance.hypervisor],

                                    instance.hvparams)

      filled_hvp.update(self.hvparams)

      hv_type = hypervisor.GetHypervisor(instance.hypervisor)

      hv_type.CheckParameterSyntax(filled_hvp)

      _CheckHVParams(self, instance.all_nodes, instance.hypervisor, filled_hvp)

      self.op.hvparams = self.hvparams

    result = self.rpc.call_instance_start(node_current, instance,

                                          self.hvparams, self.beparams)