add case for migrating guest while scp files

   xxxx-95968 - [virtual network][virtual-nic-device] Migrate guest while scp files

Signed-off-by: nanli <nanli@redhat.com>

Author: nanli1

libvirt/tests/cfg/virtual_network/qemu/migrate_with_file_transfer.cfg

@@ -0,0 +1,35 @@
+- virtual_network.qemu_test.migrate_with_file_transfer:
+    type = migrate_with_file_transfer
+    create_vm_libvirt = "yes"
+    kill_vm_libvirt = "yes"
+    start_vm = "yes"
+    take_regular_screendumps = no
+    storage_type = 'nfs'
+    setup_local_nfs = 'yes'
+    disk_type = "file"
+    disk_source_protocol = "netfs"
+    nfs_mount_dir = "/var/lib/libvirt/migrate"
+    nfs_mount_options = "soft,timeo=50,retrans=3"
+    virsh_migrate_dest_state = running
+    virsh_migrate_options = "--live --p2p --verbose"
+    virsh_migrate_connect_uri = "qemu:///system"
+    migration_setup = "yes"
+    ssh_remote_auth = True
+    mnt_path_name = ${nfs_mount_dir}
+    nfs_server_ip = "${migrate_source_host}"
+    migrate_desturi_port = "22"
+    migrate_desturi_type = "ssh"
+    virsh_migrate_desturi = "qemu+ssh://${migrate_dest_host}/system"
+    migrate_main_vm = "${main_vm}"
+    login_timeout = "360"
+    migrate_speed = 15
+    iterations = 1
+    guest_path = "/tmp/file"
+    file_size = "500"
+    transfer_timeout = "240"
+    migrate_vm_back = "no"
+    migration_type = "precopy"
+    virsh_migrate_extra = ""
+    action_during_mig = [{"func": "utils_test.run_file_transfer", "func_param": {"test": params.get('test'), "params": params.get('params'), "env": params.get('env')}}]
+    Windows:
+        guest_path = "C:\\tmpfile"

libvirt/tests/src/virtual_network/qemu/migrate_with_file_transfer.py

@@ -0,0 +1,73 @@
+# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+#
+#   Copyright Redhat
+#
+#   SPDX-License-Identifier: GPL-2.0
+#
+#   Author: Nannan Li <nanli@redhat.com>
+#
+# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+from virttest.libvirt_xml.vm_xml import VMXML
+
+from provider.migration import base_steps
+from provider.virtual_network import network_base
+
+
+def run(test, params, env):
+    """
+    Test file transfer during migration
+
+    :param test: test object
+    :param params: Dictionary with the test parameters
+    :param env: Dictionary with test environment.
+    """
+
+    def run_test():
+        """
+        Test file transfer during migration
+        """
+        test.log.info("TEST_STEP 1:Guest xml is: %s\n", VMXML.new_from_dumpxml(vm_name))
+
+        test.log.info("TEST_STEP 2: Starting migration with file transfers")
+        migration_obj.setup_connection()
+        if not vm.is_alive():
+            vm.start()
+        migration_obj.run_migration()
+
+        test.log.info("TEST_STEP 3: Testing network connectivity on destination host")
+        backup_uri = vm.connect_uri
+        vm.connect_uri = dest_uri
+
+        session = vm.wait_for_login(timeout=login_timeout)
+        ips = {'outside_ip': outside_ip}
+        network_base.ping_check(params, ips, session)
+        session.close()
+        vm.connect_uri = backup_uri
+
+        if migrate_vm_back:
+            test.log.info("TEST_STEP4: Migrating VM back to source host")
+            migration_obj.run_migration_back()
+
+    def teardown_test():
+        """
+        Cleanup test environment
+        """
+        migration_obj.cleanup_connection()
+
+    vm_name = params.get("main_vm")
+    vm = env.get_vm(vm_name)
+    dest_uri = params.get("virsh_migrate_desturi")
+    migrate_vm_back = params.get_boolean("migrate_vm_back", True)
+    login_timeout = params.get_numeric("login_timeout", "240")
+    outside_ip = params.get("outside_ip", "8.8.8.8")
+
+    # Add required objects to params for action_during_mig
+    params.update({"params": params, "test": test, "env": env})
+
+    migration_obj = base_steps.MigrationBase(test, vm, params)
+
+    try:
+        run_test()
+    finally:
+        teardown_test()

provider/migration/migration_base.py

@@ -12,6 +12,7 @@
 from virttest import utils_misc                      # pylint: disable=W0611
 from virttest import utils_libvirtd                  # pylint: disable=W0611
 from virttest import utils_conn
+from virttest import utils_test
 
 from virttest.libvirt_xml import vm_xml
 from virttest.migration import MigrationTest