/xnu-2422.115.4/bsd/net/classq/ |
H A D | classq_subr.c | 91 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 D | pktsched.c | 131 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 D | pktsched_tcq.c | 141 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 D | pktsched_priq.c | 169 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 D | pktsched_cbq.c | 157 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 D | pktsched_qfq.c | 247 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 D | pktsched_fairq.c | 228 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 D | pktsched_hfsc.c | 244 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 D | pktsched_rmclass.c | 243 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 D | pktsched_priq.h | 182 extern int priq_teardown_ifclassq(struct ifclassq *ifq);
|
H A D | pktsched_tcq.h | 154 extern int tcq_teardown_ifclassq(struct ifclassq *ifq);
|
H A D | pktsched_fairq.h | 223 extern int fairq_teardown_ifclassq(struct ifclassq *ifq);
|
H A D | pktsched_qfq.h | 296 extern int qfq_teardown_ifclassq(struct ifclassq *ifq);
|
/xnu-2422.115.4/bsd/sys/ |
H A D | kpi_mbuf.h | 1625 #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 D | if_var.h | 746 #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 D | if.c | 1213 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 D | kpi_interface.c | 1094 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 D | altq_fairq.c | 217 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 D | altq_priq.c | 182 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 D | altq_qfq.c | 153 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 D | altq_cbq.c | 185 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 D | altq_hfsc.c | 203 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 D | altq_subr.c | 167 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 D | igmp.c | 490 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 D | mld6.c | 492 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...] |