RDMA/rxe: Remove references to ib_device and pool
authorBob Pearson <rpearsonhpe@gmail.com>
Mon, 25 Jan 2021 21:16:39 +0000 (15:16 -0600)
committerJason Gunthorpe <jgg@nvidia.com>
Thu, 28 Jan 2021 19:29:56 +0000 (15:29 -0400)
rxe_pool.c takes references to the pool and ib_device structs for each
object allocated and also keeps an atomic num_elem count in each
pool. This is more work than is needed. Pool allocation is only called
from verbs APIs which already have references to ib_device and pools are
only diasbled when the driver is removed so no protection of the pool
addresses are needed. The elem count is used to warn if elements are still
present in a pool when it is cleaned up which is useful.

This patch eliminates the references to the ib_device and pool structs.

Link: https://lore.kernel.org/r/20210125211641.2694-5-rpearson@hpe.com
Signed-off-by: Bob Pearson <rpearson@hpe.com>
Signed-off-by: Jason Gunthorpe <jgg@nvidia.com>
drivers/infiniband/sw/rxe/rxe_pool.c
drivers/infiniband/sw/rxe/rxe_pool.h

index 0ca46bd8be515a3a88bd595996a2e8a3dc26372d..5f85a90e5a5af0d29b45875ec81b07aec3760932 100644 (file)
@@ -142,8 +142,6 @@ int rxe_pool_init(
 
        atomic_set(&pool->num_elem, 0);
 
-       kref_init(&pool->ref_cnt);
-
        rwlock_init(&pool->pool_lock);
 
        if (rxe_type_info[type].flags & RXE_POOL_INDEX) {
@@ -165,19 +163,6 @@ out:
        return err;
 }
 
-static void rxe_pool_release(struct kref *kref)
-{
-       struct rxe_pool *pool = container_of(kref, struct rxe_pool, ref_cnt);
-
-       pool->state = RXE_POOL_STATE_INVALID;
-       kfree(pool->index.table);
-}
-
-static void rxe_pool_put(struct rxe_pool *pool)
-{
-       kref_put(&pool->ref_cnt, rxe_pool_release);
-}
-
 void rxe_pool_cleanup(struct rxe_pool *pool)
 {
        unsigned long flags;
@@ -189,7 +174,8 @@ void rxe_pool_cleanup(struct rxe_pool *pool)
                        pool_name(pool));
        write_unlock_irqrestore(&pool->pool_lock, flags);
 
-       rxe_pool_put(pool);
+       pool->state = RXE_POOL_STATE_INVALID;
+       kfree(pool->index.table);
 }
 
 static u32 alloc_index(struct rxe_pool *pool)
@@ -345,11 +331,6 @@ void *rxe_alloc_locked(struct rxe_pool *pool)
        if (pool->state != RXE_POOL_STATE_VALID)
                return NULL;
 
-       kref_get(&pool->ref_cnt);
-
-       if (!ib_device_try_get(&pool->rxe->ib_dev))
-               goto out_put_pool;
-
        if (atomic_inc_return(&pool->num_elem) > pool->max_elem)
                goto out_cnt;
 
@@ -366,9 +347,6 @@ void *rxe_alloc_locked(struct rxe_pool *pool)
 
 out_cnt:
        atomic_dec(&pool->num_elem);
-       ib_device_put(&pool->rxe->ib_dev);
-out_put_pool:
-       rxe_pool_put(pool);
        return NULL;
 }
 
@@ -385,12 +363,8 @@ void *rxe_alloc(struct rxe_pool *pool)
                return NULL;
        }
 
-       kref_get(&pool->ref_cnt);
        read_unlock_irqrestore(&pool->pool_lock, flags);
 
-       if (!ib_device_try_get(&pool->rxe->ib_dev))
-               goto out_put_pool;
-
        if (atomic_inc_return(&pool->num_elem) > pool->max_elem)
                goto out_cnt;
 
@@ -407,9 +381,6 @@ void *rxe_alloc(struct rxe_pool *pool)
 
 out_cnt:
        atomic_dec(&pool->num_elem);
-       ib_device_put(&pool->rxe->ib_dev);
-out_put_pool:
-       rxe_pool_put(pool);
        return NULL;
 }
 
@@ -422,12 +393,8 @@ int __rxe_add_to_pool(struct rxe_pool *pool, struct rxe_pool_entry *elem)
                read_unlock_irqrestore(&pool->pool_lock, flags);
                return -EINVAL;
        }
-       kref_get(&pool->ref_cnt);
        read_unlock_irqrestore(&pool->pool_lock, flags);
 
-       if (!ib_device_try_get(&pool->rxe->ib_dev))
-               goto out_put_pool;
-
        if (atomic_inc_return(&pool->num_elem) > pool->max_elem)
                goto out_cnt;
 
@@ -438,9 +405,6 @@ int __rxe_add_to_pool(struct rxe_pool *pool, struct rxe_pool_entry *elem)
 
 out_cnt:
        atomic_dec(&pool->num_elem);
-       ib_device_put(&pool->rxe->ib_dev);
-out_put_pool:
-       rxe_pool_put(pool);
        return -EINVAL;
 }
 
@@ -461,8 +425,6 @@ void rxe_elem_release(struct kref *kref)
        }
 
        atomic_dec(&pool->num_elem);
-       ib_device_put(&pool->rxe->ib_dev);
-       rxe_pool_put(pool);
 }
 
 void *rxe_pool_get_index(struct rxe_pool *pool, u32 index)
index 22714dafe00d07c11603942364c9fddf55af63a4..8f8de746ca1753cfebd65cec80cbbea2ddca96c9 100644 (file)
@@ -68,7 +68,6 @@ struct rxe_pool {
        struct rxe_dev          *rxe;
        rwlock_t                pool_lock; /* protects pool add/del/search */
        size_t                  elem_size;
-       struct kref             ref_cnt;
        void                    (*cleanup)(struct rxe_pool_entry *obj);
        enum rxe_pool_state     state;
        enum rxe_pool_flags     flags;