X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=zbd.h;h=521283b200d0f6ceb24b699a901493e3381d55e9;hp=08751fd5bf348d43e0efc35f0b891f158eb06299;hb=ce4d13ca162df4127ec3b5911553802c53396705;hpb=a7c2b6fc2959cddbf7a479c86eb93d609669241a diff --git a/zbd.h b/zbd.h index 08751fd5..521283b2 100644 --- a/zbd.h +++ b/zbd.h @@ -31,8 +31,8 @@ enum io_u_action { /** * struct fio_zone_info - information about a single ZBD zone - * @start: zone start in 512 byte units - * @wp: zone write pointer location in 512 byte units + * @start: zone start location (bytes) + * @wp: zone write pointer location (bytes) * @verify_block: number of blocks that have been verified for this zone * @mutex: protects the modifiable members in this structure * @type: zone type (BLK_ZONE_TYPE_*) @@ -95,9 +95,25 @@ int zbd_init(struct thread_data *td); void zbd_file_reset(struct thread_data *td, struct fio_file *f); bool zbd_unaligned_write(int error_code); enum io_u_action zbd_adjust_block(struct thread_data *td, struct io_u *io_u); -int zbd_do_trim(struct thread_data *td, const struct io_u *io_u); -void zbd_update_wp(struct thread_data *td, const struct io_u *io_u); char *zbd_write_status(const struct thread_stat *ts); + +static inline void zbd_queue_io_u(struct io_u *io_u, enum fio_q_status status) +{ + if (io_u->zbd_queue_io) { + io_u->zbd_queue_io(io_u, status, io_u->error == 0); + io_u->zbd_queue_io = NULL; + } +} + +static inline void zbd_put_io_u(struct io_u *io_u) +{ + if (io_u->zbd_put_io) { + io_u->zbd_put_io(io_u); + io_u->zbd_queue_io = NULL; + io_u->zbd_put_io = NULL; + } +} + #else static inline void zbd_free_zone_info(struct fio_file *f) { @@ -123,20 +139,14 @@ static inline enum io_u_action zbd_adjust_block(struct thread_data *td, return io_u_accept; } -static inline int zbd_do_trim(struct thread_data *td, const struct io_u *io_u) -{ - return 1; -} - -static inline void zbd_update_wp(struct thread_data *td, - const struct io_u *io_u) -{ -} - static inline char *zbd_write_status(const struct thread_stat *ts) { return NULL; } + +static inline void zbd_queue_io_u(struct io_u *io_u, + enum fio_q_status status) {} +static inline void zbd_put_io_u(struct io_u *io_u) {} #endif #endif /* FIO_ZBD_H */