| 81 |
#endif |
#endif |
| 82 |
CEOP |
CEOP |
| 83 |
|
|
|
#ifdef USE_SINGLE_THREADED_EXCH_COMMS |
|
| 84 |
INTEGER myBxLoSave(MAX_NO_THREADS) |
INTEGER myBxLoSave(MAX_NO_THREADS) |
| 85 |
INTEGER myBxHiSave(MAX_NO_THREADS) |
INTEGER myBxHiSave(MAX_NO_THREADS) |
| 86 |
INTEGER myByLoSave(MAX_NO_THREADS) |
INTEGER myByLoSave(MAX_NO_THREADS) |
| 87 |
INTEGER myByHiSave(MAX_NO_THREADS) |
INTEGER myByHiSave(MAX_NO_THREADS) |
| 88 |
#endif /* SINGLE_THREADED_EXCH_COMMS */ |
LOGICAL doingSingleThreadedComms |
| 89 |
|
|
| 90 |
#ifdef USE_SINGLE_THREADED_EXCH_COMMS |
doingSingleThreadedComms = .FALSE. |
| 91 |
_BARRIER |
#ifdef ALLOW_USE_MPI |
| 92 |
IF ( myThid .EQ. 1 ) THEN |
#ifndef ALWAYS_USE_MPI |
| 93 |
DO I=1,nThreads |
IF ( usingMPI ) THEN |
| 94 |
myBxLoSave(I) = myBxLo(I) |
#endif |
| 95 |
myBxHiSave(I) = myBxHi(I) |
C Set default behavior to have MPI comms done by a single thread. |
| 96 |
myByLoSave(I) = myByLo(I) |
C Most MPI implementations don't support concurrent comms from |
| 97 |
myByHiSave(I) = myByHi(I) |
C several threads. |
| 98 |
myBxLo(I) = 0 |
IF ( nThreads .GT. 1 ) THEN |
| 99 |
myBxHi(I) = -1 |
_BARRIER |
| 100 |
myByLo(I) = 0 |
_BEGIN_MASTER( myThid ) |
| 101 |
myByHi(I) = -1 |
DO I=1,nThreads |
| 102 |
ENDDO |
myBxLoSave(I) = myBxLo(I) |
| 103 |
myBxLo(1) = 1 |
myBxHiSave(I) = myBxHi(I) |
| 104 |
myBxHi(1) = nSx |
myByLoSave(I) = myByLo(I) |
| 105 |
myByLo(1) = 1 |
myByHiSave(I) = myByHi(I) |
| 106 |
myByHi(1) = nSy |
ENDDO |
| 107 |
|
C Comment out loop below and myB[xy][Lo|Hi](1) settings below |
| 108 |
|
C if you want to get multi-threaded MPI comms. |
| 109 |
|
DO I=1,nThreads |
| 110 |
|
myBxLo(I) = 0 |
| 111 |
|
myBxHi(I) = -1 |
| 112 |
|
myByLo(I) = 0 |
| 113 |
|
myByHi(I) = -1 |
| 114 |
|
ENDDO |
| 115 |
|
myBxLo(1) = 1 |
| 116 |
|
myBxHi(1) = nSx |
| 117 |
|
myByLo(1) = 1 |
| 118 |
|
myByHi(1) = nSy |
| 119 |
|
doingSingleThreadedComms = .TRUE. |
| 120 |
|
_END_MASTER( myThid ) |
| 121 |
|
_BARRIER |
| 122 |
ENDIF |
ENDIF |
| 123 |
_BARRIER |
#ifndef ALWAYS_USE_MPI |
| 124 |
#endif /* SINGLE_THREADED_EXCH_COMMS */ |
ENDIF |
| 125 |
|
#endif |
| 126 |
|
#endif |
| 127 |
|
|
| 128 |
C-- Under a "put" scenario we |
C-- Under a "put" scenario we |
| 129 |
C-- i. set completetion signal for buffer we put into. |
C-- i. set completetion signal for buffer we put into. |
| 361 |
ENDDO |
ENDDO |
| 362 |
ENDDO |
ENDDO |
| 363 |
|
|
| 364 |
#ifdef USE_SINGLE_THREADED_EXCH_COMMS |
IF ( doingSingleThreadedComms ) THEN |
| 365 |
_BARRIER |
C Restore saved settings that were stored to allow |
| 366 |
IF ( myThid .EQ. 1 ) THEN |
C single thred comms. |
| 367 |
DO I=1,nThreads |
_BARRIER |
| 368 |
myBxLo(I) = myBxLoSave(I) |
_BEGIN_MASTER(myThid) |
| 369 |
myBxHi(I) = myBxHiSave(I) |
DO I=1,nThreads |
| 370 |
myByLo(I) = myByLoSave(I) |
myBxLo(I) = myBxLoSave(I) |
| 371 |
myByHi(I) = myByHiSave(I) |
myBxHi(I) = myBxHiSave(I) |
| 372 |
ENDDO |
myByLo(I) = myByLoSave(I) |
| 373 |
ENDIF |
myByHi(I) = myByHiSave(I) |
| 374 |
_BARRIER |
ENDDO |
| 375 |
#endif /* USE_SINGLE_THREADED_EXCH_COMMS */ |
_END_MASTER(myThid) |
| 376 |
|
_BARRIER |
| 377 |
|
ENDIF |
| 378 |
|
|
| 379 |
RETURN |
RETURN |
| 380 |
END |
END |