X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=ioengine.h;h=6809501ffa795fa46e59419d91345bfc3904a0a6;hp=f6238f83a6a64139fcd941c086ab94dbf6a6e1b5;hb=d5e3f5d8ef7fab70288aa57c8660bc3d2199655f;hpb=0d29de831183dfd049c97a03008d425ce21e2fa4 diff --git a/ioengine.h b/ioengine.h index f6238f83..6809501f 100644 --- a/ioengine.h +++ b/ioengine.h @@ -1,7 +1,14 @@ #ifndef FIO_IOENGINE_H #define FIO_IOENGINE_H -#define FIO_IOOPS_VERSION 12 +#ifdef CONFIG_LIBAIO +#include +#endif +#ifdef CONFIG_GUASI +#include +#endif + +#define FIO_IOOPS_VERSION 14 enum { IO_U_F_FREE = 1 << 0, @@ -10,6 +17,8 @@ enum { IO_U_F_IN_CUR_DEPTH = 1 << 3, IO_U_F_BUSY_OK = 1 << 4, IO_U_F_TRIMMED = 1 << 5, + IO_U_F_BARRIER = 1 << 6, + IO_U_F_VER_LIST = 1 << 7, }; /* @@ -17,32 +26,47 @@ enum { */ struct io_u { union { -#ifdef FIO_HAVE_LIBAIO +#ifdef CONFIG_LIBAIO struct iocb iocb; #endif -#ifdef FIO_HAVE_POSIXAIO - struct aiocb aiocb; +#ifdef CONFIG_POSIXAIO + os_aiocb_t aiocb; #endif #ifdef FIO_HAVE_SGIO struct sg_io_hdr hdr; #endif -#ifdef FIO_HAVE_GUASI +#ifdef CONFIG_GUASI guasi_req_t greq; #endif -#ifdef FIO_HAVE_SOLARISAIO +#ifdef CONFIG_SOLARISAIO aio_result_t resultp; +#endif +#ifdef FIO_HAVE_BINJECT + struct b_user_cmd buc; +#endif +#ifdef CONFIG_RDMA + struct ibv_mr *mr; #endif void *mmap_data; }; struct timeval start_time; struct timeval issue_time; + struct fio_file *file; + unsigned int flags; + enum fio_ddir ddir; + /* * Allocated/set buffer and length */ - void *buf; unsigned long buflen; unsigned long long offset; + void *buf; + + /* + * Initial seed for generating the buffer contents + */ + unsigned long rand_seed; /* * IO engine state, may be different from above when we get @@ -60,8 +84,6 @@ struct io_u { unsigned int resid; unsigned int error; - enum fio_ddir ddir; - /* * io engine private data */ @@ -71,10 +93,6 @@ struct io_u { void *engine_data; }; - unsigned int flags; - - struct fio_file *file; - struct flist_head list; /* @@ -109,6 +127,11 @@ struct ioengine_ops { int (*open_file)(struct thread_data *, struct fio_file *); int (*close_file)(struct thread_data *, struct fio_file *); int (*get_file_size)(struct thread_data *, struct fio_file *); + void (*terminate)(struct thread_data *); + int (*io_u_init)(struct thread_data *, struct io_u *); + void (*io_u_free)(struct thread_data *, struct io_u *); + int option_struct_size; + struct fio_option *options; void *data; void *dlhandle; }; @@ -118,11 +141,12 @@ enum fio_ioengine_flags { FIO_RAWIO = 1 << 1, /* some sort of direct/raw io */ FIO_DISKLESSIO = 1 << 2, /* no disk involved */ FIO_NOEXTEND = 1 << 3, /* engine can't extend file */ - FIO_NODISKUTIL = 1 << 4, /* diskutil can't handle filename */ + FIO_NODISKUTIL = 1 << 4, /* diskutil can't handle filename */ FIO_UNIDIR = 1 << 5, /* engine is uni-directional */ FIO_NOIO = 1 << 6, /* thread does only pseudo IO */ - FIO_SIGQUIT = 1 << 7, /* needs SIGQUIT to exit */ - FIO_PIPEIO = 1 << 8, /* input/output no seekable */ + FIO_PIPEIO = 1 << 7, /* input/output no seekable */ + FIO_BARRIER = 1 << 8, /* engine supports barriers */ + FIO_MEMALIGN = 1 << 9, /* engine wants aligned memory */ }; /* @@ -141,8 +165,11 @@ extern int __must_check td_io_get_file_size(struct thread_data *, struct fio_fil extern struct ioengine_ops *load_ioengine(struct thread_data *, const char *); extern void register_ioengine(struct ioengine_ops *); extern void unregister_ioengine(struct ioengine_ops *); +extern void free_ioengine(struct thread_data *); extern void close_ioengine(struct thread_data *); +extern int fio_show_ioengine_help(const char *engine); + /* * io unit handling */ @@ -157,7 +184,7 @@ extern int __must_check io_u_queued_complete(struct thread_data *, int, unsigned extern void io_u_queued(struct thread_data *, struct io_u *); extern void io_u_log_error(struct thread_data *, struct io_u *); extern void io_u_mark_depth(struct thread_data *, unsigned int); -extern void io_u_fill_buffer(struct thread_data *td, struct io_u *, unsigned int); +extern void io_u_fill_buffer(struct thread_data *td, struct io_u *, unsigned int, unsigned int); void io_u_mark_complete(struct thread_data *, unsigned int); void io_u_mark_submit(struct thread_data *, unsigned int);