github/ocf
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add remove_core fcn

Browse Source 
Signed-off-by: Jan Musial <jan.musial@intel.com>
This commit is contained in:
Jan Musial 2019-04-04 10:58:29 +02:00
parent d9d4f2fab1
commit be773a45af
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
tests/functional/pyocf/types/cache.py
View File

@ -20,6 +20,7 @@ from ctypes import (
from enum import IntEnum from enum import IntEnum
from datetime import timedelta from datetime import timedelta
from ..ocf import OcfLib
from .shared import Uuid, OcfError, CacheLineSize, CacheLines, OcfCompletion from .shared import Uuid, OcfError, CacheLineSize, CacheLines, OcfCompletion
from ..utils import Size, struct_to_dict from ..utils import Size, struct_to_dict
from .core import Core from .core import Core
@ -289,6 +290,27 @@ class Cache:
self.put_and_write_unlock() self.put_and_write_unlock()
def remove_core(self, core: Core):
self.get_and_write_lock()
c = OcfCompletion(
[
("priv", c_void_p),
("error", c_int),
]
)
self.owner.lib.ocf_mngt_cache_remove_core(
core.handle, c, None
)
c.wait()
if c.results["error"]:
self.put_and_write_unlock()
raise OcfError("Failed removing core", c.results["error"])
self.put_and_write_unlock()
def get_stats(self): def get_stats(self):
cache_info = CacheInfo() cache_info = CacheInfo()
usage = UsageStats() usage = UsageStats()
@ -389,3 +411,7 @@ class Cache:
self.put_and_write_unlock() self.put_and_write_unlock()
self.owner.caches.remove(self) self.owner.caches.remove(self)
lib = OcfLib.getInstance()
lib.ocf_mngt_cache_remove_core.argtypes = [c_void_p, c_void_p, c_void_p]
lib.ocf_mngt_cache_add_core.argtypes = [c_void_p, c_void_p, c_void_p, c_void_p]