Skip to content
Snippets Groups Projects
Commit 6a327093 authored by Bernardo Dal Seno's avatar Bernardo Dal Seno
Browse files

Fix merge 8e09e801 that resulted in duplicated code


A fragment in LUInstanceCreate.CheckPrereq() removed in commit ba147ff8 was
reintroduced in merge 8e09e801 due to a change in df28c49b.

Signed-off-by: default avatarBernardo Dal Seno <bdalseno@google.com>
Reviewed-by: default avatarGuido Trotter <ultrotter@google.com>
parent 7db266bb
No related branches found
No related tags found
No related merge requests found
...@@ -10765,25 +10765,6 @@ class LUInstanceCreate(LogicalUnit): ...@@ -10765,25 +10765,6 @@ class LUInstanceCreate(LogicalUnit):
   
nodenames = [pnode.name] + self.secondaries nodenames = [pnode.name] + self.secondaries
   
# Verify instance specs
spindle_use = self.be_full.get(constants.BE_SPINDLE_USE, None)
ispec = {
constants.ISPEC_MEM_SIZE: self.be_full.get(constants.BE_MAXMEM, None),
constants.ISPEC_CPU_COUNT: self.be_full.get(constants.BE_VCPUS, None),
constants.ISPEC_DISK_COUNT: len(self.disks),
constants.ISPEC_DISK_SIZE: [disk["size"] for disk in self.disks],
constants.ISPEC_NIC_COUNT: len(self.nics),
constants.ISPEC_SPINDLE_USE: spindle_use,
}
group_info = self.cfg.GetNodeGroup(pnode.group)
ipolicy = ganeti.masterd.instance.CalculateGroupIPolicy(cluster, group_info)
res = _ComputeIPolicyInstanceSpecViolation(ipolicy, ispec)
if not self.op.ignore_ipolicy and res:
msg = ("Instance allocation to group %s (%s) violates policy: %s" %
(pnode.group, group_info.name, utils.CommaJoin(res)))
raise errors.OpPrereqError(msg, errors.ECODE_INVAL)
if not self.adopt_disks: if not self.adopt_disks:
if self.op.disk_template == constants.DT_RBD: if self.op.disk_template == constants.DT_RBD:
# _CheckRADOSFreeSpace() is just a placeholder. # _CheckRADOSFreeSpace() is just a placeholder.
...@@ -10884,10 +10865,9 @@ class LUInstanceCreate(LogicalUnit): ...@@ -10884,10 +10865,9 @@ class LUInstanceCreate(LogicalUnit):
ipolicy = ganeti.masterd.instance.CalculateGroupIPolicy(cluster, group_info) ipolicy = ganeti.masterd.instance.CalculateGroupIPolicy(cluster, group_info)
res = _ComputeIPolicyInstanceSpecViolation(ipolicy, ispec) res = _ComputeIPolicyInstanceSpecViolation(ipolicy, ispec)
if not self.op.ignore_ipolicy and res: if not self.op.ignore_ipolicy and res:
raise errors.OpPrereqError(("Instance allocation to group %s violates" msg = ("Instance allocation to group %s (%s) violates policy: %s" %
" policy: %s") % (pnode.group, (pnode.group, group_info.name, utils.CommaJoin(res)))
utils.CommaJoin(res)), raise errors.OpPrereqError(msg, errors.ECODE_INVAL)
errors.ECODE_INVAL)
   
_CheckHVParams(self, nodenames, self.op.hypervisor, self.op.hvparams) _CheckHVParams(self, nodenames, self.op.hypervisor, self.op.hvparams)
   
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment