Function EventRecordCallback

PresentData/PresentMonTraceSession.cpp:296–424

    bool TRACK_PRESENTMON,
    bool TRACK_PCL>
void CALLBACK EventRecordCallback(EVENT_RECORD* pEventRecord)
{
    auto session = (PMTraceSession*) pEventRecord->UserContext;
    const auto& hdr = pEventRecord->EventHeader;

    PMTraceConsumer::EventProcessingScope processingScope(*session->mPMConsumer);
    if (!processingScope) {
        return;
    }

    if constexpr (IS_REALTIME_SESSION) {
        session->ProcessEtwEventLatencyStats(hdr.TimeStamp.QuadPart);
    }

    if constexpr (!IS_REALTIME_SESSION) {
        if (session->mStartTimestamp.QuadPart == 0) {
            session->mStartTimestamp = hdr.TimeStamp;
            // one-time capture of timing info needed to calibrate ETL replay event pacing
            if (session->mPMConsumer->mPaceEvents || session->mPMConsumer->mRetimeEvents) {
                session->mPacingActualLogStartTimestamp = hdr.TimeStamp.QuadPart;
                session->mPacingRealtimeStartTimestamp = pmon::util::GetCurrentTimestamp();
                session->mPacingQpcPeriod = pmon::util::GetTimestampPeriodSeconds();
                session->mPacingQpcOffset = session->mPacingRealtimeStartTimestamp - hdr.TimeStamp.QuadPart;
                // override the processing start timestamp with the adjusted value
                session->mStartTimestamp.QuadPart = session->mPacingRealtimeStartTimestamp;
                if (session->mPMConsumer->mRetimeEvents) {
                    // perform the first adjustment of the event header (no wait or calculation necessary)
                    pEventRecord->EventHeader.TimeStamp.QuadPart = session->mPacingRealtimeStartTimestamp;
                }
            }
        }
        else if (session->mPMConsumer->mPaceEvents || session->mPMConsumer->mRetimeEvents) {
            const auto currentQpc = pmon::util::GetCurrentTimestamp();
            const auto adjustedTimestamp = hdr.TimeStamp.QuadPart + session->mPacingQpcOffset;
            const auto delta = pmon::util::TimestampDeltaToSeconds(currentQpc, adjustedTimestamp, session->mPacingQpcPeriod);
            if (session->mPMConsumer->mPaceEvents && delta > 0.001) {
                session->mPacingWaiter.Wait(delta);
            }
            if (session->mPMConsumer->mRetimeEvents) {
                pEventRecord->EventHeader.TimeStamp.QuadPart = adjustedTimestamp;
            }
        }
    }

    VerboseTraceEvent(session->mPMConsumer, pEventRecord, &session->mPMConsumer->mMetadata);

    if (hdr.ProviderId == Microsoft_Windows_DxgKrnl::GUID) {
        session->mPMConsumer->HandleDXGKEvent(pEventRecord);
        return;
    }
    if (hdr.ProviderId == Microsoft_Windows_DXGI::GUID) {
        session->mPMConsumer->HandleDXGIEvent(pEventRecord);
        return;
    }
    if constexpr (TRACK_DISPLAY || TRACK_INPUT) {
        if (hdr.ProviderId == Microsoft_Windows_Win32k::GUID) {
            session->mPMConsumer->HandleWin32kEvent(pEventRecord);
            return;