diff options
-rw-r--r-- | fio.h | 4 | ||||
-rw-r--r-- | io_u.c | 24 | ||||
-rw-r--r-- | parse.c | 2 | ||||
-rw-r--r-- | profile.c | 4 | ||||
-rw-r--r-- | profile.h | 15 |
5 files changed, 35 insertions, 14 deletions
@@ -30,6 +30,7 @@ #include "iolog.h" #include "helpers.h" #include "options.h" +#include "profile.h" #ifdef FIO_HAVE_GUASI #include <guasi.h> @@ -430,8 +431,7 @@ struct thread_data { /* * Can be overloaded by profiles */ - int (*fill_io_u_off)(struct thread_data *, struct io_u *); - int (*fill_io_u_size)(struct thread_data *, struct io_u *); + struct prof_io_ops prof_io_ops; }; /* @@ -233,8 +233,10 @@ static int __get_next_offset(struct thread_data *td, struct io_u *io_u) static int get_next_offset(struct thread_data *td, struct io_u *io_u) { - if (td->fill_io_u_off) - return td->fill_io_u_off(td, io_u); + struct prof_io_ops *ops = &td->prof_io_ops; + + if (ops->fill_io_u_off) + return ops->fill_io_u_off(td, io_u); return __get_next_offset(td, io_u); } @@ -286,8 +288,10 @@ static unsigned int __get_next_buflen(struct thread_data *td, struct io_u *io_u) static unsigned int get_next_buflen(struct thread_data *td, struct io_u *io_u) { - if (td->fill_io_u_size) - return td->fill_io_u_size(td, io_u); + struct prof_io_ops *ops = &td->prof_io_ops; + + if (ops->fill_io_u_size) + return ops->fill_io_u_size(td, io_u); return __get_next_buflen(td, io_u); } @@ -785,7 +789,7 @@ static struct fio_file *get_next_file_rr(struct thread_data *td, int goodf, return f; } -static struct fio_file *get_next_file(struct thread_data *td) +static struct fio_file *__get_next_file(struct thread_data *td) { struct fio_file *f; @@ -820,6 +824,16 @@ out: return f; } +static struct fio_file *get_next_file(struct thread_data *td) +{ + struct prof_io_ops *ops = &td->prof_io_ops; + + if (ops->get_next_file) + return ops->get_next_file(td); + + return __get_next_file(td); +} + static int set_io_u_file(struct thread_data *td, struct io_u *io_u) { struct fio_file *f; @@ -825,6 +825,8 @@ int show_cmd_help(struct fio_option *options, const char *name) int found = 0; int show_all = 0; + printf("exec_profile=%s\n", exec_profile); + if (!name || !strcmp(name, "all")) show_all = 1; @@ -93,6 +93,6 @@ void profile_add_hooks(struct thread_data *td) if (!ops) return; - td->fill_io_u_off = ops->fill_io_u_off; - td->fill_io_u_size = ops->fill_io_u_size; + if (ops->io_ops) + td->prof_io_ops = *ops->io_ops; } @@ -3,6 +3,15 @@ #include "flist.h" +/* + * Functions for overriding internal fio io_u functions + */ +struct prof_io_ops { + int (*fill_io_u_off)(struct thread_data *, struct io_u *); + int (*fill_io_u_size)(struct thread_data *, struct io_u *); + struct fio_file *(*get_next_file)(struct thread_data *); +}; + struct profile_ops { struct flist_head list; char name[32]; @@ -24,11 +33,7 @@ struct profile_ops { */ const char **cmdline; - /* - * Functions for overriding internal fio io_u functions - */ - int (*fill_io_u_off)(struct thread_data *, struct io_u *); - int (*fill_io_u_size)(struct thread_data *, struct io_u *); + struct prof_io_ops *io_ops; }; int register_profile(struct profile_ops *); |