Method Output

IntelPresentMon/PresentMonService/MockPresentMonSession.cpp:405–435

}

void MockPresentMonSession::Output() {
    // Structures to track processes and statistics from recorded events.
    std::vector<ProcessEvent> processEvents;
    std::vector<std::shared_ptr<PresentEvent>> presentEvents;
    std::vector<std::pair<uint32_t, uint64_t>> terminatedProcesses;
    processEvents.reserve(128);
    presentEvents.reserve(4096);
    terminatedProcesses.reserve(16);

    for (;;) {
        // Read quit_output_thread_ here, but then check it after processing
        // queued events. This ensures that we call DequeueAnalyzedInfo() at
        // least once after events have stopped being collected so that all
        // events are included.
        const auto quit = quit_output_thread_.load();

        // Copy and process all the collected events, and update the various
        // tracking and statistics data structures.
        ProcessEvents(&processEvents, &presentEvents, &terminatedProcesses);

        // Everything is processed and output out at this point, so if we're
        // quiting we don't need to update the rest.
        if (quit) {
            break;
        }

        // Sleep to reduce overhead.
        // TODO: sync this to eliminate overhead / lag
        std::this_thread::sleep_for(10ms);
    }
}

void MockPresentMonSession::StartOutputThread() {
    quit_output_thread_ = false;