Statistics
| Branch: | Tag: | Revision:

root / lib / backend.py @ f491c3a8

History | View | Annotate | Download (38.1 kB)

1
#!/usr/bin/python
2
#
3

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

    
21

    
22
"""Functions used by the node daemon"""
23

    
24

    
25
import os
26
import os.path
27
import shutil
28
import time
29
import tempfile
30
import stat
31
import errno
32
import re
33
import subprocess
34

    
35
from ganeti import logger
36
from ganeti import errors
37
from ganeti import utils
38
from ganeti import ssh
39
from ganeti import hypervisor
40
from ganeti import constants
41
from ganeti import bdev
42
from ganeti import objects
43
from ganeti import ssconf
44

    
45

    
46
def StartMaster():
47
  """Activate local node as master node.
48

49
  There are two needed steps for this:
50
    - run the master script
51
    - register the cron script
52

53
  """
54
  result = utils.RunCmd([constants.MASTER_SCRIPT, "-d", "start"])
55

    
56
  if result.failed:
57
    logger.Error("could not activate cluster interface with command %s,"
58
                 " error: '%s'" % (result.cmd, result.output))
59
    return False
60

    
61
  return True
62

    
63

    
64
def StopMaster():
65
  """Deactivate this node as master.
66

67
  This does two things:
68
    - run the master stop script
69
    - remove link to master cron script.
70

71
  """
72
  result = utils.RunCmd([constants.MASTER_SCRIPT, "-d", "stop"])
73

    
74
  if result.failed:
75
    logger.Error("could not deactivate cluster interface with command %s,"
76
                 " error: '%s'" % (result.cmd, result.output))
77
    return False
78

    
79
  return True
80

    
81

    
82
def AddNode(dsa, dsapub, rsa, rsapub, sshkey, sshpub):
83
  """ adds the node to the cluster
84
      - updates the hostkey
85
      - adds the ssh-key
86
      - sets the node id
87
      - sets the node status to installed
88

89
  """
90
  f = open("/etc/ssh/ssh_host_rsa_key", 'w')
91
  f.write(rsa)
92
  f.close()
93

    
94
  f = open("/etc/ssh/ssh_host_rsa_key.pub", 'w')
95
  f.write(rsapub)
96
  f.close()
97

    
98
  f = open("/etc/ssh/ssh_host_dsa_key", 'w')
99
  f.write(dsa)
100
  f.close()
101

    
102
  f = open("/etc/ssh/ssh_host_dsa_key.pub", 'w')
103
  f.write(dsapub)
104
  f.close()
105

    
106
  if not os.path.isdir("/root/.ssh"):
107
    os.mkdir("/root/.ssh")
108

    
109
  f = open("/root/.ssh/id_dsa", 'w')
110
  f.write(sshkey)
111
  f.close()
112

    
113
  f = open("/root/.ssh/id_dsa.pub", 'w')
114
  f.write(sshpub)
115
  f.close()
116

    
117
  f = open('/root/.ssh/id_dsa.pub', 'r')
118
  try:
119
    utils.AddAuthorizedKey('/root/.ssh/authorized_keys', f.read(8192))
120
  finally:
121
    f.close()
122

    
123
  utils.RunCmd([constants.SSH_INITD_SCRIPT, "restart"])
124

    
125
  return True
126

    
127

    
128
def LeaveCluster():
129
  """Cleans up the current node and prepares it to be removed from the cluster.
130

131
  """
132
  if os.path.exists(constants.DATA_DIR):
133
    for dirpath, dirnames, filenames in os.walk(constants.DATA_DIR):
134
      if dirpath == constants.DATA_DIR:
135
        for i in filenames:
136
          os.unlink(os.path.join(dirpath, i))
137

    
138
  f = open('/root/.ssh/id_dsa.pub', 'r')
139
  try:
140
    utils.RemoveAuthorizedKey('/root/.ssh/authorized_keys', f.read(8192))
141
  finally:
142
    f.close()
143

    
144
  utils.RemoveFile('/root/.ssh/id_dsa')
145
  utils.RemoveFile('/root/.ssh/id_dsa.pub')
146

    
147

    
148
def GetNodeInfo(vgname):
149
  """ gives back a hash with different informations
150
  about the node
151

152
  Returns:
153
    { 'vg_size' : xxx,  'vg_free' : xxx, 'memory_domain0': xxx,
154
      'memory_free' : xxx, 'memory_total' : xxx }
155
    where
156
    vg_size is the size of the configured volume group in MiB
157
    vg_free is the free size of the volume group in MiB
158
    memory_dom0 is the memory allocated for domain0 in MiB
159
    memory_free is the currently available (free) ram in MiB
160
    memory_total is the total number of ram in MiB
161

162
  """
163
  outputarray = {}
164
  vginfo = _GetVGInfo(vgname)
165
  outputarray['vg_size'] = vginfo['vg_size']
166
  outputarray['vg_free'] = vginfo['vg_free']
167

    
168
  hyper = hypervisor.GetHypervisor()
169
  hyp_info = hyper.GetNodeInfo()
170
  if hyp_info is not None:
171
    outputarray.update(hyp_info)
172

    
173
  return outputarray
174

    
175

    
176
def VerifyNode(what):
177
  """Verify the status of the local node.
178

179
  Args:
180
    what - a dictionary of things to check:
181
      'filelist' : list of files for which to compute checksums
182
      'nodelist' : list of nodes we should check communication with
183
      'hypervisor': run the hypervisor-specific verify
184

185
  Requested files on local node are checksummed and the result returned.
186

187
  The nodelist is traversed, with the following checks being made
188
  for each node:
189
  - known_hosts key correct
190
  - correct resolving of node name (target node returns its own hostname
191
    by ssh-execution of 'hostname', result compared against name in list.
192

193
  """
194
  result = {}
195

    
196
  if 'hypervisor' in what:
197
    result['hypervisor'] = hypervisor.GetHypervisor().Verify()
198

    
199
  if 'filelist' in what:
200
    result['filelist'] = utils.FingerprintFiles(what['filelist'])
201

    
202
  if 'nodelist' in what:
203
    result['nodelist'] = {}
204
    for node in what['nodelist']:
205
      success, message = ssh.VerifyNodeHostname(node)
206
      if not success:
207
        result['nodelist'][node] = message
208
  return result
209

    
210

    
211
def GetVolumeList(vg_name):
212
  """Compute list of logical volumes and their size.
213

214
  Returns:
215
    dictionary of all partions (key) with their size:
216
    test1: 20.06MiB
217

218
  """
219
  result = utils.RunCmd(["lvs", "--noheadings", "--units=m",
220
                         "-oname,size", vg_name])
221
  if result.failed:
222
    logger.Error("Failed to list logical volumes, lvs output: %s" %
223
                 result.output)
224
    return {}
225

    
226
  lvlist = [line.split() for line in result.output.splitlines()]
227
  return dict(lvlist)
228

    
229

    
230
def ListVolumeGroups():
231
  """List the volume groups and their size
232

233
  Returns:
234
    Dictionary with keys volume name and values the size of the volume
235

236
  """
237
  return utils.ListVolumeGroups()
238

    
239

    
240
def NodeVolumes():
241
  """List all volumes on this node.
242

243
  """
244
  result = utils.RunCmd(["lvs", "--noheadings", "--units=m", "--nosuffix",
245
                         "--separator=|",
246
                         "--options=lv_name,lv_size,devices,vg_name"])
247
  if result.failed:
248
    logger.Error("Failed to list logical volumes, lvs output: %s" %
249
                 result.output)
250
    return {}
251

    
252
  def parse_dev(dev):
253
    if '(' in dev:
254
      return dev.split('(')[0]
255
    else:
256
      return dev
257

    
258
  def map_line(line):
259
    return {
260
      'name': line[0].strip(),
261
      'size': line[1].strip(),
262
      'dev': parse_dev(line[2].strip()),
263
      'vg': line[3].strip(),
264
    }
265

    
266
  return [map_line(line.split('|')) for line in result.output.splitlines()]
267

    
268

    
269
def BridgesExist(bridges_list):
270
  """Check if a list of bridges exist on the current node
271

272
  Returns:
273
    True if all of them exist, false otherwise
274

275
  """
276
  for bridge in bridges_list:
277
    if not utils.BridgeExists(bridge):
278
      return False
279

    
280
  return True
281

    
282

    
283
def GetInstanceList():
284
  """ provides a list of instances
285

286
  Returns:
287
    A list of all running instances on the current node
288
    - instance1.example.com
289
    - instance2.example.com
290

291
  """
292
  try:
293
    names = hypervisor.GetHypervisor().ListInstances()
294
  except errors.HypervisorError, err:
295
    logger.Error("error enumerating instances: %s" % str(err))
296
    raise
297

    
298
  return names
299

    
300

    
301
def GetInstanceInfo(instance):
302
  """ gives back the informations about an instance
303
  as a dictonary
304

305
  Args:
306
    instance: name of the instance (ex. instance1.example.com)
307

308
  Returns:
309
    { 'memory' : 511, 'state' : '-b---', 'time' : 3188.8, }
310
    where
311
    memory: memory size of instance (int)
312
    state: xen state of instance (string)
313
    time: cpu time of instance (float)
314

315
  """
316
  output = {}
317

    
318
  iinfo = hypervisor.GetHypervisor().GetInstanceInfo(instance)
319
  if iinfo is not None:
320
    output['memory'] = iinfo[2]
321
    output['state'] = iinfo[4]
322
    output['time'] = iinfo[5]
323

    
324
  return output
325

    
326

    
327
def GetAllInstancesInfo():
328
  """Gather data about all instances.
329

330
  This is the equivalent of `GetInstanceInfo()`, except that it
331
  computes data for all instances at once, thus being faster if one
332
  needs data about more than one instance.
333

334
  Returns: a dictionary of dictionaries, keys being the instance name,
335
    and with values:
336
    { 'memory' : 511, 'state' : '-b---', 'time' : 3188.8, }
337
    where
338
    memory: memory size of instance (int)
339
    state: xen state of instance (string)
340
    time: cpu time of instance (float)
341
    vcpus: the number of cpus
342

343
  """
344
  output = {}
345

    
346
  iinfo = hypervisor.GetHypervisor().GetAllInstancesInfo()
347
  if iinfo:
348
    for name, inst_id, memory, vcpus, state, times in iinfo:
349
      output[name] = {
350
        'memory': memory,
351
        'vcpus': vcpus,
352
        'state': state,
353
        'time': times,
354
        }
355

    
356
  return output
357

    
358

    
359
def AddOSToInstance(instance, os_disk, swap_disk):
360
  """Add an os to an instance.
361

362
  Args:
363
    instance: the instance object
364
    os_disk: the instance-visible name of the os device
365
    swap_disk: the instance-visible name of the swap device
366

367
  """
368
  inst_os = OSFromDisk(instance.os)
369

    
370
  create_script = inst_os.create_script
371

    
372
  os_device = instance.FindDisk(os_disk)
373
  if os_device is None:
374
    logger.Error("Can't find this device-visible name '%s'" % os_disk)
375
    return False
376

    
377
  swap_device = instance.FindDisk(swap_disk)
378
  if swap_device is None:
379
    logger.Error("Can't find this device-visible name '%s'" % swap_disk)
380
    return False
381

    
382
  real_os_dev = _RecursiveFindBD(os_device)
383
  if real_os_dev is None:
384
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
385
                                  str(os_device))
386
  real_os_dev.Open()
387

    
388
  real_swap_dev = _RecursiveFindBD(swap_device)
389
  if real_swap_dev is None:
390
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
391
                                  str(swap_device))
392
  real_swap_dev.Open()
393

    
394
  logfile = "%s/add-%s-%s-%d.log" % (constants.LOG_OS_DIR, instance.os,
395
                                     instance.name, int(time.time()))
396
  if not os.path.exists(constants.LOG_OS_DIR):
397
    os.mkdir(constants.LOG_OS_DIR, 0750)
398

    
399
  command = utils.BuildShellCmd("cd %s && %s -i %s -b %s -s %s &>%s",
400
                                inst_os.path, create_script, instance.name,
401
                                real_os_dev.dev_path, real_swap_dev.dev_path,
402
                                logfile)
403

    
404
  result = utils.RunCmd(command)
405

    
406
  if result.failed:
407
    logger.Error("os create command '%s' returned error: %s"
408
                 " output: %s" %
409
                 (command, result.fail_reason, result.output))
410
    return False
411

    
412
  return True
413

    
414

    
415
def RunRenameInstance(instance, old_name, os_disk, swap_disk):
416
  """Run the OS rename script for an instance.
417

418
  Args:
419
    instance: the instance object
420
    old_name: the old name of the instance
421
    os_disk: the instance-visible name of the os device
422
    swap_disk: the instance-visible name of the swap device
423

424
  """
425
  inst_os = OSFromDisk(instance.os)
426

    
427
  script = inst_os.rename_script
428

    
429
  os_device = instance.FindDisk(os_disk)
430
  if os_device is None:
431
    logger.Error("Can't find this device-visible name '%s'" % os_disk)
432
    return False
433

    
434
  swap_device = instance.FindDisk(swap_disk)
435
  if swap_device is None:
436
    logger.Error("Can't find this device-visible name '%s'" % swap_disk)
437
    return False
438

    
439
  real_os_dev = _RecursiveFindBD(os_device)
440
  if real_os_dev is None:
441
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
442
                                  str(os_device))
443
  real_os_dev.Open()
444

    
445
  real_swap_dev = _RecursiveFindBD(swap_device)
446
  if real_swap_dev is None:
447
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
448
                                  str(swap_device))
449
  real_swap_dev.Open()
450

    
451
  logfile = "%s/rename-%s-%s-%s-%d.log" % (constants.LOG_OS_DIR, instance.os,
452
                                           old_name,
453
                                           instance.name, int(time.time()))
454
  if not os.path.exists(constants.LOG_OS_DIR):
455
    os.mkdir(constants.LOG_OS_DIR, 0750)
456

    
457
  command = utils.BuildShellCmd("cd %s && %s -o %s -n %s -b %s -s %s &>%s",
458
                                inst_os.path, script, old_name, instance.name,
459
                                real_os_dev.dev_path, real_swap_dev.dev_path,
460
                                logfile)
461

    
462
  result = utils.RunCmd(command)
463

    
464
  if result.failed:
465
    logger.Error("os create command '%s' returned error: %s"
466
                 " output: %s" %
467
                 (command, result.fail_reason, result.output))
468
    return False
469

    
470
  return True
471

    
472

    
473
def _GetVGInfo(vg_name):
474
  """Get informations about the volume group.
475

476
  Args:
477
    vg_name: the volume group
478

479
  Returns:
480
    { 'vg_size' : xxx, 'vg_free' : xxx, 'pv_count' : xxx }
481
    where
482
    vg_size is the total size of the volume group in MiB
483
    vg_free is the free size of the volume group in MiB
484
    pv_count are the number of physical disks in that vg
485

486
  """
487
  retval = utils.RunCmd(["vgs", "-ovg_size,vg_free,pv_count", "--noheadings",
488
                         "--nosuffix", "--units=m", "--separator=:", vg_name])
489

    
490
  if retval.failed:
491
    errmsg = "volume group %s not present" % vg_name
492
    logger.Error(errmsg)
493
    raise errors.LVMError(errmsg)
494
  valarr = retval.stdout.strip().split(':')
495
  retdic = {
496
    "vg_size": int(round(float(valarr[0]), 0)),
497
    "vg_free": int(round(float(valarr[1]), 0)),
498
    "pv_count": int(valarr[2]),
499
    }
500
  return retdic
501

    
502

    
503
def _GatherBlockDevs(instance):
504
  """Set up an instance's block device(s).
505

506
  This is run on the primary node at instance startup. The block
507
  devices must be already assembled.
508

509
  """
510
  block_devices = []
511
  for disk in instance.disks:
512
    device = _RecursiveFindBD(disk)
513
    if device is None:
514
      raise errors.BlockDeviceError("Block device '%s' is not set up." %
515
                                    str(disk))
516
    device.Open()
517
    block_devices.append((disk, device))
518
  return block_devices
519

    
520

    
521
def StartInstance(instance, extra_args):
522
  """Start an instance.
523

524
  Args:
525
    instance - name of instance to start.
526

527
  """
528
  running_instances = GetInstanceList()
529

    
530
  if instance.name in running_instances:
531
    return True
532

    
533
  block_devices = _GatherBlockDevs(instance)
534
  hyper = hypervisor.GetHypervisor()
535

    
536
  try:
537
    hyper.StartInstance(instance, block_devices, extra_args)
538
  except errors.HypervisorError, err:
539
    logger.Error("Failed to start instance: %s" % err)
540
    return False
541

    
542
  return True
543

    
544

    
545
def ShutdownInstance(instance):
546
  """Shut an instance down.
547

548
  Args:
549
    instance - name of instance to shutdown.
550

551
  """
552
  running_instances = GetInstanceList()
553

    
554
  if instance.name not in running_instances:
555
    return True
556

    
557
  hyper = hypervisor.GetHypervisor()
558
  try:
559
    hyper.StopInstance(instance)
560
  except errors.HypervisorError, err:
561
    logger.Error("Failed to stop instance: %s" % err)
562
    return False
563

    
564
  # test every 10secs for 2min
565
  shutdown_ok = False
566

    
567
  time.sleep(1)
568
  for dummy in range(11):
569
    if instance.name not in GetInstanceList():
570
      break
571
    time.sleep(10)
572
  else:
573
    # the shutdown did not succeed
574
    logger.Error("shutdown of '%s' unsuccessful, using destroy" % instance)
575

    
576
    try:
577
      hyper.StopInstance(instance, force=True)
578
    except errors.HypervisorError, err:
579
      logger.Error("Failed to stop instance: %s" % err)
580
      return False
581

    
582
    time.sleep(1)
583
    if instance.name in GetInstanceList():
584
      logger.Error("could not shutdown instance '%s' even by destroy")
585
      return False
586

    
587
  return True
588

    
589

    
590
def CreateBlockDevice(disk, size, on_primary, info):
591
  """Creates a block device for an instance.
592

593
  Args:
594
   bdev: a ganeti.objects.Disk object
595
   size: the size of the physical underlying devices
596
   do_open: if the device should be `Assemble()`-d and
597
            `Open()`-ed after creation
598

599
  Returns:
600
    the new unique_id of the device (this can sometime be
601
    computed only after creation), or None. On secondary nodes,
602
    it's not required to return anything.
603

604
  """
605
  clist = []
606
  if disk.children:
607
    for child in disk.children:
608
      crdev = _RecursiveAssembleBD(child, on_primary)
609
      if on_primary or disk.AssembleOnSecondary():
610
        # we need the children open in case the device itself has to
611
        # be assembled
612
        crdev.Open()
613
      else:
614
        crdev.Close()
615
      clist.append(crdev)
616
  try:
617
    device = bdev.FindDevice(disk.dev_type, disk.physical_id, clist)
618
    if device is not None:
619
      logger.Info("removing existing device %s" % disk)
620
      device.Remove()
621
  except errors.BlockDeviceError, err:
622
    pass
623

    
624
  device = bdev.Create(disk.dev_type, disk.physical_id,
625
                       clist, size)
626
  if device is None:
627
    raise ValueError("Can't create child device for %s, %s" %
628
                     (disk, size))
629
  if on_primary or disk.AssembleOnSecondary():
630
    device.Assemble()
631
    device.SetSyncSpeed(constants.SYNC_SPEED)
632
    if on_primary or disk.OpenOnSecondary():
633
      device.Open(force=True)
634

    
635
  device.SetInfo(info)
636

    
637
  physical_id = device.unique_id
638
  return physical_id
639

    
640

    
641
def RemoveBlockDevice(disk):
642
  """Remove a block device.
643

644
  This is intended to be called recursively.
645

646
  """
647
  try:
648
    # since we are removing the device, allow a partial match
649
    # this allows removal of broken mirrors
650
    rdev = _RecursiveFindBD(disk, allow_partial=True)
651
  except errors.BlockDeviceError, err:
652
    # probably can't attach
653
    logger.Info("Can't attach to device %s in remove" % disk)
654
    rdev = None
655
  if rdev is not None:
656
    result = rdev.Remove()
657
  else:
658
    result = True
659
  if disk.children:
660
    for child in disk.children:
661
      result = result and RemoveBlockDevice(child)
662
  return result
663

    
664

    
665
def _RecursiveAssembleBD(disk, as_primary):
666
  """Activate a block device for an instance.
667

668
  This is run on the primary and secondary nodes for an instance.
669

670
  This function is called recursively.
671

672
  Args:
673
    disk: a objects.Disk object
674
    as_primary: if we should make the block device read/write
675

676
  Returns:
677
    the assembled device or None (in case no device was assembled)
678

679
  If the assembly is not successful, an exception is raised.
680

681
  """
682
  children = []
683
  if disk.children:
684
    for chld_disk in disk.children:
685
      children.append(_RecursiveAssembleBD(chld_disk, as_primary))
686

    
687
  if as_primary or disk.AssembleOnSecondary():
688
    r_dev = bdev.AttachOrAssemble(disk.dev_type, disk.physical_id, children)
689
    r_dev.SetSyncSpeed(constants.SYNC_SPEED)
690
    result = r_dev
691
    if as_primary or disk.OpenOnSecondary():
692
      r_dev.Open()
693
    else:
694
      r_dev.Close()
695
  else:
696
    result = True
697
  return result
698

    
699

    
700
def AssembleBlockDevice(disk, as_primary):
701
  """Activate a block device for an instance.
702

703
  This is a wrapper over _RecursiveAssembleBD.
704

705
  Returns:
706
    a /dev path for primary nodes
707
    True for secondary nodes
708

709
  """
710
  result = _RecursiveAssembleBD(disk, as_primary)
711
  if isinstance(result, bdev.BlockDev):
712
    result = result.dev_path
713
  return result
714

    
715

    
716
def ShutdownBlockDevice(disk):
717
  """Shut down a block device.
718

719
  First, if the device is assembled (can `Attach()`), then the device
720
  is shutdown. Then the children of the device are shutdown.
721

722
  This function is called recursively. Note that we don't cache the
723
  children or such, as oppossed to assemble, shutdown of different
724
  devices doesn't require that the upper device was active.
725

726
  """
727
  r_dev = _RecursiveFindBD(disk)
728
  if r_dev is not None:
729
    result = r_dev.Shutdown()
730
  else:
731
    result = True
732
  if disk.children:
733
    for child in disk.children:
734
      result = result and ShutdownBlockDevice(child)
735
  return result
736

    
737

    
738
def MirrorAddChild(md_cdev, new_cdev):
739
  """Extend an MD raid1 array.
740

741
  """
742
  md_bdev = _RecursiveFindBD(md_cdev, allow_partial=True)
743
  if md_bdev is None:
744
    logger.Error("Can't find md device")
745
    return False
746
  new_bdev = _RecursiveFindBD(new_cdev)
747
  if new_bdev is None:
748
    logger.Error("Can't find new device to add")
749
    return False
750
  new_bdev.Open()
751
  md_bdev.AddChild(new_bdev)
752
  return True
753

    
754

    
755
def MirrorRemoveChild(md_cdev, new_cdev):
756
  """Reduce an MD raid1 array.
757

758
  """
759
  md_bdev = _RecursiveFindBD(md_cdev)
760
  if md_bdev is None:
761
    return False
762
  new_bdev = _RecursiveFindBD(new_cdev)
763
  if new_bdev is None:
764
    return False
765
  new_bdev.Open()
766
  md_bdev.RemoveChild(new_bdev.dev_path)
767
  return True
768

    
769

    
770
def GetMirrorStatus(disks):
771
  """Get the mirroring status of a list of devices.
772

773
  Args:
774
    disks: list of `objects.Disk`
775

776
  Returns:
777
    list of (mirror_done, estimated_time) tuples, which
778
    are the result of bdev.BlockDevice.CombinedSyncStatus()
779

780
  """
781
  stats = []
782
  for dsk in disks:
783
    rbd = _RecursiveFindBD(dsk)
784
    if rbd is None:
785
      raise errors.BlockDeviceError("Can't find device %s" % str(dsk))
786
    stats.append(rbd.CombinedSyncStatus())
787
  return stats
788

    
789

    
790
def _RecursiveFindBD(disk, allow_partial=False):
791
  """Check if a device is activated.
792

793
  If so, return informations about the real device.
794

795
  Args:
796
    disk: the objects.Disk instance
797
    allow_partial: don't abort the find if a child of the
798
                   device can't be found; this is intended to be
799
                   used when repairing mirrors
800

801
  Returns:
802
    None if the device can't be found
803
    otherwise the device instance
804

805
  """
806
  children = []
807
  if disk.children:
808
    for chdisk in disk.children:
809
      children.append(_RecursiveFindBD(chdisk))
810

    
811
  return bdev.FindDevice(disk.dev_type, disk.physical_id, children)
812

    
813

    
814
def FindBlockDevice(disk):
815
  """Check if a device is activated.
816

817
  If so, return informations about the real device.
818

819
  Args:
820
    disk: the objects.Disk instance
821
  Returns:
822
    None if the device can't be found
823
    (device_path, major, minor, sync_percent, estimated_time, is_degraded)
824

825
  """
826
  rbd = _RecursiveFindBD(disk)
827
  if rbd is None:
828
    return rbd
829
  sync_p, est_t, is_degr = rbd.GetSyncStatus()
830
  return rbd.dev_path, rbd.major, rbd.minor, sync_p, est_t, is_degr
831

    
832

    
833
def UploadFile(file_name, data, mode, uid, gid, atime, mtime):
834
  """Write a file to the filesystem.
835

836
  This allows the master to overwrite(!) a file. It will only perform
837
  the operation if the file belongs to a list of configuration files.
838

839
  """
840
  if not os.path.isabs(file_name):
841
    logger.Error("Filename passed to UploadFile is not absolute: '%s'" %
842
                 file_name)
843
    return False
844

    
845
  allowed_files = [constants.CLUSTER_CONF_FILE, "/etc/hosts",
846
                   constants.SSH_KNOWN_HOSTS_FILE]
847
  allowed_files.extend(ssconf.SimpleStore().GetFileList())
848
  if file_name not in allowed_files:
849
    logger.Error("Filename passed to UploadFile not in allowed"
850
                 " upload targets: '%s'" % file_name)
851
    return False
852

    
853
  dir_name, small_name = os.path.split(file_name)
854
  fd, new_name = tempfile.mkstemp('.new', small_name, dir_name)
855
  # here we need to make sure we remove the temp file, if any error
856
  # leaves it in place
857
  try:
858
    os.chown(new_name, uid, gid)
859
    os.chmod(new_name, mode)
860
    os.write(fd, data)
861
    os.fsync(fd)
862
    os.utime(new_name, (atime, mtime))
863
    os.rename(new_name, file_name)
864
  finally:
865
    os.close(fd)
866
    utils.RemoveFile(new_name)
867
  return True
868

    
869

    
870
def _ErrnoOrStr(err):
871
  """Format an EnvironmentError exception.
872

873
  If the `err` argument has an errno attribute, it will be looked up
874
  and converted into a textual EXXXX description. Otherwise the string
875
  representation of the error will be returned.
876

877
  """
878
  if hasattr(err, 'errno'):
879
    detail = errno.errorcode[err.errno]
880
  else:
881
    detail = str(err)
882
  return detail
883

    
884

    
885
def _OSOndiskVersion(name, os_dir=None):
886
  """Compute and return the api version of a given OS.
887

888
  This function will try to read the api version of the os given by
889
  the 'name' parameter. By default, it wil use the constants.OS_DIR
890
  as top-level directory for OSes, but this can be overriden by the
891
  use of the os_dir parameter. Return value will be either an
892
  integer denoting the version or None in the case when this is not
893
  a valid OS name.
894

895
  """
896
  if os_dir is None:
897
    os_dir = os.path.sep.join([constants.OS_DIR, name])
898

    
899
  api_file = os.path.sep.join([os_dir, "ganeti_api_version"])
900

    
901
  try:
902
    st = os.stat(api_file)
903
  except EnvironmentError, err:
904
    raise errors.InvalidOS(name, "'ganeti_api_version' file not"
905
                           " found (%s)" % _ErrnoOrStr(err))
906

    
907
  if not stat.S_ISREG(stat.S_IFMT(st.st_mode)):
908
    raise errors.InvalidOS(name, "'ganeti_api_version' file is not"
909
                           " a regular file")
910

    
911
  try:
912
    f = open(api_file)
913
    try:
914
      api_version = f.read(256)
915
    finally:
916
      f.close()
917
  except EnvironmentError, err:
918
    raise errors.InvalidOS(name, "error while reading the"
919
                           " API version (%s)" % _ErrnoOrStr(err))
920

    
921
  api_version = api_version.strip()
922
  try:
923
    api_version = int(api_version)
924
  except (TypeError, ValueError), err:
925
    raise errors.InvalidOS(name, "API version is not integer (%s)" % str(err))
926

    
927
  return api_version
928

    
929

    
930
def DiagnoseOS(top_dir=None):
931
  """Compute the validity for all OSes.
932

933
  For each name in the give top_dir parameter (if not given, defaults
934
  to constants.OS_DIR), it will return an object. If this is a valid
935
  os, the object will be an instance of the object.OS class. If not,
936
  it will be an instance of errors.InvalidOS and this signifies that
937
  this name does not correspond to a valid OS.
938

939
  Returns:
940
    list of objects
941

942
  """
943
  if top_dir is None:
944
    top_dir = constants.OS_DIR
945

    
946
  try:
947
    f_names = os.listdir(top_dir)
948
  except EnvironmentError, err:
949
    logger.Error("Can't list the OS directory: %s" % str(err))
950
    return False
951
  result = []
952
  for name in f_names:
953
    try:
954
      os_inst = OSFromDisk(name, os.path.sep.join([top_dir, name]))
955
      result.append(os_inst)
956
    except errors.InvalidOS, err:
957
      result.append(err)
958

    
959
  return result
960

    
961

    
962
def OSFromDisk(name, os_dir=None):
963
  """Create an OS instance from disk.
964

965
  This function will return an OS instance if the given name is a
966
  valid OS name. Otherwise, it will raise an appropriate
967
  `errors.InvalidOS` exception, detailing why this is not a valid
968
  OS.
969

970
  """
971
  if os_dir is None:
972
    os_dir = os.path.sep.join([constants.OS_DIR, name])
973

    
974
  api_version = _OSOndiskVersion(name, os_dir)
975

    
976
  if api_version != constants.OS_API_VERSION:
977
    raise errors.InvalidOS(name, "API version mismatch (found %s want %s)"
978
                           % (api_version, constants.OS_API_VERSION))
979

    
980
  # OS Scripts dictionary, we will populate it with the actual script names
981
  os_scripts = {'create': '', 'export': '', 'import': '', 'rename': ''}
982

    
983
  for script in os_scripts:
984
    os_scripts[script] = os.path.sep.join([os_dir, script])
985

    
986
    try:
987
      st = os.stat(os_scripts[script])
988
    except EnvironmentError, err:
989
      raise errors.InvalidOS(name, "'%s' script missing (%s)" %
990
                             (script, _ErrnoOrStr(err)))
991

    
992
    if stat.S_IMODE(st.st_mode) & stat.S_IXUSR != stat.S_IXUSR:
993
      raise errors.InvalidOS(name, "'%s' script not executable" % script)
994

    
995
    if not stat.S_ISREG(stat.S_IFMT(st.st_mode)):
996
      raise errors.InvalidOS(name, "'%s' is not a regular file" % script)
997

    
998

    
999
  return objects.OS(name=name, path=os_dir,
1000
                    create_script=os_scripts['create'],
1001
                    export_script=os_scripts['export'],
1002
                    import_script=os_scripts['import'],
1003
                    rename_script=os_scripts['rename'],
1004
                    api_version=api_version)
1005

    
1006

    
1007
def SnapshotBlockDevice(disk):
1008
  """Create a snapshot copy of a block device.
1009

1010
  This function is called recursively, and the snapshot is actually created
1011
  just for the leaf lvm backend device.
1012

1013
  Args:
1014
    disk: the disk to be snapshotted
1015

1016
  Returns:
1017
    a config entry for the actual lvm device snapshotted.
1018

1019
  """
1020
  if disk.children:
1021
    if len(disk.children) == 1:
1022
      # only one child, let's recurse on it
1023
      return SnapshotBlockDevice(disk.children[0])
1024
    else:
1025
      # more than one child, choose one that matches
1026
      for child in disk.children:
1027
        if child.size == disk.size:
1028
          # return implies breaking the loop
1029
          return SnapshotBlockDevice(child)
1030
  elif disk.dev_type == "lvm":
1031
    r_dev = _RecursiveFindBD(disk)
1032
    if r_dev is not None:
1033
      # let's stay on the safe side and ask for the full size, for now
1034
      return r_dev.Snapshot(disk.size)
1035
    else:
1036
      return None
1037
  else:
1038
    raise errors.ProgrammerError("Cannot snapshot non-lvm block device"
1039
                                 "'%s' of type '%s'" %
1040
                                 (disk.unique_id, disk.dev_type))
1041

    
1042

    
1043
def ExportSnapshot(disk, dest_node, instance):
1044
  """Export a block device snapshot to a remote node.
1045

1046
  Args:
1047
    disk: the snapshot block device
1048
    dest_node: the node to send the image to
1049
    instance: instance being exported
1050

1051
  Returns:
1052
    True if successful, False otherwise.
1053

1054
  """
1055
  inst_os = OSFromDisk(instance.os)
1056
  export_script = inst_os.export_script
1057

    
1058
  logfile = "%s/exp-%s-%s-%s.log" % (constants.LOG_OS_DIR, inst_os.name,
1059
                                     instance.name, int(time.time()))
1060
  if not os.path.exists(constants.LOG_OS_DIR):
1061
    os.mkdir(constants.LOG_OS_DIR, 0750)
1062

    
1063
  real_os_dev = _RecursiveFindBD(disk)
1064
  if real_os_dev is None:
1065
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
1066
                                  str(disk))
1067
  real_os_dev.Open()
1068

    
1069
  destdir = os.path.join(constants.EXPORT_DIR, instance.name + ".new")
1070
  destfile = disk.physical_id[1]
1071

    
1072
  # the target command is built out of three individual commands,
1073
  # which are joined by pipes; we check each individual command for
1074
  # valid parameters
1075

    
1076
  expcmd = utils.BuildShellCmd("cd %s; %s -i %s -b %s 2>%s", inst_os.path,
1077
                               export_script, instance.name,
1078
                               real_os_dev.dev_path, logfile)
1079

    
1080
  comprcmd = "gzip"
1081

    
1082
  destcmd = utils.BuildShellCmd("mkdir -p %s && cat > %s/%s",
1083
                                destdir, destdir, destfile)
1084
  remotecmd = ssh.BuildSSHCmd(dest_node, 'root', destcmd)
1085

    
1086

    
1087

    
1088
  # all commands have been checked, so we're safe to combine them
1089
  command = '|'.join([expcmd, comprcmd, utils.ShellQuoteArgs(remotecmd)])
1090

    
1091
  result = utils.RunCmd(command)
1092

    
1093
  if result.failed:
1094
    logger.Error("os snapshot export command '%s' returned error: %s"
1095
                 " output: %s" %
1096
                 (command, result.fail_reason, result.output))
1097
    return False
1098

    
1099
  return True
1100

    
1101

    
1102
def FinalizeExport(instance, snap_disks):
1103
  """Write out the export configuration information.
1104

1105
  Args:
1106
    instance: instance configuration
1107
    snap_disks: snapshot block devices
1108

1109
  Returns:
1110
    False in case of error, True otherwise.
1111

1112
  """
1113
  destdir = os.path.join(constants.EXPORT_DIR, instance.name + ".new")
1114
  finaldestdir = os.path.join(constants.EXPORT_DIR, instance.name)
1115

    
1116
  config = objects.SerializableConfigParser()
1117

    
1118
  config.add_section(constants.INISECT_EXP)
1119
  config.set(constants.INISECT_EXP, 'version', '0')
1120
  config.set(constants.INISECT_EXP, 'timestamp', '%d' % int(time.time()))
1121
  config.set(constants.INISECT_EXP, 'source', instance.primary_node)
1122
  config.set(constants.INISECT_EXP, 'os', instance.os)
1123
  config.set(constants.INISECT_EXP, 'compression', 'gzip')
1124

    
1125
  config.add_section(constants.INISECT_INS)
1126
  config.set(constants.INISECT_INS, 'name', instance.name)
1127
  config.set(constants.INISECT_INS, 'memory', '%d' % instance.memory)
1128
  config.set(constants.INISECT_INS, 'vcpus', '%d' % instance.vcpus)
1129
  config.set(constants.INISECT_INS, 'disk_template', instance.disk_template)
1130
  for nic_count, nic in enumerate(instance.nics):
1131
    config.set(constants.INISECT_INS, 'nic%d_mac' %
1132
               nic_count, '%s' % nic.mac)
1133
    config.set(constants.INISECT_INS, 'nic%d_ip' % nic_count, '%s' % nic.ip)
1134
  # TODO: redundant: on load can read nics until it doesn't exist
1135
  config.set(constants.INISECT_INS, 'nic_count' , '%d' % nic_count)
1136

    
1137
  for disk_count, disk in enumerate(snap_disks):
1138
    config.set(constants.INISECT_INS, 'disk%d_ivname' % disk_count,
1139
               ('%s' % disk.iv_name))
1140
    config.set(constants.INISECT_INS, 'disk%d_dump' % disk_count,
1141
               ('%s' % disk.physical_id[1]))
1142
    config.set(constants.INISECT_INS, 'disk%d_size' % disk_count,
1143
               ('%d' % disk.size))
1144
  config.set(constants.INISECT_INS, 'disk_count' , '%d' % disk_count)
1145

    
1146
  cff = os.path.join(destdir, constants.EXPORT_CONF_FILE)
1147
  cfo = open(cff, 'w')
1148
  try:
1149
    config.write(cfo)
1150
  finally:
1151
    cfo.close()
1152

    
1153
  shutil.rmtree(finaldestdir, True)
1154
  shutil.move(destdir, finaldestdir)
1155

    
1156
  return True
1157

    
1158

    
1159
def ExportInfo(dest):
1160
  """Get export configuration information.
1161

1162
  Args:
1163
    dest: directory containing the export
1164

1165
  Returns:
1166
    A serializable config file containing the export info.
1167

1168
  """
1169
  cff = os.path.join(dest, constants.EXPORT_CONF_FILE)
1170

    
1171
  config = objects.SerializableConfigParser()
1172
  config.read(cff)
1173

    
1174
  if (not config.has_section(constants.INISECT_EXP) or
1175
      not config.has_section(constants.INISECT_INS)):
1176
    return None
1177

    
1178
  return config
1179

    
1180

    
1181
def ImportOSIntoInstance(instance, os_disk, swap_disk, src_node, src_image):
1182
  """Import an os image into an instance.
1183

1184
  Args:
1185
    instance: the instance object
1186
    os_disk: the instance-visible name of the os device
1187
    swap_disk: the instance-visible name of the swap device
1188
    src_node: node holding the source image
1189
    src_image: path to the source image on src_node
1190

1191
  Returns:
1192
    False in case of error, True otherwise.
1193

1194
  """
1195
  inst_os = OSFromDisk(instance.os)
1196
  import_script = inst_os.import_script
1197

    
1198
  os_device = instance.FindDisk(os_disk)
1199
  if os_device is None:
1200
    logger.Error("Can't find this device-visible name '%s'" % os_disk)
1201
    return False
1202

    
1203
  swap_device = instance.FindDisk(swap_disk)
1204
  if swap_device is None:
1205
    logger.Error("Can't find this device-visible name '%s'" % swap_disk)
1206
    return False
1207

    
1208
  real_os_dev = _RecursiveFindBD(os_device)
1209
  if real_os_dev is None:
1210
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
1211
                                  str(os_device))
1212
  real_os_dev.Open()
1213

    
1214
  real_swap_dev = _RecursiveFindBD(swap_device)
1215
  if real_swap_dev is None:
1216
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
1217
                                  str(swap_device))
1218
  real_swap_dev.Open()
1219

    
1220
  logfile = "%s/import-%s-%s-%s.log" % (constants.LOG_OS_DIR, instance.os,
1221
                                        instance.name, int(time.time()))
1222
  if not os.path.exists(constants.LOG_OS_DIR):
1223
    os.mkdir(constants.LOG_OS_DIR, 0750)
1224

    
1225
  destcmd = utils.BuildShellCmd('cat %s', src_image)
1226
  remotecmd = ssh.BuildSSHCmd(src_node, 'root', destcmd)
1227

    
1228
  comprcmd = "gunzip"
1229
  impcmd = utils.BuildShellCmd("(cd %s; %s -i %s -b %s -s %s &>%s)",
1230
                               inst_os.path, import_script, instance.name,
1231
                               real_os_dev.dev_path, real_swap_dev.dev_path,
1232
                               logfile)
1233

    
1234
  command = '|'.join([utils.ShellQuoteArgs(remotecmd), comprcmd, impcmd])
1235

    
1236
  result = utils.RunCmd(command)
1237

    
1238
  if result.failed:
1239
    logger.Error("os import command '%s' returned error: %s"
1240
                 " output: %s" %
1241
                 (command, result.fail_reason, result.output))
1242
    return False
1243

    
1244
  return True
1245

    
1246

    
1247
def ListExports():
1248
  """Return a list of exports currently available on this machine.
1249

1250
  """
1251
  if os.path.isdir(constants.EXPORT_DIR):
1252
    return os.listdir(constants.EXPORT_DIR)
1253
  else:
1254
    return []
1255

    
1256

    
1257
def RemoveExport(export):
1258
  """Remove an existing export from the node.
1259

1260
  Args:
1261
    export: the name of the export to remove
1262

1263
  Returns:
1264
    False in case of error, True otherwise.
1265

1266
  """
1267
  target = os.path.join(constants.EXPORT_DIR, export)
1268

    
1269
  shutil.rmtree(target)
1270
  # TODO: catch some of the relevant exceptions and provide a pretty
1271
  # error message if rmtree fails.
1272

    
1273
  return True
1274

    
1275

    
1276
class HooksRunner(object):
1277
  """Hook runner.
1278

1279
  This class is instantiated on the node side (ganeti-noded) and not on
1280
  the master side.
1281

1282
  """
1283
  RE_MASK = re.compile("^[a-zA-Z0-9_-]+$")
1284

    
1285
  def __init__(self, hooks_base_dir=None):
1286
    """Constructor for hooks runner.
1287

1288
    Args:
1289
      - hooks_base_dir: if not None, this overrides the
1290
        constants.HOOKS_BASE_DIR (useful for unittests)
1291
      - logs_base_dir: if not None, this overrides the
1292
        constants.LOG_HOOKS_DIR (useful for unittests)
1293
      - logging: enable or disable logging of script output
1294

1295
    """
1296
    if hooks_base_dir is None:
1297
      hooks_base_dir = constants.HOOKS_BASE_DIR
1298
    self._BASE_DIR = hooks_base_dir
1299

    
1300
  @staticmethod
1301
  def ExecHook(script, env):
1302
    """Exec one hook script.
1303

1304
    Args:
1305
     - phase: the phase
1306
     - script: the full path to the script
1307
     - env: the environment with which to exec the script
1308

1309
    """
1310
    # exec the process using subprocess and log the output
1311
    fdstdin = None
1312
    try:
1313
      fdstdin = open("/dev/null", "r")
1314
      child = subprocess.Popen([script], stdin=fdstdin, stdout=subprocess.PIPE,
1315
                               stderr=subprocess.STDOUT, close_fds=True,
1316
                               shell=False, cwd="/",env=env)
1317
      output = ""
1318
      try:
1319
        output = child.stdout.read(4096)
1320
        child.stdout.close()
1321
      except EnvironmentError, err:
1322
        output += "Hook script error: %s" % str(err)
1323

    
1324
      while True:
1325
        try:
1326
          result = child.wait()
1327
          break
1328
        except EnvironmentError, err:
1329
          if err.errno == errno.EINTR:
1330
            continue
1331
          raise
1332
    finally:
1333
      # try not to leak fds
1334
      for fd in (fdstdin, ):
1335
        if fd is not None:
1336
          try:
1337
            fd.close()
1338
          except EnvironmentError, err:
1339
            # just log the error
1340
            #logger.Error("While closing fd %s: %s" % (fd, err))
1341
            pass
1342

    
1343
    return result == 0, output
1344

    
1345
  def RunHooks(self, hpath, phase, env):
1346
    """Run the scripts in the hooks directory.
1347

1348
    This method will not be usually overriden by child opcodes.
1349

1350
    """
1351
    if phase == constants.HOOKS_PHASE_PRE:
1352
      suffix = "pre"
1353
    elif phase == constants.HOOKS_PHASE_POST:
1354
      suffix = "post"
1355
    else:
1356
      raise errors.ProgrammerError("Unknown hooks phase: '%s'" % phase)
1357
    rr = []
1358

    
1359
    subdir = "%s-%s.d" % (hpath, suffix)
1360
    dir_name = "%s/%s" % (self._BASE_DIR, subdir)
1361
    try:
1362
      dir_contents = os.listdir(dir_name)
1363
    except OSError, err:
1364
      # must log
1365
      return rr
1366

    
1367
    # we use the standard python sort order,
1368
    # so 00name is the recommended naming scheme
1369
    dir_contents.sort()
1370
    for relname in dir_contents:
1371
      fname = os.path.join(dir_name, relname)
1372
      if not (os.path.isfile(fname) and os.access(fname, os.X_OK) and
1373
          self.RE_MASK.match(relname) is not None):
1374
        rrval = constants.HKR_SKIP
1375
        output = ""
1376
      else:
1377
        result, output = self.ExecHook(fname, env)
1378
        if not result:
1379
          rrval = constants.HKR_FAIL
1380
        else:
1381
          rrval = constants.HKR_SUCCESS
1382
      rr.append(("%s/%s" % (subdir, relname), rrval, output))
1383

    
1384
    return rr