• Home
  • Raw
  • Download

Lines Matching refs:ddir

145 			    enum fio_ddir ddir)  in __check_min_rate()  argument
155 assert(ddir_rw(ddir)); in __check_min_rate()
157 if (!td->o.ratemin[ddir] && !td->o.rate_iops_min[ddir]) in __check_min_rate()
166 iops += td->this_io_blocks[ddir]; in __check_min_rate()
167 bytes += td->this_io_bytes[ddir]; in __check_min_rate()
168 ratemin += td->o.ratemin[ddir]; in __check_min_rate()
169 rate_iops += td->o.rate_iops[ddir]; in __check_min_rate()
170 rate_iops_min += td->o.rate_iops_min[ddir]; in __check_min_rate()
175 if (td->rate_bytes[ddir] || td->rate_blocks[ddir]) { in __check_min_rate()
176 spent = mtime_since(&td->lastrate[ddir], now); in __check_min_rate()
180 if (td->o.rate[ddir]) { in __check_min_rate()
184 if (bytes < td->rate_bytes[ddir]) { in __check_min_rate()
190 rate = ((bytes - td->rate_bytes[ddir]) * 1000) / spent; in __check_min_rate()
195 bytes < td->rate_bytes[ddir]) { in __check_min_rate()
212 rate = ((iops - td->rate_blocks[ddir]) * 1000) / spent; in __check_min_rate()
217 iops < td->rate_blocks[ddir]) { in __check_min_rate()
226 td->rate_bytes[ddir] = bytes; in __check_min_rate()
227 td->rate_blocks[ddir] = iops; in __check_min_rate()
228 memcpy(&td->lastrate[ddir], now, sizeof(*now)); in __check_min_rate()
294 io_u->ddir = DDIR_SYNC; in fio_io_sync()
366 static int break_on_this_error(struct thread_data *td, enum fio_ddir ddir, in break_on_this_error() argument
378 eb = td_error_type(ddir, err); in break_on_this_error()
485 enum fio_ddir ddir; in do_verify() local
532 if (io_u->ddir == DDIR_READ) { in do_verify()
540 } else if (io_u->ddir == DDIR_TRIM) { in do_verify()
541 io_u->ddir = DDIR_READ; in do_verify()
544 } else if (io_u->ddir == DDIR_WRITE) { in do_verify()
545 io_u->ddir = DDIR_READ; in do_verify()
567 ddir = io_u->ddir; in do_verify()
593 if (ddir_rw(io_u->ddir)) in do_verify()
594 td->ts.short_io_u[io_u->ddir]++; in do_verify()
622 if (break_on_this_error(td, ddir, &ret)) in do_verify()
753 enum fio_ddir ddir; in do_io() local
790 ddir = io_u->ddir; in do_io()
797 if (td->o.verify != VERIFY_NONE && io_u->ddir == DDIR_READ && in do_io()
826 if (td_write(td) && io_u->ddir == DDIR_WRITE && in do_io()
861 if (ddir_rw(io_u->ddir)) in do_io()
862 td->ts.short_io_u[io_u->ddir]++; in do_io()
904 if (break_on_this_error(td, ddir, &ret)) in do_io()
1281 if (ddir_rw(io_u->ddir)) { in do_dry_run()
1283 td->ts.total_io_u[io_u->ddir]++; in do_dry_run()
1286 if (td_write(td) && io_u->ddir == DDIR_WRITE && in do_dry_run()