Lines Matching refs:flows
129 struct fq_pie_flow *flows; /* array of flows (queues) */ member
273 SYSCTL_UINT(_net_inet_ip_dummynet_fqpie, OID_AUTO, flows,
587 free(psi_extra->flows, M_DUMMYNET); in fqpie_callout_cleanup()
870 struct fq_pie_flow *flows; in fq_pie_enqueue() local
875 flows = si->si_extra->flows; in fq_pie_enqueue()
885 drop = pie_enqueue(&flows[idx], m, si); in fq_pie_enqueue()
894 if (!flows[idx].active) { in fq_pie_enqueue()
895 STAILQ_INSERT_TAIL(&si->newflows, &flows[idx], flowchain); in fq_pie_enqueue()
896 flows[idx].deficit = param->quantum; in fq_pie_enqueue()
897 fq_activate_pie(&flows[idx]); in fq_pie_enqueue()
898 flows[idx].active = 1; in fq_pie_enqueue()
907 if (flows[maxidx].active) in fq_pie_enqueue()
912 if (flows[i].active && flows[i].stats.length > in fq_pie_enqueue()
913 flows[maxidx].stats.length) in fq_pie_enqueue()
915 pie_drop_head(&flows[maxidx], si); in fq_pie_enqueue()
1015 struct fq_pie_flow *flows; in fq_pie_new_sched() local
1040 si->si_extra->flows = mallocarray(schk->cfg.flows_cnt, in fq_pie_new_sched()
1042 flows = si->si_extra->flows; in fq_pie_new_sched()
1043 if (flows == NULL) { in fq_pie_new_sched()
1060 flows[i].pst.parms = &schk->cfg.pcfg; in fq_pie_new_sched()
1061 flows[i].psi_extra = si->si_extra; in fq_pie_new_sched()
1062 pie_init(&flows[i], schk); in fq_pie_new_sched()
1080 struct fq_pie_flow *flows; in fq_pie_free_sched() local
1085 flows = si->si_extra->flows; in fq_pie_free_sched()
1087 pie_cleanup(&flows[i]); in fq_pie_free_sched()