[PATCH v2 19/34] net/mlx5: update ASO resources in non-template setup

Maayan Kashani mkashani at nvidia.com
Mon Jun 3 10:10:40 CEST 2024


From: Gregory Etelson <getelson at nvidia.com>

Non-template PMD implementation allocates ASO flow actions resources
on-demand.

Current PMD implementation iterated over actions array in search for
actions that required ASO resources allocations.

The patch replaced the iteration with actions flags bitmap queries.

Signed-off-by: Gregory Etelson <getelson at nvidia.com>
---
 drivers/net/mlx5/mlx5_flow_hw.c | 102 ++++++++++++++------------------
 1 file changed, 45 insertions(+), 57 deletions(-)

diff --git a/drivers/net/mlx5/mlx5_flow_hw.c b/drivers/net/mlx5/mlx5_flow_hw.c
index 9f43fbfb35..f2ed2d8e46 100644
--- a/drivers/net/mlx5/mlx5_flow_hw.c
+++ b/drivers/net/mlx5/mlx5_flow_hw.c
@@ -12671,79 +12671,67 @@ static int flow_hw_register_matcher(struct rte_eth_dev *dev,
 					NULL, "fail to register matcher");
 }
 
-static int flow_hw_ensure_action_pools_allocated(struct rte_eth_dev *dev,
-					const struct rte_flow_action actions[],
-					struct rte_flow_error *error)
+static int
+flow_hw_allocate_actions(struct rte_eth_dev *dev,
+			 uint64_t action_flags,
+			 struct rte_flow_error *error)
 {
-	bool actions_end = false;
 	struct mlx5_priv *priv = dev->data->dev_private;
 	int ret;
 	uint obj_num;
 
-	for (; !actions_end; actions++) {
-		switch ((int)actions->type) {
-		case RTE_FLOW_ACTION_TYPE_AGE:
-			/* If no age objects were previously allocated. */
-			if (!priv->hws_age_req) {
-				/* If no counters were previously allocated. */
-				if (!priv->hws_cpool) {
-					obj_num = MLX5_CNT_NT_MAX(priv);
-					ret = mlx5_hws_cnt_pool_create(dev, obj_num,
-						priv->nb_queue, NULL);
-					if (ret)
-						goto err;
-				}
-				if (priv->hws_cpool) {
-					/* Allocate same number of counters. */
-					ret = mlx5_hws_age_pool_init(dev,
-								priv->hws_cpool->cfg.request_num,
-								priv->nb_queue, false);
-					if (ret)
-						goto err;
-				}
-			}
-		break;
-		case RTE_FLOW_ACTION_TYPE_COUNT:
+	if (action_flags & MLX5_FLOW_ACTION_AGE) {
+		/* If no age objects were previously allocated. */
+		if (!priv->hws_age_req) {
 			/* If no counters were previously allocated. */
 			if (!priv->hws_cpool) {
 				obj_num = MLX5_CNT_NT_MAX(priv);
 				ret = mlx5_hws_cnt_pool_create(dev, obj_num,
-					priv->nb_queue, NULL);
-				if (ret)
-					goto err;
-			}
-		break;
-		case RTE_FLOW_ACTION_TYPE_CONNTRACK:
-			/* If no CT were previously allocated. */
-			if (!priv->hws_ctpool) {
-				obj_num = MLX5_CT_NT_MAX(priv);
-				ret = mlx5_flow_ct_init(dev, obj_num, priv->nb_queue);
-				if (ret)
-					goto err;
-			}
-		break;
-		case RTE_FLOW_ACTION_TYPE_METER_MARK:
-			/* If no meters were previously allocated. */
-			if (!priv->hws_mpool) {
-				obj_num = MLX5_MTR_NT_MAX(priv);
-				ret = mlx5_flow_meter_init(dev, obj_num, 0, 0,
-								priv->nb_queue);
+							       priv->nb_queue, NULL);
 				if (ret)
 					goto err;
 			}
-		break;
-		case RTE_FLOW_ACTION_TYPE_END:
-			actions_end = true;
-		break;
-		default:
-			break;
+			/* Allocate same number of counters. */
+			ret = mlx5_hws_age_pool_init(dev, priv->hws_cpool->cfg.request_num,
+						     priv->nb_queue, false);
+			if (ret)
+				goto err;
+		}
+	}
+	if (action_flags & MLX5_FLOW_ACTION_COUNT) {
+		/* If no counters were previously allocated. */
+		if (!priv->hws_cpool) {
+			obj_num = MLX5_CNT_NT_MAX(priv);
+			ret = mlx5_hws_cnt_pool_create(dev, obj_num,
+						       priv->nb_queue, NULL);
+			if (ret)
+				goto err;
+		}
+	}
+	if (action_flags & MLX5_FLOW_ACTION_CT) {
+		/* If no CT were previously allocated. */
+		if (!priv->hws_ctpool) {
+			obj_num = MLX5_CT_NT_MAX(priv);
+			ret = mlx5_flow_ct_init(dev, obj_num, priv->nb_queue);
+			if (ret)
+				goto err;
+		}
+	}
+	if (action_flags & MLX5_FLOW_ACTION_METER) {
+		/* If no meters were previously allocated. */
+		if (!priv->hws_mpool) {
+			obj_num = MLX5_MTR_NT_MAX(priv);
+			ret = mlx5_flow_meter_init(dev, obj_num, 0, 0,
+						   priv->nb_queue);
+			if (ret)
+				goto err;
 		}
 	}
 	return 0;
 err:
 	return rte_flow_error_set(error, ret,
-						RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
-						NULL, "fail to allocate actions");
+				  RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
+				  NULL, "fail to allocate actions");
 }
 
 /* TODO: remove dev if not used */
@@ -12861,7 +12849,7 @@ flow_hw_create_flow(struct rte_eth_dev *dev, enum mlx5_flow_type type,
 	 * The output actions bit mask instead of
 	 * looping on the actions array twice.
 	 */
-	ret = flow_hw_ensure_action_pools_allocated(dev, actions, error);
+	ret = flow_hw_allocate_actions(dev, action_flags, error);
 	if (ret)
 		goto error;
 
-- 
2.25.1



More information about the dev mailing list