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

tests: add disabling udev in fault injection test

Browse Source 
Signed-off-by: Kamil Gierszewski <kamil.gierszewski@huawei.com>
This commit is contained in:
Kamil Gierszewski 2024-10-02 12:20:21 +02:00
parent 1c26de3e7f
commit 5cada7a0ec
No known key found for this signature in database
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
test/functional/tests/fault_injection/test_fault_injection_interrupts.py
View File

@ -1,5 +1,6 @@
# #
# Copyright(c) 2020-2022 Intel Corporation # Copyright(c) 2020-2022 Intel Corporation
# Copyright(c) 2024 Huawei Technologies Co., Ltd.
# SPDX-License-Identifier: BSD-3-Clause # SPDX-License-Identifier: BSD-3-Clause
# #
@ -317,6 +318,9 @@ def test_interrupt_cache_mode_switch_parametrized(cache_mode, stop_percentage):
with TestRun.step("Prepare cache and core."): with TestRun.step("Prepare cache and core."):
cache_part, core_part = prepare() cache_part, core_part = prepare()
with TestRun.step("Disable udev"):
Udev.disable()
for _ in TestRun.iteration( for _ in TestRun.iteration(
range(iterations_per_config), f"Reload cache configuration {iterations_per_config} times." range(iterations_per_config), f"Reload cache configuration {iterations_per_config} times."
): ):
@ -331,16 +335,21 @@ def test_interrupt_cache_mode_switch_parametrized(cache_mode, stop_percentage):
core = cache.add_core(core_part) core = cache.add_core(core_part)
with TestRun.step(f"Create test file in mount point of exported object."): with TestRun.step(f"Create test file in mount point of exported object."):
test_file_size = Size(1024, Unit.MebiByte) test_file_size = Size(4, Unit.GibiByte)
test_file = fs_utils.create_random_test_file(test_file_path, test_file_size) test_file = fs_utils.create_random_test_file(test_file_path, test_file_size)
with TestRun.step("Check md5 sum of test file."): with TestRun.step("Check md5 sum of test file."):
test_file_md5_before = test_file.md5sum() test_file_md5_before = test_file.md5sum()
with TestRun.step("Export file to CAS"): with TestRun.step("Export file to CAS"):
Dd().block_size(test_file_size).input(test_file.full_path).output(core.path).oflag( dd = (
"direct" Dd()
).run() .block_size(test_file_size)
.input(test_file.full_path)
.output(core.path)
.oflag("direct")
)
dd.run()
with TestRun.step("Get number of dirty data on exported object before interruption."): with TestRun.step("Get number of dirty data on exported object before interruption."):
os_utils.sync() os_utils.sync()
@ -378,7 +387,7 @@ def test_interrupt_cache_mode_switch_parametrized(cache_mode, stop_percentage):
if cache.get_cache_mode() != cache_mode: if cache.get_cache_mode() != cache_mode:
TestRun.LOGGER.error("Cache mode should remain the same.") TestRun.LOGGER.error("Cache mode should remain the same.")
with TestRun.step("Unmount core and stop cache."): with TestRun.step("Stop cache."):
cache.stop() cache.stop()
with TestRun.step("Check md5 sum of test file again."): with TestRun.step("Check md5 sum of test file again."):