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

Revision 3d3a04bc

         self.write_count = 0
         self._lock = _config_lock
         self._config_data = None
         self._config_time = None
         self._config_size = None
         self._config_inode = None
         self._offline = offline
         if cfg_file is None:
           self._cfg_file = constants.CLUSTER_CONF_FILE
-...
         # better to raise an error before starting to modify the config
         # file than after it was modified
         self._my_hostname = utils.HostInfo().name
         self._OpenConfig()
       # this method needs to be static, so that we can call it on the class
       @staticmethod
-...
         This should check the current instances for duplicates.
         """
         self._OpenConfig()
         prefix = self._config_data.cluster.mac_prefix
         all_macs = self._AllMACs()
         retries = 64
-...
         check for potential collisions elsewhere.
         """
         self._OpenConfig()
         all_macs = self._AllMACs()
         return mac in all_macs
-...
         This checks the current disks for duplicates.
         """
         self._OpenConfig()
         all_secrets = self._AllDRBDSecrets()
         retries = 64
         while retries > 0:
-...
         """Compute the list of all LVs.
         """
         self._OpenConfig()
         lvnames = set()
         for instance in self._config_data.instances.values():
           node_data = instance.MapLVsByNode()
-...
         """Return all MACs present in the config.
         """
         self._OpenConfig()
         result = []
         for instance in self._config_data.instances.values():
           for nic in instance.nics:
-...
       def VerifyConfig(self):
         """Stub verify function.
         """
         self._OpenConfig()
         result = []
         seen_macs = []
         ports = {}
-...
         if not isinstance(port, int):
           raise errors.ProgrammerError("Invalid type passed for port")
         self._OpenConfig()
         self._config_data.cluster.tcpudp_port_pool.add(port)
         self._WriteConfig()
-...
         """Returns a copy of the current port list.
         """
         self._OpenConfig()
         return self._config_data.cluster.tcpudp_port_pool.copy()
       @locking.ssynchronized(_config_lock)
-...
         highest_used_port).
         """
         self._OpenConfig()
         # If there are TCP/IP ports configured, we use them first.
         if self._config_data.cluster.tcpudp_port_pool:
           port = self._config_data.cluster.tcpudp_port_pool.pop()
-...
         order as the passed nodes.
         """
         self._OpenConfig()
         d_map = self._ComputeDRBDMap(instance)
         result = []
         for nname in nodes:
-...
         @return: Cluster name
         """
         self._OpenConfig()
         return self._config_data.cluster.cluster_name
       @locking.ssynchronized(_config_lock, shared=1)
-...
         @return: Master hostname
         """
         self._OpenConfig()
         return self._config_data.cluster.master_node
       @locking.ssynchronized(_config_lock, shared=1)
-...
         @return: Master IP
         """
         self._OpenConfig()
         return self._config_data.cluster.master_ip
       @locking.ssynchronized(_config_lock, shared=1)
-...
         """Get the master network device for this cluster.
         """
         self._OpenConfig()
         return self._config_data.cluster.master_netdev
       @locking.ssynchronized(_config_lock, shared=1)
-...
         """Get the file storage dir for this cluster.
         """
         self._OpenConfig()
         return self._config_data.cluster.file_storage_dir
       @locking.ssynchronized(_config_lock, shared=1)
-...
         """Get the hypervisor type for this cluster.
         """
         self._OpenConfig()
         return self._config_data.cluster.hypervisor
       @locking.ssynchronized(_config_lock, shared=1)
-...
         Returns: rsa hostkey
         """
         self._OpenConfig()
         return self._config_data.cluster.rsahostkeypub
       @locking.ssynchronized(_config_lock)
-...
           all_lvs = instance.MapLVsByNode()
           logging.info("Instance '%s' DISK_LAYOUT: %s", instance.name, all_lvs)
         self._OpenConfig()
         instance.serial_no = 1
         self._config_data.instances[instance.name] = instance
         self._config_data.cluster.serial_no += 1
-...
           raise errors.ProgrammerError("Invalid status '%s' passed to"
                                        " ConfigWriter._SetInstanceStatus()" %
                                        status)
         self._OpenConfig()
         if instance_name not in self._config_data.instances:
           raise errors.ConfigurationError("Unknown instance '%s'" %
-...
         """Remove the instance from the configuration.
         """
         self._OpenConfig()
         if instance_name not in self._config_data.instances:
           raise errors.ConfigurationError("Unknown instance '%s'" % instance_name)
         del self._config_data.instances[instance_name]
-...
         rename.
         """
         self._OpenConfig()
         if old_name not in self._config_data.instances:
           raise errors.ConfigurationError("Unknown instance '%s'" % old_name)
         inst = self._config_data.instances[old_name]
-...
         This function is for internal use, when the config lock is already held.
         """
         self._OpenConfig()
         return self._config_data.instances.keys()
       @locking.ssynchronized(_config_lock, shared=1)
-...
         """Attempt to expand an incomplete instance name.
         """
         self._OpenConfig()
         return utils.MatchNameComponent(short_name,
                                         self._config_data.instances.keys())
-...
         This function is for internal use, when the config lock is already held.
         """
         self._OpenConfig()
         if instance_name not in self._config_data.instances:
           return None
-...
         """
         logging.info("Adding node %s to configuration" % node.name)
         self._OpenConfig()
         node.serial_no = 1
         self._config_data.nodes[node.name] = node
         self._config_data.cluster.serial_no += 1
-...
         """
         logging.info("Removing node %s from configuration" % node_name)
         self._OpenConfig()
         if node_name not in self._config_data.nodes:
           raise errors.ConfigurationError("Unknown node '%s'" % node_name)
-...
         """Attempt to expand an incomplete instance name.
         """
         self._OpenConfig()
         return utils.MatchNameComponent(short_name,
                                         self._config_data.nodes.keys())
-...
         Returns: the node object
         """
         self._OpenConfig()
         if node_name not in self._config_data.nodes:
           return None
-...
         This function is for internal use, when the config lock is already held.
         """
         self._OpenConfig()
         return self._config_data.nodes.keys()
-...
         file, since de-serialisation could be slow.
         """
         try:
           st = os.stat(self._cfg_file)
         except OSError, err:
           raise errors.ConfigurationError("Can't stat config file: %s" % err)
         if (self._config_data is not None and
             self._config_time is not None and
             self._config_time == st.st_mtime and
             self._config_size == st.st_size and
             self._config_inode == st.st_ino):
           # data is current, so skip loading of config file
           return
         f = open(self._cfg_file, 'r')
         try:
           try:
-...
           raise errors.ConfigurationError("Incomplete configuration"
                                           " (missing cluster.rsahostkeypub)")
         self._config_data = data
         self._config_time = st.st_mtime
         self._config_size = st.st_size
         self._config_inode = st.st_ino
       def _DistributeConfig(self):
         """Distribute the configuration to the other nodes.
-...
         # we don't need to do os.close(fd) as f.close() did it
         os.rename(name, destination)
         self.write_count += 1
         # re-set our cache as not to re-read the config file
         try:
           st = os.stat(destination)
         except OSError, err:
           raise errors.ConfigurationError("Can't stat config file: %s" % err)
         self._config_time = st.st_mtime
         self._config_size = st.st_size
         self._config_inode = st.st_ino
         # and redistribute the config file
         self._DistributeConfig()
-...
         """Return the volume group name.
         """
         self._OpenConfig()
         return self._config_data.cluster.volume_group_name
       @locking.ssynchronized(_config_lock)
-...
         """Set the volume group name.
         """
         self._OpenConfig()
         self._config_data.cluster.volume_group_name = vg_name
         self._config_data.cluster.serial_no += 1
         self._WriteConfig()
-...
         """Return the default bridge.
         """
         self._OpenConfig()
         return self._config_data.cluster.default_bridge
       @locking.ssynchronized(_config_lock, shared=1)
-...
         """Return the mac prefix.
         """
         self._OpenConfig()
         return self._config_data.cluster.mac_prefix
       @locking.ssynchronized(_config_lock, shared=1)
-...
           the cluster object
         """
         self._OpenConfig()
         return self._config_data.cluster
       @locking.ssynchronized(_config_lock)

b/tools/cfgshell
152	152	arg = None
153	153	try:
154	154	self.cfg = config.ConfigWriter(cfg_file=arg, offline=True)
155		self.cfg._OpenConfig()
156	155	self.parents = [self.cfg._config_data]
157	156	self.path = []
158	157	except errors.ConfigurationError, err:

Also available in: Unified diff

Synnefo » snf-ganeti

Revision 3d3a04bc