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

pyocf: volume offlining

Browse Source 
Signed-off-by: Adam Rutkowski <adam.j.rutkowski@intel.com>
This commit is contained in:
Adam Rutkowski 2021-10-27 16:07:51 +02:00
parent 33b134242b
commit 7cb9523d8c
1 changed files with 34 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
tests/functional/pyocf/types/volume.py
View File

@ -239,6 +239,7 @@ class Volume:
type(self)._uuid_[self.uuid] = self type(self)._uuid_[self.uuid] = self
self.reset_stats() self.reset_stats()
self.is_online = True
self.opened = False self.opened = False
def do_open(self): def do_open(self):
@ -254,10 +255,10 @@ class Volume:
def get_max_io_size(self): def get_max_io_size(self):
raise NotImplementedError raise NotImplementedError
def submit_flush(self, flush): def do_submit_flush(self, flush):
raise NotImplementedError raise NotImplementedError
def submit_discard(self, discard): def do_submit_discard(self, discard):
raise NotImplementedError raise NotImplementedError
def get_stats(self): def get_stats(self):
@ -269,10 +270,6 @@ class Volume:
def inc_stats(self, _dir): def inc_stats(self, _dir):
self.stats[_dir] += 1 self.stats[_dir] += 1
def submit_io(self, io):
volume.inc_stats(IoDir(io.contents._dir))
volume.do_submit_io(io)
def do_submit_io(self, io): def do_submit_io(self, io):
raise NotImplementedError raise NotImplementedError
@ -282,6 +279,35 @@ class Volume:
def md5(self): def md5(self):
raise NotImplementedError raise NotImplementedError
def offline(self):
self.is_online = False
def online(self):
self.is_online = True
def _reject_io(self, io):
cast(io, POINTER(Io)).contents._end(io, -OcfErrorCode.OCF_ERR_IO)
def submit_flush(self, io):
if self.is_online:
self.do_submit_flush(io)
else:
self._reject_io(io)
def submit_io(self, io):
if self.is_online:
self.inc_stats(IoDir(io.contents._dir))
self.do_submit_io(io)
else:
self._reject_io(io)
def submit_discard(self, io):
if self.is_online:
self.do_submit_discard(io)
else:
self._reject_io(io)
class RamVolume(Volume): class RamVolume(Volume):
props = None props = None
@ -309,10 +335,10 @@ class RamVolume(Volume):
def get_max_io_size(self): def get_max_io_size(self):
return S.from_KiB(128) return S.from_KiB(128)
def submit_flush(self, flush): def do_submit_flush(self, flush):
flush.contents._end(flush, 0) flush.contents._end(flush, 0)
def submit_discard(self, discard): def do_submit_discard(self, discard):
try: try:
dst = self.data_ptr + discard.contents._addr dst = self.data_ptr + discard.contents._addr
memset(dst, 0, discard.contents._bytes) memset(dst, 0, discard.contents._bytes)