| 735 |
735 |
return instances
|
| 736 |
736 |
|
| 737 |
737 |
|
|
738 |
def _GetStorageTypeArgs(cfg, storage_type):
|
|
739 |
"""Returns the arguments for a storage type.
|
|
740 |
|
|
741 |
"""
|
|
742 |
# Special case for file storage
|
|
743 |
if storage_type == constants.ST_FILE:
|
|
744 |
return [cfg.GetFileStorageDir()]
|
|
745 |
|
|
746 |
return []
|
|
747 |
|
|
748 |
|
| 738 |
749 |
class LUDestroyCluster(NoHooksLU):
|
| 739 |
750 |
"""Logical unit for destroying the cluster.
|
| 740 |
751 |
|
| ... | ... | |
| 2349 |
2360 |
"""Computes the list of nodes and their attributes.
|
| 2350 |
2361 |
|
| 2351 |
2362 |
"""
|
| 2352 |
|
# Special case for file storage
|
| 2353 |
|
if self.op.storage_type == constants.ST_FILE:
|
| 2354 |
|
st_args = [self.cfg.GetFileStorageDir()]
|
| 2355 |
|
else:
|
| 2356 |
|
st_args = []
|
| 2357 |
|
|
| 2358 |
2363 |
# Always get name to sort by
|
| 2359 |
2364 |
if constants.SF_NAME in self.op.output_fields:
|
| 2360 |
2365 |
fields = self.op.output_fields[:]
|
| ... | ... | |
| 2368 |
2373 |
field_idx = dict([(name, idx) for (idx, name) in enumerate(fields)])
|
| 2369 |
2374 |
name_idx = field_idx[constants.SF_NAME]
|
| 2370 |
2375 |
|
|
2376 |
st_args = _GetStorageTypeArgs(self.cfg, self.op.storage_type)
|
| 2371 |
2377 |
data = self.rpc.call_storage_list(self.nodes,
|
| 2372 |
2378 |
self.op.storage_type, st_args,
|
| 2373 |
2379 |
self.op.name, fields)
|
| ... | ... | |
| 2406 |
2412 |
return result
|
| 2407 |
2413 |
|
| 2408 |
2414 |
|
|
2415 |
class LUModifyNodeStorage(NoHooksLU):
|
|
2416 |
"""Logical unit for modifying a storage volume on a node.
|
|
2417 |
|
|
2418 |
"""
|
|
2419 |
_OP_REQP = ["node_name", "storage_type", "name", "changes"]
|
|
2420 |
REQ_BGL = False
|
|
2421 |
|
|
2422 |
def CheckArguments(self):
|
|
2423 |
node_name = self.cfg.ExpandNodeName(self.op.node_name)
|
|
2424 |
if node_name is None:
|
|
2425 |
raise errors.OpPrereqError("Invalid node name '%s'" % self.op.node_name)
|
|
2426 |
|
|
2427 |
self.op.node_name = node_name
|
|
2428 |
|
|
2429 |
storage_type = self.op.storage_type
|
|
2430 |
if storage_type not in constants.VALID_STORAGE_FIELDS:
|
|
2431 |
raise errors.OpPrereqError("Unknown storage type: %s" % storage_type)
|
|
2432 |
|
|
2433 |
def ExpandNames(self):
|
|
2434 |
self.needed_locks = {
|
|
2435 |
locking.LEVEL_NODE: self.op.node_name,
|
|
2436 |
}
|
|
2437 |
|
|
2438 |
def CheckPrereq(self):
|
|
2439 |
"""Check prerequisites.
|
|
2440 |
|
|
2441 |
"""
|
|
2442 |
storage_type = self.op.storage_type
|
|
2443 |
|
|
2444 |
try:
|
|
2445 |
modifiable = constants.MODIFIABLE_STORAGE_FIELDS[storage_type]
|
|
2446 |
except KeyError:
|
|
2447 |
raise errors.OpPrereqError("Storage units of type '%s' can not be"
|
|
2448 |
" modified" % storage_type)
|
|
2449 |
|
|
2450 |
diff = set(self.op.changes.keys()) - modifiable
|
|
2451 |
if diff:
|
|
2452 |
raise errors.OpPrereqError("The following fields can not be modified for"
|
|
2453 |
" storage units of type '%s': %r" %
|
|
2454 |
(storage_type, list(diff)))
|
|
2455 |
|
|
2456 |
def Exec(self, feedback_fn):
|
|
2457 |
"""Computes the list of nodes and their attributes.
|
|
2458 |
|
|
2459 |
"""
|
|
2460 |
st_args = _GetStorageTypeArgs(self.cfg, self.op.storage_type)
|
|
2461 |
result = self.rpc.call_storage_modify(self.op.node_name,
|
|
2462 |
self.op.storage_type, st_args,
|
|
2463 |
self.op.name, self.op.changes)
|
|
2464 |
result.Raise("Failed to modify storage unit '%s' on %s" %
|
|
2465 |
(self.op.name, self.op.node_name))
|
|
2466 |
|
|
2467 |
|
| 2409 |
2468 |
class LUAddNode(LogicalUnit):
|
| 2410 |
2469 |
"""Logical unit for adding node to the cluster.
|
| 2411 |
2470 |
|
| ... | ... | |
| 2773 |
2832 |
def ExpandNames(self):
|
| 2774 |
2833 |
"""Locking for PowercycleNode.
|
| 2775 |
2834 |
|
| 2776 |
|
This is a last-resource option and shouldn't block on other
|
|
2835 |
This is a last-resort option and shouldn't block on other
|
| 2777 |
2836 |
jobs. Therefore, we grab no locks.
|
| 2778 |
2837 |
|
| 2779 |
2838 |
"""
|