diff options
-rw-r--r-- | src/gallium/auxiliary/util/u_queue.c | 42 | ||||
-rw-r--r-- | src/gallium/auxiliary/util/u_queue.h | 2 | ||||
-rw-r--r-- | src/gallium/drivers/freedreno/freedreno_batch.c | 2 | ||||
-rw-r--r-- | src/gallium/drivers/radeonsi/si_state_shaders.c | 6 | ||||
-rw-r--r-- | src/gallium/winsys/amdgpu/drm/amdgpu_cs.c | 2 | ||||
-rw-r--r-- | src/gallium/winsys/radeon/drm/radeon_drm_cs.c | 2 |
6 files changed, 30 insertions, 26 deletions
diff --git a/src/gallium/auxiliary/util/u_queue.c b/src/gallium/auxiliary/util/u_queue.c index 52cfc0a4bf2..386dc4a9946 100644 --- a/src/gallium/auxiliary/util/u_queue.c +++ b/src/gallium/auxiliary/util/u_queue.c @@ -88,7 +88,7 @@ remove_from_atexit_list(struct util_queue *queue) } /**************************************************************************** - * util_queue implementation + * util_queue_fence */ static void @@ -101,7 +101,7 @@ util_queue_fence_signal(struct util_queue_fence *fence) } void -util_queue_job_wait(struct util_queue_fence *fence) +util_queue_fence_wait(struct util_queue_fence *fence) { pipe_mutex_lock(fence->mutex); while (!fence->signalled) @@ -109,6 +109,27 @@ util_queue_job_wait(struct util_queue_fence *fence) pipe_mutex_unlock(fence->mutex); } +void +util_queue_fence_init(struct util_queue_fence *fence) +{ + memset(fence, 0, sizeof(*fence)); + pipe_mutex_init(fence->mutex); + pipe_condvar_init(fence->cond); + fence->signalled = true; +} + +void +util_queue_fence_destroy(struct util_queue_fence *fence) +{ + assert(fence->signalled); + pipe_condvar_destroy(fence->cond); + pipe_mutex_destroy(fence->mutex); +} + +/**************************************************************************** + * util_queue implementation + */ + struct thread_input { struct util_queue *queue; int thread_index; @@ -267,23 +288,6 @@ util_queue_destroy(struct util_queue *queue) } void -util_queue_fence_init(struct util_queue_fence *fence) -{ - memset(fence, 0, sizeof(*fence)); - pipe_mutex_init(fence->mutex); - pipe_condvar_init(fence->cond); - fence->signalled = true; -} - -void -util_queue_fence_destroy(struct util_queue_fence *fence) -{ - assert(fence->signalled); - pipe_condvar_destroy(fence->cond); - pipe_mutex_destroy(fence->mutex); -} - -void util_queue_add_job(struct util_queue *queue, void *job, struct util_queue_fence *fence, diff --git a/src/gallium/auxiliary/util/u_queue.h b/src/gallium/auxiliary/util/u_queue.h index 335813f63c1..2e0a5a36e26 100644 --- a/src/gallium/auxiliary/util/u_queue.h +++ b/src/gallium/auxiliary/util/u_queue.h @@ -87,7 +87,7 @@ void util_queue_add_job(struct util_queue *queue, util_queue_execute_func execute, util_queue_execute_func cleanup); -void util_queue_job_wait(struct util_queue_fence *fence); +void util_queue_fence_wait(struct util_queue_fence *fence); int64_t util_queue_get_thread_time_nano(struct util_queue *queue, unsigned thread_index); diff --git a/src/gallium/drivers/freedreno/freedreno_batch.c b/src/gallium/drivers/freedreno/freedreno_batch.c index f5a5c6a3cc9..c6dcf11aca5 100644 --- a/src/gallium/drivers/freedreno/freedreno_batch.c +++ b/src/gallium/drivers/freedreno/freedreno_batch.c @@ -230,7 +230,7 @@ fd_batch_sync(struct fd_batch *batch) { if (!batch->ctx->screen->reorder) return; - util_queue_job_wait(&batch->flush_fence); + util_queue_fence_wait(&batch->flush_fence); } static void diff --git a/src/gallium/drivers/radeonsi/si_state_shaders.c b/src/gallium/drivers/radeonsi/si_state_shaders.c index 0e85c129437..f615aa84471 100644 --- a/src/gallium/drivers/radeonsi/si_state_shaders.c +++ b/src/gallium/drivers/radeonsi/si_state_shaders.c @@ -1200,7 +1200,7 @@ again: * in a compiler thread. */ if (thread_index < 0) - util_queue_job_wait(&sel->ready); + util_queue_fence_wait(&sel->ready); pipe_mutex_lock(sel->mutex); @@ -1832,7 +1832,7 @@ static void si_bind_ps_shader(struct pipe_context *ctx, void *state) static void si_delete_shader(struct si_context *sctx, struct si_shader *shader) { if (shader->is_optimized) { - util_queue_job_wait(&shader->optimized_ready); + util_queue_fence_wait(&shader->optimized_ready); util_queue_fence_destroy(&shader->optimized_ready); } @@ -1884,7 +1884,7 @@ static void si_delete_shader_selector(struct pipe_context *ctx, void *state) [PIPE_SHADER_FRAGMENT] = &sctx->ps_shader, }; - util_queue_job_wait(&sel->ready); + util_queue_fence_wait(&sel->ready); if (current_shader[sel->type]->cso == sel) { current_shader[sel->type]->cso = NULL; diff --git a/src/gallium/winsys/amdgpu/drm/amdgpu_cs.c b/src/gallium/winsys/amdgpu/drm/amdgpu_cs.c index 9d5b0bde877..01f38d56b83 100644 --- a/src/gallium/winsys/amdgpu/drm/amdgpu_cs.c +++ b/src/gallium/winsys/amdgpu/drm/amdgpu_cs.c @@ -1118,7 +1118,7 @@ void amdgpu_cs_sync_flush(struct radeon_winsys_cs *rcs) struct amdgpu_cs *cs = amdgpu_cs(rcs); /* Wait for any pending ioctl of this CS to complete. */ - util_queue_job_wait(&cs->flush_completed); + util_queue_fence_wait(&cs->flush_completed); } static int amdgpu_cs_flush(struct radeon_winsys_cs *rcs, diff --git a/src/gallium/winsys/radeon/drm/radeon_drm_cs.c b/src/gallium/winsys/radeon/drm/radeon_drm_cs.c index 8f9e8a60593..fb6a6bb8070 100644 --- a/src/gallium/winsys/radeon/drm/radeon_drm_cs.c +++ b/src/gallium/winsys/radeon/drm/radeon_drm_cs.c @@ -486,7 +486,7 @@ void radeon_drm_cs_sync_flush(struct radeon_winsys_cs *rcs) /* Wait for any pending ioctl of this CS to complete. */ if (util_queue_is_initialized(&cs->ws->cs_queue)) - util_queue_job_wait(&cs->flush_completed); + util_queue_fence_wait(&cs->flush_completed); } /* Add the given fence to a slab buffer fence list. |