rtcMonitor.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_RTCSUPERVISOR_RTCMONITOR_HPP
#define RTCTK_RTCSUPERVISOR_RTCMONITOR_HPP
 
#include <rtctk/componentFramework/logger.hpp>
 
#include <atomic>
#include <chrono>
#include <functional>
#include <thread>
 
#include <boost/asio.hpp>
 
namespace rtctk::rtcSupervisor {
 
class RtcMonitor {
public:
    using MonitorFunction = std::function<void()>;  // noexcept function (C++17 has problems here)
 
    explicit RtcMonitor(MonitorFunction func);
    virtual ~RtcMonitor();

    void Run();

    void Idle();

    boost::asio::io_context& GetIoContext() {
        return m_io_context;
    }
 
private:
    void Work();
 
    log4cplus::Logger& m_logger;
    std::chrono::microseconds m_interval;
    MonitorFunction m_mon_func;
    std::atomic<bool> m_time_to_stop;
    std::atomic<bool> m_mon_active;
    boost::asio::io_context m_io_context;
    std::thread m_thread;
};
 
}  // namespace rtctk::rtcSupervisor
 
#endif  // RTCTK_RTCSUPERVISOR_RTCMONITOR_HPP