From 0dee3e5a9dbdf1dcc7922453188d4a246e14098e Mon Sep 17 00:00:00 2001 From: Balamuruhan S Date: Fri, 7 Jun 2019 15:02:43 +0530 Subject: [PATCH] utils_test/libvirt: Reorg disk related APIs into utils_disk Reorganise disk related method to utils_disk and break circular imports caused with respect to disk related APIs in utils_misc. Signed-off-by: Balamuruhan S --- selftests/unit/test_nfs.py | 20 ++-- virttest/env_process.py | 7 +- virttest/gluster.py | 94 ------------------- virttest/nfs.py | 9 +- virttest/qemu_storage.py | 5 +- virttest/storage.py | 62 +------------ virttest/tests/unattended_install.py | 7 +- virttest/utils_disk.py | 133 ++++++++++++++++++++++++++- virttest/utils_misc.py | 51 ---------- virttest/utils_storage.py | 52 +++++++++++ virttest/utils_test/libvirt.py | 19 ---- virttest/utils_v2v.py | 9 +- 12 files changed, 217 insertions(+), 251 deletions(-) create mode 100644 virttest/utils_storage.py diff --git a/selftests/unit/test_nfs.py b/selftests/unit/test_nfs.py index 77d0720d6ad..ea98e50d169 100644 --- a/selftests/unit/test_nfs.py +++ b/selftests/unit/test_nfs.py @@ -14,7 +14,7 @@ from virttest.unittest_utils import mock from virttest import nfs -from virttest import utils_misc +from virttest import utils_disk from virttest.staging import service @@ -58,16 +58,16 @@ def setup_stubs_setup(self, nfs_obj): os.makedirs.expect_call(nfs_obj.export_dir) nfs_obj.exportfs.export.expect_call() os.makedirs.expect_call(nfs_obj.mount_dir) - utils_misc.mount.expect_call(nfs_obj.mount_src, nfs_obj.mount_dir, - "nfs", perm=nfs_obj.mount_options) + utils_disk.mount.expect_call(nfs_obj.mount_src, nfs_obj.mount_dir, + "nfs", nfs_obj.mount_options) def setup_stubs_is_mounted(self, nfs_obj): - utils_misc.is_mounted.expect_call(nfs_obj.mount_src, - nfs_obj.mount_dir, - "nfs").and_return(True) + utils_disk.is_mount.expect_call(nfs_obj.mount_src, + nfs_obj.mount_dir, + "nfs").and_return(True) def setup_stubs_cleanup(self, nfs_obj): - utils_misc.umount.expect_call(nfs_obj.mount_src, + utils_disk.umount.expect_call(nfs_obj.mount_src, nfs_obj.mount_dir, "nfs") nfs_obj.exportfs.reset_export.expect_call() @@ -84,9 +84,9 @@ def setUp(self): self.god.stub_function(process, "system_output") self.god.stub_function(os.path, "isfile") self.god.stub_function(os, "makedirs") - self.god.stub_function(utils_misc, "is_mounted") - self.god.stub_function(utils_misc, "mount") - self.god.stub_function(utils_misc, "umount") + self.god.stub_function(utils_disk, "is_mount") + self.god.stub_function(utils_disk, "mount") + self.god.stub_function(utils_disk, "umount") self.god.stub_function(service.Factory, "create_service") attr = getattr(nfs, "Exportfs") setattr(attr, "already_exported", False) diff --git a/virttest/env_process.py b/virttest/env_process.py index 34cedc171c5..175d1303809 100644 --- a/virttest/env_process.py +++ b/virttest/env_process.py @@ -31,6 +31,7 @@ from virttest import test_setup from virttest import virt_vm from virttest import utils_misc +from virttest import utils_disk from virttest import storage from virttest import qemu_storage from virttest import utils_libvirtd @@ -89,17 +90,17 @@ def preprocess_image(test, params, image_name, vm_process_status=None): if params.get("force_create_image") == "yes": create_image = True elif (params.get("create_image") == "yes" and not - storage.file_exists(params, image_filename)): + utils_disk.file_exists(params, image_filename)): create_image = True if params.get("backup_image_before_testing", "no") == "yes": image = qemu_storage.QemuImg(params, base_dir, image_name) image.backup_image(params, base_dir, "backup", True, True) if create_image: - if storage.file_exists(params, image_filename): + if utils_disk.file_exists(params, image_filename): # As rbd image can not be covered, so need remove it if we need # force create a new image. - storage.file_remove(params, image_filename) + utils_disk.file_remove(params, image_filename) image = qemu_storage.QemuImg(params, base_dir, image_name) logging.info("Create image on %s." % image.storage_type) image.create(params) diff --git a/virttest/gluster.py b/virttest/gluster.py index 04c128dc4c7..92bc339a2da 100644 --- a/virttest/gluster.py +++ b/virttest/gluster.py @@ -14,8 +14,6 @@ from avocado.utils import process -from virttest import data_dir -from virttest import utils_misc from virttest import utils_net from virttest import error_context from virttest.compat_52lts import decode_to_text @@ -177,48 +175,6 @@ def gluster_vol_create(vol_name, hostname, brick_path, force=False): return is_gluster_vol_avail(vol_name) -def glusterfs_mount(g_uri, mount_point): - """ - Mount gluster volume to mountpoint. - - :param g_uri: stripped gluster uri from create_gluster_uri(.., True) - :type g_uri: str - """ - utils_misc.mount(g_uri, mount_point, "glusterfs", None, - False, "fuse.glusterfs") - - -@error_context.context_aware -def create_gluster_vol(params): - vol_name = params.get("gluster_volume_name") - force = params.get('force_recreate_gluster') == "yes" - - brick_path = params.get("gluster_brick") - if not os.path.isabs(brick_path): # do nothing when path is absolute - base_dir = params.get("images_base_dir", data_dir.get_data_dir()) - brick_path = os.path.join(base_dir, brick_path) - - error_context.context("Host name lookup failed") - hostname = socket.gethostname() - if not hostname or hostname == "(none)": - if_up = utils_net.get_net_if(state="UP") - for i in if_up: - ipv4_value = utils_net.get_net_if_addrs(i)["ipv4"] - logging.debug("ipv4_value is %s", ipv4_value) - if ipv4_value != []: - ip_addr = ipv4_value[0] - break - hostname = ip_addr - - # Start the gluster dameon, if not started - glusterd_start() - # Check for the volume is already present, if not create one. - if not is_gluster_vol_avail(vol_name) or force: - return gluster_vol_create(vol_name, hostname, brick_path, force) - else: - return True - - @error_context.context_aware def create_gluster_uri(params, stripped=False): """ @@ -248,56 +204,6 @@ def create_gluster_uri(params, stripped=False): return gluster_uri -def file_exists(params, filename_path): - sg_uri = create_gluster_uri(params, stripped=True) - g_uri = create_gluster_uri(params, stripped=False) - # Using directly /tmp dir because directory should be really temporary and - # should be deleted immediately when no longer needed and - # created directory don't file tmp dir by any data. - tmpdir = "gmount-%s" % (utils_misc.generate_random_string(6)) - tmpdir_path = os.path.join(data_dir.get_tmp_dir(), tmpdir) - while os.path.exists(tmpdir_path): - tmpdir = "gmount-%s" % (utils_misc.generate_random_string(6)) - tmpdir_path = os.path.join(data_dir.get_tmp_dir(), tmpdir) - ret = False - try: - try: - os.mkdir(tmpdir_path) - glusterfs_mount(sg_uri, tmpdir_path) - mount_filename_path = os.path.join(tmpdir_path, - filename_path[len(g_uri):]) - if os.path.exists(mount_filename_path): - ret = True - except Exception as e: - logging.error("Failed to mount gluster volume %s to" - " mount dir %s: %s" % (sg_uri, tmpdir_path, e)) - finally: - if utils_misc.umount(sg_uri, tmpdir_path, "glusterfs", False, - "fuse.glusterfs"): - try: - os.rmdir(tmpdir_path) - except OSError: - pass - else: - logging.warning("Unable to unmount tmp directory %s with glusterfs" - " mount.", tmpdir_path) - return ret - - -def get_image_filename(params, image_name, image_format): - """ - Form the image file name using gluster uri - """ - - img_name = image_name.split('/')[-1] - gluster_uri = create_gluster_uri(params) - if params.get("image_raw_device") == "yes": - image_filename = "%s%s" % (gluster_uri, img_name) - else: - image_filename = "%s%s.%s" % (gluster_uri, img_name, image_format) - return image_filename - - @error_context.context_aware def gluster_allow_insecure(vol_name): """ diff --git a/virttest/nfs.py b/virttest/nfs.py index d101e1c2bd0..30ce50fd172 100644 --- a/virttest/nfs.py +++ b/virttest/nfs.py @@ -12,6 +12,7 @@ from avocado.core import exceptions from virttest import utils_misc +from virttest import utils_disk from virttest.utils_iptables import Iptables from virttest.utils_conn import SSHConnection from virttest.compat_52lts import results_stdout_52lts, results_stderr_52lts @@ -183,20 +184,20 @@ def is_mounted(self): :return: If the src is mounted as expect :rtype: Boolean """ - return utils_misc.is_mounted(self.mount_src, self.mount_dir, "nfs") + return utils_disk.is_mount(self.mount_src, self.mount_dir, "nfs") def mount(self): """ Mount source into given mount point. """ - return utils_misc.mount(self.mount_src, self.mount_dir, "nfs", - perm=self.mount_options) + return utils_disk.mount(self.mount_src, self.mount_dir, "nfs", + self.mount_options) def umount(self): """ Umount the given mount point. """ - return utils_misc.umount(self.mount_src, self.mount_dir, "nfs") + return utils_disk.umount(self.mount_src, self.mount_dir, "nfs") def setup(self): """ diff --git a/virttest/qemu_storage.py b/virttest/qemu_storage.py index 829c54e04f2..84926da482c 100644 --- a/virttest/qemu_storage.py +++ b/virttest/qemu_storage.py @@ -14,6 +14,7 @@ from avocado.utils import process from virttest import utils_misc +from virttest import utils_disk from virttest import virt_vm from virttest import storage from virttest import data_dir @@ -509,7 +510,7 @@ def check_image(self, params, root_dir, force_share=False): image_is_checkable = self.image_format in ['qcow2', 'qed'] force_share &= self.cap_force_share - if (storage.file_exists(params, image_filename) or + if (utils_disk.file_exists(params, image_filename) or self.is_remote_image()) and image_is_checkable: check_img = self.support_cmd("check") and self.support_cmd("info") if not check_img: @@ -566,7 +567,7 @@ def check_image(self, params, root_dir, force_share=False): "integrity problem was found " "though. (%s)" % image_filename) else: - if not storage.file_exists(params, image_filename): + if not utils_disk.file_exists(params, image_filename): logging.debug("Image file %s not found, skipping check", image_filename) elif not image_is_checkable: diff --git a/virttest/storage.py b/virttest/storage.py index 3e69e3b480c..52364868c94 100644 --- a/virttest/storage.py +++ b/virttest/storage.py @@ -17,8 +17,8 @@ from virttest import iscsi from virttest import utils_misc +from virttest import utils_storage from virttest import virt_vm -from virttest import gluster from virttest import lvm from virttest import ceph from virttest import data_dir @@ -41,7 +41,7 @@ def preprocess_image_backend(bindir, params, env): enable_gluster = params.get("enable_gluster") gluster_image = params.get("gluster_brick") if enable_gluster and gluster_image: - return gluster.create_gluster_vol(params) + return utils_storage.create_gluster_vol(params) return True @@ -54,61 +54,6 @@ def postprocess_images(bindir, params): image_obj.rm_cloned_image(params, vm, image, bindir) -def file_exists(params, filename_path): - """ - Check if image_filename exists. - - :param params: Dictionary containing the test parameters. - :param filename_path: path to file - :type filename_path: str - :param root_dir: Base directory for relative filenames. - :type root_dir: str - - :return: True if image file exists else False - """ - gluster_image = params.get("gluster_brick") - if gluster_image: - return gluster.file_exists(params, filename_path) - - if params.get("enable_ceph") == "yes": - image_name = params.get("image_name") - image_format = params.get("image_format", "qcow2") - ceph_monitor = params["ceph_monitor"] - rbd_pool_name = params["rbd_pool_name"] - rbd_image_name = "%s.%s" % (image_name.split("/")[-1], image_format) - return ceph.rbd_image_exist(ceph_monitor, rbd_pool_name, - rbd_image_name) - - return os.path.exists(filename_path) - - -def file_remove(params, filename_path): - """ - Remove the image - :param params: Dictionary containing the test parameters. - :param filename_path: path to file - """ - if params.get("enable_ceph") == "yes": - image_name = params.get("image_name") - image_format = params.get("image_format", "qcow2") - ceph_monitor = params["ceph_monitor"] - rbd_pool_name = params["rbd_pool_name"] - rbd_image_name = "%s.%s" % (image_name.split("/")[-1], image_format) - return ceph.rbd_image_rm(ceph_monitor, rbd_pool_name, rbd_image_name) - - if params.get("gluster_brick"): - # TODO: Add implementation for gluster_brick - return - - if params.get('storage_type') in ('iscsi', 'lvm'): - # TODO: Add implementation for iscsi/lvm - return - - if os.path.exists(filename_path): - os.unlink(filename_path) - return - - def get_image_blkdebug_filename(params, root_dir): """ Generate an blkdebug file path from params and root_dir. @@ -150,7 +95,8 @@ def get_image_filename(params, root_dir): if enable_gluster: image_name = params.get("image_name", "image") image_format = params.get("image_format", "qcow2") - return gluster.get_image_filename(params, image_name, image_format) + return utils_storage.get_gluster_image_filename(params, image_name, + image_format) if enable_ceph: image_format = params.get("image_format", "qcow2") ceph_monitor = params["ceph_monitor"] diff --git a/virttest/tests/unattended_install.py b/virttest/tests/unattended_install.py index 7086657bf05..1c826f0a55c 100644 --- a/virttest/tests/unattended_install.py +++ b/virttest/tests/unattended_install.py @@ -18,6 +18,7 @@ from avocado.utils import process from avocado.utils import crypto from avocado.utils import download +from avocado.utils import wait from virttest import virt_vm from virttest import asset @@ -1120,10 +1121,10 @@ def terminate_syslog_server_thread(): def copy_file_from_nfs(src, dst, mount_point, image_name): logging.info("Test failed before the install process start." " So just copy a good image from nfs for following tests.") - utils_misc.mount(src, mount_point, "nfs", perm="ro") + utils_disk.mount(src, mount_point, "nfs", "ro") image_src = utils_misc.get_path(mount_point, image_name) shutil.copy(image_src, dst) - utils_misc.umount(src, mount_point, "nfs") + utils_disk.umount(src, mount_point, "nfs") def string_in_serial_log(serial_log_file_path, string): @@ -1390,7 +1391,7 @@ def copy_images(): if params.get("medium", "cdrom") == "import": vm.shutdown() try: - if utils_misc.wait_for(vm.is_dead, shutdown_cleanly_timeout, 1, 1): + if wait.wait_for(vm.is_dead, shutdown_cleanly_timeout, 1, 1): logging.info("Guest managed to shutdown cleanly") except qemu_monitor.MonitorError as e: logging.warning("Guest apparently shut down, but got a " diff --git a/virttest/utils_disk.py b/virttest/utils_disk.py index 27c906355e2..4f7f360bf57 100644 --- a/virttest/utils_disk.py +++ b/virttest/utils_disk.py @@ -24,6 +24,11 @@ from virttest import error_context from virttest import utils_numeric +from virttest import utils_misc +from virttest import data_dir +from virttest import gluster +from virttest import ceph +from virttest.libvirt_xml import pool_xml from virttest.compat_52lts import decode_to_text from virttest.compat_52lts import results_stdout_52lts @@ -64,8 +69,19 @@ def copytree(src, dst, overwrite=True, ignore=''): shutil.copy(src_file, dst_dir) +def glusterfs_mount(g_uri, mount_point): + """ + Mount gluster volume to mountpoint. + + :param g_uri: stripped gluster uri from create_gluster_uri(.., True) + :type g_uri: str + """ + mount(g_uri, mount_point, "glusterfs", None, + False, "fuse.glusterfs") + + def is_mount(src, dst=None, fstype=None, options=None, verbose=False, - session=None): + session=None, fstype_mtab=None): """ Check is src or dst mounted. @@ -107,7 +123,8 @@ def is_mount(src, dst=None, fstype=None, options=None, verbose=False, return False -def mount(src, dst, fstype=None, options=None, verbose=False, session=None): +def mount(src, dst, fstype=None, options=None, verbose=False, session=None, + fstype_mtab=None): """ Mount src under dst if it's really mounted, then remout with options. @@ -135,7 +152,8 @@ def mount(src, dst, fstype=None, options=None, verbose=False, session=None): return process.system(cmd, verbose=verbose) == 0 -def umount(src, dst, fstype=None, verbose=False, session=None): +def umount(src, dst, fstype=None, verbose=False, session=None, + fstype_mtab=None): """ Umount src from dst, if src really mounted under dst. @@ -835,6 +853,115 @@ def get_disk_by_serial(serial_str, session=None): return disk +def new_disk_vol_name(pool_name): + """ + According to BZ#1138523, the new volume name must be the next + created partition(sdb1, etc.), so we need to inspect the original + partitions of the disk then count the new partition number. + + :param pool_name: Disk pool name + :return: New volume name or none + """ + poolxml = pool_xml.PoolXML.new_from_dumpxml(pool_name) + if poolxml.get_type(pool_name) != "disk": + logging.error("This is not a disk pool") + return None + disk = poolxml.get_source().device_path[5:] + part_num = len(list(filter(lambda s: s.startswith(disk), + get_parts_list()))) + return disk + str(part_num) + + +def gluster_file_exists(params, filename_path): + sg_uri = gluster.create_gluster_uri(params, stripped=True) + g_uri = gluster.create_gluster_uri(params, stripped=False) + # Using directly /tmp dir because directory should be really temporary and + # should be deleted immediately when no longer needed and + # created directory don't file tmp dir by any data. + tmpdir = "gmount-%s" % (utils_misc.generate_random_string(6)) + tmpdir_path = os.path.join(data_dir.get_tmp_dir(), tmpdir) + while os.path.exists(tmpdir_path): + tmpdir = "gmount-%s" % (utils_misc.generate_random_string(6)) + tmpdir_path = os.path.join(data_dir.get_tmp_dir(), tmpdir) + ret = False + try: + try: + os.mkdir(tmpdir_path) + glusterfs_mount(sg_uri, tmpdir_path) + mount_filename_path = os.path.join(tmpdir_path, + filename_path[len(g_uri):]) + if os.path.exists(mount_filename_path): + ret = True + except Exception as e: + logging.error("Failed to mount gluster volume %s to" + " mount dir %s: %s" % (sg_uri, tmpdir_path, e)) + finally: + if umount(sg_uri, tmpdir_path, "glusterfs", False, "fuse.glusterfs"): + try: + os.rmdir(tmpdir_path) + except OSError: + pass + else: + logging.warning("Unable to unmount tmp directory %s with glusterfs" + " mount.", tmpdir_path) + return ret + + +def file_remove(params, filename_path): + """ + Remove the image + :param params: Dictionary containing the test parameters. + :param filename_path: path to file + """ + if params.get("enable_ceph") == "yes": + image_name = params.get("image_name") + image_format = params.get("image_format", "qcow2") + ceph_monitor = params["ceph_monitor"] + rbd_pool_name = params["rbd_pool_name"] + rbd_image_name = "%s.%s" % (image_name.split("/")[-1], image_format) + return ceph.rbd_image_rm(ceph_monitor, rbd_pool_name, rbd_image_name) + + if params.get("gluster_brick"): + # TODO: Add implementation for gluster_brick + return + + if params.get('storage_type') in ('iscsi', 'lvm'): + # TODO: Add implementation for iscsi/lvm + return + + if os.path.exists(filename_path): + os.unlink(filename_path) + return + + +def file_exists(params, filename_path): + """ + Check if image_filename exists. + + :param params: Dictionary containing the test parameters. + :param filename_path: path to file + :type filename_path: str + :param root_dir: Base directory for relative filenames. + :type root_dir: str + + :return: True if image file exists else False + """ + gluster_image = params.get("gluster_brick") + if gluster_image: + return gluster_file_exists(params, filename_path) + + if params.get("enable_ceph") == "yes": + image_name = params.get("image_name") + image_format = params.get("image_format", "qcow2") + ceph_monitor = params["ceph_monitor"] + rbd_pool_name = params["rbd_pool_name"] + rbd_image_name = "%s.%s" % (image_name.split("/")[-1], image_format) + return ceph.rbd_image_exist(ceph_monitor, rbd_pool_name, + rbd_image_name) + + return os.path.exists(filename_path) + + class Disk(object): """ diff --git a/virttest/utils_misc.py b/virttest/utils_misc.py index 4931059b5f5..b25217489d5 100644 --- a/virttest/utils_misc.py +++ b/virttest/utils_misc.py @@ -70,7 +70,6 @@ from virttest import error_context from virttest import cartesian_config from virttest import utils_selinux -from virttest import utils_disk from virttest import logging_manager from virttest.staging import utils_koji from virttest.staging import service @@ -991,56 +990,6 @@ def safe_rmdir(path, timeout=10): (path, timeout, attempts)) -def umount(src, mount_point, fstype, verbose=False, fstype_mtab=None): - """ - Umount the src mounted in mount_point. - - :src: mount source - :mount_point: mount point - :type: file system type - :param fstype_mtab: file system type in mtab could be different - :type fstype_mtab: str - """ - return utils_disk.umount(src, mount_point, fstype, verbose) - - -def mount(src, mount_point, fstype, perm=None, verbose=False, fstype_mtab=None): - """ - Mount the src into mount_point of the host. - - :src: mount source - :mount_point: mount point - :fstype: file system type - :perm: mount permission - :param fstype_mtab: file system type in mtab could be different - :type fstype_mtab: str - """ - return utils_disk.mount(src, mount_point, fstype, perm, verbose) - - -def is_mounted(src, mount_point, fstype, perm=None, verbose=False, - fstype_mtab=None): - """ - Check mount status from /etc/mtab - - :param src: mount source - :type src: string - :param mount_point: mount point - :type mount_point: string - :param fstype: file system type - :type fstype: string - :param perm: mount permission - :type perm: string - :param verbose: if display mtab content - :type verbose: Boolean - :param fstype_mtab: file system type in mtab could be different - :type fstype_mtab: str - :return: if the src is mounted as expect - :rtype: Boolean - """ - return utils_disk.is_mount(src, mount_point, fstype, perm, verbose) - - def install_host_kernel(job, params): """ Install a host kernel, given the appropriate params. diff --git a/virttest/utils_storage.py b/virttest/utils_storage.py new file mode 100644 index 00000000000..4565c566309 --- /dev/null +++ b/virttest/utils_storage.py @@ -0,0 +1,52 @@ +import logging +import socket +import os + +from virttest import utils_misc +from virttest import utils_net +from virttest import gluster + + +def create_gluster_vol(params): + vol_name = params.get("gluster_volume_name") + force = params.get('force_recreate_gluster') == "yes" + + brick_path = params.get("gluster_brick") + if not os.path.isabs(brick_path): # do nothing when path is absolute + base_dir = params.get("images_base_dir", data_dir.get_data_dir()) + brick_path = os.path.join(base_dir, brick_path) + + logging.error("Host name lookup failed") + hostname = socket.gethostname() + if not hostname or hostname == "(none)": + if_up = utils_net.get_net_if(state="UP") + for i in if_up: + ipv4_value = utils_net.get_net_if_addrs(i)["ipv4"] + logging.debug("ipv4_value is %s", ipv4_value) + if ipv4_value != []: + ip_addr = ipv4_value[0] + break + hostname = ip_addr + + # Start the gluster dameon, if not started + gluster.glusterd_start() + # Check for the volume is already present, if not create one. + if not gluster.is_gluster_vol_avail(vol_name) or force: + return gluster.gluster_vol_create(vol_name, hostname, brick_path, + force) + else: + return True + + +def get_gluster_image_filename(params, image_name, image_format): + """ + Form the image file name using gluster uri + """ + + img_name = image_name.split('/')[-1] + gluster_uri = gluster.create_gluster_uri(params) + if params.get("image_raw_device") == "yes": + image_filename = "%s%s" % (gluster_uri, img_name) + else: + image_filename = "%s%s.%s" % (gluster_uri, img_name, image_format) + return image_filename diff --git a/virttest/utils_test/libvirt.py b/virttest/utils_test/libvirt.py index 7f7500603c6..7a149ca6c63 100644 --- a/virttest/utils_test/libvirt.py +++ b/virttest/utils_test/libvirt.py @@ -3287,25 +3287,6 @@ def exec_virsh_edit(source, edit_cmd, connect_uri="qemu:///system"): return False -def new_disk_vol_name(pool_name): - """ - According to BZ#1138523, the new volume name must be the next - created partition(sdb1, etc.), so we need to inspect the original - partitions of the disk then count the new partition number. - - :param pool_name: Disk pool name - :return: New volume name or none - """ - poolxml = pool_xml.PoolXML.new_from_dumpxml(pool_name) - if poolxml.get_type(pool_name) != "disk": - logging.error("This is not a disk pool") - return None - disk = poolxml.get_source().device_path[5:] - part_num = len(list(filter(lambda s: s.startswith(disk), - utils_misc.utils_disk.get_parts_list()))) - return disk + str(part_num) - - def update_polkit_rule(params, pattern, new_value): """ This function help to update the rule during testing. diff --git a/virttest/utils_v2v.py b/virttest/utils_v2v.py index e74a2c19a8e..92b5d0bbdbd 100644 --- a/virttest/utils_v2v.py +++ b/virttest/utils_v2v.py @@ -11,6 +11,7 @@ from avocado.utils import path from avocado.utils import process +from avocado.utils import wait from avocado.core import exceptions from virttest.compat_52lts import results_stdout_52lts, results_stderr_52lts, decode_to_text @@ -21,7 +22,7 @@ from virttest import ppm_utils from virttest import data_dir from virttest import remote -from virttest import utils_misc +from virttest import utils_disk try: V2V_EXEC = path.find_command('virt-v2v') @@ -101,7 +102,7 @@ def __init__(self, target, uri): def cleanup(self): # Cleanup NFS mount records for src, dst, fstype in self.mount_record.values(): - utils_misc.umount(src, dst, fstype) + utils_disk.umount(src, dst, fstype) def get_cmd_options(self, params): """ @@ -154,7 +155,7 @@ def _compose_input_transport_options(): if not os.path.exists(mount_point): os.makedirs(mount_point) - if not utils_misc.mount( + if not utils_disk.mount( self.vddk_libdir_src, mount_point, 'nfs', @@ -469,7 +470,7 @@ def wait_for_x_start(self, timeout=30): cmd = 'xset -q' if self.run_cmd(cmd)[0] == 127: return - utils_misc.wait_for( + wait.wait_for( lambda: not bool( self.run_cmd( cmd,