1 /* -*- mode: c; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4; c-file-style: "stroustrup"; -*-
4 * This file is part of Gromacs Copyright (c) 1991-2008
5 * David van der Spoel, Erik Lindahl, Berk Hess, University of Groningen.
7 * This program is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU General Public License
9 * as published by the Free Software Foundation; either version 2
10 * of the License, or (at your option) any later version.
12 * To help us fund GROMACS development, we humbly ask that you cite
13 * the research papers on the package. Check out http://www.gromacs.org
16 * Gnomes, ROck Monsters And Chili Sauce
32 #include "domdec_network.h"
35 #include "chargegroup.h"
44 #include "gmx_wallcycle.h"
48 #include "mtop_util.h"
50 #include "gmx_ga2la.h"
60 #define DDRANK(dd,rank) (rank)
61 #define DDMASTERRANK(dd) (dd->masterrank)
63 typedef struct gmx_domdec_master
65 /* The cell boundaries */
67 /* The global charge group division */
68 int *ncg; /* Number of home charge groups for each node */
69 int *index; /* Index of nnodes+1 into cg */
70 int *cg; /* Global charge group index */
71 int *nat; /* Number of home atoms for each node. */
72 int *ibuf; /* Buffer for communication */
73 rvec *vbuf; /* Buffer for state scattering and gathering */
74 } gmx_domdec_master_t;
78 /* The numbers of charge groups to send and receive for each cell
79 * that requires communication, the last entry contains the total
80 * number of atoms that needs to be communicated.
82 int nsend[DD_MAXIZONE+2];
83 int nrecv[DD_MAXIZONE+2];
84 /* The charge groups to send */
87 /* The atom range for non-in-place communication */
88 int cell2at0[DD_MAXIZONE];
89 int cell2at1[DD_MAXIZONE];
94 int np; /* Number of grid pulses in this dimension */
95 int np_dlb; /* For dlb, for use with edlbAUTO */
96 gmx_domdec_ind_t *ind; /* The indices to communicate, size np */
98 gmx_bool bInPlace; /* Can we communicate in place? */
99 } gmx_domdec_comm_dim_t;
103 gmx_bool *bCellMin; /* Temp. var.: is this cell size at the limit */
104 real *cell_f; /* State var.: cell boundaries, box relative */
105 real *old_cell_f; /* Temp. var.: old cell size */
106 real *cell_f_max0; /* State var.: max lower boundary, incl neighbors */
107 real *cell_f_min1; /* State var.: min upper boundary, incl neighbors */
108 real *bound_min; /* Temp. var.: lower limit for cell boundary */
109 real *bound_max; /* Temp. var.: upper limit for cell boundary */
110 gmx_bool bLimited; /* State var.: is DLB limited in this dim and row */
111 real *buf_ncd; /* Temp. var. */
114 #define DD_NLOAD_MAX 9
116 /* Here floats are accurate enough, since these variables
117 * only influence the load balancing, not the actual MD results.
141 gmx_cgsort_t *sort1,*sort2;
143 gmx_cgsort_t *sort_new;
155 /* This enum determines the order of the coordinates.
156 * ddnatHOME and ddnatZONE should be first and second,
157 * the others can be ordered as wanted.
159 enum { ddnatHOME, ddnatZONE, ddnatVSITE, ddnatCON, ddnatNR };
161 enum { edlbAUTO, edlbNO, edlbYES, edlbNR };
162 const char *edlb_names[edlbNR] = { "auto", "no", "yes" };
166 int dim; /* The dimension */
167 gmx_bool dim_match;/* Tells if DD and PME dims match */
168 int nslab; /* The number of PME slabs in this dimension */
169 real *slb_dim_f; /* Cell sizes for determining the PME comm. with SLB */
170 int *pp_min; /* The minimum pp node location, size nslab */
171 int *pp_max; /* The maximum pp node location,size nslab */
172 int maxshift; /* The maximum shift for coordinate redistribution in PME */
177 real min0; /* The minimum bottom of this zone */
178 real max1; /* The maximum top of this zone */
179 real mch0; /* The maximum bottom communicaton height for this zone */
180 real mch1; /* The maximum top communicaton height for this zone */
181 real p1_0; /* The bottom value of the first cell in this zone */
182 real p1_1; /* The top value of the first cell in this zone */
185 typedef struct gmx_domdec_comm
187 /* All arrays are indexed with 0 to dd->ndim (not Cartesian indexing),
188 * unless stated otherwise.
191 /* The number of decomposition dimensions for PME, 0: no PME */
193 /* The number of nodes doing PME (PP/PME or only PME) */
197 /* The communication setup including the PME only nodes */
198 gmx_bool bCartesianPP_PME;
201 int *pmenodes; /* size npmenodes */
202 int *ddindex2simnodeid; /* size npmenodes, only with bCartesianPP
203 * but with bCartesianPP_PME */
204 gmx_ddpme_t ddpme[2];
206 /* The DD particle-particle nodes only */
207 gmx_bool bCartesianPP;
208 int *ddindex2ddnodeid; /* size npmenode, only with bCartesianPP_PME */
210 /* The global charge groups */
213 /* Should we sort the cgs */
215 gmx_domdec_sort_t *sort;
217 /* Are there bonded and multi-body interactions between charge groups? */
218 gmx_bool bInterCGBondeds;
219 gmx_bool bInterCGMultiBody;
221 /* Data for the optional bonded interaction atom communication range */
228 /* Are we actually using DLB? */
229 gmx_bool bDynLoadBal;
231 /* Cell sizes for static load balancing, first index cartesian */
234 /* The width of the communicated boundaries */
237 /* The minimum cell size (including triclinic correction) */
239 /* For dlb, for use with edlbAUTO */
240 rvec cellsize_min_dlb;
241 /* The lower limit for the DD cell size with DLB */
243 /* Effectively no NB cut-off limit with DLB for systems without PBC? */
244 gmx_bool bVacDLBNoLimit;
246 /* tric_dir is only stored here because dd_get_ns_ranges needs it */
248 /* box0 and box_size are required with dim's without pbc and -gcom */
252 /* The cell boundaries */
256 /* The old location of the cell boundaries, to check cg displacements */
260 /* The communication setup and charge group boundaries for the zones */
261 gmx_domdec_zones_t zones;
263 /* The zone limits for DD dimensions 1 and 2 (not 0), determined from
264 * cell boundaries of neighboring cells for dynamic load balancing.
266 gmx_ddzone_t zone_d1[2];
267 gmx_ddzone_t zone_d2[2][2];
269 /* The coordinate/force communication setup and indices */
270 gmx_domdec_comm_dim_t cd[DIM];
271 /* The maximum number of cells to communicate with in one dimension */
274 /* Which cg distribution is stored on the master node */
275 int master_cg_ddp_count;
277 /* The number of cg's received from the direct neighbors */
278 int zone_ncg1[DD_MAXZONE];
280 /* The atom counts, the range for each type t is nat[t-1] <= at < nat[t] */
283 /* Communication buffer for general use */
287 /* Communication buffer for general use */
290 /* Communication buffers only used with multiple grid pulses */
295 /* Communication buffers for local redistribution */
297 int cggl_flag_nalloc[DIM*2];
299 int cgcm_state_nalloc[DIM*2];
301 /* Cell sizes for dynamic load balancing */
302 gmx_domdec_root_t **root;
306 real cell_f_max0[DIM];
307 real cell_f_min1[DIM];
309 /* Stuff for load communication */
310 gmx_bool bRecordLoad;
311 gmx_domdec_load_t *load;
313 MPI_Comm *mpi_comm_load;
316 /* Maximum DLB scaling per load balancing step in percent */
320 float cycl[ddCyclNr];
321 int cycl_n[ddCyclNr];
322 float cycl_max[ddCyclNr];
323 /* Flop counter (0=no,1=yes,2=with (eFlop-1)*5% noise */
327 /* Have often have did we have load measurements */
329 /* Have often have we collected the load measurements */
333 double sum_nat[ddnatNR-ddnatZONE];
343 /* The last partition step */
344 gmx_large_int_t globalcomm_step;
352 /* The size per charge group of the cggl_flag buffer in gmx_domdec_comm_t */
355 /* The flags for the cggl_flag buffer in gmx_domdec_comm_t */
356 #define DD_FLAG_NRCG 65535
357 #define DD_FLAG_FW(d) (1<<(16+(d)*2))
358 #define DD_FLAG_BW(d) (1<<(16+(d)*2+1))
360 /* Zone permutation required to obtain consecutive charge groups
361 * for neighbor searching.
363 static const int zone_perm[3][4] = { {0,0,0,0},{1,0,0,0},{3,0,1,2} };
365 /* dd_zo and dd_zp3/dd_zp2 are set up such that i zones with non-zero
366 * components see only j zones with that component 0.
369 /* The DD zone order */
370 static const ivec dd_zo[DD_MAXZONE] =
371 {{0,0,0},{1,0,0},{1,1,0},{0,1,0},{0,1,1},{0,0,1},{1,0,1},{1,1,1}};
376 static const ivec dd_zp3[dd_zp3n] = {{0,0,8},{1,3,6},{2,5,6},{3,5,7}};
381 static const ivec dd_zp2[dd_zp2n] = {{0,0,4},{1,3,4}};
386 static const ivec dd_zp1[dd_zp1n] = {{0,0,2}};
388 /* Factors used to avoid problems due to rounding issues */
389 #define DD_CELL_MARGIN 1.0001
390 #define DD_CELL_MARGIN2 1.00005
391 /* Factor to account for pressure scaling during nstlist steps */
392 #define DD_PRES_SCALE_MARGIN 1.02
394 /* Allowed performance loss before we DLB or warn */
395 #define DD_PERF_LOSS 0.05
397 #define DD_CELL_F_SIZE(dd,di) ((dd)->nc[(dd)->dim[(di)]]+1+(di)*2+1+(di))
399 /* Use separate MPI send and receive commands
400 * when nnodes <= GMX_DD_NNODES_SENDRECV.
401 * This saves memory (and some copying for small nnodes).
402 * For high parallelization scatter and gather calls are used.
404 #define GMX_DD_NNODES_SENDRECV 4
408 #define dd_index(n,i) ((((i)[ZZ]*(n)[YY] + (i)[YY])*(n)[XX]) + (i)[XX])
410 static void index2xyz(ivec nc,int ind,ivec xyz)
412 xyz[XX] = ind % nc[XX];
413 xyz[YY] = (ind / nc[XX]) % nc[YY];
414 xyz[ZZ] = ind / (nc[YY]*nc[XX]);
418 /* This order is required to minimize the coordinate communication in PME
419 * which uses decomposition in the x direction.
421 #define dd_index(n,i) ((((i)[XX]*(n)[YY] + (i)[YY])*(n)[ZZ]) + (i)[ZZ])
423 static void ddindex2xyz(ivec nc,int ind,ivec xyz)
425 xyz[XX] = ind / (nc[YY]*nc[ZZ]);
426 xyz[YY] = (ind / nc[ZZ]) % nc[YY];
427 xyz[ZZ] = ind % nc[ZZ];
430 static int ddcoord2ddnodeid(gmx_domdec_t *dd,ivec c)
435 ddindex = dd_index(dd->nc,c);
436 if (dd->comm->bCartesianPP_PME)
438 ddnodeid = dd->comm->ddindex2ddnodeid[ddindex];
440 else if (dd->comm->bCartesianPP)
443 MPI_Cart_rank(dd->mpi_comm_all,c,&ddnodeid);
454 static gmx_bool dynamic_dd_box(gmx_ddbox_t *ddbox,t_inputrec *ir)
456 return (ddbox->nboundeddim < DIM || DYNAMIC_BOX(*ir));
459 int ddglatnr(gmx_domdec_t *dd,int i)
469 if (i >= dd->comm->nat[ddnatNR-1])
471 gmx_fatal(FARGS,"glatnr called with %d, which is larger than the local number of atoms (%d)",i,dd->comm->nat[ddnatNR-1]);
473 atnr = dd->gatindex[i] + 1;
479 t_block *dd_charge_groups_global(gmx_domdec_t *dd)
481 return &dd->comm->cgs_gl;
484 static void vec_rvec_init(vec_rvec_t *v)
490 static void vec_rvec_check_alloc(vec_rvec_t *v,int n)
494 v->nalloc = over_alloc_dd(n);
495 srenew(v->v,v->nalloc);
499 void dd_store_state(gmx_domdec_t *dd,t_state *state)
503 if (state->ddp_count != dd->ddp_count)
505 gmx_incons("The state does not the domain decomposition state");
508 state->ncg_gl = dd->ncg_home;
509 if (state->ncg_gl > state->cg_gl_nalloc)
511 state->cg_gl_nalloc = over_alloc_dd(state->ncg_gl);
512 srenew(state->cg_gl,state->cg_gl_nalloc);
514 for(i=0; i<state->ncg_gl; i++)
516 state->cg_gl[i] = dd->index_gl[i];
519 state->ddp_count_cg_gl = dd->ddp_count;
522 gmx_domdec_zones_t *domdec_zones(gmx_domdec_t *dd)
524 return &dd->comm->zones;
527 void dd_get_ns_ranges(gmx_domdec_t *dd,int icg,
528 int *jcg0,int *jcg1,ivec shift0,ivec shift1)
530 gmx_domdec_zones_t *zones;
533 zones = &dd->comm->zones;
536 while (icg >= zones->izone[izone].cg1)
545 else if (izone < zones->nizone)
547 *jcg0 = zones->izone[izone].jcg0;
551 gmx_fatal(FARGS,"DD icg %d out of range: izone (%d) >= nizone (%d)",
552 icg,izone,zones->nizone);
555 *jcg1 = zones->izone[izone].jcg1;
557 for(d=0; d<dd->ndim; d++)
560 shift0[dim] = zones->izone[izone].shift0[dim];
561 shift1[dim] = zones->izone[izone].shift1[dim];
562 if (dd->comm->tric_dir[dim] || (dd->bGridJump && d > 0))
564 /* A conservative approach, this can be optimized */
571 int dd_natoms_vsite(gmx_domdec_t *dd)
573 return dd->comm->nat[ddnatVSITE];
576 void dd_get_constraint_range(gmx_domdec_t *dd,int *at_start,int *at_end)
578 *at_start = dd->comm->nat[ddnatCON-1];
579 *at_end = dd->comm->nat[ddnatCON];
582 void dd_move_x(gmx_domdec_t *dd,matrix box,rvec x[])
584 int nzone,nat_tot,n,d,p,i,j,at0,at1,zone;
586 gmx_domdec_comm_t *comm;
587 gmx_domdec_comm_dim_t *cd;
588 gmx_domdec_ind_t *ind;
589 rvec shift={0,0,0},*buf,*rbuf;
590 gmx_bool bPBC,bScrew;
594 cgindex = dd->cgindex;
599 nat_tot = dd->nat_home;
600 for(d=0; d<dd->ndim; d++)
602 bPBC = (dd->ci[dd->dim[d]] == 0);
603 bScrew = (bPBC && dd->bScrewPBC && dd->dim[d] == XX);
606 copy_rvec(box[dd->dim[d]],shift);
609 for(p=0; p<cd->np; p++)
616 for(i=0; i<ind->nsend[nzone]; i++)
618 at0 = cgindex[index[i]];
619 at1 = cgindex[index[i]+1];
620 for(j=at0; j<at1; j++)
622 copy_rvec(x[j],buf[n]);
629 for(i=0; i<ind->nsend[nzone]; i++)
631 at0 = cgindex[index[i]];
632 at1 = cgindex[index[i]+1];
633 for(j=at0; j<at1; j++)
635 /* We need to shift the coordinates */
636 rvec_add(x[j],shift,buf[n]);
643 for(i=0; i<ind->nsend[nzone]; i++)
645 at0 = cgindex[index[i]];
646 at1 = cgindex[index[i]+1];
647 for(j=at0; j<at1; j++)
650 buf[n][XX] = x[j][XX] + shift[XX];
652 * This operation requires a special shift force
653 * treatment, which is performed in calc_vir.
655 buf[n][YY] = box[YY][YY] - x[j][YY];
656 buf[n][ZZ] = box[ZZ][ZZ] - x[j][ZZ];
668 rbuf = comm->vbuf2.v;
670 /* Send and receive the coordinates */
671 dd_sendrecv_rvec(dd, d, dddirBackward,
672 buf, ind->nsend[nzone+1],
673 rbuf, ind->nrecv[nzone+1]);
677 for(zone=0; zone<nzone; zone++)
679 for(i=ind->cell2at0[zone]; i<ind->cell2at1[zone]; i++)
681 copy_rvec(rbuf[j],x[i]);
686 nat_tot += ind->nrecv[nzone+1];
692 void dd_move_f(gmx_domdec_t *dd,rvec f[],rvec *fshift)
694 int nzone,nat_tot,n,d,p,i,j,at0,at1,zone;
696 gmx_domdec_comm_t *comm;
697 gmx_domdec_comm_dim_t *cd;
698 gmx_domdec_ind_t *ind;
702 gmx_bool bPBC,bScrew;
706 cgindex = dd->cgindex;
711 nzone = comm->zones.n/2;
712 nat_tot = dd->nat_tot;
713 for(d=dd->ndim-1; d>=0; d--)
715 bPBC = (dd->ci[dd->dim[d]] == 0);
716 bScrew = (bPBC && dd->bScrewPBC && dd->dim[d] == XX);
717 if (fshift == NULL && !bScrew)
721 /* Determine which shift vector we need */
727 for(p=cd->np-1; p>=0; p--) {
729 nat_tot -= ind->nrecv[nzone+1];
736 sbuf = comm->vbuf2.v;
738 for(zone=0; zone<nzone; zone++)
740 for(i=ind->cell2at0[zone]; i<ind->cell2at1[zone]; i++)
742 copy_rvec(f[i],sbuf[j]);
747 /* Communicate the forces */
748 dd_sendrecv_rvec(dd, d, dddirForward,
749 sbuf, ind->nrecv[nzone+1],
750 buf, ind->nsend[nzone+1]);
752 /* Add the received forces */
756 for(i=0; i<ind->nsend[nzone]; i++)
758 at0 = cgindex[index[i]];
759 at1 = cgindex[index[i]+1];
760 for(j=at0; j<at1; j++)
762 rvec_inc(f[j],buf[n]);
769 for(i=0; i<ind->nsend[nzone]; i++)
771 at0 = cgindex[index[i]];
772 at1 = cgindex[index[i]+1];
773 for(j=at0; j<at1; j++)
775 rvec_inc(f[j],buf[n]);
776 /* Add this force to the shift force */
777 rvec_inc(fshift[is],buf[n]);
784 for(i=0; i<ind->nsend[nzone]; i++)
786 at0 = cgindex[index[i]];
787 at1 = cgindex[index[i]+1];
788 for(j=at0; j<at1; j++)
790 /* Rotate the force */
791 f[j][XX] += buf[n][XX];
792 f[j][YY] -= buf[n][YY];
793 f[j][ZZ] -= buf[n][ZZ];
796 /* Add this force to the shift force */
797 rvec_inc(fshift[is],buf[n]);
808 void dd_atom_spread_real(gmx_domdec_t *dd,real v[])
810 int nzone,nat_tot,n,d,p,i,j,at0,at1,zone;
812 gmx_domdec_comm_t *comm;
813 gmx_domdec_comm_dim_t *cd;
814 gmx_domdec_ind_t *ind;
819 cgindex = dd->cgindex;
821 buf = &comm->vbuf.v[0][0];
824 nat_tot = dd->nat_home;
825 for(d=0; d<dd->ndim; d++)
828 for(p=0; p<cd->np; p++)
833 for(i=0; i<ind->nsend[nzone]; i++)
835 at0 = cgindex[index[i]];
836 at1 = cgindex[index[i]+1];
837 for(j=at0; j<at1; j++)
850 rbuf = &comm->vbuf2.v[0][0];
852 /* Send and receive the coordinates */
853 dd_sendrecv_real(dd, d, dddirBackward,
854 buf, ind->nsend[nzone+1],
855 rbuf, ind->nrecv[nzone+1]);
859 for(zone=0; zone<nzone; zone++)
861 for(i=ind->cell2at0[zone]; i<ind->cell2at1[zone]; i++)
868 nat_tot += ind->nrecv[nzone+1];
874 void dd_atom_sum_real(gmx_domdec_t *dd,real v[])
876 int nzone,nat_tot,n,d,p,i,j,at0,at1,zone;
878 gmx_domdec_comm_t *comm;
879 gmx_domdec_comm_dim_t *cd;
880 gmx_domdec_ind_t *ind;
885 cgindex = dd->cgindex;
887 buf = &comm->vbuf.v[0][0];
890 nzone = comm->zones.n/2;
891 nat_tot = dd->nat_tot;
892 for(d=dd->ndim-1; d>=0; d--)
895 for(p=cd->np-1; p>=0; p--) {
897 nat_tot -= ind->nrecv[nzone+1];
904 sbuf = &comm->vbuf2.v[0][0];
906 for(zone=0; zone<nzone; zone++)
908 for(i=ind->cell2at0[zone]; i<ind->cell2at1[zone]; i++)
915 /* Communicate the forces */
916 dd_sendrecv_real(dd, d, dddirForward,
917 sbuf, ind->nrecv[nzone+1],
918 buf, ind->nsend[nzone+1]);
920 /* Add the received forces */
922 for(i=0; i<ind->nsend[nzone]; i++)
924 at0 = cgindex[index[i]];
925 at1 = cgindex[index[i]+1];
926 for(j=at0; j<at1; j++)
937 static void print_ddzone(FILE *fp,int d,int i,int j,gmx_ddzone_t *zone)
939 fprintf(fp,"zone d0 %d d1 %d d2 %d min0 %6.3f max1 %6.3f mch0 %6.3f mch1 %6.3f p1_0 %6.3f p1_1 %6.3f\n",
941 zone->min0,zone->max1,
942 zone->mch0,zone->mch0,
943 zone->p1_0,zone->p1_1);
946 static void dd_sendrecv_ddzone(const gmx_domdec_t *dd,
947 int ddimind,int direction,
948 gmx_ddzone_t *buf_s,int n_s,
949 gmx_ddzone_t *buf_r,int n_r)
951 rvec vbuf_s[5*2],vbuf_r[5*2];
956 vbuf_s[i*2 ][0] = buf_s[i].min0;
957 vbuf_s[i*2 ][1] = buf_s[i].max1;
958 vbuf_s[i*2 ][2] = buf_s[i].mch0;
959 vbuf_s[i*2+1][0] = buf_s[i].mch1;
960 vbuf_s[i*2+1][1] = buf_s[i].p1_0;
961 vbuf_s[i*2+1][2] = buf_s[i].p1_1;
964 dd_sendrecv_rvec(dd, ddimind, direction,
970 buf_r[i].min0 = vbuf_r[i*2 ][0];
971 buf_r[i].max1 = vbuf_r[i*2 ][1];
972 buf_r[i].mch0 = vbuf_r[i*2 ][2];
973 buf_r[i].mch1 = vbuf_r[i*2+1][0];
974 buf_r[i].p1_0 = vbuf_r[i*2+1][1];
975 buf_r[i].p1_1 = vbuf_r[i*2+1][2];
979 static void dd_move_cellx(gmx_domdec_t *dd,gmx_ddbox_t *ddbox,
980 rvec cell_ns_x0,rvec cell_ns_x1)
982 int d,d1,dim,dim1,pos,buf_size,i,j,k,p,npulse,npulse_min;
983 gmx_ddzone_t *zp,buf_s[5],buf_r[5],buf_e[5];
984 rvec extr_s[2],extr_r[2];
987 gmx_domdec_comm_t *comm;
992 for(d=1; d<dd->ndim; d++)
995 zp = (d == 1) ? &comm->zone_d1[0] : &comm->zone_d2[0][0];
996 zp->min0 = cell_ns_x0[dim];
997 zp->max1 = cell_ns_x1[dim];
998 zp->mch0 = cell_ns_x0[dim];
999 zp->mch1 = cell_ns_x1[dim];
1000 zp->p1_0 = cell_ns_x0[dim];
1001 zp->p1_1 = cell_ns_x1[dim];
1004 for(d=dd->ndim-2; d>=0; d--)
1007 bPBC = (dim < ddbox->npbcdim);
1009 /* Use an rvec to store two reals */
1010 extr_s[d][0] = comm->cell_f0[d+1];
1011 extr_s[d][1] = comm->cell_f1[d+1];
1015 /* Store the extremes in the backward sending buffer,
1016 * so the get updated separately from the forward communication.
1018 for(d1=d; d1<dd->ndim-1; d1++)
1020 /* We invert the order to be able to use the same loop for buf_e */
1021 buf_s[pos].min0 = extr_s[d1][1];
1022 buf_s[pos].max1 = extr_s[d1][0];
1023 buf_s[pos].mch0 = 0;
1024 buf_s[pos].mch1 = 0;
1025 /* Store the cell corner of the dimension we communicate along */
1026 buf_s[pos].p1_0 = comm->cell_x0[dim];
1027 buf_s[pos].p1_1 = 0;
1031 buf_s[pos] = (dd->ndim == 2) ? comm->zone_d1[0] : comm->zone_d2[0][0];
1034 if (dd->ndim == 3 && d == 0)
1036 buf_s[pos] = comm->zone_d2[0][1];
1038 buf_s[pos] = comm->zone_d1[0];
1042 /* We only need to communicate the extremes
1043 * in the forward direction
1045 npulse = comm->cd[d].np;
1048 /* Take the minimum to avoid double communication */
1049 npulse_min = min(npulse,dd->nc[dim]-1-npulse);
1053 /* Without PBC we should really not communicate over
1054 * the boundaries, but implementing that complicates
1055 * the communication setup and therefore we simply
1056 * do all communication, but ignore some data.
1058 npulse_min = npulse;
1060 for(p=0; p<npulse_min; p++)
1062 /* Communicate the extremes forward */
1063 bUse = (bPBC || dd->ci[dim] > 0);
1065 dd_sendrecv_rvec(dd, d, dddirForward,
1066 extr_s+d, dd->ndim-d-1,
1067 extr_r+d, dd->ndim-d-1);
1071 for(d1=d; d1<dd->ndim-1; d1++)
1073 extr_s[d1][0] = max(extr_s[d1][0],extr_r[d1][0]);
1074 extr_s[d1][1] = min(extr_s[d1][1],extr_r[d1][1]);
1080 for(p=0; p<npulse; p++)
1082 /* Communicate all the zone information backward */
1083 bUse = (bPBC || dd->ci[dim] < dd->nc[dim] - 1);
1085 dd_sendrecv_ddzone(dd, d, dddirBackward,
1092 for(d1=d+1; d1<dd->ndim; d1++)
1094 /* Determine the decrease of maximum required
1095 * communication height along d1 due to the distance along d,
1096 * this avoids a lot of useless atom communication.
1098 dist_d = comm->cell_x1[dim] - buf_r[0].p1_0;
1100 if (ddbox->tric_dir[dim])
1102 /* c is the off-diagonal coupling between the cell planes
1103 * along directions d and d1.
1105 c = ddbox->v[dim][dd->dim[d1]][dim];
1111 det = (1 + c*c)*comm->cutoff*comm->cutoff - dist_d*dist_d;
1114 dh[d1] = comm->cutoff - (c*dist_d + sqrt(det))/(1 + c*c);
1118 /* A negative value signals out of range */
1124 /* Accumulate the extremes over all pulses */
1125 for(i=0; i<buf_size; i++)
1129 buf_e[i] = buf_r[i];
1135 buf_e[i].min0 = min(buf_e[i].min0,buf_r[i].min0);
1136 buf_e[i].max1 = max(buf_e[i].max1,buf_r[i].max1);
1139 if (dd->ndim == 3 && d == 0 && i == buf_size - 1)
1147 if (bUse && dh[d1] >= 0)
1149 buf_e[i].mch0 = max(buf_e[i].mch0,buf_r[i].mch0-dh[d1]);
1150 buf_e[i].mch1 = max(buf_e[i].mch1,buf_r[i].mch1-dh[d1]);
1153 /* Copy the received buffer to the send buffer,
1154 * to pass the data through with the next pulse.
1156 buf_s[i] = buf_r[i];
1158 if (((bPBC || dd->ci[dim]+npulse < dd->nc[dim]) && p == npulse-1) ||
1159 (!bPBC && dd->ci[dim]+1+p == dd->nc[dim]-1))
1161 /* Store the extremes */
1164 for(d1=d; d1<dd->ndim-1; d1++)
1166 extr_s[d1][1] = min(extr_s[d1][1],buf_e[pos].min0);
1167 extr_s[d1][0] = max(extr_s[d1][0],buf_e[pos].max1);
1171 if (d == 1 || (d == 0 && dd->ndim == 3))
1175 comm->zone_d2[1-d][i] = buf_e[pos];
1181 comm->zone_d1[1] = buf_e[pos];
1195 print_ddzone(debug,1,i,0,&comm->zone_d1[i]);
1197 cell_ns_x0[dim] = min(cell_ns_x0[dim],comm->zone_d1[i].min0);
1198 cell_ns_x1[dim] = max(cell_ns_x1[dim],comm->zone_d1[i].max1);
1210 print_ddzone(debug,2,i,j,&comm->zone_d2[i][j]);
1212 cell_ns_x0[dim] = min(cell_ns_x0[dim],comm->zone_d2[i][j].min0);
1213 cell_ns_x1[dim] = max(cell_ns_x1[dim],comm->zone_d2[i][j].max1);
1217 for(d=1; d<dd->ndim; d++)
1219 comm->cell_f_max0[d] = extr_s[d-1][0];
1220 comm->cell_f_min1[d] = extr_s[d-1][1];
1223 fprintf(debug,"Cell fraction d %d, max0 %f, min1 %f\n",
1224 d,comm->cell_f_max0[d],comm->cell_f_min1[d]);
1229 static void dd_collect_cg(gmx_domdec_t *dd,
1230 t_state *state_local)
1232 gmx_domdec_master_t *ma=NULL;
1233 int buf2[2],*ibuf,i,ncg_home=0,*cg=NULL,nat_home=0;
1236 if (state_local->ddp_count == dd->comm->master_cg_ddp_count)
1238 /* The master has the correct distribution */
1242 if (state_local->ddp_count == dd->ddp_count)
1244 ncg_home = dd->ncg_home;
1246 nat_home = dd->nat_home;
1248 else if (state_local->ddp_count_cg_gl == state_local->ddp_count)
1250 cgs_gl = &dd->comm->cgs_gl;
1252 ncg_home = state_local->ncg_gl;
1253 cg = state_local->cg_gl;
1255 for(i=0; i<ncg_home; i++)
1257 nat_home += cgs_gl->index[cg[i]+1] - cgs_gl->index[cg[i]];
1262 gmx_incons("Attempted to collect a vector for a state for which the charge group distribution is unknown");
1265 buf2[0] = dd->ncg_home;
1266 buf2[1] = dd->nat_home;
1276 /* Collect the charge group and atom counts on the master */
1277 dd_gather(dd,2*sizeof(int),buf2,ibuf);
1282 for(i=0; i<dd->nnodes; i++)
1284 ma->ncg[i] = ma->ibuf[2*i];
1285 ma->nat[i] = ma->ibuf[2*i+1];
1286 ma->index[i+1] = ma->index[i] + ma->ncg[i];
1289 /* Make byte counts and indices */
1290 for(i=0; i<dd->nnodes; i++)
1292 ma->ibuf[i] = ma->ncg[i]*sizeof(int);
1293 ma->ibuf[dd->nnodes+i] = ma->index[i]*sizeof(int);
1297 fprintf(debug,"Initial charge group distribution: ");
1298 for(i=0; i<dd->nnodes; i++)
1299 fprintf(debug," %d",ma->ncg[i]);
1300 fprintf(debug,"\n");
1304 /* Collect the charge group indices on the master */
1306 dd->ncg_home*sizeof(int),dd->index_gl,
1307 DDMASTER(dd) ? ma->ibuf : NULL,
1308 DDMASTER(dd) ? ma->ibuf+dd->nnodes : NULL,
1309 DDMASTER(dd) ? ma->cg : NULL);
1311 dd->comm->master_cg_ddp_count = state_local->ddp_count;
1314 static void dd_collect_vec_sendrecv(gmx_domdec_t *dd,
1317 gmx_domdec_master_t *ma;
1318 int n,i,c,a,nalloc=0;
1327 MPI_Send(lv,dd->nat_home*sizeof(rvec),MPI_BYTE,DDMASTERRANK(dd),
1328 dd->rank,dd->mpi_comm_all);
1331 /* Copy the master coordinates to the global array */
1332 cgs_gl = &dd->comm->cgs_gl;
1334 n = DDMASTERRANK(dd);
1336 for(i=ma->index[n]; i<ma->index[n+1]; i++)
1338 for(c=cgs_gl->index[ma->cg[i]]; c<cgs_gl->index[ma->cg[i]+1]; c++)
1340 copy_rvec(lv[a++],v[c]);
1344 for(n=0; n<dd->nnodes; n++)
1348 if (ma->nat[n] > nalloc)
1350 nalloc = over_alloc_dd(ma->nat[n]);
1354 MPI_Recv(buf,ma->nat[n]*sizeof(rvec),MPI_BYTE,DDRANK(dd,n),
1355 n,dd->mpi_comm_all,MPI_STATUS_IGNORE);
1358 for(i=ma->index[n]; i<ma->index[n+1]; i++)
1360 for(c=cgs_gl->index[ma->cg[i]]; c<cgs_gl->index[ma->cg[i]+1]; c++)
1362 copy_rvec(buf[a++],v[c]);
1371 static void get_commbuffer_counts(gmx_domdec_t *dd,
1372 int **counts,int **disps)
1374 gmx_domdec_master_t *ma;
1379 /* Make the rvec count and displacment arrays */
1381 *disps = ma->ibuf + dd->nnodes;
1382 for(n=0; n<dd->nnodes; n++)
1384 (*counts)[n] = ma->nat[n]*sizeof(rvec);
1385 (*disps)[n] = (n == 0 ? 0 : (*disps)[n-1] + (*counts)[n-1]);
1389 static void dd_collect_vec_gatherv(gmx_domdec_t *dd,
1392 gmx_domdec_master_t *ma;
1393 int *rcounts=NULL,*disps=NULL;
1402 get_commbuffer_counts(dd,&rcounts,&disps);
1407 dd_gatherv(dd,dd->nat_home*sizeof(rvec),lv,rcounts,disps,buf);
1411 cgs_gl = &dd->comm->cgs_gl;
1414 for(n=0; n<dd->nnodes; n++)
1416 for(i=ma->index[n]; i<ma->index[n+1]; i++)
1418 for(c=cgs_gl->index[ma->cg[i]]; c<cgs_gl->index[ma->cg[i]+1]; c++)
1420 copy_rvec(buf[a++],v[c]);
1427 void dd_collect_vec(gmx_domdec_t *dd,
1428 t_state *state_local,rvec *lv,rvec *v)
1430 gmx_domdec_master_t *ma;
1431 int n,i,c,a,nalloc=0;
1434 dd_collect_cg(dd,state_local);
1436 if (dd->nnodes <= GMX_DD_NNODES_SENDRECV)
1438 dd_collect_vec_sendrecv(dd,lv,v);
1442 dd_collect_vec_gatherv(dd,lv,v);
1447 void dd_collect_state(gmx_domdec_t *dd,
1448 t_state *state_local,t_state *state)
1452 nh = state->nhchainlength;
1456 state->lambda = state_local->lambda;
1457 state->veta = state_local->veta;
1458 state->vol0 = state_local->vol0;
1459 copy_mat(state_local->box,state->box);
1460 copy_mat(state_local->boxv,state->boxv);
1461 copy_mat(state_local->svir_prev,state->svir_prev);
1462 copy_mat(state_local->fvir_prev,state->fvir_prev);
1463 copy_mat(state_local->pres_prev,state->pres_prev);
1466 for(i=0; i<state_local->ngtc; i++)
1468 for(j=0; j<nh; j++) {
1469 state->nosehoover_xi[i*nh+j] = state_local->nosehoover_xi[i*nh+j];
1470 state->nosehoover_vxi[i*nh+j] = state_local->nosehoover_vxi[i*nh+j];
1472 state->therm_integral[i] = state_local->therm_integral[i];
1474 for(i=0; i<state_local->nnhpres; i++)
1476 for(j=0; j<nh; j++) {
1477 state->nhpres_xi[i*nh+j] = state_local->nhpres_xi[i*nh+j];
1478 state->nhpres_vxi[i*nh+j] = state_local->nhpres_vxi[i*nh+j];
1482 for(est=0; est<estNR; est++)
1484 if (EST_DISTR(est) && (state_local->flags & (1<<est)))
1488 dd_collect_vec(dd,state_local,state_local->x,state->x);
1491 dd_collect_vec(dd,state_local,state_local->v,state->v);
1494 dd_collect_vec(dd,state_local,state_local->sd_X,state->sd_X);
1497 dd_collect_vec(dd,state_local,state_local->cg_p,state->cg_p);
1500 if (state->nrngi == 1)
1504 for(i=0; i<state_local->nrng; i++)
1506 state->ld_rng[i] = state_local->ld_rng[i];
1512 dd_gather(dd,state_local->nrng*sizeof(state->ld_rng[0]),
1513 state_local->ld_rng,state->ld_rng);
1517 if (state->nrngi == 1)
1521 state->ld_rngi[0] = state_local->ld_rngi[0];
1526 dd_gather(dd,sizeof(state->ld_rngi[0]),
1527 state_local->ld_rngi,state->ld_rngi);
1530 case estDISRE_INITF:
1531 case estDISRE_RM3TAV:
1532 case estORIRE_INITF:
1536 gmx_incons("Unknown state entry encountered in dd_collect_state");
1542 static void dd_realloc_fr_cg(t_forcerec *fr,int nalloc)
1546 fprintf(debug,"Reallocating forcerec: currently %d, required %d, allocating %d\n",fr->cg_nalloc,nalloc,over_alloc_dd(nalloc));
1548 fr->cg_nalloc = over_alloc_dd(nalloc);
1549 srenew(fr->cg_cm,fr->cg_nalloc);
1550 srenew(fr->cginfo,fr->cg_nalloc);
1553 static void dd_realloc_state(t_state *state,rvec **f,int nalloc)
1559 fprintf(debug,"Reallocating state: currently %d, required %d, allocating %d\n",state->nalloc,nalloc,over_alloc_dd(nalloc));
1562 state->nalloc = over_alloc_dd(nalloc);
1564 for(est=0; est<estNR; est++)
1566 if (EST_DISTR(est) && (state->flags & (1<<est)))
1570 srenew(state->x,state->nalloc);
1573 srenew(state->v,state->nalloc);
1576 srenew(state->sd_X,state->nalloc);
1579 srenew(state->cg_p,state->nalloc);
1583 case estDISRE_INITF:
1584 case estDISRE_RM3TAV:
1585 case estORIRE_INITF:
1587 /* No reallocation required */
1590 gmx_incons("Unknown state entry encountered in dd_realloc_state");
1597 srenew(*f,state->nalloc);
1601 static void dd_distribute_vec_sendrecv(gmx_domdec_t *dd,t_block *cgs,
1604 gmx_domdec_master_t *ma;
1605 int n,i,c,a,nalloc=0;
1612 for(n=0; n<dd->nnodes; n++)
1616 if (ma->nat[n] > nalloc)
1618 nalloc = over_alloc_dd(ma->nat[n]);
1621 /* Use lv as a temporary buffer */
1623 for(i=ma->index[n]; i<ma->index[n+1]; i++)
1625 for(c=cgs->index[ma->cg[i]]; c<cgs->index[ma->cg[i]+1]; c++)
1627 copy_rvec(v[c],buf[a++]);
1630 if (a != ma->nat[n])
1632 gmx_fatal(FARGS,"Internal error a (%d) != nat (%d)",
1637 MPI_Send(buf,ma->nat[n]*sizeof(rvec),MPI_BYTE,
1638 DDRANK(dd,n),n,dd->mpi_comm_all);
1643 n = DDMASTERRANK(dd);
1645 for(i=ma->index[n]; i<ma->index[n+1]; i++)
1647 for(c=cgs->index[ma->cg[i]]; c<cgs->index[ma->cg[i]+1]; c++)
1649 copy_rvec(v[c],lv[a++]);
1656 MPI_Recv(lv,dd->nat_home*sizeof(rvec),MPI_BYTE,DDMASTERRANK(dd),
1657 MPI_ANY_TAG,dd->mpi_comm_all,MPI_STATUS_IGNORE);
1662 static void dd_distribute_vec_scatterv(gmx_domdec_t *dd,t_block *cgs,
1665 gmx_domdec_master_t *ma;
1666 int *scounts=NULL,*disps=NULL;
1667 int n,i,c,a,nalloc=0;
1674 get_commbuffer_counts(dd,&scounts,&disps);
1678 for(n=0; n<dd->nnodes; n++)
1680 for(i=ma->index[n]; i<ma->index[n+1]; i++)
1682 for(c=cgs->index[ma->cg[i]]; c<cgs->index[ma->cg[i]+1]; c++)
1684 copy_rvec(v[c],buf[a++]);
1690 dd_scatterv(dd,scounts,disps,buf,dd->nat_home*sizeof(rvec),lv);
1693 static void dd_distribute_vec(gmx_domdec_t *dd,t_block *cgs,rvec *v,rvec *lv)
1695 if (dd->nnodes <= GMX_DD_NNODES_SENDRECV)
1697 dd_distribute_vec_sendrecv(dd,cgs,v,lv);
1701 dd_distribute_vec_scatterv(dd,cgs,v,lv);
1705 static void dd_distribute_state(gmx_domdec_t *dd,t_block *cgs,
1706 t_state *state,t_state *state_local,
1709 int i,j,ngtch,ngtcp,nh;
1711 nh = state->nhchainlength;
1715 state_local->lambda = state->lambda;
1716 state_local->veta = state->veta;
1717 state_local->vol0 = state->vol0;
1718 copy_mat(state->box,state_local->box);
1719 copy_mat(state->box_rel,state_local->box_rel);
1720 copy_mat(state->boxv,state_local->boxv);
1721 copy_mat(state->svir_prev,state_local->svir_prev);
1722 copy_mat(state->fvir_prev,state_local->fvir_prev);
1723 for(i=0; i<state_local->ngtc; i++)
1725 for(j=0; j<nh; j++) {
1726 state_local->nosehoover_xi[i*nh+j] = state->nosehoover_xi[i*nh+j];
1727 state_local->nosehoover_vxi[i*nh+j] = state->nosehoover_vxi[i*nh+j];
1729 state_local->therm_integral[i] = state->therm_integral[i];
1731 for(i=0; i<state_local->nnhpres; i++)
1733 for(j=0; j<nh; j++) {
1734 state_local->nhpres_xi[i*nh+j] = state->nhpres_xi[i*nh+j];
1735 state_local->nhpres_vxi[i*nh+j] = state->nhpres_vxi[i*nh+j];
1739 dd_bcast(dd,sizeof(real),&state_local->lambda);
1740 dd_bcast(dd,sizeof(real),&state_local->veta);
1741 dd_bcast(dd,sizeof(real),&state_local->vol0);
1742 dd_bcast(dd,sizeof(state_local->box),state_local->box);
1743 dd_bcast(dd,sizeof(state_local->box_rel),state_local->box_rel);
1744 dd_bcast(dd,sizeof(state_local->boxv),state_local->boxv);
1745 dd_bcast(dd,sizeof(state_local->svir_prev),state_local->svir_prev);
1746 dd_bcast(dd,sizeof(state_local->fvir_prev),state_local->fvir_prev);
1747 dd_bcast(dd,((state_local->ngtc*nh)*sizeof(double)),state_local->nosehoover_xi);
1748 dd_bcast(dd,((state_local->ngtc*nh)*sizeof(double)),state_local->nosehoover_vxi);
1749 dd_bcast(dd,state_local->ngtc*sizeof(double),state_local->therm_integral);
1750 dd_bcast(dd,((state_local->nnhpres*nh)*sizeof(double)),state_local->nhpres_xi);
1751 dd_bcast(dd,((state_local->nnhpres*nh)*sizeof(double)),state_local->nhpres_vxi);
1753 if (dd->nat_home > state_local->nalloc)
1755 dd_realloc_state(state_local,f,dd->nat_home);
1757 for(i=0; i<estNR; i++)
1759 if (EST_DISTR(i) && (state_local->flags & (1<<i)))
1763 dd_distribute_vec(dd,cgs,state->x,state_local->x);
1766 dd_distribute_vec(dd,cgs,state->v,state_local->v);
1769 dd_distribute_vec(dd,cgs,state->sd_X,state_local->sd_X);
1772 dd_distribute_vec(dd,cgs,state->cg_p,state_local->cg_p);
1775 if (state->nrngi == 1)
1778 state_local->nrng*sizeof(state_local->ld_rng[0]),
1779 state->ld_rng,state_local->ld_rng);
1784 state_local->nrng*sizeof(state_local->ld_rng[0]),
1785 state->ld_rng,state_local->ld_rng);
1789 if (state->nrngi == 1)
1791 dd_bcastc(dd,sizeof(state_local->ld_rngi[0]),
1792 state->ld_rngi,state_local->ld_rngi);
1796 dd_scatter(dd,sizeof(state_local->ld_rngi[0]),
1797 state->ld_rngi,state_local->ld_rngi);
1800 case estDISRE_INITF:
1801 case estDISRE_RM3TAV:
1802 case estORIRE_INITF:
1804 /* Not implemented yet */
1807 gmx_incons("Unknown state entry encountered in dd_distribute_state");
1813 static char dim2char(int dim)
1819 case XX: c = 'X'; break;
1820 case YY: c = 'Y'; break;
1821 case ZZ: c = 'Z'; break;
1822 default: gmx_fatal(FARGS,"Unknown dim %d",dim);
1828 static void write_dd_grid_pdb(const char *fn,gmx_large_int_t step,
1829 gmx_domdec_t *dd,matrix box,gmx_ddbox_t *ddbox)
1831 rvec grid_s[2],*grid_r=NULL,cx,r;
1832 char fname[STRLEN],format[STRLEN],buf[22];
1838 copy_rvec(dd->comm->cell_x0,grid_s[0]);
1839 copy_rvec(dd->comm->cell_x1,grid_s[1]);
1843 snew(grid_r,2*dd->nnodes);
1846 dd_gather(dd,2*sizeof(rvec),grid_s[0],DDMASTER(dd) ? grid_r[0] : NULL);
1850 for(d=0; d<DIM; d++)
1852 for(i=0; i<DIM; i++)
1860 if (dd->nc[d] > 1 && d < ddbox->npbcdim)
1862 tric[d][i] = box[i][d]/box[i][i];
1871 sprintf(fname,"%s_%s.pdb",fn,gmx_step_str(step,buf));
1872 sprintf(format,"%s%s\n",pdbformat,"%6.2f%6.2f");
1873 out = gmx_fio_fopen(fname,"w");
1874 gmx_write_pdb_box(out,dd->bScrewPBC ? epbcSCREW : epbcXYZ,box);
1876 for(i=0; i<dd->nnodes; i++)
1878 vol = dd->nnodes/(box[XX][XX]*box[YY][YY]*box[ZZ][ZZ]);
1879 for(d=0; d<DIM; d++)
1881 vol *= grid_r[i*2+1][d] - grid_r[i*2][d];
1889 cx[XX] = grid_r[i*2+x][XX];
1890 cx[YY] = grid_r[i*2+y][YY];
1891 cx[ZZ] = grid_r[i*2+z][ZZ];
1893 fprintf(out,format,"ATOM",a++,"CA","GLY",' ',1+i,
1894 10*r[XX],10*r[YY],10*r[ZZ],1.0,vol);
1898 for(d=0; d<DIM; d++)
1904 case 0: y = 1 + i*8 + 2*x; break;
1905 case 1: y = 1 + i*8 + 2*x - (x % 2); break;
1906 case 2: y = 1 + i*8 + x; break;
1908 fprintf(out,"%6s%5d%5d\n","CONECT",y,y+(1<<d));
1912 gmx_fio_fclose(out);
1917 void write_dd_pdb(const char *fn,gmx_large_int_t step,const char *title,
1918 gmx_mtop_t *mtop,t_commrec *cr,
1919 int natoms,rvec x[],matrix box)
1921 char fname[STRLEN],format[STRLEN],format4[STRLEN],buf[22];
1924 char *atomname,*resname;
1931 natoms = dd->comm->nat[ddnatVSITE];
1934 sprintf(fname,"%s_%s_n%d.pdb",fn,gmx_step_str(step,buf),cr->sim_nodeid);
1936 sprintf(format,"%s%s\n",pdbformat,"%6.2f%6.2f");
1937 sprintf(format4,"%s%s\n",pdbformat4,"%6.2f%6.2f");
1939 out = gmx_fio_fopen(fname,"w");
1941 fprintf(out,"TITLE %s\n",title);
1942 gmx_write_pdb_box(out,dd->bScrewPBC ? epbcSCREW : epbcXYZ,box);
1943 for(i=0; i<natoms; i++)
1945 ii = dd->gatindex[i];
1946 gmx_mtop_atominfo_global(mtop,ii,&atomname,&resnr,&resname);
1947 if (i < dd->comm->nat[ddnatZONE])
1950 while (i >= dd->cgindex[dd->comm->zones.cg_range[c+1]])
1956 else if (i < dd->comm->nat[ddnatVSITE])
1958 b = dd->comm->zones.n;
1962 b = dd->comm->zones.n + 1;
1964 fprintf(out,strlen(atomname)<4 ? format : format4,
1965 "ATOM",(ii+1)%100000,
1966 atomname,resname,' ',resnr%10000,' ',
1967 10*x[i][XX],10*x[i][YY],10*x[i][ZZ],1.0,b);
1969 fprintf(out,"TER\n");
1971 gmx_fio_fclose(out);
1974 real dd_cutoff_mbody(gmx_domdec_t *dd)
1976 gmx_domdec_comm_t *comm;
1983 if (comm->bInterCGBondeds)
1985 if (comm->cutoff_mbody > 0)
1987 r = comm->cutoff_mbody;
1991 /* cutoff_mbody=0 means we do not have DLB */
1992 r = comm->cellsize_min[dd->dim[0]];
1993 for(di=1; di<dd->ndim; di++)
1995 r = min(r,comm->cellsize_min[dd->dim[di]]);
1997 if (comm->bBondComm)
1999 r = max(r,comm->cutoff_mbody);
2003 r = min(r,comm->cutoff);
2011 real dd_cutoff_twobody(gmx_domdec_t *dd)
2015 r_mb = dd_cutoff_mbody(dd);
2017 return max(dd->comm->cutoff,r_mb);
2021 static void dd_cart_coord2pmecoord(gmx_domdec_t *dd,ivec coord,ivec coord_pme)
2025 nc = dd->nc[dd->comm->cartpmedim];
2026 ntot = dd->comm->ntot[dd->comm->cartpmedim];
2027 copy_ivec(coord,coord_pme);
2028 coord_pme[dd->comm->cartpmedim] =
2029 nc + (coord[dd->comm->cartpmedim]*(ntot - nc) + (ntot - nc)/2)/nc;
2032 static int low_ddindex2pmeindex(int ndd,int npme,int ddindex)
2034 /* Here we assign a PME node to communicate with this DD node
2035 * by assuming that the major index of both is x.
2036 * We add cr->npmenodes/2 to obtain an even distribution.
2038 return (ddindex*npme + npme/2)/ndd;
2041 static int ddindex2pmeindex(const gmx_domdec_t *dd,int ddindex)
2043 return low_ddindex2pmeindex(dd->nnodes,dd->comm->npmenodes,ddindex);
2046 static int cr_ddindex2pmeindex(const t_commrec *cr,int ddindex)
2048 return low_ddindex2pmeindex(cr->dd->nnodes,cr->npmenodes,ddindex);
2051 static int *dd_pmenodes(t_commrec *cr)
2056 snew(pmenodes,cr->npmenodes);
2058 for(i=0; i<cr->dd->nnodes; i++) {
2059 p0 = cr_ddindex2pmeindex(cr,i);
2060 p1 = cr_ddindex2pmeindex(cr,i+1);
2061 if (i+1 == cr->dd->nnodes || p1 > p0) {
2063 fprintf(debug,"pmenode[%d] = %d\n",n,i+1+n);
2064 pmenodes[n] = i + 1 + n;
2072 static int gmx_ddcoord2pmeindex(t_commrec *cr,int x,int y,int z)
2075 ivec coords,coords_pme,nc;
2080 if (dd->comm->bCartesian) {
2081 gmx_ddindex2xyz(dd->nc,ddindex,coords);
2082 dd_coords2pmecoords(dd,coords,coords_pme);
2083 copy_ivec(dd->ntot,nc);
2084 nc[dd->cartpmedim] -= dd->nc[dd->cartpmedim];
2085 coords_pme[dd->cartpmedim] -= dd->nc[dd->cartpmedim];
2087 slab = (coords_pme[XX]*nc[YY] + coords_pme[YY])*nc[ZZ] + coords_pme[ZZ];
2089 slab = (ddindex*cr->npmenodes + cr->npmenodes/2)/dd->nnodes;
2095 slab = ddindex2pmeindex(dd,dd_index(dd->nc,coords));
2100 static int ddcoord2simnodeid(t_commrec *cr,int x,int y,int z)
2102 gmx_domdec_comm_t *comm;
2104 int ddindex,nodeid=-1;
2106 comm = cr->dd->comm;
2111 if (comm->bCartesianPP_PME)
2114 MPI_Cart_rank(cr->mpi_comm_mysim,coords,&nodeid);
2119 ddindex = dd_index(cr->dd->nc,coords);
2120 if (comm->bCartesianPP)
2122 nodeid = comm->ddindex2simnodeid[ddindex];
2128 nodeid = ddindex + gmx_ddcoord2pmeindex(cr,x,y,z);
2140 static int dd_simnode2pmenode(t_commrec *cr,int sim_nodeid)
2143 gmx_domdec_comm_t *comm;
2144 ivec coord,coord_pme;
2151 /* This assumes a uniform x domain decomposition grid cell size */
2152 if (comm->bCartesianPP_PME)
2155 MPI_Cart_coords(cr->mpi_comm_mysim,sim_nodeid,DIM,coord);
2156 if (coord[comm->cartpmedim] < dd->nc[comm->cartpmedim])
2158 /* This is a PP node */
2159 dd_cart_coord2pmecoord(dd,coord,coord_pme);
2160 MPI_Cart_rank(cr->mpi_comm_mysim,coord_pme,&pmenode);
2164 else if (comm->bCartesianPP)
2166 if (sim_nodeid < dd->nnodes)
2168 pmenode = dd->nnodes + ddindex2pmeindex(dd,sim_nodeid);
2173 /* This assumes DD cells with identical x coordinates
2174 * are numbered sequentially.
2176 if (dd->comm->pmenodes == NULL)
2178 if (sim_nodeid < dd->nnodes)
2180 /* The DD index equals the nodeid */
2181 pmenode = dd->nnodes + ddindex2pmeindex(dd,sim_nodeid);
2187 while (sim_nodeid > dd->comm->pmenodes[i])
2191 if (sim_nodeid < dd->comm->pmenodes[i])
2193 pmenode = dd->comm->pmenodes[i];
2201 gmx_bool gmx_pmeonlynode(t_commrec *cr,int sim_nodeid)
2203 gmx_bool bPMEOnlyNode;
2205 if (DOMAINDECOMP(cr))
2207 bPMEOnlyNode = (dd_simnode2pmenode(cr,sim_nodeid) == -1);
2211 bPMEOnlyNode = FALSE;
2214 return bPMEOnlyNode;
2217 void get_pme_ddnodes(t_commrec *cr,int pmenodeid,
2218 int *nmy_ddnodes,int **my_ddnodes,int *node_peer)
2222 ivec coord,coord_pme;
2226 snew(*my_ddnodes,(dd->nnodes+cr->npmenodes-1)/cr->npmenodes);
2229 for(x=0; x<dd->nc[XX]; x++)
2231 for(y=0; y<dd->nc[YY]; y++)
2233 for(z=0; z<dd->nc[ZZ]; z++)
2235 if (dd->comm->bCartesianPP_PME)
2240 dd_cart_coord2pmecoord(dd,coord,coord_pme);
2241 if (dd->ci[XX] == coord_pme[XX] &&
2242 dd->ci[YY] == coord_pme[YY] &&
2243 dd->ci[ZZ] == coord_pme[ZZ])
2244 (*my_ddnodes)[(*nmy_ddnodes)++] = ddcoord2simnodeid(cr,x,y,z);
2248 /* The slab corresponds to the nodeid in the PME group */
2249 if (gmx_ddcoord2pmeindex(cr,x,y,z) == pmenodeid)
2251 (*my_ddnodes)[(*nmy_ddnodes)++] = ddcoord2simnodeid(cr,x,y,z);
2258 /* The last PP-only node is the peer node */
2259 *node_peer = (*my_ddnodes)[*nmy_ddnodes-1];
2263 fprintf(debug,"Receive coordinates from PP nodes:");
2264 for(x=0; x<*nmy_ddnodes; x++)
2266 fprintf(debug," %d",(*my_ddnodes)[x]);
2268 fprintf(debug,"\n");
2272 static gmx_bool receive_vir_ener(t_commrec *cr)
2274 gmx_domdec_comm_t *comm;
2275 int pmenode,coords[DIM],rank;
2279 if (cr->npmenodes < cr->dd->nnodes)
2281 comm = cr->dd->comm;
2282 if (comm->bCartesianPP_PME)
2284 pmenode = dd_simnode2pmenode(cr,cr->sim_nodeid);
2286 MPI_Cart_coords(cr->mpi_comm_mysim,cr->sim_nodeid,DIM,coords);
2287 coords[comm->cartpmedim]++;
2288 if (coords[comm->cartpmedim] < cr->dd->nc[comm->cartpmedim])
2290 MPI_Cart_rank(cr->mpi_comm_mysim,coords,&rank);
2291 if (dd_simnode2pmenode(cr,rank) == pmenode)
2293 /* This is not the last PP node for pmenode */
2301 pmenode = dd_simnode2pmenode(cr,cr->sim_nodeid);
2302 if (cr->sim_nodeid+1 < cr->nnodes &&
2303 dd_simnode2pmenode(cr,cr->sim_nodeid+1) == pmenode)
2305 /* This is not the last PP node for pmenode */
2314 static void set_zones_ncg_home(gmx_domdec_t *dd)
2316 gmx_domdec_zones_t *zones;
2319 zones = &dd->comm->zones;
2321 zones->cg_range[0] = 0;
2322 for(i=1; i<zones->n+1; i++)
2324 zones->cg_range[i] = dd->ncg_home;
2328 static void rebuild_cgindex(gmx_domdec_t *dd,int *gcgs_index,t_state *state)
2330 int nat,i,*ind,*dd_cg_gl,*cgindex,cg_gl;
2333 dd_cg_gl = dd->index_gl;
2334 cgindex = dd->cgindex;
2337 for(i=0; i<state->ncg_gl; i++)
2341 dd_cg_gl[i] = cg_gl;
2342 nat += gcgs_index[cg_gl+1] - gcgs_index[cg_gl];
2346 dd->ncg_home = state->ncg_gl;
2349 set_zones_ncg_home(dd);
2352 static int ddcginfo(const cginfo_mb_t *cginfo_mb,int cg)
2354 while (cg >= cginfo_mb->cg_end)
2359 return cginfo_mb->cginfo[(cg - cginfo_mb->cg_start) % cginfo_mb->cg_mod];
2362 static void dd_set_cginfo(int *index_gl,int cg0,int cg1,
2363 t_forcerec *fr,char *bLocalCG)
2365 cginfo_mb_t *cginfo_mb;
2371 cginfo_mb = fr->cginfo_mb;
2372 cginfo = fr->cginfo;
2374 for(cg=cg0; cg<cg1; cg++)
2376 cginfo[cg] = ddcginfo(cginfo_mb,index_gl[cg]);
2380 if (bLocalCG != NULL)
2382 for(cg=cg0; cg<cg1; cg++)
2384 bLocalCG[index_gl[cg]] = TRUE;
2389 static void make_dd_indices(gmx_domdec_t *dd,int *gcgs_index,int cg_start)
2391 int nzone,zone,zone1,cg0,cg,cg_gl,a,a_gl;
2392 int *zone2cg,*zone_ncg1,*index_gl,*gatindex;
2396 bLocalCG = dd->comm->bLocalCG;
2398 if (dd->nat_tot > dd->gatindex_nalloc)
2400 dd->gatindex_nalloc = over_alloc_dd(dd->nat_tot);
2401 srenew(dd->gatindex,dd->gatindex_nalloc);
2404 nzone = dd->comm->zones.n;
2405 zone2cg = dd->comm->zones.cg_range;
2406 zone_ncg1 = dd->comm->zone_ncg1;
2407 index_gl = dd->index_gl;
2408 gatindex = dd->gatindex;
2410 if (zone2cg[1] != dd->ncg_home)
2412 gmx_incons("dd->ncg_zone is not up to date");
2415 /* Make the local to global and global to local atom index */
2416 a = dd->cgindex[cg_start];
2417 for(zone=0; zone<nzone; zone++)
2425 cg0 = zone2cg[zone];
2427 for(cg=cg0; cg<zone2cg[zone+1]; cg++)
2430 if (cg - cg0 >= zone_ncg1[zone])
2432 /* Signal that this cg is from more than one zone away */
2435 cg_gl = index_gl[cg];
2436 for(a_gl=gcgs_index[cg_gl]; a_gl<gcgs_index[cg_gl+1]; a_gl++)
2439 ga2la_set(dd->ga2la,a_gl,a,zone1);
2446 static int check_bLocalCG(gmx_domdec_t *dd,int ncg_sys,const char *bLocalCG,
2452 if (bLocalCG == NULL)
2456 for(i=0; i<dd->ncg_tot; i++)
2458 if (!bLocalCG[dd->index_gl[i]])
2461 "DD node %d, %s: cg %d, global cg %d is not marked in bLocalCG (ncg_home %d)\n",dd->rank,where,i+1,dd->index_gl[i]+1,dd->ncg_home);
2466 for(i=0; i<ncg_sys; i++)
2473 if (ngl != dd->ncg_tot)
2475 fprintf(stderr,"DD node %d, %s: In bLocalCG %d cgs are marked as local, whereas there are %d\n",dd->rank,where,ngl,dd->ncg_tot);
2482 static void check_index_consistency(gmx_domdec_t *dd,
2483 int natoms_sys,int ncg_sys,
2486 int nerr,ngl,i,a,cell;
2491 if (dd->comm->DD_debug > 1)
2493 snew(have,natoms_sys);
2494 for(a=0; a<dd->nat_tot; a++)
2496 if (have[dd->gatindex[a]] > 0)
2498 fprintf(stderr,"DD node %d: global atom %d occurs twice: index %d and %d\n",dd->rank,dd->gatindex[a]+1,have[dd->gatindex[a]],a+1);
2502 have[dd->gatindex[a]] = a + 1;
2508 snew(have,dd->nat_tot);
2511 for(i=0; i<natoms_sys; i++)
2513 if (ga2la_get(dd->ga2la,i,&a,&cell))
2515 if (a >= dd->nat_tot)
2517 fprintf(stderr,"DD node %d: global atom %d marked as local atom %d, which is larger than nat_tot (%d)\n",dd->rank,i+1,a+1,dd->nat_tot);
2523 if (dd->gatindex[a] != i)
2525 fprintf(stderr,"DD node %d: global atom %d marked as local atom %d, which has global atom index %d\n",dd->rank,i+1,a+1,dd->gatindex[a]+1);
2532 if (ngl != dd->nat_tot)
2535 "DD node %d, %s: %d global atom indices, %d local atoms\n",
2536 dd->rank,where,ngl,dd->nat_tot);
2538 for(a=0; a<dd->nat_tot; a++)
2543 "DD node %d, %s: local atom %d, global %d has no global index\n",
2544 dd->rank,where,a+1,dd->gatindex[a]+1);
2549 nerr += check_bLocalCG(dd,ncg_sys,dd->comm->bLocalCG,where);
2552 gmx_fatal(FARGS,"DD node %d, %s: %d atom/cg index inconsistencies",
2553 dd->rank,where,nerr);
2557 static void clear_dd_indices(gmx_domdec_t *dd,int cg_start,int a_start)
2564 /* Clear the whole list without searching */
2565 ga2la_clear(dd->ga2la);
2569 for(i=a_start; i<dd->nat_tot; i++)
2571 ga2la_del(dd->ga2la,dd->gatindex[i]);
2575 bLocalCG = dd->comm->bLocalCG;
2578 for(i=cg_start; i<dd->ncg_tot; i++)
2580 bLocalCG[dd->index_gl[i]] = FALSE;
2584 dd_clear_local_vsite_indices(dd);
2586 if (dd->constraints)
2588 dd_clear_local_constraint_indices(dd);
2592 static real grid_jump_limit(gmx_domdec_comm_t *comm,int dim_ind)
2594 real grid_jump_limit;
2596 /* The distance between the boundaries of cells at distance
2597 * x+-1,y+-1 or y+-1,z+-1 is limited by the cut-off restrictions
2598 * and by the fact that cells should not be shifted by more than
2599 * half their size, such that cg's only shift by one cell
2600 * at redecomposition.
2602 grid_jump_limit = comm->cellsize_limit;
2603 if (!comm->bVacDLBNoLimit)
2605 grid_jump_limit = max(grid_jump_limit,
2606 comm->cutoff/comm->cd[dim_ind].np);
2609 return grid_jump_limit;
2612 static void check_grid_jump(gmx_large_int_t step,gmx_domdec_t *dd,gmx_ddbox_t *ddbox)
2614 gmx_domdec_comm_t *comm;
2620 for(d=1; d<dd->ndim; d++)
2623 limit = grid_jump_limit(comm,d);
2624 bfac = ddbox->box_size[dim];
2625 if (ddbox->tric_dir[dim])
2627 bfac *= ddbox->skew_fac[dim];
2629 if ((comm->cell_f1[d] - comm->cell_f_max0[d])*bfac < limit ||
2630 (comm->cell_f0[d] - comm->cell_f_min1[d])*bfac > -limit)
2633 gmx_fatal(FARGS,"Step %s: The domain decomposition grid has shifted too much in the %c-direction around cell %d %d %d\n",
2634 gmx_step_str(step,buf),
2635 dim2char(dim),dd->ci[XX],dd->ci[YY],dd->ci[ZZ]);
2640 static int dd_load_count(gmx_domdec_comm_t *comm)
2642 return (comm->eFlop ? comm->flop_n : comm->cycl_n[ddCyclF]);
2645 static float dd_force_load(gmx_domdec_comm_t *comm)
2652 if (comm->eFlop > 1)
2654 load *= 1.0 + (comm->eFlop - 1)*(0.1*rand()/RAND_MAX - 0.05);
2659 load = comm->cycl[ddCyclF];
2660 if (comm->cycl_n[ddCyclF] > 1)
2662 /* Subtract the maximum of the last n cycle counts
2663 * to get rid of possible high counts due to other soures,
2664 * for instance system activity, that would otherwise
2665 * affect the dynamic load balancing.
2667 load -= comm->cycl_max[ddCyclF];
2674 static void set_slb_pme_dim_f(gmx_domdec_t *dd,int dim,real **dim_f)
2676 gmx_domdec_comm_t *comm;
2681 snew(*dim_f,dd->nc[dim]+1);
2683 for(i=1; i<dd->nc[dim]; i++)
2685 if (comm->slb_frac[dim])
2687 (*dim_f)[i] = (*dim_f)[i-1] + comm->slb_frac[dim][i-1];
2691 (*dim_f)[i] = (real)i/(real)dd->nc[dim];
2694 (*dim_f)[dd->nc[dim]] = 1;
2697 static void init_ddpme(gmx_domdec_t *dd,gmx_ddpme_t *ddpme,int dimind)
2699 int pmeindex,slab,nso,i;
2702 if (dimind == 0 && dd->dim[0] == YY && dd->comm->npmenodes_x == 1)
2708 ddpme->dim = dimind;
2710 ddpme->dim_match = (ddpme->dim == dd->dim[dimind]);
2712 ddpme->nslab = (ddpme->dim == 0 ?
2713 dd->comm->npmenodes_x :
2714 dd->comm->npmenodes_y);
2716 if (ddpme->nslab <= 1)
2721 nso = dd->comm->npmenodes/ddpme->nslab;
2722 /* Determine for each PME slab the PP location range for dimension dim */
2723 snew(ddpme->pp_min,ddpme->nslab);
2724 snew(ddpme->pp_max,ddpme->nslab);
2725 for(slab=0; slab<ddpme->nslab; slab++) {
2726 ddpme->pp_min[slab] = dd->nc[dd->dim[dimind]] - 1;
2727 ddpme->pp_max[slab] = 0;
2729 for(i=0; i<dd->nnodes; i++) {
2730 ddindex2xyz(dd->nc,i,xyz);
2731 /* For y only use our y/z slab.
2732 * This assumes that the PME x grid size matches the DD grid size.
2734 if (dimind == 0 || xyz[XX] == dd->ci[XX]) {
2735 pmeindex = ddindex2pmeindex(dd,i);
2737 slab = pmeindex/nso;
2739 slab = pmeindex % ddpme->nslab;
2741 ddpme->pp_min[slab] = min(ddpme->pp_min[slab],xyz[dimind]);
2742 ddpme->pp_max[slab] = max(ddpme->pp_max[slab],xyz[dimind]);
2746 set_slb_pme_dim_f(dd,ddpme->dim,&ddpme->slb_dim_f);
2749 int dd_pme_maxshift_x(gmx_domdec_t *dd)
2751 if (dd->comm->ddpme[0].dim == XX)
2753 return dd->comm->ddpme[0].maxshift;
2761 int dd_pme_maxshift_y(gmx_domdec_t *dd)
2763 if (dd->comm->ddpme[0].dim == YY)
2765 return dd->comm->ddpme[0].maxshift;
2767 else if (dd->comm->npmedecompdim >= 2 && dd->comm->ddpme[1].dim == YY)
2769 return dd->comm->ddpme[1].maxshift;
2777 static void set_pme_maxshift(gmx_domdec_t *dd,gmx_ddpme_t *ddpme,
2778 gmx_bool bUniform,gmx_ddbox_t *ddbox,real *cell_f)
2780 gmx_domdec_comm_t *comm;
2783 real range,pme_boundary;
2787 nc = dd->nc[ddpme->dim];
2790 if (!ddpme->dim_match)
2792 /* PP decomposition is not along dim: the worst situation */
2795 else if (ns <= 3 || (bUniform && ns == nc))
2797 /* The optimal situation */
2802 /* We need to check for all pme nodes which nodes they
2803 * could possibly need to communicate with.
2805 xmin = ddpme->pp_min;
2806 xmax = ddpme->pp_max;
2807 /* Allow for atoms to be maximally 2/3 times the cut-off
2808 * out of their DD cell. This is a reasonable balance between
2809 * between performance and support for most charge-group/cut-off
2812 range = 2.0/3.0*comm->cutoff/ddbox->box_size[ddpme->dim];
2813 /* Avoid extra communication when we are exactly at a boundary */
2819 /* PME slab s spreads atoms between box frac. s/ns and (s+1)/ns */
2820 pme_boundary = (real)s/ns;
2823 cell_f[xmax[s-(sh+1) ]+1] + range > pme_boundary) ||
2825 cell_f[xmax[s-(sh+1)+ns]+1] - 1 + range > pme_boundary)))
2829 pme_boundary = (real)(s+1)/ns;
2832 cell_f[xmin[s+(sh+1) ] ] - range < pme_boundary) ||
2834 cell_f[xmin[s+(sh+1)-ns] ] + 1 - range < pme_boundary)))
2841 ddpme->maxshift = sh;
2845 fprintf(debug,"PME slab communication range for dim %d is %d\n",
2846 ddpme->dim,ddpme->maxshift);
2850 static void check_box_size(gmx_domdec_t *dd,gmx_ddbox_t *ddbox)
2854 for(d=0; d<dd->ndim; d++)
2857 if (dim < ddbox->nboundeddim &&
2858 ddbox->box_size[dim]*ddbox->skew_fac[dim] <
2859 dd->nc[dim]*dd->comm->cellsize_limit*DD_CELL_MARGIN)
2861 gmx_fatal(FARGS,"The %c-size of the box (%f) times the triclinic skew factor (%f) is smaller than the number of DD cells (%d) times the smallest allowed cell size (%f)\n",
2862 dim2char(dim),ddbox->box_size[dim],ddbox->skew_fac[dim],
2863 dd->nc[dim],dd->comm->cellsize_limit);
2868 static void set_dd_cell_sizes_slb(gmx_domdec_t *dd,gmx_ddbox_t *ddbox,
2869 gmx_bool bMaster,ivec npulse)
2871 gmx_domdec_comm_t *comm;
2874 real *cell_x,cell_dx,cellsize;
2878 for(d=0; d<DIM; d++)
2880 cellsize_min[d] = ddbox->box_size[d]*ddbox->skew_fac[d];
2882 if (dd->nc[d] == 1 || comm->slb_frac[d] == NULL)
2885 cell_dx = ddbox->box_size[d]/dd->nc[d];
2888 for(j=0; j<dd->nc[d]+1; j++)
2890 dd->ma->cell_x[d][j] = ddbox->box0[d] + j*cell_dx;
2895 comm->cell_x0[d] = ddbox->box0[d] + (dd->ci[d] )*cell_dx;
2896 comm->cell_x1[d] = ddbox->box0[d] + (dd->ci[d]+1)*cell_dx;
2898 cellsize = cell_dx*ddbox->skew_fac[d];
2899 while (cellsize*npulse[d] < comm->cutoff && npulse[d] < dd->nc[d]-1)
2903 cellsize_min[d] = cellsize;
2907 /* Statically load balanced grid */
2908 /* Also when we are not doing a master distribution we determine
2909 * all cell borders in a loop to obtain identical values
2910 * to the master distribution case and to determine npulse.
2914 cell_x = dd->ma->cell_x[d];
2918 snew(cell_x,dd->nc[d]+1);
2920 cell_x[0] = ddbox->box0[d];
2921 for(j=0; j<dd->nc[d]; j++)
2923 cell_dx = ddbox->box_size[d]*comm->slb_frac[d][j];
2924 cell_x[j+1] = cell_x[j] + cell_dx;
2925 cellsize = cell_dx*ddbox->skew_fac[d];
2926 while (cellsize*npulse[d] < comm->cutoff &&
2927 npulse[d] < dd->nc[d]-1)
2931 cellsize_min[d] = min(cellsize_min[d],cellsize);
2935 comm->cell_x0[d] = cell_x[dd->ci[d]];
2936 comm->cell_x1[d] = cell_x[dd->ci[d]+1];
2940 /* The following limitation is to avoid that a cell would receive
2941 * some of its own home charge groups back over the periodic boundary.
2942 * Double charge groups cause trouble with the global indices.
2944 if (d < ddbox->npbcdim &&
2945 dd->nc[d] > 1 && npulse[d] >= dd->nc[d])
2947 gmx_fatal_collective(FARGS,NULL,dd,
2948 "The box size in direction %c (%f) times the triclinic skew factor (%f) is too small for a cut-off of %f with %d domain decomposition cells, use 1 or more than %d %s or increase the box size in this direction",
2949 dim2char(d),ddbox->box_size[d],ddbox->skew_fac[d],
2951 dd->nc[d],dd->nc[d],
2952 dd->nnodes > dd->nc[d] ? "cells" : "processors");
2956 if (!comm->bDynLoadBal)
2958 copy_rvec(cellsize_min,comm->cellsize_min);
2961 for(d=0; d<comm->npmedecompdim; d++)
2963 set_pme_maxshift(dd,&comm->ddpme[d],
2964 comm->slb_frac[dd->dim[d]]==NULL,ddbox,
2965 comm->ddpme[d].slb_dim_f);
2970 static void dd_cell_sizes_dlb_root_enforce_limits(gmx_domdec_t *dd,
2971 int d,int dim,gmx_domdec_root_t *root,
2973 gmx_bool bUniform,gmx_large_int_t step, real cellsize_limit_f, int range[])
2975 gmx_domdec_comm_t *comm;
2976 int ncd,i,j,nmin,nmin_old;
2977 gmx_bool bLimLo,bLimHi;
2979 real fac,halfway,cellsize_limit_f_i,region_size;
2980 gmx_bool bPBC,bLastHi=FALSE;
2981 int nrange[]={range[0],range[1]};
2983 region_size= root->cell_f[range[1]]-root->cell_f[range[0]];
2989 bPBC = (dim < ddbox->npbcdim);
2991 cell_size = root->buf_ncd;
2995 fprintf(debug,"enforce_limits: %d %d\n",range[0],range[1]);
2998 /* First we need to check if the scaling does not make cells
2999 * smaller than the smallest allowed size.
3000 * We need to do this iteratively, since if a cell is too small,
3001 * it needs to be enlarged, which makes all the other cells smaller,
3002 * which could in turn make another cell smaller than allowed.
3004 for(i=range[0]; i<range[1]; i++)
3006 root->bCellMin[i] = FALSE;
3012 /* We need the total for normalization */
3014 for(i=range[0]; i<range[1]; i++)
3016 if (root->bCellMin[i] == FALSE)
3018 fac += cell_size[i];
3021 fac = ( region_size - nmin*cellsize_limit_f)/fac; /* substracting cells already set to cellsize_limit_f */
3022 /* Determine the cell boundaries */
3023 for(i=range[0]; i<range[1]; i++)
3025 if (root->bCellMin[i] == FALSE)
3027 cell_size[i] *= fac;
3028 if (!bPBC && (i == 0 || i == dd->nc[dim] -1))
3030 cellsize_limit_f_i = 0;
3034 cellsize_limit_f_i = cellsize_limit_f;
3036 if (cell_size[i] < cellsize_limit_f_i)
3038 root->bCellMin[i] = TRUE;
3039 cell_size[i] = cellsize_limit_f_i;
3043 root->cell_f[i+1] = root->cell_f[i] + cell_size[i];
3046 while (nmin > nmin_old);
3049 cell_size[i] = root->cell_f[i+1] - root->cell_f[i];
3050 /* For this check we should not use DD_CELL_MARGIN,
3051 * but a slightly smaller factor,
3052 * since rounding could get use below the limit.
3054 if (bPBC && cell_size[i] < cellsize_limit_f*DD_CELL_MARGIN2/DD_CELL_MARGIN)
3057 gmx_fatal(FARGS,"Step %s: the dynamic load balancing could not balance dimension %c: box size %f, triclinic skew factor %f, #cells %d, minimum cell size %f\n",
3058 gmx_step_str(step,buf),
3059 dim2char(dim),ddbox->box_size[dim],ddbox->skew_fac[dim],
3060 ncd,comm->cellsize_min[dim]);
3063 root->bLimited = (nmin > 0) || (range[0]>0) || (range[1]<ncd);
3067 /* Check if the boundary did not displace more than halfway
3068 * each of the cells it bounds, as this could cause problems,
3069 * especially when the differences between cell sizes are large.
3070 * If changes are applied, they will not make cells smaller
3071 * than the cut-off, as we check all the boundaries which
3072 * might be affected by a change and if the old state was ok,
3073 * the cells will at most be shrunk back to their old size.
3075 for(i=range[0]+1; i<range[1]; i++)
3077 halfway = 0.5*(root->old_cell_f[i] + root->old_cell_f[i-1]);
3078 if (root->cell_f[i] < halfway)
3080 root->cell_f[i] = halfway;
3081 /* Check if the change also causes shifts of the next boundaries */
3082 for(j=i+1; j<range[1]; j++)
3084 if (root->cell_f[j] < root->cell_f[j-1] + cellsize_limit_f)
3085 root->cell_f[j] = root->cell_f[j-1] + cellsize_limit_f;
3088 halfway = 0.5*(root->old_cell_f[i] + root->old_cell_f[i+1]);
3089 if (root->cell_f[i] > halfway)
3091 root->cell_f[i] = halfway;
3092 /* Check if the change also causes shifts of the next boundaries */
3093 for(j=i-1; j>=range[0]+1; j--)
3095 if (root->cell_f[j] > root->cell_f[j+1] - cellsize_limit_f)
3096 root->cell_f[j] = root->cell_f[j+1] - cellsize_limit_f;
3102 /* nrange is defined as [lower, upper) range for new call to enforce_limits */
3103 /* find highest violation of LimLo (a) and the following violation of LimHi (thus the lowest following) (b)
3104 * then call enforce_limits for (oldb,a), (a,b). In the next step: (b,nexta). oldb and nexta can be the boundaries.
3105 * for a and b nrange is used */
3108 /* Take care of the staggering of the cell boundaries */
3111 for(i=range[0]; i<range[1]; i++)
3113 root->cell_f_max0[i] = root->cell_f[i];
3114 root->cell_f_min1[i] = root->cell_f[i+1];
3119 for(i=range[0]+1; i<range[1]; i++)
3121 bLimLo = (root->cell_f[i] < root->bound_min[i]);
3122 bLimHi = (root->cell_f[i] > root->bound_max[i]);
3123 if (bLimLo && bLimHi)
3125 /* Both limits violated, try the best we can */
3126 /* For this case we split the original range (range) in two parts and care about the other limitiations in the next iteration. */
3127 root->cell_f[i] = 0.5*(root->bound_min[i] + root->bound_max[i]);
3130 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3134 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3140 /* root->cell_f[i] = root->bound_min[i]; */
3141 nrange[1]=i; /* only store violation location. There could be a LimLo violation following with an higher index */
3144 else if (bLimHi && !bLastHi)
3147 if (nrange[1] < range[1]) /* found a LimLo before */
3149 root->cell_f[nrange[1]] = root->bound_min[nrange[1]];
3150 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3151 nrange[0]=nrange[1];
3153 root->cell_f[i] = root->bound_max[i];
3155 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3160 if (nrange[1] < range[1]) /* found last a LimLo */
3162 root->cell_f[nrange[1]] = root->bound_min[nrange[1]];
3163 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3164 nrange[0]=nrange[1];
3166 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3168 else if (nrange[0] > range[0]) /* found at least one LimHi */
3170 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, nrange);
3177 static void set_dd_cell_sizes_dlb_root(gmx_domdec_t *dd,
3178 int d,int dim,gmx_domdec_root_t *root,
3179 gmx_ddbox_t *ddbox,gmx_bool bDynamicBox,
3180 gmx_bool bUniform,gmx_large_int_t step)
3182 gmx_domdec_comm_t *comm;
3185 real load_aver,load_i,imbalance,change,change_max,sc;
3186 real cellsize_limit_f,dist_min_f,dist_min_f_hard,space;
3190 int range[] = { 0, 0 };
3194 /* Convert the maximum change from the input percentage to a fraction */
3195 change_limit = comm->dlb_scale_lim*0.01;
3199 bPBC = (dim < ddbox->npbcdim);
3201 cell_size = root->buf_ncd;
3203 /* Store the original boundaries */
3204 for(i=0; i<ncd+1; i++)
3206 root->old_cell_f[i] = root->cell_f[i];
3209 for(i=0; i<ncd; i++)
3211 cell_size[i] = 1.0/ncd;
3214 else if (dd_load_count(comm))
3216 load_aver = comm->load[d].sum_m/ncd;
3218 for(i=0; i<ncd; i++)
3220 /* Determine the relative imbalance of cell i */
3221 load_i = comm->load[d].load[i*comm->load[d].nload+2];
3222 imbalance = (load_i - load_aver)/(load_aver>0 ? load_aver : 1);
3223 /* Determine the change of the cell size using underrelaxation */
3224 change = -relax*imbalance;
3225 change_max = max(change_max,max(change,-change));
3227 /* Limit the amount of scaling.
3228 * We need to use the same rescaling for all cells in one row,
3229 * otherwise the load balancing might not converge.
3232 if (change_max > change_limit)
3234 sc *= change_limit/change_max;
3236 for(i=0; i<ncd; i++)
3238 /* Determine the relative imbalance of cell i */
3239 load_i = comm->load[d].load[i*comm->load[d].nload+2];
3240 imbalance = (load_i - load_aver)/(load_aver>0 ? load_aver : 1);
3241 /* Determine the change of the cell size using underrelaxation */
3242 change = -sc*imbalance;
3243 cell_size[i] = (root->cell_f[i+1]-root->cell_f[i])*(1 + change);
3247 cellsize_limit_f = comm->cellsize_min[dim]/ddbox->box_size[dim];
3248 cellsize_limit_f *= DD_CELL_MARGIN;
3249 dist_min_f_hard = grid_jump_limit(comm,d)/ddbox->box_size[dim];
3250 dist_min_f = dist_min_f_hard * DD_CELL_MARGIN;
3251 if (ddbox->tric_dir[dim])
3253 cellsize_limit_f /= ddbox->skew_fac[dim];
3254 dist_min_f /= ddbox->skew_fac[dim];
3256 if (bDynamicBox && d > 0)
3258 dist_min_f *= DD_PRES_SCALE_MARGIN;
3260 if (d > 0 && !bUniform)
3262 /* Make sure that the grid is not shifted too much */
3263 for(i=1; i<ncd; i++) {
3264 if (root->cell_f_min1[i] - root->cell_f_max0[i-1] < 2 * dist_min_f_hard)
3266 gmx_incons("Inconsistent DD boundary staggering limits!");
3268 root->bound_min[i] = root->cell_f_max0[i-1] + dist_min_f;
3269 space = root->cell_f[i] - (root->cell_f_max0[i-1] + dist_min_f);
3271 root->bound_min[i] += 0.5*space;
3273 root->bound_max[i] = root->cell_f_min1[i] - dist_min_f;
3274 space = root->cell_f[i] - (root->cell_f_min1[i] - dist_min_f);
3276 root->bound_max[i] += 0.5*space;
3281 "dim %d boundary %d %.3f < %.3f < %.3f < %.3f < %.3f\n",
3283 root->cell_f_max0[i-1] + dist_min_f,
3284 root->bound_min[i],root->cell_f[i],root->bound_max[i],
3285 root->cell_f_min1[i] - dist_min_f);
3290 root->cell_f[0] = 0;
3291 root->cell_f[ncd] = 1;
3292 dd_cell_sizes_dlb_root_enforce_limits(dd, d, dim, root, ddbox, bUniform, step, cellsize_limit_f, range);
3295 /* After the checks above, the cells should obey the cut-off
3296 * restrictions, but it does not hurt to check.
3298 for(i=0; i<ncd; i++)
3302 fprintf(debug,"Relative bounds dim %d cell %d: %f %f\n",
3303 dim,i,root->cell_f[i],root->cell_f[i+1]);
3306 if ((bPBC || (i != 0 && i != dd->nc[dim]-1)) &&
3307 root->cell_f[i+1] - root->cell_f[i] <
3308 cellsize_limit_f/DD_CELL_MARGIN)
3312 "\nWARNING step %s: direction %c, cell %d too small: %f\n",
3313 gmx_step_str(step,buf),dim2char(dim),i,
3314 (root->cell_f[i+1] - root->cell_f[i])
3315 *ddbox->box_size[dim]*ddbox->skew_fac[dim]);
3320 /* Store the cell boundaries of the lower dimensions at the end */
3321 for(d1=0; d1<d; d1++)
3323 root->cell_f[pos++] = comm->cell_f0[d1];
3324 root->cell_f[pos++] = comm->cell_f1[d1];
3327 if (d < comm->npmedecompdim)
3329 /* The master determines the maximum shift for
3330 * the coordinate communication between separate PME nodes.
3332 set_pme_maxshift(dd,&comm->ddpme[d],bUniform,ddbox,root->cell_f);
3334 root->cell_f[pos++] = comm->ddpme[0].maxshift;
3337 root->cell_f[pos++] = comm->ddpme[1].maxshift;
3341 static void relative_to_absolute_cell_bounds(gmx_domdec_t *dd,
3342 gmx_ddbox_t *ddbox,int dimind)
3344 gmx_domdec_comm_t *comm;
3349 /* Set the cell dimensions */
3350 dim = dd->dim[dimind];
3351 comm->cell_x0[dim] = comm->cell_f0[dimind]*ddbox->box_size[dim];
3352 comm->cell_x1[dim] = comm->cell_f1[dimind]*ddbox->box_size[dim];
3353 if (dim >= ddbox->nboundeddim)
3355 comm->cell_x0[dim] += ddbox->box0[dim];
3356 comm->cell_x1[dim] += ddbox->box0[dim];
3360 static void distribute_dd_cell_sizes_dlb(gmx_domdec_t *dd,
3361 int d,int dim,real *cell_f_row,
3364 gmx_domdec_comm_t *comm;
3370 /* Each node would only need to know two fractions,
3371 * but it is probably cheaper to broadcast the whole array.
3373 MPI_Bcast(cell_f_row,DD_CELL_F_SIZE(dd,d)*sizeof(real),MPI_BYTE,
3374 0,comm->mpi_comm_load[d]);
3376 /* Copy the fractions for this dimension from the buffer */
3377 comm->cell_f0[d] = cell_f_row[dd->ci[dim] ];
3378 comm->cell_f1[d] = cell_f_row[dd->ci[dim]+1];
3379 /* The whole array was communicated, so set the buffer position */
3380 pos = dd->nc[dim] + 1;
3381 for(d1=0; d1<=d; d1++)
3385 /* Copy the cell fractions of the lower dimensions */
3386 comm->cell_f0[d1] = cell_f_row[pos++];
3387 comm->cell_f1[d1] = cell_f_row[pos++];
3389 relative_to_absolute_cell_bounds(dd,ddbox,d1);
3391 /* Convert the communicated shift from float to int */
3392 comm->ddpme[0].maxshift = (int)(cell_f_row[pos++] + 0.5);
3395 comm->ddpme[1].maxshift = (int)(cell_f_row[pos++] + 0.5);
3399 static void set_dd_cell_sizes_dlb_change(gmx_domdec_t *dd,
3400 gmx_ddbox_t *ddbox,gmx_bool bDynamicBox,
3401 gmx_bool bUniform,gmx_large_int_t step)
3403 gmx_domdec_comm_t *comm;
3405 gmx_bool bRowMember,bRowRoot;
3410 for(d=0; d<dd->ndim; d++)
3415 for(d1=d; d1<dd->ndim; d1++)
3417 if (dd->ci[dd->dim[d1]] > 0)
3430 set_dd_cell_sizes_dlb_root(dd,d,dim,comm->root[d],
3431 ddbox,bDynamicBox,bUniform,step);
3432 cell_f_row = comm->root[d]->cell_f;
3436 cell_f_row = comm->cell_f_row;
3438 distribute_dd_cell_sizes_dlb(dd,d,dim,cell_f_row,ddbox);
3443 static void set_dd_cell_sizes_dlb_nochange(gmx_domdec_t *dd,gmx_ddbox_t *ddbox)
3447 /* This function assumes the box is static and should therefore
3448 * not be called when the box has changed since the last
3449 * call to dd_partition_system.
3451 for(d=0; d<dd->ndim; d++)
3453 relative_to_absolute_cell_bounds(dd,ddbox,d);
3459 static void set_dd_cell_sizes_dlb(gmx_domdec_t *dd,
3460 gmx_ddbox_t *ddbox,gmx_bool bDynamicBox,
3461 gmx_bool bUniform,gmx_bool bDoDLB,gmx_large_int_t step,
3462 gmx_wallcycle_t wcycle)
3464 gmx_domdec_comm_t *comm;
3471 wallcycle_start(wcycle,ewcDDCOMMBOUND);
3472 set_dd_cell_sizes_dlb_change(dd,ddbox,bDynamicBox,bUniform,step);
3473 wallcycle_stop(wcycle,ewcDDCOMMBOUND);
3475 else if (bDynamicBox)
3477 set_dd_cell_sizes_dlb_nochange(dd,ddbox);
3480 /* Set the dimensions for which no DD is used */
3481 for(dim=0; dim<DIM; dim++) {
3482 if (dd->nc[dim] == 1) {
3483 comm->cell_x0[dim] = 0;
3484 comm->cell_x1[dim] = ddbox->box_size[dim];
3485 if (dim >= ddbox->nboundeddim)
3487 comm->cell_x0[dim] += ddbox->box0[dim];
3488 comm->cell_x1[dim] += ddbox->box0[dim];
3494 static void realloc_comm_ind(gmx_domdec_t *dd,ivec npulse)
3497 gmx_domdec_comm_dim_t *cd;
3499 for(d=0; d<dd->ndim; d++)
3501 cd = &dd->comm->cd[d];
3502 np = npulse[dd->dim[d]];
3503 if (np > cd->np_nalloc)
3507 fprintf(debug,"(Re)allocing cd for %c to %d pulses\n",
3508 dim2char(dd->dim[d]),np);
3510 if (DDMASTER(dd) && cd->np_nalloc > 0)
3512 fprintf(stderr,"\nIncreasing the number of cell to communicate in dimension %c to %d for the first time\n",dim2char(dd->dim[d]),np);
3515 for(i=cd->np_nalloc; i<np; i++)
3517 cd->ind[i].index = NULL;
3518 cd->ind[i].nalloc = 0;
3527 static void set_dd_cell_sizes(gmx_domdec_t *dd,
3528 gmx_ddbox_t *ddbox,gmx_bool bDynamicBox,
3529 gmx_bool bUniform,gmx_bool bDoDLB,gmx_large_int_t step,
3530 gmx_wallcycle_t wcycle)
3532 gmx_domdec_comm_t *comm;
3538 /* Copy the old cell boundaries for the cg displacement check */
3539 copy_rvec(comm->cell_x0,comm->old_cell_x0);
3540 copy_rvec(comm->cell_x1,comm->old_cell_x1);
3542 if (comm->bDynLoadBal)
3546 check_box_size(dd,ddbox);
3548 set_dd_cell_sizes_dlb(dd,ddbox,bDynamicBox,bUniform,bDoDLB,step,wcycle);
3552 set_dd_cell_sizes_slb(dd,ddbox,FALSE,npulse);
3553 realloc_comm_ind(dd,npulse);
3558 for(d=0; d<DIM; d++)
3560 fprintf(debug,"cell_x[%d] %f - %f skew_fac %f\n",
3561 d,comm->cell_x0[d],comm->cell_x1[d],ddbox->skew_fac[d]);
3566 static void comm_dd_ns_cell_sizes(gmx_domdec_t *dd,
3568 rvec cell_ns_x0,rvec cell_ns_x1,
3569 gmx_large_int_t step)
3571 gmx_domdec_comm_t *comm;
3576 for(dim_ind=0; dim_ind<dd->ndim; dim_ind++)
3578 dim = dd->dim[dim_ind];
3580 /* Without PBC we don't have restrictions on the outer cells */
3581 if (!(dim >= ddbox->npbcdim &&
3582 (dd->ci[dim] == 0 || dd->ci[dim] == dd->nc[dim] - 1)) &&
3583 comm->bDynLoadBal &&
3584 (comm->cell_x1[dim] - comm->cell_x0[dim])*ddbox->skew_fac[dim] <
3585 comm->cellsize_min[dim])
3588 gmx_fatal(FARGS,"Step %s: The %c-size (%f) times the triclinic skew factor (%f) is smaller than the smallest allowed cell size (%f) for domain decomposition grid cell %d %d %d",
3589 gmx_step_str(step,buf),dim2char(dim),
3590 comm->cell_x1[dim] - comm->cell_x0[dim],
3591 ddbox->skew_fac[dim],
3592 dd->comm->cellsize_min[dim],
3593 dd->ci[XX],dd->ci[YY],dd->ci[ZZ]);
3597 if ((dd->bGridJump && dd->ndim > 1) || ddbox->nboundeddim < DIM)
3599 /* Communicate the boundaries and update cell_ns_x0/1 */
3600 dd_move_cellx(dd,ddbox,cell_ns_x0,cell_ns_x1);
3601 if (dd->bGridJump && dd->ndim > 1)
3603 check_grid_jump(step,dd,ddbox);
3608 static void make_tric_corr_matrix(int npbcdim,matrix box,matrix tcm)
3612 tcm[YY][XX] = -box[YY][XX]/box[YY][YY];
3620 tcm[ZZ][XX] = -(box[ZZ][YY]*tcm[YY][XX] + box[ZZ][XX])/box[ZZ][ZZ];
3621 tcm[ZZ][YY] = -box[ZZ][YY]/box[ZZ][ZZ];
3630 static void check_screw_box(matrix box)
3632 /* Mathematical limitation */
3633 if (box[YY][XX] != 0 || box[ZZ][XX] != 0)
3635 gmx_fatal(FARGS,"With screw pbc the unit cell can not have non-zero off-diagonal x-components");
3638 /* Limitation due to the asymmetry of the eighth shell method */
3639 if (box[ZZ][YY] != 0)
3641 gmx_fatal(FARGS,"pbc=screw with non-zero box_zy is not supported");
3645 static void distribute_cg(FILE *fplog,gmx_large_int_t step,
3646 matrix box,ivec tric_dir,t_block *cgs,rvec pos[],
3649 gmx_domdec_master_t *ma;
3650 int **tmp_ind=NULL,*tmp_nalloc=NULL;
3651 int i,icg,j,k,k0,k1,d,npbcdim;
3653 rvec box_size,cg_cm;
3655 real nrcg,inv_ncg,pos_d;
3657 gmx_bool bUnbounded,bScrew;
3661 if (tmp_ind == NULL)
3663 snew(tmp_nalloc,dd->nnodes);
3664 snew(tmp_ind,dd->nnodes);
3665 for(i=0; i<dd->nnodes; i++)
3667 tmp_nalloc[i] = over_alloc_large(cgs->nr/dd->nnodes+1);
3668 snew(tmp_ind[i],tmp_nalloc[i]);
3672 /* Clear the count */
3673 for(i=0; i<dd->nnodes; i++)
3679 make_tric_corr_matrix(dd->npbcdim,box,tcm);
3681 cgindex = cgs->index;
3683 /* Compute the center of geometry for all charge groups */
3684 for(icg=0; icg<cgs->nr; icg++)
3687 k1 = cgindex[icg+1];
3691 copy_rvec(pos[k0],cg_cm);
3698 for(k=k0; (k<k1); k++)
3700 rvec_inc(cg_cm,pos[k]);
3702 for(d=0; (d<DIM); d++)
3704 cg_cm[d] *= inv_ncg;
3707 /* Put the charge group in the box and determine the cell index */
3708 for(d=DIM-1; d>=0; d--) {
3710 if (d < dd->npbcdim)
3712 bScrew = (dd->bScrewPBC && d == XX);
3713 if (tric_dir[d] && dd->nc[d] > 1)
3715 /* Use triclinic coordintates for this dimension */
3716 for(j=d+1; j<DIM; j++)
3718 pos_d += cg_cm[j]*tcm[j][d];
3721 while(pos_d >= box[d][d])
3724 rvec_dec(cg_cm,box[d]);
3727 cg_cm[YY] = box[YY][YY] - cg_cm[YY];
3728 cg_cm[ZZ] = box[ZZ][ZZ] - cg_cm[ZZ];
3730 for(k=k0; (k<k1); k++)
3732 rvec_dec(pos[k],box[d]);
3735 pos[k][YY] = box[YY][YY] - pos[k][YY];
3736 pos[k][ZZ] = box[ZZ][ZZ] - pos[k][ZZ];
3743 rvec_inc(cg_cm,box[d]);
3746 cg_cm[YY] = box[YY][YY] - cg_cm[YY];
3747 cg_cm[ZZ] = box[ZZ][ZZ] - cg_cm[ZZ];
3749 for(k=k0; (k<k1); k++)
3751 rvec_inc(pos[k],box[d]);
3753 pos[k][YY] = box[YY][YY] - pos[k][YY];
3754 pos[k][ZZ] = box[ZZ][ZZ] - pos[k][ZZ];
3759 /* This could be done more efficiently */
3761 while(ind[d]+1 < dd->nc[d] && pos_d >= ma->cell_x[d][ind[d]+1])
3766 i = dd_index(dd->nc,ind);
3767 if (ma->ncg[i] == tmp_nalloc[i])
3769 tmp_nalloc[i] = over_alloc_large(ma->ncg[i]+1);
3770 srenew(tmp_ind[i],tmp_nalloc[i]);
3772 tmp_ind[i][ma->ncg[i]] = icg;
3774 ma->nat[i] += cgindex[icg+1] - cgindex[icg];
3778 for(i=0; i<dd->nnodes; i++)
3781 for(k=0; k<ma->ncg[i]; k++)
3783 ma->cg[k1++] = tmp_ind[i][k];
3786 ma->index[dd->nnodes] = k1;
3788 for(i=0; i<dd->nnodes; i++)
3798 fprintf(fplog,"Charge group distribution at step %s:",
3799 gmx_step_str(step,buf));
3800 for(i=0; i<dd->nnodes; i++)
3802 fprintf(fplog," %d",ma->ncg[i]);
3804 fprintf(fplog,"\n");
3808 static void get_cg_distribution(FILE *fplog,gmx_large_int_t step,gmx_domdec_t *dd,
3809 t_block *cgs,matrix box,gmx_ddbox_t *ddbox,
3812 gmx_domdec_master_t *ma=NULL;
3815 int *ibuf,buf2[2] = { 0, 0 };
3823 check_screw_box(box);
3826 set_dd_cell_sizes_slb(dd,ddbox,TRUE,npulse);
3828 distribute_cg(fplog,step,box,ddbox->tric_dir,cgs,pos,dd);
3829 for(i=0; i<dd->nnodes; i++)
3831 ma->ibuf[2*i] = ma->ncg[i];
3832 ma->ibuf[2*i+1] = ma->nat[i];
3840 dd_scatter(dd,2*sizeof(int),ibuf,buf2);
3842 dd->ncg_home = buf2[0];
3843 dd->nat_home = buf2[1];
3844 dd->ncg_tot = dd->ncg_home;
3845 dd->nat_tot = dd->nat_home;
3846 if (dd->ncg_home > dd->cg_nalloc || dd->cg_nalloc == 0)
3848 dd->cg_nalloc = over_alloc_dd(dd->ncg_home);
3849 srenew(dd->index_gl,dd->cg_nalloc);
3850 srenew(dd->cgindex,dd->cg_nalloc+1);
3854 for(i=0; i<dd->nnodes; i++)
3856 ma->ibuf[i] = ma->ncg[i]*sizeof(int);
3857 ma->ibuf[dd->nnodes+i] = ma->index[i]*sizeof(int);
3862 DDMASTER(dd) ? ma->ibuf : NULL,
3863 DDMASTER(dd) ? ma->ibuf+dd->nnodes : NULL,
3864 DDMASTER(dd) ? ma->cg : NULL,
3865 dd->ncg_home*sizeof(int),dd->index_gl);
3867 /* Determine the home charge group sizes */
3869 for(i=0; i<dd->ncg_home; i++)
3871 cg_gl = dd->index_gl[i];
3873 dd->cgindex[i] + cgs->index[cg_gl+1] - cgs->index[cg_gl];
3878 fprintf(debug,"Home charge groups:\n");
3879 for(i=0; i<dd->ncg_home; i++)
3881 fprintf(debug," %d",dd->index_gl[i]);
3883 fprintf(debug,"\n");
3885 fprintf(debug,"\n");
3889 static int compact_and_copy_vec_at(int ncg,int *move,
3892 rvec *src,gmx_domdec_comm_t *comm,
3895 int m,icg,i,i0,i1,nrcg;
3901 for(m=0; m<DIM*2; m++)
3907 for(icg=0; icg<ncg; icg++)
3909 i1 = cgindex[icg+1];
3915 /* Compact the home array in place */
3916 for(i=i0; i<i1; i++)
3918 copy_rvec(src[i],src[home_pos++]);
3924 /* Copy to the communication buffer */
3926 pos_vec[m] += 1 + vec*nrcg;
3927 for(i=i0; i<i1; i++)
3929 copy_rvec(src[i],comm->cgcm_state[m][pos_vec[m]++]);
3931 pos_vec[m] += (nvec - vec - 1)*nrcg;
3935 home_pos += i1 - i0;
3943 static int compact_and_copy_vec_cg(int ncg,int *move,
3945 int nvec,rvec *src,gmx_domdec_comm_t *comm,
3948 int m,icg,i0,i1,nrcg;
3954 for(m=0; m<DIM*2; m++)
3960 for(icg=0; icg<ncg; icg++)
3962 i1 = cgindex[icg+1];
3968 /* Compact the home array in place */
3969 copy_rvec(src[icg],src[home_pos++]);
3975 /* Copy to the communication buffer */
3976 copy_rvec(src[icg],comm->cgcm_state[m][pos_vec[m]]);
3977 pos_vec[m] += 1 + nrcg*nvec;
3989 static int compact_ind(int ncg,int *move,
3990 int *index_gl,int *cgindex,
3992 gmx_ga2la_t ga2la,char *bLocalCG,
3995 int cg,nat,a0,a1,a,a_gl;
4000 for(cg=0; cg<ncg; cg++)
4006 /* Compact the home arrays in place.
4007 * Anything that can be done here avoids access to global arrays.
4009 cgindex[home_pos] = nat;
4010 for(a=a0; a<a1; a++)
4013 gatindex[nat] = a_gl;
4014 /* The cell number stays 0, so we don't need to set it */
4015 ga2la_change_la(ga2la,a_gl,nat);
4018 index_gl[home_pos] = index_gl[cg];
4019 cginfo[home_pos] = cginfo[cg];
4020 /* The charge group remains local, so bLocalCG does not change */
4025 /* Clear the global indices */
4026 for(a=a0; a<a1; a++)
4028 ga2la_del(ga2la,gatindex[a]);
4032 bLocalCG[index_gl[cg]] = FALSE;
4036 cgindex[home_pos] = nat;
4041 static void clear_and_mark_ind(int ncg,int *move,
4042 int *index_gl,int *cgindex,int *gatindex,
4043 gmx_ga2la_t ga2la,char *bLocalCG,
4048 for(cg=0; cg<ncg; cg++)
4054 /* Clear the global indices */
4055 for(a=a0; a<a1; a++)
4057 ga2la_del(ga2la,gatindex[a]);
4061 bLocalCG[index_gl[cg]] = FALSE;
4063 /* Signal that this cg has moved using the ns cell index.
4064 * Here we set it to -1.
4065 * fill_grid will change it from -1 to 4*grid->ncells.
4067 cell_index[cg] = -1;
4072 static void print_cg_move(FILE *fplog,
4074 gmx_large_int_t step,int cg,int dim,int dir,
4075 gmx_bool bHaveLimitdAndCMOld,real limitd,
4076 rvec cm_old,rvec cm_new,real pos_d)
4078 gmx_domdec_comm_t *comm;
4083 fprintf(fplog,"\nStep %s:\n",gmx_step_str(step,buf));
4084 if (bHaveLimitdAndCMOld)
4086 fprintf(fplog,"The charge group starting at atom %d moved than the distance allowed by the domain decomposition (%f) in direction %c\n",
4087 ddglatnr(dd,dd->cgindex[cg]),limitd,dim2char(dim));
4091 fprintf(fplog,"The charge group starting at atom %d moved than the distance allowed by the domain decomposition in direction %c\n",
4092 ddglatnr(dd,dd->cgindex[cg]),dim2char(dim));
4094 fprintf(fplog,"distance out of cell %f\n",
4095 dir==1 ? pos_d - comm->cell_x1[dim] : pos_d - comm->cell_x0[dim]);
4096 if (bHaveLimitdAndCMOld)
4098 fprintf(fplog,"Old coordinates: %8.3f %8.3f %8.3f\n",
4099 cm_old[XX],cm_old[YY],cm_old[ZZ]);
4101 fprintf(fplog,"New coordinates: %8.3f %8.3f %8.3f\n",
4102 cm_new[XX],cm_new[YY],cm_new[ZZ]);
4103 fprintf(fplog,"Old cell boundaries in direction %c: %8.3f %8.3f\n",
4105 comm->old_cell_x0[dim],comm->old_cell_x1[dim]);
4106 fprintf(fplog,"New cell boundaries in direction %c: %8.3f %8.3f\n",
4108 comm->cell_x0[dim],comm->cell_x1[dim]);
4111 static void cg_move_error(FILE *fplog,
4113 gmx_large_int_t step,int cg,int dim,int dir,
4114 gmx_bool bHaveLimitdAndCMOld,real limitd,
4115 rvec cm_old,rvec cm_new,real pos_d)
4119 print_cg_move(fplog, dd,step,cg,dim,dir,
4120 bHaveLimitdAndCMOld,limitd,cm_old,cm_new,pos_d);
4122 print_cg_move(stderr,dd,step,cg,dim,dir,
4123 bHaveLimitdAndCMOld,limitd,cm_old,cm_new,pos_d);
4125 "A charge group moved too far between two domain decomposition steps\n"
4126 "This usually means that your system is not well equilibrated");
4129 static void rotate_state_atom(t_state *state,int a)
4133 for(est=0; est<estNR; est++)
4135 if (EST_DISTR(est) && (state->flags & (1<<est))) {
4138 /* Rotate the complete state; for a rectangular box only */
4139 state->x[a][YY] = state->box[YY][YY] - state->x[a][YY];
4140 state->x[a][ZZ] = state->box[ZZ][ZZ] - state->x[a][ZZ];
4143 state->v[a][YY] = -state->v[a][YY];
4144 state->v[a][ZZ] = -state->v[a][ZZ];
4147 state->sd_X[a][YY] = -state->sd_X[a][YY];
4148 state->sd_X[a][ZZ] = -state->sd_X[a][ZZ];
4151 state->cg_p[a][YY] = -state->cg_p[a][YY];
4152 state->cg_p[a][ZZ] = -state->cg_p[a][ZZ];
4154 case estDISRE_INITF:
4155 case estDISRE_RM3TAV:
4156 case estORIRE_INITF:
4158 /* These are distances, so not affected by rotation */
4161 gmx_incons("Unknown state entry encountered in rotate_state_atom");
4167 static int dd_redistribute_cg(FILE *fplog,gmx_large_int_t step,
4168 gmx_domdec_t *dd,ivec tric_dir,
4169 t_state *state,rvec **f,
4170 t_forcerec *fr,t_mdatoms *md,
4176 int ncg[DIM*2],nat[DIM*2];
4177 int c,i,cg,k,k0,k1,d,dim,dim2,dir,d2,d3,d4,cell_d;
4178 int mc,cdd,nrcg,ncg_recv,nat_recv,nvs,nvr,nvec,vec;
4179 int sbuf[2],rbuf[2];
4180 int home_pos_cg,home_pos_at,ncg_stay_home,buf_pos;
4182 gmx_bool bV=FALSE,bSDX=FALSE,bCGP=FALSE;
4187 rvec *cg_cm,cell_x0,cell_x1,limitd,limit0,limit1,cm_new;
4189 cginfo_mb_t *cginfo_mb;
4190 gmx_domdec_comm_t *comm;
4194 check_screw_box(state->box);
4200 for(i=0; i<estNR; i++)
4206 case estX: /* Always present */ break;
4207 case estV: bV = (state->flags & (1<<i)); break;
4208 case estSDX: bSDX = (state->flags & (1<<i)); break;
4209 case estCGP: bCGP = (state->flags & (1<<i)); break;
4212 case estDISRE_INITF:
4213 case estDISRE_RM3TAV:
4214 case estORIRE_INITF:
4216 /* No processing required */
4219 gmx_incons("Unknown state entry encountered in dd_redistribute_cg");
4224 if (dd->ncg_tot > comm->nalloc_int)
4226 comm->nalloc_int = over_alloc_dd(dd->ncg_tot);
4227 srenew(comm->buf_int,comm->nalloc_int);
4229 move = comm->buf_int;
4231 /* Clear the count */
4232 for(c=0; c<dd->ndim*2; c++)
4238 npbcdim = dd->npbcdim;
4240 for(d=0; (d<DIM); d++)
4242 limitd[d] = dd->comm->cellsize_min[d];
4243 if (d >= npbcdim && dd->ci[d] == 0)
4245 cell_x0[d] = -GMX_FLOAT_MAX;
4249 cell_x0[d] = comm->cell_x0[d];
4251 if (d >= npbcdim && dd->ci[d] == dd->nc[d] - 1)
4253 cell_x1[d] = GMX_FLOAT_MAX;
4257 cell_x1[d] = comm->cell_x1[d];
4261 limit0[d] = comm->old_cell_x0[d] - limitd[d];
4262 limit1[d] = comm->old_cell_x1[d] + limitd[d];
4266 /* We check after communication if a charge group moved
4267 * more than one cell. Set the pre-comm check limit to float_max.
4269 limit0[d] = -GMX_FLOAT_MAX;
4270 limit1[d] = GMX_FLOAT_MAX;
4274 make_tric_corr_matrix(npbcdim,state->box,tcm);
4276 cgindex = dd->cgindex;
4278 /* Compute the center of geometry for all home charge groups
4279 * and put them in the box and determine where they should go.
4281 for(cg=0; cg<dd->ncg_home; cg++)
4288 copy_rvec(state->x[k0],cm_new);
4295 for(k=k0; (k<k1); k++)
4297 rvec_inc(cm_new,state->x[k]);
4299 for(d=0; (d<DIM); d++)
4301 cm_new[d] = inv_ncg*cm_new[d];
4306 /* Do pbc and check DD cell boundary crossings */
4307 for(d=DIM-1; d>=0; d--)
4311 bScrew = (dd->bScrewPBC && d == XX);
4312 /* Determine the location of this cg in lattice coordinates */
4316 for(d2=d+1; d2<DIM; d2++)
4318 pos_d += cm_new[d2]*tcm[d2][d];
4321 /* Put the charge group in the triclinic unit-cell */
4322 if (pos_d >= cell_x1[d])
4324 if (pos_d >= limit1[d])
4326 cg_move_error(fplog,dd,step,cg,d,1,TRUE,limitd[d],
4327 cg_cm[cg],cm_new,pos_d);
4330 if (dd->ci[d] == dd->nc[d] - 1)
4332 rvec_dec(cm_new,state->box[d]);
4335 cm_new[YY] = state->box[YY][YY] - cm_new[YY];
4336 cm_new[ZZ] = state->box[ZZ][ZZ] - cm_new[ZZ];
4338 for(k=k0; (k<k1); k++)
4340 rvec_dec(state->x[k],state->box[d]);
4343 rotate_state_atom(state,k);
4348 else if (pos_d < cell_x0[d])
4350 if (pos_d < limit0[d])
4352 cg_move_error(fplog,dd,step,cg,d,-1,TRUE,limitd[d],
4353 cg_cm[cg],cm_new,pos_d);
4358 rvec_inc(cm_new,state->box[d]);
4361 cm_new[YY] = state->box[YY][YY] - cm_new[YY];
4362 cm_new[ZZ] = state->box[ZZ][ZZ] - cm_new[ZZ];
4364 for(k=k0; (k<k1); k++)
4366 rvec_inc(state->x[k],state->box[d]);
4369 rotate_state_atom(state,k);
4375 else if (d < npbcdim)
4377 /* Put the charge group in the rectangular unit-cell */
4378 while (cm_new[d] >= state->box[d][d])
4380 rvec_dec(cm_new,state->box[d]);
4381 for(k=k0; (k<k1); k++)
4383 rvec_dec(state->x[k],state->box[d]);
4386 while (cm_new[d] < 0)
4388 rvec_inc(cm_new,state->box[d]);
4389 for(k=k0; (k<k1); k++)
4391 rvec_inc(state->x[k],state->box[d]);
4397 copy_rvec(cm_new,cg_cm[cg]);
4399 /* Determine where this cg should go */
4402 for(d=0; d<dd->ndim; d++)
4407 flag |= DD_FLAG_FW(d);
4413 else if (dev[dim] == -1)
4415 flag |= DD_FLAG_BW(d);
4417 if (dd->nc[dim] > 2)
4431 if (ncg[mc]+1 > comm->cggl_flag_nalloc[mc])
4433 comm->cggl_flag_nalloc[mc] = over_alloc_dd(ncg[mc]+1);
4434 srenew(comm->cggl_flag[mc],comm->cggl_flag_nalloc[mc]*DD_CGIBS);
4436 comm->cggl_flag[mc][ncg[mc]*DD_CGIBS ] = dd->index_gl[cg];
4437 /* We store the cg size in the lower 16 bits
4438 * and the place where the charge group should go
4439 * in the next 6 bits. This saves some communication volume.
4441 comm->cggl_flag[mc][ncg[mc]*DD_CGIBS+1] = nrcg | flag;
4447 inc_nrnb(nrnb,eNR_CGCM,dd->nat_home);
4448 inc_nrnb(nrnb,eNR_RESETX,dd->ncg_home);
4464 /* Make sure the communication buffers are large enough */
4465 for(mc=0; mc<dd->ndim*2; mc++)
4467 nvr = ncg[mc] + nat[mc]*nvec;
4468 if (nvr > comm->cgcm_state_nalloc[mc])
4470 comm->cgcm_state_nalloc[mc] = over_alloc_dd(nvr);
4471 srenew(comm->cgcm_state[mc],comm->cgcm_state_nalloc[mc]);
4475 /* Recalculating cg_cm might be cheaper than communicating,
4476 * but that could give rise to rounding issues.
4479 compact_and_copy_vec_cg(dd->ncg_home,move,cgindex,
4480 nvec,cg_cm,comm,bCompact);
4484 compact_and_copy_vec_at(dd->ncg_home,move,cgindex,
4485 nvec,vec++,state->x,comm,bCompact);
4488 compact_and_copy_vec_at(dd->ncg_home,move,cgindex,
4489 nvec,vec++,state->v,comm,bCompact);
4493 compact_and_copy_vec_at(dd->ncg_home,move,cgindex,
4494 nvec,vec++,state->sd_X,comm,bCompact);
4498 compact_and_copy_vec_at(dd->ncg_home,move,cgindex,
4499 nvec,vec++,state->cg_p,comm,bCompact);
4504 compact_ind(dd->ncg_home,move,
4505 dd->index_gl,dd->cgindex,dd->gatindex,
4506 dd->ga2la,comm->bLocalCG,
4511 clear_and_mark_ind(dd->ncg_home,move,
4512 dd->index_gl,dd->cgindex,dd->gatindex,
4513 dd->ga2la,comm->bLocalCG,
4514 fr->ns.grid->cell_index);
4517 cginfo_mb = fr->cginfo_mb;
4519 ncg_stay_home = home_pos_cg;
4520 for(d=0; d<dd->ndim; d++)
4526 for(dir=0; dir<(dd->nc[dim]==2 ? 1 : 2); dir++)
4529 /* Communicate the cg and atom counts */
4534 fprintf(debug,"Sending ddim %d dir %d: ncg %d nat %d\n",
4535 d,dir,sbuf[0],sbuf[1]);
4537 dd_sendrecv_int(dd, d, dir, sbuf, 2, rbuf, 2);
4539 if ((ncg_recv+rbuf[0])*DD_CGIBS > comm->nalloc_int)
4541 comm->nalloc_int = over_alloc_dd((ncg_recv+rbuf[0])*DD_CGIBS);
4542 srenew(comm->buf_int,comm->nalloc_int);
4545 /* Communicate the charge group indices, sizes and flags */
4546 dd_sendrecv_int(dd, d, dir,
4547 comm->cggl_flag[cdd], sbuf[0]*DD_CGIBS,
4548 comm->buf_int+ncg_recv*DD_CGIBS, rbuf[0]*DD_CGIBS);
4550 nvs = ncg[cdd] + nat[cdd]*nvec;
4551 i = rbuf[0] + rbuf[1] *nvec;
4552 vec_rvec_check_alloc(&comm->vbuf,nvr+i);
4554 /* Communicate cgcm and state */
4555 dd_sendrecv_rvec(dd, d, dir,
4556 comm->cgcm_state[cdd], nvs,
4557 comm->vbuf.v+nvr, i);
4558 ncg_recv += rbuf[0];
4559 nat_recv += rbuf[1];
4563 /* Process the received charge groups */
4565 for(cg=0; cg<ncg_recv; cg++)
4567 flag = comm->buf_int[cg*DD_CGIBS+1];
4569 if (dim >= npbcdim && dd->nc[dim] > 2)
4571 /* No pbc in this dim and more than one domain boundary.
4572 * We to a separate check if a charge did not move too far.
4574 if (((flag & DD_FLAG_FW(d)) &&
4575 comm->vbuf.v[buf_pos][d] > cell_x1[dim]) ||
4576 ((flag & DD_FLAG_BW(d)) &&
4577 comm->vbuf.v[buf_pos][d] < cell_x0[dim]))
4579 cg_move_error(fplog,dd,step,cg,d,
4580 (flag & DD_FLAG_FW(d)) ? 1 : 0,
4582 comm->vbuf.v[buf_pos],
4583 comm->vbuf.v[buf_pos],
4584 comm->vbuf.v[buf_pos][d]);
4591 /* Check which direction this cg should go */
4592 for(d2=d+1; (d2<dd->ndim && mc==-1); d2++)
4596 /* The cell boundaries for dimension d2 are not equal
4597 * for each cell row of the lower dimension(s),
4598 * therefore we might need to redetermine where
4599 * this cg should go.
4602 /* If this cg crosses the box boundary in dimension d2
4603 * we can use the communicated flag, so we do not
4604 * have to worry about pbc.
4606 if (!((dd->ci[dim2] == dd->nc[dim2]-1 &&
4607 (flag & DD_FLAG_FW(d2))) ||
4608 (dd->ci[dim2] == 0 &&
4609 (flag & DD_FLAG_BW(d2)))))
4611 /* Clear the two flags for this dimension */
4612 flag &= ~(DD_FLAG_FW(d2) | DD_FLAG_BW(d2));
4613 /* Determine the location of this cg
4614 * in lattice coordinates
4616 pos_d = comm->vbuf.v[buf_pos][dim2];
4619 for(d3=dim2+1; d3<DIM; d3++)
4622 comm->vbuf.v[buf_pos][d3]*tcm[d3][dim2];
4625 /* Check of we are not at the box edge.
4626 * pbc is only handled in the first step above,
4627 * but this check could move over pbc while
4628 * the first step did not due to different rounding.
4630 if (pos_d >= cell_x1[dim2] &&
4631 dd->ci[dim2] != dd->nc[dim2]-1)
4633 flag |= DD_FLAG_FW(d2);
4635 else if (pos_d < cell_x0[dim2] &&
4638 flag |= DD_FLAG_BW(d2);
4640 comm->buf_int[cg*DD_CGIBS+1] = flag;
4643 /* Set to which neighboring cell this cg should go */
4644 if (flag & DD_FLAG_FW(d2))
4648 else if (flag & DD_FLAG_BW(d2))
4650 if (dd->nc[dd->dim[d2]] > 2)
4662 nrcg = flag & DD_FLAG_NRCG;
4665 if (home_pos_cg+1 > dd->cg_nalloc)
4667 dd->cg_nalloc = over_alloc_dd(home_pos_cg+1);
4668 srenew(dd->index_gl,dd->cg_nalloc);
4669 srenew(dd->cgindex,dd->cg_nalloc+1);
4671 /* Set the global charge group index and size */
4672 dd->index_gl[home_pos_cg] = comm->buf_int[cg*DD_CGIBS];
4673 dd->cgindex[home_pos_cg+1] = dd->cgindex[home_pos_cg] + nrcg;
4674 /* Copy the state from the buffer */
4675 if (home_pos_cg >= fr->cg_nalloc)
4677 dd_realloc_fr_cg(fr,home_pos_cg+1);
4680 copy_rvec(comm->vbuf.v[buf_pos++],cg_cm[home_pos_cg]);
4681 /* Set the cginfo */
4682 fr->cginfo[home_pos_cg] = ddcginfo(cginfo_mb,
4683 dd->index_gl[home_pos_cg]);
4686 comm->bLocalCG[dd->index_gl[home_pos_cg]] = TRUE;
4689 if (home_pos_at+nrcg > state->nalloc)
4691 dd_realloc_state(state,f,home_pos_at+nrcg);
4693 for(i=0; i<nrcg; i++)
4695 copy_rvec(comm->vbuf.v[buf_pos++],
4696 state->x[home_pos_at+i]);
4700 for(i=0; i<nrcg; i++)
4702 copy_rvec(comm->vbuf.v[buf_pos++],
4703 state->v[home_pos_at+i]);
4708 for(i=0; i<nrcg; i++)
4710 copy_rvec(comm->vbuf.v[buf_pos++],
4711 state->sd_X[home_pos_at+i]);
4716 for(i=0; i<nrcg; i++)
4718 copy_rvec(comm->vbuf.v[buf_pos++],
4719 state->cg_p[home_pos_at+i]);
4723 home_pos_at += nrcg;
4727 /* Reallocate the buffers if necessary */
4728 if (ncg[mc]+1 > comm->cggl_flag_nalloc[mc])
4730 comm->cggl_flag_nalloc[mc] = over_alloc_dd(ncg[mc]+1);
4731 srenew(comm->cggl_flag[mc],comm->cggl_flag_nalloc[mc]*DD_CGIBS);
4733 nvr = ncg[mc] + nat[mc]*nvec;
4734 if (nvr + 1 + nrcg*nvec > comm->cgcm_state_nalloc[mc])
4736 comm->cgcm_state_nalloc[mc] = over_alloc_dd(nvr + 1 + nrcg*nvec);
4737 srenew(comm->cgcm_state[mc],comm->cgcm_state_nalloc[mc]);
4739 /* Copy from the receive to the send buffers */
4740 memcpy(comm->cggl_flag[mc] + ncg[mc]*DD_CGIBS,
4741 comm->buf_int + cg*DD_CGIBS,
4742 DD_CGIBS*sizeof(int));
4743 memcpy(comm->cgcm_state[mc][nvr],
4744 comm->vbuf.v[buf_pos],
4745 (1+nrcg*nvec)*sizeof(rvec));
4746 buf_pos += 1 + nrcg*nvec;
4753 /* With sorting (!bCompact) the indices are now only partially up to date
4754 * and ncg_home and nat_home are not the real count, since there are
4755 * "holes" in the arrays for the charge groups that moved to neighbors.
4757 dd->ncg_home = home_pos_cg;
4758 dd->nat_home = home_pos_at;
4762 fprintf(debug,"Finished repartitioning\n");
4765 return ncg_stay_home;
4768 void dd_cycles_add(gmx_domdec_t *dd,float cycles,int ddCycl)
4770 dd->comm->cycl[ddCycl] += cycles;
4771 dd->comm->cycl_n[ddCycl]++;
4772 if (cycles > dd->comm->cycl_max[ddCycl])
4774 dd->comm->cycl_max[ddCycl] = cycles;
4778 static double force_flop_count(t_nrnb *nrnb)
4785 for(i=eNR_NBKERNEL010; i<eNR_NBKERNEL_FREE_ENERGY; i++)
4787 /* To get closer to the real timings, we half the count
4788 * for the normal loops and again half it for water loops.
4791 if (strstr(name,"W3") != NULL || strstr(name,"W4") != NULL)
4793 sum += nrnb->n[i]*0.25*cost_nrnb(i);
4797 sum += nrnb->n[i]*0.50*cost_nrnb(i);
4800 for(i=eNR_NBKERNEL_FREE_ENERGY; i<=eNR_NB14; i++)
4803 if (strstr(name,"W3") != NULL || strstr(name,"W4") != NULL)
4804 sum += nrnb->n[i]*cost_nrnb(i);
4806 for(i=eNR_BONDS; i<=eNR_WALLS; i++)
4808 sum += nrnb->n[i]*cost_nrnb(i);
4814 void dd_force_flop_start(gmx_domdec_t *dd,t_nrnb *nrnb)
4816 if (dd->comm->eFlop)
4818 dd->comm->flop -= force_flop_count(nrnb);
4821 void dd_force_flop_stop(gmx_domdec_t *dd,t_nrnb *nrnb)
4823 if (dd->comm->eFlop)
4825 dd->comm->flop += force_flop_count(nrnb);
4830 static void clear_dd_cycle_counts(gmx_domdec_t *dd)
4834 for(i=0; i<ddCyclNr; i++)
4836 dd->comm->cycl[i] = 0;
4837 dd->comm->cycl_n[i] = 0;
4838 dd->comm->cycl_max[i] = 0;
4841 dd->comm->flop_n = 0;
4844 static void get_load_distribution(gmx_domdec_t *dd,gmx_wallcycle_t wcycle)
4846 gmx_domdec_comm_t *comm;
4847 gmx_domdec_load_t *load;
4848 gmx_domdec_root_t *root=NULL;
4849 int d,dim,cid,i,pos;
4850 float cell_frac=0,sbuf[DD_NLOAD_MAX];
4855 fprintf(debug,"get_load_distribution start\n");
4858 wallcycle_start(wcycle,ewcDDCOMMLOAD);
4862 bSepPME = (dd->pme_nodeid >= 0);
4864 for(d=dd->ndim-1; d>=0; d--)
4867 /* Check if we participate in the communication in this dimension */
4868 if (d == dd->ndim-1 ||
4869 (dd->ci[dd->dim[d+1]]==0 && dd->ci[dd->dim[dd->ndim-1]]==0))
4871 load = &comm->load[d];
4874 cell_frac = comm->cell_f1[d] - comm->cell_f0[d];
4877 if (d == dd->ndim-1)
4879 sbuf[pos++] = dd_force_load(comm);
4880 sbuf[pos++] = sbuf[0];
4883 sbuf[pos++] = sbuf[0];
4884 sbuf[pos++] = cell_frac;
4887 sbuf[pos++] = comm->cell_f_max0[d];
4888 sbuf[pos++] = comm->cell_f_min1[d];
4893 sbuf[pos++] = comm->cycl[ddCyclPPduringPME];
4894 sbuf[pos++] = comm->cycl[ddCyclPME];
4899 sbuf[pos++] = comm->load[d+1].sum;
4900 sbuf[pos++] = comm->load[d+1].max;
4903 sbuf[pos++] = comm->load[d+1].sum_m;
4904 sbuf[pos++] = comm->load[d+1].cvol_min*cell_frac;
4905 sbuf[pos++] = comm->load[d+1].flags;
4908 sbuf[pos++] = comm->cell_f_max0[d];
4909 sbuf[pos++] = comm->cell_f_min1[d];
4914 sbuf[pos++] = comm->load[d+1].mdf;
4915 sbuf[pos++] = comm->load[d+1].pme;
4919 /* Communicate a row in DD direction d.
4920 * The communicators are setup such that the root always has rank 0.
4923 MPI_Gather(sbuf ,load->nload*sizeof(float),MPI_BYTE,
4924 load->load,load->nload*sizeof(float),MPI_BYTE,
4925 0,comm->mpi_comm_load[d]);
4927 if (dd->ci[dim] == dd->master_ci[dim])
4929 /* We are the root, process this row */
4930 if (comm->bDynLoadBal)
4932 root = comm->root[d];
4942 for(i=0; i<dd->nc[dim]; i++)
4944 load->sum += load->load[pos++];
4945 load->max = max(load->max,load->load[pos]);
4951 /* This direction could not be load balanced properly,
4952 * therefore we need to use the maximum iso the average load.
4954 load->sum_m = max(load->sum_m,load->load[pos]);
4958 load->sum_m += load->load[pos];
4961 load->cvol_min = min(load->cvol_min,load->load[pos]);
4965 load->flags = (int)(load->load[pos++] + 0.5);
4969 root->cell_f_max0[i] = load->load[pos++];
4970 root->cell_f_min1[i] = load->load[pos++];
4975 load->mdf = max(load->mdf,load->load[pos]);
4977 load->pme = max(load->pme,load->load[pos]);
4981 if (comm->bDynLoadBal && root->bLimited)
4983 load->sum_m *= dd->nc[dim];
4984 load->flags |= (1<<d);
4992 comm->nload += dd_load_count(comm);
4993 comm->load_step += comm->cycl[ddCyclStep];
4994 comm->load_sum += comm->load[0].sum;
4995 comm->load_max += comm->load[0].max;
4996 if (comm->bDynLoadBal)
4998 for(d=0; d<dd->ndim; d++)
5000 if (comm->load[0].flags & (1<<d))
5002 comm->load_lim[d]++;
5008 comm->load_mdf += comm->load[0].mdf;
5009 comm->load_pme += comm->load[0].pme;
5013 wallcycle_stop(wcycle,ewcDDCOMMLOAD);
5017 fprintf(debug,"get_load_distribution finished\n");
5021 static float dd_force_imb_perf_loss(gmx_domdec_t *dd)
5023 /* Return the relative performance loss on the total run time
5024 * due to the force calculation load imbalance.
5026 if (dd->comm->nload > 0)
5029 (dd->comm->load_max*dd->nnodes - dd->comm->load_sum)/
5030 (dd->comm->load_step*dd->nnodes);
5038 static void print_dd_load_av(FILE *fplog,gmx_domdec_t *dd)
5041 int npp,npme,nnodes,d,limp;
5042 float imbal,pme_f_ratio,lossf,lossp=0;
5044 gmx_domdec_comm_t *comm;
5047 if (DDMASTER(dd) && comm->nload > 0)
5050 npme = (dd->pme_nodeid >= 0) ? comm->npmenodes : 0;
5051 nnodes = npp + npme;
5052 imbal = comm->load_max*npp/comm->load_sum - 1;
5053 lossf = dd_force_imb_perf_loss(dd);
5054 sprintf(buf," Average load imbalance: %.1f %%\n",imbal*100);
5055 fprintf(fplog,"%s",buf);
5056 fprintf(stderr,"\n");
5057 fprintf(stderr,"%s",buf);
5058 sprintf(buf," Part of the total run time spent waiting due to load imbalance: %.1f %%\n",lossf*100);
5059 fprintf(fplog,"%s",buf);
5060 fprintf(stderr,"%s",buf);
5062 if (comm->bDynLoadBal)
5064 sprintf(buf," Steps where the load balancing was limited by -rdd, -rcon and/or -dds:");
5065 for(d=0; d<dd->ndim; d++)
5067 limp = (200*comm->load_lim[d]+1)/(2*comm->nload);
5068 sprintf(buf+strlen(buf)," %c %d %%",dim2char(dd->dim[d]),limp);
5074 sprintf(buf+strlen(buf),"\n");
5075 fprintf(fplog,"%s",buf);
5076 fprintf(stderr,"%s",buf);
5080 pme_f_ratio = comm->load_pme/comm->load_mdf;
5081 lossp = (comm->load_pme -comm->load_mdf)/comm->load_step;
5084 lossp *= (float)npme/(float)nnodes;
5088 lossp *= (float)npp/(float)nnodes;
5090 sprintf(buf," Average PME mesh/force load: %5.3f\n",pme_f_ratio);
5091 fprintf(fplog,"%s",buf);
5092 fprintf(stderr,"%s",buf);
5093 sprintf(buf," Part of the total run time spent waiting due to PP/PME imbalance: %.1f %%\n",fabs(lossp)*100);
5094 fprintf(fplog,"%s",buf);
5095 fprintf(stderr,"%s",buf);
5097 fprintf(fplog,"\n");
5098 fprintf(stderr,"\n");
5100 if (lossf >= DD_PERF_LOSS)
5103 "NOTE: %.1f %% performance was lost due to load imbalance\n"
5104 " in the domain decomposition.\n",lossf*100);
5105 if (!comm->bDynLoadBal)
5107 sprintf(buf+strlen(buf)," You might want to use dynamic load balancing (option -dlb.)\n");
5111 sprintf(buf+strlen(buf)," You might want to decrease the cell size limit (options -rdd, -rcon and/or -dds).\n");
5113 fprintf(fplog,"%s\n",buf);
5114 fprintf(stderr,"%s\n",buf);
5116 if (npme > 0 && fabs(lossp) >= DD_PERF_LOSS)
5119 "NOTE: %.1f %% performance was lost because the PME nodes\n"
5120 " had %s work to do than the PP nodes.\n"
5121 " You might want to %s the number of PME nodes\n"
5122 " or %s the cut-off and the grid spacing.\n",
5124 (lossp < 0) ? "less" : "more",
5125 (lossp < 0) ? "decrease" : "increase",
5126 (lossp < 0) ? "decrease" : "increase");
5127 fprintf(fplog,"%s\n",buf);
5128 fprintf(stderr,"%s\n",buf);
5133 static float dd_vol_min(gmx_domdec_t *dd)
5135 return dd->comm->load[0].cvol_min*dd->nnodes;
5138 static gmx_bool dd_load_flags(gmx_domdec_t *dd)
5140 return dd->comm->load[0].flags;
5143 static float dd_f_imbal(gmx_domdec_t *dd)
5145 return dd->comm->load[0].max*dd->nnodes/dd->comm->load[0].sum - 1;
5148 static float dd_pme_f_ratio(gmx_domdec_t *dd)
5150 return dd->comm->load[0].pme/dd->comm->load[0].mdf;
5153 static void dd_print_load(FILE *fplog,gmx_domdec_t *dd,gmx_large_int_t step)
5158 flags = dd_load_flags(dd);
5162 "DD load balancing is limited by minimum cell size in dimension");
5163 for(d=0; d<dd->ndim; d++)
5167 fprintf(fplog," %c",dim2char(dd->dim[d]));
5170 fprintf(fplog,"\n");
5172 fprintf(fplog,"DD step %s",gmx_step_str(step,buf));
5173 if (dd->comm->bDynLoadBal)
5175 fprintf(fplog," vol min/aver %5.3f%c",
5176 dd_vol_min(dd),flags ? '!' : ' ');
5178 fprintf(fplog," load imb.: force %4.1f%%",dd_f_imbal(dd)*100);
5179 if (dd->comm->cycl_n[ddCyclPME])
5181 fprintf(fplog," pme mesh/force %5.3f",dd_pme_f_ratio(dd));
5183 fprintf(fplog,"\n\n");
5186 static void dd_print_load_verbose(gmx_domdec_t *dd)
5188 if (dd->comm->bDynLoadBal)
5190 fprintf(stderr,"vol %4.2f%c ",
5191 dd_vol_min(dd),dd_load_flags(dd) ? '!' : ' ');
5193 fprintf(stderr,"imb F %2d%% ",(int)(dd_f_imbal(dd)*100+0.5));
5194 if (dd->comm->cycl_n[ddCyclPME])
5196 fprintf(stderr,"pme/F %4.2f ",dd_pme_f_ratio(dd));
5201 static void make_load_communicator(gmx_domdec_t *dd,MPI_Group g_all,
5202 int dim_ind,ivec loc)
5204 MPI_Group g_row = MPI_GROUP_EMPTY;
5208 gmx_domdec_root_t *root;
5209 gmx_bool bPartOfGroup = FALSE;
5211 dim = dd->dim[dim_ind];
5212 copy_ivec(loc,loc_c);
5213 snew(rank,dd->nc[dim]);
5214 for(i=0; i<dd->nc[dim]; i++)
5217 rank[i] = dd_index(dd->nc,loc_c);
5218 if (rank[i] == dd->rank)
5220 /* This process is part of the group */
5221 bPartOfGroup = TRUE;
5226 MPI_Group_incl(g_all,dd->nc[dim],rank,&g_row);
5228 MPI_Comm_create(dd->mpi_comm_all,g_row,&c_row);
5231 dd->comm->mpi_comm_load[dim_ind] = c_row;
5232 if (dd->comm->eDLB != edlbNO)
5234 if (dd->ci[dim] == dd->master_ci[dim])
5236 /* This is the root process of this row */
5237 snew(dd->comm->root[dim_ind],1);
5238 root = dd->comm->root[dim_ind];
5239 snew(root->cell_f,DD_CELL_F_SIZE(dd,dim_ind));
5240 snew(root->old_cell_f,dd->nc[dim]+1);
5241 snew(root->bCellMin,dd->nc[dim]);
5244 snew(root->cell_f_max0,dd->nc[dim]);
5245 snew(root->cell_f_min1,dd->nc[dim]);
5246 snew(root->bound_min,dd->nc[dim]);
5247 snew(root->bound_max,dd->nc[dim]);
5249 snew(root->buf_ncd,dd->nc[dim]);
5253 /* This is not a root process, we only need to receive cell_f */
5254 snew(dd->comm->cell_f_row,DD_CELL_F_SIZE(dd,dim_ind));
5257 if (dd->ci[dim] == dd->master_ci[dim])
5259 snew(dd->comm->load[dim_ind].load,dd->nc[dim]*DD_NLOAD_MAX);
5266 static void make_load_communicators(gmx_domdec_t *dd)
5274 fprintf(debug,"Making load communicators\n");
5276 MPI_Comm_group(dd->mpi_comm_all,&g_all);
5278 snew(dd->comm->load,dd->ndim);
5279 snew(dd->comm->mpi_comm_load,dd->ndim);
5282 make_load_communicator(dd,g_all,0,loc);
5285 for(i=0; i<dd->nc[dim0]; i++) {
5287 make_load_communicator(dd,g_all,1,loc);
5292 for(i=0; i<dd->nc[dim0]; i++) {
5295 for(j=0; j<dd->nc[dim1]; j++) {
5297 make_load_communicator(dd,g_all,2,loc);
5302 MPI_Group_free(&g_all);
5305 fprintf(debug,"Finished making load communicators\n");
5309 void setup_dd_grid(FILE *fplog,gmx_domdec_t *dd)
5315 ivec dd_zp[DD_MAXIZONE];
5316 gmx_domdec_zones_t *zones;
5317 gmx_domdec_ns_ranges_t *izone;
5319 for(d=0; d<dd->ndim; d++)
5322 copy_ivec(dd->ci,tmp);
5323 tmp[dim] = (tmp[dim] + 1) % dd->nc[dim];
5324 dd->neighbor[d][0] = ddcoord2ddnodeid(dd,tmp);
5325 copy_ivec(dd->ci,tmp);
5326 tmp[dim] = (tmp[dim] - 1 + dd->nc[dim]) % dd->nc[dim];
5327 dd->neighbor[d][1] = ddcoord2ddnodeid(dd,tmp);
5330 fprintf(debug,"DD rank %d neighbor ranks in dir %d are + %d - %d\n",
5333 dd->neighbor[d][1]);
5339 fprintf(stderr,"Making %dD domain decomposition %d x %d x %d\n",
5340 dd->ndim,dd->nc[XX],dd->nc[YY],dd->nc[ZZ]);
5344 fprintf(fplog,"\nMaking %dD domain decomposition grid %d x %d x %d, home cell index %d %d %d\n\n",
5346 dd->nc[XX],dd->nc[YY],dd->nc[ZZ],
5347 dd->ci[XX],dd->ci[YY],dd->ci[ZZ]);
5354 for(i=0; i<nzonep; i++)
5356 copy_ivec(dd_zp3[i],dd_zp[i]);
5362 for(i=0; i<nzonep; i++)
5364 copy_ivec(dd_zp2[i],dd_zp[i]);
5370 for(i=0; i<nzonep; i++)
5372 copy_ivec(dd_zp1[i],dd_zp[i]);
5376 gmx_fatal(FARGS,"Can only do 1, 2 or 3D domain decomposition");
5381 zones = &dd->comm->zones;
5383 for(i=0; i<nzone; i++)
5386 clear_ivec(zones->shift[i]);
5387 for(d=0; d<dd->ndim; d++)
5389 zones->shift[i][dd->dim[d]] = dd_zo[i][m++];
5394 for(i=0; i<nzone; i++)
5396 for(d=0; d<DIM; d++)
5398 s[d] = dd->ci[d] - zones->shift[i][d];
5403 else if (s[d] >= dd->nc[d])
5409 zones->nizone = nzonep;
5410 for(i=0; i<zones->nizone; i++)
5412 if (dd_zp[i][0] != i)
5414 gmx_fatal(FARGS,"Internal inconsistency in the dd grid setup");
5416 izone = &zones->izone[i];
5417 izone->j0 = dd_zp[i][1];
5418 izone->j1 = dd_zp[i][2];
5419 for(dim=0; dim<DIM; dim++)
5421 if (dd->nc[dim] == 1)
5423 /* All shifts should be allowed */
5424 izone->shift0[dim] = -1;
5425 izone->shift1[dim] = 1;
5430 izone->shift0[d] = 0;
5431 izone->shift1[d] = 0;
5432 for(j=izone->j0; j<izone->j1; j++) {
5433 if (dd->shift[j][d] > dd->shift[i][d])
5434 izone->shift0[d] = -1;
5435 if (dd->shift[j][d] < dd->shift[i][d])
5436 izone->shift1[d] = 1;
5442 /* Assume the shift are not more than 1 cell */
5443 izone->shift0[dim] = 1;
5444 izone->shift1[dim] = -1;
5445 for(j=izone->j0; j<izone->j1; j++)
5447 shift_diff = zones->shift[j][dim] - zones->shift[i][dim];
5448 if (shift_diff < izone->shift0[dim])
5450 izone->shift0[dim] = shift_diff;
5452 if (shift_diff > izone->shift1[dim])
5454 izone->shift1[dim] = shift_diff;
5461 if (dd->comm->eDLB != edlbNO)
5463 snew(dd->comm->root,dd->ndim);
5466 if (dd->comm->bRecordLoad)
5468 make_load_communicators(dd);
5472 static void make_pp_communicator(FILE *fplog,t_commrec *cr,int reorder)
5475 gmx_domdec_comm_t *comm;
5486 if (comm->bCartesianPP)
5488 /* Set up cartesian communication for the particle-particle part */
5491 fprintf(fplog,"Will use a Cartesian communicator: %d x %d x %d\n",
5492 dd->nc[XX],dd->nc[YY],dd->nc[ZZ]);
5495 for(i=0; i<DIM; i++)
5499 MPI_Cart_create(cr->mpi_comm_mygroup,DIM,dd->nc,periods,reorder,
5501 /* We overwrite the old communicator with the new cartesian one */
5502 cr->mpi_comm_mygroup = comm_cart;
5505 dd->mpi_comm_all = cr->mpi_comm_mygroup;
5506 MPI_Comm_rank(dd->mpi_comm_all,&dd->rank);
5508 if (comm->bCartesianPP_PME)
5510 /* Since we want to use the original cartesian setup for sim,
5511 * and not the one after split, we need to make an index.
5513 snew(comm->ddindex2ddnodeid,dd->nnodes);
5514 comm->ddindex2ddnodeid[dd_index(dd->nc,dd->ci)] = dd->rank;
5515 gmx_sumi(dd->nnodes,comm->ddindex2ddnodeid,cr);
5516 /* Get the rank of the DD master,
5517 * above we made sure that the master node is a PP node.
5527 MPI_Allreduce(&rank,&dd->masterrank,1,MPI_INT,MPI_SUM,dd->mpi_comm_all);
5529 else if (comm->bCartesianPP)
5531 if (cr->npmenodes == 0)
5533 /* The PP communicator is also
5534 * the communicator for this simulation
5536 cr->mpi_comm_mysim = cr->mpi_comm_mygroup;
5538 cr->nodeid = dd->rank;
5540 MPI_Cart_coords(dd->mpi_comm_all,dd->rank,DIM,dd->ci);
5542 /* We need to make an index to go from the coordinates
5543 * to the nodeid of this simulation.
5545 snew(comm->ddindex2simnodeid,dd->nnodes);
5546 snew(buf,dd->nnodes);
5547 if (cr->duty & DUTY_PP)
5549 buf[dd_index(dd->nc,dd->ci)] = cr->sim_nodeid;
5551 /* Communicate the ddindex to simulation nodeid index */
5552 MPI_Allreduce(buf,comm->ddindex2simnodeid,dd->nnodes,MPI_INT,MPI_SUM,
5553 cr->mpi_comm_mysim);
5556 /* Determine the master coordinates and rank.
5557 * The DD master should be the same node as the master of this sim.
5559 for(i=0; i<dd->nnodes; i++)
5561 if (comm->ddindex2simnodeid[i] == 0)
5563 ddindex2xyz(dd->nc,i,dd->master_ci);
5564 MPI_Cart_rank(dd->mpi_comm_all,dd->master_ci,&dd->masterrank);
5569 fprintf(debug,"The master rank is %d\n",dd->masterrank);
5574 /* No Cartesian communicators */
5575 /* We use the rank in dd->comm->all as DD index */
5576 ddindex2xyz(dd->nc,dd->rank,dd->ci);
5577 /* The simulation master nodeid is 0, so the DD master rank is also 0 */
5579 clear_ivec(dd->master_ci);
5586 "Domain decomposition nodeid %d, coordinates %d %d %d\n\n",
5587 dd->rank,dd->ci[XX],dd->ci[YY],dd->ci[ZZ]);
5592 "Domain decomposition nodeid %d, coordinates %d %d %d\n\n",
5593 dd->rank,dd->ci[XX],dd->ci[YY],dd->ci[ZZ]);
5597 static void receive_ddindex2simnodeid(t_commrec *cr)
5601 gmx_domdec_comm_t *comm;
5608 if (!comm->bCartesianPP_PME && comm->bCartesianPP)
5610 snew(comm->ddindex2simnodeid,dd->nnodes);
5611 snew(buf,dd->nnodes);
5612 if (cr->duty & DUTY_PP)
5614 buf[dd_index(dd->nc,dd->ci)] = cr->sim_nodeid;
5617 /* Communicate the ddindex to simulation nodeid index */
5618 MPI_Allreduce(buf,comm->ddindex2simnodeid,dd->nnodes,MPI_INT,MPI_SUM,
5619 cr->mpi_comm_mysim);
5626 static gmx_domdec_master_t *init_gmx_domdec_master_t(gmx_domdec_t *dd,
5629 gmx_domdec_master_t *ma;
5634 snew(ma->ncg,dd->nnodes);
5635 snew(ma->index,dd->nnodes+1);
5637 snew(ma->nat,dd->nnodes);
5638 snew(ma->ibuf,dd->nnodes*2);
5639 snew(ma->cell_x,DIM);
5640 for(i=0; i<DIM; i++)
5642 snew(ma->cell_x[i],dd->nc[i]+1);
5645 if (dd->nnodes <= GMX_DD_NNODES_SENDRECV)
5651 snew(ma->vbuf,natoms);
5657 static void split_communicator(FILE *fplog,t_commrec *cr,int dd_node_order,
5661 gmx_domdec_comm_t *comm;
5672 if (comm->bCartesianPP)
5674 for(i=1; i<DIM; i++)
5676 bDiv[i] = ((cr->npmenodes*dd->nc[i]) % (dd->nnodes) == 0);
5678 if (bDiv[YY] || bDiv[ZZ])
5680 comm->bCartesianPP_PME = TRUE;
5681 /* If we have 2D PME decomposition, which is always in x+y,
5682 * we stack the PME only nodes in z.
5683 * Otherwise we choose the direction that provides the thinnest slab
5684 * of PME only nodes as this will have the least effect
5685 * on the PP communication.
5686 * But for the PME communication the opposite might be better.
5688 if (bDiv[ZZ] && (comm->npmenodes_y > 1 ||
5690 dd->nc[YY] > dd->nc[ZZ]))
5692 comm->cartpmedim = ZZ;
5696 comm->cartpmedim = YY;
5698 comm->ntot[comm->cartpmedim]
5699 += (cr->npmenodes*dd->nc[comm->cartpmedim])/dd->nnodes;
5703 fprintf(fplog,"#pmenodes (%d) is not a multiple of nx*ny (%d*%d) or nx*nz (%d*%d)\n",cr->npmenodes,dd->nc[XX],dd->nc[YY],dd->nc[XX],dd->nc[ZZ]);
5705 "Will not use a Cartesian communicator for PP <-> PME\n\n");
5710 if (comm->bCartesianPP_PME)
5714 fprintf(fplog,"Will use a Cartesian communicator for PP <-> PME: %d x %d x %d\n",comm->ntot[XX],comm->ntot[YY],comm->ntot[ZZ]);
5717 for(i=0; i<DIM; i++)
5721 MPI_Cart_create(cr->mpi_comm_mysim,DIM,comm->ntot,periods,reorder,
5724 MPI_Comm_rank(comm_cart,&rank);
5725 if (MASTERNODE(cr) && rank != 0)
5727 gmx_fatal(FARGS,"MPI rank 0 was renumbered by MPI_Cart_create, we do not allow this");
5730 /* With this assigment we loose the link to the original communicator
5731 * which will usually be MPI_COMM_WORLD, unless have multisim.
5733 cr->mpi_comm_mysim = comm_cart;
5734 cr->sim_nodeid = rank;
5736 MPI_Cart_coords(cr->mpi_comm_mysim,cr->sim_nodeid,DIM,dd->ci);
5740 fprintf(fplog,"Cartesian nodeid %d, coordinates %d %d %d\n\n",
5741 cr->sim_nodeid,dd->ci[XX],dd->ci[YY],dd->ci[ZZ]);
5744 if (dd->ci[comm->cartpmedim] < dd->nc[comm->cartpmedim])
5748 if (cr->npmenodes == 0 ||
5749 dd->ci[comm->cartpmedim] >= dd->nc[comm->cartpmedim])
5751 cr->duty = DUTY_PME;
5754 /* Split the sim communicator into PP and PME only nodes */
5755 MPI_Comm_split(cr->mpi_comm_mysim,
5757 dd_index(comm->ntot,dd->ci),
5758 &cr->mpi_comm_mygroup);
5762 switch (dd_node_order)
5767 fprintf(fplog,"Order of the nodes: PP first, PME last\n");
5770 case ddnoINTERLEAVE:
5771 /* Interleave the PP-only and PME-only nodes,
5772 * as on clusters with dual-core machines this will double
5773 * the communication bandwidth of the PME processes
5774 * and thus speed up the PP <-> PME and inter PME communication.
5778 fprintf(fplog,"Interleaving PP and PME nodes\n");
5780 comm->pmenodes = dd_pmenodes(cr);
5785 gmx_fatal(FARGS,"Unknown dd_node_order=%d",dd_node_order);
5788 if (dd_simnode2pmenode(cr,cr->sim_nodeid) == -1)
5790 cr->duty = DUTY_PME;
5797 /* Split the sim communicator into PP and PME only nodes */
5798 MPI_Comm_split(cr->mpi_comm_mysim,
5801 &cr->mpi_comm_mygroup);
5802 MPI_Comm_rank(cr->mpi_comm_mygroup,&cr->nodeid);
5808 fprintf(fplog,"This is a %s only node\n\n",
5809 (cr->duty & DUTY_PP) ? "particle-particle" : "PME-mesh");
5813 void make_dd_communicators(FILE *fplog,t_commrec *cr,int dd_node_order)
5816 gmx_domdec_comm_t *comm;
5822 copy_ivec(dd->nc,comm->ntot);
5824 comm->bCartesianPP = (dd_node_order == ddnoCARTESIAN);
5825 comm->bCartesianPP_PME = FALSE;
5827 /* Reorder the nodes by default. This might change the MPI ranks.
5828 * Real reordering is only supported on very few architectures,
5829 * Blue Gene is one of them.
5831 CartReorder = (getenv("GMX_NO_CART_REORDER") == NULL);
5833 if (cr->npmenodes > 0)
5835 /* Split the communicator into a PP and PME part */
5836 split_communicator(fplog,cr,dd_node_order,CartReorder);
5837 if (comm->bCartesianPP_PME)
5839 /* We (possibly) reordered the nodes in split_communicator,
5840 * so it is no longer required in make_pp_communicator.
5842 CartReorder = FALSE;
5847 /* All nodes do PP and PME */
5849 /* We do not require separate communicators */
5850 cr->mpi_comm_mygroup = cr->mpi_comm_mysim;
5854 if (cr->duty & DUTY_PP)
5856 /* Copy or make a new PP communicator */
5857 make_pp_communicator(fplog,cr,CartReorder);
5861 receive_ddindex2simnodeid(cr);
5864 if (!(cr->duty & DUTY_PME))
5866 /* Set up the commnuication to our PME node */
5867 dd->pme_nodeid = dd_simnode2pmenode(cr,cr->sim_nodeid);
5868 dd->pme_receive_vir_ener = receive_vir_ener(cr);
5871 fprintf(debug,"My pme_nodeid %d receive ener %d\n",
5872 dd->pme_nodeid,dd->pme_receive_vir_ener);
5877 dd->pme_nodeid = -1;
5882 dd->ma = init_gmx_domdec_master_t(dd,
5884 comm->cgs_gl.index[comm->cgs_gl.nr]);
5888 static real *get_slb_frac(FILE *fplog,const char *dir,int nc,const char *size_string)
5895 if (nc > 1 && size_string != NULL)
5899 fprintf(fplog,"Using static load balancing for the %s direction\n",
5904 for (i=0; i<nc; i++)
5907 sscanf(size_string,"%lf%n",&dbl,&n);
5910 gmx_fatal(FARGS,"Incorrect or not enough DD cell size entries for direction %s: '%s'",dir,size_string);
5919 fprintf(fplog,"Relative cell sizes:");
5921 for (i=0; i<nc; i++)
5926 fprintf(fplog," %5.3f",slb_frac[i]);
5931 fprintf(fplog,"\n");
5938 static int multi_body_bondeds_count(gmx_mtop_t *mtop)
5941 gmx_mtop_ilistloop_t iloop;
5945 iloop = gmx_mtop_ilistloop_init(mtop);
5946 while (gmx_mtop_ilistloop_next(iloop,&il,&nmol))
5948 for(ftype=0; ftype<F_NRE; ftype++)
5950 if ((interaction_function[ftype].flags & IF_BOND) &&
5953 n += nmol*il[ftype].nr/(1 + NRAL(ftype));
5961 static int dd_nst_env(FILE *fplog,const char *env_var,int def)
5967 val = getenv(env_var);
5970 if (sscanf(val,"%d",&nst) <= 0)
5976 fprintf(fplog,"Found env.var. %s = %s, using value %d\n",
5984 static void dd_warning(t_commrec *cr,FILE *fplog,const char *warn_string)
5988 fprintf(stderr,"\n%s\n",warn_string);
5992 fprintf(fplog,"\n%s\n",warn_string);
5996 static void check_dd_restrictions(t_commrec *cr,gmx_domdec_t *dd,
5997 t_inputrec *ir,FILE *fplog)
5999 if (ir->ePBC == epbcSCREW &&
6000 (dd->nc[XX] == 1 || dd->nc[YY] > 1 || dd->nc[ZZ] > 1))
6002 gmx_fatal(FARGS,"With pbc=%s can only do domain decomposition in the x-direction",epbc_names[ir->ePBC]);
6005 if (ir->ns_type == ensSIMPLE)
6007 gmx_fatal(FARGS,"Domain decomposition does not support simple neighbor searching, use grid searching or use particle decomposition");
6010 if (ir->nstlist == 0)
6012 gmx_fatal(FARGS,"Domain decomposition does not work with nstlist=0");
6015 if (ir->comm_mode == ecmANGULAR && ir->ePBC != epbcNONE)
6017 dd_warning(cr,fplog,"comm-mode angular will give incorrect results when the comm group partially crosses a periodic boundary");
6021 static real average_cellsize_min(gmx_domdec_t *dd,gmx_ddbox_t *ddbox)
6026 r = ddbox->box_size[XX];
6027 for(di=0; di<dd->ndim; di++)
6030 /* Check using the initial average cell size */
6031 r = min(r,ddbox->box_size[d]*ddbox->skew_fac[d]/dd->nc[d]);
6037 static int check_dlb_support(FILE *fplog,t_commrec *cr,
6038 const char *dlb_opt,gmx_bool bRecordLoad,
6039 unsigned long Flags,t_inputrec *ir)
6047 case 'a': eDLB = edlbAUTO; break;
6048 case 'n': eDLB = edlbNO; break;
6049 case 'y': eDLB = edlbYES; break;
6050 default: gmx_incons("Unknown dlb_opt");
6053 if (Flags & MD_RERUN)
6058 if (!EI_DYNAMICS(ir->eI))
6060 if (eDLB == edlbYES)
6062 sprintf(buf,"NOTE: dynamic load balancing is only supported with dynamics, not with integrator '%s'\n",EI(ir->eI));
6063 dd_warning(cr,fplog,buf);
6071 dd_warning(cr,fplog,"NOTE: Cycle counting is not supported on this architecture, will not use dynamic load balancing\n");
6076 if (Flags & MD_REPRODUCIBLE)
6083 dd_warning(cr,fplog,"NOTE: reproducibility requested, will not use dynamic load balancing\n");
6087 dd_warning(cr,fplog,"WARNING: reproducibility requested with dynamic load balancing, the simulation will NOT be binary reproducible\n");
6090 gmx_fatal(FARGS,"Death horror: undefined case (%d) for load balancing choice",eDLB);
6098 static void set_dd_dim(FILE *fplog,gmx_domdec_t *dd)
6103 if (getenv("GMX_DD_ORDER_ZYX") != NULL)
6105 /* Decomposition order z,y,x */
6108 fprintf(fplog,"Using domain decomposition order z, y, x\n");
6110 for(dim=DIM-1; dim>=0; dim--)
6112 if (dd->nc[dim] > 1)
6114 dd->dim[dd->ndim++] = dim;
6120 /* Decomposition order x,y,z */
6121 for(dim=0; dim<DIM; dim++)
6123 if (dd->nc[dim] > 1)
6125 dd->dim[dd->ndim++] = dim;
6131 static gmx_domdec_comm_t *init_dd_comm()
6133 gmx_domdec_comm_t *comm;
6137 snew(comm->cggl_flag,DIM*2);
6138 snew(comm->cgcm_state,DIM*2);
6139 for(i=0; i<DIM*2; i++)
6141 comm->cggl_flag_nalloc[i] = 0;
6142 comm->cgcm_state_nalloc[i] = 0;
6145 comm->nalloc_int = 0;
6146 comm->buf_int = NULL;
6148 vec_rvec_init(&comm->vbuf);
6150 comm->n_load_have = 0;
6151 comm->n_load_collect = 0;
6153 for(i=0; i<ddnatNR-ddnatZONE; i++)
6155 comm->sum_nat[i] = 0;
6159 comm->load_step = 0;
6162 clear_ivec(comm->load_lim);
6169 gmx_domdec_t *init_domain_decomposition(FILE *fplog,t_commrec *cr,
6170 unsigned long Flags,
6172 real comm_distance_min,real rconstr,
6173 const char *dlb_opt,real dlb_scale,
6174 const char *sizex,const char *sizey,const char *sizez,
6175 gmx_mtop_t *mtop,t_inputrec *ir,
6178 int *npme_x,int *npme_y)
6181 gmx_domdec_comm_t *comm;
6184 real r_2b,r_mb,r_bonded=-1,r_bonded_limit=-1,limit,acs;
6191 "\nInitializing Domain Decomposition on %d nodes\n",cr->nnodes);
6196 dd->comm = init_dd_comm();
6198 snew(comm->cggl_flag,DIM*2);
6199 snew(comm->cgcm_state,DIM*2);
6201 dd->npbcdim = ePBC2npbcdim(ir->ePBC);
6202 dd->bScrewPBC = (ir->ePBC == epbcSCREW);
6204 dd->bSendRecv2 = dd_nst_env(fplog,"GMX_DD_SENDRECV2",0);
6205 comm->dlb_scale_lim = dd_nst_env(fplog,"GMX_DLB_MAX",10);
6206 comm->eFlop = dd_nst_env(fplog,"GMX_DLB_FLOP",0);
6207 recload = dd_nst_env(fplog,"GMX_DD_LOAD",1);
6208 comm->nstSortCG = dd_nst_env(fplog,"GMX_DD_SORT",1);
6209 comm->nstDDDump = dd_nst_env(fplog,"GMX_DD_DUMP",0);
6210 comm->nstDDDumpGrid = dd_nst_env(fplog,"GMX_DD_DUMP_GRID",0);
6211 comm->DD_debug = dd_nst_env(fplog,"GMX_DD_DEBUG",0);
6213 dd->pme_recv_f_alloc = 0;
6214 dd->pme_recv_f_buf = NULL;
6216 if (dd->bSendRecv2 && fplog)
6218 fprintf(fplog,"Will use two sequential MPI_Sendrecv calls instead of two simultaneous non-blocking MPI_Irecv and MPI_Isend pairs for constraint and vsite communication\n");
6224 fprintf(fplog,"Will load balance based on FLOP count\n");
6226 if (comm->eFlop > 1)
6228 srand(1+cr->nodeid);
6230 comm->bRecordLoad = TRUE;
6234 comm->bRecordLoad = (wallcycle_have_counter() && recload > 0);
6238 comm->eDLB = check_dlb_support(fplog,cr,dlb_opt,comm->bRecordLoad,Flags,ir);
6240 comm->bDynLoadBal = (comm->eDLB == edlbYES);
6243 fprintf(fplog,"Dynamic load balancing: %s\n",edlb_names[comm->eDLB]);
6245 dd->bGridJump = comm->bDynLoadBal;
6247 if (comm->nstSortCG)
6251 if (comm->nstSortCG == 1)
6253 fprintf(fplog,"Will sort the charge groups at every domain (re)decomposition\n");
6257 fprintf(fplog,"Will sort the charge groups every %d steps\n",
6267 fprintf(fplog,"Will not sort the charge groups\n");
6271 comm->bInterCGBondeds = (ncg_mtop(mtop) > mtop->mols.nr);
6272 if (comm->bInterCGBondeds)
6274 comm->bInterCGMultiBody = (multi_body_bondeds_count(mtop) > 0);
6278 comm->bInterCGMultiBody = FALSE;
6281 dd->bInterCGcons = inter_charge_group_constraints(mtop);
6283 if (ir->rlistlong == 0)
6285 /* Set the cut-off to some very large value,
6286 * so we don't need if statements everywhere in the code.
6287 * We use sqrt, since the cut-off is squared in some places.
6289 comm->cutoff = GMX_CUTOFF_INF;
6293 comm->cutoff = ir->rlistlong;
6295 comm->cutoff_mbody = 0;
6297 comm->cellsize_limit = 0;
6298 comm->bBondComm = FALSE;
6300 if (comm->bInterCGBondeds)
6302 if (comm_distance_min > 0)
6304 comm->cutoff_mbody = comm_distance_min;
6305 if (Flags & MD_DDBONDCOMM)
6307 comm->bBondComm = (comm->cutoff_mbody > comm->cutoff);
6311 comm->cutoff = max(comm->cutoff,comm->cutoff_mbody);
6313 r_bonded_limit = comm->cutoff_mbody;
6315 else if (ir->bPeriodicMols)
6317 /* Can not easily determine the required cut-off */
6318 dd_warning(cr,fplog,"NOTE: Periodic molecules: can not easily determine the required minimum bonded cut-off, using half the non-bonded cut-off\n");
6319 comm->cutoff_mbody = comm->cutoff/2;
6320 r_bonded_limit = comm->cutoff_mbody;
6326 dd_bonded_cg_distance(fplog,dd,mtop,ir,x,box,
6327 Flags & MD_DDBONDCHECK,&r_2b,&r_mb);
6329 gmx_bcast(sizeof(r_2b),&r_2b,cr);
6330 gmx_bcast(sizeof(r_mb),&r_mb,cr);
6332 /* We use an initial margin of 10% for the minimum cell size,
6333 * except when we are just below the non-bonded cut-off.
6335 if (Flags & MD_DDBONDCOMM)
6337 if (max(r_2b,r_mb) > comm->cutoff)
6339 r_bonded = max(r_2b,r_mb);
6340 r_bonded_limit = 1.1*r_bonded;
6341 comm->bBondComm = TRUE;
6346 r_bonded_limit = min(1.1*r_bonded,comm->cutoff);
6348 /* We determine cutoff_mbody later */
6352 /* No special bonded communication,
6353 * simply increase the DD cut-off.
6355 r_bonded_limit = 1.1*max(r_2b,r_mb);
6356 comm->cutoff_mbody = r_bonded_limit;
6357 comm->cutoff = max(comm->cutoff,comm->cutoff_mbody);
6360 comm->cellsize_limit = max(comm->cellsize_limit,r_bonded_limit);
6364 "Minimum cell size due to bonded interactions: %.3f nm\n",
6365 comm->cellsize_limit);
6369 if (dd->bInterCGcons && rconstr <= 0)
6371 /* There is a cell size limit due to the constraints (P-LINCS) */
6372 rconstr = constr_r_max(fplog,mtop,ir);
6376 "Estimated maximum distance required for P-LINCS: %.3f nm\n",
6378 if (rconstr > comm->cellsize_limit)
6380 fprintf(fplog,"This distance will limit the DD cell size, you can override this with -rcon\n");
6384 else if (rconstr > 0 && fplog)
6386 /* Here we do not check for dd->bInterCGcons,
6387 * because one can also set a cell size limit for virtual sites only
6388 * and at this point we don't know yet if there are intercg v-sites.
6391 "User supplied maximum distance required for P-LINCS: %.3f nm\n",
6394 comm->cellsize_limit = max(comm->cellsize_limit,rconstr);
6396 comm->cgs_gl = gmx_mtop_global_cgs(mtop);
6400 copy_ivec(nc,dd->nc);
6401 set_dd_dim(fplog,dd);
6402 set_ddbox_cr(cr,&dd->nc,ir,box,&comm->cgs_gl,x,ddbox);
6404 if (cr->npmenodes == -1)
6408 acs = average_cellsize_min(dd,ddbox);
6409 if (acs < comm->cellsize_limit)
6413 fprintf(fplog,"ERROR: The initial cell size (%f) is smaller than the cell size limit (%f)\n",acs,comm->cellsize_limit);
6415 gmx_fatal_collective(FARGS,cr,NULL,
6416 "The initial cell size (%f) is smaller than the cell size limit (%f), change options -dd, -rdd or -rcon, see the log file for details",
6417 acs,comm->cellsize_limit);
6422 set_ddbox_cr(cr,NULL,ir,box,&comm->cgs_gl,x,ddbox);
6424 /* We need to choose the optimal DD grid and possibly PME nodes */
6425 limit = dd_choose_grid(fplog,cr,dd,ir,mtop,box,ddbox,
6426 comm->eDLB!=edlbNO,dlb_scale,
6427 comm->cellsize_limit,comm->cutoff,
6428 comm->bInterCGBondeds,comm->bInterCGMultiBody);
6430 if (dd->nc[XX] == 0)
6432 bC = (dd->bInterCGcons && rconstr > r_bonded_limit);
6433 sprintf(buf,"Change the number of nodes or mdrun option %s%s%s",
6434 !bC ? "-rdd" : "-rcon",
6435 comm->eDLB!=edlbNO ? " or -dds" : "",
6436 bC ? " or your LINCS settings" : "");
6438 gmx_fatal_collective(FARGS,cr,NULL,
6439 "There is no domain decomposition for %d nodes that is compatible with the given box and a minimum cell size of %g nm\n"
6441 "Look in the log file for details on the domain decomposition",
6442 cr->nnodes-cr->npmenodes,limit,buf);
6444 set_dd_dim(fplog,dd);
6450 "Domain decomposition grid %d x %d x %d, separate PME nodes %d\n",
6451 dd->nc[XX],dd->nc[YY],dd->nc[ZZ],cr->npmenodes);
6454 dd->nnodes = dd->nc[XX]*dd->nc[YY]*dd->nc[ZZ];
6455 if (cr->nnodes - dd->nnodes != cr->npmenodes)
6457 gmx_fatal_collective(FARGS,cr,NULL,
6458 "The size of the domain decomposition grid (%d) does not match the number of nodes (%d). The total number of nodes is %d",
6459 dd->nnodes,cr->nnodes - cr->npmenodes,cr->nnodes);
6461 if (cr->npmenodes > dd->nnodes)
6463 gmx_fatal_collective(FARGS,cr,NULL,
6464 "The number of separate PME nodes (%d) is larger than the number of PP nodes (%d), this is not supported.",cr->npmenodes,dd->nnodes);
6466 if (cr->npmenodes > 0)
6468 comm->npmenodes = cr->npmenodes;
6472 comm->npmenodes = dd->nnodes;
6475 if (EEL_PME(ir->coulombtype))
6477 /* The following choices should match those
6478 * in comm_cost_est in domdec_setup.c.
6479 * Note that here the checks have to take into account
6480 * that the decomposition might occur in a different order than xyz
6481 * (for instance through the env.var. GMX_DD_ORDER_ZYX),
6482 * in which case they will not match those in comm_cost_est,
6483 * but since that is mainly for testing purposes that's fine.
6485 if (dd->ndim >= 2 && dd->dim[0] == XX && dd->dim[1] == YY &&
6486 comm->npmenodes > dd->nc[XX] && comm->npmenodes % dd->nc[XX] == 0 &&
6487 getenv("GMX_PMEONEDD") == NULL)
6489 comm->npmedecompdim = 2;
6490 comm->npmenodes_x = dd->nc[XX];
6491 comm->npmenodes_y = comm->npmenodes/comm->npmenodes_x;
6495 /* In case nc is 1 in both x and y we could still choose to
6496 * decompose pme in y instead of x, but we use x for simplicity.
6498 comm->npmedecompdim = 1;
6499 if (dd->dim[0] == YY)
6501 comm->npmenodes_x = 1;
6502 comm->npmenodes_y = comm->npmenodes;
6506 comm->npmenodes_x = comm->npmenodes;
6507 comm->npmenodes_y = 1;
6512 fprintf(fplog,"PME domain decomposition: %d x %d x %d\n",
6513 comm->npmenodes_x,comm->npmenodes_y,1);
6518 comm->npmedecompdim = 0;
6519 comm->npmenodes_x = 0;
6520 comm->npmenodes_y = 0;
6523 /* Technically we don't need both of these,
6524 * but it simplifies code not having to recalculate it.
6526 *npme_x = comm->npmenodes_x;
6527 *npme_y = comm->npmenodes_y;
6529 snew(comm->slb_frac,DIM);
6530 if (comm->eDLB == edlbNO)
6532 comm->slb_frac[XX] = get_slb_frac(fplog,"x",dd->nc[XX],sizex);
6533 comm->slb_frac[YY] = get_slb_frac(fplog,"y",dd->nc[YY],sizey);
6534 comm->slb_frac[ZZ] = get_slb_frac(fplog,"z",dd->nc[ZZ],sizez);
6537 if (comm->bInterCGBondeds && comm->cutoff_mbody == 0)
6539 if (comm->bBondComm || comm->eDLB != edlbNO)
6541 /* Set the bonded communication distance to halfway
6542 * the minimum and the maximum,
6543 * since the extra communication cost is nearly zero.
6545 acs = average_cellsize_min(dd,ddbox);
6546 comm->cutoff_mbody = 0.5*(r_bonded + acs);
6547 if (comm->eDLB != edlbNO)
6549 /* Check if this does not limit the scaling */
6550 comm->cutoff_mbody = min(comm->cutoff_mbody,dlb_scale*acs);
6552 if (!comm->bBondComm)
6554 /* Without bBondComm do not go beyond the n.b. cut-off */
6555 comm->cutoff_mbody = min(comm->cutoff_mbody,comm->cutoff);
6556 if (comm->cellsize_limit >= comm->cutoff)
6558 /* We don't loose a lot of efficieny
6559 * when increasing it to the n.b. cut-off.
6560 * It can even be slightly faster, because we need
6561 * less checks for the communication setup.
6563 comm->cutoff_mbody = comm->cutoff;
6566 /* Check if we did not end up below our original limit */
6567 comm->cutoff_mbody = max(comm->cutoff_mbody,r_bonded_limit);
6569 if (comm->cutoff_mbody > comm->cellsize_limit)
6571 comm->cellsize_limit = comm->cutoff_mbody;
6574 /* Without DLB and cutoff_mbody<cutoff, cutoff_mbody is dynamic */
6579 fprintf(debug,"Bonded atom communication beyond the cut-off: %d\n"
6580 "cellsize limit %f\n",
6581 comm->bBondComm,comm->cellsize_limit);
6586 check_dd_restrictions(cr,dd,ir,fplog);
6589 comm->globalcomm_step = INT_MIN;
6592 clear_dd_cycle_counts(dd);
6597 static void set_dlb_limits(gmx_domdec_t *dd)
6602 for(d=0; d<dd->ndim; d++)
6604 dd->comm->cd[d].np = dd->comm->cd[d].np_dlb;
6605 dd->comm->cellsize_min[dd->dim[d]] =
6606 dd->comm->cellsize_min_dlb[dd->dim[d]];
6611 static void turn_on_dlb(FILE *fplog,t_commrec *cr,gmx_large_int_t step)
6614 gmx_domdec_comm_t *comm;
6624 fprintf(fplog,"At step %s the performance loss due to force load imbalance is %.1f %%\n",gmx_step_str(step,buf),dd_force_imb_perf_loss(dd)*100);
6627 cellsize_min = comm->cellsize_min[dd->dim[0]];
6628 for(d=1; d<dd->ndim; d++)
6630 cellsize_min = min(cellsize_min,comm->cellsize_min[dd->dim[d]]);
6633 if (cellsize_min < comm->cellsize_limit*1.05)
6635 dd_warning(cr,fplog,"NOTE: the minimum cell size is smaller than 1.05 times the cell size limit, will not turn on dynamic load balancing\n");
6637 /* Change DLB from "auto" to "no". */
6638 comm->eDLB = edlbNO;
6643 dd_warning(cr,fplog,"NOTE: Turning on dynamic load balancing\n");
6644 comm->bDynLoadBal = TRUE;
6645 dd->bGridJump = TRUE;
6649 /* We can set the required cell size info here,
6650 * so we do not need to communicate this.
6651 * The grid is completely uniform.
6653 for(d=0; d<dd->ndim; d++)
6657 comm->load[d].sum_m = comm->load[d].sum;
6659 nc = dd->nc[dd->dim[d]];
6662 comm->root[d]->cell_f[i] = i/(real)nc;
6665 comm->root[d]->cell_f_max0[i] = i /(real)nc;
6666 comm->root[d]->cell_f_min1[i] = (i+1)/(real)nc;
6669 comm->root[d]->cell_f[nc] = 1.0;
6674 static char *init_bLocalCG(gmx_mtop_t *mtop)
6679 ncg = ncg_mtop(mtop);
6681 for(cg=0; cg<ncg; cg++)
6683 bLocalCG[cg] = FALSE;
6689 void dd_init_bondeds(FILE *fplog,
6690 gmx_domdec_t *dd,gmx_mtop_t *mtop,
6691 gmx_vsite_t *vsite,gmx_constr_t constr,
6692 t_inputrec *ir,gmx_bool bBCheck,cginfo_mb_t *cginfo_mb)
6694 gmx_domdec_comm_t *comm;
6698 dd_make_reverse_top(fplog,dd,mtop,vsite,constr,ir,bBCheck);
6702 if (comm->bBondComm)
6704 /* Communicate atoms beyond the cut-off for bonded interactions */
6707 comm->cglink = make_charge_group_links(mtop,dd,cginfo_mb);
6709 comm->bLocalCG = init_bLocalCG(mtop);
6713 /* Only communicate atoms based on cut-off */
6714 comm->cglink = NULL;
6715 comm->bLocalCG = NULL;
6719 static void print_dd_settings(FILE *fplog,gmx_domdec_t *dd,
6721 gmx_bool bDynLoadBal,real dlb_scale,
6724 gmx_domdec_comm_t *comm;
6739 fprintf(fplog,"The maximum number of communication pulses is:");
6740 for(d=0; d<dd->ndim; d++)
6742 fprintf(fplog," %c %d",dim2char(dd->dim[d]),comm->cd[d].np_dlb);
6744 fprintf(fplog,"\n");
6745 fprintf(fplog,"The minimum size for domain decomposition cells is %.3f nm\n",comm->cellsize_limit);
6746 fprintf(fplog,"The requested allowed shrink of DD cells (option -dds) is: %.2f\n",dlb_scale);
6747 fprintf(fplog,"The allowed shrink of domain decomposition cells is:");
6748 for(d=0; d<DIM; d++)
6752 if (d >= ddbox->npbcdim && dd->nc[d] == 2)
6759 comm->cellsize_min_dlb[d]/
6760 (ddbox->box_size[d]*ddbox->skew_fac[d]/dd->nc[d]);
6762 fprintf(fplog," %c %.2f",dim2char(d),shrink);
6765 fprintf(fplog,"\n");
6769 set_dd_cell_sizes_slb(dd,ddbox,FALSE,np);
6770 fprintf(fplog,"The initial number of communication pulses is:");
6771 for(d=0; d<dd->ndim; d++)
6773 fprintf(fplog," %c %d",dim2char(dd->dim[d]),np[dd->dim[d]]);
6775 fprintf(fplog,"\n");
6776 fprintf(fplog,"The initial domain decomposition cell size is:");
6777 for(d=0; d<DIM; d++) {
6780 fprintf(fplog," %c %.2f nm",
6781 dim2char(d),dd->comm->cellsize_min[d]);
6784 fprintf(fplog,"\n\n");
6787 if (comm->bInterCGBondeds || dd->vsite_comm || dd->constraint_comm)
6789 fprintf(fplog,"The maximum allowed distance for charge groups involved in interactions is:\n");
6790 fprintf(fplog,"%40s %-7s %6.3f nm\n",
6791 "non-bonded interactions","",comm->cutoff);
6795 limit = dd->comm->cellsize_limit;
6799 if (dynamic_dd_box(ddbox,ir))
6801 fprintf(fplog,"(the following are initial values, they could change due to box deformation)\n");
6803 limit = dd->comm->cellsize_min[XX];
6804 for(d=1; d<DIM; d++)
6806 limit = min(limit,dd->comm->cellsize_min[d]);
6810 if (comm->bInterCGBondeds)
6812 fprintf(fplog,"%40s %-7s %6.3f nm\n",
6813 "two-body bonded interactions","(-rdd)",
6814 max(comm->cutoff,comm->cutoff_mbody));
6815 fprintf(fplog,"%40s %-7s %6.3f nm\n",
6816 "multi-body bonded interactions","(-rdd)",
6817 (comm->bBondComm || dd->bGridJump) ? comm->cutoff_mbody : min(comm->cutoff,limit));
6821 fprintf(fplog,"%40s %-7s %6.3f nm\n",
6822 "virtual site constructions","(-rcon)",limit);
6824 if (dd->constraint_comm)
6826 sprintf(buf,"atoms separated by up to %d constraints",
6828 fprintf(fplog,"%40s %-7s %6.3f nm\n",
6829 buf,"(-rcon)",limit);
6831 fprintf(fplog,"\n");
6837 void set_dd_parameters(FILE *fplog,gmx_domdec_t *dd,real dlb_scale,
6838 t_inputrec *ir,t_forcerec *fr,
6841 gmx_domdec_comm_t *comm;
6842 int d,dim,npulse,npulse_d_max,npulse_d;
6849 bNoCutOff = (ir->rvdw == 0 || ir->rcoulomb == 0);
6851 if (EEL_PME(ir->coulombtype))
6853 init_ddpme(dd,&comm->ddpme[0],0);
6854 if (comm->npmedecompdim >= 2)
6856 init_ddpme(dd,&comm->ddpme[1],1);
6861 comm->npmenodes = 0;
6862 if (dd->pme_nodeid >= 0)
6864 gmx_fatal_collective(FARGS,NULL,dd,
6865 "Can not have separate PME nodes without PME electrostatics");
6869 /* If each molecule is a single charge group
6870 * or we use domain decomposition for each periodic dimension,
6871 * we do not need to take pbc into account for the bonded interactions.
6873 if (fr->ePBC == epbcNONE || !comm->bInterCGBondeds ||
6874 (dd->nc[XX]>1 && dd->nc[YY]>1 && (dd->nc[ZZ]>1 || fr->ePBC==epbcXY)))
6876 fr->bMolPBC = FALSE;
6885 fprintf(debug,"The DD cut-off is %f\n",comm->cutoff);
6887 if (comm->eDLB != edlbNO)
6889 /* Determine the maximum number of comm. pulses in one dimension */
6891 comm->cellsize_limit = max(comm->cellsize_limit,comm->cutoff_mbody);
6893 /* Determine the maximum required number of grid pulses */
6894 if (comm->cellsize_limit >= comm->cutoff)
6896 /* Only a single pulse is required */
6899 else if (!bNoCutOff && comm->cellsize_limit > 0)
6901 /* We round down slightly here to avoid overhead due to the latency
6902 * of extra communication calls when the cut-off
6903 * would be only slightly longer than the cell size.
6904 * Later cellsize_limit is redetermined,
6905 * so we can not miss interactions due to this rounding.
6907 npulse = (int)(0.96 + comm->cutoff/comm->cellsize_limit);
6911 /* There is no cell size limit */
6912 npulse = max(dd->nc[XX]-1,max(dd->nc[YY]-1,dd->nc[ZZ]-1));
6915 if (!bNoCutOff && npulse > 1)
6917 /* See if we can do with less pulses, based on dlb_scale */
6919 for(d=0; d<dd->ndim; d++)
6922 npulse_d = (int)(1 + dd->nc[dim]*comm->cutoff
6923 /(ddbox->box_size[dim]*ddbox->skew_fac[dim]*dlb_scale));
6924 npulse_d_max = max(npulse_d_max,npulse_d);
6926 npulse = min(npulse,npulse_d_max);
6929 /* This env var can override npulse */
6930 d = dd_nst_env(fplog,"GMX_DD_NPULSE",0);
6937 comm->bVacDLBNoLimit = (ir->ePBC == epbcNONE);
6938 for(d=0; d<dd->ndim; d++)
6940 comm->cd[d].np_dlb = min(npulse,dd->nc[dd->dim[d]]-1);
6941 comm->cd[d].np_nalloc = comm->cd[d].np_dlb;
6942 snew(comm->cd[d].ind,comm->cd[d].np_nalloc);
6943 comm->maxpulse = max(comm->maxpulse,comm->cd[d].np_dlb);
6944 if (comm->cd[d].np_dlb < dd->nc[dd->dim[d]]-1)
6946 comm->bVacDLBNoLimit = FALSE;
6950 /* cellsize_limit is set for LINCS in init_domain_decomposition */
6951 if (!comm->bVacDLBNoLimit)
6953 comm->cellsize_limit = max(comm->cellsize_limit,
6954 comm->cutoff/comm->maxpulse);
6956 comm->cellsize_limit = max(comm->cellsize_limit,comm->cutoff_mbody);
6957 /* Set the minimum cell size for each DD dimension */
6958 for(d=0; d<dd->ndim; d++)
6960 if (comm->bVacDLBNoLimit ||
6961 comm->cd[d].np_dlb*comm->cellsize_limit >= comm->cutoff)
6963 comm->cellsize_min_dlb[dd->dim[d]] = comm->cellsize_limit;
6967 comm->cellsize_min_dlb[dd->dim[d]] =
6968 comm->cutoff/comm->cd[d].np_dlb;
6971 if (comm->cutoff_mbody <= 0)
6973 comm->cutoff_mbody = min(comm->cutoff,comm->cellsize_limit);
6975 if (comm->bDynLoadBal)
6981 print_dd_settings(fplog,dd,ir,comm->bDynLoadBal,dlb_scale,ddbox);
6982 if (comm->eDLB == edlbAUTO)
6986 fprintf(fplog,"When dynamic load balancing gets turned on, these settings will change to:\n");
6988 print_dd_settings(fplog,dd,ir,TRUE,dlb_scale,ddbox);
6991 if (ir->ePBC == epbcNONE)
6993 vol_frac = 1 - 1/(double)dd->nnodes;
6998 (1 + comm_box_frac(dd->nc,comm->cutoff,ddbox))/(double)dd->nnodes;
7002 fprintf(debug,"Volume fraction for all DD zones: %f\n",vol_frac);
7004 natoms_tot = comm->cgs_gl.index[comm->cgs_gl.nr];
7006 dd->ga2la = ga2la_init(natoms_tot,vol_frac*natoms_tot);
7009 static void merge_cg_buffers(int ncell,
7010 gmx_domdec_comm_dim_t *cd, int pulse,
7012 int *index_gl, int *recv_i,
7013 rvec *cg_cm, rvec *recv_vr,
7015 cginfo_mb_t *cginfo_mb,int *cginfo)
7017 gmx_domdec_ind_t *ind,*ind_p;
7018 int p,cell,c,cg,cg0,cg1,cg_gl,nat;
7021 ind = &cd->ind[pulse];
7023 /* First correct the already stored data */
7024 shift = ind->nrecv[ncell];
7025 for(cell=ncell-1; cell>=0; cell--)
7027 shift -= ind->nrecv[cell];
7030 /* Move the cg's present from previous grid pulses */
7031 cg0 = ncg_cell[ncell+cell];
7032 cg1 = ncg_cell[ncell+cell+1];
7033 cgindex[cg1+shift] = cgindex[cg1];
7034 for(cg=cg1-1; cg>=cg0; cg--)
7036 index_gl[cg+shift] = index_gl[cg];
7037 copy_rvec(cg_cm[cg],cg_cm[cg+shift]);
7038 cgindex[cg+shift] = cgindex[cg];
7039 cginfo[cg+shift] = cginfo[cg];
7041 /* Correct the already stored send indices for the shift */
7042 for(p=1; p<=pulse; p++)
7044 ind_p = &cd->ind[p];
7046 for(c=0; c<cell; c++)
7048 cg0 += ind_p->nsend[c];
7050 cg1 = cg0 + ind_p->nsend[cell];
7051 for(cg=cg0; cg<cg1; cg++)
7053 ind_p->index[cg] += shift;
7059 /* Merge in the communicated buffers */
7063 for(cell=0; cell<ncell; cell++)
7065 cg1 = ncg_cell[ncell+cell+1] + shift;
7068 /* Correct the old cg indices */
7069 for(cg=ncg_cell[ncell+cell]; cg<cg1; cg++)
7071 cgindex[cg+1] += shift_at;
7074 for(cg=0; cg<ind->nrecv[cell]; cg++)
7076 /* Copy this charge group from the buffer */
7077 index_gl[cg1] = recv_i[cg0];
7078 copy_rvec(recv_vr[cg0],cg_cm[cg1]);
7079 /* Add it to the cgindex */
7080 cg_gl = index_gl[cg1];
7081 cginfo[cg1] = ddcginfo(cginfo_mb,cg_gl);
7082 nat = GET_CGINFO_NATOMS(cginfo[cg1]);
7083 cgindex[cg1+1] = cgindex[cg1] + nat;
7088 shift += ind->nrecv[cell];
7089 ncg_cell[ncell+cell+1] = cg1;
7093 static void make_cell2at_index(gmx_domdec_comm_dim_t *cd,
7094 int nzone,int cg0,const int *cgindex)
7098 /* Store the atom block boundaries for easy copying of communication buffers
7101 for(zone=0; zone<nzone; zone++)
7103 for(p=0; p<cd->np; p++) {
7104 cd->ind[p].cell2at0[zone] = cgindex[cg];
7105 cg += cd->ind[p].nrecv[zone];
7106 cd->ind[p].cell2at1[zone] = cgindex[cg];
7111 static gmx_bool missing_link(t_blocka *link,int cg_gl,char *bLocalCG)
7117 for(i=link->index[cg_gl]; i<link->index[cg_gl+1]; i++)
7119 if (!bLocalCG[link->a[i]])
7128 static void setup_dd_communication(gmx_domdec_t *dd,
7129 matrix box,gmx_ddbox_t *ddbox,t_forcerec *fr)
7131 int dim_ind,dim,dim0,dim1=-1,dim2=-1,dimd,p,nat_tot;
7132 int nzone,nzone_send,zone,zonei,cg0,cg1;
7133 int c,i,j,cg,cg_gl,nrcg;
7134 int *zone_cg_range,pos_cg,*index_gl,*cgindex,*recv_i;
7135 gmx_domdec_comm_t *comm;
7136 gmx_domdec_zones_t *zones;
7137 gmx_domdec_comm_dim_t *cd;
7138 gmx_domdec_ind_t *ind;
7139 cginfo_mb_t *cginfo_mb;
7140 gmx_bool bBondComm,bDist2B,bDistMB,bDistMB_pulse,bDistBonded,bScrew;
7141 real r_mb,r_comm2,r_scomm2,r_bcomm2,r,r_0,r_1,r2,rb2,r2inc,inv_ncg,tric_sh;
7143 real corner[DIM][4],corner_round_0=0,corner_round_1[4];
7144 real bcorner[DIM],bcorner_round_1=0;
7146 rvec *cg_cm,*normal,*v_d,*v_0=NULL,*v_1=NULL,*recv_vr;
7147 real skew_fac2_d,skew_fac_01;
7153 fprintf(debug,"Setting up DD communication\n");
7159 for(dim_ind=0; dim_ind<dd->ndim; dim_ind++)
7161 dim = dd->dim[dim_ind];
7163 /* Check if we need to use triclinic distances */
7164 tric_dist[dim_ind] = 0;
7165 for(i=0; i<=dim_ind; i++)
7167 if (ddbox->tric_dir[dd->dim[i]])
7169 tric_dist[dim_ind] = 1;
7174 bBondComm = comm->bBondComm;
7176 /* Do we need to determine extra distances for multi-body bondeds? */
7177 bDistMB = (comm->bInterCGMultiBody && dd->bGridJump && dd->ndim > 1);
7179 /* Do we need to determine extra distances for only two-body bondeds? */
7180 bDist2B = (bBondComm && !bDistMB);
7182 r_comm2 = sqr(comm->cutoff);
7183 r_bcomm2 = sqr(comm->cutoff_mbody);
7187 fprintf(debug,"bBondComm %d, r_bc %f\n",bBondComm,sqrt(r_bcomm2));
7190 zones = &comm->zones;
7193 /* The first dimension is equal for all cells */
7194 corner[0][0] = comm->cell_x0[dim0];
7197 bcorner[0] = corner[0][0];
7202 /* This cell row is only seen from the first row */
7203 corner[1][0] = comm->cell_x0[dim1];
7204 /* All rows can see this row */
7205 corner[1][1] = comm->cell_x0[dim1];
7208 corner[1][1] = max(comm->cell_x0[dim1],comm->zone_d1[1].mch0);
7211 /* For the multi-body distance we need the maximum */
7212 bcorner[1] = max(comm->cell_x0[dim1],comm->zone_d1[1].p1_0);
7215 /* Set the upper-right corner for rounding */
7216 corner_round_0 = comm->cell_x1[dim0];
7223 corner[2][j] = comm->cell_x0[dim2];
7227 /* Use the maximum of the i-cells that see a j-cell */
7228 for(i=0; i<zones->nizone; i++)
7230 for(j=zones->izone[i].j0; j<zones->izone[i].j1; j++)
7236 comm->zone_d2[zones->shift[i][dim0]][zones->shift[i][dim1]].mch0);
7242 /* For the multi-body distance we need the maximum */
7243 bcorner[2] = comm->cell_x0[dim2];
7248 bcorner[2] = max(bcorner[2],
7249 comm->zone_d2[i][j].p1_0);
7255 /* Set the upper-right corner for rounding */
7256 /* Cell (0,0,0) and cell (1,0,0) can see cell 4 (0,1,1)
7257 * Only cell (0,0,0) can see cell 7 (1,1,1)
7259 corner_round_1[0] = comm->cell_x1[dim1];
7260 corner_round_1[3] = comm->cell_x1[dim1];
7263 corner_round_1[0] = max(comm->cell_x1[dim1],
7264 comm->zone_d1[1].mch1);
7267 /* For the multi-body distance we need the maximum */
7268 bcorner_round_1 = max(comm->cell_x1[dim1],
7269 comm->zone_d1[1].p1_1);
7275 /* Triclinic stuff */
7276 normal = ddbox->normal;
7280 v_0 = ddbox->v[dim0];
7281 if (ddbox->tric_dir[dim0] && ddbox->tric_dir[dim1])
7283 /* Determine the coupling coefficient for the distances
7284 * to the cell planes along dim0 and dim1 through dim2.
7285 * This is required for correct rounding.
7288 ddbox->v[dim0][dim1+1][dim0]*ddbox->v[dim1][dim1+1][dim1];
7291 fprintf(debug,"\nskew_fac_01 %f\n",skew_fac_01);
7297 v_1 = ddbox->v[dim1];
7300 zone_cg_range = zones->cg_range;
7301 index_gl = dd->index_gl;
7302 cgindex = dd->cgindex;
7303 cginfo_mb = fr->cginfo_mb;
7305 zone_cg_range[0] = 0;
7306 zone_cg_range[1] = dd->ncg_home;
7307 comm->zone_ncg1[0] = dd->ncg_home;
7308 pos_cg = dd->ncg_home;
7310 nat_tot = dd->nat_home;
7312 for(dim_ind=0; dim_ind<dd->ndim; dim_ind++)
7314 dim = dd->dim[dim_ind];
7315 cd = &comm->cd[dim_ind];
7317 if (dim >= ddbox->npbcdim && dd->ci[dim] == 0)
7319 /* No pbc in this dimension, the first node should not comm. */
7327 bScrew = (dd->bScrewPBC && dim == XX);
7329 v_d = ddbox->v[dim];
7330 skew_fac2_d = sqr(ddbox->skew_fac[dim]);
7332 cd->bInPlace = TRUE;
7333 for(p=0; p<cd->np; p++)
7335 /* Only atoms communicated in the first pulse are used
7336 * for multi-body bonded interactions or for bBondComm.
7338 bDistBonded = ((bDistMB || bDist2B) && p == 0);
7339 bDistMB_pulse = (bDistMB && bDistBonded);
7344 for(zone=0; zone<nzone_send; zone++)
7346 if (tric_dist[dim_ind] && dim_ind > 0)
7348 /* Determine slightly more optimized skew_fac's
7350 * This reduces the number of communicated atoms
7351 * by about 10% for 3D DD of rhombic dodecahedra.
7353 for(dimd=0; dimd<dim; dimd++)
7355 sf2_round[dimd] = 1;
7356 if (ddbox->tric_dir[dimd])
7358 for(i=dd->dim[dimd]+1; i<DIM; i++)
7360 /* If we are shifted in dimension i
7361 * and the cell plane is tilted forward
7362 * in dimension i, skip this coupling.
7364 if (!(zones->shift[nzone+zone][i] &&
7365 ddbox->v[dimd][i][dimd] >= 0))
7368 sqr(ddbox->v[dimd][i][dimd]);
7371 sf2_round[dimd] = 1/sf2_round[dimd];
7376 zonei = zone_perm[dim_ind][zone];
7379 /* Here we permutate the zones to obtain a convenient order
7380 * for neighbor searching
7382 cg0 = zone_cg_range[zonei];
7383 cg1 = zone_cg_range[zonei+1];
7387 /* Look only at the cg's received in the previous grid pulse
7389 cg1 = zone_cg_range[nzone+zone+1];
7390 cg0 = cg1 - cd->ind[p-1].nrecv[zone];
7392 ind->nsend[zone] = 0;
7393 for(cg=cg0; cg<cg1; cg++)
7397 if (tric_dist[dim_ind] == 0)
7399 /* Rectangular direction, easy */
7400 r = cg_cm[cg][dim] - corner[dim_ind][zone];
7407 r = cg_cm[cg][dim] - bcorner[dim_ind];
7413 /* Rounding gives at most a 16% reduction
7414 * in communicated atoms
7416 if (dim_ind >= 1 && (zonei == 1 || zonei == 2))
7418 r = cg_cm[cg][dim0] - corner_round_0;
7419 /* This is the first dimension, so always r >= 0 */
7426 if (dim_ind == 2 && (zonei == 2 || zonei == 3))
7428 r = cg_cm[cg][dim1] - corner_round_1[zone];
7435 r = cg_cm[cg][dim1] - bcorner_round_1;
7445 /* Triclinic direction, more complicated */
7448 /* Rounding, conservative as the skew_fac multiplication
7449 * will slightly underestimate the distance.
7451 if (dim_ind >= 1 && (zonei == 1 || zonei == 2))
7453 rn[dim0] = cg_cm[cg][dim0] - corner_round_0;
7454 for(i=dim0+1; i<DIM; i++)
7456 rn[dim0] -= cg_cm[cg][i]*v_0[i][dim0];
7458 r2 = rn[dim0]*rn[dim0]*sf2_round[dim0];
7461 rb[dim0] = rn[dim0];
7464 /* Take care that the cell planes along dim0 might not
7465 * be orthogonal to those along dim1 and dim2.
7467 for(i=1; i<=dim_ind; i++)
7470 if (normal[dim0][dimd] > 0)
7472 rn[dimd] -= rn[dim0]*normal[dim0][dimd];
7475 rb[dimd] -= rb[dim0]*normal[dim0][dimd];
7480 if (dim_ind == 2 && (zonei == 2 || zonei == 3))
7482 rn[dim1] += cg_cm[cg][dim1] - corner_round_1[zone];
7484 for(i=dim1+1; i<DIM; i++)
7486 tric_sh -= cg_cm[cg][i]*v_1[i][dim1];
7488 rn[dim1] += tric_sh;
7491 r2 += rn[dim1]*rn[dim1]*sf2_round[dim1];
7492 /* Take care of coupling of the distances
7493 * to the planes along dim0 and dim1 through dim2.
7495 r2 -= rn[dim0]*rn[dim1]*skew_fac_01;
7496 /* Take care that the cell planes along dim1
7497 * might not be orthogonal to that along dim2.
7499 if (normal[dim1][dim2] > 0)
7501 rn[dim2] -= rn[dim1]*normal[dim1][dim2];
7507 cg_cm[cg][dim1] - bcorner_round_1 + tric_sh;
7510 rb2 += rb[dim1]*rb[dim1]*sf2_round[dim1];
7511 /* Take care of coupling of the distances
7512 * to the planes along dim0 and dim1 through dim2.
7514 rb2 -= rb[dim0]*rb[dim1]*skew_fac_01;
7515 /* Take care that the cell planes along dim1
7516 * might not be orthogonal to that along dim2.
7518 if (normal[dim1][dim2] > 0)
7520 rb[dim2] -= rb[dim1]*normal[dim1][dim2];
7525 /* The distance along the communication direction */
7526 rn[dim] += cg_cm[cg][dim] - corner[dim_ind][zone];
7528 for(i=dim+1; i<DIM; i++)
7530 tric_sh -= cg_cm[cg][i]*v_d[i][dim];
7535 r2 += rn[dim]*rn[dim]*skew_fac2_d;
7536 /* Take care of coupling of the distances
7537 * to the planes along dim0 and dim1 through dim2.
7539 if (dim_ind == 1 && zonei == 1)
7541 r2 -= rn[dim0]*rn[dim]*skew_fac_01;
7547 rb[dim] += cg_cm[cg][dim] - bcorner[dim_ind] + tric_sh;
7550 rb2 += rb[dim]*rb[dim]*skew_fac2_d;
7551 /* Take care of coupling of the distances
7552 * to the planes along dim0 and dim1 through dim2.
7554 if (dim_ind == 1 && zonei == 1)
7556 rb2 -= rb[dim0]*rb[dim]*skew_fac_01;
7564 ((bDistMB && rb2 < r_bcomm2) ||
7565 (bDist2B && r2 < r_bcomm2)) &&
7567 (GET_CGINFO_BOND_INTER(fr->cginfo[cg]) &&
7568 missing_link(comm->cglink,index_gl[cg],
7571 /* Make an index to the local charge groups */
7572 if (nsend+1 > ind->nalloc)
7574 ind->nalloc = over_alloc_large(nsend+1);
7575 srenew(ind->index,ind->nalloc);
7577 if (nsend+1 > comm->nalloc_int)
7579 comm->nalloc_int = over_alloc_large(nsend+1);
7580 srenew(comm->buf_int,comm->nalloc_int);
7582 ind->index[nsend] = cg;
7583 comm->buf_int[nsend] = index_gl[cg];
7585 vec_rvec_check_alloc(&comm->vbuf,nsend+1);
7587 if (dd->ci[dim] == 0)
7589 /* Correct cg_cm for pbc */
7590 rvec_add(cg_cm[cg],box[dim],comm->vbuf.v[nsend]);
7593 comm->vbuf.v[nsend][YY] =
7594 box[YY][YY]-comm->vbuf.v[nsend][YY];
7595 comm->vbuf.v[nsend][ZZ] =
7596 box[ZZ][ZZ]-comm->vbuf.v[nsend][ZZ];
7601 copy_rvec(cg_cm[cg],comm->vbuf.v[nsend]);
7604 nat += cgindex[cg+1] - cgindex[cg];
7608 /* Clear the counts in case we do not have pbc */
7609 for(zone=nzone_send; zone<nzone; zone++)
7611 ind->nsend[zone] = 0;
7613 ind->nsend[nzone] = nsend;
7614 ind->nsend[nzone+1] = nat;
7615 /* Communicate the number of cg's and atoms to receive */
7616 dd_sendrecv_int(dd, dim_ind, dddirBackward,
7617 ind->nsend, nzone+2,
7618 ind->nrecv, nzone+2);
7620 /* The rvec buffer is also required for atom buffers of size nsend
7621 * in dd_move_x and dd_move_f.
7623 vec_rvec_check_alloc(&comm->vbuf,ind->nsend[nzone+1]);
7627 /* We can receive in place if only the last zone is not empty */
7628 for(zone=0; zone<nzone-1; zone++)
7630 if (ind->nrecv[zone] > 0)
7632 cd->bInPlace = FALSE;
7637 /* The int buffer is only required here for the cg indices */
7638 if (ind->nrecv[nzone] > comm->nalloc_int2)
7640 comm->nalloc_int2 = over_alloc_dd(ind->nrecv[nzone]);
7641 srenew(comm->buf_int2,comm->nalloc_int2);
7643 /* The rvec buffer is also required for atom buffers
7644 * of size nrecv in dd_move_x and dd_move_f.
7646 i = max(cd->ind[0].nrecv[nzone+1],ind->nrecv[nzone+1]);
7647 vec_rvec_check_alloc(&comm->vbuf2,i);
7651 /* Make space for the global cg indices */
7652 if (pos_cg + ind->nrecv[nzone] > dd->cg_nalloc
7653 || dd->cg_nalloc == 0)
7655 dd->cg_nalloc = over_alloc_dd(pos_cg + ind->nrecv[nzone]);
7656 srenew(index_gl,dd->cg_nalloc);
7657 srenew(cgindex,dd->cg_nalloc+1);
7659 /* Communicate the global cg indices */
7662 recv_i = index_gl + pos_cg;
7666 recv_i = comm->buf_int2;
7668 dd_sendrecv_int(dd, dim_ind, dddirBackward,
7669 comm->buf_int, nsend,
7670 recv_i, ind->nrecv[nzone]);
7672 /* Make space for cg_cm */
7673 if (pos_cg + ind->nrecv[nzone] > fr->cg_nalloc)
7675 dd_realloc_fr_cg(fr,pos_cg + ind->nrecv[nzone]);
7678 /* Communicate cg_cm */
7681 recv_vr = cg_cm + pos_cg;
7685 recv_vr = comm->vbuf2.v;
7687 dd_sendrecv_rvec(dd, dim_ind, dddirBackward,
7688 comm->vbuf.v, nsend,
7689 recv_vr, ind->nrecv[nzone]);
7691 /* Make the charge group index */
7694 zone = (p == 0 ? 0 : nzone - 1);
7695 while (zone < nzone)
7697 for(cg=0; cg<ind->nrecv[zone]; cg++)
7699 cg_gl = index_gl[pos_cg];
7700 fr->cginfo[pos_cg] = ddcginfo(cginfo_mb,cg_gl);
7701 nrcg = GET_CGINFO_NATOMS(fr->cginfo[pos_cg]);
7702 cgindex[pos_cg+1] = cgindex[pos_cg] + nrcg;
7705 /* Update the charge group presence,
7706 * so we can use it in the next pass of the loop.
7708 comm->bLocalCG[cg_gl] = TRUE;
7714 comm->zone_ncg1[nzone+zone] = ind->nrecv[zone];
7717 zone_cg_range[nzone+zone] = pos_cg;
7722 /* This part of the code is never executed with bBondComm. */
7723 merge_cg_buffers(nzone,cd,p,zone_cg_range,
7724 index_gl,recv_i,cg_cm,recv_vr,
7725 cgindex,fr->cginfo_mb,fr->cginfo);
7726 pos_cg += ind->nrecv[nzone];
7728 nat_tot += ind->nrecv[nzone+1];
7732 /* Store the atom block for easy copying of communication buffers */
7733 make_cell2at_index(cd,nzone,zone_cg_range[nzone],cgindex);
7737 dd->index_gl = index_gl;
7738 dd->cgindex = cgindex;
7740 dd->ncg_tot = zone_cg_range[zones->n];
7741 dd->nat_tot = nat_tot;
7742 comm->nat[ddnatHOME] = dd->nat_home;
7743 for(i=ddnatZONE; i<ddnatNR; i++)
7745 comm->nat[i] = dd->nat_tot;
7750 /* We don't need to update cginfo, since that was alrady done above.
7751 * So we pass NULL for the forcerec.
7753 dd_set_cginfo(dd->index_gl,dd->ncg_home,dd->ncg_tot,
7754 NULL,comm->bLocalCG);
7759 fprintf(debug,"Finished setting up DD communication, zones:");
7760 for(c=0; c<zones->n; c++)
7762 fprintf(debug," %d",zones->cg_range[c+1]-zones->cg_range[c]);
7764 fprintf(debug,"\n");
7768 static void set_cg_boundaries(gmx_domdec_zones_t *zones)
7772 for(c=0; c<zones->nizone; c++)
7774 zones->izone[c].cg1 = zones->cg_range[c+1];
7775 zones->izone[c].jcg0 = zones->cg_range[zones->izone[c].j0];
7776 zones->izone[c].jcg1 = zones->cg_range[zones->izone[c].j1];
7780 static int comp_cgsort(const void *a,const void *b)
7784 gmx_cgsort_t *cga,*cgb;
7785 cga = (gmx_cgsort_t *)a;
7786 cgb = (gmx_cgsort_t *)b;
7788 comp = cga->nsc - cgb->nsc;
7791 comp = cga->ind_gl - cgb->ind_gl;
7797 static void order_int_cg(int n,gmx_cgsort_t *sort,
7802 /* Order the data */
7805 buf[i] = a[sort[i].ind];
7808 /* Copy back to the original array */
7815 static void order_vec_cg(int n,gmx_cgsort_t *sort,
7820 /* Order the data */
7823 copy_rvec(v[sort[i].ind],buf[i]);
7826 /* Copy back to the original array */
7829 copy_rvec(buf[i],v[i]);
7833 static void order_vec_atom(int ncg,int *cgindex,gmx_cgsort_t *sort,
7836 int a,atot,cg,cg0,cg1,i;
7838 /* Order the data */
7840 for(cg=0; cg<ncg; cg++)
7842 cg0 = cgindex[sort[cg].ind];
7843 cg1 = cgindex[sort[cg].ind+1];
7844 for(i=cg0; i<cg1; i++)
7846 copy_rvec(v[i],buf[a]);
7852 /* Copy back to the original array */
7853 for(a=0; a<atot; a++)
7855 copy_rvec(buf[a],v[a]);
7859 static void ordered_sort(int nsort2,gmx_cgsort_t *sort2,
7860 int nsort_new,gmx_cgsort_t *sort_new,
7861 gmx_cgsort_t *sort1)
7865 /* The new indices are not very ordered, so we qsort them */
7866 qsort_threadsafe(sort_new,nsort_new,sizeof(sort_new[0]),comp_cgsort);
7868 /* sort2 is already ordered, so now we can merge the two arrays */
7872 while(i2 < nsort2 || i_new < nsort_new)
7876 sort1[i1++] = sort_new[i_new++];
7878 else if (i_new == nsort_new)
7880 sort1[i1++] = sort2[i2++];
7882 else if (sort2[i2].nsc < sort_new[i_new].nsc ||
7883 (sort2[i2].nsc == sort_new[i_new].nsc &&
7884 sort2[i2].ind_gl < sort_new[i_new].ind_gl))
7886 sort1[i1++] = sort2[i2++];
7890 sort1[i1++] = sort_new[i_new++];
7895 static void dd_sort_state(gmx_domdec_t *dd,int ePBC,
7896 rvec *cgcm,t_forcerec *fr,t_state *state,
7899 gmx_domdec_sort_t *sort;
7900 gmx_cgsort_t *cgsort,*sort_i;
7901 int ncg_new,nsort2,nsort_new,i,cell_index,*ibuf,cgsize;
7904 sort = dd->comm->sort;
7906 if (dd->ncg_home > sort->sort_nalloc)
7908 sort->sort_nalloc = over_alloc_dd(dd->ncg_home);
7909 srenew(sort->sort1,sort->sort_nalloc);
7910 srenew(sort->sort2,sort->sort_nalloc);
7913 if (ncg_home_old >= 0)
7915 /* The charge groups that remained in the same ns grid cell
7916 * are completely ordered. So we can sort efficiently by sorting
7917 * the charge groups that did move into the stationary list.
7922 for(i=0; i<dd->ncg_home; i++)
7924 /* Check if this cg did not move to another node */
7925 cell_index = fr->ns.grid->cell_index[i];
7926 if (cell_index != 4*fr->ns.grid->ncells)
7928 if (i >= ncg_home_old || cell_index != sort->sort1[i].nsc)
7930 /* This cg is new on this node or moved ns grid cell */
7931 if (nsort_new >= sort->sort_new_nalloc)
7933 sort->sort_new_nalloc = over_alloc_dd(nsort_new+1);
7934 srenew(sort->sort_new,sort->sort_new_nalloc);
7936 sort_i = &(sort->sort_new[nsort_new++]);
7940 /* This cg did not move */
7941 sort_i = &(sort->sort2[nsort2++]);
7943 /* Sort on the ns grid cell indices
7944 * and the global topology index
7946 sort_i->nsc = cell_index;
7947 sort_i->ind_gl = dd->index_gl[i];
7954 fprintf(debug,"ordered sort cgs: stationary %d moved %d\n",
7957 /* Sort efficiently */
7958 ordered_sort(nsort2,sort->sort2,nsort_new,sort->sort_new,sort->sort1);
7962 cgsort = sort->sort1;
7964 for(i=0; i<dd->ncg_home; i++)
7966 /* Sort on the ns grid cell indices
7967 * and the global topology index
7969 cgsort[i].nsc = fr->ns.grid->cell_index[i];
7970 cgsort[i].ind_gl = dd->index_gl[i];
7972 if (cgsort[i].nsc != 4*fr->ns.grid->ncells)
7979 fprintf(debug,"qsort cgs: %d new home %d\n",dd->ncg_home,ncg_new);
7981 /* Determine the order of the charge groups using qsort */
7982 qsort_threadsafe(cgsort,dd->ncg_home,sizeof(cgsort[0]),comp_cgsort);
7984 cgsort = sort->sort1;
7986 /* We alloc with the old size, since cgindex is still old */
7987 vec_rvec_check_alloc(&dd->comm->vbuf,dd->cgindex[dd->ncg_home]);
7988 vbuf = dd->comm->vbuf.v;
7990 /* Remove the charge groups which are no longer at home here */
7991 dd->ncg_home = ncg_new;
7993 /* Reorder the state */
7994 for(i=0; i<estNR; i++)
7996 if (EST_DISTR(i) && (state->flags & (1<<i)))
8001 order_vec_atom(dd->ncg_home,dd->cgindex,cgsort,state->x,vbuf);
8004 order_vec_atom(dd->ncg_home,dd->cgindex,cgsort,state->v,vbuf);
8007 order_vec_atom(dd->ncg_home,dd->cgindex,cgsort,state->sd_X,vbuf);
8010 order_vec_atom(dd->ncg_home,dd->cgindex,cgsort,state->cg_p,vbuf);
8014 case estDISRE_INITF:
8015 case estDISRE_RM3TAV:
8016 case estORIRE_INITF:
8018 /* No ordering required */
8021 gmx_incons("Unknown state entry encountered in dd_sort_state");
8027 order_vec_cg(dd->ncg_home,cgsort,cgcm,vbuf);
8029 if (dd->ncg_home+1 > sort->ibuf_nalloc)
8031 sort->ibuf_nalloc = over_alloc_dd(dd->ncg_home+1);
8032 srenew(sort->ibuf,sort->ibuf_nalloc);
8035 /* Reorder the global cg index */
8036 order_int_cg(dd->ncg_home,cgsort,dd->index_gl,ibuf);
8037 /* Reorder the cginfo */
8038 order_int_cg(dd->ncg_home,cgsort,fr->cginfo,ibuf);
8039 /* Rebuild the local cg index */
8041 for(i=0; i<dd->ncg_home; i++)
8043 cgsize = dd->cgindex[cgsort[i].ind+1] - dd->cgindex[cgsort[i].ind];
8044 ibuf[i+1] = ibuf[i] + cgsize;
8046 for(i=0; i<dd->ncg_home+1; i++)
8048 dd->cgindex[i] = ibuf[i];
8050 /* Set the home atom number */
8051 dd->nat_home = dd->cgindex[dd->ncg_home];
8053 /* Copy the sorted ns cell indices back to the ns grid struct */
8054 for(i=0; i<dd->ncg_home; i++)
8056 fr->ns.grid->cell_index[i] = cgsort[i].nsc;
8058 fr->ns.grid->nr = dd->ncg_home;
8061 static void add_dd_statistics(gmx_domdec_t *dd)
8063 gmx_domdec_comm_t *comm;
8068 for(ddnat=ddnatZONE; ddnat<ddnatNR; ddnat++)
8070 comm->sum_nat[ddnat-ddnatZONE] +=
8071 comm->nat[ddnat] - comm->nat[ddnat-1];
8076 void reset_dd_statistics_counters(gmx_domdec_t *dd)
8078 gmx_domdec_comm_t *comm;
8083 /* Reset all the statistics and counters for total run counting */
8084 for(ddnat=ddnatZONE; ddnat<ddnatNR; ddnat++)
8086 comm->sum_nat[ddnat-ddnatZONE] = 0;
8090 comm->load_step = 0;
8093 clear_ivec(comm->load_lim);
8098 void print_dd_statistics(t_commrec *cr,t_inputrec *ir,FILE *fplog)
8100 gmx_domdec_comm_t *comm;
8104 comm = cr->dd->comm;
8106 gmx_sumd(ddnatNR-ddnatZONE,comm->sum_nat,cr);
8113 fprintf(fplog,"\n D O M A I N D E C O M P O S I T I O N S T A T I S T I C S\n\n");
8115 for(ddnat=ddnatZONE; ddnat<ddnatNR; ddnat++)
8117 av = comm->sum_nat[ddnat-ddnatZONE]/comm->ndecomp;
8122 " av. #atoms communicated per step for force: %d x %.1f\n",
8126 if (cr->dd->vsite_comm)
8129 " av. #atoms communicated per step for vsites: %d x %.1f\n",
8130 (EEL_PME(ir->coulombtype) || ir->coulombtype==eelEWALD) ? 3 : 2,
8135 if (cr->dd->constraint_comm)
8138 " av. #atoms communicated per step for LINCS: %d x %.1f\n",
8139 1 + ir->nLincsIter,av);
8143 gmx_incons(" Unknown type for DD statistics");
8146 fprintf(fplog,"\n");
8148 if (comm->bRecordLoad && EI_DYNAMICS(ir->eI))
8150 print_dd_load_av(fplog,cr->dd);
8154 void dd_partition_system(FILE *fplog,
8155 gmx_large_int_t step,
8157 gmx_bool bMasterState,
8159 t_state *state_global,
8160 gmx_mtop_t *top_global,
8162 t_state *state_local,
8165 gmx_localtop_t *top_local,
8168 gmx_shellfc_t shellfc,
8169 gmx_constr_t constr,
8171 gmx_wallcycle_t wcycle,
8175 gmx_domdec_comm_t *comm;
8176 gmx_ddbox_t ddbox={0};
8178 gmx_large_int_t step_pcoupl;
8179 rvec cell_ns_x0,cell_ns_x1;
8180 int i,j,n,cg0=0,ncg_home_old=-1,nat_f_novirsum;
8181 gmx_bool bBoxChanged,bNStGlobalComm,bDoDLB,bCheckDLB,bTurnOnDLB,bLogLoad;
8182 gmx_bool bRedist,bSortCG,bResortAll;
8190 bBoxChanged = (bMasterState || DEFORM(*ir));
8191 if (ir->epc != epcNO)
8193 /* With nstpcouple > 1 pressure coupling happens.
8194 * one step after calculating the pressure.
8195 * Box scaling happens at the end of the MD step,
8196 * after the DD partitioning.
8197 * We therefore have to do DLB in the first partitioning
8198 * after an MD step where P-coupling occured.
8199 * We need to determine the last step in which p-coupling occurred.
8200 * MRS -- need to validate this for vv?
8205 step_pcoupl = step - 1;
8209 step_pcoupl = ((step - 1)/n)*n + 1;
8211 if (step_pcoupl >= comm->globalcomm_step)
8217 bNStGlobalComm = (step >= comm->globalcomm_step + nstglobalcomm);
8219 if (!comm->bDynLoadBal)
8225 /* Should we do dynamic load balacing this step?
8226 * Since it requires (possibly expensive) global communication,
8227 * we might want to do DLB less frequently.
8229 if (bBoxChanged || ir->epc != epcNO)
8231 bDoDLB = bBoxChanged;
8235 bDoDLB = bNStGlobalComm;
8239 /* Check if we have recorded loads on the nodes */
8240 if (comm->bRecordLoad && dd_load_count(comm))
8242 if (comm->eDLB == edlbAUTO && !comm->bDynLoadBal)
8244 /* Check if we should use DLB at the second partitioning
8245 * and every 100 partitionings,
8246 * so the extra communication cost is negligible.
8248 n = max(100,nstglobalcomm);
8249 bCheckDLB = (comm->n_load_collect == 0 ||
8250 comm->n_load_have % n == n-1);
8257 /* Print load every nstlog, first and last step to the log file */
8258 bLogLoad = ((ir->nstlog > 0 && step % ir->nstlog == 0) ||
8259 comm->n_load_collect == 0 ||
8261 (step + ir->nstlist > ir->init_step + ir->nsteps)));
8263 /* Avoid extra communication due to verbose screen output
8264 * when nstglobalcomm is set.
8266 if (bDoDLB || bLogLoad || bCheckDLB ||
8267 (bVerbose && (ir->nstlist == 0 || nstglobalcomm <= ir->nstlist)))
8269 get_load_distribution(dd,wcycle);
8274 dd_print_load(fplog,dd,step-1);
8278 dd_print_load_verbose(dd);
8281 comm->n_load_collect++;
8284 /* Since the timings are node dependent, the master decides */
8288 (dd_force_imb_perf_loss(dd) >= DD_PERF_LOSS);
8291 fprintf(debug,"step %s, imb loss %f\n",
8292 gmx_step_str(step,sbuf),
8293 dd_force_imb_perf_loss(dd));
8296 dd_bcast(dd,sizeof(bTurnOnDLB),&bTurnOnDLB);
8299 turn_on_dlb(fplog,cr,step);
8304 comm->n_load_have++;
8307 cgs_gl = &comm->cgs_gl;
8312 /* Clear the old state */
8313 clear_dd_indices(dd,0,0);
8315 set_ddbox(dd,bMasterState,cr,ir,state_global->box,
8316 TRUE,cgs_gl,state_global->x,&ddbox);
8318 get_cg_distribution(fplog,step,dd,cgs_gl,
8319 state_global->box,&ddbox,state_global->x);
8321 dd_distribute_state(dd,cgs_gl,
8322 state_global,state_local,f);
8324 dd_make_local_cgs(dd,&top_local->cgs);
8326 if (dd->ncg_home > fr->cg_nalloc)
8328 dd_realloc_fr_cg(fr,dd->ncg_home);
8330 calc_cgcm(fplog,0,dd->ncg_home,
8331 &top_local->cgs,state_local->x,fr->cg_cm);
8333 inc_nrnb(nrnb,eNR_CGCM,dd->nat_home);
8335 dd_set_cginfo(dd->index_gl,0,dd->ncg_home,fr,comm->bLocalCG);
8339 else if (state_local->ddp_count != dd->ddp_count)
8341 if (state_local->ddp_count > dd->ddp_count)
8343 gmx_fatal(FARGS,"Internal inconsistency state_local->ddp_count (%d) > dd->ddp_count (%d)",state_local->ddp_count,dd->ddp_count);
8346 if (state_local->ddp_count_cg_gl != state_local->ddp_count)
8348 gmx_fatal(FARGS,"Internal inconsistency state_local->ddp_count_cg_gl (%d) != state_local->ddp_count (%d)",state_local->ddp_count_cg_gl,state_local->ddp_count);
8351 /* Clear the old state */
8352 clear_dd_indices(dd,0,0);
8354 /* Build the new indices */
8355 rebuild_cgindex(dd,cgs_gl->index,state_local);
8356 make_dd_indices(dd,cgs_gl->index,0);
8358 /* Redetermine the cg COMs */
8359 calc_cgcm(fplog,0,dd->ncg_home,
8360 &top_local->cgs,state_local->x,fr->cg_cm);
8362 inc_nrnb(nrnb,eNR_CGCM,dd->nat_home);
8364 dd_set_cginfo(dd->index_gl,0,dd->ncg_home,fr,comm->bLocalCG);
8366 set_ddbox(dd,bMasterState,cr,ir,state_local->box,
8367 TRUE,&top_local->cgs,state_local->x,&ddbox);
8369 bRedist = comm->bDynLoadBal;
8373 /* We have the full state, only redistribute the cgs */
8375 /* Clear the non-home indices */
8376 clear_dd_indices(dd,dd->ncg_home,dd->nat_home);
8378 /* Avoid global communication for dim's without pbc and -gcom */
8379 if (!bNStGlobalComm)
8381 copy_rvec(comm->box0 ,ddbox.box0 );
8382 copy_rvec(comm->box_size,ddbox.box_size);
8384 set_ddbox(dd,bMasterState,cr,ir,state_local->box,
8385 bNStGlobalComm,&top_local->cgs,state_local->x,&ddbox);
8390 /* For dim's without pbc and -gcom */
8391 copy_rvec(ddbox.box0 ,comm->box0 );
8392 copy_rvec(ddbox.box_size,comm->box_size);
8394 set_dd_cell_sizes(dd,&ddbox,dynamic_dd_box(&ddbox,ir),bMasterState,bDoDLB,
8397 if (comm->nstDDDumpGrid > 0 && step % comm->nstDDDumpGrid == 0)
8399 write_dd_grid_pdb("dd_grid",step,dd,state_local->box,&ddbox);
8402 /* Check if we should sort the charge groups */
8403 if (comm->nstSortCG > 0)
8405 bSortCG = (bMasterState ||
8406 (bRedist && (step % comm->nstSortCG == 0)));
8413 ncg_home_old = dd->ncg_home;
8417 cg0 = dd_redistribute_cg(fplog,step,dd,ddbox.tric_dir,
8418 state_local,f,fr,mdatoms,
8422 get_nsgrid_boundaries(fr->ns.grid,dd,
8423 state_local->box,&ddbox,&comm->cell_x0,&comm->cell_x1,
8424 dd->ncg_home,fr->cg_cm,
8425 cell_ns_x0,cell_ns_x1,&grid_density);
8429 comm_dd_ns_cell_sizes(dd,&ddbox,cell_ns_x0,cell_ns_x1,step);
8432 copy_ivec(fr->ns.grid->n,ncells_old);
8433 grid_first(fplog,fr->ns.grid,dd,&ddbox,fr->ePBC,
8434 state_local->box,cell_ns_x0,cell_ns_x1,
8435 fr->rlistlong,grid_density);
8436 /* We need to store tric_dir for dd_get_ns_ranges called from ns.c */
8437 copy_ivec(ddbox.tric_dir,comm->tric_dir);
8441 /* Sort the state on charge group position.
8442 * This enables exact restarts from this step.
8443 * It also improves performance by about 15% with larger numbers
8444 * of atoms per node.
8447 /* Fill the ns grid with the home cell,
8448 * so we can sort with the indices.
8450 set_zones_ncg_home(dd);
8451 fill_grid(fplog,&comm->zones,fr->ns.grid,dd->ncg_home,
8452 0,dd->ncg_home,fr->cg_cm);
8454 /* Check if we can user the old order and ns grid cell indices
8455 * of the charge groups to sort the charge groups efficiently.
8457 bResortAll = (bMasterState ||
8458 fr->ns.grid->n[XX] != ncells_old[XX] ||
8459 fr->ns.grid->n[YY] != ncells_old[YY] ||
8460 fr->ns.grid->n[ZZ] != ncells_old[ZZ]);
8464 fprintf(debug,"Step %s, sorting the %d home charge groups\n",
8465 gmx_step_str(step,sbuf),dd->ncg_home);
8467 dd_sort_state(dd,ir->ePBC,fr->cg_cm,fr,state_local,
8468 bResortAll ? -1 : ncg_home_old);
8469 /* Rebuild all the indices */
8471 ga2la_clear(dd->ga2la);
8474 /* Setup up the communication and communicate the coordinates */
8475 setup_dd_communication(dd,state_local->box,&ddbox,fr);
8477 /* Set the indices */
8478 make_dd_indices(dd,cgs_gl->index,cg0);
8480 /* Set the charge group boundaries for neighbor searching */
8481 set_cg_boundaries(&comm->zones);
8484 write_dd_pdb("dd_home",step,"dump",top_global,cr,
8485 -1,state_local->x,state_local->box);
8488 /* Extract a local topology from the global topology */
8489 for(i=0; i<dd->ndim; i++)
8491 np[dd->dim[i]] = comm->cd[i].np;
8493 dd_make_local_top(fplog,dd,&comm->zones,dd->npbcdim,state_local->box,
8494 comm->cellsize_min,np,
8495 fr,vsite,top_global,top_local);
8497 /* Set up the special atom communication */
8498 n = comm->nat[ddnatZONE];
8499 for(i=ddnatZONE+1; i<ddnatNR; i++)
8504 if (vsite && vsite->n_intercg_vsite)
8506 n = dd_make_local_vsites(dd,n,top_local->idef.il);
8510 if (dd->bInterCGcons)
8512 /* Only for inter-cg constraints we need special code */
8513 n = dd_make_local_constraints(dd,n,top_global,
8514 constr,ir->nProjOrder,
8515 &top_local->idef.il[F_CONSTR]);
8519 gmx_incons("Unknown special atom type setup");
8524 /* Make space for the extra coordinates for virtual site
8525 * or constraint communication.
8527 state_local->natoms = comm->nat[ddnatNR-1];
8528 if (state_local->natoms > state_local->nalloc)
8530 dd_realloc_state(state_local,f,state_local->natoms);
8533 if (fr->bF_NoVirSum)
8535 if (vsite && vsite->n_intercg_vsite)
8537 nat_f_novirsum = comm->nat[ddnatVSITE];
8541 if (EEL_FULL(ir->coulombtype) && dd->n_intercg_excl > 0)
8543 nat_f_novirsum = dd->nat_tot;
8547 nat_f_novirsum = dd->nat_home;
8556 /* Set the number of atoms required for the force calculation.
8557 * Forces need to be constrained when using a twin-range setup
8558 * or with energy minimization. For simple simulations we could
8559 * avoid some allocation, zeroing and copying, but this is
8560 * probably not worth the complications ande checking.
8562 forcerec_set_ranges(fr,dd->ncg_home,dd->ncg_tot,
8563 dd->nat_tot,comm->nat[ddnatCON],nat_f_novirsum);
8565 /* We make the all mdatoms up to nat_tot_con.
8566 * We could save some work by only setting invmass
8567 * between nat_tot and nat_tot_con.
8569 /* This call also sets the new number of home particles to dd->nat_home */
8570 atoms2md(top_global,ir,
8571 comm->nat[ddnatCON],dd->gatindex,0,dd->nat_home,mdatoms);
8573 /* Now we have the charges we can sort the FE interactions */
8574 dd_sort_local_top(dd,mdatoms,top_local);
8578 /* Make the local shell stuff, currently no communication is done */
8579 make_local_shells(cr,mdatoms,shellfc);
8582 if (ir->implicit_solvent)
8584 make_local_gb(cr,fr->born,ir->gb_algorithm);
8587 if (!(cr->duty & DUTY_PME))
8589 /* Send the charges to our PME only node */
8590 gmx_pme_send_q(cr,mdatoms->nChargePerturbed,
8591 mdatoms->chargeA,mdatoms->chargeB,
8592 dd_pme_maxshift_x(dd),dd_pme_maxshift_y(dd));
8597 set_constraints(constr,top_local,ir,mdatoms,cr);
8600 if (ir->ePull != epullNO)
8602 /* Update the local pull groups */
8603 dd_make_local_pull_groups(dd,ir->pull,mdatoms);
8606 add_dd_statistics(dd);
8608 /* Make sure we only count the cycles for this DD partitioning */
8609 clear_dd_cycle_counts(dd);
8611 /* Because the order of the atoms might have changed since
8612 * the last vsite construction, we need to communicate the constructing
8613 * atom coordinates again (for spreading the forces this MD step).
8615 dd_move_x_vsites(dd,state_local->box,state_local->x);
8617 if (comm->nstDDDump > 0 && step % comm->nstDDDump == 0)
8619 dd_move_x(dd,state_local->box,state_local->x);
8620 write_dd_pdb("dd_dump",step,"dump",top_global,cr,
8621 -1,state_local->x,state_local->box);
8626 /* Store the global communication step */
8627 comm->globalcomm_step = step;
8630 /* Increase the DD partitioning counter */
8632 /* The state currently matches this DD partitioning count, store it */
8633 state_local->ddp_count = dd->ddp_count;
8636 /* The DD master node knows the complete cg distribution,
8637 * store the count so we can possibly skip the cg info communication.
8639 comm->master_cg_ddp_count = (bSortCG ? 0 : dd->ddp_count);
8642 if (comm->DD_debug > 0)
8644 /* Set the env var GMX_DD_DEBUG if you suspect corrupted indices */
8645 check_index_consistency(dd,top_global->natoms,ncg_mtop(top_global),
8646 "after partitioning");