Home
last modified time | relevance | path

Searched refs:ev (Results 1 – 25 of 66) sorted by relevance

123

/dpdk/app/test-eventdev/
H A Dtest_pipeline_queue.c27 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_queue_worker_single_stage_tx()
34 if (ev.sched_type == RTE_SCHED_TYPE_ATOMIC) { in pipeline_queue_worker_single_stage_tx()
35 enq = pipeline_event_tx(dev, port, &ev, t); in pipeline_queue_worker_single_stage_tx()
36 ev.op = RTE_EVENT_OP_RELEASE; in pipeline_queue_worker_single_stage_tx()
39 ev.queue_id++; in pipeline_queue_worker_single_stage_tx()
40 pipeline_fwd_event(&ev, RTE_SCHED_TYPE_ATOMIC); in pipeline_queue_worker_single_stage_tx()
41 enq = pipeline_event_enqueue(dev, port, &ev, t); in pipeline_queue_worker_single_stage_tx()
44 pipeline_worker_cleanup(dev, port, &ev, enq, deq); 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()
64 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_single_stage_fwd()
[all …]
H A Dtest_pipeline_atq.c27 deq = rte_event_dequeue_burst(dev, port, &ev, 1, 0); in pipeline_atq_worker_single_stage_tx()
34 deq = pipeline_event_tx(dev, port, &ev, t); in pipeline_atq_worker_single_stage_tx()
37 pipeline_worker_cleanup(dev, port, &ev, enq, deq); 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()
57 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_atq_worker_single_stage_fwd()
58 pipeline_fwd_event(&ev, RTE_SCHED_TYPE_ATOMIC); in pipeline_atq_worker_single_stage_fwd()
59 enq = pipeline_event_enqueue(dev, port, &ev, t); in pipeline_atq_worker_single_stage_fwd()
62 pipeline_worker_cleanup(dev, port, &ev, enq, deq); 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()
82 rte_prefetch0(ev[i + 1].mbuf); in pipeline_atq_worker_single_stage_burst_tx()
[all …]
H A Dtest_order_atq.c13 order_atq_process_stage_0(struct rte_event *const ev) in order_atq_process_stage_0() argument
15 ev->sub_event_type = 1; /* move to stage 1 (atomic) on the same queue */ in order_atq_process_stage_0()
16 ev->op = RTE_EVENT_OP_FORWARD; in order_atq_process_stage_0()
17 ev->sched_type = RTE_SCHED_TYPE_ATOMIC; in order_atq_process_stage_0()
18 ev->event_type = RTE_EVENT_TYPE_CPU; in order_atq_process_stage_0()
25 struct rte_event ev; in order_atq_worker() local
29 &ev, 1, 0); in order_atq_worker()
38 order_flow_id_copy_from_mbuf(t, &ev); in order_atq_worker()
40 if (ev.sub_event_type == 0) { /* stage 0 from producer */ in order_atq_worker()
41 order_atq_process_stage_0(&ev); in order_atq_worker()
[all …]
H A Dtest_order_queue.c13 order_queue_process_stage_0(struct rte_event *const ev) in order_queue_process_stage_0() argument
15 ev->queue_id = 1; /* q1 atomic queue */ in order_queue_process_stage_0()
16 ev->op = RTE_EVENT_OP_FORWARD; in order_queue_process_stage_0()
17 ev->sched_type = RTE_SCHED_TYPE_ATOMIC; in order_queue_process_stage_0()
18 ev->event_type = RTE_EVENT_TYPE_CPU; in order_queue_process_stage_0()
25 struct rte_event ev; in order_queue_worker() local
29 &ev, 1, 0); in order_queue_worker()
38 order_flow_id_copy_from_mbuf(t, &ev); in order_queue_worker()
40 if (ev.queue_id == 0) { /* from ordered queue */ in order_queue_worker()
41 order_queue_process_stage_0(&ev); in order_queue_worker()
[all …]
H A Dtest_pipeline_common.h65 alignas(RTE_CACHE_LINE_SIZE) struct rte_event ev
73 alignas(RTE_CACHE_LINE_SIZE) struct rte_event ev[BURST_SIZE + 1]
84 alignas(RTE_CACHE_LINE_SIZE) struct rte_event ev
96 alignas(RTE_CACHE_LINE_SIZE) struct rte_event ev[BURST_SIZE + 1]
99 pipeline_fwd_event(struct rte_event *ev, uint8_t sched) in pipeline_fwd_event() argument
101 ev->event_type = RTE_EVENT_TYPE_CPU; in pipeline_fwd_event()
102 ev->op = RTE_EVENT_OP_FORWARD; in pipeline_fwd_event()
103 ev->sched_type = sched; in pipeline_fwd_event()
107 pipeline_fwd_event_vector(struct rte_event *ev, uint8_t sched) in pipeline_fwd_event_vector() argument
109 ev->event_type = RTE_EVENT_TYPE_CPU_VECTOR; in pipeline_fwd_event_vector()
[all …]
H A Dtest_order_common.h96 struct rte_event *const ev, const uint32_t nb_flows, in order_process_stage_1() argument
100 const uint32_t flow = (uintptr_t)ev->mbuf % nb_flows; in order_process_stage_1()
102 if (*order_mbuf_seqn(t, ev->mbuf) != expected_flow_seq[flow]) { in order_process_stage_1()
104 flow, *order_mbuf_seqn(t, ev->mbuf), in order_process_stage_1()
115 rte_pktmbuf_free(ev->mbuf); in order_process_stage_1()
121 struct rte_event *const ev) in order_process_stage_invalid() argument
123 evt_err("invalid queue %d", ev->queue_id); in order_process_stage_invalid()
/dpdk/drivers/event/dlb2/
H A Ddlb2_sse.c34 const struct rte_event ev[], in dlb2_event_build_hcws() argument
69 cmd_byte_map[qm_port->is_directed][ev[0].op], in dlb2_event_build_hcws()
72 cmd_byte_map[qm_port->is_directed][ev[1].op], in dlb2_event_build_hcws()
75 cmd_byte_map[qm_port->is_directed][ev[2].op], in dlb2_event_build_hcws()
78 cmd_byte_map[qm_port->is_directed][ev[3].op], in dlb2_event_build_hcws()
85 sched_word[0] = EV_TO_DLB2_PRIO(ev[0].priority) << 10 | in dlb2_event_build_hcws()
88 sched_word[1] = EV_TO_DLB2_PRIO(ev[1].priority) << 10 | in dlb2_event_build_hcws()
91 sched_word[2] = EV_TO_DLB2_PRIO(ev[2].priority) << 10 | in dlb2_event_build_hcws()
94 sched_word[3] = EV_TO_DLB2_PRIO(ev[3].priority) << 10 | in dlb2_event_build_hcws()
130 sched_word[0] : ev[0].flow_id, in dlb2_event_build_hcws()
[all …]
H A Ddlb2_selftest.c153 enqueue_timeout(uint8_t port_id, struct rte_event *ev, uint64_t tmo_us) in enqueue_timeout() argument
159 if (rte_event_enqueue_burst(evdev, port_id, ev, 1) == 1) in enqueue_timeout()
181 struct rte_event ev; in test_stop_flush() local
186 ev.op = RTE_EVENT_OP_NEW; in test_stop_flush()
232 ev.mbuf = rte_pktmbuf_alloc(t->mbuf_pool); in test_stop_flush()
233 ev.queue_id = 0; in test_stop_flush()
234 ev.sched_type = RTE_SCHED_TYPE_ATOMIC; in test_stop_flush()
236 if (enqueue_timeout(0, &ev, 1000)) { in test_stop_flush()
244 ev.mbuf = rte_pktmbuf_alloc(t->mbuf_pool); in test_stop_flush()
245 ev.queue_id = 1; in test_stop_flush()
[all …]
/dpdk/examples/eventdev_pipeline/
H A Dpipeline_worker_tx.c12 worker_fwd_event(struct rte_event *ev, uint8_t sched) in worker_fwd_event() argument
14 ev->event_type = RTE_EVENT_TYPE_CPU; in worker_fwd_event()
15 ev->op = RTE_EVENT_OP_FORWARD; in worker_fwd_event()
16 ev->sched_type = sched; in worker_fwd_event()
21 struct rte_event *ev) in worker_event_enqueue() argument
23 while (!rte_event_enqueue_burst(dev, port, ev, 1) && !fdata->done) in worker_event_enqueue()
29 struct rte_event *ev, const uint16_t nb_rx) in worker_event_enqueue_burst() argument
33 enq = rte_event_enqueue_burst(dev, port, ev, nb_rx); in worker_event_enqueue_burst()
36 ev + enq, nb_rx - enq); in worker_event_enqueue_burst()
42 worker_tx_pkt(const uint8_t dev, const uint8_t port, struct rte_event *ev) in worker_tx_pkt() argument
60 struct rte_event ev; worker_do_tx_single() local
101 struct rte_event ev; worker_do_tx_single_atq() local
137 struct rte_event ev[BATCH_SIZE + 1]; worker_do_tx_single_burst() local
184 struct rte_event ev[BATCH_SIZE + 1]; worker_do_tx_single_burst_atq() local
231 struct rte_event ev; worker_do_tx() local
285 struct rte_event ev; worker_do_tx_atq() local
336 struct rte_event ev[BATCH_SIZE]; worker_do_tx_burst() local
392 struct rte_event ev[BATCH_SIZE]; worker_do_tx_burst_atq() local
[all...]
/dpdk/drivers/event/octeontx/
H A Dssovf_evdev_selftest.c265 update_event_and_validation_attr(struct rte_mbuf *m, struct rte_event *ev, in update_event_and_validation_attr() argument
281 ev->flow_id = flow_id; in update_event_and_validation_attr()
282 ev->sub_event_type = sub_event_type; in update_event_and_validation_attr()
283 ev->event_type = event_type; in update_event_and_validation_attr()
285 ev->op = RTE_EVENT_OP_NEW; in update_event_and_validation_attr()
286 ev->sched_type = sched_type; in update_event_and_validation_attr()
287 ev->queue_id = queue; in update_event_and_validation_attr()
288 ev->mbuf = m; in update_event_and_validation_attr()
300 struct rte_event ev = {.event = 0, .u64 = 0}; in inject_events() local
306 update_event_and_validation_attr(m, &ev, flow_id, event_type, in inject_events()
[all …]
/dpdk/app/test/
H A Dtest_event_timer_adapter.c470 struct rte_event ev; in test_timer_state() local
472 .ev.op = RTE_EVENT_OP_NEW, in test_timer_state()
473 .ev.queue_id = 0, in test_timer_state()
474 .ev.sched_type = RTE_SCHED_TYPE_ATOMIC, in test_timer_state()
475 .ev.priority = RTE_EVENT_DEV_PRIORITY_NORMAL, in test_timer_state()
476 .ev.event_type = RTE_EVENT_TYPE_TIMER, in test_timer_state()
482 ev_tim->ev.event_ptr = ev_tim; in test_timer_state()
506 TEST_ASSERT_EQUAL(timeout_event_dequeue(&ev, 1, WAIT_TICKS(wait_ticks)), 1, in test_timer_state()
530 .ev.op = RTE_EVENT_OP_NEW, in _arm_timers()
531 .ev.queue_id = 0, in _arm_timers()
[all …]
H A Dtest_event_eth_rx_adapter.c556 struct rte_event ev; in adapter_queue_event_buf_test() local
565 ev.queue_id = 0; in adapter_queue_event_buf_test()
566 ev.sched_type = RTE_SCHED_TYPE_ATOMIC; in adapter_queue_event_buf_test()
567 ev.priority = 0; in adapter_queue_event_buf_test()
571 ev.flow_id = 1; in adapter_queue_event_buf_test()
575 queue_config.ev = ev; in adapter_queue_event_buf_test()
603 struct rte_event ev; in adapter_queue_stats_test() local
621 ev.queue_id = 0; in adapter_queue_stats_test()
622 ev.sched_type = RTE_SCHED_TYPE_ATOMIC; in adapter_queue_stats_test()
623 ev.priority = 0; in adapter_queue_stats_test()
[all …]
/dpdk/drivers/event/dpaa2/
H A Ddpaa2_eventdev_selftest.c218 update_event_and_validation_attr(struct rte_mbuf *m, struct rte_event *ev, in update_event_and_validation_attr() argument
235 ev->flow_id = flow_id; in update_event_and_validation_attr()
236 ev->sub_event_type = sub_event_type; in update_event_and_validation_attr()
237 ev->event_type = event_type; in update_event_and_validation_attr()
239 ev->op = RTE_EVENT_OP_NEW; in update_event_and_validation_attr()
240 ev->sched_type = sched_type; in update_event_and_validation_attr()
241 ev->queue_id = queue; in update_event_and_validation_attr()
242 ev->mbuf = m; in update_event_and_validation_attr()
254 struct rte_event ev = {.event = 0, .u64 = 0}; in inject_events() local
259 update_event_and_validation_attr(m, &ev, flow_id, event_type, in inject_events()
[all …]
/dpdk/drivers/event/sw/
H A Dsw_evdev_selftest.c383 struct rte_event ev; in run_prio_packet_test() local
391 ev = (struct rte_event){ in run_prio_packet_test()
397 err = rte_event_enqueue_burst(evdev, t->port[0], &ev, 1); in run_prio_packet_test()
420 struct rte_event ev, ev2; in run_prio_packet_test() local
422 deq_pkts = rte_event_dequeue_burst(evdev, t->port[0], &ev, 1, 0); in run_prio_packet_test()
428 if (*rte_event_pmd_selftest_seqn(ev.mbuf) != MAGIC_SEQN[1]) { in run_prio_packet_test()
434 rte_pktmbuf_free(ev.mbuf); in run_prio_packet_test()
474 struct rte_event ev = { in test_single_directed_packet() local
489 err = rte_event_enqueue_burst(evdev, rx_enq, &ev, 1); in test_single_directed_packet()
512 deq_pkts = rte_event_dequeue_burst(evdev, wrk_enq, &ev, 1, 0); in test_single_directed_packet()
[all …]
H A Diq_chunk.h67 iq_enqueue(struct sw_evdev *sw, struct sw_iq *iq, const struct rte_event *ev) in iq_enqueue() argument
69 iq->tail->events[iq->tail_idx++] = *ev; in iq_enqueue()
108 struct rte_event *ev, in iq_dequeue_burst() argument
124 ev[total++] = current->events[index++]; in iq_dequeue_burst()
156 struct rte_event *ev, in iq_put_back() argument
171 iq->head->events[idx + i] = ev[i]; in iq_put_back()
180 iq->head->events[i] = ev[remaining + i]; in iq_put_back()
188 iq->head->events[iq->head_idx + i] = ev[i]; in iq_put_back()
/dpdk/lib/eventdev/
H A Drte_eventdev_core.h16 const struct rte_event ev[],
20 typedef uint16_t (*event_dequeue_burst_t)(void *port, struct rte_event ev[],
29 struct rte_event ev[],
34 struct rte_event ev[],
38 typedef uint16_t (*event_dma_adapter_enqueue_t)(void *port, struct rte_event ev[],
H A Deventdev_private.c10 __rte_unused const struct rte_event ev[], in dummy_event_enqueue() argument
20 __rte_unused struct rte_event ev[], in dummy_event_enqueue_burst()
38 __rte_unused struct rte_event ev[], in dummy_event_dequeue_burst() argument
48 __rte_unused struct rte_event ev[], in dummy_event_maintain()
58 __rte_unused struct rte_event ev[], in dummy_event_tx_adapter_enqueue()
67 dummy_event_dma_adapter_enqueue(__rte_unused void *port, __rte_unused struct rte_event ev[], in dummy_event_tx_adapter_enqueue_same_dest()
19 dummy_event_enqueue_burst(__rte_unused void * port,__rte_unused const struct rte_event ev[],__rte_unused uint16_t nb_events) dummy_event_enqueue_burst() argument
28 dummy_event_dequeue(__rte_unused void * port,__rte_unused struct rte_event * ev,__rte_unused uint64_t timeout_ticks) dummy_event_dequeue() argument
56 dummy_event_tx_adapter_enqueue(__rte_unused void * port,__rte_unused struct rte_event ev[],__rte_unused uint16_t nb_events) dummy_event_tx_adapter_enqueue() argument
66 dummy_event_tx_adapter_enqueue_same_dest(__rte_unused void * port,__rte_unused struct rte_event ev[],__rte_unused uint16_t nb_events) dummy_event_tx_adapter_enqueue_same_dest() argument
76 dummy_event_crypto_adapter_enqueue(__rte_unused void * port,__rte_unused struct rte_event ev[],__rte_unused uint16_t nb_events) dummy_event_crypto_adapter_enqueue() argument
85 dummy_event_dma_adapter_enqueue(__rte_unused void * port,__rte_unused struct rte_event ev[],__rte_unused uint16_t nb_events) dummy_event_dma_adapter_enqueue() argument
H A Drte_eventdev.h56 * |done ev| | event queue 0 | | +--------+ +------+
1593 * if (ev.event_type & RTE_EVENT_TYPE_VECTOR) {
1809 * to the adapter using the ev.flow_id member.
1810 * @see struct rte_event_eth_rx_adapter_queue_conf::ev
2578 const struct rte_event ev[], uint16_t nb_events,
2598 rte_eventdev_trace_enq_burst(dev_id, port_id, ev, nb_events, (void *)fn);
2600 return fn(port, ev, nb_events);
2610 * supplied in the *ev* array of *rte_event* structure.
2623 * @param ev
2636 * events at the end of ev[] ar
2474 __rte_event_enqueue_burst(uint8_t dev_id,uint8_t port_id,const struct rte_event ev[],uint16_t nb_events,const event_enqueue_burst_t fn) __rte_event_enqueue_burst() argument
2550 rte_event_enqueue_burst(uint8_t dev_id,uint8_t port_id,const struct rte_event ev[],uint16_t nb_events) rte_event_enqueue_burst() argument
2602 rte_event_enqueue_new_burst(uint8_t dev_id,uint8_t port_id,const struct rte_event ev[],uint16_t nb_events) rte_event_enqueue_new_burst() argument
2654 rte_event_enqueue_forward_burst(uint8_t dev_id,uint8_t port_id,const struct rte_event ev[],uint16_t nb_events) rte_event_enqueue_forward_burst() argument
2730 rte_event_dequeue_burst(uint8_t dev_id,uint8_t port_id,struct rte_event ev[],uint16_t nb_events,uint64_t timeout_ticks) rte_event_dequeue_burst() argument
[all...]
/dpdk/drivers/event/cnxk/tx/cn9k/
H A Dtx_all_offload.c10 cn9k_sso_hws_tx_adptr_enq_seg_all_offload(void *port, struct rte_event ev[], uint16_t nb_events) in cn9k_sso_hws_tx_adptr_enq_seg_all_offload() argument
20 return cn9k_sso_hws_event_tx(ws->base, &ev[0], cmd, (uint64_t *)ws->tx_adptr_data, flags); in cn9k_sso_hws_tx_adptr_enq_seg_all_offload()
24 cn9k_sso_hws_tx_adptr_enq_dual_seg_all_offload(void *port, struct rte_event ev[], in cn9k_sso_hws_tx_adptr_enq_dual_seg_all_offload() argument
35 return cn9k_sso_hws_event_tx(ws->base[!ws->vws], &ev[0], cmd, (uint64_t *)ws->tx_adptr_data, in cn9k_sso_hws_tx_adptr_enq_dual_seg_all_offload()
40 cn9k_sso_hws_tx_adptr_enq_seg_all_offload_tst(void *port, struct rte_event ev[], uint16_t nb_events) in cn9k_sso_hws_tx_adptr_enq_seg_all_offload_tst() argument
50 return cn9k_sso_hws_event_tx(ws->base, &ev[0], cmd, (uint64_t *)ws->tx_adptr_data, flags); in cn9k_sso_hws_tx_adptr_enq_seg_all_offload_tst()
54 cn9k_sso_hws_tx_adptr_enq_dual_seg_all_offload_tst(void *port, struct rte_event ev[], in cn9k_sso_hws_tx_adptr_enq_dual_seg_all_offload_tst() argument
65 return cn9k_sso_hws_event_tx(ws->base[!ws->vws], &ev[0], cmd, (uint64_t *)ws->tx_adptr_data, in cn9k_sso_hws_tx_adptr_enq_dual_seg_all_offload_tst()
/dpdk/lib/port/
H A Drte_port_eventdev.c38 struct rte_event ev[RTE_PORT_IN_BURST_SIZE_MAX]; member
76 p->ev, n_pkts, 0); in rte_port_eventdev_reader_rx()
79 pkts[i] = p->ev[i].mbuf; in rte_port_eventdev_reader_rx()
134 struct rte_event ev[2 * RTE_PORT_IN_BURST_SIZE_MAX]; member
182 memset(&port->ev, 0, sizeof(port->ev)); in rte_port_eventdev_writer_create()
184 for (i = 0; i < RTE_DIM(port->ev); i++) { in rte_port_eventdev_writer_create()
185 port->ev[i].queue_id = port->queue_id; in rte_port_eventdev_writer_create()
186 port->ev[i].sched_type = port->sched_type; in rte_port_eventdev_writer_create()
187 port->ev[i].op = port->evt_op; in rte_port_eventdev_writer_create()
199 p->ev, p->enq_buf_count); in send_burst()
[all …]
/dpdk/examples/l2fwd-event/
H A Dl2fwd_event.c156 l2fwd_event_fwd(struct l2fwd_resources *rsrc, struct rte_event *ev, in l2fwd_event_fwd()
160 struct rte_mbuf *mbuf = ev->mbuf; in l2fwd_event_fwd()
175 ev->queue_id = tx_q_id; in l2fwd_event_fwd()
176 ev->op = RTE_EVENT_OP_FORWARD; in l2fwd_event_fwd()
198 struct rte_event ev; in l2fwd_event_loop_single()
208 deq = rte_event_dequeue_burst(event_d_id, port_id, &ev, 1, 0); in l2fwd_event_loop_single()
212 l2fwd_event_fwd(rsrc, &ev, tx_q_id, timer_period, flags); in l2fwd_event_loop_single()
217 port_id, &ev, 1); in l2fwd_event_loop_single()
224 event_d_id, port_id, &ev, 1, 0); in l2fwd_event_loop_single()
229 l2fwd_event_worker_cleanup(event_d_id, port_id, &ev, en in l2fwd_event_loop_single()
155 l2fwd_event_fwd(struct l2fwd_resources * rsrc,struct rte_event * ev,const uint8_t tx_q_id,const uint64_t timer_period,const uint32_t flags) l2fwd_event_fwd() argument
197 struct rte_event ev; l2fwd_event_loop_single() local
242 struct rte_event ev[MAX_PKT_BURST]; l2fwd_event_loop_burst() local
426 struct rte_event ev[MAX_PKT_BURST]; l2fwd_event_loop_vector() local
[all...]
/dpdk/drivers/net/sfc/
H A Dsfc_ef100.h46 sfc_ef100_ev_present(const efx_qword_t *ev, bool phase_bit) in sfc_ef100_ev_present() argument
48 return !((ev->eq_u64[0] & in sfc_ef100_ev_present()
54 sfc_ef100_ev_type_is(const efx_qword_t *ev, unsigned int type) in sfc_ef100_ev_type_is() argument
56 return (ev->eq_u64[0] & EFX_INPLACE_MASK64(0, 63, ESF_GZ_E_TYPE)) == in sfc_ef100_ev_type_is()
/dpdk/drivers/event/opdl/
H A Dopdl_evdev_init.c20 const struct rte_event ev[], in enqueue_check() argument
29 if (ev[i].queue_id != p->next_external_qid) { in enqueue_check()
36 ev[i].queue_id, in enqueue_check()
65 ev[0].queue_id != p->next_external_qid) { in enqueue_check()
76 struct rte_event ev[], in update_on_dequeue() argument
83 ev[i].queue_id = in update_on_dequeue()
98 ev[0].queue_id = in update_on_dequeue()
112 const struct rte_event ev[], in opdl_rx_error_enqueue() argument
116 RTE_SET_USED(ev); in opdl_rx_error_enqueue()
134 const struct rte_event ev[], in opdl_rx_enqueue() argument
[all …]
/dpdk/examples/ipsec-secgw/
H A Dipsec_worker.c351 crypto_prepare_event(struct rte_mbuf *pkt, struct rte_ipsec_session *sess, struct rte_event *ev) in crypto_op_reset()
364 ev->event = 0; in crypto_prepare_event()
365 ev->event_ptr = cop; in crypto_prepare_event()
385 struct rte_event ev;
391 crypto_prepare_event(pkt, sess, &ev); in event_crypto_enqueue()
395 ev_link->event_port_id, &ev, 1); in event_crypto_enqueue()
407 const struct eh_event_link_info *ev_link, struct rte_event *ev) in event_crypto_enqueue()
417 pkt = ev->mbuf; in process_ipsec_ev_inbound()
532 ev->mbuf = NULL; in process_ipsec_ev_inbound()
538 const struct eh_event_link_info *ev_link, struct rte_event *ev) in process_ipsec_ev_inbound()
356 crypto_prepare_event(struct rte_mbuf * pkt,struct rte_ipsec_session * sess,struct rte_event * ev) crypto_prepare_event() argument
390 struct rte_event ev; event_crypto_enqueue() local
412 process_ipsec_ev_inbound(struct ipsec_ctx * ctx,struct route_table * rt,const struct eh_event_link_info * ev_link,struct rte_event * ev) process_ipsec_ev_inbound() argument
543 process_ipsec_ev_outbound(struct ipsec_ctx * ctx,struct route_table * rt,const struct eh_event_link_info * ev_link,struct rte_event * ev) process_ipsec_ev_outbound() argument
960 ipsec_event_vector_free(struct rte_event * ev) ipsec_event_vector_free() argument
970 ipsec_ev_vector_process(struct lcore_conf_ev_tx_int_port_wrkr * lconf,struct eh_event_link_info * links,struct rte_event * ev) ipsec_ev_vector_process() argument
1002 ipsec_ev_vector_drv_mode_process(struct eh_event_link_info * links,struct rte_event * ev,struct port_drv_mode_data * data) ipsec_ev_vector_drv_mode_process() argument
1084 ipsec_ev_cryptodev_vector_process(const struct lcore_conf_ev_tx_int_port_wrkr * lconf,const struct eh_event_link_info * links,struct rte_event * ev) ipsec_ev_cryptodev_vector_process() argument
1126 ipsec_ev_cryptodev_process(const struct lcore_conf_ev_tx_int_port_wrkr * lconf,struct rte_event * ev) ipsec_ev_cryptodev_process() argument
1151 ipsec_event_port_flush(uint8_t eventdev_id __rte_unused,struct rte_event ev,void * args __rte_unused) ipsec_event_port_flush() argument
1191 struct rte_event ev; ipsec_wrkr_non_burst_int_port_drv_mode() local
1316 struct rte_event ev; ipsec_wrkr_non_burst_int_port_app_mode() local
[all...]
/dpdk/drivers/event/cnxk/tx/cn10k/
H A Dtx_all_offload.c14 cn10k_sso_hws_tx_adptr_enq_seg_all_offload(void *port, struct rte_event ev[], uint16_t nb_events) in cn10k_sso_hws_tx_adptr_enq_seg_all_offload() argument
22 return cn10k_sso_hws_event_tx(ws, &ev[0], cmd, (const uint64_t *)ws->tx_adptr_data, flags); in cn10k_sso_hws_tx_adptr_enq_seg_all_offload()
26 cn10k_sso_hws_tx_adptr_enq_seg_all_offload_tst(void *port, struct rte_event ev[], in cn10k_sso_hws_tx_adptr_enq_seg_all_offload_tst() argument
37 return cn10k_sso_hws_event_tx(ws, &ev[0], cmd, (const uint64_t *)ws->tx_adptr_data, flags); in cn10k_sso_hws_tx_adptr_enq_seg_all_offload_tst()

123