Add tests for CAS device serial

Katarzyna Treder · Katarzyna Treder · commit 0260a844185f · 2025-06-10T12:15:46.000+02:00
Signed-off-by: Katarzyna Treder &lt;katarzyna.treder@h-partners.com&gt;
diff --git a/test/functional/tests/misc/test_exported_object_serial.py b/test/functional/tests/misc/test_exported_object_serial.py
@@ -0,0 +1,73 @@
+#
+# Copyright(c) 2024-2025 Huawei Technologies Co., Ltd.
+# SPDX-License-Identifier: BSD-3-Clause
+#
+
+import itertools
+import os
+import random
+import pytest
+
+from api.cas import casadm
+from api.cas.init_config import InitConfig
+from core.test_run import TestRun
+from storage_devices.disk import DiskType, DiskTypeSet, DiskTypeLowerThan
+from type_def.size import Size, Unit
+
+serial_template = "opencas-"
+
+
+@pytest.mark.require_disk("cache", DiskTypeSet([DiskType.optane, DiskType.nand]))
+@pytest.mark.require_disk("core", DiskTypeLowerThan("cache"))
+def test_exported_object_serial():
+    """
+        title: Cached volume serial creation.
+        description: Validate if each exported object is created with proper serial.
+        pass_criteria:
+          - Each exported object has proper serial in following format:
+            opencas-casX-Y where X is cache ID and Y is core ID
+          - serial is not changed after system reboot
+    """
+    caches_count = 4
+    cores_count = [random.randint(1, 4) for _ in range(caches_count)]
+
+    with TestRun.step("Prepare devices"):
+        cache_dev = TestRun.disks["cache"]
+        core_dev = TestRun.disks["core"]
+
+        cache_dev.create_partitions([Size(1, Unit.GibiByte)] * caches_count)
+        core_dev.create_partitions([Size(1, Unit.GibiByte)] * sum(cores_count))
+
+    with TestRun.step("Start caches and add cores"):
+        caches = [
+            casadm.start_cache(cache_dev.partitions[cache_num], force=True)
+            for cache_num in range(caches_count)
+        ]
+
+        part_num = itertools.count().__next__
+        cores_per_cache = [
+            [
+                caches[cache_num].add_core(core_dev.partitions[part_num()])
+                for _ in range(cores_count[cache_num])
+            ] for cache_num in range(caches_count)
+        ]
+        cores = list(itertools.chain(*cores_per_cache))
+
+    with TestRun.step("Check if each cached volume has proper serial"):
+        check_serial(cores)
+
+    with TestRun.step("Create init config from running configuration"):
+        InitConfig.create_init_config_from_running_configuration()
+
+    with TestRun.step("Reboot platform"):
+        TestRun.executor.reboot()
+
+    with TestRun.step("Check if cached volumes have proper serial after reboot"):
+        check_serial(cores)
+
+
+def check_serial(cores):
+    for core in cores:
+        serial = core.get_serial()
+        if serial != serial_template + os.path.basename(core.path):
+            TestRun.LOGGER.error(f"Cached volume {core.path} has wrong serial: '{serial}'")
diff --git a/test/functional/tests/volumes/common.py b/test/functional/tests/volumes/common.py
@@ -1,6 +1,6 @@
 #
 # Copyright(c) 2022 Intel Corporation
-# Copyright(c) 2024 Huawei Technologies Co., Ltd.
+# Copyright(c) 2024-2025 Huawei Technologies Co., Ltd.
 # SPDX-License-Identifier: BSD-3-Clause
 #
 
@@ -57,14 +57,15 @@ def get_test_configuration():
 
     return config_output.stdout, devices
 
+
 def validate_configuration(config_before_reboot, devices_before):
     config_after_reboot, devices_after = get_test_configuration()
 
     if config_after_reboot == config_before_reboot:
         TestRun.LOGGER.info(f"Configuration is as expected")
     else:
-        TestRun.LOGGER.info(f"config before reboot: {config_before_reboot}")
-        TestRun.LOGGER.info(f"config after reboot: {config_after_reboot}")
+        TestRun.LOGGER.info(f"Config before reboot: {config_before_reboot}")
+        TestRun.LOGGER.info(f"Config after reboot: {config_after_reboot}")
         TestRun.LOGGER.error(f"Configuration changed after reboot")
 
     if devices_after == devices_before:
diff --git a/test/functional/tests/volumes/test_many_cores_on_many_lvms.py b/test/functional/tests/volumes/test_many_cores_on_many_lvms.py
@@ -1,6 +1,6 @@
 #
 # Copyright(c) 2022 Intel Corporation
-# Copyright(c) 2024 Huawei Technologies Co., Ltd.
+# Copyright(c) 2024-2025 Huawei Technologies Co., Ltd.
 # SPDX-License-Identifier: BSD-3-Clause
 #
 
@@ -22,14 +22,14 @@
 @pytest.mark.require_disk("core", DiskTypeSet([DiskType.optane, DiskType.nand]))
 def test_many_cores_on_many_lvms():
     """
-        title: Test for CAS creation with lvms as cores: 1 cache, 16 lvms, 16 cores.
-        description: |
-          Validation of LVM support, CAS with 1 cache and 16 lvms as 16 cores.
-        pass_criteria:
-          - LVMs created successfully.
-          - CAS devices created successfully.
-          - FIO with verification ran successfully.
-          - Configuration after reboot match configuration before.
+    title: Test for CAS creation with lvms as cores: 1 cache, 16 lvms, 16 cores.
+    description: |
+        Validation of LVM support, CAS with 1 cache and 16 lvms as 16 cores.
+    pass_criteria:
+      - LVMs created successfully.
+      - CAS devices created successfully.
+      - FIO with verification ran successfully.
+      - Configuration after reboot match configuration before.
     """
     with TestRun.step(f"Prepare devices."):
         cache_device = TestRun.disks['cache']
diff --git a/test/functional/tests/volumes/test_many_lvms_on_many_cores.py b/test/functional/tests/volumes/test_many_lvms_on_many_cores.py
@@ -1,6 +1,6 @@
 #
 # Copyright(c) 2022 Intel Corporation
-# Copyright(c) 2024 Huawei Technologies Co., Ltd.
+# Copyright(c) 2024-2025 Huawei Technologies Co., Ltd.
 # SPDX-License-Identifier: BSD-3-Clause
 #
 
@@ -23,14 +23,14 @@
 @pytest.mark.require_disk("core2", DiskTypeLowerThan("cache"))
 def test_many_lvms_on_many_cores():
     """
-        title: Test for LVM creation on CAS: 1 cache, 4 cores, 4 lvms.
-        description: |
-          Validation of LVM support, LVMs created (4) on CAS device (1 cache, 4 cores).
-        pass_criteria:
-          - CAS devices created successfully.
-          - LVMs created successfully.
-          - FIO with verification ran successfully.
-          - Configuration after reboot match configuration before.
+    title: Test for LVM creation on CAS: 1 cache, 4 cores, 4 lvms.
+    description: |
+        Validation of LVM support, LVMs created (4) on CAS device (1 cache, 4 cores).
+    pass_criteria:
+      - CAS devices created successfully.
+      - LVMs created successfully.
+      - FIO with verification ran successfully.
+      - Configuration after reboot match configuration before.
     """
     with TestRun.step(f"Create CAS device."):
         cache_device = TestRun.disks['cache']
diff --git a/test/functional/tests/volumes/test_many_lvms_on_many_cores_by_serial.py b/test/functional/tests/volumes/test_many_lvms_on_many_cores_by_serial.py
@@ -0,0 +1,87 @@
+#
+# Copyright(c) 2024-2025 Huawei Technologies Co., Ltd.
+# SPDX-License-Identifier: BSD-3-Clause
+#
+
+import datetime
+import pytest
+
+from storage_devices.lvm import Lvm, LvmConfiguration
+from api.cas import casadm
+from core.test_run import TestRun
+from storage_devices.disk import DiskType, DiskTypeSet, DiskTypeLowerThan
+from test_tools.fio.fio import Fio
+from test_tools.fio.fio_param import ReadWrite, IoEngine, VerifyMethod
+from type_def.size import Size, Unit
+from tests.volumes.common import get_test_configuration, lvm_filters, validate_configuration
+
+
+@pytest.mark.require_disk("cache", DiskTypeSet([DiskType.optane, DiskType.nand]))
+@pytest.mark.require_disk("core", DiskTypeLowerThan("cache"))
+def test_many_lvms_on_many_cores_by_serial():
+    """
+    title: Test for LVM creation on cached volumes using their serial - many lvms on many cores.
+    description: |
+        Validate if LVMs based on exported objects combined into one volume group are created
+        successfully using cached volume's serial after system reboot.
+    pass_criteria:
+      - exported objects created successfully
+      - LVMs created successfully
+      - FIO with verification ran successfully
+      - Configuration after reboot match configuration before
+    """
+    with TestRun.step("Prepare devices."):
+        cache_dev = TestRun.disks["cache"]
+        core_dev = TestRun.disks["core"]
+        cache_dev.create_partitions([Size(2, Unit.GibiByte)])
+        core_dev.create_partitions([Size(2, Unit.GibiByte)] * 4)
+
+        cache = casadm.start_cache(cache_dev.partitions[0], force=True)
+        cores = [cache.add_core(core_part) for core_part in core_dev.partitions]
+
+    with TestRun.step("Configure LVM to use devices file."):
+        LvmConfiguration.set_use_devices_file(True)
+
+    with TestRun.step("Add CAS device type to the LVM config file."):
+        LvmConfiguration.add_block_device_to_lvm_config("cas")
+
+    with TestRun.step("Create LVMs on cached volumes."):
+        config = LvmConfiguration(lvm_filters,
+                                  pv_num=4,
+                                  vg_num=1,
+                                  lv_num=16,)
+
+        lvms = Lvm.create_specific_lvm_configuration(cores, config)
+
+    with TestRun.step("Run FIO with verification on LVM."):
+        fio_run = (Fio().create_command()
+                   .read_write(ReadWrite.randrw)
+                   .io_engine(IoEngine.sync)
+                   .io_depth(1)
+                   .time_based()
+                   .run_time(datetime.timedelta(seconds=30))
+                   .do_verify()
+                   .verify(VerifyMethod.md5)
+                   .block_size(Size(1, Unit.Blocks4096)))
+        for lvm in lvms:
+            fio_run.add_job().target(lvm).size(lvm.size)
+        fio_run.run()
+
+    with TestRun.step("Flush buffers"):
+        for lvm in lvms:
+            TestRun.executor.run_expect_success(f"hdparm -f {lvm.path}")
+
+    with TestRun.step("Create init config from running configuration"):
+        config_before_reboot, devices_before = get_test_configuration()
+
+    with TestRun.step("Reboot system."):
+        TestRun.executor.reboot()
+
+    with TestRun.step("Validate running configuration"):
+        validate_configuration(config_before_reboot, devices_before)
+
+    with TestRun.step("Run FIO with verification on LVM."):
+        fio_run.run()
+
+    with TestRun.step("Remove LVMs."):
+        Lvm.remove_all()
diff --git a/test/functional/tests/volumes/test_many_lvms_on_single_core.py b/test/functional/tests/volumes/test_many_lvms_on_single_core.py
@@ -1,6 +1,6 @@
 #
 # Copyright(c) 2022 Intel Corporation
-# Copyright(c) 2024 Huawei Technologies Co., Ltd.
+# Copyright(c) 2024-2025 Huawei Technologies Co., Ltd.
 # SPDX-License-Identifier: BSD-3-Clause
 #
 
@@ -22,14 +22,14 @@
 @pytest.mark.require_disk("core", DiskTypeLowerThan("cache"))
 def test_many_lvms_on_single_core():
     """
-        title: Test for LVM creation on CAS device - many lvms on single core.
-        description: |
-          Validation of LVM support, many LVMs (16) created on CAS device (1 cache, 1 core).
-        pass_criteria:
-          - CAS devices created successfully.
-          - LVMs created successfully.
-          - FIO with verification ran successfully.
-          - Configuration after reboot match configuration before.
+    title: Test for LVM creation on CAS device - many lvms on single core.
+    description: |
+        Validation of LVM support, many LVMs (16) created on CAS device (1 cache, 1 core).
+    pass_criteria:
+      - CAS devices created successfully.
+      - LVMs created successfully.
+      - FIO with verification ran successfully.
+      - Configuration after reboot match configuration before.
     """
     with TestRun.step(f"Create CAS device."):
         cache_dev = TestRun.disks['cache']
