Statistics
| Branch: | Tag: | Revision:

root / daemons / ganeti-noded @ 38e250ba

History | View | Annotate | Download (21.1 kB)

1 a8083063 Iustin Pop
#!/usr/bin/python
2 a8083063 Iustin Pop
#
3 a8083063 Iustin Pop
4 a8083063 Iustin Pop
# Copyright (C) 2006, 2007 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
"""Ganeti node daemon"""
23 a8083063 Iustin Pop
24 3ecf6786 Iustin Pop
# functions in this module need to have a given name structure, so:
25 3ecf6786 Iustin Pop
# pylint: disable-msg=C0103
26 3ecf6786 Iustin Pop
27 a8083063 Iustin Pop
import os
28 a8083063 Iustin Pop
import sys
29 a8083063 Iustin Pop
import traceback
30 761ce945 Guido Trotter
import SocketServer
31 0214b0c0 Iustin Pop
import errno
32 c89189b1 Iustin Pop
import logging
33 84b58db2 Michael Hanselmann
import signal
34 a8083063 Iustin Pop
35 a8083063 Iustin Pop
from optparse import OptionParser
36 a8083063 Iustin Pop
37 a8083063 Iustin Pop
from ganeti import backend
38 a8083063 Iustin Pop
from ganeti import constants
39 a8083063 Iustin Pop
from ganeti import objects
40 a8083063 Iustin Pop
from ganeti import errors
41 25d6d12a Michael Hanselmann
from ganeti import jstore
42 cc28af80 Michael Hanselmann
from ganeti import daemon
43 1df6506c Michael Hanselmann
from ganeti import http
44 16abfbc2 Alexander Schreiber
from ganeti import utils
45 a8083063 Iustin Pop
46 19205c39 Michael Hanselmann
import ganeti.http.server
47 19205c39 Michael Hanselmann
48 a8083063 Iustin Pop
49 25d6d12a Michael Hanselmann
queue_lock = None
50 25d6d12a Michael Hanselmann
51 25d6d12a Michael Hanselmann
52 7f30777b Michael Hanselmann
def _RequireJobQueueLock(fn):
53 7f30777b Michael Hanselmann
  """Decorator for job queue manipulating functions.
54 7f30777b Michael Hanselmann
55 7f30777b Michael Hanselmann
  """
56 8785cb30 Michael Hanselmann
  QUEUE_LOCK_TIMEOUT = 10
57 8785cb30 Michael Hanselmann
58 7f30777b Michael Hanselmann
  def wrapper(*args, **kwargs):
59 7f30777b Michael Hanselmann
    # Locking in exclusive, blocking mode because there could be several
60 506cff12 Michael Hanselmann
    # children running at the same time. Waiting up to 10 seconds.
61 8785cb30 Michael Hanselmann
    queue_lock.Exclusive(blocking=True, timeout=QUEUE_LOCK_TIMEOUT)
62 7f30777b Michael Hanselmann
    try:
63 7f30777b Michael Hanselmann
      return fn(*args, **kwargs)
64 7f30777b Michael Hanselmann
    finally:
65 7f30777b Michael Hanselmann
      queue_lock.Unlock()
66 8785cb30 Michael Hanselmann
67 7f30777b Michael Hanselmann
  return wrapper
68 7f30777b Michael Hanselmann
69 7f30777b Michael Hanselmann
70 19205c39 Michael Hanselmann
class NodeHttpServer(http.server.HttpServer):
71 3ecf6786 Iustin Pop
  """The server implementation.
72 3ecf6786 Iustin Pop
73 3ecf6786 Iustin Pop
  This class holds all methods exposed over the RPC interface.
74 3ecf6786 Iustin Pop
75 3ecf6786 Iustin Pop
  """
76 cc28af80 Michael Hanselmann
  def __init__(self, *args, **kwargs):
77 19205c39 Michael Hanselmann
    http.server.HttpServer.__init__(self, *args, **kwargs)
78 cc28af80 Michael Hanselmann
    self.noded_pid = os.getpid()
79 cc28af80 Michael Hanselmann
80 cc28af80 Michael Hanselmann
  def HandleRequest(self, req):
81 1df6506c Michael Hanselmann
    """Handle a request.
82 a8083063 Iustin Pop
83 098c0958 Michael Hanselmann
    """
84 19205c39 Michael Hanselmann
    if req.request_method.upper() != http.HTTP_PUT:
85 84f2756e Michael Hanselmann
      raise http.HttpBadRequest()
86 1df6506c Michael Hanselmann
87 cc28af80 Michael Hanselmann
    path = req.request_path
88 81010134 Iustin Pop
    if path.startswith("/"):
89 81010134 Iustin Pop
      path = path[1:]
90 81010134 Iustin Pop
91 1df6506c Michael Hanselmann
    method = getattr(self, "perspective_%s" % path, None)
92 1df6506c Michael Hanselmann
    if method is None:
93 84f2756e Michael Hanselmann
      raise http.HttpNotFound()
94 a8083063 Iustin Pop
95 81010134 Iustin Pop
    try:
96 aa9075c5 Michael Hanselmann
      try:
97 19205c39 Michael Hanselmann
        return method(req.request_body)
98 aa9075c5 Michael Hanselmann
      except:
99 aa9075c5 Michael Hanselmann
        logging.exception("Error in RPC call")
100 aa9075c5 Michael Hanselmann
        raise
101 9ae49f27 Guido Trotter
    except errors.QuitGanetiException, err:
102 84b58db2 Michael Hanselmann
      # Tell parent to quit
103 cc28af80 Michael Hanselmann
      os.kill(self.noded_pid, signal.SIGTERM)
104 a8083063 Iustin Pop
105 a8083063 Iustin Pop
  # the new block devices  --------------------------
106 a8083063 Iustin Pop
107 3ecf6786 Iustin Pop
  @staticmethod
108 3ecf6786 Iustin Pop
  def perspective_blockdev_create(params):
109 3ecf6786 Iustin Pop
    """Create a block device.
110 3ecf6786 Iustin Pop
111 3ecf6786 Iustin Pop
    """
112 3f78eef2 Iustin Pop
    bdev_s, size, owner, on_primary, info = params
113 319856a9 Michael Hanselmann
    bdev = objects.Disk.FromDict(bdev_s)
114 a8083063 Iustin Pop
    if bdev is None:
115 a8083063 Iustin Pop
      raise ValueError("can't unserialize data!")
116 3f78eef2 Iustin Pop
    return backend.CreateBlockDevice(bdev, size, owner, on_primary, info)
117 a8083063 Iustin Pop
118 3ecf6786 Iustin Pop
  @staticmethod
119 3ecf6786 Iustin Pop
  def perspective_blockdev_remove(params):
120 3ecf6786 Iustin Pop
    """Remove a block device.
121 3ecf6786 Iustin Pop
122 3ecf6786 Iustin Pop
    """
123 a8083063 Iustin Pop
    bdev_s = params[0]
124 319856a9 Michael Hanselmann
    bdev = objects.Disk.FromDict(bdev_s)
125 a8083063 Iustin Pop
    return backend.RemoveBlockDevice(bdev)
126 a8083063 Iustin Pop
127 3ecf6786 Iustin Pop
  @staticmethod
128 f3e513ad Iustin Pop
  def perspective_blockdev_rename(params):
129 f3e513ad Iustin Pop
    """Remove a block device.
130 f3e513ad Iustin Pop
131 f3e513ad Iustin Pop
    """
132 f3e513ad Iustin Pop
    devlist = [(objects.Disk.FromDict(ds), uid) for ds, uid in params]
133 f3e513ad Iustin Pop
    return backend.RenameBlockDevices(devlist)
134 f3e513ad Iustin Pop
135 f3e513ad Iustin Pop
  @staticmethod
136 3ecf6786 Iustin Pop
  def perspective_blockdev_assemble(params):
137 3ecf6786 Iustin Pop
    """Assemble a block device.
138 3ecf6786 Iustin Pop
139 3ecf6786 Iustin Pop
    """
140 3f78eef2 Iustin Pop
    bdev_s, owner, on_primary = params
141 319856a9 Michael Hanselmann
    bdev = objects.Disk.FromDict(bdev_s)
142 a8083063 Iustin Pop
    if bdev is None:
143 a8083063 Iustin Pop
      raise ValueError("can't unserialize data!")
144 3f78eef2 Iustin Pop
    return backend.AssembleBlockDevice(bdev, owner, on_primary)
145 a8083063 Iustin Pop
146 3ecf6786 Iustin Pop
  @staticmethod
147 3ecf6786 Iustin Pop
  def perspective_blockdev_shutdown(params):
148 3ecf6786 Iustin Pop
    """Shutdown a block device.
149 3ecf6786 Iustin Pop
150 3ecf6786 Iustin Pop
    """
151 a8083063 Iustin Pop
    bdev_s = params[0]
152 319856a9 Michael Hanselmann
    bdev = objects.Disk.FromDict(bdev_s)
153 a8083063 Iustin Pop
    if bdev is None:
154 a8083063 Iustin Pop
      raise ValueError("can't unserialize data!")
155 a8083063 Iustin Pop
    return backend.ShutdownBlockDevice(bdev)
156 a8083063 Iustin Pop
157 3ecf6786 Iustin Pop
  @staticmethod
158 153d9724 Iustin Pop
  def perspective_blockdev_addchildren(params):
159 3ecf6786 Iustin Pop
    """Add a child to a mirror device.
160 3ecf6786 Iustin Pop
161 3ecf6786 Iustin Pop
    Note: this is only valid for mirror devices. It's the caller's duty
162 3ecf6786 Iustin Pop
    to send a correct disk, otherwise we raise an error.
163 3ecf6786 Iustin Pop
164 3ecf6786 Iustin Pop
    """
165 a8083063 Iustin Pop
    bdev_s, ndev_s = params
166 319856a9 Michael Hanselmann
    bdev = objects.Disk.FromDict(bdev_s)
167 153d9724 Iustin Pop
    ndevs = [objects.Disk.FromDict(disk_s) for disk_s in ndev_s]
168 153d9724 Iustin Pop
    if bdev is None or ndevs.count(None) > 0:
169 a8083063 Iustin Pop
      raise ValueError("can't unserialize data!")
170 153d9724 Iustin Pop
    return backend.MirrorAddChildren(bdev, ndevs)
171 a8083063 Iustin Pop
172 3ecf6786 Iustin Pop
  @staticmethod
173 153d9724 Iustin Pop
  def perspective_blockdev_removechildren(params):
174 3ecf6786 Iustin Pop
    """Remove a child from a mirror device.
175 3ecf6786 Iustin Pop
176 3ecf6786 Iustin Pop
    This is only valid for mirror devices, of course. It's the callers
177 3ecf6786 Iustin Pop
    duty to send a correct disk, otherwise we raise an error.
178 3ecf6786 Iustin Pop
179 3ecf6786 Iustin Pop
    """
180 a8083063 Iustin Pop
    bdev_s, ndev_s = params
181 319856a9 Michael Hanselmann
    bdev = objects.Disk.FromDict(bdev_s)
182 153d9724 Iustin Pop
    ndevs = [objects.Disk.FromDict(disk_s) for disk_s in ndev_s]
183 153d9724 Iustin Pop
    if bdev is None or ndevs.count(None) > 0:
184 a8083063 Iustin Pop
      raise ValueError("can't unserialize data!")
185 153d9724 Iustin Pop
    return backend.MirrorRemoveChildren(bdev, ndevs)
186 a8083063 Iustin Pop
187 3ecf6786 Iustin Pop
  @staticmethod
188 3ecf6786 Iustin Pop
  def perspective_blockdev_getmirrorstatus(params):
189 3ecf6786 Iustin Pop
    """Return the mirror status for a list of disks.
190 3ecf6786 Iustin Pop
191 3ecf6786 Iustin Pop
    """
192 319856a9 Michael Hanselmann
    disks = [objects.Disk.FromDict(dsk_s)
193 a8083063 Iustin Pop
            for dsk_s in params]
194 a8083063 Iustin Pop
    return backend.GetMirrorStatus(disks)
195 a8083063 Iustin Pop
196 3ecf6786 Iustin Pop
  @staticmethod
197 3ecf6786 Iustin Pop
  def perspective_blockdev_find(params):
198 3ecf6786 Iustin Pop
    """Expose the FindBlockDevice functionality for a disk.
199 3ecf6786 Iustin Pop
200 3ecf6786 Iustin Pop
    This will try to find but not activate a disk.
201 3ecf6786 Iustin Pop
202 3ecf6786 Iustin Pop
    """
203 319856a9 Michael Hanselmann
    disk = objects.Disk.FromDict(params[0])
204 a8083063 Iustin Pop
    return backend.FindBlockDevice(disk)
205 a8083063 Iustin Pop
206 3ecf6786 Iustin Pop
  @staticmethod
207 3ecf6786 Iustin Pop
  def perspective_blockdev_snapshot(params):
208 3ecf6786 Iustin Pop
    """Create a snapshot device.
209 3ecf6786 Iustin Pop
210 3ecf6786 Iustin Pop
    Note that this is only valid for LVM disks, if we get passed
211 3ecf6786 Iustin Pop
    something else we raise an exception. The snapshot device can be
212 3ecf6786 Iustin Pop
    remove by calling the generic block device remove call.
213 3ecf6786 Iustin Pop
214 3ecf6786 Iustin Pop
    """
215 319856a9 Michael Hanselmann
    cfbd = objects.Disk.FromDict(params[0])
216 a8083063 Iustin Pop
    return backend.SnapshotBlockDevice(cfbd)
217 a8083063 Iustin Pop
218 4c8ba8b3 Iustin Pop
  @staticmethod
219 4c8ba8b3 Iustin Pop
  def perspective_blockdev_grow(params):
220 4c8ba8b3 Iustin Pop
    """Grow a stack of devices.
221 4c8ba8b3 Iustin Pop
222 4c8ba8b3 Iustin Pop
    """
223 4c8ba8b3 Iustin Pop
    cfbd = objects.Disk.FromDict(params[0])
224 4c8ba8b3 Iustin Pop
    amount = params[1]
225 4c8ba8b3 Iustin Pop
    return backend.GrowBlockDevice(cfbd, amount)
226 4c8ba8b3 Iustin Pop
227 d61cbe76 Iustin Pop
  @staticmethod
228 d61cbe76 Iustin Pop
  def perspective_blockdev_close(params):
229 d61cbe76 Iustin Pop
    """Closes the given block devices.
230 d61cbe76 Iustin Pop
231 d61cbe76 Iustin Pop
    """
232 b2e7666a Iustin Pop
    disks = [objects.Disk.FromDict(cf) for cf in params[1]]
233 b2e7666a Iustin Pop
    return backend.CloseBlockDevices(params[0], disks)
234 d61cbe76 Iustin Pop
235 6b93ec9d Iustin Pop
  # blockdev/drbd specific methods ----------
236 6b93ec9d Iustin Pop
237 6b93ec9d Iustin Pop
  @staticmethod
238 6b93ec9d Iustin Pop
  def perspective_drbd_disconnect_net(params):
239 6b93ec9d Iustin Pop
    """Disconnects the network connection of drbd disks.
240 6b93ec9d Iustin Pop
241 6b93ec9d Iustin Pop
    Note that this is only valid for drbd disks, so the members of the
242 6b93ec9d Iustin Pop
    disk list must all be drbd devices.
243 6b93ec9d Iustin Pop
244 6b93ec9d Iustin Pop
    """
245 6b93ec9d Iustin Pop
    nodes_ip, disks = params
246 6b93ec9d Iustin Pop
    disks = [objects.Disk.FromDict(cf) for cf in disks]
247 6b93ec9d Iustin Pop
    return backend.DrbdDisconnectNet(nodes_ip, disks)
248 6b93ec9d Iustin Pop
249 6b93ec9d Iustin Pop
  @staticmethod
250 6b93ec9d Iustin Pop
  def perspective_drbd_attach_net(params):
251 6b93ec9d Iustin Pop
    """Attaches the network connection of drbd disks.
252 6b93ec9d Iustin Pop
253 6b93ec9d Iustin Pop
    Note that this is only valid for drbd disks, so the members of the
254 6b93ec9d Iustin Pop
    disk list must all be drbd devices.
255 6b93ec9d Iustin Pop
256 6b93ec9d Iustin Pop
    """
257 6b93ec9d Iustin Pop
    nodes_ip, disks, instance_name, multimaster = params
258 6b93ec9d Iustin Pop
    disks = [objects.Disk.FromDict(cf) for cf in disks]
259 6b93ec9d Iustin Pop
    return backend.DrbdAttachNet(nodes_ip, disks, instance_name, multimaster)
260 6b93ec9d Iustin Pop
261 6b93ec9d Iustin Pop
  @staticmethod
262 6b93ec9d Iustin Pop
  def perspective_drbd_wait_sync(params):
263 6b93ec9d Iustin Pop
    """Wait until DRBD disks are synched.
264 6b93ec9d Iustin Pop
265 6b93ec9d Iustin Pop
    Note that this is only valid for drbd disks, so the members of the
266 6b93ec9d Iustin Pop
    disk list must all be drbd devices.
267 6b93ec9d Iustin Pop
268 6b93ec9d Iustin Pop
    """
269 6b93ec9d Iustin Pop
    nodes_ip, disks = params
270 6b93ec9d Iustin Pop
    disks = [objects.Disk.FromDict(cf) for cf in disks]
271 6b93ec9d Iustin Pop
    return backend.DrbdWaitSync(nodes_ip, disks)
272 6b93ec9d Iustin Pop
273 a8083063 Iustin Pop
  # export/import  --------------------------
274 a8083063 Iustin Pop
275 3ecf6786 Iustin Pop
  @staticmethod
276 3ecf6786 Iustin Pop
  def perspective_snapshot_export(params):
277 3ecf6786 Iustin Pop
    """Export a given snapshot.
278 3ecf6786 Iustin Pop
279 3ecf6786 Iustin Pop
    """
280 319856a9 Michael Hanselmann
    disk = objects.Disk.FromDict(params[0])
281 a8083063 Iustin Pop
    dest_node = params[1]
282 319856a9 Michael Hanselmann
    instance = objects.Instance.FromDict(params[2])
283 62c9ec92 Iustin Pop
    cluster_name = params[3]
284 74c47259 Iustin Pop
    dev_idx = params[4]
285 74c47259 Iustin Pop
    return backend.ExportSnapshot(disk, dest_node, instance,
286 74c47259 Iustin Pop
                                  cluster_name, dev_idx)
287 3ecf6786 Iustin Pop
288 3ecf6786 Iustin Pop
  @staticmethod
289 3ecf6786 Iustin Pop
  def perspective_finalize_export(params):
290 3ecf6786 Iustin Pop
    """Expose the finalize export functionality.
291 a8083063 Iustin Pop
292 3ecf6786 Iustin Pop
    """
293 319856a9 Michael Hanselmann
    instance = objects.Instance.FromDict(params[0])
294 319856a9 Michael Hanselmann
    snap_disks = [objects.Disk.FromDict(str_data)
295 a8083063 Iustin Pop
                  for str_data in params[1]]
296 a8083063 Iustin Pop
    return backend.FinalizeExport(instance, snap_disks)
297 a8083063 Iustin Pop
298 3ecf6786 Iustin Pop
  @staticmethod
299 3ecf6786 Iustin Pop
  def perspective_export_info(params):
300 3ecf6786 Iustin Pop
    """Query information about an existing export on this node.
301 3ecf6786 Iustin Pop
302 3ecf6786 Iustin Pop
    The given path may not contain an export, in which case we return
303 3ecf6786 Iustin Pop
    None.
304 3ecf6786 Iustin Pop
305 3ecf6786 Iustin Pop
    """
306 3ecf6786 Iustin Pop
    path = params[0]
307 3ecf6786 Iustin Pop
    einfo = backend.ExportInfo(path)
308 a8083063 Iustin Pop
    if einfo is None:
309 a8083063 Iustin Pop
      return einfo
310 a8083063 Iustin Pop
    return einfo.Dumps()
311 a8083063 Iustin Pop
312 3ecf6786 Iustin Pop
  @staticmethod
313 3ecf6786 Iustin Pop
  def perspective_export_list(params):
314 3ecf6786 Iustin Pop
    """List the available exports on this node.
315 3ecf6786 Iustin Pop
316 3ecf6786 Iustin Pop
    Note that as opposed to export_info, which may query data about an
317 3ecf6786 Iustin Pop
    export in any path, this only queries the standard Ganeti path
318 3ecf6786 Iustin Pop
    (constants.EXPORT_DIR).
319 3ecf6786 Iustin Pop
320 3ecf6786 Iustin Pop
    """
321 a8083063 Iustin Pop
    return backend.ListExports()
322 a8083063 Iustin Pop
323 3ecf6786 Iustin Pop
  @staticmethod
324 3ecf6786 Iustin Pop
  def perspective_export_remove(params):
325 3ecf6786 Iustin Pop
    """Remove an export.
326 3ecf6786 Iustin Pop
327 3ecf6786 Iustin Pop
    """
328 a8083063 Iustin Pop
    export = params[0]
329 a8083063 Iustin Pop
    return backend.RemoveExport(export)
330 a8083063 Iustin Pop
331 a8083063 Iustin Pop
  # volume  --------------------------
332 a8083063 Iustin Pop
333 3ecf6786 Iustin Pop
  @staticmethod
334 3ecf6786 Iustin Pop
  def perspective_volume_list(params):
335 3ecf6786 Iustin Pop
    """Query the list of logical volumes in a given volume group.
336 3ecf6786 Iustin Pop
337 3ecf6786 Iustin Pop
    """
338 a8083063 Iustin Pop
    vgname = params[0]
339 a8083063 Iustin Pop
    return backend.GetVolumeList(vgname)
340 a8083063 Iustin Pop
341 3ecf6786 Iustin Pop
  @staticmethod
342 3ecf6786 Iustin Pop
  def perspective_vg_list(params):
343 3ecf6786 Iustin Pop
    """Query the list of volume groups.
344 3ecf6786 Iustin Pop
345 3ecf6786 Iustin Pop
    """
346 a8083063 Iustin Pop
    return backend.ListVolumeGroups()
347 a8083063 Iustin Pop
348 a8083063 Iustin Pop
  # bridge  --------------------------
349 a8083063 Iustin Pop
350 3ecf6786 Iustin Pop
  @staticmethod
351 3ecf6786 Iustin Pop
  def perspective_bridges_exist(params):
352 3ecf6786 Iustin Pop
    """Check if all bridges given exist on this node.
353 3ecf6786 Iustin Pop
354 3ecf6786 Iustin Pop
    """
355 a8083063 Iustin Pop
    bridges_list = params[0]
356 a8083063 Iustin Pop
    return backend.BridgesExist(bridges_list)
357 a8083063 Iustin Pop
358 a8083063 Iustin Pop
  # instance  --------------------------
359 a8083063 Iustin Pop
360 3ecf6786 Iustin Pop
  @staticmethod
361 3ecf6786 Iustin Pop
  def perspective_instance_os_add(params):
362 3ecf6786 Iustin Pop
    """Install an OS on a given instance.
363 3ecf6786 Iustin Pop
364 3ecf6786 Iustin Pop
    """
365 d15a9ad3 Guido Trotter
    inst_s = params[0]
366 319856a9 Michael Hanselmann
    inst = objects.Instance.FromDict(inst_s)
367 d15a9ad3 Guido Trotter
    return backend.AddOSToInstance(inst)
368 a8083063 Iustin Pop
369 3ecf6786 Iustin Pop
  @staticmethod
370 decd5f45 Iustin Pop
  def perspective_instance_run_rename(params):
371 decd5f45 Iustin Pop
    """Runs the OS rename script for an instance.
372 decd5f45 Iustin Pop
373 decd5f45 Iustin Pop
    """
374 d15a9ad3 Guido Trotter
    inst_s, old_name = params
375 319856a9 Michael Hanselmann
    inst = objects.Instance.FromDict(inst_s)
376 d15a9ad3 Guido Trotter
    return backend.RunRenameInstance(inst, old_name)
377 decd5f45 Iustin Pop
378 decd5f45 Iustin Pop
  @staticmethod
379 3ecf6786 Iustin Pop
  def perspective_instance_os_import(params):
380 3ecf6786 Iustin Pop
    """Run the import function of an OS onto a given instance.
381 3ecf6786 Iustin Pop
382 3ecf6786 Iustin Pop
    """
383 6c0af70e Guido Trotter
    inst_s, src_node, src_images, cluster_name = params
384 319856a9 Michael Hanselmann
    inst = objects.Instance.FromDict(inst_s)
385 6c0af70e Guido Trotter
    return backend.ImportOSIntoInstance(inst, src_node, src_images,
386 6c0af70e Guido Trotter
                                        cluster_name)
387 a8083063 Iustin Pop
388 3ecf6786 Iustin Pop
  @staticmethod
389 3ecf6786 Iustin Pop
  def perspective_instance_shutdown(params):
390 3ecf6786 Iustin Pop
    """Shutdown an instance.
391 3ecf6786 Iustin Pop
392 3ecf6786 Iustin Pop
    """
393 319856a9 Michael Hanselmann
    instance = objects.Instance.FromDict(params[0])
394 a8083063 Iustin Pop
    return backend.ShutdownInstance(instance)
395 a8083063 Iustin Pop
396 3ecf6786 Iustin Pop
  @staticmethod
397 3ecf6786 Iustin Pop
  def perspective_instance_start(params):
398 3ecf6786 Iustin Pop
    """Start an instance.
399 3ecf6786 Iustin Pop
400 3ecf6786 Iustin Pop
    """
401 319856a9 Michael Hanselmann
    instance = objects.Instance.FromDict(params[0])
402 a8083063 Iustin Pop
    extra_args = params[1]
403 a8083063 Iustin Pop
    return backend.StartInstance(instance, extra_args)
404 a8083063 Iustin Pop
405 3ecf6786 Iustin Pop
  @staticmethod
406 6906a9d8 Guido Trotter
  def perspective_migration_info(params):
407 6906a9d8 Guido Trotter
    """Gather information about an instance to be migrated.
408 6906a9d8 Guido Trotter
409 6906a9d8 Guido Trotter
    """
410 6906a9d8 Guido Trotter
    instance = objects.Instance.FromDict(params[0])
411 6906a9d8 Guido Trotter
    return backend.MigrationInfo(instance)
412 6906a9d8 Guido Trotter
413 6906a9d8 Guido Trotter
  @staticmethod
414 6906a9d8 Guido Trotter
  def perspective_accept_instance(params):
415 6906a9d8 Guido Trotter
    """Prepare the node to accept an instance.
416 6906a9d8 Guido Trotter
417 6906a9d8 Guido Trotter
    """
418 6906a9d8 Guido Trotter
    instance, info, target = params
419 6906a9d8 Guido Trotter
    instance = objects.Instance.FromDict(instance)
420 6906a9d8 Guido Trotter
    return backend.AcceptInstance(instance, info, target)
421 6906a9d8 Guido Trotter
422 6906a9d8 Guido Trotter
  @staticmethod
423 6906a9d8 Guido Trotter
  def perspective_finalize_migration(params):
424 6906a9d8 Guido Trotter
    """Finalize the instance migration.
425 6906a9d8 Guido Trotter
426 6906a9d8 Guido Trotter
    """
427 6906a9d8 Guido Trotter
    instance, info, success = params
428 6906a9d8 Guido Trotter
    instance = objects.Instance.FromDict(instance)
429 6906a9d8 Guido Trotter
    return backend.FinalizeMigration(instance, info, success)
430 6906a9d8 Guido Trotter
431 6906a9d8 Guido Trotter
  @staticmethod
432 2a10865c Iustin Pop
  def perspective_instance_migrate(params):
433 2a10865c Iustin Pop
    """Migrates an instance.
434 2a10865c Iustin Pop
435 2a10865c Iustin Pop
    """
436 2a10865c Iustin Pop
    instance, target, live = params
437 9f0e6b37 Iustin Pop
    instance = objects.Instance.FromDict(instance)
438 2a10865c Iustin Pop
    return backend.MigrateInstance(instance, target, live)
439 2a10865c Iustin Pop
440 2a10865c Iustin Pop
  @staticmethod
441 007a2f3e Alexander Schreiber
  def perspective_instance_reboot(params):
442 007a2f3e Alexander Schreiber
    """Reboot an instance.
443 007a2f3e Alexander Schreiber
444 007a2f3e Alexander Schreiber
    """
445 007a2f3e Alexander Schreiber
    instance = objects.Instance.FromDict(params[0])
446 007a2f3e Alexander Schreiber
    reboot_type = params[1]
447 007a2f3e Alexander Schreiber
    extra_args = params[2]
448 007a2f3e Alexander Schreiber
    return backend.RebootInstance(instance, reboot_type, extra_args)
449 007a2f3e Alexander Schreiber
450 007a2f3e Alexander Schreiber
  @staticmethod
451 3ecf6786 Iustin Pop
  def perspective_instance_info(params):
452 3ecf6786 Iustin Pop
    """Query instance information.
453 3ecf6786 Iustin Pop
454 3ecf6786 Iustin Pop
    """
455 16ad1a83 Iustin Pop
    return backend.GetInstanceInfo(params[0], params[1])
456 a8083063 Iustin Pop
457 3ecf6786 Iustin Pop
  @staticmethod
458 56e7640c Iustin Pop
  def perspective_instance_migratable(params):
459 56e7640c Iustin Pop
    """Query whether the specified instance can be migrated.
460 56e7640c Iustin Pop
461 56e7640c Iustin Pop
    """
462 56e7640c Iustin Pop
    instance = objects.Instance.FromDict(params[0])
463 56e7640c Iustin Pop
    return backend.GetInstanceMigratable(instance)
464 56e7640c Iustin Pop
465 56e7640c Iustin Pop
  @staticmethod
466 3ecf6786 Iustin Pop
  def perspective_all_instances_info(params):
467 3ecf6786 Iustin Pop
    """Query information about all instances.
468 3ecf6786 Iustin Pop
469 3ecf6786 Iustin Pop
    """
470 e69d05fd Iustin Pop
    return backend.GetAllInstancesInfo(params[0])
471 a8083063 Iustin Pop
472 3ecf6786 Iustin Pop
  @staticmethod
473 3ecf6786 Iustin Pop
  def perspective_instance_list(params):
474 3ecf6786 Iustin Pop
    """Query the list of running instances.
475 3ecf6786 Iustin Pop
476 3ecf6786 Iustin Pop
    """
477 e69d05fd Iustin Pop
    return backend.GetInstanceList(params[0])
478 a8083063 Iustin Pop
479 a8083063 Iustin Pop
  # node --------------------------
480 a8083063 Iustin Pop
481 3ecf6786 Iustin Pop
  @staticmethod
482 16abfbc2 Alexander Schreiber
  def perspective_node_tcp_ping(params):
483 16abfbc2 Alexander Schreiber
    """Do a TcpPing on the remote node.
484 16abfbc2 Alexander Schreiber
485 16abfbc2 Alexander Schreiber
    """
486 b15d625f Iustin Pop
    return utils.TcpPing(params[1], params[2], timeout=params[3],
487 b15d625f Iustin Pop
                         live_port_needed=params[4], source=params[0])
488 16abfbc2 Alexander Schreiber
489 16abfbc2 Alexander Schreiber
  @staticmethod
490 caad16e2 Iustin Pop
  def perspective_node_has_ip_address(params):
491 caad16e2 Iustin Pop
    """Checks if a node has the given ip address.
492 caad16e2 Iustin Pop
493 caad16e2 Iustin Pop
    """
494 caad16e2 Iustin Pop
    return utils.OwnIpAddress(params[0])
495 caad16e2 Iustin Pop
496 caad16e2 Iustin Pop
  @staticmethod
497 3ecf6786 Iustin Pop
  def perspective_node_info(params):
498 3ecf6786 Iustin Pop
    """Query node information.
499 3ecf6786 Iustin Pop
500 3ecf6786 Iustin Pop
    """
501 e69d05fd Iustin Pop
    vgname, hypervisor_type = params
502 e69d05fd Iustin Pop
    return backend.GetNodeInfo(vgname, hypervisor_type)
503 a8083063 Iustin Pop
504 3ecf6786 Iustin Pop
  @staticmethod
505 3ecf6786 Iustin Pop
  def perspective_node_add(params):
506 3ecf6786 Iustin Pop
    """Complete the registration of this node in the cluster.
507 3ecf6786 Iustin Pop
508 3ecf6786 Iustin Pop
    """
509 a8083063 Iustin Pop
    return backend.AddNode(params[0], params[1], params[2],
510 a8083063 Iustin Pop
                           params[3], params[4], params[5])
511 a8083063 Iustin Pop
512 3ecf6786 Iustin Pop
  @staticmethod
513 3ecf6786 Iustin Pop
  def perspective_node_verify(params):
514 3ecf6786 Iustin Pop
    """Run a verify sequence on this node.
515 3ecf6786 Iustin Pop
516 3ecf6786 Iustin Pop
    """
517 62c9ec92 Iustin Pop
    return backend.VerifyNode(params[0], params[1])
518 a8083063 Iustin Pop
519 3ecf6786 Iustin Pop
  @staticmethod
520 3ecf6786 Iustin Pop
  def perspective_node_start_master(params):
521 3ecf6786 Iustin Pop
    """Promote this node to master status.
522 3ecf6786 Iustin Pop
523 3ecf6786 Iustin Pop
    """
524 1c65840b Iustin Pop
    return backend.StartMaster(params[0])
525 a8083063 Iustin Pop
526 3ecf6786 Iustin Pop
  @staticmethod
527 3ecf6786 Iustin Pop
  def perspective_node_stop_master(params):
528 3ecf6786 Iustin Pop
    """Demote this node from master status.
529 3ecf6786 Iustin Pop
530 3ecf6786 Iustin Pop
    """
531 1c65840b Iustin Pop
    return backend.StopMaster(params[0])
532 a8083063 Iustin Pop
533 3ecf6786 Iustin Pop
  @staticmethod
534 3ecf6786 Iustin Pop
  def perspective_node_leave_cluster(params):
535 3ecf6786 Iustin Pop
    """Cleanup after leaving a cluster.
536 3ecf6786 Iustin Pop
537 3ecf6786 Iustin Pop
    """
538 a8083063 Iustin Pop
    return backend.LeaveCluster()
539 a8083063 Iustin Pop
540 3ecf6786 Iustin Pop
  @staticmethod
541 3ecf6786 Iustin Pop
  def perspective_node_volumes(params):
542 3ecf6786 Iustin Pop
    """Query the list of all logical volume groups.
543 3ecf6786 Iustin Pop
544 3ecf6786 Iustin Pop
    """
545 dcb93971 Michael Hanselmann
    return backend.NodeVolumes()
546 dcb93971 Michael Hanselmann
547 56aa9fd5 Iustin Pop
  @staticmethod
548 56aa9fd5 Iustin Pop
  def perspective_node_demote_from_mc(params):
549 56aa9fd5 Iustin Pop
    """Demote a node from the master candidate role.
550 56aa9fd5 Iustin Pop
551 56aa9fd5 Iustin Pop
    """
552 56aa9fd5 Iustin Pop
    return backend.DemoteFromMC()
553 56aa9fd5 Iustin Pop
554 56aa9fd5 Iustin Pop
555 a8083063 Iustin Pop
  # cluster --------------------------
556 a8083063 Iustin Pop
557 3ecf6786 Iustin Pop
  @staticmethod
558 3ecf6786 Iustin Pop
  def perspective_version(params):
559 3ecf6786 Iustin Pop
    """Query version information.
560 3ecf6786 Iustin Pop
561 3ecf6786 Iustin Pop
    """
562 a8083063 Iustin Pop
    return constants.PROTOCOL_VERSION
563 a8083063 Iustin Pop
564 3ecf6786 Iustin Pop
  @staticmethod
565 3ecf6786 Iustin Pop
  def perspective_upload_file(params):
566 3ecf6786 Iustin Pop
    """Upload a file.
567 3ecf6786 Iustin Pop
568 3ecf6786 Iustin Pop
    Note that the backend implementation imposes strict rules on which
569 3ecf6786 Iustin Pop
    files are accepted.
570 3ecf6786 Iustin Pop
571 3ecf6786 Iustin Pop
    """
572 a8083063 Iustin Pop
    return backend.UploadFile(*params)
573 a8083063 Iustin Pop
574 4e071d3b Iustin Pop
  @staticmethod
575 4e071d3b Iustin Pop
  def perspective_master_info(params):
576 4e071d3b Iustin Pop
    """Query master information.
577 4e071d3b Iustin Pop
578 4e071d3b Iustin Pop
    """
579 4e071d3b Iustin Pop
    return backend.GetMasterInfo()
580 a8083063 Iustin Pop
581 6ddc95ec Michael Hanselmann
  @staticmethod
582 6ddc95ec Michael Hanselmann
  def perspective_write_ssconf_files(params):
583 6ddc95ec Michael Hanselmann
    """Write ssconf files.
584 6ddc95ec Michael Hanselmann
585 6ddc95ec Michael Hanselmann
    """
586 03d1dba2 Michael Hanselmann
    (values,) = params
587 03d1dba2 Michael Hanselmann
    return backend.WriteSsconfFiles(values)
588 6ddc95ec Michael Hanselmann
589 a8083063 Iustin Pop
  # os -----------------------
590 a8083063 Iustin Pop
591 3ecf6786 Iustin Pop
  @staticmethod
592 3ecf6786 Iustin Pop
  def perspective_os_diagnose(params):
593 3ecf6786 Iustin Pop
    """Query detailed information about existing OSes.
594 3ecf6786 Iustin Pop
595 3ecf6786 Iustin Pop
    """
596 4e679f11 Guido Trotter
    return [os.ToDict() for os in backend.DiagnoseOS()]
597 a8083063 Iustin Pop
598 3ecf6786 Iustin Pop
  @staticmethod
599 3ecf6786 Iustin Pop
  def perspective_os_get(params):
600 3ecf6786 Iustin Pop
    """Query information about a given OS.
601 3ecf6786 Iustin Pop
602 3ecf6786 Iustin Pop
    """
603 a8083063 Iustin Pop
    name = params[0]
604 a8083063 Iustin Pop
    try:
605 dfa96ded Guido Trotter
      os_obj = backend.OSFromDisk(name)
606 a8083063 Iustin Pop
    except errors.InvalidOS, err:
607 dfa96ded Guido Trotter
      os_obj = objects.OS.FromInvalidOS(err)
608 dfa96ded Guido Trotter
    return os_obj.ToDict()
609 a8083063 Iustin Pop
610 a8083063 Iustin Pop
  # hooks -----------------------
611 a8083063 Iustin Pop
612 3ecf6786 Iustin Pop
  @staticmethod
613 3ecf6786 Iustin Pop
  def perspective_hooks_runner(params):
614 3ecf6786 Iustin Pop
    """Run hook scripts.
615 3ecf6786 Iustin Pop
616 3ecf6786 Iustin Pop
    """
617 a8083063 Iustin Pop
    hpath, phase, env = params
618 a8083063 Iustin Pop
    hr = backend.HooksRunner()
619 a8083063 Iustin Pop
    return hr.RunHooks(hpath, phase, env)
620 a8083063 Iustin Pop
621 8d528b7c Iustin Pop
  # iallocator -----------------
622 8d528b7c Iustin Pop
623 8d528b7c Iustin Pop
  @staticmethod
624 8d528b7c Iustin Pop
  def perspective_iallocator_runner(params):
625 8d528b7c Iustin Pop
    """Run an iallocator script.
626 8d528b7c Iustin Pop
627 8d528b7c Iustin Pop
    """
628 8d528b7c Iustin Pop
    name, idata = params
629 8d528b7c Iustin Pop
    iar = backend.IAllocatorRunner()
630 8d528b7c Iustin Pop
    return iar.Run(name, idata)
631 8d528b7c Iustin Pop
632 06009e27 Iustin Pop
  # test -----------------------
633 06009e27 Iustin Pop
634 06009e27 Iustin Pop
  @staticmethod
635 06009e27 Iustin Pop
  def perspective_test_delay(params):
636 06009e27 Iustin Pop
    """Run test delay.
637 06009e27 Iustin Pop
638 06009e27 Iustin Pop
    """
639 06009e27 Iustin Pop
    duration = params[0]
640 06009e27 Iustin Pop
    return utils.TestDelay(duration)
641 06009e27 Iustin Pop
642 4e071d3b Iustin Pop
  # file storage ---------------
643 4e071d3b Iustin Pop
644 a5d7fb43 Manuel Franceschini
  @staticmethod
645 a5d7fb43 Manuel Franceschini
  def perspective_file_storage_dir_create(params):
646 a5d7fb43 Manuel Franceschini
    """Create the file storage directory.
647 a5d7fb43 Manuel Franceschini
648 a5d7fb43 Manuel Franceschini
    """
649 a5d7fb43 Manuel Franceschini
    file_storage_dir = params[0]
650 a5d7fb43 Manuel Franceschini
    return backend.CreateFileStorageDir(file_storage_dir)
651 a5d7fb43 Manuel Franceschini
652 a5d7fb43 Manuel Franceschini
  @staticmethod
653 a5d7fb43 Manuel Franceschini
  def perspective_file_storage_dir_remove(params):
654 a5d7fb43 Manuel Franceschini
    """Remove the file storage directory.
655 a5d7fb43 Manuel Franceschini
656 a5d7fb43 Manuel Franceschini
    """
657 a5d7fb43 Manuel Franceschini
    file_storage_dir = params[0]
658 a5d7fb43 Manuel Franceschini
    return backend.RemoveFileStorageDir(file_storage_dir)
659 a5d7fb43 Manuel Franceschini
660 a5d7fb43 Manuel Franceschini
  @staticmethod
661 a5d7fb43 Manuel Franceschini
  def perspective_file_storage_dir_rename(params):
662 a5d7fb43 Manuel Franceschini
    """Rename the file storage directory.
663 a5d7fb43 Manuel Franceschini
664 a5d7fb43 Manuel Franceschini
    """
665 a5d7fb43 Manuel Franceschini
    old_file_storage_dir = params[0]
666 a5d7fb43 Manuel Franceschini
    new_file_storage_dir = params[1]
667 a5d7fb43 Manuel Franceschini
    return backend.RenameFileStorageDir(old_file_storage_dir,
668 a5d7fb43 Manuel Franceschini
                                        new_file_storage_dir)
669 a5d7fb43 Manuel Franceschini
670 4e071d3b Iustin Pop
  # jobs ------------------------
671 4e071d3b Iustin Pop
672 ca52cdeb Michael Hanselmann
  @staticmethod
673 7f30777b Michael Hanselmann
  @_RequireJobQueueLock
674 ca52cdeb Michael Hanselmann
  def perspective_jobqueue_update(params):
675 ca52cdeb Michael Hanselmann
    """Update job queue.
676 ca52cdeb Michael Hanselmann
677 ca52cdeb Michael Hanselmann
    """
678 ca52cdeb Michael Hanselmann
    (file_name, content) = params
679 7f30777b Michael Hanselmann
    return backend.JobQueueUpdate(file_name, content)
680 ca52cdeb Michael Hanselmann
681 ca52cdeb Michael Hanselmann
  @staticmethod
682 f1f3f45c Michael Hanselmann
  @_RequireJobQueueLock
683 ca52cdeb Michael Hanselmann
  def perspective_jobqueue_purge(params):
684 ca52cdeb Michael Hanselmann
    """Purge job queue.
685 ca52cdeb Michael Hanselmann
686 ca52cdeb Michael Hanselmann
    """
687 ca52cdeb Michael Hanselmann
    return backend.JobQueuePurge()
688 ca52cdeb Michael Hanselmann
689 af5ebcb1 Michael Hanselmann
  @staticmethod
690 af5ebcb1 Michael Hanselmann
  @_RequireJobQueueLock
691 af5ebcb1 Michael Hanselmann
  def perspective_jobqueue_rename(params):
692 af5ebcb1 Michael Hanselmann
    """Rename a job queue file.
693 af5ebcb1 Michael Hanselmann
694 af5ebcb1 Michael Hanselmann
    """
695 dd875d32 Michael Hanselmann
    # TODO: What if a file fails to rename?
696 dd875d32 Michael Hanselmann
    return [backend.JobQueueRename(old, new) for old, new in params]
697 af5ebcb1 Michael Hanselmann
698 5d672980 Iustin Pop
  @staticmethod
699 5d672980 Iustin Pop
  def perspective_jobqueue_set_drain(params):
700 5d672980 Iustin Pop
    """Set/unset the queue drain flag.
701 5d672980 Iustin Pop
702 5d672980 Iustin Pop
    """
703 5d672980 Iustin Pop
    drain_flag = params[0]
704 5d672980 Iustin Pop
    return backend.JobQueueSetDrainFlag(drain_flag)
705 5d672980 Iustin Pop
706 5d672980 Iustin Pop
707 6217e295 Iustin Pop
  # hypervisor ---------------
708 6217e295 Iustin Pop
709 6217e295 Iustin Pop
  @staticmethod
710 6217e295 Iustin Pop
  def perspective_hypervisor_validate_params(params):
711 6217e295 Iustin Pop
    """Validate the hypervisor parameters.
712 6217e295 Iustin Pop
713 6217e295 Iustin Pop
    """
714 6217e295 Iustin Pop
    (hvname, hvparams) = params
715 6217e295 Iustin Pop
    return backend.ValidateHVParams(hvname, hvparams)
716 6217e295 Iustin Pop
717 a8083063 Iustin Pop
718 a8083063 Iustin Pop
def ParseOptions():
719 a8083063 Iustin Pop
  """Parse the command line options.
720 a8083063 Iustin Pop
721 c41eea6e Iustin Pop
  @return: (options, args) as from OptionParser.parse_args()
722 a8083063 Iustin Pop
723 a8083063 Iustin Pop
  """
724 a8083063 Iustin Pop
  parser = OptionParser(description="Ganeti node daemon",
725 a8083063 Iustin Pop
                        usage="%prog [-f] [-d]",
726 a8083063 Iustin Pop
                        version="%%prog (ganeti) %s" %
727 a8083063 Iustin Pop
                        constants.RELEASE_VERSION)
728 a8083063 Iustin Pop
729 a8083063 Iustin Pop
  parser.add_option("-f", "--foreground", dest="fork",
730 a8083063 Iustin Pop
                    help="Don't detach from the current terminal",
731 a8083063 Iustin Pop
                    default=True, action="store_false")
732 a8083063 Iustin Pop
  parser.add_option("-d", "--debug", dest="debug",
733 a8083063 Iustin Pop
                    help="Enable some debug messages",
734 a8083063 Iustin Pop
                    default=False, action="store_true")
735 a8083063 Iustin Pop
  options, args = parser.parse_args()
736 a8083063 Iustin Pop
  return options, args
737 a8083063 Iustin Pop
738 a8083063 Iustin Pop
739 8adbffaa Iustin Pop
def EnsureRuntimeEnvironment():
740 8adbffaa Iustin Pop
  """Ensure our run-time environment is complete.
741 8adbffaa Iustin Pop
742 8adbffaa Iustin Pop
  Currently this creates directories which could be missing, either
743 8adbffaa Iustin Pop
  due to directories being on a tmpfs mount, or due to incomplete
744 8adbffaa Iustin Pop
  packaging.
745 8adbffaa Iustin Pop
746 8adbffaa Iustin Pop
  """
747 817a030d Guido Trotter
  dirs = [(val, constants.RUN_DIRS_MODE) for val in constants.SUB_RUN_DIRS]
748 8adbffaa Iustin Pop
  dirs.append((constants.LOG_OS_DIR, 0750))
749 8adbffaa Iustin Pop
  for dir_name, dir_mode in dirs:
750 8adbffaa Iustin Pop
    if not os.path.exists(dir_name):
751 8adbffaa Iustin Pop
      try:
752 8adbffaa Iustin Pop
        os.mkdir(dir_name, dir_mode)
753 8adbffaa Iustin Pop
      except EnvironmentError, err:
754 8adbffaa Iustin Pop
        if err.errno != errno.EEXIST:
755 8adbffaa Iustin Pop
          print ("Node setup wrong, cannot create directory '%s': %s" %
756 8adbffaa Iustin Pop
                 (dir_name, err))
757 8adbffaa Iustin Pop
          sys.exit(5)
758 8adbffaa Iustin Pop
    if not os.path.isdir(dir_name):
759 8adbffaa Iustin Pop
      print ("Node setup wrong, '%s' is not a directory" % dir_name)
760 8adbffaa Iustin Pop
      sys.exit(5)
761 8adbffaa Iustin Pop
762 8adbffaa Iustin Pop
763 a8083063 Iustin Pop
def main():
764 3ecf6786 Iustin Pop
  """Main function for the node daemon.
765 3ecf6786 Iustin Pop
766 3ecf6786 Iustin Pop
  """
767 25d6d12a Michael Hanselmann
  global queue_lock
768 25d6d12a Michael Hanselmann
769 a8083063 Iustin Pop
  options, args = ParseOptions()
770 f362096f Iustin Pop
  utils.debug = options.debug
771 7d88772a Iustin Pop
772 7d88772a Iustin Pop
  if options.fork:
773 7d88772a Iustin Pop
    utils.CloseFDs()
774 7d88772a Iustin Pop
775 a8083063 Iustin Pop
  for fname in (constants.SSL_CERT_FILE,):
776 a8083063 Iustin Pop
    if not os.path.isfile(fname):
777 a8083063 Iustin Pop
      print "config %s not there, will not run." % fname
778 a8083063 Iustin Pop
      sys.exit(5)
779 a8083063 Iustin Pop
780 a8083063 Iustin Pop
  try:
781 8594f271 Michael Hanselmann
    port = utils.GetNodeDaemonPort()
782 a8083063 Iustin Pop
  except errors.ConfigurationError, err:
783 a8083063 Iustin Pop
    print "Cluster configuration incomplete: '%s'" % str(err)
784 a8083063 Iustin Pop
    sys.exit(5)
785 a8083063 Iustin Pop
786 8adbffaa Iustin Pop
  EnsureRuntimeEnvironment()
787 0214b0c0 Iustin Pop
788 a8083063 Iustin Pop
  # become a daemon
789 a8083063 Iustin Pop
  if options.fork:
790 8f765069 Iustin Pop
    utils.Daemonize(logfile=constants.LOG_NODESERVER)
791 a8083063 Iustin Pop
792 99e88451 Iustin Pop
  utils.WritePidFile(constants.NODED_PID)
793 cc28af80 Michael Hanselmann
  try:
794 82d9caef Iustin Pop
    utils.SetupLogging(logfile=constants.LOG_NODESERVER, debug=options.debug,
795 82d9caef Iustin Pop
                       stderr_logging=not options.fork)
796 cc28af80 Michael Hanselmann
    logging.info("ganeti node daemon startup")
797 73d927a2 Guido Trotter
798 eafd8762 Michael Hanselmann
    # Read SSL certificate
799 eafd8762 Michael Hanselmann
    ssl_params = http.HttpSslParams(ssl_key_path=constants.SSL_CERT_FILE,
800 eafd8762 Michael Hanselmann
                                    ssl_cert_path=constants.SSL_CERT_FILE)
801 eafd8762 Michael Hanselmann
802 cc28af80 Michael Hanselmann
    # Prepare job queue
803 cc28af80 Michael Hanselmann
    queue_lock = jstore.InitAndVerifyQueue(must_lock=False)
804 a8083063 Iustin Pop
805 cc28af80 Michael Hanselmann
    mainloop = daemon.Mainloop()
806 eafd8762 Michael Hanselmann
    server = NodeHttpServer(mainloop, "", port,
807 eafd8762 Michael Hanselmann
                            ssl_params=ssl_params, ssl_verify_peer=True)
808 cc28af80 Michael Hanselmann
    server.Start()
809 cc28af80 Michael Hanselmann
    try:
810 cc28af80 Michael Hanselmann
      mainloop.Run()
811 cc28af80 Michael Hanselmann
    finally:
812 cc28af80 Michael Hanselmann
      server.Stop()
813 73d927a2 Guido Trotter
  finally:
814 99e88451 Iustin Pop
    utils.RemovePidFile(constants.NODED_PID)
815 73d927a2 Guido Trotter
816 a8083063 Iustin Pop
817 3ecf6786 Iustin Pop
if __name__ == '__main__':
818 a8083063 Iustin Pop
  main()