WatchDog.hpp

Go to the documentation of this file.

#ifndef SRC_IV_THREADS_WATCHDOG_HPP
#define SRC_IV_THREADS_WATCHDOG_HPP
 
#include "core/defines.hpp"
#include "logs/AbstractProgress.hpp"
#include "threads/IRunnable.hpp"
#include "threads/Thread.hpp"
#include "threads/ThreadRunnablePeriodic.hpp"
 
#include <map>
#include <optional>
#include <string>
#include <thread>
 
namespace iv::threads
{
 
enum eThreadType
{
    Communication,
    Editor,
    Internal
};
 
struct ThreadData
{
    iv::types::threadName name;
    iv::types::timestamp lastTimeRunning;
    iv::threads::Thread *thread;
    iv::threads::IRunnable *runnable;
    eThreadType type;
};
 
class WatchDog final : public iv::threads::ThreadRunnablePeriodic
{
public:
    WatchDog();
    ~WatchDog() override = default;
 
    static bool startMonitoring();
    static bool stopMonitoring();
 
    static void addThread(const iv::types::threadName &name, ThreadRunnablePeriodic *runnable, eThreadType type);
    static void removeThread(const iv::types::threadName &name);
 
    static void startThreads(eThreadType type, const std::optional<std::shared_ptr<AbstractProgress>> &progress);
    static void restartThreads(eThreadType type, const std::optional<std::shared_ptr<AbstractProgress>> &progress);
    static void stopThreads(eThreadType type, const std::optional<std::shared_ptr<AbstractProgress>> &progress);
 
    static bool startThread(const iv::types::threadName &name);
    static bool restartThread(const iv::types::threadName &name);
    static bool stopThread(const iv::types::threadName &name);
 
    static void pauseThread(const iv::types::threadName &name);
    static void resumeThread(const iv::types::threadName &name);
    static std::optional<ThreadData> getThreadData(const iv::types::threadName &name);
 
    static std::map<std::thread::id, std::atomic<bool>> haveThreadsCrashed;
 
private:
    static std::map<iv::types::threadName, ThreadData> m_threads;
    static std::mutex m_mutex;
    void periodicTask() override;
 
    iv::types::timestamp startTime;
 
    // Diamar Threads
    // iv::threads::RunManageOfflineUnitAndStation m_runManageOfflineUnitAndStation;
    // iv::threads::RunReconnect m_runReconnect;
    // iv::threads::RunSendHeartbeatStation m_runSendHeartbeatStation;
    // iv::threads::RunSendRedundancy m_runSendRedundancy;
    // iv::threads::RunSendStationValuesToLoms m_runSendStationValuesToLoms;
    // //iv::threads::RunSendUpdateGroupAlarms m_runSendUpdateGroupAlarms; // TODO: Problematico
    // iv::threads::RunStationLogics m_runStationLogics;
    // iv::threads::RunTanks m_runTanks;
    // iv::threads::RunUpdateChannels m_runUpdateChannels;
    //
    // // Edit Diamar Threads
    // //iv::threads::RunReceiveEditorComms m_runReceiveEditorComms;
    // //iv::threads::RunUpdateInfoUnit m_runUpdateInfoUnit;
};
 
}// namespace iv::threads
 
#endif//SRC_IV_THREADS_WATCHDOG_HPP