/external/fio/ |
D | eta.c | 59 else if (td->o.rwmix[DDIR_WRITE] == 100) in check_str_update() 66 else if (td->o.rwmix[DDIR_WRITE] == 100) in check_str_update() 194 if (td->o.rwmix[DDIR_WRITE]) in thread_eta() 195 perc = td->o.rwmix[DDIR_WRITE]; in thread_eta() 273 rate_bytes += td->o.rate[DDIR_WRITE]; in thread_eta() 389 io_bytes[DDIR_READ] = io_bytes[DDIR_WRITE] = io_bytes[DDIR_TRIM] = 0; in calc_thread_status() 390 io_iops[DDIR_READ] = io_iops[DDIR_WRITE] = io_iops[DDIR_TRIM] = 0; in calc_thread_status() 412 je->t_rate[1] += td->o.rate[DDIR_WRITE]; in calc_thread_status() 413 je->t_iops[1] += td->o.rate_iops[DDIR_WRITE]; in calc_thread_status() 414 je->m_rate[1] += td->o.ratemin[DDIR_WRITE]; in calc_thread_status() [all …]
|
D | init.c | 536 if (td->o.rate[DDIR_WRITE] || td->o.rate_iops[DDIR_WRITE]) in setup_rate() 537 ret |= __setup_rate(td, DDIR_WRITE); in setup_rate() 547 o->min_bs[DDIR_WRITE] == o->max_bs[DDIR_WRITE] && in fixed_block_size() 549 o->min_bs[DDIR_READ] == o->min_bs[DDIR_WRITE] && in fixed_block_size() 630 if (!o->min_bs[DDIR_WRITE]) in fixup_options() 631 o->min_bs[DDIR_WRITE] = o->bs[DDIR_WRITE]; in fixup_options() 632 if (!o->max_bs[DDIR_WRITE]) in fixup_options() 633 o->max_bs[DDIR_WRITE] = o->bs[DDIR_WRITE]; in fixup_options() 639 o->rw_min_bs = min(o->min_bs[DDIR_READ], o->min_bs[DDIR_WRITE]); in fixup_options() 647 if (!o->ba[DDIR_WRITE] || !td_random(td)) in fixup_options() [all …]
|
D | io_ddir.h | 6 DDIR_WRITE = 1, enumerator 59 return ddir == DDIR_READ || ddir == DDIR_WRITE || ddir == DDIR_TRIM; in ddir_rw() 72 ((arr)[DDIR_READ] + (arr)[DDIR_WRITE] + (arr)[DDIR_TRIM])
|
D | blktrace.c | 237 ipo->ddir = DDIR_WRITE; in store_ipo() 381 return DDIR_WRITE; in t_get_ddir() 534 if (!ios[DDIR_READ] && !ios[DDIR_WRITE]) { in load_blktrace() 537 } else if (ios[DDIR_READ] && !ios[DDIR_WRITE]) { in load_blktrace() 540 } else if (!ios[DDIR_READ] && ios[DDIR_WRITE]) { in load_blktrace() 542 td->o.max_bs[DDIR_WRITE] = rw_bs[DDIR_WRITE]; in load_blktrace() 546 td->o.max_bs[DDIR_WRITE] = rw_bs[DDIR_WRITE]; in load_blktrace()
|
D | backend.c | 232 if (td->bytes_done[DDIR_WRITE]) in check_min_rate() 233 ret |= __check_min_rate(td, now, DDIR_WRITE); in check_min_rate() 370 if (ddir == DDIR_WRITE && td_write(td) && td->o.verify_only) in update_runtime() 450 __should_check_rate(td, DDIR_WRITE) || in wait_for_completions() 510 __should_check_rate(td, DDIR_WRITE) || in io_queue_event() 692 } else if (io_u->ddir == DDIR_WRITE) { in do_verify() 771 bytes = this_bytes[DDIR_READ] + this_bytes[DDIR_WRITE]; in io_bytes_exceeded() 773 bytes = this_bytes[DDIR_WRITE]; in io_bytes_exceeded() 960 if (td_write(td) && io_u->ddir == DDIR_WRITE && in do_io() 1155 min_write = td->o.min_bs[DDIR_WRITE]; in init_io_u() [all …]
|
D | io_u.c | 541 ddir = is_random ? DDIR_WRITE: DDIR_READ; in __get_next_buflen() 626 return DDIR_WRITE; in get_rand_ddir() 724 if (td->o.fsync_blocks && td->io_issues[DDIR_WRITE] && in get_rw_ddir() 725 !(td->io_issues[DDIR_WRITE] % td->o.fsync_blocks)) in get_rw_ddir() 728 if (td->o.fdatasync_blocks && td->io_issues[DDIR_WRITE] && in get_rw_ddir() 729 !(td->io_issues[DDIR_WRITE] % td->o.fdatasync_blocks)) in get_rw_ddir() 732 if (td->sync_file_range_nr && td->io_issues[DDIR_WRITE] && in get_rw_ddir() 733 !(td->io_issues[DDIR_WRITE] % td->sync_file_range_nr)) in get_rw_ddir() 758 ddir = DDIR_WRITE; in get_rw_ddir() 774 if (f->last_pos[DDIR_WRITE] == f->last_pos[DDIR_TRIM]) in set_rw_ddir() [all …]
|
D | fio.h | 504 assert(!(io_u->ddir == DDIR_WRITE && !td_write(td))); in fio_ro_check() 711 if (td->bytes_done[DDIR_WRITE] && __should_check_rate(td, DDIR_WRITE)) in should_check_rate() 723 max_bs = max(td->o.max_bs[DDIR_READ], td->o.max_bs[DDIR_WRITE]); in td_max_bs() 731 min_bs = min(td->o.min_bs[DDIR_READ], td->o.min_bs[DDIR_WRITE]); in td_min_bs()
|
D | options.c | 202 ret = fn(&td->o, DDIR_WRITE, odir + 1); in str_split_parse() 211 ret = fn(&td->o, DDIR_WRITE, op); in str_split_parse() 415 td->o.rwmix[DDIR_WRITE] = 100 - *val; in str_rwmix_read_cb() 423 td->o.rwmix[DDIR_WRITE] = *val; in str_rwmix_write_cb() 1977 .off2 = offsetof(struct thread_options, bs[DDIR_WRITE]), 1994 .off2 = offsetof(struct thread_options, ba[DDIR_WRITE]), 2011 .off3 = offsetof(struct thread_options, min_bs[DDIR_WRITE]), 2012 .off4 = offsetof(struct thread_options, max_bs[DDIR_WRITE]), 2177 .off2 = offsetof(struct thread_options, perc_rand[DDIR_WRITE]), 3155 .off1 = offsetof(struct thread_options, rwmix[DDIR_WRITE]), [all …]
|
D | stat.c | 740 if (ts->io_bytes[DDIR_WRITE]) in show_thread_status_normal() 741 show_ddir_status(rs, ts, DDIR_WRITE, out); in show_thread_status_normal() 1027 show_ddir_status_terse(ts, rs, DDIR_WRITE, out); in show_thread_status_terse_v2() 1091 show_ddir_status_terse(ts, rs, DDIR_WRITE, out); in show_thread_status_terse_v3_v4() 1197 add_ddir_status_json(ts, rs, DDIR_WRITE, root); in show_thread_status_json() 1860 td->ts.io_bytes[DDIR_WRITE] = td->io_bytes[DDIR_WRITE]; in __show_running_run_stats() 1867 if (td_write(td) && td->ts.io_bytes[DDIR_WRITE]) in __show_running_run_stats() 1868 td->ts.runtime[DDIR_WRITE] += rt[i]; in __show_running_run_stats() 1888 if (td_write(td) && td->ts.io_bytes[DDIR_WRITE]) in __show_running_run_stats() 1889 td->ts.runtime[DDIR_WRITE] -= rt[i]; in __show_running_run_stats()
|
D | rate-submit.c | 218 sum_ddir(dst, src, DDIR_WRITE); in io_workqueue_update_acct_fn()
|
/external/fio/engines/ |
D | sync.c | 112 else if (io_u->ddir == DDIR_WRITE) in fio_pvsyncio_queue() 143 else if (io_u->ddir == DDIR_WRITE) in fio_pvsyncio2_queue() 165 else if (io_u->ddir == DDIR_WRITE) in fio_psyncio_queue() 185 else if (io_u->ddir == DDIR_WRITE) in fio_syncio_queue()
|
D | ftruncate.c | 26 if (io_u->ddir != DDIR_WRITE) { in fio_ftruncate_queue()
|
D | libhdfs.c | 149 } else if (io_u->ddir == DDIR_WRITE) { in fio_hdfsio_prep() 177 if( (io_u->ddir == DDIR_READ || io_u->ddir == DDIR_WRITE) && in fio_hdfsio_queue() 191 } else if (io_u->ddir == DDIR_WRITE) { in fio_hdfsio_queue()
|
D | guasi.c | 68 io_u->ddir == DDIR_WRITE) { in fio_guasi_event() 166 else if (io_u->ddir == DDIR_WRITE) in fio_guasi_commit()
|
D | glusterfs.c | 181 b = malloc(td->o.max_bs[DDIR_WRITE]); in fio_gf_open_file() 185 bs = td->o.max_bs[DDIR_WRITE]; in fio_gf_open_file()
|
D | falloc.c | 83 else if (io_u->ddir == DDIR_WRITE) in fio_fallocate_queue()
|
D | net.c | 342 if ((o->listen && io_u->ddir == DDIR_WRITE) || in fio_netio_prep() 556 if ((td->this_io_bytes[DDIR_WRITE] + io_u->xfer_buflen < in fio_netio_send() 654 if (ddir == DDIR_WRITE) { in __fio_netio_queue() 679 if (ddir == DDIR_WRITE && err == EMSGSIZE) in __fio_netio_queue() 707 ret = __fio_netio_queue(td, io_u, DDIR_WRITE); in fio_netio_queue() 708 else if (td_write(td) && io_u->ddir == DDIR_WRITE) in fio_netio_queue()
|
D | glusterfs_sync.c | 42 else if (io_u->ddir == DDIR_WRITE) in fio_gf_queue()
|
D | fusion-aw.c | 42 if (io_u->ddir != DDIR_WRITE) { in queue()
|
D | glusterfs_async.c | 112 else if (io_u->ddir == DDIR_WRITE) in fio_gf_async_queue()
|
D | mtd.c | 95 } else if (io_u->ddir == DDIR_WRITE) { in fio_mtd_queue()
|
D | e4defrag.c | 150 if (io_u->ddir != DDIR_WRITE) { in fio_e4defrag_queue()
|
D | posixaio.c | 180 else if (io_u->ddir == DDIR_WRITE) in fio_posixaio_queue()
|
D | splice.c | 222 } else if (io_u->ddir == DDIR_WRITE) in fio_spliceio_queue()
|
D | mmap.c | 174 else if (io_u->ddir == DDIR_WRITE) in fio_mmapio_queue()
|