Commit 04562694 authored by Vlad Dogaru's avatar Vlad Dogaru Committed by Jakub Kicinski
Browse files

net/mlx5: HWS, Add fullness tracking to pool

parent 43a2038c
Loading
Loading
Loading
Loading
+7 −0
Original line number Diff line number Diff line
@@ -324,6 +324,8 @@ int mlx5hws_pool_chunk_alloc(struct mlx5hws_pool *pool,

	mutex_lock(&pool->lock);
	ret = pool->p_get_chunk(pool, chunk);
	if (ret == 0)
		pool->available_elems -= 1 << chunk->order;
	mutex_unlock(&pool->lock);

	return ret;
@@ -334,6 +336,7 @@ void mlx5hws_pool_chunk_free(struct mlx5hws_pool *pool,
{
	mutex_lock(&pool->lock);
	pool->p_put_chunk(pool, chunk);
	pool->available_elems += 1 << chunk->order;
	mutex_unlock(&pool->lock);
}

@@ -360,6 +363,7 @@ mlx5hws_pool_create(struct mlx5hws_context *ctx, struct mlx5hws_pool_attr *pool_
		res_db_type = MLX5HWS_POOL_DB_TYPE_BITMAP;

	pool->alloc_log_sz = pool_attr->alloc_log_sz;
	pool->available_elems = 1 << pool_attr->alloc_log_sz;

	if (hws_pool_db_init(pool, res_db_type))
		goto free_pool;
@@ -377,6 +381,9 @@ void mlx5hws_pool_destroy(struct mlx5hws_pool *pool)
{
	mutex_destroy(&pool->lock);

	if (pool->available_elems != 1 << pool->alloc_log_sz)
		mlx5hws_err(pool->ctx, "Attempting to destroy non-empty pool\n");

	if (pool->resource)
		hws_pool_resource_free(pool);

+25 −0
Original line number Diff line number Diff line
@@ -71,6 +71,7 @@ struct mlx5hws_pool {
	enum mlx5hws_pool_flags flags;
	struct mutex lock; /* protect the pool */
	size_t alloc_log_sz;
	size_t available_elems;
	enum mlx5hws_table_type tbl_type;
	enum mlx5hws_pool_optimize opt_type;
	struct mlx5hws_pool_resource *resource;
@@ -103,4 +104,28 @@ static inline u32 mlx5hws_pool_get_base_mirror_id(struct mlx5hws_pool *pool)
{
	return pool->mirror_resource->base_id;
}

static inline bool
mlx5hws_pool_empty(struct mlx5hws_pool *pool)
{
	bool ret;

	mutex_lock(&pool->lock);
	ret = pool->available_elems == 0;
	mutex_unlock(&pool->lock);

	return ret;
}

static inline bool
mlx5hws_pool_full(struct mlx5hws_pool *pool)
{
	bool ret;

	mutex_lock(&pool->lock);
	ret = pool->available_elems == (1 << pool->alloc_log_sz);
	mutex_unlock(&pool->lock);

	return ret;
}
#endif /* MLX5HWS_POOL_H_ */