Function screenshotWriterThreadFunc

layersvt/screenshot.cpp:1565–1641

}

void screenshotWriterThreadFunc() {
    bool pauseFileRecorded = false;
    if (!std::atomic_load(&pauseCapture)) {
        std::remove(settings.pauseFileName.c_str());
    }
    while (true) {
        {
            std::lock_guard<std::mutex> lock(globalLock);
            if (globalLayerSettingSet != VK_NULL_HANDLE) {
                updatePauseCapture(globalLayerSettingSet);
            }
        }
        bool paused = std::atomic_load(&pauseCapture);
        if (!paused && pauseFileRecorded) {
            std::remove(settings.pauseFileName.c_str());  // delete file
            pauseFileRecorded = false;
        }

        std::shared_ptr<ScreenshotQueueData> dataToSave;
        {
            PROFILE(paused ? "paused" : "Waiting for CPU")
            std::unique_lock<std::mutex> lock(globalLock);
            if (screenshotsData.empty()) {
                if (paused && !pauseFileRecorded) {
                    std::ofstream pauseFile(settings.pauseFileName.c_str());
                    pauseFileRecorded = true;
                }
                // Make sure we don't wait on the CPU thread if we are shutting down, will deadlock.
                if (shutdownScreenshotThread) break;
                screenshotQueuedCV.wait(lock);
            }
            if (screenshotsData.empty()) continue;
            dataToSave = screenshotsData.front();
        }

        VkResult fenceWaitResult = VK_TIMEOUT;
        {
            PROFILE("Waiting for GPU")
            while (fenceWaitResult == VK_TIMEOUT) {
                fenceWaitResult =
                    dataToSave->pTableDevice->WaitForFences(dataToSave->device, 1, &dataToSave->fence, VK_TRUE, UINT64_MAX);
            }
        }

        if (fenceWaitResult == VK_SUCCESS) {
            writeScreenshot(*dataToSave);
            std::lock_guard<std::mutex> lock(globalLock);
            screenshotDataCache[dataToSave->image1].emplace_back(dataToSave);
        }
        {
            std::lock_guard<std::mutex> lock(globalLock);
            screenshotsData.pop_front();
            PROFILE_COUNTER("screenshot.QueueSize", screenshotsData.size());
        }

        screenshotSavedCV.notify_all();

        if (settings.isFrameAfterEndOfCaptureRange(dataToSave->frameNumber + 1)) {