RDMA/rxe: Remove unneeded pool->state

rxe_pool.c uses the field pool->state to mark a pool as invalid when it is
shut down and checks it in several pool APIs to verify that the pool has
not been shut down. This is unneeded because the pools are not marked
invalid unless the entire driver is being removed at which point no
functional APIs should or could be executing. This patch removes this
field and associated code.

Link: https://lore.kernel.org/r/20210125211641.2694-6-rpearson@hpe.com
Suggested-by: zyjzyj2000@gmail.c
Signed-off-by: Bob Pearson <rpearson@hpe.com>
Signed-off-by: Jason Gunthorpe <jgg@nvidia.com>
This commit is contained in:
Bob Pearson 2021-01-25 15:16:40 -06:00 коммит произвёл Jason Gunthorpe
Родитель 6cde3e8ec1
Коммит eae5f0642e
2 изменённых файлов: 1 добавлений и 43 удалений

Просмотреть файл

@ -157,24 +157,16 @@ int rxe_pool_init(
pool->key.key_size = rxe_type_info[type].key_size; pool->key.key_size = rxe_type_info[type].key_size;
} }
pool->state = RXE_POOL_STATE_VALID;
out: out:
return err; return err;
} }
void rxe_pool_cleanup(struct rxe_pool *pool) void rxe_pool_cleanup(struct rxe_pool *pool)
{ {
unsigned long flags;
write_lock_irqsave(&pool->pool_lock, flags);
pool->state = RXE_POOL_STATE_INVALID;
if (atomic_read(&pool->num_elem) > 0) if (atomic_read(&pool->num_elem) > 0)
pr_warn("%s pool destroyed with unfree'd elem\n", pr_warn("%s pool destroyed with unfree'd elem\n",
pool_name(pool)); pool_name(pool));
write_unlock_irqrestore(&pool->pool_lock, flags);
pool->state = RXE_POOL_STATE_INVALID;
kfree(pool->index.table); kfree(pool->index.table);
} }
@ -328,9 +320,6 @@ void *rxe_alloc_locked(struct rxe_pool *pool)
struct rxe_pool_entry *elem; struct rxe_pool_entry *elem;
u8 *obj; u8 *obj;
if (pool->state != RXE_POOL_STATE_VALID)
return NULL;
if (atomic_inc_return(&pool->num_elem) > pool->max_elem) if (atomic_inc_return(&pool->num_elem) > pool->max_elem)
goto out_cnt; goto out_cnt;
@ -352,19 +341,10 @@ out_cnt:
void *rxe_alloc(struct rxe_pool *pool) void *rxe_alloc(struct rxe_pool *pool)
{ {
unsigned long flags;
struct rxe_type_info *info = &rxe_type_info[pool->type]; struct rxe_type_info *info = &rxe_type_info[pool->type];
struct rxe_pool_entry *elem; struct rxe_pool_entry *elem;
u8 *obj; u8 *obj;
read_lock_irqsave(&pool->pool_lock, flags);
if (pool->state != RXE_POOL_STATE_VALID) {
read_unlock_irqrestore(&pool->pool_lock, flags);
return NULL;
}
read_unlock_irqrestore(&pool->pool_lock, flags);
if (atomic_inc_return(&pool->num_elem) > pool->max_elem) if (atomic_inc_return(&pool->num_elem) > pool->max_elem)
goto out_cnt; goto out_cnt;
@ -386,15 +366,6 @@ out_cnt:
int __rxe_add_to_pool(struct rxe_pool *pool, struct rxe_pool_entry *elem) int __rxe_add_to_pool(struct rxe_pool *pool, struct rxe_pool_entry *elem)
{ {
unsigned long flags;
read_lock_irqsave(&pool->pool_lock, flags);
if (pool->state != RXE_POOL_STATE_VALID) {
read_unlock_irqrestore(&pool->pool_lock, flags);
return -EINVAL;
}
read_unlock_irqrestore(&pool->pool_lock, flags);
if (atomic_inc_return(&pool->num_elem) > pool->max_elem) if (atomic_inc_return(&pool->num_elem) > pool->max_elem)
goto out_cnt; goto out_cnt;
@ -437,9 +408,6 @@ void *rxe_pool_get_index(struct rxe_pool *pool, u32 index)
read_lock_irqsave(&pool->pool_lock, flags); read_lock_irqsave(&pool->pool_lock, flags);
if (pool->state != RXE_POOL_STATE_VALID)
goto out;
node = pool->index.tree.rb_node; node = pool->index.tree.rb_node;
while (node) { while (node) {
@ -460,8 +428,8 @@ void *rxe_pool_get_index(struct rxe_pool *pool, u32 index)
obj = NULL; obj = NULL;
} }
out:
read_unlock_irqrestore(&pool->pool_lock, flags); read_unlock_irqrestore(&pool->pool_lock, flags);
return obj; return obj;
} }
@ -473,9 +441,6 @@ void *rxe_pool_get_key_locked(struct rxe_pool *pool, void *key)
u8 *obj = NULL; u8 *obj = NULL;
int cmp; int cmp;
if (pool->state != RXE_POOL_STATE_VALID)
goto out;
node = pool->key.tree.rb_node; node = pool->key.tree.rb_node;
while (node) { while (node) {
@ -499,7 +464,6 @@ void *rxe_pool_get_key_locked(struct rxe_pool *pool, void *key)
obj = NULL; obj = NULL;
} }
out:
return obj; return obj;
} }

Просмотреть файл

@ -46,11 +46,6 @@ struct rxe_type_info {
extern struct rxe_type_info rxe_type_info[]; extern struct rxe_type_info rxe_type_info[];
enum rxe_pool_state {
RXE_POOL_STATE_INVALID,
RXE_POOL_STATE_VALID,
};
struct rxe_pool_entry { struct rxe_pool_entry {
struct rxe_pool *pool; struct rxe_pool *pool;
struct kref ref_cnt; struct kref ref_cnt;
@ -69,7 +64,6 @@ struct rxe_pool {
rwlock_t pool_lock; /* protects pool add/del/search */ rwlock_t pool_lock; /* protects pool add/del/search */
size_t elem_size; size_t elem_size;
void (*cleanup)(struct rxe_pool_entry *obj); void (*cleanup)(struct rxe_pool_entry *obj);
enum rxe_pool_state state;
enum rxe_pool_flags flags; enum rxe_pool_flags flags;
enum rxe_elem_type type; enum rxe_elem_type type;