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>
This commit is contained in:
Roi Dayan 2021-08-03 16:19:52 -07:00 committed by Saeed Mahameed
parent d044425403
commit 5d5defd6b8
2 changed files with 50 additions and 0 deletions

View file

@ -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);

View file

@ -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__ */