Commit cfefe007 authored by Guido Trotter's avatar Guido Trotter
Browse files

Check memory size before setting it

With this change when a user asks for a new memory size for an instance,
the number is checked instead of just applied. The operation fails only
if the instance would not be able to restart on its primary node, but
generates warnings should it be impossible to failover the instance or
should the computation be impossible due to nodes being unreachable.

This is a forward-port from branches/ganeti-1.2

Original-Reviewed-by: iustinp
Reviewed-by: iustinp
parent 4300c4b6
......@@ -4305,9 +4305,41 @@ class LUSetInstanceParams(LogicalUnit):
" like a valid IP address" %
self.instance = self.cfg.GetInstanceInfo(self.op.instance_name)
instance = self.instance = self.cfg.GetInstanceInfo(self.op.instance_name)
assert self.instance is not None, \
"Cannot retrieve locked instance %s" % self.op.instance_name
self.warn = []
if self.mem is not None and not self.force:
pnode = self.instance.primary_node
nodelist = [pnode]
instance_info = rpc.call_instance_info(pnode,
nodeinfo = rpc.call_node_info(nodelist, self.cfg.GetVGName())
if pnode not in nodeinfo or not isinstance(nodeinfo[pnode], dict):
# Assume the primary node is unreachable and go ahead
self.warn.append("Can't get info from primary node %s" % pnode)
if instance_info:
current_mem = instance_info['memory']
# Assume instance not running
# (there is a slight race condition here, but it's not very probable,
# and we have no other way to check)
current_mem = 0
miss_mem = self.mem - current_mem - nodeinfo[pnode]['memory_free']
if miss_mem > 0:
raise errors.OpPrereqError("This change will prevent the instance"
" from starting, due to %d MB of memory"
" missing on its primary node" % miss_mem)
for node in instance.secondary_nodes:
if node not in nodeinfo or not isinstance(nodeinfo[node], dict):
self.warn.append("Can't get info from secondary node %s" % node)
elif self.mem > nodeinfo[node]['memory_free']:
self.warn.append("Not enough memory to failover instance to secondary"
" node %s" % node)
def Exec(self, feedback_fn):
......@@ -4315,6 +4347,11 @@ class LUSetInstanceParams(LogicalUnit):
All parameters take effect only at the next restart of the instance.
# Process here the warnings from CheckPrereq, as we don't have a
# feedback_fn there.
for warn in self.warn:
feedback_fn("WARNING: %s" % warn)
result = []
instance = self.instance
if self.mem:
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment