Statistics
| Branch: | Tag: | Revision:

root / lib / backend.py @ 56bcd3f4

History | View | Annotate | Download (38.9 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
def _OSSearch(name, search_path=None):
885
  """Search for OSes with the given name in the search_path.
886

887
  Args:
888
    name: The name of the OS to look for
889
    search_path: List of dirs to search (defaults to constants.OS_SEARCH_PATH)
890
    
891
  Returns:
892
    The base_dir the OS resides in
893

894
  """
895

    
896
  if search_path is None:
897
    search_path = constants.OS_SEARCH_PATH
898

    
899
  for dir in search_path:
900
    t_os_dir = os.path.sep.join([dir, name])
901
    if os.path.isdir(t_os_dir):
902
        return dir
903

    
904
  return None
905

    
906
def _OSOndiskVersion(name, os_dir):
907
  """Compute and return the api version of a given OS.
908

909
  This function will try to read the api version of the os given by
910
  the 'name' parameter and residing in the 'os_dir' directory.
911

912
  Return value will be either an integer denoting the version or None in the
913
  case when this is not a valid OS name.
914

915
  """
916

    
917
  api_file = os.path.sep.join([os_dir, "ganeti_api_version"])
918

    
919
  try:
920
    st = os.stat(api_file)
921
  except EnvironmentError, err:
922
    raise errors.InvalidOS(name, "'ganeti_api_version' file not"
923
                           " found (%s)" % _ErrnoOrStr(err))
924

    
925
  if not stat.S_ISREG(stat.S_IFMT(st.st_mode)):
926
    raise errors.InvalidOS(name, "'ganeti_api_version' file is not"
927
                           " a regular file")
928

    
929
  try:
930
    f = open(api_file)
931
    try:
932
      api_version = f.read(256)
933
    finally:
934
      f.close()
935
  except EnvironmentError, err:
936
    raise errors.InvalidOS(name, "error while reading the"
937
                           " API version (%s)" % _ErrnoOrStr(err))
938

    
939
  api_version = api_version.strip()
940
  try:
941
    api_version = int(api_version)
942
  except (TypeError, ValueError), err:
943
    raise errors.InvalidOS(name, "API version is not integer (%s)" % str(err))
944

    
945
  return api_version
946

    
947

    
948
def DiagnoseOS(top_dirs=None):
949
  """Compute the validity for all OSes.
950

951
  For each name in all the given top directories (if not given defaults i
952
  to constants.OS_SEARCH_PATH it will return an object. If this is a valid
953
  os, the object will be an instance of the object.OS class. If not,
954
  it will be an instance of errors.InvalidOS and this signifies that
955
  this name does not correspond to a valid OS.
956

957
  Returns:
958
    list of objects
959

960
  """
961
  if top_dirs is None:
962
    top_dirs = constants.OS_SEARCH_PATH
963

    
964
  result = []
965
  for dir in top_dirs:
966
    if os.path.isdir(dir):
967
      try:
968
        f_names = os.listdir(dir)
969
      except EnvironmentError, err:
970
        logger.Error("Can't list the OS directory %s: %s" % (dir,str(err)))
971
        break
972
      for name in f_names:
973
        try:
974
          os_inst = OSFromDisk(name, base_dir=dir)
975
          result.append(os_inst)
976
        except errors.InvalidOS, err:
977
          result.append(err)
978

    
979
  return result
980

    
981

    
982
def OSFromDisk(name, base_dir=None):
983
  """Create an OS instance from disk.
984

985
  This function will return an OS instance if the given name is a
986
  valid OS name. Otherwise, it will raise an appropriate
987
  `errors.InvalidOS` exception, detailing why this is not a valid
988
  OS.
989

990
  Args:
991
    os_dir: Directory containing the OS scripts. Defaults to a search
992
            in all the OS_SEARCH_PATH directories.
993

994
  """
995

    
996
  if base_dir is None:
997
    base_dir = _OSSearch(name)
998
  else:
999
    if not os.path.isdir(os.path.sep.join([base_dir, name])):
1000
      raise errors.InvalidOS(name, "OS not found in base dir %s" % base_dir)
1001

    
1002
  if base_dir is None:
1003
    raise errors.InvalidOS(name, "OS dir not found in search path")
1004

    
1005
  os_dir = os.path.sep.join([base_dir, name])
1006
  api_version = _OSOndiskVersion(name, os_dir)
1007

    
1008
  if api_version != constants.OS_API_VERSION:
1009
    raise errors.InvalidOS(name, "API version mismatch (found %s want %s)"
1010
                           % (api_version, constants.OS_API_VERSION))
1011

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

    
1015
  for script in os_scripts:
1016
    os_scripts[script] = os.path.sep.join([os_dir, script])
1017

    
1018
    try:
1019
      st = os.stat(os_scripts[script])
1020
    except EnvironmentError, err:
1021
      raise errors.InvalidOS(name, "'%s' script missing (%s)" %
1022
                             (script, _ErrnoOrStr(err)))
1023

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

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

    
1030

    
1031
  return objects.OS(name=name, path=os_dir,
1032
                    create_script=os_scripts['create'],
1033
                    export_script=os_scripts['export'],
1034
                    import_script=os_scripts['import'],
1035
                    rename_script=os_scripts['rename'],
1036
                    api_version=api_version)
1037

    
1038

    
1039
def SnapshotBlockDevice(disk):
1040
  """Create a snapshot copy of a block device.
1041

1042
  This function is called recursively, and the snapshot is actually created
1043
  just for the leaf lvm backend device.
1044

1045
  Args:
1046
    disk: the disk to be snapshotted
1047

1048
  Returns:
1049
    a config entry for the actual lvm device snapshotted.
1050

1051
  """
1052
  if disk.children:
1053
    if len(disk.children) == 1:
1054
      # only one child, let's recurse on it
1055
      return SnapshotBlockDevice(disk.children[0])
1056
    else:
1057
      # more than one child, choose one that matches
1058
      for child in disk.children:
1059
        if child.size == disk.size:
1060
          # return implies breaking the loop
1061
          return SnapshotBlockDevice(child)
1062
  elif disk.dev_type == "lvm":
1063
    r_dev = _RecursiveFindBD(disk)
1064
    if r_dev is not None:
1065
      # let's stay on the safe side and ask for the full size, for now
1066
      return r_dev.Snapshot(disk.size)
1067
    else:
1068
      return None
1069
  else:
1070
    raise errors.ProgrammerError("Cannot snapshot non-lvm block device"
1071
                                 "'%s' of type '%s'" %
1072
                                 (disk.unique_id, disk.dev_type))
1073

    
1074

    
1075
def ExportSnapshot(disk, dest_node, instance):
1076
  """Export a block device snapshot to a remote node.
1077

1078
  Args:
1079
    disk: the snapshot block device
1080
    dest_node: the node to send the image to
1081
    instance: instance being exported
1082

1083
  Returns:
1084
    True if successful, False otherwise.
1085

1086
  """
1087
  inst_os = OSFromDisk(instance.os)
1088
  export_script = inst_os.export_script
1089

    
1090
  logfile = "%s/exp-%s-%s-%s.log" % (constants.LOG_OS_DIR, inst_os.name,
1091
                                     instance.name, int(time.time()))
1092
  if not os.path.exists(constants.LOG_OS_DIR):
1093
    os.mkdir(constants.LOG_OS_DIR, 0750)
1094

    
1095
  real_os_dev = _RecursiveFindBD(disk)
1096
  if real_os_dev is None:
1097
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
1098
                                  str(disk))
1099
  real_os_dev.Open()
1100

    
1101
  destdir = os.path.join(constants.EXPORT_DIR, instance.name + ".new")
1102
  destfile = disk.physical_id[1]
1103

    
1104
  # the target command is built out of three individual commands,
1105
  # which are joined by pipes; we check each individual command for
1106
  # valid parameters
1107

    
1108
  expcmd = utils.BuildShellCmd("cd %s; %s -i %s -b %s 2>%s", inst_os.path,
1109
                               export_script, instance.name,
1110
                               real_os_dev.dev_path, logfile)
1111

    
1112
  comprcmd = "gzip"
1113

    
1114
  destcmd = utils.BuildShellCmd("mkdir -p %s && cat > %s/%s",
1115
                                destdir, destdir, destfile)
1116
  remotecmd = ssh.BuildSSHCmd(dest_node, 'root', destcmd)
1117

    
1118

    
1119

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

    
1123
  result = utils.RunCmd(command)
1124

    
1125
  if result.failed:
1126
    logger.Error("os snapshot export command '%s' returned error: %s"
1127
                 " output: %s" %
1128
                 (command, result.fail_reason, result.output))
1129
    return False
1130

    
1131
  return True
1132

    
1133

    
1134
def FinalizeExport(instance, snap_disks):
1135
  """Write out the export configuration information.
1136

1137
  Args:
1138
    instance: instance configuration
1139
    snap_disks: snapshot block devices
1140

1141
  Returns:
1142
    False in case of error, True otherwise.
1143

1144
  """
1145
  destdir = os.path.join(constants.EXPORT_DIR, instance.name + ".new")
1146
  finaldestdir = os.path.join(constants.EXPORT_DIR, instance.name)
1147

    
1148
  config = objects.SerializableConfigParser()
1149

    
1150
  config.add_section(constants.INISECT_EXP)
1151
  config.set(constants.INISECT_EXP, 'version', '0')
1152
  config.set(constants.INISECT_EXP, 'timestamp', '%d' % int(time.time()))
1153
  config.set(constants.INISECT_EXP, 'source', instance.primary_node)
1154
  config.set(constants.INISECT_EXP, 'os', instance.os)
1155
  config.set(constants.INISECT_EXP, 'compression', 'gzip')
1156

    
1157
  config.add_section(constants.INISECT_INS)
1158
  config.set(constants.INISECT_INS, 'name', instance.name)
1159
  config.set(constants.INISECT_INS, 'memory', '%d' % instance.memory)
1160
  config.set(constants.INISECT_INS, 'vcpus', '%d' % instance.vcpus)
1161
  config.set(constants.INISECT_INS, 'disk_template', instance.disk_template)
1162
  for nic_count, nic in enumerate(instance.nics):
1163
    config.set(constants.INISECT_INS, 'nic%d_mac' %
1164
               nic_count, '%s' % nic.mac)
1165
    config.set(constants.INISECT_INS, 'nic%d_ip' % nic_count, '%s' % nic.ip)
1166
  # TODO: redundant: on load can read nics until it doesn't exist
1167
  config.set(constants.INISECT_INS, 'nic_count' , '%d' % nic_count)
1168

    
1169
  for disk_count, disk in enumerate(snap_disks):
1170
    config.set(constants.INISECT_INS, 'disk%d_ivname' % disk_count,
1171
               ('%s' % disk.iv_name))
1172
    config.set(constants.INISECT_INS, 'disk%d_dump' % disk_count,
1173
               ('%s' % disk.physical_id[1]))
1174
    config.set(constants.INISECT_INS, 'disk%d_size' % disk_count,
1175
               ('%d' % disk.size))
1176
  config.set(constants.INISECT_INS, 'disk_count' , '%d' % disk_count)
1177

    
1178
  cff = os.path.join(destdir, constants.EXPORT_CONF_FILE)
1179
  cfo = open(cff, 'w')
1180
  try:
1181
    config.write(cfo)
1182
  finally:
1183
    cfo.close()
1184

    
1185
  shutil.rmtree(finaldestdir, True)
1186
  shutil.move(destdir, finaldestdir)
1187

    
1188
  return True
1189

    
1190

    
1191
def ExportInfo(dest):
1192
  """Get export configuration information.
1193

1194
  Args:
1195
    dest: directory containing the export
1196

1197
  Returns:
1198
    A serializable config file containing the export info.
1199

1200
  """
1201
  cff = os.path.join(dest, constants.EXPORT_CONF_FILE)
1202

    
1203
  config = objects.SerializableConfigParser()
1204
  config.read(cff)
1205

    
1206
  if (not config.has_section(constants.INISECT_EXP) or
1207
      not config.has_section(constants.INISECT_INS)):
1208
    return None
1209

    
1210
  return config
1211

    
1212

    
1213
def ImportOSIntoInstance(instance, os_disk, swap_disk, src_node, src_image):
1214
  """Import an os image into an instance.
1215

1216
  Args:
1217
    instance: the instance object
1218
    os_disk: the instance-visible name of the os device
1219
    swap_disk: the instance-visible name of the swap device
1220
    src_node: node holding the source image
1221
    src_image: path to the source image on src_node
1222

1223
  Returns:
1224
    False in case of error, True otherwise.
1225

1226
  """
1227
  inst_os = OSFromDisk(instance.os)
1228
  import_script = inst_os.import_script
1229

    
1230
  os_device = instance.FindDisk(os_disk)
1231
  if os_device is None:
1232
    logger.Error("Can't find this device-visible name '%s'" % os_disk)
1233
    return False
1234

    
1235
  swap_device = instance.FindDisk(swap_disk)
1236
  if swap_device is None:
1237
    logger.Error("Can't find this device-visible name '%s'" % swap_disk)
1238
    return False
1239

    
1240
  real_os_dev = _RecursiveFindBD(os_device)
1241
  if real_os_dev is None:
1242
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
1243
                                  str(os_device))
1244
  real_os_dev.Open()
1245

    
1246
  real_swap_dev = _RecursiveFindBD(swap_device)
1247
  if real_swap_dev is None:
1248
    raise errors.BlockDeviceError("Block device '%s' is not set up" %
1249
                                  str(swap_device))
1250
  real_swap_dev.Open()
1251

    
1252
  logfile = "%s/import-%s-%s-%s.log" % (constants.LOG_OS_DIR, instance.os,
1253
                                        instance.name, int(time.time()))
1254
  if not os.path.exists(constants.LOG_OS_DIR):
1255
    os.mkdir(constants.LOG_OS_DIR, 0750)
1256

    
1257
  destcmd = utils.BuildShellCmd('cat %s', src_image)
1258
  remotecmd = ssh.BuildSSHCmd(src_node, 'root', destcmd)
1259

    
1260
  comprcmd = "gunzip"
1261
  impcmd = utils.BuildShellCmd("(cd %s; %s -i %s -b %s -s %s &>%s)",
1262
                               inst_os.path, import_script, instance.name,
1263
                               real_os_dev.dev_path, real_swap_dev.dev_path,
1264
                               logfile)
1265

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

    
1268
  result = utils.RunCmd(command)
1269

    
1270
  if result.failed:
1271
    logger.Error("os import command '%s' returned error: %s"
1272
                 " output: %s" %
1273
                 (command, result.fail_reason, result.output))
1274
    return False
1275

    
1276
  return True
1277

    
1278

    
1279
def ListExports():
1280
  """Return a list of exports currently available on this machine.
1281

1282
  """
1283
  if os.path.isdir(constants.EXPORT_DIR):
1284
    return os.listdir(constants.EXPORT_DIR)
1285
  else:
1286
    return []
1287

    
1288

    
1289
def RemoveExport(export):
1290
  """Remove an existing export from the node.
1291

1292
  Args:
1293
    export: the name of the export to remove
1294

1295
  Returns:
1296
    False in case of error, True otherwise.
1297

1298
  """
1299
  target = os.path.join(constants.EXPORT_DIR, export)
1300

    
1301
  shutil.rmtree(target)
1302
  # TODO: catch some of the relevant exceptions and provide a pretty
1303
  # error message if rmtree fails.
1304

    
1305
  return True
1306

    
1307

    
1308
class HooksRunner(object):
1309
  """Hook runner.
1310

1311
  This class is instantiated on the node side (ganeti-noded) and not on
1312
  the master side.
1313

1314
  """
1315
  RE_MASK = re.compile("^[a-zA-Z0-9_-]+$")
1316

    
1317
  def __init__(self, hooks_base_dir=None):
1318
    """Constructor for hooks runner.
1319

1320
    Args:
1321
      - hooks_base_dir: if not None, this overrides the
1322
        constants.HOOKS_BASE_DIR (useful for unittests)
1323
      - logs_base_dir: if not None, this overrides the
1324
        constants.LOG_HOOKS_DIR (useful for unittests)
1325
      - logging: enable or disable logging of script output
1326

1327
    """
1328
    if hooks_base_dir is None:
1329
      hooks_base_dir = constants.HOOKS_BASE_DIR
1330
    self._BASE_DIR = hooks_base_dir
1331

    
1332
  @staticmethod
1333
  def ExecHook(script, env):
1334
    """Exec one hook script.
1335

1336
    Args:
1337
     - phase: the phase
1338
     - script: the full path to the script
1339
     - env: the environment with which to exec the script
1340

1341
    """
1342
    # exec the process using subprocess and log the output
1343
    fdstdin = None
1344
    try:
1345
      fdstdin = open("/dev/null", "r")
1346
      child = subprocess.Popen([script], stdin=fdstdin, stdout=subprocess.PIPE,
1347
                               stderr=subprocess.STDOUT, close_fds=True,
1348
                               shell=False, cwd="/",env=env)
1349
      output = ""
1350
      try:
1351
        output = child.stdout.read(4096)
1352
        child.stdout.close()
1353
      except EnvironmentError, err:
1354
        output += "Hook script error: %s" % str(err)
1355

    
1356
      while True:
1357
        try:
1358
          result = child.wait()
1359
          break
1360
        except EnvironmentError, err:
1361
          if err.errno == errno.EINTR:
1362
            continue
1363
          raise
1364
    finally:
1365
      # try not to leak fds
1366
      for fd in (fdstdin, ):
1367
        if fd is not None:
1368
          try:
1369
            fd.close()
1370
          except EnvironmentError, err:
1371
            # just log the error
1372
            #logger.Error("While closing fd %s: %s" % (fd, err))
1373
            pass
1374

    
1375
    return result == 0, output
1376

    
1377
  def RunHooks(self, hpath, phase, env):
1378
    """Run the scripts in the hooks directory.
1379

1380
    This method will not be usually overriden by child opcodes.
1381

1382
    """
1383
    if phase == constants.HOOKS_PHASE_PRE:
1384
      suffix = "pre"
1385
    elif phase == constants.HOOKS_PHASE_POST:
1386
      suffix = "post"
1387
    else:
1388
      raise errors.ProgrammerError("Unknown hooks phase: '%s'" % phase)
1389
    rr = []
1390

    
1391
    subdir = "%s-%s.d" % (hpath, suffix)
1392
    dir_name = "%s/%s" % (self._BASE_DIR, subdir)
1393
    try:
1394
      dir_contents = os.listdir(dir_name)
1395
    except OSError, err:
1396
      # must log
1397
      return rr
1398

    
1399
    # we use the standard python sort order,
1400
    # so 00name is the recommended naming scheme
1401
    dir_contents.sort()
1402
    for relname in dir_contents:
1403
      fname = os.path.join(dir_name, relname)
1404
      if not (os.path.isfile(fname) and os.access(fname, os.X_OK) and
1405
          self.RE_MASK.match(relname) is not None):
1406
        rrval = constants.HKR_SKIP
1407
        output = ""
1408
      else:
1409
        result, output = self.ExecHook(fname, env)
1410
        if not result:
1411
          rrval = constants.HKR_FAIL
1412
        else:
1413
          rrval = constants.HKR_SUCCESS
1414
      rr.append(("%s/%s" % (subdir, relname), rrval, output))
1415

    
1416
    return rr