[PATCH 7/9] drm/amdkfd: Clean up process queue management

Oded Gabbay oded.gabbay at gmail.com
Sun Oct 8 12:37:03 UTC 2017


On Wed, Sep 27, 2017 at 7:09 AM, Felix Kuehling <Felix.Kuehling at amd.com> wrote:
> Removed unused num_concurrent_processes.
>
> Implemented counting of queues in QPD. This makes counting the queue
> list repeatedly in several places unnecessary.
>
> Signed-off-by: Felix Kuehling <Felix.Kuehling at amd.com>
> ---
>  drivers/gpu/drm/amd/amdkfd/kfd_device_queue_manager.c  | 5 +++++
>  drivers/gpu/drm/amd/amdkfd/kfd_packet_manager.c        | 7 +------
>  drivers/gpu/drm/amd/amdkfd/kfd_priv.h                  | 1 -
>  drivers/gpu/drm/amd/amdkfd/kfd_process_queue_manager.c | 9 ++-------
>  4 files changed, 8 insertions(+), 14 deletions(-)
>
> diff --git a/drivers/gpu/drm/amd/amdkfd/kfd_device_queue_manager.c b/drivers/gpu/drm/amd/amdkfd/kfd_device_queue_manager.c
> index d0e7288..a7455db 100644
> --- a/drivers/gpu/drm/amd/amdkfd/kfd_device_queue_manager.c
> +++ b/drivers/gpu/drm/amd/amdkfd/kfd_device_queue_manager.c
> @@ -188,6 +188,7 @@ static int create_queue_nocpsch(struct device_queue_manager *dqm,
>         }
>
>         list_add(&q->list, &qpd->queues_list);
> +       qpd->queue_count++;
>         if (q->properties.is_active)
>                 dqm->queue_count++;
>
> @@ -346,6 +347,7 @@ static int destroy_queue_nocpsch_locked(struct device_queue_manager *dqm,
>
>                 deallocate_vmid(dqm, qpd, q);
>         }
> +       qpd->queue_count--;
>         if (q->properties.is_active)
>                 dqm->queue_count--;
>
> @@ -855,6 +857,7 @@ static int create_queue_cpsch(struct device_queue_manager *dqm, struct queue *q,
>                 goto out;
>
>         list_add(&q->list, &qpd->queues_list);
> +       qpd->queue_count++;
>         if (q->properties.is_active) {
>                 dqm->queue_count++;
>                 retval = execute_queues_cpsch(dqm, false);
> @@ -1016,6 +1019,7 @@ static int destroy_queue_cpsch(struct device_queue_manager *dqm,
>                 dqm->sdma_queue_count--;
>
>         list_del(&q->list);
> +       qpd->queue_count--;
>         if (q->properties.is_active)
>                 dqm->queue_count--;
>
> @@ -1204,6 +1208,7 @@ static int process_termination_cpsch(struct device_queue_manager *dqm,
>                         goto out;
>                 }
>                 list_del(&q->list);
> +               qpd->queue_count--;
>                 mqd->uninit_mqd(mqd, q->mqd, q->mqd_mem_obj);
>         }
>
> diff --git a/drivers/gpu/drm/amd/amdkfd/kfd_packet_manager.c b/drivers/gpu/drm/amd/amdkfd/kfd_packet_manager.c
> index e5a15ba..5d1770e 100644
> --- a/drivers/gpu/drm/amd/amdkfd/kfd_packet_manager.c
> +++ b/drivers/gpu/drm/amd/amdkfd/kfd_packet_manager.c
> @@ -140,8 +140,6 @@ static int pm_create_map_process(struct packet_manager *pm, uint32_t *buffer,
>                                 struct qcm_process_device *qpd)
>  {
>         struct pm4_mes_map_process *packet;
> -       struct queue *cur;
> -       uint32_t num_queues;
>
>         packet = (struct pm4_mes_map_process *)buffer;
>
> @@ -156,10 +154,7 @@ static int pm_create_map_process(struct packet_manager *pm, uint32_t *buffer,
>         packet->bitfields10.gds_size = qpd->gds_size;
>         packet->bitfields10.num_gws = qpd->num_gws;
>         packet->bitfields10.num_oac = qpd->num_oac;
> -       num_queues = 0;
> -       list_for_each_entry(cur, &qpd->queues_list, list)
> -               num_queues++;
> -       packet->bitfields10.num_queues = (qpd->is_debug) ? 0 : num_queues;
> +       packet->bitfields10.num_queues = (qpd->is_debug) ? 0 : qpd->queue_count;
>
>         packet->sh_mem_config = qpd->sh_mem_config;
>         packet->sh_mem_bases = qpd->sh_mem_bases;
> diff --git a/drivers/gpu/drm/amd/amdkfd/kfd_priv.h b/drivers/gpu/drm/amd/amdkfd/kfd_priv.h
> index ca37210..5b33ddd 100644
> --- a/drivers/gpu/drm/amd/amdkfd/kfd_priv.h
> +++ b/drivers/gpu/drm/amd/amdkfd/kfd_priv.h
> @@ -408,7 +408,6 @@ struct scheduling_resources {
>  struct process_queue_manager {
>         /* data */
>         struct kfd_process      *process;
> -       unsigned int            num_concurrent_processes;
>         struct list_head        queues;
>         unsigned long           *queue_slot_bitmap;
>  };
> diff --git a/drivers/gpu/drm/amd/amdkfd/kfd_process_queue_manager.c b/drivers/gpu/drm/amd/amdkfd/kfd_process_queue_manager.c
> index 63c569b..88ad178 100644
> --- a/drivers/gpu/drm/amd/amdkfd/kfd_process_queue_manager.c
> +++ b/drivers/gpu/drm/amd/amdkfd/kfd_process_queue_manager.c
> @@ -149,8 +149,6 @@ int pqm_create_queue(struct process_queue_manager *pqm,
>         struct queue *q;
>         struct process_queue_node *pqn;
>         struct kernel_queue *kq;
> -       int num_queues = 0;
> -       struct queue *cur;
>         enum kfd_queue_type type = properties->type;
>
>         q = NULL;
> @@ -168,11 +166,8 @@ int pqm_create_queue(struct process_queue_manager *pqm,
>          * If we are just about to create DIQ, the is_debug flag is not set yet
>          * Hence we also check the type as well
>          */
> -       if ((pdd->qpd.is_debug) ||
> -               (type == KFD_QUEUE_TYPE_DIQ)) {
> -               list_for_each_entry(cur, &pdd->qpd.queues_list, list)
> -                       num_queues++;
> -               if (num_queues >= dev->device_info->max_no_of_hqd/2)
> +       if ((pdd->qpd.is_debug) || (type == KFD_QUEUE_TYPE_DIQ)) {
> +               if (pdd->qpd.queue_count >= dev->device_info->max_no_of_hqd/2)
>                         return -ENOSPC;
>         }
>
> --
> 2.7.4
>
This patch is:
Reviewed-by: Oded Gabbay <oded.gabbay at gmail.com>


More information about the amd-gfx mailing list