mlxsw: core: Make counter index allocated inside the action append

So far, the caller of mlxsw_afa_block_append_counter needed to allocate
counter index by hand. Benefit from the previously introduced resource
infra and counter_index_get/put callbacks, and allocate the counter
index in place where it is needed, inside the action append function.

Signed-off-by: Jiri Pirko <jiri@mellanox.com>
Reviewed-by: Ido Schimmel <idosch@mellanox.com>
Signed-off-by: David S. Miller <davem@davemloft.net>

diff --git a/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.c b/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.c
index 18ee66aac266c2ab757dee4e3f75c4e9c4a8adbe..2e1a61c87c3952842d5f74bcf6918955ef6be3f6 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.c
+++ b/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.c
@@ -559,6 +559,53 @@ err_fwd_entry_get:
        return ERR_PTR(err);
 }
 
+struct mlxsw_afa_counter {
+       struct mlxsw_afa_resource resource;
+       u32 counter_index;
+};
+
+static void
+mlxsw_afa_counter_destroy(struct mlxsw_afa_block *block,
+                         struct mlxsw_afa_counter *counter)
+{
+       block->afa->ops->counter_index_put(block->afa->ops_priv,
+                                          counter->counter_index);
+       kfree(counter);
+}
+
+static void
+mlxsw_afa_counter_destructor(struct mlxsw_afa_block *block,
+                            struct mlxsw_afa_resource *resource)
+{
+       struct mlxsw_afa_counter *counter;
+
+       counter = container_of(resource, struct mlxsw_afa_counter, resource);
+       mlxsw_afa_counter_destroy(block, counter);
+}
+
+static struct mlxsw_afa_counter *
+mlxsw_afa_counter_create(struct mlxsw_afa_block *block)
+{
+       struct mlxsw_afa_counter *counter;
+       int err;
+
+       counter = kzalloc(sizeof(*counter), GFP_KERNEL);
+       if (!counter)
+               return ERR_PTR(-ENOMEM);
+
+       err = block->afa->ops->counter_index_get(block->afa->ops_priv,
+                                                &counter->counter_index);
+       if (err)
+               goto err_counter_index_get;
+       counter->resource.destructor = mlxsw_afa_counter_destructor;
+       mlxsw_afa_resource_add(block, &counter->resource);
+       return counter;
+
+err_counter_index_get:
+       kfree(counter);
+       return ERR_PTR(err);
+}
+
 #define MLXSW_AFA_ONE_ACTION_LEN 32
 #define MLXSW_AFA_PAYLOAD_OFFSET 4
 
@@ -876,11 +923,10 @@ mlxsw_afa_polcnt_pack(char *payload,
        mlxsw_afa_polcnt_counter_index_set(payload, counter_index);
 }
 
-int mlxsw_afa_block_append_counter(struct mlxsw_afa_block *block,
-                                  u32 counter_index)
+int mlxsw_afa_block_append_allocated_counter(struct mlxsw_afa_block *block,
+                                            u32 counter_index)
 {
-       char *act = mlxsw_afa_block_append_action(block,
-                                                 MLXSW_AFA_POLCNT_CODE,
+       char *act = mlxsw_afa_block_append_action(block, MLXSW_AFA_POLCNT_CODE,
                                                  MLXSW_AFA_POLCNT_SIZE);
        if (!act)
                return -ENOBUFS;
@@ -888,6 +934,32 @@ int mlxsw_afa_block_append_counter(struct mlxsw_afa_block *block,
                              counter_index);
        return 0;
 }
+EXPORT_SYMBOL(mlxsw_afa_block_append_allocated_counter);
+
+int mlxsw_afa_block_append_counter(struct mlxsw_afa_block *block,
+                                  u32 *p_counter_index)
+{
+       struct mlxsw_afa_counter *counter;
+       u32 counter_index;
+       int err;
+
+       counter = mlxsw_afa_counter_create(block);
+       if (IS_ERR(counter))
+               return PTR_ERR(counter);
+       counter_index = counter->counter_index;
+
+       err = mlxsw_afa_block_append_allocated_counter(block, counter_index);
+       if (err)
+               goto err_append_allocated_counter;
+
+       if (p_counter_index)
+               *p_counter_index = counter_index;
+       return 0;
+
+err_append_allocated_counter:
+       mlxsw_afa_counter_destroy(block, counter);
+       return err;
+}
 EXPORT_SYMBOL(mlxsw_afa_block_append_counter);
 
 /* Virtual Router and Forwarding Domain Action

diff --git a/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.h b/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.h
index 89f977996ae29c506cdc2c9b0554fc3c0782c4da..a48c3d10688c9f8b68ac320ca1c0035a9fa39dba 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.h
+++ b/drivers/net/ethernet/mellanox/mlxsw/core_acl_flex_actions.h
@@ -69,8 +69,10 @@ int mlxsw_afa_block_append_fwd(struct mlxsw_afa_block *block,
                               u8 local_port, bool in_port);
 int mlxsw_afa_block_append_vlan_modify(struct mlxsw_afa_block *block,
                                       u16 vid, u8 pcp, u8 et);
+int mlxsw_afa_block_append_allocated_counter(struct mlxsw_afa_block *block,
+                                            u32 counter_index);
 int mlxsw_afa_block_append_counter(struct mlxsw_afa_block *block,
-                                  u32 counter_index);
+                                  u32 *p_counter_index);
 int mlxsw_afa_block_append_fid_set(struct mlxsw_afa_block *block, u16 fid);
 int mlxsw_afa_block_append_mcrouter(struct mlxsw_afa_block *block,
                                    u16 expected_irif, u16 min_mtu,

diff --git a/drivers/net/ethernet/mellanox/mlxsw/spectrum.h b/drivers/net/ethernet/mellanox/mlxsw/spectrum.h
index 58ff79211c09e33e742462ce79891b0962f850bb..8a30e76c99a962442df5dbc7e6d2a84c780cbf8f 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlxsw/spectrum.h
+++ b/drivers/net/ethernet/mellanox/mlxsw/spectrum.h
@@ -457,7 +457,6 @@ struct mlxsw_sp_acl_rule_info {
        struct mlxsw_afk_element_values values;
        struct mlxsw_afa_block *act_block;
        unsigned int counter_index;
-       bool counter_valid;
 };
 
 enum mlxsw_sp_acl_profile {

diff --git a/drivers/net/ethernet/mellanox/mlxsw/spectrum_acl.c b/drivers/net/ethernet/mellanox/mlxsw/spectrum_acl.c
index 9439bfa4ecc29e2d18463d4cf6503ea895a3e522..fac7bf5054669821bbaa961f6f4a733a58e45a25 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlxsw/spectrum_acl.c
+++ b/drivers/net/ethernet/mellanox/mlxsw/spectrum_acl.c
@@ -462,27 +462,6 @@ u16 mlxsw_sp_acl_ruleset_group_id(struct mlxsw_sp_acl_ruleset *ruleset)
        return ops->ruleset_group_id(ruleset->priv);
 }
 
-static int
-mlxsw_sp_acl_rulei_counter_alloc(struct mlxsw_sp *mlxsw_sp,
-                                struct mlxsw_sp_acl_rule_info *rulei)
-{
-       int err;
-
-       err = mlxsw_sp_flow_counter_alloc(mlxsw_sp, &rulei->counter_index);
-       if (err)
-               return err;
-       rulei->counter_valid = true;
-       return 0;
-}
-
-static void
-mlxsw_sp_acl_rulei_counter_free(struct mlxsw_sp *mlxsw_sp,
-                               struct mlxsw_sp_acl_rule_info *rulei)
-{
-       rulei->counter_valid = false;
-       mlxsw_sp_flow_counter_free(mlxsw_sp, rulei->counter_index);
-}
-
 struct mlxsw_sp_acl_rule_info *
 mlxsw_sp_acl_rulei_create(struct mlxsw_sp_acl *acl)
 {
@@ -619,7 +598,7 @@ int mlxsw_sp_acl_rulei_act_count(struct mlxsw_sp *mlxsw_sp,
                                 struct mlxsw_sp_acl_rule_info *rulei)
 {
        return mlxsw_afa_block_append_counter(rulei->act_block,
-                                             rulei->counter_index);
+                                             &rulei->counter_index);
 }
 
 int mlxsw_sp_acl_rulei_act_fid_set(struct mlxsw_sp *mlxsw_sp,
@@ -653,13 +632,8 @@ mlxsw_sp_acl_rule_create(struct mlxsw_sp *mlxsw_sp,
                goto err_rulei_create;
        }
 
-       err = mlxsw_sp_acl_rulei_counter_alloc(mlxsw_sp, rule->rulei);
-       if (err)
-               goto err_counter_alloc;
        return rule;
 
-err_counter_alloc:
-       mlxsw_sp_acl_rulei_destroy(rule->rulei);
 err_rulei_create:
        kfree(rule);
 err_alloc:
@@ -672,7 +646,6 @@ void mlxsw_sp_acl_rule_destroy(struct mlxsw_sp *mlxsw_sp,
 {
        struct mlxsw_sp_acl_ruleset *ruleset = rule->ruleset;
 
-       mlxsw_sp_acl_rulei_counter_free(mlxsw_sp, rule->rulei);
        mlxsw_sp_acl_rulei_destroy(rule->rulei);
        kfree(rule);
        mlxsw_sp_acl_ruleset_ref_dec(mlxsw_sp, ruleset);

diff --git a/drivers/net/ethernet/mellanox/mlxsw/spectrum_mr_tcam.c b/drivers/net/ethernet/mellanox/mlxsw/spectrum_mr_tcam.c
index 34a0b632e5dd34038b8edb4fb3b31b58adb54f75..4c7f32d4288d472d3e76ad5378fc82b7abd7b256 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlxsw/spectrum_mr_tcam.c
+++ b/drivers/net/ethernet/mellanox/mlxsw/spectrum_mr_tcam.c
@@ -243,7 +243,8 @@ mlxsw_sp_mr_tcam_afa_block_create(struct mlxsw_sp *mlxsw_sp,
        if (!afa_block)
                return ERR_PTR(-ENOMEM);
 
-       err = mlxsw_afa_block_append_counter(afa_block, counter_index);
+       err = mlxsw_afa_block_append_allocated_counter(afa_block,
+                                                      counter_index);
        if (err)
                goto err;