Home
last modified time | relevance | path

Searched refs:rte_event_dequeue_burst (Results 1 – 25 of 34) sorted by relevance

12

/dpdk/app/test-eventdev/
H A Dtest_pipeline_atq.c27 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_single_stage_tx()
50 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_single_stage_fwd()
74 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in pipeline_atq_worker_single_stage_burst_tx()
102 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in pipeline_atq_worker_single_stage_burst_fwd()
132 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_single_stage_tx_vector()
156 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_single_stage_fwd_vector()
183 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in pipeline_atq_worker_single_stage_burst_tx_vector()
243 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_multi_stage_tx()
275 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_multi_stage_fwd()
382 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_multi_stage_tx_vector()
[all …]
H A Dtest_pipeline_queue.c27 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_single_stage_tx()
57 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_single_stage_fwd()
82 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in pipeline_queue_worker_single_stage_burst_tx()
116 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in pipeline_queue_worker_single_stage_burst_fwd()
146 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_single_stage_tx_vector()
178 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_single_stage_fwd_vector()
205 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in pipeline_queue_worker_single_stage_burst_tx_vector()
273 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_multi_stage_tx()
308 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_multi_stage_fwd()
422 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_multi_stage_tx_vector()
[all …]
H A Dtest_order_atq.c28 uint16_t event = rte_event_dequeue_burst(dev_id, port, in order_atq_worker()
63 uint16_t const nb_rx = rte_event_dequeue_burst(dev_id, port, ev, in order_atq_worker_burst()
H A Dtest_order_queue.c28 uint16_t event = rte_event_dequeue_burst(dev_id, port, in order_queue_worker()
63 uint16_t const nb_rx = rte_event_dequeue_burst(dev_id, port, ev, in order_queue_worker_burst()
H A Dtest_perf_atq.c45 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in perf_atq_worker()
104 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in perf_atq_worker_burst()
H A Dtest_perf_queue.c47 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in perf_queue_worker()
106 nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0); in perf_queue_worker_burst()
/dpdk/drivers/event/opdl/
H A Dopdl_test.c277 deq_pkts = rte_event_dequeue_burst(evdev, t->port[i], in ordered_basic()
306 deq_pkts = rte_event_dequeue_burst(evdev, t->port[tx_port], deq_ev, in ordered_basic()
416 deq_pkts = rte_event_dequeue_burst(evdev, t->port[i], in atomic_basic()
457 deq_pkts = rte_event_dequeue_burst(evdev, t->port[tx_port], deq_ev, in atomic_basic()
644 deq_pkts = rte_event_dequeue_burst(evdev, in single_link_w_stats()
670 deq_pkts = rte_event_dequeue_burst(evdev, in single_link_w_stats()
837 test_num_events = rte_event_dequeue_burst(evdev, in qid_basic()
916 num_events = rte_event_dequeue_burst(evdev, in qid_basic()
963 num_events = rte_event_dequeue_burst(evdev, in qid_basic()
/dpdk/app/test/
H A Dtest_event_timer_adapter.c472 TEST_ASSERT_EQUAL(rte_event_dequeue_burst(evdev, 0, &ev, 1, 0), 1, in test_timer_state()
540 valid_event = rte_event_dequeue_burst(evdev, 0, &ev, 1, 0); in _wait_timer_triggers()
1221 sum += rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, in stat_inc_reset_ev_enq()
1237 n = rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, RTE_DIM(evs), in stat_inc_reset_ev_enq()
1312 n = rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, RTE_DIM(evs), 0); in event_timer_arm()
1362 n = rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, RTE_DIM(evs), 0); in event_timer_arm_double()
1409 n = rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, RTE_DIM(evs), 0); in event_timer_arm_expiry()
1417 n = rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, RTE_DIM(evs), 0); in event_timer_arm_expiry()
1469 n = rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, RTE_DIM(evs), 0); in event_timer_arm_rearm()
1546 sum += rte_event_dequeue_burst(evdev, TEST_PORT_ID, evs, in event_timer_arm_max()
[all …]
H A Dtest_event_crypto_adapter.c132 while (rte_event_dequeue_burst(evdev, in send_recv_ev()
361 while (rte_event_dequeue_burst(evdev, in send_op_recv_ev()
/dpdk/drivers/event/dlb2/
H A Ddlb2_selftest.c903 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_load_balanced_traffic()
918 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_load_balanced_traffic()
1030 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_directed_traffic()
1051 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_directed_traffic()
1192 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_deferred_sched()
1203 if (rte_event_dequeue_burst(evdev, 1, &ev, 1, timeout) != 1) { in test_deferred_sched()
1330 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_delayed_pop()
1349 ret = rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout); in test_delayed_pop()
1370 if (rte_event_dequeue_burst(evdev, 0, &ev, 1, timeout) != 1) { in test_delayed_pop()
/dpdk/examples/eventdev_pipeline/
H A Dpipeline_worker_tx.c62 if (!rte_event_dequeue_burst(dev, port, &ev, 1, 0)) { in worker_do_tx_single()
103 if (!rte_event_dequeue_burst(dev, port, &ev, 1, 0)) { in worker_do_tx_single_atq()
144 nb_rx = rte_event_dequeue_burst(dev, port, ev, BATCH_SIZE, 0); in worker_do_tx_single_burst()
191 nb_rx = rte_event_dequeue_burst(dev, port, ev, BATCH_SIZE, 0); in worker_do_tx_single_burst_atq()
240 if (!rte_event_dequeue_burst(dev, port, &ev, 1, 0)) { in worker_do_tx()
293 if (!rte_event_dequeue_burst(dev, port, &ev, 1, 0)) { in worker_do_tx_atq()
344 nb_rx = rte_event_dequeue_burst(dev, port, ev, BATCH_SIZE, 0); in worker_do_tx_burst()
400 nb_rx = rte_event_dequeue_burst(dev, port, ev, BATCH_SIZE, 0); in worker_do_tx_burst_atq()
H A Dpipeline_worker_generic.c31 nb_rx = rte_event_dequeue_burst(dev_id, port_id, &ev, 1, 0); in worker_generic()
86 nb_rx = rte_event_dequeue_burst(dev_id, port_id, events, in worker_generic_burst()
/dpdk/drivers/event/octeontx/
H A Dssovf_evdev_selftest.c320 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in check_excess_events()
400 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in consume_events()
563 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_multi_port_fn()
894 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, in worker_flow_based_pipeline()
1049 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, in worker_group_based_pipeline()
1207 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_flow_based_pipeline_max_stages_rand_sched_type()
1282 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_queue_based_pipeline_max_stages_rand_sched_type()
1324 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_mixed_pipeline_max_stages_rand_sched_type()
/dpdk/drivers/event/sw/
H A Dsw_evdev_selftest.c511 deq_pkts = rte_event_dequeue_burst(evdev, wrk_enq, &ev, 1, 0); in test_single_directed_packet()
565 deq_pkts = rte_event_dequeue_burst(evdev, 0, &ev, 1, 0); in test_directed_forward_credits()
748 p = rte_event_dequeue_burst(evdev, t->port[0], &ev, 1, 0); in burst_packets()
763 p = rte_event_dequeue_burst(evdev, t->port[1], &ev, 1, 0); in burst_packets()
1279 int deq = rte_event_dequeue_burst(evdev, t->port[0], ev, in port_reconfig_credits()
1897 rte_event_dequeue_burst(evdev, t->port[0], ev, 32, 0); in qid_priorities()
2148 if (!rte_event_dequeue_burst(evdev, t->port[1], &ev, 1, 0)) { in load_balancing_history()
2235 while (rte_event_dequeue_burst(evdev, i, &ev, 1, 0)) in load_balancing_history()
2585 deq_pkts = rte_event_dequeue_burst(evdev, t->port[p2], events, in inflight_counts()
2712 deq_pkts = rte_event_dequeue_burst(evdev, t->port[i], in parallel_basic()
[all …]
/dpdk/drivers/event/cnxk/
H A Dcnxk_eventdev_selftest.c302 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in check_excess_events()
381 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in consume_events()
549 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_multi_port_fn()
899 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, in worker_flow_based_pipeline()
1055 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, in worker_group_based_pipeline()
1213 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_flow_based_pipeline_max_stages_rand_sched_type()
1289 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_queue_based_pipeline_max_stages_rand_sched_type()
1334 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_mixed_pipeline_max_stages_rand_sched_type()
/dpdk/drivers/net/octeontx/
H A Docteontx_rxtx.c33 valid_event = rte_event_dequeue_burst(rxq->evdev, in octeontx_recv_pkts()
/dpdk/examples/l2fwd-event/
H A Dl2fwd_event.c207 deq = rte_event_dequeue_burst(event_d_id, port_id, &ev, 1, 0); in l2fwd_event_loop_single()
254 nb_rx = rte_event_dequeue_burst(event_d_id, port_id, ev, in l2fwd_event_loop_burst()
437 nb_rx = rte_event_dequeue_burst(event_d_id, port_id, ev, in l2fwd_event_loop_vector()
/dpdk/drivers/event/dpaa2/
H A Ddpaa2_eventdev_selftest.c275 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in check_excess_events()
355 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in consume_events()
451 valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); in worker_multi_port_fn()
/dpdk/examples/l3fwd/
H A Dl3fwd_lpm.c277 deq = rte_event_dequeue_burst(event_d_id, event_p_id, &ev, 1, in lpm_event_loop_single()
333 nb_deq = rte_event_dequeue_burst(event_d_id, event_p_id, in lpm_event_loop_burst()
473 nb_deq = rte_event_dequeue_burst(event_d_id, event_p_id, events, in lpm_event_loop_vector()
H A Dl3fwd_em.c669 deq = rte_event_dequeue_burst(event_d_id, event_p_id, &ev, 1, in em_event_loop_single()
733 nb_deq = rte_event_dequeue_burst(event_d_id, event_p_id, in em_event_loop_burst()
858 nb_deq = rte_event_dequeue_burst(event_d_id, event_p_id, events, in em_event_loop_vector()
H A Dl3fwd_fib.c278 nb_deq = rte_event_dequeue_burst(event_d_id, event_p_id, in fib_event_loop()
507 nb_deq = rte_event_dequeue_burst(event_d_id, event_p_id, events, in fib_event_loop_vector()
/dpdk/lib/eventdev/
H A Drte_eventdev.h2152 rte_event_dequeue_burst(uint8_t dev_id, uint8_t port_id, struct rte_event ev[], in rte_event_dequeue_burst() function
/dpdk/examples/ipsec-secgw/
H A Dipsec_worker.c803 nb_rx = rte_event_dequeue_burst(links[0].eventdev_id, in ipsec_wrkr_non_burst_int_port_drv_mode()
936 nb_rx = rte_event_dequeue_burst(links[0].eventdev_id, in ipsec_wrkr_non_burst_int_port_app_mode()
/dpdk/doc/guides/eventdevs/
H A Dsw.rst151 ``rte_event_dequeue_burst`` function.
/dpdk/lib/port/
H A Drte_port_eventdev.c73 rx_evts_cnt = rte_event_dequeue_burst(p->eventdev_id, p->port_id, in rte_port_eventdev_reader_rx()

12