Home
last modified time | relevance | path

Searched refs:flow_id (Results 1 – 25 of 85) sorted by relevance

1234

/dpdk/drivers/net/bnxt/tf_core/
H A Dtf_ext_flow_handle.h126 #define TF_SET_FLOW_ID(flow_id, gfid, flag, dir) \ argument
128 (flow_id) &= ~(TF_GFID_FLOW_ID_MASK | \
131 (flow_id) |= (((gfid) << TF_GFID_FLOW_ID_SFT) & \
139 #define TF_GET_GFID_FROM_FLOW_ID(flow_id, gfid) \ argument
141 gfid = (((flow_id) & TF_GFID_FLOW_ID_MASK) >> \
145 #define TF_GET_DIR_FROM_FLOW_ID(flow_id, dir) \ argument
147 dir = (((flow_id) & TF_DIR_FLOW_ID_MASK) >> \
151 #define TF_GET_FLAG_FROM_FLOW_ID(flow_id, flag) \ argument
153 flag = (((flow_id) & TF_FLAG_FLOW_ID_MASK) >> \
/dpdk/app/test-eventdev/
H A Dtest_order_common.h68 event->flow_id = *RTE_MBUF_DYNFIELD(event->mbuf, in order_flow_id_copy_from_mbuf()
73 order_flow_id_save(struct test_order *t, flow_id_t flow_id, in order_flow_id_save() argument
77 t->flow_id_dynfield_offset, flow_id_t *) = flow_id; in order_flow_id_save()
78 event->flow_id = flow_id; in order_flow_id_save()
H A Dtest_perf_common.c65 ev.flow_id = flow_counter++ % nb_flows; in perf_producer()
126 ev[i].flow_id = flow_counter++ % nb_flows; in perf_producer_burst()
190 m[i]->tim.ev.flow_id = flow_counter++ % nb_flows; in perf_event_timer_producer()
256 m[i]->tim.ev.flow_id = flow_counter++ % nb_flows; in perf_event_timer_producer_burst()
810 uint32_t flow_id; in perf_event_dev_port_setup() local
832 for (flow_id = 0; flow_id < t->nb_flows; flow_id++) { in perf_event_dev_port_setup()
837 m_data.response_info.flow_id = flow_id; in perf_event_dev_port_setup()
840 p->ca.crypto_sess[flow_id] = crypto_sess; in perf_event_dev_port_setup()
1276 uint32_t flow_id; in perf_cryptodev_destroy() local
1279 for (flow_id = 0; flow_id < t->nb_flows; flow_id++) { in perf_cryptodev_destroy()
[all …]
/dpdk/drivers/net/bnxt/tf_ulp/
H A Dulp_def_rules.c299 uint32_t *flow_id) in ulp_default_flow_create() argument
380 mapper_params.flow_id = fid; in ulp_default_flow_create()
386 *flow_id = fid; in ulp_default_flow_create()
411 ulp_default_flow_destroy(struct rte_eth_dev *eth_dev, uint32_t flow_id) in ulp_default_flow_destroy() argument
422 if (!flow_id) { in ulp_default_flow_destroy()
432 flow_id); in ulp_default_flow_destroy()
480 uint32_t *flow_id) in bnxt_create_port_app_df_rule() argument
497 *flow_id = 0; in bnxt_create_port_app_df_rule()
501 flow_id); in bnxt_create_port_app_df_rule()
539 uint32_t *flow_id) in bnxt_create_port_vfr_default_rule() argument
[all …]
H A Dbnxt_ulp_flow.c102 mapper_cparms->flow_id = params->fid; in bnxt_ulp_init_mapper_params()
171 struct rte_flow *flow_id; in bnxt_ulp_flow_create() local
273 flow_id = (struct rte_flow *)((uintptr_t)fid); in bnxt_ulp_flow_create()
274 return flow_id; in bnxt_ulp_flow_create()
367 uint32_t flow_id; in bnxt_ulp_flow_destroy() local
381 flow_id = (uint32_t)(uintptr_t)flow; in bnxt_ulp_flow_destroy()
394 if (ulp_flow_db_validate_flow_func(ulp_ctx, flow_id, func_id) == in bnxt_ulp_flow_destroy()
409 flow_id); in bnxt_ulp_flow_destroy()
466 uint32_t flow_id; in bnxt_ulp_flow_query() local
477 flow_id = (uint32_t)(uintptr_t)flow; in bnxt_ulp_flow_query()
[all …]
H A Dulp_flow_db.c296 uint32_t flow_id, in ulp_flow_db_func_id_set() argument
1003 uint32_t flow_id = 0; in ulp_flow_db_function_flow_flush() local
1022 &flow_id)) { in ulp_flow_db_function_flow_flush()
1026 flow_id); in ulp_flow_db_function_flow_flush()
1060 uint32_t flow_id, in ulp_flow_db_validate_flow_func() argument
1090 uint32_t flow_id, in ulp_flow_db_resource_params_get() argument
1119 if (flow_id >= flow_tbl->num_flows || !flow_id) { in ulp_flow_db_resource_params_get()
1130 res_id = flow_id; in ulp_flow_db_resource_params_get()
1166 uint32_t flow_id, in ulp_default_flow_db_cfa_action_get() argument
1175 flow_id, in ulp_default_flow_db_cfa_action_get()
[all …]
H A Dbnxt_ulp.h124 uint32_t flow_id; member
241 uint32_t *flow_id);
246 uint32_t flow_id);
H A Dulp_flow_db.h247 uint32_t flow_id,
261 uint32_t flow_id,
H A Dulp_fc_mgr.h168 uint32_t flow_id,
H A Dulp_mapper.h85 uint32_t flow_id; member
/dpdk/drivers/event/dpaa2/
H A Ddpaa2_eventdev_selftest.c42 uint32_t flow_id; member
219 uint32_t flow_id, uint8_t event_type, in update_event_and_validation_attr() argument
227 attr->flow_id = flow_id; in update_event_and_validation_attr()
235 ev->flow_id = flow_id; in update_event_and_validation_attr()
246 inject_events(uint32_t flow_id, uint8_t event_type, uint8_t sub_event_type, in inject_events() argument
259 update_event_and_validation_attr(m, &ev, flow_id, event_type, in inject_events()
320 RTE_TEST_ASSERT_EQUAL(attr->flow_id, ev->flow_id, in validate_event()
322 attr->flow_id, ev->flow_id); in validate_event()
/dpdk/drivers/event/octeontx/
H A Dssovf_evdev_selftest.c40 uint32_t flow_id; member
264 uint32_t flow_id, uint8_t event_type, in update_event_and_validation_attr() argument
272 attr->flow_id = flow_id; in update_event_and_validation_attr()
279 ev->flow_id = flow_id; in update_event_and_validation_attr()
290 inject_events(uint32_t flow_id, uint8_t event_type, uint8_t sub_event_type, in inject_events() argument
304 update_event_and_validation_attr(m, &ev, flow_id, event_type, in inject_events()
365 RTE_TEST_ASSERT_EQUAL(attr->flow_id, ev->flow_id, in validate_event()
367 attr->flow_id, ev->flow_id); in validate_event()
902 ev.flow_id = 0x2; in worker_flow_based_pipeline()
1057 ev.flow_id = 0x2; in worker_group_based_pipeline()
[all …]
/dpdk/drivers/net/ionic/
H A Dionic_rx_filter.c52 ionic_rx_filter_save(struct ionic_lif *lif, uint32_t flow_id, in ionic_rx_filter_save() argument
63 f->flow_id = flow_id; in ionic_rx_filter_save()
H A Dionic_rx_filter.h15 uint32_t flow_id; member
40 int ionic_rx_filter_save(struct ionic_lif *lif, uint32_t flow_id,
/dpdk/drivers/event/cnxk/
H A Dcnxk_eventdev_selftest.c39 uint32_t flow_id; member
245 uint32_t flow_id, uint8_t event_type, in update_event_and_validation_attr() argument
253 attr->flow_id = flow_id; in update_event_and_validation_attr()
260 ev->flow_id = flow_id; in update_event_and_validation_attr()
285 update_event_and_validation_attr(m, &ev, flow_id, event_type, in inject_events()
346 RTE_TEST_ASSERT_EQUAL(attr->flow_id, ev->flow_id, in validate_event()
347 "flow_id mismatch enq=%d deq =%d", attr->flow_id, in validate_event()
348 ev->flow_id); in validate_event()
907 ev.flow_id = 0x2; in worker_flow_based_pipeline()
1063 ev.flow_id = 0x2; in worker_group_based_pipeline()
[all …]
/dpdk/drivers/net/dpaa2/
H A Ddpaa2_ethdev.c422 mc_q->flow_id = 0xffff; in dpaa2_alloc_rx_tx_queues()
436 mc_q->flow_id = 0; in dpaa2_alloc_rx_tx_queues()
717 uint8_t flow_id; in dpaa2_dev_rx_queue_setup() local
759 flow_id = dpaa2_q->flow_id; in dpaa2_dev_rx_queue_setup()
836 dpaa2_q->tc_index, flow_id, in dpaa2_dev_rx_queue_setup()
885 uint8_t options = 0, flow_id; in dpaa2_dev_tx_queue_setup() local
931 flow_id = 0; in dpaa2_dev_tx_queue_setup()
938 tc_id, flow_id, ret); in dpaa2_dev_tx_queue_setup()
942 dpaa2_q->flow_id = flow_id; in dpaa2_dev_tx_queue_setup()
2240 uint8_t flow_id = dpaa2_ethq->flow_id; in dpaa2_eth_eventq_attach() local
[all …]
H A Ddpaa2_tm.c569 uint8_t flow_id, options = 0; in dpaa2_tm_configure_queue() local
580 flow_id = 0; in dpaa2_tm_configure_queue()
591 flow_id, options, &tx_flow_cfg); in dpaa2_tm_configure_queue()
596 ((node->parent->channel_id << 8) | tc_id), flow_id, in dpaa2_tm_configure_queue()
601 dpaa2_q->flow_id = flow_id; in dpaa2_tm_configure_queue()
606 dpaa2_q->flow_id, &tx_flow_cfg, &qid); in dpaa2_tm_configure_queue()
/dpdk/drivers/event/dsw/
H A Ddsw_event.c595 uint16_t flow_id = port->next_parallel_flow_id; in dsw_port_get_parallel_flow_id() local
600 return flow_id; in dsw_port_get_parallel_flow_id()
628 dsw_flow_id_hash(uint32_t flow_id) in dsw_flow_id_hash() argument
634 hash ^= ((flow_id >> offset) & DSW_MAX_FLOWS_MASK); in dsw_flow_id_hash()
647 event.flow_id = dsw_port_get_parallel_flow_id(source_port); in dsw_port_buffer_parallel()
650 dsw_flow_id_hash(event.flow_id)); in dsw_port_buffer_parallel()
668 flow_hash = dsw_flow_id_hash(event->flow_id); in dsw_port_buffer_event()
708 flow_hash = dsw_flow_id_hash(event->flow_id); in dsw_port_flush_paused_events()
997 dsw_flow_id_hash(e->flow_id) == flow_hash) { in dsw_port_forward_emigrated_flow()
1304 qf->flow_hash = dsw_flow_id_hash(event->flow_id); in dsw_port_record_seen_events()
[all …]
/dpdk/drivers/net/bnxt/
H A Dbnxt_flow.c1071 filter->flow_id = filter1->flow_id; in bnxt_update_filter_flags_en()
1509 filter->flow_id = filter1->flow_id; in bnxt_validate_and_parse_flow()
1954 uint32_t tun_type, flow_id; in bnxt_flow_create() local
2090 filter->mark, filter->flow_id); in bnxt_flow_create()
2095 flow_id = filter->flow_id & BNXT_FLOW_ID_MASK; in bnxt_flow_create()
2096 if (bp->mark_table[flow_id].valid) { in bnxt_flow_create()
2104 bp->mark_table[flow_id].valid = true; in bnxt_flow_create()
2197 uint32_t flow_id; in _bnxt_flow_destroy() local
2220 flow_id = filter->flow_id & BNXT_FLOW_ID_MASK; in _bnxt_flow_destroy()
2221 memset(&bp->mark_table[flow_id], 0, in _bnxt_flow_destroy()
[all …]
/dpdk/drivers/event/sw/
H A Dsw_evdev_scheduler.c51 const uint16_t flow_id = SW_HASH_FLOWID(qes[i].flow_id); in sw_schedule_atomic_to_cq() local
52 struct sw_fid_t *fid = &qid->fids[flow_id]; in sw_schedule_atomic_to_cq()
93 p->hist_list[head].fid = flow_id; in sw_schedule_atomic_to_cq()
165 p->hist_list[head].fid = SW_HASH_FLOWID(qe->flow_id); in sw_schedule_parallel_to_cq()
/dpdk/drivers/net/mlx4/
H A Dmlx4_glue.c155 mlx4_glue_destroy_flow(struct ibv_flow *flow_id) in mlx4_glue_destroy_flow() argument
157 return ibv_destroy_flow(flow_id); in mlx4_glue_destroy_flow()
H A Dmlx4_glue.h60 int (*destroy_flow)(struct ibv_flow *flow_id);
/dpdk/drivers/net/iavf/
H A Diavf_ipsec_crypto.h157 uint8_t is_v4, uint32_t flow_id);
/dpdk/drivers/event/opdl/
H A Dopdl_ring.c500 uint32_t flow_id = 0; in opdl_stage_claim_singlethread() local
533 flow_id = OPDL_FLOWID_MASK & event; in opdl_stage_claim_singlethread()
538 if ((flow_id % s->nb_instance) == s->instance_id) { in opdl_stage_claim_singlethread()
983 uint32_t flow_id = 0; in opdl_ring_cas_slot() local
1016 flow_id = OPDL_FLOWID_MASK & event; in opdl_ring_cas_slot()
1021 if ((flow_id % s->nb_instance) == s->instance_id) { in opdl_ring_cas_slot()
/dpdk/drivers/common/mlx5/linux/
H A Dmlx5_glue.c204 mlx5_glue_destroy_flow(struct ibv_flow *flow_id) in mlx5_glue_destroy_flow() argument
206 return ibv_destroy_flow(flow_id); in mlx5_glue_destroy_flow()
902 mlx5_glue_dv_destroy_flow(void *flow_id) in mlx5_glue_dv_destroy_flow() argument
905 return mlx5dv_dr_rule_destroy(flow_id); in mlx5_glue_dv_destroy_flow()
907 return ibv_destroy_flow(flow_id); in mlx5_glue_dv_destroy_flow()

1234