Commit b648cdb1 authored by Pietro Incardona's avatar Pietro Incardona

Fixing Sementic send interface

parent c20c6a40
...@@ -18,3 +18,7 @@ util/Vcluster_log.hpp ...@@ -18,3 +18,7 @@ util/Vcluster_log.hpp
.cu.o : .cu.o :
$(NVCC) $(NVCCFLAGS) -o $@ -c $< $(NVCC) $(NVCCFLAGS) -o $@ -c $<
test: vcluster
source $(HOME)/openfpm_vars && cd .. && mpirun -np 3 ./src/vcluster && mpirun -np 4 ./src/vcluster
...@@ -953,19 +953,13 @@ public: ...@@ -953,19 +953,13 @@ public:
*/ */
void execute() void execute()
{ {
int err = 0;
// if req == 0 return // if req == 0 return
if (req.size() == 0) if (req.size() == 0)
return; return;
// Wait for all the requests // Wait for all the requests
stat.resize(req.size()); stat.resize(req.size());
err = MPI_Waitall(req.size(),&req.get(0),&stat.get(0)); MPI_SAFE_CALL(MPI_Waitall(req.size(),&req.get(0),&stat.get(0)));
// MPI error get the message and abort MPI
if (err != MPI_SUCCESS)
MPI_Abort(MPI_COMM_WORLD,1);
// Remove executed request and status // Remove executed request and status
req.clear(); req.clear();
......
...@@ -17,6 +17,8 @@ void reset_recv_buf() ...@@ -17,6 +17,8 @@ void reset_recv_buf()
{ {
for (size_t i = 0 ; i < recv_buf.size() ; i++) for (size_t i = 0 ; i < recv_buf.size() ; i++)
recv_buf.get(i).resize(0); recv_buf.get(i).resize(0);
recv_buf.resize(0);
} }
/*! \brief Base info /*! \brief Base info
......
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