Changeset 1745 for XIOS/dev/dev_trunk_omp/src/event_scheduler.cpp
- Timestamp:
- 10/17/19 10:22:09 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/dev_trunk_omp/src/event_scheduler.cpp
r1646 r1745 139 139 while(received) 140 140 { 141 #ifdef _usingEP 141 142 MPI_Iprobe(-2,1,communicator,&received, &status) ; 143 #else 144 MPI_Iprobe(MPI_ANY_SOURCE,1,communicator,&received, &status) ; 145 #endif 142 146 if (received) 143 147 { 144 148 recvRequest=new SPendingRequest ; 149 #ifdef _usingEP 145 150 MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, -2, 1, communicator, &(recvRequest->request)) ; 151 #else 152 MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, MPI_ANY_SOURCE, 1, communicator, &(recvRequest->request)) ; 153 #endif 146 154 pendingRecvParentRequest.push(recvRequest) ; 147 155 } … … 181 189 while(received) 182 190 { 191 #ifdef _usingEP 183 192 MPI_Iprobe(-2,0,communicator,&received, &status) ; 193 #else 194 MPI_Iprobe(MPI_ANY_SOURCE,0,communicator,&received, &status) ; 195 #endif 184 196 if (received) 185 197 { 186 198 recvRequest=new SPendingRequest ; 199 #ifdef _usingEP 187 200 MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, -2, 0, communicator, &recvRequest->request) ; 201 #else 202 MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, MPI_ANY_SOURCE, 0, communicator, &recvRequest->request) ; 203 #endif 188 204 pendingRecvChildRequest.push_back(recvRequest) ; 189 205 }
Note: See TracChangeset
for help on using the changeset viewer.