Changeset 1638 for XIOS/trunk/src/filter/spatial_transform_filter.cpp
- Timestamp:
- 01/22/19 16:15:03 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/trunk/src/filter/spatial_transform_filter.cpp
r1637 r1638 224 224 225 225 idxSendBuff = 0; 226 std::vector< MPI_Request> sendRecvRequest;226 std::vector<ep_lib::MPI_Request> sendRecvRequest; 227 227 for (itSend = itbSend; itSend != iteSend; ++itSend, ++idxSendBuff) 228 228 { … … 234 234 sendBuff[idxSendBuff][idx] = dataCurrentSrc(localIndex_p(idx)); 235 235 } 236 sendRecvRequest.push_back( MPI_Request());237 MPI_Isend(sendBuff[idxSendBuff], countSize, MPI_DOUBLE, destRank, 12, client->intraComm, &sendRecvRequest.back());236 sendRecvRequest.push_back(ep_lib::MPI_Request()); 237 ep_lib::MPI_Isend(sendBuff[idxSendBuff], countSize, EP_DOUBLE, destRank, 12, client->intraComm, &sendRecvRequest.back()); 238 238 } 239 239 … … 252 252 int srcRank = itRecv->first; 253 253 int countSize = itRecv->second.size(); 254 sendRecvRequest.push_back( MPI_Request());255 MPI_Irecv(recvBuff + currentBuff, countSize, MPI_DOUBLE, srcRank, 12, client->intraComm, &sendRecvRequest.back());254 sendRecvRequest.push_back(ep_lib::MPI_Request()); 255 ep_lib::MPI_Irecv(recvBuff + currentBuff, countSize, EP_DOUBLE, srcRank, 12, client->intraComm, &sendRecvRequest.back()); 256 256 currentBuff += countSize; 257 257 } 258 std::vector< MPI_Status> status(sendRecvRequest.size());259 MPI_Waitall(sendRecvRequest.size(), &sendRecvRequest[0], &status[0]);258 std::vector<ep_lib::MPI_Status> status(sendRecvRequest.size()); 259 ep_lib::MPI_Waitall(sendRecvRequest.size(), &sendRecvRequest[0], &status[0]); 260 260 261 261 dataCurrentDest.resize(*itNbListRecv);
Note: See TracChangeset
for help on using the changeset viewer.