--- trunk/src/io/RestWriter.cpp 2014/02/20 16:27:30 1968 +++ trunk/src/io/RestWriter.cpp 2014/02/26 14:14:50 1969 @@ -78,7 +78,7 @@ namespace OpenMD { #ifdef IS_MPI - MPI::Status istatus; + MPI_Status* istatus; #endif #ifndef IS_MPI @@ -148,19 +148,21 @@ namespace OpenMD { (*output_) << "#time\t"; (*output_) << buffer; - int nProc = MPI::COMM_WORLD.Get_size(); + int nProc; + MPI_Comm_size( MPI_COMM_WORLD, &nProc); + for (int i = 1; i < nProc; ++i) { // receive the length of the string buffer that was // prepared by processor i int recvLength; - MPI::COMM_WORLD.Recv(&recvLength, 1, MPI::INT, i, 0, istatus); + MPI_Recv(&recvLength, 1, MPI_INT, i, 0, MPI_COMM_WORLD, istatus); char* recvBuffer = new char[recvLength]; if (recvBuffer == NULL) { } else { - MPI::COMM_WORLD.Recv(recvBuffer, recvLength, MPI::CHAR, i, 0, - istatus); + MPI_Recv(recvBuffer, recvLength, MPI_CHAR, i, 0, MPI_COMM_WORLD, + istatus); (*output_) << recvBuffer; delete [] recvBuffer; } @@ -168,9 +170,9 @@ namespace OpenMD { (*output_).flush(); } else { int sendBufferLength = buffer.size() + 1; - MPI::COMM_WORLD.Send(&sendBufferLength, 1, MPI::INT, masterNode, 0); - MPI::COMM_WORLD.Send((void *)buffer.c_str(), sendBufferLength, MPI::CHAR, - masterNode, 0); + MPI_Send(&sendBufferLength, 1, MPI_INT, masterNode, 0, MPI_COMM_WORLD); + MPI_Send((void *)buffer.c_str(), sendBufferLength, MPI_CHAR, + masterNode, 0, MPI_COMM_WORLD); } #endif // is_mpi @@ -180,7 +182,7 @@ namespace OpenMD { void RestWriter::writeRest(std::vector > restInfo) { #ifdef IS_MPI - MPI::Status istatus; + MPI_Status* istatus; #endif #ifndef IS_MPI @@ -224,19 +226,19 @@ namespace OpenMD { (*output_) << buffer; int nProc; - nProc = MPI::COMM_WORLD.Get_size(); + MPI_Comm_size( MPI_COMM_WORLD, &nProc); for (int i = 1; i < nProc; ++i) { // receive the length of the string buffer that was // prepared by processor i int recvLength; - MPI::COMM_WORLD.Recv(&recvLength, 1, MPI::INT, i, 0, istatus); + MPI_Recv(&recvLength, 1, MPI_INT, i, 0, MPI_COMM_WORLD, istatus); char* recvBuffer = new char[recvLength]; if (recvBuffer == NULL) { } else { - MPI::COMM_WORLD.Recv(recvBuffer, recvLength, MPI::CHAR, i, 0, - istatus); + MPI_Recv(recvBuffer, recvLength, MPI_CHAR, i, 0, MPI_COMM_WORLD, + istatus); (*output_) << recvBuffer; delete [] recvBuffer; @@ -245,9 +247,9 @@ namespace OpenMD { (*output_).flush(); } else { int sendBufferLength = buffer.size() + 1; - MPI::COMM_WORLD.Send(&sendBufferLength, 1, MPI::INT, masterNode, 0); - MPI::COMM_WORLD.Send((void *)buffer.c_str(), sendBufferLength, - MPI::CHAR, masterNode, 0); + MPI_Send(&sendBufferLength, 1, MPI_INT, masterNode, 0, MPI_COMM_WORLD); + MPI_Send((void *)buffer.c_str(), sendBufferLength, + MPI_CHAR, masterNode, 0, MPI_COMM_WORLD); } #endif // is_mpi }