47
48
49
50
51 USE spmd_comm_world_mod, ONLY : spmd_comm_world
52#include "implicit_f.inc"
53
54
55
56#include "spmd.inc"
57
58
59
60
61#include "com01_c.inc"
62#include "task_c.inc"
63
64
65
66 INTEGER NBF_L, NBPART, SIZE, IADG(NSPMD,*),BUF
67 REAL WAL(*)
68 REAL, DIMENSION(:), ALLOCATABLE :: WAR
69
70
71
72#ifdef MPI
73 INTEGER MSGOFF,MSGTYP,IDEB,K,N,NB_TMP,LEN,IADP(NSPMD)
74 INTEGER STATUS(MPI_STATUS_SIZE),IERROR
75 DATA msgoff/7002/
76
77
78
79 ALLOCATE(war(buf+1))
80
81 IF (ispmd/=0) THEN
82 msgtyp=msgoff
83 CALL mpi_send(wal,nbf_l,mpi_real4,it_spmd(1),msgtyp,
84 . spmd_comm_world,ierror)
85
86 ELSE
87
88 DO k=1,nbf_l
89 war(k) = wal(k)
90 END DO
91
92 ideb = nbf_l + 1
93 iadp(1) = 1
94
95 DO k=2,nspmd
96 iadp(k) = ideb
97 msgtyp=msgoff
98
100 . spmd_comm_world,status,ierror)
102 CALL mpi_recv(war(ideb),nb_tmp,mpi_real4,it_spmd(k),msgtyp,
103 . spmd_comm_world,status,ierror)
104
105 ideb = ideb + nb_tmp
106 END DO
107 DO n = 1, nbpart
108 DO k = 1, nspmd
109 IF (n>1) THEN
110 len = (iadg(k,n) - iadg(k,n-1))*SIZE
111 ELSE
112 len = iadg(k,n)*SIZE
113 ENDIF
114 IF(len>0)
CALL write_r_c(war(iadp(k)),len)
115 iadp(k) = iadp(k) + len
116 ENDDO
117 ENDDO
118 ENDIF
119
120 DEALLOCATE(war)
121#endif
122 RETURN
subroutine mpi_recv(buf, cnt, datatype, source, tag, comm, status, ierr)
subroutine mpi_get_count(status, datatype, cnt, ierr)
subroutine mpi_send(buf, cnt, datatype, dest, tag, comm, ierr)
subroutine mpi_probe(source, tag, comm, status, ierr)
void write_r_c(float *w, int *len)