monitorThread.hpp

Go to the documentation of this file.

 
#ifndef IFW_CCF_CTL_MONITOR_THREAD_HPP_
#define IFW_CCF_CTL_MONITOR_THREAD_HPP_
 
#include <boost/exception/diagnostic_information.hpp>
 
#include <ccf/common/base.hpp>
#include <ccf/common/utilities.hpp>
 
namespace ccf::control {
 
  class MonitorThread: public ccf::mptk::Thread {
    public:
 
      MonitorThread(const std::string& thread_name,
                    ccf::mptk::MessageBus& message_bus,
                    const double period = 0.1);
 
      virtual ~MonitorThread();
 
      void Initialise();
 
      virtual void UserLogic();
 
    private:
      void _CollectData();
      void _ComputePublishStatistics();
      void _CheckMessageBus();
      void _HandleNewSetup(ccf::Status status,
                           std::string& diagnostics);
      void _UpdateRecordingStatus();
 
      void _ComputeStatistics(const std::vector<double>& data_set,
                              uint16_t& samples_in_set,
                              double& mean,
                              double& min,
                              double& max,
                              double& stddev,
                              double& jitter,
                              const double theoretic_periodicty = INT_MIN);
 
      std::list<std::string> m_thread_names;
      std::map<std::string, ccf::common::FrameStatistics> m_thr_name_to_frame_stat;
      std::map<std::string, double> m_thread_drift;
      std::map<uint64_t, double> m_thread_drift_window;
      uint64_t m_drift_count;
      double m_mon_last_rec_wait_clean_up;
  };
 
}
 
#endif // IFW_CCF_CTL_MONITOR_THREAD_HPP_