net/pktsched/pktsched_qfq.c

489 	_qinit(&cl->cl_q, Q_DROPTAIL, qlimit);
603 			    qlimit(&cl->cl_q) * 10/100,
604 			    qlimit(&cl->cl_q) * 30/100,
607 				qtype(&cl->cl_q) = Q_RED;
615 				qtype(&cl->cl_q) = Q_RIO;
623 				qtype(&cl->cl_q) = Q_BLUE;
629 				    qlimit(&cl->cl_q), cl->cl_qflags);
631 				qtype(&cl->cl_q) = Q_SFB;
683 		if (q_is_rio(&cl->cl_q))
687 		if (q_is_red(&cl->cl_q))
691 		if (q_is_blue(&cl->cl_q))
694 		if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
697 		qtype(&cl->cl_q) = Q_DROPTAIL;
698 		qstate(&cl->cl_q) = QS_RUNNING;
903 	if (qempty(&cl->cl_q))  {
909 		len = m_pktlen(qhead(&cl->cl_q));
961 	VERIFY(cl != NULL && !qempty(&cl->cl_q));
975 	if (qempty(&cl->cl_q))
1121 	if (qlen(&cl->cl_q) > 1)
1309 	if (q_is_rio(&cl->cl_q))
1310 		return (rio_addq(cl->cl_rio, &cl->cl_q, m, t));
1314 	if (q_is_red(&cl->cl_q))
1315 		return (red_addq(cl->cl_red, &cl->cl_q, m, t));
1319 	if (q_is_blue(&cl->cl_q))
1320 		return (blue_addq(cl->cl_blue, &cl->cl_q, m, t));
1323 	if (q_is_sfb(&cl->cl_q)) {
1332 			    qlimit(&cl->cl_q), cl->cl_qflags);
1335 				qtype(&cl->cl_q) = Q_DROPTAIL;
1358 			return (sfb_addq(cl->cl_sfb, &cl->cl_q, m, t));
1359 	} else if (qlen(&cl->cl_q) >= qlimit(&cl->cl_q)) {
1368 	_addq(&cl->cl_q, m);
1379 	if (q_is_rio(&cl->cl_q))
1380 		return (rio_getq(cl->cl_rio, &cl->cl_q));
1384 	if (q_is_red(&cl->cl_q))
1385 		return (red_getq(cl->cl_red, &cl->cl_q));
1389 	if (q_is_blue(&cl->cl_q))
1390 		return (blue_getq(cl->cl_blue, &cl->cl_q));
1393 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1394 		return (sfb_getq(cl->cl_sfb, &cl->cl_q));
1396 	return (_getq(&cl->cl_q));
1404 	return (qhead(&cl->cl_q));
1416 	if ((qlen = qlen(&cl->cl_q)) == 0)
1423 	if (q_is_rio(&cl->cl_q))
1424 		rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len);
1428 	if (q_is_red(&cl->cl_q))
1429 		red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len);
1433 	if (q_is_blue(&cl->cl_q))
1434 		blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len);
1437 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1438 		sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len);
1440 		_flushq_flow(&cl->cl_q, flow, &cnt, &len);
1443 		VERIFY(qlen(&cl->cl_q) == (qlen - cnt));
1455 		if (qempty(&cl->cl_q))
1464 			    qlen(&cl->cl_q), cnt, len, flow);
1487 	if (q_is_rio(&cl->cl_q))
1491 	if (q_is_red(&cl->cl_q))
1495 	if (q_is_blue(&cl->cl_q))
1498 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1517 	sp->qlength = qlen(&cl->cl_q);
1518 	sp->qlimit = qlimit(&cl->cl_q);
1523 	sp->qtype = qtype(&cl->cl_q);
1524 	sp->qstate = qstate(&cl->cl_q);
1526 	if (q_is_red(&cl->cl_q))
1530 	if (q_is_rio(&cl->cl_q))
1534 	if (q_is_blue(&cl->cl_q))
1537 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1975 	if (q_is_rio(&cl->cl_q))
1976 		err = rio_suspendq(cl->cl_rio, &cl->cl_q, FALSE);
1980 	if (q_is_red(&cl->cl_q))
1981 		err = red_suspendq(cl->cl_red, &cl->cl_q, FALSE);
1985 	if (q_is_blue(&cl->cl_q))
1986 		err = blue_suspendq(cl->cl_blue, &cl->cl_q, FALSE);
1989 	if (q_is_sfb(&cl->cl_q) && cl->cl_sfb != NULL)
1990 		err = sfb_suspendq(cl->cl_sfb, &cl->cl_q, FALSE);
1993 		qstate(&cl->cl_q) = QS_RUNNING;
2007 	if (q_is_rio(&cl->cl_q))
2008 		err = rio_suspendq(cl->cl_rio, &cl->cl_q, TRUE);
2012 	if (q_is_red(&cl->cl_q))
2013 		err = red_suspendq(cl->cl_red, &cl->cl_q, TRUE);
2017 	if (q_is_blue(&cl->cl_q))
2018 		err = blue_suspendq(cl->cl_blue, &cl->cl_q, TRUE);
2021 	if (q_is_sfb(&cl->cl_q)) {
2023 			err = sfb_suspendq(cl->cl_sfb, &cl->cl_q, TRUE);
2031 		qstate(&cl->cl_q) = QS_SUSPENDED;