90 	uint32_t flows_cnt;	/* number of flows */
122  * sub-queues and the flows array pointer even after the scheduler instance
129 	struct fq_pie_flow *flows;	/* array of flows (queues) */  member
149  * flows=1024, limit=10240, quantum =1514
273 SYSCTL_UINT(_net_inet_ip_dummynet_fqpie, OID_AUTO, flows,
567  * callout function to destroy PIE lock, and free fq_pie flows and fq_pie si
585 	/* when all sub-queues are destroyed, free flows fq_pie extra vars memory */  in fqpie_callout_cleanup()
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()
892 	 * new flows list, initialize and activate it.  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()
955 			 * by quantum, move the flow to the tail of old flows list  in fq_pie_dequeue()
969 		/* the new flows list is empty, try old flows list */  in fq_pie_dequeue()
978 			/* If the selected flow belongs to new flows list, then move   in fq_pie_dequeue()
979 			 * it to the tail of old flows list. Otherwise, deactivate it and  in fq_pie_dequeue()
1007  * also, allocate memory for flows array.
1015 	struct fq_pie_flow *flows;  in fq_pie_new_sched()  local
1039 	/* allocate memory for flows array */  in fq_pie_new_sched()
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()
1046 		D("cannot allocate memory for fq_pie flows");  in fq_pie_new_sched()
1054 	/* init the old and new flows lists */  in fq_pie_new_sched()
1058 	/* init the flows (sub-queues) */  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()
1110 	 * FQ_PIE: 7- quantum, 8- limit, 9- flows  in fq_pie_config()