Lines Matching refs:sel_flow
134 struct fq_pie_flow *sel_flow; in fq_pie_qdisc_enqueue() local
151 sel_flow = &q->flows[idx]; in fq_pie_qdisc_enqueue()
164 if (!pie_drop_early(sch, &q->p_params, &sel_flow->vars, in fq_pie_qdisc_enqueue()
165 sel_flow->backlog, skb->len)) { in fq_pie_qdisc_enqueue()
168 sel_flow->vars.prob <= (MAX_PROB / 100) * q->ecn_prob && in fq_pie_qdisc_enqueue()
186 flow_queue_add(sel_flow, skb); in fq_pie_qdisc_enqueue()
187 if (list_empty(&sel_flow->flowchain)) { in fq_pie_qdisc_enqueue()
188 list_add_tail(&sel_flow->flowchain, &q->new_flows); in fq_pie_qdisc_enqueue()
190 sel_flow->deficit = q->quantum; in fq_pie_qdisc_enqueue()
191 sel_flow->qlen = 0; in fq_pie_qdisc_enqueue()
192 sel_flow->backlog = 0; in fq_pie_qdisc_enqueue()
194 sel_flow->qlen++; in fq_pie_qdisc_enqueue()
195 sel_flow->backlog += pkt_len; in fq_pie_qdisc_enqueue()
200 sel_flow->vars.accu_prob = 0; in fq_pie_qdisc_enqueue()