Function publishProcessMetrics

src/DocLayer.actor.cpp:465–493

} // namespace Tests

ACTOR void publishProcessMetrics() {
	// Give time to systemMonitor to log events.
	wait(delay(5.0));

	TraceEvent("BD_processMetricsPublisher");
	try {
		loop {
			// Update metrics at high priority.
			wait(delay(5.0, TaskMaxPriority));

			auto processMetrics = latestEventCache.get("ProcessMetrics");
			double processMetricsElapsed = processMetrics.getDouble("Elapsed");
			double cpuSeconds = processMetrics.getDouble("CPUSeconds");
			double mainThreadCPUSeconds = processMetrics.getDouble("MainThreadCPUSeconds");

			double cpuUsage = std::max(0.0, cpuSeconds / processMetricsElapsed) * 100;
			double mainThreadCPUUsage = std::max(0.0, mainThreadCPUSeconds / processMetricsElapsed) * 100;

			DocumentLayer::metricReporter->captureGauge(DocLayerConstants::MT_GUAGE_CPU_PERCENTAGE, cpuUsage);
			DocumentLayer::metricReporter->captureGauge(DocLayerConstants::MT_GUAGE_MAIN_THREAD_CPU_PERCENTAGE,
			                                            mainThreadCPUUsage);
			DocumentLayer::metricReporter->captureGauge(DocLayerConstants::MT_GUAGE_MEMORY_USAGE,
			                                            processMetrics.getInt64("Memory"));
		};
	} catch (...) {
		TraceEvent("BD_processMetricsPublisherException");
		throw;
	}
}

typedef std::vector<std::pair<FDBNetworkOption, Standalone<StringRef>>> NetworkOptionsT;