DRCEResourceMonitor.hpp

Go to the documentation of this file.

#ifndef DRCE_RESOURCE_MONITOR_HPP
#define DRCE_RESOURCE_MONITOR_HPP

#include <Poco/Thread.h>
#include <Poco/Mutex.h>
#include <string>
#include <map>

#include "DRCEAsyncTasksQueue.hpp"
#include "DRCEStatVariables.hpp"
#include "DRCEAvgCounts.hpp"
#include "LoggerStream.hpp"

namespace HCE
{
namespace drce
{
//-----------------------------------------------------------------------------
class DRCEResourceMonitor : public Poco::Runnable
{
  enum {DEFAULT_TIME_PERIOD=10000};
public:
  DRCEResourceMonitor(DRCEAsyncTasksQueue& asyncTasksQueue_,
      CustomMessage& message_);
  ~DRCEResourceMonitor(void);

  void run(void);

  void terminate(void);
  bool isTerminated(void);

  void setTimePeriod(unsigned int timePeriod_);
  unsigned int getTimePeriod(void);

  void fillFieldsArray(DRCEResultData& resultData);
  static void fillFieldsArray(DRCEResultData& resultData, DRCEAsyncTasksQueue& asyncTasksQueue_, CustomMessage& message_, DRCEResourceMonitor* pResourceMonitor=nullptr);
  static bool fillFieldsArray(DRCEResultDataItem& resultDataItem, DRCEAsyncTasksQueue& asyncTasksQueue_, CustomMessage& message_, DRCEResourceMonitor* pResourceMonitor=nullptr);

  StatVariables getStatVariables(void);

  void dump(StatVariables& statVariables, AvgCounts& avgCounts);
  void restore(const StatVariables& statVariables, const AvgCounts& avgCounts);

  void addTimeAsyncTask(size_t value);
  void addTimeSyncTask(size_t value);
  void addSizeInputBufferSyncTasks(size_t value);
  void addSizeInputBufferAsyncTasks(size_t value);
  void addSizeOutputBufferSyncTasks(size_t value);
  void addSizeOutputBufferAsyncTasks(size_t value);
  void addCpuUsageAsyncTasks(double value);
  void addMemoryUsageAsyncTasks(size_t value);
  void addCountAsyncTasksForMinute(double value);
  void addCountSyncTasksForMinute(double value);
  void incrementCountSyncTasks(void);
  void incrementCountAsyncTasks(void);
  void incrementCountSyncTasksFail(void);
  void incrementCountAsyncTasksFail(void);
private:
  template <class T> void addStatValue(T value, StatVariableData<T>& statVariableData, size_t& count);
  void countTasksForMinute(Poco::Timestamp& ts, size_t& countSyncTasks, size_t& countAsyncTasks);
  StatVariables recountStatVariables(void);
  void setStatVariables(StatVariables&& rhs);
private:
  Poco::Thread thread;
  Poco::Mutex mutex;
  volatile bool terminated;
  unsigned int timePeriod;

  DRCEAsyncTasksQueue& asyncTasksQueue;
  CustomMessage& message;
  StatVariables statVariables;
  StatVariables counterStatVariables;

  AvgCounts avgCounts;
};
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
} // end namespace drce
} // end namespace HCE

#endif // DRCE_RESOURCE_MONITOR_HPP