Add volume test

Test for preserving partitions from core device.
Test for preserving partitions at core device, which were made on exported object,
after stopping cache.
Also added two fields to 'Core' class which allows it to use 'create_partitions' function.

Signed-off-by: Slawomir Jankowski <slawomir.jankowski@intel.com>

test/functional/api/cas/core.py

@@ -33,6 +33,8 @@ class Core(Device):
         if core_info["exp_obj"] != "-":
             Device.__init__(self, core_info["exp_obj"])
         self.cache_id = cache_id
+        self.partitions = []
+        self.block_size = None
 
     def __get_core_info(self):
         output = TestRun.executor.run(

test/functional/tests/volumes/test_volume_partitions.py

@@ -0,0 +1,173 @@
+#
+# Copyright(c) 2020 Intel Corporation
+# SPDX-License-Identifier: BSD-3-Clause-Clear
+#
+
+import pytest
+
+from api.cas import casadm
+from api.cas.cache_config import CacheMode
+from storage_devices.disk import DiskType, DiskTypeSet, DiskTypeLowerThan
+from core.test_run import TestRun
+from storage_devices.partition import Partition
+from test_tools import fs_utils, disk_utils
+from test_tools.disk_utils import PartitionTable, Filesystem
+from test_utils.size import Size, Unit
+
+mount_point = "/mnt/cas"
+cores_number = 16
+
+
+@pytest.mark.parametrize("cache_mode", CacheMode)
+@pytest.mark.parametrize("partition_table", PartitionTable)
+@pytest.mark.parametrize("filesystem", Filesystem)
+@pytest.mark.require_disk("cache", DiskTypeSet([DiskType.optane, DiskType.nand]))
+@pytest.mark.require_disk("core", DiskTypeLowerThan("cache"))
+def test_cas_preserves_partitions(partition_table, filesystem, cache_mode):
+    """
+        title: Volume test for preserving partition table from core device.
+        description: |
+          Validation of the ability of CAS to preserve partition table on core device
+          after adding it to cache.
+        pass_criteria:
+          - Md5 sums on partitions shall be identical before and after running cache.
+          - Partition table shall be preserved on exported object.
+    """
+    with TestRun.step(f"Prepare cache and core devices."):
+        cache_dev = TestRun.disks['cache']
+        cache_dev.create_partitions([Size(1, Unit.GibiByte)])
+        cache_dev = cache_dev.partitions[0]
+        core_dev = TestRun.disks['core']
+        core_sizes = [Size(1, Unit.GibiByte)] * cores_number
+        core_dev.create_partitions(core_sizes, partition_table)
+
+    with TestRun.step("Create filesystem on core devices."):
+        for i in range(cores_number):
+            core_dev.partitions[i].create_filesystem(filesystem)
+
+    with TestRun.step("Mount core devices and create test files."):
+        files = []
+        for i, core in enumerate(core_dev.partitions):
+            mount_path = f"{mount_point}{i}"
+            core.mount(mount_path)
+            test_file_path = f"{mount_path}/test_file"
+            files.append(fs_utils.create_random_test_file(test_file_path))
+
+    with TestRun.step("Check md5 sums of test files."):
+        test_files_md5sums = []
+        for file in files:
+            test_files_md5sums.append(file.md5sum())
+
+    with TestRun.step("Unmount core devices."):
+        for core in core_dev.partitions:
+            core.unmount()
+
+    with TestRun.step(f"Start cache."):
+        cache = casadm.start_cache(cache_dev, cache_mode, force=True)
+
+    with TestRun.step("Add cores to cache."):
+        cores = []
+        for i in range(cores_number):
+            cores.append(cache.add_core(core_dev.partitions[i]))
+
+    with TestRun.step("Mount core devices."):
+        for i, core in enumerate(cores):
+            mount_path = f"{mount_point}{i}"
+            core.mount(mount_path)
+
+    with TestRun.step("Check again md5 sums of test files."):
+        test_files_md5sums_new = []
+        for file in files:
+            test_files_md5sums_new.append(file.md5sum())
+
+    with TestRun.step("Unmount core devices."):
+        for core in cores:
+            core.unmount()
+
+    with TestRun.step("Stop cache."):
+        cache.stop()
+
+    with TestRun.step("Compare md5 sums of test files."):
+        if test_files_md5sums != test_files_md5sums_new:
+            TestRun.fail("Md5 sums are different.")
+
+
+@pytest.mark.parametrize("cache_mode", CacheMode)
+@pytest.mark.parametrize("partition_table", PartitionTable)
+@pytest.mark.parametrize("filesystem", Filesystem)
+@pytest.mark.require_disk("cache", DiskTypeSet([DiskType.optane, DiskType.nand]))
+@pytest.mark.require_disk("core", DiskTypeLowerThan("cache"))
+def test_partition_create_cas(partition_table, filesystem, cache_mode):
+    """
+        title: Test for preserving partition table created on exported volume after stopping cache.
+        description: |
+          Validation of the ability of CAS to preserve partition table created on exported volume
+          after stopping cache.
+        pass_criteria:
+          - Md5 sums on partitions shall be identical before and after stopping cache.
+          - Partition table shall be preserved on core device.
+    """
+    with TestRun.step(f"Prepare cache and core devices."):
+        cache_dev = TestRun.disks['cache']
+        cache_dev.create_partitions([Size(256, Unit.MebiByte)])
+        cache_dev = cache_dev.partitions[0]
+        core_dev = TestRun.disks['core']
+
+    with TestRun.step(f"Start cache."):
+        cache = casadm.start_cache(cache_dev, cache_mode, force=True)
+        core = cache.add_core(core_dev)
+
+    with TestRun.step("Create partitions on exported device."):
+        core_sizes = [Size(1, Unit.GibiByte)] * cores_number
+        core.block_size = core_dev.block_size
+        disk_utils.create_partitions(core, core_sizes, partition_table)
+
+    with TestRun.step("Create filesystem on core devices."):
+        for part in core.partitions:
+            part.create_filesystem(filesystem)
+
+    with TestRun.step("Mount core devices and create test files."):
+        files = []
+        for i, part in enumerate(core.partitions):
+            mount_path = f"{mount_point}{i}"
+            part.mount(mount_path)
+            test_file_path = f"{mount_path}/test_file"
+            files.append(fs_utils.create_random_test_file(test_file_path))
+
+    with TestRun.step("Check md5 sums of test files."):
+        test_files_md5sums = []
+        for file in files:
+            test_files_md5sums.append(file.md5sum())
+
+    with TestRun.step("Unmount core devices."):
+        for part in core.partitions:
+            part.unmount()
+
+    with TestRun.step("Stop cache."):
+        cache.stop()
+
+    with TestRun.step("Read partitions on core device."):
+        for part in core.partitions:
+            part.parent_device = core_dev
+            new_part = Partition(part.parent_device, part.type, part.number)
+            core_dev.partitions.append(new_part)
+
+    with TestRun.step("Mount core devices."):
+        counter = 1
+        for i, core in enumerate(core_dev.partitions):
+            mount_path = f"{mount_point}{i}"
+            core.mount(mount_path)
+            counter += 1
+
+    with TestRun.step("Check again md5 sums of test files."):
+        test_files_md5sums_new = []
+        for file in files:
+            test_files_md5sums_new.append(file.md5sum())
+
+    with TestRun.step("Unmount core devices."):
+        for core in core_dev.partitions:
+            core.unmount()
+
+    with TestRun.step("Compare md5 sums of test files."):
+        if test_files_md5sums != test_files_md5sums_new:
+            TestRun.fail("Md5 sums are different.")