ParallelExecution.h

Go to the documentation of this file.

 
 
#pragma once
#ifdef ENABLE_MPI
#include <mpi.h>
#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <chrono>
#include <thread>
#include <string>
#include <vector>
#include <filesystem>
#include "ParallelUtilities.h"
#include "ParallelGlobal.h"
#include "Server.h"
#include "Client.h"
 
#include "../System/SystemModule.h"
#include "../ControlPanel/ControlPanel.h"
#include "../Scheduler/InitiatingEventController.h"
#include "../Procedure/Procedures.h"
#include "../Global/RestartNodeInfo.h"
#include "../Branch/BranchRecord.h"
#include <sstream>
#include <iostream>
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>
#include <boost/archive/binary_oarchive.hpp>
#include <boost/archive/binary_iarchive.hpp>
 
extern Client* g_client;
 
void set_global_client(Client* c);
 
using PU = ParallelUtilities;
 
typedef double parameters;
 
class parallelexec {
public:
    int argc;
    char **argv;
    MPI_Status statusServer;
    MPI_Status statusClient;
    BranchEndState *es_pt;
    std::string str, time_begin, time_end;
    time_t t_current;
    RestartNodeInfo *restart_from_intfc;
 
    parallelexec();
 
    void parallel_init(int *argc, char **argv[]);
 
    void parallel_final();
 
    int ReceiveDonePacket();
    RestartNodeInfo *NewReceiveNumberOfBranches();
    void Start_Simulation();
    void Branch_Sequence(int i);
    void Simulate_Sequence();
 
    void Setup_Directories();
 
    template <typename T>
    static void saveToFile(const T& object, const std::string& filePath);
 
    template <typename T>
    static void loadFromFile(T& object, const std::string& filePath);
 
    template <typename T>
    static void send_object(const T& obj, int dest_rank, int tag, MPI_Comm comm);
 
    template <typename T>
    static void receive_object(T& obj, int src_rank, int tag, MPI_Comm comm);
};
#endif // ENABLE_MPI