drm/amdkfd: Clean up process queue management
authorFelix Kuehling <Felix.Kuehling@amd.com>
Wed, 27 Sep 2017 04:09:54 +0000 (00:09 -0400)
committerOded Gabbay <oded.gabbay@gmail.com>
Wed, 27 Sep 2017 04:09:54 +0000 (00:09 -0400)
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@amd.com>
Reviewed-by: Oded Gabbay <oded.gabbay@gmail.com>
Signed-off-by: Oded Gabbay <oded.gabbay@gmail.com>
drivers/gpu/drm/amd/amdkfd/kfd_device_queue_manager.c
drivers/gpu/drm/amd/amdkfd/kfd_packet_manager.c
drivers/gpu/drm/amd/amdkfd/kfd_priv.h
drivers/gpu/drm/amd/amdkfd/kfd_process_queue_manager.c

index dd7e44593cfe3b3aa996e6841afd72b431b653d0..c0685cd64d12ce44eca2d78764e526fd5ac6f605 100644 (file)
@@ -189,6 +189,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++;
 
@@ -347,6 +348,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--;
 
@@ -856,6 +858,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,
@@ -1014,6 +1017,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);
        }
 
index e5a15babb4f364c3cf65fa6864714ab25696908d..5d1770e577e9dfe23d5398b7153452dc7d19499e 100644 (file)
@@ -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;
index 7f141730de41d55cae365dedea64dc3f91c80cec..7d86ec9790d35bb3da87f100ec7cecf167daed24 100644 (file)
@@ -405,7 +405,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;
 };
index 63c569b62cee1013098e9039ae05a68fe05f3f3d..88ad178bffb65596c1ccb27eb145a5c4028d7c8b 100644 (file)
@@ -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;
        }