Conor McCarthy : vkd3d: Replace the signaled semaphore list with a resizable array.
Alexandre Julliard
julliard at winehq.org
Mon May 2 15:34:30 CDT 2022
Module: vkd3d
Branch: master
Commit: 07e38212ec950d91d59fc5f3220d05314c470c49
URL: https://source.winehq.org/git/vkd3d.git/?a=commit;h=07e38212ec950d91d59fc5f3220d05314c470c49
Author: Conor McCarthy <cmccarthy at codeweavers.com>
Date: Fri Apr 29 23:21:09 2022 +1000
vkd3d: Replace the signaled semaphore list with a resizable array.
Order does not need to be preserved here, and another function will add
to this array when mapped timeline semaphores are implemented.
Signed-off-by: Conor McCarthy <cmccarthy at codeweavers.com>
Signed-off-by: Henri Verbeet <hverbeet at codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard at winehq.org>
---
libs/vkd3d/command.c | 44 +++++++++++++++++++++++++++-----------------
libs/vkd3d/vkd3d_private.h | 4 ++--
2 files changed, 29 insertions(+), 19 deletions(-)
diff --git a/libs/vkd3d/command.c b/libs/vkd3d/command.c
index 7690760c..55e6be58 100644
--- a/libs/vkd3d/command.c
+++ b/libs/vkd3d/command.c
@@ -590,32 +590,34 @@ static void d3d12_fence_garbage_collect_vk_semaphores_locked(struct d3d12_fence
{
struct d3d12_device *device = fence->device;
const struct vkd3d_vk_device_procs *vk_procs = &device->vk_procs;
- struct vkd3d_signaled_semaphore *current, *p;
- unsigned int semaphore_count;
+ struct vkd3d_signaled_semaphore *current;
+ unsigned int i, semaphore_count;
semaphore_count = fence->semaphore_count;
if (!destroy_all && semaphore_count < VKD3D_MAX_VK_SYNC_OBJECTS)
return;
- LIST_FOR_EACH_ENTRY_SAFE(current, p, &fence->semaphores, struct vkd3d_signaled_semaphore, entry)
+ i = 0;
+ while (i < fence->semaphore_count)
{
if (!destroy_all && fence->semaphore_count < VKD3D_MAX_VK_SYNC_OBJECTS)
break;
+ current = &fence->semaphores[i];
/* The semaphore doesn't have a pending signal operation if the fence
* was signaled. */
if ((current->vk_fence || current->is_acquired) && !destroy_all)
+ {
+ ++i;
continue;
+ }
if (current->vk_fence)
WARN("Destroying potentially pending semaphore.\n");
assert(!current->is_acquired);
VK_CALL(vkDestroySemaphore(device->vk_device, current->vk_semaphore, NULL));
- list_remove(¤t->entry);
- vkd3d_free(current);
-
- --fence->semaphore_count;
+ fence->semaphores[i] = fence->semaphores[--fence->semaphore_count];
}
if (semaphore_count != fence->semaphore_count)
@@ -656,6 +658,7 @@ static struct vkd3d_signaled_semaphore *d3d12_fence_acquire_vk_semaphore(struct
struct vkd3d_signaled_semaphore *semaphore;
struct vkd3d_signaled_semaphore *current;
uint64_t semaphore_value;
+ unsigned int i;
int rc;
TRACE("fence %p, value %#"PRIx64".\n", fence, value);
@@ -669,8 +672,9 @@ static struct vkd3d_signaled_semaphore *d3d12_fence_acquire_vk_semaphore(struct
semaphore = NULL;
semaphore_value = ~(uint64_t)0;
- LIST_FOR_EACH_ENTRY(current, &fence->semaphores, struct vkd3d_signaled_semaphore, entry)
+ for (i = 0; i < fence->semaphore_count; ++i)
{
+ current = &fence->semaphores[i];
/* Prefer a semaphore with the smallest value. */
if (!current->is_acquired && current->value >= value && semaphore_value >= current->value)
{
@@ -703,10 +707,7 @@ static void d3d12_fence_remove_vk_semaphore(struct d3d12_fence *fence, struct vk
assert(semaphore->is_acquired);
- list_remove(&semaphore->entry);
- vkd3d_free(semaphore);
-
- --fence->semaphore_count;
+ *semaphore = fence->semaphores[--fence->semaphore_count];
vkd3d_mutex_unlock(&fence->mutex);
}
@@ -751,14 +752,20 @@ static HRESULT d3d12_fence_add_vk_semaphore(struct d3d12_fence *fence,
d3d12_fence_garbage_collect_vk_semaphores_locked(fence, false);
+ if (!vkd3d_array_reserve((void**)&fence->semaphores, &fence->semaphores_size,
+ fence->semaphore_count + 1, sizeof(*fence->semaphores)))
+ {
+ ERR("Failed to add semaphore.\n");
+ vkd3d_mutex_unlock(&fence->mutex);
+ return false;
+ }
+
+ semaphore = &fence->semaphores[fence->semaphore_count++];
semaphore->value = value;
semaphore->vk_semaphore = vk_semaphore;
semaphore->vk_fence = vk_fence;
semaphore->is_acquired = false;
- list_add_tail(&fence->semaphores, &semaphore->entry);
- ++fence->semaphore_count;
-
vkd3d_mutex_unlock(&fence->mutex);
return hr;
@@ -821,8 +828,9 @@ static HRESULT d3d12_fence_signal(struct d3d12_fence *fence, uint64_t value, VkF
{
const struct vkd3d_vk_device_procs *vk_procs = &device->vk_procs;
- LIST_FOR_EACH_ENTRY(current, &fence->semaphores, struct vkd3d_signaled_semaphore, entry)
+ for (i = 0; i < fence->semaphore_count; ++i)
{
+ current = &fence->semaphores[i];
if (current->vk_fence == vk_fence)
current->vk_fence = VK_NULL_HANDLE;
}
@@ -910,6 +918,7 @@ static void d3d12_fence_decref(struct d3d12_fence *fence)
d3d12_fence_destroy_vk_objects(fence);
vkd3d_free(fence->events);
+ vkd3d_free(fence->semaphores);
if ((rc = vkd3d_mutex_destroy(&fence->mutex)))
ERR("Failed to destroy mutex, error %d.\n", rc);
vkd3d_cond_destroy(&fence->null_event_cond);
@@ -1278,7 +1287,8 @@ static HRESULT d3d12_fence_init(struct d3d12_fence *fence, struct d3d12_device *
fence->pending_timeline_value = initial_value;
fence->gpu_wait_count = 0;
- list_init(&fence->semaphores);
+ fence->semaphores = NULL;
+ fence->semaphores_size = 0;
fence->semaphore_count = 0;
memset(fence->old_vk_fences, 0, sizeof(fence->old_vk_fences));
diff --git a/libs/vkd3d/vkd3d_private.h b/libs/vkd3d/vkd3d_private.h
index 350382cd..4e03145d 100644
--- a/libs/vkd3d/vkd3d_private.h
+++ b/libs/vkd3d/vkd3d_private.h
@@ -501,7 +501,6 @@ HRESULT vkd3d_set_private_data_interface(struct vkd3d_private_store *store, cons
struct vkd3d_signaled_semaphore
{
- struct list entry;
uint64_t value;
VkSemaphore vk_semaphore;
VkFence vk_fence;
@@ -539,7 +538,8 @@ struct d3d12_fence
struct vkd3d_pending_fence_wait gpu_waits[VKD3D_MAX_FENCE_WAITING_QUEUES];
unsigned int gpu_wait_count;
- struct list semaphores;
+ struct vkd3d_signaled_semaphore *semaphores;
+ size_t semaphores_size;
unsigned int semaphore_count;
VkFence old_vk_fences[VKD3D_MAX_VK_SYNC_OBJECTS];
More information about the wine-cvs
mailing list