root / lib / cmdlib / instance_utils.py @ a57e502a
History | View | Annotate | Download (18.8 kB)
1 | 22b7f6f8 | Thomas Thrainer | #
|
---|---|---|---|
2 | 22b7f6f8 | Thomas Thrainer | #
|
3 | 22b7f6f8 | Thomas Thrainer | |
4 | 22b7f6f8 | Thomas Thrainer | # Copyright (C) 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013 Google Inc.
|
5 | 22b7f6f8 | Thomas Thrainer | #
|
6 | 22b7f6f8 | Thomas Thrainer | # This program is free software; you can redistribute it and/or modify
|
7 | 22b7f6f8 | Thomas Thrainer | # it under the terms of the GNU General Public License as published by
|
8 | 22b7f6f8 | Thomas Thrainer | # the Free Software Foundation; either version 2 of the License, or
|
9 | 22b7f6f8 | Thomas Thrainer | # (at your option) any later version.
|
10 | 22b7f6f8 | Thomas Thrainer | #
|
11 | 22b7f6f8 | Thomas Thrainer | # This program is distributed in the hope that it will be useful, but
|
12 | 22b7f6f8 | Thomas Thrainer | # WITHOUT ANY WARRANTY; without even the implied warranty of
|
13 | 22b7f6f8 | Thomas Thrainer | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
14 | 22b7f6f8 | Thomas Thrainer | # General Public License for more details.
|
15 | 22b7f6f8 | Thomas Thrainer | #
|
16 | 22b7f6f8 | Thomas Thrainer | # You should have received a copy of the GNU General Public License
|
17 | 22b7f6f8 | Thomas Thrainer | # along with this program; if not, write to the Free Software
|
18 | 22b7f6f8 | Thomas Thrainer | # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
19 | 22b7f6f8 | Thomas Thrainer | # 02110-1301, USA.
|
20 | 22b7f6f8 | Thomas Thrainer | |
21 | 22b7f6f8 | Thomas Thrainer | |
22 | 22b7f6f8 | Thomas Thrainer | """Utility function mainly, but not only used by instance LU's."""
|
23 | 22b7f6f8 | Thomas Thrainer | |
24 | 22b7f6f8 | Thomas Thrainer | import logging |
25 | 22b7f6f8 | Thomas Thrainer | import os |
26 | 22b7f6f8 | Thomas Thrainer | |
27 | 22b7f6f8 | Thomas Thrainer | from ganeti import constants |
28 | 22b7f6f8 | Thomas Thrainer | from ganeti import errors |
29 | 22b7f6f8 | Thomas Thrainer | from ganeti import locking |
30 | 22b7f6f8 | Thomas Thrainer | from ganeti import network |
31 | 22b7f6f8 | Thomas Thrainer | from ganeti import objects |
32 | 22b7f6f8 | Thomas Thrainer | from ganeti import pathutils |
33 | 22b7f6f8 | Thomas Thrainer | from ganeti import utils |
34 | 5eacbcae | Thomas Thrainer | from ganeti.cmdlib.common import AnnotateDiskParams, \ |
35 | 1f7c8208 | Helga Velroyen | ComputeIPolicyInstanceViolation, CheckDiskTemplateEnabled |
36 | 22b7f6f8 | Thomas Thrainer | |
37 | 22b7f6f8 | Thomas Thrainer | |
38 | 1c3231aa | Thomas Thrainer | def BuildInstanceHookEnv(name, primary_node_name, secondary_node_names, os_type, |
39 | 1c3231aa | Thomas Thrainer | status, minmem, maxmem, vcpus, nics, disk_template, |
40 | 1c3231aa | Thomas Thrainer | disks, bep, hvp, hypervisor_name, tags): |
41 | 22b7f6f8 | Thomas Thrainer | """Builds instance related env variables for hooks
|
42 | 22b7f6f8 | Thomas Thrainer |
|
43 | 22b7f6f8 | Thomas Thrainer | This builds the hook environment from individual variables.
|
44 | 22b7f6f8 | Thomas Thrainer |
|
45 | 22b7f6f8 | Thomas Thrainer | @type name: string
|
46 | 22b7f6f8 | Thomas Thrainer | @param name: the name of the instance
|
47 | 1c3231aa | Thomas Thrainer | @type primary_node_name: string
|
48 | 1c3231aa | Thomas Thrainer | @param primary_node_name: the name of the instance's primary node
|
49 | 1c3231aa | Thomas Thrainer | @type secondary_node_names: list
|
50 | 1c3231aa | Thomas Thrainer | @param secondary_node_names: list of secondary nodes as strings
|
51 | 22b7f6f8 | Thomas Thrainer | @type os_type: string
|
52 | 22b7f6f8 | Thomas Thrainer | @param os_type: the name of the instance's OS
|
53 | 22b7f6f8 | Thomas Thrainer | @type status: string
|
54 | 22b7f6f8 | Thomas Thrainer | @param status: the desired status of the instance
|
55 | 22b7f6f8 | Thomas Thrainer | @type minmem: string
|
56 | 22b7f6f8 | Thomas Thrainer | @param minmem: the minimum memory size of the instance
|
57 | 22b7f6f8 | Thomas Thrainer | @type maxmem: string
|
58 | 22b7f6f8 | Thomas Thrainer | @param maxmem: the maximum memory size of the instance
|
59 | 22b7f6f8 | Thomas Thrainer | @type vcpus: string
|
60 | 22b7f6f8 | Thomas Thrainer | @param vcpus: the count of VCPUs the instance has
|
61 | 22b7f6f8 | Thomas Thrainer | @type nics: list
|
62 | d676dbea | Sebastian Gebhard | @param nics: list of tuples (name, uuid, ip, mac, mode, link, vlan, net,
|
63 | d676dbea | Sebastian Gebhard | netinfo) representing the NICs the instance has
|
64 | 22b7f6f8 | Thomas Thrainer | @type disk_template: string
|
65 | 22b7f6f8 | Thomas Thrainer | @param disk_template: the disk template of the instance
|
66 | 22b7f6f8 | Thomas Thrainer | @type disks: list
|
67 | 22b7f6f8 | Thomas Thrainer | @param disks: list of tuples (name, uuid, size, mode)
|
68 | 22b7f6f8 | Thomas Thrainer | @type bep: dict
|
69 | 22b7f6f8 | Thomas Thrainer | @param bep: the backend parameters for the instance
|
70 | 22b7f6f8 | Thomas Thrainer | @type hvp: dict
|
71 | 22b7f6f8 | Thomas Thrainer | @param hvp: the hypervisor parameters for the instance
|
72 | 22b7f6f8 | Thomas Thrainer | @type hypervisor_name: string
|
73 | 22b7f6f8 | Thomas Thrainer | @param hypervisor_name: the hypervisor for the instance
|
74 | 22b7f6f8 | Thomas Thrainer | @type tags: list
|
75 | 22b7f6f8 | Thomas Thrainer | @param tags: list of instance tags as strings
|
76 | 22b7f6f8 | Thomas Thrainer | @rtype: dict
|
77 | 22b7f6f8 | Thomas Thrainer | @return: the hook environment for this instance
|
78 | 22b7f6f8 | Thomas Thrainer |
|
79 | 22b7f6f8 | Thomas Thrainer | """
|
80 | 22b7f6f8 | Thomas Thrainer | env = { |
81 | 22b7f6f8 | Thomas Thrainer | "OP_TARGET": name,
|
82 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_NAME": name,
|
83 | 1c3231aa | Thomas Thrainer | "INSTANCE_PRIMARY": primary_node_name,
|
84 | 1c3231aa | Thomas Thrainer | "INSTANCE_SECONDARIES": " ".join(secondary_node_names), |
85 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_OS_TYPE": os_type,
|
86 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_STATUS": status,
|
87 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_MINMEM": minmem,
|
88 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_MAXMEM": maxmem,
|
89 | 22b7f6f8 | Thomas Thrainer | # TODO(2.9) remove deprecated "memory" value
|
90 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_MEMORY": maxmem,
|
91 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_VCPUS": vcpus,
|
92 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_DISK_TEMPLATE": disk_template,
|
93 | 22b7f6f8 | Thomas Thrainer | "INSTANCE_HYPERVISOR": hypervisor_name,
|
94 | 22b7f6f8 | Thomas Thrainer | } |
95 | 22b7f6f8 | Thomas Thrainer | if nics:
|
96 | 22b7f6f8 | Thomas Thrainer | nic_count = len(nics)
|
97 | d676dbea | Sebastian Gebhard | for idx, (name, uuid, ip, mac, mode, link, vlan, net, netinfo) \
|
98 | d676dbea | Sebastian Gebhard | in enumerate(nics): |
99 | 22b7f6f8 | Thomas Thrainer | if ip is None: |
100 | 22b7f6f8 | Thomas Thrainer | ip = ""
|
101 | 8a348b15 | Christos Stavrakakis | if name:
|
102 | 8a348b15 | Christos Stavrakakis | env["INSTANCE_NIC%d_NAME" % idx] = name
|
103 | 8a348b15 | Christos Stavrakakis | env["INSTANCE_NIC%d_UUID" % idx] = uuid
|
104 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC%d_IP" % idx] = ip
|
105 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC%d_MAC" % idx] = mac
|
106 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC%d_MODE" % idx] = mode
|
107 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC%d_LINK" % idx] = link
|
108 | d676dbea | Sebastian Gebhard | env["INSTANCE_NIC%d_VLAN" % idx] = vlan
|
109 | 22b7f6f8 | Thomas Thrainer | if netinfo:
|
110 | 22b7f6f8 | Thomas Thrainer | nobj = objects.Network.FromDict(netinfo) |
111 | 22b7f6f8 | Thomas Thrainer | env.update(nobj.HooksDict("INSTANCE_NIC%d_" % idx))
|
112 | 22b7f6f8 | Thomas Thrainer | elif network:
|
113 | 22b7f6f8 | Thomas Thrainer | # FIXME: broken network reference: the instance NIC specifies a
|
114 | 22b7f6f8 | Thomas Thrainer | # network, but the relevant network entry was not in the config. This
|
115 | 22b7f6f8 | Thomas Thrainer | # should be made impossible.
|
116 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC%d_NETWORK_NAME" % idx] = net
|
117 | d676dbea | Sebastian Gebhard | if mode == constants.NIC_MODE_BRIDGED or \ |
118 | d676dbea | Sebastian Gebhard | mode == constants.NIC_MODE_OVS: |
119 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC%d_BRIDGE" % idx] = link
|
120 | 22b7f6f8 | Thomas Thrainer | else:
|
121 | 22b7f6f8 | Thomas Thrainer | nic_count = 0
|
122 | 22b7f6f8 | Thomas Thrainer | |
123 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_NIC_COUNT"] = nic_count
|
124 | 22b7f6f8 | Thomas Thrainer | |
125 | 22b7f6f8 | Thomas Thrainer | if disks:
|
126 | 22b7f6f8 | Thomas Thrainer | disk_count = len(disks)
|
127 | 8a348b15 | Christos Stavrakakis | for idx, (name, uuid, size, mode) in enumerate(disks): |
128 | 8a348b15 | Christos Stavrakakis | if name:
|
129 | 8a348b15 | Christos Stavrakakis | env["INSTANCE_DISK%d_NAME" % idx] = name
|
130 | 8a348b15 | Christos Stavrakakis | env["INSTANCE_DISK%d_UUID" % idx] = uuid
|
131 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_DISK%d_SIZE" % idx] = size
|
132 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_DISK%d_MODE" % idx] = mode
|
133 | 22b7f6f8 | Thomas Thrainer | else:
|
134 | 22b7f6f8 | Thomas Thrainer | disk_count = 0
|
135 | 22b7f6f8 | Thomas Thrainer | |
136 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_DISK_COUNT"] = disk_count
|
137 | 22b7f6f8 | Thomas Thrainer | |
138 | 22b7f6f8 | Thomas Thrainer | if not tags: |
139 | 22b7f6f8 | Thomas Thrainer | tags = [] |
140 | 22b7f6f8 | Thomas Thrainer | |
141 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_TAGS"] = " ".join(tags) |
142 | 22b7f6f8 | Thomas Thrainer | |
143 | 22b7f6f8 | Thomas Thrainer | for source, kind in [(bep, "BE"), (hvp, "HV")]: |
144 | 22b7f6f8 | Thomas Thrainer | for key, value in source.items(): |
145 | 22b7f6f8 | Thomas Thrainer | env["INSTANCE_%s_%s" % (kind, key)] = value
|
146 | 22b7f6f8 | Thomas Thrainer | |
147 | 22b7f6f8 | Thomas Thrainer | return env
|
148 | 22b7f6f8 | Thomas Thrainer | |
149 | 22b7f6f8 | Thomas Thrainer | |
150 | 5eacbcae | Thomas Thrainer | def BuildInstanceHookEnvByObject(lu, instance, override=None): |
151 | 22b7f6f8 | Thomas Thrainer | """Builds instance related env variables for hooks from an object.
|
152 | 22b7f6f8 | Thomas Thrainer |
|
153 | 22b7f6f8 | Thomas Thrainer | @type lu: L{LogicalUnit}
|
154 | 22b7f6f8 | Thomas Thrainer | @param lu: the logical unit on whose behalf we execute
|
155 | 22b7f6f8 | Thomas Thrainer | @type instance: L{objects.Instance}
|
156 | 22b7f6f8 | Thomas Thrainer | @param instance: the instance for which we should build the
|
157 | 22b7f6f8 | Thomas Thrainer | environment
|
158 | 22b7f6f8 | Thomas Thrainer | @type override: dict
|
159 | 22b7f6f8 | Thomas Thrainer | @param override: dictionary with key/values that will override
|
160 | 22b7f6f8 | Thomas Thrainer | our values
|
161 | 22b7f6f8 | Thomas Thrainer | @rtype: dict
|
162 | 22b7f6f8 | Thomas Thrainer | @return: the hook environment dictionary
|
163 | 22b7f6f8 | Thomas Thrainer |
|
164 | 22b7f6f8 | Thomas Thrainer | """
|
165 | 22b7f6f8 | Thomas Thrainer | cluster = lu.cfg.GetClusterInfo() |
166 | 22b7f6f8 | Thomas Thrainer | bep = cluster.FillBE(instance) |
167 | 22b7f6f8 | Thomas Thrainer | hvp = cluster.FillHV(instance) |
168 | 22b7f6f8 | Thomas Thrainer | args = { |
169 | 22b7f6f8 | Thomas Thrainer | "name": instance.name,
|
170 | 1c3231aa | Thomas Thrainer | "primary_node_name": lu.cfg.GetNodeName(instance.primary_node),
|
171 | 1c3231aa | Thomas Thrainer | "secondary_node_names": lu.cfg.GetNodeNames(instance.secondary_nodes),
|
172 | 22b7f6f8 | Thomas Thrainer | "os_type": instance.os,
|
173 | 22b7f6f8 | Thomas Thrainer | "status": instance.admin_state,
|
174 | 22b7f6f8 | Thomas Thrainer | "maxmem": bep[constants.BE_MAXMEM],
|
175 | 22b7f6f8 | Thomas Thrainer | "minmem": bep[constants.BE_MINMEM],
|
176 | 22b7f6f8 | Thomas Thrainer | "vcpus": bep[constants.BE_VCPUS],
|
177 | 5eacbcae | Thomas Thrainer | "nics": NICListToTuple(lu, instance.nics),
|
178 | 22b7f6f8 | Thomas Thrainer | "disk_template": instance.disk_template,
|
179 | 8a348b15 | Christos Stavrakakis | "disks": [(disk.name, disk.uuid, disk.size, disk.mode)
|
180 | 22b7f6f8 | Thomas Thrainer | for disk in instance.disks], |
181 | 22b7f6f8 | Thomas Thrainer | "bep": bep,
|
182 | 22b7f6f8 | Thomas Thrainer | "hvp": hvp,
|
183 | 22b7f6f8 | Thomas Thrainer | "hypervisor_name": instance.hypervisor,
|
184 | 22b7f6f8 | Thomas Thrainer | "tags": instance.tags,
|
185 | 22b7f6f8 | Thomas Thrainer | } |
186 | 22b7f6f8 | Thomas Thrainer | if override:
|
187 | 22b7f6f8 | Thomas Thrainer | args.update(override) |
188 | 5eacbcae | Thomas Thrainer | return BuildInstanceHookEnv(**args) # pylint: disable=W0142 |
189 | 22b7f6f8 | Thomas Thrainer | |
190 | 22b7f6f8 | Thomas Thrainer | |
191 | 5eacbcae | Thomas Thrainer | def GetClusterDomainSecret(): |
192 | 22b7f6f8 | Thomas Thrainer | """Reads the cluster domain secret.
|
193 | 22b7f6f8 | Thomas Thrainer |
|
194 | 22b7f6f8 | Thomas Thrainer | """
|
195 | 22b7f6f8 | Thomas Thrainer | return utils.ReadOneLineFile(pathutils.CLUSTER_DOMAIN_SECRET_FILE,
|
196 | 22b7f6f8 | Thomas Thrainer | strict=True)
|
197 | 22b7f6f8 | Thomas Thrainer | |
198 | 22b7f6f8 | Thomas Thrainer | |
199 | 1c3231aa | Thomas Thrainer | def CheckNodeNotDrained(lu, node_uuid): |
200 | 22b7f6f8 | Thomas Thrainer | """Ensure that a given node is not drained.
|
201 | 22b7f6f8 | Thomas Thrainer |
|
202 | 22b7f6f8 | Thomas Thrainer | @param lu: the LU on behalf of which we make the check
|
203 | 1c3231aa | Thomas Thrainer | @param node_uuid: the node to check
|
204 | 22b7f6f8 | Thomas Thrainer | @raise errors.OpPrereqError: if the node is drained
|
205 | 22b7f6f8 | Thomas Thrainer |
|
206 | 22b7f6f8 | Thomas Thrainer | """
|
207 | c214896c | Thomas Thrainer | node = lu.cfg.GetNodeInfo(node_uuid) |
208 | c214896c | Thomas Thrainer | if node.drained:
|
209 | c214896c | Thomas Thrainer | raise errors.OpPrereqError("Can't use drained node %s" % node.name, |
210 | 22b7f6f8 | Thomas Thrainer | errors.ECODE_STATE) |
211 | 22b7f6f8 | Thomas Thrainer | |
212 | 22b7f6f8 | Thomas Thrainer | |
213 | 1c3231aa | Thomas Thrainer | def CheckNodeVmCapable(lu, node_uuid): |
214 | 763ad5be | Thomas Thrainer | """Ensure that a given node is vm capable.
|
215 | 22b7f6f8 | Thomas Thrainer |
|
216 | 763ad5be | Thomas Thrainer | @param lu: the LU on behalf of which we make the check
|
217 | 1c3231aa | Thomas Thrainer | @param node_uuid: the node to check
|
218 | 763ad5be | Thomas Thrainer | @raise errors.OpPrereqError: if the node is not vm capable
|
219 | 22b7f6f8 | Thomas Thrainer |
|
220 | 22b7f6f8 | Thomas Thrainer | """
|
221 | 1c3231aa | Thomas Thrainer | if not lu.cfg.GetNodeInfo(node_uuid).vm_capable: |
222 | 1c3231aa | Thomas Thrainer | raise errors.OpPrereqError("Can't use non-vm_capable node %s" % node_uuid, |
223 | 763ad5be | Thomas Thrainer | errors.ECODE_STATE) |
224 | 22b7f6f8 | Thomas Thrainer | |
225 | 22b7f6f8 | Thomas Thrainer | |
226 | 5eacbcae | Thomas Thrainer | def RemoveInstance(lu, feedback_fn, instance, ignore_failures): |
227 | 22b7f6f8 | Thomas Thrainer | """Utility function to remove an instance.
|
228 | 22b7f6f8 | Thomas Thrainer |
|
229 | 22b7f6f8 | Thomas Thrainer | """
|
230 | 22b7f6f8 | Thomas Thrainer | logging.info("Removing block devices for instance %s", instance.name)
|
231 | 22b7f6f8 | Thomas Thrainer | |
232 | 5eacbcae | Thomas Thrainer | if not RemoveDisks(lu, instance, ignore_failures=ignore_failures): |
233 | 22b7f6f8 | Thomas Thrainer | if not ignore_failures: |
234 | 22b7f6f8 | Thomas Thrainer | raise errors.OpExecError("Can't remove instance's disks") |
235 | 22b7f6f8 | Thomas Thrainer | feedback_fn("Warning: can't remove instance's disks")
|
236 | 22b7f6f8 | Thomas Thrainer | |
237 | 22b7f6f8 | Thomas Thrainer | logging.info("Removing instance %s out of cluster config", instance.name)
|
238 | 22b7f6f8 | Thomas Thrainer | |
239 | da4a52a3 | Thomas Thrainer | lu.cfg.RemoveInstance(instance.uuid) |
240 | 22b7f6f8 | Thomas Thrainer | |
241 | 22b7f6f8 | Thomas Thrainer | assert not lu.remove_locks.get(locking.LEVEL_INSTANCE), \ |
242 | 22b7f6f8 | Thomas Thrainer | "Instance lock removal conflict"
|
243 | 22b7f6f8 | Thomas Thrainer | |
244 | 22b7f6f8 | Thomas Thrainer | # Remove lock for the instance
|
245 | 22b7f6f8 | Thomas Thrainer | lu.remove_locks[locking.LEVEL_INSTANCE] = instance.name |
246 | 22b7f6f8 | Thomas Thrainer | |
247 | 22b7f6f8 | Thomas Thrainer | |
248 | 1c3231aa | Thomas Thrainer | def RemoveDisks(lu, instance, target_node_uuid=None, ignore_failures=False): |
249 | 22b7f6f8 | Thomas Thrainer | """Remove all disks for an instance.
|
250 | 22b7f6f8 | Thomas Thrainer |
|
251 | 22b7f6f8 | Thomas Thrainer | This abstracts away some work from `AddInstance()` and
|
252 | 22b7f6f8 | Thomas Thrainer | `RemoveInstance()`. Note that in case some of the devices couldn't
|
253 | 22b7f6f8 | Thomas Thrainer | be removed, the removal will continue with the other ones.
|
254 | 22b7f6f8 | Thomas Thrainer |
|
255 | 22b7f6f8 | Thomas Thrainer | @type lu: L{LogicalUnit}
|
256 | 22b7f6f8 | Thomas Thrainer | @param lu: the logical unit on whose behalf we execute
|
257 | 22b7f6f8 | Thomas Thrainer | @type instance: L{objects.Instance}
|
258 | 22b7f6f8 | Thomas Thrainer | @param instance: the instance whose disks we should remove
|
259 | 1c3231aa | Thomas Thrainer | @type target_node_uuid: string
|
260 | 1c3231aa | Thomas Thrainer | @param target_node_uuid: used to override the node on which to remove the
|
261 | 1c3231aa | Thomas Thrainer | disks
|
262 | 22b7f6f8 | Thomas Thrainer | @rtype: boolean
|
263 | 22b7f6f8 | Thomas Thrainer | @return: the success of the removal
|
264 | 22b7f6f8 | Thomas Thrainer |
|
265 | 22b7f6f8 | Thomas Thrainer | """
|
266 | 22b7f6f8 | Thomas Thrainer | logging.info("Removing block devices for instance %s", instance.name)
|
267 | 22b7f6f8 | Thomas Thrainer | |
268 | 22b7f6f8 | Thomas Thrainer | all_result = True
|
269 | 22b7f6f8 | Thomas Thrainer | ports_to_release = set()
|
270 | 5eacbcae | Thomas Thrainer | anno_disks = AnnotateDiskParams(instance, instance.disks, lu.cfg) |
271 | 22b7f6f8 | Thomas Thrainer | for (idx, device) in enumerate(anno_disks): |
272 | 1c3231aa | Thomas Thrainer | if target_node_uuid:
|
273 | 1c3231aa | Thomas Thrainer | edata = [(target_node_uuid, device)] |
274 | 22b7f6f8 | Thomas Thrainer | else:
|
275 | 22b7f6f8 | Thomas Thrainer | edata = device.ComputeNodeTree(instance.primary_node) |
276 | 1c3231aa | Thomas Thrainer | for node_uuid, disk in edata: |
277 | 0c3d9c7c | Thomas Thrainer | result = lu.rpc.call_blockdev_remove(node_uuid, (disk, instance)) |
278 | 22b7f6f8 | Thomas Thrainer | if result.fail_msg:
|
279 | 22b7f6f8 | Thomas Thrainer | lu.LogWarning("Could not remove disk %s on node %s,"
|
280 | 1c3231aa | Thomas Thrainer | " continuing anyway: %s", idx,
|
281 | 1c3231aa | Thomas Thrainer | lu.cfg.GetNodeName(node_uuid), result.fail_msg) |
282 | 1c3231aa | Thomas Thrainer | if not (result.offline and node_uuid != instance.primary_node): |
283 | 22b7f6f8 | Thomas Thrainer | all_result = False
|
284 | 22b7f6f8 | Thomas Thrainer | |
285 | 22b7f6f8 | Thomas Thrainer | # if this is a DRBD disk, return its port to the pool
|
286 | 22b7f6f8 | Thomas Thrainer | if device.dev_type in constants.LDS_DRBD: |
287 | 22b7f6f8 | Thomas Thrainer | ports_to_release.add(device.logical_id[2])
|
288 | 22b7f6f8 | Thomas Thrainer | |
289 | 22b7f6f8 | Thomas Thrainer | if all_result or ignore_failures: |
290 | 22b7f6f8 | Thomas Thrainer | for port in ports_to_release: |
291 | 22b7f6f8 | Thomas Thrainer | lu.cfg.AddTcpUdpPort(port) |
292 | 22b7f6f8 | Thomas Thrainer | |
293 | 1f7c8208 | Helga Velroyen | CheckDiskTemplateEnabled(lu.cfg.GetClusterInfo(), instance.disk_template) |
294 | 1f7c8208 | Helga Velroyen | |
295 | 22b7f6f8 | Thomas Thrainer | if instance.disk_template in constants.DTS_FILEBASED: |
296 | 22b7f6f8 | Thomas Thrainer | file_storage_dir = os.path.dirname(instance.disks[0].logical_id[1]) |
297 | 1c3231aa | Thomas Thrainer | if target_node_uuid:
|
298 | 1c3231aa | Thomas Thrainer | tgt = target_node_uuid |
299 | 22b7f6f8 | Thomas Thrainer | else:
|
300 | 22b7f6f8 | Thomas Thrainer | tgt = instance.primary_node |
301 | 22b7f6f8 | Thomas Thrainer | result = lu.rpc.call_file_storage_dir_remove(tgt, file_storage_dir) |
302 | 22b7f6f8 | Thomas Thrainer | if result.fail_msg:
|
303 | 22b7f6f8 | Thomas Thrainer | lu.LogWarning("Could not remove directory '%s' on node %s: %s",
|
304 | 1c3231aa | Thomas Thrainer | file_storage_dir, lu.cfg.GetNodeName(tgt), result.fail_msg) |
305 | 22b7f6f8 | Thomas Thrainer | all_result = False
|
306 | 22b7f6f8 | Thomas Thrainer | |
307 | 22b7f6f8 | Thomas Thrainer | return all_result
|
308 | 22b7f6f8 | Thomas Thrainer | |
309 | 22b7f6f8 | Thomas Thrainer | |
310 | 5eacbcae | Thomas Thrainer | def NICToTuple(lu, nic): |
311 | 22b7f6f8 | Thomas Thrainer | """Build a tupple of nic information.
|
312 | 22b7f6f8 | Thomas Thrainer |
|
313 | 22b7f6f8 | Thomas Thrainer | @type lu: L{LogicalUnit}
|
314 | 22b7f6f8 | Thomas Thrainer | @param lu: the logical unit on whose behalf we execute
|
315 | 22b7f6f8 | Thomas Thrainer | @type nic: L{objects.NIC}
|
316 | 22b7f6f8 | Thomas Thrainer | @param nic: nic to convert to hooks tuple
|
317 | 22b7f6f8 | Thomas Thrainer |
|
318 | 22b7f6f8 | Thomas Thrainer | """
|
319 | 22b7f6f8 | Thomas Thrainer | cluster = lu.cfg.GetClusterInfo() |
320 | 22b7f6f8 | Thomas Thrainer | filled_params = cluster.SimpleFillNIC(nic.nicparams) |
321 | 22b7f6f8 | Thomas Thrainer | mode = filled_params[constants.NIC_MODE] |
322 | 22b7f6f8 | Thomas Thrainer | link = filled_params[constants.NIC_LINK] |
323 | d676dbea | Sebastian Gebhard | vlan = filled_params[constants.NIC_VLAN] |
324 | 22b7f6f8 | Thomas Thrainer | netinfo = None
|
325 | 22b7f6f8 | Thomas Thrainer | if nic.network:
|
326 | 22b7f6f8 | Thomas Thrainer | nobj = lu.cfg.GetNetwork(nic.network) |
327 | 22b7f6f8 | Thomas Thrainer | netinfo = objects.Network.ToDict(nobj) |
328 | d676dbea | Sebastian Gebhard | return (nic.name, nic.uuid, nic.ip, nic.mac, mode, link, vlan,
|
329 | d676dbea | Sebastian Gebhard | nic.network, netinfo) |
330 | 22b7f6f8 | Thomas Thrainer | |
331 | 22b7f6f8 | Thomas Thrainer | |
332 | 5eacbcae | Thomas Thrainer | def NICListToTuple(lu, nics): |
333 | 22b7f6f8 | Thomas Thrainer | """Build a list of nic information tuples.
|
334 | 22b7f6f8 | Thomas Thrainer |
|
335 | 22b7f6f8 | Thomas Thrainer | This list is suitable to be passed to _BuildInstanceHookEnv or as a return
|
336 | 22b7f6f8 | Thomas Thrainer | value in LUInstanceQueryData.
|
337 | 22b7f6f8 | Thomas Thrainer |
|
338 | 22b7f6f8 | Thomas Thrainer | @type lu: L{LogicalUnit}
|
339 | 22b7f6f8 | Thomas Thrainer | @param lu: the logical unit on whose behalf we execute
|
340 | 22b7f6f8 | Thomas Thrainer | @type nics: list of L{objects.NIC}
|
341 | 22b7f6f8 | Thomas Thrainer | @param nics: list of nics to convert to hooks tuples
|
342 | 22b7f6f8 | Thomas Thrainer |
|
343 | 22b7f6f8 | Thomas Thrainer | """
|
344 | 22b7f6f8 | Thomas Thrainer | hooks_nics = [] |
345 | 22b7f6f8 | Thomas Thrainer | for nic in nics: |
346 | 5eacbcae | Thomas Thrainer | hooks_nics.append(NICToTuple(lu, nic)) |
347 | 22b7f6f8 | Thomas Thrainer | return hooks_nics
|
348 | 763ad5be | Thomas Thrainer | |
349 | 763ad5be | Thomas Thrainer | |
350 | 5eacbcae | Thomas Thrainer | def CopyLockList(names): |
351 | 763ad5be | Thomas Thrainer | """Makes a copy of a list of lock names.
|
352 | 763ad5be | Thomas Thrainer |
|
353 | 763ad5be | Thomas Thrainer | Handles L{locking.ALL_SET} correctly.
|
354 | 763ad5be | Thomas Thrainer |
|
355 | 763ad5be | Thomas Thrainer | """
|
356 | 763ad5be | Thomas Thrainer | if names == locking.ALL_SET:
|
357 | 763ad5be | Thomas Thrainer | return locking.ALL_SET
|
358 | 763ad5be | Thomas Thrainer | else:
|
359 | 763ad5be | Thomas Thrainer | return names[:]
|
360 | 763ad5be | Thomas Thrainer | |
361 | 763ad5be | Thomas Thrainer | |
362 | 5eacbcae | Thomas Thrainer | def ReleaseLocks(lu, level, names=None, keep=None): |
363 | 763ad5be | Thomas Thrainer | """Releases locks owned by an LU.
|
364 | 763ad5be | Thomas Thrainer |
|
365 | 763ad5be | Thomas Thrainer | @type lu: L{LogicalUnit}
|
366 | 763ad5be | Thomas Thrainer | @param level: Lock level
|
367 | 763ad5be | Thomas Thrainer | @type names: list or None
|
368 | 763ad5be | Thomas Thrainer | @param names: Names of locks to release
|
369 | 763ad5be | Thomas Thrainer | @type keep: list or None
|
370 | 763ad5be | Thomas Thrainer | @param keep: Names of locks to retain
|
371 | 763ad5be | Thomas Thrainer |
|
372 | 763ad5be | Thomas Thrainer | """
|
373 | 763ad5be | Thomas Thrainer | assert not (keep is not None and names is not None), \ |
374 | 763ad5be | Thomas Thrainer | "Only one of the 'names' and the 'keep' parameters can be given"
|
375 | 763ad5be | Thomas Thrainer | |
376 | 763ad5be | Thomas Thrainer | if names is not None: |
377 | 763ad5be | Thomas Thrainer | should_release = names.__contains__ |
378 | 763ad5be | Thomas Thrainer | elif keep:
|
379 | 763ad5be | Thomas Thrainer | should_release = lambda name: name not in keep |
380 | 763ad5be | Thomas Thrainer | else:
|
381 | 763ad5be | Thomas Thrainer | should_release = None
|
382 | 763ad5be | Thomas Thrainer | |
383 | 763ad5be | Thomas Thrainer | owned = lu.owned_locks(level) |
384 | 763ad5be | Thomas Thrainer | if not owned: |
385 | 763ad5be | Thomas Thrainer | # Not owning any lock at this level, do nothing
|
386 | 763ad5be | Thomas Thrainer | pass
|
387 | 763ad5be | Thomas Thrainer | |
388 | 763ad5be | Thomas Thrainer | elif should_release:
|
389 | 763ad5be | Thomas Thrainer | retain = [] |
390 | 763ad5be | Thomas Thrainer | release = [] |
391 | 763ad5be | Thomas Thrainer | |
392 | 763ad5be | Thomas Thrainer | # Determine which locks to release
|
393 | 763ad5be | Thomas Thrainer | for name in owned: |
394 | 763ad5be | Thomas Thrainer | if should_release(name):
|
395 | 763ad5be | Thomas Thrainer | release.append(name) |
396 | 763ad5be | Thomas Thrainer | else:
|
397 | 763ad5be | Thomas Thrainer | retain.append(name) |
398 | 763ad5be | Thomas Thrainer | |
399 | 763ad5be | Thomas Thrainer | assert len(lu.owned_locks(level)) == (len(retain) + len(release)) |
400 | 763ad5be | Thomas Thrainer | |
401 | 763ad5be | Thomas Thrainer | # Release just some locks
|
402 | 763ad5be | Thomas Thrainer | lu.glm.release(level, names=release) |
403 | 763ad5be | Thomas Thrainer | |
404 | 763ad5be | Thomas Thrainer | assert frozenset(lu.owned_locks(level)) == frozenset(retain) |
405 | 763ad5be | Thomas Thrainer | else:
|
406 | 763ad5be | Thomas Thrainer | # Release everything
|
407 | 763ad5be | Thomas Thrainer | lu.glm.release(level) |
408 | 763ad5be | Thomas Thrainer | |
409 | 763ad5be | Thomas Thrainer | assert not lu.glm.is_owned(level), "No locks should be owned" |
410 | 763ad5be | Thomas Thrainer | |
411 | 763ad5be | Thomas Thrainer | |
412 | 763ad5be | Thomas Thrainer | def _ComputeIPolicyNodeViolation(ipolicy, instance, current_group, |
413 | 763ad5be | Thomas Thrainer | target_group, cfg, |
414 | 5eacbcae | Thomas Thrainer | _compute_fn=ComputeIPolicyInstanceViolation): |
415 | 763ad5be | Thomas Thrainer | """Compute if instance meets the specs of the new target group.
|
416 | 763ad5be | Thomas Thrainer |
|
417 | 763ad5be | Thomas Thrainer | @param ipolicy: The ipolicy to verify
|
418 | 763ad5be | Thomas Thrainer | @param instance: The instance object to verify
|
419 | 763ad5be | Thomas Thrainer | @param current_group: The current group of the instance
|
420 | 763ad5be | Thomas Thrainer | @param target_group: The new group of the instance
|
421 | 763ad5be | Thomas Thrainer | @type cfg: L{config.ConfigWriter}
|
422 | 763ad5be | Thomas Thrainer | @param cfg: Cluster configuration
|
423 | 763ad5be | Thomas Thrainer | @param _compute_fn: The function to verify ipolicy (unittest only)
|
424 | 5eacbcae | Thomas Thrainer | @see: L{ganeti.cmdlib.common.ComputeIPolicySpecViolation}
|
425 | 763ad5be | Thomas Thrainer |
|
426 | 763ad5be | Thomas Thrainer | """
|
427 | 763ad5be | Thomas Thrainer | if current_group == target_group:
|
428 | 763ad5be | Thomas Thrainer | return []
|
429 | 763ad5be | Thomas Thrainer | else:
|
430 | 763ad5be | Thomas Thrainer | return _compute_fn(ipolicy, instance, cfg)
|
431 | 763ad5be | Thomas Thrainer | |
432 | 763ad5be | Thomas Thrainer | |
433 | 5eacbcae | Thomas Thrainer | def CheckTargetNodeIPolicy(lu, ipolicy, instance, node, cfg, ignore=False, |
434 | 5eacbcae | Thomas Thrainer | _compute_fn=_ComputeIPolicyNodeViolation): |
435 | 763ad5be | Thomas Thrainer | """Checks that the target node is correct in terms of instance policy.
|
436 | 763ad5be | Thomas Thrainer |
|
437 | 763ad5be | Thomas Thrainer | @param ipolicy: The ipolicy to verify
|
438 | 763ad5be | Thomas Thrainer | @param instance: The instance object to verify
|
439 | 763ad5be | Thomas Thrainer | @param node: The new node to relocate
|
440 | 763ad5be | Thomas Thrainer | @type cfg: L{config.ConfigWriter}
|
441 | 763ad5be | Thomas Thrainer | @param cfg: Cluster configuration
|
442 | 763ad5be | Thomas Thrainer | @param ignore: Ignore violations of the ipolicy
|
443 | 763ad5be | Thomas Thrainer | @param _compute_fn: The function to verify ipolicy (unittest only)
|
444 | 5eacbcae | Thomas Thrainer | @see: L{ganeti.cmdlib.common.ComputeIPolicySpecViolation}
|
445 | 763ad5be | Thomas Thrainer |
|
446 | 763ad5be | Thomas Thrainer | """
|
447 | 763ad5be | Thomas Thrainer | primary_node = lu.cfg.GetNodeInfo(instance.primary_node) |
448 | 763ad5be | Thomas Thrainer | res = _compute_fn(ipolicy, instance, primary_node.group, node.group, cfg) |
449 | 763ad5be | Thomas Thrainer | |
450 | 763ad5be | Thomas Thrainer | if res:
|
451 | 763ad5be | Thomas Thrainer | msg = ("Instance does not meet target node group's (%s) instance"
|
452 | 763ad5be | Thomas Thrainer | " policy: %s") % (node.group, utils.CommaJoin(res))
|
453 | 763ad5be | Thomas Thrainer | if ignore:
|
454 | 763ad5be | Thomas Thrainer | lu.LogWarning(msg) |
455 | 763ad5be | Thomas Thrainer | else:
|
456 | 763ad5be | Thomas Thrainer | raise errors.OpPrereqError(msg, errors.ECODE_INVAL)
|
457 | 763ad5be | Thomas Thrainer | |
458 | 763ad5be | Thomas Thrainer | |
459 | 5eacbcae | Thomas Thrainer | def GetInstanceInfoText(instance): |
460 | 763ad5be | Thomas Thrainer | """Compute that text that should be added to the disk's metadata.
|
461 | 763ad5be | Thomas Thrainer |
|
462 | 763ad5be | Thomas Thrainer | """
|
463 | 763ad5be | Thomas Thrainer | return "originstname+%s" % instance.name |
464 | 87e25be1 | Thomas Thrainer | |
465 | 87e25be1 | Thomas Thrainer | |
466 | 1c3231aa | Thomas Thrainer | def CheckNodeFreeMemory(lu, node_uuid, reason, requested, hvname, hvparams): |
467 | 87e25be1 | Thomas Thrainer | """Checks if a node has enough free memory.
|
468 | 87e25be1 | Thomas Thrainer |
|
469 | 87e25be1 | Thomas Thrainer | This function checks if a given node has the needed amount of free
|
470 | 87e25be1 | Thomas Thrainer | memory. In case the node has less memory or we cannot get the
|
471 | 87e25be1 | Thomas Thrainer | information from the node, this function raises an OpPrereqError
|
472 | 87e25be1 | Thomas Thrainer | exception.
|
473 | 87e25be1 | Thomas Thrainer |
|
474 | 87e25be1 | Thomas Thrainer | @type lu: C{LogicalUnit}
|
475 | 87e25be1 | Thomas Thrainer | @param lu: a logical unit from which we get configuration data
|
476 | 1c3231aa | Thomas Thrainer | @type node_uuid: C{str}
|
477 | 1c3231aa | Thomas Thrainer | @param node_uuid: the node to check
|
478 | 87e25be1 | Thomas Thrainer | @type reason: C{str}
|
479 | 87e25be1 | Thomas Thrainer | @param reason: string to use in the error message
|
480 | 87e25be1 | Thomas Thrainer | @type requested: C{int}
|
481 | 87e25be1 | Thomas Thrainer | @param requested: the amount of memory in MiB to check for
|
482 | a295eb80 | Helga Velroyen | @type hvname: string
|
483 | a295eb80 | Helga Velroyen | @param hvname: the hypervisor's name
|
484 | a295eb80 | Helga Velroyen | @type hvparams: dict of strings
|
485 | a295eb80 | Helga Velroyen | @param hvparams: the hypervisor's parameters
|
486 | 87e25be1 | Thomas Thrainer | @rtype: integer
|
487 | 87e25be1 | Thomas Thrainer | @return: node current free memory
|
488 | 87e25be1 | Thomas Thrainer | @raise errors.OpPrereqError: if the node doesn't have enough memory, or
|
489 | 87e25be1 | Thomas Thrainer | we cannot check the node
|
490 | 87e25be1 | Thomas Thrainer |
|
491 | 87e25be1 | Thomas Thrainer | """
|
492 | 1c3231aa | Thomas Thrainer | node_name = lu.cfg.GetNodeName(node_uuid) |
493 | da803ff1 | Helga Velroyen | nodeinfo = lu.rpc.call_node_info([node_uuid], None, [(hvname, hvparams)])
|
494 | 1c3231aa | Thomas Thrainer | nodeinfo[node_uuid].Raise("Can't get data from node %s" % node_name,
|
495 | 1c3231aa | Thomas Thrainer | prereq=True, ecode=errors.ECODE_ENVIRON)
|
496 | 1c3231aa | Thomas Thrainer | (_, _, (hv_info, )) = nodeinfo[node_uuid].payload |
497 | 87e25be1 | Thomas Thrainer | |
498 | 87e25be1 | Thomas Thrainer | free_mem = hv_info.get("memory_free", None) |
499 | 87e25be1 | Thomas Thrainer | if not isinstance(free_mem, int): |
500 | 87e25be1 | Thomas Thrainer | raise errors.OpPrereqError("Can't compute free memory on node %s, result" |
501 | 1c3231aa | Thomas Thrainer | " was '%s'" % (node_name, free_mem),
|
502 | 87e25be1 | Thomas Thrainer | errors.ECODE_ENVIRON) |
503 | 87e25be1 | Thomas Thrainer | if requested > free_mem:
|
504 | 87e25be1 | Thomas Thrainer | raise errors.OpPrereqError("Not enough memory on node %s for %s:" |
505 | 87e25be1 | Thomas Thrainer | " needed %s MiB, available %s MiB" %
|
506 | 1c3231aa | Thomas Thrainer | (node_name, reason, requested, free_mem), |
507 | 87e25be1 | Thomas Thrainer | errors.ECODE_NORES) |
508 | 87e25be1 | Thomas Thrainer | return free_mem
|
509 | 87e25be1 | Thomas Thrainer | |
510 | 87e25be1 | Thomas Thrainer | |
511 | 1c3231aa | Thomas Thrainer | def CheckInstanceBridgesExist(lu, instance, node_uuid=None): |
512 | 87e25be1 | Thomas Thrainer | """Check that the brigdes needed by an instance exist.
|
513 | 87e25be1 | Thomas Thrainer |
|
514 | 87e25be1 | Thomas Thrainer | """
|
515 | 1c3231aa | Thomas Thrainer | if node_uuid is None: |
516 | 1c3231aa | Thomas Thrainer | node_uuid = instance.primary_node |
517 | 1c3231aa | Thomas Thrainer | CheckNicsBridgesExist(lu, instance.nics, node_uuid) |
518 | 87e25be1 | Thomas Thrainer | |
519 | 87e25be1 | Thomas Thrainer | |
520 | 1c3231aa | Thomas Thrainer | def CheckNicsBridgesExist(lu, nics, node_uuid): |
521 | 87e25be1 | Thomas Thrainer | """Check that the brigdes needed by a list of nics exist.
|
522 | 87e25be1 | Thomas Thrainer |
|
523 | 87e25be1 | Thomas Thrainer | """
|
524 | 87e25be1 | Thomas Thrainer | cluster = lu.cfg.GetClusterInfo() |
525 | 1c3231aa | Thomas Thrainer | paramslist = [cluster.SimpleFillNIC(nic.nicparams) for nic in nics] |
526 | 87e25be1 | Thomas Thrainer | brlist = [params[constants.NIC_LINK] for params in paramslist |
527 | 87e25be1 | Thomas Thrainer | if params[constants.NIC_MODE] == constants.NIC_MODE_BRIDGED]
|
528 | 87e25be1 | Thomas Thrainer | if brlist:
|
529 | 1c3231aa | Thomas Thrainer | result = lu.rpc.call_bridges_exist(node_uuid, brlist) |
530 | 87e25be1 | Thomas Thrainer | result.Raise("Error checking bridges on destination node '%s'" %
|
531 | 1c3231aa | Thomas Thrainer | lu.cfg.GetNodeName(node_uuid), prereq=True,
|
532 | 1c3231aa | Thomas Thrainer | ecode=errors.ECODE_ENVIRON) |
533 | 13f6af81 | Thomas Thrainer | |
534 | 13f6af81 | Thomas Thrainer | |
535 | 1c3231aa | Thomas Thrainer | def CheckNodeHasOS(lu, node_uuid, os_name, force_variant): |
536 | 13f6af81 | Thomas Thrainer | """Ensure that a node supports a given OS.
|
537 | 13f6af81 | Thomas Thrainer |
|
538 | 13f6af81 | Thomas Thrainer | @param lu: the LU on behalf of which we make the check
|
539 | 1c3231aa | Thomas Thrainer | @param node_uuid: the node to check
|
540 | 13f6af81 | Thomas Thrainer | @param os_name: the OS to query about
|
541 | 13f6af81 | Thomas Thrainer | @param force_variant: whether to ignore variant errors
|
542 | 13f6af81 | Thomas Thrainer | @raise errors.OpPrereqError: if the node is not supporting the OS
|
543 | 13f6af81 | Thomas Thrainer |
|
544 | 13f6af81 | Thomas Thrainer | """
|
545 | 1c3231aa | Thomas Thrainer | result = lu.rpc.call_os_get(node_uuid, os_name) |
546 | 13f6af81 | Thomas Thrainer | result.Raise("OS '%s' not in supported OS list for node %s" %
|
547 | 1c3231aa | Thomas Thrainer | (os_name, lu.cfg.GetNodeName(node_uuid)), |
548 | 13f6af81 | Thomas Thrainer | prereq=True, ecode=errors.ECODE_INVAL)
|
549 | 13f6af81 | Thomas Thrainer | if not force_variant: |
550 | 13f6af81 | Thomas Thrainer | _CheckOSVariant(result.payload, os_name) |
551 | 13f6af81 | Thomas Thrainer | |
552 | 13f6af81 | Thomas Thrainer | |
553 | 13f6af81 | Thomas Thrainer | def _CheckOSVariant(os_obj, name): |
554 | 13f6af81 | Thomas Thrainer | """Check whether an OS name conforms to the os variants specification.
|
555 | 13f6af81 | Thomas Thrainer |
|
556 | 13f6af81 | Thomas Thrainer | @type os_obj: L{objects.OS}
|
557 | 13f6af81 | Thomas Thrainer | @param os_obj: OS object to check
|
558 | 13f6af81 | Thomas Thrainer | @type name: string
|
559 | 13f6af81 | Thomas Thrainer | @param name: OS name passed by the user, to check for validity
|
560 | 13f6af81 | Thomas Thrainer |
|
561 | 13f6af81 | Thomas Thrainer | """
|
562 | 13f6af81 | Thomas Thrainer | variant = objects.OS.GetVariant(name) |
563 | 13f6af81 | Thomas Thrainer | if not os_obj.supported_variants: |
564 | 13f6af81 | Thomas Thrainer | if variant:
|
565 | 13f6af81 | Thomas Thrainer | raise errors.OpPrereqError("OS '%s' doesn't support variants ('%s'" |
566 | 13f6af81 | Thomas Thrainer | " passed)" % (os_obj.name, variant),
|
567 | 13f6af81 | Thomas Thrainer | errors.ECODE_INVAL) |
568 | 13f6af81 | Thomas Thrainer | return
|
569 | 13f6af81 | Thomas Thrainer | if not variant: |
570 | 13f6af81 | Thomas Thrainer | raise errors.OpPrereqError("OS name must include a variant", |
571 | 13f6af81 | Thomas Thrainer | errors.ECODE_INVAL) |
572 | 13f6af81 | Thomas Thrainer | |
573 | 13f6af81 | Thomas Thrainer | if variant not in os_obj.supported_variants: |
574 | 13f6af81 | Thomas Thrainer | raise errors.OpPrereqError("Unsupported OS variant", errors.ECODE_INVAL) |