net/mlx5: add Direct Verbs translate actions

In this commit we add the translation of flow actions.
Unlike the Verbs API actions are separeted from the items and are passed
to the API in array structure.
Since the target action like RSS require the QP information those
actions are handled both in the translate action and in the apply.

Signed-off-by: Ori Kam <orika@mellanox.com>
Acked-by: Yongseok Koh <yskoh@mellanox.com>

diff --git a/drivers/net/mlx5/mlx5_flow.h b/drivers/net/mlx5/mlx5_flow.h
index 1e4209a..9870805 100644 (file)
--- a/drivers/net/mlx5/mlx5_flow.h
+++ b/drivers/net/mlx5/mlx5_flow.h
@@ -138,6 +138,8 @@ struct mlx5_flow_dv_match_params {
        /**< Matcher value. This value is used as the mask or as a key. */
 };
 
+#define MLX5_DV_MAX_NUMBER_OF_ACTIONS 8
+
 /* Matcher structure. */
 struct mlx5_flow_dv_matcher {
        LIST_ENTRY(mlx5_flow_dv_matcher) next;
@@ -159,6 +161,11 @@ struct mlx5_flow_dv {
        struct mlx5_flow_dv_match_params value;
        /**< Holds the value that the packet is compared to. */
        struct ibv_flow *flow; /**< Installed flow. */
+#ifdef HAVE_IBV_FLOW_DV_SUPPORT
+       struct mlx5dv_flow_action_attr actions[MLX5_DV_MAX_NUMBER_OF_ACTIONS];
+       /**< Action list. */
+#endif
+       int actions_n; /**< number of actions. */
 };
 
 /* Verbs specification header. */

diff --git a/drivers/net/mlx5/mlx5_flow_dv.c b/drivers/net/mlx5/mlx5_flow_dv.c
index a49e627..f7007db 100644 (file)
--- a/drivers/net/mlx5/mlx5_flow_dv.c
+++ b/drivers/net/mlx5/mlx5_flow_dv.c
@@ -946,6 +946,65 @@ flow_dv_create_item(void *matcher, void *key,
        }
 }
 
+/**
+ * Store the requested actions in an array.
+ *
+ * @param[in] action
+ *   Flow action to translate.
+ * @param[in, out] dev_flow
+ *   Pointer to the mlx5_flow.
+ */
+static void
+flow_dv_create_action(const struct rte_flow_action *action,
+                     struct mlx5_flow *dev_flow)
+{
+       const struct rte_flow_action_queue *queue;
+       const struct rte_flow_action_rss *rss;
+       int actions_n = dev_flow->dv.actions_n;
+       struct rte_flow *flow = dev_flow->flow;
+
+       switch (action->type) {
+       case RTE_FLOW_ACTION_TYPE_VOID:
+               break;
+       case RTE_FLOW_ACTION_TYPE_FLAG:
+               dev_flow->dv.actions[actions_n].type = MLX5DV_FLOW_ACTION_TAG;
+               dev_flow->dv.actions[actions_n].tag_value =
+                       MLX5_FLOW_MARK_DEFAULT;
+               actions_n++;
+               break;
+       case RTE_FLOW_ACTION_TYPE_MARK:
+               dev_flow->dv.actions[actions_n].type = MLX5DV_FLOW_ACTION_TAG;
+               dev_flow->dv.actions[actions_n].tag_value =
+                       ((const struct rte_flow_action_mark *)
+                        (action->conf))->id;
+               actions_n++;
+               break;
+       case RTE_FLOW_ACTION_TYPE_DROP:
+               dev_flow->dv.actions[actions_n].type = MLX5DV_FLOW_ACTION_DROP;
+               flow->actions |= MLX5_FLOW_ACTION_DROP;
+               break;
+       case RTE_FLOW_ACTION_TYPE_QUEUE:
+               queue = action->conf;
+               flow->rss.queue_num = 1;
+               (*flow->queue)[0] = queue->index;
+               break;
+       case RTE_FLOW_ACTION_TYPE_RSS:
+               rss = action->conf;
+               if (flow->queue)
+                       memcpy((*flow->queue), rss->queue,
+                              rss->queue_num * sizeof(uint16_t));
+               flow->rss.queue_num = rss->queue_num;
+               memcpy(flow->key, rss->key, MLX5_RSS_HASH_KEY_LEN);
+               flow->rss.types = rss->types;
+               flow->rss.level = rss->level;
+               /* Added to array only in apply since we need the QP */
+               break;
+       default:
+               break;
+       }
+       dev_flow->dv.actions_n = actions_n;
+}
+
 static uint32_t matcher_zero[MLX5_ST_SZ_DW(fte_match_param)] = { 0 };
 
 #define HEADER_IS_ZERO(match_criteria, headers)                                     \
@@ -1109,6 +1168,8 @@ flow_dv_translate(struct rte_eth_dev *dev,
        matcher.egress = attr->egress;
        if (flow_dv_matcher_register(dev, &matcher, dev_flow, error))
                return -rte_errno;
+       for (; actions->type != RTE_FLOW_ACTION_TYPE_END; actions++)
+               flow_dv_create_action(actions, dev_flow);
        return 0;
 }