pyocf: Various improvements in RIO

Signed-off-by: Jan Musial <jan.musial@intel.com>
This commit is contained in:
Jan Musial 2022-05-18 11:07:36 +02:00
parent 438b6d158e
commit 3b7d25737b

View File

@ -124,9 +124,9 @@ class Rio:
def run(self):
iogen = IoGen(
(self.jobspec.offset, self.jobspec.size),
(self.jobspec.offset, self.jobspec.size - self.jobspec.offset),
self.jobspec.bs,
self.jobspec.randseed,
self.jobspec.randseed + hash(self.name),
self.jobspec.readwrite.is_random(),
self.jobspec.randommap,
)
@ -150,7 +150,7 @@ class Rio:
while not self.should_finish():
with self.qd_condition:
self.qd_condition.wait_for(lambda: self.qd <= self.jobspec.qd)
self.qd_condition.wait_for(lambda: self.qd < self.jobspec.qd)
data = Data(self.jobspec.bs) # TODO pattern and verify
io = self.jobspec.target.new_io(
@ -195,6 +195,10 @@ class Rio:
self.global_jobspec.randommap = False
return self
def randseed(self, seed):
self.global_jobspec.randseed = seed
return self
def bs(self, bs: Size):
self.global_jobspec.bs = bs
return self