ProcessMonitor.h

Go to the documentation of this file.

// Copyright CERN and copyright holders of ALICE O2. This software is
// distributed under the terms of the GNU General Public License v3 (GPL
// Version 3), copied verbatim in the file "COPYING".
//
// See http://alice-o2.web.cern.ch/license for full licensing information.
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.


#ifndef ALICEO2_MONITORING_CORE_PROCESSMONITOR_H
#define ALICEO2_MONITORING_CORE_PROCESSMONITOR_H

#include <atomic>
#include <boost/algorithm/string.hpp>
#include <iostream>
#include <string>
#include <vector>
#include <sys/resource.h>

#include "Monitoring/Metric.h"

namespace o2
{
namespace monitoring
{

class ProcessMonitor
{
  friend class Monitoring;

 public:
  enum {
    MEMORY_USAGE_PERCENTAGE = 0,
    VIRTUAL_MEMORY_SIZE,
    RESIDENT_SET_SIZE,
    CPU_USED_PERCENTAGE,
    INVOLUNTARY_CONTEXT_SWITCHING,
    CPU_USED_ABSOLUTE,
    AVG_RESIDENT_SET_SIZE,
    AVG_VIRTUAL_MEMORY_SIZE,
    AVG_CPU_USED_PERCENTAGE,
    ACCUMULATED_CPU_TIME,
    PSS,
    AVAILABLE_METRICS_SIZE
  };

  static std::vector<std::string> getAvailableMetricsNames();
  std::vector<Metric> getPerformanceMetrics();

 public:
  ProcessMonitor();

  ~ProcessMonitor() = default;

  void init();

 private:
  double splitStatusLineAndRetriveValue(const std::string& line) const;

  void setTotalMemory();

 private:
  static constexpr const char* metricsNames[] = {"memoryUsagePercentage", "virtualMemorySize", "residentSetSize",
                                                 "cpuUsedPercentage", "involuntaryContextSwitches", "cpuUsedAbsolute",
                                                 "averageResidentSetSize", "averageVirtualMemorySize", "averageCpuUsedPercentage",
                                                 "cpuTimeConsumedByProcess", "proportionalSetSize"};

  static constexpr unsigned int VM_SIZE_INDEX = 18;
  static constexpr unsigned int VM_RSS_INDEX = 22;

  unsigned int mPid;

  unsigned int mTotalMemory;

  struct rusage mPreviousGetrUsage;

  std::vector<double> mVmSizeMeasurements;
  std::vector<double> mVmRssMeasurements;
  std::vector<uint64_t> mCpuMicroSeconds;
  std::vector<double> mCpuPerctange;

  std::chrono::high_resolution_clock::time_point mTimeLastRun;

  std::vector<Metric> getMemoryUsage();

  Metric getPss();

  std::vector<Metric> getCpuAndContexts();

  std::vector<Metric> makeLastMeasurementAndGetMetrics();
};

} // namespace monitoring
} // namespace o2

#endif // ALICEO2_MONITORING_CORE_PROCESSMONITOR_H