| /dpdk/examples/l3fwd/ |
| H A D | l3fwd_fib.c | 255 int i, nb_enq = 0, nb_deq = 0; in fib_event_loop() local
357 while (nb_enq < nb_deq && !force_quit) in fib_event_loop()
359 event_p_id, events + nb_enq, in fib_event_loop()
360 nb_deq - nb_enq); in fib_event_loop()
366 while (nb_enq < nb_deq && !force_quit) in fib_event_loop()
369 events + nb_enq, in fib_event_loop()
370 nb_deq - nb_enq, 0); in fib_event_loop()
497 int nb_enq = 0, nb_deq = 0, i; in fib_event_loop_vector() local
530 nb_enq += rte_event_enqueue_burst( in fib_event_loop_vector()
532 nb_deq - nb_enq); in fib_event_loop_vector()
[all …]
|
| H A D | l3fwd_lpm.c | 318 int i, nb_enq = 0, nb_deq = 0; in lpm_event_loop_burst() local
356 while (nb_enq < nb_deq && !force_quit) in lpm_event_loop_burst()
358 event_p_id, events + nb_enq, in lpm_event_loop_burst()
359 nb_deq - nb_enq); in lpm_event_loop_burst()
365 while (nb_enq < nb_deq && !force_quit) in lpm_event_loop_burst()
368 events + nb_enq, in lpm_event_loop_burst()
369 nb_deq - nb_enq, 0); in lpm_event_loop_burst()
459 int i, nb_enq = 0, nb_deq = 0; in lpm_event_loop_vector() local
496 nb_enq += rte_event_enqueue_burst( in lpm_event_loop_vector()
498 nb_deq - nb_enq); in lpm_event_loop_vector()
[all …]
|
| H A D | l3fwd_em.c | 718 int i, nb_enq = 0, nb_deq = 0; in em_event_loop_burst() local
762 while (nb_enq < nb_deq && !force_quit) in em_event_loop_burst()
764 event_p_id, events + nb_enq, in em_event_loop_burst()
765 nb_deq - nb_enq); in em_event_loop_burst()
771 while (nb_enq < nb_deq && !force_quit) in em_event_loop_burst()
774 events + nb_enq, in em_event_loop_burst()
775 nb_deq - nb_enq, 0); in em_event_loop_burst()
844 int i, nb_enq = 0, nb_deq = 0; in em_event_loop_vector() local
885 nb_enq += rte_event_enqueue_burst( in em_event_loop_vector()
887 nb_deq - nb_enq); in em_event_loop_vector()
[all …]
|
| H A D | l3fwd_event.c | 316 struct rte_event events[], uint16_t nb_enq, in l3fwd_event_worker_cleanup() argument
323 l3fwd_event_vector_array_free(events + nb_enq, in l3fwd_event_worker_cleanup()
324 nb_deq - nb_enq); in l3fwd_event_worker_cleanup()
326 for (i = nb_enq; i < nb_deq; i++) in l3fwd_event_worker_cleanup()
|
| H A D | l3fwd_event.h | 114 struct rte_event events[], uint16_t nb_enq,
|
| /dpdk/lib/port/ |
| H A D | rte_port_eventdev.c | 194 uint32_t nb_enq; in send_burst() local
200 nb_enq); in send_burst()
202 for (; nb_enq < p->enq_buf_count; nb_enq++) in send_burst()
203 rte_pktmbuf_free(p->ev[nb_enq].mbuf); in send_burst()
407 uint32_t nb_enq, i; in send_burst_nodrop() local
413 if (nb_enq >= p->enq_buf_count) { in send_burst_nodrop()
420 p->ev + nb_enq, in send_burst_nodrop()
421 p->enq_buf_count - nb_enq); in send_burst_nodrop()
424 if (nb_enq >= p->enq_buf_count) { in send_burst_nodrop()
431 p->enq_buf_count - nb_enq); in send_burst_nodrop()
[all …]
|
| /dpdk/examples/bbdev_app/ |
| H A D | main.c | 780 if (unlikely(nb_enq < nb_rx)) { in run_encoding()
782 nb_rx - nb_enq); in run_encoding()
784 nb_rx - nb_enq); in run_encoding()
787 if (!nb_enq) in run_encoding()
791 lcore_stats->enqueued += nb_enq; in run_encoding()
798 } while (unlikely(nb_deq < nb_enq)); in run_encoding()
876 if (unlikely(nb_enq < nb_recv)) { in run_decoding()
878 nb_recv - nb_enq); in run_decoding()
880 nb_recv - nb_enq); in run_decoding()
883 if (!nb_enq) in run_decoding()
[all …]
|
| /dpdk/examples/l2fwd-event/ |
| H A D | l2fwd_common.c | 143 struct rte_event events[], uint16_t nb_enq, in l2fwd_event_worker_cleanup() argument
150 l2fwd_event_vector_array_free(events + nb_enq, in l2fwd_event_worker_cleanup()
151 nb_deq - nb_enq); in l2fwd_event_worker_cleanup()
153 for (i = nb_enq; i < nb_deq; i++) in l2fwd_event_worker_cleanup()
|
| H A D | l2fwd_common.h | 144 struct rte_event events[], uint16_t nb_enq,
|
| /dpdk/examples/eventdev_pipeline/ |
| H A D | pipeline_common.h | 152 uint16_t nb_enq, uint16_t nb_deq) in worker_cleanup() argument
156 if (!(nb_deq - nb_enq)) in worker_cleanup()
160 for (i = nb_enq; i < nb_deq; i++) { in worker_cleanup()
|
| /dpdk/examples/dma/ |
| H A D | dmafwd.c | 392 uint32_t nb_rx, nb_enq, i, j; in dma_rx_port() local
419 nb_enq = dma_enqueue(pkts_burst, pkts_burst_copy, in dma_rx_port()
424 (void *)&pkts_burst[nb_enq], in dma_rx_port()
425 nb_rx - nb_enq); in dma_rx_port()
427 (void *)&pkts_burst_copy[nb_enq], in dma_rx_port()
428 nb_rx - nb_enq); in dma_rx_port()
431 (nb_rx - nb_enq); in dma_rx_port()
446 nb_enq = rte_ring_enqueue_burst(rx_config->rx_to_tx_ring, in dma_rx_port()
451 (void *)&pkts_burst_copy[nb_enq], in dma_rx_port()
452 nb_rx - nb_enq); in dma_rx_port()
[all …]
|
| /dpdk/lib/eventdev/ |
| H A D | rte_event_crypto_adapter.c | 582 unsigned int nb_enq, nb_enqueued; in eca_crypto_adapter_enq_run() local
598 for (nb_enq = 0; nb_enq < max_enq; nb_enq += n) { in eca_crypto_adapter_enq_run()
|
| /dpdk/app/test-eventdev/ |
| H A D | test_perf_common.h | 189 uint16_t nb_enq, uint16_t nb_deq);
|
| H A D | test_perf_common.c | 997 uint8_t port_id, struct rte_event events[], uint16_t nb_enq, in perf_worker_cleanup() argument
1003 for (i = nb_enq; i < nb_deq; i++) in perf_worker_cleanup()
|