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

tests: Wrappers for purge commands

Browse Source 
Signed-off-by: Michal Mielewczyk <michal.mielewczyk@intel.com>
This commit is contained in:
Michal Mielewczyk 2020-05-11 06:24:40 -04:00
parent 3b62e40a2e
commit c28babde8b
4 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/functional/api/cas/cache.py
View File

@ -117,6 +117,10 @@ class Cache:
sync() sync()
assert self.get_dirty_blocks().get_value(Unit.Blocks4096) == 0 assert self.get_dirty_blocks().get_value(Unit.Blocks4096) == 0
def purge_cache(self):
casadm.purge_cache(cache_id=self.cache_id)
sync()
def stop(self, no_data_flush: bool = False): def stop(self, no_data_flush: bool = False):
return casadm.stop_cache(self.cache_id, no_data_flush) return casadm.stop_cache(self.cache_id, no_data_flush)

14
test/functional/api/cas/casadm.py
View File

@ -79,6 +79,20 @@ def try_add(core_device: Device, cache_id: int):
return Core(core_device.system_path, cache_id) return Core(core_device.system_path, cache_id)
def purge_cache(cache_id: int):
output = TestRun.executor.run(script_purge_cache(str(cache_id)))
if output.exit_code != 0:
raise CmdException("Purge cache failed.", output)
return output
def purge_core(cache_id: int, core_id: int):
output = TestRun.executor.run(script_purge_core(str(cache_id), str(core_id)))
if output.exit_code != 0:
raise CmdException("Purge core failed.", output)
return output
def reset_counters(cache_id: int, core_id: int = None, shortcut: bool = False): def reset_counters(cache_id: int, core_id: int = None, shortcut: bool = False):
_core_id = None if core_id is None else str(core_id) _core_id = None if core_id is None else str(core_id)
output = TestRun.executor.run( output = TestRun.executor.run(

8
test/functional/api/cas/cli.py
View File

@ -24,6 +24,14 @@ def script_try_add_cmd(cache_id: str, core_dev: str):
f"--core-device {core_dev}" f"--core-device {core_dev}"
def script_purge_cache_cmd(cache_id: str):
return f"{casadm_bin} --script --purge-cache --cache-id {cache_id}"
def script_purge_core_cmd(cache_id: str, core_id: str):
return f"{casadm_bin} --script --purge-core --cache-id {cache_id} --core-id {core_id}"
def remove_core_cmd(cache_id: str, core_id: str, force: bool = False, shortcut: bool = False): def remove_core_cmd(cache_id: str, core_id: str, force: bool = False, shortcut: bool = False):
command = f" -R -i {cache_id} -j {core_id}" if shortcut \ command = f" -R -i {cache_id} -j {core_id}" if shortcut \
else f" --remove-core --cache-id {cache_id} --core-id {core_id}" else f" --remove-core --cache-id {cache_id} --core-id {core_id}"

4
test/functional/api/cas/core.py
View File

@ -111,6 +111,10 @@ class Core(Device):
sync() sync()
assert self.get_dirty_blocks().get_value(Unit.Blocks4096) == 0 assert self.get_dirty_blocks().get_value(Unit.Blocks4096) == 0
def purge_core(self):
casadm.purge_core(self.cache_id, self.core_id)
sync()
def set_seq_cutoff_parameters(self, seq_cutoff_param: SeqCutOffParameters): def set_seq_cutoff_parameters(self, seq_cutoff_param: SeqCutOffParameters):
return casadm.set_param_cutoff(self.cache_id, self.core_id, return casadm.set_param_cutoff(self.cache_id, self.core_id,
seq_cutoff_param.threshold, seq_cutoff_param.policy) seq_cutoff_param.threshold, seq_cutoff_param.policy)