modelled_process.h

#ifndef MODELLED_PROCESS_H
#define MODELLED_PROCESS_H
 
#include <asyncbsdsocket/poller.h>
#include <atomic>
#include <future>
#include <map>
#include <string>
#include "../../log/logging_framework.h"
#include "../deterministic_client.h"
 
namespace ara
{
    namespace exec
    {
        namespace helper
        {
            class ModelledProcess
            {
            private:
                static const log::LogMode cLogMode;
                static const std::string cContextId;
                static const std::string cContextDescription;
 
                log::LoggingFramework *mLoggingFramework;
                log::Logger mLogger;
                DeterministicClient mDeterministicClient;
                std::atomic_bool mCancellationToken;
                std::future<int> mExitCode;
 
            protected:
                static const log::LogLevel cLogLevel;
                static const log::LogLevel cErrorLevel;
 
                const int cSuccessfulExitCode{0};
                const int cUnsuccessfulExitCode{1};
 
                AsyncBsdSocketLib::Poller *const Poller;
 
                ModelledProcess(
                    std::string appId, AsyncBsdSocketLib::Poller *poller);
 
                virtual int Main(
                    const std::atomic_bool *cancellationToken,
                    const std::map<std::string, std::string> &arguments) = 0;
 
                void Log(
                    log::LogLevel logLevel, const log::LogStream &logStream);
 
                bool WaitForActivation();
 
            public:
                void Initialize(const std::map<std::string, std::string> &arguments);
 
                int Terminate();
 
                virtual ~ModelledProcess();
            };
        }
    }
}
 
#endif