Lines Matching refs:flows
96 uint32_t flows_cnt; /* number of flows */
129 * sub-queues and the flows array pointer even after the scheduler instance
136 struct fq_pie_flow *flows; /* array of flows (queues) */
157 * flows=1024, limit=10240, quantum =1514
278 SYSCTL_UINT(_net_inet_ip_dummynet_fqpie, OID_AUTO, flows,
569 * callout function to destroy PIE lock, and free fq_pie flows and fq_pie si
587 /* when all sub-queues are destroyed, free flows fq_pie extra vars memory */
589 free(psi_extra->flows, M_DUMMYNET);
870 struct fq_pie_flow *flows;
875 flows = si->si_extra->flows;
885 drop = pie_enqueue(&flows[idx], m, si);
892 * new flows list, initialize and activate it.
894 if (!flows[idx].active) {
895 STAILQ_INSERT_TAIL(&si->newflows, &flows[idx], flowchain);
896 flows[idx].deficit = param->quantum;
897 fq_activate_pie(&flows[idx]);
898 flows[idx].active = 1;
907 if (flows[maxidx].active)
912 if (flows[i].active && flows[i].stats.length >
913 flows[maxidx].stats.length)
915 pie_drop_head(&flows[maxidx], si);
955 * by quantum, move the flow to the tail of old flows list
969 /* the new flows list is empty, try old flows list */
978 /* If the selected flow belongs to new flows list, then move
979 * it to the tail of old flows list. Otherwise, deactivate it and
1007 * also, allocate memory for flows array.
1015 struct fq_pie_flow *flows;
1039 /* allocate memory for flows array */
1040 si->si_extra->flows = mallocarray(schk->cfg.flows_cnt,
1042 flows = si->si_extra->flows;
1043 if (flows == NULL) {
1046 D("cannot allocate memory for fq_pie flows");
1054 /* init the old and new flows lists */
1058 /* init the flows (sub-queues) */
1060 flows[i].pst.parms = &schk->cfg.pcfg;
1061 flows[i].psi_extra = si->si_extra;
1062 pie_init(&flows[i], schk);
1079 struct fq_pie_flow *flows;
1084 flows = si->si_extra->flows;
1086 pie_cleanup(&flows[i]);
1109 * FQ_PIE: 7- quantum, 8- limit, 9- flows