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

improve test_ioclass_file_size

Browse Source 
- add sync and drop caches after 'dd' commands

Signed-off-by: Karolina Rogowska <karolina.rogowska@intel.com>
This commit is contained in:
Karolina Rogowska 2021-05-11 15:04:01 +02:00
parent a226b39c4e
commit 3e7c51a2fc
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/functional/tests/io_class/test_io_class_file.py
View File

@ -4,6 +4,7 @@
# #
import random import random
import pytest import pytest
from api.cas import ioclass_config, casadm from api.cas import ioclass_config, casadm
@ -387,6 +388,8 @@ def test_ioclass_file_size(filesystem):
io_class_id=ioclass_id).usage_stats.occupancy io_class_id=ioclass_id).usage_stats.occupancy
file_path = f"{mountpoint}/test_file_{size.get_value()}" file_path = f"{mountpoint}/test_file_{size.get_value()}"
Dd().input("/dev/zero").output(file_path).oflag("sync").block_size(size).count(1).run() Dd().input("/dev/zero").output(file_path).oflag("sync").block_size(size).count(1).run()
sync()
drop_caches(DropCachesMode.ALL)
occupancy_after = cache.get_io_class_statistics( occupancy_after = cache.get_io_class_statistics(
io_class_id=ioclass_id).usage_stats.occupancy io_class_id=ioclass_id).usage_stats.occupancy
if occupancy_after != occupancy_before + size: if occupancy_after != occupancy_before + size:
@ -420,10 +423,13 @@ def test_ioclass_file_size(filesystem):
occupancy_before = cache.get_io_class_statistics(io_class_id=0).usage_stats.occupancy occupancy_before = cache.get_io_class_statistics(io_class_id=0).usage_stats.occupancy
for file in test_files: for file in test_files:
Dd().input(file.full_path).output("/dev/null").block_size(file.size).run() Dd().input(file.full_path).output("/dev/null").block_size(file.size).run()
sync()
drop_caches(DropCachesMode.ALL)
occupancy_after = cache.get_io_class_statistics(io_class_id=0).usage_stats.occupancy occupancy_after = cache.get_io_class_statistics(io_class_id=0).usage_stats.occupancy
if occupancy_after != occupancy_before + file.size: occupancy_expected = occupancy_before + file.size
if occupancy_after != occupancy_expected:
TestRun.fail("File not reclassified properly!\n" TestRun.fail("File not reclassified properly!\n"
f"Expected {occupancy_before + file.size}\n" f"Expected {occupancy_expected}\n"
f"Actual {occupancy_after}") f"Actual {occupancy_after}")
occupancy_before = occupancy_after occupancy_before = occupancy_after
sync() sync()
@ -453,6 +459,8 @@ def test_ioclass_file_size(filesystem):
occupancy_before = cache.get_io_class_statistics( occupancy_before = cache.get_io_class_statistics(
io_class_id=ioclass_id).usage_stats.occupancy io_class_id=ioclass_id).usage_stats.occupancy
Dd().input(file.full_path).output("/dev/null").block_size(file.size).run() Dd().input(file.full_path).output("/dev/null").block_size(file.size).run()
sync()
drop_caches(DropCachesMode.ALL)
occupancy_after = cache.get_io_class_statistics( occupancy_after = cache.get_io_class_statistics(
io_class_id=ioclass_id).usage_stats.occupancy io_class_id=ioclass_id).usage_stats.occupancy
actual_blocks = occupancy_after.get_value(Unit.Blocks4096) actual_blocks = occupancy_after.get_value(Unit.Blocks4096)