ExecutorWatchdog.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_EXECUTORWATCHDOG_HXX_
#define _UTILS_EXECUTORWATCHDOG_HXX_
 
#include "executor/StateFlow.hxx"
#include "os/os.h"
#include "utils/logging.h"
 
class ExecutorWatchdog : public StateFlowBase
{
public:
    ExecutorWatchdog(Service *service)
        : StateFlowBase(service)
    {
        start_flow(STATE(take_stamp));
    }
 
private:
    Action take_stamp()
    {
        lastTimeMsec_ = NSEC_TO_MSEC(os_get_time_monotonic());
        return sleep_and_call(&timer_, MSEC_TO_NSEC(50), STATE(woken));
    }
 
    Action woken()
    {
        uint32_t new_time_msec = NSEC_TO_MSEC(os_get_time_monotonic());
        auto diff = new_time_msec - lastTimeMsec_;
        if (diff > 100)
        {
            LOG(WARNING, "[WARN] Executor was blocked for %d msec",
                (int)(diff - 50));
        }
        if (++count_ > (5000 / 50))
        {
            count_ = 0;
            LOG(INFO, "Watchdog alive.");
        }
        return call_immediately(STATE(take_stamp));
    }
 
    StateFlowTimer timer_ {this};
    uint32_t lastTimeMsec_ {0};
    int count_ {0};
};
 
#endif // _UTILS_EXECUTORWATCHDOG_HXX_