35
36
37
38 USE spmd_comm_world_mod, ONLY : spmd_comm_world
39#include "implicit_f.inc"
40
41
42
43#include "spmd.inc"
44
45
46
47#include "com01_c.inc"
48#include "task_c.inc"
49
50
51
52 INTEGER NRTM,NUMNOD,LENR,LENT,MAXCC,NLN,NLG(NLN),
53 . IRECT(4,NRTM),ITAG(*),
54 . (2,*), FR_ELEM(*), ISDSIZ(*), IRCSIZ(*)
55
56
57
58#ifdef MPI
59 INTEGER I ,J ,N1, N2, N3, N4, IERROR, IAD, SIZ, NB,
60 . MSGTYP, LOC_PROC, MSGOFF,
61 . IBUFS(), IBUFR(LENR),
62 . STATUS(MPI_STATUS_SIZE),REQ_R(NSPMD)
63 DATA msgoff/194/
64
65
66
67 loc_proc = ispmd+1
68
69 iad = 1
70 DO i=1,nspmd
71 ircsiz(i) = 0
72 siz = iad_elem(1,i+1)-iad_elem(1,i)
73 IF(siz>0)THEN
74 msgtyp = msgoff
76 s ibufr(iad),siz,mpi_integer,it_spmd(i),msgtyp,
77 g spmd_comm_world,req_r(i),ierror)
78 iad = iad + siz
79 ENDIF
80 END DO
81 DO n1=1,numnod
82 itag(n1) = 0
83 END DO
84
85 DO i=1,nrtm
86 n1 = irect(1,i)
87 n2 = irect(2,i)
88 n3 = irect(3,i)
89 n4 = irect(4,i)
90 n1 = nlg(n1)
91 n2 = nlg(n2)
92 n3 = nlg(n3)
93 n4 = nlg(n4)
94 itag(n1) = itag(n1) + 1
95 itag(n2) = itag(n2) + 1
96 itag(n3) = itag(n3) + 1
97 itag(n4) = itag(n4) + 1
98 END DO
99 DO i=1,nspmd
100 isdsiz(i) = 0
101 siz = iad_elem(1,i+1)-iad_elem(1,i)
102 IF(siz>0)THEN
103 iad = 1
104#include "vectorize.inc"
105 DO j=iad_elem(1,i),iad_elem(1,i+1)-1
106 n1 = fr_elem(j)
107 isdsiz(i) = isdsiz(i) + itag(n1)
108 ibufs(iad) = itag(n1)
109 iad = iad + 1
110 END DO
111 msgtyp = msgoff
113 s ibufs,siz,mpi_integer,it_spmd(i),msgtyp,
114 g spmd_comm_world,ierror)
115 END IF
116 END DO
117
118 isdsiz(nspmd+1) = 0
119 ircsiz(nspmd+1) = 0
120 iad = 0
121 DO i = 1, nspmd
122 siz = iad_elem(1,i+1)-iad_elem(1,i)
123 IF(siz>0)THEN
124 CALL mpi_wait(req_r(i),status,ierror)
125 DO j=iad_elem(1,i),iad_elem(1,i+1)-1
126 n1 = fr_elem(j)
127 iad = iad + 1
128 nb = ibufr(iad)
129 ircsiz(i) = ircsiz(i) + nb
130 itag(n1) = itag(n1) + nb
131 END DO
132 isdsiz(nspmd+1) = isdsiz(nspmd+1) + isdsiz(i)
133 ircsiz(nspmd+1) = ircsiz(nspmd+1) + ircsiz(i)
134 END IF
135 END DO
136
137 lent = 0
138 maxcc = 0
139 DO n1=1,numnod
140 lent = lent + itag(n1)
141 maxcc =
max(maxcc,itag(n1))
142 END DO
143
144#endif
145 RETURN
subroutine mpi_wait(ireq, status, ierr)
subroutine mpi_send(buf, cnt, datatype, dest, tag, comm, ierr)
subroutine mpi_irecv(buf, cnt, datatype, source, tag, comm, ireq, ierr)