Lines Matching refs:td
16 int flow_threshold_exceeded(struct thread_data *td)
18 struct fio_flow *flow = td->flow;
24 sign = td->o.flow > 0 ? 1 : -1;
25 if (sign * flow->flow_counter > td->o.flow_watermark) {
26 if (td->o.flow_sleep) {
27 io_u_quiesce(td);
28 usleep(td->o.flow_sleep);
36 flow->flow_counter += td->o.flow;
92 void flow_init_job(struct thread_data *td)
94 if (td->o.flow)
95 td->flow = flow_get(td->o.flow_id);
98 void flow_exit_job(struct thread_data *td)
100 if (td->flow) {
101 flow_put(td->flow);
102 td->flow = NULL;
