MPI_IBcastW.hpp

/*
 * MPI_IBcastW.hpp
 *
 *  Created on: Apr 8, 2017
 *      Author: i-bird
 */

#ifndef OPENFPM_VCLUSTER_SRC_MPI_WRAPPER_MPI_IBCASTW_HPP_
#define OPENFPM_VCLUSTER_SRC_MPI_WRAPPER_MPI_IBCASTW_HPP_



#include <mpi.h>

class MPI_IBcastWB
{
public:
    static inline void bcast(size_t proc ,void * buf, size_t sz, MPI_Request & req)
    {
        MPI_SAFE_CALL(MPI_Ibcast(buf,sz,MPI_BYTE, proc , MPI_COMM_WORLD,&req));
    }
};

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


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

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

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

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

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

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

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

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

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

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


#endif /* OPENFPM_VCLUSTER_SRC_MPI_WRAPPER_MPI_IBCASTW_HPP_ */