projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Make 'loops' honor full write+verify loops
[fio.git]
/
backend.c
diff --git
a/backend.c
b/backend.c
index 3430e6612d4312740f31045d6ebf6ff4ff96950b..fdb7413d7719ff9ff4b46af8e611c072c6918435 100644
(file)
--- a/
backend.c
+++ b/
backend.c
@@
-658,10
+658,10
@@
static unsigned int exceeds_number_ios(struct thread_data *td)
if (!td->o.number_ios)
return 0;
if (!td->o.number_ios)
return 0;
- number_ios = ddir_rw_sum(td->
this_
io_blocks);
+ number_ios = ddir_rw_sum(td->io_blocks);
number_ios += td->io_u_queued + td->io_u_in_flight;
number_ios += td->io_u_queued + td->io_u_in_flight;
- return number_ios >=
td->o.number_ios
;
+ return number_ios >=
(td->o.number_ios * td->loops)
;
}
static int io_issue_bytes_exceeded(struct thread_data *td)
}
static int io_issue_bytes_exceeded(struct thread_data *td)
@@
-682,6
+682,7
@@
static int io_issue_bytes_exceeded(struct thread_data *td)
else
limit = td->o.size;
else
limit = td->o.size;
+ limit *= td->loops;
return bytes >= limit || exceeds_number_ios(td);
}
return bytes >= limit || exceeds_number_ios(td);
}
@@
-703,6
+704,7
@@
static int io_complete_bytes_exceeded(struct thread_data *td)
else
limit = td->o.size;
else
limit = td->o.size;
+ limit *= td->loops;
return bytes >= limit || exceeds_number_ios(td);
}
return bytes >= limit || exceeds_number_ios(td);
}