net/pktsched/pktsched_qfq.c

246 	struct ifclassq *ifq = qif->qif_ifq;
249 	IFCQ_LOCK(ifq);
251 	IFCQ_UNLOCK(ifq);
341 	struct ifclassq *ifq = qif->qif_ifq;
344 	IFCQ_LOCK_ASSERT_HELD(ifq);
353 		qfq_purgeq(qif, ifq->ifcq_disc_slots[i].cl,
362 			qfq_purgeq(qif, ifq->ifcq_disc_slots[i].cl,
421 	struct ifclassq *ifq;
475 	ifq = qif->qif_ifq;
484 	if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
485 		qlimit = IFCQ_MAXLEN(ifq);
661 	struct ifclassq *ifq = qif->qif_ifq;
664 	IFCQ_LOCK_ASSERT_HELD(ifq);
931 	struct ifclassq *ifq = qif->qif_ifq;
938 	IFCQ_LOCK_ASSERT_HELD(ifq);
958 	VERIFY(!IFCQ_IS_EMPTY(ifq));
974 	IFCQ_DEC_LEN(ifq);
978 	IFCQ_XMIT_ADD(ifq, 1, len);
1069 	struct ifclassq *ifq = qif->qif_ifq;
1074 	IFCQ_LOCK_ASSERT_HELD(ifq);
1082 				IFCQ_CONVERT_LOCK(ifq);
1102 			IFCQ_DROP_ADD(ifq, 1, len);
1114 	IFCQ_INC_LEN(ifq);
1304 	struct ifclassq *ifq = qif->qif_ifq;
1306 	IFCQ_LOCK_ASSERT_HELD(ifq);
1329 			IFCQ_CONVERT_LOCK(ifq);
1360 		IFCQ_CONVERT_LOCK(ifq);
1411 	struct ifclassq *ifq = qif->qif_ifq;
1414 	IFCQ_LOCK_ASSERT_HELD(ifq);
1420 	IFCQ_CONVERT_LOCK(ifq);
1450 		IFCQ_DROP_ADD(ifq, cnt, len);
1452 		VERIFY(((signed)IFCQ_LEN(ifq) - cnt) >= 0);
1453 		IFCQ_LEN(ifq) -= cnt;
1691 qfq_enqueue_ifclassq(struct ifclassq *ifq, struct mbuf *m)
1695 	IFCQ_LOCK_ASSERT_HELD(ifq);
1700 		    if_name(ifq->ifcq_ifp));
1701 		IFCQ_CONVERT_LOCK(ifq);
1709 	return (qfq_enqueue(ifq->ifcq_disc,
1710 	    ifq->ifcq_disc_slots[i].cl, m, m_pftag(m)));
1723 qfq_dequeue_ifclassq(struct ifclassq *ifq, cqdq_op_t op)
1725 	return (qfq_dequeue(ifq->ifcq_disc, op));
1729 qfq_request_ifclassq(struct ifclassq *ifq, cqrq_t req, void *arg)
1731 	struct qfq_if *qif = (struct qfq_if *)ifq->ifcq_disc;
1734 	IFCQ_LOCK_ASSERT_HELD(ifq);
1757 qfq_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags)
1759 	struct ifnet *ifp = ifq->ifcq_ifp;
1766 	IFCQ_LOCK_ASSERT_HELD(ifq);
1767 	VERIFY(ifq->ifcq_disc == NULL);
1768 	VERIFY(ifq->ifcq_type == PKTSCHEDT_NONE);
1787 	if ((maxlen = IFCQ_MAXLEN(ifq)) == 0)
1830 	err = ifclassq_attach(ifq, PKTSCHEDT_QFQ, qif,
1836 		ifq->ifcq_disc_slots[SCIDX_BK_SYS].qid = SCIDX_BK_SYS;
1837 		ifq->ifcq_disc_slots[SCIDX_BK_SYS].cl = cl0;
1839 		ifq->ifcq_disc_slots[SCIDX_BK].qid = SCIDX_BK;
1840 		ifq->ifcq_disc_slots[SCIDX_BK].cl = cl1;
1842 		ifq->ifcq_disc_slots[SCIDX_BE].qid = SCIDX_BE;
1843 		ifq->ifcq_disc_slots[SCIDX_BE].cl = cl2;
1845 		ifq->ifcq_disc_slots[SCIDX_RD].qid = SCIDX_RD;
1846 		ifq->ifcq_disc_slots[SCIDX_RD].cl = cl3;
1848 		ifq->ifcq_disc_slots[SCIDX_OAM].qid = SCIDX_OAM;
1849 		ifq->ifcq_disc_slots[SCIDX_OAM].cl = cl4;
1851 		ifq->ifcq_disc_slots[SCIDX_AV].qid = SCIDX_AV;
1852 		ifq->ifcq_disc_slots[SCIDX_AV].cl = cl5;
1854 		ifq->ifcq_disc_slots[SCIDX_RV].qid = SCIDX_RV;
1855 		ifq->ifcq_disc_slots[SCIDX_RV].cl = cl6;
1857 		ifq->ifcq_disc_slots[SCIDX_VI].qid = SCIDX_VI;
1858 		ifq->ifcq_disc_slots[SCIDX_VI].cl = cl7;
1860 		ifq->ifcq_disc_slots[SCIDX_VO].qid = SCIDX_VO;
1861 		ifq->ifcq_disc_slots[SCIDX_VO].cl = cl8;
1863 		ifq->ifcq_disc_slots[SCIDX_CTL].qid = SCIDX_CTL;
1864 		ifq->ifcq_disc_slots[SCIDX_CTL].cl = cl9;
1875 qfq_teardown_ifclassq(struct ifclassq *ifq)
1877 	struct qfq_if *qif = ifq->ifcq_disc;
1880 	IFCQ_LOCK_ASSERT_HELD(ifq);
1881 	VERIFY(qif != NULL && ifq->ifcq_type == PKTSCHEDT_QFQ);
1885 	ifq->ifcq_disc = NULL;
1887 		ifq->ifcq_disc_slots[i].qid = 0;
1888 		ifq->ifcq_disc_slots[i].cl = NULL;
1891 	return (ifclassq_detach(ifq));
1895 qfq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot,
1898 	struct qfq_if *qif = ifq->ifcq_disc;
1900 	IFCQ_LOCK_ASSERT_HELD(ifq);
1901 	VERIFY(ifq->ifcq_type == PKTSCHEDT_QFQ);
1906 	return (qfq_get_class_stats(qif, ifq->ifcq_disc_slots[slot].qid,
1913 	struct ifclassq *ifq = qif->qif_ifq;
1917 	IFCQ_LOCK_ASSERT_HELD(ifq);
1929 	cl = ifq->ifcq_disc_slots[SCIDX_BK_SYS].cl;
1969 	struct ifclassq *ifq = qif->qif_ifq;
1972 	IFCQ_LOCK_ASSERT_HELD(ifq);
2001 	struct ifclassq *ifq = qif->qif_ifq;
2004 	IFCQ_LOCK_ASSERT_HELD(ifq);