Function PacedPlaybackTest

IntelPresentMon/SampleClient/PacedPlayback.cpp:192–272

};

int PacedPlaybackTest(std::unique_ptr<pmapi::Session> pSession)
{
	auto& opt = clio::Options::Get();

	std::optional<PM_STATUS> errorStatus;

	try {
		if (!opt.processId) {
			pmlog_error("need pid");
		}

		// connect to service and register query
		TestClientModule client{ std::move(pSession), *opt.windowSize, *opt.metricOffset };
		if (opt.etwFlushPeriodMs) {
			client.SetETWFlushPeriod(*opt.etwFlushPeriodMs);
		}
		if (opt.telemetryPeriodMs) {
			client.SetTelemetryPeriod(*opt.telemetryPeriodMs);
		}

		// ping gate to sync on init finished
		std::string line;
		std::getline(std::cin, line);
		if (line != "%ping") {
			std::cout << "%%{ping-error}%%" << std::endl;
			return -1;
		}
		std::cout << "%%{ping-ok}%%" << std::endl;

		// poll for designated period and parse run results
		const auto runTimeEnd = *opt.runStart + *opt.runTime;
		auto run = client.RecordPolling(*opt.processId, *opt.runStart, runTimeEnd, *opt.pollPeriod);
		WriteRunToCsv(*opt.outputPath, MakeHeader(client.GetQueryElements(), client.GetIntrospection()), run);
	}
	catch (const pmapi::ApiErrorException& e) {
		if (!opt.testExpectError) {
			throw;
		}
		errorStatus = e.GetCode();
	}

	std::string line;

	// if we captured an error, wait here for error ack
	if (errorStatus) {
		std::getline(std::cin, line);
		if (line != "%err-check") {
			std::cout << "%%{err-check-error}%%" << std::endl;
			return -1;
		}
		auto&& err = pmapi::EnumMap::GetKeyMap(PM_ENUM_STATUS)->at(*errorStatus).narrowSymbol;
		std::cout << "%%{err-check-ok:" << err << "}%%" << std::endl;
	}

	// wait for command
	while (std::getline(std::cin, line)) {
		if (line == "%quit") {
			std::cout << "%%{quit-ok}%%" << std::endl;