| /xnu-12377.61.12/bsd/net/pktsched/ |
| H A D | pktsched_netem.h | 35 typedef int (netem_output_func_t)(void *handle, pktsched_pkt_t *pkts,
|
| H A D | pktsched_netem.c | 720 pktsched_pkt_t *pkts, uint32_t n_pkts);
1225 pktsched_pkt_t pkts[NETEM_MAX_BATCH_SIZE]; in netem_output_thread_cont() local
1259 ret = netem_dequeue_internal_locked(ne, &pkts[n_pkts], in netem_output_thread_cont()
1269 pkts, n_pkts); in netem_output_thread_cont()
|
| H A D | pktsched_fq_codel.c | 1449 u_int32_t pkts, bytes; in fq_if_purge_flow() local
1455 pkts = bytes = 0; in fq_if_purge_flow()
1463 pkts++; in fq_if_purge_flow()
1475 IFCQ_DROP_ADD(fqs->fqs_ifq, pkts, bytes); in fq_if_purge_flow()
1498 *pktsp = pkts; in fq_if_purge_flow()
1579 uint32_t bytes = 0, pkts = 0; in fq_if_purge_sc() local
1588 fq_if_purge_flow(fqs, fq, &pkts, &bytes, now); in fq_if_purge_sc()
1590 req->packets += pkts; in fq_if_purge_sc()
|
| /xnu-12377.61.12/bsd/net/classq/ |
| H A D | classq_sfb.h | 68 u_int16_t pkts; /* number of packets */ member
|
| /xnu-12377.61.12/bsd/net/ |
| H A D | if_fake.c | 2232 kern_packet_t pkts[IFF_MAX_BATCH_SIZE]; in feth_nx_sync_tx() local
2317 pkts[n_pkts++] = sph; in feth_nx_sync_tx()
2319 feth_rx_submit(fakeif, peer_fakeif, pkts, n_pkts); in feth_nx_sync_tx()
2320 feth_tx_complete(fakeif, pkts, n_pkts); in feth_nx_sync_tx()
2331 feth_rx_submit(fakeif, peer_fakeif, pkts, n_pkts); in feth_nx_sync_tx()
2332 feth_tx_complete(fakeif, pkts, n_pkts); in feth_nx_sync_tx()
2909 kern_packet_t pkts[IFF_MAX_BATCH_SIZE]; in feth_nx_tx_queue_deliver_pkt_chain() local
2943 pkts[n_pkts++] = sph; in feth_nx_tx_queue_deliver_pkt_chain()
2946 qset_idx, pkts, n_pkts); in feth_nx_tx_queue_deliver_pkt_chain()
2947 feth_tx_complete(fakeif, pkts, n_pkts); in feth_nx_tx_queue_deliver_pkt_chain()
[all …]
|
| H A D | dlil.c | 2772 ifnet_get_sndq_len(struct ifnet *ifp, u_int32_t *pkts) in ifnet_get_sndq_len() argument
2776 if (ifp == NULL || pkts == NULL) { in ifnet_get_sndq_len()
2782 IF_CLASSQ_ALL_GRPS, pkts, NULL); in ifnet_get_sndq_len()
2790 u_int32_t *pkts, u_int32_t *bytes) in ifnet_get_service_class_sndq_len() argument
2795 (pkts == NULL && bytes == NULL)) { in ifnet_get_service_class_sndq_len()
2801 pkts, bytes); in ifnet_get_service_class_sndq_len()
3262 ifnet_enqueue_netem(void *handle, pktsched_pkt_t *__sized_by(n_pkts)pkts, uint32_t n_pkts) in ifnet_enqueue_netem() argument
3270 (void) ifnet_enqueue_single(ifp, ifp->if_snd, &pkts[i].pktsched_pkt, in ifnet_enqueue_netem()
3274 (void) ifnet_enqueue_single(ifp, ifp->if_snd, &pkts[i].pktsched_pkt, in ifnet_enqueue_netem()
|
| H A D | if_var_private.h | 1809 pktsched_pkt_t *__sized_by(n_pkts) pkts, uint32_t n_pkts);
|
| /xnu-12377.61.12/bsd/skywalk/nexus/flowswitch/ |
| H A D | fsw_var.h | 160 pktsched_pkt_t *__counted_by(n_pkts) pkts, uint32_t n_pkts);
|
| H A D | fsw_dp.c | 1284 pkts_to_pktq(struct __kern_packet **__counted_by(n_pkts)pkts, uint32_t n_pkts, struct pktq *pktq) in pkts_to_pktq() argument
1289 struct __kern_packet *__single pkt = pkts[i]; in pkts_to_pktq()
2297 struct pktq pkts; in fsw_rps_thread_cont() local
2299 KPKTQ_INIT(&pkts); in fsw_rps_thread_cont()
2300 KPKTQ_CONCAT(&pkts, &frt->frt_pktq); in fsw_rps_thread_cont()
2305 _fsw_receive(fsw, &pkts); in fsw_rps_thread_cont()
2510 pktsched_pkt_t *__counted_by(n_pkts)pkts, uint32_t n_pkts) in fsw_dev_input_netem_dequeue() argument
2522 ASSERT(pkts[i].pktsched_ptype == QP_PACKET); in fsw_dev_input_netem_dequeue()
2523 ASSERT(pkts[i].pktsched_pkt_kpkt != NULL); in fsw_dev_input_netem_dequeue()
2524 kpkts[i] = pkts[i].pktsched_pkt_kpkt; in fsw_dev_input_netem_dequeue()
|
| /xnu-12377.61.12/bsd/skywalk/nexus/netif/ |
| H A D | nx_netif_mit.c | 755 nx_netif_mit_stats(struct __kern_channel_ring *kr, uint64_t pkts, in nx_netif_mit_stats() argument
783 PKTCNTR_ADD(&mit->mit_sstats, pkts, bytes); in nx_netif_mit_stats()
|
| /xnu-12377.61.12/bsd/skywalk/nexus/ |
| H A D | nexus_adapter.c | 3551 uint64_t *__indexable pkts; in alloc_packets() local
3566 pkts = buf_arr; in alloc_packets()
3581 kern_packet_t ph = (kern_packet_t)pkts[i]; in alloc_packets()
3590 pkts += cnt; in alloc_packets()
3598 pp_free_packet_batch(pp, pkts, remain); in alloc_packets()
3602 ASSERT(pkts[i] == 0); in alloc_packets()
|
| /xnu-12377.61.12/bsd/netinet/ |
| H A D | in_tclass.c | 1060 so_inc_recv_data_stat(struct socket *so, size_t pkts, size_t bytes) in so_inc_recv_data_stat() argument
1062 so->so_tc_stats[SO_STATS_DATA].rxpackets += pkts; in so_inc_recv_data_stat()
|
| /xnu-12377.61.12/bsd/skywalk/nexus/flowswitch/flow/ |
| H A D | flow_var.h | 253 struct pktq *pkts, uint32_t rx_bytes, struct mbufq *host_mq,
|
| /xnu-12377.61.12/tests/skywalk/ |
| H A D | skywalk_test_utils.c | 1757 sktu_channel_port_tx_burst_pkt(channel_port_t port, packet_t *pkts, in sktu_channel_port_tx_burst_pkt() argument
1801 error = sktu_channel_port_tx(port, pkts[i]); in sktu_channel_port_tx_burst_pkt()
|