diff --git a/src/VirtualFluids_GPU/Communication/Communicator.cpp b/src/VirtualFluids_GPU/Communication/Communicator.cpp index c094f3c7707acdd0afb66e9119078f9d8c185f9d..d362f79b46a3266f5371adeb678b8c874bb3110a 100644 --- a/src/VirtualFluids_GPU/Communication/Communicator.cpp +++ b/src/VirtualFluids_GPU/Communication/Communicator.cpp @@ -152,6 +152,10 @@ void Communicator::barrierGPU() //printf("\n End Waitall \n"); //fflush(stdout); } +void Communicator::barrier() +{ + MPI_Barrier(commGPU); +} ////////////////////////////////////////////////////////////////////////// void Communicator::exchngDataGeo( int* sbuf_t, int* rbuf_t, int* sbuf_b, int* rbuf_b, int count ) diff --git a/src/VirtualFluids_GPU/Communication/Communicator.h b/src/VirtualFluids_GPU/Communication/Communicator.h index 94dd51406fa4b8a141c05bfc7fa7db14c12cdb65..47bc3e632119934df9d80038566bf888695ad5cd 100644 --- a/src/VirtualFluids_GPU/Communication/Communicator.h +++ b/src/VirtualFluids_GPU/Communication/Communicator.h @@ -45,6 +45,7 @@ public: void waitGPU(int id); void resetRequest(); void barrierGPU(); + void barrier(); ////////////////////////////////////////////////////////////////////////// void exchngDataGeo(int* sbuf_t, int* rbuf_t, int* sbuf_b, int* rbuf_b, int count); MPI_Comm getCommunicator();