1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 """Global Configuration data for Ganeti.
23
24 This module provides the interface to a special case of cluster
25 configuration data, which is mostly static and available to all nodes.
26
27 """
28
29 import sys
30 import re
31 import os
32 import errno
33
34 from ganeti import errors
35 from ganeti import constants
36 from ganeti import utils
37 from ganeti import serializer
38 from ganeti import objects
39 from ganeti import netutils
40
41
42 SSCONF_LOCK_TIMEOUT = 10
43
44 RE_VALID_SSCONF_NAME = re.compile(r"^[-_a-z0-9]+$")
45
46
48 """Simple class to read configuration file.
49
50 """
52 """Initializes this class.
53
54 @type file_name: string
55 @param file_name: Configuration file path
56
57 """
58 self._file_name = file_name
59 self._last_inode = None
60 self._last_mtime = None
61 self._last_size = None
62
63 self._config_data = None
64 self._inst_ips_by_link = None
65 self._ip_to_inst_by_link = None
66 self._instances_ips = None
67 self._mc_primary_ips = None
68 self._nodes_primary_ips = None
69
70
71 self._Load(force=True)
72
73 - def _Load(self, force=False):
74 """Loads (or reloads) the config file.
75
76 @type force: boolean
77 @param force: whether to force the reload without checking the mtime
78 @rtype: boolean
79 @return: boolean value that says whether we reloaded the configuration or
80 not (because we decided it was already up-to-date)
81
82 """
83 try:
84 cfg_stat = os.stat(self._file_name)
85 except EnvironmentError, err:
86 raise errors.ConfigurationError("Cannot stat config file %s: %s" %
87 (self._file_name, err))
88 inode = cfg_stat.st_ino
89 mtime = cfg_stat.st_mtime
90 size = cfg_stat.st_size
91
92 if (force or inode != self._last_inode or
93 mtime > self._last_mtime or
94 size != self._last_size):
95 self._last_inode = inode
96 self._last_mtime = mtime
97 self._last_size = size
98 else:
99
100 return False
101
102 try:
103 self._config_data = serializer.Load(utils.ReadFile(self._file_name))
104 except EnvironmentError, err:
105 raise errors.ConfigurationError("Cannot read config file %s: %s" %
106 (self._file_name, err))
107 except ValueError, err:
108 raise errors.ConfigurationError("Cannot load config file %s: %s" %
109 (self._file_name, err))
110
111 self._ip_to_inst_by_link = {}
112 self._instances_ips = []
113 self._inst_ips_by_link = {}
114 c_nparams = self._config_data["cluster"]["nicparams"][constants.PP_DEFAULT]
115 for iname in self._config_data["instances"]:
116 instance = self._config_data["instances"][iname]
117 for nic in instance["nics"]:
118 if "ip" in nic and nic["ip"]:
119 params = objects.FillDict(c_nparams, nic["nicparams"])
120 if not params["link"] in self._inst_ips_by_link:
121 self._inst_ips_by_link[params["link"]] = []
122 self._ip_to_inst_by_link[params["link"]] = {}
123 self._ip_to_inst_by_link[params["link"]][nic["ip"]] = iname
124 self._inst_ips_by_link[params["link"]].append(nic["ip"])
125
126 self._nodes_primary_ips = []
127 self._mc_primary_ips = []
128 for node_name in self._config_data["nodes"]:
129 node = self._config_data["nodes"][node_name]
130 self._nodes_primary_ips.append(node["primary_ip"])
131 if node["master_candidate"]:
132 self._mc_primary_ips.append(node["primary_ip"])
133
134 return True
135
136
137
138 Reload = _Load
139
141 return self._config_data["cluster"]["cluster_name"]
142
144 return self._config_data["cluster"]["rsahostkeypub"]
145
147 return self._config_data["cluster"]["master_node"]
148
150 return self._config_data["cluster"]["master_ip"]
151
153 return self._config_data["cluster"]["master_netdev"]
154
156 return self._config_data["cluster"]["master_netmask"]
157
159 return self._config_data["cluster"]["file_storage_dir"]
160
162 return self._config_data["cluster"]["shared_file_storage_dir"]
163
165 return self._config_data["nodes"].keys()
166
168 return self._config_data["serial_no"]
169
171 return self._config_data["cluster"]["serial_no"]
172
175
178
180 """Get a node's status flags
181
182 @type node: string
183 @param node: node name
184 @rtype: (bool, bool, bool)
185 @return: (master_candidate, drained, offline) (or None if no such node)
186
187 """
188 if node not in self._config_data["nodes"]:
189 return None
190
191 master_candidate = self._config_data["nodes"][node]["master_candidate"]
192 drained = self._config_data["nodes"][node]["drained"]
193 offline = self._config_data["nodes"][node]["offline"]
194 return master_candidate, drained, offline
195
197 """Get instance name from its link and ip address.
198
199 @type ip: string
200 @param ip: ip address
201 @type link: string
202 @param link: nic link
203 @rtype: string
204 @return: instance name
205
206 """
207 if not link:
208 link = self.GetDefaultNicLink()
209 if not link in self._ip_to_inst_by_link:
210 return None
211 if not ip in self._ip_to_inst_by_link[link]:
212 return None
213 return self._ip_to_inst_by_link[link][ip]
214
216 """Get a node's primary ip
217
218 @type node: string
219 @param node: node name
220 @rtype: string, or None
221 @return: node's primary ip, or None if no such node
222
223 """
224 if node not in self._config_data["nodes"]:
225 return None
226 return self._config_data["nodes"][node]["primary_ip"]
227
229 """Get an instance's primary node
230
231 @type instance: string
232 @param instance: instance name
233 @rtype: string, or None
234 @return: primary node, or None if no such instance
235
236 """
237 if instance not in self._config_data["instances"]:
238 return None
239 return self._config_data["instances"][instance]["primary_node"]
240
242 return self._nodes_primary_ips
243
245 return self._mc_primary_ips
246
248 """Get list of nic ips connected to a certain link.
249
250 @type link: string
251 @param link: nic link
252 @rtype: list
253 @return: list of ips connected to that link
254
255 """
256 if not link:
257 link = self.GetDefaultNicLink()
258
259 if link in self._inst_ips_by_link:
260 return self._inst_ips_by_link[link]
261 else:
262 return []
263
264
266 """Interface to static cluster data.
267
268 This is different that the config.ConfigWriter and
269 SimpleConfigReader classes in that it holds data that will always be
270 present, even on nodes which don't have all the cluster data.
271
272 Other particularities of the datastore:
273 - keys are restricted to predefined values
274
275 """
276 _VALID_KEYS = (
277 constants.SS_CLUSTER_NAME,
278 constants.SS_CLUSTER_TAGS,
279 constants.SS_FILE_STORAGE_DIR,
280 constants.SS_SHARED_FILE_STORAGE_DIR,
281 constants.SS_MASTER_CANDIDATES,
282 constants.SS_MASTER_CANDIDATES_IPS,
283 constants.SS_MASTER_IP,
284 constants.SS_MASTER_NETDEV,
285 constants.SS_MASTER_NETMASK,
286 constants.SS_MASTER_NODE,
287 constants.SS_NODE_LIST,
288 constants.SS_NODE_PRIMARY_IPS,
289 constants.SS_NODE_SECONDARY_IPS,
290 constants.SS_OFFLINE_NODES,
291 constants.SS_ONLINE_NODES,
292 constants.SS_PRIMARY_IP_FAMILY,
293 constants.SS_INSTANCE_LIST,
294 constants.SS_RELEASE_VERSION,
295 constants.SS_HYPERVISOR_LIST,
296 constants.SS_MAINTAIN_NODE_HEALTH,
297 constants.SS_UID_POOL,
298 constants.SS_NODEGROUPS,
299 )
300 _MAX_SIZE = 131072
301
303 if cfg_location is None:
304 self._cfg_dir = constants.DATA_DIR
305 else:
306 self._cfg_dir = cfg_location
307
318
320 """Generic routine to read keys.
321
322 This will read the file which holds the value requested. Errors
323 will be changed into ConfigurationErrors.
324
325 """
326 filename = self.KeyToFilename(key)
327 try:
328 data = utils.ReadFile(filename, size=self._MAX_SIZE)
329 except EnvironmentError, err:
330 if err.errno == errno.ENOENT and default is not None:
331 return default
332 raise errors.ConfigurationError("Can't read from the ssconf file:"
333 " '%s'" % str(err))
334 data = data.rstrip("\n")
335 return data
336
359
361 """Return the list of all config files.
362
363 This is used for computing node replication data.
364
365 """
366 return [self.KeyToFilename(key) for key in self._VALID_KEYS]
367
373
379
385
393
401
407
413
424
430
438
446
454
462
470
478
480 """Return the value of the maintain_node_health option.
481
482 """
483 data = self._ReadFile(constants.SS_MAINTAIN_NODE_HEALTH)
484
485 return data == "True"
486
488 """Return the user-id pool definition string.
489
490 The separator character is a newline.
491
492 The return value can be parsed using uidpool.ParseUidPool()::
493
494 ss = ssconf.SimpleStore()
495 uid_pool = uidpool.ParseUidPool(ss.GetUidPool(), separator="\\n")
496
497 """
498 data = self._ReadFile(constants.SS_UID_POOL)
499 return data
500
511
512
514 """Get the master node and my own hostname.
515
516 This can be either used for a 'soft' check (compared to CheckMaster,
517 which exits) or just for computing both at the same time.
518
519 The function does not handle any errors, these should be handled in
520 the caller (errors.ConfigurationError, errors.ResolverError).
521
522 @param ss: either a sstore.SimpleConfigReader or a
523 sstore.SimpleStore instance
524 @rtype: tuple
525 @return: a tuple (master node name, my own name)
526
527 """
528 if ss is None:
529 ss = SimpleStore()
530 return ss.GetMasterNode(), netutils.Hostname.GetSysName()
531
532
553