net/pktsched/pktsched_tcq.c

140 	struct ifclassq *ifq = tif->tif_ifq;
143 	IFCQ_LOCK(ifq);
145 	IFCQ_UNLOCK(ifq);
214 	struct ifclassq *ifq = tif->tif_ifq;
217 	IFCQ_LOCK_ASSERT_HELD(ifq);
226 		tcq_purgeq(tif, ifq->ifcq_disc_slots[i].cl,
235 			tcq_purgeq(tif, ifq->ifcq_disc_slots[i].cl,
287 	struct ifclassq *ifq;
331 	ifq = tif->tif_ifq;
366 	if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
367 		qlimit = IFCQ_MAXLEN(ifq);
476 	struct ifclassq *ifq = tif->tif_ifq;
479 	IFCQ_LOCK_ASSERT_HELD(ifq);
532 	struct ifclassq *ifq = tif->tif_ifq;
535 	IFCQ_LOCK_ASSERT_HELD(ifq);
543 				IFCQ_CONVERT_LOCK(ifq);
563 			IFCQ_DROP_ADD(ifq, 1, len);
575 	IFCQ_INC_LEN(ifq);
597 	struct ifclassq *ifq = tif->tif_ifq;
600 	IFCQ_LOCK_ASSERT_HELD(ifq);
611 	VERIFY(!IFCQ_IS_EMPTY(ifq));
618 		IFCQ_DEC_LEN(ifq);
622 		IFCQ_XMIT_ADD(ifq, 1, m_pktlen(m));
631 	struct ifclassq *ifq = tif->tif_ifq;
633 	IFCQ_LOCK_ASSERT_HELD(ifq);
656 			IFCQ_CONVERT_LOCK(ifq);
687 		IFCQ_CONVERT_LOCK(ifq);
738 	struct ifclassq *ifq = tif->tif_ifq;
741 	IFCQ_LOCK_ASSERT_HELD(ifq);
747 	IFCQ_CONVERT_LOCK(ifq);
773 		IFCQ_DROP_ADD(ifq, cnt, len);
775 		VERIFY(((signed)IFCQ_LEN(ifq) - cnt) >= 0);
776 		IFCQ_LEN(ifq) -= cnt;
887 tcq_enqueue_ifclassq(struct ifclassq *ifq, struct mbuf *m)
891 	IFCQ_LOCK_ASSERT_HELD(ifq);
896 		    if_name(ifq->ifcq_ifp));
897 		IFCQ_CONVERT_LOCK(ifq);
905 	return (tcq_enqueue(ifq->ifcq_disc,
906 	    ifq->ifcq_disc_slots[i].cl, m, m_pftag(m)));
919 tcq_dequeue_tc_ifclassq(struct ifclassq *ifq, mbuf_svc_class_t sc,
926 	return (tcq_dequeue_cl(ifq->ifcq_disc,
927 	    ifq->ifcq_disc_slots[i].cl, sc, op));
931 tcq_request_ifclassq(struct ifclassq *ifq, cqrq_t req, void *arg)
933 	struct tcq_if	*tif = (struct tcq_if *)ifq->ifcq_disc;
936 	IFCQ_LOCK_ASSERT_HELD(ifq);
959 tcq_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags)
961 	struct ifnet *ifp = ifq->ifcq_ifp;
967 	IFCQ_LOCK_ASSERT_HELD(ifq);
968 	VERIFY(ifq->ifcq_disc == NULL);
969 	VERIFY(ifq->ifcq_type == PKTSCHEDT_NONE);
988 	if ((maxlen = IFCQ_MAXLEN(ifq)) == 0)
1007 	err = ifclassq_attach(ifq, PKTSCHEDT_TCQ, tif,
1014 		ifq->ifcq_disc_slots[SCIDX_BK_SYS].qid = SCIDX_BK;
1015 		ifq->ifcq_disc_slots[SCIDX_BK_SYS].cl = cl0;
1017 		ifq->ifcq_disc_slots[SCIDX_BK].qid = SCIDX_BK;
1018 		ifq->ifcq_disc_slots[SCIDX_BK].cl = cl0;
1021 		ifq->ifcq_disc_slots[SCIDX_BE].qid = SCIDX_BE;
1022 		ifq->ifcq_disc_slots[SCIDX_BE].cl = cl1;
1024 		ifq->ifcq_disc_slots[SCIDX_RD].qid = SCIDX_BE;
1025 		ifq->ifcq_disc_slots[SCIDX_RD].cl = cl1;
1027 		ifq->ifcq_disc_slots[SCIDX_OAM].qid = SCIDX_BE;
1028 		ifq->ifcq_disc_slots[SCIDX_OAM].cl = cl1;
1031 		ifq->ifcq_disc_slots[SCIDX_AV].qid = SCIDX_VI;
1032 		ifq->ifcq_disc_slots[SCIDX_AV].cl = cl2;
1034 		ifq->ifcq_disc_slots[SCIDX_RV].qid = SCIDX_VI;
1035 		ifq->ifcq_disc_slots[SCIDX_RV].cl = cl2;
1037 		ifq->ifcq_disc_slots[SCIDX_VI].qid = SCIDX_VI;
1038 		ifq->ifcq_disc_slots[SCIDX_VI].cl = cl2;
1041 		ifq->ifcq_disc_slots[SCIDX_VO].qid = SCIDX_VO;
1042 		ifq->ifcq_disc_slots[SCIDX_VO].cl = cl3;
1044 		ifq->ifcq_disc_slots[SCIDX_CTL].qid = SCIDX_VO;
1045 		ifq->ifcq_disc_slots[SCIDX_CTL].cl = cl3;
1056 tcq_teardown_ifclassq(struct ifclassq *ifq)
1058 	struct tcq_if *tif = ifq->ifcq_disc;
1061 	IFCQ_LOCK_ASSERT_HELD(ifq);
1062 	VERIFY(tif != NULL && ifq->ifcq_type == PKTSCHEDT_TCQ);
1066 	ifq->ifcq_disc = NULL;
1068 		ifq->ifcq_disc_slots[i].qid = 0;
1069 		ifq->ifcq_disc_slots[i].cl = NULL;
1072 	return (ifclassq_detach(ifq));
1076 tcq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot,
1079 	struct tcq_if *tif = ifq->ifcq_disc;
1081 	IFCQ_LOCK_ASSERT_HELD(ifq);
1082 	VERIFY(ifq->ifcq_type == PKTSCHEDT_TCQ);
1087 	return (tcq_get_class_stats(tif, ifq->ifcq_disc_slots[slot].qid,
1094 	struct ifclassq *ifq = tif->tif_ifq;
1098 	IFCQ_LOCK_ASSERT_HELD(ifq);
1110 	cl = ifq->ifcq_disc_slots[SCIDX_BK_SYS].cl;
1150 	struct ifclassq *ifq = tif->tif_ifq;
1153 	IFCQ_LOCK_ASSERT_HELD(ifq);
1182 	struct ifclassq *ifq = tif->tif_ifq;
1185 	IFCQ_LOCK_ASSERT_HELD(ifq);