Package ganeti :: Package cmdlib :: Package cluster :: Class LUClusterSetParams
[hide private]
[frames] | no frames]

Class LUClusterSetParams

source code


Change the parameters of the cluster.

Instance Methods [hide private]
 
CheckArguments(self)
Check parameters
source code
 
ExpandNames(self)
Expand names for this LU.
source code
dict
BuildHooksEnv(self)
Build hooks env.
source code
tuple; (list, list)
BuildHooksNodes(self)
Build hooks nodes.
source code
 
_CheckVgName(self, node_uuids, enabled_disk_templates, new_enabled_disk_templates)
Check the consistency of the vg name on all nodes and in case it gets unset whether there are instances still using it.
source code
 
_CheckVgNameOnNodes(self, node_uuids)
Check the status of the volume group on each node.
source code
 
_GetDiskTemplateSets(self, cluster)
Computes three sets of disk templates.
source code
 
_CheckIpolicy(self, cluster, enabled_disk_templates)
Checks the ipolicy.
source code
 
_CheckDrbdHelperOnNodes(self, drbd_helper, node_uuids)
Checks whether the set DRBD helper actually exists on the nodes.
source code
 
_CheckDrbdHelper(self, node_uuids, drbd_enabled, drbd_gets_enabled)
Check the DRBD usermode helper.
source code
 
_CheckInstancesOfDisabledDiskTemplates(self, disabled_disk_templates)
Check whether we try to disable a disk template that is in use.
source code
 
CheckPrereq(self)
Check prerequisites.
source code
 
_BuildOSParams(self, cluster)
Calculate the new OS parameters for this operation.
source code
 
_SetVgName(self, feedback_fn)
Determines and sets the new volume group name.
source code
 
_SetFileStorageDir(self, feedback_fn)
Set the file storage directory.
source code
 
_SetSharedFileStorageDir(self, feedback_fn)
Set the shared file storage directory.
source code
 
_SetDrbdHelper(self, feedback_fn)
Set the DRBD usermode helper.
source code
 
Exec(self, feedback_fn)
Change the parameters of the cluster.
source code

Inherited from base.LogicalUnit: AssertReleasedLocks, DeclareLocks, HooksCallBack, PreparePostHookNodes, PrepareRetry, WConfdClient, __init__, owned_locks, release_request

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Static Methods [hide private]
 
_GetDiskTemplateSetsInner(op_enabled_disk_templates, old_enabled_disk_templates)
Computes three sets of disk templates.
source code
None
_CheckInstanceCommunicationNetwork(network, warning_fn)
Check whether an existing network is configured for instance communication.
source code
ganeti.cmdlib.ResultWithJobs or None
_EnsureInstanceCommunicationNetwork(cfg, network_name)
Ensure that the instance communication network exists and is connected to all groups.
source code
LUClusterSetParams._EnsureInstanceCommunicationNetwork or None
_ModifyInstanceCommunicationNetwork(cfg, network_name, feedback_fn)
Update the instance communication network stored in the cluster configuration.
source code
Class Variables [hide private]
  HPATH = "cluster-modify"
hash(x)
  HTYPE = constants.HTYPE_CLUSTER
hash(x)
  REQ_BGL = False
Instance Variables [hide private]

Inherited from base.LogicalUnit: dry_run_result

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

CheckArguments(self)

source code 

Check parameters

Overrides: base.LogicalUnit.CheckArguments

ExpandNames(self)

source code 

Expand names for this LU.

This method is called before starting to execute the opcode, and it should update all the parameters of the opcode to their canonical form (e.g. a short node name must be fully expanded after this method has successfully completed). This way locking, hooks, logging, etc. can work correctly.

LUs which implement this method must also populate the self.needed_locks member, as a dict with lock levels as keys, and a list of needed lock names as values. Rules:

  • use an empty dict if you don't need any lock
  • if you don't need any lock at a particular level omit that level (note that in this case DeclareLocks won't be called at all for that level)
  • if you need locks at a level, but you can't calculate it in this function, initialise that level with an empty list and do further processing in LogicalUnit.DeclareLocks (see that function's docstring)
  • don't put anything for the BGL level
  • if you want all locks at a level use locking.ALL_SET as a value

If you need to share locks (rather than acquire them exclusively) at one level you can modify self.share_locks, setting a true value (usually 1) for that level. By default locks are not shared.

This function can also define a list of tasklets, which then will be executed in order instead of the usual LU-level CheckPrereq and Exec functions, if those are not defined by the LU.

Examples:

 # Acquire all nodes and one instance
 self.needed_locks = {
   locking.LEVEL_NODE: locking.ALL_SET,
   locking.LEVEL_INSTANCE: ['instance1.example.com'],
 }
 # Acquire just two nodes
 self.needed_locks = {
   locking.LEVEL_NODE: ['node1-uuid', 'node2-uuid'],
 }
 # Acquire no locks
 self.needed_locks = {} # No, you can't leave it to the default value None
Overrides: base.LogicalUnit.ExpandNames
(inherited documentation)

BuildHooksEnv(self)

source code 

Build hooks env.

Returns: dict
Dictionary containing the environment that will be used for running the hooks for this LU. The keys of the dict must not be prefixed with "GANETI_"--that'll be added by the hooks runner. The hooks runner will extend the environment with additional variables. If no environment should be defined, an empty dictionary should be returned (not None).
Overrides: base.LogicalUnit.BuildHooksEnv

BuildHooksNodes(self)

source code 

Build hooks nodes.

Returns: tuple; (list, list)
Tuple containing a list of node UUIDs on which the hook should run before the execution and a list of node UUIDs on which the hook should run after the execution. No nodes should be returned as an empty list (and not None).
Overrides: base.LogicalUnit.BuildHooksNodes

_GetDiskTemplateSetsInner(op_enabled_disk_templates, old_enabled_disk_templates)
Static Method

source code 

Computes three sets of disk templates.

See Also: _GetDiskTemplateSets for more details.

_GetDiskTemplateSets(self, cluster)

source code 

Computes three sets of disk templates.

The three sets are:

  • disk templates that will be enabled after this operation (no matter if they were enabled before or not)
  • disk templates that get enabled by this operation (thus haven't been enabled before.)
  • disk templates that get disabled by this operation

_CheckIpolicy(self, cluster, enabled_disk_templates)

source code 

Checks the ipolicy.

Parameters:
  • cluster (objects.Cluster) - the cluster's configuration
  • enabled_disk_templates (list of string) - list of (possibly newly) enabled disk templates

_CheckDrbdHelperOnNodes(self, drbd_helper, node_uuids)

source code 

Checks whether the set DRBD helper actually exists on the nodes.

Parameters:
  • drbd_helper (string) - path of the drbd usermode helper binary
  • node_uuids (list of strings) - list of node UUIDs to check for the helper

_CheckDrbdHelper(self, node_uuids, drbd_enabled, drbd_gets_enabled)

source code 

Check the DRBD usermode helper.

Parameters:
  • node_uuids (list of strings) - a list of nodes' UUIDs
  • drbd_enabled (boolean) - whether DRBD will be enabled after this operation (no matter if it was disabled before or not)
  • drbd_gets_enabled (boolen) - true if DRBD was disabled before this operation, but will be enabled afterwards

_CheckInstancesOfDisabledDiskTemplates(self, disabled_disk_templates)

source code 

Check whether we try to disable a disk template that is in use.

Parameters:
  • disabled_disk_templates (list of string) - list of disk templates that are going to be disabled by this operation

_CheckInstanceCommunicationNetwork(network, warning_fn)
Static Method

source code 

Check whether an existing network is configured for instance communication.

Checks whether an existing network is configured with the parameters that are advisable for instance communication, and otherwise issue security warnings.

Parameters:
Returns: None
None

CheckPrereq(self)

source code 

Check prerequisites.

This checks whether the given params don't conflict and if the given volume group is valid.

Overrides: base.LogicalUnit.CheckPrereq

_EnsureInstanceCommunicationNetwork(cfg, network_name)
Static Method

source code 

Ensure that the instance communication network exists and is connected to all groups.

The instance communication network given by network_name it is created, if necessary, via the opcode 'OpNetworkAdd'. Also, the instance communication network is connected to all existing node groups, if necessary, via the opcode 'OpNetworkConnect'.

Parameters:
  • cfg (config.ConfigWriter) - cluster configuration
  • network_name (string) - instance communication network name
Returns: ganeti.cmdlib.ResultWithJobs or None
ganeti.cmdlib.ResultWithJobs if the instance communication needs to be created or it needs to be connected to a group, otherwise None

_ModifyInstanceCommunicationNetwork(cfg, network_name, feedback_fn)
Static Method

source code 

Update the instance communication network stored in the cluster configuration.

Compares the user-supplied instance communication network against the one stored in the Ganeti cluster configuration. If there is a change, the instance communication network may be possibly created and connected to all groups (see LUClusterSetParams._EnsureInstanceCommunicationNetwork).

Parameters:
Returns: LUClusterSetParams._EnsureInstanceCommunicationNetwork or None
see LUClusterSetParams._EnsureInstanceCommunicationNetwork

Exec(self, feedback_fn)

source code 

Change the parameters of the cluster.

Overrides: base.LogicalUnit.Exec