98 	struct priq_if	*pif;  in priq_add_altq()  local
105 	pif = malloc(sizeof(struct priq_if), M_DEVBUF, M_NOWAIT | M_ZERO);  in priq_add_altq()
106 	if (pif == NULL)  in priq_add_altq()
108 	pif->pif_bandwidth = a->ifbandwidth;  in priq_add_altq()
109 	pif->pif_maxpri = -1;  in priq_add_altq()
110 	pif->pif_ifq = &ifp->if_snd;  in priq_add_altq()
113 	a->altq_disc = pif;  in priq_add_altq()
121 	struct priq_if *pif;  in priq_remove_altq()  local
123 	if ((pif = a->altq_disc) == NULL)  in priq_remove_altq()
127 	(void)priq_clear_interface(pif);  in priq_remove_altq()
129 	free(pif, M_DEVBUF);  in priq_remove_altq()
136 	struct priq_if *pif;  in priq_add_queue()  local
139 	if ((pif = a->altq_disc) == NULL)  in priq_add_queue()
147 	if (pif->pif_classes[a->priority] != NULL)  in priq_add_queue()
149 	if (clh_to_clp(pif, a->qid) != NULL)  in priq_add_queue()
152 	cl = priq_class_create(pif, a->priority, a->qlimit,  in priq_add_queue()
163 	struct priq_if *pif;  in priq_remove_queue()  local
166 	if ((pif = a->altq_disc) == NULL)  in priq_remove_queue()
169 	if ((cl = clh_to_clp(pif, a->qid)) == NULL)  in priq_remove_queue()
178 	struct priq_if *pif;  in priq_getqstats()  local
183 	if ((pif = altq_lookup(a->ifname, ALTQT_PRIQ)) == NULL)  in priq_getqstats()
186 	if ((cl = clh_to_clp(pif, a->qid)) == NULL)  in priq_getqstats()
205 priq_clear_interface(struct priq_if *pif)  in priq_clear_interface()  argument
212 	acc_discard_filters(&pif->pif_classifier, NULL, 1);  in priq_clear_interface()
216 	for (pri = 0; pri <= pif->pif_maxpri; pri++)  in priq_clear_interface()
217 		if ((cl = pif->pif_classes[pri]) != NULL)  in priq_clear_interface()
226 	struct priq_if	*pif = (struct priq_if *)ifq->altq_disc;  in priq_request()  local
232 		priq_purge(pif);  in priq_request()
240 priq_purge(struct priq_if *pif)  in priq_purge()  argument
245 	for (pri = 0; pri <= pif->pif_maxpri; pri++) {  in priq_purge()
246 		if ((cl = pif->pif_classes[pri]) != NULL && !qempty(cl->cl_q))  in priq_purge()
249 	if (ALTQ_IS_ENABLED(pif->pif_ifq))  in priq_purge()
250 		pif->pif_ifq->ifq_len = 0;  in priq_purge()
254 priq_class_create(struct priq_if *pif, int pri, int qlimit, int flags, int qid)  in priq_class_create()  argument
276 	if ((cl = pif->pif_classes[pri]) != NULL) {  in priq_class_create()
308 	pif->pif_classes[pri] = cl;  in priq_class_create()
310 		pif->pif_default = cl;  in priq_class_create()
319 	if (pri > pif->pif_maxpri)  in priq_class_create()
320 		pif->pif_maxpri = pri;  in priq_class_create()
321 	cl->cl_pif = pif;  in priq_class_create()
335 		if (pif->pif_bandwidth < 8)  in priq_class_create()
338 			red_pkttime = (int64_t)pif->pif_ifq->altq_ifp->if_mtu  in priq_class_create()
339 			  * 1000 * 1000 * 1000 / (pif->pif_bandwidth / 8);  in priq_class_create()
394 	struct priq_if *pif;  in priq_class_destroy()  local
408 	pif = cl->cl_pif;  in priq_class_destroy()
409 	pif->pif_classes[cl->cl_pri] = NULL;  in priq_class_destroy()
410 	if (pif->pif_maxpri == cl->cl_pri) {  in priq_class_destroy()
412 			if (pif->pif_classes[pri] != NULL) {  in priq_class_destroy()
413 				pif->pif_maxpri = pri;  in priq_class_destroy()
417 			pif->pif_maxpri = -1;  in priq_class_destroy()
448 	struct priq_if	*pif = (struct priq_if *)ifq->altq_disc;  in priq_enqueue()  local
465 		cl = clh_to_clp(pif, t->qid);  in priq_enqueue()
467 		cl = pif->pif_default;  in priq_enqueue()
498 	struct priq_if	*pif = (struct priq_if *)ifq->altq_disc;  in priq_dequeue()  local
509 	for (pri = pif->pif_maxpri;  pri >= 0; pri--) {  in priq_dequeue()
510 		if ((cl = pif->pif_classes[pri]) != NULL &&  in priq_dequeue()
624 clh_to_clp(struct priq_if *pif, u_int32_t chandle)  in clh_to_clp()  argument
632 	for (idx = pif->pif_maxpri; idx >= 0; idx--)  in clh_to_clp()
633 		if ((cl = pif->pif_classes[idx]) != NULL &&  in clh_to_clp()