Method Poll

IntelPresentMon/PresentMonMiddleware/DynamicQuery.cpp:371–500

}

uint32_t PM_DYNAMIC_QUERY::Poll(uint8_t* pBlobBase, ipc::MiddlewareComms& comms,
	uint64_t nowTimestamp, FrameMetricsSource* frameSource, uint32_t processId, uint32_t maxSwapChains) const
{
	if (pBlobBase == nullptr || maxSwapChains == 0) {
		return 0;
	}

	const auto window = GenerateQueryWindow_(nowTimestamp);
	const bool integrityCheckEnabled = util::log::GlobalPolicy::Get().GetLogLevel() >= util::log::Level::Debug;

	// Validate pending windows from previous polls before polling this window.
	if (integrityCheckEnabled) {
		ValidatePendingIntegrityWindows_(frameSource, comms, processId, nowTimestamp);
	}

	std::vector<uint64_t> swapChainAddresses;
	if (frameSource != nullptr) {
		swapChainAddresses = frameSource->GetSwapChainAddressesInTimestampRange(window.oldest, window.newest);
	}

	const bool snapshotDumpEnabled = util::log::GlobalPolicy::Get().GetLogLevel() >= util::log::Level::Verbose &&
		util::log::GlobalPolicy::VCheck(util::log::V::middleware);

	std::optional<FrameMetricsSource::PollSnapshotData> pollSnapshots;
	if (snapshotDumpEnabled && frameSource != nullptr && frameTimeOrFpsOffset_.has_value()) {
		pollSnapshots = frameSource->CapturePollSnapshotData();
	}

	bool sawZeroFrameTimeOrFpsValue = false;
	const uint64_t targetStartQpc = GetTargetStartQpc_(comms, processId);
	const std::string elapsedSinceTargetStartSecondsText =
		BuildElapsedSinceTargetStartText_(targetStartQpc, nowTimestamp, qpcPeriodSeconds_);

	auto dumpSnapshotsIfNeeded = [&]() {
		if (!pollSnapshots || !sawZeroFrameTimeOrFpsValue) {
			return;
		}
		size_t totalSwapChainFrameSnapshots = 0;
		for (const auto& swapChainSnapshots : pollSnapshots->swapChainSnapshots) {
			totalSwapChainFrameSnapshots += swapChainSnapshots.snapshots.size();
		}

		pmlog_verb(util::log::V::middleware)("Dynamic query detected zero frame time/FPS metric and dumped poll snapshots")
			.every(std::chrono::milliseconds{ 500 })
			.pmwatch(processId)
			.pmwatch(nowTimestamp)
			.watch("queryHandle", reinterpret_cast<void*>(const_cast<PM_DYNAMIC_QUERY*>(this)))
			.watch("elapsed_since_target_start_s", elapsedSinceTargetStartSecondsText)
			.pmwatch(pollSnapshots->ipcStoreSnapshots.size())
			.pmwatch(pollSnapshots->swapChainSnapshots.size())
			.watch("total_swap_chain_frame_snapshots", totalSwapChainFrameSnapshots)
			.watch("poll_snapshot_csv", BuildPollSnapshotCsv_(*pollSnapshots))
			.diag();
	};

	auto pollOnce = [&](const SwapChainState* pSwapChain, uint64_t swapChainAddress, uint8_t* pBlob) {
		const bool hasFrameSamples = pSwapChain != nullptr &&
			pSwapChain->CountInTimestampRange(window.oldest, window.newest) > 0;