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

test-api: update parser

Browse Source 
Signed-off-by: Kamil Gierszewski <kamil.gierszewski@huawei.com>
This commit is contained in:
Kamil Gierszewski 2025-01-02 03:47:03 +01:00
parent 8cd3f4a631
commit 0e24e52686
No known key found for this signature in database
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/functional/api/cas/casadm_parser.py
View File

@ -59,7 +59,7 @@ def get_cores(cache_id: int) -> list:
cores_dict = get_cas_devices_dict()["cores"].values() cores_dict = get_cas_devices_dict()["cores"].values()
def is_active(core): def is_active(core):
return CoreStatus[core["status"].lower()] == CoreStatus.active return core["status"] == CoreStatus.active
return [ return [
Core(core["device_path"], core["cache_id"]) Core(core["device_path"], core["cache_id"])
@ -74,7 +74,7 @@ def get_inactive_cores(cache_id: int) -> list:
cores_dict = get_cas_devices_dict()["cores"].values() cores_dict = get_cas_devices_dict()["cores"].values()
def is_inactive(core): def is_inactive(core):
return CoreStatus[core["status"].lower()] == CoreStatus.inactive return core["status"] == CoreStatus.inactive
return [ return [
Core(core["device_path"], core["cache_id"]) Core(core["device_path"], core["cache_id"])
@ -89,7 +89,7 @@ def get_detached_cores(cache_id: int) -> list:
cores_dict = get_cas_devices_dict()["cores"].values() cores_dict = get_cas_devices_dict()["cores"].values()
def is_detached(core): def is_detached(core):
return CoreStatus[core["status"].lower()] == CoreStatus.detached return core["status"] == CoreStatus.detached
return [ return [
Core(core["device_path"], core["cache_id"]) Core(core["device_path"], core["cache_id"])
@ -110,15 +110,17 @@ def get_cas_devices_dict() -> dict:
params = [ params = [
("id", cache_id), ("id", cache_id),
("device_path", device["disk"]), ("device_path", device["disk"]),
("status", device["status"]), ("status", CacheStatus(device["status"].lower())),
] ]
devices["caches"][cache_id] = dict([(key, value) for key, value in params]) devices["caches"][cache_id] = dict([(key, value) for key, value in params])
elif device["type"] == "core": elif device["type"] == "core":
params = [ params = [
("cache_id", cache_id), ("cache_id", cache_id),
("core_id", (int(device["id"]) if device["id"] != "-" else device["id"])),
("device_path", device["disk"]), ("device_path", device["disk"]),
("status", device["status"]), ("status", CoreStatus(device["status"].lower())),
("exp_obj", device["device"]),
] ]
if core_pool: if core_pool:
params.append(("core_pool", device)) params.append(("core_pool", device))