Commit bc920fd4 authored by Felix Kuehling's avatar Felix Kuehling Committed by Oded Gabbay

drm/amdkfd: Clean up process queue management

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: default avatarFelix Kuehling <Felix.Kuehling@amd.com>
Reviewed-by: default avatarOded Gabbay <oded.gabbay@gmail.com>
Signed-off-by: default avatarOded Gabbay <oded.gabbay@gmail.com>
parent e6f791b1
...@@ -189,6 +189,7 @@ static int create_queue_nocpsch(struct device_queue_manager *dqm, ...@@ -189,6 +189,7 @@ static int create_queue_nocpsch(struct device_queue_manager *dqm,
} }
list_add(&q->list, &qpd->queues_list); list_add(&q->list, &qpd->queues_list);
qpd->queue_count++;
if (q->properties.is_active) if (q->properties.is_active)
dqm->queue_count++; dqm->queue_count++;
...@@ -347,6 +348,7 @@ static int destroy_queue_nocpsch_locked(struct device_queue_manager *dqm, ...@@ -347,6 +348,7 @@ static int destroy_queue_nocpsch_locked(struct device_queue_manager *dqm,
deallocate_vmid(dqm, qpd, q); deallocate_vmid(dqm, qpd, q);
} }
qpd->queue_count--;
if (q->properties.is_active) if (q->properties.is_active)
dqm->queue_count--; dqm->queue_count--;
...@@ -856,6 +858,7 @@ static int create_queue_cpsch(struct device_queue_manager *dqm, struct queue *q, ...@@ -856,6 +858,7 @@ static int create_queue_cpsch(struct device_queue_manager *dqm, struct queue *q,
goto out; goto out;
list_add(&q->list, &qpd->queues_list); list_add(&q->list, &qpd->queues_list);
qpd->queue_count++;
if (q->properties.is_active) { if (q->properties.is_active) {
dqm->queue_count++; dqm->queue_count++;
retval = execute_queues_cpsch(dqm, retval = execute_queues_cpsch(dqm,
...@@ -1014,6 +1017,7 @@ static int destroy_queue_cpsch(struct device_queue_manager *dqm, ...@@ -1014,6 +1017,7 @@ static int destroy_queue_cpsch(struct device_queue_manager *dqm,
dqm->sdma_queue_count--; dqm->sdma_queue_count--;
list_del(&q->list); list_del(&q->list);
qpd->queue_count--;
if (q->properties.is_active) if (q->properties.is_active)
dqm->queue_count--; dqm->queue_count--;
...@@ -1204,6 +1208,7 @@ static int process_termination_cpsch(struct device_queue_manager *dqm, ...@@ -1204,6 +1208,7 @@ static int process_termination_cpsch(struct device_queue_manager *dqm,
goto out; goto out;
} }
list_del(&q->list); list_del(&q->list);
qpd->queue_count--;
mqd->uninit_mqd(mqd, q->mqd, q->mqd_mem_obj); mqd->uninit_mqd(mqd, q->mqd, q->mqd_mem_obj);
} }
......
...@@ -140,8 +140,6 @@ static int pm_create_map_process(struct packet_manager *pm, uint32_t *buffer, ...@@ -140,8 +140,6 @@ static int pm_create_map_process(struct packet_manager *pm, uint32_t *buffer,
struct qcm_process_device *qpd) struct qcm_process_device *qpd)
{ {
struct pm4_mes_map_process *packet; struct pm4_mes_map_process *packet;
struct queue *cur;
uint32_t num_queues;
packet = (struct pm4_mes_map_process *)buffer; packet = (struct pm4_mes_map_process *)buffer;
...@@ -156,10 +154,7 @@ static int pm_create_map_process(struct packet_manager *pm, uint32_t *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.gds_size = qpd->gds_size;
packet->bitfields10.num_gws = qpd->num_gws; packet->bitfields10.num_gws = qpd->num_gws;
packet->bitfields10.num_oac = qpd->num_oac; packet->bitfields10.num_oac = qpd->num_oac;
num_queues = 0; packet->bitfields10.num_queues = (qpd->is_debug) ? 0 : qpd->queue_count;
list_for_each_entry(cur, &qpd->queues_list, list)
num_queues++;
packet->bitfields10.num_queues = (qpd->is_debug) ? 0 : num_queues;
packet->sh_mem_config = qpd->sh_mem_config; packet->sh_mem_config = qpd->sh_mem_config;
packet->sh_mem_bases = qpd->sh_mem_bases; packet->sh_mem_bases = qpd->sh_mem_bases;
......
...@@ -405,7 +405,6 @@ struct scheduling_resources { ...@@ -405,7 +405,6 @@ struct scheduling_resources {
struct process_queue_manager { struct process_queue_manager {
/* data */ /* data */
struct kfd_process *process; struct kfd_process *process;
unsigned int num_concurrent_processes;
struct list_head queues; struct list_head queues;
unsigned long *queue_slot_bitmap; unsigned long *queue_slot_bitmap;
}; };
......
...@@ -149,8 +149,6 @@ int pqm_create_queue(struct process_queue_manager *pqm, ...@@ -149,8 +149,6 @@ int pqm_create_queue(struct process_queue_manager *pqm,
struct queue *q; struct queue *q;
struct process_queue_node *pqn; struct process_queue_node *pqn;
struct kernel_queue *kq; struct kernel_queue *kq;
int num_queues = 0;
struct queue *cur;
enum kfd_queue_type type = properties->type; enum kfd_queue_type type = properties->type;
q = NULL; q = NULL;
...@@ -168,11 +166,8 @@ int pqm_create_queue(struct process_queue_manager *pqm, ...@@ -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 * If we are just about to create DIQ, the is_debug flag is not set yet
* Hence we also check the type as well * Hence we also check the type as well
*/ */
if ((pdd->qpd.is_debug) || if ((pdd->qpd.is_debug) || (type == KFD_QUEUE_TYPE_DIQ)) {
(type == KFD_QUEUE_TYPE_DIQ)) { if (pdd->qpd.queue_count >= dev->device_info->max_no_of_hqd/2)
list_for_each_entry(cur, &pdd->qpd.queues_list, list)
num_queues++;
if (num_queues >= dev->device_info->max_no_of_hqd/2)
return -ENOSPC; return -ENOSPC;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment