| /dpdk/app/test-pmd/ |
| H A D | shared_rxq_fwd.c | 15 rte_pktmbuf_free_bulk(pkts_burst, nb_rx); in forward_rx_only()
51 fs->rx_packets += nb_rx; in forward_sub_burst()
52 forward_rx_only(nb_rx, pkts); in forward_sub_burst()
55 src_fs->fwd_dropped += nb_rx; in forward_sub_burst()
56 while (nb_rx > 0) in forward_sub_burst()
57 rte_pktmbuf_free(pkts[--nb_rx]); in forward_sub_burst()
75 for (i = 0; i < nb_rx - 1; ++i) { in forward_shared_rxq()
90 &pkts_burst[nb_rx - nb_sub_burst]); in forward_shared_rxq()
97 uint16_t nb_rx; in shared_rxq_fwd() local
103 inc_rx_burst_stats(fs, nb_rx); in shared_rxq_fwd()
[all …]
|
| H A D | noisy_vnf.c | 113 if (nb_tx < nb_rx) { in drop_pkts()
116 } while (++nb_tx < nb_rx); in drop_pkts()
119 return nb_rx - nb_tx; in drop_pkts()
147 uint16_t nb_rx = 0; in pkt_burst_noisy_vnf() local
157 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_noisy_vnf()
158 if (unlikely(nb_rx == 0)) in pkt_burst_noisy_vnf()
160 fs->rx_packets += nb_rx; in pkt_burst_noisy_vnf()
165 pkts_burst, nb_rx); in pkt_burst_noisy_vnf()
175 if (fifo_free >= nb_rx) { in pkt_burst_noisy_vnf()
178 if (nb_enqd < nb_rx) in pkt_burst_noisy_vnf()
[all …]
|
| H A D | macswap.c | 56 uint16_t nb_rx; in pkt_burst_mac_swap() local
68 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_mac_swap()
69 if (unlikely(nb_rx == 0)) in pkt_burst_mac_swap()
72 fs->rx_packets += nb_rx; in pkt_burst_mac_swap()
75 do_macswap(pkts_burst, nb_rx, txp); in pkt_burst_mac_swap()
81 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_mac_swap()
83 while (nb_tx < nb_rx && retry++ < burst_tx_retry_num) { in pkt_burst_mac_swap()
86 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_swap()
91 if (unlikely(nb_tx < nb_rx)) { in pkt_burst_mac_swap()
92 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_mac_swap()
[all …]
|
| H A D | iofwd.c | 49 uint16_t nb_rx; in pkt_burst_io_forward() local
59 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, in pkt_burst_io_forward()
61 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_io_forward()
62 if (unlikely(nb_rx == 0)) in pkt_burst_io_forward()
64 fs->rx_packets += nb_rx; in pkt_burst_io_forward()
67 pkts_burst, nb_rx); in pkt_burst_io_forward()
71 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_io_forward()
76 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_io_forward()
81 if (unlikely(nb_tx < nb_rx)) { in pkt_burst_io_forward()
82 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_io_forward()
[all …]
|
| H A D | macfwd.c | 53 uint16_t nb_rx; in pkt_burst_mac_forward() local
67 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_mac_forward()
68 if (unlikely(nb_rx == 0)) in pkt_burst_mac_forward()
71 fs->rx_packets += nb_rx; in pkt_burst_mac_forward()
80 for (i = 0; i < nb_rx; i++) { in pkt_burst_mac_forward()
81 if (likely(i < nb_rx - 1)) in pkt_burst_mac_forward()
101 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_mac_forward()
106 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_forward()
112 if (unlikely(nb_tx < nb_rx)) { in pkt_burst_mac_forward()
113 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_mac_forward()
[all …]
|
| H A D | 5tswap.c | 93 uint16_t nb_rx; in pkt_burst_5tuple_swap() local
117 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_5tuple_swap()
118 if (unlikely(nb_rx == 0)) in pkt_burst_5tuple_swap()
121 fs->rx_packets += nb_rx; in pkt_burst_5tuple_swap()
124 vlan_qinq_set(pkts_burst, nb_rx, ol_flags, in pkt_burst_5tuple_swap()
126 for (i = 0; i < nb_rx; i++) { in pkt_burst_5tuple_swap()
127 if (likely(i < nb_rx - 1)) in pkt_burst_5tuple_swap()
174 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_5tuple_swap()
179 if (unlikely(nb_tx < nb_rx)) { in pkt_burst_5tuple_swap()
180 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_5tuple_swap()
[all …]
|
| H A D | rxonly.c | 49 uint16_t nb_rx; in pkt_burst_receive() local
58 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_receive()
60 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_receive()
61 if (unlikely(nb_rx == 0)) in pkt_burst_receive()
64 fs->rx_packets += nb_rx; in pkt_burst_receive()
65 for (i = 0; i < nb_rx; i++) in pkt_burst_receive()
|
| H A D | csumonly.c | 828 uint16_t nb_rx; in pkt_burst_checksum_forward() local
849 if (unlikely(nb_rx == 0)) in pkt_burst_checksum_forward()
852 fs->rx_packets += nb_rx; in pkt_burst_checksum_forward()
872 if (likely(i < nb_rx - 1)) in pkt_burst_checksum_forward()
1087 nb_rx = rte_gro_reassemble_burst(pkts_burst, nb_rx, in pkt_burst_checksum_forward()
1091 nb_rx = rte_gro_reassemble(pkts_burst, nb_rx, gro_ctx); in pkt_burst_checksum_forward()
1100 &pkts_burst[nb_rx], in pkt_burst_checksum_forward()
1137 nb_rx = nb_segments; in pkt_burst_checksum_forward()
1143 tx_pkts_burst, nb_rx); in pkt_burst_checksum_forward()
1144 if (nb_prep != nb_rx) in pkt_burst_checksum_forward()
[all …]
|
| /dpdk/app/test-eventdev/ |
| H A D | test_pipeline_atq.c | 71 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_single_stage_burst_tx() local
76 if (!nb_rx) { in pipeline_atq_worker_single_stage_burst_tx()
81 for (i = 0; i < nb_rx; i++) { in pipeline_atq_worker_single_stage_burst_tx()
99 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_single_stage_burst_fwd() local
104 if (!nb_rx) { in pipeline_atq_worker_single_stage_burst_fwd()
185 if (!nb_rx) { in pipeline_atq_worker_single_stage_burst_tx_vector()
214 if (!nb_rx) { in pipeline_atq_worker_single_stage_burst_fwd_vector()
309 if (!nb_rx) { in pipeline_atq_worker_multi_stage_burst_tx()
346 if (!nb_rx) { in pipeline_atq_worker_multi_stage_burst_fwd()
453 if (!nb_rx) { in pipeline_atq_worker_multi_stage_burst_tx_vector()
[all …]
|
| H A D | test_pipeline_queue.c | 79 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_single_stage_burst_tx() local
84 if (!nb_rx) { in pipeline_queue_worker_single_stage_burst_tx()
89 for (i = 0; i < nb_rx; i++) { in pipeline_queue_worker_single_stage_burst_tx()
118 if (!nb_rx) { in pipeline_queue_worker_single_stage_burst_fwd()
131 w->processed_pkts += nb_rx; in pipeline_queue_worker_single_stage_burst_fwd()
207 if (!nb_rx) { in pipeline_queue_worker_single_stage_burst_tx_vector()
243 if (!nb_rx) { in pipeline_queue_worker_single_stage_burst_fwd_vector()
344 if (!nb_rx) { in pipeline_queue_worker_multi_stage_burst_tx()
383 if (!nb_rx) { in pipeline_queue_worker_multi_stage_burst_fwd()
496 if (!nb_rx) { in pipeline_queue_worker_multi_stage_burst_tx_vector()
[all …]
|
| H A D | test_pipeline_common.h | 142 struct rte_event *ev, const uint16_t nb_rx, in pipeline_event_tx_burst() argument
147 enq = rte_event_eth_tx_adapter_enqueue(dev, port, ev, nb_rx, 0); in pipeline_event_tx_burst()
148 while (enq < nb_rx && !t->done) { in pipeline_event_tx_burst()
150 ev + enq, nb_rx - enq, 0); in pipeline_event_tx_burst()
171 struct rte_event *ev, const uint16_t nb_rx, in pipeline_event_enqueue_burst() argument
176 enq = rte_event_enqueue_burst(dev, port, ev, nb_rx); in pipeline_event_enqueue_burst()
177 while (enq < nb_rx && !t->done) { in pipeline_event_enqueue_burst()
179 ev + enq, nb_rx - enq); in pipeline_event_enqueue_burst()
|
| H A D | test_order_atq.c | 63 uint16_t const nb_rx = rte_event_dequeue_burst(dev_id, port, ev, in order_atq_worker_burst() local
66 if (nb_rx == 0) { in order_atq_worker_burst()
73 for (i = 0; i < nb_rx; i++) { in order_atq_worker_burst()
90 enq = rte_event_enqueue_burst(dev_id, port, ev, nb_rx); in order_atq_worker_burst()
91 while (enq < nb_rx) { in order_atq_worker_burst()
93 ev + enq, nb_rx - enq); in order_atq_worker_burst()
|
| /dpdk/app/test/ |
| H A D | test_pmd_perf.c | 357 count += nb_rx; in measure_rxtx()
360 drop += (nb_rx - nb_tx); in measure_rxtx()
397 count += nb_rx; in measure_rxonly()
400 drop += (nb_rx - nb_tx); in measure_rxonly()
433 count += nb_rx; in measure_txonly()
438 drop += (nb_rx - nb_tx); in measure_txonly()
520 while (nb_tx < nb_rx) in main_loop()
522 nb_free += nb_rx; in main_loop()
594 next[portid] += nb_rx; in poll_burst()
595 num[portid] -= nb_rx; in poll_burst()
[all …]
|
| /dpdk/drivers/net/failsafe/ |
| H A D | failsafe_rxtx.c | 87 uint16_t nb_rx; in failsafe_rx_burst() local
93 nb_rx = 0; in failsafe_rx_burst()
99 nb_rx = ETH(sdev)-> in failsafe_rx_burst()
105 if (nb_rx) in failsafe_rx_burst()
106 failsafe_rx_set_port(rx_pkts, nb_rx, in failsafe_rx_burst()
108 return nb_rx; in failsafe_rx_burst()
119 uint16_t nb_rx; in failsafe_rx_burst_fast() local
127 nb_rx = ETH(sdev)-> in failsafe_rx_burst_fast()
133 if (nb_rx) in failsafe_rx_burst_fast()
134 failsafe_rx_set_port(rx_pkts, nb_rx, in failsafe_rx_burst_fast()
[all …]
|
| /dpdk/drivers/net/virtio/ |
| H A D | virtio_rxtx_packed.c | 86 uint16_t num, nb_rx = 0; in virtio_recv_pkts_packed_vec() local
91 return nb_rx; in virtio_recv_pkts_packed_vec()
100 &rx_pkts[nb_rx])) { in virtio_recv_pkts_packed_vec()
101 nb_rx += PACKED_BATCH_SIZE; in virtio_recv_pkts_packed_vec()
107 &rx_pkts[nb_rx])) { in virtio_recv_pkts_packed_vec()
108 nb_rx++; in virtio_recv_pkts_packed_vec()
117 rxvq->stats.packets += nb_rx; in virtio_recv_pkts_packed_vec()
140 return nb_rx; in virtio_recv_pkts_packed_vec()
|
| H A D | virtio_rxtx.c | 997 nb_rx = 0; in virtio_recv_pkts()
1085 return nb_rx; in virtio_recv_pkts()
1104 nb_rx = 0; in virtio_recv_pkts_packed()
1186 return nb_rx; in virtio_recv_pkts_packed()
1210 nb_rx = 0; in virtio_recv_pkts_inorder()
1297 nb_rx++; in virtio_recv_pkts_inorder()
1327 nb_rx++; in virtio_recv_pkts_inorder()
1476 nb_rx++; in virtio_recv_mergeable_pkts()
1506 nb_rx++; in virtio_recv_mergeable_pkts()
1648 nb_rx++; in virtio_recv_mergeable_pkts_packed()
[all …]
|
| /dpdk/examples/l2fwd-event/ |
| H A D | l2fwd_event.c | 243 uint16_t nb_rx = 0, nb_tx = 0; in l2fwd_event_loop_burst() local
256 if (nb_rx == 0) in l2fwd_event_loop_burst()
259 for (i = 0; i < nb_rx; i++) { in l2fwd_event_loop_burst()
268 ev, nb_rx); in l2fwd_event_loop_burst()
272 nb_rx - nb_tx); in l2fwd_event_loop_burst()
279 nb_rx, 0); in l2fwd_event_loop_burst()
427 uint16_t nb_rx = 0, nb_tx = 0; in l2fwd_event_loop_vector() local
439 if (nb_rx == 0) in l2fwd_event_loop_vector()
454 nb_rx); in l2fwd_event_loop_vector()
458 nb_rx - nb_tx); in l2fwd_event_loop_vector()
[all …]
|
| /dpdk/lib/power/ |
| H A D | rte_power_pmd_mgmt.c | 266 return nb_rx; in clb_multiwait()
270 return nb_rx; in clb_multiwait()
276 return nb_rx; in clb_multiwait()
281 return nb_rx; in clb_multiwait()
306 return nb_rx; in clb_umwait()
327 return nb_rx; in clb_pause()
331 return nb_rx; in clb_pause()
346 return nb_rx; in clb_pause()
368 return nb_rx; in clb_scale_freq()
372 return nb_rx; in clb_scale_freq()
[all …]
|
| /dpdk/examples/eventdev_pipeline/ |
| H A D | pipeline_worker_tx.c | 34 ev + enq, nb_rx - enq); in worker_event_enqueue_burst()
146 if (!nb_rx) { in worker_do_tx_single_burst()
150 received += nb_rx; in worker_do_tx_single_burst()
152 for (i = 0; i < nb_rx; i++) { in worker_do_tx_single_burst()
193 if (!nb_rx) { in worker_do_tx_single_burst_atq()
198 received += nb_rx; in worker_do_tx_single_burst_atq()
200 for (i = 0; i < nb_rx; i++) { in worker_do_tx_single_burst_atq()
346 if (nb_rx == 0) { in worker_do_tx_burst()
350 received += nb_rx; in worker_do_tx_burst()
402 if (nb_rx == 0) { in worker_do_tx_burst_atq()
[all …]
|
| /dpdk/examples/l3fwd/ |
| H A D | l3fwd_em_sequential.h | 76 l3fwd_em_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_em_send_packets() argument
82 if (nb_rx > 0) { in l3fwd_em_send_packets()
87 for (i = 1, j = 0; j < nb_rx; i++, j++) { in l3fwd_em_send_packets()
88 if (i < nb_rx) { in l3fwd_em_send_packets()
96 send_packets_multi(qconf, pkts_burst, dst_port, nb_rx); in l3fwd_em_send_packets()
104 l3fwd_em_process_events(int nb_rx, struct rte_event **events, in l3fwd_em_process_events() argument
112 for (i = 1, j = 0; j < nb_rx; i++, j++) { in l3fwd_em_process_events()
115 if (i < nb_rx) { in l3fwd_em_process_events()
|
| H A D | l3fwd_em.h | 125 l3fwd_em_no_opt_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_em_no_opt_send_packets() argument
131 for (j = 0; j < PREFETCH_OFFSET && j < nb_rx; j++) in l3fwd_em_no_opt_send_packets()
138 for (j = 0; j < (nb_rx - PREFETCH_OFFSET); j++) { in l3fwd_em_no_opt_send_packets()
145 for (; j < nb_rx; j++) in l3fwd_em_no_opt_send_packets()
154 l3fwd_em_no_opt_process_events(int nb_rx, struct rte_event **events, in l3fwd_em_no_opt_process_events() argument
160 for (j = 0; j < PREFETCH_OFFSET && j < nb_rx; j++) in l3fwd_em_no_opt_process_events()
167 for (j = 0; j < (nb_rx - PREFETCH_OFFSET); j++) { in l3fwd_em_no_opt_process_events()
174 for (; j < nb_rx; j++) in l3fwd_em_no_opt_process_events()
|
| H A D | l3fwd_fib.c | 110 uint32_t ipv4_arr[nb_rx]; in fib_send_packets()
111 uint8_t ipv6_arr[nb_rx][RTE_FIB6_IPV6_ADDR_SIZE]; in fib_send_packets()
112 uint16_t hops[nb_rx]; in fib_send_packets()
113 uint64_t hopsv4[nb_rx], hopsv6[nb_rx]; in fib_send_packets()
114 uint8_t type_arr[nb_rx]; in fib_send_packets()
136 for (; i < nb_rx; i++) in fib_send_packets()
153 for (i = 0; i < nb_rx; i++) { in fib_send_packets()
162 send_packets_multi(qconf, pkts_burst, hops, nb_rx); in fib_send_packets()
164 fib_send_single(nb_rx, qconf, pkts_burst, hops); in fib_send_packets()
175 int i, nb_rx; in fib_main_loop() local
[all …]
|
| /dpdk/examples/qos_sched/ |
| H A D | app_thread.c | 64 uint32_t i, nb_rx; in app_rx_thread() local
76 nb_rx = rte_eth_rx_burst(conf->rx_port, conf->rx_queue, rx_mbufs, in app_rx_thread()
79 if (likely(nb_rx != 0)) { in app_rx_thread()
80 APP_STATS_ADD(conf->stat.nb_rx, nb_rx); in app_rx_thread()
82 for(i = 0; i < nb_rx; i++) { in app_rx_thread()
93 (void **)rx_mbufs, nb_rx, NULL) == 0)) { in app_rx_thread()
94 for(i = 0; i < nb_rx; i++) { in app_rx_thread()
210 APP_STATS_ADD(conf->stat.nb_rx, nb_pkt); in app_worker_thread()
246 APP_STATS_ADD(conf->stat.nb_rx, nb_pkt); in app_mixed_thread()
|
| /dpdk/drivers/net/hns3/ |
| H A D | hns3_rxtx_vec.c | 114 uint16_t nb_rx; in hns3_recv_pkts_vec() local
134 nb_rx = hns3_recv_burst_vec(rxq, rx_pkts, nb_pkts, in hns3_recv_pkts_vec()
136 nb_rx = hns3_rx_reassemble_pkts(rx_pkts, nb_rx, pkt_err_mask); in hns3_recv_pkts_vec()
137 return nb_rx; in hns3_recv_pkts_vec()
140 nb_rx = 0; in hns3_recv_pkts_vec()
146 ret = hns3_recv_burst_vec(rxq, &rx_pkts[nb_rx], n, in hns3_recv_pkts_vec()
149 nb_rx += hns3_rx_reassemble_pkts(&rx_pkts[nb_rx], ret, in hns3_recv_pkts_vec()
158 return nb_rx; in hns3_recv_pkts_vec()
|
| H A D | hns3_rxtx_vec_sve.c | 90 uint16_t nb_rx = 0; in hns3_recv_burst_vec_sve() local
227 nb_rx += bd_valid_num; in hns3_recv_burst_vec_sve()
232 rxq->rx_rearm_nb += nb_rx; in hns3_recv_burst_vec_sve()
233 rxq->next_to_use += nb_rx; in hns3_recv_burst_vec_sve()
237 return nb_rx; in hns3_recv_burst_vec_sve()
296 uint16_t nb_rx; in hns3_recv_pkts_vec_sve() local
315 nb_rx = hns3_rx_reassemble_pkts(rx_pkts, nb_rx, pkt_err_mask); in hns3_recv_pkts_vec_sve()
316 return nb_rx; in hns3_recv_pkts_vec_sve()
319 nb_rx = 0; in hns3_recv_pkts_vec_sve()
328 nb_rx += hns3_rx_reassemble_pkts(&rx_pkts[nb_rx], ret, in hns3_recv_pkts_vec_sve()
[all …]
|