Method Consume

IntelPresentMon/PresentMonMiddleware/FrameMetricsSource.cpp:248–287

	}

	std::vector<util::metrics::FrameMetrics> FrameMetricsSource::Consume(size_t maxFrames)
	{
		std::vector<util::metrics::FrameMetrics> output;
		Update();

		if (maxFrames == 0) {
			return output;
		}

		output.reserve(maxFrames);

		for (size_t i = 0; i < maxFrames; ++i) {
			SwapChainState* selectedState = nullptr;
			const util::metrics::FrameMetrics* selectedMetrics = nullptr;
			uint64_t selectedSwapChain = 0;

			for (auto& [address, state] : swapChains_) {
				if (!state.HasPending()) {
					continue;
				}
				const auto& metrics = state.Peek();
				if (selectedMetrics == nullptr ||
					metrics.timeInSeconds < selectedMetrics->timeInSeconds ||
					(metrics.timeInSeconds == selectedMetrics->timeInSeconds && address < selectedSwapChain)) {
					selectedMetrics = &metrics;
					selectedState = &state;
					selectedSwapChain = address;
				}
			}

			if (selectedMetrics == nullptr || selectedState == nullptr) {
				break;
			}

			output.push_back(*selectedMetrics);
			selectedState->ConsumeNext();
		}

		return output;
	}

	void FrameMetricsSource::Flush()
	{