github/open-cas-linux
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

tests: reformat test_trim_eviction

Browse Source 
This commit doesn't introduce any changes to the flow of the tests.

Signed-off-by: Michal Mielewczyk <michal.mielewczyk@intel.com>
This commit is contained in:
Michal Mielewczyk 2022-06-17 11:18:17 +02:00
parent 9ad1d878a2
commit 67aac6de1d
1 changed files with 21 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
test/functional/tests/io/trim/test_trim_eviction.py
View File

@ -27,22 +27,22 @@ from test_utils.filesystem.file import File
@pytest.mark.parametrizex("cleaning", [CleaningPolicy.alru, CleaningPolicy.nop]) @pytest.mark.parametrizex("cleaning", [CleaningPolicy.alru, CleaningPolicy.nop])
def test_trim_eviction(cache_mode, cache_line_size, filesystem, cleaning): def test_trim_eviction(cache_mode, cache_line_size, filesystem, cleaning):
""" """
title: Test verifying if trim requests do not cause eviction on CAS device. title: Test verifying if trim requests do not cause eviction on CAS device.
description: | description: |
When trim requests enabled and files are being added and removed from CAS device, When trim requests enabled and files are being added and removed from CAS device,
there is no eviction (no reads from cache). there is no eviction (no reads from cache).
pass_criteria: pass_criteria:
- Reads from cache device are the same before and after removing test file. - Reads from cache device are the same before and after removing test file.
""" """
mount_point = "/mnt" mount_point = "/mnt"
test_file_path = os.path.join(mount_point, "test_file") test_file_path = os.path.join(mount_point, "test_file")
with TestRun.step("Prepare devices."): with TestRun.step("Prepare devices."):
cache_disk = TestRun.disks['cache'] cache_disk = TestRun.disks["cache"]
cache_disk.create_partitions([Size(1, Unit.GibiByte)]) cache_disk.create_partitions([Size(1, Unit.GibiByte)])
cache_dev = cache_disk.partitions[0] cache_dev = cache_disk.partitions[0]
core_disk = TestRun.disks['core'] core_disk = TestRun.disks["core"]
core_disk.create_partitions([Size(1, Unit.GibiByte)]) core_disk.create_partitions([Size(1, Unit.GibiByte)])
core_dev = core_disk.partitions[0] core_dev = core_disk.partitions[0]
@ -76,7 +76,9 @@ def test_trim_eviction(cache_mode, cache_line_size, filesystem, cleaning):
with TestRun.step("Remove file and create a new one."): with TestRun.step("Remove file and create a new one."):
cache_iostats_before = cache_dev.get_io_stats() cache_iostats_before = cache_dev.get_io_stats()
data_reads_before = cache.get_io_class_statistics(io_class_id=0).block_stats.cache.reads data_reads_before = cache.get_io_class_statistics(io_class_id=0).block_stats.cache.reads
metadata_reads_before = cache.get_io_class_statistics(io_class_id=1).block_stats.cache.reads metadata_reads_before = cache.get_io_class_statistics(
io_class_id=1
).block_stats.cache.reads
test_file.remove() test_file.remove()
os_utils.sync() os_utils.sync()
os_utils.drop_caches() os_utils.drop_caches()
@ -106,16 +108,19 @@ def test_trim_eviction(cache_mode, cache_line_size, filesystem, cleaning):
) )
else: else:
TestRun.LOGGER.info( TestRun.LOGGER.info(
"Number of reads from cache before and after removing test file is the same.") "Number of reads from cache before and after removing test file is the same."
)
def create_file_with_ddrescue(core_dev, test_file_path): def create_file_with_ddrescue(core_dev, test_file_path):
dd = Dd() \ dd = (
.block_size(Size(1, Unit.MebiByte)) \ Dd()
.count(900) \ .block_size(Size(1, Unit.MebiByte))
.input("/dev/urandom") \ .count(900)
.output(test_file_path) \ .input("/dev/urandom")
.oflag("sync") .output(test_file_path)
.oflag("sync")
)
dd.run() dd.run()
return File(test_file_path) return File(test_file_path)