xref: /petsc/src/mat/impls/aij/mpi/mpiptap.c (revision 5c65b9ec7a426b386fab06d5b4773e7c8ee3a336)
182412ba7SHong Zhang 
242c57489SHong Zhang /*
342c57489SHong Zhang   Defines projective product routines where A is a MPIAIJ matrix
442c57489SHong Zhang           C = P^T * A * P
542c57489SHong Zhang */
642c57489SHong Zhang 
7c6db04a5SJed Brown #include <../src/mat/impls/aij/seq/aij.h>   /*I "petscmat.h" I*/
8c6db04a5SJed Brown #include <../src/mat/utils/freespace.h>
9c6db04a5SJed Brown #include <../src/mat/impls/aij/mpi/mpiaij.h>
10c6db04a5SJed Brown #include <petscbt.h>
118563dfccSBarry Smith #include <petsctime.h>
12694f88d4SFande Kong #include <petsc/private/hashmapiv.h>
134a56b808SFande Kong #include <petsc/private/hashseti.h>
144a56b808SFande Kong #include <petscsf.h>
1542c57489SHong Zhang 
1624ecddacSHong Zhang 
17cf97cf3cSHong Zhang PetscErrorCode MatView_MPIAIJ_PtAP(Mat A,PetscViewer viewer)
18cf97cf3cSHong Zhang {
19cf97cf3cSHong Zhang   PetscErrorCode    ierr;
20cf97cf3cSHong Zhang   Mat_MPIAIJ        *a=(Mat_MPIAIJ*)A->data;
213cdca5ebSHong Zhang   Mat_APMPI         *ptap=a->ap;
22cf97cf3cSHong Zhang   PetscBool         iascii;
23cf97cf3cSHong Zhang   PetscViewerFormat format;
24cf97cf3cSHong Zhang 
25cf97cf3cSHong Zhang   PetscFunctionBegin;
26baa1ba78SHong Zhang   if (!ptap) {
27baa1ba78SHong Zhang     /* hack: MatDuplicate() sets oldmat->ops->view to newmat which is a base mat class with null ptpa! */
28baa1ba78SHong Zhang     A->ops->view = MatView_MPIAIJ;
29baa1ba78SHong Zhang     ierr = (A->ops->view)(A,viewer);CHKERRQ(ierr);
30baa1ba78SHong Zhang     PetscFunctionReturn(0);
31baa1ba78SHong Zhang   }
32baa1ba78SHong Zhang 
33cf97cf3cSHong Zhang   ierr = PetscObjectTypeCompare((PetscObject)viewer,PETSCVIEWERASCII,&iascii);CHKERRQ(ierr);
34cf97cf3cSHong Zhang   if (iascii) {
35cf97cf3cSHong Zhang     ierr = PetscViewerGetFormat(viewer,&format);CHKERRQ(ierr);
36cf97cf3cSHong Zhang     if (format == PETSC_VIEWER_ASCII_INFO || format == PETSC_VIEWER_ASCII_INFO_DETAIL) {
37cf97cf3cSHong Zhang       if (ptap->algType == 0) {
38cf97cf3cSHong Zhang         ierr = PetscViewerASCIIPrintf(viewer,"using scalable MatPtAP() implementation\n");CHKERRQ(ierr);
39cf97cf3cSHong Zhang       } else if (ptap->algType == 1) {
40cf97cf3cSHong Zhang         ierr = PetscViewerASCIIPrintf(viewer,"using nonscalable MatPtAP() implementation\n");CHKERRQ(ierr);
414a56b808SFande Kong       } else if (ptap->algType == 2) {
424a56b808SFande Kong         ierr = PetscViewerASCIIPrintf(viewer,"using allatonce MatPtAP() implementation\n");CHKERRQ(ierr);
434a56b808SFande Kong       } else if (ptap->algType == 3) {
444a56b808SFande Kong         ierr = PetscViewerASCIIPrintf(viewer,"using merged allatonce MatPtAP() implementation\n");CHKERRQ(ierr);
45cf97cf3cSHong Zhang       }
46cf97cf3cSHong Zhang     }
47cf97cf3cSHong Zhang   }
48cf97cf3cSHong Zhang   ierr = (ptap->view)(A,viewer);CHKERRQ(ierr);
49cf97cf3cSHong Zhang   PetscFunctionReturn(0);
50cf97cf3cSHong Zhang }
51cf97cf3cSHong Zhang 
524624976aSHong Zhang PetscErrorCode MatFreeIntermediateDataStructures_MPIAIJ_AP(Mat A)
53cc6cb787SHong Zhang {
54cc6cb787SHong Zhang   PetscErrorCode      ierr;
55f8487c73SHong Zhang   Mat_MPIAIJ          *a=(Mat_MPIAIJ*)A->data;
563cdca5ebSHong Zhang   Mat_APMPI           *ptap=a->ap;
5760552ceaSHong Zhang   Mat_Merge_SeqsToMPI *merge;
58cc6cb787SHong Zhang 
59cc6cb787SHong Zhang   PetscFunctionBegin;
60dd4011a9SHong Zhang   if (!ptap) PetscFunctionReturn(0);
61dd4011a9SHong Zhang 
62b7f45c76SHong Zhang   ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr);
63f8487c73SHong Zhang   ierr = PetscFree(ptap->bufa);CHKERRQ(ierr);
64a1a4e84aSHong Zhang   ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr);
65a1a4e84aSHong Zhang   ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr);
66c5af039cSHong Zhang   ierr = MatDestroy(&ptap->A_loc);CHKERRQ(ierr); /* used by MatTransposeMatMult() */
6705d62848SHong Zhang   ierr = MatDestroy(&ptap->Rd);CHKERRQ(ierr);
6805d62848SHong Zhang   ierr = MatDestroy(&ptap->Ro);CHKERRQ(ierr);
698403a639SHong Zhang   if (ptap->AP_loc) { /* used by alg_rap */
70681d504bSHong Zhang     Mat_SeqAIJ *ap = (Mat_SeqAIJ*)(ptap->AP_loc)->data;
71681d504bSHong Zhang     ierr = PetscFree(ap->i);CHKERRQ(ierr);
72681d504bSHong Zhang     ierr = PetscFree2(ap->j,ap->a);CHKERRQ(ierr);
730d3441aeSHong Zhang     ierr = MatDestroy(&ptap->AP_loc);CHKERRQ(ierr);
748403a639SHong Zhang   } else { /* used by alg_ptap */
758403a639SHong Zhang     ierr = PetscFree(ptap->api);CHKERRQ(ierr);
768403a639SHong Zhang     ierr = PetscFree(ptap->apj);CHKERRQ(ierr);
77681d504bSHong Zhang   }
782259aa2eSHong Zhang   ierr = MatDestroy(&ptap->C_loc);CHKERRQ(ierr);
792259aa2eSHong Zhang   ierr = MatDestroy(&ptap->C_oth);CHKERRQ(ierr);
80414894bdSHong Zhang   if (ptap->apa) {ierr = PetscFree(ptap->apa);CHKERRQ(ierr);}
81a560ef98SHong Zhang 
8260552ceaSHong Zhang   ierr = MatDestroy(&ptap->Pt);CHKERRQ(ierr);
8360552ceaSHong Zhang 
8460552ceaSHong Zhang   merge=ptap->merge;
858403a639SHong Zhang   if (merge) { /* used by alg_ptap */
86cc6cb787SHong Zhang     ierr = PetscFree(merge->id_r);CHKERRQ(ierr);
87cc6cb787SHong Zhang     ierr = PetscFree(merge->len_s);CHKERRQ(ierr);
88cc6cb787SHong Zhang     ierr = PetscFree(merge->len_r);CHKERRQ(ierr);
89cc6cb787SHong Zhang     ierr = PetscFree(merge->bi);CHKERRQ(ierr);
90cc6cb787SHong Zhang     ierr = PetscFree(merge->bj);CHKERRQ(ierr);
91c05d87d6SBarry Smith     ierr = PetscFree(merge->buf_ri[0]);CHKERRQ(ierr);
92cc6cb787SHong Zhang     ierr = PetscFree(merge->buf_ri);CHKERRQ(ierr);
93c05d87d6SBarry Smith     ierr = PetscFree(merge->buf_rj[0]);CHKERRQ(ierr);
94cc6cb787SHong Zhang     ierr = PetscFree(merge->buf_rj);CHKERRQ(ierr);
95445158ffSHong Zhang     ierr = PetscFree(merge->coi);CHKERRQ(ierr);
96445158ffSHong Zhang     ierr = PetscFree(merge->coj);CHKERRQ(ierr);
9705b42c5fSBarry Smith     ierr = PetscFree(merge->owners_co);CHKERRQ(ierr);
986bf464f9SBarry Smith     ierr = PetscLayoutDestroy(&merge->rowmap);CHKERRQ(ierr);
99f8487c73SHong Zhang     ierr = PetscFree(ptap->merge);CHKERRQ(ierr);
100bf0cc555SLisandro Dalcin   }
101a3bb6f32SFande Kong   ierr = ISLocalToGlobalMappingDestroy(&ptap->ltog);CHKERRQ(ierr);
1024a56b808SFande Kong 
1034a56b808SFande Kong   ierr = PetscSFDestroy(&ptap->sf);CHKERRQ(ierr);
1044a56b808SFande Kong   ierr = PetscFree(ptap->c_othi);CHKERRQ(ierr);
1054a56b808SFande Kong   ierr = PetscFree(ptap->c_rmti);CHKERRQ(ierr);
1063697aca6SHong Zhang   PetscFunctionReturn(0);
107c8b0795cSMark F. Adams }
108dce485f0SBarry Smith 
1093697aca6SHong Zhang PetscErrorCode MatDestroy_MPIAIJ_PtAP(Mat A)
1103697aca6SHong Zhang {
1113697aca6SHong Zhang   PetscErrorCode ierr;
1129b3d8a68SHong Zhang   Mat_MPIAIJ     *a=(Mat_MPIAIJ*)A->data;
1139b3d8a68SHong Zhang   Mat_APMPI      *ptap=a->ap;
1143697aca6SHong Zhang 
1153697aca6SHong Zhang   PetscFunctionBegin;
116dd4011a9SHong Zhang   ierr = (*A->ops->freeintermediatedatastructures)(A);CHKERRQ(ierr);
1179b3d8a68SHong Zhang   ierr = (*ptap->destroy)(A);CHKERRQ(ierr); /* MatDestroy_MPIAIJ(A) */
1189b3d8a68SHong Zhang   ierr = PetscFree(ptap);CHKERRQ(ierr);
119cc6cb787SHong Zhang   PetscFunctionReturn(0);
120cc6cb787SHong Zhang }
121cc6cb787SHong Zhang 
122150d2497SBarry Smith PETSC_INTERN PetscErrorCode MatPtAP_MPIAIJ_MPIAIJ(Mat A,Mat P,MatReuse scall,PetscReal fill,Mat *C)
12342c57489SHong Zhang {
12442c57489SHong Zhang   PetscErrorCode ierr;
125a4ffb656SHong Zhang   PetscBool      flg;
12667a12041SHong Zhang   MPI_Comm       comm;
127a4ffb656SHong Zhang #if !defined(PETSC_HAVE_HYPRE)
1284a56b808SFande Kong   const char          *algTypes[4] = {"scalable","nonscalable","allatonce","allatonce_merged"};
1294a56b808SFande Kong   PetscInt            nalg=4;
130a4ffb656SHong Zhang #else
1314a56b808SFande Kong   const char          *algTypes[5] = {"scalable","nonscalable","allatonce","allatonce_merged","hypre"};
1324a56b808SFande Kong   PetscInt            nalg=5;
133a4ffb656SHong Zhang #endif
134a4ffb656SHong Zhang   PetscInt            pN=P->cmap->N,alg=1; /* set default algorithm */
13542c57489SHong Zhang 
13642c57489SHong Zhang   PetscFunctionBegin;
13767a12041SHong Zhang   /* check if matrix local sizes are compatible */
13867a12041SHong Zhang   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
1396c4ed002SBarry Smith   if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Arow (%D, %D) != Prow (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend);
1406c4ed002SBarry Smith   if (A->cmap->rstart != P->rmap->rstart || A->cmap->rend != P->rmap->rend) SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Acol (%D, %D) != Prow (%D,%D)",A->cmap->rstart,A->cmap->rend,P->rmap->rstart,P->rmap->rend);
14167a12041SHong Zhang 
142cf3ca8ceSHong Zhang   if (scall == MAT_INITIAL_MATRIX) {
143a4ffb656SHong Zhang     /* pick an algorithm */
144715a5346SHong Zhang     ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)A),((PetscObject)A)->prefix,"MatPtAP","Mat");CHKERRQ(ierr);
145a4ffb656SHong Zhang     ierr = PetscOptionsEList("-matptap_via","Algorithmic approach","MatPtAP",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr);
146a4ffb656SHong Zhang     ierr = PetscOptionsEnd();CHKERRQ(ierr);
147a4ffb656SHong Zhang 
148a4ffb656SHong Zhang     if (!flg && pN > 100000) { /* may switch to scalable algorithm as default */
149a4ffb656SHong Zhang       MatInfo     Ainfo,Pinfo;
150a4ffb656SHong Zhang       PetscInt    nz_local;
151a4ffb656SHong Zhang       PetscBool   alg_scalable_loc=PETSC_FALSE,alg_scalable;
152a4ffb656SHong Zhang 
153a4ffb656SHong Zhang       ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr);
154a4ffb656SHong Zhang       ierr = MatGetInfo(P,MAT_LOCAL,&Pinfo);CHKERRQ(ierr);
155a4ffb656SHong Zhang       nz_local = (PetscInt)(Ainfo.nz_allocated + Pinfo.nz_allocated);
156a4ffb656SHong Zhang 
157a4ffb656SHong Zhang       if (pN > fill*nz_local) alg_scalable_loc = PETSC_TRUE;
158a4ffb656SHong Zhang       ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr);
159a4ffb656SHong Zhang 
160a4ffb656SHong Zhang       if (alg_scalable) {
161a4ffb656SHong Zhang         alg = 0; /* scalable algorithm would 50% slower than nonscalable algorithm */
1620d3441aeSHong Zhang       }
163a4ffb656SHong Zhang     }
164a4ffb656SHong Zhang 
165a4ffb656SHong Zhang     switch (alg) {
166a4ffb656SHong Zhang     case 1:
16780da8df7SHong Zhang       /* do R=P^T locally, then C=R*A*P -- nonscalable */
168a4ffb656SHong Zhang       ierr = PetscLogEventBegin(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
169a4ffb656SHong Zhang       ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ(A,P,fill,C);CHKERRQ(ierr);
1703ff4c91cSHong Zhang       ierr = PetscLogEventEnd(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
171a4ffb656SHong Zhang       break;
172a4ffb656SHong Zhang     case 2:
1734a56b808SFande Kong       /* compute C=P^T*A*P allatonce */
1744a56b808SFande Kong       ierr = PetscLogEventBegin(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
1754a56b808SFande Kong       ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ_allatonce(A,P,fill,C);CHKERRQ(ierr);
1764a56b808SFande Kong       ierr = PetscLogEventEnd(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
1774a56b808SFande Kong       break;
1784a56b808SFande Kong     case 3:
1794a56b808SFande Kong       /* compute C=P^T*A*P allatonce */
1804a56b808SFande Kong       ierr = PetscLogEventBegin(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
1814a56b808SFande Kong       ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ_allatonce_merged(A,P,fill,C);CHKERRQ(ierr);
1824a56b808SFande Kong       ierr = PetscLogEventEnd(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
1834a56b808SFande Kong       break;
1844a56b808SFande Kong #if defined(PETSC_HAVE_HYPRE)
1854a56b808SFande Kong     case 4:
186a4ffb656SHong Zhang       /* Use boomerAMGBuildCoarseOperator */
1870abfe76eSFande Kong       ierr = PetscLogEventBegin(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
188a4ffb656SHong Zhang       ierr = MatPtAPSymbolic_AIJ_AIJ_wHYPRE(A,P,fill,C);CHKERRQ(ierr);
1890abfe76eSFande Kong       ierr = PetscLogEventEnd(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
190a4ffb656SHong Zhang       break;
191a4ffb656SHong Zhang #endif
192a4ffb656SHong Zhang     default:
193a4ffb656SHong Zhang       /* do R=P^T locally, then C=R*A*P */
194a4ffb656SHong Zhang       ierr = PetscLogEventBegin(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
195a4ffb656SHong Zhang       ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable(A,P,fill,C);CHKERRQ(ierr);
196a4ffb656SHong Zhang       ierr = PetscLogEventEnd(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
197a4ffb656SHong Zhang       break;
198a4ffb656SHong Zhang     }
1997d0a89b7SHong Zhang 
2004a56b808SFande Kong     if (alg == 0 || alg == 1 || alg == 2 || alg == 3) {
2017d0a89b7SHong Zhang       Mat_MPIAIJ *c  = (Mat_MPIAIJ*)(*C)->data;
2027d0a89b7SHong Zhang       Mat_APMPI  *ap = c->ap;
2037d0a89b7SHong Zhang       ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)(*C)),((PetscObject)(*C))->prefix,"MatFreeIntermediateDataStructures","Mat");CHKERRQ(ierr);
2047d0a89b7SHong Zhang       ap->freestruct = PETSC_FALSE;
2057d0a89b7SHong Zhang       ierr = PetscOptionsBool("-mat_freeintermediatedatastructures","Free intermediate data structures", "MatFreeIntermediateDataStructures",ap->freestruct,&ap->freestruct, NULL);CHKERRQ(ierr);
2067d0a89b7SHong Zhang       ierr = PetscOptionsEnd();CHKERRQ(ierr);
2077a7894deSKris Buschelman     }
2087d0a89b7SHong Zhang   }
2097d0a89b7SHong Zhang 
2103ff4c91cSHong Zhang   ierr = PetscLogEventBegin(MAT_PtAPNumeric,A,P,0,0);CHKERRQ(ierr);
2118403a639SHong Zhang   ierr = (*(*C)->ops->ptapnumeric)(A,P,*C);CHKERRQ(ierr);
2123ff4c91cSHong Zhang   ierr = PetscLogEventEnd(MAT_PtAPNumeric,A,P,0,0);CHKERRQ(ierr);
21342c57489SHong Zhang   PetscFunctionReturn(0);
21442c57489SHong Zhang }
21542c57489SHong Zhang 
216cf742fccSHong Zhang PetscErrorCode MatPtAPNumeric_MPIAIJ_MPIAIJ_scalable(Mat A,Mat P,Mat C)
217cf742fccSHong Zhang {
218cf742fccSHong Zhang   PetscErrorCode    ierr;
219cf742fccSHong Zhang   Mat_MPIAIJ        *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
220cf742fccSHong Zhang   Mat_SeqAIJ        *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
22192ec70a1SHong Zhang   Mat_SeqAIJ        *ap,*p_loc,*p_oth=NULL,*c_seq;
2223cdca5ebSHong Zhang   Mat_APMPI         *ptap = c->ap;
223cf742fccSHong Zhang   Mat               AP_loc,C_loc,C_oth;
224a3bb6f32SFande Kong   PetscInt          i,rstart,rend,cm,ncols,row,*api,*apj,am = A->rmap->n,apnz,nout;
225cf742fccSHong Zhang   PetscScalar       *apa;
226cf742fccSHong Zhang   const PetscInt    *cols;
227cf742fccSHong Zhang   const PetscScalar *vals;
228cf742fccSHong Zhang 
229cf742fccSHong Zhang   PetscFunctionBegin;
230fa2a5dcfSHong Zhang   if (!ptap->AP_loc) {
23180da8df7SHong Zhang     MPI_Comm comm;
23280da8df7SHong Zhang     ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr);
23380da8df7SHong Zhang     SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'");
23480da8df7SHong Zhang   }
23580da8df7SHong Zhang 
236cf742fccSHong Zhang   ierr = MatZeroEntries(C);CHKERRQ(ierr);
237cf742fccSHong Zhang 
238cf742fccSHong Zhang   /* 1) get R = Pd^T,Ro = Po^T */
239cf742fccSHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
240419ecdd9Sandi selinger     ierr = MatTranspose(p->A,MAT_REUSE_MATRIX,&ptap->Rd);CHKERRQ(ierr);
241419ecdd9Sandi selinger     ierr = MatTranspose(p->B,MAT_REUSE_MATRIX,&ptap->Ro);CHKERRQ(ierr);
242cf742fccSHong Zhang   }
243cf742fccSHong Zhang 
244cf742fccSHong Zhang   /* 2) get AP_loc */
245cf742fccSHong Zhang   AP_loc = ptap->AP_loc;
246cf742fccSHong Zhang   ap = (Mat_SeqAIJ*)AP_loc->data;
247cf742fccSHong Zhang 
248cf742fccSHong Zhang   /* 2-1) get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
249cf742fccSHong Zhang   /*-----------------------------------------------------*/
250cf742fccSHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
251cf742fccSHong Zhang     /* P_oth and P_loc are obtained in MatPtASymbolic() when reuse == MAT_INITIAL_MATRIX */
252cf742fccSHong Zhang     ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
253cf742fccSHong Zhang     ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
254cf742fccSHong Zhang   }
255cf742fccSHong Zhang 
256cf742fccSHong Zhang   /* 2-2) compute numeric A_loc*P - dominating part */
257cf742fccSHong Zhang   /* ---------------------------------------------- */
258cf742fccSHong Zhang   /* get data from symbolic products */
259cf742fccSHong Zhang   p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data;
26052f7967eSHong Zhang   if (ptap->P_oth) p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data;
26152f7967eSHong Zhang 
262cf742fccSHong Zhang   api   = ap->i;
263cf742fccSHong Zhang   apj   = ap->j;
264a3bb6f32SFande Kong   ierr = ISLocalToGlobalMappingApply(ptap->ltog,api[AP_loc->rmap->n],apj,apj);CHKERRQ(ierr);
265cf742fccSHong Zhang   for (i=0; i<am; i++) {
266cf742fccSHong Zhang     /* AP[i,:] = A[i,:]*P = Ad*P_loc Ao*P_oth */
267cf742fccSHong Zhang     apnz = api[i+1] - api[i];
268b4e8d1b6SHong Zhang     apa = ap->a + api[i];
269580bdb30SBarry Smith     ierr = PetscArrayzero(apa,apnz);CHKERRQ(ierr);
270b4e8d1b6SHong Zhang     AProw_scalable(i,ad,ao,p_loc,p_oth,api,apj,apa);
271cf742fccSHong Zhang   }
272a3bb6f32SFande Kong   ierr = ISGlobalToLocalMappingApply(ptap->ltog,IS_GTOLM_DROP,api[AP_loc->rmap->n],apj,&nout,apj);CHKERRQ(ierr);
273a3bb6f32SFande Kong   if (api[AP_loc->rmap->n] != nout) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_ARG_INCOMP,"Incorrect mapping %D != %D\n",api[AP_loc->rmap->n],nout);
274cf742fccSHong Zhang 
275cf742fccSHong Zhang   /* 3) C_loc = Rd*AP_loc, C_oth = Ro*AP_loc */
276154d0d78SFande Kong   /* Always use scalable version since we are in the MPI scalable version */
277cf742fccSHong Zhang   ierr = MatMatMultNumeric_SeqAIJ_SeqAIJ_Scalable(ptap->Rd,AP_loc,ptap->C_loc);CHKERRQ(ierr);
278cf742fccSHong Zhang   ierr = MatMatMultNumeric_SeqAIJ_SeqAIJ_Scalable(ptap->Ro,AP_loc,ptap->C_oth);CHKERRQ(ierr);
279cf742fccSHong Zhang 
280cf742fccSHong Zhang   C_loc = ptap->C_loc;
281cf742fccSHong Zhang   C_oth = ptap->C_oth;
282cf742fccSHong Zhang 
283cf742fccSHong Zhang   /* add C_loc and Co to to C */
284cf742fccSHong Zhang   ierr = MatGetOwnershipRange(C,&rstart,&rend);CHKERRQ(ierr);
285cf742fccSHong Zhang 
286cf742fccSHong Zhang   /* C_loc -> C */
287cf742fccSHong Zhang   cm    = C_loc->rmap->N;
288cf742fccSHong Zhang   c_seq = (Mat_SeqAIJ*)C_loc->data;
289cf742fccSHong Zhang   cols = c_seq->j;
290cf742fccSHong Zhang   vals = c_seq->a;
291a3bb6f32SFande Kong   ierr = ISLocalToGlobalMappingApply(ptap->ltog,c_seq->i[C_loc->rmap->n],c_seq->j,c_seq->j);CHKERRQ(ierr);
292edeac6deSandi selinger 
293e9ede7d0Sandi selinger   /* The (fast) MatSetValues_MPIAIJ_CopyFromCSRFormat function can only be used when C->was_assembled is PETSC_FALSE and */
294edeac6deSandi selinger   /* when there are no off-processor parts.  */
2951de21080Sandi selinger   /* If was_assembled is true, then the statement aj[rowstart_diag+dnz_row] = mat_j[col] - cstart; in MatSetValues_MPIAIJ_CopyFromCSRFormat */
2961de21080Sandi selinger   /* is no longer true. Then the more complex function MatSetValues_MPIAIJ() has to be used, where the column index is looked up from */
2971de21080Sandi selinger   /* a table, and other, more complex stuff has to be done. */
298edeac6deSandi selinger   if (C->assembled) {
299edeac6deSandi selinger     C->was_assembled = PETSC_TRUE;
300edeac6deSandi selinger     C->assembled     = PETSC_FALSE;
301edeac6deSandi selinger   }
302edeac6deSandi selinger   if (C->was_assembled) {
303cf742fccSHong Zhang     for (i=0; i<cm; i++) {
304cf742fccSHong Zhang       ncols = c_seq->i[i+1] - c_seq->i[i];
305cf742fccSHong Zhang       row = rstart + i;
306edeac6deSandi selinger       ierr = MatSetValues_MPIAIJ(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr);
307cf742fccSHong Zhang       cols += ncols; vals += ncols;
308cf742fccSHong Zhang     }
309edeac6deSandi selinger   } else {
310e9ede7d0Sandi selinger     ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat(C,c_seq->j,c_seq->i,c_seq->a);CHKERRQ(ierr);
311edeac6deSandi selinger   }
312a3bb6f32SFande Kong   ierr = ISGlobalToLocalMappingApply(ptap->ltog,IS_GTOLM_DROP,c_seq->i[C_loc->rmap->n],c_seq->j,&nout,c_seq->j);CHKERRQ(ierr);
313a3bb6f32SFande Kong   if (c_seq->i[C_loc->rmap->n] != nout) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_ARG_INCOMP,"Incorrect mapping %D != %D\n",c_seq->i[C_loc->rmap->n],nout);
314cf742fccSHong Zhang 
315cf742fccSHong Zhang   /* Co -> C, off-processor part */
316cf742fccSHong Zhang   cm = C_oth->rmap->N;
317cf742fccSHong Zhang   c_seq = (Mat_SeqAIJ*)C_oth->data;
318cf742fccSHong Zhang   cols = c_seq->j;
319cf742fccSHong Zhang   vals = c_seq->a;
320a3bb6f32SFande Kong   ierr = ISLocalToGlobalMappingApply(ptap->ltog,c_seq->i[C_oth->rmap->n],c_seq->j,c_seq->j);CHKERRQ(ierr);
321cf742fccSHong Zhang   for (i=0; i<cm; i++) {
322cf742fccSHong Zhang     ncols = c_seq->i[i+1] - c_seq->i[i];
323cf742fccSHong Zhang     row = p->garray[i];
324cf742fccSHong Zhang     ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr);
325cf742fccSHong Zhang     cols += ncols; vals += ncols;
326cf742fccSHong Zhang   }
327cf742fccSHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
328cf742fccSHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
329cf742fccSHong Zhang 
330cf742fccSHong Zhang   ptap->reuse = MAT_REUSE_MATRIX;
33180da8df7SHong Zhang 
332a3bb6f32SFande Kong   ierr = ISGlobalToLocalMappingApply(ptap->ltog,IS_GTOLM_DROP,c_seq->i[C_oth->rmap->n],c_seq->j,&nout,c_seq->j);CHKERRQ(ierr);
333a3bb6f32SFande Kong   if (c_seq->i[C_oth->rmap->n] != nout) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_ARG_INCOMP,"Incorrect mapping %D != %D\n",c_seq->i[C_loc->rmap->n],nout);
334a3bb6f32SFande Kong 
33580da8df7SHong Zhang   /* supporting struct ptap consumes almost same amount of memory as C=PtAP, release it if C will not be updated by A and P */
3367d0a89b7SHong Zhang   if (ptap->freestruct) {
33780da8df7SHong Zhang     ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr);
33880da8df7SHong Zhang   }
339cf742fccSHong Zhang   PetscFunctionReturn(0);
340cf742fccSHong Zhang }
341cf742fccSHong Zhang 
342e953e47cSHong Zhang PetscErrorCode MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable(Mat A,Mat P,PetscReal fill,Mat *C)
3430d3441aeSHong Zhang {
3440d3441aeSHong Zhang   PetscErrorCode      ierr;
3453cdca5ebSHong Zhang   Mat_APMPI           *ptap;
346681d504bSHong Zhang   Mat_MPIAIJ          *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c;
3472259aa2eSHong Zhang   MPI_Comm            comm;
3482259aa2eSHong Zhang   PetscMPIInt         size,rank;
34976db11f6SHong Zhang   Mat                 Cmpi,P_loc,P_oth;
35015a3b8e2SHong Zhang   PetscFreeSpaceList  free_space=NULL,current_space=NULL;
351d0e9a2f7SHong Zhang   PetscInt            am=A->rmap->n,pm=P->rmap->n,pN=P->cmap->N,pn=P->cmap->n;
352d0e9a2f7SHong Zhang   PetscInt            *lnk,i,k,pnz,row,nsend;
353f671be37SHong Zhang   PetscMPIInt         tagi,tagj,*len_si,*len_s,*len_ri,icompleted=0,nrecv;
35415a3b8e2SHong Zhang   PetscInt            **buf_rj,**buf_ri,**buf_ri_k;
355d0e9a2f7SHong Zhang   PetscInt            len,proc,*dnz,*onz,*owners,nzi,nspacedouble;
35615a3b8e2SHong Zhang   PetscInt            nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci;
35715a3b8e2SHong Zhang   MPI_Request         *swaits,*rwaits;
35815a3b8e2SHong Zhang   MPI_Status          *sstatus,rstatus;
359445158ffSHong Zhang   PetscLayout         rowmap;
360445158ffSHong Zhang   PetscInt            *owners_co,*coi,*coj;    /* i and j array of (p->B)^T*A*P - used in the communication */
361445158ffSHong Zhang   PetscMPIInt         *len_r,*id_r;    /* array of length of comm->size, store send/recv matrix values */
362a3bb6f32SFande Kong   PetscInt            *api,*apj,*Jptr,apnz,*prmap=p->garray,con,j,Crmax,*aj,*ai,*pi,nout;
36352f7967eSHong Zhang   Mat_SeqAIJ          *p_loc,*p_oth=NULL,*ad=(Mat_SeqAIJ*)(a->A)->data,*ao=NULL,*c_loc,*c_oth;
36467a12041SHong Zhang   PetscScalar         *apv;
36578d30b94SHong Zhang   PetscTable          ta;
366b92f168fSBarry Smith   MatType             mtype;
367e83e5f86SFande Kong   const char          *prefix;
368aa690a28SHong Zhang #if defined(PETSC_USE_INFO)
3698cb82516SHong Zhang   PetscReal           apfill;
370aa690a28SHong Zhang #endif
37167a12041SHong Zhang 
37267a12041SHong Zhang   PetscFunctionBegin;
37367a12041SHong Zhang   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
37467a12041SHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
37567a12041SHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
376ae5f0867Sstefano_zampini 
37752f7967eSHong Zhang   if (size > 1) ao = (Mat_SeqAIJ*)(a->B)->data;
37852f7967eSHong Zhang 
379ae5f0867Sstefano_zampini   /* create symbolic parallel matrix Cmpi */
380ae5f0867Sstefano_zampini   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
381b92f168fSBarry Smith   ierr = MatGetType(A,&mtype);CHKERRQ(ierr);
382b92f168fSBarry Smith   ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr);
383ae5f0867Sstefano_zampini 
3843cdca5ebSHong Zhang   /* create struct Mat_APMPI and attached it to C later */
385e953e47cSHong Zhang   ierr        = PetscNew(&ptap);CHKERRQ(ierr);
386e953e47cSHong Zhang   ptap->reuse = MAT_INITIAL_MATRIX;
387cf97cf3cSHong Zhang   ptap->algType = 0;
388e953e47cSHong Zhang 
389e953e47cSHong Zhang   /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
39076db11f6SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&P_oth);CHKERRQ(ierr);
391e953e47cSHong Zhang   /* get P_loc by taking all local rows of P */
39276db11f6SHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&P_loc);CHKERRQ(ierr);
39376db11f6SHong Zhang 
39476db11f6SHong Zhang   ptap->P_loc = P_loc;
39576db11f6SHong Zhang   ptap->P_oth = P_oth;
396e953e47cSHong Zhang 
397e953e47cSHong Zhang   /* (0) compute Rd = Pd^T, Ro = Po^T  */
398e953e47cSHong Zhang   /* --------------------------------- */
399419ecdd9Sandi selinger   ierr = MatTranspose(p->A,MAT_INITIAL_MATRIX,&ptap->Rd);CHKERRQ(ierr);
400419ecdd9Sandi selinger   ierr = MatTranspose(p->B,MAT_INITIAL_MATRIX,&ptap->Ro);CHKERRQ(ierr);
401e953e47cSHong Zhang 
402e953e47cSHong Zhang   /* (1) compute symbolic AP = A_loc*P = Ad*P_loc + Ao*P_oth (api,apj) */
403e953e47cSHong Zhang   /* ----------------------------------------------------------------- */
40476db11f6SHong Zhang   p_loc  = (Mat_SeqAIJ*)P_loc->data;
40552f7967eSHong Zhang   if (P_oth) p_oth = (Mat_SeqAIJ*)P_oth->data;
406e953e47cSHong Zhang 
407e953e47cSHong Zhang   /* create and initialize a linked list */
408e953e47cSHong Zhang   ierr = PetscTableCreate(pn,pN,&ta);CHKERRQ(ierr); /* for compute AP_loc and Cmpi */
40976db11f6SHong Zhang   MatRowMergeMax_SeqAIJ(p_loc,P_loc->rmap->N,ta);
41076db11f6SHong Zhang   MatRowMergeMax_SeqAIJ(p_oth,P_oth->rmap->N,ta);
411e953e47cSHong Zhang   ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr); /* Crmax = nnz(sum of Prows) */
412e953e47cSHong Zhang 
41376db11f6SHong Zhang   ierr = PetscLLCondensedCreate_Scalable(Crmax,&lnk);CHKERRQ(ierr);
414e953e47cSHong Zhang 
415e953e47cSHong Zhang   /* Initial FreeSpace size is fill*(nnz(A) + nnz(P)) */
41652f7967eSHong Zhang   if (ao) {
417e953e47cSHong Zhang     ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(ad->i[am],PetscIntSumTruncate(ao->i[am],p_loc->i[pm]))),&free_space);CHKERRQ(ierr);
41852f7967eSHong Zhang   } else {
41952f7967eSHong Zhang     ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(ad->i[am],p_loc->i[pm])),&free_space);CHKERRQ(ierr);
42052f7967eSHong Zhang   }
421e953e47cSHong Zhang   current_space = free_space;
422e953e47cSHong Zhang   nspacedouble  = 0;
423e953e47cSHong Zhang 
424e953e47cSHong Zhang   ierr   = PetscMalloc1(am+1,&api);CHKERRQ(ierr);
425e953e47cSHong Zhang   api[0] = 0;
426e953e47cSHong Zhang   for (i=0; i<am; i++) {
427e953e47cSHong Zhang     /* diagonal portion: Ad[i,:]*P */
428e953e47cSHong Zhang     ai = ad->i; pi = p_loc->i;
429e953e47cSHong Zhang     nzi = ai[i+1] - ai[i];
430e953e47cSHong Zhang     aj  = ad->j + ai[i];
431e953e47cSHong Zhang     for (j=0; j<nzi; j++) {
432e953e47cSHong Zhang       row  = aj[j];
433e953e47cSHong Zhang       pnz  = pi[row+1] - pi[row];
434e953e47cSHong Zhang       Jptr = p_loc->j + pi[row];
435e953e47cSHong Zhang       /* add non-zero cols of P into the sorted linked list lnk */
43676db11f6SHong Zhang       ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr);
437e953e47cSHong Zhang     }
438e953e47cSHong Zhang     /* off-diagonal portion: Ao[i,:]*P */
43952f7967eSHong Zhang     if (ao) {
440e953e47cSHong Zhang       ai = ao->i; pi = p_oth->i;
441e953e47cSHong Zhang       nzi = ai[i+1] - ai[i];
442e953e47cSHong Zhang       aj  = ao->j + ai[i];
443e953e47cSHong Zhang       for (j=0; j<nzi; j++) {
444e953e47cSHong Zhang         row  = aj[j];
445e953e47cSHong Zhang         pnz  = pi[row+1] - pi[row];
446e953e47cSHong Zhang         Jptr = p_oth->j + pi[row];
44776db11f6SHong Zhang         ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr);
448e953e47cSHong Zhang       }
44952f7967eSHong Zhang     }
450e953e47cSHong Zhang     apnz     = lnk[0];
451e953e47cSHong Zhang     api[i+1] = api[i] + apnz;
452e953e47cSHong Zhang 
453e953e47cSHong Zhang     /* if free space is not available, double the total space in the list */
454e953e47cSHong Zhang     if (current_space->local_remaining<apnz) {
455e953e47cSHong Zhang       ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),&current_space);CHKERRQ(ierr);
456e953e47cSHong Zhang       nspacedouble++;
457e953e47cSHong Zhang     }
458e953e47cSHong Zhang 
459e953e47cSHong Zhang     /* Copy data into free space, then initialize lnk */
46076db11f6SHong Zhang     ierr = PetscLLCondensedClean_Scalable(apnz,current_space->array,lnk);CHKERRQ(ierr);
461e953e47cSHong Zhang 
462e953e47cSHong Zhang     current_space->array           += apnz;
463e953e47cSHong Zhang     current_space->local_used      += apnz;
464e953e47cSHong Zhang     current_space->local_remaining -= apnz;
465e953e47cSHong Zhang   }
466e953e47cSHong Zhang   /* Allocate space for apj and apv, initialize apj, and */
467e953e47cSHong Zhang   /* destroy list of free space and other temporary array(s) */
468a3bb6f32SFande Kong   ierr = PetscCalloc2(api[am],&apj,api[am],&apv);CHKERRQ(ierr);
469e953e47cSHong Zhang   ierr = PetscFreeSpaceContiguous(&free_space,apj);CHKERRQ(ierr);
47076db11f6SHong Zhang   ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr);
471e953e47cSHong Zhang 
472e953e47cSHong Zhang   /* Create AP_loc for reuse */
473e953e47cSHong Zhang   ierr = MatCreateSeqAIJWithArrays(PETSC_COMM_SELF,am,pN,api,apj,apv,&ptap->AP_loc);CHKERRQ(ierr);
474a3bb6f32SFande Kong   ierr = MatSeqAIJCompactOutExtraColumns_SeqAIJ(ptap->AP_loc, &ptap->ltog);CHKERRQ(ierr);
475e953e47cSHong Zhang 
476e953e47cSHong Zhang #if defined(PETSC_USE_INFO)
47752f7967eSHong Zhang   if (ao) {
478e953e47cSHong Zhang     apfill = (PetscReal)api[am]/(ad->i[am]+ao->i[am]+p_loc->i[pm]+1);
47952f7967eSHong Zhang   } else {
48052f7967eSHong Zhang     apfill = (PetscReal)api[am]/(ad->i[am]+p_loc->i[pm]+1);
48152f7967eSHong Zhang   }
482e953e47cSHong Zhang   ptap->AP_loc->info.mallocs           = nspacedouble;
483e953e47cSHong Zhang   ptap->AP_loc->info.fill_ratio_given  = fill;
484e953e47cSHong Zhang   ptap->AP_loc->info.fill_ratio_needed = apfill;
485e953e47cSHong Zhang 
486e953e47cSHong Zhang   if (api[am]) {
487b11c1ec8SHong Zhang     ierr = PetscInfo3(ptap->AP_loc,"Scalable algorithm, AP_loc reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)apfill);CHKERRQ(ierr);
488e953e47cSHong Zhang     ierr = PetscInfo1(ptap->AP_loc,"Use MatPtAP(A,B,MatReuse,%g,&C) for best AP_loc performance.;\n",(double)apfill);CHKERRQ(ierr);
489e953e47cSHong Zhang   } else {
490b11c1ec8SHong Zhang     ierr = PetscInfo(ptap->AP_loc,"Scalable algorithm, AP_loc is empty \n");CHKERRQ(ierr);
491e953e47cSHong Zhang   }
492e953e47cSHong Zhang #endif
493e953e47cSHong Zhang 
494e953e47cSHong Zhang   /* (2-1) compute symbolic Co = Ro*AP_loc  */
495e953e47cSHong Zhang   /* ------------------------------------ */
496e83e5f86SFande Kong   ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr);
497e83e5f86SFande Kong   ierr = MatSetOptionsPrefix(ptap->Ro,prefix);CHKERRQ(ierr);
498e83e5f86SFande Kong   ierr = MatAppendOptionsPrefix(ptap->Ro,"inner_offdiag_");CHKERRQ(ierr);
499e953e47cSHong Zhang   ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Ro,ptap->AP_loc,fill,&ptap->C_oth);CHKERRQ(ierr);
500e953e47cSHong Zhang 
501e953e47cSHong Zhang   /* (3) send coj of C_oth to other processors  */
502e953e47cSHong Zhang   /* ------------------------------------------ */
503e953e47cSHong Zhang   /* determine row ownership */
504e953e47cSHong Zhang   ierr = PetscLayoutCreate(comm,&rowmap);CHKERRQ(ierr);
505e953e47cSHong Zhang   rowmap->n  = pn;
506e953e47cSHong Zhang   rowmap->bs = 1;
507e953e47cSHong Zhang   ierr   = PetscLayoutSetUp(rowmap);CHKERRQ(ierr);
508e953e47cSHong Zhang   owners = rowmap->range;
509e953e47cSHong Zhang 
510e953e47cSHong Zhang   /* determine the number of messages to send, their lengths */
511e953e47cSHong Zhang   ierr = PetscMalloc4(size,&len_s,size,&len_si,size,&sstatus,size+2,&owners_co);CHKERRQ(ierr);
512580bdb30SBarry Smith   ierr = PetscArrayzero(len_s,size);CHKERRQ(ierr);
513580bdb30SBarry Smith   ierr = PetscArrayzero(len_si,size);CHKERRQ(ierr);
514e953e47cSHong Zhang 
515e953e47cSHong Zhang   c_oth = (Mat_SeqAIJ*)ptap->C_oth->data;
516e953e47cSHong Zhang   coi   = c_oth->i; coj = c_oth->j;
517e953e47cSHong Zhang   con   = ptap->C_oth->rmap->n;
518e953e47cSHong Zhang   proc  = 0;
519a3bb6f32SFande Kong   ierr = ISLocalToGlobalMappingApply(ptap->ltog,coi[con],coj,coj);CHKERRQ(ierr);
520e953e47cSHong Zhang   for (i=0; i<con; i++) {
521e953e47cSHong Zhang     while (prmap[i] >= owners[proc+1]) proc++;
522e953e47cSHong Zhang     len_si[proc]++;               /* num of rows in Co(=Pt*AP) to be sent to [proc] */
523e953e47cSHong Zhang     len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */
524e953e47cSHong Zhang   }
525e953e47cSHong Zhang 
526e953e47cSHong Zhang   len          = 0; /* max length of buf_si[], see (4) */
527e953e47cSHong Zhang   owners_co[0] = 0;
528e953e47cSHong Zhang   nsend        = 0;
529e953e47cSHong Zhang   for (proc=0; proc<size; proc++) {
530e953e47cSHong Zhang     owners_co[proc+1] = owners_co[proc] + len_si[proc];
531e953e47cSHong Zhang     if (len_s[proc]) {
532e953e47cSHong Zhang       nsend++;
533e953e47cSHong Zhang       len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */
534e953e47cSHong Zhang       len         += len_si[proc];
535e953e47cSHong Zhang     }
536e953e47cSHong Zhang   }
537e953e47cSHong Zhang 
538e953e47cSHong Zhang   /* determine the number and length of messages to receive for coi and coj  */
539e953e47cSHong Zhang   ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&nrecv);CHKERRQ(ierr);
540e953e47cSHong Zhang   ierr = PetscGatherMessageLengths2(comm,nsend,nrecv,len_s,len_si,&id_r,&len_r,&len_ri);CHKERRQ(ierr);
541e953e47cSHong Zhang 
542e953e47cSHong Zhang   /* post the Irecv and Isend of coj */
543e953e47cSHong Zhang   ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr);
544e953e47cSHong Zhang   ierr = PetscPostIrecvInt(comm,tagj,nrecv,id_r,len_r,&buf_rj,&rwaits);CHKERRQ(ierr);
545e953e47cSHong Zhang   ierr = PetscMalloc1(nsend+1,&swaits);CHKERRQ(ierr);
546e953e47cSHong Zhang   for (proc=0, k=0; proc<size; proc++) {
547e953e47cSHong Zhang     if (!len_s[proc]) continue;
548e953e47cSHong Zhang     i    = owners_co[proc];
549e953e47cSHong Zhang     ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr);
550e953e47cSHong Zhang     k++;
551e953e47cSHong Zhang   }
552e953e47cSHong Zhang 
553e953e47cSHong Zhang   /* (2-2) compute symbolic C_loc = Rd*AP_loc */
554e953e47cSHong Zhang   /* ---------------------------------------- */
555e83e5f86SFande Kong   ierr = MatSetOptionsPrefix(ptap->Rd,prefix);CHKERRQ(ierr);
556e83e5f86SFande Kong   ierr = MatAppendOptionsPrefix(ptap->Rd,"inner_diag_");CHKERRQ(ierr);
557e953e47cSHong Zhang   ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Rd,ptap->AP_loc,fill,&ptap->C_loc);CHKERRQ(ierr);
558e953e47cSHong Zhang   c_loc = (Mat_SeqAIJ*)ptap->C_loc->data;
559a3bb6f32SFande Kong   ierr = ISLocalToGlobalMappingApply(ptap->ltog,c_loc->i[ptap->C_loc->rmap->n],c_loc->j,c_loc->j);CHKERRQ(ierr);
560e953e47cSHong Zhang 
561e953e47cSHong Zhang   /* receives coj are complete */
562e953e47cSHong Zhang   for (i=0; i<nrecv; i++) {
563e953e47cSHong Zhang     ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
564e953e47cSHong Zhang   }
565e953e47cSHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
566e953e47cSHong Zhang   if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);}
567e953e47cSHong Zhang 
568e953e47cSHong Zhang   /* add received column indices into ta to update Crmax */
569e953e47cSHong Zhang   for (k=0; k<nrecv; k++) {/* k-th received message */
570e953e47cSHong Zhang     Jptr = buf_rj[k];
571e953e47cSHong Zhang     for (j=0; j<len_r[k]; j++) {
572e953e47cSHong Zhang       ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr);
573e953e47cSHong Zhang     }
574e953e47cSHong Zhang   }
575e953e47cSHong Zhang   ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr);
576e953e47cSHong Zhang   ierr = PetscTableDestroy(&ta);CHKERRQ(ierr);
577e953e47cSHong Zhang 
578e953e47cSHong Zhang   /* (4) send and recv coi */
579e953e47cSHong Zhang   /*-----------------------*/
580e953e47cSHong Zhang   ierr   = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr);
581e953e47cSHong Zhang   ierr   = PetscPostIrecvInt(comm,tagi,nrecv,id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr);
582e953e47cSHong Zhang   ierr   = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr);
583e953e47cSHong Zhang   buf_si = buf_s;  /* points to the beginning of k-th msg to be sent */
584e953e47cSHong Zhang   for (proc=0,k=0; proc<size; proc++) {
585e953e47cSHong Zhang     if (!len_s[proc]) continue;
586e953e47cSHong Zhang     /* form outgoing message for i-structure:
587e953e47cSHong Zhang          buf_si[0]:                 nrows to be sent
588e953e47cSHong Zhang                [1:nrows]:           row index (global)
589e953e47cSHong Zhang                [nrows+1:2*nrows+1]: i-structure index
590e953e47cSHong Zhang     */
591e953e47cSHong Zhang     /*-------------------------------------------*/
592e953e47cSHong Zhang     nrows       = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */
593e953e47cSHong Zhang     buf_si_i    = buf_si + nrows+1;
594e953e47cSHong Zhang     buf_si[0]   = nrows;
595e953e47cSHong Zhang     buf_si_i[0] = 0;
596e953e47cSHong Zhang     nrows       = 0;
597e953e47cSHong Zhang     for (i=owners_co[proc]; i<owners_co[proc+1]; i++) {
598e953e47cSHong Zhang       nzi = coi[i+1] - coi[i];
599e953e47cSHong Zhang       buf_si_i[nrows+1] = buf_si_i[nrows] + nzi;  /* i-structure */
600e953e47cSHong Zhang       buf_si[nrows+1]   = prmap[i] -owners[proc]; /* local row index */
601e953e47cSHong Zhang       nrows++;
602e953e47cSHong Zhang     }
603e953e47cSHong Zhang     ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr);
604e953e47cSHong Zhang     k++;
605e953e47cSHong Zhang     buf_si += len_si[proc];
606e953e47cSHong Zhang   }
607e953e47cSHong Zhang   for (i=0; i<nrecv; i++) {
608e953e47cSHong Zhang     ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
609e953e47cSHong Zhang   }
610e953e47cSHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
611e953e47cSHong Zhang   if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);}
612e953e47cSHong Zhang 
613e953e47cSHong Zhang   ierr = PetscFree4(len_s,len_si,sstatus,owners_co);CHKERRQ(ierr);
614e953e47cSHong Zhang   ierr = PetscFree(len_ri);CHKERRQ(ierr);
615e953e47cSHong Zhang   ierr = PetscFree(swaits);CHKERRQ(ierr);
616e953e47cSHong Zhang   ierr = PetscFree(buf_s);CHKERRQ(ierr);
617b4e8d1b6SHong Zhang 
618e953e47cSHong Zhang   /* (5) compute the local portion of Cmpi      */
619e953e47cSHong Zhang   /* ------------------------------------------ */
620e953e47cSHong Zhang   /* set initial free space to be Crmax, sufficient for holding nozeros in each row of Cmpi */
621e953e47cSHong Zhang   ierr          = PetscFreeSpaceGet(Crmax,&free_space);CHKERRQ(ierr);
622e953e47cSHong Zhang   current_space = free_space;
623e953e47cSHong Zhang 
624e953e47cSHong Zhang   ierr = PetscMalloc3(nrecv,&buf_ri_k,nrecv,&nextrow,nrecv,&nextci);CHKERRQ(ierr);
625e953e47cSHong Zhang   for (k=0; k<nrecv; k++) {
626e953e47cSHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
627e953e47cSHong Zhang     nrows       = *buf_ri_k[k];
628e953e47cSHong Zhang     nextrow[k]  = buf_ri_k[k] + 1;  /* next row number of k-th recved i-structure */
629e953e47cSHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
630e953e47cSHong Zhang   }
631e953e47cSHong Zhang 
632e953e47cSHong Zhang   ierr = MatPreallocateInitialize(comm,pn,pn,dnz,onz);CHKERRQ(ierr);
633cf742fccSHong Zhang   ierr = PetscLLCondensedCreate_Scalable(Crmax,&lnk);CHKERRQ(ierr);
634e953e47cSHong Zhang   for (i=0; i<pn; i++) {
635e953e47cSHong Zhang     /* add C_loc into Cmpi */
636e953e47cSHong Zhang     nzi  = c_loc->i[i+1] - c_loc->i[i];
637e953e47cSHong Zhang     Jptr = c_loc->j + c_loc->i[i];
638cf742fccSHong Zhang     ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr);
639e953e47cSHong Zhang 
640e953e47cSHong Zhang     /* add received col data into lnk */
641e953e47cSHong Zhang     for (k=0; k<nrecv; k++) { /* k-th received message */
642e953e47cSHong Zhang       if (i == *nextrow[k]) { /* i-th row */
643e953e47cSHong Zhang         nzi  = *(nextci[k]+1) - *nextci[k];
644e953e47cSHong Zhang         Jptr = buf_rj[k] + *nextci[k];
645cf742fccSHong Zhang         ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr);
646e953e47cSHong Zhang         nextrow[k]++; nextci[k]++;
647e953e47cSHong Zhang       }
648e953e47cSHong Zhang     }
649e953e47cSHong Zhang     nzi = lnk[0];
650e953e47cSHong Zhang 
651e953e47cSHong Zhang     /* copy data into free space, then initialize lnk */
652cf742fccSHong Zhang     ierr = PetscLLCondensedClean_Scalable(nzi,current_space->array,lnk);CHKERRQ(ierr);
653e953e47cSHong Zhang     ierr = MatPreallocateSet(i+owners[rank],nzi,current_space->array,dnz,onz);CHKERRQ(ierr);
654e953e47cSHong Zhang   }
655e953e47cSHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
656cf742fccSHong Zhang   ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr);
657e953e47cSHong Zhang   ierr = PetscFreeSpaceDestroy(free_space);CHKERRQ(ierr);
658e953e47cSHong Zhang 
659e953e47cSHong Zhang   /* local sizes and preallocation */
660e953e47cSHong Zhang   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
661ac94c67aSTristan Konolige   if (P->cmap->bs > 0) {
662ac94c67aSTristan Konolige     ierr = PetscLayoutSetBlockSize(Cmpi->rmap,P->cmap->bs);CHKERRQ(ierr);
663ac94c67aSTristan Konolige     ierr = PetscLayoutSetBlockSize(Cmpi->cmap,P->cmap->bs);CHKERRQ(ierr);
664ac94c67aSTristan Konolige   }
665e953e47cSHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
666e953e47cSHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
667e953e47cSHong Zhang 
668e953e47cSHong Zhang   /* members in merge */
669e953e47cSHong Zhang   ierr = PetscFree(id_r);CHKERRQ(ierr);
670e953e47cSHong Zhang   ierr = PetscFree(len_r);CHKERRQ(ierr);
671e953e47cSHong Zhang   ierr = PetscFree(buf_ri[0]);CHKERRQ(ierr);
672e953e47cSHong Zhang   ierr = PetscFree(buf_ri);CHKERRQ(ierr);
673e953e47cSHong Zhang   ierr = PetscFree(buf_rj[0]);CHKERRQ(ierr);
674e953e47cSHong Zhang   ierr = PetscFree(buf_rj);CHKERRQ(ierr);
675e953e47cSHong Zhang   ierr = PetscLayoutDestroy(&rowmap);CHKERRQ(ierr);
676e953e47cSHong Zhang 
677e953e47cSHong Zhang   /* attach the supporting struct to Cmpi for reuse */
678e953e47cSHong Zhang   c = (Mat_MPIAIJ*)Cmpi->data;
6793cdca5ebSHong Zhang   c->ap           = ptap;
680e953e47cSHong Zhang   ptap->duplicate = Cmpi->ops->duplicate;
681e953e47cSHong Zhang   ptap->destroy   = Cmpi->ops->destroy;
682cf97cf3cSHong Zhang   ptap->view      = Cmpi->ops->view;
683e953e47cSHong Zhang 
684e953e47cSHong Zhang   /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */
685e953e47cSHong Zhang   Cmpi->assembled        = PETSC_FALSE;
686a4ffb656SHong Zhang   Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_scalable;
687e953e47cSHong Zhang   Cmpi->ops->destroy     = MatDestroy_MPIAIJ_PtAP;
688cf97cf3cSHong Zhang   Cmpi->ops->view        = MatView_MPIAIJ_PtAP;
6894624976aSHong Zhang   Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP;
690e953e47cSHong Zhang   *C                     = Cmpi;
691a3bb6f32SFande Kong 
692a3bb6f32SFande Kong    nout = 0;
693a3bb6f32SFande Kong    ierr = ISGlobalToLocalMappingApply(ptap->ltog,IS_GTOLM_DROP,c_oth->i[ptap->C_oth->rmap->n],c_oth->j,&nout,c_oth->j);CHKERRQ(ierr);
694a3bb6f32SFande Kong    if (c_oth->i[ptap->C_oth->rmap->n] != nout) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_ARG_INCOMP,"Incorrect mapping %D != %D\n",c_oth->i[ptap->C_oth->rmap->n],nout);
695a3bb6f32SFande Kong    ierr = ISGlobalToLocalMappingApply(ptap->ltog,IS_GTOLM_DROP,c_loc->i[ptap->C_loc->rmap->n],c_loc->j,&nout,c_loc->j);CHKERRQ(ierr);
696a3bb6f32SFande Kong    if (c_loc->i[ptap->C_loc->rmap->n] != nout) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_ARG_INCOMP,"Incorrect mapping %D != %D\n",c_loc->i[ptap->C_loc->rmap->n],nout);
697a3bb6f32SFande Kong 
698e953e47cSHong Zhang   PetscFunctionReturn(0);
699e953e47cSHong Zhang }
700e953e47cSHong Zhang 
7014a56b808SFande Kong PETSC_STATIC_INLINE PetscErrorCode MatPtAPSymbolicComputeOneRowOfAP_private(Mat A,Mat P,Mat P_oth,PetscInt i,PetscHSetI dht,PetscHSetI oht)
7024a56b808SFande Kong {
7034a56b808SFande Kong   Mat_MPIAIJ           *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data;
7044a56b808SFande Kong   Mat_SeqAIJ           *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_oth=(Mat_SeqAIJ*)P_oth->data,*pd=(Mat_SeqAIJ*)p->A->data,*po=(Mat_SeqAIJ*)p->B->data;
7054a56b808SFande Kong   PetscInt             *ai,nzi,j,*aj,row,col,*pi,*pj,pnz,nzpi,*p_othcols,k;
7064a56b808SFande Kong   PetscInt             pcstart,pcend,column;
7074a56b808SFande Kong   PetscErrorCode       ierr;
7084a56b808SFande Kong 
7094a56b808SFande Kong   PetscFunctionBegin;
7104a56b808SFande Kong 
7114a56b808SFande Kong   pcstart = P->cmap->rstart;
7124a56b808SFande Kong   pcend   = P->cmap->rend;
7134a56b808SFande Kong   /* diagonal portion: Ad[i,:]*P */
7144a56b808SFande Kong   ai = ad->i;
7154a56b808SFande Kong   nzi = ai[i+1] - ai[i];
7164a56b808SFande Kong   aj  = ad->j + ai[i];
7174a56b808SFande Kong   for (j=0; j<nzi; j++) {
7184a56b808SFande Kong     row  = aj[j];
7194a56b808SFande Kong     nzpi = pd->i[row+1] - pd->i[row];
7204a56b808SFande Kong     pj  = pd->j + pd->i[row];
7214a56b808SFande Kong     for (k=0; k<nzpi; k++) {
7224a56b808SFande Kong       ierr = PetscHSetIAdd(dht,pj[k]+pcstart);CHKERRQ(ierr);
7234a56b808SFande Kong     }
7244a56b808SFande Kong   }
7254a56b808SFande Kong   for (j=0; j<nzi; j++) {
7264a56b808SFande Kong     row  = aj[j];
7274a56b808SFande Kong     nzpi = po->i[row+1] - po->i[row];
7284a56b808SFande Kong     pj  = po->j + po->i[row];
7294a56b808SFande Kong     for (k=0; k<nzpi; k++) {
7304a56b808SFande Kong       ierr = PetscHSetIAdd(oht,p->garray[pj[k]]);CHKERRQ(ierr);
7314a56b808SFande Kong     }
7324a56b808SFande Kong   }
7334a56b808SFande Kong 
7344a56b808SFande Kong   /* off diagonal part: Ao[i, :]*P_oth */
7354a56b808SFande Kong   if (ao) {
7364a56b808SFande Kong     ai = ao->i;
7374a56b808SFande Kong     pi = p_oth->i;
7384a56b808SFande Kong     nzi = ai[i+1] - ai[i];
7394a56b808SFande Kong     aj  = ao->j + ai[i];
7404a56b808SFande Kong     for (j=0; j<nzi; j++) {
7414a56b808SFande Kong       row  = aj[j];
7424a56b808SFande Kong       pnz  = pi[row+1] - pi[row];
7434a56b808SFande Kong       p_othcols = p_oth->j + pi[row];
7444a56b808SFande Kong       for (col=0; col<pnz; col++) {
7454a56b808SFande Kong         column = p_othcols[col];
7464a56b808SFande Kong         if (column>=pcstart && column<pcend) {
7474a56b808SFande Kong           ierr = PetscHSetIAdd(dht,column);CHKERRQ(ierr);
7484a56b808SFande Kong         } else {
7494a56b808SFande Kong           ierr = PetscHSetIAdd(oht,column);CHKERRQ(ierr);
7504a56b808SFande Kong         }
7514a56b808SFande Kong       }
7524a56b808SFande Kong     }
7534a56b808SFande Kong   } /* end if (ao) */
7544a56b808SFande Kong   PetscFunctionReturn(0);
7554a56b808SFande Kong }
7564a56b808SFande Kong 
7574a56b808SFande Kong PETSC_STATIC_INLINE PetscErrorCode MatPtAPNumericComputeOneRowOfAP_private(Mat A,Mat P,Mat P_oth,PetscInt i,PetscHMapIV hmap)
7584a56b808SFande Kong {
7594a56b808SFande Kong   Mat_MPIAIJ           *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data;
7604a56b808SFande Kong   Mat_SeqAIJ           *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_oth=(Mat_SeqAIJ*)P_oth->data,*pd=(Mat_SeqAIJ*)p->A->data,*po=(Mat_SeqAIJ*)p->B->data;
7614a56b808SFande Kong   PetscInt             *ai,nzi,j,*aj,row,col,*pi,pnz,*p_othcols,pcstart,*pj,k,nzpi;
7624a56b808SFande Kong   PetscScalar          ra,*aa,*pa;
7634a56b808SFande Kong   PetscErrorCode       ierr;
7644a56b808SFande Kong 
7654a56b808SFande Kong   PetscFunctionBegin;
7664a56b808SFande Kong   pcstart = P->cmap->rstart;
7674a56b808SFande Kong   /* diagonal portion: Ad[i,:]*P */
7684a56b808SFande Kong   ai  = ad->i;
7694a56b808SFande Kong   nzi = ai[i+1] - ai[i];
7704a56b808SFande Kong   aj  = ad->j + ai[i];
7714a56b808SFande Kong   aa  = ad->a + ai[i];
7724a56b808SFande Kong 
7734a56b808SFande Kong   for (j=0; j<nzi; j++) {
7744a56b808SFande Kong     ra   = aa[j];
7754a56b808SFande Kong     row  = aj[j];
7764a56b808SFande Kong     nzpi = pd->i[row+1] - pd->i[row];
7774a56b808SFande Kong     pj = pd->j + pd->i[row];
7784a56b808SFande Kong     pa = pd->a + pd->i[row];
7794a56b808SFande Kong     for (k=0; k<nzpi; k++) {
780694f88d4SFande Kong       ierr = PetscHMapIVAddValue(hmap,pj[k]+pcstart,ra*pa[k]);CHKERRQ(ierr);
7814a56b808SFande Kong     }
78249c8f2b8SFande Kong     ierr = PetscLogFlops(2.0*nzpi);CHKERRQ(ierr);
7834a56b808SFande Kong   }
7844a56b808SFande Kong   for (j=0; j<nzi; j++) {
7854a56b808SFande Kong     ra   = aa[j];
7864a56b808SFande Kong     row  = aj[j];
7874a56b808SFande Kong     nzpi = po->i[row+1] - po->i[row];
7884a56b808SFande Kong     pj = po->j + po->i[row];
7894a56b808SFande Kong     pa = po->a + po->i[row];
7904a56b808SFande Kong     for (k=0; k<nzpi; k++) {
791694f88d4SFande Kong       ierr = PetscHMapIVAddValue(hmap,p->garray[pj[k]],ra*pa[k]);CHKERRQ(ierr);
7924a56b808SFande Kong     }
79349c8f2b8SFande Kong     ierr = PetscLogFlops(2.0*nzpi);CHKERRQ(ierr);
7944a56b808SFande Kong   }
7954a56b808SFande Kong 
7964a56b808SFande Kong 
7974a56b808SFande Kong   /* off diagonal part: Ao[i, :]*P_oth */
7984a56b808SFande Kong   if (ao) {
7994a56b808SFande Kong     ai = ao->i;
8004a56b808SFande Kong     pi = p_oth->i;
8014a56b808SFande Kong     nzi = ai[i+1] - ai[i];
8024a56b808SFande Kong     aj  = ao->j + ai[i];
8034a56b808SFande Kong     aa  = ao->a + ai[i];
8044a56b808SFande Kong     for (j=0; j<nzi; j++) {
8054a56b808SFande Kong       row  = aj[j];
8064a56b808SFande Kong       ra   = aa[j];
8074a56b808SFande Kong       pnz  = pi[row+1] - pi[row];
8084a56b808SFande Kong       p_othcols = p_oth->j + pi[row];
8094a56b808SFande Kong       pa   = p_oth->a + pi[row];
8104a56b808SFande Kong       for (col=0; col<pnz; col++) {
811694f88d4SFande Kong         ierr = PetscHMapIVAddValue(hmap,p_othcols[col],ra*pa[col]);CHKERRQ(ierr);
8124a56b808SFande Kong       }
81349c8f2b8SFande Kong       ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
8144a56b808SFande Kong     }
8154a56b808SFande Kong   } /* end if (ao) */
816bb5ddf68SFande Kong 
8174a56b808SFande Kong   PetscFunctionReturn(0);
8184a56b808SFande Kong }
8194a56b808SFande Kong 
820*5c65b9ecSFande Kong PetscErrorCode MatGetBrowsOfAcols_MPIXAIJ(Mat,Mat,MatReuse,Mat*);
821*5c65b9ecSFande Kong 
8224a56b808SFande Kong PetscErrorCode MatPtAPNumeric_MPIAIJ_MPIAIJ_allatonce(Mat A,Mat P,Mat C)
8234a56b808SFande Kong {
8244a56b808SFande Kong   PetscErrorCode    ierr;
8254a56b808SFande Kong   Mat_MPIAIJ        *p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
8264a56b808SFande Kong   Mat_SeqAIJ        *cd,*co,*po,*pd;
8274a56b808SFande Kong   Mat_APMPI         *ptap = c->ap;
8284a56b808SFande Kong   PetscHMapIV       hmap;
8294a56b808SFande Kong   PetscInt          i,j,jj,kk,nzi,*c_rmtj,voff,*c_othj,pn,pon,pcstart,pcend,ccstart,ccend,row,am,*poj,*pdj,*apindices,cmaxr,*c_rmtc,*c_rmtjj,*dcc,*occ,loc;
8304a56b808SFande Kong   PetscScalar       *c_rmta,*c_otha,*poa,*pda,*apvalues,*apvaluestmp,*c_rmtaa;
8314a56b808SFande Kong   MPI_Comm          comm;
8324a56b808SFande Kong 
8334a56b808SFande Kong   PetscFunctionBegin;
8344a56b808SFande Kong   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
835bb9bda99SHong Zhang   if (!ptap->P_oth) SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'");
8364a56b808SFande Kong 
8374a56b808SFande Kong   ierr = MatZeroEntries(C);CHKERRQ(ierr);
8384a56b808SFande Kong 
8394a56b808SFande Kong   /* Get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
8404a56b808SFande Kong   /*-----------------------------------------------------*/
8414a56b808SFande Kong   if (ptap->reuse == MAT_REUSE_MATRIX) {
8424a56b808SFande Kong     /* P_oth and P_loc are obtained in MatPtASymbolic() when reuse == MAT_INITIAL_MATRIX */
843*5c65b9ecSFande Kong     ierr =  MatGetBrowsOfAcols_MPIXAIJ(A,P,MAT_REUSE_MATRIX,&ptap->P_oth);CHKERRQ(ierr);
8444a56b808SFande Kong   }
8454a56b808SFande Kong 
8464a56b808SFande Kong   po = (Mat_SeqAIJ*) p->B->data;
8474a56b808SFande Kong   pd = (Mat_SeqAIJ*) p->A->data;
8484a56b808SFande Kong 
8494a56b808SFande Kong   ierr = MatGetLocalSize(p->B,NULL,&pon);CHKERRQ(ierr);
8504a56b808SFande Kong 
8514a56b808SFande Kong   ierr = PetscCalloc2(ptap->c_rmti[pon],&c_rmtj,ptap->c_rmti[pon],&c_rmta);CHKERRQ(ierr);
8524a56b808SFande Kong   ierr = MatGetLocalSize(A,&am,NULL);CHKERRQ(ierr);
8534a56b808SFande Kong   cmaxr = 0;
8544a56b808SFande Kong   for (i=0; i<pon; i++) {
8554a56b808SFande Kong     cmaxr = PetscMax(cmaxr,ptap->c_rmti[i+1]-ptap->c_rmti[i]);
8564a56b808SFande Kong   }
8574a56b808SFande Kong   ierr = PetscCalloc4(cmaxr,&apindices,cmaxr,&apvalues,cmaxr,&apvaluestmp,pon,&c_rmtc);CHKERRQ(ierr);
8584a56b808SFande Kong   ierr = PetscHMapIVCreate(&hmap);CHKERRQ(ierr);
8594a56b808SFande Kong   ierr = PetscHMapIVResize(hmap,cmaxr);CHKERRQ(ierr);
8604a56b808SFande Kong   for (i=0; i<am && pon; i++) {
8614a56b808SFande Kong     ierr = PetscHMapIVClear(hmap);CHKERRQ(ierr);
8624a56b808SFande Kong     nzi = po->i[i+1] - po->i[i];
8634a56b808SFande Kong     if (!nzi) continue;
8644a56b808SFande Kong     ierr = MatPtAPNumericComputeOneRowOfAP_private(A,P,ptap->P_oth,i,hmap);CHKERRQ(ierr);
8654a56b808SFande Kong     voff = 0;
8664a56b808SFande Kong     ierr = PetscHMapIVGetPairs(hmap,&voff,apindices,apvalues);CHKERRQ(ierr);
8674a56b808SFande Kong     if (!voff) continue;
8684a56b808SFande Kong 
8694a56b808SFande Kong     /* Form C(ii, :) */
8704a56b808SFande Kong     poj = po->j + po->i[i];
8714a56b808SFande Kong     poa = po->a + po->i[i];
8724a56b808SFande Kong     for (j=0; j<nzi; j++) {
8734a56b808SFande Kong       c_rmtjj = c_rmtj + ptap->c_rmti[poj[j]];
8744a56b808SFande Kong       c_rmtaa = c_rmta + ptap->c_rmti[poj[j]];
8754a56b808SFande Kong       for (jj=0; jj<voff; jj++) {
8764a56b808SFande Kong         apvaluestmp[jj] = apvalues[jj]*poa[j];
8774a56b808SFande Kong         /*If the row is empty */
8784a56b808SFande Kong         if (!c_rmtc[poj[j]]) {
8794a56b808SFande Kong           c_rmtjj[jj] = apindices[jj];
8804a56b808SFande Kong           c_rmtaa[jj] = apvaluestmp[jj];
8814a56b808SFande Kong           c_rmtc[poj[j]]++;
8824a56b808SFande Kong         } else {
8834a56b808SFande Kong           ierr = PetscFindInt(apindices[jj],c_rmtc[poj[j]],c_rmtjj,&loc);CHKERRQ(ierr);
8844a56b808SFande Kong           if (loc>=0){ /* hit */
8854a56b808SFande Kong             c_rmtaa[loc] += apvaluestmp[jj];
88649c8f2b8SFande Kong             ierr = PetscLogFlops(1.0);CHKERRQ(ierr);
8874a56b808SFande Kong           } else { /* new element */
8884a56b808SFande Kong             loc = -(loc+1);
8894a56b808SFande Kong             /* Move data backward */
8904a56b808SFande Kong             for (kk=c_rmtc[poj[j]]; kk>loc; kk--) {
8914a56b808SFande Kong               c_rmtjj[kk] = c_rmtjj[kk-1];
8924a56b808SFande Kong               c_rmtaa[kk] = c_rmtaa[kk-1];
8934a56b808SFande Kong             }/* End kk */
8944a56b808SFande Kong             c_rmtjj[loc] = apindices[jj];
8954a56b808SFande Kong             c_rmtaa[loc] = apvaluestmp[jj];
8964a56b808SFande Kong             c_rmtc[poj[j]]++;
8974a56b808SFande Kong           }
8984a56b808SFande Kong         }
89949c8f2b8SFande Kong         ierr = PetscLogFlops(voff);CHKERRQ(ierr);
9004a56b808SFande Kong       } /* End jj */
9014a56b808SFande Kong     } /* End j */
9024a56b808SFande Kong   } /* End i */
9034a56b808SFande Kong 
9044a56b808SFande Kong   ierr = PetscFree4(apindices,apvalues,apvaluestmp,c_rmtc);CHKERRQ(ierr);
9054a56b808SFande Kong 
9064a56b808SFande Kong   ierr = MatGetLocalSize(P,NULL,&pn);CHKERRQ(ierr);
9074a56b808SFande Kong   ierr = PetscCalloc2(ptap->c_othi[pn],&c_othj,ptap->c_othi[pn],&c_otha);CHKERRQ(ierr);
9084a56b808SFande Kong 
9094a56b808SFande Kong   ierr = PetscSFReduceBegin(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPIU_REPLACE);CHKERRQ(ierr);
9104a56b808SFande Kong   ierr = PetscSFReduceBegin(ptap->sf,MPIU_SCALAR,c_rmta,c_otha,MPIU_REPLACE);CHKERRQ(ierr);
9114a56b808SFande Kong   ierr = MatGetOwnershipRangeColumn(P,&pcstart,&pcend);CHKERRQ(ierr);
9124a56b808SFande Kong   cd = (Mat_SeqAIJ*)(c->A)->data;
9134a56b808SFande Kong   co = (Mat_SeqAIJ*)(c->B)->data;
9144a56b808SFande Kong 
9154a56b808SFande Kong   cmaxr = 0;
9164a56b808SFande Kong   for (i=0; i<pn; i++) {
9174a56b808SFande Kong     cmaxr = PetscMax(cmaxr,(cd->i[i+1]-cd->i[i])+(co->i[i+1]-co->i[i]));
9184a56b808SFande Kong   }
9194a56b808SFande Kong   ierr = PetscCalloc5(cmaxr,&apindices,cmaxr,&apvalues,cmaxr,&apvaluestmp,pn,&dcc,pn,&occ);CHKERRQ(ierr);
9204a56b808SFande Kong   ierr = PetscHMapIVCreate(&hmap);CHKERRQ(ierr);
9214a56b808SFande Kong   ierr = PetscHMapIVResize(hmap,cmaxr);CHKERRQ(ierr);
9224a56b808SFande Kong   for (i=0; i<am && pn; i++) {
9234a56b808SFande Kong     ierr = PetscHMapIVClear(hmap);CHKERRQ(ierr);
9244a56b808SFande Kong     nzi = pd->i[i+1] - pd->i[i];
9254a56b808SFande Kong     if (!nzi) continue;
9264a56b808SFande Kong     ierr = MatPtAPNumericComputeOneRowOfAP_private(A,P,ptap->P_oth,i,hmap);CHKERRQ(ierr);
9274a56b808SFande Kong     voff = 0;
9284a56b808SFande Kong     ierr = PetscHMapIVGetPairs(hmap,&voff,apindices,apvalues);CHKERRQ(ierr);
9294a56b808SFande Kong     if (!voff) continue;
9304a56b808SFande Kong     /* Form C(ii, :) */
9314a56b808SFande Kong     pdj = pd->j + pd->i[i];
9324a56b808SFande Kong     pda = pd->a + pd->i[i];
9334a56b808SFande Kong     for (j=0; j<nzi; j++) {
9344a56b808SFande Kong       row = pcstart + pdj[j];
9354a56b808SFande Kong       for (jj=0; jj<voff; jj++) {
9364a56b808SFande Kong         apvaluestmp[jj] = apvalues[jj]*pda[j];
9374a56b808SFande Kong       }
93849c8f2b8SFande Kong       ierr = PetscLogFlops(voff);CHKERRQ(ierr);
9394a56b808SFande Kong       ierr = MatSetValues(C,1,&row,voff,apindices,apvaluestmp,ADD_VALUES);CHKERRQ(ierr);
9404a56b808SFande Kong     }
9414a56b808SFande Kong   }
9424a56b808SFande Kong 
9434a56b808SFande Kong   ierr = MatGetOwnershipRangeColumn(C,&ccstart,&ccend);CHKERRQ(ierr);
9444a56b808SFande Kong   ierr = PetscFree5(apindices,apvalues,apvaluestmp,dcc,occ);CHKERRQ(ierr);
9454a56b808SFande Kong   ierr = PetscHMapIVDestroy(&hmap);CHKERRQ(ierr);
9464a56b808SFande Kong   ierr = PetscSFReduceEnd(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPI_SUM);CHKERRQ(ierr);
9474a56b808SFande Kong   ierr = PetscSFReduceEnd(ptap->sf,MPIU_SCALAR,c_rmta,c_otha,MPIU_REPLACE);CHKERRQ(ierr);
9484a56b808SFande Kong   ierr = PetscFree2(c_rmtj,c_rmta);CHKERRQ(ierr);
9494a56b808SFande Kong 
9504a56b808SFande Kong   /* Add contributions from remote */
9514a56b808SFande Kong   for (i = 0; i < pn; i++) {
9524a56b808SFande Kong     row = i + pcstart;
9534a56b808SFande Kong     ierr = MatSetValues(C,1,&row,ptap->c_othi[i+1]-ptap->c_othi[i],c_othj+ptap->c_othi[i],c_otha+ptap->c_othi[i],ADD_VALUES);CHKERRQ(ierr);
9544a56b808SFande Kong   }
9554a56b808SFande Kong   ierr = PetscFree2(c_othj,c_otha);CHKERRQ(ierr);
9564a56b808SFande Kong 
9574a56b808SFande Kong   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
9584a56b808SFande Kong   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
9594a56b808SFande Kong 
9604a56b808SFande Kong   ptap->reuse = MAT_REUSE_MATRIX;
9614a56b808SFande Kong 
9624a56b808SFande Kong   /* supporting struct ptap consumes almost same amount of memory as C=PtAP, release it if C will not be updated by A and P */
9634a56b808SFande Kong   if (ptap->freestruct) {
9644a56b808SFande Kong     ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr);
9654a56b808SFande Kong   }
9664a56b808SFande Kong   PetscFunctionReturn(0);
9674a56b808SFande Kong }
9684a56b808SFande Kong 
9694a56b808SFande Kong PetscErrorCode MatPtAPNumeric_MPIAIJ_MPIAIJ_allatonce_merged(Mat A,Mat P,Mat C)
9704a56b808SFande Kong {
9714a56b808SFande Kong   PetscErrorCode    ierr;
9724a56b808SFande Kong   Mat_MPIAIJ        *p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
9734a56b808SFande Kong   Mat_SeqAIJ        *cd,*co,*po,*pd;
9744a56b808SFande Kong   Mat_APMPI         *ptap = c->ap;
9754a56b808SFande Kong   PetscHMapIV       hmap;
9764a56b808SFande Kong   PetscInt          i,j,jj,kk,nzi,dnzi,*c_rmtj,voff,*c_othj,pn,pon,pcstart,pcend,row,am,*poj,*pdj,*apindices,cmaxr,*c_rmtc,*c_rmtjj,loc;
9774a56b808SFande Kong   PetscScalar       *c_rmta,*c_otha,*poa,*pda,*apvalues,*apvaluestmp,*c_rmtaa;
9784a56b808SFande Kong   MPI_Comm          comm;
9794a56b808SFande Kong 
9804a56b808SFande Kong   PetscFunctionBegin;
9814a56b808SFande Kong   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
982bb9bda99SHong Zhang   if (!ptap->P_oth) SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'");
9834a56b808SFande Kong 
9844a56b808SFande Kong   ierr = MatZeroEntries(C);CHKERRQ(ierr);
9854a56b808SFande Kong 
9864a56b808SFande Kong   /* Get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
9874a56b808SFande Kong   /*-----------------------------------------------------*/
9884a56b808SFande Kong   if (ptap->reuse == MAT_REUSE_MATRIX) {
9894a56b808SFande Kong     /* P_oth and P_loc are obtained in MatPtASymbolic() when reuse == MAT_INITIAL_MATRIX */
990*5c65b9ecSFande Kong     ierr =  MatGetBrowsOfAcols_MPIXAIJ(A,P,MAT_REUSE_MATRIX,&ptap->P_oth);CHKERRQ(ierr);
9914a56b808SFande Kong   }
9924a56b808SFande Kong 
9934a56b808SFande Kong   po = (Mat_SeqAIJ*) p->B->data;
9944a56b808SFande Kong   pd = (Mat_SeqAIJ*) p->A->data;
9954a56b808SFande Kong 
9964a56b808SFande Kong   ierr = MatGetLocalSize(p->B,NULL,&pon);CHKERRQ(ierr);
9974a56b808SFande Kong   ierr = MatGetLocalSize(P,NULL,&pn);CHKERRQ(ierr);
9984a56b808SFande Kong 
9994a56b808SFande Kong   ierr = PetscCalloc2(ptap->c_rmti[pon],&c_rmtj,ptap->c_rmti[pon],&c_rmta);CHKERRQ(ierr);
10004a56b808SFande Kong   ierr = MatGetLocalSize(A,&am,NULL);CHKERRQ(ierr);
10014a56b808SFande Kong   ierr = MatGetOwnershipRangeColumn(P,&pcstart,&pcend);CHKERRQ(ierr);
10024a56b808SFande Kong   cmaxr = 0;
10034a56b808SFande Kong   for (i=0; i<pon; i++) {
10044a56b808SFande Kong     cmaxr = PetscMax(cmaxr,ptap->c_rmti[i+1]-ptap->c_rmti[i]);
10054a56b808SFande Kong   }
10064a56b808SFande Kong   cd = (Mat_SeqAIJ*)(c->A)->data;
10074a56b808SFande Kong   co = (Mat_SeqAIJ*)(c->B)->data;
10084a56b808SFande Kong   for (i=0; i<pn; i++) {
10094a56b808SFande Kong     cmaxr = PetscMax(cmaxr,(cd->i[i+1]-cd->i[i])+(co->i[i+1]-co->i[i]));
10104a56b808SFande Kong   }
10114a56b808SFande Kong   ierr = PetscCalloc4(cmaxr,&apindices,cmaxr,&apvalues,cmaxr,&apvaluestmp,pon,&c_rmtc);CHKERRQ(ierr);
10124a56b808SFande Kong   ierr = PetscHMapIVCreate(&hmap);CHKERRQ(ierr);
10134a56b808SFande Kong   ierr = PetscHMapIVResize(hmap,cmaxr);CHKERRQ(ierr);
10144a56b808SFande Kong   for (i=0; i<am && (pon || pn); i++) {
10154a56b808SFande Kong     ierr = PetscHMapIVClear(hmap);CHKERRQ(ierr);
10164a56b808SFande Kong     nzi  = po->i[i+1] - po->i[i];
10174a56b808SFande Kong     dnzi = pd->i[i+1] - pd->i[i];
10184a56b808SFande Kong     if (!nzi && !dnzi) continue;
10194a56b808SFande Kong     ierr = MatPtAPNumericComputeOneRowOfAP_private(A,P,ptap->P_oth,i,hmap);CHKERRQ(ierr);
10204a56b808SFande Kong     voff = 0;
10214a56b808SFande Kong     ierr = PetscHMapIVGetPairs(hmap,&voff,apindices,apvalues);CHKERRQ(ierr);
10224a56b808SFande Kong     if (!voff) continue;
10234a56b808SFande Kong 
10244a56b808SFande Kong     /* Form remote C(ii, :) */
10254a56b808SFande Kong     poj = po->j + po->i[i];
10264a56b808SFande Kong     poa = po->a + po->i[i];
10274a56b808SFande Kong     for (j=0; j<nzi; j++) {
10284a56b808SFande Kong       c_rmtjj = c_rmtj + ptap->c_rmti[poj[j]];
10294a56b808SFande Kong       c_rmtaa = c_rmta + ptap->c_rmti[poj[j]];
10304a56b808SFande Kong       for (jj=0; jj<voff; jj++) {
10314a56b808SFande Kong         apvaluestmp[jj] = apvalues[jj]*poa[j];
10324a56b808SFande Kong         /*If the row is empty */
10334a56b808SFande Kong         if (!c_rmtc[poj[j]]) {
10344a56b808SFande Kong           c_rmtjj[jj] = apindices[jj];
10354a56b808SFande Kong           c_rmtaa[jj] = apvaluestmp[jj];
10364a56b808SFande Kong           c_rmtc[poj[j]]++;
10374a56b808SFande Kong         } else {
10384a56b808SFande Kong           ierr = PetscFindInt(apindices[jj],c_rmtc[poj[j]],c_rmtjj,&loc);CHKERRQ(ierr);
10394a56b808SFande Kong           if (loc>=0){ /* hit */
10404a56b808SFande Kong             c_rmtaa[loc] += apvaluestmp[jj];
104149c8f2b8SFande Kong             ierr = PetscLogFlops(1.0);CHKERRQ(ierr);
10424a56b808SFande Kong           } else { /* new element */
10434a56b808SFande Kong             loc = -(loc+1);
10444a56b808SFande Kong             /* Move data backward */
10454a56b808SFande Kong             for (kk=c_rmtc[poj[j]]; kk>loc; kk--) {
10464a56b808SFande Kong               c_rmtjj[kk] = c_rmtjj[kk-1];
10474a56b808SFande Kong               c_rmtaa[kk] = c_rmtaa[kk-1];
10484a56b808SFande Kong             }/* End kk */
10494a56b808SFande Kong             c_rmtjj[loc] = apindices[jj];
10504a56b808SFande Kong             c_rmtaa[loc] = apvaluestmp[jj];
10514a56b808SFande Kong             c_rmtc[poj[j]]++;
10524a56b808SFande Kong           }
10534a56b808SFande Kong         }
10544a56b808SFande Kong       } /* End jj */
105549c8f2b8SFande Kong       ierr = PetscLogFlops(voff);CHKERRQ(ierr);
10564a56b808SFande Kong     } /* End j */
10574a56b808SFande Kong 
10584a56b808SFande Kong     /* Form local C(ii, :) */
10594a56b808SFande Kong     pdj = pd->j + pd->i[i];
10604a56b808SFande Kong     pda = pd->a + pd->i[i];
10614a56b808SFande Kong     for (j=0; j<dnzi; j++) {
10624a56b808SFande Kong       row = pcstart + pdj[j];
10634a56b808SFande Kong       for (jj=0; jj<voff; jj++) {
10644a56b808SFande Kong         apvaluestmp[jj] = apvalues[jj]*pda[j];
10654a56b808SFande Kong       }/* End kk */
106649c8f2b8SFande Kong       ierr = PetscLogFlops(voff);CHKERRQ(ierr);
10674a56b808SFande Kong       ierr = MatSetValues(C,1,&row,voff,apindices,apvaluestmp,ADD_VALUES);CHKERRQ(ierr);
10684a56b808SFande Kong     }/* End j */
10694a56b808SFande Kong   } /* End i */
10704a56b808SFande Kong 
10714a56b808SFande Kong   ierr = PetscFree4(apindices,apvalues,apvaluestmp,c_rmtc);CHKERRQ(ierr);
10724a56b808SFande Kong   ierr = PetscHMapIVDestroy(&hmap);CHKERRQ(ierr);
10734a56b808SFande Kong   ierr = PetscCalloc2(ptap->c_othi[pn],&c_othj,ptap->c_othi[pn],&c_otha);CHKERRQ(ierr);
10744a56b808SFande Kong 
10754a56b808SFande Kong   ierr = PetscSFReduceBegin(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPIU_REPLACE);CHKERRQ(ierr);
10764a56b808SFande Kong   ierr = PetscSFReduceBegin(ptap->sf,MPIU_SCALAR,c_rmta,c_otha,MPIU_REPLACE);CHKERRQ(ierr);
10774a56b808SFande Kong   ierr = PetscSFReduceEnd(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPI_SUM);CHKERRQ(ierr);
10784a56b808SFande Kong   ierr = PetscSFReduceEnd(ptap->sf,MPIU_SCALAR,c_rmta,c_otha,MPIU_REPLACE);CHKERRQ(ierr);
10794a56b808SFande Kong   ierr = PetscFree2(c_rmtj,c_rmta);CHKERRQ(ierr);
10804a56b808SFande Kong 
10814a56b808SFande Kong   /* Add contributions from remote */
10824a56b808SFande Kong   for (i = 0; i < pn; i++) {
10834a56b808SFande Kong     row = i + pcstart;
10844a56b808SFande Kong     ierr = MatSetValues(C,1,&row,ptap->c_othi[i+1]-ptap->c_othi[i],c_othj+ptap->c_othi[i],c_otha+ptap->c_othi[i],ADD_VALUES);CHKERRQ(ierr);
10854a56b808SFande Kong   }
10864a56b808SFande Kong   ierr = PetscFree2(c_othj,c_otha);CHKERRQ(ierr);
10874a56b808SFande Kong 
10884a56b808SFande Kong   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
10894a56b808SFande Kong   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
10904a56b808SFande Kong 
10914a56b808SFande Kong   ptap->reuse = MAT_REUSE_MATRIX;
10924a56b808SFande Kong 
10934a56b808SFande Kong   /* supporting struct ptap consumes almost same amount of memory as C=PtAP, release it if C will not be updated by A and P */
10944a56b808SFande Kong   if (ptap->freestruct) {
10954a56b808SFande Kong     ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr);
10964a56b808SFande Kong   }
10974a56b808SFande Kong   PetscFunctionReturn(0);
10984a56b808SFande Kong }
10994a56b808SFande Kong 
11004a56b808SFande Kong PetscErrorCode MatPtAPSymbolic_MPIAIJ_MPIAIJ_allatonce(Mat A,Mat P,PetscReal fill,Mat *C)
11014a56b808SFande Kong {
11024a56b808SFande Kong   Mat_APMPI           *ptap;
11034a56b808SFande Kong   Mat_MPIAIJ          *p=(Mat_MPIAIJ*)P->data,*c;
11044a56b808SFande Kong   MPI_Comm            comm;
11054a56b808SFande Kong   Mat                 Cmpi;
11064a56b808SFande Kong   Mat_SeqAIJ          *pd,*po;
11074a56b808SFande Kong   MatType             mtype;
11084a56b808SFande Kong   PetscSF             sf;
11094a56b808SFande Kong   PetscSFNode         *iremote;
11104a56b808SFande Kong   PetscInt            rootspacesize,*rootspace,*rootspaceoffsets,nleaves;
11114a56b808SFande Kong   const PetscInt      *rootdegrees;
11124a56b808SFande Kong   PetscHSetI          ht,oht,*hta,*hto;
11134a56b808SFande Kong   PetscInt            pn,pon,*c_rmtc,i,j,nzi,htsize,htosize,*c_rmtj,off,*c_othj,rcvncols,sendncols,*c_rmtoffsets;
11144a56b808SFande Kong   PetscInt            owner,lidx,*rdj,col,pcstart,pcend,*dnz,*onz,am,arstart,arend,*poj,*pdj;
11154a56b808SFande Kong   PetscInt            nalg=2,alg=0;
11164a56b808SFande Kong   PetscBool           flg;
11174a56b808SFande Kong   const char          *algTypes[2] = {"overlapping","merged"};
11184a56b808SFande Kong   PetscErrorCode      ierr;
11194a56b808SFande Kong 
11204a56b808SFande Kong   PetscFunctionBegin;
11214a56b808SFande Kong   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
11224a56b808SFande Kong 
11234a56b808SFande Kong   /* Create symbolic parallel matrix Cmpi */
11244a56b808SFande Kong   ierr = MatGetLocalSize(P,NULL,&pn);CHKERRQ(ierr);
11254a56b808SFande Kong   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
11264a56b808SFande Kong   ierr = MatGetType(A,&mtype);CHKERRQ(ierr);
11274a56b808SFande Kong   ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr);
11284a56b808SFande Kong   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
11294a56b808SFande Kong 
11304a56b808SFande Kong   ierr        = PetscNew(&ptap);CHKERRQ(ierr);
11314a56b808SFande Kong   ptap->reuse = MAT_INITIAL_MATRIX;
11324a56b808SFande Kong   ptap->algType = 2;
11334a56b808SFande Kong 
11344a56b808SFande Kong   /* Get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
1135*5c65b9ecSFande Kong   ierr =  MatGetBrowsOfAcols_MPIXAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->P_oth);CHKERRQ(ierr);
11364a56b808SFande Kong 
11374a56b808SFande Kong   po = (Mat_SeqAIJ*)p->B->data;
11384a56b808SFande Kong   pd = (Mat_SeqAIJ*)p->A->data;
11394a56b808SFande Kong 
11404a56b808SFande Kong   /* This equals to the number of offdiag columns in P */
11414a56b808SFande Kong   ierr = MatGetLocalSize(p->B,NULL,&pon);CHKERRQ(ierr);
11424a56b808SFande Kong   /* offsets */
11434a56b808SFande Kong   ierr = PetscMalloc1(pon+1,&ptap->c_rmti);CHKERRQ(ierr);
11444a56b808SFande Kong   /* The number of columns we will send to remote ranks */
11454a56b808SFande Kong   ierr = PetscMalloc1(pon,&c_rmtc);CHKERRQ(ierr);
11464a56b808SFande Kong   ierr = PetscMalloc1(pon,&hta);CHKERRQ(ierr);
11474a56b808SFande Kong   for (i=0; i<pon; i++) {
11484a56b808SFande Kong     ierr = PetscHSetICreate(&hta[i]);CHKERRQ(ierr);
11494a56b808SFande Kong   }
11504a56b808SFande Kong   ierr = MatGetLocalSize(A,&am,NULL);CHKERRQ(ierr);
11514a56b808SFande Kong   ierr = MatGetOwnershipRange(A,&arstart,&arend);CHKERRQ(ierr);
11524a56b808SFande Kong   /* Create hash table to merge all columns for C(i, :) */
11534a56b808SFande Kong   ierr = PetscHSetICreate(&ht);CHKERRQ(ierr);
11544a56b808SFande Kong 
11554a56b808SFande Kong   ptap->c_rmti[0] = 0;
11564a56b808SFande Kong   /* 2) Pass 1: calculate the size for C_rmt (a matrix need to be sent to other processors)  */
11574a56b808SFande Kong   for (i=0; i<am && pon; i++) {
11584a56b808SFande Kong     /* Form one row of AP */
11594a56b808SFande Kong     ierr = PetscHSetIClear(ht);CHKERRQ(ierr);
11604a56b808SFande Kong     /* If the off diag is empty, we should not do any calculation */
11614a56b808SFande Kong     nzi = po->i[i+1] - po->i[i];
11624a56b808SFande Kong     if (!nzi) continue;
11634a56b808SFande Kong 
11644a56b808SFande Kong     ierr = MatPtAPSymbolicComputeOneRowOfAP_private(A,P,ptap->P_oth,i,ht,ht);CHKERRQ(ierr);
11654a56b808SFande Kong     ierr = PetscHSetIGetSize(ht,&htsize);CHKERRQ(ierr);
11664a56b808SFande Kong     /* If AP is empty, just continue */
11674a56b808SFande Kong     if (!htsize) continue;
11684a56b808SFande Kong     /* Form C(ii, :) */
11694a56b808SFande Kong     poj = po->j + po->i[i];
11704a56b808SFande Kong     for (j=0; j<nzi; j++) {
1171694f88d4SFande Kong       ierr = PetscHSetIUpdate(hta[poj[j]],ht);CHKERRQ(ierr);
11724a56b808SFande Kong     }
11734a56b808SFande Kong   }
11744a56b808SFande Kong 
11754a56b808SFande Kong   for (i=0; i<pon; i++) {
11764a56b808SFande Kong     ierr = PetscHSetIGetSize(hta[i],&htsize);CHKERRQ(ierr);
11774a56b808SFande Kong     ptap->c_rmti[i+1] = ptap->c_rmti[i] + htsize;
11784a56b808SFande Kong     c_rmtc[i] = htsize;
11794a56b808SFande Kong   }
11804a56b808SFande Kong 
11814a56b808SFande Kong   ierr = PetscMalloc1(ptap->c_rmti[pon],&c_rmtj);CHKERRQ(ierr);
11824a56b808SFande Kong 
11834a56b808SFande Kong   for (i=0; i<pon; i++) {
11844a56b808SFande Kong     off = 0;
11854a56b808SFande Kong     ierr = PetscHSetIGetElems(hta[i],&off,c_rmtj+ptap->c_rmti[i]);CHKERRQ(ierr);
11864a56b808SFande Kong     ierr = PetscHSetIDestroy(&hta[i]);CHKERRQ(ierr);
11874a56b808SFande Kong   }
11884a56b808SFande Kong   ierr = PetscFree(hta);CHKERRQ(ierr);
11894a56b808SFande Kong 
1190071fcb05SBarry Smith   ierr = PetscMalloc1(pon,&iremote);CHKERRQ(ierr);
11914a56b808SFande Kong   for (i=0; i<pon; i++) {
1192ef7a94f2SFande Kong     owner = 0; lidx = 0;
11934a56b808SFande Kong     ierr = PetscLayoutFindOwnerIndex(P->cmap,p->garray[i],&owner,&lidx);CHKERRQ(ierr);
11944a56b808SFande Kong     iremote[i].index = lidx;
11954a56b808SFande Kong     iremote[i].rank  = owner;
11964a56b808SFande Kong   }
11974a56b808SFande Kong 
11984a56b808SFande Kong   ierr = PetscSFCreate(comm,&sf);CHKERRQ(ierr);
11994a56b808SFande Kong   ierr = PetscSFSetGraph(sf,pn,pon,NULL,PETSC_OWN_POINTER,iremote,PETSC_OWN_POINTER);CHKERRQ(ierr);
12004a56b808SFande Kong   /* Reorder ranks properly so that the data handled by gather and scatter have the same order */
12014a56b808SFande Kong   ierr = PetscSFSetRankOrder(sf,PETSC_TRUE);CHKERRQ(ierr);
12024a56b808SFande Kong   ierr = PetscSFSetFromOptions(sf);CHKERRQ(ierr);
12034a56b808SFande Kong   ierr = PetscSFSetUp(sf);CHKERRQ(ierr);
12044a56b808SFande Kong   /* How many neighbors have contributions to my rows? */
12054a56b808SFande Kong   ierr = PetscSFComputeDegreeBegin(sf,&rootdegrees);CHKERRQ(ierr);
12064a56b808SFande Kong   ierr = PetscSFComputeDegreeEnd(sf,&rootdegrees);CHKERRQ(ierr);
12074a56b808SFande Kong   rootspacesize = 0;
12084a56b808SFande Kong   for (i = 0; i < pn; i++) {
12094a56b808SFande Kong     rootspacesize += rootdegrees[i];
12104a56b808SFande Kong   }
1211071fcb05SBarry Smith   ierr = PetscMalloc1(rootspacesize,&rootspace);CHKERRQ(ierr);
1212071fcb05SBarry Smith   ierr = PetscMalloc1(rootspacesize+1,&rootspaceoffsets);CHKERRQ(ierr);
12134a56b808SFande Kong   /* Get information from leaves
12144a56b808SFande Kong    * Number of columns other people contribute to my rows
12154a56b808SFande Kong    * */
12164a56b808SFande Kong   ierr = PetscSFGatherBegin(sf,MPIU_INT,c_rmtc,rootspace);CHKERRQ(ierr);
12174a56b808SFande Kong   ierr = PetscSFGatherEnd(sf,MPIU_INT,c_rmtc,rootspace);CHKERRQ(ierr);
12184a56b808SFande Kong   ierr = PetscFree(c_rmtc);CHKERRQ(ierr);
12194a56b808SFande Kong   ierr = PetscCalloc1(pn+1,&ptap->c_othi);CHKERRQ(ierr);
12204a56b808SFande Kong   /* The number of columns is received for each row */
12214a56b808SFande Kong   ptap->c_othi[0] = 0;
12224a56b808SFande Kong   rootspacesize = 0;
12234a56b808SFande Kong   rootspaceoffsets[0] = 0;
12244a56b808SFande Kong   for (i = 0; i < pn; i++) {
12254a56b808SFande Kong     rcvncols = 0;
12264a56b808SFande Kong     for (j = 0; j<rootdegrees[i]; j++) {
12274a56b808SFande Kong       rcvncols += rootspace[rootspacesize];
12284a56b808SFande Kong       rootspaceoffsets[rootspacesize+1] = rootspaceoffsets[rootspacesize] + rootspace[rootspacesize];
12294a56b808SFande Kong       rootspacesize++;
12304a56b808SFande Kong     }
12314a56b808SFande Kong     ptap->c_othi[i+1] = ptap->c_othi[i] + rcvncols;
12324a56b808SFande Kong   }
12334a56b808SFande Kong   ierr = PetscFree(rootspace);CHKERRQ(ierr);
12344a56b808SFande Kong 
1235071fcb05SBarry Smith   ierr = PetscMalloc1(pon,&c_rmtoffsets);CHKERRQ(ierr);
12364a56b808SFande Kong   ierr = PetscSFScatterBegin(sf,MPIU_INT,rootspaceoffsets,c_rmtoffsets);CHKERRQ(ierr);
12374a56b808SFande Kong   ierr = PetscSFScatterEnd(sf,MPIU_INT,rootspaceoffsets,c_rmtoffsets);CHKERRQ(ierr);
12384a56b808SFande Kong   ierr = PetscSFDestroy(&sf);CHKERRQ(ierr);
12394a56b808SFande Kong   ierr = PetscFree(rootspaceoffsets);CHKERRQ(ierr);
12404a56b808SFande Kong 
12414a56b808SFande Kong   ierr = PetscCalloc1(ptap->c_rmti[pon],&iremote);CHKERRQ(ierr);
12424a56b808SFande Kong   nleaves = 0;
12434a56b808SFande Kong   for (i = 0; i<pon; i++) {
1244ef7a94f2SFande Kong     owner = 0; lidx = 0;
12454a56b808SFande Kong     ierr = PetscLayoutFindOwnerIndex(P->cmap,p->garray[i],&owner,&lidx);CHKERRQ(ierr);
12464a56b808SFande Kong     sendncols = ptap->c_rmti[i+1] - ptap->c_rmti[i];
12474a56b808SFande Kong     for (j=0; j<sendncols; j++) {
12484a56b808SFande Kong       iremote[nleaves].rank = owner;
12494a56b808SFande Kong       iremote[nleaves++].index = c_rmtoffsets[i] + j;
12504a56b808SFande Kong     }
12514a56b808SFande Kong   }
12524a56b808SFande Kong   ierr = PetscFree(c_rmtoffsets);CHKERRQ(ierr);
12534a56b808SFande Kong   ierr = PetscCalloc1(ptap->c_othi[pn],&c_othj);CHKERRQ(ierr);
12544a56b808SFande Kong 
12554a56b808SFande Kong   ierr = PetscSFCreate(comm,&ptap->sf);CHKERRQ(ierr);
12564a56b808SFande Kong   ierr = PetscSFSetGraph(ptap->sf,ptap->c_othi[pn],nleaves,NULL,PETSC_OWN_POINTER,iremote,PETSC_OWN_POINTER);CHKERRQ(ierr);
12574a56b808SFande Kong   ierr = PetscSFSetFromOptions(ptap->sf);CHKERRQ(ierr);
12584a56b808SFande Kong   /* One to one map */
12594a56b808SFande Kong   ierr = PetscSFReduceBegin(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPIU_REPLACE);CHKERRQ(ierr);
12604a56b808SFande Kong 
1261071fcb05SBarry Smith   ierr = PetscMalloc2(pn,&dnz,pn,&onz);CHKERRQ(ierr);
12624a56b808SFande Kong   ierr = PetscHSetICreate(&oht);CHKERRQ(ierr);
12634a56b808SFande Kong   ierr = MatGetOwnershipRangeColumn(P,&pcstart,&pcend);CHKERRQ(ierr);
12644a56b808SFande Kong   ierr = PetscMalloc2(pn,&hta,pn,&hto);CHKERRQ(ierr);
12654a56b808SFande Kong   for (i=0; i<pn; i++) {
12664a56b808SFande Kong     ierr = PetscHSetICreate(&hta[i]);CHKERRQ(ierr);
12674a56b808SFande Kong     ierr = PetscHSetICreate(&hto[i]);CHKERRQ(ierr);
12684a56b808SFande Kong   }
12694a56b808SFande Kong   /* Work on local part */
12704a56b808SFande Kong   /* 4) Pass 1: Estimate memory for C_loc */
12714a56b808SFande Kong   for (i=0; i<am && pn; i++) {
12724a56b808SFande Kong     ierr = PetscHSetIClear(ht);CHKERRQ(ierr);
12734a56b808SFande Kong     ierr = PetscHSetIClear(oht);CHKERRQ(ierr);
12744a56b808SFande Kong     nzi = pd->i[i+1] - pd->i[i];
12754a56b808SFande Kong     if (!nzi) continue;
12764a56b808SFande Kong 
12774a56b808SFande Kong     ierr = MatPtAPSymbolicComputeOneRowOfAP_private(A,P,ptap->P_oth,i,ht,oht);CHKERRQ(ierr);
12784a56b808SFande Kong     ierr = PetscHSetIGetSize(ht,&htsize);CHKERRQ(ierr);
12794a56b808SFande Kong     ierr = PetscHSetIGetSize(oht,&htosize);CHKERRQ(ierr);
12804a56b808SFande Kong     if (!(htsize+htosize)) continue;
12814a56b808SFande Kong     /* Form C(ii, :) */
12824a56b808SFande Kong     pdj = pd->j + pd->i[i];
12834a56b808SFande Kong     for (j=0; j<nzi; j++) {
1284694f88d4SFande Kong       ierr = PetscHSetIUpdate(hta[pdj[j]],ht);CHKERRQ(ierr);
1285694f88d4SFande Kong       ierr = PetscHSetIUpdate(hto[pdj[j]],oht);CHKERRQ(ierr);
12864a56b808SFande Kong     }
12874a56b808SFande Kong   }
12884a56b808SFande Kong 
12894a56b808SFande Kong   ierr = PetscHSetIDestroy(&ht);CHKERRQ(ierr);
12904a56b808SFande Kong   ierr = PetscHSetIDestroy(&oht);CHKERRQ(ierr);
12914a56b808SFande Kong 
12924a56b808SFande Kong   /* Get remote data */
12934a56b808SFande Kong   ierr = PetscSFReduceEnd(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPIU_REPLACE);CHKERRQ(ierr);
12944a56b808SFande Kong   ierr = PetscFree(c_rmtj);CHKERRQ(ierr);
12954a56b808SFande Kong 
12964a56b808SFande Kong   for (i = 0; i < pn; i++) {
12974a56b808SFande Kong     nzi = ptap->c_othi[i+1] - ptap->c_othi[i];
12984a56b808SFande Kong     rdj = c_othj + ptap->c_othi[i];
12994a56b808SFande Kong     for (j = 0; j < nzi; j++) {
13004a56b808SFande Kong       col =  rdj[j];
13014a56b808SFande Kong       /* diag part */
13024a56b808SFande Kong       if (col>=pcstart && col<pcend) {
13034a56b808SFande Kong         ierr = PetscHSetIAdd(hta[i],col);CHKERRQ(ierr);
13044a56b808SFande Kong       } else { /* off diag */
13054a56b808SFande Kong         ierr = PetscHSetIAdd(hto[i],col);CHKERRQ(ierr);
13064a56b808SFande Kong       }
13074a56b808SFande Kong     }
13084a56b808SFande Kong     ierr = PetscHSetIGetSize(hta[i],&htsize);CHKERRQ(ierr);
13094a56b808SFande Kong     dnz[i] = htsize;
13104a56b808SFande Kong     ierr = PetscHSetIDestroy(&hta[i]);CHKERRQ(ierr);
13114a56b808SFande Kong     ierr = PetscHSetIGetSize(hto[i],&htsize);CHKERRQ(ierr);
13124a56b808SFande Kong     onz[i] = htsize;
13134a56b808SFande Kong     ierr = PetscHSetIDestroy(&hto[i]);CHKERRQ(ierr);
13144a56b808SFande Kong   }
13154a56b808SFande Kong 
13164a56b808SFande Kong   ierr = PetscFree2(hta,hto);CHKERRQ(ierr);
13174a56b808SFande Kong   ierr = PetscFree(c_othj);CHKERRQ(ierr);
13184a56b808SFande Kong 
13194a56b808SFande Kong   /* local sizes and preallocation */
13204a56b808SFande Kong   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
13214a56b808SFande Kong   ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(P->cmap->bs));CHKERRQ(ierr);
13224a56b808SFande Kong   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
13234a56b808SFande Kong   ierr = PetscFree2(dnz,onz);CHKERRQ(ierr);
13244a56b808SFande Kong 
13254a56b808SFande Kong   /* attach the supporting struct to Cmpi for reuse */
13264a56b808SFande Kong   c = (Mat_MPIAIJ*)Cmpi->data;
13274a56b808SFande Kong   c->ap           = ptap;
13284a56b808SFande Kong   ptap->duplicate = Cmpi->ops->duplicate;
13294a56b808SFande Kong   ptap->destroy   = Cmpi->ops->destroy;
13304a56b808SFande Kong   ptap->view      = Cmpi->ops->view;
13314a56b808SFande Kong 
13324a56b808SFande Kong   /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */
13334a56b808SFande Kong   Cmpi->assembled        = PETSC_FALSE;
13344a56b808SFande Kong   /* pick an algorithm */
13354a56b808SFande Kong   ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)A),((PetscObject)A)->prefix,"MatPtAP","Mat");CHKERRQ(ierr);
13364a56b808SFande Kong   alg = 0;
13374a56b808SFande Kong   ierr = PetscOptionsEList("-matptap_allatonce_via","PtAP allatonce numeric approach","MatPtAP",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr);
13384a56b808SFande Kong   ierr = PetscOptionsEnd();CHKERRQ(ierr);
13394a56b808SFande Kong   switch (alg) {
13404a56b808SFande Kong     case 0:
13414a56b808SFande Kong       Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_allatonce;
13424a56b808SFande Kong       break;
13434a56b808SFande Kong     case 1:
13444a56b808SFande Kong       Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_allatonce_merged;
13454a56b808SFande Kong       break;
13464a56b808SFande Kong     default:
13474a56b808SFande Kong       SETERRQ(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG," Unsupported allatonce numerical algorithm \n");
13484a56b808SFande Kong   }
13494a56b808SFande Kong   Cmpi->ops->destroy     = MatDestroy_MPIAIJ_PtAP;
13504a56b808SFande Kong   Cmpi->ops->view        = MatView_MPIAIJ_PtAP;
13514a56b808SFande Kong   Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP;
13524a56b808SFande Kong   *C                     = Cmpi;
13534a56b808SFande Kong   PetscFunctionReturn(0);
13544a56b808SFande Kong }
13554a56b808SFande Kong 
13564a56b808SFande Kong PetscErrorCode MatPtAPSymbolic_MPIAIJ_MPIAIJ_allatonce_merged(Mat A,Mat P,PetscReal fill,Mat *C)
13574a56b808SFande Kong {
13584a56b808SFande Kong   Mat_APMPI           *ptap;
13594a56b808SFande Kong   Mat_MPIAIJ          *p=(Mat_MPIAIJ*)P->data,*c;
13604a56b808SFande Kong   MPI_Comm            comm;
13614a56b808SFande Kong   Mat                 Cmpi;
13624a56b808SFande Kong   Mat_SeqAIJ          *pd,*po;
13634a56b808SFande Kong   MatType             mtype;
13644a56b808SFande Kong   PetscSF             sf;
13654a56b808SFande Kong   PetscSFNode         *iremote;
13664a56b808SFande Kong   PetscInt            rootspacesize,*rootspace,*rootspaceoffsets,nleaves;
13674a56b808SFande Kong   const PetscInt      *rootdegrees;
13684a56b808SFande Kong   PetscHSetI          ht,oht,*hta,*hto,*htd;
13694a56b808SFande Kong   PetscInt            pn,pon,*c_rmtc,i,j,nzi,dnzi,htsize,htosize,*c_rmtj,off,*c_othj,rcvncols,sendncols,*c_rmtoffsets;
13704a56b808SFande Kong   PetscInt            owner,lidx,*rdj,col,pcstart,pcend,*dnz,*onz,am,arstart,arend,*poj,*pdj;
13714a56b808SFande Kong   PetscInt            nalg=2,alg=0;
13724a56b808SFande Kong   PetscBool           flg;
13734a56b808SFande Kong   const char          *algTypes[2] = {"merged","overlapping"};
13744a56b808SFande Kong   PetscErrorCode      ierr;
13754a56b808SFande Kong 
13764a56b808SFande Kong   PetscFunctionBegin;
13774a56b808SFande Kong   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
13784a56b808SFande Kong 
13794a56b808SFande Kong   /* Create symbolic parallel matrix Cmpi */
13804a56b808SFande Kong   ierr = MatGetLocalSize(P,NULL,&pn);CHKERRQ(ierr);
13814a56b808SFande Kong   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
13824a56b808SFande Kong   ierr = MatGetType(A,&mtype);CHKERRQ(ierr);
13834a56b808SFande Kong   ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr);
13844a56b808SFande Kong   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
13854a56b808SFande Kong 
13864a56b808SFande Kong   ierr        = PetscNew(&ptap);CHKERRQ(ierr);
13874a56b808SFande Kong   ptap->reuse = MAT_INITIAL_MATRIX;
13884a56b808SFande Kong   ptap->algType = 3;
13894a56b808SFande Kong 
13904a56b808SFande Kong   /* 0) Get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
1391*5c65b9ecSFande Kong   ierr =  MatGetBrowsOfAcols_MPIXAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->P_oth);CHKERRQ(ierr);
13924a56b808SFande Kong 
13934a56b808SFande Kong   po = (Mat_SeqAIJ*)p->B->data;
13944a56b808SFande Kong   pd = (Mat_SeqAIJ*)p->A->data;
13954a56b808SFande Kong 
13964a56b808SFande Kong   /* This equals to the number of offdiag columns in P */
13974a56b808SFande Kong   ierr = MatGetLocalSize(p->B,NULL,&pon);CHKERRQ(ierr);
13984a56b808SFande Kong   /* offsets */
13994a56b808SFande Kong   ierr = PetscMalloc1(pon+1,&ptap->c_rmti);CHKERRQ(ierr);
14004a56b808SFande Kong   /* The number of columns we will send to remote ranks */
14014a56b808SFande Kong   ierr = PetscMalloc1(pon,&c_rmtc);CHKERRQ(ierr);
14024a56b808SFande Kong   ierr = PetscMalloc1(pon,&hta);CHKERRQ(ierr);
14034a56b808SFande Kong   for (i=0; i<pon; i++) {
14044a56b808SFande Kong     ierr = PetscHSetICreate(&hta[i]);CHKERRQ(ierr);
14054a56b808SFande Kong   }
14064a56b808SFande Kong   ierr = MatGetLocalSize(A,&am,NULL);CHKERRQ(ierr);
14074a56b808SFande Kong   ierr = MatGetOwnershipRange(A,&arstart,&arend);CHKERRQ(ierr);
14084a56b808SFande Kong   /* Create hash table to merge all columns for C(i, :) */
14094a56b808SFande Kong   ierr = PetscHSetICreate(&ht);CHKERRQ(ierr);
14104a56b808SFande Kong   ierr = PetscHSetICreate(&oht);CHKERRQ(ierr);
14114a56b808SFande Kong   ierr = PetscMalloc2(pn,&htd,pn,&hto);CHKERRQ(ierr);
14124a56b808SFande Kong   for (i=0; i<pn; i++) {
14134a56b808SFande Kong     ierr = PetscHSetICreate(&htd[i]);CHKERRQ(ierr);
14144a56b808SFande Kong     ierr = PetscHSetICreate(&hto[i]);CHKERRQ(ierr);
14154a56b808SFande Kong   }
14164a56b808SFande Kong   ptap->c_rmti[0] = 0;
14174a56b808SFande Kong   /* 2) Pass 1: calculate the size for C_rmt (a matrix need to be sent to other processors)  */
14184a56b808SFande Kong   for (i=0; i<am && (pon || pn); i++) {
14194a56b808SFande Kong     /* Form one row of AP */
14204a56b808SFande Kong     ierr = PetscHSetIClear(ht);CHKERRQ(ierr);
14214a56b808SFande Kong     ierr = PetscHSetIClear(oht);CHKERRQ(ierr);
14224a56b808SFande Kong     /* If the off diag is empty, we should not do any calculation */
14234a56b808SFande Kong     nzi = po->i[i+1] - po->i[i];
14244a56b808SFande Kong     dnzi = pd->i[i+1] - pd->i[i];
14254a56b808SFande Kong     if (!nzi && !dnzi) continue;
14264a56b808SFande Kong 
14274a56b808SFande Kong     ierr = MatPtAPSymbolicComputeOneRowOfAP_private(A,P,ptap->P_oth,i,ht,oht);CHKERRQ(ierr);
14284a56b808SFande Kong     ierr = PetscHSetIGetSize(ht,&htsize);CHKERRQ(ierr);
14294a56b808SFande Kong     ierr = PetscHSetIGetSize(oht,&htosize);CHKERRQ(ierr);
14304a56b808SFande Kong     /* If AP is empty, just continue */
14314a56b808SFande Kong     if (!(htsize+htosize)) continue;
14324a56b808SFande Kong 
14334a56b808SFande Kong     /* Form remote C(ii, :) */
14344a56b808SFande Kong     poj = po->j + po->i[i];
14354a56b808SFande Kong     for (j=0; j<nzi; j++) {
1436694f88d4SFande Kong       ierr = PetscHSetIUpdate(hta[poj[j]],ht);CHKERRQ(ierr);
1437694f88d4SFande Kong       ierr = PetscHSetIUpdate(hta[poj[j]],oht);CHKERRQ(ierr);
14384a56b808SFande Kong     }
14394a56b808SFande Kong 
14404a56b808SFande Kong     /* Form local C(ii, :) */
14414a56b808SFande Kong     pdj = pd->j + pd->i[i];
14424a56b808SFande Kong     for (j=0; j<dnzi; j++) {
1443694f88d4SFande Kong       ierr = PetscHSetIUpdate(htd[pdj[j]],ht);CHKERRQ(ierr);
1444694f88d4SFande Kong       ierr = PetscHSetIUpdate(hto[pdj[j]],oht);CHKERRQ(ierr);
14454a56b808SFande Kong     }
14464a56b808SFande Kong   }
14474a56b808SFande Kong 
14484a56b808SFande Kong   ierr = PetscHSetIDestroy(&ht);CHKERRQ(ierr);
14494a56b808SFande Kong   ierr = PetscHSetIDestroy(&oht);CHKERRQ(ierr);
14504a56b808SFande Kong 
14514a56b808SFande Kong   for (i=0; i<pon; i++) {
14524a56b808SFande Kong     ierr = PetscHSetIGetSize(hta[i],&htsize);CHKERRQ(ierr);
14534a56b808SFande Kong     ptap->c_rmti[i+1] = ptap->c_rmti[i] + htsize;
14544a56b808SFande Kong     c_rmtc[i] = htsize;
14554a56b808SFande Kong   }
14564a56b808SFande Kong 
14574a56b808SFande Kong   ierr = PetscMalloc1(ptap->c_rmti[pon],&c_rmtj);CHKERRQ(ierr);
14584a56b808SFande Kong 
14594a56b808SFande Kong   for (i=0; i<pon; i++) {
14604a56b808SFande Kong     off = 0;
14614a56b808SFande Kong     ierr = PetscHSetIGetElems(hta[i],&off,c_rmtj+ptap->c_rmti[i]);CHKERRQ(ierr);
14624a56b808SFande Kong     ierr = PetscHSetIDestroy(&hta[i]);CHKERRQ(ierr);
14634a56b808SFande Kong   }
14644a56b808SFande Kong   ierr = PetscFree(hta);CHKERRQ(ierr);
14654a56b808SFande Kong 
1466071fcb05SBarry Smith   ierr = PetscMalloc1(pon,&iremote);CHKERRQ(ierr);
14674a56b808SFande Kong   for (i=0; i<pon; i++) {
1468ef7a94f2SFande Kong     owner = 0; lidx = 0;
14694a56b808SFande Kong     ierr = PetscLayoutFindOwnerIndex(P->cmap,p->garray[i],&owner,&lidx);CHKERRQ(ierr);
14704a56b808SFande Kong     iremote[i].index = lidx;
14714a56b808SFande Kong     iremote[i].rank  = owner;
14724a56b808SFande Kong   }
14734a56b808SFande Kong 
14744a56b808SFande Kong   ierr = PetscSFCreate(comm,&sf);CHKERRQ(ierr);
14754a56b808SFande Kong   ierr = PetscSFSetGraph(sf,pn,pon,NULL,PETSC_OWN_POINTER,iremote,PETSC_OWN_POINTER);CHKERRQ(ierr);
14764a56b808SFande Kong   /* Reorder ranks properly so that the data handled by gather and scatter have the same order */
14774a56b808SFande Kong   ierr = PetscSFSetRankOrder(sf,PETSC_TRUE);CHKERRQ(ierr);
14784a56b808SFande Kong   ierr = PetscSFSetFromOptions(sf);CHKERRQ(ierr);
14794a56b808SFande Kong   ierr = PetscSFSetUp(sf);CHKERRQ(ierr);
14804a56b808SFande Kong   /* How many neighbors have contributions to my rows? */
14814a56b808SFande Kong   ierr = PetscSFComputeDegreeBegin(sf,&rootdegrees);CHKERRQ(ierr);
14824a56b808SFande Kong   ierr = PetscSFComputeDegreeEnd(sf,&rootdegrees);CHKERRQ(ierr);
14834a56b808SFande Kong   rootspacesize = 0;
14844a56b808SFande Kong   for (i = 0; i < pn; i++) {
14854a56b808SFande Kong     rootspacesize += rootdegrees[i];
14864a56b808SFande Kong   }
1487071fcb05SBarry Smith   ierr = PetscMalloc1(rootspacesize,&rootspace);CHKERRQ(ierr);
1488071fcb05SBarry Smith   ierr = PetscMalloc1(rootspacesize+1,&rootspaceoffsets);CHKERRQ(ierr);
14894a56b808SFande Kong   /* Get information from leaves
14904a56b808SFande Kong    * Number of columns other people contribute to my rows
14914a56b808SFande Kong    * */
14924a56b808SFande Kong   ierr = PetscSFGatherBegin(sf,MPIU_INT,c_rmtc,rootspace);CHKERRQ(ierr);
14934a56b808SFande Kong   ierr = PetscSFGatherEnd(sf,MPIU_INT,c_rmtc,rootspace);CHKERRQ(ierr);
14944a56b808SFande Kong   ierr = PetscFree(c_rmtc);CHKERRQ(ierr);
1495071fcb05SBarry Smith   ierr = PetscMalloc1(pn+1,&ptap->c_othi);CHKERRQ(ierr);
14964a56b808SFande Kong   /* The number of columns is received for each row */
14974a56b808SFande Kong   ptap->c_othi[0]     = 0;
14984a56b808SFande Kong   rootspacesize       = 0;
14994a56b808SFande Kong   rootspaceoffsets[0] = 0;
15004a56b808SFande Kong   for (i = 0; i < pn; i++) {
15014a56b808SFande Kong     rcvncols = 0;
15024a56b808SFande Kong     for (j = 0; j<rootdegrees[i]; j++) {
15034a56b808SFande Kong       rcvncols += rootspace[rootspacesize];
15044a56b808SFande Kong       rootspaceoffsets[rootspacesize+1] = rootspaceoffsets[rootspacesize] + rootspace[rootspacesize];
15054a56b808SFande Kong       rootspacesize++;
15064a56b808SFande Kong     }
15074a56b808SFande Kong     ptap->c_othi[i+1] = ptap->c_othi[i] + rcvncols;
15084a56b808SFande Kong   }
15094a56b808SFande Kong   ierr = PetscFree(rootspace);CHKERRQ(ierr);
15104a56b808SFande Kong 
1511071fcb05SBarry Smith   ierr = PetscMalloc1(pon,&c_rmtoffsets);CHKERRQ(ierr);
15124a56b808SFande Kong   ierr = PetscSFScatterBegin(sf,MPIU_INT,rootspaceoffsets,c_rmtoffsets);CHKERRQ(ierr);
15134a56b808SFande Kong   ierr = PetscSFScatterEnd(sf,MPIU_INT,rootspaceoffsets,c_rmtoffsets);CHKERRQ(ierr);
15144a56b808SFande Kong   ierr = PetscSFDestroy(&sf);CHKERRQ(ierr);
15154a56b808SFande Kong   ierr = PetscFree(rootspaceoffsets);CHKERRQ(ierr);
15164a56b808SFande Kong 
15174a56b808SFande Kong   ierr = PetscCalloc1(ptap->c_rmti[pon],&iremote);CHKERRQ(ierr);
15184a56b808SFande Kong   nleaves = 0;
15194a56b808SFande Kong   for (i = 0; i<pon; i++) {
1520071fcb05SBarry Smith     owner = 0;
1521071fcb05SBarry Smith     lidx  = 0;
15224a56b808SFande Kong     ierr  = PetscLayoutFindOwnerIndex(P->cmap,p->garray[i],&owner,&lidx);CHKERRQ(ierr);
15234a56b808SFande Kong     sendncols = ptap->c_rmti[i+1] - ptap->c_rmti[i];
15244a56b808SFande Kong     for (j=0; j<sendncols; j++) {
15254a56b808SFande Kong       iremote[nleaves].rank    = owner;
15264a56b808SFande Kong       iremote[nleaves++].index = c_rmtoffsets[i] + j;
15274a56b808SFande Kong     }
15284a56b808SFande Kong   }
15294a56b808SFande Kong   ierr = PetscFree(c_rmtoffsets);CHKERRQ(ierr);
15304a56b808SFande Kong   ierr = PetscCalloc1(ptap->c_othi[pn],&c_othj);CHKERRQ(ierr);
15314a56b808SFande Kong 
15324a56b808SFande Kong   ierr = PetscSFCreate(comm,&ptap->sf);CHKERRQ(ierr);
15334a56b808SFande Kong   ierr = PetscSFSetGraph(ptap->sf,ptap->c_othi[pn],nleaves,NULL,PETSC_OWN_POINTER,iremote,PETSC_OWN_POINTER);CHKERRQ(ierr);
15344a56b808SFande Kong   ierr = PetscSFSetFromOptions(ptap->sf);CHKERRQ(ierr);
15354a56b808SFande Kong   /* One to one map */
15364a56b808SFande Kong   ierr = PetscSFReduceBegin(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPIU_REPLACE);CHKERRQ(ierr);
15374a56b808SFande Kong   /* Get remote data */
15384a56b808SFande Kong   ierr = PetscSFReduceEnd(ptap->sf,MPIU_INT,c_rmtj,c_othj,MPIU_REPLACE);CHKERRQ(ierr);
15394a56b808SFande Kong   ierr = PetscFree(c_rmtj);CHKERRQ(ierr);
1540071fcb05SBarry Smith   ierr = PetscMalloc2(pn,&dnz,pn,&onz);CHKERRQ(ierr);
15414a56b808SFande Kong   ierr = MatGetOwnershipRangeColumn(P,&pcstart,&pcend);CHKERRQ(ierr);
15424a56b808SFande Kong 
15434a56b808SFande Kong   for (i = 0; i < pn; i++) {
15444a56b808SFande Kong     nzi = ptap->c_othi[i+1] - ptap->c_othi[i];
15454a56b808SFande Kong     rdj = c_othj + ptap->c_othi[i];
15464a56b808SFande Kong     for (j = 0; j < nzi; j++) {
15474a56b808SFande Kong       col =  rdj[j];
15484a56b808SFande Kong       /* diag part */
15494a56b808SFande Kong       if (col>=pcstart && col<pcend) {
15504a56b808SFande Kong         ierr = PetscHSetIAdd(htd[i],col);CHKERRQ(ierr);
15514a56b808SFande Kong       } else { /* off diag */
15524a56b808SFande Kong         ierr = PetscHSetIAdd(hto[i],col);CHKERRQ(ierr);
15534a56b808SFande Kong       }
15544a56b808SFande Kong     }
15554a56b808SFande Kong     ierr = PetscHSetIGetSize(htd[i],&htsize);CHKERRQ(ierr);
15564a56b808SFande Kong     dnz[i] = htsize;
15574a56b808SFande Kong     ierr = PetscHSetIDestroy(&htd[i]);CHKERRQ(ierr);
15584a56b808SFande Kong     ierr = PetscHSetIGetSize(hto[i],&htsize);CHKERRQ(ierr);
15594a56b808SFande Kong     onz[i] = htsize;
15604a56b808SFande Kong     ierr = PetscHSetIDestroy(&hto[i]);CHKERRQ(ierr);
15614a56b808SFande Kong   }
15624a56b808SFande Kong 
15634a56b808SFande Kong   ierr = PetscFree2(htd,hto);CHKERRQ(ierr);
15644a56b808SFande Kong   ierr = PetscFree(c_othj);CHKERRQ(ierr);
15654a56b808SFande Kong 
15664a56b808SFande Kong   /* local sizes and preallocation */
15674a56b808SFande Kong   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
15684a56b808SFande Kong   ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(P->cmap->bs));CHKERRQ(ierr);
15694a56b808SFande Kong   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
15704a56b808SFande Kong   ierr = PetscFree2(dnz,onz);CHKERRQ(ierr);
15714a56b808SFande Kong 
15724a56b808SFande Kong   /* attach the supporting struct to Cmpi for reuse */
15734a56b808SFande Kong   c = (Mat_MPIAIJ*)Cmpi->data;
15744a56b808SFande Kong   c->ap           = ptap;
15754a56b808SFande Kong   ptap->duplicate = Cmpi->ops->duplicate;
15764a56b808SFande Kong   ptap->destroy   = Cmpi->ops->destroy;
15774a56b808SFande Kong   ptap->view      = Cmpi->ops->view;
15784a56b808SFande Kong 
15794a56b808SFande Kong   /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */
15804a56b808SFande Kong   Cmpi->assembled        = PETSC_FALSE;
15814a56b808SFande Kong   /* pick an algorithm */
15824a56b808SFande Kong   ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)A),((PetscObject)A)->prefix,"MatPtAP","Mat");CHKERRQ(ierr);
15834a56b808SFande Kong   alg = 0;
15844a56b808SFande Kong   ierr = PetscOptionsEList("-matptap_allatonce_via","PtAP allatonce numeric approach","MatPtAP",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr);
15854a56b808SFande Kong   ierr = PetscOptionsEnd();CHKERRQ(ierr);
15864a56b808SFande Kong   switch (alg) {
15874a56b808SFande Kong     case 0:
15884a56b808SFande Kong       Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_allatonce_merged;
15894a56b808SFande Kong       break;
15904a56b808SFande Kong     case 1:
15914a56b808SFande Kong       Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_allatonce;
15924a56b808SFande Kong       break;
15934a56b808SFande Kong     default:
15944a56b808SFande Kong       SETERRQ(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG," Unsupported allatonce numerical algorithm \n");
15954a56b808SFande Kong   }
15964a56b808SFande Kong   Cmpi->ops->destroy     = MatDestroy_MPIAIJ_PtAP;
15974a56b808SFande Kong   Cmpi->ops->view        = MatView_MPIAIJ_PtAP;
15984a56b808SFande Kong   Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP;
15994a56b808SFande Kong   *C                     = Cmpi;
16004a56b808SFande Kong   PetscFunctionReturn(0);
16014a56b808SFande Kong }
16024a56b808SFande Kong 
1603e953e47cSHong Zhang PetscErrorCode MatPtAPSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat *C)
1604e953e47cSHong Zhang {
1605e953e47cSHong Zhang   PetscErrorCode      ierr;
16063cdca5ebSHong Zhang   Mat_APMPI           *ptap;
1607e953e47cSHong Zhang   Mat_MPIAIJ          *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c;
1608e953e47cSHong Zhang   MPI_Comm            comm;
1609e953e47cSHong Zhang   PetscMPIInt         size,rank;
1610e953e47cSHong Zhang   Mat                 Cmpi;
1611e953e47cSHong Zhang   PetscFreeSpaceList  free_space=NULL,current_space=NULL;
1612e953e47cSHong Zhang   PetscInt            am=A->rmap->n,pm=P->rmap->n,pN=P->cmap->N,pn=P->cmap->n;
1613e953e47cSHong Zhang   PetscInt            *lnk,i,k,pnz,row,nsend;
1614e953e47cSHong Zhang   PetscBT             lnkbt;
1615e953e47cSHong Zhang   PetscMPIInt         tagi,tagj,*len_si,*len_s,*len_ri,icompleted=0,nrecv;
1616e953e47cSHong Zhang   PetscInt            **buf_rj,**buf_ri,**buf_ri_k;
1617e953e47cSHong Zhang   PetscInt            len,proc,*dnz,*onz,*owners,nzi,nspacedouble;
1618e953e47cSHong Zhang   PetscInt            nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci;
1619e953e47cSHong Zhang   MPI_Request         *swaits,*rwaits;
1620e953e47cSHong Zhang   MPI_Status          *sstatus,rstatus;
1621e953e47cSHong Zhang   PetscLayout         rowmap;
1622e953e47cSHong Zhang   PetscInt            *owners_co,*coi,*coj;    /* i and j array of (p->B)^T*A*P - used in the communication */
1623e953e47cSHong Zhang   PetscMPIInt         *len_r,*id_r;    /* array of length of comm->size, store send/recv matrix values */
1624e953e47cSHong Zhang   PetscInt            *api,*apj,*Jptr,apnz,*prmap=p->garray,con,j,ap_rmax=0,Crmax,*aj,*ai,*pi;
1625ec07b8f8SHong Zhang   Mat_SeqAIJ          *p_loc,*p_oth=NULL,*ad=(Mat_SeqAIJ*)(a->A)->data,*ao=NULL,*c_loc,*c_oth;
1626e953e47cSHong Zhang   PetscScalar         *apv;
1627e953e47cSHong Zhang   PetscTable          ta;
1628b92f168fSBarry Smith   MatType             mtype;
1629e83e5f86SFande Kong   const char          *prefix;
1630e953e47cSHong Zhang #if defined(PETSC_USE_INFO)
1631e953e47cSHong Zhang   PetscReal           apfill;
1632e953e47cSHong Zhang #endif
1633e953e47cSHong Zhang 
1634e953e47cSHong Zhang   PetscFunctionBegin;
1635b4e8d1b6SHong Zhang   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
1636e953e47cSHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1637e953e47cSHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1638e953e47cSHong Zhang 
163952f7967eSHong Zhang   if (size > 1) ao = (Mat_SeqAIJ*)(a->B)->data;
1640ec07b8f8SHong Zhang 
1641e953e47cSHong Zhang   /* create symbolic parallel matrix Cmpi */
1642e953e47cSHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
1643b92f168fSBarry Smith   ierr = MatGetType(A,&mtype);CHKERRQ(ierr);
1644b92f168fSBarry Smith   ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr);
1645e953e47cSHong Zhang 
1646e953e47cSHong Zhang   /* Do dense axpy in MatPtAPNumeric_MPIAIJ_MPIAIJ() */
1647e953e47cSHong Zhang   Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ;
1648e953e47cSHong Zhang 
16493cdca5ebSHong Zhang   /* create struct Mat_APMPI and attached it to C later */
165015a3b8e2SHong Zhang   ierr        = PetscNew(&ptap);CHKERRQ(ierr);
165115a3b8e2SHong Zhang   ptap->reuse = MAT_INITIAL_MATRIX;
1652a4ffb656SHong Zhang   ptap->algType = 1;
165315a3b8e2SHong Zhang 
165415a3b8e2SHong Zhang   /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
165515a3b8e2SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
165615a3b8e2SHong Zhang   /* get P_loc by taking all local rows of P */
165715a3b8e2SHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
165815a3b8e2SHong Zhang 
165967a12041SHong Zhang   /* (0) compute Rd = Pd^T, Ro = Po^T  */
166067a12041SHong Zhang   /* --------------------------------- */
1661419ecdd9Sandi selinger   ierr = MatTranspose(p->A,MAT_INITIAL_MATRIX,&ptap->Rd);CHKERRQ(ierr);
1662419ecdd9Sandi selinger   ierr = MatTranspose(p->B,MAT_INITIAL_MATRIX,&ptap->Ro);CHKERRQ(ierr);
166315a3b8e2SHong Zhang 
166467a12041SHong Zhang   /* (1) compute symbolic AP = A_loc*P = Ad*P_loc + Ao*P_oth (api,apj) */
166567a12041SHong Zhang   /* ----------------------------------------------------------------- */
166667a12041SHong Zhang   p_loc  = (Mat_SeqAIJ*)(ptap->P_loc)->data;
166752f7967eSHong Zhang   if (ptap->P_oth) p_oth  = (Mat_SeqAIJ*)(ptap->P_oth)->data;
1668445158ffSHong Zhang 
16699a6dcab7SHong Zhang   /* create and initialize a linked list */
167045d00d1dSHong Zhang   ierr = PetscTableCreate(pn,pN,&ta);CHKERRQ(ierr); /* for compute AP_loc and Cmpi */
16714b38b95cSHong Zhang   MatRowMergeMax_SeqAIJ(p_loc,ptap->P_loc->rmap->N,ta);
16724b38b95cSHong Zhang   MatRowMergeMax_SeqAIJ(p_oth,ptap->P_oth->rmap->N,ta);
167378d30b94SHong Zhang   ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr); /* Crmax = nnz(sum of Prows) */
1674d0e9a2f7SHong Zhang   /* printf("[%d] est %d, Crmax %d; pN %d\n",rank,5*(p_loc->rmax+p_oth->rmax + (PetscInt)(1.e-2*pN)),Crmax,pN); */
167578d30b94SHong Zhang 
167678d30b94SHong Zhang   ierr = PetscLLCondensedCreate(Crmax,pN,&lnk,&lnkbt);CHKERRQ(ierr);
1677445158ffSHong Zhang 
16788cb82516SHong Zhang   /* Initial FreeSpace size is fill*(nnz(A) + nnz(P)) */
1679ec07b8f8SHong Zhang   if (ao) {
1680f91af8c7SBarry Smith     ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(ad->i[am],PetscIntSumTruncate(ao->i[am],p_loc->i[pm]))),&free_space);CHKERRQ(ierr);
1681ec07b8f8SHong Zhang   } else {
1682ec07b8f8SHong Zhang     ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(ad->i[am],p_loc->i[pm])),&free_space);CHKERRQ(ierr);
1683ec07b8f8SHong Zhang   }
1684445158ffSHong Zhang   current_space = free_space;
168567a12041SHong Zhang   nspacedouble  = 0;
168667a12041SHong Zhang 
168767a12041SHong Zhang   ierr   = PetscMalloc1(am+1,&api);CHKERRQ(ierr);
168867a12041SHong Zhang   api[0] = 0;
1689445158ffSHong Zhang   for (i=0; i<am; i++) {
169067a12041SHong Zhang     /* diagonal portion: Ad[i,:]*P */
169167a12041SHong Zhang     ai = ad->i; pi = p_loc->i;
169267a12041SHong Zhang     nzi = ai[i+1] - ai[i];
169367a12041SHong Zhang     aj  = ad->j + ai[i];
1694445158ffSHong Zhang     for (j=0; j<nzi; j++) {
1695445158ffSHong Zhang       row  = aj[j];
169667a12041SHong Zhang       pnz  = pi[row+1] - pi[row];
169767a12041SHong Zhang       Jptr = p_loc->j + pi[row];
1698445158ffSHong Zhang       /* add non-zero cols of P into the sorted linked list lnk */
1699445158ffSHong Zhang       ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
1700445158ffSHong Zhang     }
170167a12041SHong Zhang     /* off-diagonal portion: Ao[i,:]*P */
1702ec07b8f8SHong Zhang     if (ao) {
170367a12041SHong Zhang       ai = ao->i; pi = p_oth->i;
170467a12041SHong Zhang       nzi = ai[i+1] - ai[i];
170567a12041SHong Zhang       aj  = ao->j + ai[i];
1706445158ffSHong Zhang       for (j=0; j<nzi; j++) {
1707445158ffSHong Zhang         row  = aj[j];
170867a12041SHong Zhang         pnz  = pi[row+1] - pi[row];
170967a12041SHong Zhang         Jptr = p_oth->j + pi[row];
1710445158ffSHong Zhang         ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
1711445158ffSHong Zhang       }
1712ec07b8f8SHong Zhang     }
1713445158ffSHong Zhang     apnz     = lnk[0];
1714445158ffSHong Zhang     api[i+1] = api[i] + apnz;
1715445158ffSHong Zhang     if (ap_rmax < apnz) ap_rmax = apnz;
1716445158ffSHong Zhang 
1717445158ffSHong Zhang     /* if free space is not available, double the total space in the list */
1718445158ffSHong Zhang     if (current_space->local_remaining<apnz) {
1719f91af8c7SBarry Smith       ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),&current_space);CHKERRQ(ierr);
1720445158ffSHong Zhang       nspacedouble++;
1721445158ffSHong Zhang     }
1722445158ffSHong Zhang 
1723445158ffSHong Zhang     /* Copy data into free space, then initialize lnk */
1724445158ffSHong Zhang     ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
1725445158ffSHong Zhang 
1726445158ffSHong Zhang     current_space->array           += apnz;
1727445158ffSHong Zhang     current_space->local_used      += apnz;
1728445158ffSHong Zhang     current_space->local_remaining -= apnz;
1729445158ffSHong Zhang   }
1730681d504bSHong Zhang   /* Allocate space for apj and apv, initialize apj, and */
1731445158ffSHong Zhang   /* destroy list of free space and other temporary array(s) */
1732445158ffSHong Zhang   ierr   = PetscMalloc2(api[am],&apj,api[am],&apv);CHKERRQ(ierr);
1733445158ffSHong Zhang   ierr   = PetscFreeSpaceContiguous(&free_space,apj);CHKERRQ(ierr);
17349a6dcab7SHong Zhang   ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr);
17359a6dcab7SHong Zhang 
1736aa690a28SHong Zhang   /* Create AP_loc for reuse */
1737445158ffSHong Zhang   ierr = MatCreateSeqAIJWithArrays(PETSC_COMM_SELF,am,pN,api,apj,apv,&ptap->AP_loc);CHKERRQ(ierr);
1738aa690a28SHong Zhang 
1739aa690a28SHong Zhang #if defined(PETSC_USE_INFO)
1740ec07b8f8SHong Zhang   if (ao) {
1741aa690a28SHong Zhang     apfill = (PetscReal)api[am]/(ad->i[am]+ao->i[am]+p_loc->i[pm]+1);
1742ec07b8f8SHong Zhang   } else {
1743ec07b8f8SHong Zhang     apfill = (PetscReal)api[am]/(ad->i[am]+p_loc->i[pm]+1);
1744ec07b8f8SHong Zhang   }
1745aa690a28SHong Zhang   ptap->AP_loc->info.mallocs           = nspacedouble;
1746aa690a28SHong Zhang   ptap->AP_loc->info.fill_ratio_given  = fill;
1747aa690a28SHong Zhang   ptap->AP_loc->info.fill_ratio_needed = apfill;
1748aa690a28SHong Zhang 
1749aa690a28SHong Zhang   if (api[am]) {
1750b11c1ec8SHong Zhang     ierr = PetscInfo3(ptap->AP_loc,"Nonscalable algorithm, AP_loc reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)apfill);CHKERRQ(ierr);
1751aa690a28SHong Zhang     ierr = PetscInfo1(ptap->AP_loc,"Use MatPtAP(A,B,MatReuse,%g,&C) for best AP_loc performance.;\n",(double)apfill);CHKERRQ(ierr);
1752aa690a28SHong Zhang   } else {
1753b11c1ec8SHong Zhang     ierr = PetscInfo(ptap->AP_loc,"Nonscalable algorithm, AP_loc is empty \n");CHKERRQ(ierr);
1754aa690a28SHong Zhang   }
1755aa690a28SHong Zhang #endif
1756aa690a28SHong Zhang 
1757681d504bSHong Zhang   /* (2-1) compute symbolic Co = Ro*AP_loc  */
1758681d504bSHong Zhang   /* ------------------------------------ */
1759e83e5f86SFande Kong   ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr);
1760e83e5f86SFande Kong   ierr = MatSetOptionsPrefix(ptap->Ro,prefix);CHKERRQ(ierr);
1761e83e5f86SFande Kong   ierr = MatAppendOptionsPrefix(ptap->Ro,"inner_offdiag_");CHKERRQ(ierr);
176267a12041SHong Zhang   ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Ro,ptap->AP_loc,fill,&ptap->C_oth);CHKERRQ(ierr);
176315a3b8e2SHong Zhang 
176467a12041SHong Zhang   /* (3) send coj of C_oth to other processors  */
176567a12041SHong Zhang   /* ------------------------------------------ */
176615a3b8e2SHong Zhang   /* determine row ownership */
1767445158ffSHong Zhang   ierr = PetscLayoutCreate(comm,&rowmap);CHKERRQ(ierr);
1768445158ffSHong Zhang   rowmap->n  = pn;
1769445158ffSHong Zhang   rowmap->bs = 1;
1770445158ffSHong Zhang   ierr   = PetscLayoutSetUp(rowmap);CHKERRQ(ierr);
1771445158ffSHong Zhang   owners = rowmap->range;
177215a3b8e2SHong Zhang 
177315a3b8e2SHong Zhang   /* determine the number of messages to send, their lengths */
17748cb82516SHong Zhang   ierr = PetscMalloc4(size,&len_s,size,&len_si,size,&sstatus,size+2,&owners_co);CHKERRQ(ierr);
1775580bdb30SBarry Smith   ierr = PetscArrayzero(len_s,size);CHKERRQ(ierr);
1776580bdb30SBarry Smith   ierr = PetscArrayzero(len_si,size);CHKERRQ(ierr);
177715a3b8e2SHong Zhang 
177867a12041SHong Zhang   c_oth = (Mat_SeqAIJ*)ptap->C_oth->data;
177967a12041SHong Zhang   coi   = c_oth->i; coj = c_oth->j;
178067a12041SHong Zhang   con   = ptap->C_oth->rmap->n;
178115a3b8e2SHong Zhang   proc  = 0;
178267a12041SHong Zhang   for (i=0; i<con; i++) {
178315a3b8e2SHong Zhang     while (prmap[i] >= owners[proc+1]) proc++;
178415a3b8e2SHong Zhang     len_si[proc]++;               /* num of rows in Co(=Pt*AP) to be sent to [proc] */
178515a3b8e2SHong Zhang     len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */
178615a3b8e2SHong Zhang   }
178715a3b8e2SHong Zhang 
178815a3b8e2SHong Zhang   len          = 0; /* max length of buf_si[], see (4) */
178915a3b8e2SHong Zhang   owners_co[0] = 0;
179067a12041SHong Zhang   nsend        = 0;
179115a3b8e2SHong Zhang   for (proc=0; proc<size; proc++) {
179215a3b8e2SHong Zhang     owners_co[proc+1] = owners_co[proc] + len_si[proc];
179315a3b8e2SHong Zhang     if (len_s[proc]) {
1794445158ffSHong Zhang       nsend++;
179515a3b8e2SHong Zhang       len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */
179615a3b8e2SHong Zhang       len         += len_si[proc];
179715a3b8e2SHong Zhang     }
179815a3b8e2SHong Zhang   }
179915a3b8e2SHong Zhang 
180015a3b8e2SHong Zhang   /* determine the number and length of messages to receive for coi and coj  */
1801445158ffSHong Zhang   ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&nrecv);CHKERRQ(ierr);
1802445158ffSHong Zhang   ierr = PetscGatherMessageLengths2(comm,nsend,nrecv,len_s,len_si,&id_r,&len_r,&len_ri);CHKERRQ(ierr);
180315a3b8e2SHong Zhang 
180415a3b8e2SHong Zhang   /* post the Irecv and Isend of coj */
180515a3b8e2SHong Zhang   ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr);
1806445158ffSHong Zhang   ierr = PetscPostIrecvInt(comm,tagj,nrecv,id_r,len_r,&buf_rj,&rwaits);CHKERRQ(ierr);
1807445158ffSHong Zhang   ierr = PetscMalloc1(nsend+1,&swaits);CHKERRQ(ierr);
180815a3b8e2SHong Zhang   for (proc=0, k=0; proc<size; proc++) {
180915a3b8e2SHong Zhang     if (!len_s[proc]) continue;
181015a3b8e2SHong Zhang     i    = owners_co[proc];
181115a3b8e2SHong Zhang     ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr);
181215a3b8e2SHong Zhang     k++;
181315a3b8e2SHong Zhang   }
181415a3b8e2SHong Zhang 
1815681d504bSHong Zhang   /* (2-2) compute symbolic C_loc = Rd*AP_loc */
1816681d504bSHong Zhang   /* ---------------------------------------- */
1817e83e5f86SFande Kong   ierr = MatSetOptionsPrefix(ptap->Rd,prefix);CHKERRQ(ierr);
1818e83e5f86SFande Kong   ierr = MatAppendOptionsPrefix(ptap->Rd,"inner_diag_");CHKERRQ(ierr);
1819681d504bSHong Zhang   ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Rd,ptap->AP_loc,fill,&ptap->C_loc);CHKERRQ(ierr);
1820681d504bSHong Zhang   c_loc = (Mat_SeqAIJ*)ptap->C_loc->data;
1821681d504bSHong Zhang 
1822681d504bSHong Zhang   /* receives coj are complete */
1823445158ffSHong Zhang   for (i=0; i<nrecv; i++) {
1824445158ffSHong Zhang     ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
182515a3b8e2SHong Zhang   }
182615a3b8e2SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
1827445158ffSHong Zhang   if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);}
182815a3b8e2SHong Zhang 
182978d30b94SHong Zhang   /* add received column indices into ta to update Crmax */
183078d30b94SHong Zhang   for (k=0; k<nrecv; k++) {/* k-th received message */
183178d30b94SHong Zhang     Jptr = buf_rj[k];
183278d30b94SHong Zhang     for (j=0; j<len_r[k]; j++) {
183378d30b94SHong Zhang       ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr);
183478d30b94SHong Zhang     }
183578d30b94SHong Zhang   }
183678d30b94SHong Zhang   ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr);
183778d30b94SHong Zhang   ierr = PetscTableDestroy(&ta);CHKERRQ(ierr);
18389a6dcab7SHong Zhang 
183915a3b8e2SHong Zhang   /* (4) send and recv coi */
184015a3b8e2SHong Zhang   /*-----------------------*/
184115a3b8e2SHong Zhang   ierr   = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr);
1842445158ffSHong Zhang   ierr   = PetscPostIrecvInt(comm,tagi,nrecv,id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr);
184315a3b8e2SHong Zhang   ierr   = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr);
184415a3b8e2SHong Zhang   buf_si = buf_s;  /* points to the beginning of k-th msg to be sent */
184515a3b8e2SHong Zhang   for (proc=0,k=0; proc<size; proc++) {
184615a3b8e2SHong Zhang     if (!len_s[proc]) continue;
184715a3b8e2SHong Zhang     /* form outgoing message for i-structure:
184815a3b8e2SHong Zhang          buf_si[0]:                 nrows to be sent
184915a3b8e2SHong Zhang                [1:nrows]:           row index (global)
185015a3b8e2SHong Zhang                [nrows+1:2*nrows+1]: i-structure index
185115a3b8e2SHong Zhang     */
185215a3b8e2SHong Zhang     /*-------------------------------------------*/
185315a3b8e2SHong Zhang     nrows       = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */
185415a3b8e2SHong Zhang     buf_si_i    = buf_si + nrows+1;
185515a3b8e2SHong Zhang     buf_si[0]   = nrows;
185615a3b8e2SHong Zhang     buf_si_i[0] = 0;
185715a3b8e2SHong Zhang     nrows       = 0;
185815a3b8e2SHong Zhang     for (i=owners_co[proc]; i<owners_co[proc+1]; i++) {
185915a3b8e2SHong Zhang       nzi = coi[i+1] - coi[i];
186015a3b8e2SHong Zhang       buf_si_i[nrows+1] = buf_si_i[nrows] + nzi;  /* i-structure */
186115a3b8e2SHong Zhang       buf_si[nrows+1]   = prmap[i] -owners[proc]; /* local row index */
186215a3b8e2SHong Zhang       nrows++;
186315a3b8e2SHong Zhang     }
186415a3b8e2SHong Zhang     ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr);
186515a3b8e2SHong Zhang     k++;
186615a3b8e2SHong Zhang     buf_si += len_si[proc];
186715a3b8e2SHong Zhang   }
1868681d504bSHong Zhang   for (i=0; i<nrecv; i++) {
1869445158ffSHong Zhang     ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
187015a3b8e2SHong Zhang   }
187115a3b8e2SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
1872445158ffSHong Zhang   if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);}
187315a3b8e2SHong Zhang 
18748cb82516SHong Zhang   ierr = PetscFree4(len_s,len_si,sstatus,owners_co);CHKERRQ(ierr);
187515a3b8e2SHong Zhang   ierr = PetscFree(len_ri);CHKERRQ(ierr);
187615a3b8e2SHong Zhang   ierr = PetscFree(swaits);CHKERRQ(ierr);
187715a3b8e2SHong Zhang   ierr = PetscFree(buf_s);CHKERRQ(ierr);
1878a4ffb656SHong Zhang 
187967a12041SHong Zhang   /* (5) compute the local portion of Cmpi      */
188067a12041SHong Zhang   /* ------------------------------------------ */
188178d30b94SHong Zhang   /* set initial free space to be Crmax, sufficient for holding nozeros in each row of Cmpi */
188278d30b94SHong Zhang   ierr          = PetscFreeSpaceGet(Crmax,&free_space);CHKERRQ(ierr);
188315a3b8e2SHong Zhang   current_space = free_space;
188415a3b8e2SHong Zhang 
1885445158ffSHong Zhang   ierr = PetscMalloc3(nrecv,&buf_ri_k,nrecv,&nextrow,nrecv,&nextci);CHKERRQ(ierr);
1886445158ffSHong Zhang   for (k=0; k<nrecv; k++) {
188715a3b8e2SHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
188815a3b8e2SHong Zhang     nrows       = *buf_ri_k[k];
188915a3b8e2SHong Zhang     nextrow[k]  = buf_ri_k[k] + 1;  /* next row number of k-th recved i-structure */
189015a3b8e2SHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
189115a3b8e2SHong Zhang   }
1892445158ffSHong Zhang 
189378d30b94SHong Zhang   ierr = MatPreallocateInitialize(comm,pn,pn,dnz,onz);CHKERRQ(ierr);
189478d30b94SHong Zhang   ierr = PetscLLCondensedCreate(Crmax,pN,&lnk,&lnkbt);CHKERRQ(ierr);
189515a3b8e2SHong Zhang   for (i=0; i<pn; i++) {
189667a12041SHong Zhang     /* add C_loc into Cmpi */
189767a12041SHong Zhang     nzi  = c_loc->i[i+1] - c_loc->i[i];
189867a12041SHong Zhang     Jptr = c_loc->j + c_loc->i[i];
189967a12041SHong Zhang     ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr);
190015a3b8e2SHong Zhang 
190115a3b8e2SHong Zhang     /* add received col data into lnk */
1902445158ffSHong Zhang     for (k=0; k<nrecv; k++) { /* k-th received message */
190315a3b8e2SHong Zhang       if (i == *nextrow[k]) { /* i-th row */
190415a3b8e2SHong Zhang         nzi  = *(nextci[k]+1) - *nextci[k];
190515a3b8e2SHong Zhang         Jptr = buf_rj[k] + *nextci[k];
190615a3b8e2SHong Zhang         ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr);
190715a3b8e2SHong Zhang         nextrow[k]++; nextci[k]++;
190815a3b8e2SHong Zhang       }
190915a3b8e2SHong Zhang     }
1910d0e9a2f7SHong Zhang     nzi = lnk[0];
19118cb82516SHong Zhang 
191215a3b8e2SHong Zhang     /* copy data into free space, then initialize lnk */
1913d0e9a2f7SHong Zhang     ierr = PetscLLCondensedClean(pN,nzi,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
1914d0e9a2f7SHong Zhang     ierr = MatPreallocateSet(i+owners[rank],nzi,current_space->array,dnz,onz);CHKERRQ(ierr);
191515a3b8e2SHong Zhang   }
191615a3b8e2SHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
191715a3b8e2SHong Zhang   ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr);
1918445158ffSHong Zhang   ierr = PetscFreeSpaceDestroy(free_space);CHKERRQ(ierr);
191980bb4639SHong Zhang 
1920ae5f0867Sstefano_zampini   /* local sizes and preallocation */
192115a3b8e2SHong Zhang   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
1922ac94c67aSTristan Konolige   if (P->cmap->bs > 0) {
1923ac94c67aSTristan Konolige     ierr = PetscLayoutSetBlockSize(Cmpi->rmap,P->cmap->bs);CHKERRQ(ierr);
1924ac94c67aSTristan Konolige     ierr = PetscLayoutSetBlockSize(Cmpi->cmap,P->cmap->bs);CHKERRQ(ierr);
1925ac94c67aSTristan Konolige   }
192615a3b8e2SHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
192715a3b8e2SHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
192815a3b8e2SHong Zhang 
1929445158ffSHong Zhang   /* members in merge */
1930445158ffSHong Zhang   ierr = PetscFree(id_r);CHKERRQ(ierr);
1931445158ffSHong Zhang   ierr = PetscFree(len_r);CHKERRQ(ierr);
1932445158ffSHong Zhang   ierr = PetscFree(buf_ri[0]);CHKERRQ(ierr);
1933445158ffSHong Zhang   ierr = PetscFree(buf_ri);CHKERRQ(ierr);
1934445158ffSHong Zhang   ierr = PetscFree(buf_rj[0]);CHKERRQ(ierr);
1935445158ffSHong Zhang   ierr = PetscFree(buf_rj);CHKERRQ(ierr);
1936445158ffSHong Zhang   ierr = PetscLayoutDestroy(&rowmap);CHKERRQ(ierr);
193715a3b8e2SHong Zhang 
193815a3b8e2SHong Zhang   /* attach the supporting struct to Cmpi for reuse */
193915a3b8e2SHong Zhang   c = (Mat_MPIAIJ*)Cmpi->data;
19403cdca5ebSHong Zhang   c->ap           = ptap;
19411a47ec54SHong Zhang   ptap->duplicate = Cmpi->ops->duplicate;
19421a47ec54SHong Zhang   ptap->destroy   = Cmpi->ops->destroy;
1943cf97cf3cSHong Zhang   ptap->view      = Cmpi->ops->view;
19448cb82516SHong Zhang   ierr = PetscCalloc1(pN,&ptap->apa);CHKERRQ(ierr);
19452259aa2eSHong Zhang 
19461a47ec54SHong Zhang   /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */
19471a47ec54SHong Zhang   Cmpi->assembled        = PETSC_FALSE;
19481a47ec54SHong Zhang   Cmpi->ops->destroy     = MatDestroy_MPIAIJ_PtAP;
1949cf97cf3cSHong Zhang   Cmpi->ops->view        = MatView_MPIAIJ_PtAP;
19504624976aSHong Zhang   Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP;
19511a47ec54SHong Zhang   *C                     = Cmpi;
19520d3441aeSHong Zhang   PetscFunctionReturn(0);
19530d3441aeSHong Zhang }
19540d3441aeSHong Zhang 
1955aa690a28SHong Zhang PetscErrorCode MatPtAPNumeric_MPIAIJ_MPIAIJ(Mat A,Mat P,Mat C)
19560d3441aeSHong Zhang {
19570d3441aeSHong Zhang   PetscErrorCode    ierr;
19580d3441aeSHong Zhang   Mat_MPIAIJ        *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
19590d3441aeSHong Zhang   Mat_SeqAIJ        *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
19602dd9e643SHong Zhang   Mat_SeqAIJ        *ap,*p_loc,*p_oth=NULL,*c_seq;
19613cdca5ebSHong Zhang   Mat_APMPI         *ptap = c->ap;
19629ce11a7cSHong Zhang   Mat               AP_loc,C_loc,C_oth;
19630d3441aeSHong Zhang   PetscInt          i,rstart,rend,cm,ncols,row;
19648cb82516SHong Zhang   PetscInt          *api,*apj,am = A->rmap->n,j,col,apnz;
19658cb82516SHong Zhang   PetscScalar       *apa;
19660d3441aeSHong Zhang   const PetscInt    *cols;
19670d3441aeSHong Zhang   const PetscScalar *vals;
19680d3441aeSHong Zhang 
19690d3441aeSHong Zhang   PetscFunctionBegin;
1970bb9bda99SHong Zhang   if (!ptap->AP_loc) {
1971a9899c97SHong Zhang     MPI_Comm comm;
1972a9899c97SHong Zhang     ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr);
1973dd4011a9SHong Zhang     SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'");
1974a9899c97SHong Zhang   }
1975a9899c97SHong Zhang 
19760d3441aeSHong Zhang   ierr = MatZeroEntries(C);CHKERRQ(ierr);
1977e497d3c8SHong Zhang   /* 1) get R = Pd^T,Ro = Po^T */
1978748c7196SHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
1979419ecdd9Sandi selinger     ierr = MatTranspose(p->A,MAT_REUSE_MATRIX,&ptap->Rd);CHKERRQ(ierr);
1980419ecdd9Sandi selinger     ierr = MatTranspose(p->B,MAT_REUSE_MATRIX,&ptap->Ro);CHKERRQ(ierr);
1981748c7196SHong Zhang   }
19820d3441aeSHong Zhang 
1983e497d3c8SHong Zhang   /* 2) get AP_loc */
19840d3441aeSHong Zhang   AP_loc = ptap->AP_loc;
19858cb82516SHong Zhang   ap = (Mat_SeqAIJ*)AP_loc->data;
19860d3441aeSHong Zhang 
1987e497d3c8SHong Zhang   /* 2-1) get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
19880d3441aeSHong Zhang   /*-----------------------------------------------------*/
1989748c7196SHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
1990748c7196SHong Zhang     /* P_oth and P_loc are obtained in MatPtASymbolic() when reuse == MAT_INITIAL_MATRIX */
19910d3441aeSHong Zhang     ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
19920d3441aeSHong Zhang     ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
1993e497d3c8SHong Zhang   }
19940d3441aeSHong Zhang 
19958cb82516SHong Zhang   /* 2-2) compute numeric A_loc*P - dominating part */
19968cb82516SHong Zhang   /* ---------------------------------------------- */
19970d3441aeSHong Zhang   /* get data from symbolic products */
19988cb82516SHong Zhang   p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data;
19992dd9e643SHong Zhang   if (ptap->P_oth) {
20008cb82516SHong Zhang     p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data;
20012dd9e643SHong Zhang   }
20028cb82516SHong Zhang   apa   = ptap->apa;
2003681d504bSHong Zhang   api   = ap->i;
2004681d504bSHong Zhang   apj   = ap->j;
2005e497d3c8SHong Zhang   for (i=0; i<am; i++) {
2006445158ffSHong Zhang     /* AP[i,:] = A[i,:]*P = Ad*P_loc Ao*P_oth */
2007e497d3c8SHong Zhang     AProw_nonscalable(i,ad,ao,p_loc,p_oth,apa);
2008e497d3c8SHong Zhang     apnz = api[i+1] - api[i];
2009e497d3c8SHong Zhang     for (j=0; j<apnz; j++) {
2010e497d3c8SHong Zhang       col = apj[j+api[i]];
2011e497d3c8SHong Zhang       ap->a[j+ap->i[i]] = apa[col];
2012e497d3c8SHong Zhang       apa[col] = 0.0;
20130d3441aeSHong Zhang     }
20140d3441aeSHong Zhang   }
20150d3441aeSHong Zhang 
20168cb82516SHong Zhang   /* 3) C_loc = Rd*AP_loc, C_oth = Ro*AP_loc */
2017445158ffSHong Zhang   ierr = ((ptap->C_loc)->ops->matmultnumeric)(ptap->Rd,AP_loc,ptap->C_loc);CHKERRQ(ierr);
2018445158ffSHong Zhang   ierr = ((ptap->C_oth)->ops->matmultnumeric)(ptap->Ro,AP_loc,ptap->C_oth);CHKERRQ(ierr);
20199ce11a7cSHong Zhang   C_loc = ptap->C_loc;
20209ce11a7cSHong Zhang   C_oth = ptap->C_oth;
20210d3441aeSHong Zhang 
20220d3441aeSHong Zhang   /* add C_loc and Co to to C */
20230d3441aeSHong Zhang   ierr = MatGetOwnershipRange(C,&rstart,&rend);CHKERRQ(ierr);
20240d3441aeSHong Zhang 
20250d3441aeSHong Zhang   /* C_loc -> C */
20260d3441aeSHong Zhang   cm    = C_loc->rmap->N;
20279ce11a7cSHong Zhang   c_seq = (Mat_SeqAIJ*)C_loc->data;
20288cb82516SHong Zhang   cols = c_seq->j;
20298cb82516SHong Zhang   vals = c_seq->a;
2030904d1e70Sandi selinger 
2031904d1e70Sandi selinger 
2032e9ede7d0Sandi selinger   /* The (fast) MatSetValues_MPIAIJ_CopyFromCSRFormat function can only be used when C->was_assembled is PETSC_FALSE and */
2033904d1e70Sandi selinger   /* when there are no off-processor parts.  */
20341de21080Sandi selinger   /* If was_assembled is true, then the statement aj[rowstart_diag+dnz_row] = mat_j[col] - cstart; in MatSetValues_MPIAIJ_CopyFromCSRFormat */
20351de21080Sandi selinger   /* is no longer true. Then the more complex function MatSetValues_MPIAIJ() has to be used, where the column index is looked up from */
20361de21080Sandi selinger   /* a table, and other, more complex stuff has to be done. */
2037904d1e70Sandi selinger   if (C->assembled) {
2038904d1e70Sandi selinger     C->was_assembled = PETSC_TRUE;
2039904d1e70Sandi selinger     C->assembled     = PETSC_FALSE;
2040904d1e70Sandi selinger   }
2041904d1e70Sandi selinger   if (C->was_assembled) {
20420d3441aeSHong Zhang     for (i=0; i<cm; i++) {
20439ce11a7cSHong Zhang       ncols = c_seq->i[i+1] - c_seq->i[i];
20440d3441aeSHong Zhang       row = rstart + i;
2045904d1e70Sandi selinger       ierr = MatSetValues_MPIAIJ(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr);
20468cb82516SHong Zhang       cols += ncols; vals += ncols;
20470d3441aeSHong Zhang     }
2048904d1e70Sandi selinger   } else {
2049e9ede7d0Sandi selinger     ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat(C,c_seq->j,c_seq->i,c_seq->a);CHKERRQ(ierr);
2050904d1e70Sandi selinger   }
20510d3441aeSHong Zhang 
20520d3441aeSHong Zhang   /* Co -> C, off-processor part */
20539ce11a7cSHong Zhang   cm = C_oth->rmap->N;
20549ce11a7cSHong Zhang   c_seq = (Mat_SeqAIJ*)C_oth->data;
20558cb82516SHong Zhang   cols = c_seq->j;
20568cb82516SHong Zhang   vals = c_seq->a;
20579ce11a7cSHong Zhang   for (i=0; i<cm; i++) {
20589ce11a7cSHong Zhang     ncols = c_seq->i[i+1] - c_seq->i[i];
20590d3441aeSHong Zhang     row = p->garray[i];
20600d3441aeSHong Zhang     ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr);
20618cb82516SHong Zhang     cols += ncols; vals += ncols;
20620d3441aeSHong Zhang   }
2063904d1e70Sandi selinger 
20640d3441aeSHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
20650d3441aeSHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
20660d3441aeSHong Zhang 
2067748c7196SHong Zhang   ptap->reuse = MAT_REUSE_MATRIX;
20683697aca6SHong Zhang 
2069dd4011a9SHong Zhang   /* supporting struct ptap consumes almost same amount of memory as C=PtAP, release it if C will not be updated by A and P */
20707d0a89b7SHong Zhang   if (ptap->freestruct) {
2071dd4011a9SHong Zhang     ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr);
20723697aca6SHong Zhang   }
20730d3441aeSHong Zhang   PetscFunctionReturn(0);
20740d3441aeSHong Zhang }
2075