Home
last modified time | relevance | path

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

/xnu-10063.141.1/bsd/net/classq/
H A Dclassq_fq_codel.h188 MBUFQ_ENQUEUE_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
189 (_t).cp_mbuf); \
190 MBUFQ_ADD_CRUMB_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
191 (_t).cp_mbuf, PKT_CRUMB_FQ_ENQUEUE); \
207 MBUFQ_ENQUEUE_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, (_t).cp_mbuf); \
208 MBUFQ_ADD_CRUMB_MULTI(&(_q)->fq_mbufq, (_h).cp_mbuf, \
209 (_t).cp_mbuf, PKT_CRUMB_FQ_ENQUEUE); \
217 MBUFQ_DEQUEUE(&(_q)->fq_mbufq, (_p)->cp_mbuf); \
218 if (__probable((_p)->cp_mbuf != NULL)) { \
219 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.c319 struct mbuf *m = p->cp_mbuf; in ifclassq_set_packet_metadata()
396 if (err == 0 && head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
408 if (err == 0 && head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
425 if (head->cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
429 if (first.cp_mbuf == NULL) { in ifclassq_dequeue_common_default()
435 head->cp_mbuf->m_nextpkt = NULL; in ifclassq_dequeue_common_default()
436 l += head->cp_mbuf->m_pkthdr.len; in ifclassq_dequeue_common_default()
438 if (last.cp_mbuf != NULL) { in ifclassq_dequeue_common_default()
439 last.cp_mbuf->m_nextpkt = head->cp_mbuf; in ifclassq_dequeue_common_default()
477 return (first.cp_mbuf != NULL) ? 0 : EAGAIN; in ifclassq_dequeue_common_default()
[all …]
H A Dclassq_fq_codel.c596 VERIFY(p.cp_mbuf == NULL); in fq_getq_flow_internal()
/xnu-10063.141.1/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-10063.141.1/bsd/net/pktsched/
H A Dpktsched_fq_codel.c202 pkt->cp_mbuf->m_nextpkt = next_pkt->cp_mbuf; in fq_if_append_mbuf()
310 if (head->cp_mbuf == NULL) { in fq_getq_flow_mbuf()
313 ASSERT(tail->cp_mbuf != NULL); in fq_getq_flow_mbuf()
314 ASSERT(tail->cp_mbuf->m_nextpkt == NULL); in fq_getq_flow_mbuf()
315 tail->cp_mbuf->m_nextpkt = pkt.pktsched_pkt_mbuf; in fq_getq_flow_mbuf()
318 tail->cp_mbuf->m_nextpkt = NULL; in fq_getq_flow_mbuf()
613 ASSERT(fq->fq_dq_head.cp_mbuf == NULL); in fq_dqlist_add()
624 if (fq->fq_dq_head.cp_mbuf == NULL) { in fq_dqlist_remove()
628 if (head->cp_mbuf == NULL) { in fq_dqlist_remove()
631 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.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()
/xnu-10063.141.1/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-10063.141.1/bsd/net/
H A Ddlil.c2553 if (pkt.cp_mbuf != NULL) { in dlil_terminate_input_thread()
2554 mbuf_freem_list(pkt.cp_mbuf); in dlil_terminate_input_thread()
3276 m = pkt.cp_mbuf; in dlil_main_input_thread_cont()
3281 m_loop = pkt.cp_mbuf; in dlil_main_input_thread_cont()
3410 m = pkt.cp_mbuf; in dlil_input_thread_cont()
3573 m = pkt.cp_mbuf; in dlil_rxpoll_input_thread_cont()
4513 if (head.cp_mbuf != NULL) { in dlil_input_sync()
4514 dlil_input_packet_list_extended(NULL, head.cp_mbuf, in dlil_input_sync()
5364 ASSERT(p->cp_mbuf->m_flags & M_PKTHDR); in ifnet_enqueue_ifclassq()
5365 ASSERT(p->cp_mbuf->m_nextpkt == NULL); in ifnet_enqueue_ifclassq()
[all …]
/xnu-10063.141.1/bsd/netinet/
H A Din_arp.c337 _m = pkt.cp_mbuf; in arp_llinfo_addq()
340 _m = pkt.cp_mbuf; in arp_llinfo_addq()
1589 VERIFY(pkt.cp_mbuf == packet); in arp_lookup_ip()
2156 m0 = pkt.cp_mbuf; in arp_ip_handle_input()