net/pktsched/pktsched_tcq.c

197 		if ((cl = tif->tif_classes[pri]) != NULL && !qempty(&cl->cl_q))
336 		if (!qempty(&cl->cl_q))
339 		if (q_is_rio(&cl->cl_q))
343 		if (q_is_red(&cl->cl_q))
347 		if (q_is_blue(&cl->cl_q))
350 		if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
353 		qtype(&cl->cl_q) = Q_DROPTAIL;
354 		qstate(&cl->cl_q) = QS_RUNNING;
371 	_qinit(&cl->cl_q, Q_DROPTAIL, qlimit);
419 			    qlimit(&cl->cl_q) * 10/100,
420 			    qlimit(&cl->cl_q) * 30/100,
423 				qtype(&cl->cl_q) = Q_RED;
431 				qtype(&cl->cl_q) = Q_RIO;
439 				qtype(&cl->cl_q) = Q_BLUE;
445 				    qlimit(&cl->cl_q), cl->cl_qflags);
447 				qtype(&cl->cl_q) = Q_SFB;
481 	if (!qempty(&cl->cl_q))
500 		if (q_is_rio(&cl->cl_q))
504 		if (q_is_red(&cl->cl_q))
508 		if (q_is_blue(&cl->cl_q))
511 		if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
514 		qtype(&cl->cl_q) = Q_DROPTAIL;
515 		qstate(&cl->cl_q) = QS_RUNNING;
608 	if (qempty(&cl->cl_q))
619 		if (qempty(&cl->cl_q))
636 	if (q_is_rio(&cl->cl_q))
637 		return (rio_addq(cl->cl_rio, &cl->cl_q, m, t));
641 	if (q_is_red(&cl->cl_q))
642 		return (red_addq(cl->cl_red, &cl->cl_q, m, t));
646 	if (q_is_blue(&cl->cl_q))
647 		return (blue_addq(cl->cl_blue, &cl->cl_q, m, t));
650 	if (q_is_sfb(&cl->cl_q)) {
659 			    qlimit(&cl->cl_q), cl->cl_qflags);
662 				qtype(&cl->cl_q) = Q_DROPTAIL;
685 			return (sfb_addq(cl->cl_sfb, &cl->cl_q, m, t));
686 	} else if (qlen(&cl->cl_q) >= qlimit(&cl->cl_q)) {
695 	_addq(&cl->cl_q, m);
706 	if (q_is_rio(&cl->cl_q))
707 		return (rio_getq(cl->cl_rio, &cl->cl_q));
711 	if (q_is_red(&cl->cl_q))
712 		return (red_getq(cl->cl_red, &cl->cl_q));
716 	if (q_is_blue(&cl->cl_q))
717 		return (blue_getq(cl->cl_blue, &cl->cl_q));
720 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
721 		return (sfb_getq(cl->cl_sfb, &cl->cl_q));
723 	return (_getq(&cl->cl_q));
731 	return (qhead(&cl->cl_q));
743 	if ((qlen = qlen(&cl->cl_q)) == 0)
750 	if (q_is_rio(&cl->cl_q))
751 		rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len);
755 	if (q_is_red(&cl->cl_q))
756 		red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len);
760 	if (q_is_blue(&cl->cl_q))
761 		blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len);
764 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
765 		sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len);
767 		_flushq_flow(&cl->cl_q, flow, &cnt, &len);
770 		VERIFY(qlen(&cl->cl_q) == (qlen - cnt));
782 			    cl->cl_handle, cl->cl_pri, qlen, qlen(&cl->cl_q),
805 	if (q_is_rio(&cl->cl_q))
809 	if (q_is_red(&cl->cl_q))
813 	if (q_is_blue(&cl->cl_q))
816 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
833 	sp->qlength = qlen(&cl->cl_q);
834 	sp->qlimit = qlimit(&cl->cl_q);
839 	sp->qtype = qtype(&cl->cl_q);
840 	sp->qstate = qstate(&cl->cl_q);
842 	if (q_is_red(&cl->cl_q))
846 	if (q_is_rio(&cl->cl_q))
850 	if (q_is_blue(&cl->cl_q))
853 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1156 	if (q_is_rio(&cl->cl_q))
1157 		err = rio_suspendq(cl->cl_rio, &cl->cl_q, FALSE);
1161 	if (q_is_red(&cl->cl_q))
1162 		err = red_suspendq(cl->cl_red, &cl->cl_q, FALSE);
1166 	if (q_is_blue(&cl->cl_q))
1167 		err = blue_suspendq(cl->cl_blue, &cl->cl_q, FALSE);
1170 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1171 		err = sfb_suspendq(cl->cl_sfb, &cl->cl_q, FALSE);
1174 		qstate(&cl->cl_q) = QS_RUNNING;
1188 	if (q_is_rio(&cl->cl_q))
1189 		err = rio_suspendq(cl->cl_rio, &cl->cl_q, TRUE);
1193 	if (q_is_red(&cl->cl_q))
1194 		err = red_suspendq(cl->cl_red, &cl->cl_q, TRUE);
1198 	if (q_is_blue(&cl->cl_q))
1199 		err = blue_suspendq(cl->cl_blue, &cl->cl_q, TRUE);
1202 	if (q_is_sfb(&cl->cl_q)) {
1204 			err = sfb_suspendq(cl->cl_sfb, &cl->cl_q, TRUE);
1212 		qstate(&cl->cl_q) = QS_SUSPENDED;