int retval;
struct mqd_manager *mqd_mgr;
+ retval = 0;
+
+ dqm_lock(dqm);
+
if (dqm->total_queue_count >= max_num_of_queues_per_device) {
pr_warn("Can't create new usermode queue because %d queues were already created\n",
dqm->total_queue_count);
retval = -EPERM;
- goto out;
+ goto out_unlock;
}
if (q->properties.type == KFD_QUEUE_TYPE_SDMA) {
retval = allocate_sdma_queue(dqm, &q->sdma_id);
if (retval)
- goto out;
+ goto out_unlock;
q->properties.sdma_queue_id =
q->sdma_id / get_num_sdma_engines(dqm);
q->properties.sdma_engine_id =
if (retval)
goto out_deallocate_sdma_queue;
- /* Do init_mqd before dqm_lock(dqm) to avoid circular locking order:
- * lock(dqm) -> bo::reserve
- */
mqd_mgr = dqm->ops.get_mqd_manager(dqm,
get_mqd_type_from_queue_type(q->properties.type));
retval = -ENOMEM;
goto out_deallocate_doorbell;
}
-
/*
* Eviction state logic: we only mark active queues as evicted
* to avoid the overhead of restoring inactive queues later
q->properties.is_evicted = (q->properties.queue_size > 0 &&
q->properties.queue_percent > 0 &&
q->properties.queue_address != 0);
+
dqm->asic_ops.init_sdma_vm(dqm, q, qpd);
+
q->properties.tba_addr = qpd->tba_addr;
q->properties.tma_addr = qpd->tma_addr;
retval = mqd_mgr->init_mqd(mqd_mgr, &q->mqd, &q->mqd_mem_obj,
if (retval)
goto out_deallocate_doorbell;
- dqm_lock(dqm);
-
list_add(&q->list, &qpd->queues_list);
qpd->queue_count++;
if (q->properties.is_active) {
out_deallocate_sdma_queue:
if (q->properties.type == KFD_QUEUE_TYPE_SDMA)
deallocate_sdma_queue(dqm, q->sdma_id);
-out:
+out_unlock:
+ dqm_unlock(dqm);
+
return retval;
}
qpd->reset_wavefronts = true;
}
+ mqd_mgr->uninit_mqd(mqd_mgr, q->mqd, q->mqd_mem_obj);
+
/*
* Unconditionally decrement this counter, regardless of the queue's
* type
dqm_unlock(dqm);
- /* Do uninit_mqd after dqm_unlock(dqm) to avoid circular locking */
- mqd_mgr->uninit_mqd(mqd_mgr, q->mqd, q->mqd_mem_obj);
-
return retval;
failed:
qpd->reset_wavefronts = false;
}
- dqm_unlock(dqm);
-
- /* Lastly, free mqd resources.
- * Do uninit_mqd() after dqm_unlock to avoid circular locking.
- */
+ /* lastly, free mqd resources */
list_for_each_entry_safe(q, next, &qpd->queues_list, list) {
mqd_mgr = dqm->ops.get_mqd_manager(dqm,
get_mqd_type_from_queue_type(q->properties.type));
}
out:
+ dqm_unlock(dqm);
return retval;
}