deadline_supervision.h

#ifndef DEADLINE_SUPERVISION_H
#define DEADLINE_SUPERVISION_H
 
#include <chrono>
#include <condition_variable>
#include <mutex>
#include <thread>
#include "./elementary_supervision.h"
 
namespace ara
{
    namespace phm
    {
        namespace supervisors
        {
            class DeadlineSupervision : public ElementarySupervision
            {
            private:
                static const TypeOfSupervision cSupervisionType;
 
                const std::chrono::milliseconds cMinDeadline;
                const std::chrono::milliseconds cMaxDeadline;
 
                std::thread mDeadlineThread;
                bool mTargetIsReached;
                std::mutex mCvMutex;
                std::condition_variable mDeadlineCv;
                std::chrono::time_point<std::chrono::steady_clock> mTimeReference;
 
                void deadlineWorker();
 
            public:
                DeadlineSupervision(
                    std::chrono::milliseconds minDeadline,
                    std::chrono::milliseconds maxDeadline);
 
                DeadlineSupervision() = delete;
                ~DeadlineSupervision();
 
                void ReportSourceCheckpoint();
 
                void ReportTargetCheckpoint();
            };
        }
    }
}
 
#endif