/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

                                    (disk_template,
                                     ",".join(cluster.enabled_disk_templates)))
     def CheckStorageTypeEnabled(cluster, storage_type):
       """Helper function to check if a storage type is enabled.
       @type cluster: C{objects.Cluster}
       @param cluster: the cluster's configuration
       @type storage_type: str
       @param storage_type: the storage type to be checked
       """
       assert storage_type is not None
       assert storage_type in constants.VALID_STORAGE_TYPES
       # special case for lvm-pv, because it cannot be enabled
       # via disk templates
       if storage_type == constants.ST_LVM_PV:
         CheckStorageTypeEnabled(cluster, constants.ST_LVM_VG)
       else:
         possible_disk_templates = \
             utils.storage.GetDiskTemplatesOfStorageType(storage_type)
         for disk_template in possible_disk_templates:
           if disk_template in cluster.enabled_disk_templates:
             return
         raise errors.OpPrereqError("No disk template of storage type '%s' is"
                                    " enabled in this cluster. Enabled disk"
                                    " templates are: %s" % (storage_type,
                                    ",".join(cluster.enabled_disk_templates)))

                                      self.instance.disk_template,
                                      errors.ECODE_INVAL)
         if not self.cluster.IsDiskTemplateEnabled(self.instance.disk_template):
           raise errors.OpPrereqError("Disk template '%s' is not enabled for this"
                                      " cluster." % self.instance.disk_template)
         if (self.instance.disk_template,
             self.op.disk_template) not in self._DISK_CONVERSIONS:
           raise errors.OpPrereqError("Unsupported disk template conversion from"

b/lib/cmdlib/instance_storage.py
34	34	from ganeti.masterd import iallocator
35	35	from ganeti import objects
36	36	from ganeti import utils
37		from ganeti import opcodes
38	37	from ganeti import rpc
39	38	from ganeti.cmdlib.base import LogicalUnit, NoHooksLU, Tasklet
40	39	from ganeti.cmdlib.common import INSTANCE_DOWN, INSTANCE_NOT_RUNNING, \

       CheckInstanceState, INSTANCE_DOWN, GetUpdatedParams, \
       AdjustCandidatePool, CheckIAllocatorOrNode, LoadNodeEvacResult, \
       GetWantedNodes, MapInstanceLvsToNodes, RunPostHook, \
       FindFaultyInstanceDisks
       FindFaultyInstanceDisks, CheckStorageTypeEnabled
     def _DecideSelfPromotion(lu, exceptions=None):
-...
                                      (storage_type, list(diff)),
                                      errors.ECODE_INVAL)
       def CheckPrereq(self):
         """Check prerequisites.
         """
         CheckStorageTypeEnabled(self.cfg.GetClusterInfo(), self.op.storage_type)
       def ExpandNames(self):
         self.needed_locks = {
           locking.LEVEL_NODE: self.op.node_uuid,
-...
             locking.LEVEL_NODE_ALLOC: locking.ALL_SET,
+            }
       def CheckPrereq(self):
         """Check prerequisites.
         """
         CheckStorageTypeEnabled(self.cfg.GetClusterInfo(), self.op.storage_type)
       def Exec(self, feedback_fn):
         """Computes the list of nodes and their attributes.
-...
         """Check prerequisites.
         """
         CheckStorageTypeEnabled(self.cfg.GetClusterInfo(), self.op.storage_type)
         # Check whether any instance on this node has faulty disks
         for inst in _GetNodeInstances(self.cfg, self.op.node_uuid):
           if not inst.disks_active:

         })
     def RequireFileStorage():
       """Checks that file storage is enabled.
       While it doesn't really fit into this module, L{utils} was deemed too large
       of a dependency to be imported for just one or two functions.
       @raise errors.OpPrereqError: when file storage is disabled
       """
       if not constants.ENABLE_FILE_STORAGE:
         raise errors.OpPrereqError("File storage disabled at configure time",
                                    errors.ECODE_INVAL)
     def RequireSharedFileStorage():
       """Checks that shared file storage is enabled.
-...
                                    " configure time", errors.ECODE_INVAL)
     @ht.WithDesc("CheckFileStorage")
     def _CheckFileStorage(value):
       """Ensures file storage is enabled if used.
       """
       if value == constants.DT_FILE:
         RequireFileStorage()
       elif value == constants.DT_SHARED_FILE:
         RequireSharedFileStorage()
       return True
     def _BuildDiskTemplateCheck(accept_none):
       """Builds check for disk template.
-...
       if accept_none:
         template_check = ht.TMaybe(template_check)
       return ht.TAnd(template_check, _CheckFileStorage)
       return template_check
     def _CheckStorageType(storage_type):
-...
       if storage_type not in constants.VALID_STORAGE_TYPES:
         raise errors.OpPrereqError("Unknown storage type: %s" % storage_type,
                                    errors.ECODE_INVAL)
       if storage_type == constants.ST_FILE:
         # TODO: What about shared file storage?
         RequireFileStorage()
       return True

Synnefo » snf-ganeti

Revision 9d276e93