from ganeti import constants
from ganeti import utils
from ganeti import serializer
+from ganeti import objects
SSCONF_LOCK_TIMEOUT = 10
self._last_inode = None
self._last_mtime = None
self._last_size = None
+
+ self._config_data = None
+ self._inst_ips_by_link = None
+ self._ip_to_inst_by_link = None
+ self._instances_ips = None
+ self._mc_primary_ips = None
+ self._nodes_primary_ips = None
+
# we need a forced reload at class init time, to initialize _last_*
self._Load(force=True)
@type force: boolean
@param force: whether to force the reload without checking the mtime
@rtype: boolean
- @return: boolean values that says whether we reloaded the configuration or not
- (because we decided it was already up-to-date)
+ @return: boolean value that says whether we reloaded the configuration or
+ not (because we decided it was already up-to-date)
"""
- cfg_stat = os.stat(self._file_name)
+ try:
+ cfg_stat = os.stat(self._file_name)
+ except EnvironmentError, err:
+ raise errors.ConfigurationError("Cannot stat config file %s: %s" %
+ (self._file_name, err))
inode = cfg_stat.st_ino
mtime = cfg_stat.st_mtime
size = cfg_stat.st_size
- reload = False
- if force or inode != self._last_inode or \
- mtime > self._last_mtime or \
- size != self._last_size:
+ if (force or inode != self._last_inode or
+ mtime > self._last_mtime or
+ size != self._last_size):
self._last_inode = inode
self._last_mtime = mtime
self._last_size = size
- reload = True
-
- if not reload:
+ else:
+ # Don't reload
return False
try:
self._config_data = serializer.Load(utils.ReadFile(self._file_name))
- except IOError, err:
+ except EnvironmentError, err:
raise errors.ConfigurationError("Cannot read config file %s: %s" %
(self._file_name, err))
except ValueError, err:
raise errors.ConfigurationError("Cannot load config file %s: %s" %
(self._file_name, err))
+ self._ip_to_inst_by_link = {}
+ self._instances_ips = []
+ self._inst_ips_by_link = {}
+ c_nparams = self._config_data['cluster']['nicparams'][constants.PP_DEFAULT]
+ for iname in self._config_data['instances']:
+ instance = self._config_data['instances'][iname]
+ for nic in instance['nics']:
+ if 'ip' in nic and nic['ip']:
+ params = objects.FillDict(c_nparams, nic['nicparams'])
+ if not params['link'] in self._inst_ips_by_link:
+ self._inst_ips_by_link[params['link']] = []
+ self._ip_to_inst_by_link[params['link']] = {}
+ self._ip_to_inst_by_link[params['link']][nic['ip']] = iname
+ self._inst_ips_by_link[params['link']].append(nic['ip'])
+
+ self._nodes_primary_ips = []
+ self._mc_primary_ips = []
+ for node_name in self._config_data["nodes"]:
+ node = self._config_data["nodes"][node_name]
+ self._nodes_primary_ips.append(node["primary_ip"])
+ if node["master_candidate"]:
+ self._mc_primary_ips.append(node["primary_ip"])
+
return True
# Clients can request a reload of the config file, so we export our internal
def GetFileStorageDir(self):
return self._config_data["cluster"]["file_storage_dir"]
- def GetHypervisorType(self):
- return self._config_data["cluster"]["hypervisor"]
-
def GetNodeList(self):
return self._config_data["nodes"].keys()
def GetClusterSerialNo(self):
return self._config_data["cluster"]["serial_no"]
+ def GetDefaultNicParams(self):
+ return self._config_data["cluster"]["nicparams"][constants.PP_DEFAULT]
+
+ def GetDefaultNicLink(self):
+ return self.GetDefaultNicParams()[constants.NIC_LINK]
+
def GetNodeStatusFlags(self, node):
"""Get a node's status flags
offline = self._config_data["nodes"][node]["offline"]
return master_candidate, drained, offline
+ def GetInstanceByLinkIp(self, ip, link):
+ if not link:
+ link = self.GetDefaultNicLink()
+ if not link in self._ip_to_inst_by_link:
+ return None
+ if not ip in self._ip_to_inst_by_link[link]:
+ return None
+ return self._ip_to_inst_by_link[link][ip]
+
+ def GetNodePrimaryIp(self, node):
+ """Get a node's primary ip
+
+ @type node: string
+ @param node: node name
+ @rtype: string, or None
+ @return: node's primary ip, or None if no such node
+
+ """
+ if node not in self._config_data["nodes"]:
+ return None
+ return self._config_data["nodes"][node]["primary_ip"]
+
+ def GetInstancePrimaryNode(self, instance):
+ """Get an instance's primary node
+
+ @type instance: string
+ @param instance: instance name
+ @rtype: string, or None
+ @return: primary node, or None if no such instance
+
+ """
+ if instance not in self._config_data["instances"]:
+ return None
+ return self._config_data["instances"][instance]["primary_node"]
+
+ def GetNodesPrimaryIps(self):
+ return self._nodes_primary_ips
+
+ def GetMasterCandidatesPrimaryIps(self):
+ return self._mc_primary_ips
+
+ def GetInstancesIps(self, link):
+ if not link:
+ link = self.GetDefaultNicLink()
+
+ if link in self._inst_ips_by_link:
+ return self._inst_ips_by_link[link]
+ else:
+ return []
+
class SimpleStore(object):
"""Interface to static cluster data.
if debug:
sys.stderr.write("Not master candidate, exiting.\n")
sys.exit(constants.EXIT_NOTCANDIDATE)
-