net/mlx5e: Add an option to create a shared mapping

The shared mapping is identified by an id and type.

Signed-off-by: Roi Dayan <roid@nvidia.com>
Signed-off-by: Saeed Mahameed <saeedm@nvidia.com>

diff --git a/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.c b/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.c
index ea321e5287490d63f621e0e5165c4fdfa10e8392..4e72ca8070e2438d4ef5042bc237a26514a7ebc5 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.c
+++ b/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.c
@@ -5,11 +5,15 @@
 #include <linux/slab.h>
 #include <linux/xarray.h>
 #include <linux/hashtable.h>
+#include <linux/refcount.h>
 
 #include "mapping.h"
 
 #define MAPPING_GRACE_PERIOD 2000
 
+static LIST_HEAD(shared_ctx_list);
+static DEFINE_MUTEX(shared_ctx_lock);
+
 struct mapping_ctx {
        struct xarray xarray;
        DECLARE_HASHTABLE(ht, 8);
@@ -20,6 +24,10 @@ struct mapping_ctx {
        struct delayed_work dwork;
        struct list_head pending_list;
        spinlock_t pending_list_lock; /* Guards pending list */
+       u64 id;
+       u8 type;
+       struct list_head list;
+       refcount_t refcount;
 };
 
 struct mapping_item {
@@ -205,11 +213,48 @@ mapping_create(size_t data_size, u32 max_id, bool delayed_removal)
        mutex_init(&ctx->lock);
        xa_init_flags(&ctx->xarray, XA_FLAGS_ALLOC1);
 
+       refcount_set(&ctx->refcount, 1);
+       INIT_LIST_HEAD(&ctx->list);
+
+       return ctx;
+}
+
+struct mapping_ctx *
+mapping_create_for_id(u64 id, u8 type, size_t data_size, u32 max_id, bool delayed_removal)
+{
+       struct mapping_ctx *ctx;
+
+       mutex_lock(&shared_ctx_lock);
+       list_for_each_entry(ctx, &shared_ctx_list, list) {
+               if (ctx->id == id && ctx->type == type) {
+                       if (refcount_inc_not_zero(&ctx->refcount))
+                               goto unlock;
+                       break;
+               }
+       }
+
+       ctx = mapping_create(data_size, max_id, delayed_removal);
+       if (IS_ERR(ctx))
+               goto unlock;
+
+       ctx->id = id;
+       ctx->type = type;
+       list_add(&ctx->list, &shared_ctx_list);
+
+unlock:
+       mutex_unlock(&shared_ctx_lock);
        return ctx;
 }
 
 void mapping_destroy(struct mapping_ctx *ctx)
 {
+       if (!refcount_dec_and_test(&ctx->refcount))
+               return;
+
+       mutex_lock(&shared_ctx_lock);
+       list_del(&ctx->list);
+       mutex_unlock(&shared_ctx_lock);
+
        mapping_flush_work(ctx);
        xa_destroy(&ctx->xarray);
        mutex_destroy(&ctx->lock);

diff --git a/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.h b/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.h
index 285525cc5470389484365af3d97d596bf34dc0b4..4e2119f0f4c119ee7a670c5723d97ff7b863dc68 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.h
+++ b/drivers/net/ethernet/mellanox/mlx5/core/en/mapping.h
@@ -24,4 +24,9 @@ struct mapping_ctx *mapping_create(size_t data_size, u32 max_id,
                                   bool delayed_removal);
 void mapping_destroy(struct mapping_ctx *ctx);
 
+/* adds mapping with an id or get an existing mapping with the same id
+ */
+struct mapping_ctx *
+mapping_create_for_id(u64 id, u8 type, size_t data_size, u32 max_id, bool delayed_removal);
+
 #endif /* __MLX5_MAPPING_H__ */