Similar potential latency problem as was fixed for thinktime
in commit
002e7183 and for rated IO in commit
c3a1b740.
Signed-off-by: Jens Axboe <axboe@kernel.dk>
sign = td->o.flow > 0 ? 1 : -1;
if (sign * flow->flow_counter > td->o.flow_watermark) {
sign = td->o.flow > 0 ? 1 : -1;
if (sign * flow->flow_counter > td->o.flow_watermark) {
+ if (td->o.flow_sleep) {
+ io_u_quiesce(td);
usleep(td->o.flow_sleep);
usleep(td->o.flow_sleep);