| /dpdk/app/test-pmd/ |
| H A D | noisy_vnf.c | 104 &pkts[nb_tx], nb_rx - nb_tx); in do_retry()
107 return nb_tx; in do_retry()
113 if (nb_tx < nb_rx) { in drop_pkts()
115 rte_pktmbuf_free(pkts[nb_tx]); in drop_pkts()
116 } while (++nb_tx < nb_rx); in drop_pkts()
119 return nb_rx - nb_tx; in drop_pkts()
148 uint16_t nb_tx = 0; in pkt_burst_noisy_vnf() local
167 nb_tx += do_retry(nb_rx, nb_tx, pkts_burst, fs); in pkt_burst_noisy_vnf()
169 fs->tx_packets += nb_tx; in pkt_burst_noisy_vnf()
191 nb_tx += do_retry(nb_rx, nb_tx, tmp_pkts, fs); in pkt_burst_noisy_vnf()
[all …]
|
| H A D | iofwd.c | 50 uint16_t nb_tx; in pkt_burst_io_forward() local
66 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
71 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_io_forward()
75 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
76 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_io_forward()
79 fs->tx_packets += nb_tx; in pkt_burst_io_forward()
80 inc_tx_burst_stats(fs, 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()
84 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_io_forward()
[all …]
|
| H A D | macswap.c | 57 uint16_t nb_tx; in pkt_burst_mac_swap() local
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()
85 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_swap()
86 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_swap()
89 fs->tx_packets += nb_tx; in pkt_burst_mac_swap()
90 inc_tx_burst_stats(fs, 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()
94 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_mac_swap()
[all …]
|
| H A D | macfwd.c | 54 uint16_t nb_tx; in pkt_burst_mac_forward() local
101 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_mac_forward()
103 while (nb_tx < nb_rx && retry++ < burst_tx_retry_num) { in pkt_burst_mac_forward()
105 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_forward()
106 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_forward()
110 fs->tx_packets += nb_tx; in pkt_burst_mac_forward()
111 inc_tx_burst_stats(fs, 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()
115 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_mac_forward()
[all …]
|
| H A D | 5tswap.c | 94 uint16_t nb_tx; in pkt_burst_5tuple_swap() local
169 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_5tuple_swap()
171 while (nb_tx < nb_rx && retry++ < burst_tx_retry_num) { in pkt_burst_5tuple_swap()
173 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_5tuple_swap()
174 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_5tuple_swap()
177 fs->tx_packets += nb_tx; in pkt_burst_5tuple_swap()
178 inc_tx_burst_stats(fs, 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()
182 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_5tuple_swap()
[all …]
|
| H A D | flowgen.c | 75 uint16_t nb_tx; in pkt_burst_flow_gen() local
170 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_flow_gen()
174 if (unlikely(nb_tx < nb_pkt) && fs->retry_enabled) { in pkt_burst_flow_gen()
176 while (nb_tx < nb_pkt && retry++ < burst_tx_retry_num) { in pkt_burst_flow_gen()
178 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_flow_gen()
179 &pkts_burst[nb_tx], nb_pkt - nb_tx); in pkt_burst_flow_gen()
182 fs->tx_packets += nb_tx; in pkt_burst_flow_gen()
184 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_flow_gen()
185 nb_dropped = nb_pkt - nb_tx; in pkt_burst_flow_gen()
194 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_flow_gen()
[all …]
|
| H A D | icmpecho.c | 286 uint16_t nb_tx; in reply_to_icmp_echo_rqsts() local
493 while (nb_tx < nb_replies && in reply_to_icmp_echo_rqsts()
496 nb_tx += rte_eth_tx_burst(fs->tx_port, in reply_to_icmp_echo_rqsts()
498 &pkts_burst[nb_tx], in reply_to_icmp_echo_rqsts()
499 nb_replies - nb_tx); in reply_to_icmp_echo_rqsts()
502 fs->tx_packets += nb_tx; in reply_to_icmp_echo_rqsts()
503 inc_tx_burst_stats(fs, nb_tx); in reply_to_icmp_echo_rqsts()
504 if (unlikely(nb_tx < nb_replies)) { in reply_to_icmp_echo_rqsts()
505 fs->fwd_dropped += (nb_replies - nb_tx); in reply_to_icmp_echo_rqsts()
507 rte_pktmbuf_free(pkts_burst[nb_tx]); in reply_to_icmp_echo_rqsts()
[all …]
|
| H A D | txonly.c | 335 uint16_t nb_tx; in pkt_burst_transmit() local
408 &pkts_burst[nb_tx], nb_pkt - nb_tx); in pkt_burst_transmit()
411 fs->tx_packets += nb_tx; in pkt_burst_transmit()
414 RTE_PER_LCORE(_ip_var) -= nb_pkt - nb_tx; in pkt_burst_transmit()
416 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_transmit()
417 if (unlikely(nb_tx < nb_pkt)) { in pkt_burst_transmit()
422 (unsigned) nb_pkt, (unsigned) nb_tx, in pkt_burst_transmit()
423 (unsigned) (nb_pkt - nb_tx)); in pkt_burst_transmit()
424 fs->fwd_dropped += (nb_pkt - nb_tx); in pkt_burst_transmit()
426 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_transmit()
[all …]
|
| /dpdk/lib/port/ |
| H A D | rte_port_ring.c | 214 uint32_t nb_tx; in send_burst() local
220 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst()
229 uint32_t nb_tx; in send_burst_mp() local
235 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst_mp()
490 uint32_t nb_tx = 0, i; in send_burst_nodrop() local
496 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
507 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
515 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst_nodrop()
524 uint32_t nb_tx = 0, i; in send_burst_mp_nodrop() local
530 if (nb_tx >= p->tx_buf_count) { in send_burst_mp_nodrop()
[all …]
|
| H A D | rte_port_sched.c | 171 __rte_unused uint32_t nb_tx; in rte_port_sched_writer_tx() local
173 nb_tx = rte_sched_port_enqueue(p->sched, p->tx_buf, p->tx_buf_count); in rte_port_sched_writer_tx()
193 __rte_unused uint32_t nb_tx; in rte_port_sched_writer_tx_bulk() local
197 nb_tx = rte_sched_port_enqueue(p->sched, p->tx_buf, in rte_port_sched_writer_tx_bulk()
199 RTE_PORT_SCHED_WRITER_STATS_PKTS_DROP_ADD(p, tx_buf_count - nb_tx); in rte_port_sched_writer_tx_bulk()
203 nb_tx = rte_sched_port_enqueue(p->sched, pkts, n_pkts); in rte_port_sched_writer_tx_bulk()
204 RTE_PORT_SCHED_WRITER_STATS_PKTS_DROP_ADD(p, n_pkts - nb_tx); in rte_port_sched_writer_tx_bulk()
218 __rte_unused uint32_t nb_tx; in rte_port_sched_writer_tx_bulk() local
220 nb_tx = rte_sched_port_enqueue(p->sched, p->tx_buf, in rte_port_sched_writer_tx_bulk()
222 RTE_PORT_SCHED_WRITER_STATS_PKTS_DROP_ADD(p, tx_buf_count - nb_tx); in rte_port_sched_writer_tx_bulk()
[all …]
|
| H A D | rte_port_kni.c | 165 uint32_t nb_tx; in send_burst() local
170 for (; nb_tx < p->tx_buf_count; nb_tx++) in send_burst()
171 rte_pktmbuf_free(p->tx_buf[nb_tx]); in send_burst()
349 uint32_t nb_tx = 0, i; in send_burst_nodrop() local
354 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
360 nb_tx += rte_kni_tx_burst(p->kni, in send_burst_nodrop()
361 p->tx_buf + nb_tx, in send_burst_nodrop()
362 p->tx_buf_count - nb_tx); in send_burst_nodrop()
365 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
373 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst_nodrop()
[all …]
|
| H A D | rte_port_ethdev.c | 170 uint32_t nb_tx; in send_burst() local
172 nb_tx = rte_eth_tx_burst(p->port_id, p->queue_id, in send_burst()
176 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst()
177 rte_pktmbuf_free(p->tx_buf[nb_tx]); in send_burst()
358 uint32_t nb_tx = 0, i; in send_burst_nodrop() local
364 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
370 nb_tx += rte_eth_tx_burst(p->port_id, p->queue_id, in send_burst_nodrop()
371 p->tx_buf + nb_tx, p->tx_buf_count - nb_tx); in send_burst_nodrop()
374 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
382 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst_nodrop()
[all …]
|
| H A D | rte_port_sym_crypto.c | 197 uint32_t nb_tx; in send_burst() local
203 nb_tx); in send_burst()
204 for (; nb_tx < p->tx_buf_count; nb_tx++) in send_burst()
205 rte_pktmbuf_free(p->tx_buf[nb_tx]->sym->m_src); in send_burst()
389 uint32_t nb_tx = 0, i; in send_burst_nodrop() local
395 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
402 p->queue_id, p->tx_buf + nb_tx, in send_burst_nodrop()
403 p->tx_buf_count - nb_tx); in send_burst_nodrop()
406 if (nb_tx >= p->tx_buf_count) { in send_burst_nodrop()
414 p->tx_buf_count - nb_tx); in send_burst_nodrop()
[all …]
|
| H A D | rte_port_ras.c | 137 uint32_t nb_tx; in send_burst() local
139 nb_tx = rte_ring_sp_enqueue_burst(p->ring, (void **)p->tx_buf, in send_burst()
142 RTE_PORT_RING_WRITER_RAS_STATS_PKTS_DROP_ADD(p, p->tx_buf_count - nb_tx); in send_burst()
143 for ( ; nb_tx < p->tx_buf_count; nb_tx++) in send_burst()
144 rte_pktmbuf_free(p->tx_buf[nb_tx]); in send_burst()
|
| /dpdk/app/test/ |
| H A D | test_pmd_perf.c | 360 drop += (nb_rx - nb_tx); in measure_rxtx()
400 drop += (nb_rx - nb_tx); in measure_rxonly()
438 drop += (nb_rx - nb_tx); in measure_txonly()
486 if (nb_tx == 0) in main_loop()
488 num -= nb_tx; in main_loop()
489 idx += nb_tx; in main_loop()
519 nb_tx = 0; in main_loop()
520 while (nb_tx < nb_rx) in main_loop()
649 nb_tx = rte_eth_tx_burst(portid, 0, &tx_burst[idx], nb_tx); in exec_burst()
650 idx += nb_tx; in exec_burst()
[all …]
|
| /dpdk/drivers/net/virtio/ |
| H A D | virtio_rxtx_packed.c | 32 uint16_t nb_tx = 0; in virtio_xmit_pkts_packed_vec() local
36 return nb_tx; in virtio_xmit_pkts_packed_vec()
51 &tx_pkts[nb_tx])) { in virtio_xmit_pkts_packed_vec()
52 nb_tx += PACKED_BATCH_SIZE; in virtio_xmit_pkts_packed_vec()
58 tx_pkts[nb_tx])) { in virtio_xmit_pkts_packed_vec()
59 nb_tx++; in virtio_xmit_pkts_packed_vec()
66 txvq->stats.packets += nb_tx; in virtio_xmit_pkts_packed_vec()
68 if (likely(nb_tx)) { in virtio_xmit_pkts_packed_vec()
75 return nb_tx; in virtio_xmit_pkts_packed_vec()
|
| H A D | virtio_rxtx.c | 1726 for (nb_tx = 0; nb_tx < nb_pkts; nb_tx++) { in virtio_xmit_pkts_prepare()
1761 return nb_tx; in virtio_xmit_pkts_prepare()
1776 return nb_tx; in virtio_xmit_pkts_packed()
1787 for (nb_tx = 0; nb_tx < nb_pkts; nb_tx++) { in virtio_xmit_pkts_packed()
1843 return nb_tx; in virtio_xmit_pkts_packed()
1856 return nb_tx; in virtio_xmit_pkts()
1868 for (nb_tx = 0; nb_tx < nb_pkts; nb_tx++) { in virtio_xmit_pkts()
1927 return nb_tx; in virtio_xmit_pkts()
1958 return nb_tx; in virtio_xmit_pkts_inorder()
1970 for (nb_tx = 0; nb_tx < nb_pkts; nb_tx++) { in virtio_xmit_pkts_inorder()
[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
271 port_id, ev + nb_tx, in l2fwd_event_loop_burst()
272 nb_rx - nb_tx); in l2fwd_event_loop_burst()
283 ev + nb_tx, nb_rx - nb_tx, 0); in l2fwd_event_loop_burst()
427 uint16_t nb_rx = 0, nb_tx = 0; in l2fwd_event_loop_vector() local
456 nb_tx += rte_event_enqueue_burst( in l2fwd_event_loop_vector()
457 event_d_id, port_id, ev + nb_tx, in l2fwd_event_loop_vector()
458 nb_rx - nb_tx); in l2fwd_event_loop_vector()
462 nb_tx = rte_event_eth_tx_adapter_enqueue( in l2fwd_event_loop_vector()
466 event_d_id, port_id, ev + nb_tx, in l2fwd_event_loop_vector()
[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
87 w->processed_pkts += nb_tx; in pipeline_atq_worker_single_stage_burst_tx()
89 pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx); 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
117 w->processed_pkts += nb_tx; in pipeline_atq_worker_single_stage_burst_fwd()
179 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_single_stage_burst_tx_vector() local
208 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_single_stage_burst_fwd_vector() local
304 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_multi_stage_burst_tx() local
341 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_multi_stage_burst_fwd() local
447 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_atq_worker_multi_stage_burst_tx_vector() local
[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
103 pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx); in pipeline_queue_worker_single_stage_burst_tx()
113 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_single_stage_burst_fwd() local
133 pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx); in pipeline_queue_worker_single_stage_burst_fwd()
201 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_single_stage_burst_tx_vector() local
227 pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx); in pipeline_queue_worker_single_stage_burst_tx_vector()
237 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_single_stage_burst_fwd_vector() local
339 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_multi_stage_burst_tx() local
377 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_multi_stage_burst_fwd() local
490 uint16_t nb_rx = 0, nb_tx = 0; in pipeline_queue_worker_multi_stage_burst_tx_vector() local
[all …]
|
| /dpdk/drivers/net/failsafe/ |
| H A D | failsafe_rxtx.c | 147 uint16_t nb_tx; in failsafe_tx_burst() local
155 nb_tx = ETH(sdev)->tx_pkt_burst(sub_txq, tx_pkts, nb_pkts); in failsafe_tx_burst()
157 return nb_tx; in failsafe_tx_burst()
168 uint16_t nb_tx; in failsafe_tx_burst_fast() local
175 nb_tx = ETH(sdev)->tx_pkt_burst(sub_txq, tx_pkts, nb_pkts); in failsafe_tx_burst_fast()
177 return nb_tx; in failsafe_tx_burst_fast()
|
| /dpdk/examples/eventdev_pipeline/ |
| H A D | pipeline_worker_generic.c | 19 uint16_t nb_rx = 0, nb_tx = 0; in worker_generic() local
51 nb_tx = rte_event_enqueue_burst(dev_id, port_id, &ev, in worker_generic()
53 } while (!nb_tx && !fdata->done); in worker_generic()
57 worker_cleanup(dev_id, port_id, &ev, nb_tx, nb_rx); in worker_generic()
75 uint16_t i, nb_rx = 0, nb_tx = 0; in worker_generic_burst() local
109 while (nb_tx < nb_rx && !fdata->done) in worker_generic_burst()
110 nb_tx += rte_event_enqueue_burst(dev_id, port_id, in worker_generic_burst()
111 events + nb_tx, in worker_generic_burst()
112 nb_rx - nb_tx); in worker_generic_burst()
113 sent += nb_tx; in worker_generic_burst()
[all …]
|
| H A D | pipeline_worker_tx.c | 141 uint16_t nb_tx = 0, nb_rx = 0, i; in worker_do_tx_single_burst() local
168 fwd += nb_tx; in worker_do_tx_single_burst()
171 worker_cleanup(dev, port, ev, nb_tx, nb_rx); in worker_do_tx_single_burst()
188 uint16_t i, nb_rx = 0, nb_tx = 0; in worker_do_tx_single_burst_atq() local
213 fwd += nb_tx; in worker_do_tx_single_burst_atq()
216 worker_cleanup(dev, port, ev, nb_tx, nb_rx); in worker_do_tx_single_burst_atq()
341 uint16_t i, nb_rx = 0, nb_tx = 0; in worker_do_tx_burst() local
375 fwd += nb_tx; in worker_do_tx_burst()
378 worker_cleanup(dev, port, ev, nb_tx, nb_rx); in worker_do_tx_burst()
397 uint16_t i, nb_rx = 0, nb_tx = 0; in worker_do_tx_burst_atq() local
[all …]
|
| /dpdk/drivers/net/nfb/ |
| H A D | nfb_stats.c | 16 uint16_t nb_tx = dev->data->nb_tx_queues; in nfb_eth_stats_get() local
37 for (i = 0; i < nb_tx; i++) { in nfb_eth_stats_get()
60 uint16_t nb_tx = dev->data->nb_tx_queues; in nfb_eth_stats_reset() local
72 for (i = 0; i < nb_tx; i++) { in nfb_eth_stats_reset()
|
| /dpdk/examples/ntb/ |
| H A D | ntb_fwd.c | 219 uint16_t nb_tx, buf_size; in cmd_sendfile_parsed() local
302 nb_tx = ret; in cmd_sendfile_parsed()
306 &pkts_send[nb_tx], nb_pkt - nb_tx, in cmd_sendfile_parsed()
314 nb_tx += ret; in cmd_sendfile_parsed()
426 uint16_t nb_rx, nb_tx; in start_iofwd_per_lcore() local
454 nb_tx = ret; in start_iofwd_per_lcore()
476 if (unlikely(nb_tx < nb_rx)) { in start_iofwd_per_lcore()
479 } while (++nb_tx < nb_rx); in start_iofwd_per_lcore()
538 uint16_t nb_pkt, nb_tx; in start_txonly_per_lcore() local
584 nb_tx = ret; in start_txonly_per_lcore()
[all …]
|