--- trunk/src/io/RestWriter.cpp 2010/05/10 17:28:26 1442 +++ branches/development/src/io/RestWriter.cpp 2013/02/20 15:39:39 1850 @@ -35,8 +35,9 @@ * * [1] Meineke, et al., J. Comp. Chem. 26, 252-271 (2005). * [2] Fennell & Gezelter, J. Chem. Phys. 124, 234104 (2006). - * [3] Sun, Lin & Gezelter, J. Chem. Phys. 128, 24107 (2008). - * [4] Vardeman & Gezelter, in progress (2009). + * [3] Sun, Lin & Gezelter, J. Chem. Phys. 128, 234107 (2008). + * [4] Kuang & Gezelter, J. Chem. Phys. 133, 164101 (2010). + * [5] Vardeman, Stocker & Gezelter, J. Chem. Theory Comput. 7, 834 (2011). */ @@ -77,7 +78,7 @@ namespace OpenMD { #ifdef IS_MPI - MPI_Status istatus; + MPI::Status istatus; #endif #ifndef IS_MPI @@ -147,20 +148,19 @@ namespace OpenMD { (*output_) << "#time\t"; (*output_) << buffer; - int nProc; - MPI_Comm_size(MPI_COMM_WORLD, &nProc); + int nProc = MPI::COMM_WORLD.Get_size(); for (int i = 1; i < nProc; ++i) { // receive the length of the string buffer that was // prepared by processor i int recvLength; - MPI_Recv(&recvLength, 1, MPI_INT, i, 0, MPI_COMM_WORLD, &istatus); + MPI::COMM_WORLD.Recv(&recvLength, 1, MPI::INT, i, 0, istatus); char* recvBuffer = new char[recvLength]; if (recvBuffer == NULL) { } else { - MPI_Recv(recvBuffer, recvLength, MPI_CHAR, i, 0, MPI_COMM_WORLD, - &istatus); + MPI::COMM_WORLD.Recv(recvBuffer, recvLength, MPI::CHAR, i, 0, + istatus); (*output_) << recvBuffer; delete [] recvBuffer; } @@ -168,9 +168,9 @@ namespace OpenMD { (*output_).flush(); } else { int sendBufferLength = buffer.size() + 1; - 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); + MPI::COMM_WORLD.Send(&sendBufferLength, 1, MPI::INT, masterNode, 0); + MPI::COMM_WORLD.Send((void *)buffer.c_str(), sendBufferLength, MPI::CHAR, + masterNode, 0); } #endif // is_mpi @@ -180,7 +180,7 @@ namespace OpenMD { void RestWriter::writeRest(std::vector > restInfo) { #ifdef IS_MPI - MPI_Status istatus; + MPI::Status istatus; #endif #ifndef IS_MPI @@ -224,19 +224,19 @@ namespace OpenMD { (*output_) << buffer; int nProc; - MPI_Comm_size(MPI_COMM_WORLD, &nProc); + nProc = MPI::COMM_WORLD.Get_size(); for (int i = 1; i < nProc; ++i) { // receive the length of the string buffer that was // prepared by processor i int recvLength; - MPI_Recv(&recvLength, 1, MPI_INT, i, 0, MPI_COMM_WORLD, &istatus); + MPI::COMM_WORLD.Recv(&recvLength, 1, MPI::INT, i, 0, istatus); char* recvBuffer = new char[recvLength]; if (recvBuffer == NULL) { } else { - MPI_Recv(recvBuffer, recvLength, MPI_CHAR, i, 0, MPI_COMM_WORLD, - &istatus); + MPI::COMM_WORLD.Recv(recvBuffer, recvLength, MPI::CHAR, i, 0, + istatus); (*output_) << recvBuffer; delete [] recvBuffer; @@ -245,9 +245,9 @@ namespace OpenMD { (*output_).flush(); } else { int sendBufferLength = buffer.size() + 1; - 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); + MPI::COMM_WORLD.Send(&sendBufferLength, 1, MPI::INT, masterNode, 0); + MPI::COMM_WORLD.Send((void *)buffer.c_str(), sendBufferLength, + MPI::CHAR, masterNode, 0); } #endif // is_mpi }