[PATCH v2 0/3] MR251: vkd3d: Fix a few resource leaks here and there

[Giovanni Mascellani (＠giomasce)]

--
  v2: vkd3d: Release op data when destroying the queue.
      vkd3d: Always emit an error when failing to reserve for the op array.
      vkd3d: Release the op mutex on allocation failure.

https://gitlab.winehq.org/wine/vkd3d/-/merge_requests/251

[PATCH v2 1/3] vkd3d: Release the op mutex on allocation failure.

[Giovanni Mascellani]

From: Giovanni Mascellani

---
 libs/vkd3d/command.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/libs/vkd3d/command.c b/libs/vkd3d/command.c
index 1fc6c00d..48c3111c 100644
--- a/libs/vkd3d/command.c
+++ b/libs/vkd3d/command.c
@@ -6412,7 +6412,7 @@ static void STDMETHODCALLTYPE d3d12_command_queue_ExecuteCommandLists(ID3D12Comm
     if (!(op = d3d12_command_queue_op_array_require_space(&command_queue->op_queue)))
     {
         ERR("Failed to add op.\n");
-        return;
+        goto done;
     }
     op->opcode = VKD3D_CS_OP_EXECUTE;
     op->u.execute.buffers = buffers;
@@ -6420,6 +6420,7 @@ static void STDMETHODCALLTYPE d3d12_command_queue_ExecuteCommandLists(ID3D12Comm

d3d12_command_queue_submit_locked(command_queue);

+done:
     vkd3d_mutex_unlock(&command_queue->op_mutex);
     return;
 }

[PATCH v2 2/3] vkd3d: Always emit an error when failing to reserve for the op array.

[Giovanni Mascellani]

From: Giovanni Mascellani

---
 libs/vkd3d/command.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/libs/vkd3d/command.c b/libs/vkd3d/command.c
index 48c3111c..2a4bbf5d 100644
--- a/libs/vkd3d/command.c
+++ b/libs/vkd3d/command.c
@@ -6488,6 +6488,7 @@ static HRESULT STDMETHODCALLTYPE d3d12_command_queue_Signal(ID3D12CommandQueue *

if (!(op = d3d12_command_queue_op_array_require_space(&command_queue->op_queue)))
     {
+        ERR("Failed to add op.\n");
         hr = E_OUTOFMEMORY;
         goto done;
     }
@@ -6826,6 +6827,7 @@ static HRESULT STDMETHODCALLTYPE d3d12_command_queue_Wait(ID3D12CommandQueue *if

if (!(op = d3d12_command_queue_op_array_require_space(&command_queue->op_queue)))
     {
+        ERR("Failed to add op.\n");
         hr = E_OUTOFMEMORY;
         goto done;
     }

[PATCH v2 3/3] vkd3d: Release op data when destroying the queue.

[Giovanni Mascellani]

From: Giovanni Mascellani

---
 libs/vkd3d/command.c | 29 +++++++++++++++++++++++++----
 1 file changed, 25 insertions(+), 4 deletions(-)

diff --git a/libs/vkd3d/command.c b/libs/vkd3d/command.c
index 2a4bbf5d..4c9da334 100644
--- a/libs/vkd3d/command.c
+++ b/libs/vkd3d/command.c
@@ -6064,8 +6064,31 @@ static ULONG STDMETHODCALLTYPE d3d12_command_queue_AddRef(ID3D12CommandQueue *if
     return refcount;
 }

+static void d3d12_command_queue_destroy_op(struct vkd3d_cs_op_data *op)
+{
+    switch (op->opcode)
+    {
+        case VKD3D_CS_OP_WAIT:
+            d3d12_fence_decref(op->u.wait.fence);
+            break;
+
+        case VKD3D_CS_OP_SIGNAL:
+            d3d12_fence_decref(op->u.signal.fence);
+            break;
+
+        case VKD3D_CS_OP_EXECUTE:
+            vkd3d_free(op->u.execute.buffers);
+            break;
+    }
+}
+
 static void d3d12_command_queue_op_array_destroy(struct d3d12_command_queue_op_array *array)
 {
+    unsigned int i;
+
+    for (i = 0; i < array->count; ++i)
+        d3d12_command_queue_destroy_op(&array->ops[i]);
+
     vkd3d_free(array->ops);
 }

@@ -6353,8 +6376,6 @@ static void d3d12_command_queue_execute(struct d3d12_command_queue *command_queu
         ERR("Failed to submit queue(s), vr %d.\n", vr);

vkd3d_queue_release(vkd3d_queue);
-
-    vkd3d_free(buffers);
 }

static void d3d12_command_queue_submit_locked(struct d3d12_command_queue *queue)
@@ -7064,12 +7085,10 @@ static HRESULT d3d12_command_queue_flush_ops_locked(struct d3d12_command_queue *
                         return d3d12_command_queue_fixup_after_flush_locked(queue);
                     }
                     d3d12_command_queue_wait_locked(queue, fence, op->u.wait.value);
-                    d3d12_fence_decref(fence);
                     break;

case VKD3D_CS_OP_SIGNAL:
                     d3d12_command_queue_signal(queue, op->u.signal.fence, op->u.signal.value);
-                    d3d12_fence_decref(op->u.signal.fence);
                     break;

case VKD3D_CS_OP_EXECUTE:
@@ -7089,6 +7108,8 @@ static HRESULT d3d12_command_queue_flush_ops_locked(struct d3d12_command_queue *
                     vkd3d_unreachable();
             }

+            d3d12_command_queue_destroy_op(op);
+
             *flushed_any |= true;
         }