Home
last modified time | relevance | path

Searched refs:flow_table (Results 1 – 25 of 27) sorted by relevance

12

/Linux-v6.1/net/openvswitch/
Dflow_table.h62 struct flow_table { struct
80 int ovs_flow_tbl_init(struct flow_table *); argument
81 int ovs_flow_tbl_count(const struct flow_table *table);
82 void ovs_flow_tbl_destroy(struct flow_table *table);
83 int ovs_flow_tbl_flush(struct flow_table *flow_table);
85 int ovs_flow_tbl_insert(struct flow_table *table, struct sw_flow *flow,
87 void ovs_flow_tbl_remove(struct flow_table *table, struct sw_flow *flow);
88 int ovs_flow_tbl_num_masks(const struct flow_table *table);
89 u32 ovs_flow_tbl_masks_cache_size(const struct flow_table *table);
90 int ovs_flow_tbl_masks_cache_resize(struct flow_table *table, u32 size);
[all …]
Dflow_table.c102 int ovs_flow_tbl_count(const struct flow_table *table) in ovs_flow_tbl_count()
247 static int tbl_mask_array_realloc(struct flow_table *tbl, int size) in tbl_mask_array_realloc()
272 static int tbl_mask_array_add_mask(struct flow_table *tbl, in tbl_mask_array_add_mask()
300 static void tbl_mask_array_del_mask(struct flow_table *tbl, in tbl_mask_array_del_mask()
333 static void flow_mask_remove(struct flow_table *tbl, struct sw_flow_mask *mask) in flow_mask_remove()
391 int ovs_flow_tbl_masks_cache_resize(struct flow_table *table, u32 size) in ovs_flow_tbl_masks_cache_resize()
413 int ovs_flow_tbl_init(struct flow_table *table) in ovs_flow_tbl_init()
461 static void table_instance_flow_free(struct flow_table *table, in table_instance_flow_free()
466 hlist_del_rcu(&flow->flow_table.node[ti->node_ver]); in table_instance_flow_free()
478 void table_instance_flow_flush(struct flow_table *table, in table_instance_flow_flush()
[all …]
DMakefile14 flow_table.o \
Ddatapath.h89 struct flow_table table;
Dflow.h226 } flow_table, ufid_table; member
/Linux-v6.1/net/netfilter/
Dnf_flow_table_core.c283 int flow_offload_add(struct nf_flowtable *flow_table, struct flow_offload *flow) in flow_offload_add() argument
289 err = rhashtable_insert_fast(&flow_table->rhashtable, in flow_offload_add()
295 err = rhashtable_insert_fast(&flow_table->rhashtable, in flow_offload_add()
299 rhashtable_remove_fast(&flow_table->rhashtable, in flow_offload_add()
307 if (nf_flowtable_hw_offload(flow_table)) { in flow_offload_add()
309 nf_flow_offload_add(flow_table, flow); in flow_offload_add()
316 void flow_offload_refresh(struct nf_flowtable *flow_table, in flow_offload_refresh() argument
327 if (likely(!nf_flowtable_hw_offload(flow_table))) in flow_offload_refresh()
330 nf_flow_offload_add(flow_table, flow); in flow_offload_refresh()
339 static void flow_offload_del(struct nf_flowtable *flow_table, in flow_offload_del() argument
[all …]
Dnf_flow_table_ip.c344 struct nf_flowtable *flow_table = priv; in nf_flow_offload_ip_hook() local
363 tuplehash = flow_offload_lookup(flow_table, &tuple); in nf_flow_offload_ip_hook()
387 flow_offload_refresh(flow_table, flow); in nf_flow_offload_ip_hook()
398 if (flow_table->flags & NF_FLOWTABLE_COUNTER) in nf_flow_offload_ip_hook()
606 struct nf_flowtable *flow_table = priv; in nf_flow_offload_ipv6_hook() local
625 tuplehash = flow_offload_lookup(flow_table, &tuple); in nf_flow_offload_ipv6_hook()
649 flow_offload_refresh(flow_table, flow); in nf_flow_offload_ipv6_hook()
659 if (flow_table->flags & NF_FLOWTABLE_COUNTER) in nf_flow_offload_ipv6_hook()
/Linux-v6.1/include/net/netfilter/
Dnf_flow_table.h219 nf_flow_table_offload_add_cb(struct nf_flowtable *flow_table, in nf_flow_table_offload_add_cb() argument
222 struct flow_block *block = &flow_table->flow_block; in nf_flow_table_offload_add_cb()
226 down_write(&flow_table->flow_block_lock); in nf_flow_table_offload_add_cb()
242 up_write(&flow_table->flow_block_lock); in nf_flow_table_offload_add_cb()
247 nf_flow_table_offload_del_cb(struct nf_flowtable *flow_table, in nf_flow_table_offload_del_cb() argument
250 struct flow_block *block = &flow_table->flow_block; in nf_flow_table_offload_del_cb()
253 down_write(&flow_table->flow_block_lock); in nf_flow_table_offload_del_cb()
261 up_write(&flow_table->flow_block_lock); in nf_flow_table_offload_del_cb()
267 int flow_offload_add(struct nf_flowtable *flow_table, struct flow_offload *flow);
268 void flow_offload_refresh(struct nf_flowtable *flow_table,
[all …]
/Linux-v6.1/drivers/net/ethernet/mellanox/mlx5/core/en_accel/
Dmacsec_fs.c247 struct mlx5_flow_table *flow_table; in macsec_fs_tx_create() local
277 flow_table = mlx5_create_flow_table(ns, &ft_attr); in macsec_fs_tx_create()
278 if (IS_ERR(flow_table)) { in macsec_fs_tx_create()
279 err = PTR_ERR(flow_table); in macsec_fs_tx_create()
283 ft_crypto->t = flow_table; in macsec_fs_tx_create()
323 flow_table = macsec_fs_auto_group_table_create(ns, 0, TX_CHECK_TABLE_LEVEL, in macsec_fs_tx_create()
325 if (IS_ERR(flow_table)) { in macsec_fs_tx_create()
326 err = PTR_ERR(flow_table); in macsec_fs_tx_create()
330 tx_tables->ft_check = flow_table; in macsec_fs_tx_create()
334 MLX5_SET(create_flow_group_in, flow_group_in, start_flow_index, flow_table->max_fte - 1); in macsec_fs_tx_create()
[all …]
/Linux-v6.1/drivers/net/ethernet/mediatek/
Dmtk_ppe_offload.c247 if (rhashtable_lookup(&eth->flow_table, &f->cookie, mtk_flow_ht_params)) in mtk_flow_offload_replace()
454 err = rhashtable_insert_fast(&eth->flow_table, &entry->node, in mtk_flow_offload_replace()
475 entry = rhashtable_lookup(&eth->flow_table, &f->cookie, in mtk_flow_offload_destroy()
481 rhashtable_remove_fast(&eth->flow_table, &entry->node, in mtk_flow_offload_destroy()
496 entry = rhashtable_lookup(&eth->flow_table, &f->cookie, in mtk_flow_offload_stats()
605 return rhashtable_init(&eth->flow_table, &mtk_flow_ht_params); in mtk_eth_offload_init()
Dmtk_eth_soc.h1118 struct rhashtable flow_table; member
/Linux-v6.1/drivers/net/ethernet/marvell/octeontx2/nic/
Dotx2_tc.c712 flow_node = rhashtable_lookup_fast(&tc_info->flow_table, in otx2_tc_del_flow()
744 WARN_ON(rhashtable_remove_fast(&nic->tc_info.flow_table, in otx2_tc_del_flow()
790 old_node = rhashtable_lookup_fast(&tc_info->flow_table, in otx2_tc_add_flow()
826 rc = rhashtable_insert_fast(&nic->tc_info.flow_table, &new_node->node, in otx2_tc_add_flow()
873 flow_node = rhashtable_lookup_fast(&tc_info->flow_table, in otx2_tc_get_flow_stats()
1137 err = rhashtable_init(&tc->flow_table, &tc->flow_ht_params); in otx2_init_tc()
1151 rhashtable_destroy(&tc->flow_table); in otx2_shutdown_tc()
Dotx2_common.h344 struct rhashtable flow_table; member
/Linux-v6.1/drivers/net/ethernet/netronome/nfp/flower/
Dmetadata.c111 return rhashtable_lookup_fast(&priv->flow_table, &flower_cmp_arg, in nfp_flower_search_fl_table()
519 err = rhashtable_init(&priv->flow_table, &nfp_flower_table_params); in nfp_flower_metadata_init()
601 rhashtable_destroy(&priv->flow_table); in nfp_flower_metadata_init()
706 rhashtable_free_and_destroy(&priv->flow_table, in nfp_flower_metadata_cleanup()
Doffload.c1063 err = rhashtable_insert_fast(&priv->flow_table, &merge_flow->fl_node, in nfp_flower_merge_offloaded_flows()
1096 WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table, in nfp_flower_merge_offloaded_flows()
1390 err = rhashtable_insert_fast(&priv->flow_table, &flow_pay->fl_node, in nfp_flower_add_offload()
1435 WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table, in nfp_flower_add_offload()
1518 WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table, in nfp_flower_remove_merge_flow()
1620 WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table, in nfp_flower_del_offload()
Dconntrack.c1056 err = rhashtable_insert_fast(&priv->flow_table, &flow_pay->fl_node, in nfp_fl_ct_add_offload()
1075 WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table, in nfp_fl_ct_add_offload()
1132 WARN_ON_ONCE(rhashtable_remove_fast(&priv->flow_table, in nfp_fl_ct_del_offload()
1745 zt->nft = ct_act->ct.flow_table; in nfp_fl_ct_handle_pre_ct()
Dmain.h296 struct rhashtable flow_table; member
/Linux-v6.1/drivers/infiniband/hw/mlx5/
Dfs.c633 mlx5_destroy_flow_table(prio->flow_table); in put_flow_table()
634 prio->flow_table = NULL; in put_flow_table()
709 prio->flow_table = ft; in _get_prio()
795 ft = prio->flow_table; in get_flow_table()
939 if (!prio->flow_table) { in mlx5_ib_fs_add_op_fc()
955 opfc->rule[i] = mlx5_add_flow_rules(prio->flow_table, &spec[i], in mlx5_ib_fs_add_op_fc()
1047 struct mlx5_flow_table *ft = ft_prio->flow_table; in _create_flow_rule()
1158 ft_prio->flow_table = ft; in _create_flow_rule()
1509 if (prio->flow_table) in _get_flow_table()
1528 struct mlx5_flow_table *ft = ft_prio->flow_table; in _create_raw_flow_rule()
[all …]
Dmlx5_ib.h237 struct mlx5_flow_table *flow_table; member
/Linux-v6.1/drivers/net/ethernet/broadcom/bnxt/
Dbnxt_tc.c1485 rc = rhashtable_remove_fast(&tc_info->flow_table, &flow_node->node, in __bnxt_tc_del_flow()
1556 old_node = rhashtable_lookup_fast(&tc_info->flow_table, in bnxt_tc_add_flow()
1584 rc = rhashtable_insert_fast(&tc_info->flow_table, &new_node->node, in bnxt_tc_add_flow()
1614 flow_node = rhashtable_lookup_fast(&tc_info->flow_table, in bnxt_tc_del_flow()
1632 flow_node = rhashtable_lookup_fast(&tc_info->flow_table, in bnxt_tc_get_flow_stats()
1824 num_flows = atomic_read(&tc_info->flow_table.nelems); in bnxt_tc_flow_stats_work()
1828 rhashtable_walk_enter(&tc_info->flow_table, &tc_info->iter); in bnxt_tc_flow_stats_work()
2027 rc = rhashtable_init(&tc_info->flow_table, &tc_info->flow_ht_params); in bnxt_init_tc()
2075 rhashtable_destroy(&tc_info->flow_table); in bnxt_init_tc()
2090 rhashtable_destroy(&tc_info->flow_table); in bnxt_shutdown_tc()
Dbnxt.h1401 struct rhashtable flow_table; member
/Linux-v6.1/net/core/
Dnet-sysfs.c904 struct rps_dev_flow_table *flow_table; in show_rps_dev_flow_table_cnt() local
908 flow_table = rcu_dereference(queue->rps_flow_table); in show_rps_dev_flow_table_cnt()
909 if (flow_table) in show_rps_dev_flow_table_cnt()
910 val = (unsigned long)flow_table->mask + 1; in show_rps_dev_flow_table_cnt()
1004 struct rps_dev_flow_table *flow_table; in rx_queue_release() local
1012 flow_table = rcu_dereference_protected(queue->rps_flow_table, 1); in rx_queue_release()
1013 if (flow_table) { in rx_queue_release()
1015 call_rcu(&flow_table->rcu, rps_dev_flow_table_release); in rx_queue_release()
Ddev.c4396 struct rps_dev_flow_table *flow_table; in set_rps_cpu() local
4411 flow_table = rcu_dereference(rxqueue->rps_flow_table); in set_rps_cpu()
4412 if (!flow_table) in set_rps_cpu()
4414 flow_id = skb_get_hash(skb) & flow_table->mask; in set_rps_cpu()
4420 rflow = &flow_table->flows[flow_id]; in set_rps_cpu()
4444 struct rps_dev_flow_table *flow_table; in get_rps_cpu() local
4465 flow_table = rcu_dereference(rxqueue->rps_flow_table); in get_rps_cpu()
4467 if (!flow_table && !map) in get_rps_cpu()
4476 if (flow_table && sock_flow_table) { in get_rps_cpu()
4491 rflow = &flow_table->flows[hash & flow_table->mask]; in get_rps_cpu()
[all …]
/Linux-v6.1/include/net/
Dflow_offload.h279 struct nf_flowtable *flow_table; member
/Linux-v6.1/net/sched/
Dact_ct.c1579 entry->ct.flow_table = tcf_ct_ft(act); in tcf_ct_offload_act_setup()

12