On Mon, Sep 28, 2020 at 02:38:35PM -0700, Jacob Pan wrote:
> There can be multiple users of an IOASID, each user could have hardware
> contexts associated with the IOASID. In order to align lifecycles,
> reference counting is introduced in this patch. It is expected that when
> an IOASID is being freed, each user will drop a reference only after its
> context is cleared.
> 
> Signed-off-by: Jacob Pan <jacob.jun....@linux.intel.com>
> ---
>  drivers/iommu/ioasid.c | 117 
> +++++++++++++++++++++++++++++++++++++++++++++++++
>  include/linux/ioasid.h |  24 ++++++++++
>  2 files changed, 141 insertions(+)
> 
> diff --git a/drivers/iommu/ioasid.c b/drivers/iommu/ioasid.c
> index 9628e78b2ab4..828cc44b1b1c 100644
> --- a/drivers/iommu/ioasid.c
> +++ b/drivers/iommu/ioasid.c
> @@ -16,8 +16,26 @@ static ioasid_t ioasid_capacity = PCI_PASID_MAX;
>  static ioasid_t ioasid_capacity_avail = PCI_PASID_MAX;
>  static DEFINE_XARRAY_ALLOC(ioasid_sets);
>  
> +enum ioasid_state {
> +     IOASID_STATE_INACTIVE,
> +     IOASID_STATE_ACTIVE,
> +     IOASID_STATE_FREE_PENDING,
> +};
> +
> +/**
> + * struct ioasid_data - Meta data about ioasid
> + *
> + * @id:              Unique ID
> + * @users:   Number of active users
> + * @state:   Track state of the IOASID
> + * @set:     ioasid_set of the IOASID belongs to
> + * @private: Private data associated with the IOASID
> + * @rcu:     For free after RCU grace period
> + */
>  struct ioasid_data {
>       ioasid_t id;
> +     refcount_t users;
> +     enum ioasid_state state;
>       struct ioasid_set *set;
>       void *private;
>       struct rcu_head rcu;
> @@ -511,6 +529,8 @@ ioasid_t ioasid_alloc(struct ioasid_set *set, ioasid_t 
> min, ioasid_t max,
>               goto exit_free;
>       }
>       data->id = id;
> +     data->state = IOASID_STATE_ACTIVE;
> +     refcount_set(&data->users, 1);
>  
>       /* Store IOASID in the per set data */
>       if (xa_err(xa_store(&set->xa, id, data, GFP_ATOMIC))) {
> @@ -560,6 +580,14 @@ static void ioasid_free_locked(struct ioasid_set *set, 
> ioasid_t ioasid)
>       if (WARN_ON(!xa_load(&ioasid_sets, data->set->id)))
>               return;
>  
> +     /* Free is already in progress */
> +     if (data->state == IOASID_STATE_FREE_PENDING)
> +             return;

But the previous call to ioasid_free_locked() dropped a reference, then
returned because more refs where held. Shouldn't this call also
dec_and_test() the reference and call ioasid_do_free_locked() if
necessary?

> +
> +     data->state = IOASID_STATE_FREE_PENDING;
> +     if (!refcount_dec_and_test(&data->users))
> +             return;
> +
>       ioasid_do_free_locked(data);
>  }
>  
> @@ -717,6 +745,95 @@ void ioasid_set_for_each_ioasid(struct ioasid_set *set,
>  }
>  EXPORT_SYMBOL_GPL(ioasid_set_for_each_ioasid);
>  
> +int ioasid_get_locked(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     struct ioasid_data *data;
> +
> +     data = xa_load(&active_allocator->xa, ioasid);
> +     if (!data) {
> +             pr_err("Trying to get unknown IOASID %u\n", ioasid);
> +             return -EINVAL;
> +     }
> +     if (data->state == IOASID_STATE_FREE_PENDING) {
> +             pr_err("Trying to get IOASID being freed%u\n", ioasid);

Strange placement of the %u

> +             return -EBUSY;
> +     }
> +
> +     /* Check set ownership if the set is non-null */
> +     if (set && data->set != set) {
> +             pr_err("Trying to get IOASID %u outside the set\n", ioasid);
> +             /* data found but does not belong to the set */
> +             return -EACCES;
> +     }
> +     refcount_inc(&data->users);
> +
> +     return 0;
> +}
> +EXPORT_SYMBOL_GPL(ioasid_get_locked);

If this is a public facing let's add a lockdep_assert_held() to make sure
they do hold the right lock. Same for ioasid_put_locked().

Thanks,
Jean

> +
> +/**
> + * ioasid_get - Obtain a reference to an ioasid
> + * @set:     the ioasid_set to check permission against if not NULL
> + * @ioasid:  the ID to remove
> + *
> + *
> + * Return: 0 on success, error if failed.
> + */
> +int ioasid_get(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     int ret;
> +
> +     spin_lock(&ioasid_allocator_lock);
> +     ret = ioasid_get_locked(set, ioasid);
> +     spin_unlock(&ioasid_allocator_lock);
> +
> +     return ret;
> +}
> +EXPORT_SYMBOL_GPL(ioasid_get);
> +
> +bool ioasid_put_locked(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     struct ioasid_data *data;
> +
> +     data = xa_load(&active_allocator->xa, ioasid);
> +     if (!data) {
> +             pr_err("Trying to put unknown IOASID %u\n", ioasid);
> +             return false;
> +     }
> +     if (set && data->set != set) {
> +             pr_err("Trying to drop IOASID %u outside the set\n", ioasid);
> +             return false;
> +     }
> +     if (!refcount_dec_and_test(&data->users))
> +             return false;
> +
> +     ioasid_do_free_locked(data);
> +
> +     return true;
> +}
> +EXPORT_SYMBOL_GPL(ioasid_put_locked);
> +
> +/**
> + * ioasid_put - Release a reference to an ioasid
> + * @set:     the ioasid_set to check permission against if not NULL
> + * @ioasid:  the ID to remove
> + *
> + * Put a reference to the IOASID, free it when the number of references 
> drops to
> + * zero.
> + *
> + * Return: %true if the IOASID was freed, %false otherwise.
> + */
> +bool ioasid_put(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     bool ret;
> +
> +     spin_lock(&ioasid_allocator_lock);
> +     ret = ioasid_put_locked(set, ioasid);
> +     spin_unlock(&ioasid_allocator_lock);
> +     return ret;
> +}
> +EXPORT_SYMBOL_GPL(ioasid_put);
> +
>  /**
>   * ioasid_find - Find IOASID data
>   * @set: the IOASID set
> diff --git a/include/linux/ioasid.h b/include/linux/ioasid.h
> index aab58bc26714..16d421357173 100644
> --- a/include/linux/ioasid.h
> +++ b/include/linux/ioasid.h
> @@ -73,6 +73,10 @@ void *ioasid_find(struct ioasid_set *set, ioasid_t ioasid,
>                 bool (*getter)(void *));
>  int ioasid_register_allocator(struct ioasid_allocator_ops *allocator);
>  void ioasid_unregister_allocator(struct ioasid_allocator_ops *allocator);
> +int ioasid_get(struct ioasid_set *set, ioasid_t ioasid);
> +int ioasid_get_locked(struct ioasid_set *set, ioasid_t ioasid);
> +bool ioasid_put(struct ioasid_set *set, ioasid_t ioasid);
> +bool ioasid_put_locked(struct ioasid_set *set, ioasid_t ioasid);
>  int ioasid_attach_data(ioasid_t ioasid, void *data);
>  void ioasid_detach_data(ioasid_t ioasid);
>  void ioasid_set_for_each_ioasid(struct ioasid_set *sdata,
> @@ -112,6 +116,26 @@ static inline void ioasid_set_put(struct ioasid_set *set)
>  {
>  }
>  
> +static inline int ioasid_get(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     return -ENOTSUPP;
> +}
> +
> +static inline int ioasid_get_locked(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     return -ENOTSUPP;
> +}
> +
> +static inline bool ioasid_put(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     return false;
> +}
> +
> +static inline bool ioasid_put_locked(struct ioasid_set *set, ioasid_t ioasid)
> +{
> +     return false;
> +}
> +
>  static inline void *ioasid_find(struct ioasid_set *set, ioasid_t ioasid, 
> bool (*getter)(void *))
>  {
>       return NULL;
> -- 
> 2.7.4
> 
_______________________________________________
iommu mailing list
iommu@lists.linux-foundation.org
https://lists.linuxfoundation.org/mailman/listinfo/iommu

Reply via email to