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

pyocf: rio: reads and writes accounting

Browse Source 
Signed-off-by: Michal Mielewczyk <michal.mielewczyk@huawei.com>
This commit is contained in:
Michal Mielewczyk 2024-10-02 14:43:20 +02:00
parent 818dacfe89
commit 6ec4f6cceb
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/functional/pyocf/rio.py
View File

@ -87,6 +87,8 @@ class Rio:
self.ios = Size(0) self.ios = Size(0)
self.io_target = 0 self.io_target = 0
self.finish_time = None self.finish_time = None
self.submitted_reads = 0
self.submitted_writes = 0
self.qd_condition = Condition() self.qd_condition = Condition()
self.qd = 0 self.qd = 0
@ -159,6 +161,12 @@ class Rio:
io.callback = self.get_io_cb() io.callback = self.get_io_cb()
self.ios += self.jobspec.bs self.ios += self.jobspec.bs
io.submit() io.submit()
if iodir is IoDir.WRITE:
self.submitted_writes += 1
if iodir is IoDir.READ:
self.submitted_reads += 1
with self.qd_condition: with self.qd_condition:
self.qd += 1 self.qd += 1
@ -172,6 +180,8 @@ class Rio:
self._threads = [] self._threads = []
self.errors = {} self.errors = {}
self.error_count = 0 self.error_count = 0
self.submitted_reads = 0
self.submitted_writes = 0
def copy(self): def copy(self):
r = copy.copy(self) r = copy.copy(self)
@ -254,6 +264,8 @@ class Rio:
thread.join() thread.join()
self.errors.update({thread.name: thread.errors}) self.errors.update({thread.name: thread.errors})
self.error_count += len(thread.errors) self.error_count += len(thread.errors)
self.submitted_reads += thread.submitted_reads
self.submitted_writes += thread.submitted_writes
self.global_jobspec.target.close() self.global_jobspec.target.close()