source: XIOS/trunk/src/test/test_interpolate.f90 @ 1979

Last change on this file since 1979 was 1979, checked in by yushan, 4 years ago

trunk : add a test for inversed axis_interpolation. Still under development

File size: 85.2 KB
Line 
1PROGRAM test_interpolate 
2  USE xios
3  USE mod_wait
4  IMPLICIT NONE
5  INCLUDE "mpif.h"
6  INTEGER,PARAMETER :: unit=10
7  INTEGER,PARAMETER :: len_str=255
8  INTEGER :: ierr
9
10  INTEGER :: nb_proc_atm
11  INTEGER :: nb_proc_oce
12  INTEGER :: nb_proc_surf
13  CHARACTER(LEN=len_str)  :: proc_distribution
14  CHARACTER(LEN=len_str)  :: start_date
15  CHARACTER(LEN=len_str)  :: duration
16  DOUBLE PRECISION        :: sypd
17  NAMELIST /params_run/    nb_proc_atm, nb_proc_surf, nb_proc_oce, & 
18                           duration, sypd, start_date, proc_distribution
19
20
21  TYPE tmodel_params
22    CHARACTER(len_str)  :: timestep=""
23    CHARACTER(len_str)  :: domain=""
24    DOUBLE PRECISION    :: domain_proc_frac
25    INTEGER             :: domain_proc_n
26    CHARACTER(len_str)  :: axis=""
27    DOUBLE PRECISION    :: axis_proc_frac
28    INTEGER             :: axis_proc_n
29    INTEGER             :: ensemble_proc_n
30    INTEGER             :: ni 
31    INTEGER             :: nj 
32    INTEGER             :: nlev
33    CHARACTER(len_str)  :: init_field2D=""
34    DOUBLE PRECISION    :: pressure_factor
35    LOGICAL :: domain_mask
36    LOGICAL :: axis_mask
37    LOGICAL :: mask3d
38    INTEGER             :: field_sub_freq 
39    INTEGER             :: field_sub_offset
40  END TYPE  tmodel_params
41
42
43
44  CHARACTER(len_str)  :: timestep_atm
45  CHARACTER(len_str)  :: domain_atm 
46  CHARACTER(len_str)  :: axis_atm 
47  INTEGER             :: ni_atm 
48  INTEGER             :: nj_atm 
49  INTEGER             :: nlev_atm
50  CHARACTER(len_str)  :: init_field2D_atm 
51 
52 
53  LOGICAL :: i_am_atm, i_am_oce, i_am_surf, i_am_server
54  INTEGER :: rank, size_loc
55 
56   
57  OPEN(unit=unit, file='param.def',status='old',iostat=ierr)
58  nb_proc_atm=1
59  nb_proc_oce=0 
60  nb_proc_surf=0
61  duration="1d"
62  sypd=10000
63  start_date="2018-01-01"
64  proc_distribution="contiguous"
65  READ (unit, nml=params_run)
66  CLOSE(unit)
67!!! MPI Initialization
68
69  CALL MPI_INIT(ierr)
70  CALL init_wait
71  CALL MPI_COMM_RANK(MPI_COMM_WORLD,rank,ierr)
72  CALL MPI_COMM_SIZE(MPI_COMM_WORLD,size_loc,ierr)
73  if (size_loc < nb_proc_atm + nb_proc_oce + nb_proc_surf) then
74     PRINT *,"inconsistency : size=",size_loc," nb_proc_atm=",nb_proc_atm,&
75          " nb_proc_oce=",nb_proc_oce," nb_proc_surf=",nb_proc_surf
76     CALL MPI_ABORT()
77  endif
78
79  i_am_atm=.FALSE. ; i_am_oce=.FALSE. ; i_am_surf=.FALSE. ; i_am_server=.FALSE. 
80
81  IF (proc_distribution=="contiguous") THEN
82
83   ! First ranks are dedicated to Atm, next to Ocean, next to Surf, last to Server
84
85    IF (rank < nb_proc_atm) THEN
86      i_am_atm=.TRUE. 
87    ELSE IF (rank < nb_proc_atm+nb_proc_oce) THEN
88      i_am_oce=.TRUE. 
89    ELSE IF (rank < nb_proc_atm+nb_proc_oce+nb_proc_surf) THEN
90      i_am_surf=.TRUE. 
91    ELSE
92      i_am_server=.TRUE. 
93    ENDIF ;
94
95  ENDIF
96 
97 
98  IF (i_am_server) THEN
99    CALL xios_init_server()
100 
101  ELSE
102
103    IF (i_am_atm) CALL model("atm")
104 
105    CALL xios_finalize()
106  ENDIF
107
108 print*, "finished Successfully" 
109  CALL MPI_FINALIZE(ierr)
110 
111CONTAINS
112
113  SUBROUTINE model(model_id)
114  IMPLICIT NONE
115    CHARACTER(LEN=*) :: model_id
116    TYPE(tmodel_params) :: params, other_params
117    TYPE(xios_context) :: ctx_hdl
118    INTEGER :: comm
119    TYPE(xios_date)  :: cdate, edate
120    TYPE(xios_duration)  :: dtime
121    INTEGER :: rank
122    INTEGER :: size_loc
123    DOUBLE PRECISION :: timestep_in_seconds, simulated_seconds_per_seconds, elapsed_per_timestep
124    INTEGER :: ts
125
126    DOUBLE PRECISION, POINTER :: lon(:)
127    DOUBLE PRECISION, POINTER :: lat(:)
128    DOUBLE PRECISION, POINTER :: axis_value(:)
129    LOGICAL, POINTER          :: domain_mask(:)
130    INTEGER, POINTER          :: domain_index(:)
131    LOGICAL, POINTER          :: axis_mask(:)
132    INTEGER, POINTER          :: axis_index(:)
133    DOUBLE PRECISION, POINTER :: ensemble_value(:)
134   
135    DOUBLE PRECISION, POINTER :: X_lon(:)
136    DOUBLE PRECISION, POINTER :: X_lat(:)
137    LOGICAL, POINTER          :: X_mask(:)
138    INTEGER, POINTER          :: X_index(:)
139
140    DOUBLE PRECISION, POINTER :: Y_lon(:)
141    DOUBLE PRECISION, POINTER :: Y_lat(:)
142    LOGICAL, POINTER          :: Y_mask(:)
143    INTEGER, POINTER          :: Y_index(:)
144               
145    DOUBLE PRECISION, POINTER :: field2D_init(:)
146    DOUBLE PRECISION, POINTER :: fieldX_init(:)
147    DOUBLE PRECISION, POINTER :: fieldY_init(:)
148    DOUBLE PRECISION, POINTER :: fieldXY_init(:,:)
149
150    DOUBLE PRECISION, POINTER :: field2D(:), other_field2D(:)
151    DOUBLE PRECISION, POINTER :: field_X(:), other_field_X(:)
152    DOUBLE PRECISION, POINTER :: field_Y(:), other_field_Y(:)
153    DOUBLE PRECISION, POINTER :: field_Z(:), other_field_Z(:)
154    DOUBLE PRECISION, POINTER :: field_XY(:,:), other_field_XY(:,:)
155    DOUBLE PRECISION, POINTER :: field_XYZ(:,:,:), other_field_XYZ(:,:,:)
156    DOUBLE PRECISION, POINTER :: field_XZ(:,:), other_field_XZ(:,:)
157    DOUBLE PRECISION, POINTER :: field_YZ(:,:), other_field_YZ(:,:)
158   
159    DOUBLE PRECISION, POINTER :: field2D_sub(:), other_field2D_sub(:)
160    DOUBLE PRECISION, POINTER :: field3D(:,:), other_field3D(:,:)
161    DOUBLE PRECISION, POINTER :: field_in(:,:)
162    DOUBLE PRECISION, POINTER :: field3D_sub(:,:), other_field3D_sub(:,:)
163    DOUBLE PRECISION, POINTER :: field3D_recv(:,:), other_field3D_recv(:,:)
164    DOUBLE PRECISION, POINTER :: pressure(:,:), other_pressure(:,:)
165
166    DOUBLE PRECISION, POINTER :: field2D_W(:,:), other_field2D_W(:,:)
167    DOUBLE PRECISION, POINTER :: field_XW(:,:), other_field_XW(:,:)
168    DOUBLE PRECISION, POINTER :: field_YW(:,:), other_field_YW(:,:)
169    DOUBLE PRECISION, POINTER :: field_ZW(:,:), other_field_ZW(:,:)
170    DOUBLE PRECISION, POINTER :: field_XYW(:,:,:), other_field_XYW(:,:,:)
171    DOUBLE PRECISION, POINTER :: field_XYZW(:,:,:,:), other_field_XYZW(:,:,:,:)
172    DOUBLE PRECISION, POINTER :: field_XZW(:,:,:), other_field_XZW(:,:,:)
173    DOUBLE PRECISION, POINTER :: field_YZW(:,:,:), other_field_YZW(:,:,:)
174   
175    DOUBLE PRECISION, POINTER :: field2D_sub_W(:,:), other_field2D_sub_W(:,:)
176    DOUBLE PRECISION, POINTER :: field3D_W(:,:,:), other_field3D_W(:,:,:)
177    DOUBLE PRECISION, POINTER :: field3D_sub_W(:,:,:), other_field3D_sub_W(:,:,:)
178    DOUBLE PRECISION, POINTER :: field3D_recv_W(:,:,:), other_field3D_recv_W(:,:,:)
179    DOUBLE PRECISION, POINTER :: pressure_W(:,:,:), other_pressure_W(:,:,:)
180
181
182
183   
184    TYPE(xios_duration) :: freq_op_recv, freq_offset_recv
185    INTEGER :: ni,nj,nk
186    INTEGER :: i,j,k,xy,x,y,z,w
187    DOUBLE PRECISION :: scale,dist
188    LOGICAL :: ok
189    INTEGER :: ierr     
190
191    LOGICAL :: ok_field_in
192    LOGICAL :: ok_field2D, ok_field3D, ok_pressure, ok_field2D_sub, ok_field3D_sub,ok_field3D_recv, ok_field3D_send
193    LOGICAL :: ok_field_X, ok_field_Y, ok_field_XY, ok_field_Z, ok_field_XYZ, ok_field_XZ, ok_field_YZ
194    LOGICAL :: ok_field2D_W, ok_field3D_W, ok_pressure_W, ok_field2D_sub_W, ok_field3D_sub_W,ok_field3D_recv_W, ok_field3D_send_W
195    LOGICAL :: ok_field_XW, ok_field_YW, ok_field_XYW, ok_field_ZW, ok_field_XYZW, ok_field_XZW, ok_field_YZW
196
197    LOGICAL :: ok_other_field2D, ok_other_field3D, ok_other_pressure, ok_other_field2D_sub, ok_other_field3D_sub, &
198               ok_other_field3D_recv, ok_other_field3D_send
199    LOGICAL :: ok_other_field_X, ok_other_field_Y, ok_other_field_XY, ok_other_field_Z, ok_other_field_XYZ, &
200               ok_other_field_XZ, ok_other_field_YZ
201    LOGICAL :: ok_other_field2D_W, ok_other_field3D_W, ok_other_pressure_W, ok_other_field2D_sub_W, ok_other_field3D_sub_W, &
202               ok_other_field3D_recv_W, ok_other_field3D_send_W
203    LOGICAL :: ok_other_field_XW, ok_other_field_YW, ok_other_field_XYW, ok_other_field_ZW, ok_other_field_XYZW, &
204               ok_other_field_XZW, ok_other_field_YZW
205   
206      !! XIOS Initialization (get the local communicator)
207    CALL xios_initialize(trim(model_id),return_comm=comm)
208    CALL MPI_COMM_RANK(comm,rank,ierr)
209    CALL MPI_COMM_SIZE(comm,size_loc,ierr)
210    CALL xios_context_initialize(trim(model_id),comm)
211    CALL xios_get_handle(trim(model_id),ctx_hdl)
212    CALL xios_set_current_context(ctx_hdl)
213   
214    CALL init_model_params('',params)
215    CALL init_model_params('other_',other_params)
216   !!! Definition du découpage domain/axis
217
218   
219   !!! Definition de la start date et du timestep
220    CALL xios_set_start_date(xios_date_convert_from_string(start_date//" 00:00:00"))
221    dtime=xios_duration_convert_from_string(TRIM(params%timestep))
222    CALL xios_set_timestep(timestep=dtime)
223
224     !!! Calcul de temps elaps par seconde pour respecter le SYPD (hyp : pas de delai d'I/O)
225    CALL xios_get_start_date(cdate)
226    edate=cdate+xios_duration_convert_from_string(TRIM(duration))
227    timestep_in_seconds=xios_date_convert_to_seconds(cdate+dtime) - xios_date_convert_to_seconds(cdate)
228    simulated_seconds_per_seconds=sypd * 365 
229    elapsed_per_timestep=timestep_in_seconds/simulated_seconds_per_seconds ! in seconds
230
231
232!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
233!!!             standard initialisation of domain, axis, grid, field                               !
234!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
235
236    CALL init_domain("domain", comm, params, ni, nj, lon, lat, domain_mask, domain_index, &
237                                                     X_lon, X_lat, X_mask, X_index,       &
238                                                     Y_lon, Y_lat, Y_mask, Y_index)
239                                                     
240    CALL init_axis("axis", comm, params, axis_value, axis_mask, axis_index)
241    CALL init_ensemble("ensemble", comm, params, ensemble_value)
242
243    CALL set_mask3d("grid3D",params, ni, nj, lon, lat , axis_value)
244     !!! Fin de la definition du contexte
245
246    ok_field3D_recv=xios_is_valid_field("field3D_recv").AND.xios_is_valid_field("field3D_resend") ;
247    IF (ok_field3D_recv) THEN
248      CALL xios_is_defined_field_attr("field3D_recv",freq_op=ok)
249      IF (ok) THEN
250        CALL xios_get_field_attr("field3D_recv",freq_op=freq_op_recv)
251       ELSE
252         freq_op_recv%timestep=1
253         CALL xios_set_field_attr("field3D_recv",freq_op=freq_op_recv)
254      ENDIF
255      CALL xios_is_defined_field_attr("field3D_recv",freq_offset=ok)
256      IF (ok) THEN
257        CALL xios_get_field_attr("field3D_recv",freq_offset=freq_offset_recv)
258      ELSE
259         freq_offset_recv%timestep=0
260         CALL xios_set_field_attr("field3D_recv",freq_op=freq_op_recv)
261      ENDIF
262      CALL xios_set_field_attr("field3D_resend",freq_op=freq_op_recv,freq_offset=freq_offset_recv)
263    ENDIF
264   
265    ok_field3D_recv_W=xios_is_valid_field("field3D_recv_W").AND.xios_is_valid_field("field3D_resend_W") ;
266    IF (ok_field3D_recv_W) THEN
267      CALL xios_is_defined_field_attr("field3D_recv_W",freq_op=ok)
268      IF (ok) THEN
269        CALL xios_get_field_attr("field3D_recv_W",freq_op=freq_op_recv)
270       ELSE
271         freq_op_recv%timestep=1
272         CALL xios_set_field_attr("field3D_recv_W",freq_op=freq_op_recv)
273      ENDIF
274      CALL xios_is_defined_field_attr("field3D_recv_W",freq_offset=ok)
275      IF (ok) THEN
276        CALL xios_get_field_attr("field3D_recv_W",freq_offset=freq_offset_recv)
277      ELSE
278         freq_offset_recv%timestep=0
279         CALL xios_set_field_attr("field3D_recv_W",freq_op=freq_op_recv)
280      ENDIF
281      CALL xios_set_field_attr("field3D_resend_W",freq_op=freq_op_recv,freq_offset=freq_offset_recv)
282    ENDIF
283
284
285    CALL init_field2D(comm, params, lon, lat, domain_mask, field2D_init, &
286                      x_lon, x_lat, x_mask, fieldX_init, y_lon, y_lat, y_mask, fieldY_init, fieldXY_init)
287
288    xy=size(domain_index)
289    x=size(X_index)
290    y=size(Y_index)
291    z=size(axis_index)
292    w=size(ensemble_value)
293
294    ALLOCATE(field_in(0:xy-1,0:1))
295
296    ALLOCATE(field2D(0:xy-1))
297    ALLOCATE(field3D(0:xy-1,0:z-1))
298    ALLOCATE(pressure(0:xy-1,0:z-1))
299    ALLOCATE(field3D_recv(0:xy-1,0:z-1))
300    ALLOCATE(field_Z(0:z-1))
301    ALLOCATE(field_X(0:x-1))
302    ALLOCATE(field_Y(0:y-1))
303    ALLOCATE(field_XY(0:x-1,0:y-1))
304    ALLOCATE(field_XYZ(0:x-1,0:y-1,0:z-1))
305    ALLOCATE(field_XZ(0:x-1,0:z-1))
306    ALLOCATE(field_YZ(0:y-1,0:z-1))
307
308    ALLOCATE(field2D_W(0:xy-1,0:w-1))
309    ALLOCATE(field3D_W(0:xy-1,0:z-1,0:w-1))
310    ALLOCATE(pressure_W(0:xy-1,0:z-1,0:w-1))
311    ALLOCATE(field3D_recv_W(0:xy-1,0:z-1,0:w-1))
312    ALLOCATE(field_ZW(0:z-1,0:w-1))
313    ALLOCATE(field_XW(0:x-1,0:w-1))
314    ALLOCATE(field_YW(0:y-1,0:w-1))
315    ALLOCATE(field_XYW(0:x-1,0:y-1,0:w-1))
316    ALLOCATE(field_XYZW(0:x-1,0:y-1,0:z-1,0:w-1))
317    ALLOCATE(field_XZW(0:x-1,0:z-1,0:w-1))
318    ALLOCATE(field_YZW(0:y-1,0:z-1,0:w-1))
319   
320
321
322    DO i=0,xy-1
323      IF (domain_index(i)/=-1) THEN
324        field2D(i)=field2D_init(domain_index(i))
325      ENDIF
326    ENDDO
327
328    DO i=0,x-1
329      IF (X_index(i)/=-1) THEN
330        field_X(i)=fieldX_init(X_index(i))
331      ENDIF
332    ENDDO
333
334    DO i=0,y-1
335      IF (Y_index(i)/=-1) THEN
336        field_Y(i)=fieldY_init(Y_index(i))
337      ENDIF
338    ENDDO
339
340    DO j=0,y-1
341      DO i=0,x-1
342        IF (Y_index(j)/=-1 .AND. X_index(i)/=-1) THEN
343          field_XY(i,j)=fieldXY_init(X_index(i),Y_index(j))
344        ENDIF
345      ENDDO
346    ENDDO
347
348    DO i=0,z-1
349      IF (axis_index(i)/=-1) THEN
350        k=axis_index(i)
351        IF (axis_mask(k)) THEN
352          field_Z(i)=axis_value(axis_index(k))
353          field3D(:,i)=field2D(:)*axis_value(axis_index(k))
354          field_XYZ(:,:,i)=field_XY(:,:)*axis_value(axis_index(k))
355          field_XZ(:,i)=field_X(:)*axis_value(axis_index(k))
356          field_YZ(:,i)=field_Y(:)*axis_value(axis_index(k))
357        ENDIF
358      ENDIF
359    ENDDO
360         
361    pressure=1e20
362    DO j=0,z-1
363      pressure(:,j)=axis_value(j) * 100000;
364      DO i=0,xy-1
365        IF (domain_index(i)/=-1) THEN
366          k=domain_index(i)
367          IF (domain_mask(k)) THEN
368            dist=sqrt((lat(k)/90.)**2+(lon(k)/180.)**2) ;
369            pressure(i,j)=pressure(i,j)*(1+params%pressure_factor*exp(-(4*dist)**2))
370          ENDIF
371        ENDIF
372      ENDDO
373    ENDDO
374   
375
376
377    field2D_W(:,0) = field2D(:)*(1+0.1*ensemble_value(0))
378    field3D_W(:,:,0)= field3D(:,:)*(1+0.1*ensemble_value(0))
379    pressure_W(:,:,0) = pressure(:,:)*(1+0.1*ensemble_value(0))
380    field_XW(:,0) = field_X(:)*(1+0.1*ensemble_value(0))
381    field_YW(:,0) = field_Y(:)*(1+0.1*ensemble_value(0))
382    field_XYW(:,:,0) = field_XY(:,:)*(1+0.1*ensemble_value(0))
383    field_ZW(:,0) = field_Z(:)*(1+0.1*ensemble_value(0))
384    field_XYZW(:,:,:,0) = field_XYZ(:,:,:)*(1+0.1*ensemble_value(0))
385    field_XZW(:,:,0) = field_XZ(:,:)*(1+0.1*ensemble_value(0))
386    field_YZW(:,:,0) = field_YZ(:,:)*(1+0.1*ensemble_value(0))
387   
388    ok_field_in=xios_is_valid_field("field_in") ;
389    ok_field2D=xios_is_valid_field("field2D") ;
390    ok_field3D=xios_is_valid_field("field3D") ;
391    ok_pressure=xios_is_valid_field("pressure") ;
392    ok_field2D_sub=xios_is_valid_field("field2D_sub") ;
393    ok_field3D_sub=xios_is_valid_field("field3D_sub") ;
394    ok_field_X=xios_is_valid_field("field_X") ;
395    ok_field_Y=xios_is_valid_field("field_Y") ;
396    ok_field_XY=xios_is_valid_field("field_XY") ;
397    ok_field_Z=xios_is_valid_field("field_Z") ; 
398    ok_field_XYZ=xios_is_valid_field("field_XYZ") ;
399    ok_field_XZ=xios_is_valid_field("field_XZ") ;
400    ok_field_YZ=xios_is_valid_field("field_YZ") ;
401
402    ok_field2D_W=xios_is_valid_field("field2D_W") ;
403    ok_field3D_W=xios_is_valid_field("field3D_W") ;
404    ok_pressure_W=xios_is_valid_field("pressure_W") ;
405    ok_field2D_sub_W=xios_is_valid_field("field2D_sub_W") ;
406    ok_field3D_sub_W=xios_is_valid_field("field3D_sub_W") ;
407    ok_field_XW=xios_is_valid_field("field_XW") ;
408    ok_field_YW=xios_is_valid_field("field_YW") ;
409    ok_field_XYW=xios_is_valid_field("field_XYW") ;
410    ok_field_ZW=xios_is_valid_field("field_ZW") ; 
411    ok_field_XYZW=xios_is_valid_field("field_XYZW") ;
412    ok_field_XZW=xios_is_valid_field("field_XZW") ;
413    ok_field_YZW=xios_is_valid_field("field_YZW") ;
414
415
416
417    IF (ASSOCIATED(lon)) DEALLOCATE(lon)
418    IF (ASSOCIATED(lat)) DEALLOCATE(lat)
419    IF (ASSOCIATED(axis_value)) DEALLOCATE(axis_value)
420    IF (ASSOCIATED(domain_mask)) DEALLOCATE(domain_mask)
421    IF (ASSOCIATED(domain_index)) DEALLOCATE(domain_index)
422    IF (ASSOCIATED(axis_mask)) DEALLOCATE(axis_mask)
423    IF (ASSOCIATED(axis_index)) DEALLOCATE(axis_index)
424    IF (ASSOCIATED(ensemble_value)) DEALLOCATE(ensemble_value)
425    IF (ASSOCIATED(X_lon)) DEALLOCATE(X_lon)
426    IF (ASSOCIATED(X_lat)) DEALLOCATE(X_lat)
427    IF (ASSOCIATED(X_mask)) DEALLOCATE(X_mask)
428    IF (ASSOCIATED(X_index)) DEALLOCATE(X_index)
429    IF (ASSOCIATED(Y_lon)) DEALLOCATE(Y_lon)
430    IF (ASSOCIATED(Y_lat)) DEALLOCATE(Y_lat)
431    IF (ASSOCIATED(Y_mask)) DEALLOCATE(Y_mask)
432    IF (ASSOCIATED(Y_index)) DEALLOCATE(Y_index)
433    IF (ASSOCIATED(field2D_init)) DEALLOCATE(field2D_init)
434    IF (ASSOCIATED(fieldX_init)) DEALLOCATE(fieldX_init)
435    IF (ASSOCIATED(fieldY_init)) DEALLOCATE(fieldY_init)
436    IF (ASSOCIATED(fieldXY_init)) DEALLOCATE(fieldXY_init)
437
438
439!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
440!              duplicated section for other_                    !
441!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
442
443    CALL init_domain("other_domain", comm, other_params, ni, nj, lon, lat, domain_mask, domain_index, &
444                                                     X_lon, X_lat, X_mask, X_index,       &
445                                                     Y_lon, Y_lat, Y_mask, Y_index)
446                                                     
447    CALL init_axis("other_axis", comm, other_params, axis_value, axis_mask, axis_index)
448    CALL init_ensemble("other_ensemble", comm, other_params, ensemble_value)
449
450    CALL set_mask3d("other_grid3D",other_params, ni, nj, lon, lat , axis_value)
451     !!! Fin de la definition du contexte
452
453    ok_other_field3D_recv=xios_is_valid_field("other_field3D_recv").AND.xios_is_valid_field("other_field3D_resend") ;
454    IF (ok_other_field3D_recv) THEN
455      CALL xios_is_defined_field_attr("other_field3D_recv",freq_op=ok)
456      IF (ok) THEN
457        CALL xios_get_field_attr("other_field3D_recv",freq_op=freq_op_recv)
458       ELSE
459         freq_op_recv%timestep=1
460         CALL xios_set_field_attr("other_field3D_recv",freq_op=freq_op_recv)
461      ENDIF
462      CALL xios_is_defined_field_attr("other_field3D_recv",freq_offset=ok)
463      IF (ok) THEN
464        CALL xios_get_field_attr("other_field3D_recv",freq_offset=freq_offset_recv)
465      ELSE
466         freq_offset_recv%timestep=0
467         CALL xios_set_field_attr("other_field3D_recv",freq_op=freq_op_recv)
468      ENDIF
469      CALL xios_set_field_attr("other_field3D_resend",freq_op=freq_op_recv,freq_offset=freq_offset_recv)
470    ENDIF
471   
472    ok_other_field3D_recv_W=xios_is_valid_field("other_field3D_recv_W").AND.xios_is_valid_field("other_field3D_resend_W") ;
473    IF (ok_other_field3D_recv_W) THEN
474      CALL xios_is_defined_field_attr("other_field3D_recv_W",freq_op=ok)
475      IF (ok) THEN
476        CALL xios_get_field_attr("other_field3D_recv_W",freq_op=freq_op_recv)
477       ELSE
478         freq_op_recv%timestep=1
479         CALL xios_set_field_attr("other_field3D_recv_W",freq_op=freq_op_recv)
480      ENDIF
481      CALL xios_is_defined_field_attr("other_field3D_recv_W",freq_offset=ok)
482      IF (ok) THEN
483        CALL xios_get_field_attr("other_field3D_recv_W",freq_offset=freq_offset_recv)
484      ELSE
485         freq_offset_recv%timestep=0
486         CALL xios_set_field_attr("other_field3D_recv_W",freq_op=freq_op_recv)
487      ENDIF
488      CALL xios_set_field_attr("other_field3D_resend_W",freq_op=freq_op_recv,freq_offset=freq_offset_recv)
489    ENDIF
490
491
492    CALL init_field2D(comm, other_params, lon, lat, domain_mask, field2D_init, &
493                      x_lon, x_lat, x_mask, fieldX_init, y_lon, y_lat, y_mask, fieldY_init, fieldXY_init)
494
495    xy=size(domain_index)
496    x=size(X_index)
497    y=size(Y_index)
498    z=size(axis_index)
499    w=size(ensemble_value)
500
501    ALLOCATE(other_field2D(0:xy-1))
502    ALLOCATE(other_field3D(0:xy-1,0:z-1))
503    ALLOCATE(other_pressure(0:xy-1,0:z-1))
504    ALLOCATE(other_field3D_recv(0:xy-1,0:z-1))
505    ALLOCATE(other_field_Z(0:z-1))
506    ALLOCATE(other_field_X(0:x-1))
507    ALLOCATE(other_field_Y(0:y-1))
508    ALLOCATE(other_field_XY(0:x-1,0:y-1))
509    ALLOCATE(other_field_XYZ(0:x-1,0:y-1,0:z-1))
510    ALLOCATE(other_field_XZ(0:x-1,0:z-1))
511    ALLOCATE(other_field_YZ(0:y-1,0:z-1))
512
513    ALLOCATE(other_field2D_W(0:xy-1,0:w-1))
514    ALLOCATE(other_field3D_W(0:xy-1,0:z-1,0:w-1))
515    ALLOCATE(other_pressure_W(0:xy-1,0:z-1,0:w-1))
516    ALLOCATE(other_field3D_recv_W(0:xy-1,0:z-1,0:w-1))
517    ALLOCATE(other_field_ZW(0:z-1,0:w-1))
518    ALLOCATE(other_field_XW(0:x-1,0:w-1))
519    ALLOCATE(other_field_YW(0:y-1,0:w-1))
520    ALLOCATE(other_field_XYW(0:x-1,0:y-1,0:w-1))
521    ALLOCATE(other_field_XYZW(0:x-1,0:y-1,0:z-1,0:w-1))
522    ALLOCATE(other_field_XZW(0:x-1,0:z-1,0:w-1))
523    ALLOCATE(other_field_YZW(0:y-1,0:z-1,0:w-1))
524   
525
526
527    DO i=0,xy-1
528      IF (domain_index(i)/=-1) THEN
529        other_field2D(i)=field2D_init(domain_index(i))
530      ENDIF
531    ENDDO
532
533    DO i=0,x-1
534      IF (X_index(i)/=-1) THEN
535        other_field_X(i)=fieldX_init(X_index(i))
536      ENDIF
537    ENDDO
538
539    DO i=0,y-1
540      IF (Y_index(i)/=-1) THEN
541        other_field_Y(i)=fieldY_init(Y_index(i))
542      ENDIF
543    ENDDO
544
545    DO j=0,y-1
546      DO i=0,x-1
547        IF (Y_index(j)/=-1 .AND. X_index(i)/=-1) THEN
548          other_field_XY(i,j)=fieldXY_init(X_index(i),Y_index(j))
549        ENDIF
550      ENDDO
551    ENDDO
552
553    DO i=0,z-1
554      IF (axis_index(i)/=-1) THEN
555        k=axis_index(i)
556        IF (axis_mask(k)) THEN
557          other_field_Z(i)=axis_value(axis_index(k))
558          other_field3D(:,i)=other_field2D(:)*axis_value(axis_index(k))
559          other_field_XYZ(:,:,i)=other_field_XY(:,:)*axis_value(axis_index(k))
560          other_field_XZ(:,i)=other_field_X(:)*axis_value(axis_index(k))
561          other_field_YZ(:,i)=other_field_Y(:)*axis_value(axis_index(k))
562        ENDIF
563      ENDIF
564    ENDDO
565         
566    other_pressure=1e20
567    DO j=0,z-1
568      other_pressure(:,j)=axis_value(j) * 100000 ;
569      DO i=0,xy-1
570        IF (domain_index(i)/=-1) THEN
571          k=domain_index(i)
572          IF (domain_mask(k)) THEN
573            dist=sqrt((lat(k)/90.)**2+(lon(k)/180.)**2) ;
574            other_pressure(i,j)=other_pressure(i,j)*(1+other_params%pressure_factor*exp(-(4*dist)**2))
575          ENDIF
576        ENDIF
577      ENDDO
578    ENDDO
579   
580
581
582    other_field2D_W(:,0) = other_field2D(:)*(1+0.1*ensemble_value(0))
583    other_field3D_W(:,:,0)= other_field3D(:,:)*(1+0.1*ensemble_value(0))
584    other_pressure_W(:,:,0) = other_pressure(:,:)*(1+0.1*ensemble_value(0))
585    other_field_XW(:,0) = other_field_X(:)*(1+0.1*ensemble_value(0))
586    other_field_YW(:,0) = other_field_Y(:)*(1+0.1*ensemble_value(0))
587    other_field_XYW(:,:,0) = other_field_XY(:,:)*(1+0.1*ensemble_value(0))
588    other_field_ZW(:,0) = other_field_Z(:)*(1+0.1*ensemble_value(0))
589    other_field_XYZW(:,:,:,0) = other_field_XYZ(:,:,:)*(1+0.1*ensemble_value(0))
590    other_field_XZW(:,:,0) = other_field_XZ(:,:)*(1+0.1*ensemble_value(0))
591    other_field_YZW(:,:,0) = other_field_YZ(:,:)*(1+0.1*ensemble_value(0))
592   
593   
594    ok_other_field2D=xios_is_valid_field("other_field2D") ;
595    ok_other_field3D=xios_is_valid_field("other_field3D") ;
596    ok_other_pressure=xios_is_valid_field("other_pressure") ;
597    ok_other_field2D_sub=xios_is_valid_field("other_field2D_sub") ;
598    ok_other_field3D_sub=xios_is_valid_field("other_field3D_sub") ;
599    ok_other_field_X=xios_is_valid_field("other_field_X") ;
600    ok_other_field_Y=xios_is_valid_field("other_field_Y") ;
601    ok_other_field_XY=xios_is_valid_field("other_field_XY") ;
602    ok_other_field_Z=xios_is_valid_field("other_field_Z") ; 
603    ok_other_field_XYZ=xios_is_valid_field("other_field_XYZ") ;
604    ok_other_field_XZ=xios_is_valid_field("other_field_XZ") ;
605    ok_other_field_YZ=xios_is_valid_field("other_field_YZ") ;
606
607    ok_other_field2D_W=xios_is_valid_field("other_field2D_W") ;
608    ok_other_field3D_W=xios_is_valid_field("other_field3D_W") ;
609    ok_other_pressure_W=xios_is_valid_field("other_pressure_W") ;
610    ok_other_field2D_sub_W=xios_is_valid_field("other_field2D_sub_W") ;
611    ok_other_field3D_sub_W=xios_is_valid_field("other_field3D_sub_W") ;
612    ok_other_field_XW=xios_is_valid_field("other_field_XW") ;
613    ok_other_field_YW=xios_is_valid_field("other_field_YW") ;
614    ok_other_field_XYZW=xios_is_valid_field("other_field_XYW") ;
615    ok_other_field_ZW=xios_is_valid_field("other_field_ZW") ; 
616    ok_other_field_XYZW=xios_is_valid_field("other_field_XYZW") ;
617    ok_other_field_XZW=xios_is_valid_field("other_field_XZW") ;
618    ok_other_field_YZW=xios_is_valid_field("other_field_YZW") ;
619
620
621!!!!!!!!!!!!!!!!!!!!! end of duplicated section   !!!!!!!!!!!!!!!!!!!!!!!!!!
622
623    ts=1
624    cdate=cdate+dtime
625    CALL xios_close_context_definition()
626    CALL xios_set_current_context(trim(model_id))
627
628   
629    DO while ( cdate <= edate )
630 
631      !!! Mise a jour du pas de temps
632      CALL xios_update_calendar(ts)
633
634      if (ok_field_in) CALL xios_recv_field("field_in", field_in)
635      if (ok_field_in) CALL xios_send_field("field_out", field_in)
636
637      IF (ok_field2D) CALL xios_send_field("field2D",field2D)
638      IF (ok_field3D) CALL xios_send_field("field3D",field3D)
639      IF (ok_pressure) CALL xios_send_field("pressure",pressure)
640      IF (ok_field_X) CALL xios_send_field("field_X",field_X)
641      IF (ok_field_Y) CALL xios_send_field("field_Y",field_Y)
642      IF (ok_field_XY) CALL xios_send_field("field_XY",field_XY)
643      IF (ok_field_Z) CALL xios_send_field("field_Z",field_Z)
644      IF (ok_field_XYZ) CALL xios_send_field("field_XYZ",field_XYZ)
645      IF (ok_field_XZ) CALL xios_send_field("field_XZ",field_XZ)
646      IF (ok_field_YZ) CALL xios_send_field("field_YZ",field_YZ)
647     
648      IF ( MOD(params%field_sub_offset+ts-1,params%field_sub_freq)==0) THEN
649        IF (ok_field2D_sub) CALL xios_send_field("field2D_sub",field2D*10)
650        IF (ok_field3D_sub) CALL xios_send_field("field3D_sub",field3D*10)
651      ENDIF
652
653      IF (ok_field3D_recv) THEN
654        IF (xios_field_is_active("field3D_resend",.TRUE.)) THEN
655          CALL xios_recv_field("field3D_recv",field3D_recv)
656          CALL xios_send_field("field3D_resend",field3D_recv)         
657         ENDIF
658      ENDIF
659
660! ensemble
661      IF (ok_field2D_W) CALL xios_send_field("field2D_W",field2D_W)
662      IF (ok_field3D_W) CALL xios_send_field("field3D_W",field3D_W)
663      IF (ok_pressure_W) CALL xios_send_field("pressure_W",pressure_W)
664      IF (ok_field_XW) CALL xios_send_field("field_XW",field_XW)
665      IF (ok_field_YW) CALL xios_send_field("field_YW",field_YW)
666      IF (ok_field_XYW) CALL xios_send_field("field_XYW",field_XYW)
667      IF (ok_field_ZW) CALL xios_send_field("field_ZW",field_ZW)
668      IF (ok_field_XYZW) CALL xios_send_field("field_XYZW",field_XYZW)
669      IF (ok_field_XZW) CALL xios_send_field("field_XZW",field_XZW)
670      IF (ok_field_YZW) CALL xios_send_field("field_YZW",field_YZW)
671     
672      IF ( MOD(params%field_sub_offset+ts-1,params%field_sub_freq)==0) THEN
673        IF (ok_field2D_sub_W) CALL xios_send_field("field2D_sub_W",field2D_W*10)
674        IF (ok_field3D_sub_W) CALL xios_send_field("field3D_sub_W",field3D_W*10)
675      ENDIF
676
677      IF (ok_field3D_recv_W) THEN
678        IF (xios_field_is_active("field3D_resend_W",.TRUE.)) THEN
679          CALL xios_recv_field("field3D_recv_W",field3D_recv_W)
680          CALL xios_send_field("field3D_resend_W",field3D_recv_W)         
681         ENDIF
682      ENDIF
683
684      field2D=field2D+1
685      field3D=field3D+1
686
687!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
688!              duplicated section for other_                    !
689!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
690
691
692      IF (ok_other_field2D) CALL xios_send_field("other_field2D", other_field2D)
693      IF (ok_other_field3D) CALL xios_send_field("other_field3D", other_field3D)
694      IF (ok_other_pressure) CALL xios_send_field("other_pressure", other_pressure)
695      IF (ok_other_field_X) CALL xios_send_field("other_field_X", other_field_X)
696      IF (ok_other_field_Y) CALL xios_send_field("other_field_Y", other_field_Y)
697      IF (ok_other_field_XY) CALL xios_send_field("other_field_XY", other_field_XY)
698      IF (ok_other_field_Z) CALL xios_send_field("other_field_Z", other_field_Z)
699      IF (ok_other_field_XY) CALL xios_send_field("other_field_XYZ", other_field_XYZ)
700      IF (ok_other_field_XY) CALL xios_send_field("other_field_XZ", other_field_XZ)
701      IF (ok_other_field_XY) CALL xios_send_field("other_field_YZ", other_field_YZ)
702     
703      IF ( MOD(other_params%field_sub_offset+ts-1,other_params%field_sub_freq)==0) THEN
704        IF (ok_other_field2D_sub) CALL xios_send_field("other_field2D_sub",other_field2D*10)
705        IF (ok_other_field3D_sub) CALL xios_send_field("other_field3D_sub",other_field3D*10)
706      ENDIF
707
708      IF (ok_other_field3D_recv) THEN
709        IF (xios_field_is_active("other_field3D_resend",.TRUE.)) THEN
710          CALL xios_recv_field("other_field3D_recv",other_field3D_recv)
711          CALL xios_send_field("other_field3D_resend",other_field3D_recv)         
712         ENDIF
713      ENDIF
714
715! ensemble
716      IF (ok_other_field2D_W) CALL xios_send_field("other_field2D_W",other_field2D_W)
717      IF (ok_other_field3D_W) CALL xios_send_field("other_field3D_W",other_field3D_W)
718      IF (ok_other_pressure_W) CALL xios_send_field("other_pressure_W",other_pressure_W)
719      IF (ok_other_field_XW) CALL xios_send_field("other_field_XW",other_field_XW)
720      IF (ok_other_field_YW) CALL xios_send_field("other_field_YW",other_field_YW)
721      IF (ok_other_field_XYW) CALL xios_send_field("other_field_XYW",other_field_XYW)
722      IF (ok_other_field_ZW) CALL xios_send_field("other_field_ZW",other_field_ZW)
723      IF (ok_other_field_XYW) CALL xios_send_field("other_field_XYZW",other_field_XYZW)
724      IF (ok_other_field_XYW) CALL xios_send_field("other_field_XZW",other_field_XZW)
725      IF (ok_other_field_XYW) CALL xios_send_field("other_field_YZW",other_field_YZW)
726     
727      IF ( MOD(other_params%field_sub_offset+ts-1,other_params%field_sub_freq)==0) THEN
728        IF (ok_other_field2D_sub_W) CALL xios_send_field("other_field2D_sub_W",other_field2D_W*10)
729        IF (ok_other_field3D_sub_W) CALL xios_send_field("other_field3D_sub_W",other_field3D_W*10)
730      ENDIF
731
732      IF (ok_other_field3D_recv_W) THEN
733        IF (xios_field_is_active("other_field3D_resend_W",.TRUE.)) THEN
734          CALL xios_recv_field("other_field3D_recv_W",other_field3D_recv_W)
735          CALL xios_send_field("other_field3D_resend_W",other_field3D_recv_W)         
736         ENDIF
737      ENDIF
738
739      other_field2D=other_field2D+1
740      other_field3D=other_field3D+1
741
742
743!!!!!!!!!!!!!!!!!!!!!! end of duplicated section !!!!!!!!!!!!!!!!!
744
745
746
747      !! Boucle d'attente
748      CALL wait_us(int(elapsed_per_timestep*1.e6))   ! micro-secondes
749      cdate=cdate+dtime
750      ts=ts+1
751    ENDDO
752   
753    CALL xios_context_finalize()
754    CALL MPI_COMM_FREE(comm, ierr)
755   
756  END SUBROUTINE model
757
758  SUBROUTINE init_model_params(prefix,params)
759  IMPLICIT NONE
760    CHARACTER(LEN=*) :: prefix
761    TYPE(tmodel_params) :: params
762
763
764    IF (.NOT. xios_getvar(prefix//"timestep", params%timestep) )         params%timestep="1h"
765    IF (.NOT. xios_getvar(prefix//"domain", params%domain) )             params%domain="lmdz"
766    IF (.NOT. xios_getvar(prefix//"domain_mask", params%domain_mask) )   params%domain_mask=.FALSE.
767    IF (.NOT. xios_getvar(prefix//"axis", params%axis) )                 params%axis="pressure"
768    IF (.NOT. xios_getvar(prefix//"axis_mask", params%axis_mask) )       params%axis_mask=.FALSE.
769    IF (.NOT. xios_getvar(prefix//"ni", params%ni) )                     params%ni=36
770    IF (.NOT. xios_getvar(prefix//"nj", params%nj) )                     params%nj=18
771    IF (.NOT. xios_getvar(prefix//"nlev", params%nlev) )                 params%nlev=10
772    IF (.NOT. xios_getvar(prefix//"init_field2D", params%init_field2D) ) params%init_field2D="academic"
773    IF (.NOT. xios_getvar(prefix//"pressure_factor", params%pressure_factor) ) params%pressure_factor=0.
774    IF (.NOT. xios_getvar(prefix//"mask3d", params%mask3d) ) params%mask3d=.FALSE.
775    IF (.NOT. xios_getvar(prefix//"field_sub_freq", params%field_sub_freq) ) params%field_sub_freq=1
776    IF (.NOT. xios_getvar(prefix//"field_sub_offset", params%field_sub_offset) ) params%field_sub_offset=0
777
778    IF (.NOT. xios_getvar(prefix//"domain_proc_n", params%domain_proc_n)) params%domain_proc_n=0
779    IF (.NOT. xios_getvar(prefix//"axis_proc_n", params%axis_proc_n)) params%axis_proc_n=0
780    IF (.NOT. xios_getvar(prefix//"ensemble_proc_n", params%ensemble_proc_n)) params%ensemble_proc_n=1
781    IF ((.NOT. xios_getvar(prefix//"domain_proc_frac", params%domain_proc_frac)) .AND.  &
782       (.NOT. xios_getvar("prefix//axis_proc_frac", params%axis_proc_frac))) THEN
783       params%domain_proc_frac=1.0
784       params%axis_proc_frac=0.0
785    ELSE IF (.NOT. xios_getvar(prefix//"domain_proc_frac", params%domain_proc_frac)) THEN
786      params%domain_proc_frac=0.0
787    ELSE IF (.NOT. xios_getvar(prefix//"axis_proc_frac", params%axis_proc_frac)) THEN
788      params%axis_proc_frac=0.0
789    ENDIF
790   
791  END SUBROUTINE init_model_params
792
793 
794  SUBROUTINE init_domain(domain_id, comm, params, return_ni, return_nj,             &
795                         return_lon, return_lat, return_mask, return_index,         &
796                         return_X_lon,return_X_lat, return_X_mask, return_X_index,  &
797                         return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
798  IMPLICIT NONE
799    CHARACTER(LEN=*),INTENT(IN) :: domain_id
800    TYPE(tmodel_params),INTENT(IN) :: params
801    INTEGER,INTENT(IN) :: comm
802    INTEGER,INTENT(OUT) :: return_ni
803    INTEGER,INTENT(OUT) :: return_nj
804    DOUBLE PRECISION, POINTER :: return_lon(:)
805    DOUBLE PRECISION, POINTER :: return_lat(:)
806    LOGICAL, POINTER :: return_mask(:)
807    INTEGER, POINTER :: return_index(:)
808    DOUBLE PRECISION, POINTER :: return_X_lon(:)
809    DOUBLE PRECISION, POINTER :: return_X_lat(:)
810    LOGICAL, POINTER :: return_X_mask(:)
811    INTEGER, POINTER :: return_X_index(:)
812    DOUBLE PRECISION, POINTER :: return_Y_lon(:)
813    DOUBLE PRECISION, POINTER :: return_Y_lat(:)
814    LOGICAL, POINTER :: return_Y_mask(:)
815    INTEGER, POINTER :: return_Y_index(:)
816       
817    IF (params%domain=="lmdz") THEN
818      CALL init_domain_lmdz(domain_id,comm,params, return_ni, return_nj,               &
819                            return_lon, return_lat, return_mask, return_index,         &
820                            return_X_lon,return_X_lat, return_X_mask, return_X_index,  &
821                            return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
822
823    ELSE IF (params%domain=="orchidee") THEN
824     CALL init_domain_orchidee(domain_id,comm,params, return_ni, return_nj,               &
825                               return_lon, return_lat, return_mask, return_index,         &
826                               return_X_lon,return_X_lat, return_X_mask, return_X_index,  &
827                               return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
828
829    ELSE IF (params%domain=="nemo") THEN
830       CALL init_domain_nemo(domain_id,comm,params, return_ni, return_nj,               &
831                             return_lon, return_lat, return_mask, return_index,         &
832                             return_X_lon,return_X_lat, return_X_mask, return_X_index,  &
833                             return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
834
835     ELSE IF (params%domain=="dynamico") THEN
836       CALL init_domain_dynamico(domain_id,comm,params, return_ni, return_nj,               &
837                                 return_lon, return_lat, return_mask, return_index,         &
838                                 return_X_lon,return_X_lat, return_X_mask, return_X_index,  &
839                                 return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
840
841     ELSE IF (params%domain=="gaussian") THEN
842       CALL init_domain_gaussian(domain_id,comm,params, return_ni, return_nj,               &
843                                 return_lon, return_lat, return_mask, return_index,         &
844                                 return_X_lon,return_X_lat, return_X_mask, return_X_index,  &
845                                 return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
846    ENDIF
847   
848  END SUBROUTINE init_domain
849
850  SUBROUTINE init_field2D(comm,params, lon, lat, mask, return_field,        &
851                                       x_lon, x_lat, x_mask, return_fieldx, &
852                                       y_lon, y_lat, y_mask, return_fieldy, return_fieldXY)
853  IMPLICIT NONE
854    TYPE(tmodel_params) :: params
855    TYPE(xios_context) :: ctx_hdl
856    INTEGER :: comm
857    DOUBLE PRECISION, POINTER :: lon(:)
858    DOUBLE PRECISION, POINTER :: lat(:)
859    LOGICAL, POINTER :: mask(:)
860    DOUBLE PRECISION, POINTER :: return_field(:)
861
862    DOUBLE PRECISION, POINTER :: X_lon(:)
863    DOUBLE PRECISION, POINTER :: X_lat(:)
864    LOGICAL, POINTER :: X_mask(:)
865    DOUBLE PRECISION, POINTER :: return_fieldX(:)
866
867    DOUBLE PRECISION, POINTER :: Y_lon(:)
868    DOUBLE PRECISION, POINTER :: Y_lat(:)
869    LOGICAL, POINTER :: Y_mask(:)
870    DOUBLE PRECISION, POINTER :: return_fieldY(:)
871    DOUBLE PRECISION, POINTER :: return_fieldXY(:,:)
872       
873    IF (params%init_field2D=="academic") THEN
874      CALL init_field2D_academic(comm,params, lon, lat, mask, return_field, X_lon, X_lat, X_mask, return_fieldX, &
875                                Y_lon, Y_lat, Y_mask, return_fieldY, return_fieldXY)
876    ELSE IF (params%init_field2D=="constant") THEN
877      CALL init_field2D_constant(comm,params, lon, lat, mask, return_field, X_lon, X_lat, X_mask, return_fieldX, &
878                                 Y_lon, Y_lat, Y_mask, return_fieldY, return_fieldXY)
879    ELSE IF (params%init_field2D=="rank") THEN
880      CALL init_field2D_rank(comm,params, lon, lat, mask, return_field, X_lon, X_lat, X_mask, &
881                             return_fieldX, Y_lon, Y_lat, Y_mask, return_fieldY, return_fieldXY)
882    ENDIF
883   
884  END SUBROUTINE init_field2D
885
886 
887  SUBROUTINE init_axis(axis_id,comm,params, return_value, return_mask, return_index)
888  IMPLICIT NONE
889    CHARACTER(LEN=*) :: axis_id
890    TYPE(tmodel_params) :: params
891    TYPE(xios_context) :: ctx_hdl
892    INTEGER :: comm
893    DOUBLE PRECISION, POINTER :: return_value(:)
894    LOGICAL, POINTER          :: return_mask(:)
895    INTEGER, POINTER          :: return_index(:)
896   
897    IF (params%axis=="pressure") THEN
898      CALL init_axis_pressure(axis_id,comm,params, return_value, return_mask, return_index)
899    ENDIF
900   
901   END SUBROUTINE init_axis
902   
903  SUBROUTINE init_ensemble(ensemble_id,comm,params, return_value)
904  IMPLICIT NONE
905    CHARACTER(LEN=*) :: ensemble_id
906    TYPE(tmodel_params) :: params
907    TYPE(xios_context) :: ctx_hdl
908    INTEGER :: comm
909    DOUBLE PRECISION, POINTER :: return_value(:)
910    INTEGER :: domain_proc_rank, domain_proc_size   
911    INTEGER :: axis_proc_rank, axis_proc_size
912    INTEGER :: ensemble_proc_size, ensemble_proc_rank
913
914    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
915                           ensemble_proc_size, ensemble_proc_rank)
916    ALLOCATE(return_value(0:0))
917    return_value(0)=ensemble_proc_rank
918
919    IF (xios_is_valid_axis(TRIM(ensemble_id))) THEN
920      CALL xios_set_axis_attr(ensemble_id, n_glo=ensemble_proc_size, begin=ensemble_proc_rank, n=1, value=return_value(:), &
921                              unit='-')   
922    ENDIF
923   
924   END SUBROUTINE init_ensemble
925   
926
927  SUBROUTINE init_domain_gaussian(domain_id, comm, params, return_ni, return_nj,               &
928                                  return_lon,return_lat,return_mask, return_index,             &
929                                  return_X_lon,return_X_lat, return_X_mask, return_X_index,    &
930                                  return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
931  IMPLICIT NONE
932    CHARACTER(LEN=*) :: domain_id
933    TYPE(tmodel_params) :: params
934    TYPE(xios_context) :: ctx_hdl
935    INTEGER :: comm
936    INTEGER :: return_ni
937    INTEGER :: return_nj
938    DOUBLE PRECISION, POINTER :: return_lon(:)
939    DOUBLE PRECISION, POINTER :: return_lat(:)
940    LOGICAL, POINTER :: return_mask(:)
941    INTEGER, POINTER :: return_index(:)
942    DOUBLE PRECISION, POINTER :: return_X_lon(:)
943    DOUBLE PRECISION, POINTER :: return_X_lat(:)
944    LOGICAL, POINTER :: return_X_mask(:)
945    INTEGER, POINTER :: return_X_index(:)
946    DOUBLE PRECISION, POINTER :: return_Y_lon(:)
947    DOUBLE PRECISION, POINTER :: return_Y_lat(:)
948    LOGICAL, POINTER :: return_Y_mask(:)
949    INTEGER, POINTER :: return_Y_index(:)
950    INTEGER :: domain_proc_rank, domain_proc_size   
951    INTEGER :: axis_proc_rank, axis_proc_size
952    INTEGER :: ensemble_proc_size, ensemble_proc_rank
953
954    INTEGER :: mpi_rank, mpi_size
955    INTEGER ::  ierr
956   
957!  INTEGER, PARAMETER :: nlon=60
958!  INTEGER, PARAMETER :: nlat=30
959!  INTEGER,PARAMETER :: ni_glo=100
960!  INTEGER,PARAMETER :: nj_glo=100
961!  INTEGER,PARAMETER :: llm=5
962!  DOUBLE PRECISION  :: lval(llm)=1
963!  TYPE(xios_field) :: field_hdl
964!  TYPE(xios_fieldgroup) :: fieldgroup_hdl
965!  TYPE(xios_file) :: file_hdl
966!  LOGICAL :: ok
967
968!  DOUBLE PRECISION,ALLOCATABLE :: lon_glo(:),lat_glo(:)
969!  DOUBLE PRECISION,ALLOCATABLE :: bounds_lon_glo(:,:),bounds_lat_glo(:,:)
970!  DOUBLE PRECISION,ALLOCATABLE :: field_A_glo(:,:)
971!  INTEGER,ALLOCATABLE :: i_index_glo(:)
972!  INTEGER,ALLOCATABLE :: i_index(:)
973!  LOGICAL,ALLOCATABLE :: mask_glo(:),mask(:)
974!  INTEGER,ALLOCATABLE :: n_local(:),local_neighbor(:,:)
975!  DOUBLE PRECISION,ALLOCATABLE :: lon(:),lat(:),field_A_srf(:,:), lonvalue(:) ;
976!  DOUBLE PRECISION,ALLOCATABLE :: bounds_lon(:,:),bounds_lat(:,:) ;
977!  INTEGER :: ni,ibegin,iend,nj,jbegin,jend
978!  INTEGER :: i,j,l,ts,n, nbMax
979!  INTEGER :: ncell_glo,ncell,ind
980!  REAL :: ilon,ilat
981!  DOUBLE PRECISION, PARAMETER :: Pi=3.14159265359
982!  INTEGER :: list_ind(nlon,nlat)
983!  INTEGER :: rank,j1,j2,np,ncell_x
984!  INTEGER :: data_n_index
985!  INTEGER,ALLOCATABLE :: data_i_index(:)
986!  DOUBLE PRECISION,ALLOCATABLE :: field_A_compressed(:,:)
987
988
989    INTEGER :: nlon, nlat
990    DOUBLE PRECISION,ALLOCATABLE :: lon_glo(:),lat_glo(:)
991    DOUBLE PRECISION,ALLOCATABLE :: bounds_lon_glo(:,:),bounds_lat_glo(:,:)
992    INTEGER,ALLOCATABLE :: i_index_glo(:)
993    INTEGER,ALLOCATABLE :: i_index(:)
994    LOGICAL,ALLOCATABLE :: mask_glo(:),mask(:)
995    DOUBLE PRECISION,ALLOCATABLE :: lon(:),lat(:),field_A_srf(:,:), lonvalue(:) ;
996    DOUBLE PRECISION,ALLOCATABLE :: bounds_lon(:,:),bounds_lat(:,:) ;
997
998    INTEGER :: ni,ibegin,iend,nj,jbegin,jend
999    INTEGER :: i,j,l,ts,n, nbMax
1000    INTEGER :: ncell_glo,ncell,ind
1001    REAL :: ilon,ilat
1002    DOUBLE PRECISION, PARAMETER :: Pi=3.14159265359
1003    INTEGER,ALLOCATABLE :: list_ind(:,:)
1004    INTEGER :: rank,j1,j2,np,ncell_x
1005    INTEGER :: data_n_index
1006    INTEGER,ALLOCATABLE :: data_i_index(:)
1007
1008
1009
1010    CALL MPI_COMM_RANK(comm,mpi_rank,ierr)
1011    CALL MPI_COMM_SIZE(comm,mpi_size,ierr)
1012
1013    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
1014                           ensemble_proc_size, ensemble_proc_rank)
1015
1016    mpi_rank=domain_proc_rank
1017    mpi_size=domain_proc_size
1018    nlon=params%ni
1019    nlat=params%nj
1020
1021   
1022    ncell_glo=0
1023    DO j=1,nlat
1024      n =  NINT(COS(Pi/2-(j-0.5)*PI/nlat)*nlon)
1025      IF (n<8) n=8
1026      ncell_glo=ncell_glo+n
1027    ENDDO
1028
1029    ALLOCATE(lon_glo(ncell_glo))
1030    ALLOCATE(lat_glo(ncell_glo))
1031    ALLOCATE(bounds_lon_glo(4,ncell_glo))
1032    ALLOCATE(bounds_lat_glo(4,ncell_glo))
1033    ALLOCATE(i_index_glo(ncell_glo))
1034    ALLOCATE(mask_glo(ncell_glo))
1035    ALLOCATE(list_ind(nlon,nlat))
1036   
1037    ind=0
1038    DO j=1,nlat
1039      n = NINT(COS(Pi/2-(j-0.5)*PI/nlat)*nlon)
1040      if (j==1) PRINT*,"--- ",n
1041      if (j==nlat) PRINT*,"--- ",n
1042      IF (n<8) n=8
1043
1044      DO i=1,n
1045        ind=ind+1
1046        list_ind(i,j)=ind
1047        ilon=i-0.5
1048        ilat=j-0.5
1049
1050        lat_glo(ind)= 90-(ilat*180./nlat)
1051        lon_glo(ind)= (ilon*360./n)-180.
1052
1053
1054        bounds_lat_glo(1,ind)= 90-((ilat-0.5)*180./nlat)
1055        bounds_lon_glo(1,ind)=((ilon-0.5)*360./n)-180.
1056
1057        bounds_lat_glo(2,ind)= 90-((ilat-0.5)*180./nlat)
1058        bounds_lon_glo(2,ind)=((ilon+0.5)*360./n)-180.
1059
1060        bounds_lat_glo(3,ind)= 90-((ilat+0.5)*180./nlat)
1061        bounds_lon_glo(3,ind)=((ilon+0.5)*360./n)-180.
1062
1063        bounds_lat_glo(4,ind)= 90-((ilat+0.5)*180./nlat)
1064        bounds_lon_glo(4,ind)=((ilon-0.5)*360./n)-180.
1065
1066      ENDDO
1067    ENDDO
1068
1069!  mpi_size=32
1070    rank=(mpi_size-1)/2
1071    ncell_x=sqrt(ncell_glo*1./mpi_size)
1072
1073    j1=nlat/2
1074    DO WHILE(rank>=0)
1075      j2=MAX(j1-ncell_x+1,1)
1076      j=(j1+j2)/2
1077      n=NINT(COS(Pi/2-(j-0.5)*PI/nlat)*nlon)
1078      np = MIN(n/ncell_x,rank+1) ;
1079      if (j2==1) np=rank+1
1080 
1081      PRINT *,"domain ",j2,j1,rank,np ;
1082      DO j=j2,j1
1083        n=NINT(COS(Pi/2-(j-0.5)*PI/nlat)*nlon)
1084        IF (n<8) n=8
1085        DO i=1,n
1086          ind=list_ind(i,j)
1087          IF ( (i-1) < MOD(n,np)*(n/np+1)) THEN 
1088            i_index_glo(ind) = rank - (i-1)/(n/np+1)
1089          ELSE
1090            i_index_glo(ind) = rank-(MOD(n,np)+ (i-1-MOD(n,np)*(n/np+1))/(n/np))
1091          ENDIF
1092        ENDDO
1093      ENDDO
1094      rank=rank-np
1095      j1=j2-1
1096    ENDDO
1097
1098    rank=(mpi_size-1)/2+1
1099    ncell_x=sqrt(ncell_glo*1./mpi_size)
1100
1101    j1=nlat/2+1
1102    DO WHILE(rank<=mpi_size-1)
1103      j2=MIN(j1+ncell_x-1,nlat)
1104      j=(j1+j2)/2
1105      n=NINT(COS(Pi/2-(j-0.5)*PI/nlat)*nlon)
1106      np = MIN(n/ncell_x,mpi_size-rank) ;
1107      if (j2==nlat) np=mpi_size-rank
1108
1109      PRINT *,"domain ",j2,j1,rank,np ;
1110      DO j=j1,j2
1111        n=NINT(COS(Pi/2-(j-0.5)*PI/nlat)*nlon)
1112        IF (n<8) n=8
1113        DO i=1,n
1114          ind=list_ind(i,j)
1115          IF ( (i-1) < MOD(n,np)*(n/np+1)) THEN
1116            i_index_glo(ind) = rank + (i-1)/(n/np+1)
1117          ELSE
1118            i_index_glo(ind) = rank+(MOD(n,np)+ (i-1-MOD(n,np)*(n/np+1))/(n/np))
1119          ENDIF
1120        ENDDO
1121      ENDDO
1122      rank=rank+np
1123      j1=j2+1
1124   ENDDO
1125
1126    ncell=0
1127    DO ind=1,ncell_glo
1128      IF (i_index_glo(ind)==mpi_rank) ncell=ncell+1
1129    ENDDO
1130    ALLOCATE(i_index(ncell))
1131    ALLOCATE(lon(ncell))
1132    ALLOCATE(lat(ncell))
1133    ALLOCATE(bounds_lon(4,ncell))
1134    ALLOCATE(bounds_lat(4,ncell))
1135!    ALLOCATE(field_A_srf(ncell,llm))
1136    ALLOCATE(mask(ncell))
1137    ncell=0
1138    data_n_index=0
1139    DO ind=1,ncell_glo
1140      IF (i_index_glo(ind)==mpi_rank) THEN
1141        ncell=ncell+1
1142        i_index(ncell)=ind-1
1143        lon(ncell)=lon_glo(ind)
1144        lat(ncell)=lat_glo(ind)
1145        bounds_lon(:,ncell)=bounds_lon_glo(:,ind)
1146        bounds_lat(:,ncell)=bounds_lat_glo(:,ind)
1147        field_A_srf(ncell,:)=i_index_glo(ind)
1148        IF (MOD(ind,8)>=0 .AND. MOD(ind,8)<2) THEN
1149!        mask(ncell)=.FALSE.
1150
1151         mask(ncell)=.TRUE.
1152          data_n_index=data_n_index+1
1153        ELSE
1154          mask(ncell)=.TRUE.
1155          data_n_index=data_n_index+1
1156        ENDIF
1157      ENDIF
1158    ENDDO
1159
1160!    ALLOCATE(field_A_compressed(data_n_index,llm))
1161    ALLOCATE(data_i_index(data_n_index))
1162    data_n_index=0
1163    DO ind=1,ncell
1164      IF (mask(ind)) THEN
1165        data_n_index=data_n_index+1
1166        data_i_index(data_n_index)=ind-1
1167!        field_A_compressed(data_n_index,:)=field_A_srf(ind,:)
1168      ENDIF
1169    ENDDO
1170
1171    ALLOCATE(return_lon(0:ncell-1))
1172    ALLOCATE(return_lat(0:ncell-1))
1173    ALLOCATE(return_mask(0:ncell-1))
1174    ALLOCATE(return_index(0:data_n_index-1))
1175    return_lon(0:ncell-1)=lon(1:ncell)   
1176    return_lat(0:ncell-1)=lat(1:ncell)
1177    return_index(0:data_n_index-1)= data_i_index(1:data_n_index) 
1178    CALL set_domain_mask(params, lon, lat, return_mask)
1179
1180
1181    ALLOCATE(return_X_lon(0:ncell-1))
1182    ALLOCATE(return_X_lat(0:ncell-1))
1183    ALLOCATE(return_X_mask(0:ncell-1))
1184    ALLOCATE(return_X_index(0:ncell-1))
1185   
1186    return_X_lon=return_lon
1187    return_X_lat=return_lat
1188    return_X_index=return_index
1189    CALL set_domain_mask(params, return_X_lon,return_X_lat, return_X_mask)
1190
1191
1192    ALLOCATE(return_Y_lon(0:0))
1193    ALLOCATE(return_Y_lat(0:0))
1194    ALLOCATE(return_Y_mask(0:0))
1195    ALLOCATE(return_Y_index(0:0))
1196
1197    return_Y_lon(0)=lon_glo(ncell_glo/2)
1198    return_Y_lat(0)=lat_glo(ncell_glo/2)
1199    CALL set_domain_mask(params, return_Y_lon,return_Y_lat, return_Y_mask)
1200    return_Y_index(0)=0
1201
1202    return_ni=ncell
1203    return_nj=1
1204
1205
1206    IF (xios_is_valid_domain(TRIM(domain_id))) THEN
1207      CALL xios_set_domain_attr(TRIM(domain_id), type="unstructured", ni_glo=ncell_glo, ni=ncell, ibegin=0, i_index=i_index)
1208      CALL xios_set_domain_attr(TRIM(domain_id), data_dim=1, data_ni=data_n_index, data_i_index=data_i_index, mask_1d=return_mask)
1209      CALL xios_set_domain_attr(TRIM(domain_id), lonvalue_1D=lon, latvalue_1D=lat, nvertex=4, bounds_lon_1D=bounds_lon, &
1210                                bounds_lat_1D=bounds_lat)
1211    ENDIF
1212
1213    IF (xios_is_valid_axis(TRIM(domain_id)//"_X")) THEN
1214      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", n_glo=ncell_glo, n=ncell, begin=0, index=i_index,value=return_X_lon)
1215      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", data_n=data_n_index, data_index=data_i_index, mask=return_X_mask)
1216    ENDIF
1217   
1218    IF (xios_is_valid_axis(TRIM(domain_id)//"_Y")) THEN   
1219      CALL xios_set_axis_attr(TRIM(domain_id)//"_Y", n_glo=1, begin=0, n=1, value=return_Y_lat, mask=return_Y_mask)
1220    ENDIF
1221
1222
1223
1224  END SUBROUTINE init_domain_gaussian
1225
1226
1227
1228  SUBROUTINE init_domain_dynamico(domain_id, comm, params, return_ni, return_nj,           &
1229                              return_lon,return_lat,return_mask, return_index,             &
1230                              return_X_lon,return_X_lat, return_X_mask, return_X_index,    &
1231                              return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
1232  IMPLICIT NONE
1233    CHARACTER(LEN=*) :: domain_id
1234    TYPE(tmodel_params) :: params
1235    TYPE(xios_context) :: ctx_hdl
1236    INTEGER :: comm
1237    INTEGER :: return_ni
1238    INTEGER :: return_nj
1239    DOUBLE PRECISION, POINTER :: return_lon(:)
1240    DOUBLE PRECISION, POINTER :: return_lat(:)
1241    LOGICAL, POINTER :: return_mask(:)
1242    INTEGER, POINTER :: return_index(:)
1243    DOUBLE PRECISION, POINTER :: return_X_lon(:)
1244    DOUBLE PRECISION, POINTER :: return_X_lat(:)
1245    LOGICAL, POINTER :: return_X_mask(:)
1246    INTEGER, POINTER :: return_X_index(:)
1247    DOUBLE PRECISION, POINTER :: return_Y_lon(:)
1248    DOUBLE PRECISION, POINTER :: return_Y_lat(:)
1249    LOGICAL, POINTER :: return_Y_mask(:)
1250    INTEGER, POINTER :: return_Y_index(:)
1251    INTEGER :: domain_proc_rank, domain_proc_size   
1252    INTEGER :: axis_proc_rank, axis_proc_size
1253    INTEGER :: ensemble_proc_size, ensemble_proc_rank
1254
1255    INTEGER :: mpi_rank, mpi_size
1256    INTEGER ::  ierr
1257    INTEGER :: ni,nj,ni_glo,nj_glo,nvertex
1258    INTEGER :: ibegin,jbegin
1259    INTEGER :: nbp,nbp_glo, offset
1260    DOUBLE PRECISION, ALLOCATABLE :: lon_glo(:), lat_glo(:), lon(:), lat(:)
1261    DOUBLE PRECISION, ALLOCATABLE :: bounds_lon_glo(:,:), bounds_lat_glo(:,:), bounds_lon(:,:), bounds_lat(:,:)
1262    LOGICAL,ALLOCATABLE :: mask(:)
1263    LOGICAL,ALLOCATABLE :: dom_mask(:)
1264    INTEGER :: i,j
1265    INTEGER,ALLOCATABLE :: ibegin_all(:), ni_all(:)
1266       
1267    CALL MPI_COMM_RANK(comm,mpi_rank,ierr)
1268    CALL MPI_COMM_SIZE(comm,mpi_size,ierr)
1269
1270    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
1271                           ensemble_proc_size, ensemble_proc_rank)
1272
1273    CALL xios_get_current_context(ctx_hdl)
1274   
1275    CALL xios_context_initialize("grid_dynamico",comm)
1276    CALL xios_close_context_definition()
1277    CALL xios_get_domain_attr("domain_dynamico",ni_glo=ni_glo,nj_glo=nj_glo,ni=ni,nj=nj, ibegin=ibegin, jbegin=jbegin , &
1278                              nvertex=nvertex)
1279    ALLOCATE(lon(ni),lat(ni),bounds_lon(nvertex,ni),bounds_lat(nvertex,ni))
1280    CALL xios_get_domain_attr("domain_dynamico", lonvalue_1d=lon, latvalue_1d=lat, bounds_lon_1d=bounds_lon, &
1281                               bounds_lat_1d=bounds_lat)
1282    CALL xios_context_finalize
1283
1284    CALL xios_set_current_context(ctx_hdl)
1285
1286   
1287    ALLOCATE(ibegin_all(mpi_size))
1288    ALLOCATE(ni_all(mpi_size))
1289    ALLOCATE(lon_glo(0:ni_glo-1))
1290    ALLOCATE(lat_glo(0:ni_glo-1))
1291    ALLOCATE(bounds_lon_glo(nvertex,0:ni_glo-1))
1292    ALLOCATE(bounds_lat_glo(nvertex,0:ni_glo-1))
1293   
1294    CALL MPI_Allgather(ibegin, 1, MPI_INTEGER, ibegin_all, 1, MPI_INTEGER, comm, ierr)
1295    CALL MPI_Allgather(ni, 1, MPI_INTEGER, ni_all, 1, MPI_INTEGER, comm, ierr)
1296
1297    CALL MPI_AllgatherV(lon, ni, MPI_REAL8, lon_glo, ni_all, ibegin_all, MPI_REAL8, comm, ierr) 
1298    CALL MPI_AllgatherV(lat, ni, MPI_REAL8, lat_glo, ni_all, ibegin_all, MPI_REAL8, comm, ierr) 
1299    CALL MPI_AllgatherV(bounds_lon, ni*nvertex, MPI_REAL8, bounds_lon_glo, ni_all*nvertex, ibegin_all*nvertex, &
1300                        MPI_REAL8, comm, ierr) 
1301    CALL MPI_AllgatherV(bounds_lat, ni*nvertex, MPI_REAL8, bounds_lat_glo, ni_all*nvertex, ibegin_all*nvertex, &
1302                        MPI_REAL8, comm, ierr) 
1303
1304   
1305    nbp_glo=ni_glo
1306    nbp=nbp_glo/domain_proc_size
1307    IF (domain_proc_rank < MOD(nbp_glo,domain_proc_size) ) THEN
1308      nbp=nbp+1
1309      offset=nbp*domain_proc_rank
1310    ELSE
1311      offset=nbp*domain_proc_rank + MOD(nbp_glo, domain_proc_size)
1312    ENDIF
1313
1314    DEALLOCATE(lat,lon,bounds_lon,bounds_lat)
1315    ALLOCATE(lat(0:nbp-1))
1316    ALLOCATE(lon(0:nbp-1))
1317    ALLOCATE(bounds_lon(nvertex,0:nbp-1))
1318    ALLOCATE(bounds_lat(nvertex,0:nbp-1))
1319    ALLOCATE(return_lon(0:nbp-1))
1320    ALLOCATE(return_lat(0:nbp-1))
1321    ALLOCATE(return_index(0:nbp-1))
1322
1323    DO i=0,nbp-1
1324      lat(i)=lat_glo(i+offset)
1325      lon(i)=lon_glo(i+offset)
1326      bounds_lon(:,i) = bounds_lon_glo(:,i+offset) 
1327      bounds_lat(:,i) = bounds_lat_glo(:,i+offset)
1328      return_index(i)=i 
1329    ENDDO
1330    return_lon=lon
1331    return_lat=lat
1332   
1333    ALLOCATE(return_mask(0:nbp-1))
1334    CALL set_domain_mask(params, lon, lat, return_mask)
1335
1336
1337    ALLOCATE(return_X_lon(0:nbp-1))
1338    ALLOCATE(return_X_lat(0:nbp-1))
1339    ALLOCATE(return_X_mask(0:nbp-1))
1340    ALLOCATE(return_X_index(0:nbp-1))
1341   
1342    DO i=0,nbp-1
1343      return_X_lon(i)=lon_glo(i+offset)
1344      return_X_lat(i)=lat_glo(i+offset)
1345    ENDDO
1346    CALL set_domain_mask(params, return_X_lon,return_X_lat, return_X_mask)
1347    DO i=0,nbp-1
1348      return_X_index(i)=i
1349    ENDDO
1350
1351    ALLOCATE(return_Y_lon(0:0))
1352    ALLOCATE(return_Y_lat(0:0))
1353    ALLOCATE(return_Y_mask(0:0))
1354    ALLOCATE(return_Y_index(0:0))
1355
1356    return_Y_lon(0)=lon_glo(nbp_glo/2)
1357    return_Y_lat(0)=lat_glo(nbp_glo/2)
1358    CALL set_domain_mask(params, return_Y_lon,return_Y_lat, return_Y_mask)
1359    return_Y_index(0)=0
1360 
1361
1362   
1363    return_ni=nbp
1364    return_nj=1
1365
1366    IF (xios_is_valid_domain(TRIM(domain_id))) THEN
1367      CALL xios_set_domain_attr(TRIM(domain_id), type="unstructured", ni_glo=ni_glo, ibegin=offset, ni=nbp, nvertex=nvertex)
1368      CALL xios_set_domain_attr(TRIM(domain_id), data_dim=1, lonvalue_1d=lon, latvalue_1d=lat, bounds_lon_1d=bounds_lon, &
1369                                bounds_lat_1d=bounds_lat, mask_1d=return_mask)
1370    ENDIF   
1371
1372    IF (xios_is_valid_axis(TRIM(domain_id)//"_X")) THEN
1373      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", n_glo=ni_glo, begin=offset, n=nbp, value=return_X_lon)
1374    ENDIF
1375
1376    IF (xios_is_valid_axis(TRIM(domain_id)//"_Y")) THEN   
1377      CALL xios_set_axis_attr(TRIM(domain_id)//"_Y", n_glo=1, begin=0, n=1, value=return_Y_lat, mask=return_Y_mask)
1378    ENDIF
1379
1380   END SUBROUTINE init_domain_dynamico
1381   
1382
1383
1384
1385  SUBROUTINE init_domain_lmdz(domain_id, comm, params, return_ni, return_nj,               &
1386                              return_lon,return_lat,return_mask, return_index,             &
1387                              return_X_lon,return_X_lat, return_X_mask, return_X_index,    &
1388                              return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
1389  IMPLICIT NONE
1390    CHARACTER(LEN=*) :: domain_id
1391    TYPE(tmodel_params) :: params
1392    TYPE(xios_context) :: ctx_hdl
1393    INTEGER :: comm
1394    INTEGER :: return_ni
1395    INTEGER :: return_nj
1396    DOUBLE PRECISION, POINTER :: return_lon(:)
1397    DOUBLE PRECISION, POINTER :: return_lat(:)
1398    LOGICAL, POINTER :: return_mask(:)
1399    INTEGER, POINTER :: return_index(:)
1400    DOUBLE PRECISION, POINTER :: return_X_lon(:)
1401    DOUBLE PRECISION, POINTER :: return_X_lat(:)
1402    LOGICAL, POINTER :: return_X_mask(:)
1403    INTEGER, POINTER :: return_X_index(:)
1404    DOUBLE PRECISION, POINTER :: return_Y_lon(:)
1405    DOUBLE PRECISION, POINTER :: return_Y_lat(:)
1406    LOGICAL, POINTER :: return_Y_mask(:)
1407    INTEGER, POINTER :: return_Y_index(:)
1408    INTEGER :: domain_proc_rank, domain_proc_size   
1409    INTEGER :: axis_proc_rank, axis_proc_size
1410    INTEGER :: ensemble_proc_size, ensemble_proc_rank
1411
1412    INTEGER :: mpi_rank, mpi_size
1413    INTEGER ::  ierr
1414    INTEGER :: ni,nj,ni_glo,nj_glo
1415    INTEGER :: ibegin,jbegin
1416    INTEGER :: nbp,nbp_glo, offset
1417    DOUBLE PRECISION, ALLOCATABLE :: lon_glo(:), lat_glo(:), lon(:), lat(:)
1418    LOGICAL,ALLOCATABLE :: mask(:)
1419    LOGICAL,ALLOCATABLE :: dom_mask(:)
1420    INTEGER :: i,j
1421       
1422    CALL MPI_COMM_RANK(comm,mpi_rank,ierr)
1423    CALL MPI_COMM_SIZE(comm,mpi_size,ierr)
1424
1425    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
1426                           ensemble_proc_size, ensemble_proc_rank)
1427    ni_glo=params%ni
1428    nj_glo=params%nj
1429    nbp_glo=ni_glo*nj_glo
1430    nbp=nbp_glo/domain_proc_size
1431    IF (domain_proc_rank < MOD(nbp_glo,domain_proc_size) ) THEN
1432     nbp=nbp+1
1433     offset=nbp*domain_proc_rank
1434    ELSE
1435      offset=nbp*domain_proc_rank + MOD(nbp_glo, domain_proc_size)
1436    ENDIF
1437   
1438   
1439    ibegin=0 ; ni=ni_glo
1440    jbegin=offset / ni_glo
1441   
1442    nj = (offset+nbp-1) / ni_glo - jbegin + 1 
1443   
1444    offset=offset-jbegin*ni
1445   
1446    ALLOCATE(lon(0:ni-1), lat(0:nj-1), mask(0:ni*nj-1), dom_mask(0:ni*nj-1))
1447    mask(:)=.FALSE.
1448    mask(offset:offset+nbp-1)=.TRUE.
1449   
1450    ALLOCATE(lon_glo(0:ni_glo-1), lat_glo(0:nj_glo-1))
1451   
1452    DO i=0,ni_glo-1
1453      lon_glo(i)=-180+(i+0.5)*(360./ni_glo)
1454    ENDDO
1455
1456    DO j=0,nj_glo-1
1457      lat_glo(j)=-90+(j+0.5)*(180./nj_glo)
1458    ENDDO
1459     
1460    lon(:)=lon_glo(:)
1461    lat(:)=lat_glo(jbegin:jbegin+nj-1)
1462
1463    ALLOCATE(return_lon(0:ni*nj-1))
1464    ALLOCATE(return_lat(0:ni*nj-1))
1465    ALLOCATE(return_mask(0:ni*nj-1))
1466    ALLOCATE(return_index(0:ni*nj-1))
1467
1468    ALLOCATE(return_X_lon(0:ni-1))
1469    ALLOCATE(return_X_lat(0:ni-1))
1470    ALLOCATE(return_X_mask(0:ni-1))
1471    ALLOCATE(return_X_index(0:ni-1))
1472
1473    ALLOCATE(return_Y_lon(0:nj-1))
1474    ALLOCATE(return_Y_lat(0:nj-1))
1475    ALLOCATE(return_Y_mask(0:nj-1))
1476    ALLOCATE(return_Y_index(0:nj-1))
1477
1478    DO j=0,nj-1
1479      DO i=0,ni-1
1480        return_lon(i+j*ni)=lon(i)
1481        return_lat(i+j*ni)=lat(j)
1482        return_index(i+j*ni)=i+j*ni
1483      ENDDO
1484    ENDDO
1485
1486    CALL set_domain_mask(params, return_lon,return_lat, dom_mask)
1487   
1488    return_mask = mask .AND. dom_mask
1489
1490    return_X_lat(:)=lat_glo(nj_glo/2)
1491    return_X_lon(:)=lon_glo(:)
1492    CALL set_domain_mask(params, return_X_lon,return_X_lat, return_X_mask)
1493    DO i=0,ni-1
1494      return_X_index(i)=i
1495    ENDDO
1496
1497    return_Y_lon(:)=lon_glo(ni_glo/2)
1498    return_Y_lat(:)=lat_glo(jbegin:jbegin+nj-1)
1499    CALL set_domain_mask(params, return_Y_lon,return_Y_lat, return_Y_mask)
1500
1501    DO j=0,nj-1
1502      return_Y_index(j)=j
1503    ENDDO
1504
1505    return_ni=ni
1506    return_nj=nj
1507
1508    IF (xios_is_valid_domain(TRIM(domain_id))) THEN
1509      CALL xios_set_domain_attr(TRIM(domain_id), type="rectilinear", ni_glo=ni_glo, ibegin=ibegin, ni=ni, nj_glo=nj_glo, &
1510                                jbegin=jbegin, nj=nj)
1511      CALL xios_set_domain_attr(TRIM(domain_id), data_dim=2, lonvalue_1d=lon, latvalue_1d=lat, mask_1d=return_mask)
1512    ENDIF
1513   
1514    IF (xios_is_valid_axis(TRIM(domain_id)//"_X")) THEN
1515      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", n_glo=ni_glo, begin=ibegin, n=ni, value=return_X_lon)
1516    ENDIF
1517
1518    IF (xios_is_valid_axis(TRIM(domain_id)//"_Y")) THEN   
1519      CALL xios_set_axis_attr(TRIM(domain_id)//"_Y", n_glo=nj_glo, begin=jbegin, n=nj, value=return_Y_lat)
1520    ENDIF
1521
1522  END SUBROUTINE init_domain_lmdz
1523
1524
1525  SUBROUTINE init_domain_orchidee(domain_id, comm, params, return_ni, return_nj,               &
1526                                  return_lon,return_lat,return_mask, return_index,             &
1527                                  return_X_lon,return_X_lat, return_X_mask, return_X_index,    &
1528                                  return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
1529  IMPLICIT NONE
1530    CHARACTER(LEN=*) :: domain_id
1531    TYPE(tmodel_params) :: params
1532    TYPE(xios_context) :: ctx_hdl
1533    INTEGER :: comm
1534    INTEGER :: return_ni
1535    INTEGER :: return_nj
1536    DOUBLE PRECISION, POINTER :: return_lon(:)
1537    DOUBLE PRECISION, POINTER :: return_lat(:)
1538    LOGICAL, POINTER :: return_mask(:)
1539    INTEGER, POINTER :: return_index(:)
1540    DOUBLE PRECISION, POINTER :: return_X_lon(:)
1541    DOUBLE PRECISION, POINTER :: return_X_lat(:)
1542    LOGICAL, POINTER :: return_X_mask(:)
1543    INTEGER, POINTER :: return_X_index(:)
1544    DOUBLE PRECISION, POINTER :: return_Y_lon(:)
1545    DOUBLE PRECISION, POINTER :: return_Y_lat(:)
1546    LOGICAL, POINTER :: return_Y_mask(:)
1547    INTEGER, POINTER :: return_Y_index(:)
1548    INTEGER :: domain_proc_rank, domain_proc_size   
1549    INTEGER :: axis_proc_rank, axis_proc_size
1550    INTEGER :: ensemble_proc_size, ensemble_proc_rank
1551
1552    INTEGER :: mpi_rank, mpi_size
1553    INTEGER ::  ierr
1554    INTEGER :: ni,nj,ni_glo,nj_glo
1555    INTEGER :: ibegin,jbegin
1556    INTEGER :: nbp,nbp_glo, offset
1557    DOUBLE PRECISION, ALLOCATABLE :: lon_glo(:), lat_glo(:), lon(:), lat(:)
1558    LOGICAL,ALLOCATABLE :: mask(:)
1559    INTEGER :: i,j, ij, pos, i_glo, j_glo, ij_begin, ij_end
1560       
1561    CALL MPI_COMM_RANK(comm,mpi_rank,ierr)
1562    CALL MPI_COMM_SIZE(comm,mpi_size,ierr)
1563
1564    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
1565                           ensemble_proc_size, ensemble_proc_rank)
1566    ni_glo=params%ni
1567    nj_glo=params%nj
1568    nbp_glo=ni_glo*nj_glo
1569    nbp=nbp_glo/domain_proc_size
1570    IF (domain_proc_rank < MOD(nbp_glo,domain_proc_size) ) THEN
1571     nbp=nbp+1
1572     offset=nbp*domain_proc_rank
1573    ELSE
1574      offset=nbp*domain_proc_rank + MOD(nbp_glo, domain_proc_size)
1575    ENDIF
1576   
1577   
1578    ibegin=0 ; ni=ni_glo
1579    jbegin=offset / ni_glo
1580   
1581    nj = (offset+nbp-1) / ni_glo - jbegin + 1 
1582   
1583    offset=offset-jbegin*ni
1584
1585    ij_begin=offset+jbegin*ni
1586    ij_end=ij_begin+nbp-1
1587   
1588    ALLOCATE(lon(0:ni-1), lat(0:nj-1), mask(0:ni*nj-1))
1589    mask(:)=.FALSE.
1590    mask(offset:offset+nbp-1)=.TRUE.
1591   
1592    ALLOCATE(lon_glo(0:ni_glo-1), lat_glo(0:nj_glo-1))
1593   
1594    DO i=0,ni_glo-1
1595      lon_glo(i)=-180+(i+0.5)*(360./ni_glo)
1596    ENDDO
1597
1598    DO j=0,nj_glo-1
1599      lat_glo(j)=-90+(j+0.5)*(180./nj_glo)
1600    ENDDO
1601     
1602    lon(:)=lon_glo(:)
1603    lat(:)=lat_glo(jbegin:jbegin+nj-1)
1604
1605    ALLOCATE(return_lon(0:ni*nj-1))
1606    ALLOCATE(return_lat(0:ni*nj-1))
1607    ALLOCATE(return_mask(0:ni*nj-1))
1608
1609    ALLOCATE(return_X_lon(0:ni-1))
1610    ALLOCATE(return_X_lat(0:ni-1))
1611    ALLOCATE(return_X_mask(0:ni-1))
1612
1613    ALLOCATE(return_Y_lon(0:nj-1))
1614    ALLOCATE(return_Y_lat(0:nj-1))
1615    ALLOCATE(return_Y_mask(0:nj-1))
1616
1617
1618     DO j=0,nj-1
1619      DO i=0,ni-1
1620        return_lon(i+j*ni)=lon(i)
1621        return_lat(i+j*ni)=lat(j)
1622      ENDDO
1623    ENDDO
1624
1625    pos=0
1626    DO j=0,nj-1
1627      DO i=0,ni-1
1628        i_glo=i
1629        j_glo=jbegin+j
1630        ij=j*ni+i
1631        IF ( ij>=ij_begin .AND. ij<=ij_end) THEN
1632           IF ((MOD(j_glo,3)==1 .OR. MOD(j_glo,3)==2) .AND. (MOD(i_glo,5)==3 .OR. MOD(i_glo,5)==4)) CYCLE
1633           pos=pos+1
1634        ENDIF
1635      ENDDO
1636   ENDDO
1637
1638   ALLOCATE(return_index(0:pos-1))
1639   return_index(:)=-1
1640   pos=0
1641    DO j=0,nj-1
1642      DO i=0,ni-1
1643        i_glo=i
1644        j_glo=jbegin+j
1645        ij=j*ni+i
1646        IF ( ij>=ij_begin .AND. ij<=ij_end) THEN
1647           IF ((MOD(j_glo,3)==1 .OR. MOD(j_glo,3)==2) .AND. (MOD(i_glo,5)==3 .OR. MOD(i_glo,5)==4)) CYCLE
1648            return_index(pos)=i+j*ni
1649           pos=pos+1
1650        ENDIF
1651      ENDDO
1652   ENDDO     
1653
1654    CALL set_domain_mask(params, return_lon,return_lat, mask)
1655
1656    return_mask=mask
1657
1658    return_X_lat(:)=lat_glo(nj_glo/2)
1659    return_X_lon(:)=lon_glo(:)
1660    CALL set_domain_mask(params, return_X_lon,return_X_lat, return_X_mask)
1661
1662   pos=0
1663    DO i=0,ni-1
1664      i_glo=i
1665      j_glo=nj_glo/2
1666      IF ((MOD(j_glo,3)==1 .OR. MOD(j_glo,3)==2) .AND. (MOD(i_glo,5)==3 .OR. MOD(i_glo,5)==4)) CYCLE
1667      pos=pos+1
1668    ENDDO
1669
1670    ALLOCATE(return_X_index(0:pos-1))
1671    return_X_index(:)=-1
1672    pos=0
1673    DO i=0,ni-1
1674      i_glo=i
1675      j_glo=nj_glo/2
1676      IF ((MOD(j_glo,3)==1 .OR. MOD(j_glo,3)==2) .AND. (MOD(i_glo,5)==3 .OR. MOD(i_glo,5)==4)) CYCLE
1677      return_X_index(pos)=i
1678      pos=pos+1
1679    ENDDO 
1680
1681
1682   
1683    return_Y_lon(:)=lon_glo(ni_glo/2)
1684    return_Y_lat(:)=lat_glo(jbegin:jbegin+nj-1)
1685    CALL set_domain_mask(params, return_Y_lon,return_Y_lat, return_Y_mask)
1686
1687    pos=0
1688    DO j=0,nj-1
1689      i_glo=ni_glo/2
1690      j_glo=j+jbegin
1691      IF ((MOD(j_glo,3)==1 .OR. MOD(j_glo,3)==2) .AND. (MOD(i_glo,5)==3 .OR. MOD(i_glo,5)==4)) CYCLE
1692      pos=pos+1
1693    ENDDO
1694
1695    ALLOCATE(return_Y_index(0:pos-1))
1696    return_Y_index=-1
1697    pos=0
1698    DO j=0,nj-1
1699      i_glo=ni_glo/2
1700      j_glo=j+jbegin
1701      IF ((MOD(j_glo,3)==1 .OR. MOD(j_glo,3)==2) .AND. (MOD(i_glo,5)==3 .OR. MOD(i_glo,5)==4)) CYCLE
1702      return_Y_index(pos)=j
1703      pos=pos+1
1704    ENDDO
1705
1706    return_ni=ni
1707    return_nj=nj
1708
1709    IF (xios_is_valid_domain(TRIM(domain_id))) THEN
1710      CALL xios_set_domain_attr(TRIM(domain_id), type="rectilinear", ni_glo=ni_glo, ibegin=ibegin, ni=ni, nj_glo=nj_glo, &
1711                                jbegin=jbegin, nj=nj)
1712      CALL xios_set_domain_attr(TRIM(domain_id), data_dim=1, data_ni=size(return_index), data_i_index=return_index)
1713      CALL xios_set_domain_attr(TRIM(domain_id), lonvalue_1d=lon, latvalue_1d=lat, mask_1d=mask)
1714    ENDIF
1715   
1716    IF (xios_is_valid_axis(TRIM(domain_id)//"_X")) THEN
1717      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", n_glo=ni_glo, begin=ibegin, n=ni, value=return_X_lon, &
1718                              data_n=size(return_X_index), data_index=return_X_index)
1719    ENDIF
1720
1721    IF (xios_is_valid_axis(TRIM(domain_id)//"_Y")) THEN   
1722      CALL xios_set_axis_attr(TRIM(domain_id)//"_Y", n_glo=nj_glo, begin=jbegin, n=nj, value=return_Y_lat, &
1723                              data_n=size(return_Y_index), data_index=return_Y_index)
1724    ENDIF
1725
1726  END SUBROUTINE init_domain_orchidee
1727
1728
1729
1730  SUBROUTINE init_domain_nemo(domain_id, comm, params, return_ni, return_nj,               &
1731                              return_lon,return_lat,return_mask, return_index,             &
1732                              return_X_lon,return_X_lat, return_X_mask, return_X_index,    &
1733                              return_Y_lon,return_Y_lat, return_Y_mask, return_Y_index)
1734  IMPLICIT NONE
1735    CHARACTER(LEN=*) :: domain_id
1736    TYPE(tmodel_params) :: params
1737    TYPE(xios_context) :: ctx_hdl
1738    INTEGER :: comm
1739    INTEGER :: return_ni
1740    INTEGER :: return_nj
1741    DOUBLE PRECISION, POINTER :: return_lon(:)
1742    DOUBLE PRECISION, POINTER :: return_lat(:)
1743    LOGICAL, POINTER :: return_mask(:)
1744    INTEGER, POINTER :: return_index(:)
1745    DOUBLE PRECISION, POINTER :: return_X_lon(:)
1746    DOUBLE PRECISION, POINTER :: return_X_lat(:)
1747    LOGICAL, POINTER :: return_X_mask(:)
1748    INTEGER, POINTER :: return_X_index(:)
1749    DOUBLE PRECISION, POINTER :: return_Y_lon(:)
1750    DOUBLE PRECISION, POINTER :: return_Y_lat(:)
1751    LOGICAL, POINTER :: return_Y_mask(:)
1752    INTEGER, POINTER :: return_Y_index(:)
1753    INTEGER :: domain_proc_rank, domain_proc_size   
1754    INTEGER :: axis_proc_rank, axis_proc_size
1755    INTEGER :: ensemble_proc_size, ensemble_proc_rank
1756
1757    INTEGER :: mpi_rank, mpi_size
1758    INTEGER ::  ierr
1759    INTEGER :: ni,nj,ni_glo,nj_glo
1760    INTEGER :: ibegin,jbegin
1761    INTEGER :: offset_i, offset_j
1762    DOUBLE PRECISION, ALLOCATABLE :: lon_glo(:), lat_glo(:), bounds_lon_glo(:,:), bounds_lat_glo(:,:)
1763    DOUBLE PRECISION, ALLOCATABLE :: lon(:,:), lat(:,:), bounds_lon(:,:,:), bounds_lat(:,:,:) 
1764    LOGICAL,ALLOCATABLE :: mask(:)
1765    INTEGER :: i,j, ij, n, rank
1766    INTEGER :: nproc_i, nproc_j, nholes, pos_hole
1767    INTEGER,ALLOCATABLE :: size_i(:), begin_i(:), size_j(:), begin_j(:)
1768       
1769    CALL MPI_COMM_RANK(comm,mpi_rank,ierr)
1770    CALL MPI_COMM_SIZE(comm,mpi_size,ierr)
1771
1772    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
1773                           ensemble_proc_size, ensemble_proc_rank)
1774    ni_glo=params%ni
1775    nj_glo=params%nj
1776
1777    n=INT(SQRT(mpi_size*1.))
1778    nproc_i=n
1779    nproc_j=n
1780    IF ( n*n == mpi_size) THEN
1781    ! do nothing
1782    ELSE IF ( (n+1)*n < mpi_size) THEN
1783      nproc_i=nproc_i+1
1784      nproc_j=nproc_j+1
1785    ELSE
1786      nproc_i=nproc_i+1
1787    ENDIF
1788   
1789    nholes=nproc_i*nproc_j-mpi_size
1790
1791    ALLOCATE(size_i(0:nproc_i-1))
1792    ALLOCATE(begin_i(0:nproc_i-1))
1793    DO i=0,nproc_i-1
1794      size_i(i)=ni_glo/nproc_i
1795      IF (i<MOD(ni_glo,nproc_i)) size_i(i)=size_i(i)+1
1796      IF (i==0) THEN
1797        begin_i(i)=0
1798      ELSE
1799        begin_i(i)=begin_i(i-1)+size_i(i-1)
1800      ENDIF
1801    ENDDO
1802   
1803    ALLOCATE(size_j(0:nproc_j-1))
1804    ALLOCATE(begin_j(0:nproc_j-1))
1805    DO j=0,nproc_i-1
1806      size_j(j)=nj_glo/nproc_j
1807      IF (j<MOD(nj_glo,nproc_j)) size_j(j)=size_j(j)+1
1808      IF (j==0) THEN
1809        begin_j(j)=0
1810      ELSE
1811        begin_j(j)=begin_j(j-1)+size_j(j-1)
1812      ENDIF
1813    ENDDO
1814
1815
1816    pos_hole=0
1817    rank=0
1818    DO j=0,nproc_j-1
1819      DO i=0,nproc_i-1
1820
1821        ij = j*nproc_i + i
1822        IF (pos_hole<nholes) THEN
1823          IF ( MOD(ij,(nproc_i*nproc_j/nholes)) == 0) THEN
1824            pos_hole=pos_hole+1
1825            CYCLE
1826          ENDIF
1827        ENDIF
1828       
1829        IF (mpi_rank==rank) THEN
1830          ibegin = begin_i(i)
1831          ni = size_i(i)
1832          jbegin = begin_j(j)
1833          nj = size_j(j)
1834        ENDIF
1835        rank=rank+1
1836      ENDDO
1837    ENDDO
1838
1839    ALLOCATE(lon_glo(0:ni_glo-1), lat_glo(0:nj_glo-1))
1840    ALLOCATE(bounds_lon_glo(4,0:ni_glo-1), bounds_lat_glo(4,0:nj_glo-1))
1841   
1842    DO i=0,ni_glo-1
1843      lon_glo(i)=-180+(i+0.5)*(360./ni_glo)
1844      bounds_lon_glo(1,i)= -180+(i)*(360./ni_glo)
1845      bounds_lon_glo(2,i)= -180+(i+1)*(360./ni_glo)
1846    ENDDO
1847
1848    DO j=0,nj_glo-1
1849      lat_glo(j)=-90+(j+0.5)*(180./nj_glo)
1850      bounds_lat_glo(1,j)= -90+(j)*(180./nj_glo)
1851      bounds_lat_glo(2,j)= -90+(j+1)*(180./nj_glo)
1852    ENDDO
1853
1854    offset_i=2    ! halo of 2 on i
1855    offset_j=1    ! halo of 1 on j
1856
1857    ALLOCATE(lon(0:ni-1,0:nj-1))
1858    ALLOCATE(lat(0:ni-1,0:nj-1))
1859    ALLOCATE(bounds_lon(4,0:ni-1,0:nj-1))
1860    ALLOCATE(bounds_lat(4,0:ni-1,0:nj-1))
1861!    ALLOCATE(mask(0:ni-1,0:nj-1))
1862   
1863    ALLOCATE(return_lon(0:ni*nj-1))
1864    ALLOCATE(return_lat(0:ni*nj-1))
1865    ALLOCATE(return_mask(0:ni*nj-1))
1866    ALLOCATE(return_index(0:(ni+2*offset_i)*(nj+2*offset_j)-1))
1867
1868    ALLOCATE(return_X_lon(0:ni-1))
1869    ALLOCATE(return_X_lat(0:ni-1))
1870    ALLOCATE(return_X_mask(0:ni-1))
1871    ALLOCATE(return_X_index(0:ni-1))
1872
1873    ALLOCATE(return_Y_lon(0:nj-1))
1874    ALLOCATE(return_Y_lat(0:nj-1))
1875    ALLOCATE(return_Y_mask(0:nj-1))
1876    ALLOCATE(return_Y_index(0:nj-1))
1877   
1878    return_index=-1 
1879    DO j=0,nj-1
1880      DO i=0,ni-1
1881        ij=j*ni+i
1882        return_lon(ij)=lon_glo(ibegin+i)
1883        return_lat(ij)=lat_glo(jbegin+j)
1884        lon(i,j)=return_lon(ij)
1885        lat(i,j)=return_lat(ij)
1886        bounds_lon(1,i,j)=bounds_lon_glo(2,ibegin+i)
1887        bounds_lon(2,i,j)=bounds_lon_glo(1,ibegin+i)
1888        bounds_lon(3,i,j)=bounds_lon_glo(1,ibegin+i)
1889        bounds_lon(4,i,j)=bounds_lon_glo(2,ibegin+i)
1890        bounds_lat(1,i,j)=bounds_lat_glo(1,jbegin+j)
1891        bounds_lat(2,i,j)=bounds_lat_glo(1,jbegin+j)
1892        bounds_lat(3,i,j)=bounds_lat_glo(2,jbegin+j)
1893        bounds_lat(4,i,j)=bounds_lat_glo(2,jbegin+j)
1894
1895        ij=(j+offset_j)*(ni+2*offset_i)+i+offset_i
1896        return_index(ij)=i+j*ni
1897      ENDDO
1898    ENDDO
1899
1900    CALL set_domain_mask(params, return_lon,return_lat, return_mask)
1901
1902    ALLOCATE(return_X_lon(0:ni-1))
1903    ALLOCATE(return_X_lat(0:ni-1))
1904    ALLOCATE(return_X_mask(0:ni-1))
1905    ALLOCATE(return_X_index(0:ni+2*offset_i-1))
1906
1907    return_X_lat(:)=lat_glo(nj_glo/2)
1908    return_X_lon(:)=lon_glo(ibegin:ibegin+ni-1)
1909    CALL set_domain_mask(params, return_X_lon,return_X_lat, return_X_mask)
1910
1911    return_X_index(:)=-1
1912    DO i=0,ni-1
1913      return_X_index(offset_i+i)=i
1914    ENDDO
1915
1916    ALLOCATE(return_Y_lon(0:nj-1))
1917    ALLOCATE(return_Y_lat(0:nj-1))
1918    ALLOCATE(return_Y_mask(0:nj-1))
1919    ALLOCATE(return_Y_index(0:nj+2*offset_j-1))
1920
1921    return_Y_lat(:)=lat_glo(jbegin:jbegin+nj-1)
1922    return_Y_lon(:)=lon_glo(ni_glo/2)
1923    CALL set_domain_mask(params, return_Y_lon,return_Y_lat, return_Y_mask)
1924
1925    return_Y_index(:)=-1
1926    DO j=0,nj-1
1927      return_Y_index(offset_j+j)=j
1928    ENDDO
1929
1930    return_ni=ni
1931    return_nj=nj
1932
1933    IF (xios_is_valid_domain(TRIM(domain_id))) THEN
1934      CALL xios_set_domain_attr(TRIM(domain_id), type="curvilinear", data_dim=2)
1935      CALL xios_set_domain_attr(TRIM(domain_id), ni_glo=ni_glo, ibegin=ibegin, ni=ni, data_ibegin=-offset_i, data_ni=ni+2*offset_i)
1936      CALL xios_set_domain_attr(TRIM(domain_id), nj_glo=nj_glo, jbegin=jbegin, nj=nj, data_jbegin=-offset_j, data_nj=nj+2*offset_j)
1937      CALL xios_set_domain_attr(TRIM(domain_id), data_dim=2, lonvalue_2d=lon, latvalue_2d=lat, mask_1d=return_mask)
1938      CALL xios_set_domain_attr(TRIM(domain_id), bounds_lon_2d=bounds_lon, bounds_lat_2d=bounds_lat, nvertex=4)
1939    ENDIF
1940
1941   
1942    IF (xios_is_valid_axis(TRIM(domain_id)//"_X")) THEN
1943      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", n_glo=ni_glo, begin=ibegin, n=ni, data_begin=-offset_i, &
1944                              data_n=ni+2*offset_i, value=return_X_lon, mask=return_X_mask)
1945!      CALL xios_set_axis_attr(TRIM(domain_id)//"_X", n_glo=ni_glo, begin=ibegin, n=ni, data_index=return_X_index,&
1946!                               data_n=ni+2*offset_i,  value=return_X_lon)
1947    ENDIF
1948
1949    IF (xios_is_valid_axis(TRIM(domain_id)//"_Y")) THEN   
1950      CALL xios_set_axis_attr(TRIM(domain_id)//"_Y", n_glo=nj_glo, begin=jbegin, n=nj, data_begin=-offset_j, &
1951                              data_n=nj+2*offset_j, value=return_Y_lat, mask=return_Y_mask)
1952!      CALL xios_set_axis_attr(TRIM(domain_id)//"_Y", n_glo=nj_glo, begin=jbegin, n=nj, data_index=return_Y_index, &
1953!                               data_n=nj+2*offset_j, value=return_Y_lat)
1954    ENDIF
1955
1956  END SUBROUTINE init_domain_nemo
1957
1958
1959
1960
1961 
1962   SUBROUTINE set_domain_mask(params, lon,lat, mask)
1963   IMPLICIT NONE
1964     TYPE(tmodel_params) :: params
1965     DOUBLE PRECISION  :: lon(:)
1966     DOUBLE PRECISION  :: lat(:)
1967     LOGICAL           :: mask(:)
1968     INTEGER :: i,x
1969
1970     mask(:)=.TRUE.
1971     IF (params%domain_mask) THEN
1972       WHERE (lon(:)-2*lat(:)>-10 .AND. lon(:)-2*lat(:) <10) mask(:)=.FALSE.
1973       WHERE (2*lat(:)+lon(:)>-10 .AND. 2*lat(:)+lon(:)<10) mask(:)=.FALSE.
1974     ENDIF
1975
1976  END SUBROUTINE set_domain_mask
1977     
1978
1979  SUBROUTINE set_mask3d(grid_id, params, ni, nj, lon,lat, axis_value)
1980  IMPLICIT NONE
1981    CHARACTER(LEN=*) :: grid_id
1982    TYPE(tmodel_params) :: params
1983    INTEGER :: comm
1984    INTEGER :: ni
1985    INTEGER :: nj
1986    DOUBLE PRECISION, POINTER :: lon(:)
1987    DOUBLE PRECISION, POINTER :: lat(:)
1988    INTEGER, POINTER          :: domain_index(:)   
1989    DOUBLE PRECISION, POINTER :: axis_value(:)
1990    INTEGER, POINTER          :: axis_index(:)
1991    INTEGER ::i,j,ij,k,nk
1992    LOGICAL, ALLOCATABLE :: mask3d(:,:,:)
1993    DOUBLE PRECISION :: r
1994
1995    nk=size(axis_value)
1996
1997    ALLOCATE(mask3d(0:ni-1,0:nj-1,0:nk-1))
1998
1999    mask3d=.TRUE.
2000    DO k=0,nk-1
2001      DO j=0,nj-1
2002        DO i=0,ni-1
2003          ij=j*ni+i
2004          r=sqrt((lon(ij)/2)**2 + lat(ij)**2) / ((nk-k)*1./nk) 
2005          if (r < 60) mask3d(i,j,k)=.FALSE.
2006        ENDDO
2007      ENDDO
2008    ENDDO
2009
2010    IF (params%mask3d) CALL  xios_set_grid_attr(grid_id, mask_3d=mask3d)
2011
2012  END SUBROUTINE set_mask3d
2013   
2014  SUBROUTINE init_axis_pressure(axis_id,comm,params, return_value, return_mask, return_index)
2015  IMPLICIT NONE
2016    CHARACTER(LEN=*) :: axis_id
2017    TYPE(tmodel_params) :: params
2018    INTEGER :: comm
2019    DOUBLE PRECISION, POINTER :: return_value(:)
2020    LOGICAL, POINTER          :: return_mask(:)
2021    INTEGER, POINTER          :: return_index(:)
2022   
2023    INTEGER :: nlev_glo
2024    INTEGER :: nlev, begin, end
2025    DOUBLE PRECISION, ALLOCATABLE :: value_glo(:) 
2026    DOUBLE PRECISION, ALLOCATABLE :: bounds_value_glo(:,:) 
2027    DOUBLE PRECISION, ALLOCATABLE :: value(:) 
2028    DOUBLE PRECISION, ALLOCATABLE :: bounds_value(:,:) 
2029    DOUBLE PRECISION :: dp
2030    INTEGER :: i
2031
2032    INTEGER :: domain_proc_rank, domain_proc_size   
2033    INTEGER :: axis_proc_rank, axis_proc_size
2034    INTEGER :: ensemble_proc_size, ensemble_proc_rank
2035
2036    CALL get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
2037                           ensemble_proc_size, ensemble_proc_rank)     
2038
2039    nlev_glo=params%nlev
2040   
2041    ALLOCATE(value_glo(0:nlev_glo-1), bounds_value_glo(2,0:nlev_glo-1) )
2042   
2043    dp=(1-0.1)/(nlev_glo-1)
2044    DO i=0,nlev_glo-1
2045     value_glo(i)=1-i*dp
2046    ENDDO
2047   
2048    bounds_value_glo(2,0)=value_glo(0)-(value_glo(1)-value_glo(0))/2
2049    DO i=1,nlev_glo-1
2050     bounds_value_glo(2,i)=(value_glo(i-1)+value_glo(i)) /2
2051    ENDDO
2052
2053    DO i=0,nlev_glo-2
2054     bounds_value_glo(1,i)=(value_glo(i)+value_glo(i+1)) /2
2055    ENDDO
2056    bounds_value_glo(1,nlev_glo-1)=value_glo(nlev_glo-1)-(value_glo(nlev_glo-2)-value_glo(nlev_glo-1))/2
2057
2058    nlev=nlev_glo/axis_proc_size
2059    IF (axis_proc_rank < MOD(nlev_glo,axis_proc_size)) THEN
2060      nlev=nlev+1
2061      begin= axis_proc_rank*nlev
2062      end=begin+nlev-1
2063    ELSE
2064      begin=MOD(nlev_glo,axis_proc_size)*(nlev+1) + (axis_proc_rank-MOD(nlev_glo,axis_proc_size))*nlev
2065      end=begin+nlev-1
2066    ENDIF
2067
2068    ALLOCATE(value(0:nlev-1), bounds_value(2,0:nlev-1) )
2069    value(:)=value_glo(begin:end)
2070    bounds_value(:,:)=bounds_value_glo(:,begin:end)
2071   
2072    ALLOCATE(return_value(0:nlev-1))
2073    ALLOCATE(return_mask(0:nlev-1))
2074    return_value=value
2075    return_mask=.TRUE.
2076    CALL set_axis_mask(params,value,return_mask)   
2077    CALL xios_set_axis_attr(axis_id, n_glo=nlev_glo, begin=begin, n=nlev, value=value*100000, mask=return_mask, &
2078                            bounds=bounds_value*100000, unit='Pa', positive='up')   
2079   
2080
2081    ALLOCATE(return_index(0:nlev-1))
2082
2083    DO i=0,nlev-1
2084      return_index(i)=i
2085    ENDDO 
2086
2087
2088  END SUBROUTINE init_axis_pressure
2089
2090  SUBROUTINE set_axis_mask(params, value, mask)
2091  IMPLICIT NONE
2092    TYPE(tmodel_params) :: params
2093     DOUBLE PRECISION  :: value(:)
2094     LOGICAL           :: mask(:)
2095     INTEGER :: i,x
2096
2097     x=size(mask)
2098     IF (params%axis_mask) THEN
2099       DO i=0,x-1
2100         IF (MOD(i,3)==0) mask(i)=.FALSE.
2101         IF (MOD(i,4)==0) mask(i)=.FALSE.
2102       ENDDO
2103     ENDIF
2104
2105  END SUBROUTINE set_axis_mask 
2106
2107  SUBROUTINE init_field2D_academic(comm,params, lon, lat, mask, return_field,            &
2108                                   X_lon, X_lat, X_mask, return_fieldX,                  &
2109                                   Y_lon, Y_lat, Y_mask, return_fieldY, return_fieldXY)
2110  IMPLICIT NONE
2111    TYPE(tmodel_params) :: params
2112    INTEGER :: comm
2113    DOUBLE PRECISION, POINTER :: lon(:)
2114    DOUBLE PRECISION, POINTER :: lat(:)
2115    LOGICAL, POINTER :: mask(:)
2116    DOUBLE PRECISION, POINTER :: return_field(:)
2117
2118    DOUBLE PRECISION, POINTER :: X_lon(:)
2119    DOUBLE PRECISION, POINTER :: X_lat(:)
2120    LOGICAL, POINTER :: X_mask(:)
2121    DOUBLE PRECISION, POINTER :: return_fieldX(:)
2122
2123    DOUBLE PRECISION, POINTER :: Y_lon(:)
2124    DOUBLE PRECISION, POINTER :: Y_lat(:)
2125    LOGICAL, POINTER :: Y_mask(:)
2126    DOUBLE PRECISION, POINTER :: return_fieldY(:)
2127    DOUBLE PRECISION, POINTER :: return_fieldXY(:,:)
2128   
2129    DOUBLE PRECISION, PARAMETER :: coef=2., dp_pi=3.14159265359
2130    DOUBLE PRECISION :: dp_length, dp_conv
2131    INTEGER :: i,j,x,y,xy
2132   
2133     ! Parameters for analytical function
2134    dp_length= 1.2*dp_pi
2135    dp_conv=dp_pi/180.
2136   
2137    xy=size(mask)
2138    x=size(X_mask)
2139    y=size(Y_mask)
2140
2141    ALLOCATE(return_field(0:xy-1))
2142   
2143    DO i=0,xy-1
2144      IF (mask(i)) THEN
2145         return_field(i)=(coef-SIN(dp_pi*(ACOS(COS(lat(i)*dp_conv)*&
2146                   COS(lon(i)*dp_conv))/dp_length)))
2147      ENDIF
2148    ENDDO       
2149
2150
2151    ALLOCATE(return_fieldX(0:x-1))
2152   
2153    DO i=0,x-1
2154      IF (X_mask(i)) THEN
2155         return_fieldX(i)=(coef-SIN(dp_pi*(ACOS(COS(X_lat(i)*dp_conv)*&
2156                            COS(X_lon(i)*dp_conv))/dp_length)))
2157      ENDIF
2158    ENDDO           
2159
2160
2161    ALLOCATE(return_fieldY(0:y-1))
2162   
2163    DO i=0,y-1
2164      IF (Y_mask(i)) THEN
2165         return_fieldY(i)=(coef-SIN(dp_pi*(ACOS(COS(Y_lat(i)*dp_conv)*&
2166                            COS(Y_lon(i)*dp_conv))/dp_length)))
2167      ENDIF
2168    ENDDO
2169
2170    ALLOCATE(return_fieldXY(0:x-1,0:y-1))
2171   
2172    DO j=0,y-1
2173      DO i=0,x-1
2174        IF (Y_mask(j) .AND. X_mask(i)) THEN
2175           return_fieldXY(i,j)=(coef-SIN(dp_pi*(ACOS(COS(Y_lat(j)*dp_conv)*&
2176                                COS(X_lon(i)*dp_conv))/dp_length)))
2177        ENDIF
2178      ENDDO
2179    ENDDO   
2180       
2181  END SUBROUTINE init_field2D_academic
2182
2183
2184  SUBROUTINE init_field2D_constant(comm,params, lon, lat, mask, return_field,             &
2185                                   X_lon, X_lat, X_mask, return_fieldX,                   &
2186                                   Y_lon, Y_lat, Y_mask, return_fieldY, return_fieldXY)
2187  IMPLICIT NONE
2188    TYPE(tmodel_params) :: params
2189    INTEGER :: comm
2190    DOUBLE PRECISION, POINTER :: lon(:)
2191    DOUBLE PRECISION, POINTER :: lat(:)
2192    LOGICAL, POINTER :: mask(:)
2193    DOUBLE PRECISION, POINTER :: return_field(:)
2194   
2195    DOUBLE PRECISION, POINTER :: X_lon(:)
2196    DOUBLE PRECISION, POINTER :: X_lat(:)
2197    LOGICAL, POINTER :: X_mask(:)
2198    DOUBLE PRECISION, POINTER :: return_fieldX(:)
2199
2200    DOUBLE PRECISION, POINTER :: Y_lon(:)
2201    DOUBLE PRECISION, POINTER :: Y_lat(:)
2202    LOGICAL, POINTER :: Y_mask(:)
2203    DOUBLE PRECISION, POINTER :: return_fieldY(:)
2204    DOUBLE PRECISION, POINTER :: return_fieldXY(:,:)
2205    INTEGER :: x,y,xy
2206   
2207    xy=size(mask)
2208    x=size(X_mask)
2209    y=size(Y_mask)
2210       
2211    ALLOCATE(return_field(0:xy-1))
2212    return_field(:)=1
2213
2214    ALLOCATE(return_fieldX(0:x-1))
2215    return_fieldX=1
2216
2217    ALLOCATE(return_fieldY(0:y-1))
2218    return_fieldY=1
2219
2220    ALLOCATE(return_fieldXY(0:x-1,0:y-1))
2221    return_fieldXY=1
2222   
2223  END SUBROUTINE init_field2D_constant
2224
2225  SUBROUTINE init_field2D_rank(comm,params, lon, lat, mask, return_field,         &
2226                               X_lon, X_lat, X_mask, return_fieldX,               &
2227                               Y_lon, Y_lat, Y_mask, return_fieldY, return_fieldXY)
2228
2229  IMPLICIT NONE
2230    TYPE(tmodel_params) :: params
2231    INTEGER :: comm
2232    DOUBLE PRECISION, POINTER :: lon(:)
2233    DOUBLE PRECISION, POINTER :: lat(:)
2234    LOGICAL, POINTER :: mask(:)
2235    DOUBLE PRECISION, POINTER :: return_field(:)
2236
2237    DOUBLE PRECISION, POINTER :: X_lon(:)
2238    DOUBLE PRECISION, POINTER :: X_lat(:)
2239    LOGICAL, POINTER :: X_mask(:)
2240    DOUBLE PRECISION, POINTER :: return_fieldX(:)
2241
2242    DOUBLE PRECISION, POINTER :: Y_lon(:)
2243    DOUBLE PRECISION, POINTER :: Y_lat(:)
2244    LOGICAL, POINTER :: Y_mask(:)
2245    DOUBLE PRECISION, POINTER :: return_fieldY(:)
2246    DOUBLE PRECISION, POINTER :: return_fieldXY(:,:)   
2247    INTEGER ::  rank,ierr
2248    INTEGER :: x,y,xy
2249
2250    CALL MPI_COMM_RANK(comm,rank,ierr)
2251
2252   
2253   
2254    xy=size(mask)
2255    x=size(X_mask)
2256    y=size(Y_mask)
2257       
2258    ALLOCATE(return_field(0:xy-1))
2259    return_field(:)=rank
2260
2261    ALLOCATE(return_fieldX(0:x-1))
2262    return_fieldX=rank
2263
2264    ALLOCATE(return_fieldY(0:y-1))
2265    return_fieldY=rank
2266
2267    ALLOCATE(return_fieldXY(0:x-1,0:y-1))
2268    return_fieldXY=rank
2269
2270  END SUBROUTINE init_field2D_rank
2271
2272
2273
2274   SUBROUTINE get_decomposition(comm, params, domain_proc_size, domain_proc_rank, axis_proc_size, axis_proc_rank, &
2275                                ensemble_proc_size, ensemble_proc_rank)
2276   IMPLICIT NONE
2277     INTEGER,INTENT(IN) :: comm
2278     TYPE(tmodel_params) :: params
2279     INTEGER,INTENT(OUT) :: domain_proc_size
2280     INTEGER,INTENT(OUT) :: domain_proc_rank
2281     INTEGER,INTENT(OUT) :: axis_proc_size
2282     INTEGER,INTENT(OUT) :: axis_proc_rank
2283     INTEGER,INTENT(OUT) :: ensemble_proc_size
2284     INTEGER,INTENT(OUT) :: ensemble_proc_rank
2285
2286     INTEGER :: mpi_rank,mpi_size,rank, ensemble_number
2287     INTEGER :: ierr
2288     INTEGER :: n_domain,n_axis, n_ensemble, min_dist, new_dist, best
2289     INTEGER :: axis_ind, domain_ind
2290     LOGICAL :: axis_layer
2291
2292     CALL MPI_COMM_RANK(comm,mpi_rank,ierr)
2293     CALL MPI_COMM_SIZE(comm,mpi_size,ierr)
2294
2295     n_ensemble = params%ensemble_proc_n
2296     ensemble_proc_size = mpi_size / n_ensemble
2297     IF (  mpi_rank < MOD(mpi_size,n_ensemble) * (ensemble_proc_size+1) ) THEN
2298       ensemble_proc_size=ensemble_proc_size+1
2299       ensemble_proc_rank = MOD(mpi_rank,ensemble_proc_size)
2300       ensemble_number = mpi_rank / ensemble_proc_size
2301     ELSE
2302       ensemble_number = MOD(mpi_size,n_ensemble)
2303       rank =  mpi_rank - MOD(mpi_size,n_ensemble) * (ensemble_proc_size+1)
2304       ensemble_proc_rank= MOD(rank,ensemble_proc_size)
2305       ensemble_number = ensemble_number + rank / ensemble_proc_size
2306     ENDIF
2307
2308     mpi_size=ensemble_proc_size
2309     mpi_rank=ensemble_proc_rank
2310     ensemble_proc_size = n_ensemble
2311     ensemble_proc_rank = ensemble_number
2312
2313    IF (params%axis_proc_n > 0 ) THEN
2314      n_axis=params%axis_proc_n
2315      n_domain = mpi_size / n_axis
2316      axis_layer=.TRUE.
2317    ELSE IF (params%domain_proc_n > 0 ) THEN
2318      n_domain=params%domain_proc_n
2319      n_axis = mpi_size / n_domain
2320      axis_layer=.FALSE.
2321    ELSE
2322      IF (params%axis_proc_frac==0) THEN
2323         params%axis_proc_frac=1
2324         params%domain_proc_frac=mpi_size
2325      ELSE IF (params%domain_proc_frac==0) THEN
2326         params%domain_proc_frac=1
2327         params%axis_proc_frac=mpi_size
2328      ENDIF       
2329   
2330      n_domain = INT(sqrt(params%domain_proc_frac * mpi_size/ params%axis_proc_frac))
2331      n_axis =   INT(sqrt(params%axis_proc_frac * mpi_size/ params%domain_proc_frac))
2332
2333
2334      min_dist= mpi_size - n_domain*n_axis
2335      best=0
2336   
2337      new_dist = mpi_size -(n_domain+1)*n_axis
2338      IF (new_dist < min_dist .AND. new_dist >= 0 ) THEN
2339         min_dist=new_dist
2340         best=1
2341      ENDIF
2342
2343      new_dist=mpi_size-n_domain*(n_axis+1)
2344      IF (new_dist < min_dist .AND. new_dist >= 0 ) THEN
2345         min_dist=new_dist
2346         best=2
2347      ENDIF
2348
2349      IF (best==0) THEN
2350      ELSE IF (best==1) THEN
2351        n_domain=n_domain+1
2352      ELSE IF (best==2) THEN
2353        n_axis=n_axis+1
2354      ENDIF
2355
2356      IF ( MOD(mpi_size,n_axis) <= MOD(mpi_size,n_domain)) axis_layer=.TRUE.
2357
2358    ENDIF
2359   
2360    IF ( axis_layer) THEN
2361      !!! n_axis layer
2362      IF (mpi_rank < MOD(mpi_size,n_axis)*(n_domain+1)) THEN
2363        axis_proc_rank=mpi_rank/(n_domain+1)
2364        domain_proc_rank=MOD(mpi_rank,n_domain+1)
2365        axis_proc_size=n_axis
2366        domain_proc_size=n_domain+1
2367      ELSE
2368        rank=mpi_rank-MOD(mpi_size,n_axis)*(n_domain+1)
2369        axis_proc_size=n_axis
2370        axis_proc_rank=MOD(mpi_size,n_axis)+rank/n_domain
2371        domain_proc_rank=MOD(rank,n_domain)
2372        domain_proc_size=n_domain
2373      ENDIF
2374    ELSE
2375      !!! n_domain column
2376      IF (mpi_rank < MOD(mpi_size,n_domain)*(n_axis+1)) THEN
2377        domain_proc_rank=mpi_rank/(n_axis+1)
2378        axis_proc_rank=MOD(mpi_rank,n_axis+1)
2379        domain_proc_size=n_domain
2380        axis_proc_size=n_axis+1
2381      ELSE
2382        rank=mpi_rank-MOD(mpi_size,n_domain)*(n_axis+1)
2383        domain_proc_size=n_domain
2384        domain_proc_rank=MOD(mpi_size,n_domain)+rank/n_axis
2385        axis_proc_rank=MOD(rank,n_axis)
2386        axis_proc_size=n_axis
2387      ENDIF
2388    ENDIF 
2389
2390
2391  END SUBROUTINE get_decomposition
2392
2393END PROGRAM test_interpolate
2394
2395
Note: See TracBrowser for help on using the repository browser.