| 1477 |
1477 |
return config
|
| 1478 |
1478 |
|
| 1479 |
1479 |
|
| 1480 |
|
def ImportOSIntoInstance(instance, os_disk, swap_disk, src_node, src_image,
|
| 1481 |
|
cluster_name):
|
|
1480 |
def ImportOSIntoInstance(instance, src_node, src_images, cluster_name):
|
| 1482 |
1481 |
"""Import an os image into an instance.
|
| 1483 |
1482 |
|
| 1484 |
|
Args:
|
| 1485 |
|
instance: the instance object
|
| 1486 |
|
os_disk: the instance-visible name of the os device
|
| 1487 |
|
swap_disk: the instance-visible name of the swap device
|
| 1488 |
|
src_node: node holding the source image
|
| 1489 |
|
src_image: path to the source image on src_node
|
| 1490 |
|
|
| 1491 |
|
Returns:
|
| 1492 |
|
False in case of error, True otherwise.
|
|
1483 |
@type instance: L{objects.instance}
|
|
1484 |
@param instance: instance to import the disks into
|
|
1485 |
@type src_node: string
|
|
1486 |
@param src_node: source node for the disk images
|
|
1487 |
@type src_images: list of string
|
|
1488 |
@param src_images: absolute paths of the disk images
|
|
1489 |
@rtype: list of boolean
|
|
1490 |
@return: each boolean represent the success of importing the n-th disk
|
| 1493 |
1491 |
|
| 1494 |
1492 |
"""
|
| 1495 |
|
# TODO(ultrotter): Import/Export still to be converted to OS API 10
|
| 1496 |
|
logging.error("Import/Export still to be converted to OS API 10")
|
| 1497 |
|
return False
|
| 1498 |
|
|
|
1493 |
import_env = OSEnvironment(instance)
|
| 1499 |
1494 |
inst_os = OSFromDisk(instance.os)
|
| 1500 |
1495 |
import_script = inst_os.import_script
|
| 1501 |
1496 |
|
| 1502 |
|
os_device = instance.FindDisk(os_disk)
|
| 1503 |
|
if os_device is None:
|
| 1504 |
|
logging.error("Can't find this device-visible name '%s'", os_disk)
|
| 1505 |
|
return False
|
| 1506 |
|
|
| 1507 |
|
swap_device = instance.FindDisk(swap_disk)
|
| 1508 |
|
if swap_device is None:
|
| 1509 |
|
logging.error("Can't find this device-visible name '%s'", swap_disk)
|
| 1510 |
|
return False
|
| 1511 |
|
|
| 1512 |
|
real_os_dev = _RecursiveFindBD(os_device)
|
| 1513 |
|
if real_os_dev is None:
|
| 1514 |
|
raise errors.BlockDeviceError("Block device '%s' is not set up" %
|
| 1515 |
|
str(os_device))
|
| 1516 |
|
real_os_dev.Open()
|
| 1517 |
|
|
| 1518 |
|
real_swap_dev = _RecursiveFindBD(swap_device)
|
| 1519 |
|
if real_swap_dev is None:
|
| 1520 |
|
raise errors.BlockDeviceError("Block device '%s' is not set up" %
|
| 1521 |
|
str(swap_device))
|
| 1522 |
|
real_swap_dev.Open()
|
| 1523 |
|
|
| 1524 |
1497 |
logfile = "%s/import-%s-%s-%s.log" % (constants.LOG_OS_DIR, instance.os,
|
| 1525 |
1498 |
instance.name, int(time.time()))
|
| 1526 |
1499 |
if not os.path.exists(constants.LOG_OS_DIR):
|
| 1527 |
1500 |
os.mkdir(constants.LOG_OS_DIR, 0750)
|
| 1528 |
1501 |
|
| 1529 |
|
destcmd = utils.BuildShellCmd('cat %s', src_image)
|
| 1530 |
|
remotecmd = _GetSshRunner(cluster_name).BuildCmd(src_node,
|
| 1531 |
|
constants.GANETI_RUNAS,
|
| 1532 |
|
destcmd)
|
| 1533 |
|
|
| 1534 |
1502 |
comprcmd = "gunzip"
|
| 1535 |
|
impcmd = utils.BuildShellCmd("(cd %s; %s -i %s -b %s -s %s &>%s)",
|
| 1536 |
|
inst_os.path, import_script, instance.name,
|
| 1537 |
|
real_os_dev.dev_path, real_swap_dev.dev_path,
|
|
1503 |
impcmd = utils.BuildShellCmd("(cd %s; %s &>%s)", inst_os.path, import_script,
|
| 1538 |
1504 |
logfile)
|
| 1539 |
1505 |
|
| 1540 |
|
command = '|'.join([utils.ShellQuoteArgs(remotecmd), comprcmd, impcmd])
|
| 1541 |
|
env = {'HYPERVISOR': instance.hypervisor}
|
| 1542 |
|
|
| 1543 |
|
result = utils.RunCmd(command, env=env)
|
| 1544 |
|
|
| 1545 |
|
if result.failed:
|
| 1546 |
|
logging.error("os import command '%s' returned error: %s"
|
| 1547 |
|
" output: %s", command, result.fail_reason, result.output)
|
| 1548 |
|
return False
|
|
1506 |
final_result = []
|
|
1507 |
for idx, image in enumerate(src_images):
|
|
1508 |
if image:
|
|
1509 |
destcmd = utils.BuildShellCmd('cat %s', image)
|
|
1510 |
remotecmd = _GetSshRunner(cluster_name).BuildCmd(src_node,
|
|
1511 |
constants.GANETI_RUNAS,
|
|
1512 |
destcmd)
|
|
1513 |
command = '|'.join([utils.ShellQuoteArgs(remotecmd), comprcmd, impcmd])
|
|
1514 |
import_env['IMPORT_DEVICE'] = import_env['DISK_%d_PATH' % idx]
|
|
1515 |
result = utils.RunCmd(command, env=import_env)
|
|
1516 |
if result.failed:
|
|
1517 |
logging.error("disk import command '%s' returned error: %s"
|
|
1518 |
" output: %s", command, result.fail_reason, result.output)
|
|
1519 |
final_result.append(False)
|
|
1520 |
else:
|
|
1521 |
final_result.append(True)
|
|
1522 |
else:
|
|
1523 |
final_result.append(True)
|
| 1549 |
1524 |
|
| 1550 |
|
return True
|
|
1525 |
return final_result
|
| 1551 |
1526 |
|
| 1552 |
1527 |
|
| 1553 |
1528 |
def ListExports():
|