| /external/fio/ |
| D | memory.c | 15 void fio_unpin_memory(struct thread_data *td) in fio_unpin_memory()
26 int fio_pin_memory(struct thread_data *td) in fio_pin_memory()
64 static int alloc_mem_shm(struct thread_data *td, unsigned int total_mem) in alloc_mem_shm()
109 static void free_mem_shm(struct thread_data *td) in free_mem_shm()
118 static int alloc_mem_mmap(struct thread_data *td, size_t total_mem) in alloc_mem_mmap()
173 static void free_mem_mmap(struct thread_data *td, size_t total_mem) in free_mem_mmap()
185 static int alloc_mem_malloc(struct thread_data *td, size_t total_mem) in alloc_mem_malloc()
194 static void free_mem_malloc(struct thread_data *td) in free_mem_malloc()
203 int allocate_io_mem(struct thread_data *td) in allocate_io_mem()
239 void free_io_mem(struct thread_data *td) in free_io_mem()
|
| D | io_u.c | 36 static void mark_random_map(struct thread_data *td, struct io_u *io_u) in mark_random_map()
53 static uint64_t last_block(struct thread_data *td, struct fio_file *f, in last_block()
83 static int __get_next_rand_offset(struct thread_data *td, struct fio_file *f, in __get_next_rand_offset()
139 static int __get_next_rand_offset_zipf(struct thread_data *td, in __get_next_rand_offset_zipf()
147 static int __get_next_rand_offset_pareto(struct thread_data *td, in __get_next_rand_offset_pareto()
163 static int get_off_from_method(struct thread_data *td, struct fio_file *f, in get_off_from_method()
181 static inline int should_sort_io(struct thread_data *td) in should_sort_io()
195 static int should_do_random(struct thread_data *td, enum fio_ddir ddir) in should_do_random()
214 static int get_next_rand_offset(struct thread_data *td, struct fio_file *f, in get_next_rand_offset()
253 static int get_next_rand_block(struct thread_data *td, struct fio_file *f, in get_next_rand_block()
[all …]
|
| D | ioengines.c | 88 static struct ioengine_ops *dlopen_ioengine(struct thread_data *td, in dlopen_ioengine()
134 struct ioengine_ops *load_ioengine(struct thread_data *td, const char *name) in load_ioengine()
174 void free_ioengine(struct thread_data *td) in free_ioengine()
191 void close_ioengine(struct thread_data *td) in close_ioengine()
203 int td_io_prep(struct thread_data *td, struct io_u *io_u) in td_io_prep()
222 int td_io_getevents(struct thread_data *td, unsigned int min, unsigned int max, in td_io_getevents()
265 int td_io_queue(struct thread_data *td, struct io_u *io_u) in td_io_queue()
364 int td_io_init(struct thread_data *td) in td_io_init()
384 int td_io_commit(struct thread_data *td) in td_io_commit()
410 int td_io_open_file(struct thread_data *td, struct fio_file *f) in td_io_open_file()
[all …]
|
| D | filesetup.c | 27 static inline void clear_error(struct thread_data *td) in clear_error()
36 static int extend_file(struct thread_data *td, struct fio_file *f) in extend_file()
201 static int pre_read_file(struct thread_data *td, struct fio_file *f) in pre_read_file()
259 static unsigned long long get_rand_file_size(struct thread_data *td) in get_rand_file_size()
279 static int file_size(struct thread_data *td, struct fio_file *f) in file_size()
292 static int bdev_size(struct thread_data *td, struct fio_file *f) in bdev_size()
322 static int char_size(struct thread_data *td, struct fio_file *f) in char_size()
357 static int get_file_size(struct thread_data *td, struct fio_file *f) in get_file_size()
387 static int __file_invalidate_cache(struct thread_data *td, struct fio_file *f, in __file_invalidate_cache()
440 int file_invalidate_cache(struct thread_data *td, struct fio_file *f) in file_invalidate_cache()
[all …]
|
| D | iolog.c | 17 void queue_io_piece(struct thread_data *td, struct io_piece *ipo) in queue_io_piece()
23 void log_io_u(struct thread_data *td, struct io_u *io_u) in log_io_u()
38 void log_file(struct thread_data *td, struct fio_file *f, in log_file()
58 static void iolog_delay(struct thread_data *td, unsigned long delay) in iolog_delay()
84 static int ipo_special(struct thread_data *td, struct io_piece *ipo) in ipo_special()
118 int read_iolog_get(struct thread_data *td, struct io_u *io_u) in read_iolog_get()
165 void prune_io_piece_log(struct thread_data *td) in prune_io_piece_log()
190 void log_io_piece(struct thread_data *td, struct io_u *io_u) in log_io_piece()
271 void unlog_io_piece(struct thread_data *td, struct io_u *io_u) in unlog_io_piece()
288 void trim_io_piece(struct thread_data *td, struct io_u *io_u) in trim_io_piece()
[all …]
|
| D | trim.h | 14 static inline void remove_trim_entry(struct thread_data *td, struct io_piece *ipo) in remove_trim_entry()
23 static inline int get_next_trim(struct thread_data *td, struct io_u *io_u) in get_next_trim()
27 static inline int io_u_should_trim(struct thread_data *td, struct io_u *io_u) in io_u_should_trim()
31 static inline void remove_trim_entry(struct thread_data *td, struct io_piece *ipo) in remove_trim_entry()
|
| D | cgroup.c | 22 static char *find_cgroup_mnt(struct thread_data *td) in find_cgroup_mnt()
50 static void add_cgroup(struct thread_data *td, const char *name, in add_cgroup()
100 static char *get_cgroup_root(struct thread_data *td, char *mnt) in get_cgroup_root()
112 static int write_int_to_file(struct thread_data *td, const char *path, in write_int_to_file()
132 static int cgroup_write_pid(struct thread_data *td, const char *root) in cgroup_write_pid()
142 static int cgroup_del_pid(struct thread_data *td, char *mnt) in cgroup_del_pid()
147 int cgroup_setup(struct thread_data *td, struct flist_head *clist, char **mnt) in cgroup_setup()
189 void cgroup_shutdown(struct thread_data *td, char **mnt) in cgroup_shutdown()
|
| D | libfio.c | 79 static void reset_io_counters(struct thread_data *td) in reset_io_counters()
103 void clear_io_state(struct thread_data *td) in clear_io_state()
120 void reset_all_stats(struct thread_data *td) in reset_all_stats()
167 void td_set_runstate(struct thread_data *td, int runstate) in td_set_runstate()
177 int td_bump_runstate(struct thread_data *td, int new_state) in td_bump_runstate()
185 void td_restore_runstate(struct thread_data *td, int old_state) in td_restore_runstate()
192 struct thread_data *td; in fio_terminate_threads() local
224 struct thread_data *td; in fio_running_or_pending_io_threads() local
|
| D | backend.c | 140 static int __check_min_rate(struct thread_data *td, struct timeval *now, in __check_min_rate()
228 static int check_min_rate(struct thread_data *td, struct timeval *now, in check_min_rate()
247 static void cleanup_pending_aio(struct thread_data *td) in cleanup_pending_aio()
282 static int fio_io_sync(struct thread_data *td, struct fio_file *f) in fio_io_sync()
324 static int fio_file_fsync(struct thread_data *td, struct fio_file *f) in fio_file_fsync()
339 static inline void __update_tv_cache(struct thread_data *td) in __update_tv_cache()
344 static inline void update_tv_cache(struct thread_data *td) in update_tv_cache()
350 static inline int runtime_exceeded(struct thread_data *td, struct timeval *t) in runtime_exceeded()
362 static int break_on_this_error(struct thread_data *td, enum fio_ddir ddir, in break_on_this_error()
408 static void check_update_rusage(struct thread_data *td) in check_update_rusage()
[all …]
|
| D | options.c | 167 struct thread_data *td = data; in str_bssplit_cb() local
239 static int ignore_error_type(struct thread_data *td, int etype, char *str) in ignore_error_type()
295 struct thread_data *td = data; in str_ignore_error_cb() local
323 struct thread_data *td = data; in str_rw_cb() local
357 struct thread_data *td = data; in str_mem_cb() local
367 struct thread_data *td = data; in fio_clock_source_cb() local
377 struct thread_data *td = data; in str_rwmix_read_cb() local
386 struct thread_data *td = data; in str_rwmix_write_cb() local
424 struct thread_data *td = data; in str_cpumask_cb() local
457 static int set_cpus_allowed(struct thread_data *td, os_cpu_mask_t *mask, in set_cpus_allowed()
[all …]
|
| D | io_ddir.h | 28 #define td_read(td) ((td)->o.td_ddir & TD_DDIR_READ) argument
29 #define td_write(td) ((td)->o.td_ddir & TD_DDIR_WRITE) argument
30 #define td_trim(td) ((td)->o.td_ddir & TD_DDIR_TRIM) argument
31 #define td_rw(td) (((td)->o.td_ddir & TD_DDIR_RW) == TD_DDIR_RW) argument
32 #define td_random(td) ((td)->o.td_ddir & TD_DDIR_RAND) argument
33 #define file_randommap(td, f) (!(td)->o.norandommap && (f)->io_axmap) argument
|
| D | blktrace.c | 18 static int refill_fifo(struct thread_data *td, struct fifo *fifo, int fd) in refill_fifo()
44 static int trace_fifo_get(struct thread_data *td, struct fifo *fifo, int fd, in trace_fifo_get()
60 static int discard_pdu(struct thread_data *td, struct fifo *fifo, int fd, in discard_pdu()
111 static int lookup_device(struct thread_data *td, char *path, unsigned int maj, in lookup_device()
177 static void trace_add_open_close_event(struct thread_data *td, int fileno, enum file_log_act action) in trace_add_open_close_event()
190 static int trace_add_file(struct thread_data *td, __u32 device) in trace_add_file()
233 static void store_ipo(struct thread_data *td, unsigned long long offset, in store_ipo()
278 static void handle_trace_discard(struct thread_data *td, struct blk_io_trace *t, in handle_trace_discard()
308 static void handle_trace_fs(struct thread_data *td, struct blk_io_trace *t, in handle_trace_fs()
331 static void handle_trace(struct thread_data *td, struct blk_io_trace *t, in handle_trace()
[all …]
|
| /external/fio/engines/ |
| D | skeleton_external.c | 29 static struct io_u *fio_skeleton_event(struct thread_data *td, int event) in fio_skeleton_event()
40 static int fio_skeleton_getevents(struct thread_data *td, unsigned int min, in fio_skeleton_getevents()
50 static int fio_skeleton_cancel(struct thread_data *td, struct io_u *io_u) in fio_skeleton_cancel()
65 static int fio_skeleton_queue(struct thread_data *td, struct io_u *io_u) in fio_skeleton_queue()
86 static int fio_skeleton_prep(struct thread_data *td, struct io_u *io_u) in fio_skeleton_prep()
96 static int fio_skeleton_init(struct thread_data *td) in fio_skeleton_init()
106 static void fio_skeleton_cleanup(struct thread_data *td) in fio_skeleton_cleanup()
114 static int fio_skeleton_open(struct thread_data *td, struct fio_file *f) in fio_skeleton_open()
122 static int fio_skeleton_close(struct thread_data *td, struct fio_file *f) in fio_skeleton_close()
|
| D | net.c | 35 struct thread_data *td; member
192 static int poll_wait(struct thread_data *td, int fd, short events) in poll_wait()
233 static int fio_netio_prep(struct thread_data *td, struct io_u *io_u) in fio_netio_prep()
278 static int splice_in(struct thread_data *td, struct io_u *io_u) in splice_in()
288 static int splice_out(struct thread_data *td, struct io_u *io_u, in splice_out()
326 static int vmsplice_io_u_out(struct thread_data *td, struct io_u *io_u, in vmsplice_io_u_out()
337 static int vmsplice_io_u_in(struct thread_data *td, struct io_u *io_u) in vmsplice_io_u_in()
348 static int fio_netio_splice_in(struct thread_data *td, struct io_u *io_u) in fio_netio_splice_in()
363 static int fio_netio_splice_out(struct thread_data *td, struct io_u *io_u) in fio_netio_splice_out()
374 static int fio_netio_splice_in(struct thread_data *td, struct io_u *io_u) in fio_netio_splice_in()
[all …]
|
| D | sync.c | 34 static int fio_syncio_prep(struct thread_data *td, struct io_u *io_u) in fio_syncio_prep()
52 static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret) in fio_io_end()
73 static int fio_pvsyncio_queue(struct thread_data *td, struct io_u *io_u) in fio_pvsyncio_queue()
99 static int fio_psyncio_queue(struct thread_data *td, struct io_u *io_u) in fio_psyncio_queue()
119 static int fio_syncio_queue(struct thread_data *td, struct io_u *io_u) in fio_syncio_queue()
139 static int fio_vsyncio_getevents(struct thread_data *td, unsigned int min, in fio_vsyncio_getevents()
156 static struct io_u *fio_vsyncio_event(struct thread_data *td, int event) in fio_vsyncio_event()
163 static int fio_vsyncio_append(struct thread_data *td, struct io_u *io_u) in fio_vsyncio_append()
190 static int fio_vsyncio_queue(struct thread_data *td, struct io_u *io_u) in fio_vsyncio_queue()
230 static int fio_vsyncio_end(struct thread_data *td, ssize_t bytes) in fio_vsyncio_end()
[all …]
|
| D | null.c | 26 static struct io_u *fio_null_event(struct thread_data *td, int event) in fio_null_event()
33 static int fio_null_getevents(struct thread_data *td, unsigned int min_events, in fio_null_getevents()
48 static int fio_null_commit(struct thread_data *td) in fio_null_commit()
63 static int fio_null_queue(struct thread_data *td, struct io_u *io_u) in fio_null_queue()
78 static int fio_null_open(struct thread_data fio_unused *td, in fio_null_open()
84 static void fio_null_cleanup(struct thread_data *td) in fio_null_cleanup()
95 static int fio_null_init(struct thread_data *td) in fio_null_init()
|
| D | binject.c | 62 static unsigned int binject_read_commands(struct thread_data *td, void *p, in binject_read_commands()
93 static int fio_binject_getevents(struct thread_data *td, unsigned int min, in fio_binject_getevents()
173 static int fio_binject_doio(struct thread_data *td, struct io_u *io_u) in fio_binject_doio()
186 static int fio_binject_prep(struct thread_data *td, struct io_u *io_u) in fio_binject_prep()
216 static int fio_binject_queue(struct thread_data *td, struct io_u *io_u) in fio_binject_queue()
235 static struct io_u *fio_binject_event(struct thread_data *td, int event) in fio_binject_event()
242 static int binject_open_ctl(struct thread_data *td) in binject_open_ctl()
253 static void binject_unmap_dev(struct thread_data *td, struct binject_file *bf) in binject_unmap_dev()
275 static int binject_map_dev(struct thread_data *td, struct binject_file *bf, in binject_map_dev()
330 static int fio_binject_close_file(struct thread_data *td, struct fio_file *f) in fio_binject_close_file()
[all …]
|
| D | rbd.c | 25 struct thread_data *td; member
64 static int _fio_setup_rbd_data(struct thread_data *td, in _fio_setup_rbd_data()
93 static int _fio_rbd_connect(struct thread_data *td) in _fio_rbd_connect()
196 static struct io_u *fio_rbd_event(struct thread_data *td, int event) in fio_rbd_event()
203 static int fio_rbd_getevents(struct thread_data *td, unsigned int min, in fio_rbd_getevents()
236 static int fio_rbd_queue(struct thread_data *td, struct io_u *io_u) in fio_rbd_queue()
303 static int fio_rbd_init(struct thread_data *td) in fio_rbd_init()
320 static void fio_rbd_cleanup(struct thread_data *td) in fio_rbd_cleanup()
332 static int fio_rbd_setup(struct thread_data *td) in fio_rbd_setup()
400 static int fio_rbd_open(struct thread_data *td, struct fio_file *f) in fio_rbd_open()
[all …]
|
| D | guasi.c | 42 static int fio_guasi_prep(struct thread_data fio_unused *td, struct io_u *io_u) in fio_guasi_prep()
51 static struct io_u *fio_guasi_event(struct thread_data *td, int event) in fio_guasi_event()
82 static int fio_guasi_getevents(struct thread_data *td, unsigned int min, in fio_guasi_getevents()
116 static int fio_guasi_queue(struct thread_data *td, struct io_u *io_u) in fio_guasi_queue()
131 static void fio_guasi_queued(struct thread_data *td, struct io_u **io_us, int nr) in fio_guasi_queued()
149 static int fio_guasi_commit(struct thread_data *td) in fio_guasi_commit()
189 static int fio_guasi_cancel(struct thread_data fio_unused *td, in fio_guasi_cancel()
199 static void fio_guasi_cleanup(struct thread_data *td) in fio_guasi_cleanup()
216 static int fio_guasi_init(struct thread_data *td) in fio_guasi_init()
|
| D | mmap.c | 25 static int fio_mmap_file(struct thread_data *td, struct fio_file *f, in fio_mmap_file()
69 static int fio_mmapio_prep_limited(struct thread_data *td, struct io_u *io_u) in fio_mmapio_prep_limited()
90 static int fio_mmapio_prep_full(struct thread_data *td, struct io_u *io_u) in fio_mmapio_prep_full()
108 static int fio_mmapio_prep(struct thread_data *td, struct io_u *io_u) in fio_mmapio_prep()
142 static int fio_mmapio_queue(struct thread_data *td, struct io_u *io_u) in fio_mmapio_queue()
182 static int fio_mmapio_init(struct thread_data *td) in fio_mmapio_init()
|
| D | rdma.c | 119 static int client_recv(struct thread_data *td, struct ibv_wc *wc) in client_recv()
151 static int server_recv(struct thread_data *td, struct ibv_wc *wc) in server_recv()
166 static int cq_event_handler(struct thread_data *td, enum ibv_wc_opcode opcode) in cq_event_handler()
273 static int rdma_poll_wait(struct thread_data *td, enum ibv_wc_opcode opcode) in rdma_poll_wait()
310 static int fio_rdmaio_setup_qp(struct thread_data *td) in fio_rdmaio_setup_qp()
390 static int fio_rdmaio_setup_control_msg_buffers(struct thread_data *td) in fio_rdmaio_setup_control_msg_buffers()
432 static int get_next_channel_event(struct thread_data *td, in get_next_channel_event()
466 static int fio_rdmaio_prep(struct thread_data *td, struct io_u *io_u) in fio_rdmaio_prep()
509 static struct io_u *fio_rdmaio_event(struct thread_data *td, int event) in fio_rdmaio_event()
526 static int fio_rdmaio_getevents(struct thread_data *td, unsigned int min, in fio_rdmaio_getevents()
[all …]
|
| D | sg.c | 64 static int fio_sgio_getevents(struct thread_data *td, unsigned int min, in fio_sgio_getevents()
159 static int fio_sgio_ioctl_doio(struct thread_data *td, in fio_sgio_ioctl_doio()
194 static int fio_sgio_doio(struct thread_data *td, struct io_u *io_u, int do_sync) in fio_sgio_doio()
204 static int fio_sgio_prep(struct thread_data *td, struct io_u *io_u) in fio_sgio_prep()
246 static int fio_sgio_queue(struct thread_data *td, struct io_u *io_u) in fio_sgio_queue()
273 static struct io_u *fio_sgio_event(struct thread_data *td, int event) in fio_sgio_event()
280 static int fio_sgio_get_bs(struct thread_data *td, unsigned int *bs) in fio_sgio_get_bs()
308 static void fio_sgio_cleanup(struct thread_data *td) in fio_sgio_cleanup()
322 static int fio_sgio_init(struct thread_data *td) in fio_sgio_init()
348 static int fio_sgio_type_check(struct thread_data *td, struct fio_file *f) in fio_sgio_type_check()
[all …]
|
| D | solarisaio.c | 22 static int fio_solarisaio_cancel(struct thread_data fio_unused *td, in fio_solarisaio_cancel()
28 static int fio_solarisaio_prep(struct thread_data fio_unused *td, in fio_solarisaio_prep()
75 static int fio_solarisaio_getevents(struct thread_data *td, unsigned int min, in fio_solarisaio_getevents()
101 static struct io_u *fio_solarisaio_event(struct thread_data *td, int event) in fio_solarisaio_event()
108 static int fio_solarisaio_queue(struct thread_data fio_unused *td, in fio_solarisaio_queue()
156 static void fio_solarisaio_cleanup(struct thread_data *td) in fio_solarisaio_cleanup()
186 static int fio_solarisaio_init(struct thread_data *td) in fio_solarisaio_init()
|
| D | posixaio.c | 63 static int fio_posixaio_cancel(struct thread_data fio_unused *td, in fio_posixaio_cancel()
75 static int fio_posixaio_prep(struct thread_data fio_unused *td, in fio_posixaio_prep()
93 static int fio_posixaio_getevents(struct thread_data *td, unsigned int min, in fio_posixaio_getevents()
162 static struct io_u *fio_posixaio_event(struct thread_data *td, int event) in fio_posixaio_event()
169 static int fio_posixaio_queue(struct thread_data *td, in fio_posixaio_queue()
221 static void fio_posixaio_cleanup(struct thread_data *td) in fio_posixaio_cleanup()
231 static int fio_posixaio_init(struct thread_data *td) in fio_posixaio_init()
|
| D | libaio.c | 25 struct thread_data *td; member
44 static int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) in fio_libaio_prep()
58 static struct io_u *fio_libaio_event(struct thread_data *td, int event) in fio_libaio_event()
119 static int fio_libaio_getevents(struct thread_data *td, unsigned int min, in fio_libaio_getevents()
147 static int fio_libaio_queue(struct thread_data *td, struct io_u *io_u) in fio_libaio_queue()
184 static void fio_libaio_queued(struct thread_data *td, struct io_u **io_us, in fio_libaio_queued()
203 static int fio_libaio_commit(struct thread_data *td) in fio_libaio_commit()
235 static int fio_libaio_cancel(struct thread_data *td, struct io_u *io_u) in fio_libaio_cancel()
242 static void fio_libaio_cleanup(struct thread_data *td) in fio_libaio_cleanup()
255 static int fio_libaio_init(struct thread_data *td) in fio_libaio_init()
|