MPI_CoreToCoreMessage.h

#ifndef MPI_CoreToCoreMessage_H
#define MPI_CoreToCoreMessage_H
 
//inherited class header
#include "MPI_Object.h"
 
 
//types header
#include "MPI_Type.h"
 
//environement header
#include "MPI_Environment.h"
 
//MPI timer header
#include "MPI_Chrono.h"
 
template<typename T>
class MPI_CoreToCoreMessage : public MPI_Object  {
   
    //attributes
private :
  
    //UML inheritance classes
    typedef MPI_CoreToCoreMessage<T> SelfClass;
    typedef MPI_Object SuperClass;
    
    
protected:
    // CONSTRUCTORS 
    MPI_CoreToCoreMessage() {
        
    }
  
    // DESTRUCTORS 
    virtual ~MPI_CoreToCoreMessage(void) {
       
    }
public:
    //memory management
    //=================
    virtual tMemSize getMemorySize() const override{
        return sizeof(*this)+getContentsMemorySize();
    }
 
    virtual tMemSize getContentsMemorySize() const override {
        return SuperClass::getContentsMemorySize();
    }
    
    //sender methods
    //===============
    //primary type variable
    //----------------------
 
    //pointer of primary type
    //------------------------
    
    //valarray primary type
    //---------------------
public:
    virtual void send(const MPI_Environment& env,const tMPICoreId& dstCore,
                      const std::valarray<T>& data,const tMPITag& tag)=0;
    
    //MPI Type
    //---------
    virtual void send(const MPI_Environment& env,const tMPICoreId& dstCore,
                      const T* data,const tMPICount& nData,const tMPIType& dataType,const tMPITag& tag)=0;
    
    
    //receive methods
    //===============
 
    //primary type variable
    //----------------------
 
    //pointer of primary type
    //------------------------
    //valarray primary type
    //---------------------
    
    virtual void receive(const MPI_Environment& env,const tMPICoreId& srcCore,
                         std::valarray<T>& data,const tMPITag& tag)=0;
    
    //MPI Type
    //---------
 
 
    virtual void receive(const MPI_Environment& env,const tMPICoreId& dstCore,
                         T* buffer,const tMPICount& nData,const tMPIType& dataType,const tMPITag& tag)=0;
      
    //send & receive methods
    //=======================
 
    //primary type variable
    //----------------------
    virtual void sendNReceive(const MPI_Environment& env,const tMPICoreId& dstCore,const tMPICoreId& srcCore,
                              const T& sentData,const tMPITag& sentTag,
                              T& receivedData,const tMPITag& receivedTag)=0;
    //pointer of primary type
    //------------------------
    //valarray primary type
    //---------------------
    
    virtual void sendNReceive(const MPI_Environment& env,const tMPICoreId& dstCore,const tMPICoreId& srcCore,
                              const std::valarray<T>& sentData,const tMPITag& sentTag,
                              std::valarray<T>& receivedData,const tMPITag& receivedTag)=0;
 
    //MPI Type
    //---------
 
    
    virtual void sendNReceive(const MPI_Environment& env,const tMPICoreId& dstCore,const tMPICoreId& srcCore,
                              const T*  sentData,const tMPICount& nSentData,const tMPIType& sentDataType,const tMPITag& sentTag,
                              T* receivedData,const tMPICount& nReceivedData,const tMPIType& receivedDataType,const tMPITag& receivedTag)=0;
 
    //exchange methods
    //=======================
 
    //primary type variable
    //----------------------
 
    //pointer of primary type
    //------------------------
    //valarray primary type
    //---------------------
    
    virtual void exchange(const MPI_Environment& env,const tMPICoreId& srcCore,
                          std::valarray<T>& data,const tMPITag& tag)=0;
    
    //MPI Type
    //---------
 
 
 
    //mesage methods
    //==============   
   
 
    
    virtual void getElementsNumber(tMPICount& nElements)=0;
    
    virtual int wait()=0;
 
   
    virtual tBoolean isFinished()=0;
 
 
    inline static tULLInt  WaitAllMessages(const std::vector<CORE_UniquePointer<MPI_CoreToCoreMessage<T>>>& messages) {
        MPI_Chrono timer;
        timer.start();
        typename std::vector<CORE_UniquePointer<MPI_CoreToCoreMessage<T>>>::const_iterator iMessage;
        tBoolean isAllFinished=false;
        while (!isAllFinished) {
            isAllFinished=true;
            iMessage=messages.begin();
            while (iMessage!=messages.end()) {
                isAllFinished=isAllFinished && (*iMessage)->isFinished();
                iMessage++;
            }
        }
        return timer.stop();
    }
 
};
 
#endif