vioser_in_use: add case of vcpu hotplug

Vcpu hotplug test during data transfer via serial.
Signed-off-by: NXiaoling Gao <xiagao@redhat.com>

qemu/tests/cfg/vioser_in_use.cfg

@@ -27,6 +27,9 @@
             file_sender = guest
         - host_to_guest:
             file_sender = host
+        - transfer_both:
+            only with_vcpu_hotplug
+            file_sender = both
     variants:
         - with_stop_continue:
             only Windows
@@ -50,3 +53,10 @@
             interrupt_test = live_migration_guest
             mig_speed = 512M
             pre_migrate = "mig_set_speed"
+        - with_vcpu_hotplug:
+            only Windows
+            only transfer_both
+            interrupt_test = vcpu_hotplug_guest
+            vcpu_hotplug = yes
+            smp = 2
+            vcpu_maxcpus = 8

qemu/tests/vioser_in_use.py

@@ -2,6 +2,7 @@ import re
 import os
 import signal
 import logging
+import time
 
 from avocado.utils import process
 from virttest import utils_misc
@@ -45,6 +46,21 @@ def live_migration_guest(test, params, vm, session):
     vm.migrate()
 
 
+@error_context.context_aware
+def vcpu_hotplug_guest(test, params, vm, session):
+    """
+    Vcpu hot plug test.
+    """
+
+    maxcpus = int(params["vcpu_maxcpus"])
+    current_cpus = int(params.get("smp", 2))
+    for cpuid in range(current_cpus, maxcpus):
+        error_context.context("hot-pluging vCPU %s" % cpuid, logging.info)
+        vm.hotplug_vcpu(cpu_id=cpuid)
+        # make the cpu hotplug has slot during data transfer
+        time.sleep(2)
+
+
 @error_context.context_aware
 def kill_host_serial_pid(params, vm):
     """
@@ -116,10 +132,21 @@ def run(test, params, env):
 
     bg_thread = run_bg_test(test, params, vm, sender)
     globals().get(params["interrupt_test"])(test, params, vm, session)
+
+    # for vcpu hotplug subtest, only check guest crash.
+    vcpu_hotplug = params.get_boolean("vcpu_hotplug")
+    if vcpu_hotplug:
+        error_context.context("Check if guest is alive.", logging.info)
+        vm.verify_kernel_crash()
+        session = vm.wait_for_login(timeout=timeout)
+        session.close()
+        return
+
     if bg_thread:
-        bg_thread.join(timeout=timeout, suppress_exception=suppress_exception)
+        bg_thread.join(timeout=timeout,
+                       suppress_exception=suppress_exception)
     if vm.is_alive():
         kill_host_serial_pid(params, vm)
-        if (virtio_serial_file_transfer.transfer_data(params, vm, sender=sender) is
-                not True):
+        if (virtio_serial_file_transfer.transfer_data(
+                params, vm, sender=sender) is not True):
             test.fail("Serial data transfter test failed.")