Searched refs:cp_kpkt (Results 1 – 12 of 12) sorted by relevance
| /xnu-12377.41.6/bsd/net/classq/ |
| H A D | classq.c | 132 struct __kern_packet *kp = pkt->cp_kpkt; in _addq() 167 struct __kern_packet *kp_head = pkt_head->cp_kpkt; in _addq_multi() 168 struct __kern_packet *kp_tail = pkt_tail->cp_kpkt; in _addq_multi() 202 KPKTQ_DEQUEUE(&qkpktq(q), pkt->cp_kpkt); in _getq() 203 if (__probable(pkt->cp_kpkt != NULL)) { in _getq() 204 CLASSQ_PKT_INIT_PACKET(pkt, pkt->cp_kpkt); in _getq() 205 pkt_len = pkt->cp_kpkt->pkt_length; in _getq() 341 first->cp_kpkt = KPKTQ_FIRST(&qkpktq(q)); in _getq_all() 342 if (__probable(first->cp_kpkt != NULL)) { in _getq_all() 343 CLASSQ_PKT_INIT_PACKET(first, first->cp_kpkt); in _getq_all() [all …]
|
| H A D | classq_fq_codel.h | 228 KPKTQ_ENQUEUE_MULTI(&(_q)->fq_kpktq, (_h).cp_kpkt, \ 229 (_t).cp_kpkt, (_c)); \ 258 KPKTQ_DEQUEUE(&(_q)->fq_kpktq, (_p)->cp_kpkt); \ 259 if (__probable((_p)->cp_kpkt != NULL)) { \ 260 CLASSQ_PKT_INIT_PACKET((_p), (_p)->cp_kpkt); \
|
| H A D | classq.h | 93 struct __kern_packet *cp_kpkt; /* skywalk packet */ member 115 (_p)->cp_kpkt = (_k); \
|
| H A D | classq_subr.c | 446 head->cp_kpkt->pkt_nextpkt = NULL; in ifclassq_dequeue_common_default() 447 l += head->cp_kpkt->pkt_length; in ifclassq_dequeue_common_default() 449 if (last.cp_kpkt != NULL) { in ifclassq_dequeue_common_default() 450 last.cp_kpkt->pkt_nextpkt = head->cp_kpkt; in ifclassq_dequeue_common_default() 708 TBR_SCALE(pkt->cp_kpkt->pkt_length); in ifclassq_tbr_dequeue_common()
|
| /xnu-12377.41.6/bsd/skywalk/nexus/ |
| H A D | nexus_pktq.h | 172 ASSERT((pkt.cp_kpkt == NULL) || (pkt.cp_ptype == QP_PACKET)); in __pktq_deq() 173 return pkt.cp_kpkt; in __pktq_deq() 205 *plast = last.cp_kpkt; in __pktq_deq_all() 206 ASSERT((first.cp_kpkt == NULL) || (first.cp_ptype == QP_PACKET)); in __pktq_deq_all() 207 return first.cp_kpkt; in __pktq_deq_all()
|
| H A D | nexus_pktq.c | 72 ASSERT(first.cp_kpkt != NULL && last.cp_kpkt != NULL); in nx_pktq_concat()
|
| /xnu-12377.41.6/bsd/net/pktsched/ |
| H A D | pktsched.h | 70 #define pktsched_pkt_kpkt __pkt.cp_kpkt 73 #define pktsched_tail_kpkt __tail.cp_kpkt
|
| H A D | pktsched_fq_codel.c | 351 pkt->cp_kpkt->pkt_nextpkt = next_pkt->cp_kpkt; in fq_if_append_pkt() 389 if (head->cp_kpkt == NULL) { in fq_getq_flow_kpkt() 392 ASSERT(tail->cp_kpkt != NULL); in fq_getq_flow_kpkt() 393 ASSERT(tail->cp_kpkt->pkt_nextpkt == NULL); in fq_getq_flow_kpkt() 394 tail->cp_kpkt->pkt_nextpkt = pkt.pktsched_pkt_kpkt; in fq_getq_flow_kpkt() 397 tail->cp_kpkt->pkt_nextpkt = NULL; in fq_getq_flow_kpkt() 778 grp_idx = head->cp_kpkt->pkt_qset_idx; in fq_if_enqueue() 900 ASSERT(tail->cp_kpkt->pkt_nextpkt == NULL); in fq_dqlist_remove() 901 tail->cp_kpkt->pkt_nextpkt = fq->fq_dq_head.cp_kpkt; in fq_dqlist_remove() 902 ASSERT(fq->fq_dq_tail.cp_kpkt->pkt_nextpkt == NULL); in fq_dqlist_remove()
|
| H A D | pktsched_netem.c | 1168 struct __kern_packet *kp = p->cp_kpkt; in netem_enqueue()
|
| /xnu-12377.41.6/bsd/skywalk/nexus/netif/ |
| H A D | nx_netif_filter_native.c | 265 if (head->cp_kpkt != NULL) { in nx_netif_native_tx_dequeue() 274 nx_netif_filter_tx_pkt_enqueue(nifna, head->cp_kpkt); in nx_netif_native_tx_dequeue()
|
| H A D | nx_netif.c | 4165 ASSERT((pkt_head.cp_ptype == QP_PACKET) || (pkt_head.cp_kpkt == NULL)); 4171 *head = pkt_head.cp_kpkt;
|
| /xnu-12377.41.6/bsd/net/ |
| H A D | dlil.c | 3074 if (!(p->cp_kpkt->pkt_pflags & PKT_F_TS_VALID) || in ifnet_enqueue_single() 3075 p->cp_kpkt->pkt_timestamp == 0) { in ifnet_enqueue_single() 3078 p->cp_kpkt->pkt_timestamp = now_nsec; in ifnet_enqueue_single() 3080 p->cp_kpkt->pkt_pflags &= ~PKT_F_TS_VALID; in ifnet_enqueue_single() 3087 if (!(p->cp_kpkt->pkt_pflags & PKT_F_BACKGROUND)) { in ifnet_enqueue_single() 3093 if (p->cp_kpkt->pkt_pflags & PKT_F_REALTIME) { in ifnet_enqueue_single() 3099 pktlen = p->cp_kpkt->pkt_length; in ifnet_enqueue_single() 3107 if ((p->cp_kpkt->pkt_link_flags & PKT_LINKF_MCAST) != 0 && in ifnet_enqueue_single() 3113 MD_BUFLET_ADDR_ABS(p->cp_kpkt, baddr); in ifnet_enqueue_single() 3114 baddr += p->cp_kpkt->pkt_headroom; in ifnet_enqueue_single() [all …]
|