X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=ioengine.h;h=f7f3ec329c1c71491d16f5b07415f7d87ebe1724;hb=5ad7be56;hp=f9a0235cbf6e7f7fa24c9a60f4698591f6a37b6d;hpb=d8f1f7d4ef536ea04a6a5fbd0399d46f69ff4e60;p=fio.git diff --git a/ioengine.h b/ioengine.h index f9a0235c..f7f3ec32 100644 --- a/ioengine.h +++ b/ioengine.h @@ -15,7 +15,7 @@ #include #endif -#define FIO_IOOPS_VERSION 21 +#define FIO_IOOPS_VERSION 22 enum { IO_U_F_FREE = 1 << 0, @@ -119,6 +119,7 @@ struct io_u { struct ibv_mr *mr; #endif void *mmap_data; + uint64_t null; }; }; @@ -143,6 +144,7 @@ struct ioengine_ops { int (*commit)(struct thread_data *); int (*getevents)(struct thread_data *, unsigned int, unsigned int, const struct timespec *); struct io_u *(*event)(struct thread_data *, int); + char *(*errdetails)(struct io_u *); int (*cancel)(struct thread_data *, struct io_u *); void (*cleanup)(struct thread_data *); int (*open_file)(struct thread_data *, struct fio_file *); @@ -209,8 +211,8 @@ extern struct io_u *get_io_u(struct thread_data *); extern void put_io_u(struct thread_data *, struct io_u *); extern void clear_io_u(struct thread_data *, struct io_u *); extern void requeue_io_u(struct thread_data *, struct io_u **); -extern int __must_check io_u_sync_complete(struct thread_data *, struct io_u *, uint64_t *); -extern int __must_check io_u_queued_complete(struct thread_data *, int, uint64_t *); +extern int __must_check io_u_sync_complete(struct thread_data *, struct io_u *); +extern int __must_check io_u_queued_complete(struct thread_data *, int); extern void io_u_queued(struct thread_data *, struct io_u *); extern void io_u_quiesce(struct thread_data *); extern void io_u_log_error(struct thread_data *, struct io_u *); @@ -251,4 +253,14 @@ static inline enum fio_ddir acct_ddir(struct io_u *io_u) return io_u->ddir; } +static inline void io_u_clear(struct io_u *io_u, unsigned int flags) +{ + __sync_fetch_and_and(&io_u->flags, ~flags); +} + +static inline void io_u_set(struct io_u *io_u, unsigned int flags) +{ + __sync_fetch_and_or(&io_u->flags, flags); +} + #endif