Searched refs:ddir (Results 1 - 25 of 39) sorted by relevance

12

/external/fio/
H A Dio_ddir.h17 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 Dio_u.c54 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 Dtd_error.h22 enum error_type_bit td_error_type(enum fio_ddir ddir, int err);
H A Dtd_error.c7 enum error_type_bit td_error_type(enum fio_ddir ddir, int err) argument
11 if (ddir == DDIR_READ)
H A Dstat.c364 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 Dlibfio.c82 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 Deta.c408 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 Dbackend.c145 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 Dioengine.h40 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 Diolog.h104 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 Dioengines.c208 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 Dfio.h413 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 Dtrim.c62 io_u->ddir = DDIR_TRIM;
H A Dblktrace.c124 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 Dglusterfs_sync.c18 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 Dglusterfs_async.c105 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 Dfalloc.c81 if (io_u->ddir == DDIR_READ)
83 else if (io_u->ddir == DDIR_WRITE)
85 else if (io_u->ddir == DDIR_TRIM)
H A Dsync.c38 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 Dguasi.c67 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 Dlibhdfs.c85 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 Dmmap.c174 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 Dlibaio.c72 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 Dposixaio.c178 if (io_u->ddir == DDIR_READ)
180 else if (io_u->ddir == DDIR_WRITE)
182 else if (io_u->ddir == DDIR_TRIM) {
H A Dsolarisaio.c118 if (io_u->ddir == DDIR_SYNC) {
127 if (io_u->ddir == DDIR_DATASYNC) {
140 if (io_u->ddir == DDIR_READ)
H A Dsplice.c209 if (io_u->ddir == DDIR_READ) {
222 } else if (io_u->ddir == DDIR_WRITE)
224 else if (io_u->ddir == DDIR_TRIM)

Completed in 710 milliseconds

12