msgMpiRecv.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_MPI_RECV_H
#define MSG_MPI_RECV_H
 
using namespace std;
 
#include "msgCommon.h"
 
namespace openm
{
    class MpiRecvArray : public IMsgRecvArray
    {
    public:
        MpiRecvArray(
            int i_selfRank, int i_recvFrom, MsgTag i_msgTag, const type_info & i_type, size_t i_size, void * io_valueArr
            ) :
            msgTag((int)i_msgTag),
            isReceived(false),
            selfRank(i_selfRank),
            recvFromRank(i_recvFrom),
            resultSize(i_size),
            resultValueArr(io_valueArr),
            mpiType(MpiPacked::toMpiType(i_type))
        { }
 
        ~MpiRecvArray(void) noexcept { }
 
        bool tryReceive(void);
 
    private:
        int msgTag;             // MPI message tag
        bool isReceived;        // if true the data received and unpacked
        int selfRank;           // destination (ourself) MPI process rank
        int recvFromRank;       // source MPI process rank
        size_t resultSize;      // expected size of array
        void * resultValueArr;  // received data
        MPI_Datatype mpiType;   // MPI type to receive
 
    private:
        MpiRecvArray(const MpiRecvArray & i_recv) = delete;
        MpiRecvArray & operator=(const MpiRecvArray & i_recv) = delete;
    };
 
    class MpiRecvPacked : public IMsgRecvPacked
    {
    public:
        MpiRecvPacked(
            int i_selfRank, int i_recvFrom, IRowBaseVec & io_resultRowVec, const IPackedAdapter & i_adapter
            ) :
            isReceived(false),
            selfRank(i_selfRank),
            recvFromRank(i_recvFrom),
            resultRowVec(io_resultRowVec),
            packAdp(i_adapter)
        { }
 
        ~MpiRecvPacked(void) noexcept { }
 
        bool tryReceive(void);
 
    private:
        bool isReceived;                // if true the data received and unpacked
        int selfRank;                   // destination (ourself) MPI process rank
        int recvFromRank;               // source MPI process rank
        IRowBaseVec & resultRowVec;     // received data
        const IPackedAdapter & packAdp; // adapter to unpack received data
 
    private:
        MpiRecvPacked(const MpiRecvPacked & i_recv) = delete;
        MpiRecvPacked & operator=(const MpiRecvPacked & i_recv) = delete;
    };
}
 
#endif  // MSG_MPI_RECV_H