Refactor trim stress test to use fio instead of vdbench

Signed-off-by: Katarzyna Treder <katarzyna.treder@h-partners.com>

test/functional/tests/io/trim/test_trim_stress.py

@@ -4,7 +4,6 @@
 # SPDX-License-Identifier: BSD-3-Clause
 #
 
-import os
 import pytest
 
 from datetime import timedelta
@@ -13,7 +12,8 @@ from api.cas import casadm
 from api.cas.cache_config import CacheMode, CacheLineSize
 from core.test_run import TestRun
 from storage_devices.disk import DiskTypeSet, DiskType
-from test_tools.fs_tools import Filesystem
+from test_tools.fio.fio import Fio
+from test_tools.fio.fio_param import ReadWrite, IoEngine
 from type_def.size import Size, Unit
 
 
@@ -22,28 +22,23 @@ from type_def.size import Size, Unit
 @pytest.mark.require_disk("core", DiskTypeSet([DiskType.optane, DiskType.nand, DiskType.sata]))
 @pytest.mark.parametrizex("cache_mode", CacheMode)
 @pytest.mark.parametrizex("cache_line_size", CacheLineSize)
-@pytest.mark.require_plugin("vdbench")
 def test_trim_stress(cache_mode, cache_line_size):
     """
         title: Trim support on cache devices in different cache modes stress test.
         description: |
-          Stress test validating the ability of CAS to handle trim requests in different modes,
-          on different filesystem types.
+          Stress test validating the ability of CAS to handle trim requests in different modes.
         pass_criteria:
           - No kernel bug.
           - Cache should still work correctly.
     """
 
-    cores_number = 4
-    mount_point = "/mnt"
-
     with TestRun.step("Prepare devices."):
         cache_disk = TestRun.disks['cache']
         cache_disk.create_partitions([Size(1, Unit.GibiByte)])
         cache_dev = cache_disk.partitions[0]
 
         core_disk = TestRun.disks['core']
-        core_disk.create_partitions([Size(1, Unit.GibiByte)] * cores_number)
+        core_disk.create_partitions([Size(1, Unit.GibiByte)] * 3)
         core_devices = core_disk.partitions
 
     with TestRun.step("Start cache and add cores."):
@@ -52,41 +47,35 @@ def test_trim_stress(cache_mode, cache_line_size):
         for d in core_devices:
             cores.append(cache.add_core(d))
 
-    with TestRun.step("Create filesystem and mount CAS devices."):
-        directories = []
-        for counter, core in enumerate(cores):
-            core.create_filesystem(Filesystem(counter % len(Filesystem)))
-            mount_dir = os.path.join(mount_point, str(counter + 1))
-            directories.append(mount_dir)
-            core.mount(mount_dir, ["discard"])
-
     with TestRun.step("Run I/O workload."):
-        for _ in TestRun.iteration(range(1, 7)):
-            run_vdbench(directories)
+        for _ in TestRun.iteration(range(1, 6)):
+            run_fio([core.path for core in cores])
 
     with TestRun.step("Stop CAS."):
         for c in cores:
-            c.unmount()
             c.remove_core()
         cache.stop()
 
 
-def run_vdbench(directories):
-    vdbench = TestRun.plugin_manager.get_plugin('vdbench')
-    config = f"data_errors=1,validate=yes,messagescan=no,create_anchors=yes\n" \
-             f"fsd=default,depth=4,width=5,files=10,sizes=" \
-             f"(1k,10,2k,10,4k,10,8k,10,16k,10,32k,10,64k,10,128k,10,256k,10,512k,10)\n"
+def run_fio(paths):
+    block_sizes = [f"{2 ** n}k" for n in range(0, 10)]
 
-    for i, dir in enumerate(directories):
-        config += f"fsd=fsd{i},anchor={dir}\n"
+    fio = (
+        Fio().create_command()
+        .io_engine(IoEngine.libaio)
+        .io_depth(16)
+        .bs_split(":".join([f"{bs}/{100 // len(block_sizes)}" for bs in block_sizes]))
+        .time_based()
+        .run_time(timedelta(minutes=10))
+        .trim_verify_zero()
+        .verify_fatal()
+    )
 
-    config += f"\nfwd=fwd1,fsd=fsd*," \
-              f"fileio=(random),fileselect=random,threads=32," \
-              f"xfersizes=(512,10,1k,10,2k,10,4k,10,8k,10,16k,10,32k,10,64k,10," \
-              f"128k,10,256k,10)\nrd=rd1,fwd=fwd*,fwdrate=max,format=yes," \
-              f"interval=5,operations=(read,write,open,close,getattr,setattr)"
-    vdbench.create_config(config, run_time=timedelta(minutes=5))
-    if vdbench.run():
-        TestRun.LOGGER.info("VDBench finished with status zero.")
-    else:
-        TestRun.LOGGER.error("VDBench finished with non-zero status.")
+    for path, rw in zip(paths, [ReadWrite.trim, ReadWrite.randtrim, ReadWrite.trimwrite]):
+        (
+            fio.add_job(path + rw.name)
+            .file_name(path)
+            .read_write(rw)
+        )
+
+    fio.run(fio_timeout=timedelta(minutes=20))