MPI_IsendW.hpp

#ifndef MPI_ISEND_HPP
#define MPI_ISEND_HPP
 
 
#include <mpi.h>
 
class MPI_IsendWB
{
public:
    static inline void send(size_t proc , size_t tag ,const void * buf, size_t sz, MPI_Request & req)
    {
        if (sz <= 2147483647)
        {
            MPI_Isend(buf, sz,MPI_BYTE, proc, tag , MPI_COMM_WORLD,&req);
        }
        else
        {
            MPI_Isend(buf, sz >> 3 ,MPI_DOUBLE, proc, tag , MPI_COMM_WORLD,&req);
        }
 
    }
};
 
template<typename T, typename Mem, template<typename> class gr> class MPI_IsendW
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<T,Mem,gr> & v, MPI_Request & req)
    {
        if (v.size() * sizeof(T) <= 2147483647)
        {
            MPI_Isend(v.getPointer(), v.size() * sizeof(T),MPI_BYTE, proc, tag , MPI_COMM_WORLD,&req);
        }
        else
        {
            MPI_Isend(v.getPointer(), (v.size() * sizeof(T)) >> 3,MPI_DOUBLE, proc, tag , MPI_COMM_WORLD,&req);
        }
    }
};
 
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<int,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<int,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_INT, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<unsigned int,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<unsigned int,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_UNSIGNED, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<short,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<short,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_SHORT, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<unsigned short,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<unsigned short,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_UNSIGNED_SHORT, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<char,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<char,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_CHAR, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<unsigned char,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<unsigned char,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_UNSIGNED_CHAR, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<size_t,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<size_t,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_UNSIGNED_LONG, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<long int,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<long int,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_LONG, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<float,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<float,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_FLOAT, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
template<typename Mem, template<typename> class gr> class MPI_IsendW<double,Mem,gr>
{
public:
    static inline void send(size_t proc , size_t tag ,openfpm::vector<double,Mem,gr> & v, MPI_Request & req)
    {
        MPI_Isend(v.getPointer(), v.size(),MPI_DOUBLE, proc, tag , MPI_COMM_WORLD,&req);
    }
};
 
#endif