X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=flow.c;h=a8dbfb9bb48e66a991953810d2c25d92eeeacb54;hp=ee4d761db42bf30bb1f7b9667dda11f0b5d80d0c;hb=refs%2Fheads%2Fmaster;hpb=d4e74fda98b60dc175b4114492fcc7c21c617ddd diff --git a/flow.c b/flow.c index ee4d761d..c64bb3b2 100644 --- a/flow.c +++ b/flow.c @@ -5,9 +5,9 @@ struct fio_flow { unsigned int refs; - struct flist_head list; unsigned int id; - unsigned long long flow_counter; + struct flist_head list; + 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)