Home
last modified time | relevance | path

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

/xnu-8019.80.24/bsd/net/classq/
H A Dclassq_fq_codel.h104 MBUFQ_ENQUEUE_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
105 (_t).cp_mbuf); \
106 MBUFQ_ADD_CRUMB_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
107 (_t).cp_mbuf, PKT_CRUMB_FQ_ENQUEUE); \
123 MBUFQ_ENQUEUE_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
124 (_t).cp_mbuf); \
125 MBUFQ_ADD_CRUMB_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
126 (_t).cp_mbuf, PKT_CRUMB_FQ_ENQUEUE); \
134 MBUFQ_DEQUEUE(&(_q)->fq_mbufq, (_p)->cp_mbuf); \
135 if (__probable((_p)->cp_mbuf != NULL)) { \
[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_subr.c267 struct mbuf *m = p->cp_mbuf; in ifclassq_set_packet_metadata()
343 if (err == 0 && head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
355 if (err == 0 && head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
380 if (head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
384 if (first.cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
390 head->cp_mbuf->m_nextpkt = NULL; in ifclassq_dequeue_common_default()
391 l += head->cp_mbuf->m_pkthdr.len; in ifclassq_dequeue_common_default()
393 if (last.cp_mbuf != NULL) { in ifclassq_dequeue_common_default()
394 last.cp_mbuf->m_nextpkt = head->cp_mbuf; in ifclassq_dequeue_common_default()
432 return (first.cp_mbuf != NULL) ? 0 : EAGAIN; in ifclassq_dequeue_common_default()
[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_fq_codel.c498 VERIFY(p.cp_mbuf == NULL); in fq_getq_flow_internal()
/xnu-8019.80.24/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-8019.80.24/bsd/net/pktsched/
H A Dpktsched_fq_codel.c99 pkt->cp_mbuf->m_nextpkt = next_pkt->cp_mbuf; in fq_if_append_mbuf()
188 if (head->cp_mbuf == NULL) { in fq_getq_flow_mbuf()
191 ASSERT(tail->cp_mbuf != NULL); in fq_getq_flow_mbuf()
192 ASSERT(tail->cp_mbuf->m_nextpkt == NULL); in fq_getq_flow_mbuf()
193 tail->cp_mbuf->m_nextpkt = pkt.pktsched_pkt_mbuf; in fq_getq_flow_mbuf()
196 tail->cp_mbuf->m_nextpkt = NULL; in fq_getq_flow_mbuf()
450 ASSERT(fq->fq_dq_head.cp_mbuf == NULL); in fq_dqlist_add()
461 if (fq->fq_dq_head.cp_mbuf == NULL) { in fq_dqlist_remove()
465 if (head->cp_mbuf == NULL) { in fq_dqlist_remove()
468 ASSERT(tail->cp_mbuf != NULL); in fq_dqlist_remove()
[all …]
H A Dpktsched.h68 #define pktsched_pkt_mbuf __pkt.cp_mbuf
71 #define pktsched_tail_mbuf __tail.cp_mbuf
H A Dpktsched_netem.c1018 netem_log(NETEM_LOG_DEBUG, "+ %p begin", p->cp_mbuf); in netem_enqueue()
1044 p->cp_mbuf, ret); in netem_enqueue()
1063 netem_log(NETEM_LOG_DEBUG, "- %p end", p->cp_mbuf); in netem_enqueue()
/xnu-8019.80.24/bsd/skywalk/nexus/netif/
H A Dnx_netif_filter_compat.c263 if (head->cp_mbuf != NULL) { in nx_netif_compat_tx_dequeue()
272 nx_netif_filter_tx_mbuf_enqueue(nifna, head->cp_mbuf); in nx_netif_compat_tx_dequeue()
/xnu-8019.80.24/bsd/net/
H A Ddlil.c2245 if (pkt.cp_mbuf != NULL) { in dlil_terminate_input_thread()
2246 mbuf_freem_list(pkt.cp_mbuf); in dlil_terminate_input_thread()
2958 m = pkt.cp_mbuf; in dlil_main_input_thread_cont()
2963 m_loop = pkt.cp_mbuf; in dlil_main_input_thread_cont()
3092 m = pkt.cp_mbuf; in dlil_input_thread_cont()
3255 m = pkt.cp_mbuf; in dlil_rxpoll_input_thread_cont()
4025 if (head.cp_mbuf != NULL) { in dlil_input_sync()
4026 dlil_input_packet_list_extended(NULL, head.cp_mbuf, in dlil_input_sync()
4868 ASSERT(p->cp_mbuf->m_flags & M_PKTHDR); in ifnet_enqueue_ifclassq()
4869 ASSERT(p->cp_mbuf->m_nextpkt == NULL); in ifnet_enqueue_ifclassq()
[all …]
/xnu-8019.80.24/bsd/netinet/
H A Din_arp.c336 _m = pkt.cp_mbuf; in arp_llinfo_addq()
339 _m = pkt.cp_mbuf; in arp_llinfo_addq()
1588 VERIFY(pkt.cp_mbuf == packet); in arp_lookup_ip()
2153 m0 = pkt.cp_mbuf; in arp_ip_handle_input()