amdgpu_job.c 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. /*
  2. * Copyright 2015 Advanced Micro Devices, Inc.
  3. *
  4. * Permission is hereby granted, free of charge, to any person obtaining a
  5. * copy of this software and associated documentation files (the "Software"),
  6. * to deal in the Software without restriction, including without limitation
  7. * the rights to use, copy, modify, merge, publish, distribute, sublicense,
  8. * and/or sell copies of the Software, and to permit persons to whom the
  9. * Software is furnished to do so, subject to the following conditions:
  10. *
  11. * The above copyright notice and this permission notice shall be included in
  12. * all copies or substantial portions of the Software.
  13. *
  14. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
  17. * THE COPYRIGHT HOLDER(S) OR AUTHOR(S) BE LIABLE FOR ANY CLAIM, DAMAGES OR
  18. * OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
  19. * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
  20. * OTHER DEALINGS IN THE SOFTWARE.
  21. *
  22. *
  23. */
  24. #include <linux/kthread.h>
  25. #include <linux/wait.h>
  26. #include <linux/sched.h>
  27. #include <drm/drmP.h>
  28. #include "amdgpu.h"
  29. #include "amdgpu_trace.h"
  30. int amdgpu_job_alloc(struct amdgpu_device *adev, unsigned num_ibs,
  31. struct amdgpu_job **job)
  32. {
  33. size_t size = sizeof(struct amdgpu_job);
  34. if (num_ibs == 0)
  35. return -EINVAL;
  36. size += sizeof(struct amdgpu_ib) * num_ibs;
  37. *job = kzalloc(size, GFP_KERNEL);
  38. if (!*job)
  39. return -ENOMEM;
  40. (*job)->adev = adev;
  41. (*job)->ibs = (void *)&(*job)[1];
  42. (*job)->num_ibs = num_ibs;
  43. amdgpu_sync_create(&(*job)->sync);
  44. return 0;
  45. }
  46. int amdgpu_job_alloc_with_ib(struct amdgpu_device *adev, unsigned size,
  47. struct amdgpu_job **job)
  48. {
  49. int r;
  50. r = amdgpu_job_alloc(adev, 1, job);
  51. if (r)
  52. return r;
  53. r = amdgpu_ib_get(adev, NULL, size, &(*job)->ibs[0]);
  54. if (r)
  55. kfree(*job);
  56. return r;
  57. }
  58. void amdgpu_job_free(struct amdgpu_job *job)
  59. {
  60. unsigned i;
  61. for (i = 0; i < job->num_ibs; ++i)
  62. amdgpu_sa_bo_free(job->adev, &job->ibs[i].sa_bo, job->ibs[job->num_ibs - 1].fence);
  63. fence_put(job->ibs[job->num_ibs - 1].fence);
  64. amdgpu_bo_unref(&job->uf.bo);
  65. amdgpu_sync_free(&job->sync);
  66. kfree(job);
  67. }
  68. int amdgpu_job_submit(struct amdgpu_job *job, struct amdgpu_ring *ring,
  69. struct amd_sched_entity *entity, void *owner,
  70. struct fence **f)
  71. {
  72. job->ring = ring;
  73. job->base.sched = &ring->sched;
  74. job->base.s_entity = entity;
  75. job->base.s_fence = amd_sched_fence_create(job->base.s_entity, owner);
  76. if (!job->base.s_fence)
  77. return -ENOMEM;
  78. *f = fence_get(&job->base.s_fence->base);
  79. job->owner = owner;
  80. amd_sched_entity_push_job(&job->base);
  81. return 0;
  82. }
  83. static struct fence *amdgpu_job_dependency(struct amd_sched_job *sched_job)
  84. {
  85. struct amdgpu_job *job = to_amdgpu_job(sched_job);
  86. struct amdgpu_vm *vm = job->ibs->vm;
  87. struct fence *fence = amdgpu_sync_get_fence(&job->sync);
  88. if (fence == NULL && vm && !job->ibs->vm_id) {
  89. struct amdgpu_ring *ring = job->ring;
  90. unsigned i, vm_id;
  91. uint64_t vm_pd_addr;
  92. int r;
  93. r = amdgpu_vm_grab_id(vm, ring, &job->sync,
  94. &job->base.s_fence->base,
  95. &vm_id, &vm_pd_addr);
  96. if (r)
  97. DRM_ERROR("Error getting VM ID (%d)\n", r);
  98. else {
  99. for (i = 0; i < job->num_ibs; ++i) {
  100. job->ibs[i].vm_id = vm_id;
  101. job->ibs[i].vm_pd_addr = vm_pd_addr;
  102. }
  103. }
  104. fence = amdgpu_sync_get_fence(&job->sync);
  105. }
  106. return fence;
  107. }
  108. static struct fence *amdgpu_job_run(struct amd_sched_job *sched_job)
  109. {
  110. struct fence *fence = NULL;
  111. struct amdgpu_job *job;
  112. int r;
  113. if (!sched_job) {
  114. DRM_ERROR("job is null\n");
  115. return NULL;
  116. }
  117. job = to_amdgpu_job(sched_job);
  118. r = amdgpu_sync_wait(&job->sync);
  119. if (r) {
  120. DRM_ERROR("failed to sync wait (%d)\n", r);
  121. return NULL;
  122. }
  123. trace_amdgpu_sched_run_job(job);
  124. r = amdgpu_ib_schedule(job->ring, job->num_ibs, job->ibs,
  125. job->sync.last_vm_update, &fence);
  126. if (r) {
  127. DRM_ERROR("Error scheduling IBs (%d)\n", r);
  128. goto err;
  129. }
  130. err:
  131. amdgpu_job_free(job);
  132. return fence;
  133. }
  134. struct amd_sched_backend_ops amdgpu_sched_ops = {
  135. .dependency = amdgpu_job_dependency,
  136. .run_job = amdgpu_job_run,
  137. };