/external/fio/ |
H A D | io_ddir.h | 17 static inline const char *io_ddir_name(enum fio_ddir ddir) argument 22 if (ddir < DDIR_LAST) 23 return name[ddir]; 47 static inline int ddir_sync(enum fio_ddir ddir) argument 49 return ddir == DDIR_SYNC || ddir == DDIR_DATASYNC || 50 ddir == DDIR_SYNC_FILE_RANGE; 53 static inline int ddir_rw(enum fio_ddir ddir) argument 55 return ddir == DDIR_READ || ddir 58 ddir_str(enum td_ddir ddir) argument [all...] |
H A D | io_u.c | 54 enum fio_ddir ddir) 59 assert(ddir_rw(ddir)); 71 if (td->o.min_bs[ddir] > td->o.ba[ddir]) 72 max_size -= td->o.min_bs[ddir] - td->o.ba[ddir]; 74 max_blocks = max_size / (uint64_t) td->o.ba[ddir]; 87 enum fio_ddir ddir, uint64_t *b) 94 lastb = last_block(td, f, ddir); 137 struct fio_file *f, enum fio_ddir ddir, 53 last_block(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir) argument 86 __get_next_rand_offset(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *b) argument 136 __get_next_rand_offset_zipf(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *b) argument 144 __get_next_rand_offset_pareto(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *b) argument 160 get_off_from_method(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *b) argument 192 should_do_random(struct thread_data *td, enum fio_ddir ddir) argument 206 get_next_rand_offset(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *b) argument 244 get_next_rand_block(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *b) argument 262 get_next_seq_offset(struct thread_data *td, struct fio_file *f, enum fio_ddir ddir, uint64_t *offset) argument 299 get_next_block(struct thread_data *td, struct io_u *io_u, enum fio_ddir ddir, int rw_seq, unsigned int *is_random) argument 372 enum fio_ddir ddir = io_u->ddir; local 427 int ddir = io_u->ddir; local 548 rate_ddir(struct thread_data *td, enum fio_ddir ddir) argument 606 enum fio_ddir ddir; local 706 enum fio_ddir ddir = acct_ddir(__io_u); local 1593 usec_for_io(struct thread_data *td, enum fio_ddir ddir) argument 1608 enum fio_ddir ddir = io_u->ddir; local 1726 int ddir; local 1774 int ddir; local 1816 int ddir; local [all...] |
H A D | td_error.h | 22 enum error_type_bit td_error_type(enum fio_ddir ddir, int err);
|
H A D | td_error.c | 7 enum error_type_bit td_error_type(enum fio_ddir ddir, int err) argument 11 if (ddir == DDIR_READ)
|
H A D | stat.c | 364 int ddir) 373 assert(ddir_rw(ddir)); 375 if (!ts->runtime[ddir]) 379 runt = ts->runtime[ddir]; 381 bw = (1000 * ts->io_bytes[ddir]) / runt; 382 io_p = num2str(ts->io_bytes[ddir], 6, 1, i2p, 8); 385 iops = (1000 * (uint64_t)ts->total_io_u[ddir]) / runt; 389 rs->unified_rw_rep ? "mixed" : str[ddir], 391 (unsigned long long) ts->runtime[ddir]); 397 if (calc_lat(&ts->slat_stat[ddir], 363 show_ddir_status(struct group_run_stats *rs, struct thread_stat *ts, int ddir) argument 601 show_ddir_status_terse(struct thread_stat *ts, struct group_run_stats *rs, int ddir) argument 673 add_ddir_status_json(struct thread_stat *ts, struct group_run_stats *rs, int ddir, struct json_object *parent) argument 1341 int ddir; local 1567 __add_log_sample(struct io_log *iolog, unsigned long val, enum fio_ddir ddir, unsigned int bs, unsigned long t, uint64_t offset) argument 1694 add_log_sample(struct thread_data *td, struct io_log *iolog, unsigned long val, enum fio_ddir ddir, unsigned int bs, uint64_t offset) argument 1750 add_agg_sample(unsigned long val, enum fio_ddir ddir, unsigned int bs) argument 1761 add_clat_percentile_sample(struct thread_stat *ts, unsigned long usec, enum fio_ddir ddir) argument 1770 add_clat_sample(struct thread_data *td, enum fio_ddir ddir, unsigned long usec, unsigned int bs, uint64_t offset) argument 1787 add_slat_sample(struct thread_data *td, enum fio_ddir ddir, unsigned long usec, unsigned int bs, uint64_t offset) argument 1801 add_lat_sample(struct thread_data *td, enum fio_ddir ddir, unsigned long usec, unsigned int bs, uint64_t offset) argument 1815 add_bw_sample(struct thread_data *td, enum fio_ddir ddir, unsigned int bs, struct timeval *t) argument 1854 add_iops_sample(struct thread_data *td, enum fio_ddir ddir, unsigned int bs, struct timeval *t) argument [all...] |
H A D | libfio.c | 82 int ddir; local 84 for (ddir = 0; ddir < DDIR_RWDIR_CNT; ddir++) { 85 td->stat_io_bytes[ddir] = 0; 86 td->this_io_bytes[ddir] = 0; 87 td->stat_io_blocks[ddir] = 0; 88 td->this_io_blocks[ddir] = 0; 89 td->rate_bytes[ddir] = 0; 90 td->rate_blocks[ddir] [all...] |
H A D | eta.c | 408 int ddir; local 410 for (ddir = DDIR_READ; ddir < DDIR_RWDIR_CNT; ddir++) { 412 io_bytes[0] += td->io_bytes[ddir]; 413 io_iops[0] += td->io_blocks[ddir]; 415 io_bytes[ddir] += td->io_bytes[ddir]; 416 io_iops[ddir] += td->io_blocks[ddir]; 513 int ddir; local [all...] |
H A D | backend.c | 145 enum fio_ddir ddir) 155 assert(ddir_rw(ddir)); 157 if (!td->o.ratemin[ddir] && !td->o.rate_iops_min[ddir]) 166 iops += td->this_io_blocks[ddir]; 167 bytes += td->this_io_bytes[ddir]; 168 ratemin += td->o.ratemin[ddir]; 169 rate_iops += td->o.rate_iops[ddir]; 170 rate_iops_min += td->o.rate_iops_min[ddir]; 175 if (td->rate_bytes[ddir] || t 144 __check_min_rate(struct thread_data *td, struct timeval *now, enum fio_ddir ddir) argument 366 break_on_this_error(struct thread_data *td, enum fio_ddir ddir, int *retptr) argument 485 enum fio_ddir ddir; local 753 enum fio_ddir ddir; local [all...] |
H A D | ioengine.h | 40 enum fio_ddir ddir; member in struct:io_u 228 dprint(FD_IO, "%s: io_u %p: off=%llu/len=%lu/ddir=%d", p, io_u, 230 io_u->buflen, io_u->ddir); 247 return io_u->ddir;
|
H A D | iolog.h | 104 enum fio_ddir ddir) 106 io->__ddir = ddir | log->log_ddir_mask; 158 enum fio_ddir ddir; member in struct:io_piece 102 io_sample_set_ddir(struct io_log *log, struct io_sample *io, enum fio_ddir ddir) argument
|
H A D | ioengines.c | 208 lock_file(td, io_u->file, io_u->ddir); 324 if (io_u->error == EINVAL && td->io_issues[io_u->ddir & 1] == 1 && 331 if (!td->io_ops->commit || io_u->ddir == DDIR_TRIM) { 337 if (ddir_rw(io_u->ddir)) { 339 td->ts.total_io_u[io_u->ddir]++; 344 if (ddir_rw(io_u->ddir)) { 346 td->ts.total_io_u[io_u->ddir]++; 550 if (io_u->ddir == DDIR_SYNC) { 552 } else if (io_u->ddir == DDIR_DATASYNC) { 559 } else if (io_u->ddir [all...] |
H A D | fio.h | 413 assert(!(io_u->ddir == DDIR_WRITE && !td_write(td))); 563 enum fio_ddir ddir) 570 if (o->rate[ddir] || o->ratemin[ddir] || o->rate_iops[ddir] || 571 o->rate_iops_min[ddir]) 562 __should_check_rate(struct thread_data *td, enum fio_ddir ddir) argument
|
H A D | trim.c | 62 io_u->ddir = DDIR_TRIM;
|
H A D | blktrace.c | 124 ipo->ddir = DDIR_INVAL; 195 ipo->ddir = DDIR_WRITE; 197 ipo->ddir = DDIR_READ; 200 dprint(FD_BLKTRACE, "store ddir=%d, off=%llu, len=%lu, delay=%lu\n", 201 ipo->ddir, ipo->offset, 251 ipo->ddir = DDIR_TRIM;
|
/external/fio/engines/ |
H A D | glusterfs_sync.c | 18 if (!ddir_rw(io_u->ddir)) 40 if (io_u->ddir == DDIR_READ) 42 else if (io_u->ddir == DDIR_WRITE) 44 else if (io_u->ddir == DDIR_SYNC) 46 else if (io_u->ddir == DDIR_DATASYNC) 53 if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir))
|
H A D | glusterfs_async.c | 105 dprint(FD_IO, "%s op %s\n", __FUNCTION__, io_ddir_name(io_u->ddir)); 109 if (io_u->ddir == DDIR_READ) 112 else if (io_u->ddir == DDIR_WRITE) 116 else if (io_u->ddir == DDIR_TRIM) 120 else if (io_u->ddir == DDIR_DATASYNC) 122 else if (io_u->ddir == DDIR_SYNC)
|
H A D | falloc.c | 81 if (io_u->ddir == DDIR_READ) 83 else if (io_u->ddir == DDIR_WRITE) 85 else if (io_u->ddir == DDIR_TRIM)
|
H A D | sync.c | 38 if (!ddir_rw(io_u->ddir)) 54 if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir)) 87 if (io_u->ddir == DDIR_READ) 89 else if (io_u->ddir == DDIR_WRITE) 91 else if (io_u->ddir == DDIR_TRIM) { 108 if (io_u->ddir == DDIR_READ) 110 else if (io_u->ddir == DDIR_WRITE) 112 else if (io_u->ddir == DDIR_TRIM) { 128 if (io_u->ddir == DDIR_READ) 130 else if (io_u->ddir [all...] |
H A D | guasi.c | 67 if (io_u->ddir == DDIR_READ || 68 io_u->ddir == DDIR_WRITE) { 162 if (io_u->ddir == DDIR_READ) 166 else if (io_u->ddir == DDIR_WRITE) 170 else if (ddir_sync(io_u->ddir)) 174 io_u->ddir);
|
H A D | libhdfs.c | 85 if (io_u->ddir == DDIR_READ) { 87 } else if (io_u->ddir == DDIR_WRITE) { 97 if (fi->mSize >= hd->fsbs || io_u->ddir == DDIR_WRITE) { 137 if (io_u->ddir == DDIR_READ) { 140 } else if (io_u->ddir == DDIR_WRITE) {
|
H A D | mmap.c | 174 if (io_u->ddir == DDIR_READ) 176 else if (io_u->ddir == DDIR_WRITE) 178 else if (ddir_sync(io_u->ddir)) { 183 } else if (io_u->ddir == DDIR_TRIM) { 194 if (td->o.odirect && ddir_rw(io_u->ddir)) {
|
H A D | libaio.c | 72 if (io_u->ddir == DDIR_READ) 74 else if (io_u->ddir == DDIR_WRITE) 76 else if (ddir_sync(io_u->ddir)) 195 if (ddir_sync(io_u->ddir)) { 203 if (io_u->ddir == DDIR_TRIM) {
|
H A D | posixaio.c | 178 if (io_u->ddir == DDIR_READ) 180 else if (io_u->ddir == DDIR_WRITE) 182 else if (io_u->ddir == DDIR_TRIM) {
|
H A D | solarisaio.c | 118 if (io_u->ddir == DDIR_SYNC) { 127 if (io_u->ddir == DDIR_DATASYNC) { 140 if (io_u->ddir == DDIR_READ)
|
H A D | splice.c | 209 if (io_u->ddir == DDIR_READ) { 222 } else if (io_u->ddir == DDIR_WRITE) 224 else if (io_u->ddir == DDIR_TRIM)
|