| /linux-6.12.1/drivers/bluetooth/ |
| D | h4_recv.h | 52 const struct h4_recv_pkt *pkts, in h4_recv_buf() argument
64 if (buffer[0] != (&pkts[i])->type) in h4_recv_buf()
67 skb = bt_skb_alloc((&pkts[i])->maxlen, in h4_recv_buf()
72 hci_skb_pkt_type(skb) = (&pkts[i])->type; in h4_recv_buf()
73 hci_skb_expect(skb) = (&pkts[i])->hlen; in h4_recv_buf()
96 if (hci_skb_pkt_type(skb) == (&pkts[i])->type) in h4_recv_buf()
105 if (skb->len == (&pkts[i])->hlen) { in h4_recv_buf()
108 switch ((&pkts[i])->lsize) { in h4_recv_buf()
115 dlen = skb->data[(&pkts[i])->loff]; in h4_recv_buf()
126 (&pkts[i])->loff); in h4_recv_buf()
[all …]
|
| D | hci_h4.c | 156 const struct h4_recv_pkt *pkts, int pkts_count) in h4_recv_buf() argument
178 if (buffer[0] != (&pkts[i])->type) in h4_recv_buf()
181 skb = bt_skb_alloc((&pkts[i])->maxlen, in h4_recv_buf()
186 hci_skb_pkt_type(skb) = (&pkts[i])->type; in h4_recv_buf()
187 hci_skb_expect(skb) = (&pkts[i])->hlen; in h4_recv_buf()
210 if (hci_skb_pkt_type(skb) == (&pkts[i])->type) in h4_recv_buf()
219 if (skb->len == (&pkts[i])->hlen) { in h4_recv_buf()
222 switch ((&pkts[i])->lsize) { in h4_recv_buf()
229 dlen = skb->data[(&pkts[i])->loff]; in h4_recv_buf()
240 (&pkts[i])->loff); in h4_recv_buf()
[all …]
|
| /linux-6.12.1/lib/dim/ |
| D | net_dim.c | 16 {.usec = 1, .pkts = NET_DIM_DEFAULT_RX_CQ_PKTS_FROM_EQE,}, \
17 {.usec = 8, .pkts = NET_DIM_DEFAULT_RX_CQ_PKTS_FROM_EQE,}, \
18 {.usec = 64, .pkts = NET_DIM_DEFAULT_RX_CQ_PKTS_FROM_EQE,}, \
19 {.usec = 128, .pkts = NET_DIM_DEFAULT_RX_CQ_PKTS_FROM_EQE,}, \
20 {.usec = 256, .pkts = NET_DIM_DEFAULT_RX_CQ_PKTS_FROM_EQE,} \
24 {.usec = 2, .pkts = 256,}, \
25 {.usec = 8, .pkts = 128,}, \
26 {.usec = 16, .pkts = 64,}, \
27 {.usec = 32, .pkts = 64,}, \
28 {.usec = 64, .pkts = 64,} \
[all …]
|
| /linux-6.12.1/include/net/ |
| D | netdev_queues.h | 209 unsigned int pkts, unsigned int bytes) in netdev_txq_completed_mb() argument
212 netdev_tx_completed_queue(dev_queue, pkts, bytes); in netdev_txq_completed_mb()
237 #define __netif_txq_completed_wake(txq, pkts, bytes, \ argument
247 netdev_txq_completed_mb(txq, pkts, bytes); \
250 if (pkts && likely(get_desc >= start_thrs)) { \
261 #define netif_txq_completed_wake(txq, pkts, bytes, get_desc, start_thrs) \ argument
262 __netif_txq_completed_wake(txq, pkts, bytes, get_desc, start_thrs, false)
282 #define netif_subqueue_completed_wake(dev, idx, pkts, bytes, \ argument
288 netif_txq_completed_wake(txq, pkts, bytes, \
|
| /linux-6.12.1/tools/testing/selftests/drivers/net/netdevsim/ |
| D | hw_stats_l3.sh | 318 local pkts=$(get_hwstat dummy1 l3 rx.packets)
319 ((pkts < 10))
324 local pkts=$(get_hwstat dummy1 l3 rx.packets)
325 ((pkts >= 20))
333 local pkts=$(get_hwstat dummy1 l3 rx.packets)
334 ((pkts < 10))
345 local pkts=$(get_hwstat dummy1 l3 rx.packets)
346 ((pkts < 10))
390 local pkts=$(get_hwstat dummy1 l3 rx.packets)
391 ((pkts < 10))
[all …]
|
| /linux-6.12.1/tools/testing/selftests/bpf/prog_tests/ |
| D | l4lb_all.c | 16 __u64 pkts; in test_l4lb() member
27 __u64 bytes = 0, pkts = 0; in test_l4lb() local
81 pkts += stats[i].pkts; in test_l4lb()
84 pkts != NUM_ITER * 2)) in test_l4lb()
85 printf("test_l4lb:FAIL:stats %lld %lld\n", bytes, pkts); in test_l4lb()
|
| D | xdp_noinline.c | 18 __u64 pkts; in test_xdp_noinline() member
29 __u64 bytes = 0, pkts = 0; in test_xdp_noinline() local
68 pkts += stats[i].pkts; in test_xdp_noinline()
71 ASSERT_EQ(pkts, NUM_ITER * 2, "stats pkts"); in test_xdp_noinline()
|
| /linux-6.12.1/drivers/net/ethernet/huawei/hinic/ |
| D | hinic_rx.c | 58 rxq_stats->pkts = 0; in hinic_rxq_clean_stats()
78 stats->pkts = rxq_stats->pkts; in hinic_rxq_get_stats()
364 int num_wqes, pkts = 0; in rxq_recv() local
376 while (pkts < budget) { in rxq_recv()
426 pkts++; in rxq_recv()
450 rxq->rxq_stats.pkts += pkts; in rxq_recv()
454 return pkts; in rxq_recv()
462 int pkts; in rx_poll() local
464 pkts = rxq_recv(rxq, budget); in rx_poll()
465 if (pkts >= budget) in rx_poll()
[all …]
|
| /linux-6.12.1/net/netfilter/ |
| D | xt_connbytes.c | 28 u_int64_t pkts = 0; in connbytes_mt() local
74 pkts = atomic64_read(&counters[IP_CT_DIR_ORIGINAL].packets); in connbytes_mt()
78 pkts = atomic64_read(&counters[IP_CT_DIR_REPLY].packets); in connbytes_mt()
83 pkts = atomic64_read(&counters[IP_CT_DIR_ORIGINAL].packets) + in connbytes_mt()
87 if (pkts != 0) in connbytes_mt()
88 what = div64_u64(bytes, pkts); in connbytes_mt()
|
| D | nfnetlink_acct.c | 30 atomic64_t pkts; member
89 atomic64_set(&matching->pkts, 0); in nfnl_acct_new()
133 atomic64_set(&nfacct->pkts, in nfnl_acct_new()
147 u64 pkts, bytes; in nfnl_acct_fill_info() local
161 pkts = atomic64_xchg(&acct->pkts, 0); in nfnl_acct_fill_info()
167 pkts = atomic64_read(&acct->pkts); in nfnl_acct_fill_info()
170 if (nla_put_be64(skb, NFACCT_PKTS, cpu_to_be64(pkts), in nfnl_acct_fill_info()
455 atomic64_inc(&nfacct->pkts); in nfnl_acct_update()
490 atomic64_read(&nfacct->pkts) : atomic64_read(&nfacct->bytes); in nfnl_acct_overquota()
|
| /linux-6.12.1/tools/testing/selftests/net/forwarding/ |
| D | pedit_ip.sh | 133 local pkts
134 pkts=$(busywait "$TC_HIT_TIMEOUT" until_counter_is ">= 10" \
136 check_err $? "Expected to get 10 packets, but got $pkts."
138 pkts=$(tc_rule_handle_stats_get "$pedit_locus" 101)
139 ((pkts >= 10))
140 check_err $? "Expected to get 10 packets on pedit rule, but got $pkts."
|
| D | pedit_l4port.sh | 138 local pkts
139 pkts=$(busywait "$TC_HIT_TIMEOUT" until_counter_is ">= 10" \
141 check_err $? "Expected to get 10 packets, but got $pkts."
143 pkts=$(tc_rule_handle_stats_get "$pedit_locus" 101)
144 ((pkts >= 10))
145 check_err $? "Expected to get 10 packets on pedit rule, but got $pkts."
|
| D | pedit_dsfield.sh | 136 local pkts
137 pkts=$(busywait "$TC_HIT_TIMEOUT" until_counter_is ">= 10" \
139 check_err $? "Expected to get 10 packets on test probe, but got $pkts."
141 pkts=$(tc_rule_handle_stats_get "$pedit_locus" 101)
142 ((pkts >= 10))
143 check_err $? "Expected to get 10 packets on pedit rule, but got $pkts."
|
| /linux-6.12.1/tools/testing/selftests/bpf/ |
| D | xskxceiver.c | 612 return &pkt_stream->pkts[pkt_stream->current_pkt_nb++]; in pkt_stream_get_next_tx_pkt()
619 if (pkt_stream->pkts[pkt_stream->current_pkt_nb].valid) in pkt_stream_get_next_rx_pkt()
620 return &pkt_stream->pkts[pkt_stream->current_pkt_nb++]; in pkt_stream_get_next_rx_pkt()
628 free(pkt_stream->pkts); in pkt_stream_delete()
656 pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts)); in __pkt_stream_alloc()
657 if (!pkt_stream->pkts) { in __pkt_stream_alloc()
741 struct pkt *pkt = &pkt_stream->pkts[i]; in __pkt_stream_generate()
757 return pkt_stream_generate(pkt_stream->nb_pkts, pkt_stream->pkts[0].len); in pkt_stream_clone()
778 pkt_stream_pkt_set(pkt_stream, &pkt_stream->pkts[i], offset, pkt_len); in __pkt_stream_replace_half()
795 pkt_stream->pkts[0].len); in pkt_stream_receive_half()
[all …]
|
| /linux-6.12.1/drivers/net/ethernet/netronome/nfp/flower/ |
| D | qos_conf.c | 372 curr_stats->pkts = be64_to_cpu(msg->pass_pkts) + in nfp_flower_stats_rlim_reply()
378 prev_stats->pkts = curr_stats->pkts; in nfp_flower_stats_rlim_reply()
491 diff_pkts = curr_stats->pkts - prev_stats->pkts; in nfp_flower_stats_rate_limiter()
493 prev_stats->pkts = curr_stats->pkts; in nfp_flower_stats_rate_limiter()
810 meter_entry->stats.curr.pkts = be64_to_cpu(msg->pass_pkts) + in nfp_act_stats_reply()
816 meter_entry->stats.prev.pkts = meter_entry->stats.curr.pkts; in nfp_act_stats_reply()
848 diff_pkts = meter_entry->stats.curr.pkts > meter_entry->stats.prev.pkts ? in nfp_act_stats_actions()
849 meter_entry->stats.curr.pkts - meter_entry->stats.prev.pkts : 0; in nfp_act_stats_actions()
859 meter_entry->stats.prev.pkts = meter_entry->stats.curr.pkts; in nfp_act_stats_actions()
|
| /linux-6.12.1/net/vmw_vsock/ |
| D | vsock_loopback.c | 118 struct sk_buff_head pkts; in vsock_loopback_work() local
121 skb_queue_head_init(&pkts); in vsock_loopback_work()
124 skb_queue_splice_init(&vsock->pkt_queue, &pkts); in vsock_loopback_work()
127 while ((skb = __skb_dequeue(&pkts))) { in vsock_loopback_work()
|
| /linux-6.12.1/drivers/net/ethernet/microchip/lan966x/ |
| D | lan966x_mirror.c | 116 new_stats.rx_packets - old_stats->pkts, in lan966x_mirror_port_stats()
122 old_stats->pkts = new_stats.rx_packets; in lan966x_mirror_port_stats()
128 new_stats.tx_packets - old_stats->pkts, in lan966x_mirror_port_stats()
134 old_stats->pkts = new_stats.tx_packets; in lan966x_mirror_port_stats()
|
| /linux-6.12.1/net/tipc/ |
| D | bcast.c | 259 int tipc_bcast_xmit(struct net *net, struct sk_buff_head *pkts, in tipc_bcast_xmit() argument
269 rc = tipc_link_xmit(l, pkts, &xmitq); in tipc_bcast_xmit()
272 __skb_queue_purge(pkts); in tipc_bcast_xmit()
288 static int tipc_rcast_xmit(struct net *net, struct sk_buff_head *pkts, in tipc_rcast_xmit() argument
295 selector = msg_link_selector(buf_msg(skb_peek(pkts))); in tipc_rcast_xmit()
300 if (!tipc_msg_pskb_copy(dnode, pkts, &_pkts)) in tipc_rcast_xmit()
378 int tipc_mcast_xmit(struct net *net, struct sk_buff_head *pkts, in tipc_mcast_xmit() argument
392 if (dests->local && !tipc_msg_reassemble(pkts, &localq)) { in tipc_mcast_xmit()
400 skb = skb_peek(pkts); in tipc_mcast_xmit()
417 rc = tipc_rcast_xmit(net, pkts, dests, cong_link_cnt); in tipc_mcast_xmit()
[all …]
|
| /linux-6.12.1/drivers/net/ethernet/mellanox/mlx5/core/en/tc/ |
| D | act_stats.c | 172 u64 pkts, bytes, lastused; in mlx5e_tc_act_stats_fill_stats() local
184 &bytes, &pkts, &lastused); in mlx5e_tc_act_stats_fill_stats()
188 pkts - item->lastpackets, in mlx5e_tc_act_stats_fill_stats()
191 item->lastpackets = pkts; in mlx5e_tc_act_stats_fill_stats()
|
| /linux-6.12.1/drivers/usb/host/ |
| D | xhci-mtk-sch.c | 336 sch_ep->pkts = max_burst + 1; in setup_sch_info()
337 bwb_table[0] = maxpkt * sch_ep->pkts; in setup_sch_info()
352 sch_ep->pkts = esit_pkts; in setup_sch_info()
354 bwb_table[0] = maxpkt * sch_ep->pkts; in setup_sch_info()
360 sch_ep->pkts = esit_pkts; in setup_sch_info()
362 sch_ep->pkts = 1; in setup_sch_info()
364 sch_ep->pkts = roundup_pow_of_two(esit_pkts) in setup_sch_info()
368 DIV_ROUND_UP(esit_pkts, sch_ep->pkts); in setup_sch_info()
371 bw_per_microframe = maxpkt * sch_ep->pkts; in setup_sch_info()
380 sch_ep->pkts = 1; /* at most one packet for each microframe */ in setup_sch_info()
[all …]
|
| /linux-6.12.1/tools/testing/selftests/net/ |
| D | test_vxlan_nolocalbypass.sh | 86 local pkts
89 pkts=$(tc -n $ns -j -s filter show $id \
92 [[ $pkts == $count ]]
|
| /linux-6.12.1/drivers/net/ethernet/pensando/ionic/ |
| D | ionic_txrx.c | 385 stats->pkts++; in ionic_xdp_post_frame()
632 stats->pkts++; in ionic_rx_clean()
905 u64 pkts, bytes; in ionic_dim_update() local
915 pkts = lif->txqstats[qi].pkts; in ionic_dim_update()
919 pkts = lif->rxqstats[qi].pkts; in ionic_dim_update()
923 pkts = lif->txqstats[qi].pkts + lif->rxqstats[qi].pkts; in ionic_dim_update()
929 pkts, bytes, &dim_sample); in ionic_dim_update()
1240 unsigned int pkts = 0; in ionic_tx_service() local
1258 pkts++; in ionic_tx_service()
1264 (*total_pkts) += pkts; in ionic_tx_service()
[all …]
|
| /linux-6.12.1/drivers/net/ethernet/fungible/funeth/ |
| D | funeth_txrx.h | 45 #define FUN_IRQ_CQ_DB(usec, pkts) \ argument
47 ((pkts) << FUN_DB_INTCOAL_ENTRIES_S))
50 #define FUN_IRQ_SQ_DB(usec, pkts) \ argument
53 ((pkts) << FUN_DB_INTCOAL_ENTRIES_S))
|
| /linux-6.12.1/drivers/net/ethernet/microchip/sparx5/ |
| D | sparx5_mirror.c | 213 new_stats.rx_packets - old_stats->pkts, in sparx5_mirror_stats()
219 old_stats->pkts = new_stats.rx_packets; in sparx5_mirror_stats()
225 new_stats.tx_packets - old_stats->pkts, in sparx5_mirror_stats()
231 old_stats->pkts = new_stats.tx_packets; in sparx5_mirror_stats()
|
| /linux-6.12.1/drivers/net/ethernet/intel/ixgbe/ |
| D | ixgbe_txrx_common.h | 50 struct ixgbe_q_vector *q_vector, u64 pkts,
53 struct ixgbe_q_vector *q_vector, u64 pkts,
|