From 312d8736ae0df55c9f33e4eb5c00e4cd77e1c33f Mon Sep 17 00:00:00 2001 From: Nicolas James Date: Mon, 6 Apr 2026 17:03:35 +1000 Subject: Add refactored VK_NV_low_latency2 impl, (fixes many threading issues) --- src/strategies/low_latency2/swapchain_monitor.hh | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'src/strategies/low_latency2/swapchain_monitor.hh') diff --git a/src/strategies/low_latency2/swapchain_monitor.hh b/src/strategies/low_latency2/swapchain_monitor.hh index 9031bbb..47c3a75 100644 --- a/src/strategies/low_latency2/swapchain_monitor.hh +++ b/src/strategies/low_latency2/swapchain_monitor.hh @@ -27,13 +27,14 @@ class SwapchainMonitor final { void signal(const DeviceContext& device) const; }; - std::unique_ptr> pending_submissions{}; + // An empty vector here represents our 'no work' state. + std::vector>> pending_submissions{}; // A pairing of semaphore -> submissions. // If the Submissions completes then signal the bundled semaphore. struct SemaphoreSubmissions { WakeupSemaphore wakeup_semaphore{}; - std::unique_ptr> submissions{}; + std::vector>> submissions{}; }; std::optional semaphore_submission{}; @@ -47,6 +48,8 @@ class SwapchainMonitor final { std::condition_variable_any cv{}; std::jthread monitor_worker{}; + std::optional last_signal_time; + void do_monitor(const std::stop_token stoken); public: @@ -64,7 +67,8 @@ class SwapchainMonitor final { void notify_semaphore(const VkSemaphore& timeline_semaphore, const std::uint64_t& value); - void attach_work(std::unique_ptr> submissions); + void attach_work( + std::vector>> submissions); }; } // namespace low_latency -- cgit v1.2.3