34
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 "com04_c.inc"
49#include "task_c.inc"
50#include "param_c.inc"
51
52
53
54 INTEGER IACCP(*), NACCP(*)
56 . accelm(llaccelm,*)
57
58
59
60#ifdef MPI
61 INTEGER MSGTYP,MSGOFF,IERROR,LOC_PROC,NN,L,I,K,N,II,J,
62 . IDEB,SIZ,A_AR,NBIRECV,INDEX,
63 . IRINDEX(NSPMD),REQ_R(NSPMD),IAD_RECV(),
64 . (MPI_STATUS_SIZE)
66 . buf(llaccelm+1,naccelm)
67 DATA msgoff/201/
68
69
70
71 loc_proc = ispmd + 1
72 IF (loc_proc==1) THEN
73 ideb = 1
74 nbirecv = 0
75 DO i = 2, nspmd
76 iad_recv(i) = ideb
77 IF(naccp(i)>0)THEN
78 nbirecv = nbirecv + 1
79 irindex(nbirecv) = i
80 nn = naccp(i)
81 siz = (llaccelm+1)*nn
82 msgtyp = msgoff
84 s buf(1,ideb),siz,real,it_spmd(i),msgtyp,
85 g spmd_comm_world,req_r(nbirecv),ierror)
86 ideb = ideb + nn
87 END IF
88 END DO
89
90 DO ii = 1, nbirecv
92 i = irindex(index)
93 l = iad_recv(i)
94 nn = naccp(i)
95 DO n = l, l+nn-1
96 k = nint(buf(1,n))
97 DO j = 1, llaccelm
98 accelm(j,k) = buf(j+1,n)
99 END DO
100 END DO
101 END DO
102
103 ELSE
104 k = 0
105 DO n = 1, naccelm
106 IF(iaccp(n)==loc_proc)THEN
107 k = k + 1
108 buf(1,k) = n
109 DO j = 1, llaccelm
110 buf(j+1,k) = accelm(j,n)
111 END DO
112 END IF
113 END DO
114 IF(k>0)THEN
115 siz = (llaccelm+1)*k
116 msgtyp=msgoff
118 s buf,siz,real,it_spmd(1),msgtyp,
119 g spmd_comm_world,ierror)
120 END IF
121 END IF
122
123#endif
124 RETURN
subroutine mpi_send(buf, cnt, datatype, dest, tag, comm, ierr)
subroutine mpi_waitany(cnt, array_of_requests, index, status, ierr)
subroutine mpi_irecv(buf, cnt, datatype, source, tag, comm, ireq, ierr)