This patch adds pedit_headers_action structure to store the result of
parsing tc pedit actions. Then, it calls alloc_tc_pedit_action() to
populate the mlx5e hardware intermediate representation once all actions
have been parsed.

This patch comes in preparation for the new flow_action infrastructure,
where each packet mangling comes in an separated action, ie. not packed
as in tc pedit.

Signed-off-by: Pablo Neira Ayuso <pa...@netfilter.org>
---
v5: rebase on top of net-next head.

 drivers/net/ethernet/mellanox/mlx5/core/en_tc.c | 81 ++++++++++++++++++-------
 1 file changed, 59 insertions(+), 22 deletions(-)

diff --git a/drivers/net/ethernet/mellanox/mlx5/core/en_tc.c 
b/drivers/net/ethernet/mellanox/mlx5/core/en_tc.c
index d2e6c6578b9c..1daaab91280f 100644
--- a/drivers/net/ethernet/mellanox/mlx5/core/en_tc.c
+++ b/drivers/net/ethernet/mellanox/mlx5/core/en_tc.c
@@ -1751,6 +1751,12 @@ struct pedit_headers {
        struct udphdr  udp;
 };
 
+struct pedit_headers_action {
+       struct pedit_headers    vals;
+       struct pedit_headers    masks;
+       u32                     pedits;
+};
+
 static int pedit_header_offsets[] = {
        [TCA_PEDIT_KEY_EX_HDR_TYPE_ETH] = offsetof(struct pedit_headers, eth),
        [TCA_PEDIT_KEY_EX_HDR_TYPE_IP4] = offsetof(struct pedit_headers, ip4),
@@ -1762,16 +1768,15 @@ static int pedit_header_offsets[] = {
 #define pedit_header(_ph, _htype) ((void *)(_ph) + 
pedit_header_offsets[_htype])
 
 static int set_pedit_val(u8 hdr_type, u32 mask, u32 val, u32 offset,
-                        struct pedit_headers *masks,
-                        struct pedit_headers *vals)
+                        struct pedit_headers_action *hdrs)
 {
        u32 *curr_pmask, *curr_pval;
 
        if (hdr_type >= __PEDIT_HDR_TYPE_MAX)
                goto out_err;
 
-       curr_pmask = (u32 *)(pedit_header(masks, hdr_type) + offset);
-       curr_pval  = (u32 *)(pedit_header(vals, hdr_type) + offset);
+       curr_pmask = (u32 *)(pedit_header(&hdrs->masks, hdr_type) + offset);
+       curr_pval  = (u32 *)(pedit_header(&hdrs->vals, hdr_type) + offset);
 
        if (*curr_pmask & mask)  /* disallow acting twice on the same location 
*/
                goto out_err;
@@ -1827,8 +1832,7 @@ static struct mlx5_fields fields[] = {
  * max from the SW pedit action. On success, it says how many HW actions were
  * actually parsed.
  */
-static int offload_pedit_fields(struct pedit_headers *masks,
-                               struct pedit_headers *vals,
+static int offload_pedit_fields(struct pedit_headers_action *hdrs,
                                struct mlx5e_tc_flow_parse_attr *parse_attr,
                                struct netlink_ext_ack *extack)
 {
@@ -1843,10 +1847,10 @@ static int offload_pedit_fields(struct pedit_headers 
*masks,
        __be16 mask_be16;
        void *action;
 
-       set_masks = &masks[TCA_PEDIT_KEY_EX_CMD_SET];
-       add_masks = &masks[TCA_PEDIT_KEY_EX_CMD_ADD];
-       set_vals = &vals[TCA_PEDIT_KEY_EX_CMD_SET];
-       add_vals = &vals[TCA_PEDIT_KEY_EX_CMD_ADD];
+       set_masks = &hdrs[TCA_PEDIT_KEY_EX_CMD_SET].masks;
+       add_masks = &hdrs[TCA_PEDIT_KEY_EX_CMD_ADD].masks;
+       set_vals = &hdrs[TCA_PEDIT_KEY_EX_CMD_SET].vals;
+       add_vals = &hdrs[TCA_PEDIT_KEY_EX_CMD_ADD].vals;
 
        action_size = MLX5_UN_SZ_BYTES(set_action_in_add_action_in_auto);
        action = parse_attr->mod_hdr_actions;
@@ -1942,12 +1946,14 @@ static int offload_pedit_fields(struct pedit_headers 
*masks,
 }
 
 static int alloc_mod_hdr_actions(struct mlx5e_priv *priv,
-                                const struct tc_action *a, int namespace,
+                                struct pedit_headers_action *hdrs,
+                                int namespace,
                                 struct mlx5e_tc_flow_parse_attr *parse_attr)
 {
        int nkeys, action_size, max_actions;
 
-       nkeys = tcf_pedit_nkeys(a);
+       nkeys = hdrs[TCA_PEDIT_KEY_EX_CMD_SET].pedits +
+               hdrs[TCA_PEDIT_KEY_EX_CMD_ADD].pedits;
        action_size = MLX5_UN_SZ_BYTES(set_action_in_add_action_in_auto);
 
        if (namespace == MLX5_FLOW_NAMESPACE_FDB) /* FDB offloading */
@@ -1971,18 +1977,15 @@ static const struct pedit_headers zero_masks = {};
 static int parse_tc_pedit_action(struct mlx5e_priv *priv,
                                 const struct tc_action *a, int namespace,
                                 struct mlx5e_tc_flow_parse_attr *parse_attr,
+                                struct pedit_headers_action *hdrs,
                                 struct netlink_ext_ack *extack)
 {
-       struct pedit_headers masks[__PEDIT_CMD_MAX], vals[__PEDIT_CMD_MAX], 
*cmd_masks;
        int nkeys, i, err = -EOPNOTSUPP;
        u32 mask, val, offset;
        u8 cmd, htype;
 
        nkeys = tcf_pedit_nkeys(a);
 
-       memset(masks, 0, sizeof(struct pedit_headers) * __PEDIT_CMD_MAX);
-       memset(vals,  0, sizeof(struct pedit_headers) * __PEDIT_CMD_MAX);
-
        for (i = 0; i < nkeys; i++) {
                htype = tcf_pedit_htype(a, i);
                cmd = tcf_pedit_cmd(a, i);
@@ -2003,21 +2006,37 @@ static int parse_tc_pedit_action(struct mlx5e_priv 
*priv,
                val = tcf_pedit_val(a, i);
                offset = tcf_pedit_offset(a, i);
 
-               err = set_pedit_val(htype, ~mask, val, offset, &masks[cmd], 
&vals[cmd]);
+               err = set_pedit_val(htype, ~mask, val, offset, &hdrs[cmd]);
                if (err)
                        goto out_err;
+
+               hdrs[cmd].pedits++;
        }
 
-       err = alloc_mod_hdr_actions(priv, a, namespace, parse_attr);
+       return 0;
+out_err:
+       return err;
+}
+
+static int alloc_tc_pedit_action(struct mlx5e_priv *priv, int namespace,
+                                struct mlx5e_tc_flow_parse_attr *parse_attr,
+                                struct pedit_headers_action *hdrs,
+                                struct netlink_ext_ack *extack)
+{
+       struct pedit_headers *cmd_masks;
+       int err;
+       u8 cmd;
+
+       err = alloc_mod_hdr_actions(priv, hdrs, namespace, parse_attr);
        if (err)
                goto out_err;
 
-       err = offload_pedit_fields(masks, vals, parse_attr, extack);
+       err = offload_pedit_fields(hdrs, parse_attr, extack);
        if (err < 0)
                goto out_dealloc_parsed_actions;
 
        for (cmd = 0; cmd < __PEDIT_CMD_MAX; cmd++) {
-               cmd_masks = &masks[cmd];
+               cmd_masks = &hdrs[cmd].masks;
                if (memcmp(cmd_masks, &zero_masks, sizeof(zero_masks))) {
                        NL_SET_ERR_MSG_MOD(extack,
                                           "attempt to offload an unsupported 
field");
@@ -2159,6 +2178,7 @@ static int parse_tc_nic_actions(struct mlx5e_priv *priv, 
struct tcf_exts *exts,
                                struct mlx5e_tc_flow *flow,
                                struct netlink_ext_ack *extack)
 {
+       struct pedit_headers_action hdrs[__PEDIT_CMD_MAX] = {};
        struct mlx5_nic_flow_attr *attr = flow->nic_attr;
        const struct tc_action *a;
        LIST_HEAD(actions);
@@ -2181,7 +2201,7 @@ static int parse_tc_nic_actions(struct mlx5e_priv *priv, 
struct tcf_exts *exts,
 
                if (is_tcf_pedit(a)) {
                        err = parse_tc_pedit_action(priv, a, 
MLX5_FLOW_NAMESPACE_KERNEL,
-                                                   parse_attr, extack);
+                                                   parse_attr, hdrs, extack);
                        if (err)
                                return err;
 
@@ -2235,6 +2255,14 @@ static int parse_tc_nic_actions(struct mlx5e_priv *priv, 
struct tcf_exts *exts,
                return -EINVAL;
        }
 
+       if (hdrs[TCA_PEDIT_KEY_EX_CMD_SET].pedits ||
+           hdrs[TCA_PEDIT_KEY_EX_CMD_ADD].pedits) {
+               err = alloc_tc_pedit_action(priv, MLX5_FLOW_NAMESPACE_KERNEL,
+                                           parse_attr, hdrs, extack);
+               if (err)
+                       return err;
+       }
+
        attr->action = action;
        if (!actions_match_supported(priv, exts, parse_attr, flow, extack))
                return -EOPNOTSUPP;
@@ -2781,6 +2809,7 @@ static int parse_tc_fdb_actions(struct mlx5e_priv *priv, 
struct tcf_exts *exts,
                                struct mlx5e_tc_flow *flow,
                                struct netlink_ext_ack *extack)
 {
+       struct pedit_headers_action hdrs[__PEDIT_CMD_MAX] = {};
        struct mlx5_eswitch *esw = priv->mdev->priv.eswitch;
        struct mlx5_esw_flow_attr *attr = flow->esw_attr;
        struct mlx5e_rep_priv *rpriv = priv->ppriv;
@@ -2806,7 +2835,7 @@ static int parse_tc_fdb_actions(struct mlx5e_priv *priv, 
struct tcf_exts *exts,
 
                if (is_tcf_pedit(a)) {
                        err = parse_tc_pedit_action(priv, a, 
MLX5_FLOW_NAMESPACE_FDB,
-                                                   parse_attr, extack);
+                                                   parse_attr, hdrs, extack);
                        if (err)
                                return err;
 
@@ -2912,6 +2941,14 @@ static int parse_tc_fdb_actions(struct mlx5e_priv *priv, 
struct tcf_exts *exts,
                return -EINVAL;
        }
 
+       if (hdrs[TCA_PEDIT_KEY_EX_CMD_SET].pedits ||
+           hdrs[TCA_PEDIT_KEY_EX_CMD_ADD].pedits) {
+               err = alloc_tc_pedit_action(priv, MLX5_FLOW_NAMESPACE_KERNEL,
+                                           parse_attr, hdrs, extack);
+               if (err)
+                       return err;
+       }
+
        attr->action = action;
        if (!actions_match_supported(priv, exts, parse_attr, flow, extack))
                return -EOPNOTSUPP;
-- 
2.11.0

Reply via email to