34 USE spmd_mod
35
36
37
38#include "implicit_f.inc"
39
40
41
42#include "spmd.inc"
43
44
45
46#include "com01_c.inc"
47#include "task_c.inc"
48
49
50
51 INTEGER SIZE, IFLAG,
52 . FR_RMS(NSPMD+1), FR_SMS(NSPMD+1),LIST_RMS(*), LIST_SMS(*),
53 . IAD_SEND(NSPMD+1),IAD_RECV(NSPMD+1),
54 . REQ_R(NSPMD),REQ_S(NSPMD)
56 . v(SIZE,*), vfi(SIZE,*)
58 . rbuf(size*(fr_rms(nspmd+1)+fr_sms(nspmd+1))),
59 . sbuf(size*(fr_rms(nspmd+1)+fr_sms(nspmd+1)))
60
61
62
63#ifdef MPI
64 INTEGER MSGTYP,I,NOD,LOC_PROC,IERROR,MSGOFF,
65 . SIZ,J,L,NB_NOD,K,M,KK,
66 . STATUS(MPI_STATUS_SIZE)
67 DATA msgoff/217/
68
69
70
71 loc_proc = ispmd + 1
72
73 IF(iflag==1)THEN
74 l = 1
75 iad_recv(1) = 1
76 DO i=1,nspmd
77
78 siz = fr_rms(i+1) - fr_rms(i)
79 IF(i/=loc_proc)THEN
80 siz = siz + fr_sms(i+1) - fr_sms(i)
81 ENDIF
82 siz = size*siz
83
84 IF(siz/=0)THEN
85 msgtyp = msgoff
87 s rbuf(l),siz,real,it_spmd(i),msgtyp,
88 g spmd_comm_world,req_r(i),ierror)
89 ENDIF
90 l = l + siz
91 iad_recv(i+1) = l
92
93 END DO
94
95 l = 1
96 iad_send(1) = 1
97 m = 1
98 DO i=1,nspmd
99 IF(i/=loc_proc)THEN
100#include "vectorize.inc"
101 DO j=fr_sms(i),fr_sms(i+1)-1
102 nod = list_sms(m)
103 IF(nod/=0)THEN
104 DO k=1,SIZE
105 sbuf(l+k-1) = v(k,nod)
106 END DO
107 ELSE
108 DO k=1,SIZE
109 sbuf(l+k-1) = zero
110 END DO
111 END IF
112 l = l + SIZE
113 m = m + 1
114 END DO
115 END IF
116#include "vectorize.inc"
117 DO j=fr_rms(i),fr_rms(i+1)-1
118 nod = list_rms(j)
119 IF(nod/=0)THEN
120 DO k=1,SIZE
121 sbuf(l+k-1) = v(k,nod)
122 END DO
123 ELSE
124 DO k=1,SIZE
125 sbuf(l+k-1) = zero
126 END DO
127 END IF
128 l = l + SIZE
129 END DO
130 iad_send(i+1) = l
131 ENDDO
132
133
134
135 DO i=1,nspmd
136
137 IF(iad_send(i+1)-iad_send(i)>0)THEN
138 msgtyp = msgoff
139 siz = iad_send(i+1)-iad_send(i)
140 l = iad_send(i)
142 s sbuf(l),siz,real,it_spmd(i),msgtyp,
143 g spmd_comm_world,req_s(i),ierror)
144 ENDIF
145
146 ENDDO
147
148 ELSE
149
150 m = 1
151 kk= 1
152 DO i = 1, nspmd
153 IF(iad_recv(i+1)-iad_recv(i)>0)THEN
154 CALL mpi_wait(req_r(i),status,ierror)
155 l = iad_recv(i)
156#include "vectorize.inc"
157 DO j=fr_rms(i),fr_rms(i+1)-1
158 IF(list_rms(j)/=0)THEN
159 DO k=1,SIZE
160 vfi(k,kk) = rbuf(l+k-1)
161 END DO
162 END IF
163 l = l + SIZE
164 kk= kk + 1
165 END DO
166 IF(i/=loc_proc)THEN
167#include "vectorize.inc"
168 DO j=fr_sms(i),fr_sms(i+1)-1
169 IF(list_sms(m)/=0)THEN
170 DO k=1,SIZE
171 vfi(k,kk) = rbuf(l+k-1)
172 END DO
173 END IF
174 l = l + SIZE
175 m = m + 1
176 kk= kk + 1
177 END DO
178 END IF
179 ENDIF
180 END DO
181
182 DO i = 1, nspmd
183 IF(iad_send(i+1)-iad_send(i)>0)THEN
184 CALL mpi_wait(req_s(i),status,ierror)
185 ENDIF
186 ENDDO
187
188 END IF
189#endif
190 RETURN
subroutine mpi_isend(buf, cnt, datatype, dest, tag, comm, ireq, ierr)
subroutine mpi_wait(ireq, status, ierr)
subroutine mpi_irecv(buf, cnt, datatype, source, tag, comm, ireq, ierr)