net/pktsched/pktsched_priq.c

225 		if ((cl = pif->pif_classes[pri]) != NULL && !qempty(&cl->cl_q))
364 		if (!qempty(&cl->cl_q))
367 		if (q_is_rio(&cl->cl_q))
371 		if (q_is_red(&cl->cl_q))
375 		if (q_is_blue(&cl->cl_q))
378 		if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
381 		qtype(&cl->cl_q) = Q_DROPTAIL;
382 		qstate(&cl->cl_q) = QS_RUNNING;
399 	_qinit(&cl->cl_q, Q_DROPTAIL, qlimit);
447 			    qlimit(&cl->cl_q) * 10/100,
448 			    qlimit(&cl->cl_q) * 30/100,
451 				qtype(&cl->cl_q) = Q_RED;
459 				qtype(&cl->cl_q) = Q_RIO;
467 				qtype(&cl->cl_q) = Q_BLUE;
473 				    qlimit(&cl->cl_q), cl->cl_qflags);
475 				qtype(&cl->cl_q) = Q_SFB;
509 	if (!qempty(&cl->cl_q))
531 		if (q_is_rio(&cl->cl_q))
535 		if (q_is_red(&cl->cl_q))
539 		if (q_is_blue(&cl->cl_q))
542 		if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
545 		qtype(&cl->cl_q) = Q_DROPTAIL;
546 		qstate(&cl->cl_q) = QS_RUNNING;
645 	VERIFY(cl != NULL && !qempty(&cl->cl_q));
655 	if (qempty(&cl->cl_q)) {
675 	if (q_is_rio(&cl->cl_q))
676 		return (rio_addq(cl->cl_rio, &cl->cl_q, m, t));
680 	if (q_is_red(&cl->cl_q))
681 		return (red_addq(cl->cl_red, &cl->cl_q, m, t));
685 	if (q_is_blue(&cl->cl_q))
686 		return (blue_addq(cl->cl_blue, &cl->cl_q, m, t));
689 	if (q_is_sfb(&cl->cl_q)) {
698 			    qlimit(&cl->cl_q), cl->cl_qflags);
701 				qtype(&cl->cl_q) = Q_DROPTAIL;
724 			return (sfb_addq(cl->cl_sfb, &cl->cl_q, m, t));
725 	} else if (qlen(&cl->cl_q) >= qlimit(&cl->cl_q)) {
734 	_addq(&cl->cl_q, m);
745 	if (q_is_rio(&cl->cl_q))
746 		return (rio_getq(cl->cl_rio, &cl->cl_q));
750 	if (q_is_red(&cl->cl_q))
751 		return (red_getq(cl->cl_red, &cl->cl_q));
755 	if (q_is_blue(&cl->cl_q))
756 		return (blue_getq(cl->cl_blue, &cl->cl_q));
759 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
760 		return (sfb_getq(cl->cl_sfb, &cl->cl_q));
762 	return (_getq(&cl->cl_q));
770 	return (qhead(&cl->cl_q));
782 	if ((qlen = qlen(&cl->cl_q)) == 0) {
791 	if (q_is_rio(&cl->cl_q))
792 		rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len);
796 	if (q_is_red(&cl->cl_q))
797 		red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len);
801 	if (q_is_blue(&cl->cl_q))
802 		blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len);
805 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
806 		sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len);
808 		_flushq_flow(&cl->cl_q, flow, &cnt, &len);
811 		VERIFY(qlen(&cl->cl_q) == (qlen - cnt));
819 		if (qempty(&cl->cl_q))
826 			    cl->cl_handle, cl->cl_pri, qlen, qlen(&cl->cl_q),
849 	if (q_is_rio(&cl->cl_q))
853 	if (q_is_red(&cl->cl_q))
857 	if (q_is_blue(&cl->cl_q))
860 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
877 	sp->qlength = qlen(&cl->cl_q);
878 	sp->qlimit = qlimit(&cl->cl_q);
883 	sp->qtype = qtype(&cl->cl_q);
884 	sp->qstate = qstate(&cl->cl_q);
886 	if (q_is_red(&cl->cl_q))
890 	if (q_is_rio(&cl->cl_q))
894 	if (q_is_blue(&cl->cl_q))
897 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1215 	if (q_is_rio(&cl->cl_q))
1216 		err = rio_suspendq(cl->cl_rio, &cl->cl_q, FALSE);
1220 	if (q_is_red(&cl->cl_q))
1221 		err = red_suspendq(cl->cl_red, &cl->cl_q, FALSE);
1225 	if (q_is_blue(&cl->cl_q))
1226 		err = blue_suspendq(cl->cl_blue, &cl->cl_q, FALSE);
1229 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1230 		err = sfb_suspendq(cl->cl_sfb, &cl->cl_q, FALSE);
1233 		qstate(&cl->cl_q) = QS_RUNNING;
1247 	if (q_is_rio(&cl->cl_q))
1248 		err = rio_suspendq(cl->cl_rio, &cl->cl_q, TRUE);
1252 	if (q_is_red(&cl->cl_q))
1253 		err = red_suspendq(cl->cl_red, &cl->cl_q, TRUE);
1257 	if (q_is_blue(&cl->cl_q))
1258 		err = blue_suspendq(cl->cl_blue, &cl->cl_q, TRUE);
1261 	if (q_is_sfb(&cl->cl_q)) {
1263 			err = sfb_suspendq(cl->cl_sfb, &cl->cl_q, TRUE);
1271 		qstate(&cl->cl_q) = QS_SUSPENDED;