msgMpiSend.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_SEND_H
#define MSG_MPI_SEND_H
 
using namespace std;
 
#include "msgCommon.h"
#include "msgMpiPacked.h"
 
namespace openm
{
    class MpiSendBase
    {
    public:
        MpiSendBase(int i_selfRank, int i_sendTo, MsgTag i_msgTag);
 
        virtual ~MpiSendBase(void) noexcept;
 
        bool isCompleted(void);
 
    protected:
        int msgTag;         // MPI message tag
        int selfRank;       // source (ourself) MPI process rank
        int sendToRank;     // destination MPI process rank
        MPI_Request mpiRq;  // send request
 
    protected:
        // cleanup MPI send resources
        void cleanup(void) noexcept;
 
    private:
        MpiSendBase(const MpiSendBase & i_send) = delete;
        MpiSendBase & operator=(const MpiSendBase & i_send) = delete;
    };
 
    class MpiSendArray : public IMsgSendArray, public MpiSendBase
    {
    public:
        MpiSendArray(
            int i_selfRank, int i_sendTo, MsgTag i_msgTag, const type_info & i_type, size_t i_size, void * i_valueArr
            );
 
        ~MpiSendArray(void) noexcept { }
 
        bool isCompleted(void) { return MpiSendBase::isCompleted(); }
 
    private:
        unique_ptr<uint8_t[]> sendValueArr;     // copy of data to send
 
    private:
        MpiSendArray(const MpiSendArray & i_send) = delete;
        MpiSendArray & operator=(const MpiSendArray & i_send) = delete;
    };
 
    class MpiSendPacked : public MpiSendBase, public IMsgSendPacked
    {
    public:
        MpiSendPacked(
            int i_selfRank, int i_sendTo, const IRowBaseVec & i_rowVec, const IPackedAdapter & i_adapter
            );
 
        ~MpiSendPacked(void) noexcept { }
 
        bool isCompleted(void) { return MpiSendBase::isCompleted(); }
 
    private:
        vector<uint8_t> packedData;   // data to send
 
    private:
        MpiSendPacked(const MpiSendPacked & i_send) = delete;
        MpiSendPacked & operator=(const MpiSendPacked & i_send) = delete;
    };
}
 
#endif  // MSG_MPI_SEND_H