/[MITgcm]/MITgcm/pkg/compon_communic/couprecv_r4.F
ViewVC logotype

Contents of /MITgcm/pkg/compon_communic/couprecv_r4.F

Parent Directory Parent Directory | Revision Log Revision Log | View Revision Graph Revision Graph


Revision 1.1 - (show annotations) (download)
Mon Dec 15 02:35:29 2003 UTC (20 years, 5 months ago) by jmc
Branch: MAIN
CVS Tags: checkpoint58l_post, checkpoint57t_post, checkpoint57o_post, checkpoint52l_pre, checkpoint52e_pre, hrcube4, checkpoint58e_post, checkpoint57v_post, checkpoint52n_post, checkpoint52j_post, checkpoint53d_post, checkpoint58u_post, checkpoint58w_post, checkpoint54a_pre, checkpoint57m_post, checkpoint55c_post, checkpoint54e_post, checkpoint52e_post, checkpoint57s_post, checkpoint54a_post, checkpoint53c_post, checkpoint57k_post, checkpoint55d_pre, checkpoint57d_post, checkpoint57g_post, checkpoint57b_post, checkpoint57c_pre, checkpoint58r_post, checkpoint55j_post, checkpoint56b_post, checkpoint57i_post, checkpoint57y_post, checkpoint57e_post, checkpoint52l_post, checkpoint55h_post, checkpoint58n_post, checkpoint58x_post, checkpoint52k_post, checkpoint57g_pre, checkpoint54b_post, checkpoint53b_pre, checkpoint55b_post, checkpoint58t_post, checkpoint58h_post, checkpoint54d_post, checkpoint56c_post, checkpoint52m_post, checkpoint57y_pre, checkpoint55, checkpoint53a_post, checkpoint57f_pre, checkpoint57a_post, checkpoint54, checkpoint58q_post, checkpoint54f_post, checkpoint53b_post, checkpoint55g_post, checkpoint58j_post, checkpoint59e, checkpoint59d, checkpoint59g, checkpoint59f, checkpoint59a, checkpoint55f_post, checkpoint59c, checkpoint59b, checkpoint59h, checkpoint57r_post, checkpoint59, checkpoint58, checkpoint57a_pre, checkpoint55i_post, checkpoint57, checkpoint56, checkpoint53, checkpoint52d_post, eckpoint57e_pre, checkpoint57h_done, checkpoint58f_post, checkpoint53g_post, checkpoint52f_post, checkpoint57x_post, checkpoint57n_post, checkpoint58d_post, checkpoint58c_post, checkpoint57w_post, checkpoint57p_post, checkpint57u_post, checkpoint57f_post, checkpoint58a_post, checkpoint58i_post, checkpoint57q_post, checkpoint58g_post, hrcube5, checkpoint58o_post, checkpoint57z_post, checkpoint57c_post, checkpoint58y_post, checkpoint55e_post, checkpoint58k_post, checkpoint52i_post, checkpoint52j_pre, checkpoint58v_post, checkpoint53f_post, checkpoint55a_post, checkpoint53d_pre, checkpoint54c_post, checkpoint58s_post, checkpoint58p_post, checkpoint57j_post, checkpoint58b_post, checkpoint57h_pre, checkpoint58m_post, checkpoint57l_post, checkpoint52i_pre, checkpoint52h_pre, checkpoint52f_pre, checkpoint57h_post, hrcube_2, hrcube_3, checkpoint56a_post, checkpoint55d_post
coupler - multi-components interface: low-level communication S/R package.

1 !=======================================================================
2 subroutine couprecv_r4( component, dataname, Nx, Ny, arr )
3 implicit none
4 ! Arguments
5 character*(*) component
6 character*(*) dataname
7 integer Nx,Ny
8 real*4 arr(Nx,Ny)
9 ! Predefined constants/arrays
10 #include "CPLR_SIG.h"
11 ! MPI variables
12 #include "mpif.h"
13 integer count,dtype,rank,tag,comm,ierr
14 integer stat(MPI_STATUS_SIZE)
15 ! Functions
16 integer mitcplr_match_comp
17 integer generate_tag
18 ! Local
19 integer compind,numprocs
20 integer i,j,ij,n
21 integer Ni,Io,Nj,Jo
22 character*(MAXLEN_COMP_NAME) recvdname
23 ! ------------------------------------------------------------------
24
25 ! Establish who I am communicating with
26 compind=mitcplr_match_comp( component )
27 if (compind.le.0) stop 'couprecv_r4: Bad component id'
28 comm=MPI_COMM_compcplr( compind )
29 numprocs=num_component_procs(compind)
30 if (numprocs.lt.1) then
31 write(LogUnit,*) 'couprecv_r4: compind = ',compind
32 stop 'couprecv_r4: numprocs < 1'
33 endif
34 if (VERB)
35 & write(LogUnit,*) 'couprecv_r4: ',component_Name(compind)
36 if (VERB)
37 & write(LogUnit,*) 'couprecv_r4: dataname=',dataname
38
39 ! Foreach component process
40 do n=1,numprocs
41
42 ! Receive message
43 count=HEADER_SIZE+MAX_R4_BUFLEN
44 dtype=MPI_REAL
45 tag=generate_tag(102,n,dataname)
46 rank=rank_component_procs(n,compind)
47 if (VERB) then
48 write(LogUnit,*) 'couprecv_r4: calling MPI_Recv rank=',rank,
49 & ' proc=',n,'/',numprocs
50 call flush(LogUnit)
51 endif
52 call MPI_Recv(r4buf, count, dtype, rank, tag, comm, stat, ierr)
53 if (VERB) then
54 write(LogUnit,*) 'couprecv_r4: returned ierr=',ierr
55 call flush(LogUnit)
56 endif
57
58 if (ierr.ne.0) then
59 write(LogUnit,*) 'couprecv_r4tiles: rank(W,G)=',
60 & my_rank_in_world,my_rank_in_global,
61 & ' ierr=',ierr
62 stop 'couprecv_r4: MPI_Recv failed'
63 endif
64
65 ! Extract header
66 Io=int(0.5+r4buf(1))
67 Ni=int(0.5+r4buf(2))
68 Jo=int(0.5+r4buf(3))
69 Nj=int(0.5+r4buf(4))
70
71 if (Io+Ni-1.gt.Nx .or. Io.lt.1) then
72 write(LogUnit,*) 'couprecv_r4tiles: Io,Ni=',Io,Ni
73 stop 'couprecv_r4: Incompatible header/target array'
74 endif
75 if (Jo+Nj-1.gt.Ny .or. Jo.lt.1) then
76 write(LogUnit,*) 'couprecv_r4tiles: Jo,Nj=',Jo,Nj
77 stop 'couprecv_r4: Incompatible header/target array'
78 endif
79
80 call mitcplr_real2char( r4buf(9), recvdname )
81 if (recvdname .ne. dataname) then
82 write(LogUnit,*) 'couprecv_r4: recvdname = ',recvdname
83 write(LogUnit,*) 'couprecv_r4: dataname = ',dataname
84 stop 'couprecv_r4: recvdname != dataname'
85 endif
86
87 ! Extract data
88 do j=1,Nj
89 do i=1,Ni
90 ij=HEADER_SIZE+i+Ni*(j-1)
91 arr(Io+i-1,Jo+j-1)=r4buf(ij)
92 enddo
93 enddo
94
95 enddo
96
97 ! ------------------------------------------------------------------
98 return
99 end
100 !=======================================================================

  ViewVC Help
Powered by ViewVC 1.1.22