| /xnu-10063.141.1/bsd/skywalk/nexus/flowswitch/ |
| H A D | fsw_dp.c | 293 dp_free_pktq(struct nx_flowswitch *fsw __sk_unused, struct pktq *pktq) in dp_free_pktq() argument
295 pp_free_pktq(pktq); in dp_free_pktq()
298 #define dp_drop_pktq(fsw, pktq) do { \ argument
299 uint32_t _len = KPKTQ_LEN(pktq); \
300 if (KPKTQ_EMPTY(pktq)) { \
307 dp_free_pktq(fsw, pktq); \
990 uint32_t n_pkts_max, struct pktq *pktq, uint32_t *n_bytes) in fsw_rx_ring_dequeue_pktq() argument
997 ASSERT(KPKTQ_EMPTY(pktq)); in fsw_rx_ring_dequeue_pktq()
1018 KPKTQ_ENQUEUE(pktq, pkt); in fsw_rx_ring_dequeue_pktq()
1062 struct pktq *pktq, uint32_t *n_bytes, uint32_t *gso_pkts_estimate) in fsw_tx_ring_dequeue_pktq() argument
[all …]
|
| H A D | fsw_var.h | 56 struct pktq;
150 struct __kern_channel_ring *ring, struct pktq *pktq);
162 extern void fsw_receive(struct nx_flowswitch *fsw, struct pktq *pktq);
231 fsw_snoop_and_dequeue(struct flow_entry *fe, struct pktq *target, bool input) in fsw_snoop_and_dequeue()
|
| H A D | nx_flowswitch.h | 173 struct pktq frt_pktq;
|
| /xnu-10063.141.1/bsd/skywalk/nexus/netif/ |
| H A D | nx_netif_filter_vp.c | 375 struct filter_pktq pktq[KPKT_TC_MAX], *q; in netif_filter_na_txsync() local
399 pktq[i].fp_head = NULL; in netif_filter_na_txsync()
400 pktq[i].fp_tailp = &pktq[i].fp_head; in netif_filter_na_txsync()
443 q = &pktq[tc]; in netif_filter_na_txsync()
466 q = &pktq[i]; in netif_filter_na_txsync()
|
| H A D | nx_netif.h | 134 struct pktq nq_pktq;
|
| H A D | nx_netif.c | 4454 struct pktq *pktq = &q->nq_pktq; local
4467 KPKTQ_ENQUEUE_LIST(pktq, pkt_chain);
4469 pkt_chain = KPKTQ_FIRST(pktq);
4470 KPKTQ_INIT(pktq);
|
| H A D | nx_netif_gso.c | 269 struct pktq pktq_alloc, pktq_seg; in netif_gso_tcp_segment_mbuf()
|
| /xnu-10063.141.1/bsd/skywalk/packet/ |
| H A D | pbufpool_var.h | 243 extern int pp_alloc_pktq(struct kern_pbufpool *, uint16_t, struct pktq *,
249 extern void pp_free_pktq(struct pktq *);
|
| H A D | packet_queue.h | 163 KPKTQ_HEAD(pktq);
|
| H A D | pbufpool.c | 2049 struct pktq *pktq, uint32_t num, alloc_cb_func_t cb, const void *ctx, in pp_alloc_pktq() argument
2058 ASSERT(pktq != NULL && num > 0); in pp_alloc_pktq()
2100 KPKTQ_ENQUEUE(pktq, kpkt); in pp_alloc_pktq()
2275 pp_free_pktq(struct pktq *pktq) in pp_free_pktq() argument
2277 if (__improbable(KPKTQ_EMPTY(pktq))) { in pp_free_pktq()
2280 struct __kern_packet *pkt = KPKTQ_FIRST(pktq); in pp_free_pktq()
2282 KPKTQ_DISPOSE(pktq); in pp_free_pktq()
|
| /xnu-10063.141.1/bsd/skywalk/nexus/flowswitch/flow/ |
| H A D | flow_var.h | 268 struct pktq fe_rx_pktq;
283 struct pktq fe_tx_pktq;
1004 extern void fsw_host_rx(struct nx_flowswitch *, struct pktq *);
|
| H A D | flow_agg.c | 1557 struct pktq *dropped_pkts, bool is_mbuf) in flow_rx_agg_channel()
1568 struct pktq pkts; /* dst super packets */ in flow_rx_agg_channel()
1569 struct pktq disposed_pkts; /* done src packets */ in flow_rx_agg_channel()
1919 struct pktq *dropped_pkts, bool is_mbuf) in flow_rx_agg_host()
1932 struct pktq disposed_pkts; /* done src packets */ in flow_rx_agg_host()
2466 struct pktq dropped_pkts; in flow_rx_agg_tcp()
|
| /xnu-10063.141.1/bsd/net/ |
| H A D | if_redirect.c | 323 redirect_tx_submit(ifnet_t delegate_ifp, struct pktq *spktq, uint32_t if_flowhash) in redirect_tx_submit()
633 struct pktq tx_pktq; in redirect_nx_sync_tx()
692 DTRACE_SKYWALK2(unsent, if_redirect_t, rd, struct pktq *, &tx_pktq); in redirect_nx_sync_tx()
700 redirect_rx_cb(void *arg, struct pktq *spktq) in redirect_rx_cb()
715 DTRACE_SKYWALK2(no__ring__drop, if_redirect_t, rd, struct pktq *, spktq); in redirect_rx_cb()
|
| H A D | if_var_private.h | 583 typedef void (*ifnet_fsw_rx_cb_t)(void *, struct pktq *);
|