Method DequeuePresentEvents

PresentData/PresentMonTraceConsumer.cpp:3474–3493

}

void PMTraceConsumer::DequeuePresentEvents(std::vector<std::shared_ptr<PresentEvent>>& outPresentEvents)
{
    outPresentEvents.clear();
    {
        std::lock_guard<std::mutex> lock(mPresentEventMutex);
        if (mReadyCount > 0) {
            outPresentEvents.resize(mReadyCount, nullptr);
            for (uint32_t i = 0; i < mReadyCount; ++i) {
                std::swap(outPresentEvents[i], mCompletedPresents[mCompletedIndex]);
                mCompletedIndex = GetRingIndex(mCompletedIndex + 1);
            }

            mCompletedCount -= mReadyCount;
            mReadyCount = 0;
        }
    }
    if (!mIsRealtimeSession && !mDisableOfflineBackpressure) {
        mCompletedRingCondition.notify_one();
    }
}

void PMTraceConsumer::SetProviderToggleMode(bool enabled) {
    mProviderToggleMode.store(enabled, std::memory_order_release);