msgCommon.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_COMMON_H
#define MSG_COMMON_H
 
#include <climits>
#include <cstdint>
#include <memory>
#include <mutex>
#include <string>
#include <vector>
using namespace std;
 
#include "helper.h"
#include "msg.h"
 
namespace openm
{
    class IMsgSend
    {
    public:
        virtual ~IMsgSend(void) noexcept = 0;
 
        virtual bool isCompleted(void) = 0;
    };
 
    class IMsgSendArray : public IMsgSend
    {
    public:
        virtual ~IMsgSendArray(void) noexcept = 0;
 
        static IMsgSendArray * create(
            int i_selfRank, int i_sendTo, MsgTag i_msgTag, const type_info & i_type, size_t i_size, void * i_valueArr
            );
    };
 
    class IMsgSendPacked : public IMsgSend
    {
    public:
        virtual ~IMsgSendPacked(void) noexcept = 0;
 
        static IMsgSendPacked * create(
            int i_selfRank, int i_sendTo, const IRowBaseVec & i_rowVec, const IPackedAdapter & i_adapter
            );
    };
 
    class IMsgRecv
    {
    public:
        virtual ~IMsgRecv(void) noexcept = 0;
 
        virtual bool tryReceive(void) = 0;
    };
 
    class IMsgRecvArray : public IMsgRecv
    {
    public:
        virtual ~IMsgRecvArray(void) noexcept = 0;
 
        static IMsgRecvArray * create(
            int i_selfRank, int i_recvFrom, MsgTag i_msgTag, const type_info & i_type, size_t i_size, void * io_valueArr
            );
    };
 
    class IMsgRecvPacked : public IMsgRecv
    {
    public:
        virtual ~IMsgRecvPacked(void) noexcept = 0;
 
        static IMsgRecvPacked * create(
            int i_selfRank, int i_recvFrom, IRowBaseVec & io_resultRowVec, const IPackedAdapter & i_adapter
            );
    };
}
 
// define OM_MSG_MPI   to use message passing library based on MPI
// define OM_MSG_EMPTY to use empty version message passing library
//      empty version does nothing but don't require MPI installed
 
#ifdef OM_MSG_EMPTY
    #include "msgEmpty.h"
#elif OM_MSG_MPI
    #include <mpi.h>
    #include "msgMpi.h"
#else       // not defined any of OM_MSG_*
    #error No message passing providers defined
#endif      // OM_MSG_MPI
 
#endif  // MSG_COMMON_H