MPIWorkerHandler.h

#ifndef MPIWORKERHANDLER_H
#define MPIWORKERHANDLER_H

#include <string>

#include <mpi.h>

#include "AbstractWorkerHandler.h"

class MPIWorkerHandler : public AbstractWorkerHandler
{

    public:

        MPIWorkerHandler(const Command& simulator, const std::string&
                input_string);

        virtual ~MPIWorkerHandler() override;

        virtual bool isDone() override;

        static void terminateStatic();

    private:

        // Receive message from Worker
        std::string receiveMessage() const;

        // Receive error code from Worker
        int receiveErrorCode() const;

        // Discard results from MPI process
        void discardResults();

        // Intercomm with child
        // This intercommunicator is static so that it survives across multiple
        // instances of MPIWorkerHandler
        static MPI_Comm s_child_comm;

        // Flag for receiving result
        bool m_result_received = false;
};

#endif // MPIWORKERHANDLER_H