virtual_network: add case for migrating guest while netperf

    xxxx-95876 - [virtual network][virtual-nic-device] Migrate guest while running netperf

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

Author: nanli1

deps/netperf/netperf-2.7.1-1.tar.bz2

@@ -0,0 +1,45 @@
+- virtual_network.qemu_test.migrate_with_netperf:
+    type = migrate_with_netperf
+    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_options = "soft,timeo=50,retrans=3"
+    virsh_migratedest_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"
+    migrate_speed = 15
+    migrate_vm_back = "yes"
+    migration_type = "precopy"
+    virsh_migrate_extra = ""
+    # Netperf parameters
+    netperf_timeout = "60"
+    netperf_client = "${migrate_dest_host}"
+    netperf_server = "${main_vm}"
+    test_protocol = "TCP_STREAM"
+    netperf_iterations = 10
+    action_during_mig = [{"func": "network_base.exec_netperf_test", "func_param": {"params": params.get('params'), "env": params.get('env')}, "iterations": ${netperf_iterations}}]
+    os_type = "linux"
+    firewall_cmd = "systemctl stop firewalld"
+    netperf_ver = "netperf-2.7.1-1"
+    netperf_source = "${netperf_ver}.tar.bz2"
+    Windows:
+        os_type = "windows"
+        firewall_cmd = "netsh firewall set opmode mode=disable"
+        netperf_source = "netperf.exe"
+    variants:
+        - tcp:
+            migration_protocol = "tcp"
+            migrate_desturi_type = "tcp"
+            virsh_migrate_desturi = "qemu+tcp://${migrate_dest_host}/system"
+            virsh_migrate_options = "--live --p2p --verbose"

deps/netperf/netperf.exe

@@ -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 migration with netperf stress
+
+    :param test: test object
+    :param params: Dictionary with the test parameters
+    :param env: Dictionary with test environment.
+    """
+
+    def run_test():
+        """
+        Test migration with netperf stress
+        """
+        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 netperf stress")
+        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_STEP 4: 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()

libvirt/tests/cfg/virtual_network/qemu/migrate_with_netperf.cfg

@@ -7,6 +7,7 @@
 from avocado.core import exceptions
 from avocado.utils import process
 
+from provider.virtual_network import network_base    # pylint: disable=W0611
 from virttest import remote
 from virttest import virsh                           # pylint: disable=W0611
 from virttest import utils_misc                      # pylint: disable=W0611

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

@@ -7,6 +7,8 @@
 import aexpect
 from avocado.core import exceptions
 from avocado.utils import process
+
+from virttest import data_dir
 from virttest import remote
 from virttest import utils_misc
 from virttest import utils_net
@@ -448,9 +450,22 @@ def exec_netperf_test(params, env):
     netperf_server = params.get("netperf_server")
     extra_cmd_opts = params.get("extra_cmd_opts", "")
     netperf_timeout = params.get("netperf_timeout", "60")
-    test_protocol = params.get("test_protocol")
+    test_protocol = params.get("test_protocol", "TCP_STREAM")
+    os_type = params.get("os_type", "linux")
+
+    # Command configuration parameters
+    firewall_cmd = params.get("firewall_cmd", "systemctl stop firewalld")
+    restore_firewall_cmd = params.get("restore_firewall_cmd", "systemctl start firewalld")
+    kill_netserver_cmd = params.get("kill_netserver_cmd", "killall netserver")
+    netserver_cmd = params.get("netserver_cmd", "netserver")
+    netperf_bin = params.get("netperf_bin", "netperf")
+    netperf_opts = params.get("netperf_opts", "-C -c")
+    cleanup_netserver_cmd = params.get("cleanup_netserver_cmd", "killall netserver")
+    netperf_src = os.path.join(data_dir.get_deps_dir("netperf"), params.get("netperf_src"))
+    netperf_ver = params.get("netperf_ver")
     vms = params.get('vms').split()
     vm_objs = {vm_i: env.get_vm(vm_i) for vm_i in vms}
+
     before_test_cores = process.run("coredumpctl list", ignore_status=True, verbose=True).stdout_text
 
     def _get_access_info(netperf_address):
@@ -474,20 +489,42 @@ def _get_access_info(netperf_address):
     s_func, s_ip, s_session = _get_access_info(netperf_server)
 
     try:
-        if not utils_package.package_install("netperf", c_session):
-            raise exceptions.TestError("Unable to install netperf in the client host!")
-        if not utils_package.package_install("netperf", s_session):
-            raise exceptions.TestError("Unable to install netperf in the server host!")
-        c_func("systemctl stop firewalld")
-        s_func("systemctl stop firewalld")
+        # Install netperf
+        if os_type == "windows":
+            if os.path.exists(netperf_src) and netperf_server in vms:
+                vm = vm_objs.get(netperf_server)
+                remote.copy_files_to(vm.get_address(), "scp",
+                                   params.get("username"), params.get("password") , 22,
+                                   netperf_src, "C:\\netperf.exe", 600)
+                LOG.debug("Copied netperf.exe to Windows guest")
+        else:
 
+            if os.path.exists(netperf_src):
+                if c_session:
+                    c_session.cmd("cd /tmp && tar -xjf " + netperf_src + " && cd %s && make" % netperf_ver, ignore_all_errors=True)
+                if s_session:
+                    s_session.cmd("cd /tmp && tar -xjf " + netperf_src + " && cd %s && make" % netperf_ver, ignore_all_errors=True)
+            else:
+                # Fallback to package manager
+                if not utils_package.package_install("netperf", c_session):
+                    raise exceptions.TestError("Unable to install netperf in the client host!")
+                if not utils_package.package_install("netperf", s_session):
+                    raise exceptions.TestError("Unable to install netperf in the server host!")
+
+        # Disable firewall
+        c_func(firewall_cmd, ignore_status=True)
+        s_func(firewall_cmd, ignore_status=True)
+
+        # Start netserver
         LOG.debug("Start netserver...")
-        if s_ip == netperf_server:
-            s_func("killall netserver", ignore_status=True)
-        s_func("netserver")
+        if kill_netserver_cmd:
+            s_func(kill_netserver_cmd, ignore_status=True)
 
+        s_func(netserver_cmd, ignore_status=True)
+
+        # Run netperf client
         LOG.debug("Run netperf command...")
-        test_cmd = f"netperf -H {s_ip} -l {netperf_timeout} -C -c -t {test_protocol} {extra_cmd_opts}"
+        test_cmd = f"{netperf_bin} -H {s_ip} -l {netperf_timeout} -t {test_protocol} {netperf_opts} {extra_cmd_opts}"
         c_func(test_cmd, timeout=120)
 
         for vm in vm_objs.values():
@@ -505,11 +542,19 @@ def _get_access_info(netperf_address):
 
     finally:
         LOG.info("Test teardown: Cleanup env.")
-        s_func("killall netserver")
-        s_func("systemctl start firewalld")
-        # TODO: Start firewalld on guest
+        # Cleanup netserver
+        s_func(cleanup_netserver_cmd)
+
+        # Restore firewall
+        s_func(restore_firewall_cmd)
         process.run("systemctl start firewalld", ignore_status=True)
 
+        # Cleanup sessions
+        if c_session:
+            c_session.close()
+        if s_session:
+            s_session.close()
+
 
 def prepare_single_vm(params, vm_name, disk_path='', iface_list=[]):
     """