MPI_IrecvW.hpp

#ifndef MPI_IRECV_HPP
#define MPI_IRECV_HPP


#include <mpi.h>

class MPI_IrecvWB
{
public:

    static inline void recv(size_t proc , size_t tag ,void * buf, size_t sz, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(buf,sz,MPI_BYTE, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<typename T> class MPI_IrecvW
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<T> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size() * sizeof(T),MPI_BYTE, proc, tag , MPI_COMM_WORLD,&req));
    }
};


template<> class MPI_IrecvW<int>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<int> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_INT, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<unsigned int>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<unsigned int> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_UNSIGNED, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<short>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<short> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_SHORT, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<unsigned short>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<unsigned short> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_UNSIGNED_SHORT, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<char>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<char> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_CHAR, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<unsigned char>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<unsigned char> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_UNSIGNED_CHAR, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<size_t>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<size_t> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_UNSIGNED_LONG, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<long int>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<long int> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_LONG, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<float>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<float> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_FLOAT, proc, tag , MPI_COMM_WORLD,&req));
    }
};

template<> class MPI_IrecvW<double>
{
public:
    static inline void recv(size_t proc , size_t tag ,openfpm::vector<double> & v, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Irecv(v.getPointer(), v.size(),MPI_DOUBLE, proc, tag , MPI_COMM_WORLD,&req));
    }
};

#endif