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

Revision 0e3baaf3

                                  " 10 seconds" % node_name)
     def _InitFileStorage(file_storage_dir):
       """Initialize if needed the file storage.
       @param file_storage_dir: the user-supplied value
       @return: either empty string (if file storage was disabled at build
           time) or the normalized path to the storage directory
       """
       if not constants.ENABLE_FILE_STORAGE:
         return ""
       file_storage_dir = os.path.normpath(file_storage_dir)
       if not os.path.isabs(file_storage_dir):
         raise errors.OpPrereqError("The file storage directory you passed is"
                                    " not an absolute path.", errors.ECODE_INVAL)
       if not os.path.exists(file_storage_dir):
         try:
           os.makedirs(file_storage_dir, 0750)
         except OSError, err:
           raise errors.OpPrereqError("Cannot create file storage directory"
                                      " '%s': %s" % (file_storage_dir, err),
                                      errors.ECODE_ENVIRON)
       if not os.path.isdir(file_storage_dir):
         raise errors.OpPrereqError("The file storage directory '%s' is not"
                                    " a directory." % file_storage_dir,
                                    errors.ECODE_ENVIRON)
       return file_storage_dir
     def InitCluster(cluster_name, mac_prefix,
                     master_netdev, file_storage_dir, candidate_pool_size,
                     secondary_ip=None, vg_name=None, beparams=None,
-...
                                      " you are not using lvm" % vgstatus,
                                      errors.ECODE_INVAL)
       file_storage_dir = os.path.normpath(file_storage_dir)
       if not os.path.isabs(file_storage_dir):
         raise errors.OpPrereqError("The file storage directory you passed is"
                                    " not an absolute path.", errors.ECODE_INVAL)
       if not os.path.exists(file_storage_dir):
         try:
           os.makedirs(file_storage_dir, 0750)
         except OSError, err:
           raise errors.OpPrereqError("Cannot create file storage directory"
                                      " '%s': %s" % (file_storage_dir, err),
                                      errors.ECODE_ENVIRON)
       if not os.path.isdir(file_storage_dir):
         raise errors.OpPrereqError("The file storage directory '%s' is not"
                                    " a directory." % file_storage_dir,
                                    errors.ECODE_ENVIRON)
       file_storage_dir = _InitFileStorage(file_storage_dir)
       if not re.match("^[0-9a-z]{2}:[0-9a-z]{2}:[0-9a-z]{2}$", mac_prefix):
         raise errors.OpPrereqError("Invalid mac prefix given '%s'" % mac_prefix,

         _CheckOSVariant(result.payload, os_name)
     def _RequireFileStorage():
       """Checks that file storage is enabled.
       @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 _CheckDiskTemplate(template):
       """Ensure a given disk template is valid.
-...
         msg = ("Invalid disk template name '%s', valid templates are: %s" %
                (template, utils.CommaJoin(constants.DISK_TEMPLATES)))
         raise errors.OpPrereqError(msg, errors.ECODE_INVAL)
       if template == constants.DT_FILE and not constants.ENABLE_FILE_STORAGE:
         raise errors.OpPrereqError("File storage disabled at configure time",
       if template == constants.DT_FILE:
         _RequireFileStorage()
     def _CheckStorageType(storage_type):
       """Ensure a given storage type is valid.
       """
       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:
         _RequireFileStorage()
     def _CheckInstanceDown(lu, instance, reason):
-...
       REQ_BGL = False
       _FIELDS_STATIC = utils.FieldSet(constants.SF_NODE)
       def ExpandNames(self):
         storage_type = self.op.storage_type
         if storage_type not in constants.VALID_STORAGE_TYPES:
           raise errors.OpPrereqError("Unknown storage type: %s" % storage_type,
                                      errors.ECODE_INVAL)
       def CheckArguments(self):
         _CheckStorageType(self.op.storage_type)
         _CheckOutputFields(static=self._FIELDS_STATIC,
                            dynamic=utils.FieldSet(*constants.VALID_STORAGE_FIELDS),
                            selected=self.op.output_fields)
       def ExpandNames(self):
         self.needed_locks = {}
         self.share_locks[locking.LEVEL_NODE] = 1
-...
       def CheckArguments(self):
         self.opnode_name = _ExpandNodeName(self.cfg, self.op.node_name)
         storage_type = self.op.storage_type
         if storage_type not in constants.VALID_STORAGE_TYPES:
           raise errors.OpPrereqError("Unknown storage type: %s" % storage_type,
                                      errors.ECODE_INVAL)
         _CheckStorageType(self.op.storage_type)
       def ExpandNames(self):
         self.needed_locks = {
-...
         if len(secondary_nodes) != 0:
           raise errors.ProgrammerError("Wrong template configuration")
         _RequireFileStorage()
         for idx, disk in enumerate(disk_info):
           disk_index = idx + base_index
           disk_dev = objects.Disk(dev_type=constants.LD_FILE, size=disk["size"],
-...
         else:
           network_port = None
         ##if self.op.vnc_bind_address is None:
         ##  self.op.vnc_bind_address = constants.VNC_DEFAULT_BIND_ADDRESS
         if constants.ENABLE_FILE_STORAGE:
           # this is needed because os.path.join does not accept None arguments
           if self.op.file_storage_dir is None:
             string_file_storage_dir = ""
           else:
             string_file_storage_dir = self.op.file_storage_dir
         # this is needed because os.path.join does not accept None arguments
         if self.op.file_storage_dir is None:
           string_file_storage_dir = ""
           # build the full file storage dir path
           file_storage_dir = utils.PathJoin(self.cfg.GetFileStorageDir(),
                                             string_file_storage_dir, instance)
         else:
           string_file_storage_dir = self.op.file_storage_dir
         # build the full file storage dir path
         file_storage_dir = utils.PathJoin(self.cfg.GetFileStorageDir(),
                                           string_file_storage_dir, instance)
           file_storage_dir = ""
         disks = _GenerateDiskTemplate(self,
-...
       def CheckArguments(self):
         self.op.node_name = _ExpandNodeName(self.cfg, self.op.node_name)
         _CheckStorageType(self.op.storage_type)
       def ExpandNames(self):
         self.needed_locks = {
           locking.LEVEL_NODE: [self.op.node_name],

Also available in: Unified diff

Synnefo » snf-ganeti

Revision 0e3baaf3