fix test_check_number_of_processes

Signed-off-by: Karolina Rogowska <karolina.rogowska@intel.com>
This commit is contained in:
Karolina Rogowska 2022-07-26 16:11:14 +02:00
parent 8062417d10
commit 170f62a2ba

View File

@ -1,5 +1,5 @@
# #
# Copyright(c) 2020 Intel Corporation # Copyright(c) 2020-2022 Intel Corporation
# SPDX-License-Identifier: BSD-3-Clause # SPDX-License-Identifier: BSD-3-Clause
# #
@ -15,7 +15,6 @@ from test_utils.size import Size, Unit
cleaning_threads_expected = 1 cleaning_threads_expected = 1
management_thread_expected = 1 management_thread_expected = 1
fill_threads_expected = 0 fill_threads_expected = 0
metadata_updater_threads_expected = 1
@pytest.mark.require_disk("cache", DiskTypeSet([DiskType.optane, DiskType.nand])) @pytest.mark.require_disk("cache", DiskTypeSet([DiskType.optane, DiskType.nand]))
@ -25,7 +24,7 @@ def test_check_number_of_processes():
title: Check the number of processes created by CAS. title: Check the number of processes created by CAS.
description: | description: |
For created CAS device check number of IO threads, cleaning threads, management threads, For created CAS device check number of IO threads, cleaning threads, management threads,
fill threads, metadata updater threads. fill threads.
pass_criteria: pass_criteria:
- Successful CAS creation. - Successful CAS creation.
- Successful validation of each thread number. - Successful validation of each thread number.
@ -64,12 +63,6 @@ def test_check_number_of_processes():
fill_threads_actual = get_number_of_processes("cas_wb") fill_threads_actual = get_number_of_processes("cas_wb")
validate_threads_number("fill threads", fill_threads_actual, fill_threads_expected) validate_threads_number("fill threads", fill_threads_actual, fill_threads_expected)
with TestRun.step("Check number of metadata updater threads."):
metadata_updater_threads_actual = get_number_of_processes("cas_mu")
validate_threads_number("metadata updater threads", metadata_updater_threads_actual,
metadata_updater_threads_expected)
def validate_threads_number(threads_name, threads_number, threads_expected): def validate_threads_number(threads_name, threads_number, threads_expected):
if threads_number == threads_expected: if threads_number == threads_expected: