Searched refs:ifq (Results 1 - 25 of 29) sorted by relevance

12

/xnu-2422.115.4/bsd/net/classq/
H A Dclassq_subr.c91 struct ifclassq *ifq = &ifp->if_snd; local
94 IFCQ_LOCK(ifq);
95 VERIFY(IFCQ_IS_EMPTY(ifq));
96 ifq->ifcq_ifp = ifp;
97 IFCQ_LEN(ifq) = 0;
98 bzero(&ifq->ifcq_xmitcnt, sizeof (ifq->ifcq_xmitcnt));
99 bzero(&ifq->ifcq_dropcnt, sizeof (ifq->ifcq_dropcnt));
101 VERIFY(!IFCQ_TBR_IS_ENABLED(ifq));
149 struct ifclassq *ifq = &ifp->if_snd; local
200 ifclassq_pktsched_setup(struct ifclassq *ifq) argument
226 ifclassq_set_maxlen(struct ifclassq *ifq, u_int32_t maxqlen) argument
236 ifclassq_get_maxlen(struct ifclassq *ifq) argument
242 ifclassq_get_len(struct ifclassq *ifq, mbuf_svc_class_t sc, u_int32_t *packets, u_int32_t *bytes) argument
262 ifclassq_enqueue(struct ifclassq *ifq, struct mbuf *m) argument
287 ifclassq_dequeue(struct ifclassq *ifq, u_int32_t limit, struct mbuf **head, struct mbuf **tail, u_int32_t *cnt, u_int32_t *len) argument
295 ifclassq_dequeue_sc(struct ifclassq *ifq, mbuf_svc_class_t sc, u_int32_t limit, struct mbuf **head, struct mbuf **tail, u_int32_t *cnt, u_int32_t *len) argument
304 ifclassq_dequeue_common(struct ifclassq *ifq, mbuf_svc_class_t sc, u_int32_t limit, struct mbuf **head, struct mbuf **tail, u_int32_t *cnt, u_int32_t *len, boolean_t drvmgt) argument
402 ifclassq_poll(struct ifclassq *ifq) argument
408 ifclassq_poll_sc(struct ifclassq *ifq, mbuf_svc_class_t sc) argument
414 ifclassq_poll_common(struct ifclassq *ifq, mbuf_svc_class_t sc, boolean_t drvmgt) argument
462 ifclassq_update(struct ifclassq *ifq, cqev_t ev) argument
475 ifclassq_attach(struct ifclassq *ifq, u_int32_t type, void *discipline, ifclassq_enq_func enqueue, ifclassq_deq_func dequeue, ifclassq_deq_sc_func dequeue_sc, ifclassq_req_func request) argument
497 ifclassq_detach(struct ifclassq *ifq) argument
514 ifclassq_getqstats(struct ifclassq *ifq, u_int32_t qid, void *ubuf, u_int32_t *nbytes) argument
598 ifclassq_tbr_dequeue(struct ifclassq *ifq, int op) argument
604 ifclassq_tbr_dequeue_sc(struct ifclassq *ifq, int op, mbuf_svc_class_t sc) argument
610 ifclassq_tbr_dequeue_common(struct ifclassq *ifq, int op, mbuf_svc_class_t sc, boolean_t drvmgt) argument
689 ifclassq_tbr_set(struct ifclassq *ifq, struct tb_profile *profile, boolean_t update) argument
[all...]
/xnu-2422.115.4/bsd/net/pktsched/
H A Dpktsched.c131 pktsched_setup(struct ifclassq *ifq, u_int32_t scheduler, u_int32_t sflags) argument
137 IFCQ_LOCK_ASSERT_HELD(ifq);
142 if (ifq->ifcq_type == scheduler)
160 rflags = (ifq->ifcq_flags & IFCQF_ENABLED);
162 if (ifq->ifcq_type != PKTSCHEDT_NONE) {
163 (void) pktsched_teardown(ifq);
166 VERIFY(ifq->ifcq_type == PKTSCHEDT_NONE);
167 VERIFY(ifq->ifcq_disc == NULL);
168 VERIFY(ifq->ifcq_enqueue == NULL);
169 VERIFY(ifq
201 pktsched_teardown(struct ifclassq *ifq) argument
239 pktsched_getqstats(struct ifclassq *ifq, u_int32_t qid, struct if_ifclassq_stats *ifqs) argument
[all...]
H A Dpktsched_tcq.c141 struct ifclassq *ifq = tif->tif_ifq; local
144 IFCQ_LOCK(ifq);
146 IFCQ_UNLOCK(ifq);
215 struct ifclassq *ifq = tif->tif_ifq; local
218 IFCQ_LOCK_ASSERT_HELD(ifq);
227 tcq_purgeq(tif, ifq->ifcq_disc_slots[i].cl,
236 tcq_purgeq(tif, ifq->ifcq_disc_slots[i].cl,
288 struct ifclassq *ifq; local
332 ifq = tif->tif_ifq;
367 if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
477 struct ifclassq *ifq = tif->tif_ifq; local
533 struct ifclassq *ifq = tif->tif_ifq; local
602 struct ifclassq *ifq = tif->tif_ifq; local
636 struct ifclassq *ifq = tif->tif_ifq; local
745 struct ifclassq *ifq = tif->tif_ifq; local
869 struct ifclassq *ifq = tif->tif_ifq; local
915 tcq_enqueue_ifclassq(struct ifclassq *ifq, struct mbuf *m) argument
947 tcq_dequeue_tc_ifclassq(struct ifclassq *ifq, mbuf_svc_class_t sc, cqdq_op_t op) argument
959 tcq_request_ifclassq(struct ifclassq *ifq, cqrq_t req, void *arg) argument
991 tcq_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags) argument
1088 tcq_teardown_ifclassq(struct ifclassq *ifq) argument
1108 tcq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot, struct if_ifclassq_stats *ifqs) argument
1126 struct ifclassq *ifq = tif->tif_ifq; local
1182 struct ifclassq *ifq = tif->tif_ifq; local
1214 struct ifclassq *ifq = tif->tif_ifq; local
[all...]
H A Dpktsched_priq.c169 struct ifclassq *ifq = pif->pif_ifq; local
172 IFCQ_LOCK(ifq);
174 IFCQ_UNLOCK(ifq);
243 struct ifclassq *ifq = pif->pif_ifq; local
246 IFCQ_LOCK_ASSERT_HELD(ifq);
255 priq_purgeq(pif, ifq->ifcq_disc_slots[i].cl,
264 priq_purgeq(pif, ifq->ifcq_disc_slots[i].cl,
316 struct ifclassq *ifq; local
360 ifq = pif->pif_ifq;
395 if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
505 struct ifclassq *ifq = pif->pif_ifq; local
565 struct ifclassq *ifq = pif->pif_ifq; local
634 struct ifclassq *ifq = pif->pif_ifq; local
675 struct ifclassq *ifq = pif->pif_ifq; local
784 struct ifclassq *ifq = pif->pif_ifq; local
913 struct ifclassq *ifq = pif->pif_ifq; local
959 priq_enqueue_ifclassq(struct ifclassq *ifq, struct mbuf *m) argument
991 priq_dequeue_ifclassq(struct ifclassq *ifq, cqdq_op_t op) argument
997 priq_request_ifclassq(struct ifclassq *ifq, cqrq_t req, void *arg) argument
1029 priq_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags) argument
1147 priq_teardown_ifclassq(struct ifclassq *ifq) argument
1167 priq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot, struct if_ifclassq_stats *ifqs) argument
1185 struct ifclassq *ifq = pif->pif_ifq; local
1241 struct ifclassq *ifq = pif->pif_ifq; local
1273 struct ifclassq *ifq = pif->pif_ifq; local
[all...]
H A Dpktsched_cbq.c157 struct ifclassq *ifq = cbqp->ifnp.ifq_; local
160 IFCQ_LOCK(ifq);
162 IFCQ_UNLOCK(ifq);
513 struct ifclassq *ifq = cbqp->ifnp.ifq_; local
516 IFCQ_LOCK_ASSERT_HELD(ifq);
522 if_name(ifq->ifcq_ifp));
523 IFCQ_CONVERT_LOCK(ifq);
537 IFCQ_CONVERT_LOCK(ifq);
557 IFCQ_DROP_ADD(ifq, 1, len);
572 IFCQ_INC_LEN(ifq);
580 struct ifclassq *ifq = cbqp->ifnp.ifq_; local
607 cbqrestart(struct ifclassq *ifq) argument
662 cqb_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags) argument
669 cbq_teardown_ifclassq(struct ifclassq *ifq) argument
689 cbq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot, struct if_ifclassq_stats *ifqs) argument
[all...]
H A Dpktsched_qfq.c247 struct ifclassq *ifq = qif->qif_ifq; local
250 IFCQ_LOCK(ifq);
252 IFCQ_UNLOCK(ifq);
342 struct ifclassq *ifq = qif->qif_ifq; local
345 IFCQ_LOCK_ASSERT_HELD(ifq);
354 qfq_purgeq(qif, ifq->ifcq_disc_slots[i].cl,
363 qfq_purgeq(qif, ifq->ifcq_disc_slots[i].cl,
422 struct ifclassq *ifq; local
476 ifq = qif->qif_ifq;
485 if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
662 struct ifclassq *ifq = qif->qif_ifq; local
932 struct ifclassq *ifq = qif->qif_ifq; local
1071 struct ifclassq *ifq = qif->qif_ifq; local
1311 struct ifclassq *ifq = qif->qif_ifq; local
1420 struct ifclassq *ifq = qif->qif_ifq; local
1555 struct ifclassq *ifq = qif->qif_ifq; local
1723 qfq_enqueue_ifclassq(struct ifclassq *ifq, struct mbuf *m) argument
1755 qfq_dequeue_ifclassq(struct ifclassq *ifq, cqdq_op_t op) argument
1761 qfq_request_ifclassq(struct ifclassq *ifq, cqrq_t req, void *arg) argument
1792 qfq_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags) argument
1910 qfq_teardown_ifclassq(struct ifclassq *ifq) argument
1930 qfq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot, struct if_ifclassq_stats *ifqs) argument
1948 struct ifclassq *ifq = qif->qif_ifq; local
2004 struct ifclassq *ifq = qif->qif_ifq; local
2036 struct ifclassq *ifq = qif->qif_ifq; local
[all...]
H A Dpktsched_fairq.c228 struct ifclassq *ifq = fif->fif_ifq; local
231 IFCQ_LOCK(ifq);
233 IFCQ_UNLOCK(ifq);
350 struct ifclassq *ifq; local
409 ifq = fif->fif_ifq;
451 if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
452 qlimit = IFCQ_MAXLEN(ifq);
598 struct ifclassq *ifq = fif->fif_ifq; local
601 IFCQ_LOCK_ASSERT_HELD(ifq);
662 struct ifclassq *ifq local
726 struct ifclassq *ifq = fif->fif_ifq; local
814 struct ifclassq *ifq = cl->cl_fif->fif_ifq; local
1094 struct ifclassq *ifq = fif->fif_ifq; local
1256 fairq_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags) argument
1263 fairq_teardown_ifclassq(struct ifclassq *ifq) argument
1283 fairq_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot, struct if_ifclassq_stats *ifqs) argument
[all...]
H A Dpktsched_hfsc.c244 struct ifclassq *ifq = hif->hif_ifq; local
247 IFCQ_LOCK(ifq);
249 IFCQ_UNLOCK(ifq);
374 struct ifclassq *ifq; local
433 ifq = hif->hif_ifq;
436 if (qlimit == 0 || qlimit > IFCQ_MAXLEN(ifq)) {
437 qlimit = IFCQ_MAXLEN(ifq);
762 struct ifclassq *ifq = hif->hif_ifq; local
766 IFCQ_LOCK_ASSERT_HELD(ifq);
778 IFCQ_CONVERT_LOCK(ifq);
829 struct ifclassq *ifq = hif->hif_ifq; local
929 struct ifclassq *ifq = cl->cl_hif->hif_ifq; local
1026 struct ifclassq *ifq = hif->hif_ifq; local
2022 hfsc_setup_ifclassq(struct ifclassq *ifq, u_int32_t flags) argument
2029 hfsc_teardown_ifclassq(struct ifclassq *ifq) argument
2049 hfsc_getqstats_ifclassq(struct ifclassq *ifq, u_int32_t slot, struct if_ifclassq_stats *ifqs) argument
[all...]
H A Dpktsched_rmclass.c243 struct ifclassq *ifq; local
311 ifq = ifd->ifq_;
312 ifp = ifq->ifcq_ifp;
314 if (maxq == 0 || maxq > IFCQ_MAXLEN(ifq)) {
315 maxq = IFCQ_MAXLEN(ifq);
729 rmc_init(struct ifclassq *ifq, struct rm_ifdat *ifd, u_int32_t nsecPerByte, argument
733 struct ifnet *ifp = ifq->ifcq_ifp;
755 ifd->ifq_ = ifq;
1506 struct ifclassq *ifq = ifd->ifq_; local
1510 IFCQ_CONVERT_LOCK(ifq);
1699 struct ifclassq *ifq = cl->ifdat_->ifq_; local
[all...]
H A Dpktsched_priq.h182 extern int priq_teardown_ifclassq(struct ifclassq *ifq);
H A Dpktsched_tcq.h154 extern int tcq_teardown_ifclassq(struct ifclassq *ifq);
H A Dpktsched_fairq.h223 extern int fairq_teardown_ifclassq(struct ifclassq *ifq);
H A Dpktsched_qfq.h296 extern int qfq_teardown_ifclassq(struct ifclassq *ifq);
/xnu-2422.115.4/bsd/sys/
H A Dkpi_mbuf.h1625 #define IF_ENQUEUE_MBUF(ifq, m) { \
1627 if ((ifq)->ifq_tail == 0) \
1628 (ifq)->ifq_head = (m); \
1630 mbuf_setnextpkt((mbuf_t)(ifq)->ifq_tail, (m)); \
1631 (ifq)->ifq_tail = (m); \
1632 (ifq)->ifq_len++; \
1635 #define IF_PREPEND_MBUF(ifq, m) { \
1636 mbuf_setnextpkt((m), (ifq)->ifq_head); \
1637 if ((ifq)->ifq_tail == 0) \
1638 (ifq)
[all...]
/xnu-2422.115.4/bsd/net/
H A Dif_var.h746 #define IF_QFULL(ifq) ((ifq)->ifq_len >= (ifq)->ifq_maxlen)
747 #define IF_DROP(ifq) ((ifq)->ifq_drops++)
749 #define IF_ENQUEUE(ifq, m) do { \
751 if ((ifq)->ifq_tail == NULL) \
752 (ifq)->ifq_head = m; \
754 ((struct mbuf*)(ifq)->ifq_tail)->m_nextpkt = m; \
755 (ifq)
[all...]
H A Dif.c1213 struct ifclassq *ifq = &ifp->if_snd; local
1257 IFCQ_LOCK(ifq);
1258 ifnet_update_sndq(ifq, up ? CLASSQ_EV_LINK_UP : CLASSQ_EV_LINK_DOWN);
1259 IFCQ_UNLOCK(ifq);
1299 struct ifclassq *ifq = &ifp->if_snd; local
1302 IFCQ_LOCK(ifq);
1304 if (IFCQ_IS_ENABLED(ifq))
1305 IFCQ_PURGE(ifq);
1307 if (IFCQ_IS_DRAINING(ifq))
1308 ifq
1323 struct ifclassq *ifq = &ifp->if_snd; local
1551 struct ifclassq *ifq; local
2188 struct ifclassq *ifq = &ifp->if_snd; local
[all...]
H A Dkpi_interface.c1094 struct ifclassq *ifq; local
1099 ifq = &ifp->if_snd;
1101 IFCQ_LOCK(ifq);
1102 IFCQ_LOCK_ASSERT_HELD(ifq);
1122 ifnet_update_sndq(ifq, CLASSQ_EV_LINK_BANDWIDTH);
1125 IFCQ_UNLOCK(ifq);
1157 struct ifclassq *ifq = &ifp->if_snd; local
1160 IFCQ_LOCK_ASSERT_HELD(ifq);
1163 if (IFCQ_TBR_IS_ENABLED(ifq)) {
1214 struct ifclassq *ifq; local
[all...]
/xnu-2422.115.4/bsd/net/altq/
H A Daltq_fairq.c217 struct ifclassq *ifq = NULL; local
230 ifq = fif->fif_ifq;
231 IFCQ_LOCK_ASSERT_HELD(ifq); /* lock held by altq_lookup */
233 IFCQ_UNLOCK(ifq);
H A Daltq_priq.c182 struct ifclassq *ifq = NULL; local
195 ifq = pif->pif_ifq;
196 IFCQ_LOCK_ASSERT_HELD(ifq); /* lock held by altq_lookup */
198 IFCQ_UNLOCK(ifq);
H A Daltq_qfq.c153 struct ifclassq *ifq = NULL; local
166 ifq = qif->qif_ifq;
167 IFCQ_LOCK_ASSERT_HELD(ifq); /* lock held by altq_lookup */
169 IFCQ_UNLOCK(ifq);
H A Daltq_cbq.c185 struct ifclassq *ifq = NULL; local
198 ifq = cbqp->ifnp.ifq_;
199 IFCQ_LOCK_ASSERT_HELD(ifq); /* lock held by altq_lookup */
201 IFCQ_UNLOCK(ifq);
H A Daltq_hfsc.c203 struct ifclassq *ifq = NULL; local
216 ifq = hif->hif_ifq;
217 IFCQ_LOCK_ASSERT_HELD(ifq); /* lock held by altq_lookup */
219 IFCQ_UNLOCK(ifq);
H A Daltq_subr.c167 struct ifclassq *ifq = altq->altq_ifcq; local
169 IFCQ_LOCK_ASSERT_HELD(ifq);
184 struct ifclassq *ifq = altq->altq_ifcq; local
186 IFCQ_LOCK_ASSERT_HELD(ifq);
191 if_qflush(ifq->ifcq_ifp, 1);
/xnu-2422.115.4/bsd/netinet/
H A Digmp.c490 igmp_dispatch_queue(struct igmp_ifinfo *igi, struct ifqueue *ifq, int limit, argument
500 IF_DEQUEUE(ifq, m);
504 (uint64_t)VM_KERNEL_ADDRPERM(ifq),
2660 struct ifqueue *ifq; local
2745 ifq = &inm->inm_scq;
2746 IF_DRAIN(ifq);
2747 retval = igmp_v3_enqueue_group_record(ifq, inm, 1,
2749 itp->cst = (ifq->ifq_len > 0);
3007 igmp_v3_enqueue_group_record(struct ifqueue *ifq, struct in_multi *inm, argument
3097 return (igmp_v3_enqueue_filter_change(ifq, in
3383 igmp_v3_enqueue_filter_change(struct ifqueue *ifq, struct in_multi *inm) argument
[all...]
/xnu-2422.115.4/bsd/netinet6/
H A Dmld6.c492 mld_dispatch_queue(struct mld_ifinfo *mli, struct ifqueue *ifq, int limit) argument
500 IF_DEQUEUE(ifq, m);
504 (uint64_t)VM_KERNEL_ADDRPERM(ifq),
2289 struct ifqueue *ifq; local
2385 ifq = &inm->in6m_scq;
2386 IF_DRAIN(ifq);
2387 retval = mld_v2_enqueue_group_record(ifq, inm, 1,
2389 mtp->cst = (ifq->ifq_len > 0);
2651 mld_v2_enqueue_group_record(struct ifqueue *ifq, struct in6_multi *inm, argument
2762 return (mld_v2_enqueue_filter_change(ifq, in
3032 mld_v2_enqueue_filter_change(struct ifqueue *ifq, struct in6_multi *inm) argument
[all...]

Completed in 131 milliseconds

12