Statistics
| Branch: | Tag: | Revision:

root / lib / config.py @ 33c730a2

History | View | Annotate | Download (85.3 kB)

1 2f31098c Iustin Pop
#
2 a8083063 Iustin Pop
#
3 a8083063 Iustin Pop
4 12378fe3 Iustin Pop
# Copyright (C) 2006, 2007, 2008, 2009, 2010, 2011, 2012 Google Inc.
5 a8083063 Iustin Pop
#
6 a8083063 Iustin Pop
# This program is free software; you can redistribute it and/or modify
7 a8083063 Iustin Pop
# it under the terms of the GNU General Public License as published by
8 a8083063 Iustin Pop
# the Free Software Foundation; either version 2 of the License, or
9 a8083063 Iustin Pop
# (at your option) any later version.
10 a8083063 Iustin Pop
#
11 a8083063 Iustin Pop
# This program is distributed in the hope that it will be useful, but
12 a8083063 Iustin Pop
# WITHOUT ANY WARRANTY; without even the implied warranty of
13 a8083063 Iustin Pop
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14 a8083063 Iustin Pop
# General Public License for more details.
15 a8083063 Iustin Pop
#
16 a8083063 Iustin Pop
# You should have received a copy of the GNU General Public License
17 a8083063 Iustin Pop
# along with this program; if not, write to the Free Software
18 a8083063 Iustin Pop
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19 a8083063 Iustin Pop
# 02110-1301, USA.
20 a8083063 Iustin Pop
21 a8083063 Iustin Pop
22 a8083063 Iustin Pop
"""Configuration management for Ganeti
23 a8083063 Iustin Pop

24 319856a9 Michael Hanselmann
This module provides the interface to the Ganeti cluster configuration.
25 a8083063 Iustin Pop

26 319856a9 Michael Hanselmann
The configuration data is stored on every node but is updated on the master
27 319856a9 Michael Hanselmann
only. After each update, the master distributes the data to the other nodes.
28 a8083063 Iustin Pop

29 319856a9 Michael Hanselmann
Currently, the data storage format is JSON. YAML was slow and consuming too
30 319856a9 Michael Hanselmann
much memory.
31 a8083063 Iustin Pop

32 a8083063 Iustin Pop
"""
33 a8083063 Iustin Pop
34 b459a848 Andrea Spadaccini
# pylint: disable=R0904
35 d367b66c Manuel Franceschini
# R0904: Too many public methods
36 d367b66c Manuel Franceschini
37 45f62156 Bernardo Dal Seno
import copy
38 a8083063 Iustin Pop
import os
39 a8083063 Iustin Pop
import random
40 d8470559 Michael Hanselmann
import logging
41 d693c864 Iustin Pop
import time
42 54c31fd3 Michael Hanselmann
import itertools
43 a8083063 Iustin Pop
44 a8083063 Iustin Pop
from ganeti import errors
45 f78ede4e Guido Trotter
from ganeti import locking
46 a8083063 Iustin Pop
from ganeti import utils
47 a8083063 Iustin Pop
from ganeti import constants
48 a8083063 Iustin Pop
from ganeti import rpc
49 a8083063 Iustin Pop
from ganeti import objects
50 8d14b30d Iustin Pop
from ganeti import serializer
51 0fbae49a Balazs Lecz
from ganeti import uidpool
52 a744b676 Manuel Franceschini
from ganeti import netutils
53 e60c73a1 René Nussbaumer
from ganeti import runtime
54 57407093 Michael Hanselmann
from ganeti import pathutils
55 6c0a75db Dimitris Aragiorgis
from ganeti import network
56 243cdbcc Michael Hanselmann
57 243cdbcc Michael Hanselmann
58 7f93570a Iustin Pop
_config_lock = locking.SharedLock("ConfigWriter")
59 f78ede4e Guido Trotter
60 4fae38c5 Guido Trotter
# job id used for resource management at config upgrade time
61 8d9c3bef Michael Hanselmann
_UPGRADE_CONFIG_JID = "jid-cfg-upgrade"
62 4fae38c5 Guido Trotter
63 f78ede4e Guido Trotter
64 5b263ed7 Michael Hanselmann
def _ValidateConfig(data):
65 c41eea6e Iustin Pop
  """Verifies that a configuration objects looks valid.
66 c41eea6e Iustin Pop

67 c41eea6e Iustin Pop
  This only verifies the version of the configuration.
68 c41eea6e Iustin Pop

69 c41eea6e Iustin Pop
  @raise errors.ConfigurationError: if the version differs from what
70 c41eea6e Iustin Pop
      we expect
71 c41eea6e Iustin Pop

72 c41eea6e Iustin Pop
  """
73 5b263ed7 Michael Hanselmann
  if data.version != constants.CONFIG_VERSION:
74 4b63dc7a Iustin Pop
    raise errors.ConfigVersionMismatch(constants.CONFIG_VERSION, data.version)
75 a8083063 Iustin Pop
76 319856a9 Michael Hanselmann
77 013da361 Guido Trotter
class TemporaryReservationManager:
78 013da361 Guido Trotter
  """A temporary resource reservation manager.
79 013da361 Guido Trotter

80 013da361 Guido Trotter
  This is used to reserve resources in a job, before using them, making sure
81 013da361 Guido Trotter
  other jobs cannot get them in the meantime.
82 013da361 Guido Trotter

83 013da361 Guido Trotter
  """
84 013da361 Guido Trotter
  def __init__(self):
85 013da361 Guido Trotter
    self._ec_reserved = {}
86 013da361 Guido Trotter
87 013da361 Guido Trotter
  def Reserved(self, resource):
88 a7359d91 David Knowles
    for holder_reserved in self._ec_reserved.values():
89 013da361 Guido Trotter
      if resource in holder_reserved:
90 013da361 Guido Trotter
        return True
91 013da361 Guido Trotter
    return False
92 013da361 Guido Trotter
93 013da361 Guido Trotter
  def Reserve(self, ec_id, resource):
94 013da361 Guido Trotter
    if self.Reserved(resource):
95 28a7318f Iustin Pop
      raise errors.ReservationError("Duplicate reservation for resource '%s'"
96 28a7318f Iustin Pop
                                    % str(resource))
97 013da361 Guido Trotter
    if ec_id not in self._ec_reserved:
98 013da361 Guido Trotter
      self._ec_reserved[ec_id] = set([resource])
99 013da361 Guido Trotter
    else:
100 013da361 Guido Trotter
      self._ec_reserved[ec_id].add(resource)
101 013da361 Guido Trotter
102 013da361 Guido Trotter
  def DropECReservations(self, ec_id):
103 013da361 Guido Trotter
    if ec_id in self._ec_reserved:
104 013da361 Guido Trotter
      del self._ec_reserved[ec_id]
105 013da361 Guido Trotter
106 013da361 Guido Trotter
  def GetReserved(self):
107 013da361 Guido Trotter
    all_reserved = set()
108 013da361 Guido Trotter
    for holder_reserved in self._ec_reserved.values():
109 013da361 Guido Trotter
      all_reserved.update(holder_reserved)
110 013da361 Guido Trotter
    return all_reserved
111 013da361 Guido Trotter
112 ad4a9ae7 Dimitris Aragiorgis
  def GetECReserved(self, ec_id):
113 7f033fb3 Dimitris Aragiorgis
    """ Used when you want to retrieve all reservations for a specific
114 7f033fb3 Dimitris Aragiorgis
        execution context. E.g when commiting reserved IPs for a specific
115 7f033fb3 Dimitris Aragiorgis
        network.
116 7f033fb3 Dimitris Aragiorgis

117 7f033fb3 Dimitris Aragiorgis
    """
118 ad4a9ae7 Dimitris Aragiorgis
    ec_reserved = set()
119 ad4a9ae7 Dimitris Aragiorgis
    if ec_id in self._ec_reserved:
120 ad4a9ae7 Dimitris Aragiorgis
      ec_reserved.update(self._ec_reserved[ec_id])
121 ad4a9ae7 Dimitris Aragiorgis
    return ec_reserved
122 ad4a9ae7 Dimitris Aragiorgis
123 013da361 Guido Trotter
  def Generate(self, existing, generate_one_fn, ec_id):
124 013da361 Guido Trotter
    """Generate a new resource of this type
125 013da361 Guido Trotter

126 013da361 Guido Trotter
    """
127 013da361 Guido Trotter
    assert callable(generate_one_fn)
128 013da361 Guido Trotter
129 013da361 Guido Trotter
    all_elems = self.GetReserved()
130 013da361 Guido Trotter
    all_elems.update(existing)
131 013da361 Guido Trotter
    retries = 64
132 013da361 Guido Trotter
    while retries > 0:
133 013da361 Guido Trotter
      new_resource = generate_one_fn()
134 013da361 Guido Trotter
      if new_resource is not None and new_resource not in all_elems:
135 013da361 Guido Trotter
        break
136 013da361 Guido Trotter
    else:
137 013da361 Guido Trotter
      raise errors.ConfigurationError("Not able generate new resource"
138 013da361 Guido Trotter
                                      " (last tried: %s)" % new_resource)
139 013da361 Guido Trotter
    self.Reserve(ec_id, new_resource)
140 013da361 Guido Trotter
    return new_resource
141 013da361 Guido Trotter
142 013da361 Guido Trotter
143 fe698b38 Michael Hanselmann
def _MatchNameComponentIgnoreCase(short_name, names):
144 3a93eebb Michael Hanselmann
  """Wrapper around L{utils.text.MatchNameComponent}.
145 fe698b38 Michael Hanselmann

146 fe698b38 Michael Hanselmann
  """
147 fe698b38 Michael Hanselmann
  return utils.MatchNameComponent(short_name, names, case_sensitive=False)
148 fe698b38 Michael Hanselmann
149 fe698b38 Michael Hanselmann
150 82c54b5b Michael Hanselmann
def _CheckInstanceDiskIvNames(disks):
151 82c54b5b Michael Hanselmann
  """Checks if instance's disks' C{iv_name} attributes are in order.
152 82c54b5b Michael Hanselmann

153 82c54b5b Michael Hanselmann
  @type disks: list of L{objects.Disk}
154 82c54b5b Michael Hanselmann
  @param disks: List of disks
155 82c54b5b Michael Hanselmann
  @rtype: list of tuples; (int, string, string)
156 82c54b5b Michael Hanselmann
  @return: List of wrongly named disks, each tuple contains disk index,
157 82c54b5b Michael Hanselmann
    expected and actual name
158 82c54b5b Michael Hanselmann

159 82c54b5b Michael Hanselmann
  """
160 82c54b5b Michael Hanselmann
  result = []
161 82c54b5b Michael Hanselmann
162 82c54b5b Michael Hanselmann
  for (idx, disk) in enumerate(disks):
163 82c54b5b Michael Hanselmann
    exp_iv_name = "disk/%s" % idx
164 82c54b5b Michael Hanselmann
    if disk.iv_name != exp_iv_name:
165 82c54b5b Michael Hanselmann
      result.append((idx, exp_iv_name, disk.iv_name))
166 82c54b5b Michael Hanselmann
167 82c54b5b Michael Hanselmann
  return result
168 82c54b5b Michael Hanselmann
169 3c286190 Dimitris Aragiorgis
170 a8083063 Iustin Pop
class ConfigWriter:
171 098c0958 Michael Hanselmann
  """The interface to the cluster configuration.
172 a8083063 Iustin Pop

173 d8aee57e Iustin Pop
  @ivar _temporary_lvs: reservation manager for temporary LVs
174 d8aee57e Iustin Pop
  @ivar _all_rms: a list of all temporary reservation managers
175 d8aee57e Iustin Pop

176 098c0958 Michael Hanselmann
  """
177 eb180fe2 Iustin Pop
  def __init__(self, cfg_file=None, offline=False, _getents=runtime.GetEnts,
178 eb180fe2 Iustin Pop
               accept_foreign=False):
179 14e15659 Iustin Pop
    self.write_count = 0
180 f78ede4e Guido Trotter
    self._lock = _config_lock
181 a8083063 Iustin Pop
    self._config_data = None
182 a8083063 Iustin Pop
    self._offline = offline
183 a8083063 Iustin Pop
    if cfg_file is None:
184 57407093 Michael Hanselmann
      self._cfg_file = pathutils.CLUSTER_CONF_FILE
185 a8083063 Iustin Pop
    else:
186 a8083063 Iustin Pop
      self._cfg_file = cfg_file
187 e60c73a1 René Nussbaumer
    self._getents = _getents
188 4fae38c5 Guido Trotter
    self._temporary_ids = TemporaryReservationManager()
189 a81c53c9 Iustin Pop
    self._temporary_drbds = {}
190 36b66e6e Guido Trotter
    self._temporary_macs = TemporaryReservationManager()
191 afa1386e Guido Trotter
    self._temporary_secrets = TemporaryReservationManager()
192 d8aee57e Iustin Pop
    self._temporary_lvs = TemporaryReservationManager()
193 ad4a9ae7 Dimitris Aragiorgis
    self._temporary_ips = TemporaryReservationManager()
194 d8aee57e Iustin Pop
    self._all_rms = [self._temporary_ids, self._temporary_macs,
195 ad4a9ae7 Dimitris Aragiorgis
                     self._temporary_secrets, self._temporary_lvs,
196 ad4a9ae7 Dimitris Aragiorgis
                     self._temporary_ips]
197 89e1fc26 Iustin Pop
    # Note: in order to prevent errors when resolving our name in
198 89e1fc26 Iustin Pop
    # _DistributeConfig, we compute it here once and reuse it; it's
199 89e1fc26 Iustin Pop
    # better to raise an error before starting to modify the config
200 89e1fc26 Iustin Pop
    # file than after it was modified
201 b705c7a6 Manuel Franceschini
    self._my_hostname = netutils.Hostname.GetSysName()
202 3c7f6c44 Iustin Pop
    self._last_cluster_serial = -1
203 bd407597 Iustin Pop
    self._cfg_id = None
204 b2acdbdc Michael Hanselmann
    self._context = None
205 eb180fe2 Iustin Pop
    self._OpenConfig(accept_foreign)
206 a8083063 Iustin Pop
207 b2acdbdc Michael Hanselmann
  def _GetRpc(self, address_list):
208 b2acdbdc Michael Hanselmann
    """Returns RPC runner for configuration.
209 b2acdbdc Michael Hanselmann

210 b2acdbdc Michael Hanselmann
    """
211 b2acdbdc Michael Hanselmann
    return rpc.ConfigRunner(self._context, address_list)
212 b2acdbdc Michael Hanselmann
213 b2acdbdc Michael Hanselmann
  def SetContext(self, context):
214 b2acdbdc Michael Hanselmann
    """Sets Ganeti context.
215 b2acdbdc Michael Hanselmann

216 b2acdbdc Michael Hanselmann
    """
217 b2acdbdc Michael Hanselmann
    self._context = context
218 b2acdbdc Michael Hanselmann
219 a8083063 Iustin Pop
  # this method needs to be static, so that we can call it on the class
220 a8083063 Iustin Pop
  @staticmethod
221 a8083063 Iustin Pop
  def IsCluster():
222 a8083063 Iustin Pop
    """Check if the cluster is configured.
223 a8083063 Iustin Pop

224 a8083063 Iustin Pop
    """
225 57407093 Michael Hanselmann
    return os.path.exists(pathutils.CLUSTER_CONF_FILE)
226 a8083063 Iustin Pop
227 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
228 5768e6a6 René Nussbaumer
  def GetNdParams(self, node):
229 5768e6a6 René Nussbaumer
    """Get the node params populated with cluster defaults.
230 5768e6a6 René Nussbaumer

231 ce523de1 Michael Hanselmann
    @type node: L{objects.Node}
232 5768e6a6 René Nussbaumer
    @param node: The node we want to know the params for
233 5768e6a6 René Nussbaumer
    @return: A dict with the filled in node params
234 5768e6a6 René Nussbaumer

235 5768e6a6 René Nussbaumer
    """
236 5768e6a6 René Nussbaumer
    nodegroup = self._UnlockedGetNodeGroup(node.group)
237 5768e6a6 René Nussbaumer
    return self._config_data.cluster.FillND(node, nodegroup)
238 5768e6a6 René Nussbaumer
239 5768e6a6 René Nussbaumer
  @locking.ssynchronized(_config_lock, shared=1)
240 8a147bba René Nussbaumer
  def GetInstanceDiskParams(self, instance):
241 8a147bba René Nussbaumer
    """Get the disk params populated with inherit chain.
242 8a147bba René Nussbaumer

243 8a147bba René Nussbaumer
    @type instance: L{objects.Instance}
244 8a147bba René Nussbaumer
    @param instance: The instance we want to know the params for
245 8a147bba René Nussbaumer
    @return: A dict with the filled in disk params
246 8a147bba René Nussbaumer

247 8a147bba René Nussbaumer
    """
248 8a147bba René Nussbaumer
    node = self._UnlockedGetNodeInfo(instance.primary_node)
249 8a147bba René Nussbaumer
    nodegroup = self._UnlockedGetNodeGroup(node.group)
250 99ccf8b9 René Nussbaumer
    return self._UnlockedGetGroupDiskParams(nodegroup)
251 99ccf8b9 René Nussbaumer
252 99ccf8b9 René Nussbaumer
  @locking.ssynchronized(_config_lock, shared=1)
253 99ccf8b9 René Nussbaumer
  def GetGroupDiskParams(self, group):
254 99ccf8b9 René Nussbaumer
    """Get the disk params populated with inherit chain.
255 99ccf8b9 René Nussbaumer

256 af9fb4cc René Nussbaumer
    @type group: L{objects.NodeGroup}
257 99ccf8b9 René Nussbaumer
    @param group: The group we want to know the params for
258 99ccf8b9 René Nussbaumer
    @return: A dict with the filled in disk params
259 99ccf8b9 René Nussbaumer

260 99ccf8b9 René Nussbaumer
    """
261 99ccf8b9 René Nussbaumer
    return self._UnlockedGetGroupDiskParams(group)
262 99ccf8b9 René Nussbaumer
263 99ccf8b9 René Nussbaumer
  def _UnlockedGetGroupDiskParams(self, group):
264 99ccf8b9 René Nussbaumer
    """Get the disk params populated with inherit chain down to node-group.
265 99ccf8b9 René Nussbaumer

266 af9fb4cc René Nussbaumer
    @type group: L{objects.NodeGroup}
267 99ccf8b9 René Nussbaumer
    @param group: The group we want to know the params for
268 99ccf8b9 René Nussbaumer
    @return: A dict with the filled in disk params
269 99ccf8b9 René Nussbaumer

270 99ccf8b9 René Nussbaumer
    """
271 99ccf8b9 René Nussbaumer
    return self._config_data.cluster.SimpleFillDP(group.diskparams)
272 8a147bba René Nussbaumer
273 9ccacbc8 Dimitris Aragiorgis
  def _UnlockedGetNetworkMACPrefix(self, net_uuid):
274 032a7d71 Dimitris Aragiorgis
    """Return the network mac prefix if it exists or the cluster level default.
275 032a7d71 Dimitris Aragiorgis

276 032a7d71 Dimitris Aragiorgis
    """
277 032a7d71 Dimitris Aragiorgis
    prefix = None
278 9ccacbc8 Dimitris Aragiorgis
    if net_uuid:
279 1b68f268 Helga Velroyen
      nobj = self._UnlockedGetNetwork(net_uuid)
280 1b68f268 Helga Velroyen
      if nobj.mac_prefix:
281 1b68f268 Helga Velroyen
        prefix = nobj.mac_prefix
282 032a7d71 Dimitris Aragiorgis
283 032a7d71 Dimitris Aragiorgis
    return prefix
284 032a7d71 Dimitris Aragiorgis
285 032a7d71 Dimitris Aragiorgis
  def _GenerateOneMAC(self, prefix=None):
286 032a7d71 Dimitris Aragiorgis
    """Return a function that randomly generates a MAC suffic
287 032a7d71 Dimitris Aragiorgis
       and appends it to the given prefix. If prefix is not given get
288 032a7d71 Dimitris Aragiorgis
       the cluster level default.
289 032a7d71 Dimitris Aragiorgis

290 032a7d71 Dimitris Aragiorgis
    """
291 032a7d71 Dimitris Aragiorgis
    if not prefix:
292 032a7d71 Dimitris Aragiorgis
      prefix = self._config_data.cluster.mac_prefix
293 032a7d71 Dimitris Aragiorgis
294 032a7d71 Dimitris Aragiorgis
    def GenMac():
295 032a7d71 Dimitris Aragiorgis
      byte1 = random.randrange(0, 256)
296 032a7d71 Dimitris Aragiorgis
      byte2 = random.randrange(0, 256)
297 032a7d71 Dimitris Aragiorgis
      byte3 = random.randrange(0, 256)
298 032a7d71 Dimitris Aragiorgis
      mac = "%s:%02x:%02x:%02x" % (prefix, byte1, byte2, byte3)
299 032a7d71 Dimitris Aragiorgis
      return mac
300 032a7d71 Dimitris Aragiorgis
301 032a7d71 Dimitris Aragiorgis
    return GenMac
302 032a7d71 Dimitris Aragiorgis
303 8a147bba René Nussbaumer
  @locking.ssynchronized(_config_lock, shared=1)
304 9ccacbc8 Dimitris Aragiorgis
  def GenerateMAC(self, net_uuid, ec_id):
305 a8083063 Iustin Pop
    """Generate a MAC for an instance.
306 a8083063 Iustin Pop

307 a8083063 Iustin Pop
    This should check the current instances for duplicates.
308 a8083063 Iustin Pop

309 a8083063 Iustin Pop
    """
310 36b66e6e Guido Trotter
    existing = self._AllMACs()
311 9ccacbc8 Dimitris Aragiorgis
    prefix = self._UnlockedGetNetworkMACPrefix(net_uuid)
312 032a7d71 Dimitris Aragiorgis
    gen_mac = self._GenerateOneMAC(prefix)
313 a0af6c80 Dimitris Aragiorgis
    return self._temporary_ids.Generate(existing, gen_mac, ec_id)
314 a8083063 Iustin Pop
315 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
316 36b66e6e Guido Trotter
  def ReserveMAC(self, mac, ec_id):
317 36b66e6e Guido Trotter
    """Reserve a MAC for an instance.
318 1862d460 Alexander Schreiber

319 1862d460 Alexander Schreiber
    This only checks instances managed by this cluster, it does not
320 1862d460 Alexander Schreiber
    check for potential collisions elsewhere.
321 1862d460 Alexander Schreiber

322 1862d460 Alexander Schreiber
    """
323 1862d460 Alexander Schreiber
    all_macs = self._AllMACs()
324 36b66e6e Guido Trotter
    if mac in all_macs:
325 36b66e6e Guido Trotter
      raise errors.ReservationError("mac already in use")
326 36b66e6e Guido Trotter
    else:
327 8785b71b Apollon Oikonomopoulos
      self._temporary_macs.Reserve(ec_id, mac)
328 1862d460 Alexander Schreiber
329 ad4a9ae7 Dimitris Aragiorgis
  def _UnlockedCommitTemporaryIps(self, ec_id):
330 ad4a9ae7 Dimitris Aragiorgis
    """Commit all reserved IP address to their respective pools
331 ad4a9ae7 Dimitris Aragiorgis

332 ad4a9ae7 Dimitris Aragiorgis
    """
333 ad4a9ae7 Dimitris Aragiorgis
    for action, address, net_uuid in self._temporary_ips.GetECReserved(ec_id):
334 ad4a9ae7 Dimitris Aragiorgis
      self._UnlockedCommitIp(action, net_uuid, address)
335 ad4a9ae7 Dimitris Aragiorgis
336 ad4a9ae7 Dimitris Aragiorgis
  def _UnlockedCommitIp(self, action, net_uuid, address):
337 ad4a9ae7 Dimitris Aragiorgis
    """Commit a reserved IP address to an IP pool.
338 ad4a9ae7 Dimitris Aragiorgis

339 ad4a9ae7 Dimitris Aragiorgis
    The IP address is taken from the network's IP pool and marked as reserved.
340 ad4a9ae7 Dimitris Aragiorgis

341 ad4a9ae7 Dimitris Aragiorgis
    """
342 ad4a9ae7 Dimitris Aragiorgis
    nobj = self._UnlockedGetNetwork(net_uuid)
343 ad4a9ae7 Dimitris Aragiorgis
    pool = network.AddressPool(nobj)
344 e81eef56 Dimitris Aragiorgis
    if action == constants.RESERVE_ACTION:
345 ad4a9ae7 Dimitris Aragiorgis
      pool.Reserve(address)
346 e81eef56 Dimitris Aragiorgis
    elif action == constants.RELEASE_ACTION:
347 ad4a9ae7 Dimitris Aragiorgis
      pool.Release(address)
348 ad4a9ae7 Dimitris Aragiorgis
349 ad4a9ae7 Dimitris Aragiorgis
  def _UnlockedReleaseIp(self, net_uuid, address, ec_id):
350 ad4a9ae7 Dimitris Aragiorgis
    """Give a specific IP address back to an IP pool.
351 ad4a9ae7 Dimitris Aragiorgis

352 ad4a9ae7 Dimitris Aragiorgis
    The IP address is returned to the IP pool designated by pool_id and marked
353 ad4a9ae7 Dimitris Aragiorgis
    as reserved.
354 ad4a9ae7 Dimitris Aragiorgis

355 ad4a9ae7 Dimitris Aragiorgis
    """
356 e81eef56 Dimitris Aragiorgis
    self._temporary_ips.Reserve(ec_id,
357 e81eef56 Dimitris Aragiorgis
                                (constants.RELEASE_ACTION, address, net_uuid))
358 ad4a9ae7 Dimitris Aragiorgis
359 ad4a9ae7 Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
360 9ccacbc8 Dimitris Aragiorgis
  def ReleaseIp(self, net_uuid, address, ec_id):
361 ad4a9ae7 Dimitris Aragiorgis
    """Give a specified IP address back to an IP pool.
362 ad4a9ae7 Dimitris Aragiorgis

363 ad4a9ae7 Dimitris Aragiorgis
    This is just a wrapper around _UnlockedReleaseIp.
364 ad4a9ae7 Dimitris Aragiorgis

365 ad4a9ae7 Dimitris Aragiorgis
    """
366 9ccacbc8 Dimitris Aragiorgis
    if net_uuid:
367 9ccacbc8 Dimitris Aragiorgis
      self._UnlockedReleaseIp(net_uuid, address, ec_id)
368 ad4a9ae7 Dimitris Aragiorgis
369 ad4a9ae7 Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
370 9ccacbc8 Dimitris Aragiorgis
  def GenerateIp(self, net_uuid, ec_id):
371 ad4a9ae7 Dimitris Aragiorgis
    """Find a free IPv4 address for an instance.
372 ad4a9ae7 Dimitris Aragiorgis

373 ad4a9ae7 Dimitris Aragiorgis
    """
374 ad4a9ae7 Dimitris Aragiorgis
    nobj = self._UnlockedGetNetwork(net_uuid)
375 ad4a9ae7 Dimitris Aragiorgis
    pool = network.AddressPool(nobj)
376 ad4a9ae7 Dimitris Aragiorgis
377 ad4a9ae7 Dimitris Aragiorgis
    def gen_one():
378 ad4a9ae7 Dimitris Aragiorgis
      try:
379 1f1d3bf2 Dimitris Aragiorgis
        ip = pool.GenerateFree()
380 1f1d3bf2 Dimitris Aragiorgis
      except errors.AddressPoolError:
381 ad4a9ae7 Dimitris Aragiorgis
        raise errors.ReservationError("Cannot generate IP. Network is full")
382 e81eef56 Dimitris Aragiorgis
      return (constants.RESERVE_ACTION, ip, net_uuid)
383 ad4a9ae7 Dimitris Aragiorgis
384 beb81ea5 Dimitris Aragiorgis
    _, address, _ = self._temporary_ips.Generate([], gen_one, ec_id)
385 ad4a9ae7 Dimitris Aragiorgis
    return address
386 ad4a9ae7 Dimitris Aragiorgis
387 ad4a9ae7 Dimitris Aragiorgis
  def _UnlockedReserveIp(self, net_uuid, address, ec_id):
388 ad4a9ae7 Dimitris Aragiorgis
    """Reserve a given IPv4 address for use by an instance.
389 ad4a9ae7 Dimitris Aragiorgis

390 ad4a9ae7 Dimitris Aragiorgis
    """
391 ad4a9ae7 Dimitris Aragiorgis
    nobj = self._UnlockedGetNetwork(net_uuid)
392 ad4a9ae7 Dimitris Aragiorgis
    pool = network.AddressPool(nobj)
393 ad4a9ae7 Dimitris Aragiorgis
    try:
394 ad4a9ae7 Dimitris Aragiorgis
      isreserved = pool.IsReserved(address)
395 ad4a9ae7 Dimitris Aragiorgis
    except errors.AddressPoolError:
396 ad4a9ae7 Dimitris Aragiorgis
      raise errors.ReservationError("IP address not in network")
397 ad4a9ae7 Dimitris Aragiorgis
    if isreserved:
398 ad4a9ae7 Dimitris Aragiorgis
      raise errors.ReservationError("IP address already in use")
399 ad4a9ae7 Dimitris Aragiorgis
400 e81eef56 Dimitris Aragiorgis
    return self._temporary_ips.Reserve(ec_id,
401 e81eef56 Dimitris Aragiorgis
                                       (constants.RESERVE_ACTION,
402 e81eef56 Dimitris Aragiorgis
                                        address, net_uuid))
403 ad4a9ae7 Dimitris Aragiorgis
404 ad4a9ae7 Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
405 9ccacbc8 Dimitris Aragiorgis
  def ReserveIp(self, net_uuid, address, ec_id):
406 ad4a9ae7 Dimitris Aragiorgis
    """Reserve a given IPv4 address for use by an instance.
407 ad4a9ae7 Dimitris Aragiorgis

408 ad4a9ae7 Dimitris Aragiorgis
    """
409 9ccacbc8 Dimitris Aragiorgis
    if net_uuid:
410 9ccacbc8 Dimitris Aragiorgis
      return self._UnlockedReserveIp(net_uuid, address, ec_id)
411 ad4a9ae7 Dimitris Aragiorgis
412 f9518d38 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
413 d8aee57e Iustin Pop
  def ReserveLV(self, lv_name, ec_id):
414 d8aee57e Iustin Pop
    """Reserve an VG/LV pair for an instance.
415 d8aee57e Iustin Pop

416 d8aee57e Iustin Pop
    @type lv_name: string
417 d8aee57e Iustin Pop
    @param lv_name: the logical volume name to reserve
418 d8aee57e Iustin Pop

419 d8aee57e Iustin Pop
    """
420 d8aee57e Iustin Pop
    all_lvs = self._AllLVs()
421 d8aee57e Iustin Pop
    if lv_name in all_lvs:
422 d8aee57e Iustin Pop
      raise errors.ReservationError("LV already in use")
423 d8aee57e Iustin Pop
    else:
424 8785b71b Apollon Oikonomopoulos
      self._temporary_lvs.Reserve(ec_id, lv_name)
425 d8aee57e Iustin Pop
426 d8aee57e Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
427 afa1386e Guido Trotter
  def GenerateDRBDSecret(self, ec_id):
428 f9518d38 Iustin Pop
    """Generate a DRBD secret.
429 f9518d38 Iustin Pop

430 f9518d38 Iustin Pop
    This checks the current disks for duplicates.
431 f9518d38 Iustin Pop

432 f9518d38 Iustin Pop
    """
433 afa1386e Guido Trotter
    return self._temporary_secrets.Generate(self._AllDRBDSecrets(),
434 afa1386e Guido Trotter
                                            utils.GenerateSecret,
435 afa1386e Guido Trotter
                                            ec_id)
436 8d9c3bef Michael Hanselmann
437 34e54ebc Iustin Pop
  def _AllLVs(self):
438 923b1523 Iustin Pop
    """Compute the list of all LVs.
439 923b1523 Iustin Pop

440 923b1523 Iustin Pop
    """
441 923b1523 Iustin Pop
    lvnames = set()
442 923b1523 Iustin Pop
    for instance in self._config_data.instances.values():
443 923b1523 Iustin Pop
      node_data = instance.MapLVsByNode()
444 923b1523 Iustin Pop
      for lv_list in node_data.values():
445 923b1523 Iustin Pop
        lvnames.update(lv_list)
446 923b1523 Iustin Pop
    return lvnames
447 923b1523 Iustin Pop
448 34e54ebc Iustin Pop
  def _AllIDs(self, include_temporary):
449 34e54ebc Iustin Pop
    """Compute the list of all UUIDs and names we have.
450 34e54ebc Iustin Pop

451 34e54ebc Iustin Pop
    @type include_temporary: boolean
452 34e54ebc Iustin Pop
    @param include_temporary: whether to include the _temporary_ids set
453 34e54ebc Iustin Pop
    @rtype: set
454 34e54ebc Iustin Pop
    @return: a set of IDs
455 34e54ebc Iustin Pop

456 34e54ebc Iustin Pop
    """
457 34e54ebc Iustin Pop
    existing = set()
458 34e54ebc Iustin Pop
    if include_temporary:
459 4fae38c5 Guido Trotter
      existing.update(self._temporary_ids.GetReserved())
460 34e54ebc Iustin Pop
    existing.update(self._AllLVs())
461 34e54ebc Iustin Pop
    existing.update(self._config_data.instances.keys())
462 34e54ebc Iustin Pop
    existing.update(self._config_data.nodes.keys())
463 76d5d3a3 Iustin Pop
    existing.update([i.uuid for i in self._AllUUIDObjects() if i.uuid])
464 34e54ebc Iustin Pop
    return existing
465 34e54ebc Iustin Pop
466 4fae38c5 Guido Trotter
  def _GenerateUniqueID(self, ec_id):
467 430b923c Iustin Pop
    """Generate an unique UUID.
468 923b1523 Iustin Pop

469 923b1523 Iustin Pop
    This checks the current node, instances and disk names for
470 923b1523 Iustin Pop
    duplicates.
471 923b1523 Iustin Pop

472 c41eea6e Iustin Pop
    @rtype: string
473 c41eea6e Iustin Pop
    @return: the unique id
474 923b1523 Iustin Pop

475 923b1523 Iustin Pop
    """
476 4fae38c5 Guido Trotter
    existing = self._AllIDs(include_temporary=False)
477 4fae38c5 Guido Trotter
    return self._temporary_ids.Generate(existing, utils.NewUUID, ec_id)
478 923b1523 Iustin Pop
479 430b923c Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
480 4fae38c5 Guido Trotter
  def GenerateUniqueID(self, ec_id):
481 430b923c Iustin Pop
    """Generate an unique ID.
482 430b923c Iustin Pop

483 430b923c Iustin Pop
    This is just a wrapper over the unlocked version.
484 430b923c Iustin Pop

485 4fae38c5 Guido Trotter
    @type ec_id: string
486 4fae38c5 Guido Trotter
    @param ec_id: unique id for the job to reserve the id to
487 34d657ba Iustin Pop

488 34d657ba Iustin Pop
    """
489 4fae38c5 Guido Trotter
    return self._GenerateUniqueID(ec_id)
490 34d657ba Iustin Pop
491 a8083063 Iustin Pop
  def _AllMACs(self):
492 a8083063 Iustin Pop
    """Return all MACs present in the config.
493 a8083063 Iustin Pop

494 c41eea6e Iustin Pop
    @rtype: list
495 c41eea6e Iustin Pop
    @return: the list of all MACs
496 c41eea6e Iustin Pop

497 a8083063 Iustin Pop
    """
498 a8083063 Iustin Pop
    result = []
499 a8083063 Iustin Pop
    for instance in self._config_data.instances.values():
500 a8083063 Iustin Pop
      for nic in instance.nics:
501 a8083063 Iustin Pop
        result.append(nic.mac)
502 a8083063 Iustin Pop
503 a8083063 Iustin Pop
    return result
504 a8083063 Iustin Pop
505 f9518d38 Iustin Pop
  def _AllDRBDSecrets(self):
506 f9518d38 Iustin Pop
    """Return all DRBD secrets present in the config.
507 f9518d38 Iustin Pop

508 c41eea6e Iustin Pop
    @rtype: list
509 c41eea6e Iustin Pop
    @return: the list of all DRBD secrets
510 c41eea6e Iustin Pop

511 f9518d38 Iustin Pop
    """
512 f9518d38 Iustin Pop
    def helper(disk, result):
513 f9518d38 Iustin Pop
      """Recursively gather secrets from this disk."""
514 f9518d38 Iustin Pop
      if disk.dev_type == constants.DT_DRBD8:
515 f9518d38 Iustin Pop
        result.append(disk.logical_id[5])
516 f9518d38 Iustin Pop
      if disk.children:
517 f9518d38 Iustin Pop
        for child in disk.children:
518 f9518d38 Iustin Pop
          helper(child, result)
519 f9518d38 Iustin Pop
520 f9518d38 Iustin Pop
    result = []
521 f9518d38 Iustin Pop
    for instance in self._config_data.instances.values():
522 f9518d38 Iustin Pop
      for disk in instance.disks:
523 f9518d38 Iustin Pop
        helper(disk, result)
524 f9518d38 Iustin Pop
525 f9518d38 Iustin Pop
    return result
526 f9518d38 Iustin Pop
527 4b98ac29 Iustin Pop
  def _CheckDiskIDs(self, disk, l_ids, p_ids):
528 4b98ac29 Iustin Pop
    """Compute duplicate disk IDs
529 4b98ac29 Iustin Pop

530 4b98ac29 Iustin Pop
    @type disk: L{objects.Disk}
531 4b98ac29 Iustin Pop
    @param disk: the disk at which to start searching
532 4b98ac29 Iustin Pop
    @type l_ids: list
533 4b98ac29 Iustin Pop
    @param l_ids: list of current logical ids
534 4b98ac29 Iustin Pop
    @type p_ids: list
535 4b98ac29 Iustin Pop
    @param p_ids: list of current physical ids
536 4b98ac29 Iustin Pop
    @rtype: list
537 4b98ac29 Iustin Pop
    @return: a list of error messages
538 4b98ac29 Iustin Pop

539 4b98ac29 Iustin Pop
    """
540 4b98ac29 Iustin Pop
    result = []
541 25ae22e4 Iustin Pop
    if disk.logical_id is not None:
542 25ae22e4 Iustin Pop
      if disk.logical_id in l_ids:
543 25ae22e4 Iustin Pop
        result.append("duplicate logical id %s" % str(disk.logical_id))
544 25ae22e4 Iustin Pop
      else:
545 25ae22e4 Iustin Pop
        l_ids.append(disk.logical_id)
546 25ae22e4 Iustin Pop
    if disk.physical_id is not None:
547 25ae22e4 Iustin Pop
      if disk.physical_id in p_ids:
548 25ae22e4 Iustin Pop
        result.append("duplicate physical id %s" % str(disk.physical_id))
549 25ae22e4 Iustin Pop
      else:
550 25ae22e4 Iustin Pop
        p_ids.append(disk.physical_id)
551 4b98ac29 Iustin Pop
552 4b98ac29 Iustin Pop
    if disk.children:
553 4b98ac29 Iustin Pop
      for child in disk.children:
554 4b98ac29 Iustin Pop
        result.extend(self._CheckDiskIDs(child, l_ids, p_ids))
555 4b98ac29 Iustin Pop
    return result
556 4b98ac29 Iustin Pop
557 4a89c54a Iustin Pop
  def _UnlockedVerifyConfig(self):
558 a8efbb40 Iustin Pop
    """Verify function.
559 a8efbb40 Iustin Pop

560 4a89c54a Iustin Pop
    @rtype: list
561 4a89c54a Iustin Pop
    @return: a list of error messages; a non-empty list signifies
562 4a89c54a Iustin Pop
        configuration errors
563 4a89c54a Iustin Pop

564 a8083063 Iustin Pop
    """
565 b459a848 Andrea Spadaccini
    # pylint: disable=R0914
566 a8083063 Iustin Pop
    result = []
567 a8083063 Iustin Pop
    seen_macs = []
568 48ce9fd9 Iustin Pop
    ports = {}
569 a8083063 Iustin Pop
    data = self._config_data
570 7e01d204 Iustin Pop
    cluster = data.cluster
571 4b98ac29 Iustin Pop
    seen_lids = []
572 4b98ac29 Iustin Pop
    seen_pids = []
573 9a5fba23 Guido Trotter
574 9a5fba23 Guido Trotter
    # global cluster checks
575 7e01d204 Iustin Pop
    if not cluster.enabled_hypervisors:
576 9a5fba23 Guido Trotter
      result.append("enabled hypervisors list doesn't have any entries")
577 7e01d204 Iustin Pop
    invalid_hvs = set(cluster.enabled_hypervisors) - constants.HYPER_TYPES
578 9a5fba23 Guido Trotter
    if invalid_hvs:
579 9a5fba23 Guido Trotter
      result.append("enabled hypervisors contains invalid entries: %s" %
580 9a5fba23 Guido Trotter
                    invalid_hvs)
581 7e01d204 Iustin Pop
    missing_hvp = (set(cluster.enabled_hypervisors) -
582 7e01d204 Iustin Pop
                   set(cluster.hvparams.keys()))
583 9f3ac970 Iustin Pop
    if missing_hvp:
584 9f3ac970 Iustin Pop
      result.append("hypervisor parameters missing for the enabled"
585 9f3ac970 Iustin Pop
                    " hypervisor(s) %s" % utils.CommaJoin(missing_hvp))
586 9a5fba23 Guido Trotter
587 7e01d204 Iustin Pop
    if cluster.master_node not in data.nodes:
588 9a5fba23 Guido Trotter
      result.append("cluster has invalid primary node '%s'" %
589 7e01d204 Iustin Pop
                    cluster.master_node)
590 9a5fba23 Guido Trotter
591 26f2fd8d Iustin Pop
    def _helper(owner, attr, value, template):
592 26f2fd8d Iustin Pop
      try:
593 26f2fd8d Iustin Pop
        utils.ForceDictType(value, template)
594 26f2fd8d Iustin Pop
      except errors.GenericError, err:
595 26f2fd8d Iustin Pop
        result.append("%s has invalid %s: %s" % (owner, attr, err))
596 26f2fd8d Iustin Pop
597 26f2fd8d Iustin Pop
    def _helper_nic(owner, params):
598 26f2fd8d Iustin Pop
      try:
599 26f2fd8d Iustin Pop
        objects.NIC.CheckParameterSyntax(params)
600 26f2fd8d Iustin Pop
      except errors.ConfigurationError, err:
601 26f2fd8d Iustin Pop
        result.append("%s has invalid nicparams: %s" % (owner, err))
602 26f2fd8d Iustin Pop
603 8b057218 René Nussbaumer
    def _helper_ipolicy(owner, params, check_std):
604 918eb80b Agata Murawska
      try:
605 8b057218 René Nussbaumer
        objects.InstancePolicy.CheckParameterSyntax(params, check_std)
606 918eb80b Agata Murawska
      except errors.ConfigurationError, err:
607 918eb80b Agata Murawska
        result.append("%s has invalid instance policy: %s" % (owner, err))
608 918eb80b Agata Murawska
609 918eb80b Agata Murawska
    def _helper_ispecs(owner, params):
610 2cc673a3 Iustin Pop
      for key, value in params.items():
611 12378fe3 Iustin Pop
        if key in constants.IPOLICY_ISPECS:
612 2cc673a3 Iustin Pop
          fullkey = "ipolicy/" + key
613 2cc673a3 Iustin Pop
          _helper(owner, fullkey, value, constants.ISPECS_PARAMETER_TYPES)
614 2cc673a3 Iustin Pop
        else:
615 2cc673a3 Iustin Pop
          # FIXME: assuming list type
616 ff6c5e55 Iustin Pop
          if key in constants.IPOLICY_PARAMETERS:
617 ff6c5e55 Iustin Pop
            exp_type = float
618 ff6c5e55 Iustin Pop
          else:
619 ff6c5e55 Iustin Pop
            exp_type = list
620 ff6c5e55 Iustin Pop
          if not isinstance(value, exp_type):
621 2cc673a3 Iustin Pop
            result.append("%s has invalid instance policy: for %s,"
622 ff6c5e55 Iustin Pop
                          " expecting %s, got %s" %
623 ff6c5e55 Iustin Pop
                          (owner, key, exp_type.__name__, type(value)))
624 918eb80b Agata Murawska
625 26f2fd8d Iustin Pop
    # check cluster parameters
626 26f2fd8d Iustin Pop
    _helper("cluster", "beparams", cluster.SimpleFillBE({}),
627 26f2fd8d Iustin Pop
            constants.BES_PARAMETER_TYPES)
628 26f2fd8d Iustin Pop
    _helper("cluster", "nicparams", cluster.SimpleFillNIC({}),
629 26f2fd8d Iustin Pop
            constants.NICS_PARAMETER_TYPES)
630 26f2fd8d Iustin Pop
    _helper_nic("cluster", cluster.SimpleFillNIC({}))
631 26f2fd8d Iustin Pop
    _helper("cluster", "ndparams", cluster.SimpleFillND({}),
632 26f2fd8d Iustin Pop
            constants.NDS_PARAMETER_TYPES)
633 8b057218 René Nussbaumer
    _helper_ipolicy("cluster", cluster.SimpleFillIPolicy({}), True)
634 918eb80b Agata Murawska
    _helper_ispecs("cluster", cluster.SimpleFillIPolicy({}))
635 26f2fd8d Iustin Pop
636 9a5fba23 Guido Trotter
    # per-instance checks
637 a8083063 Iustin Pop
    for instance_name in data.instances:
638 a8083063 Iustin Pop
      instance = data.instances[instance_name]
639 81196341 Iustin Pop
      if instance.name != instance_name:
640 81196341 Iustin Pop
        result.append("instance '%s' is indexed by wrong name '%s'" %
641 81196341 Iustin Pop
                      (instance.name, instance_name))
642 a8083063 Iustin Pop
      if instance.primary_node not in data.nodes:
643 8522ceeb Iustin Pop
        result.append("instance '%s' has invalid primary node '%s'" %
644 a8083063 Iustin Pop
                      (instance_name, instance.primary_node))
645 a8083063 Iustin Pop
      for snode in instance.secondary_nodes:
646 a8083063 Iustin Pop
        if snode not in data.nodes:
647 8522ceeb Iustin Pop
          result.append("instance '%s' has invalid secondary node '%s'" %
648 a8083063 Iustin Pop
                        (instance_name, snode))
649 a8083063 Iustin Pop
      for idx, nic in enumerate(instance.nics):
650 a8083063 Iustin Pop
        if nic.mac in seen_macs:
651 8522ceeb Iustin Pop
          result.append("instance '%s' has NIC %d mac %s duplicate" %
652 a8083063 Iustin Pop
                        (instance_name, idx, nic.mac))
653 a8083063 Iustin Pop
        else:
654 a8083063 Iustin Pop
          seen_macs.append(nic.mac)
655 26f2fd8d Iustin Pop
        if nic.nicparams:
656 26f2fd8d Iustin Pop
          filled = cluster.SimpleFillNIC(nic.nicparams)
657 26f2fd8d Iustin Pop
          owner = "instance %s nic %d" % (instance.name, idx)
658 26f2fd8d Iustin Pop
          _helper(owner, "nicparams",
659 26f2fd8d Iustin Pop
                  filled, constants.NICS_PARAMETER_TYPES)
660 26f2fd8d Iustin Pop
          _helper_nic(owner, filled)
661 26f2fd8d Iustin Pop
662 26f2fd8d Iustin Pop
      # parameter checks
663 26f2fd8d Iustin Pop
      if instance.beparams:
664 26f2fd8d Iustin Pop
        _helper("instance %s" % instance.name, "beparams",
665 26f2fd8d Iustin Pop
                cluster.FillBE(instance), constants.BES_PARAMETER_TYPES)
666 48ce9fd9 Iustin Pop
667 48ce9fd9 Iustin Pop
      # gather the drbd ports for duplicate checks
668 e2569c1d Michael Hanselmann
      for (idx, dsk) in enumerate(instance.disks):
669 48ce9fd9 Iustin Pop
        if dsk.dev_type in constants.LDS_DRBD:
670 48ce9fd9 Iustin Pop
          tcp_port = dsk.logical_id[2]
671 48ce9fd9 Iustin Pop
          if tcp_port not in ports:
672 48ce9fd9 Iustin Pop
            ports[tcp_port] = []
673 e2569c1d Michael Hanselmann
          ports[tcp_port].append((instance.name, "drbd disk %s" % idx))
674 48ce9fd9 Iustin Pop
      # gather network port reservation
675 48ce9fd9 Iustin Pop
      net_port = getattr(instance, "network_port", None)
676 48ce9fd9 Iustin Pop
      if net_port is not None:
677 48ce9fd9 Iustin Pop
        if net_port not in ports:
678 48ce9fd9 Iustin Pop
          ports[net_port] = []
679 48ce9fd9 Iustin Pop
        ports[net_port].append((instance.name, "network port"))
680 48ce9fd9 Iustin Pop
681 332d0e37 Iustin Pop
      # instance disk verify
682 332d0e37 Iustin Pop
      for idx, disk in enumerate(instance.disks):
683 332d0e37 Iustin Pop
        result.extend(["instance '%s' disk %d error: %s" %
684 332d0e37 Iustin Pop
                       (instance.name, idx, msg) for msg in disk.Verify()])
685 4b98ac29 Iustin Pop
        result.extend(self._CheckDiskIDs(disk, seen_lids, seen_pids))
686 332d0e37 Iustin Pop
687 82c54b5b Michael Hanselmann
      wrong_names = _CheckInstanceDiskIvNames(instance.disks)
688 82c54b5b Michael Hanselmann
      if wrong_names:
689 82c54b5b Michael Hanselmann
        tmp = "; ".join(("name of disk %s should be '%s', but is '%s'" %
690 82c54b5b Michael Hanselmann
                         (idx, exp_name, actual_name))
691 82c54b5b Michael Hanselmann
                        for (idx, exp_name, actual_name) in wrong_names)
692 82c54b5b Michael Hanselmann
693 82c54b5b Michael Hanselmann
        result.append("Instance '%s' has wrongly named disks: %s" %
694 82c54b5b Michael Hanselmann
                      (instance.name, tmp))
695 82c54b5b Michael Hanselmann
696 48ce9fd9 Iustin Pop
    # cluster-wide pool of free ports
697 7e01d204 Iustin Pop
    for free_port in cluster.tcpudp_port_pool:
698 48ce9fd9 Iustin Pop
      if free_port not in ports:
699 48ce9fd9 Iustin Pop
        ports[free_port] = []
700 48ce9fd9 Iustin Pop
      ports[free_port].append(("cluster", "port marked as free"))
701 48ce9fd9 Iustin Pop
702 48ce9fd9 Iustin Pop
    # compute tcp/udp duplicate ports
703 48ce9fd9 Iustin Pop
    keys = ports.keys()
704 48ce9fd9 Iustin Pop
    keys.sort()
705 48ce9fd9 Iustin Pop
    for pnum in keys:
706 48ce9fd9 Iustin Pop
      pdata = ports[pnum]
707 48ce9fd9 Iustin Pop
      if len(pdata) > 1:
708 1f864b60 Iustin Pop
        txt = utils.CommaJoin(["%s/%s" % val for val in pdata])
709 48ce9fd9 Iustin Pop
        result.append("tcp/udp port %s has duplicates: %s" % (pnum, txt))
710 48ce9fd9 Iustin Pop
711 48ce9fd9 Iustin Pop
    # highest used tcp port check
712 48ce9fd9 Iustin Pop
    if keys:
713 7e01d204 Iustin Pop
      if keys[-1] > cluster.highest_used_port:
714 48ce9fd9 Iustin Pop
        result.append("Highest used port mismatch, saved %s, computed %s" %
715 7e01d204 Iustin Pop
                      (cluster.highest_used_port, keys[-1]))
716 a8efbb40 Iustin Pop
717 7e01d204 Iustin Pop
    if not data.nodes[cluster.master_node].master_candidate:
718 3a26773f Iustin Pop
      result.append("Master node is not a master candidate")
719 3a26773f Iustin Pop
720 4a89c54a Iustin Pop
    # master candidate checks
721 e623dbe3 Guido Trotter
    mc_now, mc_max, _ = self._UnlockedGetMasterCandidateStats()
722 ec0292f1 Iustin Pop
    if mc_now < mc_max:
723 ec0292f1 Iustin Pop
      result.append("Not enough master candidates: actual %d, target %d" %
724 ec0292f1 Iustin Pop
                    (mc_now, mc_max))
725 48ce9fd9 Iustin Pop
726 5bf07049 Iustin Pop
    # node checks
727 81196341 Iustin Pop
    for node_name, node in data.nodes.items():
728 81196341 Iustin Pop
      if node.name != node_name:
729 81196341 Iustin Pop
        result.append("Node '%s' is indexed by wrong name '%s'" %
730 81196341 Iustin Pop
                      (node.name, node_name))
731 5bf07049 Iustin Pop
      if [node.master_candidate, node.drained, node.offline].count(True) > 1:
732 5bf07049 Iustin Pop
        result.append("Node %s state is invalid: master_candidate=%s,"
733 5bf07049 Iustin Pop
                      " drain=%s, offline=%s" %
734 3d889a7d Michael Hanselmann
                      (node.name, node.master_candidate, node.drained,
735 5bf07049 Iustin Pop
                       node.offline))
736 26f2fd8d Iustin Pop
      if node.group not in data.nodegroups:
737 26f2fd8d Iustin Pop
        result.append("Node '%s' has invalid group '%s'" %
738 26f2fd8d Iustin Pop
                      (node.name, node.group))
739 26f2fd8d Iustin Pop
      else:
740 26f2fd8d Iustin Pop
        _helper("node %s" % node.name, "ndparams",
741 26f2fd8d Iustin Pop
                cluster.FillND(node, data.nodegroups[node.group]),
742 26f2fd8d Iustin Pop
                constants.NDS_PARAMETER_TYPES)
743 3697def0 Bernardo Dal Seno
      used_globals = constants.NDC_GLOBALS.intersection(node.ndparams)
744 3697def0 Bernardo Dal Seno
      if used_globals:
745 3697def0 Bernardo Dal Seno
        result.append("Node '%s' has some global parameters set: %s" %
746 3697def0 Bernardo Dal Seno
                      (node.name, utils.CommaJoin(used_globals)))
747 5bf07049 Iustin Pop
748 6520ba14 Guido Trotter
    # nodegroups checks
749 ace16501 Guido Trotter
    nodegroups_names = set()
750 6520ba14 Guido Trotter
    for nodegroup_uuid in data.nodegroups:
751 6520ba14 Guido Trotter
      nodegroup = data.nodegroups[nodegroup_uuid]
752 6520ba14 Guido Trotter
      if nodegroup.uuid != nodegroup_uuid:
753 913cc25e Adeodato Simo
        result.append("node group '%s' (uuid: '%s') indexed by wrong uuid '%s'"
754 6520ba14 Guido Trotter
                      % (nodegroup.name, nodegroup.uuid, nodegroup_uuid))
755 485ba212 Guido Trotter
      if utils.UUID_RE.match(nodegroup.name.lower()):
756 913cc25e Adeodato Simo
        result.append("node group '%s' (uuid: '%s') has uuid-like name" %
757 485ba212 Guido Trotter
                      (nodegroup.name, nodegroup.uuid))
758 ace16501 Guido Trotter
      if nodegroup.name in nodegroups_names:
759 913cc25e Adeodato Simo
        result.append("duplicate node group name '%s'" % nodegroup.name)
760 ace16501 Guido Trotter
      else:
761 ace16501 Guido Trotter
        nodegroups_names.add(nodegroup.name)
762 81e3ab4f Agata Murawska
      group_name = "group %s" % nodegroup.name
763 8b057218 René Nussbaumer
      _helper_ipolicy(group_name, cluster.SimpleFillIPolicy(nodegroup.ipolicy),
764 8b057218 René Nussbaumer
                      False)
765 81e3ab4f Agata Murawska
      _helper_ispecs(group_name, cluster.SimpleFillIPolicy(nodegroup.ipolicy))
766 26f2fd8d Iustin Pop
      if nodegroup.ndparams:
767 81e3ab4f Agata Murawska
        _helper(group_name, "ndparams",
768 26f2fd8d Iustin Pop
                cluster.SimpleFillND(nodegroup.ndparams),
769 26f2fd8d Iustin Pop
                constants.NDS_PARAMETER_TYPES)
770 26f2fd8d Iustin Pop
771 4a89c54a Iustin Pop
    # drbd minors check
772 1122eb25 Iustin Pop
    _, duplicates = self._UnlockedComputeDRBDMap()
773 4a89c54a Iustin Pop
    for node, minor, instance_a, instance_b in duplicates:
774 4a89c54a Iustin Pop
      result.append("DRBD minor %d on node %s is assigned twice to instances"
775 4a89c54a Iustin Pop
                    " %s and %s" % (minor, node, instance_a, instance_b))
776 4a89c54a Iustin Pop
777 0ce8f948 Iustin Pop
    # IP checks
778 7e01d204 Iustin Pop
    default_nicparams = cluster.nicparams[constants.PP_DEFAULT]
779 b8716596 Michael Hanselmann
    ips = {}
780 b8716596 Michael Hanselmann
781 b8716596 Michael Hanselmann
    def _AddIpAddress(ip, name):
782 b8716596 Michael Hanselmann
      ips.setdefault(ip, []).append(name)
783 b8716596 Michael Hanselmann
784 7e01d204 Iustin Pop
    _AddIpAddress(cluster.master_ip, "cluster_ip")
785 0ce8f948 Iustin Pop
786 0ce8f948 Iustin Pop
    for node in data.nodes.values():
787 b8716596 Michael Hanselmann
      _AddIpAddress(node.primary_ip, "node:%s/primary" % node.name)
788 0ce8f948 Iustin Pop
      if node.secondary_ip != node.primary_ip:
789 b8716596 Michael Hanselmann
        _AddIpAddress(node.secondary_ip, "node:%s/secondary" % node.name)
790 b8716596 Michael Hanselmann
791 b8716596 Michael Hanselmann
    for instance in data.instances.values():
792 b8716596 Michael Hanselmann
      for idx, nic in enumerate(instance.nics):
793 b8716596 Michael Hanselmann
        if nic.ip is None:
794 b8716596 Michael Hanselmann
          continue
795 b8716596 Michael Hanselmann
796 b8716596 Michael Hanselmann
        nicparams = objects.FillDict(default_nicparams, nic.nicparams)
797 b8716596 Michael Hanselmann
        nic_mode = nicparams[constants.NIC_MODE]
798 b8716596 Michael Hanselmann
        nic_link = nicparams[constants.NIC_LINK]
799 b8716596 Michael Hanselmann
800 b8716596 Michael Hanselmann
        if nic_mode == constants.NIC_MODE_BRIDGED:
801 b8716596 Michael Hanselmann
          link = "bridge:%s" % nic_link
802 b8716596 Michael Hanselmann
        elif nic_mode == constants.NIC_MODE_ROUTED:
803 b8716596 Michael Hanselmann
          link = "route:%s" % nic_link
804 b8716596 Michael Hanselmann
        else:
805 b8716596 Michael Hanselmann
          raise errors.ProgrammerError("NIC mode '%s' not handled" % nic_mode)
806 b8716596 Michael Hanselmann
807 ad4a9ae7 Dimitris Aragiorgis
        _AddIpAddress("%s/%s/%s" % (link, nic.ip, nic.network),
808 b8716596 Michael Hanselmann
                      "instance:%s/nic:%d" % (instance.name, idx))
809 0ce8f948 Iustin Pop
810 0ce8f948 Iustin Pop
    for ip, owners in ips.items():
811 0ce8f948 Iustin Pop
      if len(owners) > 1:
812 0ce8f948 Iustin Pop
        result.append("IP address %s is used by multiple owners: %s" %
813 1f864b60 Iustin Pop
                      (ip, utils.CommaJoin(owners)))
814 b8716596 Michael Hanselmann
815 a8083063 Iustin Pop
    return result
816 a8083063 Iustin Pop
817 4a89c54a Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
818 4a89c54a Iustin Pop
  def VerifyConfig(self):
819 4a89c54a Iustin Pop
    """Verify function.
820 4a89c54a Iustin Pop

821 4a89c54a Iustin Pop
    This is just a wrapper over L{_UnlockedVerifyConfig}.
822 4a89c54a Iustin Pop

823 4a89c54a Iustin Pop
    @rtype: list
824 4a89c54a Iustin Pop
    @return: a list of error messages; a non-empty list signifies
825 4a89c54a Iustin Pop
        configuration errors
826 4a89c54a Iustin Pop

827 4a89c54a Iustin Pop
    """
828 4a89c54a Iustin Pop
    return self._UnlockedVerifyConfig()
829 4a89c54a Iustin Pop
830 f78ede4e Guido Trotter
  def _UnlockedSetDiskID(self, disk, node_name):
831 a8083063 Iustin Pop
    """Convert the unique ID to the ID needed on the target nodes.
832 a8083063 Iustin Pop

833 a8083063 Iustin Pop
    This is used only for drbd, which needs ip/port configuration.
834 a8083063 Iustin Pop

835 a8083063 Iustin Pop
    The routine descends down and updates its children also, because
836 a8083063 Iustin Pop
    this helps when the only the top device is passed to the remote
837 a8083063 Iustin Pop
    node.
838 a8083063 Iustin Pop

839 f78ede4e Guido Trotter
    This function is for internal use, when the config lock is already held.
840 f78ede4e Guido Trotter

841 a8083063 Iustin Pop
    """
842 a8083063 Iustin Pop
    if disk.children:
843 a8083063 Iustin Pop
      for child in disk.children:
844 f78ede4e Guido Trotter
        self._UnlockedSetDiskID(child, node_name)
845 a8083063 Iustin Pop
846 a8083063 Iustin Pop
    if disk.logical_id is None and disk.physical_id is not None:
847 a8083063 Iustin Pop
      return
848 ffa1c0dc Iustin Pop
    if disk.dev_type == constants.LD_DRBD8:
849 f9518d38 Iustin Pop
      pnode, snode, port, pminor, sminor, secret = disk.logical_id
850 a8083063 Iustin Pop
      if node_name not in (pnode, snode):
851 3ecf6786 Iustin Pop
        raise errors.ConfigurationError("DRBD device not knowing node %s" %
852 3ecf6786 Iustin Pop
                                        node_name)
853 f78ede4e Guido Trotter
      pnode_info = self._UnlockedGetNodeInfo(pnode)
854 f78ede4e Guido Trotter
      snode_info = self._UnlockedGetNodeInfo(snode)
855 a8083063 Iustin Pop
      if pnode_info is None or snode_info is None:
856 a8083063 Iustin Pop
        raise errors.ConfigurationError("Can't find primary or secondary node"
857 a8083063 Iustin Pop
                                        " for %s" % str(disk))
858 ffa1c0dc Iustin Pop
      p_data = (pnode_info.secondary_ip, port)
859 ffa1c0dc Iustin Pop
      s_data = (snode_info.secondary_ip, port)
860 a8083063 Iustin Pop
      if pnode == node_name:
861 f9518d38 Iustin Pop
        disk.physical_id = p_data + s_data + (pminor, secret)
862 a8083063 Iustin Pop
      else: # it must be secondary, we tested above
863 f9518d38 Iustin Pop
        disk.physical_id = s_data + p_data + (sminor, secret)
864 a8083063 Iustin Pop
    else:
865 a8083063 Iustin Pop
      disk.physical_id = disk.logical_id
866 a8083063 Iustin Pop
    return
867 a8083063 Iustin Pop
868 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
869 f78ede4e Guido Trotter
  def SetDiskID(self, disk, node_name):
870 f78ede4e Guido Trotter
    """Convert the unique ID to the ID needed on the target nodes.
871 f78ede4e Guido Trotter

872 f78ede4e Guido Trotter
    This is used only for drbd, which needs ip/port configuration.
873 f78ede4e Guido Trotter

874 f78ede4e Guido Trotter
    The routine descends down and updates its children also, because
875 f78ede4e Guido Trotter
    this helps when the only the top device is passed to the remote
876 f78ede4e Guido Trotter
    node.
877 f78ede4e Guido Trotter

878 f78ede4e Guido Trotter
    """
879 f78ede4e Guido Trotter
    return self._UnlockedSetDiskID(disk, node_name)
880 f78ede4e Guido Trotter
881 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
882 b2fddf63 Iustin Pop
  def AddTcpUdpPort(self, port):
883 b2fddf63 Iustin Pop
    """Adds a new port to the available port pool.
884 b2fddf63 Iustin Pop

885 3b3b1bca Dimitris Aragiorgis
    @warning: this method does not "flush" the configuration (via
886 3b3b1bca Dimitris Aragiorgis
        L{_WriteConfig}); callers should do that themselves once the
887 3b3b1bca Dimitris Aragiorgis
        configuration is stable
888 3b3b1bca Dimitris Aragiorgis

889 b2fddf63 Iustin Pop
    """
890 264bb3c5 Michael Hanselmann
    if not isinstance(port, int):
891 3ecf6786 Iustin Pop
      raise errors.ProgrammerError("Invalid type passed for port")
892 264bb3c5 Michael Hanselmann
893 b2fddf63 Iustin Pop
    self._config_data.cluster.tcpudp_port_pool.add(port)
894 264bb3c5 Michael Hanselmann
895 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
896 b2fddf63 Iustin Pop
  def GetPortList(self):
897 264bb3c5 Michael Hanselmann
    """Returns a copy of the current port list.
898 264bb3c5 Michael Hanselmann

899 264bb3c5 Michael Hanselmann
    """
900 b2fddf63 Iustin Pop
    return self._config_data.cluster.tcpudp_port_pool.copy()
901 264bb3c5 Michael Hanselmann
902 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
903 a8083063 Iustin Pop
  def AllocatePort(self):
904 a8083063 Iustin Pop
    """Allocate a port.
905 a8083063 Iustin Pop

906 b2fddf63 Iustin Pop
    The port will be taken from the available port pool or from the
907 b2fddf63 Iustin Pop
    default port range (and in this case we increase
908 b2fddf63 Iustin Pop
    highest_used_port).
909 a8083063 Iustin Pop

910 a8083063 Iustin Pop
    """
911 264bb3c5 Michael Hanselmann
    # If there are TCP/IP ports configured, we use them first.
912 b2fddf63 Iustin Pop
    if self._config_data.cluster.tcpudp_port_pool:
913 b2fddf63 Iustin Pop
      port = self._config_data.cluster.tcpudp_port_pool.pop()
914 264bb3c5 Michael Hanselmann
    else:
915 264bb3c5 Michael Hanselmann
      port = self._config_data.cluster.highest_used_port + 1
916 264bb3c5 Michael Hanselmann
      if port >= constants.LAST_DRBD_PORT:
917 3ecf6786 Iustin Pop
        raise errors.ConfigurationError("The highest used port is greater"
918 3ecf6786 Iustin Pop
                                        " than %s. Aborting." %
919 3ecf6786 Iustin Pop
                                        constants.LAST_DRBD_PORT)
920 264bb3c5 Michael Hanselmann
      self._config_data.cluster.highest_used_port = port
921 a8083063 Iustin Pop
922 a8083063 Iustin Pop
    self._WriteConfig()
923 a8083063 Iustin Pop
    return port
924 a8083063 Iustin Pop
925 6d2e83d5 Iustin Pop
  def _UnlockedComputeDRBDMap(self):
926 a81c53c9 Iustin Pop
    """Compute the used DRBD minor/nodes.
927 a81c53c9 Iustin Pop

928 4a89c54a Iustin Pop
    @rtype: (dict, list)
929 c41eea6e Iustin Pop
    @return: dictionary of node_name: dict of minor: instance_name;
930 c41eea6e Iustin Pop
        the returned dict will have all the nodes in it (even if with
931 4a89c54a Iustin Pop
        an empty list), and a list of duplicates; if the duplicates
932 4a89c54a Iustin Pop
        list is not empty, the configuration is corrupted and its caller
933 4a89c54a Iustin Pop
        should raise an exception
934 a81c53c9 Iustin Pop

935 a81c53c9 Iustin Pop
    """
936 a81c53c9 Iustin Pop
    def _AppendUsedPorts(instance_name, disk, used):
937 4a89c54a Iustin Pop
      duplicates = []
938 f9518d38 Iustin Pop
      if disk.dev_type == constants.LD_DRBD8 and len(disk.logical_id) >= 5:
939 7c4d6c7b Michael Hanselmann
        node_a, node_b, _, minor_a, minor_b = disk.logical_id[:5]
940 7c4d6c7b Michael Hanselmann
        for node, port in ((node_a, minor_a), (node_b, minor_b)):
941 4a89c54a Iustin Pop
          assert node in used, ("Node '%s' of instance '%s' not found"
942 4a89c54a Iustin Pop
                                " in node list" % (node, instance_name))
943 a81c53c9 Iustin Pop
          if port in used[node]:
944 4a89c54a Iustin Pop
            duplicates.append((node, port, instance_name, used[node][port]))
945 4a89c54a Iustin Pop
          else:
946 4a89c54a Iustin Pop
            used[node][port] = instance_name
947 a81c53c9 Iustin Pop
      if disk.children:
948 a81c53c9 Iustin Pop
        for child in disk.children:
949 4a89c54a Iustin Pop
          duplicates.extend(_AppendUsedPorts(instance_name, child, used))
950 4a89c54a Iustin Pop
      return duplicates
951 a81c53c9 Iustin Pop
952 4a89c54a Iustin Pop
    duplicates = []
953 a81c53c9 Iustin Pop
    my_dict = dict((node, {}) for node in self._config_data.nodes)
954 79b26a7a Iustin Pop
    for instance in self._config_data.instances.itervalues():
955 79b26a7a Iustin Pop
      for disk in instance.disks:
956 79b26a7a Iustin Pop
        duplicates.extend(_AppendUsedPorts(instance.name, disk, my_dict))
957 a81c53c9 Iustin Pop
    for (node, minor), instance in self._temporary_drbds.iteritems():
958 79b26a7a Iustin Pop
      if minor in my_dict[node] and my_dict[node][minor] != instance:
959 4a89c54a Iustin Pop
        duplicates.append((node, minor, instance, my_dict[node][minor]))
960 4a89c54a Iustin Pop
      else:
961 4a89c54a Iustin Pop
        my_dict[node][minor] = instance
962 4a89c54a Iustin Pop
    return my_dict, duplicates
963 a81c53c9 Iustin Pop
964 a81c53c9 Iustin Pop
  @locking.ssynchronized(_config_lock)
965 6d2e83d5 Iustin Pop
  def ComputeDRBDMap(self):
966 6d2e83d5 Iustin Pop
    """Compute the used DRBD minor/nodes.
967 6d2e83d5 Iustin Pop

968 6d2e83d5 Iustin Pop
    This is just a wrapper over L{_UnlockedComputeDRBDMap}.
969 6d2e83d5 Iustin Pop

970 6d2e83d5 Iustin Pop
    @return: dictionary of node_name: dict of minor: instance_name;
971 6d2e83d5 Iustin Pop
        the returned dict will have all the nodes in it (even if with
972 6d2e83d5 Iustin Pop
        an empty list).
973 6d2e83d5 Iustin Pop

974 6d2e83d5 Iustin Pop
    """
975 4a89c54a Iustin Pop
    d_map, duplicates = self._UnlockedComputeDRBDMap()
976 4a89c54a Iustin Pop
    if duplicates:
977 4a89c54a Iustin Pop
      raise errors.ConfigurationError("Duplicate DRBD ports detected: %s" %
978 4a89c54a Iustin Pop
                                      str(duplicates))
979 4a89c54a Iustin Pop
    return d_map
980 6d2e83d5 Iustin Pop
981 6d2e83d5 Iustin Pop
  @locking.ssynchronized(_config_lock)
982 a81c53c9 Iustin Pop
  def AllocateDRBDMinor(self, nodes, instance):
983 a81c53c9 Iustin Pop
    """Allocate a drbd minor.
984 a81c53c9 Iustin Pop

985 a81c53c9 Iustin Pop
    The free minor will be automatically computed from the existing
986 a81c53c9 Iustin Pop
    devices. A node can be given multiple times in order to allocate
987 a81c53c9 Iustin Pop
    multiple minors. The result is the list of minors, in the same
988 a81c53c9 Iustin Pop
    order as the passed nodes.
989 a81c53c9 Iustin Pop

990 32388e6d Iustin Pop
    @type instance: string
991 32388e6d Iustin Pop
    @param instance: the instance for which we allocate minors
992 32388e6d Iustin Pop

993 a81c53c9 Iustin Pop
    """
994 32388e6d Iustin Pop
    assert isinstance(instance, basestring), \
995 4a89c54a Iustin Pop
           "Invalid argument '%s' passed to AllocateDRBDMinor" % instance
996 32388e6d Iustin Pop
997 4a89c54a Iustin Pop
    d_map, duplicates = self._UnlockedComputeDRBDMap()
998 4a89c54a Iustin Pop
    if duplicates:
999 4a89c54a Iustin Pop
      raise errors.ConfigurationError("Duplicate DRBD ports detected: %s" %
1000 4a89c54a Iustin Pop
                                      str(duplicates))
1001 a81c53c9 Iustin Pop
    result = []
1002 a81c53c9 Iustin Pop
    for nname in nodes:
1003 a81c53c9 Iustin Pop
      ndata = d_map[nname]
1004 a81c53c9 Iustin Pop
      if not ndata:
1005 a81c53c9 Iustin Pop
        # no minors used, we can start at 0
1006 a81c53c9 Iustin Pop
        result.append(0)
1007 a81c53c9 Iustin Pop
        ndata[0] = instance
1008 d48663e4 Iustin Pop
        self._temporary_drbds[(nname, 0)] = instance
1009 a81c53c9 Iustin Pop
        continue
1010 a81c53c9 Iustin Pop
      keys = ndata.keys()
1011 a81c53c9 Iustin Pop
      keys.sort()
1012 a81c53c9 Iustin Pop
      ffree = utils.FirstFree(keys)
1013 a81c53c9 Iustin Pop
      if ffree is None:
1014 a81c53c9 Iustin Pop
        # return the next minor
1015 a81c53c9 Iustin Pop
        # TODO: implement high-limit check
1016 a81c53c9 Iustin Pop
        minor = keys[-1] + 1
1017 a81c53c9 Iustin Pop
      else:
1018 a81c53c9 Iustin Pop
        minor = ffree
1019 4a89c54a Iustin Pop
      # double-check minor against current instances
1020 4a89c54a Iustin Pop
      assert minor not in d_map[nname], \
1021 4a89c54a Iustin Pop
             ("Attempt to reuse allocated DRBD minor %d on node %s,"
1022 4a89c54a Iustin Pop
              " already allocated to instance %s" %
1023 4a89c54a Iustin Pop
              (minor, nname, d_map[nname][minor]))
1024 a81c53c9 Iustin Pop
      ndata[minor] = instance
1025 4a89c54a Iustin Pop
      # double-check minor against reservation
1026 4a89c54a Iustin Pop
      r_key = (nname, minor)
1027 4a89c54a Iustin Pop
      assert r_key not in self._temporary_drbds, \
1028 4a89c54a Iustin Pop
             ("Attempt to reuse reserved DRBD minor %d on node %s,"
1029 4a89c54a Iustin Pop
              " reserved for instance %s" %
1030 4a89c54a Iustin Pop
              (minor, nname, self._temporary_drbds[r_key]))
1031 4a89c54a Iustin Pop
      self._temporary_drbds[r_key] = instance
1032 4a89c54a Iustin Pop
      result.append(minor)
1033 a81c53c9 Iustin Pop
    logging.debug("Request to allocate drbd minors, input: %s, returning %s",
1034 a81c53c9 Iustin Pop
                  nodes, result)
1035 a81c53c9 Iustin Pop
    return result
1036 a81c53c9 Iustin Pop
1037 61cf6b5e Iustin Pop
  def _UnlockedReleaseDRBDMinors(self, instance):
1038 a81c53c9 Iustin Pop
    """Release temporary drbd minors allocated for a given instance.
1039 a81c53c9 Iustin Pop

1040 a81c53c9 Iustin Pop
    @type instance: string
1041 a81c53c9 Iustin Pop
    @param instance: the instance for which temporary minors should be
1042 a81c53c9 Iustin Pop
                     released
1043 a81c53c9 Iustin Pop

1044 a81c53c9 Iustin Pop
    """
1045 32388e6d Iustin Pop
    assert isinstance(instance, basestring), \
1046 32388e6d Iustin Pop
           "Invalid argument passed to ReleaseDRBDMinors"
1047 a81c53c9 Iustin Pop
    for key, name in self._temporary_drbds.items():
1048 a81c53c9 Iustin Pop
      if name == instance:
1049 a81c53c9 Iustin Pop
        del self._temporary_drbds[key]
1050 a81c53c9 Iustin Pop
1051 61cf6b5e Iustin Pop
  @locking.ssynchronized(_config_lock)
1052 61cf6b5e Iustin Pop
  def ReleaseDRBDMinors(self, instance):
1053 61cf6b5e Iustin Pop
    """Release temporary drbd minors allocated for a given instance.
1054 61cf6b5e Iustin Pop

1055 61cf6b5e Iustin Pop
    This should be called on the error paths, on the success paths
1056 61cf6b5e Iustin Pop
    it's automatically called by the ConfigWriter add and update
1057 61cf6b5e Iustin Pop
    functions.
1058 61cf6b5e Iustin Pop

1059 61cf6b5e Iustin Pop
    This function is just a wrapper over L{_UnlockedReleaseDRBDMinors}.
1060 61cf6b5e Iustin Pop

1061 61cf6b5e Iustin Pop
    @type instance: string
1062 61cf6b5e Iustin Pop
    @param instance: the instance for which temporary minors should be
1063 61cf6b5e Iustin Pop
                     released
1064 61cf6b5e Iustin Pop

1065 61cf6b5e Iustin Pop
    """
1066 61cf6b5e Iustin Pop
    self._UnlockedReleaseDRBDMinors(instance)
1067 61cf6b5e Iustin Pop
1068 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1069 4a8b186a Michael Hanselmann
  def GetConfigVersion(self):
1070 4a8b186a Michael Hanselmann
    """Get the configuration version.
1071 4a8b186a Michael Hanselmann

1072 4a8b186a Michael Hanselmann
    @return: Config version
1073 4a8b186a Michael Hanselmann

1074 4a8b186a Michael Hanselmann
    """
1075 4a8b186a Michael Hanselmann
    return self._config_data.version
1076 4a8b186a Michael Hanselmann
1077 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1078 4a8b186a Michael Hanselmann
  def GetClusterName(self):
1079 4a8b186a Michael Hanselmann
    """Get cluster name.
1080 4a8b186a Michael Hanselmann

1081 4a8b186a Michael Hanselmann
    @return: Cluster name
1082 4a8b186a Michael Hanselmann

1083 4a8b186a Michael Hanselmann
    """
1084 4a8b186a Michael Hanselmann
    return self._config_data.cluster.cluster_name
1085 4a8b186a Michael Hanselmann
1086 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1087 4a8b186a Michael Hanselmann
  def GetMasterNode(self):
1088 4a8b186a Michael Hanselmann
    """Get the hostname of the master node for this cluster.
1089 4a8b186a Michael Hanselmann

1090 4a8b186a Michael Hanselmann
    @return: Master hostname
1091 4a8b186a Michael Hanselmann

1092 4a8b186a Michael Hanselmann
    """
1093 4a8b186a Michael Hanselmann
    return self._config_data.cluster.master_node
1094 4a8b186a Michael Hanselmann
1095 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1096 4a8b186a Michael Hanselmann
  def GetMasterIP(self):
1097 4a8b186a Michael Hanselmann
    """Get the IP of the master node for this cluster.
1098 4a8b186a Michael Hanselmann

1099 4a8b186a Michael Hanselmann
    @return: Master IP
1100 4a8b186a Michael Hanselmann

1101 4a8b186a Michael Hanselmann
    """
1102 4a8b186a Michael Hanselmann
    return self._config_data.cluster.master_ip
1103 4a8b186a Michael Hanselmann
1104 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1105 4a8b186a Michael Hanselmann
  def GetMasterNetdev(self):
1106 4a8b186a Michael Hanselmann
    """Get the master network device for this cluster.
1107 4a8b186a Michael Hanselmann

1108 4a8b186a Michael Hanselmann
    """
1109 4a8b186a Michael Hanselmann
    return self._config_data.cluster.master_netdev
1110 4a8b186a Michael Hanselmann
1111 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1112 5a8648eb Andrea Spadaccini
  def GetMasterNetmask(self):
1113 5a8648eb Andrea Spadaccini
    """Get the netmask of the master node for this cluster.
1114 5a8648eb Andrea Spadaccini

1115 5a8648eb Andrea Spadaccini
    """
1116 5a8648eb Andrea Spadaccini
    return self._config_data.cluster.master_netmask
1117 5a8648eb Andrea Spadaccini
1118 5a8648eb Andrea Spadaccini
  @locking.ssynchronized(_config_lock, shared=1)
1119 33be7576 Andrea Spadaccini
  def GetUseExternalMipScript(self):
1120 33be7576 Andrea Spadaccini
    """Get flag representing whether to use the external master IP setup script.
1121 33be7576 Andrea Spadaccini

1122 33be7576 Andrea Spadaccini
    """
1123 33be7576 Andrea Spadaccini
    return self._config_data.cluster.use_external_mip_script
1124 33be7576 Andrea Spadaccini
1125 33be7576 Andrea Spadaccini
  @locking.ssynchronized(_config_lock, shared=1)
1126 4a8b186a Michael Hanselmann
  def GetFileStorageDir(self):
1127 4a8b186a Michael Hanselmann
    """Get the file storage dir for this cluster.
1128 4a8b186a Michael Hanselmann

1129 4a8b186a Michael Hanselmann
    """
1130 4a8b186a Michael Hanselmann
    return self._config_data.cluster.file_storage_dir
1131 4a8b186a Michael Hanselmann
1132 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1133 4b97f902 Apollon Oikonomopoulos
  def GetSharedFileStorageDir(self):
1134 4b97f902 Apollon Oikonomopoulos
    """Get the shared file storage dir for this cluster.
1135 4b97f902 Apollon Oikonomopoulos

1136 4b97f902 Apollon Oikonomopoulos
    """
1137 4b97f902 Apollon Oikonomopoulos
    return self._config_data.cluster.shared_file_storage_dir
1138 4b97f902 Apollon Oikonomopoulos
1139 4b97f902 Apollon Oikonomopoulos
  @locking.ssynchronized(_config_lock, shared=1)
1140 4a8b186a Michael Hanselmann
  def GetHypervisorType(self):
1141 4a8b186a Michael Hanselmann
    """Get the hypervisor type for this cluster.
1142 4a8b186a Michael Hanselmann

1143 4a8b186a Michael Hanselmann
    """
1144 066f465d Guido Trotter
    return self._config_data.cluster.enabled_hypervisors[0]
1145 4a8b186a Michael Hanselmann
1146 4a8b186a Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1147 a8083063 Iustin Pop
  def GetHostKey(self):
1148 a8083063 Iustin Pop
    """Return the rsa hostkey from the config.
1149 a8083063 Iustin Pop

1150 c41eea6e Iustin Pop
    @rtype: string
1151 c41eea6e Iustin Pop
    @return: the rsa hostkey
1152 a8083063 Iustin Pop

1153 a8083063 Iustin Pop
    """
1154 a8083063 Iustin Pop
    return self._config_data.cluster.rsahostkeypub
1155 a8083063 Iustin Pop
1156 bf4af505 Apollon Oikonomopoulos
  @locking.ssynchronized(_config_lock, shared=1)
1157 bf4af505 Apollon Oikonomopoulos
  def GetDefaultIAllocator(self):
1158 bf4af505 Apollon Oikonomopoulos
    """Get the default instance allocator for this cluster.
1159 bf4af505 Apollon Oikonomopoulos

1160 bf4af505 Apollon Oikonomopoulos
    """
1161 bf4af505 Apollon Oikonomopoulos
    return self._config_data.cluster.default_iallocator
1162 bf4af505 Apollon Oikonomopoulos
1163 868a98ca Manuel Franceschini
  @locking.ssynchronized(_config_lock, shared=1)
1164 868a98ca Manuel Franceschini
  def GetPrimaryIPFamily(self):
1165 868a98ca Manuel Franceschini
    """Get cluster primary ip family.
1166 868a98ca Manuel Franceschini

1167 868a98ca Manuel Franceschini
    @return: primary ip family
1168 868a98ca Manuel Franceschini

1169 868a98ca Manuel Franceschini
    """
1170 868a98ca Manuel Franceschini
    return self._config_data.cluster.primary_ip_family
1171 868a98ca Manuel Franceschini
1172 c9f4b8e6 Andrea Spadaccini
  @locking.ssynchronized(_config_lock, shared=1)
1173 c9f4b8e6 Andrea Spadaccini
  def GetMasterNetworkParameters(self):
1174 c9f4b8e6 Andrea Spadaccini
    """Get network parameters of the master node.
1175 c9f4b8e6 Andrea Spadaccini

1176 f9d20654 Andrea Spadaccini
    @rtype: L{object.MasterNetworkParameters}
1177 f9d20654 Andrea Spadaccini
    @return: network parameters of the master node
1178 c9f4b8e6 Andrea Spadaccini

1179 c9f4b8e6 Andrea Spadaccini
    """
1180 c9f4b8e6 Andrea Spadaccini
    cluster = self._config_data.cluster
1181 5ae4945a Iustin Pop
    result = objects.MasterNetworkParameters(
1182 5ae4945a Iustin Pop
      name=cluster.master_node, ip=cluster.master_ip,
1183 5ae4945a Iustin Pop
      netmask=cluster.master_netmask, netdev=cluster.master_netdev,
1184 c79198a0 Andrea Spadaccini
      ip_family=cluster.primary_ip_family)
1185 c9f4b8e6 Andrea Spadaccini
1186 f9d20654 Andrea Spadaccini
    return result
1187 f9d20654 Andrea Spadaccini
1188 e11a1b77 Adeodato Simo
  @locking.ssynchronized(_config_lock)
1189 e11a1b77 Adeodato Simo
  def AddNodeGroup(self, group, ec_id, check_uuid=True):
1190 e11a1b77 Adeodato Simo
    """Add a node group to the configuration.
1191 e11a1b77 Adeodato Simo

1192 90e99856 Adeodato Simo
    This method calls group.UpgradeConfig() to fill any missing attributes
1193 90e99856 Adeodato Simo
    according to their default values.
1194 90e99856 Adeodato Simo

1195 e11a1b77 Adeodato Simo
    @type group: L{objects.NodeGroup}
1196 e11a1b77 Adeodato Simo
    @param group: the NodeGroup object to add
1197 e11a1b77 Adeodato Simo
    @type ec_id: string
1198 e11a1b77 Adeodato Simo
    @param ec_id: unique id for the job to use when creating a missing UUID
1199 e11a1b77 Adeodato Simo
    @type check_uuid: bool
1200 e11a1b77 Adeodato Simo
    @param check_uuid: add an UUID to the group if it doesn't have one or, if
1201 e11a1b77 Adeodato Simo
                       it does, ensure that it does not exist in the
1202 e11a1b77 Adeodato Simo
                       configuration already
1203 e11a1b77 Adeodato Simo

1204 e11a1b77 Adeodato Simo
    """
1205 e11a1b77 Adeodato Simo
    self._UnlockedAddNodeGroup(group, ec_id, check_uuid)
1206 e11a1b77 Adeodato Simo
    self._WriteConfig()
1207 e11a1b77 Adeodato Simo
1208 e11a1b77 Adeodato Simo
  def _UnlockedAddNodeGroup(self, group, ec_id, check_uuid):
1209 e11a1b77 Adeodato Simo
    """Add a node group to the configuration.
1210 e11a1b77 Adeodato Simo

1211 e11a1b77 Adeodato Simo
    """
1212 e11a1b77 Adeodato Simo
    logging.info("Adding node group %s to configuration", group.name)
1213 e11a1b77 Adeodato Simo
1214 e11a1b77 Adeodato Simo
    # Some code might need to add a node group with a pre-populated UUID
1215 e11a1b77 Adeodato Simo
    # generated with ConfigWriter.GenerateUniqueID(). We allow them to bypass
1216 e11a1b77 Adeodato Simo
    # the "does this UUID" exist already check.
1217 e11a1b77 Adeodato Simo
    if check_uuid:
1218 e11a1b77 Adeodato Simo
      self._EnsureUUID(group, ec_id)
1219 e11a1b77 Adeodato Simo
1220 18ffc0fe Stephen Shirley
    try:
1221 18ffc0fe Stephen Shirley
      existing_uuid = self._UnlockedLookupNodeGroup(group.name)
1222 18ffc0fe Stephen Shirley
    except errors.OpPrereqError:
1223 18ffc0fe Stephen Shirley
      pass
1224 18ffc0fe Stephen Shirley
    else:
1225 18ffc0fe Stephen Shirley
      raise errors.OpPrereqError("Desired group name '%s' already exists as a"
1226 18ffc0fe Stephen Shirley
                                 " node group (UUID: %s)" %
1227 18ffc0fe Stephen Shirley
                                 (group.name, existing_uuid),
1228 18ffc0fe Stephen Shirley
                                 errors.ECODE_EXISTS)
1229 18ffc0fe Stephen Shirley
1230 e11a1b77 Adeodato Simo
    group.serial_no = 1
1231 e11a1b77 Adeodato Simo
    group.ctime = group.mtime = time.time()
1232 90e99856 Adeodato Simo
    group.UpgradeConfig()
1233 e11a1b77 Adeodato Simo
1234 e11a1b77 Adeodato Simo
    self._config_data.nodegroups[group.uuid] = group
1235 e11a1b77 Adeodato Simo
    self._config_data.cluster.serial_no += 1
1236 e11a1b77 Adeodato Simo
1237 e11a1b77 Adeodato Simo
  @locking.ssynchronized(_config_lock)
1238 e11a1b77 Adeodato Simo
  def RemoveNodeGroup(self, group_uuid):
1239 e11a1b77 Adeodato Simo
    """Remove a node group from the configuration.
1240 e11a1b77 Adeodato Simo

1241 e11a1b77 Adeodato Simo
    @type group_uuid: string
1242 e11a1b77 Adeodato Simo
    @param group_uuid: the UUID of the node group to remove
1243 e11a1b77 Adeodato Simo

1244 e11a1b77 Adeodato Simo
    """
1245 e11a1b77 Adeodato Simo
    logging.info("Removing node group %s from configuration", group_uuid)
1246 e11a1b77 Adeodato Simo
1247 e11a1b77 Adeodato Simo
    if group_uuid not in self._config_data.nodegroups:
1248 e11a1b77 Adeodato Simo
      raise errors.ConfigurationError("Unknown node group '%s'" % group_uuid)
1249 e11a1b77 Adeodato Simo
1250 0389c42a Stephen Shirley
    assert len(self._config_data.nodegroups) != 1, \
1251 0389c42a Stephen Shirley
            "Group '%s' is the only group, cannot be removed" % group_uuid
1252 0389c42a Stephen Shirley
1253 e11a1b77 Adeodato Simo
    del self._config_data.nodegroups[group_uuid]
1254 e11a1b77 Adeodato Simo
    self._config_data.cluster.serial_no += 1
1255 e11a1b77 Adeodato Simo
    self._WriteConfig()
1256 e11a1b77 Adeodato Simo
1257 e85d8982 Stephen Shirley
  def _UnlockedLookupNodeGroup(self, target):
1258 412b3531 Guido Trotter
    """Lookup a node group's UUID.
1259 eaa98a04 Guido Trotter

1260 eaa98a04 Guido Trotter
    @type target: string or None
1261 412b3531 Guido Trotter
    @param target: group name or UUID or None to look for the default
1262 eaa98a04 Guido Trotter
    @rtype: string
1263 412b3531 Guido Trotter
    @return: nodegroup UUID
1264 eaa98a04 Guido Trotter
    @raises errors.OpPrereqError: when the target group cannot be found
1265 eaa98a04 Guido Trotter

1266 eaa98a04 Guido Trotter
    """
1267 eaa98a04 Guido Trotter
    if target is None:
1268 eaa98a04 Guido Trotter
      if len(self._config_data.nodegroups) != 1:
1269 913cc25e Adeodato Simo
        raise errors.OpPrereqError("More than one node group exists. Target"
1270 2ed0e208 Iustin Pop
                                   " group must be specified explicitly.")
1271 eaa98a04 Guido Trotter
      else:
1272 eaa98a04 Guido Trotter
        return self._config_data.nodegroups.keys()[0]
1273 eaa98a04 Guido Trotter
    if target in self._config_data.nodegroups:
1274 eaa98a04 Guido Trotter
      return target
1275 eaa98a04 Guido Trotter
    for nodegroup in self._config_data.nodegroups.values():
1276 eaa98a04 Guido Trotter
      if nodegroup.name == target:
1277 eaa98a04 Guido Trotter
        return nodegroup.uuid
1278 e0f9ed64 Adeodato Simo
    raise errors.OpPrereqError("Node group '%s' not found" % target,
1279 e0f9ed64 Adeodato Simo
                               errors.ECODE_NOENT)
1280 eaa98a04 Guido Trotter
1281 e85d8982 Stephen Shirley
  @locking.ssynchronized(_config_lock, shared=1)
1282 e85d8982 Stephen Shirley
  def LookupNodeGroup(self, target):
1283 e85d8982 Stephen Shirley
    """Lookup a node group's UUID.
1284 e85d8982 Stephen Shirley

1285 e85d8982 Stephen Shirley
    This function is just a wrapper over L{_UnlockedLookupNodeGroup}.
1286 e85d8982 Stephen Shirley

1287 e85d8982 Stephen Shirley
    @type target: string or None
1288 e85d8982 Stephen Shirley
    @param target: group name or UUID or None to look for the default
1289 e85d8982 Stephen Shirley
    @rtype: string
1290 e85d8982 Stephen Shirley
    @return: nodegroup UUID
1291 e85d8982 Stephen Shirley

1292 e85d8982 Stephen Shirley
    """
1293 e85d8982 Stephen Shirley
    return self._UnlockedLookupNodeGroup(target)
1294 e85d8982 Stephen Shirley
1295 5768e6a6 René Nussbaumer
  def _UnlockedGetNodeGroup(self, uuid):
1296 648e4196 Guido Trotter
    """Lookup a node group.
1297 648e4196 Guido Trotter

1298 648e4196 Guido Trotter
    @type uuid: string
1299 648e4196 Guido Trotter
    @param uuid: group UUID
1300 648e4196 Guido Trotter
    @rtype: L{objects.NodeGroup} or None
1301 648e4196 Guido Trotter
    @return: nodegroup object, or None if not found
1302 648e4196 Guido Trotter

1303 648e4196 Guido Trotter
    """
1304 648e4196 Guido Trotter
    if uuid not in self._config_data.nodegroups:
1305 648e4196 Guido Trotter
      return None
1306 648e4196 Guido Trotter
1307 648e4196 Guido Trotter
    return self._config_data.nodegroups[uuid]
1308 648e4196 Guido Trotter
1309 648e4196 Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1310 5768e6a6 René Nussbaumer
  def GetNodeGroup(self, uuid):
1311 5768e6a6 René Nussbaumer
    """Lookup a node group.
1312 5768e6a6 René Nussbaumer

1313 5768e6a6 René Nussbaumer
    @type uuid: string
1314 5768e6a6 René Nussbaumer
    @param uuid: group UUID
1315 5768e6a6 René Nussbaumer
    @rtype: L{objects.NodeGroup} or None
1316 5768e6a6 René Nussbaumer
    @return: nodegroup object, or None if not found
1317 5768e6a6 René Nussbaumer

1318 5768e6a6 René Nussbaumer
    """
1319 5768e6a6 René Nussbaumer
    return self._UnlockedGetNodeGroup(uuid)
1320 5768e6a6 René Nussbaumer
1321 5768e6a6 René Nussbaumer
  @locking.ssynchronized(_config_lock, shared=1)
1322 622444e5 Iustin Pop
  def GetAllNodeGroupsInfo(self):
1323 622444e5 Iustin Pop
    """Get the configuration of all node groups.
1324 622444e5 Iustin Pop

1325 622444e5 Iustin Pop
    """
1326 622444e5 Iustin Pop
    return dict(self._config_data.nodegroups)
1327 622444e5 Iustin Pop
1328 1ac6f2ad Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1329 1ac6f2ad Guido Trotter
  def GetNodeGroupList(self):
1330 1ac6f2ad Guido Trotter
    """Get a list of node groups.
1331 1ac6f2ad Guido Trotter

1332 1ac6f2ad Guido Trotter
    """
1333 1ac6f2ad Guido Trotter
    return self._config_data.nodegroups.keys()
1334 1ac6f2ad Guido Trotter
1335 dac81741 Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1336 dac81741 Michael Hanselmann
  def GetNodeGroupMembersByNodes(self, nodes):
1337 dac81741 Michael Hanselmann
    """Get nodes which are member in the same nodegroups as the given nodes.
1338 dac81741 Michael Hanselmann

1339 dac81741 Michael Hanselmann
    """
1340 dac81741 Michael Hanselmann
    ngfn = lambda node_name: self._UnlockedGetNodeInfo(node_name).group
1341 dac81741 Michael Hanselmann
    return frozenset(member_name
1342 dac81741 Michael Hanselmann
                     for node_name in nodes
1343 dac81741 Michael Hanselmann
                     for member_name in
1344 dac81741 Michael Hanselmann
                       self._UnlockedGetNodeGroup(ngfn(node_name)).members)
1345 dac81741 Michael Hanselmann
1346 080fbeea Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1347 080fbeea Michael Hanselmann
  def GetMultiNodeGroupInfo(self, group_uuids):
1348 080fbeea Michael Hanselmann
    """Get the configuration of multiple node groups.
1349 080fbeea Michael Hanselmann

1350 080fbeea Michael Hanselmann
    @param group_uuids: List of node group UUIDs
1351 080fbeea Michael Hanselmann
    @rtype: list
1352 080fbeea Michael Hanselmann
    @return: List of tuples of (group_uuid, group_info)
1353 080fbeea Michael Hanselmann

1354 080fbeea Michael Hanselmann
    """
1355 080fbeea Michael Hanselmann
    return [(uuid, self._UnlockedGetNodeGroup(uuid)) for uuid in group_uuids]
1356 080fbeea Michael Hanselmann
1357 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1358 0debfb35 Guido Trotter
  def AddInstance(self, instance, ec_id):
1359 a8083063 Iustin Pop
    """Add an instance to the config.
1360 a8083063 Iustin Pop

1361 a8083063 Iustin Pop
    This should be used after creating a new instance.
1362 a8083063 Iustin Pop

1363 c41eea6e Iustin Pop
    @type instance: L{objects.Instance}
1364 c41eea6e Iustin Pop
    @param instance: the instance object
1365 c41eea6e Iustin Pop

1366 a8083063 Iustin Pop
    """
1367 a8083063 Iustin Pop
    if not isinstance(instance, objects.Instance):
1368 a8083063 Iustin Pop
      raise errors.ProgrammerError("Invalid type passed to AddInstance")
1369 a8083063 Iustin Pop
1370 e00fb268 Iustin Pop
    if instance.disk_template != constants.DT_DISKLESS:
1371 e00fb268 Iustin Pop
      all_lvs = instance.MapLVsByNode()
1372 74a48621 Iustin Pop
      logging.info("Instance '%s' DISK_LAYOUT: %s", instance.name, all_lvs)
1373 923b1523 Iustin Pop
1374 e4640214 Guido Trotter
    all_macs = self._AllMACs()
1375 e4640214 Guido Trotter
    for nic in instance.nics:
1376 e4640214 Guido Trotter
      if nic.mac in all_macs:
1377 e4640214 Guido Trotter
        raise errors.ConfigurationError("Cannot add instance %s:"
1378 430b923c Iustin Pop
                                        " MAC address '%s' already in use." %
1379 430b923c Iustin Pop
                                        (instance.name, nic.mac))
1380 430b923c Iustin Pop
1381 0debfb35 Guido Trotter
    self._EnsureUUID(instance, ec_id)
1382 e4640214 Guido Trotter
1383 b989e85d Iustin Pop
    instance.serial_no = 1
1384 d693c864 Iustin Pop
    instance.ctime = instance.mtime = time.time()
1385 a8083063 Iustin Pop
    self._config_data.instances[instance.name] = instance
1386 81a49123 Iustin Pop
    self._config_data.cluster.serial_no += 1
1387 61cf6b5e Iustin Pop
    self._UnlockedReleaseDRBDMinors(instance.name)
1388 e8e079f3 Dimitris Aragiorgis
    self._UnlockedCommitTemporaryIps(ec_id)
1389 a8083063 Iustin Pop
    self._WriteConfig()
1390 a8083063 Iustin Pop
1391 0debfb35 Guido Trotter
  def _EnsureUUID(self, item, ec_id):
1392 430b923c Iustin Pop
    """Ensures a given object has a valid UUID.
1393 430b923c Iustin Pop

1394 430b923c Iustin Pop
    @param item: the instance or node to be checked
1395 0debfb35 Guido Trotter
    @param ec_id: the execution context id for the uuid reservation
1396 430b923c Iustin Pop

1397 430b923c Iustin Pop
    """
1398 430b923c Iustin Pop
    if not item.uuid:
1399 4fae38c5 Guido Trotter
      item.uuid = self._GenerateUniqueID(ec_id)
1400 be0fc05d Iustin Pop
    elif item.uuid in self._AllIDs(include_temporary=True):
1401 be0fc05d Iustin Pop
      raise errors.ConfigurationError("Cannot add '%s': UUID %s already"
1402 be0fc05d Iustin Pop
                                      " in use" % (item.name, item.uuid))
1403 430b923c Iustin Pop
1404 6a408fb2 Iustin Pop
  def _SetInstanceStatus(self, instance_name, status):
1405 6a408fb2 Iustin Pop
    """Set the instance's status to a given value.
1406 a8083063 Iustin Pop

1407 a8083063 Iustin Pop
    """
1408 2e04d454 Agata Murawska
    assert status in constants.ADMINST_ALL, \
1409 0d68c45d Iustin Pop
           "Invalid status '%s' passed to SetInstanceStatus" % (status,)
1410 a8083063 Iustin Pop
1411 a8083063 Iustin Pop
    if instance_name not in self._config_data.instances:
1412 3ecf6786 Iustin Pop
      raise errors.ConfigurationError("Unknown instance '%s'" %
1413 3ecf6786 Iustin Pop
                                      instance_name)
1414 a8083063 Iustin Pop
    instance = self._config_data.instances[instance_name]
1415 9ca8a7c5 Agata Murawska
    if instance.admin_state != status:
1416 9ca8a7c5 Agata Murawska
      instance.admin_state = status
1417 b989e85d Iustin Pop
      instance.serial_no += 1
1418 d693c864 Iustin Pop
      instance.mtime = time.time()
1419 455a3445 Iustin Pop
      self._WriteConfig()
1420 a8083063 Iustin Pop
1421 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1422 6a408fb2 Iustin Pop
  def MarkInstanceUp(self, instance_name):
1423 6a408fb2 Iustin Pop
    """Mark the instance status to up in the config.
1424 6a408fb2 Iustin Pop

1425 6a408fb2 Iustin Pop
    """
1426 57de31c0 Agata Murawska
    self._SetInstanceStatus(instance_name, constants.ADMINST_UP)
1427 57de31c0 Agata Murawska
1428 57de31c0 Agata Murawska
  @locking.ssynchronized(_config_lock)
1429 57de31c0 Agata Murawska
  def MarkInstanceOffline(self, instance_name):
1430 57de31c0 Agata Murawska
    """Mark the instance status to down in the config.
1431 57de31c0 Agata Murawska

1432 57de31c0 Agata Murawska
    """
1433 57de31c0 Agata Murawska
    self._SetInstanceStatus(instance_name, constants.ADMINST_OFFLINE)
1434 6a408fb2 Iustin Pop
1435 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1436 a8083063 Iustin Pop
  def RemoveInstance(self, instance_name):
1437 a8083063 Iustin Pop
    """Remove the instance from the configuration.
1438 a8083063 Iustin Pop

1439 a8083063 Iustin Pop
    """
1440 a8083063 Iustin Pop
    if instance_name not in self._config_data.instances:
1441 3ecf6786 Iustin Pop
      raise errors.ConfigurationError("Unknown instance '%s'" % instance_name)
1442 f396ad8c Vangelis Koukis
1443 f396ad8c Vangelis Koukis
    # If a network port has been allocated to the instance,
1444 f396ad8c Vangelis Koukis
    # return it to the pool of free ports.
1445 f396ad8c Vangelis Koukis
    inst = self._config_data.instances[instance_name]
1446 f396ad8c Vangelis Koukis
    network_port = getattr(inst, "network_port", None)
1447 f396ad8c Vangelis Koukis
    if network_port is not None:
1448 f396ad8c Vangelis Koukis
      self._config_data.cluster.tcpudp_port_pool.add(network_port)
1449 f396ad8c Vangelis Koukis
1450 ced51149 Dimitris Aragiorgis
    instance = self._UnlockedGetInstanceInfo(instance_name)
1451 ced51149 Dimitris Aragiorgis
1452 ced51149 Dimitris Aragiorgis
    for nic in instance.nics:
1453 9394f4d1 Dimitris Aragiorgis
      if nic.network and nic.ip:
1454 1b68f268 Helga Velroyen
        # Return all IP addresses to the respective address pools
1455 9394f4d1 Dimitris Aragiorgis
        self._UnlockedCommitIp(constants.RELEASE_ACTION, nic.network, nic.ip)
1456 ced51149 Dimitris Aragiorgis
1457 a8083063 Iustin Pop
    del self._config_data.instances[instance_name]
1458 81a49123 Iustin Pop
    self._config_data.cluster.serial_no += 1
1459 a8083063 Iustin Pop
    self._WriteConfig()
1460 a8083063 Iustin Pop
1461 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1462 fc95f88f Iustin Pop
  def RenameInstance(self, old_name, new_name):
1463 fc95f88f Iustin Pop
    """Rename an instance.
1464 fc95f88f Iustin Pop

1465 fc95f88f Iustin Pop
    This needs to be done in ConfigWriter and not by RemoveInstance
1466 fc95f88f Iustin Pop
    combined with AddInstance as only we can guarantee an atomic
1467 fc95f88f Iustin Pop
    rename.
1468 fc95f88f Iustin Pop

1469 fc95f88f Iustin Pop
    """
1470 fc95f88f Iustin Pop
    if old_name not in self._config_data.instances:
1471 fc95f88f Iustin Pop
      raise errors.ConfigurationError("Unknown instance '%s'" % old_name)
1472 ea642319 Michael Hanselmann
1473 ea642319 Michael Hanselmann
    # Operate on a copy to not loose instance object in case of a failure
1474 ea642319 Michael Hanselmann
    inst = self._config_data.instances[old_name].Copy()
1475 fc95f88f Iustin Pop
    inst.name = new_name
1476 b23c4333 Manuel Franceschini
1477 ea642319 Michael Hanselmann
    for (idx, disk) in enumerate(inst.disks):
1478 b23c4333 Manuel Franceschini
      if disk.dev_type == constants.LD_FILE:
1479 b23c4333 Manuel Franceschini
        # rename the file paths in logical and physical id
1480 b23c4333 Manuel Franceschini
        file_storage_dir = os.path.dirname(os.path.dirname(disk.logical_id[1]))
1481 ea642319 Michael Hanselmann
        disk.logical_id = (disk.logical_id[0],
1482 ea642319 Michael Hanselmann
                           utils.PathJoin(file_storage_dir, inst.name,
1483 ea642319 Michael Hanselmann
                                          "disk%s" % idx))
1484 ea642319 Michael Hanselmann
        disk.physical_id = disk.logical_id
1485 ea642319 Michael Hanselmann
1486 ea642319 Michael Hanselmann
    # Actually replace instance object
1487 ea642319 Michael Hanselmann
    del self._config_data.instances[old_name]
1488 ea642319 Michael Hanselmann
    self._config_data.instances[inst.name] = inst
1489 b23c4333 Manuel Franceschini
1490 1fc34c48 Michael Hanselmann
    # Force update of ssconf files
1491 1fc34c48 Michael Hanselmann
    self._config_data.cluster.serial_no += 1
1492 1fc34c48 Michael Hanselmann
1493 fc95f88f Iustin Pop
    self._WriteConfig()
1494 fc95f88f Iustin Pop
1495 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1496 a8083063 Iustin Pop
  def MarkInstanceDown(self, instance_name):
1497 a8083063 Iustin Pop
    """Mark the status of an instance to down in the configuration.
1498 a8083063 Iustin Pop

1499 a8083063 Iustin Pop
    """
1500 2e04d454 Agata Murawska
    self._SetInstanceStatus(instance_name, constants.ADMINST_DOWN)
1501 a8083063 Iustin Pop
1502 94bbfece Iustin Pop
  def _UnlockedGetInstanceList(self):
1503 94bbfece Iustin Pop
    """Get the list of instances.
1504 94bbfece Iustin Pop

1505 94bbfece Iustin Pop
    This function is for internal use, when the config lock is already held.
1506 94bbfece Iustin Pop

1507 94bbfece Iustin Pop
    """
1508 94bbfece Iustin Pop
    return self._config_data.instances.keys()
1509 94bbfece Iustin Pop
1510 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1511 a8083063 Iustin Pop
  def GetInstanceList(self):
1512 a8083063 Iustin Pop
    """Get the list of instances.
1513 a8083063 Iustin Pop

1514 c41eea6e Iustin Pop
    @return: array of instances, ex. ['instance2.example.com',
1515 c41eea6e Iustin Pop
        'instance1.example.com']
1516 a8083063 Iustin Pop

1517 a8083063 Iustin Pop
    """
1518 94bbfece Iustin Pop
    return self._UnlockedGetInstanceList()
1519 a8083063 Iustin Pop
1520 a8083063 Iustin Pop
  def ExpandInstanceName(self, short_name):
1521 a8083063 Iustin Pop
    """Attempt to expand an incomplete instance name.
1522 a8083063 Iustin Pop

1523 a8083063 Iustin Pop
    """
1524 fe698b38 Michael Hanselmann
    # Locking is done in L{ConfigWriter.GetInstanceList}
1525 fe698b38 Michael Hanselmann
    return _MatchNameComponentIgnoreCase(short_name, self.GetInstanceList())
1526 a8083063 Iustin Pop
1527 94bbfece Iustin Pop
  def _UnlockedGetInstanceInfo(self, instance_name):
1528 5bbd3f7f Michael Hanselmann
    """Returns information about an instance.
1529 94bbfece Iustin Pop

1530 94bbfece Iustin Pop
    This function is for internal use, when the config lock is already held.
1531 94bbfece Iustin Pop

1532 94bbfece Iustin Pop
    """
1533 94bbfece Iustin Pop
    if instance_name not in self._config_data.instances:
1534 94bbfece Iustin Pop
      return None
1535 94bbfece Iustin Pop
1536 94bbfece Iustin Pop
    return self._config_data.instances[instance_name]
1537 94bbfece Iustin Pop
1538 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1539 a8083063 Iustin Pop
  def GetInstanceInfo(self, instance_name):
1540 5bbd3f7f Michael Hanselmann
    """Returns information about an instance.
1541 a8083063 Iustin Pop

1542 5bbd3f7f Michael Hanselmann
    It takes the information from the configuration file. Other information of
1543 a8083063 Iustin Pop
    an instance are taken from the live systems.
1544 a8083063 Iustin Pop

1545 c41eea6e Iustin Pop
    @param instance_name: name of the instance, e.g.
1546 c41eea6e Iustin Pop
        I{instance1.example.com}
1547 a8083063 Iustin Pop

1548 c41eea6e Iustin Pop
    @rtype: L{objects.Instance}
1549 c41eea6e Iustin Pop
    @return: the instance object
1550 a8083063 Iustin Pop

1551 a8083063 Iustin Pop
    """
1552 94bbfece Iustin Pop
    return self._UnlockedGetInstanceInfo(instance_name)
1553 a8083063 Iustin Pop
1554 0b2de758 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1555 2674690b Michael Hanselmann
  def GetInstanceNodeGroups(self, instance_name, primary_only=False):
1556 2674690b Michael Hanselmann
    """Returns set of node group UUIDs for instance's nodes.
1557 2674690b Michael Hanselmann

1558 2674690b Michael Hanselmann
    @rtype: frozenset
1559 2674690b Michael Hanselmann

1560 2674690b Michael Hanselmann
    """
1561 2674690b Michael Hanselmann
    instance = self._UnlockedGetInstanceInfo(instance_name)
1562 2674690b Michael Hanselmann
    if not instance:
1563 2674690b Michael Hanselmann
      raise errors.ConfigurationError("Unknown instance '%s'" % instance_name)
1564 2674690b Michael Hanselmann
1565 2674690b Michael Hanselmann
    if primary_only:
1566 2674690b Michael Hanselmann
      nodes = [instance.primary_node]
1567 2674690b Michael Hanselmann
    else:
1568 2674690b Michael Hanselmann
      nodes = instance.all_nodes
1569 2674690b Michael Hanselmann
1570 2674690b Michael Hanselmann
    return frozenset(self._UnlockedGetNodeInfo(node_name).group
1571 2674690b Michael Hanselmann
                     for node_name in nodes)
1572 2674690b Michael Hanselmann
1573 2674690b Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1574 922610c9 Dimitris Aragiorgis
  def GetInstanceNetworks(self, instance_name):
1575 922610c9 Dimitris Aragiorgis
    """Returns set of network UUIDs for instance's nics.
1576 922610c9 Dimitris Aragiorgis

1577 922610c9 Dimitris Aragiorgis
    @rtype: frozenset
1578 922610c9 Dimitris Aragiorgis

1579 922610c9 Dimitris Aragiorgis
    """
1580 922610c9 Dimitris Aragiorgis
    instance = self._UnlockedGetInstanceInfo(instance_name)
1581 922610c9 Dimitris Aragiorgis
    if not instance:
1582 922610c9 Dimitris Aragiorgis
      raise errors.ConfigurationError("Unknown instance '%s'" % instance_name)
1583 922610c9 Dimitris Aragiorgis
1584 922610c9 Dimitris Aragiorgis
    networks = set()
1585 922610c9 Dimitris Aragiorgis
    for nic in instance.nics:
1586 922610c9 Dimitris Aragiorgis
      if nic.network:
1587 922610c9 Dimitris Aragiorgis
        networks.add(nic.network)
1588 922610c9 Dimitris Aragiorgis
1589 922610c9 Dimitris Aragiorgis
    return frozenset(networks)
1590 922610c9 Dimitris Aragiorgis
1591 922610c9 Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
1592 71333cb9 Iustin Pop
  def GetMultiInstanceInfo(self, instances):
1593 71333cb9 Iustin Pop
    """Get the configuration of multiple instances.
1594 71333cb9 Iustin Pop

1595 71333cb9 Iustin Pop
    @param instances: list of instance names
1596 71333cb9 Iustin Pop
    @rtype: list
1597 71333cb9 Iustin Pop
    @return: list of tuples (instance, instance_info), where
1598 71333cb9 Iustin Pop
        instance_info is what would GetInstanceInfo return for the
1599 71333cb9 Iustin Pop
        node, while keeping the original order
1600 71333cb9 Iustin Pop

1601 71333cb9 Iustin Pop
    """
1602 71333cb9 Iustin Pop
    return [(name, self._UnlockedGetInstanceInfo(name)) for name in instances]
1603 71333cb9 Iustin Pop
1604 71333cb9 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1605 0b2de758 Iustin Pop
  def GetAllInstancesInfo(self):
1606 0b2de758 Iustin Pop
    """Get the configuration of all instances.
1607 0b2de758 Iustin Pop

1608 0b2de758 Iustin Pop
    @rtype: dict
1609 5fcc718f Iustin Pop
    @return: dict of (instance, instance_info), where instance_info is what
1610 0b2de758 Iustin Pop
              would GetInstanceInfo return for the node
1611 0b2de758 Iustin Pop

1612 0b2de758 Iustin Pop
    """
1613 64d3bd52 Guido Trotter
    my_dict = dict([(instance, self._UnlockedGetInstanceInfo(instance))
1614 64d3bd52 Guido Trotter
                    for instance in self._UnlockedGetInstanceList()])
1615 0b2de758 Iustin Pop
    return my_dict
1616 0b2de758 Iustin Pop
1617 cc19798f Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1618 cc19798f Michael Hanselmann
  def GetInstancesInfoByFilter(self, filter_fn):
1619 cc19798f Michael Hanselmann
    """Get instance configuration with a filter.
1620 cc19798f Michael Hanselmann

1621 cc19798f Michael Hanselmann
    @type filter_fn: callable
1622 cc19798f Michael Hanselmann
    @param filter_fn: Filter function receiving instance object as parameter,
1623 cc19798f Michael Hanselmann
      returning boolean. Important: this function is called while the
1624 cc19798f Michael Hanselmann
      configuration locks is held. It must not do any complex work or call
1625 cc19798f Michael Hanselmann
      functions potentially leading to a deadlock. Ideally it doesn't call any
1626 cc19798f Michael Hanselmann
      other functions and just compares instance attributes.
1627 cc19798f Michael Hanselmann

1628 cc19798f Michael Hanselmann
    """
1629 cc19798f Michael Hanselmann
    return dict((name, inst)
1630 cc19798f Michael Hanselmann
                for (name, inst) in self._config_data.instances.items()
1631 cc19798f Michael Hanselmann
                if filter_fn(inst))
1632 cc19798f Michael Hanselmann
1633 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1634 0debfb35 Guido Trotter
  def AddNode(self, node, ec_id):
1635 a8083063 Iustin Pop
    """Add a node to the configuration.
1636 a8083063 Iustin Pop

1637 c41eea6e Iustin Pop
    @type node: L{objects.Node}
1638 c41eea6e Iustin Pop
    @param node: a Node instance
1639 a8083063 Iustin Pop

1640 a8083063 Iustin Pop
    """
1641 099c52ad Iustin Pop
    logging.info("Adding node %s to configuration", node.name)
1642 d8470559 Michael Hanselmann
1643 0debfb35 Guido Trotter
    self._EnsureUUID(node, ec_id)
1644 430b923c Iustin Pop
1645 b989e85d Iustin Pop
    node.serial_no = 1
1646 d693c864 Iustin Pop
    node.ctime = node.mtime = time.time()
1647 f936c153 Iustin Pop
    self._UnlockedAddNodeToGroup(node.name, node.group)
1648 a8083063 Iustin Pop
    self._config_data.nodes[node.name] = node
1649 b9f72b4e Iustin Pop
    self._config_data.cluster.serial_no += 1
1650 a8083063 Iustin Pop
    self._WriteConfig()
1651 a8083063 Iustin Pop
1652 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
1653 a8083063 Iustin Pop
  def RemoveNode(self, node_name):
1654 a8083063 Iustin Pop
    """Remove a node from the configuration.
1655 a8083063 Iustin Pop

1656 a8083063 Iustin Pop
    """
1657 099c52ad Iustin Pop
    logging.info("Removing node %s from configuration", node_name)
1658 d8470559 Michael Hanselmann
1659 a8083063 Iustin Pop
    if node_name not in self._config_data.nodes:
1660 3ecf6786 Iustin Pop
      raise errors.ConfigurationError("Unknown node '%s'" % node_name)
1661 a8083063 Iustin Pop
1662 190e3cb6 Guido Trotter
    self._UnlockedRemoveNodeFromGroup(self._config_data.nodes[node_name])
1663 a8083063 Iustin Pop
    del self._config_data.nodes[node_name]
1664 b9f72b4e Iustin Pop
    self._config_data.cluster.serial_no += 1
1665 a8083063 Iustin Pop
    self._WriteConfig()
1666 a8083063 Iustin Pop
1667 a8083063 Iustin Pop
  def ExpandNodeName(self, short_name):
1668 fe698b38 Michael Hanselmann
    """Attempt to expand an incomplete node name.
1669 a8083063 Iustin Pop

1670 a8083063 Iustin Pop
    """
1671 fe698b38 Michael Hanselmann
    # Locking is done in L{ConfigWriter.GetNodeList}
1672 fe698b38 Michael Hanselmann
    return _MatchNameComponentIgnoreCase(short_name, self.GetNodeList())
1673 a8083063 Iustin Pop
1674 f78ede4e Guido Trotter
  def _UnlockedGetNodeInfo(self, node_name):
1675 a8083063 Iustin Pop
    """Get the configuration of a node, as stored in the config.
1676 a8083063 Iustin Pop

1677 c41eea6e Iustin Pop
    This function is for internal use, when the config lock is already
1678 c41eea6e Iustin Pop
    held.
1679 f78ede4e Guido Trotter

1680 c41eea6e Iustin Pop
    @param node_name: the node name, e.g. I{node1.example.com}
1681 a8083063 Iustin Pop

1682 c41eea6e Iustin Pop
    @rtype: L{objects.Node}
1683 c41eea6e Iustin Pop
    @return: the node object
1684 a8083063 Iustin Pop

1685 a8083063 Iustin Pop
    """
1686 a8083063 Iustin Pop
    if node_name not in self._config_data.nodes:
1687 a8083063 Iustin Pop
      return None
1688 a8083063 Iustin Pop
1689 a8083063 Iustin Pop
    return self._config_data.nodes[node_name]
1690 a8083063 Iustin Pop
1691 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1692 f78ede4e Guido Trotter
  def GetNodeInfo(self, node_name):
1693 f78ede4e Guido Trotter
    """Get the configuration of a node, as stored in the config.
1694 f78ede4e Guido Trotter

1695 c41eea6e Iustin Pop
    This is just a locked wrapper over L{_UnlockedGetNodeInfo}.
1696 f78ede4e Guido Trotter

1697 c41eea6e Iustin Pop
    @param node_name: the node name, e.g. I{node1.example.com}
1698 c41eea6e Iustin Pop

1699 c41eea6e Iustin Pop
    @rtype: L{objects.Node}
1700 c41eea6e Iustin Pop
    @return: the node object
1701 f78ede4e Guido Trotter

1702 f78ede4e Guido Trotter
    """
1703 f78ede4e Guido Trotter
    return self._UnlockedGetNodeInfo(node_name)
1704 f78ede4e Guido Trotter
1705 8bf9e9a5 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1706 8bf9e9a5 Iustin Pop
  def GetNodeInstances(self, node_name):
1707 8bf9e9a5 Iustin Pop
    """Get the instances of a node, as stored in the config.
1708 8bf9e9a5 Iustin Pop

1709 8bf9e9a5 Iustin Pop
    @param node_name: the node name, e.g. I{node1.example.com}
1710 8bf9e9a5 Iustin Pop

1711 8bf9e9a5 Iustin Pop
    @rtype: (list, list)
1712 8bf9e9a5 Iustin Pop
    @return: a tuple with two lists: the primary and the secondary instances
1713 8bf9e9a5 Iustin Pop

1714 8bf9e9a5 Iustin Pop
    """
1715 8bf9e9a5 Iustin Pop
    pri = []
1716 8bf9e9a5 Iustin Pop
    sec = []
1717 8bf9e9a5 Iustin Pop
    for inst in self._config_data.instances.values():
1718 8bf9e9a5 Iustin Pop
      if inst.primary_node == node_name:
1719 8bf9e9a5 Iustin Pop
        pri.append(inst.name)
1720 8bf9e9a5 Iustin Pop
      if node_name in inst.secondary_nodes:
1721 8bf9e9a5 Iustin Pop
        sec.append(inst.name)
1722 8bf9e9a5 Iustin Pop
    return (pri, sec)
1723 8bf9e9a5 Iustin Pop
1724 c71b049c Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1725 c71b049c Michael Hanselmann
  def GetNodeGroupInstances(self, uuid, primary_only=False):
1726 c71b049c Michael Hanselmann
    """Get the instances of a node group.
1727 c71b049c Michael Hanselmann

1728 c71b049c Michael Hanselmann
    @param uuid: Node group UUID
1729 c71b049c Michael Hanselmann
    @param primary_only: Whether to only consider primary nodes
1730 c71b049c Michael Hanselmann
    @rtype: frozenset
1731 c71b049c Michael Hanselmann
    @return: List of instance names in node group
1732 c71b049c Michael Hanselmann

1733 c71b049c Michael Hanselmann
    """
1734 c71b049c Michael Hanselmann
    if primary_only:
1735 c71b049c Michael Hanselmann
      nodes_fn = lambda inst: [inst.primary_node]
1736 c71b049c Michael Hanselmann
    else:
1737 c71b049c Michael Hanselmann
      nodes_fn = lambda inst: inst.all_nodes
1738 c71b049c Michael Hanselmann
1739 c71b049c Michael Hanselmann
    return frozenset(inst.name
1740 c71b049c Michael Hanselmann
                     for inst in self._config_data.instances.values()
1741 c71b049c Michael Hanselmann
                     for node_name in nodes_fn(inst)
1742 c71b049c Michael Hanselmann
                     if self._UnlockedGetNodeInfo(node_name).group == uuid)
1743 c71b049c Michael Hanselmann
1744 f78ede4e Guido Trotter
  def _UnlockedGetNodeList(self):
1745 a8083063 Iustin Pop
    """Return the list of nodes which are in the configuration.
1746 a8083063 Iustin Pop

1747 c41eea6e Iustin Pop
    This function is for internal use, when the config lock is already
1748 c41eea6e Iustin Pop
    held.
1749 c41eea6e Iustin Pop

1750 c41eea6e Iustin Pop
    @rtype: list
1751 f78ede4e Guido Trotter

1752 a8083063 Iustin Pop
    """
1753 a8083063 Iustin Pop
    return self._config_data.nodes.keys()
1754 a8083063 Iustin Pop
1755 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
1756 f78ede4e Guido Trotter
  def GetNodeList(self):
1757 f78ede4e Guido Trotter
    """Return the list of nodes which are in the configuration.
1758 f78ede4e Guido Trotter

1759 f78ede4e Guido Trotter
    """
1760 f78ede4e Guido Trotter
    return self._UnlockedGetNodeList()
1761 f78ede4e Guido Trotter
1762 6819dc49 Iustin Pop
  def _UnlockedGetOnlineNodeList(self):
1763 94a02bb5 Iustin Pop
    """Return the list of nodes which are online.
1764 94a02bb5 Iustin Pop

1765 94a02bb5 Iustin Pop
    """
1766 94a02bb5 Iustin Pop
    all_nodes = [self._UnlockedGetNodeInfo(node)
1767 94a02bb5 Iustin Pop
                 for node in self._UnlockedGetNodeList()]
1768 94a02bb5 Iustin Pop
    return [node.name for node in all_nodes if not node.offline]
1769 94a02bb5 Iustin Pop
1770 94a02bb5 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1771 6819dc49 Iustin Pop
  def GetOnlineNodeList(self):
1772 6819dc49 Iustin Pop
    """Return the list of nodes which are online.
1773 6819dc49 Iustin Pop

1774 6819dc49 Iustin Pop
    """
1775 6819dc49 Iustin Pop
    return self._UnlockedGetOnlineNodeList()
1776 6819dc49 Iustin Pop
1777 6819dc49 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1778 075b62ca Iustin Pop
  def GetVmCapableNodeList(self):
1779 075b62ca Iustin Pop
    """Return the list of nodes which are not vm capable.
1780 075b62ca Iustin Pop

1781 075b62ca Iustin Pop
    """
1782 075b62ca Iustin Pop
    all_nodes = [self._UnlockedGetNodeInfo(node)
1783 075b62ca Iustin Pop
                 for node in self._UnlockedGetNodeList()]
1784 075b62ca Iustin Pop
    return [node.name for node in all_nodes if node.vm_capable]
1785 075b62ca Iustin Pop
1786 075b62ca Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1787 8bf9e9a5 Iustin Pop
  def GetNonVmCapableNodeList(self):
1788 8bf9e9a5 Iustin Pop
    """Return the list of nodes which are not vm capable.
1789 8bf9e9a5 Iustin Pop

1790 8bf9e9a5 Iustin Pop
    """
1791 8bf9e9a5 Iustin Pop
    all_nodes = [self._UnlockedGetNodeInfo(node)
1792 8bf9e9a5 Iustin Pop
                 for node in self._UnlockedGetNodeList()]
1793 8bf9e9a5 Iustin Pop
    return [node.name for node in all_nodes if not node.vm_capable]
1794 8bf9e9a5 Iustin Pop
1795 8bf9e9a5 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1796 f5eaa3c1 Iustin Pop
  def GetMultiNodeInfo(self, nodes):
1797 f5eaa3c1 Iustin Pop
    """Get the configuration of multiple nodes.
1798 f5eaa3c1 Iustin Pop

1799 f5eaa3c1 Iustin Pop
    @param nodes: list of node names
1800 f5eaa3c1 Iustin Pop
    @rtype: list
1801 f5eaa3c1 Iustin Pop
    @return: list of tuples of (node, node_info), where node_info is
1802 f5eaa3c1 Iustin Pop
        what would GetNodeInfo return for the node, in the original
1803 f5eaa3c1 Iustin Pop
        order
1804 f5eaa3c1 Iustin Pop

1805 f5eaa3c1 Iustin Pop
    """
1806 f5eaa3c1 Iustin Pop
    return [(name, self._UnlockedGetNodeInfo(name)) for name in nodes]
1807 f5eaa3c1 Iustin Pop
1808 f5eaa3c1 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1809 d65e5776 Iustin Pop
  def GetAllNodesInfo(self):
1810 d65e5776 Iustin Pop
    """Get the configuration of all nodes.
1811 d65e5776 Iustin Pop

1812 d65e5776 Iustin Pop
    @rtype: dict
1813 ec0292f1 Iustin Pop
    @return: dict of (node, node_info), where node_info is what
1814 d65e5776 Iustin Pop
              would GetNodeInfo return for the node
1815 d65e5776 Iustin Pop

1816 d65e5776 Iustin Pop
    """
1817 ee14d800 Michael Hanselmann
    return self._UnlockedGetAllNodesInfo()
1818 ee14d800 Michael Hanselmann
1819 ee14d800 Michael Hanselmann
  def _UnlockedGetAllNodesInfo(self):
1820 ee14d800 Michael Hanselmann
    """Gets configuration of all nodes.
1821 ee14d800 Michael Hanselmann

1822 ee14d800 Michael Hanselmann
    @note: See L{GetAllNodesInfo}
1823 ee14d800 Michael Hanselmann

1824 ee14d800 Michael Hanselmann
    """
1825 ee14d800 Michael Hanselmann
    return dict([(node, self._UnlockedGetNodeInfo(node))
1826 ee14d800 Michael Hanselmann
                 for node in self._UnlockedGetNodeList()])
1827 d65e5776 Iustin Pop
1828 9d5b1371 Michael Hanselmann
  @locking.ssynchronized(_config_lock, shared=1)
1829 9d5b1371 Michael Hanselmann
  def GetNodeGroupsFromNodes(self, nodes):
1830 9d5b1371 Michael Hanselmann
    """Returns groups for a list of nodes.
1831 9d5b1371 Michael Hanselmann

1832 9d5b1371 Michael Hanselmann
    @type nodes: list of string
1833 9d5b1371 Michael Hanselmann
    @param nodes: List of node names
1834 9d5b1371 Michael Hanselmann
    @rtype: frozenset
1835 9d5b1371 Michael Hanselmann

1836 9d5b1371 Michael Hanselmann
    """
1837 9d5b1371 Michael Hanselmann
    return frozenset(self._UnlockedGetNodeInfo(name).group for name in nodes)
1838 9d5b1371 Michael Hanselmann
1839 23f06b2b Iustin Pop
  def _UnlockedGetMasterCandidateStats(self, exceptions=None):
1840 ec0292f1 Iustin Pop
    """Get the number of current and maximum desired and possible candidates.
1841 ec0292f1 Iustin Pop

1842 23f06b2b Iustin Pop
    @type exceptions: list
1843 23f06b2b Iustin Pop
    @param exceptions: if passed, list of nodes that should be ignored
1844 ec0292f1 Iustin Pop
    @rtype: tuple
1845 e623dbe3 Guido Trotter
    @return: tuple of (current, desired and possible, possible)
1846 ec0292f1 Iustin Pop

1847 ec0292f1 Iustin Pop
    """
1848 e623dbe3 Guido Trotter
    mc_now = mc_should = mc_max = 0
1849 23f06b2b Iustin Pop
    for node in self._config_data.nodes.values():
1850 23f06b2b Iustin Pop
      if exceptions and node.name in exceptions:
1851 23f06b2b Iustin Pop
        continue
1852 490acd18 Iustin Pop
      if not (node.offline or node.drained) and node.master_capable:
1853 ec0292f1 Iustin Pop
        mc_max += 1
1854 ec0292f1 Iustin Pop
      if node.master_candidate:
1855 ec0292f1 Iustin Pop
        mc_now += 1
1856 e623dbe3 Guido Trotter
    mc_should = min(mc_max, self._config_data.cluster.candidate_pool_size)
1857 e623dbe3 Guido Trotter
    return (mc_now, mc_should, mc_max)
1858 ec0292f1 Iustin Pop
1859 ec0292f1 Iustin Pop
  @locking.ssynchronized(_config_lock, shared=1)
1860 23f06b2b Iustin Pop
  def GetMasterCandidateStats(self, exceptions=None):
1861 ec0292f1 Iustin Pop
    """Get the number of current and maximum possible candidates.
1862 ec0292f1 Iustin Pop

1863 ec0292f1 Iustin Pop
    This is just a wrapper over L{_UnlockedGetMasterCandidateStats}.
1864 ec0292f1 Iustin Pop

1865 23f06b2b Iustin Pop
    @type exceptions: list
1866 23f06b2b Iustin Pop
    @param exceptions: if passed, list of nodes that should be ignored
1867 ec0292f1 Iustin Pop
    @rtype: tuple
1868 ec0292f1 Iustin Pop
    @return: tuple of (current, max)
1869 ec0292f1 Iustin Pop

1870 ec0292f1 Iustin Pop
    """
1871 23f06b2b Iustin Pop
    return self._UnlockedGetMasterCandidateStats(exceptions)
1872 ec0292f1 Iustin Pop
1873 ec0292f1 Iustin Pop
  @locking.ssynchronized(_config_lock)
1874 44485f49 Guido Trotter
  def MaintainCandidatePool(self, exceptions):
1875 ec0292f1 Iustin Pop
    """Try to grow the candidate pool to the desired size.
1876 ec0292f1 Iustin Pop

1877 44485f49 Guido Trotter
    @type exceptions: list
1878 44485f49 Guido Trotter
    @param exceptions: if passed, list of nodes that should be ignored
1879 ec0292f1 Iustin Pop
    @rtype: list
1880 ee513a66 Iustin Pop
    @return: list with the adjusted nodes (L{objects.Node} instances)
1881 ec0292f1 Iustin Pop

1882 ec0292f1 Iustin Pop
    """
1883 44485f49 Guido Trotter
    mc_now, mc_max, _ = self._UnlockedGetMasterCandidateStats(exceptions)
1884 ec0292f1 Iustin Pop
    mod_list = []
1885 ec0292f1 Iustin Pop
    if mc_now < mc_max:
1886 ec0292f1 Iustin Pop
      node_list = self._config_data.nodes.keys()
1887 ec0292f1 Iustin Pop
      random.shuffle(node_list)
1888 ec0292f1 Iustin Pop
      for name in node_list:
1889 ec0292f1 Iustin Pop
        if mc_now >= mc_max:
1890 ec0292f1 Iustin Pop
          break
1891 ec0292f1 Iustin Pop
        node = self._config_data.nodes[name]
1892 44485f49 Guido Trotter
        if (node.master_candidate or node.offline or node.drained or
1893 490acd18 Iustin Pop
            node.name in exceptions or not node.master_capable):
1894 ec0292f1 Iustin Pop
          continue
1895 ee513a66 Iustin Pop
        mod_list.append(node)
1896 ec0292f1 Iustin Pop
        node.master_candidate = True
1897 ec0292f1 Iustin Pop
        node.serial_no += 1
1898 ec0292f1 Iustin Pop
        mc_now += 1
1899 ec0292f1 Iustin Pop
      if mc_now != mc_max:
1900 ec0292f1 Iustin Pop
        # this should not happen
1901 ec0292f1 Iustin Pop
        logging.warning("Warning: MaintainCandidatePool didn't manage to"
1902 ec0292f1 Iustin Pop
                        " fill the candidate pool (%d/%d)", mc_now, mc_max)
1903 ec0292f1 Iustin Pop
      if mod_list:
1904 ec0292f1 Iustin Pop
        self._config_data.cluster.serial_no += 1
1905 ec0292f1 Iustin Pop
        self._WriteConfig()
1906 ec0292f1 Iustin Pop
1907 ec0292f1 Iustin Pop
    return mod_list
1908 ec0292f1 Iustin Pop
1909 190e3cb6 Guido Trotter
  def _UnlockedAddNodeToGroup(self, node_name, nodegroup_uuid):
1910 190e3cb6 Guido Trotter
    """Add a given node to the specified group.
1911 190e3cb6 Guido Trotter

1912 190e3cb6 Guido Trotter
    """
1913 190e3cb6 Guido Trotter
    if nodegroup_uuid not in self._config_data.nodegroups:
1914 190e3cb6 Guido Trotter
      # This can happen if a node group gets deleted between its lookup and
1915 190e3cb6 Guido Trotter
      # when we're adding the first node to it, since we don't keep a lock in
1916 190e3cb6 Guido Trotter
      # the meantime. It's ok though, as we'll fail cleanly if the node group
1917 190e3cb6 Guido Trotter
      # is not found anymore.
1918 f936c153 Iustin Pop
      raise errors.OpExecError("Unknown node group: %s" % nodegroup_uuid)
1919 190e3cb6 Guido Trotter
    if node_name not in self._config_data.nodegroups[nodegroup_uuid].members:
1920 190e3cb6 Guido Trotter
      self._config_data.nodegroups[nodegroup_uuid].members.append(node_name)
1921 190e3cb6 Guido Trotter
1922 190e3cb6 Guido Trotter
  def _UnlockedRemoveNodeFromGroup(self, node):
1923 190e3cb6 Guido Trotter
    """Remove a given node from its group.
1924 190e3cb6 Guido Trotter

1925 190e3cb6 Guido Trotter
    """
1926 f936c153 Iustin Pop
    nodegroup = node.group
1927 190e3cb6 Guido Trotter
    if nodegroup not in self._config_data.nodegroups:
1928 f936c153 Iustin Pop
      logging.warning("Warning: node '%s' has unknown node group '%s'"
1929 190e3cb6 Guido Trotter
                      " (while being removed from it)", node.name, nodegroup)
1930 190e3cb6 Guido Trotter
    nodegroup_obj = self._config_data.nodegroups[nodegroup]
1931 190e3cb6 Guido Trotter
    if node.name not in nodegroup_obj.members:
1932 f936c153 Iustin Pop
      logging.warning("Warning: node '%s' not a member of its node group '%s'"
1933 190e3cb6 Guido Trotter
                      " (while being removed from it)", node.name, nodegroup)
1934 190e3cb6 Guido Trotter
    else:
1935 190e3cb6 Guido Trotter
      nodegroup_obj.members.remove(node.name)
1936 190e3cb6 Guido Trotter
1937 54c31fd3 Michael Hanselmann
  @locking.ssynchronized(_config_lock)
1938 54c31fd3 Michael Hanselmann
  def AssignGroupNodes(self, mods):
1939 54c31fd3 Michael Hanselmann
    """Changes the group of a number of nodes.
1940 54c31fd3 Michael Hanselmann

1941 54c31fd3 Michael Hanselmann
    @type mods: list of tuples; (node name, new group UUID)
1942 1d4930b9 Michael Hanselmann
    @param mods: Node membership modifications
1943 54c31fd3 Michael Hanselmann

1944 54c31fd3 Michael Hanselmann
    """
1945 54c31fd3 Michael Hanselmann
    groups = self._config_data.nodegroups
1946 54c31fd3 Michael Hanselmann
    nodes = self._config_data.nodes
1947 54c31fd3 Michael Hanselmann
1948 54c31fd3 Michael Hanselmann
    resmod = []
1949 54c31fd3 Michael Hanselmann
1950 54c31fd3 Michael Hanselmann
    # Try to resolve names/UUIDs first
1951 54c31fd3 Michael Hanselmann
    for (node_name, new_group_uuid) in mods:
1952 54c31fd3 Michael Hanselmann
      try:
1953 54c31fd3 Michael Hanselmann
        node = nodes[node_name]
1954 54c31fd3 Michael Hanselmann
      except KeyError:
1955 54c31fd3 Michael Hanselmann
        raise errors.ConfigurationError("Unable to find node '%s'" % node_name)
1956 54c31fd3 Michael Hanselmann
1957 54c31fd3 Michael Hanselmann
      if node.group == new_group_uuid:
1958 54c31fd3 Michael Hanselmann
        # Node is being assigned to its current group
1959 54c31fd3 Michael Hanselmann
        logging.debug("Node '%s' was assigned to its current group (%s)",
1960 54c31fd3 Michael Hanselmann
                      node_name, node.group)
1961 54c31fd3 Michael Hanselmann
        continue
1962 54c31fd3 Michael Hanselmann
1963 54c31fd3 Michael Hanselmann
      # Try to find current group of node
1964 54c31fd3 Michael Hanselmann
      try:
1965 54c31fd3 Michael Hanselmann
        old_group = groups[node.group]
1966 54c31fd3 Michael Hanselmann
      except KeyError:
1967 54c31fd3 Michael Hanselmann
        raise errors.ConfigurationError("Unable to find old group '%s'" %
1968 54c31fd3 Michael Hanselmann
                                        node.group)
1969 54c31fd3 Michael Hanselmann
1970 54c31fd3 Michael Hanselmann
      # Try to find new group for node
1971 54c31fd3 Michael Hanselmann
      try:
1972 54c31fd3 Michael Hanselmann
        new_group = groups[new_group_uuid]
1973 54c31fd3 Michael Hanselmann
      except KeyError:
1974 54c31fd3 Michael Hanselmann
        raise errors.ConfigurationError("Unable to find new group '%s'" %
1975 54c31fd3 Michael Hanselmann
                                        new_group_uuid)
1976 54c31fd3 Michael Hanselmann
1977 54c31fd3 Michael Hanselmann
      assert node.name in old_group.members, \
1978 54c31fd3 Michael Hanselmann
        ("Inconsistent configuration: node '%s' not listed in members for its"
1979 54c31fd3 Michael Hanselmann
         " old group '%s'" % (node.name, old_group.uuid))
1980 54c31fd3 Michael Hanselmann
      assert node.name not in new_group.members, \
1981 54c31fd3 Michael Hanselmann
        ("Inconsistent configuration: node '%s' already listed in members for"
1982 54c31fd3 Michael Hanselmann
         " its new group '%s'" % (node.name, new_group.uuid))
1983 54c31fd3 Michael Hanselmann
1984 54c31fd3 Michael Hanselmann
      resmod.append((node, old_group, new_group))
1985 54c31fd3 Michael Hanselmann
1986 54c31fd3 Michael Hanselmann
    # Apply changes
1987 54c31fd3 Michael Hanselmann
    for (node, old_group, new_group) in resmod:
1988 54c31fd3 Michael Hanselmann
      assert node.uuid != new_group.uuid and old_group.uuid != new_group.uuid, \
1989 54c31fd3 Michael Hanselmann
        "Assigning to current group is not possible"
1990 54c31fd3 Michael Hanselmann
1991 54c31fd3 Michael Hanselmann
      node.group = new_group.uuid
1992 54c31fd3 Michael Hanselmann
1993 54c31fd3 Michael Hanselmann
      # Update members of involved groups
1994 54c31fd3 Michael Hanselmann
      if node.name in old_group.members:
1995 54c31fd3 Michael Hanselmann
        old_group.members.remove(node.name)
1996 54c31fd3 Michael Hanselmann
      if node.name not in new_group.members:
1997 54c31fd3 Michael Hanselmann
        new_group.members.append(node.name)
1998 54c31fd3 Michael Hanselmann
1999 54c31fd3 Michael Hanselmann
    # Update timestamps and serials (only once per node/group object)
2000 54c31fd3 Michael Hanselmann
    now = time.time()
2001 75191077 Michael Hanselmann
    for obj in frozenset(itertools.chain(*resmod)): # pylint: disable=W0142
2002 54c31fd3 Michael Hanselmann
      obj.serial_no += 1
2003 54c31fd3 Michael Hanselmann
      obj.mtime = now
2004 54c31fd3 Michael Hanselmann
2005 54c31fd3 Michael Hanselmann
    # Force ssconf update
2006 54c31fd3 Michael Hanselmann
    self._config_data.cluster.serial_no += 1
2007 54c31fd3 Michael Hanselmann
2008 54c31fd3 Michael Hanselmann
    self._WriteConfig()
2009 54c31fd3 Michael Hanselmann
2010 a8083063 Iustin Pop
  def _BumpSerialNo(self):
2011 a8083063 Iustin Pop
    """Bump up the serial number of the config.
2012 a8083063 Iustin Pop

2013 a8083063 Iustin Pop
    """
2014 9d38c6e1 Iustin Pop
    self._config_data.serial_no += 1
2015 d693c864 Iustin Pop
    self._config_data.mtime = time.time()
2016 a8083063 Iustin Pop
2017 76d5d3a3 Iustin Pop
  def _AllUUIDObjects(self):
2018 76d5d3a3 Iustin Pop
    """Returns all objects with uuid attributes.
2019 76d5d3a3 Iustin Pop

2020 76d5d3a3 Iustin Pop
    """
2021 76d5d3a3 Iustin Pop
    return (self._config_data.instances.values() +
2022 76d5d3a3 Iustin Pop
            self._config_data.nodes.values() +
2023 3df43542 Guido Trotter
            self._config_data.nodegroups.values() +
2024 e0519c34 Dimitris Aragiorgis
            self._config_data.networks.values() +
2025 76d5d3a3 Iustin Pop
            [self._config_data.cluster])
2026 76d5d3a3 Iustin Pop
2027 eb180fe2 Iustin Pop
  def _OpenConfig(self, accept_foreign):
2028 a8083063 Iustin Pop
    """Read the config data from disk.
2029 a8083063 Iustin Pop

2030 a8083063 Iustin Pop
    """
2031 13998ef2 Michael Hanselmann
    raw_data = utils.ReadFile(self._cfg_file)
2032 13998ef2 Michael Hanselmann
2033 a8083063 Iustin Pop
    try:
2034 13998ef2 Michael Hanselmann
      data = objects.ConfigData.FromDict(serializer.Load(raw_data))
2035 13998ef2 Michael Hanselmann
    except Exception, err:
2036 13998ef2 Michael Hanselmann
      raise errors.ConfigurationError(err)
2037 5b263ed7 Michael Hanselmann
2038 5b263ed7 Michael Hanselmann
    # Make sure the configuration has the right version
2039 5b263ed7 Michael Hanselmann
    _ValidateConfig(data)
2040 5b263ed7 Michael Hanselmann
2041 3ccb3a64 Michael Hanselmann
    if (not hasattr(data, "cluster") or
2042 3ccb3a64 Michael Hanselmann
        not hasattr(data.cluster, "rsahostkeypub")):
2043 3ecf6786 Iustin Pop
      raise errors.ConfigurationError("Incomplete configuration"
2044 243cdbcc Michael Hanselmann
                                      " (missing cluster.rsahostkeypub)")
2045 90d726a8 Iustin Pop
2046 eb180fe2 Iustin Pop
    if data.cluster.master_node != self._my_hostname and not accept_foreign:
2047 eb180fe2 Iustin Pop
      msg = ("The configuration denotes node %s as master, while my"
2048 eb180fe2 Iustin Pop
             " hostname is %s; opening a foreign configuration is only"
2049 eb180fe2 Iustin Pop
             " possible in accept_foreign mode" %
2050 eb180fe2 Iustin Pop
             (data.cluster.master_node, self._my_hostname))
2051 eb180fe2 Iustin Pop
      raise errors.ConfigurationError(msg)
2052 eb180fe2 Iustin Pop
2053 a8083063 Iustin Pop
    self._config_data = data
2054 3c7f6c44 Iustin Pop
    # reset the last serial as -1 so that the next write will cause
2055 0779e3aa Iustin Pop
    # ssconf update
2056 0779e3aa Iustin Pop
    self._last_cluster_serial = -1
2057 a8083063 Iustin Pop
2058 45f62156 Bernardo Dal Seno
    # Upgrade configuration if needed
2059 76d5d3a3 Iustin Pop
    self._UpgradeConfig()
2060 76d5d3a3 Iustin Pop
2061 bd407597 Iustin Pop
    self._cfg_id = utils.GetFileID(path=self._cfg_file)
2062 bd407597 Iustin Pop
2063 76d5d3a3 Iustin Pop
  def _UpgradeConfig(self):
2064 45f62156 Bernardo Dal Seno
    """Run any upgrade steps.
2065 76d5d3a3 Iustin Pop

2066 45f62156 Bernardo Dal Seno
    This method performs both in-object upgrades and also update some data
2067 45f62156 Bernardo Dal Seno
    elements that need uniqueness across the whole configuration or interact
2068 45f62156 Bernardo Dal Seno
    with other objects.
2069 76d5d3a3 Iustin Pop

2070 111c4e2f Guido Trotter
    @warning: this function will call L{_WriteConfig()}, but also
2071 111c4e2f Guido Trotter
        L{DropECReservations} so it needs to be called only from a
2072 111c4e2f Guido Trotter
        "safe" place (the constructor). If one wanted to call it with
2073 111c4e2f Guido Trotter
        the lock held, a DropECReservationUnlocked would need to be
2074 111c4e2f Guido Trotter
        created first, to avoid causing deadlock.
2075 76d5d3a3 Iustin Pop

2076 76d5d3a3 Iustin Pop
    """
2077 45f62156 Bernardo Dal Seno
    # Keep a copy of the persistent part of _config_data to check for changes
2078 45f62156 Bernardo Dal Seno
    # Serialization doesn't guarantee order in dictionaries
2079 45f62156 Bernardo Dal Seno
    oldconf = copy.deepcopy(self._config_data.ToDict())
2080 45f62156 Bernardo Dal Seno
2081 45f62156 Bernardo Dal Seno
    # In-object upgrades
2082 45f62156 Bernardo Dal Seno
    self._config_data.UpgradeConfig()
2083 45f62156 Bernardo Dal Seno
2084 76d5d3a3 Iustin Pop
    for item in self._AllUUIDObjects():
2085 76d5d3a3 Iustin Pop
      if item.uuid is None:
2086 4fae38c5 Guido Trotter
        item.uuid = self._GenerateUniqueID(_UPGRADE_CONFIG_JID)
2087 f9e81396 Guido Trotter
    if not self._config_data.nodegroups:
2088 75cf411a Adeodato Simo
      default_nodegroup_name = constants.INITIAL_NODE_GROUP_NAME
2089 75cf411a Adeodato Simo
      default_nodegroup = objects.NodeGroup(name=default_nodegroup_name,
2090 75cf411a Adeodato Simo
                                            members=[])
2091 e11a1b77 Adeodato Simo
      self._UnlockedAddNodeGroup(default_nodegroup, _UPGRADE_CONFIG_JID, True)
2092 190e3cb6 Guido Trotter
    for node in self._config_data.nodes.values():
2093 f936c153 Iustin Pop
      if not node.group:
2094 f936c153 Iustin Pop
        node.group = self.LookupNodeGroup(None)
2095 190e3cb6 Guido Trotter
      # This is technically *not* an upgrade, but needs to be done both when
2096 190e3cb6 Guido Trotter
      # nodegroups are being added, and upon normally loading the config,
2097 190e3cb6 Guido Trotter
      # because the members list of a node group is discarded upon
2098 190e3cb6 Guido Trotter
      # serializing/deserializing the object.
2099 f936c153 Iustin Pop
      self._UnlockedAddNodeToGroup(node.name, node.group)
2100 45f62156 Bernardo Dal Seno
2101 45f62156 Bernardo Dal Seno
    modified = (oldconf != self._config_data.ToDict())
2102 76d5d3a3 Iustin Pop
    if modified:
2103 76d5d3a3 Iustin Pop
      self._WriteConfig()
2104 4fae38c5 Guido Trotter
      # This is ok even if it acquires the internal lock, as _UpgradeConfig is
2105 4fae38c5 Guido Trotter
      # only called at config init time, without the lock held
2106 4fae38c5 Guido Trotter
      self.DropECReservations(_UPGRADE_CONFIG_JID)
2107 4fae38c5 Guido Trotter
2108 a4eae71f Michael Hanselmann
  def _DistributeConfig(self, feedback_fn):
2109 a8083063 Iustin Pop
    """Distribute the configuration to the other nodes.
2110 a8083063 Iustin Pop

2111 a8083063 Iustin Pop
    Currently, this only copies the configuration file. In the future,
2112 a8083063 Iustin Pop
    it could be used to encapsulate the 2/3-phase update mechanism.
2113 a8083063 Iustin Pop

2114 a8083063 Iustin Pop
    """
2115 a8083063 Iustin Pop
    if self._offline:
2116 a8083063 Iustin Pop
      return True
2117 a4eae71f Michael Hanselmann
2118 a8083063 Iustin Pop
    bad = False
2119 a8083063 Iustin Pop
2120 6a5b8b4b Iustin Pop
    node_list = []
2121 6a5b8b4b Iustin Pop
    addr_list = []
2122 6a5b8b4b Iustin Pop
    myhostname = self._my_hostname
2123 6b294c53 Iustin Pop
    # we can skip checking whether _UnlockedGetNodeInfo returns None
2124 6b294c53 Iustin Pop
    # since the node list comes from _UnlocketGetNodeList, and we are
2125 6b294c53 Iustin Pop
    # called with the lock held, so no modifications should take place
2126 6b294c53 Iustin Pop
    # in between
2127 6a5b8b4b Iustin Pop
    for node_name in self._UnlockedGetNodeList():
2128 6a5b8b4b Iustin Pop
      if node_name == myhostname:
2129 6a5b8b4b Iustin Pop
        continue
2130 6a5b8b4b Iustin Pop
      node_info = self._UnlockedGetNodeInfo(node_name)
2131 6a5b8b4b Iustin Pop
      if not node_info.master_candidate:
2132 6a5b8b4b Iustin Pop
        continue
2133 6a5b8b4b Iustin Pop
      node_list.append(node_info.name)
2134 6a5b8b4b Iustin Pop
      addr_list.append(node_info.primary_ip)
2135 6b294c53 Iustin Pop
2136 415a7304 Michael Hanselmann
    # TODO: Use dedicated resolver talking to config writer for name resolution
2137 415a7304 Michael Hanselmann
    result = \
2138 b2acdbdc Michael Hanselmann
      self._GetRpc(addr_list).call_upload_file(node_list, self._cfg_file)
2139 1b54fc6c Guido Trotter
    for to_node, to_result in result.items():
2140 3cebe102 Michael Hanselmann
      msg = to_result.fail_msg
2141 1b54fc6c Guido Trotter
      if msg:
2142 1b54fc6c Guido Trotter
        msg = ("Copy of file %s to node %s failed: %s" %
2143 dd7db360 Iustin Pop
               (self._cfg_file, to_node, msg))
2144 1b54fc6c Guido Trotter
        logging.error(msg)
2145 a4eae71f Michael Hanselmann
2146 a4eae71f Michael Hanselmann
        if feedback_fn:
2147 a4eae71f Michael Hanselmann
          feedback_fn(msg)
2148 a4eae71f Michael Hanselmann
2149 a8083063 Iustin Pop
        bad = True
2150 a4eae71f Michael Hanselmann
2151 a8083063 Iustin Pop
    return not bad
2152 a8083063 Iustin Pop
2153 a4eae71f Michael Hanselmann
  def _WriteConfig(self, destination=None, feedback_fn=None):
2154 a8083063 Iustin Pop
    """Write the configuration data to persistent storage.
2155 a8083063 Iustin Pop

2156 a8083063 Iustin Pop
    """
2157 a4eae71f Michael Hanselmann
    assert feedback_fn is None or callable(feedback_fn)
2158 a4eae71f Michael Hanselmann
2159 d2231b8c Iustin Pop
    # Warn on config errors, but don't abort the save - the
2160 d2231b8c Iustin Pop
    # configuration has already been modified, and we can't revert;
2161 d2231b8c Iustin Pop
    # the best we can do is to warn the user and save as is, leaving
2162 d2231b8c Iustin Pop
    # recovery to the user
2163 4a89c54a Iustin Pop
    config_errors = self._UnlockedVerifyConfig()
2164 4a89c54a Iustin Pop
    if config_errors:
2165 d2231b8c Iustin Pop
      errmsg = ("Configuration data is not consistent: %s" %
2166 1f864b60 Iustin Pop
                (utils.CommaJoin(config_errors)))
2167 d2231b8c Iustin Pop
      logging.critical(errmsg)
2168 d2231b8c Iustin Pop
      if feedback_fn:
2169 d2231b8c Iustin Pop
        feedback_fn(errmsg)
2170 d2231b8c Iustin Pop
2171 a8083063 Iustin Pop
    if destination is None:
2172 a8083063 Iustin Pop
      destination = self._cfg_file
2173 a8083063 Iustin Pop
    self._BumpSerialNo()
2174 8d14b30d Iustin Pop
    txt = serializer.Dump(self._config_data.ToDict())
2175 13998ef2 Michael Hanselmann
2176 e60c73a1 René Nussbaumer
    getents = self._getents()
2177 bd407597 Iustin Pop
    try:
2178 bd407597 Iustin Pop
      fd = utils.SafeWriteFile(destination, self._cfg_id, data=txt,
2179 bd407597 Iustin Pop
                               close=False, gid=getents.confd_gid, mode=0640)
2180 bd407597 Iustin Pop
    except errors.LockError:
2181 bd407597 Iustin Pop
      raise errors.ConfigurationError("The configuration file has been"
2182 bd407597 Iustin Pop
                                      " modified since the last write, cannot"
2183 bd407597 Iustin Pop
                                      " update")
2184 bd407597 Iustin Pop
    try:
2185 bd407597 Iustin Pop
      self._cfg_id = utils.GetFileID(fd=fd)
2186 bd407597 Iustin Pop
    finally:
2187 bd407597 Iustin Pop
      os.close(fd)
2188 13998ef2 Michael Hanselmann
2189 14e15659 Iustin Pop
    self.write_count += 1
2190 3d3a04bc Iustin Pop
2191 f56618e0 Iustin Pop
    # and redistribute the config file to master candidates
2192 a4eae71f Michael Hanselmann
    self._DistributeConfig(feedback_fn)
2193 a8083063 Iustin Pop
2194 54d1a06e Michael Hanselmann
    # Write ssconf files on all nodes (including locally)
2195 0779e3aa Iustin Pop
    if self._last_cluster_serial < self._config_data.cluster.serial_no:
2196 d9a855f1 Michael Hanselmann
      if not self._offline:
2197 b2acdbdc Michael Hanselmann
        result = self._GetRpc(None).call_write_ssconf_files(
2198 6819dc49 Iustin Pop
          self._UnlockedGetOnlineNodeList(),
2199 e1e75d00 Iustin Pop
          self._UnlockedGetSsconfValues())
2200 a4eae71f Michael Hanselmann
2201 e1e75d00 Iustin Pop
        for nname, nresu in result.items():
2202 3cebe102 Michael Hanselmann
          msg = nresu.fail_msg
2203 e1e75d00 Iustin Pop
          if msg:
2204 a4eae71f Michael Hanselmann
            errmsg = ("Error while uploading ssconf files to"
2205 a4eae71f Michael Hanselmann
                      " node %s: %s" % (nname, msg))
2206 a4eae71f Michael Hanselmann
            logging.warning(errmsg)
2207 a4eae71f Michael Hanselmann
2208 a4eae71f Michael Hanselmann
            if feedback_fn:
2209 a4eae71f Michael Hanselmann
              feedback_fn(errmsg)
2210 a4eae71f Michael Hanselmann
2211 0779e3aa Iustin Pop
      self._last_cluster_serial = self._config_data.cluster.serial_no
2212 54d1a06e Michael Hanselmann
2213 03d1dba2 Michael Hanselmann
  def _UnlockedGetSsconfValues(self):
2214 054596f0 Iustin Pop
    """Return the values needed by ssconf.
2215 054596f0 Iustin Pop

2216 054596f0 Iustin Pop
    @rtype: dict
2217 054596f0 Iustin Pop
    @return: a dictionary with keys the ssconf names and values their
2218 054596f0 Iustin Pop
        associated value
2219 054596f0 Iustin Pop

2220 054596f0 Iustin Pop
    """
2221 a3316e4a Iustin Pop
    fn = "\n".join
2222 81a49123 Iustin Pop
    instance_names = utils.NiceSort(self._UnlockedGetInstanceList())
2223 a3316e4a Iustin Pop
    node_names = utils.NiceSort(self._UnlockedGetNodeList())
2224 a3316e4a Iustin Pop
    node_info = [self._UnlockedGetNodeInfo(name) for name in node_names]
2225 c3029d0a Luca Bigliardi
    node_pri_ips = ["%s %s" % (ninfo.name, ninfo.primary_ip)
2226 5909fb97 Luca Bigliardi
                    for ninfo in node_info]
2227 c3029d0a Luca Bigliardi
    node_snd_ips = ["%s %s" % (ninfo.name, ninfo.secondary_ip)
2228 5909fb97 Luca Bigliardi
                    for ninfo in node_info]
2229 a3316e4a Iustin Pop
2230 81a49123 Iustin Pop
    instance_data = fn(instance_names)
2231 a3316e4a Iustin Pop
    off_data = fn(node.name for node in node_info if node.offline)
2232 81a49123 Iustin Pop
    on_data = fn(node.name for node in node_info if not node.offline)
2233 a3316e4a Iustin Pop
    mc_data = fn(node.name for node in node_info if node.master_candidate)
2234 8113a52e Luca Bigliardi
    mc_ips_data = fn(node.primary_ip for node in node_info
2235 8113a52e Luca Bigliardi
                     if node.master_candidate)
2236 a3316e4a Iustin Pop
    node_data = fn(node_names)
2237 f9780ccd Luca Bigliardi
    node_pri_ips_data = fn(node_pri_ips)
2238 f9780ccd Luca Bigliardi
    node_snd_ips_data = fn(node_snd_ips)
2239 f56618e0 Iustin Pop
2240 054596f0 Iustin Pop
    cluster = self._config_data.cluster
2241 5d60b3bd Iustin Pop
    cluster_tags = fn(cluster.GetTags())
2242 4f7a6a10 Iustin Pop
2243 4f7a6a10 Iustin Pop
    hypervisor_list = fn(cluster.enabled_hypervisors)
2244 4f7a6a10 Iustin Pop
2245 0fbae49a Balazs Lecz
    uid_pool = uidpool.FormatUidPool(cluster.uid_pool, separator="\n")
2246 0fbae49a Balazs Lecz
2247 6f076453 Guido Trotter
    nodegroups = ["%s %s" % (nodegroup.uuid, nodegroup.name) for nodegroup in
2248 6f076453 Guido Trotter
                  self._config_data.nodegroups.values()]
2249 6f076453 Guido Trotter
    nodegroups_data = fn(utils.NiceSort(nodegroups))
2250 6c0a75db Dimitris Aragiorgis
    networks = ["%s %s" % (net.uuid, net.name) for net in
2251 6c0a75db Dimitris Aragiorgis
                self._config_data.networks.values()]
2252 6c0a75db Dimitris Aragiorgis
    networks_data = fn(utils.NiceSort(networks))
2253 6f076453 Guido Trotter
2254 2afc9238 Iustin Pop
    ssconf_values = {
2255 054596f0 Iustin Pop
      constants.SS_CLUSTER_NAME: cluster.cluster_name,
2256 5d60b3bd Iustin Pop
      constants.SS_CLUSTER_TAGS: cluster_tags,
2257 054596f0 Iustin Pop
      constants.SS_FILE_STORAGE_DIR: cluster.file_storage_dir,
2258 4b97f902 Apollon Oikonomopoulos
      constants.SS_SHARED_FILE_STORAGE_DIR: cluster.shared_file_storage_dir,
2259 a3316e4a Iustin Pop
      constants.SS_MASTER_CANDIDATES: mc_data,
2260 8113a52e Luca Bigliardi
      constants.SS_MASTER_CANDIDATES_IPS: mc_ips_data,
2261 054596f0 Iustin Pop
      constants.SS_MASTER_IP: cluster.master_ip,
2262 054596f0 Iustin Pop
      constants.SS_MASTER_NETDEV: cluster.master_netdev,
2263 5a8648eb Andrea Spadaccini
      constants.SS_MASTER_NETMASK: str(cluster.master_netmask),
2264 054596f0 Iustin Pop
      constants.SS_MASTER_NODE: cluster.master_node,
2265 a3316e4a Iustin Pop
      constants.SS_NODE_LIST: node_data,
2266 f9780ccd Luca Bigliardi
      constants.SS_NODE_PRIMARY_IPS: node_pri_ips_data,
2267 f9780ccd Luca Bigliardi
      constants.SS_NODE_SECONDARY_IPS: node_snd_ips_data,
2268 a3316e4a Iustin Pop
      constants.SS_OFFLINE_NODES: off_data,
2269 81a49123 Iustin Pop
      constants.SS_ONLINE_NODES: on_data,
2270 868a98ca Manuel Franceschini
      constants.SS_PRIMARY_IP_FAMILY: str(cluster.primary_ip_family),
2271 81a49123 Iustin Pop
      constants.SS_INSTANCE_LIST: instance_data,
2272 8a113c7a Iustin Pop
      constants.SS_RELEASE_VERSION: constants.RELEASE_VERSION,
2273 4f7a6a10 Iustin Pop
      constants.SS_HYPERVISOR_LIST: hypervisor_list,
2274 5c465a95 Iustin Pop
      constants.SS_MAINTAIN_NODE_HEALTH: str(cluster.maintain_node_health),
2275 0fbae49a Balazs Lecz
      constants.SS_UID_POOL: uid_pool,
2276 6f076453 Guido Trotter
      constants.SS_NODEGROUPS: nodegroups_data,
2277 6c0a75db Dimitris Aragiorgis
      constants.SS_NETWORKS: networks_data,
2278 03d1dba2 Michael Hanselmann
      }
2279 2afc9238 Iustin Pop
    bad_values = [(k, v) for k, v in ssconf_values.items()
2280 2afc9238 Iustin Pop
                  if not isinstance(v, (str, basestring))]
2281 2afc9238 Iustin Pop
    if bad_values:
2282 2afc9238 Iustin Pop
      err = utils.CommaJoin("%s=%s" % (k, v) for k, v in bad_values)
2283 2afc9238 Iustin Pop
      raise errors.ConfigurationError("Some ssconf key(s) have non-string"
2284 2afc9238 Iustin Pop
                                      " values: %s" % err)
2285 2afc9238 Iustin Pop
    return ssconf_values
2286 03d1dba2 Michael Hanselmann
2287 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
2288 d367b66c Manuel Franceschini
  def GetSsconfValues(self):
2289 d367b66c Manuel Franceschini
    """Wrapper using lock around _UnlockedGetSsconf().
2290 d367b66c Manuel Franceschini

2291 d367b66c Manuel Franceschini
    """
2292 d367b66c Manuel Franceschini
    return self._UnlockedGetSsconfValues()
2293 d367b66c Manuel Franceschini
2294 d367b66c Manuel Franceschini
  @locking.ssynchronized(_config_lock, shared=1)
2295 a8083063 Iustin Pop
  def GetVGName(self):
2296 a8083063 Iustin Pop
    """Return the volume group name.
2297 a8083063 Iustin Pop

2298 a8083063 Iustin Pop
    """
2299 a8083063 Iustin Pop
    return self._config_data.cluster.volume_group_name
2300 a8083063 Iustin Pop
2301 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
2302 89ff8e15 Manuel Franceschini
  def SetVGName(self, vg_name):
2303 89ff8e15 Manuel Franceschini
    """Set the volume group name.
2304 89ff8e15 Manuel Franceschini

2305 89ff8e15 Manuel Franceschini
    """
2306 2d4011cd Manuel Franceschini
    self._config_data.cluster.volume_group_name = vg_name
2307 b9f72b4e Iustin Pop
    self._config_data.cluster.serial_no += 1
2308 89ff8e15 Manuel Franceschini
    self._WriteConfig()
2309 89ff8e15 Manuel Franceschini
2310 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
2311 9e33896b Luca Bigliardi
  def GetDRBDHelper(self):
2312 9e33896b Luca Bigliardi
    """Return DRBD usermode helper.
2313 9e33896b Luca Bigliardi

2314 9e33896b Luca Bigliardi
    """
2315 9e33896b Luca Bigliardi
    return self._config_data.cluster.drbd_usermode_helper
2316 9e33896b Luca Bigliardi
2317 9e33896b Luca Bigliardi
  @locking.ssynchronized(_config_lock)
2318 9e33896b Luca Bigliardi
  def SetDRBDHelper(self, drbd_helper):
2319 9e33896b Luca Bigliardi
    """Set DRBD usermode helper.
2320 9e33896b Luca Bigliardi

2321 9e33896b Luca Bigliardi
    """
2322 9e33896b Luca Bigliardi
    self._config_data.cluster.drbd_usermode_helper = drbd_helper
2323 9e33896b Luca Bigliardi
    self._config_data.cluster.serial_no += 1
2324 9e33896b Luca Bigliardi
    self._WriteConfig()
2325 9e33896b Luca Bigliardi
2326 9e33896b Luca Bigliardi
  @locking.ssynchronized(_config_lock, shared=1)
2327 a8083063 Iustin Pop
  def GetMACPrefix(self):
2328 a8083063 Iustin Pop
    """Return the mac prefix.
2329 a8083063 Iustin Pop

2330 a8083063 Iustin Pop
    """
2331 a8083063 Iustin Pop
    return self._config_data.cluster.mac_prefix
2332 62779dd0 Iustin Pop
2333 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock, shared=1)
2334 62779dd0 Iustin Pop
  def GetClusterInfo(self):
2335 5bbd3f7f Michael Hanselmann
    """Returns information about the cluster
2336 62779dd0 Iustin Pop

2337 c41eea6e Iustin Pop
    @rtype: L{objects.Cluster}
2338 c41eea6e Iustin Pop
    @return: the cluster object
2339 62779dd0 Iustin Pop

2340 62779dd0 Iustin Pop
    """
2341 62779dd0 Iustin Pop
    return self._config_data.cluster
2342 e00fb268 Iustin Pop
2343 51cb1581 Luca Bigliardi
  @locking.ssynchronized(_config_lock, shared=1)
2344 51cb1581 Luca Bigliardi
  def HasAnyDiskOfType(self, dev_type):
2345 51cb1581 Luca Bigliardi
    """Check if in there is at disk of the given type in the configuration.
2346 51cb1581 Luca Bigliardi

2347 51cb1581 Luca Bigliardi
    """
2348 51cb1581 Luca Bigliardi
    return self._config_data.HasAnyDiskOfType(dev_type)
2349 51cb1581 Luca Bigliardi
2350 f78ede4e Guido Trotter
  @locking.ssynchronized(_config_lock)
2351 d1547283 Dimitris Aragiorgis
  def Update(self, target, feedback_fn, ec_id=None):
2352 e00fb268 Iustin Pop
    """Notify function to be called after updates.
2353 e00fb268 Iustin Pop

2354 e00fb268 Iustin Pop
    This function must be called when an object (as returned by
2355 e00fb268 Iustin Pop
    GetInstanceInfo, GetNodeInfo, GetCluster) has been updated and the
2356 e00fb268 Iustin Pop
    caller wants the modifications saved to the backing store. Note
2357 e00fb268 Iustin Pop
    that all modified objects will be saved, but the target argument
2358 e00fb268 Iustin Pop
    is the one the caller wants to ensure that it's saved.
2359 e00fb268 Iustin Pop

2360 c41eea6e Iustin Pop
    @param target: an instance of either L{objects.Cluster},
2361 c41eea6e Iustin Pop
        L{objects.Node} or L{objects.Instance} which is existing in
2362 c41eea6e Iustin Pop
        the cluster
2363 a4eae71f Michael Hanselmann
    @param feedback_fn: Callable feedback function
2364 c41eea6e Iustin Pop

2365 e00fb268 Iustin Pop
    """
2366 e00fb268 Iustin Pop
    if self._config_data is None:
2367 3ecf6786 Iustin Pop
      raise errors.ProgrammerError("Configuration file not read,"
2368 3ecf6786 Iustin Pop
                                   " cannot save.")
2369 f34901f8 Iustin Pop
    update_serial = False
2370 e00fb268 Iustin Pop
    if isinstance(target, objects.Cluster):
2371 e00fb268 Iustin Pop
      test = target == self._config_data.cluster
2372 e00fb268 Iustin Pop
    elif isinstance(target, objects.Node):
2373 e00fb268 Iustin Pop
      test = target in self._config_data.nodes.values()
2374 f34901f8 Iustin Pop
      update_serial = True
2375 e00fb268 Iustin Pop
    elif isinstance(target, objects.Instance):
2376 e00fb268 Iustin Pop
      test = target in self._config_data.instances.values()
2377 e11a1b77 Adeodato Simo
    elif isinstance(target, objects.NodeGroup):
2378 e11a1b77 Adeodato Simo
      test = target in self._config_data.nodegroups.values()
2379 1e0d3321 Dimitris Aragiorgis
    elif isinstance(target, objects.Network):
2380 1e0d3321 Dimitris Aragiorgis
      test = target in self._config_data.networks.values()
2381 e00fb268 Iustin Pop
    else:
2382 3ecf6786 Iustin Pop
      raise errors.ProgrammerError("Invalid object type (%s) passed to"
2383 3ecf6786 Iustin Pop
                                   " ConfigWriter.Update" % type(target))
2384 e00fb268 Iustin Pop
    if not test:
2385 3ecf6786 Iustin Pop
      raise errors.ConfigurationError("Configuration updated since object"
2386 3ecf6786 Iustin Pop
                                      " has been read or unknown object")
2387 f34901f8 Iustin Pop
    target.serial_no += 1
2388 d693c864 Iustin Pop
    target.mtime = now = time.time()
2389 f34901f8 Iustin Pop
2390 cff4c037 Iustin Pop
    if update_serial:
2391 f34901f8 Iustin Pop
      # for node updates, we need to increase the cluster serial too
2392 f34901f8 Iustin Pop
      self._config_data.cluster.serial_no += 1
2393 d693c864 Iustin Pop
      self._config_data.cluster.mtime = now
2394 b989e85d Iustin Pop
2395 61cf6b5e Iustin Pop
    if isinstance(target, objects.Instance):
2396 61cf6b5e Iustin Pop
      self._UnlockedReleaseDRBDMinors(target.name)
2397 61cf6b5e Iustin Pop
2398 d1547283 Dimitris Aragiorgis
    if ec_id is not None:
2399 d1547283 Dimitris Aragiorgis
      # Commit all ips reserved by OpInstanceSetParams and OpGroupSetParams
2400 d1547283 Dimitris Aragiorgis
      self._UnlockedCommitTemporaryIps(ec_id)
2401 d1547283 Dimitris Aragiorgis
2402 a4eae71f Michael Hanselmann
    self._WriteConfig(feedback_fn=feedback_fn)
2403 73064714 Guido Trotter
2404 73064714 Guido Trotter
  @locking.ssynchronized(_config_lock)
2405 73064714 Guido Trotter
  def DropECReservations(self, ec_id):
2406 73064714 Guido Trotter
    """Drop per-execution-context reservations
2407 73064714 Guido Trotter

2408 73064714 Guido Trotter
    """
2409 d8aee57e Iustin Pop
    for rm in self._all_rms:
2410 d8aee57e Iustin Pop
      rm.DropECReservations(ec_id)
2411 6c0a75db Dimitris Aragiorgis
2412 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2413 6c0a75db Dimitris Aragiorgis
  def GetAllNetworksInfo(self):
2414 6a94d553 Dimitris Aragiorgis
    """Get configuration info of all the networks.
2415 6c0a75db Dimitris Aragiorgis

2416 6c0a75db Dimitris Aragiorgis
    """
2417 6c0a75db Dimitris Aragiorgis
    return dict(self._config_data.networks)
2418 6c0a75db Dimitris Aragiorgis
2419 6c0a75db Dimitris Aragiorgis
  def _UnlockedGetNetworkList(self):
2420 6c0a75db Dimitris Aragiorgis
    """Get the list of networks.
2421 6c0a75db Dimitris Aragiorgis

2422 6c0a75db Dimitris Aragiorgis
    This function is for internal use, when the config lock is already held.
2423 6c0a75db Dimitris Aragiorgis

2424 6c0a75db Dimitris Aragiorgis
    """
2425 6c0a75db Dimitris Aragiorgis
    return self._config_data.networks.keys()
2426 6c0a75db Dimitris Aragiorgis
2427 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2428 6c0a75db Dimitris Aragiorgis
  def GetNetworkList(self):
2429 6c0a75db Dimitris Aragiorgis
    """Get the list of networks.
2430 6c0a75db Dimitris Aragiorgis

2431 6c0a75db Dimitris Aragiorgis
    @return: array of networks, ex. ["main", "vlan100", "200]
2432 6c0a75db Dimitris Aragiorgis

2433 6c0a75db Dimitris Aragiorgis
    """
2434 6c0a75db Dimitris Aragiorgis
    return self._UnlockedGetNetworkList()
2435 6c0a75db Dimitris Aragiorgis
2436 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2437 6c0a75db Dimitris Aragiorgis
  def GetNetworkNames(self):
2438 6c0a75db Dimitris Aragiorgis
    """Get a list of network names
2439 6c0a75db Dimitris Aragiorgis

2440 6c0a75db Dimitris Aragiorgis
    """
2441 beb81ea5 Dimitris Aragiorgis
    names = [net.name
2442 beb81ea5 Dimitris Aragiorgis
             for net in self._config_data.networks.values()]
2443 6c0a75db Dimitris Aragiorgis
    return names
2444 6c0a75db Dimitris Aragiorgis
2445 6c0a75db Dimitris Aragiorgis
  def _UnlockedGetNetwork(self, uuid):
2446 6c0a75db Dimitris Aragiorgis
    """Returns information about a network.
2447 6c0a75db Dimitris Aragiorgis

2448 6c0a75db Dimitris Aragiorgis
    This function is for internal use, when the config lock is already held.
2449 6c0a75db Dimitris Aragiorgis

2450 6c0a75db Dimitris Aragiorgis
    """
2451 6c0a75db Dimitris Aragiorgis
    if uuid not in self._config_data.networks:
2452 6c0a75db Dimitris Aragiorgis
      return None
2453 6c0a75db Dimitris Aragiorgis
2454 6c0a75db Dimitris Aragiorgis
    return self._config_data.networks[uuid]
2455 6c0a75db Dimitris Aragiorgis
2456 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2457 6c0a75db Dimitris Aragiorgis
  def GetNetwork(self, uuid):
2458 6c0a75db Dimitris Aragiorgis
    """Returns information about a network.
2459 6c0a75db Dimitris Aragiorgis

2460 6c0a75db Dimitris Aragiorgis
    It takes the information from the configuration file.
2461 6c0a75db Dimitris Aragiorgis

2462 6c0a75db Dimitris Aragiorgis
    @param uuid: UUID of the network
2463 6c0a75db Dimitris Aragiorgis

2464 6c0a75db Dimitris Aragiorgis
    @rtype: L{objects.Network}
2465 6c0a75db Dimitris Aragiorgis
    @return: the network object
2466 6c0a75db Dimitris Aragiorgis

2467 6c0a75db Dimitris Aragiorgis
    """
2468 6c0a75db Dimitris Aragiorgis
    return self._UnlockedGetNetwork(uuid)
2469 6c0a75db Dimitris Aragiorgis
2470 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock)
2471 6c0a75db Dimitris Aragiorgis
  def AddNetwork(self, net, ec_id, check_uuid=True):
2472 6c0a75db Dimitris Aragiorgis
    """Add a network to the configuration.
2473 6c0a75db Dimitris Aragiorgis

2474 6c0a75db Dimitris Aragiorgis
    @type net: L{objects.Network}
2475 6c0a75db Dimitris Aragiorgis
    @param net: the Network object to add
2476 6c0a75db Dimitris Aragiorgis
    @type ec_id: string
2477 6c0a75db Dimitris Aragiorgis
    @param ec_id: unique id for the job to use when creating a missing UUID
2478 6c0a75db Dimitris Aragiorgis

2479 6c0a75db Dimitris Aragiorgis
    """
2480 6c0a75db Dimitris Aragiorgis
    self._UnlockedAddNetwork(net, ec_id, check_uuid)
2481 6c0a75db Dimitris Aragiorgis
    self._WriteConfig()
2482 6c0a75db Dimitris Aragiorgis
2483 6c0a75db Dimitris Aragiorgis
  def _UnlockedAddNetwork(self, net, ec_id, check_uuid):
2484 6c0a75db Dimitris Aragiorgis
    """Add a network to the configuration.
2485 6c0a75db Dimitris Aragiorgis

2486 6c0a75db Dimitris Aragiorgis
    """
2487 6c0a75db Dimitris Aragiorgis
    logging.info("Adding network %s to configuration", net.name)
2488 6c0a75db Dimitris Aragiorgis
2489 6c0a75db Dimitris Aragiorgis
    if check_uuid:
2490 6c0a75db Dimitris Aragiorgis
      self._EnsureUUID(net, ec_id)
2491 6c0a75db Dimitris Aragiorgis
2492 6c0a75db Dimitris Aragiorgis
    net.serial_no = 1
2493 6c0a75db Dimitris Aragiorgis
    self._config_data.networks[net.uuid] = net
2494 6c0a75db Dimitris Aragiorgis
    self._config_data.cluster.serial_no += 1
2495 6c0a75db Dimitris Aragiorgis
2496 6c0a75db Dimitris Aragiorgis
  def _UnlockedLookupNetwork(self, target):
2497 6c0a75db Dimitris Aragiorgis
    """Lookup a network's UUID.
2498 6c0a75db Dimitris Aragiorgis

2499 6c0a75db Dimitris Aragiorgis
    @type target: string
2500 6c0a75db Dimitris Aragiorgis
    @param target: network name or UUID
2501 6c0a75db Dimitris Aragiorgis
    @rtype: string
2502 6c0a75db Dimitris Aragiorgis
    @return: network UUID
2503 6c0a75db Dimitris Aragiorgis
    @raises errors.OpPrereqError: when the target network cannot be found
2504 6c0a75db Dimitris Aragiorgis

2505 6c0a75db Dimitris Aragiorgis
    """
2506 9394f4d1 Dimitris Aragiorgis
    if target is None:
2507 9394f4d1 Dimitris Aragiorgis
      return None
2508 6c0a75db Dimitris Aragiorgis
    if target in self._config_data.networks:
2509 6c0a75db Dimitris Aragiorgis
      return target
2510 6c0a75db Dimitris Aragiorgis
    for net in self._config_data.networks.values():
2511 6c0a75db Dimitris Aragiorgis
      if net.name == target:
2512 6c0a75db Dimitris Aragiorgis
        return net.uuid
2513 1b68f268 Helga Velroyen
    raise errors.OpPrereqError("Network '%s' not found" % target,
2514 1b68f268 Helga Velroyen
                               errors.ECODE_NOENT)
2515 6c0a75db Dimitris Aragiorgis
2516 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2517 6c0a75db Dimitris Aragiorgis
  def LookupNetwork(self, target):
2518 6c0a75db Dimitris Aragiorgis
    """Lookup a network's UUID.
2519 6c0a75db Dimitris Aragiorgis

2520 6c0a75db Dimitris Aragiorgis
    This function is just a wrapper over L{_UnlockedLookupNetwork}.
2521 6c0a75db Dimitris Aragiorgis

2522 6c0a75db Dimitris Aragiorgis
    @type target: string
2523 6c0a75db Dimitris Aragiorgis
    @param target: network name or UUID
2524 6c0a75db Dimitris Aragiorgis
    @rtype: string
2525 6c0a75db Dimitris Aragiorgis
    @return: network UUID
2526 6c0a75db Dimitris Aragiorgis

2527 6c0a75db Dimitris Aragiorgis
    """
2528 6c0a75db Dimitris Aragiorgis
    return self._UnlockedLookupNetwork(target)
2529 6c0a75db Dimitris Aragiorgis
2530 6c0a75db Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock)
2531 6c0a75db Dimitris Aragiorgis
  def RemoveNetwork(self, network_uuid):
2532 6c0a75db Dimitris Aragiorgis
    """Remove a network from the configuration.
2533 6c0a75db Dimitris Aragiorgis

2534 6c0a75db Dimitris Aragiorgis
    @type network_uuid: string
2535 6c0a75db Dimitris Aragiorgis
    @param network_uuid: the UUID of the network to remove
2536 6c0a75db Dimitris Aragiorgis

2537 6c0a75db Dimitris Aragiorgis
    """
2538 6c0a75db Dimitris Aragiorgis
    logging.info("Removing network %s from configuration", network_uuid)
2539 6c0a75db Dimitris Aragiorgis
2540 6c0a75db Dimitris Aragiorgis
    if network_uuid not in self._config_data.networks:
2541 6c0a75db Dimitris Aragiorgis
      raise errors.ConfigurationError("Unknown network '%s'" % network_uuid)
2542 6c0a75db Dimitris Aragiorgis
2543 6c0a75db Dimitris Aragiorgis
    del self._config_data.networks[network_uuid]
2544 6c0a75db Dimitris Aragiorgis
    self._config_data.cluster.serial_no += 1
2545 6c0a75db Dimitris Aragiorgis
    self._WriteConfig()
2546 ad4a9ae7 Dimitris Aragiorgis
2547 9ccacbc8 Dimitris Aragiorgis
  def _UnlockedGetGroupNetParams(self, net_uuid, node):
2548 ad4a9ae7 Dimitris Aragiorgis
    """Get the netparams (mode, link) of a network.
2549 ad4a9ae7 Dimitris Aragiorgis

2550 ad4a9ae7 Dimitris Aragiorgis
    Get a network's netparams for a given node.
2551 ad4a9ae7 Dimitris Aragiorgis

2552 9ccacbc8 Dimitris Aragiorgis
    @type net_uuid: string
2553 9ccacbc8 Dimitris Aragiorgis
    @param net_uuid: network uuid
2554 ad4a9ae7 Dimitris Aragiorgis
    @type node: string
2555 ad4a9ae7 Dimitris Aragiorgis
    @param node: node name
2556 ad4a9ae7 Dimitris Aragiorgis
    @rtype: dict or None
2557 ad4a9ae7 Dimitris Aragiorgis
    @return: netparams
2558 ad4a9ae7 Dimitris Aragiorgis

2559 ad4a9ae7 Dimitris Aragiorgis
    """
2560 ad4a9ae7 Dimitris Aragiorgis
    node_info = self._UnlockedGetNodeInfo(node)
2561 ad4a9ae7 Dimitris Aragiorgis
    nodegroup_info = self._UnlockedGetNodeGroup(node_info.group)
2562 ad4a9ae7 Dimitris Aragiorgis
    netparams = nodegroup_info.networks.get(net_uuid, None)
2563 ad4a9ae7 Dimitris Aragiorgis
2564 ad4a9ae7 Dimitris Aragiorgis
    return netparams
2565 ad4a9ae7 Dimitris Aragiorgis
2566 ad4a9ae7 Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2567 9ccacbc8 Dimitris Aragiorgis
  def GetGroupNetParams(self, net_uuid, node):
2568 ad4a9ae7 Dimitris Aragiorgis
    """Locking wrapper of _UnlockedGetGroupNetParams()
2569 ad4a9ae7 Dimitris Aragiorgis

2570 ad4a9ae7 Dimitris Aragiorgis
    """
2571 9ccacbc8 Dimitris Aragiorgis
    return self._UnlockedGetGroupNetParams(net_uuid, node)
2572 ad4a9ae7 Dimitris Aragiorgis
2573 ad4a9ae7 Dimitris Aragiorgis
  @locking.ssynchronized(_config_lock, shared=1)
2574 ad4a9ae7 Dimitris Aragiorgis
  def CheckIPInNodeGroup(self, ip, node):
2575 6a94d553 Dimitris Aragiorgis
    """Check IP uniqueness in nodegroup.
2576 6a94d553 Dimitris Aragiorgis

2577 6a94d553 Dimitris Aragiorgis
    Check networks that are connected in the node's node group
2578 6a94d553 Dimitris Aragiorgis
    if ip is contained in any of them. Used when creating/adding
2579 6a94d553 Dimitris Aragiorgis
    a NIC to ensure uniqueness among nodegroups.
2580 ad4a9ae7 Dimitris Aragiorgis

2581 ad4a9ae7 Dimitris Aragiorgis
    @type ip: string
2582 ad4a9ae7 Dimitris Aragiorgis
    @param ip: ip address
2583 ad4a9ae7 Dimitris Aragiorgis
    @type node: string
2584 ad4a9ae7 Dimitris Aragiorgis
    @param node: node name
2585 ad4a9ae7 Dimitris Aragiorgis
    @rtype: (string, dict) or (None, None)
2586 ad4a9ae7 Dimitris Aragiorgis
    @return: (network name, netparams)
2587 ad4a9ae7 Dimitris Aragiorgis

2588 ad4a9ae7 Dimitris Aragiorgis
    """
2589 ad4a9ae7 Dimitris Aragiorgis
    if ip is None:
2590 ad4a9ae7 Dimitris Aragiorgis
      return (None, None)
2591 ad4a9ae7 Dimitris Aragiorgis
    node_info = self._UnlockedGetNodeInfo(node)
2592 ad4a9ae7 Dimitris Aragiorgis
    nodegroup_info = self._UnlockedGetNodeGroup(node_info.group)
2593 ad4a9ae7 Dimitris Aragiorgis
    for net_uuid in nodegroup_info.networks.keys():
2594 ad4a9ae7 Dimitris Aragiorgis
      net_info = self._UnlockedGetNetwork(net_uuid)
2595 ad4a9ae7 Dimitris Aragiorgis
      pool = network.AddressPool(net_info)
2596 beb81ea5 Dimitris Aragiorgis
      if pool.Contains(ip):
2597 ad4a9ae7 Dimitris Aragiorgis
        return (net_info.name, nodegroup_info.networks[net_uuid])
2598 ad4a9ae7 Dimitris Aragiorgis
2599 ad4a9ae7 Dimitris Aragiorgis
    return (None, None)