| /external/fio/ |
| D | io_u.c | 54 enum fio_ddir ddir) in last_block() argument
59 assert(ddir_rw(ddir)); in last_block()
71 if (td->o.min_bs[ddir] > td->o.ba[ddir]) in last_block()
72 max_size -= td->o.min_bs[ddir] - td->o.ba[ddir]; in last_block()
74 max_blocks = max_size / (uint64_t) td->o.ba[ddir]; in last_block()
87 enum fio_ddir ddir, uint64_t *b) in __get_next_rand_offset() argument
94 lastb = last_block(td, f, ddir); in __get_next_rand_offset()
137 struct fio_file *f, enum fio_ddir ddir, in __get_next_rand_offset_zipf() argument
145 struct fio_file *f, enum fio_ddir ddir, in __get_next_rand_offset_pareto() argument
161 enum fio_ddir ddir, uint64_t *b) in get_off_from_method() argument
[all …]
|
| D | io_ddir.h | 17 static inline const char *io_ddir_name(enum fio_ddir ddir) in io_ddir_name() argument
22 if (ddir < DDIR_LAST) in io_ddir_name()
23 return name[ddir]; in io_ddir_name()
47 static inline int ddir_sync(enum fio_ddir ddir) in ddir_sync() argument
49 return ddir == DDIR_SYNC || ddir == DDIR_DATASYNC || in ddir_sync()
50 ddir == DDIR_SYNC_FILE_RANGE; in ddir_sync()
53 static inline int ddir_rw(enum fio_ddir ddir) in ddir_rw() argument
55 return ddir == DDIR_READ || ddir == DDIR_WRITE || ddir == DDIR_TRIM; in ddir_rw()
58 static inline const char *ddir_str(enum td_ddir ddir) in ddir_str() argument
64 return __str[ddir]; in ddir_str()
|
| D | stat.c | 364 int ddir) in show_ddir_status() argument
373 assert(ddir_rw(ddir)); in show_ddir_status()
375 if (!ts->runtime[ddir]) in show_ddir_status()
379 runt = ts->runtime[ddir]; in show_ddir_status()
381 bw = (1000 * ts->io_bytes[ddir]) / runt; in show_ddir_status()
382 io_p = num2str(ts->io_bytes[ddir], 6, 1, i2p, 8); in show_ddir_status()
385 iops = (1000 * (uint64_t)ts->total_io_u[ddir]) / runt; in show_ddir_status()
389 rs->unified_rw_rep ? "mixed" : str[ddir], in show_ddir_status()
391 (unsigned long long) ts->runtime[ddir]); in show_ddir_status()
397 if (calc_lat(&ts->slat_stat[ddir], &min, &max, &mean, &dev)) in show_ddir_status()
[all …]
|
| D | eta.c | 408 int ddir; in calc_thread_status() local
410 for (ddir = DDIR_READ; ddir < DDIR_RWDIR_CNT; ddir++) { in calc_thread_status()
412 io_bytes[0] += td->io_bytes[ddir]; in calc_thread_status()
413 io_iops[0] += td->io_blocks[ddir]; in calc_thread_status()
415 io_bytes[ddir] += td->io_bytes[ddir]; in calc_thread_status()
416 io_iops[ddir] += td->io_blocks[ddir]; in calc_thread_status()
513 int ddir; in display_thread_status() local
528 for (ddir = DDIR_READ; ddir < DDIR_RWDIR_CNT; ddir++) { in display_thread_status()
529 rate_str[ddir] = num2str(je->rate[ddir], 5, in display_thread_status()
531 iops_str[ddir] = num2str(je->iops[ddir], 4, 1, 0, 0); in display_thread_status()
[all …]
|
| D | libfio.c | 82 int ddir; in reset_io_counters() local
84 for (ddir = 0; ddir < DDIR_RWDIR_CNT; ddir++) { in reset_io_counters()
85 td->stat_io_bytes[ddir] = 0; in reset_io_counters()
86 td->this_io_bytes[ddir] = 0; in reset_io_counters()
87 td->stat_io_blocks[ddir] = 0; in reset_io_counters()
88 td->this_io_blocks[ddir] = 0; in reset_io_counters()
89 td->rate_bytes[ddir] = 0; in reset_io_counters()
90 td->rate_blocks[ddir] = 0; in reset_io_counters()
|
| D | backend.c | 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()
[all …]
|
| D | ioengines.c | 208 lock_file(td, io_u->file, io_u->ddir); in td_io_prep()
324 if (io_u->error == EINVAL && td->io_issues[io_u->ddir & 1] == 1 && in td_io_queue()
331 if (!td->io_ops->commit || io_u->ddir == DDIR_TRIM) { in td_io_queue()
337 if (ddir_rw(io_u->ddir)) { in td_io_queue()
339 td->ts.total_io_u[io_u->ddir]++; in td_io_queue()
344 if (ddir_rw(io_u->ddir)) { in td_io_queue()
346 td->ts.total_io_u[io_u->ddir]++; in td_io_queue()
550 if (io_u->ddir == DDIR_SYNC) { in do_io_u_sync()
552 } else if (io_u->ddir == DDIR_DATASYNC) { in do_io_u_sync()
559 } else if (io_u->ddir == DDIR_SYNC_FILE_RANGE) in do_io_u_sync()
|
| D | fio.h | 413 assert(!(io_u->ddir == DDIR_WRITE && !td_write(td))); in fio_ro_check()
563 enum fio_ddir ddir) in __should_check_rate() argument
570 if (o->rate[ddir] || o->ratemin[ddir] || o->rate_iops[ddir] || in __should_check_rate()
571 o->rate_iops_min[ddir]) in __should_check_rate()
|
| D | td_error.c | 7 enum error_type_bit td_error_type(enum fio_ddir ddir, int err) in td_error_type() argument
11 if (ddir == DDIR_READ) in td_error_type()
|
| D | iolog.h | 104 enum fio_ddir ddir) in io_sample_set_ddir() argument
106 io->__ddir = ddir | log->log_ddir_mask; in io_sample_set_ddir()
158 enum fio_ddir ddir; member
|
| D | ioengine.h | 40 enum fio_ddir ddir; member
230 io_u->buflen, io_u->ddir); in dprint_io_u()
247 return io_u->ddir; in acct_ddir()
|
| D | gclient.c | 1120 int ddir) argument
1122 unsigned int *io_u_plat = ts->io_u_plat[ddir];
1123 unsigned long nr = ts->clat_stat[ddir].samples;
1177 struct thread_stat *ts, int ddir) argument
1188 if (!ts->runtime[ddir])
1192 runt = ts->runtime[ddir];
1194 bw = (1000 * ts->io_bytes[ddir]) / runt;
1195 io_p = num2str(ts->io_bytes[ddir], 6, 1, i2p, 8);
1198 iops = (1000 * (uint64_t)ts->total_io_u[ddir]) / runt;
1204 frame = gtk_frame_new(ddir_label[ddir]);
[all …]
|
| D | blktrace.c | 124 ipo->ddir = DDIR_INVAL; in trace_add_open_close_event()
195 ipo->ddir = DDIR_WRITE; in store_ipo()
197 ipo->ddir = DDIR_READ; in store_ipo()
201 ipo->ddir, ipo->offset, in store_ipo()
251 ipo->ddir = DDIR_TRIM; in handle_trace_discard()
|
| /external/fio/engines/ |
| D | sync.c | 38 if (!ddir_rw(io_u->ddir)) in fio_syncio_prep()
54 if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir)) in fio_io_end()
87 if (io_u->ddir == DDIR_READ) in fio_pvsyncio_queue()
89 else if (io_u->ddir == DDIR_WRITE) in fio_pvsyncio_queue()
91 else if (io_u->ddir == DDIR_TRIM) { in fio_pvsyncio_queue()
108 if (io_u->ddir == DDIR_READ) in fio_psyncio_queue()
110 else if (io_u->ddir == DDIR_WRITE) in fio_psyncio_queue()
112 else if (io_u->ddir == DDIR_TRIM) { in fio_psyncio_queue()
128 if (io_u->ddir == DDIR_READ) in fio_syncio_queue()
130 else if (io_u->ddir == DDIR_WRITE) in fio_syncio_queue()
[all …]
|
| D | glusterfs_sync.c | 18 if (!ddir_rw(io_u->ddir)) in fio_gf_prep()
40 if (io_u->ddir == DDIR_READ) in fio_gf_queue()
42 else if (io_u->ddir == DDIR_WRITE) in fio_gf_queue()
44 else if (io_u->ddir == DDIR_SYNC) in fio_gf_queue()
46 else if (io_u->ddir == DDIR_DATASYNC) in fio_gf_queue()
53 if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir)) in fio_gf_queue()
|
| D | glusterfs_async.c | 105 dprint(FD_IO, "%s op %s\n", __FUNCTION__, io_ddir_name(io_u->ddir)); in fio_gf_async_queue()
109 if (io_u->ddir == DDIR_READ) in fio_gf_async_queue()
112 else if (io_u->ddir == DDIR_WRITE) in fio_gf_async_queue()
116 else if (io_u->ddir == DDIR_TRIM) in fio_gf_async_queue()
120 else if (io_u->ddir == DDIR_DATASYNC) in fio_gf_async_queue()
122 else if (io_u->ddir == DDIR_SYNC) in fio_gf_async_queue()
|
| D | libhdfs.c | 85 if (io_u->ddir == DDIR_READ) { in fio_hdfsio_prep()
87 } else if (io_u->ddir == DDIR_WRITE) { in fio_hdfsio_prep()
97 if (fi->mSize >= hd->fsbs || io_u->ddir == DDIR_WRITE) { in fio_hdfsio_prep()
137 if (io_u->ddir == DDIR_READ) { in fio_hdfsio_queue()
140 } else if (io_u->ddir == DDIR_WRITE) { in fio_hdfsio_queue()
|
| D | guasi.c | 67 if (io_u->ddir == DDIR_READ || in fio_guasi_event()
68 io_u->ddir == DDIR_WRITE) { in fio_guasi_event()
162 if (io_u->ddir == DDIR_READ) in fio_guasi_commit()
166 else if (io_u->ddir == DDIR_WRITE) in fio_guasi_commit()
170 else if (ddir_sync(io_u->ddir)) in fio_guasi_commit()
174 io_u->ddir); in fio_guasi_commit()
|
| D | falloc.c | 81 if (io_u->ddir == DDIR_READ) in fio_fallocate_queue()
83 else if (io_u->ddir == DDIR_WRITE) in fio_fallocate_queue()
85 else if (io_u->ddir == DDIR_TRIM) in fio_fallocate_queue()
|
| D | mmap.c | 174 if (io_u->ddir == DDIR_READ) in fio_mmapio_queue()
176 else if (io_u->ddir == DDIR_WRITE) in fio_mmapio_queue()
178 else if (ddir_sync(io_u->ddir)) { in fio_mmapio_queue()
183 } else if (io_u->ddir == DDIR_TRIM) { in fio_mmapio_queue()
194 if (td->o.odirect && ddir_rw(io_u->ddir)) { in fio_mmapio_queue()
|
| D | libaio.c | 72 if (io_u->ddir == DDIR_READ) in fio_libaio_prep()
74 else if (io_u->ddir == DDIR_WRITE) in fio_libaio_prep()
76 else if (ddir_sync(io_u->ddir)) in fio_libaio_prep()
195 if (ddir_sync(io_u->ddir)) { in fio_libaio_queue()
203 if (io_u->ddir == DDIR_TRIM) { in fio_libaio_queue()
|
| D | rbd.c | 351 if (io_u->ddir == DDIR_WRITE) { in fio_rbd_queue()
359 } else if (io_u->ddir == DDIR_READ) { in fio_rbd_queue()
367 } else if (io_u->ddir == DDIR_TRIM) { in fio_rbd_queue()
374 } else if (io_u->ddir == DDIR_SYNC) { in fio_rbd_queue()
382 io_u->ddir); in fio_rbd_queue()
|
| D | solarisaio.c | 118 if (io_u->ddir == DDIR_SYNC) { in fio_solarisaio_queue()
127 if (io_u->ddir == DDIR_DATASYNC) { in fio_solarisaio_queue()
140 if (io_u->ddir == DDIR_READ) in fio_solarisaio_queue()
|
| D | posixaio.c | 178 if (io_u->ddir == DDIR_READ) in fio_posixaio_queue()
180 else if (io_u->ddir == DDIR_WRITE) in fio_posixaio_queue()
182 else if (io_u->ddir == DDIR_TRIM) { in fio_posixaio_queue()
|
| D | splice.c | 209 if (io_u->ddir == DDIR_READ) { in fio_spliceio_queue()
222 } else if (io_u->ddir == DDIR_WRITE) in fio_spliceio_queue()
224 else if (io_u->ddir == DDIR_TRIM) in fio_spliceio_queue()
|