Added consumed signal to RecordAndSubmitTask submission.

vsg-dev · Sep 13, 2024 · c8bfbc5 · c8bfbc5
1 parent 66ba870
commit c8bfbc5
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 4 deletions.
diff --git a/src/vsg/app/RecordAndSubmitTask.cpp b/src/vsg/app/RecordAndSubmitTask.cpp
@@ -84,7 +84,7 @@ VkResult RecordAndSubmitTask::submit(ref_ptr<FrameStamp> frameStamp)
 {
     CPU_INSTRUMENTATION_L1_NC(instrumentation, "RecordAndSubmitTask submit", COLOR_RECORD);
 
-    //info("RecordAndSubmitTask::submit()");
+    info("\nRecordAndSubmitTask::submit()");
 
     if (VkResult result = start(); result != VK_SUCCESS) return result;
 
@@ -96,6 +96,7 @@ VkResult RecordAndSubmitTask::submit(ref_ptr<FrameStamp> frameStamp)
             {
                 //info("    adding early transfer dataTransferredSemaphore ", transfer.dataTransferredSemaphore);
                 transientWaitSemaphores.push_back(transfer.dataTransferredSemaphore);
+                dataTransferred = true;
             }
         }
         else
@@ -153,7 +154,7 @@ VkResult RecordAndSubmitTask::finish(ref_ptr<RecordedCommandBuffers> recordedCom
 {
     CPU_INSTRUMENTATION_L1_NC(instrumentation, "RecordAndSubmitTask finish", COLOR_RECORD);
 
-    //info("RecordAndSubmitTask::finish()");
+    info("RecordAndSubmitTask::finish()");
 
     auto current_fence = fence();
 
@@ -167,6 +168,7 @@ VkResult RecordAndSubmitTask::finish(ref_ptr<RecordedCommandBuffers> recordedCom
             if (transfer.dataTransferredSemaphore)
             {
                 //info("    adding late transfer dataTransferredSemaphore ", transfer.dataTransferredSemaphore);
+                dataTransferred = true;
                 transientWaitSemaphores.push_back(transfer.dataTransferredSemaphore);
             }
         }
@@ -239,9 +241,15 @@ VkResult RecordAndSubmitTask::finish(ref_ptr<RecordedCommandBuffers> recordedCom
         vk_signalSemaphores.emplace_back(*semaphore);
         current_fence->dependentSemaphores().push_back(semaphore);
     }
-
     transientSignalSemaphores.clear();
 
+    if (dataTransferred)
+    {
+        vk_signalSemaphores.emplace_back(transferConsumerCompletedSemaphore->vk());
+    }
+
+
+
     VkSubmitInfo submitInfo = {};
     submitInfo.sType = VK_STRUCTURE_TYPE_SUBMIT_INFO;
 

diff --git a/src/vsg/app/TransferTask.cpp b/src/vsg/app/TransferTask.cpp
@@ -36,7 +36,7 @@ TransferTask::TransferTask(Device* in_device, uint32_t numBuffers) :
         _lateDataToCopy.frames.emplace_back(TransferBlock::create());
     }
 
-    // level = Logger::LOGGER_INFO;
+    level = Logger::LOGGER_INFO;
 }
 
 void TransferTask::advance()