35
36
37
38 USE spmd_comm_world_mod, ONLY : spmd_comm_world
39#include "implicit_f.inc"
40#include "macro.inc"
41
42
43
44#include "spmd.inc"
45
46
47
48#include "com01_c.inc"
49#include "task_c.inc"
50#include "tabsiz_c.inc"
51
52
53
54 INTEGER, INTENT(IN) :: DIM,DIM1,DIM2,LENCOM
55 INTEGER, INTENT(IN) :: NERCVOIS(SNERCVOIS), NESDVOIS(SNESDVOIS)
56 INTEGER, INTENT(IN) :: LERCVOIS(SLERCVOIS), LESDVOIS(SLESDVOIS)
57 my_real,
DIMENSION(DIM1,DIM2),
INTENT(INOUT) :: phi
58
59
60
61#ifdef MPI
62 INTEGER I, NDIM, IDEB, IDEB2, MSGOFF, IERROR,MSGTYP,IAD_RECV(NSPMD),
63 . STATUS(MPI_STATUS_SIZE), REQ_S(NSPMD), REQ_R(NSPMD),
64 . LOC_PROC, N, NN, NBIRECV, IRINDEX(NSPMD), II, INDEX,
65 . LEN
66 DATA msgoff/3004/
68 . wa(dim, lencom)
69
70
71
72
73
74 loc_proc = ispmd+1
75 ideb = 0
76 ideb2 = 0
77 nbirecv = 0
78 DO i = 1, nspmd
79 msgtyp = msgoff
80 iad_recv(i) = ideb2+1
81 IF(nercvois(i)>0) THEN
82 nbirecv = nbirecv + 1
83 irindex(nbirecv) = i
84 len = nercvois(i)
86 s wa(1,ideb2+1),len*dim,real,it_spmd(i),msgtyp,
87 g spmd_comm_world,req_r(nbirecv),ierror)
88 ideb2 = ideb2 + len
89 ENDIF
90 ENDDO
91
92 ideb = 0
93 DO i = 1, nspmd
94 msgtyp = msgoff
95 len = nesdvois(i)
96 IF(len>0) THEN
97 DO n = 1, len
98 nn = lesdvois(ideb+n)
99 DO ndim = 1, dim
100 wa(ndim,ideb2+n) = phi(nn,ndim)
101 ENDDO
102 ENDDO
104 s wa(1,ideb2+1),len*dim,real,it_spmd(i),msgtyp,
105 g spmd_comm_world,req_s(i),ierror)
106 ideb = ideb + len
107 ideb2 = ideb2 + len
108 ENDIF
109 ENDDO
110
111 DO ii = 1, nbirecv
112 CALL mpi_waitany(nbirecv,req_r,index,status,ierror)
113 i = irindex(index)
114 ideb = iad_recv(i)-1
115 DO n = 1, nercvois(i)
116 nn = lercvois(ideb+n)
117 DO ndim = 1, dim
118 phi(nn,ndim) = wa(ndim,ideb+n)
119 ENDDO
120 ENDDO
121 ENDDO
122
123 DO i = 1, nspmd
124 IF(nesdvois(i)>0) THEN
125 CALL mpi_wait(req_s(i),status,ierror)
126 ENDIF
127 ENDDO
128
129
130#endif
131 RETURN
subroutine mpi_isend(buf, cnt, datatype, dest, tag, comm, ireq, ierr)
subroutine mpi_wait(ireq, status, ierr)
subroutine mpi_waitany(cnt, array_of_requests, index, status, ierr)
subroutine mpi_irecv(buf, cnt, datatype, source, tag, comm, ireq, ierr)