path: root/zbd.c
diff options
authorShin'ichiro Kawasaki <>2021-01-27 13:19:18 +0900
committerJens Axboe <>2021-01-29 08:14:00 -0700
commit43bcbd5b55ada031fe94a505f48e878a027de445 (patch)
tree50f1b040fd99857062d0e3ece861ba0a75afd3bd /zbd.c
parent21c0c884ed77df2ad72e0e54fce5973cfb6e4426 (diff)
zbd: do not set zbd handlers for conventional zones
When zbd_adjust_block() modifies io_u to satisfy write pointer restrictions, it may change the zone for the io_u. The function sets pointers to zbd_queue_io() and zbd_put_io() handlers to io_u to further process write pointer zones. However, when the I/O is redirected to a conventional zone, these handlers should not be set in io_u. Skip setting the handlers when this function returns a conventional zone. When zbd_adjust_block() can not find a zone to fit the I/O, the existing code unlocks the zone pointer 'zb' used in the function. This unlock should not be performed if 'zb' points to a conventional zone upon return, skip it in this case. These changes make the assert for 'zb' pointer near 'accept' label in zbd_adjust_block() unnecessary. Replace it with assert for zb->has_wp, since the zone at the step shall have write pointer. Since zone locking functions (zone_lock(), zbd_queue_io() and zbd_put_io()) are supposed to be called only for write pointer zones, add assertions to zone_lock() and zone_unlock() to make sure this is the case. This allows us to convert a few existing conditional checks to assertions to make zone type validation more strict. Signed-off-by: Shin'ichiro Kawasaki <> Signed-off-by: Dmitry Fomichev <> Signed-off-by: Jens Axboe <>
Diffstat (limited to 'zbd.c')
1 files changed, 13 insertions, 6 deletions
diff --git a/zbd.c b/zbd.c
index a14e4a38..88cbc6fa 100644
--- a/zbd.c
+++ b/zbd.c
@@ -174,6 +174,8 @@ static void zone_lock(struct thread_data *td, struct fio_file *f, struct fio_zon
/* A thread should never lock zones outside its working area. */
assert(f->min_zone <= nz && nz < f->max_zone);
+ assert(z->has_wp);
* Lock the io_u target zone. The zone will be unlocked if io_u offset
* is changed or when io_u completes and zbd_put_io() executed.
@@ -194,6 +196,7 @@ static inline void zone_unlock(struct fio_zone_info *z)
int ret;
+ assert(z->has_wp);
ret = pthread_mutex_unlock(&z->mutex);
@@ -1326,8 +1329,7 @@ static void zbd_queue_io(struct thread_data *td, struct io_u *io_u, int q,
assert(zone_idx < zbd_info->nr_zones);
z = get_zone(f, zone_idx);
- if (!z->has_wp)
- return;
+ assert(z->has_wp);
if (!success)
goto unlock;
@@ -1386,8 +1388,7 @@ static void zbd_put_io(struct thread_data *td, const struct io_u *io_u)
assert(zone_idx < zbd_info->nr_zones);
z = get_zone(f, zone_idx);
- if (!z->has_wp)
- return;
+ assert(z->has_wp);
"%s: terminate I/O (%lld, %llu) for zone %u\n",
@@ -1618,6 +1619,12 @@ enum io_u_action zbd_adjust_block(struct thread_data *td, struct io_u *io_u)
((io_u->offset - orig_zb->start) %
(range - io_u->buflen)) / min_bs * min_bs;
+ * When zbd_find_zone() returns a conventional zone,
+ * we can simply accept the new i/o offset here.
+ */
+ if (!zb->has_wp)
+ return io_u_accept;
+ /*
* Make sure the I/O does not cross over the zone wp position.
new_len = min((unsigned long long)io_u->buflen,
@@ -1713,7 +1720,7 @@ enum io_u_action zbd_adjust_block(struct thread_data *td, struct io_u *io_u)
- assert(zb);
+ assert(zb->has_wp);
assert(zb->cond != ZBD_ZONE_COND_OFFLINE);
@@ -1722,7 +1729,7 @@ accept:
return io_u_accept;
- if (zb)
+ if (zb && zb->has_wp)
return io_u_eof;