sign = td->o.flow > 0 ? 1 : -1;
if (sign * flow->flow_counter > td->o.flow_watermark) {
- if (td->o.flow_sleep)
+ if (td->o.flow_sleep) {
+ io_u_quiesce(td);
usleep(td->o.flow_sleep);
+ }
+
return 1;
}
flow = smalloc(sizeof(*flow));
if (!flow) {
log_err("fio: smalloc pool exhausted\n");
+ fio_mutex_up(flow_lock);
return NULL;
}
flow->refs = 0;