35
36
37
39
40
41
42 USE spmd_comm_world_mod, ONLY : spmd_comm_world
43#include "implicit_f.inc"
44
45
46
47#include "spmd.inc"
48
49
50
51#include "task_c.inc"
52#include "com01_c.inc"
53
54
55
56 INTEGER IAD_ELEM(2,*), FR_ELEM(*),ITAB(*)
58 * mtf(14,*),a(3,*)
59
60
61
62#ifdef MPI
63 INTEGER STATUS(),
64 * REQ_SI(NSPMD),REQ_RI(NSPMD),MSGTYP,IERROR,MSGOFF
65 INTEGER L,NNOD,P,J,LOC_PROC,PTR,SIZ,NB,NOD
66 INTEGER IADS(NSPMD+1),IADR(NSPMD+1),LENRV
68 * testval
70 * DIMENSION(:), ALLOCATABLE :: bbufs,bbufr
71 DATA msgoff/155/
72
73 lenrv = (iad_elem(1,nspmd+1)-iad_elem(1,1))*4
74 ALLOCATE (bbufs(lenrv),bbufr(lenrv))
75 loc_proc=ispmd+1
76
77 bbufr=-1.
78
79 iadr(1) = 1
80 l=1
81 DO p=1,nspmd
82 iadr(p) = l
83 siz = (iad_elem(1,p+1)-iad_elem(1,p))*4
84 IF(siz/=0)THEN
85 msgtyp = msgoff
87 s bbufr(l),siz,real,it_spmd(p),msgtyp,
88 g spmd_comm_world,req_ri(p),ierror)
89 l = l + siz
90 ENDIF
91 END DO
92 iadr(nspmd+1) = l
93
94
95 l=1
96 nnod=0
97 DO p=1,nspmd
98 iads(p)=l
99 DO j=iad_elem(1,p),iad_elem(1,p+1)-1
100 nod = fr_elem(j)
101 bbufs(l) = mtf(1,nod)
102 bbufs(l+1) = a(1,nod)
103 bbufs(l+2) = a(2,nod)
104 bbufs(l+3) = a(3,nod)
105 l = l + 4
106 ENDDO
107 ENDDO
108 iads(nspmd+1)=l
109
110 DO p=1,nspmd
111 IF(iad_elem(1,p+1)-iad_elem(1,p)>0)THEN
112 msgtyp = msgoff
113 siz=iads(p+1)-iads(p)
114 l=iads(p)
116 s bbufs(l),siz,real,it_spmd(p),msgtyp,
117 g spmd_comm_world,req_si(p),ierror)
118 ENDIF
119 ENDDO
120
121
122
123 DO p = 1, nspmd
124
125 nb = iad_elem(1,p+1)-iad_elem(1,p)
126 IF(nb>0)THEN
127 CALL mpi_wait(req_ri(p),status,ierror)
128 l=iadr(p)
129 DO j=iad_elem(1,p),iad_elem(1,p+1)-1
130 nod = fr_elem(j)
131 IF (bbufr(l) > zero)THEN
132 a(1,nod)=bbufr(l+1)
133 a(2,nod)=bbufr(l+2)
134 a(3,nod)=bbufr(l+3)
135 ENDIF
136 l=l+4
137 ENDDO
138 ENDIF
139 ENDDO
140
141
142 DO p = 1, nspmd
143 siz=iads(p+1)-iads(p)
144 IF(siz>0) THEN
145 CALL mpi_wait(req_si(p),status,ierror)
146 ENDIF
147 ENDDO
148#endif
149 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)