Scheduler.h

Go to the documentation of this file.

#pragma once
 
 
#include <typeinfo>
#ifdef WINDOWS
#include <direct.h>
#include <boost/serialization/export.hpp>
    #define GetCurrentDir _getcwd
#else
#include <unistd.h>
#define GetCurrentDir getcwd
#endif
 
#include <stdlib.h>
#include <string.h>
#include <string>
#include <fstream>
#include <iostream>
#include <boost/serialization/string.hpp>
#include <boost/archive/text_iarchive.hpp>
#include <boost/archive/text_oarchive.hpp>
#include "../Global/SimConstants.h"
#include "../Global/TermConversions.h"
#include <boost/serialization/export.hpp>
#include <boost/serialization/access.hpp>
 
 
class Scheduler  
{
public:
    Scheduler();
    virtual ~Scheduler();
    void initiationForSimulation(ConsoleMode iMode = ConsoleMode::Console);
    void endSimulation();
    void readInfoFromFile(ConsoleMode iMode = ConsoleMode::Console);
    void setProjectDirectory(std::string);
    void setOutputDirectory(std::string);
    void setESDirectory(std::string);
    void setPEDirectory(std::string);
    void setKPSDirectory(std::string);
    void setInputDeckFileDirectoryAndName(std::string);
    int getSolverPort() const;
    void setEOPDirectory(std::string);
    void setODMDirectory(std::string);
    void setOATDirectory(std::string);
    void setOCTDirectory(std::string);
    void setHardwareReliabilityDirectory(std::string);
    void setIndicatorsDirectory(std::string);
    void setSchedulerDirectory(std::string);
    void setSystemDirectory(std::string);
    void setSupportSystemsDirectory(std::string);
    std::string getProjectDirectory();
    std::string getOutputDirectory();
    std::string getESDirectory();
    std::string getPEDirectory();
    std::string getKPSDirectory();
    std::string getInputDeckFileDirectoryAndName();
    std::string getEOPDirectory();
    std::string getODMDirectory();
    std::string getOATDirectory();
    std::string getOCTDirectory();
    std::string getHardwareReliabilityDirectory();
    std::string getIndicatorsDirectory();
    std::string getSchedulerDirectory();
    std::string getSystemDirectory();
    std::string getSupportSystemsDirectory();
    bool checkForTerminatingCurrentSequence();
    void setSequenceTruncationProbability(double);
    void setSequenceTruncationTime(double);
    double getSequenceTruncationProbability();
    double getSequenceTruncationTime();
    void setODMActionTimeMultiplier(double);
    double getODMActionTimeMultiplier();
    void setOATActionTimeMultiplier(double);
    double getOATActionTimeMultiplier();
    void setOCTActionTimeMultiplier(double);
    double getOCTActionTimeMultiplier();
    void setSequenceTerminatedByAlarm(bool);
    bool getSequenceTerminatedByAlarm();
    void setSequenceTerminatedByNonResponseAction(bool);
    bool getSequenceTerminatedByNonResponseAction();
    void setInfoOfSequenceTerminatedByAlarm(std::string);
    std::string getInfoOfSequenceTerminatedByAlarm();
    void setInfoSequenceTerminatedByNonResponseAction(std::string);
    std::string getInfoSequenceTerminatedByNonResponseAction();
    void copyScheduler(Scheduler &);
    void saveSchedulerToFile(std::ofstream &);
    void retrieveSchedulerFromFile(std::ifstream &);
    void setFileNameNodeMultiProcessor(std::string);
    void setFileNameIndeck(std::string);
    void setFileNameRestart(std::string);
    void setFileNameES(std::string);
    std::string getFileNameNodeMultiProcessor();
    std::string getFileNameIndeck();
    std::string getFileNameRestart();
    std::string getFileNameES();
    void setMiMode(ConsoleMode);
    ConsoleMode getMiMode();
    void resetScheduler();
    void parseOptions(int argc, char* argv[]);
    int getVizPort() const { return viz_port_; }
 
    // #ifndef _CONSOLE
       //  int getClusterNodeSequenceFromSrv() const;
       //  int getPENodeSequenceFromSrv() const;
       //  int getESNodeSequenceFromSrv() const;
    // #endif
private:
    ConsoleMode m_iMode;
    std::string project_directory, output_directory, es_directory, pe_directory, kps_directory;
    std::string input_deck_file_directory_and_name;
    std::string eop_directory, ODM_directory, OAT_directory, OCT_directory, support_systems_directory;
    std::string hardware_reliability_directory, indicators_directory, scheduler_directory, system_directory;
    double sequence_truncation_probabiliy, sequence_truncation_time;
    double OAT_action_time_multiplier, ODM_action_time_multiplier, OCT_action_time_multiplier;
    bool sequence_terminated_by_alarm;
    bool sequence_terminated_by_non_response_action;
    std::string info_of_sequence_terminated_by_alarm;
    std::string info_sequence_terminated_by_non_response_action;
    std::string file_name_NodeMultiProcessor, file_name_indeck, file_name_restart, file_name_ES;
    int solver_port_ = 9090;
    int viz_port_ = 0;
 
    friend class boost::serialization::access;
    template<class Archive>
    void serialize(Archive &ar, const unsigned int version) {
        ar & m_iMode;
        ar & project_directory;
        ar & output_directory;
        ar & es_directory;
        ar & pe_directory;
        ar & kps_directory;
        ar & input_deck_file_directory_and_name;
        ar & eop_directory;
        ar & ODM_directory;
        ar & OAT_directory;
        ar & OCT_directory;
        ar & support_systems_directory;
        ar & hardware_reliability_directory;
        ar & indicators_directory;
        ar & scheduler_directory;
        ar & system_directory;
        ar & sequence_truncation_probabiliy;
        ar & sequence_truncation_time;
        ar & OAT_action_time_multiplier;
        ar & ODM_action_time_multiplier;
        ar & OCT_action_time_multiplier;
        ar & sequence_terminated_by_alarm;
        ar & sequence_terminated_by_non_response_action;
        ar & info_of_sequence_terminated_by_alarm;
        ar & info_sequence_terminated_by_non_response_action;
        ar & file_name_NodeMultiProcessor;
        ar & file_name_indeck;
        ar & file_name_restart;
        ar & file_name_ES;
    }
};
 
 
BOOST_CLASS_EXPORT_KEY(Scheduler)