MPI_RAMIO.h

#ifndef MPI_RAMIO_H
#define MPI_RAMIO_H
 
//inherited header
#include "MPI_Object.h"
 
//mpi environment header
#include "MPI_Environment.h"
 
//mpi type header
#include "MPI_Type.h"
 
template<typename T>
class MPI_RAMIO : public MPI_Object  {
    
    //attributes
private :
    std::valarray<T> mMemory;
    int mMPITSize;//MPI size of T
    MPI_Win mWin;//ramWindow
public:
    // CONSTRUCTORS 
    MPI_RAMIO() {
        MPI_Type::GetSize<T>(mMPITSize);
    }
    
    // DESTRUCTORS 
    virtual ~MPI_RAMIO(void) {
        
    }
    
    MPI_RAMIO<T>& operator=(const T& value) {
        if (value==0) {
            memset(&mMemory[0],0,sizeof(T)*mMemory.size());
        } else {
            for(auto& v:mMemory) {
                v=value;
            }
        }
        return *this;
    }
    
    
    inline void openRAMWindow(const MPI_Environment& env,const tMPICount& n) {
        mMemory.resize(n);
        MPI_Win_create(&mMemory[0],(tMPIByte) mMPITSize*n,mMPITSize,MPI_INFO_NULL,env.getWorld(),&mWin);
    }
    inline void closeRAMWindow() {
        MPI_Win_free(&mWin);
        
    }
    inline void flush() {
        MPI_Win_fence(0,mWin);
    }
    
    //IO methods
    //===============
    
    inline void read(std::valarray<T>& values,const tMPICoreId& srcCore) {
        MPI_Get(&values[0],values.size(),MPI_Type::GetPrimaryType<T>(),
                srcCore,0,values.size(),MPI_Type::GetPrimaryType<T>(),mWin);
    }
    inline void write(const std::valarray<T>& values,const tMPICoreId& destCore) {
        MPI_Put(&values[0],values.size(),MPI_Type::GetPrimaryType<T>(),
                destCore,0,values.size(),MPI_Type::GetPrimaryType<T>(),mWin);
    }
    
    
 
};
 
#endif