projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
steadystate: implement transmission of steadystate data over the wire in client/serve...
[fio.git]
/
io_u.c
diff --git
a/io_u.c
b/io_u.c
index 34acc5698e37cc4b7f1e8572ffa55ecd49d342bb..22701274cf3cc5aa2fe78d70a0d25171432281df 100644
(file)
--- a/
io_u.c
+++ b/
io_u.c
@@
-768,7
+768,7
@@
static void set_rw_ddir(struct thread_data *td, struct io_u *io_u)
io_u->ddir = io_u->acct_ddir = ddir;
io_u->ddir = io_u->acct_ddir = ddir;
- if (io_u->ddir == DDIR_WRITE &&
(td->io_ops->flags &
FIO_BARRIER) &&
+ if (io_u->ddir == DDIR_WRITE &&
td_ioengine_flagged(td,
FIO_BARRIER) &&
td->o.barrier_blocks &&
!(td->io_issues[DDIR_WRITE] % td->o.barrier_blocks) &&
td->io_issues[DDIR_WRITE])
td->o.barrier_blocks &&
!(td->io_issues[DDIR_WRITE] % td->o.barrier_blocks) &&
td->io_issues[DDIR_WRITE])
@@
-843,7
+843,7
@@
static int fill_io_u(struct thread_data *td, struct io_u *io_u)
{
unsigned int is_random;
{
unsigned int is_random;
- if (td
->io_ops->flags & FIO_NOIO
)
+ if (td
_ioengine_flagged(td, FIO_NOIO)
)
goto out;
set_rw_ddir(td, io_u);
goto out;
set_rw_ddir(td, io_u);
@@
-1622,7
+1622,7
@@
struct io_u *get_io_u(struct thread_data *td)
assert(fio_file_open(f));
if (ddir_rw(io_u->ddir)) {
assert(fio_file_open(f));
if (ddir_rw(io_u->ddir)) {
- if (!io_u->buflen && !
(td->io_ops->flags &
FIO_NOIO)) {
+ if (!io_u->buflen && !
td_ioengine_flagged(td,
FIO_NOIO)) {
dprint(FD_IO, "get_io_u: zero buflen on %p\n", io_u);
goto err_put;
}
dprint(FD_IO, "get_io_u: zero buflen on %p\n", io_u);
goto err_put;
}