msgExecBase.h

Go to the documentation of this file.

 
// Copyright (c) 2013-2015 OpenM++
// This code is licensed under the MIT license (see LICENSE.txt for details)
 
#ifndef MSG_EXEC_BASE_H
#define MSG_EXEC_BASE_H
 
#include <string>
#include <vector>
#include <mutex>
using namespace std;
 
#include "msg.h"
 
namespace openm
{
    class MsgExecBase
    {
    public:
        virtual ~MsgExecBase(void) noexcept { };
 
        int worldSize(void) const;
 
        int rank(void) const;
 
        int groupRank(void) const;
 
        void startSend(int i_sendTo, MsgTag i_msgTag, const type_info & i_type, size_t i_size, void * i_valueArr);
 
        void startSendPacked(int i_sendTo, const IRowBaseVec & i_rowVec, const IPackedAdapter & i_adapter);
 
        bool tryReceive(int i_recvFrom, MsgTag i_msgTag, const type_info & i_type, size_t i_size, void * io_valueArr) const;
 
        bool tryReceive(int i_recvFrom, IRowBaseVec & io_resultRowVec, const IPackedAdapter & i_adapter) const;
 
        void waitSendAll(void);
 
    protected:
        MsgExecBase(IFinalState * i_final) : worldCommSize(1), worldRank(0), group_rank(0), theFinal(i_final) { }
 
    protected:
        int worldCommSize;                  // total number of processes in world communicator
        int worldRank;                      // rank of process in world communicator
        int group_rank;                     // rank of process in group communicator
        IFinalState * theFinal = nullptr;   // final model run state interface
 
        list<unique_ptr<IMsgSend> > sendLst;    // list of active send requests
 
    private:
        MsgExecBase(const MsgExecBase & i_msgExec) = delete;
        MsgExecBase & operator=(const MsgExecBase & i_msgExec) = delete;
    };
 
    extern recursive_mutex msgMutex;
}
 
#endif  // MSG_EXEC_BASE_H