Commit 88038776 authored by incardon's avatar incardon

Adding barrier

parent a9991812
...@@ -439,6 +439,15 @@ class Vcluster: public Vcluster_base ...@@ -439,6 +439,15 @@ class Vcluster: public Vcluster_base
return true; return true;
} }
/*! \brief Just a call to mpi_barrier
*
*
*/
void barrier()
{
MPI_Barrier(MPI_COMM_WORLD);
}
/*! \brief Semantic Scatter, scatter the data from one processor to the other node /*! \brief Semantic Scatter, scatter the data from one processor to the other node
* *
* Semantic communication differ from the normal one. They in general * Semantic communication differ from the normal one. They in general
......
...@@ -55,7 +55,7 @@ struct unpack_selector_with_prp<true,T,S> ...@@ -55,7 +55,7 @@ struct unpack_selector_with_prp<true,T,S>
template<typename op, unsigned int ... prp> static void call_unpack(S & recv, openfpm::vector<BHeapMemory> & recv_buf, openfpm::vector<size_t> * sz, openfpm::vector<size_t> * sz_byte, op & op_param) template<typename op, unsigned int ... prp> static void call_unpack(S & recv, openfpm::vector<BHeapMemory> & recv_buf, openfpm::vector<size_t> * sz, openfpm::vector<size_t> * sz_byte, op & op_param)
{ {
if (sz_byte != NULL) if (sz_byte != NULL)
sz_byte->resize(recv_buf.size()); {sz_byte->resize(recv_buf.size());}
for (size_t i = 0 ; i < recv_buf.size() ; i++) for (size_t i = 0 ; i < recv_buf.size() ; i++)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment