migration: Add case about migrate-compcache

To test that memory compression cache size can be set/got by
migrate-compcache.

VIRT-298168 - [migrate-compcache] set/get cache size for migration
memory compression

Signed-off-by: lcheng <[email protected]>

Author: cliping

libvirt/tests/cfg/migration/migration_cmd/migrate_compcache.cfg

@@ -0,0 +1,41 @@
+- migration.migration_cmd.migrate_compcache:
+    type = migrate_compcache
+    migration_setup = 'no'
+    disk_type = "file"
+    # Console output can only be monitored via virsh console output
+    only_pty = True
+    take_regular_screendumps = no
+    # Extra options to pass after <domain> <desturi>
+    virsh_migrate_extra = ''
+    # SSH connection time out
+    ssh_timeout = 60
+    image_convert = 'no'
+    server_ip = "${migrate_dest_host}"
+    server_user = "root"
+    server_pwd = "${migrate_dest_pwd}"
+    status_error = "no"
+    variants vm_status:
+        - vm_running:
+            start_vm = "yes"
+            variants:
+                - compcache_512M:
+                    compression_cache = "536870912"
+                - compcache_256M:
+                    compression_cache = "268435456"
+                - compcache_1K:
+                    compression_cache = "1024"
+                    status_error = "yes"
+                    err_msg = "Parameter 'xbzrle_cache_size' expects a power of two no less than the target page size"
+                - compcache_0:
+                    compression_cache = "0"
+                    status_error = "yes"
+                    err_msg = "Parameter 'xbzrle_cache_size' expects a power of two no less than the target page size"
+                - compcache_large:
+                    compression_cache = "18446744073709551616"
+                    status_error = "yes"
+                    err_msg = "for <size> option is malformed or out of range"
+        - vm_shutoff:
+            start_vm = "no"
+            compression_cache = "536870912"
+            status_error = "yes"
+            err_msg = "domain is not running"

libvirt/tests/src/migration/migration_cmd/migrate_compcache.py

@@ -0,0 +1,74 @@
+# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+#
+#   Copyright Redhat
+#
+#   SPDX-License-Identifier: GPL-2.0
+#
+#   Author: Liping Cheng <[email protected]>
+#
+# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+from virttest import virsh
+
+from virttest.utils_test import libvirt
+
+
+def run(test, params, env):
+    """
+    To verify that memory compression cache size can be set/got by
+    migrate-compcache.
+
+    :param test: test object
+    :param params: Dictionary with the test parameters
+    :param env: Dictionary with test environment.
+    """
+    vm_name = params.get("migrate_main_vm")
+    compression_cache = params.get("compression_cache")
+    status_error = "yes" == params.get("status_error", "no")
+    err_msg = params.get("err_msg")
+    vm_status = params.get("vm_status")
+    vm = env.get_vm(vm_name)
+
+    test.log.info("Run test for migrate-compcache/migrate-compcache.")
+
+    ret = virsh.migrate_compcache(vm_name, debug=True)
+    orig_size = None
+    if ret.exit_status:
+        if vm_status == "vm_shutoff":
+            libvirt.check_result(ret, err_msg)
+        else:
+            test.fail(f"Failed to get compression cache size: {ret.stdout_text}")
+    else:
+        orig_size = ret.stdout_text.strip().split(":")[-1]
+
+    ret = virsh.migrate_compcache(vm_name, size=compression_cache, debug=True)
+    if ret.exit_status:
+        if status_error:
+            libvirt.check_result(ret, err_msg)
+        else:
+            test.fail(f"Failed to set compression cache size: {ret.stdout_text}")
+
+    if vm_status != "vm_shutoff":
+        new_size = virsh.migrate_compcache(vm_name, debug=True).stdout_text.strip().split(":")[-1]
+        if status_error:
+            if orig_size.split()[0].strip() != new_size.split()[0].strip():
+                test.fail(f"For negative testing, compression cache size is modified: {new_size}")
+            else:
+                test.log.info(f"For negative testing, compression cache size "
+                              "remains the same as before.")
+        else:
+            value = new_size.split()[0].strip()
+            unit = new_size.split()[-1].strip()
+            value = int(float(value))
+            if unit == "KiB":
+                size = int(int(compression_cache) / 1024)
+            elif unit == "MiB":
+                size = int(int(compression_cache) / 1048576)
+            elif unit == "GiB":
+                size = int(int(compression_cache) / 1073741824)
+            if value != size:
+                test.fail(f"For positive testing, failed to set the compression "
+                          "cache size: expected {size}, actual {value}")
+            else:
+                test.log.info(f"For positive testing, the compression cache "
+                              "size was set successfully.")