Add Private_Clean and Private_Dirty memory mapping metrics (#224)

Author: awegrzyn

CMakeLists.txt

@@ -17,7 +17,7 @@ endif()
 
 # Define project
 project(Monitoring
-  VERSION 3.4.0
+  VERSION 3.5.0
   DESCRIPTION "O2 Monitoring library"
   LANGUAGES CXX
 )

include/Monitoring/ProcessMonitor.h

@@ -50,6 +50,8 @@ class ProcessMonitor
     AVG_CPU_USED_PERCENTAGE,
     ACCUMULATED_CPU_TIME,
     PSS,
+    PRIVATE_CLEAN,
+    PRIVATE_DIRTY,
     AVAILABLE_METRICS_SIZE
   };
 
@@ -75,7 +77,7 @@ class ProcessMonitor
   static constexpr const char* metricsNames[] = {"memoryUsagePercentage", "virtualMemorySize", "residentSetSize",
                                                  "cpuUsedPercentage", "involuntaryContextSwitches", "voluntaryContextSwitches", "cpuUsedAbsolute",
                                                  "averageResidentSetSize", "averageVirtualMemorySize", "averageCpuUsedPercentage",
-                                                 "cpuTimeConsumedByProcess", "proportionalSetSize"};
+                                                 "cpuTimeConsumedByProcess", "proportionalSetSize", "memPrivateClean", "memPrivateDirty"};
 
   static constexpr unsigned int VM_SIZE_INDEX = 18;
   static constexpr unsigned int VM_RSS_INDEX = 22;
@@ -101,8 +103,8 @@ class ProcessMonitor
   /// Retrieves virtual memory and resident set size usage
   std::vector<Metric> getMemoryUsage();
 
-  /// Retrieves proportional set size
-  Metric getPss();
+  /// Retrieves memory maping metrics
+  std::vector<Metric> getSmaps();
 
   /// Retrieves CPU usage (%) and number of context switches during the interval
   std::vector<Metric> getCpuAndContexts();

src/ProcessMonitor.cxx

@@ -72,18 +72,26 @@ std::vector<Metric> ProcessMonitor::getMemoryUsage()
   return metrics;
 }
 
-Metric ProcessMonitor::getPss()
+std::vector<Metric> ProcessMonitor::getSmaps()
 {
   std::ifstream statusStream("/proc/self/smaps");
   double pssTotal = 0;
-  std::string pssString;
+  double cleanTotal = 0;
+  double dirtyTotal = 0;
+  std::string smapsString;
 
-  while (std::getline(statusStream, pssString)) {
-    if (pssString.rfind("Pss:", 0) == 0) {
-      pssTotal += splitStatusLineAndRetriveValue(pssString);
+  while (std::getline(statusStream, smapsString)) {
+    if (smapsString.rfind("Pss:", 0) == 0) {
+      pssTotal += splitStatusLineAndRetriveValue(smapsString);
+    }
+    if (smapsString.rfind("Private_Clean:", 0) == 0) {
+      cleanTotal += splitStatusLineAndRetriveValue(smapsString);
+    }
+    if (smapsString.rfind("Private_Dirty:", 0) == 0) {
+      dirtyTotal += splitStatusLineAndRetriveValue(smapsString);
     }
   }
-  return {pssTotal, metricsNames[PSS]};
+  return {{pssTotal, metricsNames[PSS]}, {cleanTotal, metricsNames[PRIVATE_CLEAN]}, {dirtyTotal, metricsNames[PRIVATE_DIRTY]}};
 }
 
 std::vector<Metric> ProcessMonitor::getCpuAndContexts()
@@ -132,7 +140,8 @@ std::vector<Metric> ProcessMonitor::getPerformanceMetrics()
 #ifdef O2_MONITORING_OS_LINUX
   auto memoryMetrics = getMemoryUsage();
   std::move(memoryMetrics.begin(), memoryMetrics.end(), std::back_inserter(metrics));
-  metrics.emplace_back(getPss());
+  auto smapMetrics = getSmaps();
+  std::move(smapMetrics.begin(), smapMetrics.end(), std::back_inserter(metrics));
 #endif
   return metrics;
 }