Home
last modified time | relevance | path

Searched refs:cp_mbuf (Results 1 – 14 of 14) sorted by relevance

/xnu-12377.41.6/bsd/net/classq/
H A Dclassq_fq_codel.h220 MBUFQ_ENQUEUE_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
221 (_t).cp_mbuf); \
222 MBUFQ_ADD_CRUMB_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
223 (_t).cp_mbuf, PKT_CRUMB_FQ_ENQUEUE); \
239 MBUFQ_ENQUEUE_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, (_t).cp_mbuf); \
240 MBUFQ_ADD_CRUMB_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
241 (_t).cp_mbuf, PKT_CRUMB_FQ_ENQUEUE); \
249 MBUFQ_DEQUEUE(&(_q)->fq_mbufq, (_p)->cp_mbuf); \
250 if (__probable((_p)->cp_mbuf != NULL)) { \
251 CLASSQ_PKT_INIT_MBUF((_p), (_p)->cp_mbuf); \
[all …]
H A Dclassq.c124 struct mbuf *m = pkt->cp_mbuf; in _addq()
159 struct mbuf *m_head = pkt_head->cp_mbuf; in _addq_multi()
160 struct mbuf *m_tail = pkt_tail->cp_mbuf; in _addq_multi()
192 MBUFQ_DEQUEUE(&qmbufq(q), pkt->cp_mbuf); in _getq()
193 if (__probable(pkt->cp_mbuf != NULL)) { in _getq()
194 CLASSQ_PKT_INIT_MBUF(pkt, pkt->cp_mbuf); in _getq()
195 pkt_len = m_length(pkt->cp_mbuf); in _getq()
217 if (pkt->cp_mbuf == NULL) { in _getq()
292 if (pkt->cp_mbuf != NULL) { in _getq_flow_or_scidx()
326 first->cp_mbuf = MBUFQ_FIRST(&qmbufq(q)); in _getq_all()
[all …]
H A Dclassq.h91 struct mbuf *cp_mbuf; /* mbuf packet */ member
100 (classq_pkt_t){ .cp_mbuf = NULL, .cp_ptype = QP_INVALID }
104 (_p)->cp_mbuf = NULL; \
109 (_p)->cp_mbuf = (_m); \
H A Dclassq_subr.c340 struct mbuf *m = p->cp_mbuf; in ifclassq_set_packet_metadata()
399 if (err == 0 && head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
410 if (err == 0 && head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
426 if (head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
430 if (first.cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
436 head->cp_mbuf->m_nextpkt = NULL; in ifclassq_dequeue_common_default()
437 l += head->cp_mbuf->m_pkthdr.len; in ifclassq_dequeue_common_default()
439 if (last.cp_mbuf != NULL) { in ifclassq_dequeue_common_default()
440 last.cp_mbuf->m_nextpkt = head->cp_mbuf; in ifclassq_dequeue_common_default()
478 return (first.cp_mbuf != NULL) ? 0 : EAGAIN; in ifclassq_dequeue_common_default()
[all …]
H A Dclassq_fq_codel.c614 VERIFY(p.cp_mbuf == NULL); in fq_getq_flow_internal()
/xnu-12377.41.6/bsd/skywalk/nexus/
H A Dnexus_mbq.h198 ASSERT((pkt.cp_mbuf == NULL) || (pkt.cp_ptype == QP_MBUF)); in __mbq_deq()
199 return pkt.cp_mbuf; in __mbq_deq()
231 *mlast = last.cp_mbuf; in __mbq_deq_all()
232 ASSERT((first.cp_mbuf == NULL) || (first.cp_ptype == QP_MBUF)); in __mbq_deq_all()
233 return first.cp_mbuf; in __mbq_deq_all()
H A Dnexus_mbq.c99 ASSERT(first.cp_mbuf != NULL && last.cp_mbuf != NULL); in nx_mbq_concat()
/xnu-12377.41.6/bsd/net/pktsched/
H A Dpktsched_fq_codel.c333 pkt->cp_mbuf->m_nextpkt = next_pkt->cp_mbuf; in fq_if_append_mbuf()
449 if (head->cp_mbuf == NULL) { in fq_getq_flow_mbuf()
452 ASSERT(tail->cp_mbuf != NULL); in fq_getq_flow_mbuf()
453 ASSERT(tail->cp_mbuf->m_nextpkt == NULL); in fq_getq_flow_mbuf()
454 tail->cp_mbuf->m_nextpkt = pkt.pktsched_pkt_mbuf; in fq_getq_flow_mbuf()
457 tail->cp_mbuf->m_nextpkt = NULL; in fq_getq_flow_mbuf()
872 ASSERT(fq->fq_dq_head.cp_mbuf == NULL); in fq_dqlist_add()
883 if (fq->fq_dq_head.cp_mbuf == NULL) { in fq_dqlist_remove()
887 if (head->cp_mbuf == NULL) { in fq_dqlist_remove()
890 ASSERT(tail->cp_mbuf != NULL); in fq_dqlist_remove()
[all …]
H A Dpktsched.h69 #define pktsched_pkt_mbuf __pkt.cp_mbuf
72 #define pktsched_tail_mbuf __tail.cp_mbuf
H A Dpktsched_netem.c1098 NETEM_LOG(LOG_DEBUG, "┌ begin p %p len %u, now %llu", p->cp_mbuf, in nlc_enqueue()
1126 p->cp_mbuf, ret); in nlc_enqueue()
1146 NETEM_LOG(LOG_DEBUG, "└ %p end", p->cp_mbuf); in nlc_enqueue()
1153 NETEM_LOG(LOG_DEBUG, "└ %p end", p->cp_mbuf); in nlc_enqueue()
1163 struct pkthdr *pkth = &(p->cp_mbuf->m_pkthdr); in netem_enqueue()
/xnu-12377.41.6/bsd/skywalk/nexus/netif/
H A Dnx_netif_filter_compat.c264 if (head->cp_mbuf != NULL) { in nx_netif_compat_tx_dequeue()
273 nx_netif_filter_tx_mbuf_enqueue(nifna, head->cp_mbuf); in nx_netif_compat_tx_dequeue()
/xnu-12377.41.6/bsd/net/
H A Ddlil.c2974 ASSERT(p->cp_mbuf->m_flags & M_PKTHDR); in ifnet_enqueue_single()
2975 ASSERT(p->cp_mbuf->m_nextpkt == NULL); in ifnet_enqueue_single()
2977 if (!(p->cp_mbuf->m_pkthdr.pkt_flags & PKTF_TS_VALID) || in ifnet_enqueue_single()
2978 p->cp_mbuf->m_pkthdr.pkt_timestamp == 0) { in ifnet_enqueue_single()
2981 p->cp_mbuf->m_pkthdr.pkt_timestamp = now_nsec; in ifnet_enqueue_single()
2983 p->cp_mbuf->m_pkthdr.pkt_flags &= ~PKTF_TS_VALID; in ifnet_enqueue_single()
2989 if ((p->cp_mbuf->m_pkthdr.pkt_flags & PKTF_FLOW_ID) && in ifnet_enqueue_single()
2990 p->cp_mbuf->m_pkthdr.pkt_flowsrc == FLOWSRC_INPCB) { in ifnet_enqueue_single()
2991 if (!(p->cp_mbuf->m_pkthdr.pkt_flags & in ifnet_enqueue_single()
2998 if (p->cp_mbuf->m_pkthdr.pkt_flags & PKTF_SO_REALTIME) { in ifnet_enqueue_single()
[all …]
H A Ddlil_input.c256 if (pkt.cp_mbuf != NULL) { in dlil_terminate_input_thread()
257 mbuf_freem_list(pkt.cp_mbuf); in dlil_terminate_input_thread()
607 if (head.cp_mbuf != NULL) { in dlil_input_sync()
608 dlil_input_packet_list_extended(ifp, head.cp_mbuf, in dlil_input_sync()
1194 m = pkt.cp_mbuf; in dlil_input_thread_cont()
1400 m = pkt.cp_mbuf; in dlil_main_input_thread_cont()
1405 m_loop = pkt.cp_mbuf; in dlil_main_input_thread_cont()
1556 m = pkt.cp_mbuf; in dlil_rxpoll_input_thread_cont()
/xnu-12377.41.6/bsd/netinet/
H A Din_arp.c323 _m = pkt.cp_mbuf; in arp_llinfo_addq()
326 _m = pkt.cp_mbuf; in arp_llinfo_addq()
1580 VERIFY(pkt.cp_mbuf == packet); in arp_lookup_ip()
2165 m0 = pkt.cp_mbuf; in arp_ip_handle_input()