X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=flow.c;h=c64bb3b27559053d27a79fa2c9a45f68de6e71c2;hb=b158577d787beaa6d098be3f180f947f7ad80b22;hp=aca051e6de40bd8b38516c53b6bdeb56eaa16a58;hpb=2b7968d3708da475edc9c37e7009ab4fe8a3ecf7;p=fio.git diff --git a/flow.c b/flow.c index aca051e6..c64bb3b2 100644 --- a/flow.c +++ b/flow.c @@ -7,7 +7,7 @@ struct fio_flow { unsigned int refs; unsigned int id; struct flist_head list; - unsigned long long flow_counter; + unsigned long flow_counter; unsigned int total_weight; }; @@ -37,6 +37,8 @@ int flow_threshold_exceeded(struct thread_data *td) if (td->o.flow_sleep) { io_u_quiesce(td); usleep(td->o.flow_sleep); + } else if (td->o.zone_mode == ZONE_MODE_ZBD) { + io_u_quiesce(td); } return 1; @@ -90,7 +92,7 @@ static struct fio_flow *flow_get(unsigned int id) return flow; } -static void flow_put(struct fio_flow *flow, unsigned long long flow_counter, +static void flow_put(struct fio_flow *flow, unsigned long flow_counter, unsigned int weight) { if (!flow_lock)