154 |
theTag = _tileTagRecvW(bi,bj) |
theTag = _tileTagRecvW(bi,bj) |
155 |
theType = _MPI_TYPE_RX |
theType = _MPI_TYPE_RX |
156 |
theSize = sNy*exchWidthX*myNz |
theSize = sNy*exchWidthX*myNz |
157 |
|
# ifndef ALLOW_AUTODIFF_OPENAD |
158 |
CALL MPI_Recv( westRecvBuf_RX(1,eBl,bi,bj), theSize, theType, |
CALL MPI_Recv( westRecvBuf_RX(1,eBl,bi,bj), theSize, theType, |
159 |
& theProc, theTag, MPI_COMM_MODEL, |
& theProc, theTag, MPI_COMM_MODEL, |
160 |
& mpiStatus, mpiRc ) |
& mpiStatus, mpiRc ) |
161 |
|
# else |
162 |
|
CALL ampi_recv_RX( |
163 |
|
& westRecvBuf_RX(1,eBl,bi,bj) , |
164 |
|
& theSize , |
165 |
|
& theType , |
166 |
|
& theProc , |
167 |
|
& theTag , |
168 |
|
& MPI_COMM_MODEL , |
169 |
|
& exchReqIdX(exchNReqsX(1,bi,bj)+1,1,bi,bj), |
170 |
|
& exchNReqsX(1,bi,bj), |
171 |
|
& mpiStatus , |
172 |
|
& mpiRc ) |
173 |
|
# endif /* ALLOW_AUTODIFF_OPENAD */ |
174 |
#ifndef ALWAYS_USE_MPI |
#ifndef ALWAYS_USE_MPI |
175 |
ENDIF |
ENDIF |
176 |
#endif |
#endif |
185 |
theTag = _tileTagRecvE(bi,bj) |
theTag = _tileTagRecvE(bi,bj) |
186 |
theType = _MPI_TYPE_RX |
theType = _MPI_TYPE_RX |
187 |
theSize = sNy*exchWidthX*myNz |
theSize = sNy*exchWidthX*myNz |
188 |
|
# ifndef ALLOW_AUTODIFF_OPENAD |
189 |
CALL MPI_Recv( eastRecvBuf_RX(1,eBl,bi,bj), theSize, theType, |
CALL MPI_Recv( eastRecvBuf_RX(1,eBl,bi,bj), theSize, theType, |
190 |
& theProc, theTag, MPI_COMM_MODEL, |
& theProc, theTag, MPI_COMM_MODEL, |
191 |
& mpiStatus, mpiRc ) |
& mpiStatus, mpiRc ) |
192 |
|
# else |
193 |
|
CALL ampi_recv_RX( |
194 |
|
& eastRecvBuf_RX(1,eBl,bi,bj) , |
195 |
|
& theSize , |
196 |
|
& theType , |
197 |
|
& theProc , |
198 |
|
& theTag , |
199 |
|
& MPI_COMM_MODEL , |
200 |
|
& exchReqIdX(exchNReqsX(1,bi,bj)+1,1,bi,bj), |
201 |
|
& exchNReqsX(1,bi,bj), |
202 |
|
& mpiStatus , |
203 |
|
& mpiRc ) |
204 |
|
# endif /* ALLOW_AUTODIFF_OPENAD */ |
205 |
#ifndef ALWAYS_USE_MPI |
#ifndef ALWAYS_USE_MPI |
206 |
ENDIF |
ENDIF |
207 |
#endif |
#endif |
223 |
ebL = exchangeBufLevel(1,bi,bj) |
ebL = exchangeBufLevel(1,bi,bj) |
224 |
westCommMode = _tileCommModeW(bi,bj) |
westCommMode = _tileCommModeW(bi,bj) |
225 |
eastCommMode = _tileCommModeE(bi,bj) |
eastCommMode = _tileCommModeE(bi,bj) |
226 |
|
# ifndef ALLOW_AUTODIFF_OPENAD |
227 |
10 CONTINUE |
10 CONTINUE |
228 |
CALL FOOL_THE_COMPILER( spinCount ) |
CALL FOOL_THE_COMPILER( spinCount ) |
229 |
spinCount = spinCount+1 |
spinCount = spinCount+1 |
233 |
C ENDIF |
C ENDIF |
234 |
IF ( westRecvAck(eBl,bi,bj) .EQ. 0 ) GOTO 10 |
IF ( westRecvAck(eBl,bi,bj) .EQ. 0 ) GOTO 10 |
235 |
IF ( eastRecvAck(eBl,bi,bj) .EQ. 0 ) GOTO 10 |
IF ( eastRecvAck(eBl,bi,bj) .EQ. 0 ) GOTO 10 |
236 |
|
# else |
237 |
|
do while ((westRecvAck(eBl,bi,bj) .EQ. 0. |
238 |
|
& .or. |
239 |
|
& eastRecvAck(eBl,bi,bj) .EQ. 0. )) |
240 |
|
CALL FOOL_THE_COMPILER( spinCount ) |
241 |
|
spinCount = spinCount+1 |
242 |
|
end do |
243 |
|
# endif /* ALLOW_AUTODIFF_OPENAD */ |
244 |
C Clear outstanding requests |
C Clear outstanding requests |
245 |
westRecvAck(eBl,bi,bj) = 0 |
westRecvAck(eBl,bi,bj) = 0 |
246 |
eastRecvAck(eBl,bi,bj) = 0 |
eastRecvAck(eBl,bi,bj) = 0 |
250 |
#ifndef ALWAYS_USE_MPI |
#ifndef ALWAYS_USE_MPI |
251 |
IF ( usingMPI ) THEN |
IF ( usingMPI ) THEN |
252 |
#endif |
#endif |
253 |
|
# ifndef ALLOW_AUTODIFF_OPENAD |
254 |
CALL MPI_Waitall( exchNReqsX(1,bi,bj), exchReqIdX(1,1,bi,bj), |
CALL MPI_Waitall( exchNReqsX(1,bi,bj), exchReqIdX(1,1,bi,bj), |
255 |
& mpiStatus, mpiRC ) |
& mpiStatus, mpiRC ) |
256 |
|
# else |
257 |
|
CALL ampi_waitall( |
258 |
|
& exchNReqsX(1,bi,bj), |
259 |
|
& exchReqIdX(1,1,bi,bj), |
260 |
|
& mpiStatus, |
261 |
|
& mpiRC ) |
262 |
|
# endif /* ALLOW_AUTODIFF_OPENAD */ |
263 |
#ifndef ALWAYS_USE_MPI |
#ifndef ALWAYS_USE_MPI |
264 |
ENDIF |
ENDIF |
265 |
#endif |
#endif |