xref: /petsc/src/mat/impls/aij/mpi/mpimatmatmult.c (revision a7c7454dd425191f4a23aa5860b8c6bac03cfd7b)
1be1d678aSKris Buschelman 
22499ec78SHong Zhang /*
32499ec78SHong Zhang   Defines matrix-matrix product routines for pairs of MPIAIJ matrices
42499ec78SHong Zhang           C = A * B
52499ec78SHong Zhang */
6c6db04a5SJed Brown #include <../src/mat/impls/aij/seq/aij.h> /*I "petscmat.h" I*/
7c6db04a5SJed Brown #include <../src/mat/utils/freespace.h>
8c6db04a5SJed Brown #include <../src/mat/impls/aij/mpi/mpiaij.h>
9c6db04a5SJed Brown #include <petscbt.h>
10c6db04a5SJed Brown #include <../src/mat/impls/dense/mpi/mpidense.h>
119a6d0b0bSJed Brown #include <petsc-private/vecimpl.h>
121634b032SHong Zhang 
132499ec78SHong Zhang #undef __FUNCT__
142499ec78SHong Zhang #define __FUNCT__ "MatMatMult_MPIAIJ_MPIAIJ"
152499ec78SHong Zhang PetscErrorCode MatMatMult_MPIAIJ_MPIAIJ(Mat A,Mat B,MatReuse scall,PetscReal fill, Mat *C)
162499ec78SHong Zhang {
172499ec78SHong Zhang   PetscErrorCode ierr;
180fc8cf34SHong Zhang   const char     *algTypes[2] = {"scalable","nonscalable"};
190fc8cf34SHong Zhang   PetscInt       alg=0; /* set default algorithm */
202499ec78SHong Zhang 
212499ec78SHong Zhang   PetscFunctionBegin;
222499ec78SHong Zhang   if (scall == MAT_INITIAL_MATRIX) {
230fc8cf34SHong Zhang     ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr);
240fc8cf34SHong Zhang     ierr = PetscOptionsEList("-matmatmult_via","Algorithmic approach","MatMatMult",algTypes,2,algTypes[0],&alg,NULL);CHKERRQ(ierr);
250fc8cf34SHong Zhang     ierr = PetscOptionsEnd();CHKERRQ(ierr);
260fc8cf34SHong Zhang 
273ff4c91cSHong Zhang     ierr = PetscLogEventBegin(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr);
280fc8cf34SHong Zhang     switch (alg) {
290fc8cf34SHong Zhang     case 1:
300fc8cf34SHong Zhang       ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(A,B,fill,C);CHKERRQ(ierr);
310fc8cf34SHong Zhang       break;
320fc8cf34SHong Zhang     default:
33b2405163SHong Zhang       ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ(A,B,fill,C);CHKERRQ(ierr);
340fc8cf34SHong Zhang       break;
350fc8cf34SHong Zhang     }
363ff4c91cSHong Zhang     ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr);
372499ec78SHong Zhang   }
383ff4c91cSHong Zhang   ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr);
39598bc09dSHong Zhang   ierr = (*(*C)->ops->matmultnumeric)(A,B,*C);CHKERRQ(ierr);
403ff4c91cSHong Zhang   ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr);
412499ec78SHong Zhang   PetscFunctionReturn(0);
422499ec78SHong Zhang }
432499ec78SHong Zhang 
44f33d1a9aSHong Zhang #undef __FUNCT__
45a1a4e84aSHong Zhang #define __FUNCT__ "MatDestroy_MPIAIJ_MatMatMult"
46a1a4e84aSHong Zhang PetscErrorCode MatDestroy_MPIAIJ_MatMatMult(Mat A)
47598bc09dSHong Zhang {
48598bc09dSHong Zhang   PetscErrorCode ierr;
49598bc09dSHong Zhang   Mat_MPIAIJ     *a    = (Mat_MPIAIJ*)A->data;
50598bc09dSHong Zhang   Mat_PtAPMPI    *ptap = a->ptap;
51598bc09dSHong Zhang 
52598bc09dSHong Zhang   PetscFunctionBegin;
53b7f45c76SHong Zhang   ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr);
54598bc09dSHong Zhang   ierr = PetscFree(ptap->bufa);CHKERRQ(ierr);
55a1a4e84aSHong Zhang   ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr);
56a1a4e84aSHong Zhang   ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr);
57ab1b013aSHong Zhang   ierr = MatDestroy(&ptap->Pt);CHKERRQ(ierr);
58a1a4e84aSHong Zhang   ierr = PetscFree(ptap->api);CHKERRQ(ierr);
59a1a4e84aSHong Zhang   ierr = PetscFree(ptap->apj);CHKERRQ(ierr);
60598bc09dSHong Zhang   ierr = PetscFree(ptap->apa);CHKERRQ(ierr);
61598bc09dSHong Zhang   ierr = ptap->destroy(A);CHKERRQ(ierr);
62598bc09dSHong Zhang   ierr = PetscFree(ptap);CHKERRQ(ierr);
63598bc09dSHong Zhang   PetscFunctionReturn(0);
64598bc09dSHong Zhang }
65598bc09dSHong Zhang 
662499ec78SHong Zhang #undef __FUNCT__
67a1a4e84aSHong Zhang #define __FUNCT__ "MatDuplicate_MPIAIJ_MatMatMult"
68a1a4e84aSHong Zhang PetscErrorCode MatDuplicate_MPIAIJ_MatMatMult(Mat A, MatDuplicateOption op, Mat *M)
694ae0847bSHong Zhang {
704ae0847bSHong Zhang   PetscErrorCode ierr;
714ae0847bSHong Zhang   Mat_MPIAIJ     *a    = (Mat_MPIAIJ*)A->data;
724ae0847bSHong Zhang   Mat_PtAPMPI    *ptap = a->ptap;
734ae0847bSHong Zhang 
744ae0847bSHong Zhang   PetscFunctionBegin;
754ae0847bSHong Zhang   ierr = (*ptap->duplicate)(A,op,M);CHKERRQ(ierr);
7626fbe8dcSKarl Rupp 
774ae0847bSHong Zhang   (*M)->ops->destroy   = ptap->destroy;   /* = MatDestroy_MPIAIJ, *M doesn't duplicate A's special structure! */
784ae0847bSHong Zhang   (*M)->ops->duplicate = ptap->duplicate; /* = MatDuplicate_MPIAIJ */
794ae0847bSHong Zhang   PetscFunctionReturn(0);
804ae0847bSHong Zhang }
814ae0847bSHong Zhang 
824ae0847bSHong Zhang #undef __FUNCT__
83a1a4e84aSHong Zhang #define __FUNCT__ "MatMatMultNumeric_MPIAIJ_MPIAIJ"
84a1a4e84aSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ(Mat A,Mat P,Mat C)
85598bc09dSHong Zhang {
86598bc09dSHong Zhang   PetscErrorCode ierr;
874ae0847bSHong Zhang   Mat_MPIAIJ     *a  =(Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data;
88598bc09dSHong Zhang   Mat_SeqAIJ     *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
89598bc09dSHong Zhang   Mat_SeqAIJ     *cd =(Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data;
90598bc09dSHong Zhang   PetscInt       *adi=ad->i,*adj,*aoi=ao->i,*aoj;
91598bc09dSHong Zhang   PetscScalar    *ada,*aoa,*cda=cd->a,*coa=co->a;
92598bc09dSHong Zhang   Mat_SeqAIJ     *p_loc,*p_oth;
93598bc09dSHong Zhang   PetscInt       *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj;
94598bc09dSHong Zhang   PetscScalar    *pa_loc,*pa_oth,*pa,*apa,valtmp,*ca;
95598bc09dSHong Zhang   PetscInt       cm   =C->rmap->n,anz,pnz;
96598bc09dSHong Zhang   Mat_PtAPMPI    *ptap=c->ptap;
9765a57a32SSean Farley   PetscInt       *api,*apj,*apJ,i,j,k,row;
9829825010SHong Zhang   PetscInt       cstart=C->cmap->rstart;
99598bc09dSHong Zhang   PetscInt       cdnz,conz,k0,k1;
100598bc09dSHong Zhang 
101598bc09dSHong Zhang   PetscFunctionBegin;
102a1a4e84aSHong Zhang   /* 1) get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
103598bc09dSHong Zhang   /*-----------------------------------------------------*/
104a1a4e84aSHong Zhang   /* update numerical values of P_oth and P_loc */
105b7f45c76SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
106a1a4e84aSHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
107598bc09dSHong Zhang 
108598bc09dSHong Zhang   /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */
109598bc09dSHong Zhang   /*----------------------------------------------------------*/
110598bc09dSHong Zhang   /* get data from symbolic products */
111a1a4e84aSHong Zhang   p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data;
112a1a4e84aSHong Zhang   p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data;
113598bc09dSHong Zhang   pi_loc=p_loc->i; pj_loc=p_loc->j; pa_loc=p_loc->a;
114598bc09dSHong Zhang   pi_oth=p_oth->i; pj_oth=p_oth->j; pa_oth=p_oth->a;
115598bc09dSHong Zhang 
116598bc09dSHong Zhang   /* get apa for storing dense row A[i,:]*P */
117598bc09dSHong Zhang   apa = ptap->apa;
118598bc09dSHong Zhang 
11929825010SHong Zhang   api = ptap->api;
12029825010SHong Zhang   apj = ptap->apj;
121598bc09dSHong Zhang   for (i=0; i<cm; i++) {
122598bc09dSHong Zhang     /* diagonal portion of A */
123598bc09dSHong Zhang     anz = adi[i+1] - adi[i];
124598bc09dSHong Zhang     adj = ad->j + adi[i];
125598bc09dSHong Zhang     ada = ad->a + adi[i];
126598bc09dSHong Zhang     for (j=0; j<anz; j++) {
127598bc09dSHong Zhang       row = adj[j];
128598bc09dSHong Zhang       pnz = pi_loc[row+1] - pi_loc[row];
129598bc09dSHong Zhang       pj  = pj_loc + pi_loc[row];
130598bc09dSHong Zhang       pa  = pa_loc + pi_loc[row];
131598bc09dSHong Zhang 
132598bc09dSHong Zhang       /* perform dense axpy */
133598bc09dSHong Zhang       valtmp = ada[j];
134598bc09dSHong Zhang       for (k=0; k<pnz; k++) {
135598bc09dSHong Zhang         apa[pj[k]] += valtmp*pa[k];
136598bc09dSHong Zhang       }
137598bc09dSHong Zhang       ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
138598bc09dSHong Zhang     }
139598bc09dSHong Zhang 
140598bc09dSHong Zhang     /* off-diagonal portion of A */
141598bc09dSHong Zhang     anz = aoi[i+1] - aoi[i];
142598bc09dSHong Zhang     aoj = ao->j + aoi[i];
143598bc09dSHong Zhang     aoa = ao->a + aoi[i];
144598bc09dSHong Zhang     for (j=0; j<anz; j++) {
145598bc09dSHong Zhang       row = aoj[j];
146598bc09dSHong Zhang       pnz = pi_oth[row+1] - pi_oth[row];
147598bc09dSHong Zhang       pj  = pj_oth + pi_oth[row];
148598bc09dSHong Zhang       pa  = pa_oth + pi_oth[row];
149598bc09dSHong Zhang 
150598bc09dSHong Zhang       /* perform dense axpy */
151598bc09dSHong Zhang       valtmp = aoa[j];
152598bc09dSHong Zhang       for (k=0; k<pnz; k++) {
153598bc09dSHong Zhang         apa[pj[k]] += valtmp*pa[k];
154598bc09dSHong Zhang       }
155598bc09dSHong Zhang       ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
156598bc09dSHong Zhang     }
157598bc09dSHong Zhang 
158598bc09dSHong Zhang     /* set values in C */
159598bc09dSHong Zhang     apJ  = apj + api[i];
160598bc09dSHong Zhang     cdnz = cd->i[i+1] - cd->i[i];
161598bc09dSHong Zhang     conz = co->i[i+1] - co->i[i];
162598bc09dSHong Zhang 
163598bc09dSHong Zhang     /* 1st off-diagoanl part of C */
164598bc09dSHong Zhang     ca = coa + co->i[i];
165598bc09dSHong Zhang     k  = 0;
166598bc09dSHong Zhang     for (k0=0; k0<conz; k0++) {
167598bc09dSHong Zhang       if (apJ[k] >= cstart) break;
168598bc09dSHong Zhang       ca[k0]      = apa[apJ[k]];
169598bc09dSHong Zhang       apa[apJ[k]] = 0.0;
170598bc09dSHong Zhang       k++;
171598bc09dSHong Zhang     }
172598bc09dSHong Zhang 
173598bc09dSHong Zhang     /* diagonal part of C */
174598bc09dSHong Zhang     ca = cda + cd->i[i];
175598bc09dSHong Zhang     for (k1=0; k1<cdnz; k1++) {
176598bc09dSHong Zhang       ca[k1]      = apa[apJ[k]];
177598bc09dSHong Zhang       apa[apJ[k]] = 0.0;
178598bc09dSHong Zhang       k++;
179598bc09dSHong Zhang     }
180598bc09dSHong Zhang 
181598bc09dSHong Zhang     /* 2nd off-diagoanl part of C */
182598bc09dSHong Zhang     ca = coa + co->i[i];
183598bc09dSHong Zhang     for (; k0<conz; k0++) {
184598bc09dSHong Zhang       ca[k0]      = apa[apJ[k]];
185598bc09dSHong Zhang       apa[apJ[k]] = 0.0;
186598bc09dSHong Zhang       k++;
187598bc09dSHong Zhang     }
188598bc09dSHong Zhang   }
189598bc09dSHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
190598bc09dSHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
191598bc09dSHong Zhang   PetscFunctionReturn(0);
192598bc09dSHong Zhang }
193598bc09dSHong Zhang 
194598bc09dSHong Zhang #undef __FUNCT__
1950fc8cf34SHong Zhang #define __FUNCT__ "MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable"
1960fc8cf34SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,PetscReal fill,Mat *C)
197598bc09dSHong Zhang {
198598bc09dSHong Zhang   PetscErrorCode     ierr;
199ce94432eSBarry Smith   MPI_Comm           comm;
200bfcd1a73SHong Zhang   Mat                Cmpi;
201598bc09dSHong Zhang   Mat_PtAPMPI        *ptap;
2020298fd71SBarry Smith   PetscFreeSpaceList free_space=NULL,current_space=NULL;
2034ae0847bSHong Zhang   Mat_MPIAIJ         *a        =(Mat_MPIAIJ*)A->data,*c;
204bfcd1a73SHong Zhang   Mat_SeqAIJ         *ad       =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth;
2054ae0847bSHong Zhang   PetscInt           *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz;
2064ae0847bSHong Zhang   PetscInt           *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart;
207d14fa243SHong Zhang   PetscInt           *lnk,i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi;
208bfcd1a73SHong Zhang   PetscInt           am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n;
209598bc09dSHong Zhang   PetscBT            lnkbt;
210598bc09dSHong Zhang   PetscScalar        *apa;
211bfcd1a73SHong Zhang   PetscReal          afill;
212f84c536bSHong Zhang   PetscInt           nlnk_max,armax,prmax;
213598bc09dSHong Zhang 
214598bc09dSHong Zhang   PetscFunctionBegin;
215ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
216a1a4e84aSHong Zhang   if (A->cmap->rstart != P->rmap->rstart || A->cmap->rend != P->rmap->rend) {
217cf1a0672SHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, (%D, %D) != (%D,%D)",A->cmap->rstart,A->cmap->rend,P->rmap->rstart,P->rmap->rend);
218a1a4e84aSHong Zhang   }
219152983bfSHong Zhang 
220598bc09dSHong Zhang   /* create struct Mat_PtAPMPI and attached it to C later */
221b00a9115SJed Brown   ierr = PetscNew(&ptap);CHKERRQ(ierr);
222598bc09dSHong Zhang 
223598bc09dSHong Zhang   /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
224b7f45c76SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
22519f0e57aSHong Zhang 
226598bc09dSHong Zhang   /* get P_loc by taking all local rows of P */
227a1a4e84aSHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
228598bc09dSHong Zhang 
229a1a4e84aSHong Zhang   p_loc  = (Mat_SeqAIJ*)(ptap->P_loc)->data;
230a1a4e84aSHong Zhang   p_oth  = (Mat_SeqAIJ*)(ptap->P_oth)->data;
231598bc09dSHong Zhang   pi_loc = p_loc->i; pj_loc = p_loc->j;
232598bc09dSHong Zhang   pi_oth = p_oth->i; pj_oth = p_oth->j;
233598bc09dSHong Zhang 
234598bc09dSHong Zhang   /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */
235598bc09dSHong Zhang   /*-------------------------------------------------------------------*/
236785e854fSJed Brown   ierr      = PetscMalloc1((am+2),&api);CHKERRQ(ierr);
237a1a4e84aSHong Zhang   ptap->api = api;
238598bc09dSHong Zhang   api[0]    = 0;
239598bc09dSHong Zhang 
240598bc09dSHong Zhang   /* create and initialize a linked list */
241f84c536bSHong Zhang   armax    = ad->rmax+ao->rmax;
242f84c536bSHong Zhang   prmax    = PetscMax(p_loc->rmax,p_oth->rmax);
243f84c536bSHong Zhang   nlnk_max = armax*prmax;
244f84c536bSHong Zhang   if (!nlnk_max || nlnk_max > pN) nlnk_max = pN;
2450d3134e9SHong Zhang   ierr = PetscLLCondensedCreate(nlnk_max,pN,&lnk,&lnkbt);CHKERRQ(ierr);
246598bc09dSHong Zhang 
247bfcd1a73SHong Zhang   /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */
248bfcd1a73SHong Zhang   ierr = PetscFreeSpaceGet((PetscInt)(fill*(adi[am]+aoi[am]+pi_loc[pm])),&free_space);CHKERRQ(ierr);
2492205254eSKarl Rupp 
250598bc09dSHong Zhang   current_space = free_space;
251598bc09dSHong Zhang 
252598bc09dSHong Zhang   ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr);
253598bc09dSHong Zhang   for (i=0; i<am; i++) {
254598bc09dSHong Zhang     /* diagonal portion of A */
255598bc09dSHong Zhang     nzi = adi[i+1] - adi[i];
256598bc09dSHong Zhang     for (j=0; j<nzi; j++) {
257598bc09dSHong Zhang       row  = *adj++;
258598bc09dSHong Zhang       pnz  = pi_loc[row+1] - pi_loc[row];
259598bc09dSHong Zhang       Jptr = pj_loc + pi_loc[row];
260598bc09dSHong Zhang       /* add non-zero cols of P into the sorted linked list lnk */
2611fbbb359SHong Zhang       ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
262598bc09dSHong Zhang     }
263598bc09dSHong Zhang     /* off-diagonal portion of A */
264598bc09dSHong Zhang     nzi = aoi[i+1] - aoi[i];
265598bc09dSHong Zhang     for (j=0; j<nzi; j++) {
266598bc09dSHong Zhang       row  = *aoj++;
267598bc09dSHong Zhang       pnz  = pi_oth[row+1] - pi_oth[row];
268598bc09dSHong Zhang       Jptr = pj_oth + pi_oth[row];
2691fbbb359SHong Zhang       ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
270598bc09dSHong Zhang     }
271598bc09dSHong Zhang 
272d14fa243SHong Zhang     apnz     = lnk[0];
273598bc09dSHong Zhang     api[i+1] = api[i] + apnz;
274598bc09dSHong Zhang 
275598bc09dSHong Zhang     /* if free space is not available, double the total space in the list */
276598bc09dSHong Zhang     if (current_space->local_remaining<apnz) {
277598bc09dSHong Zhang       ierr = PetscFreeSpaceGet(apnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
278598bc09dSHong Zhang       nspacedouble++;
279598bc09dSHong Zhang     }
280598bc09dSHong Zhang 
281598bc09dSHong Zhang     /* Copy data into free space, then initialize lnk */
2821fbbb359SHong Zhang     ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
283598bc09dSHong Zhang     ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr);
2842205254eSKarl Rupp 
285598bc09dSHong Zhang     current_space->array           += apnz;
286598bc09dSHong Zhang     current_space->local_used      += apnz;
287598bc09dSHong Zhang     current_space->local_remaining -= apnz;
288598bc09dSHong Zhang   }
289598bc09dSHong Zhang 
290598bc09dSHong Zhang   /* Allocate space for apj, initialize apj, and */
291598bc09dSHong Zhang   /* destroy list of free space and other temporary array(s) */
292785e854fSJed Brown   ierr = PetscMalloc1((api[am]+1),&ptap->apj);CHKERRQ(ierr);
293a1a4e84aSHong Zhang   apj  = ptap->apj;
294a1a4e84aSHong Zhang   ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr);
295598bc09dSHong Zhang   ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr);
296598bc09dSHong Zhang 
297f84c536bSHong Zhang   /* malloc apa to store dense row A[i,:]*P */
2981795a4d1SJed Brown   ierr = PetscCalloc1(pN,&apa);CHKERRQ(ierr);
2992205254eSKarl Rupp 
300f84c536bSHong Zhang   ptap->apa = apa;
301f84c536bSHong Zhang 
302bfcd1a73SHong Zhang   /* create and assemble symbolic parallel matrix Cmpi */
303598bc09dSHong Zhang   /*----------------------------------------------------*/
304bfcd1a73SHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
305bfcd1a73SHong Zhang   ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
30633d57670SJed Brown   ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr);
307a2f3521dSMark F. Adams 
308bfcd1a73SHong Zhang   ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr);
309bfcd1a73SHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
310598bc09dSHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
311598bc09dSHong Zhang   for (i=0; i<am; i++) {
312598bc09dSHong Zhang     row  = i + rstart;
313598bc09dSHong Zhang     apnz = api[i+1] - api[i];
314bfcd1a73SHong Zhang     ierr = MatSetValues(Cmpi,1,&row,apnz,apj,apa,INSERT_VALUES);CHKERRQ(ierr);
315598bc09dSHong Zhang     apj += apnz;
316598bc09dSHong Zhang   }
317bfcd1a73SHong Zhang   ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
318bfcd1a73SHong Zhang   ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
319598bc09dSHong Zhang 
320bfcd1a73SHong Zhang   ptap->destroy        = Cmpi->ops->destroy;
321bfcd1a73SHong Zhang   ptap->duplicate      = Cmpi->ops->duplicate;
322bfcd1a73SHong Zhang   Cmpi->ops->destroy   = MatDestroy_MPIAIJ_MatMatMult;
323bfcd1a73SHong Zhang   Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatMatMult;
324598bc09dSHong Zhang 
325bfcd1a73SHong Zhang   /* attach the supporting struct to Cmpi for reuse */
326bfcd1a73SHong Zhang   c       = (Mat_MPIAIJ*)Cmpi->data;
327598bc09dSHong Zhang   c->ptap = ptap;
328598bc09dSHong Zhang 
329bfcd1a73SHong Zhang   *C = Cmpi;
330bfcd1a73SHong Zhang 
331bfcd1a73SHong Zhang   /* set MatInfo */
332118727c9SMark F. Adams   afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5;
333bfcd1a73SHong Zhang   if (afill < 1.0) afill = 1.0;
334bfcd1a73SHong Zhang   Cmpi->info.mallocs           = nspacedouble;
335bfcd1a73SHong Zhang   Cmpi->info.fill_ratio_given  = fill;
336bfcd1a73SHong Zhang   Cmpi->info.fill_ratio_needed = afill;
337bfcd1a73SHong Zhang 
338bfcd1a73SHong Zhang #if defined(PETSC_USE_INFO)
339bfcd1a73SHong Zhang   if (api[am]) {
34057622a8eSBarry Smith     ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr);
34157622a8eSBarry Smith     ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr);
342bfcd1a73SHong Zhang   } else {
343bfcd1a73SHong Zhang     ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr);
344bfcd1a73SHong Zhang   }
345bfcd1a73SHong Zhang #endif
346598bc09dSHong Zhang   PetscFunctionReturn(0);
347598bc09dSHong Zhang }
348598bc09dSHong Zhang 
3499123193aSHong Zhang #undef __FUNCT__
3509123193aSHong Zhang #define __FUNCT__ "MatMatMult_MPIAIJ_MPIDense"
3519123193aSHong Zhang PetscErrorCode MatMatMult_MPIAIJ_MPIDense(Mat A,Mat B,MatReuse scall,PetscReal fill,Mat *C)
3529123193aSHong Zhang {
3539123193aSHong Zhang   PetscErrorCode ierr;
3549123193aSHong Zhang 
3559123193aSHong Zhang   PetscFunctionBegin;
3569123193aSHong Zhang   if (scall == MAT_INITIAL_MATRIX) {
3573ff4c91cSHong Zhang     ierr = PetscLogEventBegin(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr);
3589123193aSHong Zhang     ierr = MatMatMultSymbolic_MPIAIJ_MPIDense(A,B,fill,C);CHKERRQ(ierr);
3593ff4c91cSHong Zhang     ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr);
3609123193aSHong Zhang   }
3613ff4c91cSHong Zhang   ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr);
3629123193aSHong Zhang   ierr = MatMatMultNumeric_MPIAIJ_MPIDense(A,B,*C);CHKERRQ(ierr);
3633ff4c91cSHong Zhang   ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr);
3649123193aSHong Zhang   PetscFunctionReturn(0);
3659123193aSHong Zhang }
3669123193aSHong Zhang 
3674324174eSBarry Smith typedef struct {
3684324174eSBarry Smith   Mat         workB;
3694324174eSBarry Smith   PetscScalar *rvalues,*svalues;
3704324174eSBarry Smith   MPI_Request *rwaits,*swaits;
3714324174eSBarry Smith } MPIAIJ_MPIDense;
3724324174eSBarry Smith 
3737af9e4fdSHong Zhang #undef __FUNCT__
37496b95a6bSBarry Smith #define __FUNCT__ "MatMPIAIJ_MPIDenseDestroy"
37596b95a6bSBarry Smith PetscErrorCode MatMPIAIJ_MPIDenseDestroy(void *ctx)
3764324174eSBarry Smith {
3774324174eSBarry Smith   MPIAIJ_MPIDense *contents = (MPIAIJ_MPIDense*) ctx;
3784324174eSBarry Smith   PetscErrorCode  ierr;
3794324174eSBarry Smith 
3804324174eSBarry Smith   PetscFunctionBegin;
3816bf464f9SBarry Smith   ierr = MatDestroy(&contents->workB);CHKERRQ(ierr);
3824324174eSBarry Smith   ierr = PetscFree4(contents->rvalues,contents->svalues,contents->rwaits,contents->swaits);CHKERRQ(ierr);
3834324174eSBarry Smith   ierr = PetscFree(contents);CHKERRQ(ierr);
3844324174eSBarry Smith   PetscFunctionReturn(0);
3854324174eSBarry Smith }
3864324174eSBarry Smith 
3879123193aSHong Zhang #undef __FUNCT__
3889123193aSHong Zhang #define __FUNCT__ "MatMatMultSymbolic_MPIAIJ_MPIDense"
3899123193aSHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIDense(Mat A,Mat B,PetscReal fill,Mat *C)
3909123193aSHong Zhang {
3919123193aSHong Zhang   PetscErrorCode         ierr;
392f32d5d43SBarry Smith   Mat_MPIAIJ             *aij = (Mat_MPIAIJ*) A->data;
393d0f46423SBarry Smith   PetscInt               nz   = aij->B->cmap->n;
394bf0cc555SLisandro Dalcin   PetscContainer         container;
3954324174eSBarry Smith   MPIAIJ_MPIDense        *contents;
3964324174eSBarry Smith   VecScatter             ctx   = aij->Mvctx;
3974324174eSBarry Smith   VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata;
3984324174eSBarry Smith   VecScatter_MPI_General *to   = (VecScatter_MPI_General*) ctx->todata;
399d0f46423SBarry Smith   PetscInt               m     = A->rmap->n,n=B->cmap->n;
4009123193aSHong Zhang 
4019123193aSHong Zhang   PetscFunctionBegin;
402ce94432eSBarry Smith   ierr = MatCreate(PetscObjectComm((PetscObject)B),C);CHKERRQ(ierr);
403d0f46423SBarry Smith   ierr = MatSetSizes(*C,m,n,A->rmap->N,B->cmap->N);CHKERRQ(ierr);
40433d57670SJed Brown   ierr = MatSetBlockSizesFromMats(*C,A,B);CHKERRQ(ierr);
405cb2480eaSBarry Smith   ierr = MatSetType(*C,MATMPIDENSE);CHKERRQ(ierr);
4060298fd71SBarry Smith   ierr = MatMPIDenseSetPreallocation(*C,NULL);CHKERRQ(ierr);
407cb2480eaSBarry Smith   ierr = MatAssemblyBegin(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
408cb2480eaSBarry Smith   ierr = MatAssemblyEnd(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
4092205254eSKarl Rupp 
410d73949e8SHong Zhang   (*C)->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense;
411f32d5d43SBarry Smith 
412b00a9115SJed Brown   ierr = PetscNew(&contents);CHKERRQ(ierr);
413f32d5d43SBarry Smith   /* Create work matrix used to store off processor rows of B needed for local product */
4140298fd71SBarry Smith   ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,B->cmap->N,NULL,&contents->workB);CHKERRQ(ierr);
4154324174eSBarry Smith   /* Create work arrays needed */
416dcca6d9dSJed Brown   ierr = PetscMalloc4(B->cmap->N*from->starts[from->n],&contents->rvalues,
417dcca6d9dSJed Brown                       B->cmap->N*to->starts[to->n],&contents->svalues,
418dcca6d9dSJed Brown                       from->n,&contents->rwaits,
419dcca6d9dSJed Brown                       to->n,&contents->swaits);CHKERRQ(ierr);
4204324174eSBarry Smith 
421ce94432eSBarry Smith   ierr = PetscContainerCreate(PetscObjectComm((PetscObject)A),&container);CHKERRQ(ierr);
422bf0cc555SLisandro Dalcin   ierr = PetscContainerSetPointer(container,contents);CHKERRQ(ierr);
42396b95a6bSBarry Smith   ierr = PetscContainerSetUserDestroy(container,MatMPIAIJ_MPIDenseDestroy);CHKERRQ(ierr);
424bf0cc555SLisandro Dalcin   ierr = PetscObjectCompose((PetscObject)(*C),"workB",(PetscObject)container);CHKERRQ(ierr);
425bf0cc555SLisandro Dalcin   ierr = PetscContainerDestroy(&container);CHKERRQ(ierr);
4269123193aSHong Zhang   PetscFunctionReturn(0);
4279123193aSHong Zhang }
4289123193aSHong Zhang 
4297af9e4fdSHong Zhang #undef __FUNCT__
4307af9e4fdSHong Zhang #define __FUNCT__ "MatMPIDenseScatter"
431f32d5d43SBarry Smith /*
4322636ff26SBarry Smith     Performs an efficient scatter on the rows of B needed by this process; this is
4332636ff26SBarry Smith     a modification of the VecScatterBegin_() routines.
434f32d5d43SBarry Smith */
4354324174eSBarry Smith PetscErrorCode MatMPIDenseScatter(Mat A,Mat B,Mat C,Mat *outworkB)
436f32d5d43SBarry Smith {
437f32d5d43SBarry Smith   Mat_MPIAIJ             *aij = (Mat_MPIAIJ*)A->data;
438f32d5d43SBarry Smith   PetscErrorCode         ierr;
439f32d5d43SBarry Smith   PetscScalar            *b,*w,*svalues,*rvalues;
440f32d5d43SBarry Smith   VecScatter             ctx   = aij->Mvctx;
441f32d5d43SBarry Smith   VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata;
442f32d5d43SBarry Smith   VecScatter_MPI_General *to   = (VecScatter_MPI_General*) ctx->todata;
443f32d5d43SBarry Smith   PetscInt               i,j,k;
444aa5bb8c0SSatish Balay   PetscInt               *sindices,*sstarts,*rindices,*rstarts;
445aa5bb8c0SSatish Balay   PetscMPIInt            *sprocs,*rprocs,nrecvs;
446f32d5d43SBarry Smith   MPI_Request            *swaits,*rwaits;
447ce94432eSBarry Smith   MPI_Comm               comm;
448d0f46423SBarry Smith   PetscMPIInt            tag  = ((PetscObject)ctx)->tag,ncols = B->cmap->N, nrows = aij->B->cmap->n,imdex,nrowsB = B->rmap->n;
449f32d5d43SBarry Smith   MPI_Status             status;
4504324174eSBarry Smith   MPIAIJ_MPIDense        *contents;
451bf0cc555SLisandro Dalcin   PetscContainer         container;
4524324174eSBarry Smith   Mat                    workB;
453f32d5d43SBarry Smith 
454f32d5d43SBarry Smith   PetscFunctionBegin;
455ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
456bf0cc555SLisandro Dalcin   ierr = PetscObjectQuery((PetscObject)C,"workB",(PetscObject*)&container);CHKERRQ(ierr);
45729825010SHong Zhang   if (!container) SETERRQ(comm,PETSC_ERR_PLIB,"Container does not exist");
458bf0cc555SLisandro Dalcin   ierr = PetscContainerGetPointer(container,(void**)&contents);CHKERRQ(ierr);
4594324174eSBarry Smith 
4604324174eSBarry Smith   workB = *outworkB = contents->workB;
461cf1a0672SHong Zhang   if (nrows != workB->rmap->n) SETERRQ2(comm,PETSC_ERR_PLIB,"Number of rows of workB %D not equal to columns of aij->B %D",nrows,workB->cmap->n);
462f32d5d43SBarry Smith   sindices = to->indices;
463f32d5d43SBarry Smith   sstarts  = to->starts;
464f32d5d43SBarry Smith   sprocs   = to->procs;
4654324174eSBarry Smith   swaits   = contents->swaits;
4664324174eSBarry Smith   svalues  = contents->svalues;
467f32d5d43SBarry Smith 
468f32d5d43SBarry Smith   rindices = from->indices;
469f32d5d43SBarry Smith   rstarts  = from->starts;
470f32d5d43SBarry Smith   rprocs   = from->procs;
4714324174eSBarry Smith   rwaits   = contents->rwaits;
4724324174eSBarry Smith   rvalues  = contents->rvalues;
473f32d5d43SBarry Smith 
4748c778c55SBarry Smith   ierr = MatDenseGetArray(B,&b);CHKERRQ(ierr);
4758c778c55SBarry Smith   ierr = MatDenseGetArray(workB,&w);CHKERRQ(ierr);
476f32d5d43SBarry Smith 
477f32d5d43SBarry Smith   for (i=0; i<from->n; i++) {
478f32d5d43SBarry Smith     ierr = MPI_Irecv(rvalues+ncols*rstarts[i],ncols*(rstarts[i+1]-rstarts[i]),MPIU_SCALAR,rprocs[i],tag,comm,rwaits+i);CHKERRQ(ierr);
479f32d5d43SBarry Smith   }
480f32d5d43SBarry Smith 
481f32d5d43SBarry Smith   for (i=0; i<to->n; i++) {
482f32d5d43SBarry Smith     /* pack a message at a time */
483f32d5d43SBarry Smith     for (j=0; j<sstarts[i+1]-sstarts[i]; j++) {
484f32d5d43SBarry Smith       for (k=0; k<ncols; k++) {
485f32d5d43SBarry Smith         svalues[ncols*(sstarts[i] + j) + k] = b[sindices[sstarts[i]+j] + nrowsB*k];
4862636ff26SBarry Smith       }
4872636ff26SBarry Smith     }
488f32d5d43SBarry Smith     ierr = MPI_Isend(svalues+ncols*sstarts[i],ncols*(sstarts[i+1]-sstarts[i]),MPIU_SCALAR,sprocs[i],tag,comm,swaits+i);CHKERRQ(ierr);
489f32d5d43SBarry Smith   }
4902636ff26SBarry Smith 
491f32d5d43SBarry Smith   nrecvs = from->n;
492f32d5d43SBarry Smith   while (nrecvs) {
493f32d5d43SBarry Smith     ierr = MPI_Waitany(from->n,rwaits,&imdex,&status);CHKERRQ(ierr);
494f32d5d43SBarry Smith     nrecvs--;
495f32d5d43SBarry Smith     /* unpack a message at a time */
496f32d5d43SBarry Smith     for (j=0; j<rstarts[imdex+1]-rstarts[imdex]; j++) {
497f32d5d43SBarry Smith       for (k=0; k<ncols; k++) {
498f32d5d43SBarry Smith         w[rindices[rstarts[imdex]+j] + nrows*k] = rvalues[ncols*(rstarts[imdex] + j) + k];
4992636ff26SBarry Smith       }
5002636ff26SBarry Smith     }
501f32d5d43SBarry Smith   }
502cb9801acSJed Brown   if (to->n) {ierr = MPI_Waitall(to->n,swaits,to->sstatus);CHKERRQ(ierr);}
503f32d5d43SBarry Smith 
5048c778c55SBarry Smith   ierr = MatDenseRestoreArray(B,&b);CHKERRQ(ierr);
5058c778c55SBarry Smith   ierr = MatDenseRestoreArray(workB,&w);CHKERRQ(ierr);
506f32d5d43SBarry Smith   ierr = MatAssemblyBegin(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
507f32d5d43SBarry Smith   ierr = MatAssemblyEnd(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
508f32d5d43SBarry Smith   PetscFunctionReturn(0);
509f32d5d43SBarry Smith }
510f32d5d43SBarry Smith extern PetscErrorCode MatMatMultNumericAdd_SeqAIJ_SeqDense(Mat,Mat,Mat);
511f32d5d43SBarry Smith 
5129123193aSHong Zhang #undef __FUNCT__
5139123193aSHong Zhang #define __FUNCT__ "MatMatMultNumeric_MPIAIJ_MPIDense"
5149123193aSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense(Mat A,Mat B,Mat C)
5159123193aSHong Zhang {
5169123193aSHong Zhang   PetscErrorCode ierr;
517f32d5d43SBarry Smith   Mat_MPIAIJ     *aij    = (Mat_MPIAIJ*)A->data;
518f32d5d43SBarry Smith   Mat_MPIDense   *bdense = (Mat_MPIDense*)B->data;
519f32d5d43SBarry Smith   Mat_MPIDense   *cdense = (Mat_MPIDense*)C->data;
520f32d5d43SBarry Smith   Mat            workB;
5219123193aSHong Zhang 
5229123193aSHong Zhang   PetscFunctionBegin;
523f32d5d43SBarry Smith   /* diagonal block of A times all local rows of B*/
524f32d5d43SBarry Smith   ierr = MatMatMultNumeric_SeqAIJ_SeqDense(aij->A,bdense->A,cdense->A);CHKERRQ(ierr);
525f32d5d43SBarry Smith 
526f32d5d43SBarry Smith   /* get off processor parts of B needed to complete the product */
5274324174eSBarry Smith   ierr = MatMPIDenseScatter(A,B,C,&workB);CHKERRQ(ierr);
528f32d5d43SBarry Smith 
529f32d5d43SBarry Smith   /* off-diagonal block of A times nonlocal rows of B */
530f32d5d43SBarry Smith   ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cdense->A);CHKERRQ(ierr);
5319123193aSHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
5329123193aSHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
5339123193aSHong Zhang   PetscFunctionReturn(0);
5349123193aSHong Zhang }
535cf1a0672SHong Zhang 
5361634b032SHong Zhang #undef __FUNCT__
537cf1a0672SHong Zhang #define __FUNCT__ "MatMatMultNumeric_MPIAIJ_MPIAIJ_Scalable"
538cf1a0672SHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ_Scalable(Mat A,Mat P,Mat C)
5391634b032SHong Zhang {
5401634b032SHong Zhang   PetscErrorCode ierr;
541cf1a0672SHong Zhang   Mat_MPIAIJ     *a   = (Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data;
542cf1a0672SHong Zhang   Mat_SeqAIJ     *ad  = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
543cf1a0672SHong Zhang   Mat_SeqAIJ     *cd  = (Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data;
544cf1a0672SHong Zhang   PetscInt       *adi = ad->i,*adj,*aoi=ao->i,*aoj;
545cf1a0672SHong Zhang   PetscScalar    *ada,*aoa,*cda=cd->a,*coa=co->a;
546cf1a0672SHong Zhang   Mat_SeqAIJ     *p_loc,*p_oth;
547cf1a0672SHong Zhang   PetscInt       *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj;
54829825010SHong Zhang   PetscScalar    *pa_loc,*pa_oth,*pa,valtmp,*ca;
54929825010SHong Zhang   PetscInt       cm          = C->rmap->n,anz,pnz;
550cf1a0672SHong Zhang   Mat_PtAPMPI    *ptap       = c->ptap;
55129825010SHong Zhang   PetscScalar    *apa_sparse = ptap->apa;
552cf1a0672SHong Zhang   PetscInt       *api,*apj,*apJ,i,j,k,row;
55329825010SHong Zhang   PetscInt       cstart = C->cmap->rstart;
55429825010SHong Zhang   PetscInt       cdnz,conz,k0,k1,nextp;
555*a7c7454dSHong Zhang   MPI_Comm       comm;
556*a7c7454dSHong Zhang   PetscMPIInt    size;
5571634b032SHong Zhang 
5581634b032SHong Zhang   PetscFunctionBegin;
559*a7c7454dSHong Zhang   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
560*a7c7454dSHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
561*a7c7454dSHong Zhang 
562cf1a0672SHong Zhang   /* 1) get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
563cf1a0672SHong Zhang   /*-----------------------------------------------------*/
564cf1a0672SHong Zhang   /* update numerical values of P_oth and P_loc */
565b7f45c76SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
566cf1a0672SHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
567cf1a0672SHong Zhang 
568cf1a0672SHong Zhang   /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */
569cf1a0672SHong Zhang   /*----------------------------------------------------------*/
570cf1a0672SHong Zhang   /* get data from symbolic products */
571cf1a0672SHong Zhang   p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data;
572cf1a0672SHong Zhang   pi_loc=p_loc->i; pj_loc=p_loc->j; pa_loc=p_loc->a;
573*a7c7454dSHong Zhang   if (size >1) {
574*a7c7454dSHong Zhang     p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data;
575cf1a0672SHong Zhang     pi_oth=p_oth->i; pj_oth=p_oth->j; pa_oth=p_oth->a;
576*a7c7454dSHong Zhang   }
577cf1a0672SHong Zhang 
57829825010SHong Zhang   api = ptap->api;
57929825010SHong Zhang   apj = ptap->apj;
580cf1a0672SHong Zhang   for (i=0; i<cm; i++) {
58129825010SHong Zhang     apJ = apj + api[i];
58229825010SHong Zhang 
583cf1a0672SHong Zhang     /* diagonal portion of A */
584cf1a0672SHong Zhang     anz = adi[i+1] - adi[i];
585cf1a0672SHong Zhang     adj = ad->j + adi[i];
586cf1a0672SHong Zhang     ada = ad->a + adi[i];
587cf1a0672SHong Zhang     for (j=0; j<anz; j++) {
588cf1a0672SHong Zhang       row = adj[j];
589cf1a0672SHong Zhang       pnz = pi_loc[row+1] - pi_loc[row];
590cf1a0672SHong Zhang       pj  = pj_loc + pi_loc[row];
591cf1a0672SHong Zhang       pa  = pa_loc + pi_loc[row];
59229825010SHong Zhang       /* perform sparse axpy */
593cf1a0672SHong Zhang       valtmp = ada[j];
59429825010SHong Zhang       nextp  = 0;
59529825010SHong Zhang       for (k=0; nextp<pnz; k++) {
59629825010SHong Zhang         if (apJ[k] == pj[nextp]) { /* column of AP == column of P */
59729825010SHong Zhang           apa_sparse[k] += valtmp*pa[nextp++];
59829825010SHong Zhang         }
5991634b032SHong Zhang       }
600cf1a0672SHong Zhang       ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
601cf1a0672SHong Zhang     }
6021634b032SHong Zhang 
603cf1a0672SHong Zhang     /* off-diagonal portion of A */
604cf1a0672SHong Zhang     anz = aoi[i+1] - aoi[i];
605cf1a0672SHong Zhang     aoj = ao->j + aoi[i];
606cf1a0672SHong Zhang     aoa = ao->a + aoi[i];
607cf1a0672SHong Zhang     for (j=0; j<anz; j++) {
608cf1a0672SHong Zhang       row = aoj[j];
609cf1a0672SHong Zhang       pnz = pi_oth[row+1] - pi_oth[row];
610cf1a0672SHong Zhang       pj  = pj_oth + pi_oth[row];
611cf1a0672SHong Zhang       pa  = pa_oth + pi_oth[row];
61229825010SHong Zhang       /* perform sparse axpy */
613cf1a0672SHong Zhang       valtmp = aoa[j];
61429825010SHong Zhang       nextp  = 0;
61529825010SHong Zhang       for (k=0; nextp<pnz; k++) {
61629825010SHong Zhang         if (apJ[k] == pj[nextp]) { /* column of AP == column of P */
61729825010SHong Zhang           apa_sparse[k] += valtmp*pa[nextp++];
61829825010SHong Zhang         }
619cf1a0672SHong Zhang       }
620cf1a0672SHong Zhang       ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
621cf1a0672SHong Zhang     }
6221634b032SHong Zhang 
623cf1a0672SHong Zhang     /* set values in C */
624cf1a0672SHong Zhang     cdnz = cd->i[i+1] - cd->i[i];
625cf1a0672SHong Zhang     conz = co->i[i+1] - co->i[i];
6261634b032SHong Zhang 
627cf1a0672SHong Zhang     /* 1st off-diagoanl part of C */
628cf1a0672SHong Zhang     ca = coa + co->i[i];
629cf1a0672SHong Zhang     k  = 0;
630cf1a0672SHong Zhang     for (k0=0; k0<conz; k0++) {
631cf1a0672SHong Zhang       if (apJ[k] >= cstart) break;
63229825010SHong Zhang       ca[k0]        = apa_sparse[k];
63329825010SHong Zhang       apa_sparse[k] = 0.0;
634cf1a0672SHong Zhang       k++;
635cf1a0672SHong Zhang     }
6361634b032SHong Zhang 
637cf1a0672SHong Zhang     /* diagonal part of C */
638cf1a0672SHong Zhang     ca = cda + cd->i[i];
639cf1a0672SHong Zhang     for (k1=0; k1<cdnz; k1++) {
64029825010SHong Zhang       ca[k1]        = apa_sparse[k];
64129825010SHong Zhang       apa_sparse[k] = 0.0;
642cf1a0672SHong Zhang       k++;
643cf1a0672SHong Zhang     }
644cf1a0672SHong Zhang 
645cf1a0672SHong Zhang     /* 2nd off-diagoanl part of C */
646cf1a0672SHong Zhang     ca = coa + co->i[i];
647cf1a0672SHong Zhang     for (; k0<conz; k0++) {
64829825010SHong Zhang       ca[k0]        = apa_sparse[k];
64929825010SHong Zhang       apa_sparse[k] = 0.0;
650cf1a0672SHong Zhang       k++;
651cf1a0672SHong Zhang     }
652cf1a0672SHong Zhang   }
653cf1a0672SHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
654cf1a0672SHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
655cf1a0672SHong Zhang   PetscFunctionReturn(0);
656cf1a0672SHong Zhang }
657cf1a0672SHong Zhang 
6580fc8cf34SHong Zhang /* same as MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(), except using LLCondensed to avoid O(BN) memory requirement */
659cf1a0672SHong Zhang #undef __FUNCT__
660b2405163SHong Zhang #define __FUNCT__ "MatMatMultSymbolic_MPIAIJ_MPIAIJ"
661b2405163SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat *C)
662cf1a0672SHong Zhang {
663cf1a0672SHong Zhang   PetscErrorCode     ierr;
664ce94432eSBarry Smith   MPI_Comm           comm;
665*a7c7454dSHong Zhang   PetscMPIInt        size;
666cf1a0672SHong Zhang   Mat                Cmpi;
667cf1a0672SHong Zhang   Mat_PtAPMPI        *ptap;
6680298fd71SBarry Smith   PetscFreeSpaceList free_space = NULL,current_space=NULL;
669cf1a0672SHong Zhang   Mat_MPIAIJ         *a         = (Mat_MPIAIJ*)A->data,*c;
670cf1a0672SHong Zhang   Mat_SeqAIJ         *ad        = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth;
671cf1a0672SHong Zhang   PetscInt           *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz;
672cf1a0672SHong Zhang   PetscInt           *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart;
673f84c536bSHong Zhang   PetscInt           i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi,*lnk,apnz_max=0;
674cf1a0672SHong Zhang   PetscInt           am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n;
675cf1a0672SHong Zhang   PetscInt           nlnk_max,armax,prmax;
676cf1a0672SHong Zhang   PetscReal          afill;
677cf1a0672SHong Zhang   PetscScalar        *apa;
678cf1a0672SHong Zhang 
679cf1a0672SHong Zhang   PetscFunctionBegin;
680ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
681*a7c7454dSHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
682*a7c7454dSHong Zhang 
683cf1a0672SHong Zhang   /* create struct Mat_PtAPMPI and attached it to C later */
684b00a9115SJed Brown   ierr = PetscNew(&ptap);CHKERRQ(ierr);
685cf1a0672SHong Zhang 
686cf1a0672SHong Zhang   /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
687b7f45c76SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
68819f0e57aSHong Zhang 
689cf1a0672SHong Zhang   /* get P_loc by taking all local rows of P */
690cf1a0672SHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
691cf1a0672SHong Zhang 
692cf1a0672SHong Zhang   p_loc  = (Mat_SeqAIJ*)(ptap->P_loc)->data;
693cf1a0672SHong Zhang   pi_loc = p_loc->i; pj_loc = p_loc->j;
694*a7c7454dSHong Zhang   if (size > 1) {
695*a7c7454dSHong Zhang     p_oth  = (Mat_SeqAIJ*)(ptap->P_oth)->data;
696*a7c7454dSHong Zhang     pi_oth = p_oth->i;
697*a7c7454dSHong Zhang     pj_oth = p_oth->j;
698*a7c7454dSHong Zhang   }
699cf1a0672SHong Zhang 
700cf1a0672SHong Zhang   /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */
701cf1a0672SHong Zhang   /*-------------------------------------------------------------------*/
702785e854fSJed Brown   ierr      = PetscMalloc1((am+2),&api);CHKERRQ(ierr);
703cf1a0672SHong Zhang   ptap->api = api;
704cf1a0672SHong Zhang   api[0]    = 0;
705cf1a0672SHong Zhang 
706cf1a0672SHong Zhang   /* create and initialize a linked list */
707cf1a0672SHong Zhang   armax = ad->rmax+ao->rmax;
708*a7c7454dSHong Zhang   if (size >1) {
709cf1a0672SHong Zhang     prmax = PetscMax(p_loc->rmax,p_oth->rmax);
710*a7c7454dSHong Zhang   } else {
711*a7c7454dSHong Zhang     prmax = p_loc->rmax;
712*a7c7454dSHong Zhang   }
713cf1a0672SHong Zhang   nlnk_max = armax*prmax;
714cf1a0672SHong Zhang   if (!nlnk_max || nlnk_max > pN) nlnk_max = pN;
715f84c536bSHong Zhang   ierr = PetscLLCondensedCreate_Scalable(nlnk_max,&lnk);CHKERRQ(ierr);
716cf1a0672SHong Zhang 
717cf1a0672SHong Zhang   /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */
718cf1a0672SHong Zhang   ierr = PetscFreeSpaceGet((PetscInt)(fill*(adi[am]+aoi[am]+pi_loc[pm])),&free_space);CHKERRQ(ierr);
7192205254eSKarl Rupp 
720cf1a0672SHong Zhang   current_space = free_space;
721cf1a0672SHong Zhang 
722cf1a0672SHong Zhang   ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr);
723cf1a0672SHong Zhang   for (i=0; i<am; i++) {
724cf1a0672SHong Zhang     /* diagonal portion of A */
725cf1a0672SHong Zhang     nzi = adi[i+1] - adi[i];
726cf1a0672SHong Zhang     for (j=0; j<nzi; j++) {
727cf1a0672SHong Zhang       row  = *adj++;
728cf1a0672SHong Zhang       pnz  = pi_loc[row+1] - pi_loc[row];
729cf1a0672SHong Zhang       Jptr = pj_loc + pi_loc[row];
730cf1a0672SHong Zhang       /* add non-zero cols of P into the sorted linked list lnk */
731f84c536bSHong Zhang       ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr);
732cf1a0672SHong Zhang     }
733cf1a0672SHong Zhang     /* off-diagonal portion of A */
734cf1a0672SHong Zhang     nzi = aoi[i+1] - aoi[i];
735cf1a0672SHong Zhang     for (j=0; j<nzi; j++) {
736cf1a0672SHong Zhang       row  = *aoj++;
737cf1a0672SHong Zhang       pnz  = pi_oth[row+1] - pi_oth[row];
738cf1a0672SHong Zhang       Jptr = pj_oth + pi_oth[row];
739f84c536bSHong Zhang       ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr);
740cf1a0672SHong Zhang     }
741cf1a0672SHong Zhang 
742f84c536bSHong Zhang     apnz     = *lnk;
743cf1a0672SHong Zhang     api[i+1] = api[i] + apnz;
744cf1a0672SHong Zhang     if (apnz > apnz_max) apnz_max = apnz;
745cf1a0672SHong Zhang 
746cf1a0672SHong Zhang     /* if free space is not available, double the total space in the list */
747cf1a0672SHong Zhang     if (current_space->local_remaining<apnz) {
748cf1a0672SHong Zhang       ierr = PetscFreeSpaceGet(apnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
749cf1a0672SHong Zhang       nspacedouble++;
750cf1a0672SHong Zhang     }
751cf1a0672SHong Zhang 
752cf1a0672SHong Zhang     /* Copy data into free space, then initialize lnk */
753f84c536bSHong Zhang     ierr = PetscLLCondensedClean_Scalable(apnz,current_space->array,lnk);CHKERRQ(ierr);
754cf1a0672SHong Zhang     ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr);
7552205254eSKarl Rupp 
756cf1a0672SHong Zhang     current_space->array           += apnz;
757cf1a0672SHong Zhang     current_space->local_used      += apnz;
758cf1a0672SHong Zhang     current_space->local_remaining -= apnz;
759cf1a0672SHong Zhang   }
760cf1a0672SHong Zhang 
761cf1a0672SHong Zhang   /* Allocate space for apj, initialize apj, and */
762cf1a0672SHong Zhang   /* destroy list of free space and other temporary array(s) */
763785e854fSJed Brown   ierr = PetscMalloc1((api[am]+1),&ptap->apj);CHKERRQ(ierr);
764cf1a0672SHong Zhang   apj  = ptap->apj;
765cf1a0672SHong Zhang   ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr);
766f84c536bSHong Zhang   ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr);
767cf1a0672SHong Zhang 
768cf1a0672SHong Zhang   /* create and assemble symbolic parallel matrix Cmpi */
769cf1a0672SHong Zhang   /*----------------------------------------------------*/
770cf1a0672SHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
771cf1a0672SHong Zhang   ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
77233d57670SJed Brown   ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr);
773cf1a0672SHong Zhang   ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr);
774cf1a0672SHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
775cf1a0672SHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
776cf1a0672SHong Zhang 
77729825010SHong Zhang   /* malloc apa for assembly Cmpi */
7781795a4d1SJed Brown   ierr = PetscCalloc1(apnz_max,&apa);CHKERRQ(ierr);
7792205254eSKarl Rupp 
78029825010SHong Zhang   ptap->apa = apa;
781cf1a0672SHong Zhang   for (i=0; i<am; i++) {
782cf1a0672SHong Zhang     row  = i + rstart;
783cf1a0672SHong Zhang     apnz = api[i+1] - api[i];
784cf1a0672SHong Zhang     ierr = MatSetValues(Cmpi,1,&row,apnz,apj,apa,INSERT_VALUES);CHKERRQ(ierr);
785cf1a0672SHong Zhang     apj += apnz;
786cf1a0672SHong Zhang   }
787cf1a0672SHong Zhang   ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
788cf1a0672SHong Zhang   ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
789cf1a0672SHong Zhang 
790cf1a0672SHong Zhang   ptap->destroy             = Cmpi->ops->destroy;
791cf1a0672SHong Zhang   ptap->duplicate           = Cmpi->ops->duplicate;
792cf1a0672SHong Zhang   Cmpi->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ_Scalable;
793cf1a0672SHong Zhang   Cmpi->ops->destroy        = MatDestroy_MPIAIJ_MatMatMult;
794cf1a0672SHong Zhang   Cmpi->ops->duplicate      = MatDuplicate_MPIAIJ_MatMatMult;
795cf1a0672SHong Zhang 
796cf1a0672SHong Zhang   /* attach the supporting struct to Cmpi for reuse */
797cf1a0672SHong Zhang   c       = (Mat_MPIAIJ*)Cmpi->data;
798cf1a0672SHong Zhang   c->ptap = ptap;
799cf1a0672SHong Zhang 
800cf1a0672SHong Zhang   *C = Cmpi;
801cf1a0672SHong Zhang 
802cf1a0672SHong Zhang   /* set MatInfo */
803118727c9SMark F. Adams   afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5;
804cf1a0672SHong Zhang   if (afill < 1.0) afill = 1.0;
805cf1a0672SHong Zhang   Cmpi->info.mallocs           = nspacedouble;
806cf1a0672SHong Zhang   Cmpi->info.fill_ratio_given  = fill;
807cf1a0672SHong Zhang   Cmpi->info.fill_ratio_needed = afill;
808cf1a0672SHong Zhang 
809cf1a0672SHong Zhang #if defined(PETSC_USE_INFO)
810cf1a0672SHong Zhang   if (api[am]) {
81157622a8eSBarry Smith     ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr);
81257622a8eSBarry Smith     ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr);
813cf1a0672SHong Zhang   } else {
814cf1a0672SHong Zhang     ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr);
815cf1a0672SHong Zhang   }
816cf1a0672SHong Zhang #endif
8171634b032SHong Zhang   PetscFunctionReturn(0);
8181634b032SHong Zhang }
819f96d37fcSHong Zhang 
820f96d37fcSHong Zhang /*-------------------------------------------------------------------------*/
821f96d37fcSHong Zhang #undef __FUNCT__
822f96d37fcSHong Zhang #define __FUNCT__ "MatTransposeMatMult_MPIAIJ_MPIAIJ"
823c5af039cSHong Zhang PetscErrorCode MatTransposeMatMult_MPIAIJ_MPIAIJ(Mat P,Mat A,MatReuse scall,PetscReal fill,Mat *C)
824f96d37fcSHong Zhang {
825f96d37fcSHong Zhang   PetscErrorCode ierr;
826c216dbf3SHong Zhang   const char     *algTypes[3] = {"scalable","nonscalable","matmatmult"};
827c216dbf3SHong Zhang   PetscInt       alg=0; /* set default algorithm */
828f96d37fcSHong Zhang 
829f96d37fcSHong Zhang   PetscFunctionBegin;
830c216dbf3SHong Zhang   if (scall == MAT_INITIAL_MATRIX) {
831c216dbf3SHong Zhang     ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr);
832c216dbf3SHong Zhang     ierr = PetscOptionsEList("-mattransposematmult_via","Algorithmic approach","MatTransposeMatMult",algTypes,3,algTypes[0],&alg,NULL);CHKERRQ(ierr);
833c216dbf3SHong Zhang     ierr = PetscOptionsEnd();CHKERRQ(ierr);
834c216dbf3SHong Zhang 
835c216dbf3SHong Zhang     ierr = PetscLogEventBegin(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr);
836c216dbf3SHong Zhang     switch (alg) {
837c216dbf3SHong Zhang     case 1:
8382bbb1c24SHong Zhang       ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(P,A,fill,C);CHKERRQ(ierr);
839c216dbf3SHong Zhang       break;
840c216dbf3SHong Zhang     case 2:
841275476c6SMatthew G. Knepley     {
842ab1b013aSHong Zhang       Mat         Pt;
843ab1b013aSHong Zhang       Mat_PtAPMPI *ptap;
844ab1b013aSHong Zhang       Mat_MPIAIJ  *c;
845ab1b013aSHong Zhang       ierr = MatTranspose(P,MAT_INITIAL_MATRIX,&Pt);CHKERRQ(ierr);
846ab1b013aSHong Zhang       ierr = MatMatMult(Pt,A,MAT_INITIAL_MATRIX,fill,C);CHKERRQ(ierr);
847ab1b013aSHong Zhang       c        = (Mat_MPIAIJ*)(*C)->data;
848ab1b013aSHong Zhang       ptap     = c->ptap;
849ab1b013aSHong Zhang       ptap->Pt = Pt;
850c216dbf3SHong Zhang       (*C)->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult;
851c216dbf3SHong Zhang       PetscFunctionReturn(0);
852275476c6SMatthew G. Knepley     }
853c216dbf3SHong Zhang       break;
854c216dbf3SHong Zhang     default:
8556da69ca6SHong Zhang       ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(P,A,fill,C);CHKERRQ(ierr);
856c216dbf3SHong Zhang       break;
857c216dbf3SHong Zhang     }
858c216dbf3SHong Zhang     ierr = PetscLogEventEnd(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr);
859c216dbf3SHong Zhang   }
860c216dbf3SHong Zhang   ierr = PetscLogEventBegin(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr);
861c216dbf3SHong Zhang   ierr = (*(*C)->ops->mattransposemultnumeric)(P,A,*C);CHKERRQ(ierr);
862c216dbf3SHong Zhang   ierr = PetscLogEventEnd(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr);
863ab1b013aSHong Zhang   PetscFunctionReturn(0);
864ab1b013aSHong Zhang }
865ab1b013aSHong Zhang 
866c216dbf3SHong Zhang /* This routine only works when scall=MAT_REUSE_MATRIX! */
867c216dbf3SHong Zhang #undef __FUNCT__
868c216dbf3SHong Zhang #define __FUNCT__ "MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult"
869c216dbf3SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult(Mat P,Mat A,Mat C)
870c216dbf3SHong Zhang {
871c216dbf3SHong Zhang   PetscErrorCode ierr;
8722bbb1c24SHong Zhang   Mat_MPIAIJ     *c=(Mat_MPIAIJ*)C->data;
8732bbb1c24SHong Zhang   Mat_PtAPMPI    *ptap= c->ptap;
8742bbb1c24SHong Zhang   Mat            Pt=ptap->Pt;
875c216dbf3SHong Zhang 
876c216dbf3SHong Zhang   PetscFunctionBegin;
877c216dbf3SHong Zhang   ierr = MatTranspose(P,MAT_REUSE_MATRIX,&Pt);CHKERRQ(ierr);
878c216dbf3SHong Zhang   ierr = MatMatMultNumeric(Pt,A,C);CHKERRQ(ierr);
879f96d37fcSHong Zhang   PetscFunctionReturn(0);
880f96d37fcSHong Zhang }
881f96d37fcSHong Zhang 
8826da69ca6SHong Zhang /* Non-scalable version, use dense axpy */
883f96d37fcSHong Zhang #undef __FUNCT__
8846da69ca6SHong Zhang #define __FUNCT__ "MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable"
8856da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,Mat C)
886f96d37fcSHong Zhang {
887c5af039cSHong Zhang   PetscErrorCode      ierr;
888c5af039cSHong Zhang   Mat_Merge_SeqsToMPI *merge;
889497f5370SHong Zhang   Mat_MPIAIJ          *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
890c5af039cSHong Zhang   Mat_SeqAIJ          *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data;
891c5af039cSHong Zhang   Mat_PtAPMPI         *ptap;
892d6ab1dc0SHong Zhang   PetscInt            *adj,*aJ;
893497f5370SHong Zhang   PetscInt            i,j,k,anz,pnz,row,*cj;
894e745005bSHong Zhang   MatScalar           *ada,*aval,*ca,valtmp;
895c5af039cSHong Zhang   PetscInt            am  =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n;
896ce94432eSBarry Smith   MPI_Comm            comm;
897c5af039cSHong Zhang   PetscMPIInt         size,rank,taga,*len_s;
898c5af039cSHong Zhang   PetscInt            *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci;
899c5af039cSHong Zhang   PetscInt            **buf_ri,**buf_rj;
900c5af039cSHong Zhang   PetscInt            cnz=0,*bj_i,*bi,*bj,bnz,nextcj;  /* bi,bj,ba: local array of C(mpi mat) */
901c5af039cSHong Zhang   MPI_Request         *s_waits,*r_waits;
902c5af039cSHong Zhang   MPI_Status          *status;
903c5af039cSHong Zhang   MatScalar           **abuf_r,*ba_i,*pA,*coa,*ba;
904d6ab1dc0SHong Zhang   PetscInt            *ai,*aj,*coi,*coj;
905a2ea699eSBarry Smith   PetscInt            *poJ,*pdJ;
906c5af039cSHong Zhang   Mat                 A_loc;
907c5af039cSHong Zhang   Mat_SeqAIJ          *a_loc;
908f96d37fcSHong Zhang 
909f96d37fcSHong Zhang   PetscFunctionBegin;
910ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr);
911c5af039cSHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
912c5af039cSHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
913c5af039cSHong Zhang 
914c5af039cSHong Zhang   ptap  = c->ptap;
915c5af039cSHong Zhang   merge = ptap->merge;
916c5af039cSHong Zhang 
917c5af039cSHong Zhang   /* 2) compute numeric C_seq = P_loc^T*A_loc*P - dominating part */
918c5af039cSHong Zhang   /*--------------------------------------------------------------*/
919c5af039cSHong Zhang   /* get data from symbolic products */
920c5af039cSHong Zhang   coi  = merge->coi; coj = merge->coj;
9211795a4d1SJed Brown   ierr = PetscCalloc1((coi[pon]+1),&coa);CHKERRQ(ierr);
922c5af039cSHong Zhang 
923c5af039cSHong Zhang   bi     = merge->bi; bj = merge->bj;
924c5af039cSHong Zhang   owners = merge->rowmap->range;
9251795a4d1SJed Brown   ierr   = PetscCalloc1((bi[cm]+1),&ba);CHKERRQ(ierr);
926c5af039cSHong Zhang 
927c5af039cSHong Zhang   /* get A_loc by taking all local rows of A */
928c5af039cSHong Zhang   A_loc = ptap->A_loc;
929c5af039cSHong Zhang   ierr  = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr);
930c5af039cSHong Zhang   a_loc = (Mat_SeqAIJ*)(A_loc)->data;
931d6ab1dc0SHong Zhang   ai    = a_loc->i;
932d6ab1dc0SHong Zhang   aj    = a_loc->j;
933c5af039cSHong Zhang 
9341795a4d1SJed Brown   ierr = PetscCalloc1((A->cmap->N),&aval);CHKERRQ(ierr); /* non-scalable!!! */
935c5af039cSHong Zhang 
936c5af039cSHong Zhang   for (i=0; i<am; i++) {
937e745005bSHong Zhang     /* 2-a) put A[i,:] to dense array aval */
938d6ab1dc0SHong Zhang     anz = ai[i+1] - ai[i];
939d6ab1dc0SHong Zhang     adj = aj + ai[i];
940d6ab1dc0SHong Zhang     ada = a_loc->a + ai[i];
941c5af039cSHong Zhang     for (j=0; j<anz; j++) {
942e745005bSHong Zhang       aval[adj[j]] = ada[j];
943c5af039cSHong Zhang     }
944c5af039cSHong Zhang 
945c5af039cSHong Zhang     /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */
946c5af039cSHong Zhang     /*--------------------------------------------------------------*/
947c5af039cSHong Zhang     /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */
948c5af039cSHong Zhang     pnz = po->i[i+1] - po->i[i];
949c5af039cSHong Zhang     poJ = po->j + po->i[i];
950c5af039cSHong Zhang     pA  = po->a + po->i[i];
951c5af039cSHong Zhang     for (j=0; j<pnz; j++) {
952c5af039cSHong Zhang       row = poJ[j];
953c5af039cSHong Zhang       cnz = coi[row+1] - coi[row];
954c5af039cSHong Zhang       cj  = coj + coi[row];
955c5af039cSHong Zhang       ca  = coa + coi[row];
956c5af039cSHong Zhang       /* perform dense axpy */
957c5af039cSHong Zhang       valtmp = pA[j];
958c5af039cSHong Zhang       for (k=0; k<cnz; k++) {
959e745005bSHong Zhang         ca[k] += valtmp*aval[cj[k]];
960c5af039cSHong Zhang       }
961c5af039cSHong Zhang       ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
962c5af039cSHong Zhang     }
963c5af039cSHong Zhang 
964c5af039cSHong Zhang     /* put the value into Cd (diagonal part) */
965c5af039cSHong Zhang     pnz = pd->i[i+1] - pd->i[i];
966c5af039cSHong Zhang     pdJ = pd->j + pd->i[i];
967c5af039cSHong Zhang     pA  = pd->a + pd->i[i];
968c5af039cSHong Zhang     for (j=0; j<pnz; j++) {
969c5af039cSHong Zhang       row = pdJ[j];
970c5af039cSHong Zhang       cnz = bi[row+1] - bi[row];
971c5af039cSHong Zhang       cj  = bj + bi[row];
972c5af039cSHong Zhang       ca  = ba + bi[row];
973c5af039cSHong Zhang       /* perform dense axpy */
974c5af039cSHong Zhang       valtmp = pA[j];
975c5af039cSHong Zhang       for (k=0; k<cnz; k++) {
976e745005bSHong Zhang         ca[k] += valtmp*aval[cj[k]];
977c5af039cSHong Zhang       }
978c5af039cSHong Zhang       ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
979c5af039cSHong Zhang     }
980c5af039cSHong Zhang 
981d6ab1dc0SHong Zhang     /* zero the current row of Pt*A */
982d6ab1dc0SHong Zhang     aJ = aj + ai[i];
983e745005bSHong Zhang     for (k=0; k<anz; k++) aval[aJ[k]] = 0.0;
984c5af039cSHong Zhang   }
985c5af039cSHong Zhang 
986c5af039cSHong Zhang   /* 3) send and recv matrix values coa */
987c5af039cSHong Zhang   /*------------------------------------*/
988c5af039cSHong Zhang   buf_ri = merge->buf_ri;
989c5af039cSHong Zhang   buf_rj = merge->buf_rj;
990c5af039cSHong Zhang   len_s  = merge->len_s;
991c5af039cSHong Zhang   ierr   = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr);
992c5af039cSHong Zhang   ierr   = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr);
993c5af039cSHong Zhang 
994dcca6d9dSJed Brown   ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr);
995c5af039cSHong Zhang   for (proc=0,k=0; proc<size; proc++) {
996c5af039cSHong Zhang     if (!len_s[proc]) continue;
997c5af039cSHong Zhang     i    = merge->owners_co[proc];
998c5af039cSHong Zhang     ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr);
999c5af039cSHong Zhang     k++;
1000c5af039cSHong Zhang   }
1001c5af039cSHong Zhang   if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);}
1002c5af039cSHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);}
1003c5af039cSHong Zhang 
1004c5af039cSHong Zhang   ierr = PetscFree2(s_waits,status);CHKERRQ(ierr);
1005c5af039cSHong Zhang   ierr = PetscFree(r_waits);CHKERRQ(ierr);
1006c5af039cSHong Zhang   ierr = PetscFree(coa);CHKERRQ(ierr);
1007c5af039cSHong Zhang 
1008c5af039cSHong Zhang   /* 4) insert local Cseq and received values into Cmpi */
1009c5af039cSHong Zhang   /*----------------------------------------------------*/
1010dcca6d9dSJed Brown   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
1011c5af039cSHong Zhang   for (k=0; k<merge->nrecv; k++) {
1012c36aecf5SHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
1013c5af039cSHong Zhang     nrows       = *(buf_ri_k[k]);
1014c5af039cSHong Zhang     nextrow[k]  = buf_ri_k[k]+1;  /* next row number of k-th recved i-structure */
1015c5af039cSHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
1016c5af039cSHong Zhang   }
1017c5af039cSHong Zhang 
1018c5af039cSHong Zhang   for (i=0; i<cm; i++) {
1019c5af039cSHong Zhang     row  = owners[rank] + i; /* global row index of C_seq */
1020c5af039cSHong Zhang     bj_i = bj + bi[i];  /* col indices of the i-th row of C */
1021c5af039cSHong Zhang     ba_i = ba + bi[i];
1022c5af039cSHong Zhang     bnz  = bi[i+1] - bi[i];
1023c5af039cSHong Zhang     /* add received vals into ba */
1024c5af039cSHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
1025c5af039cSHong Zhang       /* i-th row */
1026c5af039cSHong Zhang       if (i == *nextrow[k]) {
1027c5af039cSHong Zhang         cnz    = *(nextci[k]+1) - *nextci[k];
1028c5af039cSHong Zhang         cj     = buf_rj[k] + *(nextci[k]);
1029c5af039cSHong Zhang         ca     = abuf_r[k] + *(nextci[k]);
1030c5af039cSHong Zhang         nextcj = 0;
1031c5af039cSHong Zhang         for (j=0; nextcj<cnz; j++) {
1032c5af039cSHong Zhang           if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */
1033c5af039cSHong Zhang             ba_i[j] += ca[nextcj++];
1034c5af039cSHong Zhang           }
1035c5af039cSHong Zhang         }
1036c5af039cSHong Zhang         nextrow[k]++; nextci[k]++;
1037c5af039cSHong Zhang         ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
1038c5af039cSHong Zhang       }
1039c5af039cSHong Zhang     }
1040c5af039cSHong Zhang     ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr);
1041c5af039cSHong Zhang   }
1042c5af039cSHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1043c5af039cSHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1044c5af039cSHong Zhang 
1045c5af039cSHong Zhang   ierr = PetscFree(ba);CHKERRQ(ierr);
1046c5af039cSHong Zhang   ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr);
1047c5af039cSHong Zhang   ierr = PetscFree(abuf_r);CHKERRQ(ierr);
1048c5af039cSHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
1049e745005bSHong Zhang   ierr = PetscFree(aval);CHKERRQ(ierr);
1050f96d37fcSHong Zhang   PetscFunctionReturn(0);
1051f96d37fcSHong Zhang }
1052f96d37fcSHong Zhang 
1053c5af039cSHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ() */
1054f96d37fcSHong Zhang #undef __FUNCT__
10552bbb1c24SHong Zhang #define __FUNCT__ "MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable"
10562bbb1c24SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,PetscReal fill,Mat *C)
1057f96d37fcSHong Zhang {
1058f96d37fcSHong Zhang   PetscErrorCode      ierr;
10594e938277SHong Zhang   Mat                 Cmpi,A_loc,POt,PDt;
1060f96d37fcSHong Zhang   Mat_PtAPMPI         *ptap;
10610298fd71SBarry Smith   PetscFreeSpaceList  free_space=NULL,current_space=NULL;
1062f96d37fcSHong Zhang   Mat_MPIAIJ          *p        =(Mat_MPIAIJ*)P->data,*c;
1063f96d37fcSHong Zhang   PetscInt            *pdti,*pdtj,*poti,*potj,*ptJ;
1064f96d37fcSHong Zhang   PetscInt            nnz;
10654e938277SHong Zhang   PetscInt            *lnk,*owners_co,*coi,*coj,i,k,pnz,row;
1066497f5370SHong Zhang   PetscInt            am=A->rmap->n,pn=P->cmap->n;
1067f96d37fcSHong Zhang   PetscBT             lnkbt;
1068ce94432eSBarry Smith   MPI_Comm            comm;
1069f96d37fcSHong Zhang   PetscMPIInt         size,rank,tagi,tagj,*len_si,*len_s,*len_ri;
1070f96d37fcSHong Zhang   PetscInt            **buf_rj,**buf_ri,**buf_ri_k;
1071f96d37fcSHong Zhang   PetscInt            len,proc,*dnz,*onz,*owners;
1072f96d37fcSHong Zhang   PetscInt            nzi,*bi,*bj;
1073f96d37fcSHong Zhang   PetscInt            nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci;
1074f96d37fcSHong Zhang   MPI_Request         *swaits,*rwaits;
1075f96d37fcSHong Zhang   MPI_Status          *sstatus,rstatus;
1076f96d37fcSHong Zhang   Mat_Merge_SeqsToMPI *merge;
1077d6ab1dc0SHong Zhang   PetscInt            *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j;
1078f96d37fcSHong Zhang   PetscReal           afill  =1.0,afill_tmp;
1079c36aecf5SHong Zhang   PetscInt            rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Crmax;
1080f96d37fcSHong Zhang   PetscScalar         *vals;
10814e938277SHong Zhang   Mat_SeqAIJ          *a_loc, *pdt,*pot;
1082f96d37fcSHong Zhang 
1083f96d37fcSHong Zhang   PetscFunctionBegin;
1084ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
1085c5af039cSHong Zhang   /* check if matrix local sizes are compatible */
1086c5af039cSHong Zhang   if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) {
1087c5af039cSHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, A (%D, %D) != P (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend);
1088c5af039cSHong Zhang   }
1089c5af039cSHong Zhang 
1090f96d37fcSHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1091f96d37fcSHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1092f96d37fcSHong Zhang 
1093f96d37fcSHong Zhang   /* create struct Mat_PtAPMPI and attached it to C later */
1094b00a9115SJed Brown   ierr = PetscNew(&ptap);CHKERRQ(ierr);
1095f96d37fcSHong Zhang 
1096f96d37fcSHong Zhang   /* get A_loc by taking all local rows of A */
1097f96d37fcSHong Zhang   ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr);
10982205254eSKarl Rupp 
1099c5af039cSHong Zhang   ptap->A_loc = A_loc;
11002205254eSKarl Rupp 
11011c7d5954SHong Zhang   a_loc = (Mat_SeqAIJ*)(A_loc)->data;
1102d6ab1dc0SHong Zhang   ai    = a_loc->i;
1103d6ab1dc0SHong Zhang   aj    = a_loc->j;
1104f96d37fcSHong Zhang 
1105f96d37fcSHong Zhang   /* determine symbolic Co=(p->B)^T*A - send to others */
1106f96d37fcSHong Zhang   /*----------------------------------------------------*/
11074e938277SHong Zhang   ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr);
11084e938277SHong Zhang   pdt  = (Mat_SeqAIJ*)PDt->data;
11094e938277SHong Zhang   pdti = pdt->i; pdtj = pdt->j;
11104e938277SHong Zhang 
11114e938277SHong Zhang   ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr);
11124e938277SHong Zhang   pot  = (Mat_SeqAIJ*)POt->data;
11134e938277SHong Zhang   poti = pot->i; potj = pot->j;
1114f96d37fcSHong Zhang 
1115f96d37fcSHong Zhang   /* then, compute symbolic Co = (p->B)^T*A */
11162205254eSKarl Rupp   pon    = (p->B)->cmap->n; /* total num of rows to be sent to other processors >= (num of nonzero rows of C_seq) - pn */
1117785e854fSJed Brown   ierr   = PetscMalloc1((pon+1),&coi);CHKERRQ(ierr);
1118f96d37fcSHong Zhang   coi[0] = 0;
1119f96d37fcSHong Zhang 
1120f96d37fcSHong Zhang   /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */
1121d6ab1dc0SHong Zhang   nnz           = fill*(poti[pon] + ai[am]);
1122a2ea699eSBarry Smith   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
1123f96d37fcSHong Zhang   current_space = free_space;
112419f0e57aSHong Zhang 
1125f96d37fcSHong Zhang   /* create and initialize a linked list */
11264e938277SHong Zhang   i     = PetscMax(pdt->rmax,pot->rmax);
1127c36aecf5SHong Zhang   Crmax = i*a_loc->rmax*size;
11284e938277SHong Zhang   if (!Crmax || Crmax > aN) Crmax = aN;
11294e938277SHong Zhang   ierr = PetscLLCondensedCreate(Crmax,aN,&lnk,&lnkbt);CHKERRQ(ierr);
1130f96d37fcSHong Zhang 
1131f96d37fcSHong Zhang   for (i=0; i<pon; i++) {
1132f96d37fcSHong Zhang     pnz = poti[i+1] - poti[i];
1133f96d37fcSHong Zhang     ptJ = potj + poti[i];
1134f96d37fcSHong Zhang     for (j=0; j<pnz; j++) {
1135f96d37fcSHong Zhang       row  = ptJ[j]; /* row of A_loc == col of Pot */
1136d6ab1dc0SHong Zhang       anz  = ai[row+1] - ai[row];
1137d6ab1dc0SHong Zhang       Jptr = aj + ai[row];
1138f96d37fcSHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
1139d6ab1dc0SHong Zhang       ierr = PetscLLCondensedAddSorted(anz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
1140f96d37fcSHong Zhang     }
11414e938277SHong Zhang     nnz = lnk[0];
1142f96d37fcSHong Zhang 
1143f96d37fcSHong Zhang     /* If free space is not available, double the total space in the list */
1144f96d37fcSHong Zhang     if (current_space->local_remaining<nnz) {
1145f96d37fcSHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
1146f96d37fcSHong Zhang       nspacedouble++;
1147f96d37fcSHong Zhang     }
1148f96d37fcSHong Zhang 
1149f96d37fcSHong Zhang     /* Copy data into free space, and zero out denserows */
11504e938277SHong Zhang     ierr = PetscLLCondensedClean(aN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
11512205254eSKarl Rupp 
1152f96d37fcSHong Zhang     current_space->array           += nnz;
1153f96d37fcSHong Zhang     current_space->local_used      += nnz;
1154f96d37fcSHong Zhang     current_space->local_remaining -= nnz;
11552205254eSKarl Rupp 
1156f96d37fcSHong Zhang     coi[i+1] = coi[i] + nnz;
1157f96d37fcSHong Zhang   }
1158f96d37fcSHong Zhang 
1159785e854fSJed Brown   ierr = PetscMalloc1((coi[pon]+1),&coj);CHKERRQ(ierr);
1160f96d37fcSHong Zhang   ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr);
11612205254eSKarl Rupp 
1162118727c9SMark F. Adams   afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1);
1163f96d37fcSHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
1164f96d37fcSHong Zhang 
1165f96d37fcSHong Zhang   /* send j-array (coj) of Co to other processors */
1166f96d37fcSHong Zhang   /*----------------------------------------------*/
1167f96d37fcSHong Zhang   /* determine row ownership */
1168b00a9115SJed Brown   ierr = PetscNew(&merge);CHKERRQ(ierr);
1169f96d37fcSHong Zhang   ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr);
11702205254eSKarl Rupp 
1171f96d37fcSHong Zhang   merge->rowmap->n  = pn;
1172f96d37fcSHong Zhang   merge->rowmap->bs = 1;
11732205254eSKarl Rupp 
1174f96d37fcSHong Zhang   ierr   = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr);
1175f96d37fcSHong Zhang   owners = merge->rowmap->range;
1176f96d37fcSHong Zhang 
1177f96d37fcSHong Zhang   /* determine the number of messages to send, their lengths */
11781795a4d1SJed Brown   ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr);
1179785e854fSJed Brown   ierr = PetscMalloc1(size,&merge->len_s);CHKERRQ(ierr);
11802205254eSKarl Rupp 
1181f96d37fcSHong Zhang   len_s        = merge->len_s;
1182f96d37fcSHong Zhang   merge->nsend = 0;
1183f96d37fcSHong Zhang 
1184785e854fSJed Brown   ierr = PetscMalloc1((size+2),&owners_co);CHKERRQ(ierr);
1185f96d37fcSHong Zhang   ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr);
1186f96d37fcSHong Zhang 
1187f96d37fcSHong Zhang   proc = 0;
1188f96d37fcSHong Zhang   for (i=0; i<pon; i++) {
1189f96d37fcSHong Zhang     while (prmap[i] >= owners[proc+1]) proc++;
1190f96d37fcSHong Zhang     len_si[proc]++;  /* num of rows in Co to be sent to [proc] */
1191f96d37fcSHong Zhang     len_s[proc] += coi[i+1] - coi[i];
1192f96d37fcSHong Zhang   }
1193f96d37fcSHong Zhang 
1194f96d37fcSHong Zhang   len          = 0; /* max length of buf_si[] */
1195f96d37fcSHong Zhang   owners_co[0] = 0;
1196f96d37fcSHong Zhang   for (proc=0; proc<size; proc++) {
1197f96d37fcSHong Zhang     owners_co[proc+1] = owners_co[proc] + len_si[proc];
1198f96d37fcSHong Zhang     if (len_si[proc]) {
1199f96d37fcSHong Zhang       merge->nsend++;
1200f96d37fcSHong Zhang       len_si[proc] = 2*(len_si[proc] + 1);
1201f96d37fcSHong Zhang       len         += len_si[proc];
1202f96d37fcSHong Zhang     }
1203f96d37fcSHong Zhang   }
1204f96d37fcSHong Zhang 
1205f96d37fcSHong Zhang   /* determine the number and length of messages to receive for coi and coj  */
12060298fd71SBarry Smith   ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr);
1207f96d37fcSHong Zhang   ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr);
1208f96d37fcSHong Zhang 
1209f96d37fcSHong Zhang   /* post the Irecv and Isend of coj */
1210f96d37fcSHong Zhang   ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr);
1211f96d37fcSHong Zhang   ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr);
1212785e854fSJed Brown   ierr = PetscMalloc1((merge->nsend+1),&swaits);CHKERRQ(ierr);
1213f96d37fcSHong Zhang   for (proc=0, k=0; proc<size; proc++) {
1214f96d37fcSHong Zhang     if (!len_s[proc]) continue;
1215f96d37fcSHong Zhang     i    = owners_co[proc];
1216f96d37fcSHong Zhang     ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr);
1217f96d37fcSHong Zhang     k++;
1218f96d37fcSHong Zhang   }
1219f96d37fcSHong Zhang 
1220f96d37fcSHong Zhang   /* receives and sends of coj are complete */
1221785e854fSJed Brown   ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr);
1222f96d37fcSHong Zhang   for (i=0; i<merge->nrecv; i++) {
1223c280ed6aSJed Brown     PetscMPIInt icompleted;
1224c280ed6aSJed Brown     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
1225f96d37fcSHong Zhang   }
1226f96d37fcSHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
1227f96d37fcSHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
1228f96d37fcSHong Zhang 
1229f96d37fcSHong Zhang   /* send and recv coi */
1230f96d37fcSHong Zhang   /*-------------------*/
1231f96d37fcSHong Zhang   ierr   = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr);
1232f96d37fcSHong Zhang   ierr   = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr);
1233785e854fSJed Brown   ierr   = PetscMalloc1((len+1),&buf_s);CHKERRQ(ierr);
1234f96d37fcSHong Zhang   buf_si = buf_s;  /* points to the beginning of k-th msg to be sent */
1235f96d37fcSHong Zhang   for (proc=0,k=0; proc<size; proc++) {
1236f96d37fcSHong Zhang     if (!len_s[proc]) continue;
1237f96d37fcSHong Zhang     /* form outgoing message for i-structure:
1238f96d37fcSHong Zhang          buf_si[0]:                 nrows to be sent
1239f96d37fcSHong Zhang                [1:nrows]:           row index (global)
1240f96d37fcSHong Zhang                [nrows+1:2*nrows+1]: i-structure index
1241f96d37fcSHong Zhang     */
1242f96d37fcSHong Zhang     /*-------------------------------------------*/
1243f96d37fcSHong Zhang     nrows       = len_si[proc]/2 - 1;
1244f96d37fcSHong Zhang     buf_si_i    = buf_si + nrows+1;
1245f96d37fcSHong Zhang     buf_si[0]   = nrows;
1246f96d37fcSHong Zhang     buf_si_i[0] = 0;
1247f96d37fcSHong Zhang     nrows       = 0;
1248f96d37fcSHong Zhang     for (i=owners_co[proc]; i<owners_co[proc+1]; i++) {
1249f96d37fcSHong Zhang       nzi               = coi[i+1] - coi[i];
1250f96d37fcSHong Zhang       buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */
1251f96d37fcSHong Zhang       buf_si[nrows+1]   = prmap[i] -owners[proc]; /* local row index */
1252f96d37fcSHong Zhang       nrows++;
1253f96d37fcSHong Zhang     }
1254f96d37fcSHong Zhang     ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr);
1255f96d37fcSHong Zhang     k++;
1256f96d37fcSHong Zhang     buf_si += len_si[proc];
1257f96d37fcSHong Zhang   }
1258f96d37fcSHong Zhang   i = merge->nrecv;
1259f96d37fcSHong Zhang   while (i--) {
1260c280ed6aSJed Brown     PetscMPIInt icompleted;
1261c280ed6aSJed Brown     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
1262f96d37fcSHong Zhang   }
1263f96d37fcSHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
1264f96d37fcSHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
1265f96d37fcSHong Zhang   ierr = PetscFree(len_si);CHKERRQ(ierr);
1266f96d37fcSHong Zhang   ierr = PetscFree(len_ri);CHKERRQ(ierr);
1267f96d37fcSHong Zhang   ierr = PetscFree(swaits);CHKERRQ(ierr);
1268f96d37fcSHong Zhang   ierr = PetscFree(sstatus);CHKERRQ(ierr);
1269f96d37fcSHong Zhang   ierr = PetscFree(buf_s);CHKERRQ(ierr);
1270f96d37fcSHong Zhang 
1271f96d37fcSHong Zhang   /* compute the local portion of C (mpi mat) */
1272f96d37fcSHong Zhang   /*------------------------------------------*/
1273f96d37fcSHong Zhang   /* allocate bi array and free space for accumulating nonzero column info */
1274785e854fSJed Brown   ierr  = PetscMalloc1((pn+1),&bi);CHKERRQ(ierr);
1275f96d37fcSHong Zhang   bi[0] = 0;
1276f96d37fcSHong Zhang 
1277c36aecf5SHong Zhang   /* set initial free space to be fill*(nnz(P) + nnz(A)) */
1278d6ab1dc0SHong Zhang   nnz           = fill*(pdti[pn] + poti[pon] + ai[am]);
1279a2ea699eSBarry Smith   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
1280f96d37fcSHong Zhang   current_space = free_space;
1281f96d37fcSHong Zhang 
1282dcca6d9dSJed Brown   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
1283f96d37fcSHong Zhang   for (k=0; k<merge->nrecv; k++) {
1284f96d37fcSHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
1285f96d37fcSHong Zhang     nrows       = *buf_ri_k[k];
1286f96d37fcSHong Zhang     nextrow[k]  = buf_ri_k[k] + 1;  /* next row number of k-th recved i-structure */
1287f96d37fcSHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
1288f96d37fcSHong Zhang   }
1289f96d37fcSHong Zhang 
12901c7d5954SHong Zhang   ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr);
1291f96d37fcSHong Zhang   rmax = 0;
1292f96d37fcSHong Zhang   for (i=0; i<pn; i++) {
1293f96d37fcSHong Zhang     /* add pdt[i,:]*AP into lnk */
1294f96d37fcSHong Zhang     pnz = pdti[i+1] - pdti[i];
1295f96d37fcSHong Zhang     ptJ = pdtj + pdti[i];
1296f96d37fcSHong Zhang     for (j=0; j<pnz; j++) {
1297f96d37fcSHong Zhang       row  = ptJ[j];  /* row of AP == col of Pt */
1298d6ab1dc0SHong Zhang       anz  = ai[row+1] - ai[row];
1299d6ab1dc0SHong Zhang       Jptr = aj + ai[row];
1300f96d37fcSHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
1301d6ab1dc0SHong Zhang       ierr = PetscLLCondensedAddSorted(anz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
1302f96d37fcSHong Zhang     }
13034e938277SHong Zhang 
1304f96d37fcSHong Zhang     /* add received col data into lnk */
1305f96d37fcSHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
1306f96d37fcSHong Zhang       if (i == *nextrow[k]) { /* i-th row */
1307f96d37fcSHong Zhang         nzi  = *(nextci[k]+1) - *nextci[k];
1308f96d37fcSHong Zhang         Jptr = buf_rj[k] + *nextci[k];
13094e938277SHong Zhang         ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr);
1310f96d37fcSHong Zhang         nextrow[k]++; nextci[k]++;
1311f96d37fcSHong Zhang       }
1312f96d37fcSHong Zhang     }
13134e938277SHong Zhang     nnz = lnk[0];
1314f96d37fcSHong Zhang 
1315f96d37fcSHong Zhang     /* if free space is not available, make more free space */
1316f96d37fcSHong Zhang     if (current_space->local_remaining<nnz) {
1317f96d37fcSHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
1318f96d37fcSHong Zhang       nspacedouble++;
1319f96d37fcSHong Zhang     }
1320f96d37fcSHong Zhang     /* copy data into free space, then initialize lnk */
13214e938277SHong Zhang     ierr = PetscLLCondensedClean(aN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
1322f96d37fcSHong Zhang     ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr);
13232205254eSKarl Rupp 
1324f96d37fcSHong Zhang     current_space->array           += nnz;
1325f96d37fcSHong Zhang     current_space->local_used      += nnz;
1326f96d37fcSHong Zhang     current_space->local_remaining -= nnz;
13272205254eSKarl Rupp 
1328f96d37fcSHong Zhang     bi[i+1] = bi[i] + nnz;
1329f96d37fcSHong Zhang     if (nnz > rmax) rmax = nnz;
1330f96d37fcSHong Zhang   }
1331f96d37fcSHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
1332f96d37fcSHong Zhang 
1333785e854fSJed Brown   ierr = PetscMalloc1((bi[pn]+1),&bj);CHKERRQ(ierr);
1334f96d37fcSHong Zhang   ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr);
13352205254eSKarl Rupp 
1336118727c9SMark F. Adams   afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1);
1337f96d37fcSHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
1338d6ab1dc0SHong Zhang   ierr = PetscLLCondensedDestroy(lnk,lnkbt);CHKERRQ(ierr);
13394e938277SHong Zhang   ierr = MatDestroy(&POt);CHKERRQ(ierr);
13404e938277SHong Zhang   ierr = MatDestroy(&PDt);CHKERRQ(ierr);
1341f96d37fcSHong Zhang 
13421c7d5954SHong Zhang   /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part   */
13431c7d5954SHong Zhang   /*----------------------------------------------------------------------------------*/
13441795a4d1SJed Brown   ierr = PetscCalloc1(rmax+1,&vals);CHKERRQ(ierr);
1345f96d37fcSHong Zhang 
1346f96d37fcSHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
1347f96d37fcSHong Zhang   ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
134833d57670SJed Brown   ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(A->cmap->bs));CHKERRQ(ierr);
1349f96d37fcSHong Zhang   ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr);
1350f96d37fcSHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
1351f96d37fcSHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
1352f96d37fcSHong Zhang   ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr);
1353f96d37fcSHong Zhang   for (i=0; i<pn; i++) {
1354f96d37fcSHong Zhang     row  = i + rstart;
1355f96d37fcSHong Zhang     nnz  = bi[i+1] - bi[i];
1356f96d37fcSHong Zhang     Jptr = bj + bi[i];
1357f96d37fcSHong Zhang     ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,vals,INSERT_VALUES);CHKERRQ(ierr);
1358f96d37fcSHong Zhang   }
1359f96d37fcSHong Zhang   ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1360f96d37fcSHong Zhang   ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1361f96d37fcSHong Zhang   ierr = PetscFree(vals);CHKERRQ(ierr);
1362f96d37fcSHong Zhang 
1363f96d37fcSHong Zhang   merge->bi        = bi;
1364f96d37fcSHong Zhang   merge->bj        = bj;
1365f96d37fcSHong Zhang   merge->coi       = coi;
1366f96d37fcSHong Zhang   merge->coj       = coj;
1367f96d37fcSHong Zhang   merge->buf_ri    = buf_ri;
1368f96d37fcSHong Zhang   merge->buf_rj    = buf_rj;
1369f96d37fcSHong Zhang   merge->owners_co = owners_co;
1370f96d37fcSHong Zhang   merge->destroy   = Cmpi->ops->destroy;
1371f96d37fcSHong Zhang   merge->duplicate = Cmpi->ops->duplicate;
1372f96d37fcSHong Zhang 
13736da69ca6SHong Zhang   Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable;
1374c5af039cSHong Zhang   Cmpi->ops->destroy                 = MatDestroy_MPIAIJ_PtAP;
1375f96d37fcSHong Zhang 
1376f96d37fcSHong Zhang   /* attach the supporting struct to Cmpi for reuse */
1377f96d37fcSHong Zhang   c           = (Mat_MPIAIJ*)Cmpi->data;
1378f96d37fcSHong Zhang   c->ptap     = ptap;
13790298fd71SBarry Smith   ptap->api   = NULL;
13800298fd71SBarry Smith   ptap->apj   = NULL;
1381f96d37fcSHong Zhang   ptap->merge = merge;
1382d6ab1dc0SHong Zhang   ptap->rmax  = rmax;
1383d6ab1dc0SHong Zhang 
1384d6ab1dc0SHong Zhang   *C = Cmpi;
1385d6ab1dc0SHong Zhang #if defined(PETSC_USE_INFO)
1386d6ab1dc0SHong Zhang   if (bi[pn] != 0) {
138757622a8eSBarry Smith     ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr);
138857622a8eSBarry Smith     ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr);
1389d6ab1dc0SHong Zhang   } else {
1390d6ab1dc0SHong Zhang     ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr);
1391d6ab1dc0SHong Zhang   }
1392d6ab1dc0SHong Zhang #endif
1393d6ab1dc0SHong Zhang   PetscFunctionReturn(0);
1394d6ab1dc0SHong Zhang }
1395d6ab1dc0SHong Zhang 
1396d6ab1dc0SHong Zhang #undef __FUNCT__
13976da69ca6SHong Zhang #define __FUNCT__ "MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ"
13986da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ(Mat P,Mat A,Mat C)
1399d6ab1dc0SHong Zhang {
1400d6ab1dc0SHong Zhang   PetscErrorCode      ierr;
1401d6ab1dc0SHong Zhang   Mat_Merge_SeqsToMPI *merge;
1402d6ab1dc0SHong Zhang   Mat_MPIAIJ          *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
1403d6ab1dc0SHong Zhang   Mat_SeqAIJ          *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data;
1404d6ab1dc0SHong Zhang   Mat_PtAPMPI         *ptap;
1405e745005bSHong Zhang   PetscInt            *adj;
1406e745005bSHong Zhang   PetscInt            i,j,k,anz,pnz,row,*cj,nexta;
1407e745005bSHong Zhang   MatScalar           *ada,*ca,valtmp;
1408d6ab1dc0SHong Zhang   PetscInt            am  =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n;
1409ce94432eSBarry Smith   MPI_Comm            comm;
1410d6ab1dc0SHong Zhang   PetscMPIInt         size,rank,taga,*len_s;
1411d6ab1dc0SHong Zhang   PetscInt            *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci;
1412d6ab1dc0SHong Zhang   PetscInt            **buf_ri,**buf_rj;
1413d6ab1dc0SHong Zhang   PetscInt            cnz=0,*bj_i,*bi,*bj,bnz,nextcj;  /* bi,bj,ba: local array of C(mpi mat) */
1414d6ab1dc0SHong Zhang   MPI_Request         *s_waits,*r_waits;
1415d6ab1dc0SHong Zhang   MPI_Status          *status;
1416d6ab1dc0SHong Zhang   MatScalar           **abuf_r,*ba_i,*pA,*coa,*ba;
1417d6ab1dc0SHong Zhang   PetscInt            *ai,*aj,*coi,*coj;
1418a2ea699eSBarry Smith   PetscInt            *poJ,*pdJ;
1419d6ab1dc0SHong Zhang   Mat                 A_loc;
1420d6ab1dc0SHong Zhang   Mat_SeqAIJ          *a_loc;
1421d6ab1dc0SHong Zhang 
1422d6ab1dc0SHong Zhang   PetscFunctionBegin;
1423ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr);
1424d6ab1dc0SHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1425d6ab1dc0SHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1426d6ab1dc0SHong Zhang 
1427d6ab1dc0SHong Zhang   ptap  = c->ptap;
1428d6ab1dc0SHong Zhang   merge = ptap->merge;
1429d6ab1dc0SHong Zhang 
1430e745005bSHong Zhang   /* 2) compute numeric C_seq = P_loc^T*A_loc */
1431e745005bSHong Zhang   /*------------------------------------------*/
1432d6ab1dc0SHong Zhang   /* get data from symbolic products */
1433d6ab1dc0SHong Zhang   coi    = merge->coi; coj = merge->coj;
14341795a4d1SJed Brown   ierr   = PetscCalloc1((coi[pon]+1),&coa);CHKERRQ(ierr);
1435d6ab1dc0SHong Zhang   bi     = merge->bi; bj = merge->bj;
1436d6ab1dc0SHong Zhang   owners = merge->rowmap->range;
14371795a4d1SJed Brown   ierr   = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr);
1438d6ab1dc0SHong Zhang 
1439d6ab1dc0SHong Zhang   /* get A_loc by taking all local rows of A */
1440d6ab1dc0SHong Zhang   A_loc = ptap->A_loc;
1441d6ab1dc0SHong Zhang   ierr  = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr);
1442d6ab1dc0SHong Zhang   a_loc = (Mat_SeqAIJ*)(A_loc)->data;
1443d6ab1dc0SHong Zhang   ai    = a_loc->i;
1444d6ab1dc0SHong Zhang   aj    = a_loc->j;
1445d6ab1dc0SHong Zhang 
1446d6ab1dc0SHong Zhang   for (i=0; i<am; i++) {
1447d6ab1dc0SHong Zhang     anz = ai[i+1] - ai[i];
1448d6ab1dc0SHong Zhang     adj = aj + ai[i];
1449d6ab1dc0SHong Zhang     ada = a_loc->a + ai[i];
1450d6ab1dc0SHong Zhang 
1451d6ab1dc0SHong Zhang     /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */
1452e745005bSHong Zhang     /*-------------------------------------------------------------*/
1453d6ab1dc0SHong Zhang     /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */
1454d6ab1dc0SHong Zhang     pnz = po->i[i+1] - po->i[i];
1455d6ab1dc0SHong Zhang     poJ = po->j + po->i[i];
1456d6ab1dc0SHong Zhang     pA  = po->a + po->i[i];
1457d6ab1dc0SHong Zhang     for (j=0; j<pnz; j++) {
1458d6ab1dc0SHong Zhang       row = poJ[j];
1459d6ab1dc0SHong Zhang       cj  = coj + coi[row];
1460d6ab1dc0SHong Zhang       ca  = coa + coi[row];
1461e745005bSHong Zhang       /* perform sparse axpy */
1462e745005bSHong Zhang       nexta  = 0;
1463d6ab1dc0SHong Zhang       valtmp = pA[j];
1464e745005bSHong Zhang       for (k=0; nexta<anz; k++) {
1465e745005bSHong Zhang         if (cj[k] == adj[nexta]) {
1466e745005bSHong Zhang           ca[k] += valtmp*ada[nexta];
1467e745005bSHong Zhang           nexta++;
1468d6ab1dc0SHong Zhang         }
1469e745005bSHong Zhang       }
1470e745005bSHong Zhang       ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr);
1471d6ab1dc0SHong Zhang     }
1472d6ab1dc0SHong Zhang 
1473d6ab1dc0SHong Zhang     /* put the value into Cd (diagonal part) */
1474d6ab1dc0SHong Zhang     pnz = pd->i[i+1] - pd->i[i];
1475d6ab1dc0SHong Zhang     pdJ = pd->j + pd->i[i];
1476d6ab1dc0SHong Zhang     pA  = pd->a + pd->i[i];
1477d6ab1dc0SHong Zhang     for (j=0; j<pnz; j++) {
1478d6ab1dc0SHong Zhang       row = pdJ[j];
1479d6ab1dc0SHong Zhang       cj  = bj + bi[row];
1480d6ab1dc0SHong Zhang       ca  = ba + bi[row];
1481e745005bSHong Zhang       /* perform sparse axpy */
1482e745005bSHong Zhang       nexta  = 0;
1483d6ab1dc0SHong Zhang       valtmp = pA[j];
1484e745005bSHong Zhang       for (k=0; nexta<anz; k++) {
1485e745005bSHong Zhang         if (cj[k] == adj[nexta]) {
1486e745005bSHong Zhang           ca[k] += valtmp*ada[nexta];
1487e745005bSHong Zhang           nexta++;
1488d6ab1dc0SHong Zhang         }
1489e745005bSHong Zhang       }
1490e745005bSHong Zhang       ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr);
1491d6ab1dc0SHong Zhang     }
1492d6ab1dc0SHong Zhang   }
1493d6ab1dc0SHong Zhang 
1494d6ab1dc0SHong Zhang   /* 3) send and recv matrix values coa */
1495d6ab1dc0SHong Zhang   /*------------------------------------*/
1496d6ab1dc0SHong Zhang   buf_ri = merge->buf_ri;
1497d6ab1dc0SHong Zhang   buf_rj = merge->buf_rj;
1498d6ab1dc0SHong Zhang   len_s  = merge->len_s;
1499d6ab1dc0SHong Zhang   ierr   = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr);
1500d6ab1dc0SHong Zhang   ierr   = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr);
1501d6ab1dc0SHong Zhang 
1502dcca6d9dSJed Brown   ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr);
1503d6ab1dc0SHong Zhang   for (proc=0,k=0; proc<size; proc++) {
1504d6ab1dc0SHong Zhang     if (!len_s[proc]) continue;
1505d6ab1dc0SHong Zhang     i    = merge->owners_co[proc];
1506d6ab1dc0SHong Zhang     ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr);
1507d6ab1dc0SHong Zhang     k++;
1508d6ab1dc0SHong Zhang   }
1509d6ab1dc0SHong Zhang   if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);}
1510d6ab1dc0SHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);}
1511d6ab1dc0SHong Zhang 
1512d6ab1dc0SHong Zhang   ierr = PetscFree2(s_waits,status);CHKERRQ(ierr);
1513d6ab1dc0SHong Zhang   ierr = PetscFree(r_waits);CHKERRQ(ierr);
1514d6ab1dc0SHong Zhang   ierr = PetscFree(coa);CHKERRQ(ierr);
1515d6ab1dc0SHong Zhang 
1516d6ab1dc0SHong Zhang   /* 4) insert local Cseq and received values into Cmpi */
1517d6ab1dc0SHong Zhang   /*----------------------------------------------------*/
1518dcca6d9dSJed Brown   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
1519d6ab1dc0SHong Zhang   for (k=0; k<merge->nrecv; k++) {
1520e745005bSHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
1521d6ab1dc0SHong Zhang     nrows       = *(buf_ri_k[k]);
1522d6ab1dc0SHong Zhang     nextrow[k]  = buf_ri_k[k]+1;  /* next row number of k-th recved i-structure */
1523d6ab1dc0SHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
1524d6ab1dc0SHong Zhang   }
1525d6ab1dc0SHong Zhang 
1526d6ab1dc0SHong Zhang   for (i=0; i<cm; i++) {
1527d6ab1dc0SHong Zhang     row  = owners[rank] + i; /* global row index of C_seq */
1528d6ab1dc0SHong Zhang     bj_i = bj + bi[i];  /* col indices of the i-th row of C */
1529d6ab1dc0SHong Zhang     ba_i = ba + bi[i];
1530d6ab1dc0SHong Zhang     bnz  = bi[i+1] - bi[i];
1531d6ab1dc0SHong Zhang     /* add received vals into ba */
1532d6ab1dc0SHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
1533d6ab1dc0SHong Zhang       /* i-th row */
1534d6ab1dc0SHong Zhang       if (i == *nextrow[k]) {
1535d6ab1dc0SHong Zhang         cnz    = *(nextci[k]+1) - *nextci[k];
1536d6ab1dc0SHong Zhang         cj     = buf_rj[k] + *(nextci[k]);
1537d6ab1dc0SHong Zhang         ca     = abuf_r[k] + *(nextci[k]);
1538d6ab1dc0SHong Zhang         nextcj = 0;
1539d6ab1dc0SHong Zhang         for (j=0; nextcj<cnz; j++) {
1540d6ab1dc0SHong Zhang           if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */
1541d6ab1dc0SHong Zhang             ba_i[j] += ca[nextcj++];
1542d6ab1dc0SHong Zhang           }
1543d6ab1dc0SHong Zhang         }
1544d6ab1dc0SHong Zhang         nextrow[k]++; nextci[k]++;
1545d6ab1dc0SHong Zhang         ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
1546d6ab1dc0SHong Zhang       }
1547d6ab1dc0SHong Zhang     }
1548d6ab1dc0SHong Zhang     ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr);
1549d6ab1dc0SHong Zhang   }
1550d6ab1dc0SHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1551d6ab1dc0SHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1552d6ab1dc0SHong Zhang 
1553d6ab1dc0SHong Zhang   ierr = PetscFree(ba);CHKERRQ(ierr);
1554d6ab1dc0SHong Zhang   ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr);
1555d6ab1dc0SHong Zhang   ierr = PetscFree(abuf_r);CHKERRQ(ierr);
1556d6ab1dc0SHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
1557d6ab1dc0SHong Zhang   PetscFunctionReturn(0);
1558d6ab1dc0SHong Zhang }
1559d6ab1dc0SHong Zhang 
15602bbb1c24SHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ();
15612bbb1c24SHong Zhang    differ from MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable in using LLCondensedCreate_Scalable() */
1562d6ab1dc0SHong Zhang #undef __FUNCT__
15636da69ca6SHong Zhang #define __FUNCT__ "MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ"
15646da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(Mat P,Mat A,PetscReal fill,Mat *C)
1565d6ab1dc0SHong Zhang {
1566d6ab1dc0SHong Zhang   PetscErrorCode      ierr;
1567d6ab1dc0SHong Zhang   Mat                 Cmpi,A_loc,POt,PDt;
1568d6ab1dc0SHong Zhang   Mat_PtAPMPI         *ptap;
15690298fd71SBarry Smith   PetscFreeSpaceList  free_space=NULL,current_space=NULL;
1570d6ab1dc0SHong Zhang   Mat_MPIAIJ          *p        =(Mat_MPIAIJ*)P->data,*c;
1571d6ab1dc0SHong Zhang   PetscInt            *pdti,*pdtj,*poti,*potj,*ptJ;
1572d6ab1dc0SHong Zhang   PetscInt            nnz;
1573d6ab1dc0SHong Zhang   PetscInt            *lnk,*owners_co,*coi,*coj,i,k,pnz,row;
1574d6ab1dc0SHong Zhang   PetscInt            am  =A->rmap->n,pn=P->cmap->n;
1575ce94432eSBarry Smith   MPI_Comm            comm;
1576d6ab1dc0SHong Zhang   PetscMPIInt         size,rank,tagi,tagj,*len_si,*len_s,*len_ri;
1577d6ab1dc0SHong Zhang   PetscInt            **buf_rj,**buf_ri,**buf_ri_k;
1578d6ab1dc0SHong Zhang   PetscInt            len,proc,*dnz,*onz,*owners;
1579d6ab1dc0SHong Zhang   PetscInt            nzi,*bi,*bj;
1580d6ab1dc0SHong Zhang   PetscInt            nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci;
1581d6ab1dc0SHong Zhang   MPI_Request         *swaits,*rwaits;
1582d6ab1dc0SHong Zhang   MPI_Status          *sstatus,rstatus;
1583d6ab1dc0SHong Zhang   Mat_Merge_SeqsToMPI *merge;
1584d6ab1dc0SHong Zhang   PetscInt            *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j;
1585d6ab1dc0SHong Zhang   PetscReal           afill  =1.0,afill_tmp;
1586c36aecf5SHong Zhang   PetscInt            rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Crmax;
1587d6ab1dc0SHong Zhang   PetscScalar         *vals;
1588d6ab1dc0SHong Zhang   Mat_SeqAIJ          *a_loc, *pdt,*pot;
1589d6ab1dc0SHong Zhang 
1590d6ab1dc0SHong Zhang   PetscFunctionBegin;
1591ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
1592d6ab1dc0SHong Zhang   /* check if matrix local sizes are compatible */
1593d6ab1dc0SHong Zhang   if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) {
1594d6ab1dc0SHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, A (%D, %D) != P (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend);
1595d6ab1dc0SHong Zhang   }
1596d6ab1dc0SHong Zhang 
1597d6ab1dc0SHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1598d6ab1dc0SHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1599d6ab1dc0SHong Zhang 
1600d6ab1dc0SHong Zhang   /* create struct Mat_PtAPMPI and attached it to C later */
1601b00a9115SJed Brown   ierr = PetscNew(&ptap);CHKERRQ(ierr);
1602d6ab1dc0SHong Zhang 
1603d6ab1dc0SHong Zhang   /* get A_loc by taking all local rows of A */
1604d6ab1dc0SHong Zhang   ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr);
16052205254eSKarl Rupp 
1606d6ab1dc0SHong Zhang   ptap->A_loc = A_loc;
1607d6ab1dc0SHong Zhang   a_loc       = (Mat_SeqAIJ*)(A_loc)->data;
1608d6ab1dc0SHong Zhang   ai          = a_loc->i;
1609d6ab1dc0SHong Zhang   aj          = a_loc->j;
1610d6ab1dc0SHong Zhang 
1611d6ab1dc0SHong Zhang   /* determine symbolic Co=(p->B)^T*A - send to others */
1612d6ab1dc0SHong Zhang   /*----------------------------------------------------*/
1613d6ab1dc0SHong Zhang   ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr);
1614d6ab1dc0SHong Zhang   pdt  = (Mat_SeqAIJ*)PDt->data;
1615d6ab1dc0SHong Zhang   pdti = pdt->i; pdtj = pdt->j;
1616d6ab1dc0SHong Zhang 
1617d6ab1dc0SHong Zhang   ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr);
1618d6ab1dc0SHong Zhang   pot  = (Mat_SeqAIJ*)POt->data;
1619d6ab1dc0SHong Zhang   poti = pot->i; potj = pot->j;
1620d6ab1dc0SHong Zhang 
1621d6ab1dc0SHong Zhang   /* then, compute symbolic Co = (p->B)^T*A */
1622d6ab1dc0SHong Zhang   pon    = (p->B)->cmap->n; /* total num of rows to be sent to other processors
1623d6ab1dc0SHong Zhang                          >= (num of nonzero rows of C_seq) - pn */
1624785e854fSJed Brown   ierr   = PetscMalloc1((pon+1),&coi);CHKERRQ(ierr);
1625d6ab1dc0SHong Zhang   coi[0] = 0;
1626d6ab1dc0SHong Zhang 
1627d6ab1dc0SHong Zhang   /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */
1628d6ab1dc0SHong Zhang   nnz           = fill*(poti[pon] + ai[am]);
1629a2ea699eSBarry Smith   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
1630d6ab1dc0SHong Zhang   current_space = free_space;
163119f0e57aSHong Zhang 
1632d6ab1dc0SHong Zhang   /* create and initialize a linked list */
1633d6ab1dc0SHong Zhang   i     = PetscMax(pdt->rmax,pot->rmax);
1634c36aecf5SHong Zhang   Crmax = i*a_loc->rmax*size; /* non-scalable! */
1635d6ab1dc0SHong Zhang   if (!Crmax || Crmax > aN) Crmax = aN;
1636d6ab1dc0SHong Zhang   ierr = PetscLLCondensedCreate_Scalable(Crmax,&lnk);CHKERRQ(ierr);
1637d6ab1dc0SHong Zhang 
1638d6ab1dc0SHong Zhang   for (i=0; i<pon; i++) {
1639d6ab1dc0SHong Zhang     pnz = poti[i+1] - poti[i];
1640d6ab1dc0SHong Zhang     ptJ = potj + poti[i];
1641d6ab1dc0SHong Zhang     for (j=0; j<pnz; j++) {
1642d6ab1dc0SHong Zhang       row  = ptJ[j]; /* row of A_loc == col of Pot */
1643d6ab1dc0SHong Zhang       anz  = ai[row+1] - ai[row];
1644d6ab1dc0SHong Zhang       Jptr = aj + ai[row];
1645d6ab1dc0SHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
1646d6ab1dc0SHong Zhang       ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr);
1647d6ab1dc0SHong Zhang     }
1648d6ab1dc0SHong Zhang     nnz = lnk[0];
1649d6ab1dc0SHong Zhang 
1650d6ab1dc0SHong Zhang     /* If free space is not available, double the total space in the list */
1651d6ab1dc0SHong Zhang     if (current_space->local_remaining<nnz) {
1652d6ab1dc0SHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
1653d6ab1dc0SHong Zhang       nspacedouble++;
1654d6ab1dc0SHong Zhang     }
1655d6ab1dc0SHong Zhang 
1656d6ab1dc0SHong Zhang     /* Copy data into free space, and zero out denserows */
1657d6ab1dc0SHong Zhang     ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr);
16582205254eSKarl Rupp 
1659d6ab1dc0SHong Zhang     current_space->array           += nnz;
1660d6ab1dc0SHong Zhang     current_space->local_used      += nnz;
1661d6ab1dc0SHong Zhang     current_space->local_remaining -= nnz;
16622205254eSKarl Rupp 
1663d6ab1dc0SHong Zhang     coi[i+1] = coi[i] + nnz;
1664d6ab1dc0SHong Zhang   }
1665d6ab1dc0SHong Zhang 
1666785e854fSJed Brown   ierr = PetscMalloc1((coi[pon]+1),&coj);CHKERRQ(ierr);
1667d6ab1dc0SHong Zhang   ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr);
16682205254eSKarl Rupp 
1669118727c9SMark F. Adams   afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1);
1670d6ab1dc0SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
1671d6ab1dc0SHong Zhang 
1672d6ab1dc0SHong Zhang   /* send j-array (coj) of Co to other processors */
1673d6ab1dc0SHong Zhang   /*----------------------------------------------*/
1674d6ab1dc0SHong Zhang   /* determine row ownership */
1675b00a9115SJed Brown   ierr = PetscNew(&merge);CHKERRQ(ierr);
1676d6ab1dc0SHong Zhang   ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr);
16772205254eSKarl Rupp 
1678d6ab1dc0SHong Zhang   merge->rowmap->n  = pn;
1679d6ab1dc0SHong Zhang   merge->rowmap->bs = 1;
16802205254eSKarl Rupp 
1681d6ab1dc0SHong Zhang   ierr   = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr);
1682d6ab1dc0SHong Zhang   owners = merge->rowmap->range;
1683d6ab1dc0SHong Zhang 
1684d6ab1dc0SHong Zhang   /* determine the number of messages to send, their lengths */
16851795a4d1SJed Brown   ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr);
1686785e854fSJed Brown   ierr = PetscMalloc1(size,&merge->len_s);CHKERRQ(ierr);
16872205254eSKarl Rupp 
1688d6ab1dc0SHong Zhang   len_s        = merge->len_s;
1689d6ab1dc0SHong Zhang   merge->nsend = 0;
1690d6ab1dc0SHong Zhang 
1691785e854fSJed Brown   ierr = PetscMalloc1((size+2),&owners_co);CHKERRQ(ierr);
1692d6ab1dc0SHong Zhang   ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr);
1693d6ab1dc0SHong Zhang 
1694d6ab1dc0SHong Zhang   proc = 0;
1695d6ab1dc0SHong Zhang   for (i=0; i<pon; i++) {
1696d6ab1dc0SHong Zhang     while (prmap[i] >= owners[proc+1]) proc++;
1697d6ab1dc0SHong Zhang     len_si[proc]++;  /* num of rows in Co to be sent to [proc] */
1698d6ab1dc0SHong Zhang     len_s[proc] += coi[i+1] - coi[i];
1699d6ab1dc0SHong Zhang   }
1700d6ab1dc0SHong Zhang 
1701d6ab1dc0SHong Zhang   len          = 0; /* max length of buf_si[] */
1702d6ab1dc0SHong Zhang   owners_co[0] = 0;
1703d6ab1dc0SHong Zhang   for (proc=0; proc<size; proc++) {
1704d6ab1dc0SHong Zhang     owners_co[proc+1] = owners_co[proc] + len_si[proc];
1705d6ab1dc0SHong Zhang     if (len_si[proc]) {
1706d6ab1dc0SHong Zhang       merge->nsend++;
1707d6ab1dc0SHong Zhang       len_si[proc] = 2*(len_si[proc] + 1);
1708d6ab1dc0SHong Zhang       len         += len_si[proc];
1709d6ab1dc0SHong Zhang     }
1710d6ab1dc0SHong Zhang   }
1711d6ab1dc0SHong Zhang 
1712d6ab1dc0SHong Zhang   /* determine the number and length of messages to receive for coi and coj  */
17130298fd71SBarry Smith   ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr);
1714d6ab1dc0SHong Zhang   ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr);
1715d6ab1dc0SHong Zhang 
1716d6ab1dc0SHong Zhang   /* post the Irecv and Isend of coj */
1717d6ab1dc0SHong Zhang   ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr);
1718d6ab1dc0SHong Zhang   ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr);
1719785e854fSJed Brown   ierr = PetscMalloc1((merge->nsend+1),&swaits);CHKERRQ(ierr);
1720d6ab1dc0SHong Zhang   for (proc=0, k=0; proc<size; proc++) {
1721d6ab1dc0SHong Zhang     if (!len_s[proc]) continue;
1722d6ab1dc0SHong Zhang     i    = owners_co[proc];
1723d6ab1dc0SHong Zhang     ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr);
1724d6ab1dc0SHong Zhang     k++;
1725d6ab1dc0SHong Zhang   }
1726d6ab1dc0SHong Zhang 
1727d6ab1dc0SHong Zhang   /* receives and sends of coj are complete */
1728785e854fSJed Brown   ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr);
1729d6ab1dc0SHong Zhang   for (i=0; i<merge->nrecv; i++) {
1730c280ed6aSJed Brown     PetscMPIInt icompleted;
1731c280ed6aSJed Brown     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
1732d6ab1dc0SHong Zhang   }
1733d6ab1dc0SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
1734d6ab1dc0SHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
1735d6ab1dc0SHong Zhang 
1736d6ab1dc0SHong Zhang   /* send and recv coi */
1737d6ab1dc0SHong Zhang   /*-------------------*/
1738d6ab1dc0SHong Zhang   ierr   = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr);
1739d6ab1dc0SHong Zhang   ierr   = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr);
1740785e854fSJed Brown   ierr   = PetscMalloc1((len+1),&buf_s);CHKERRQ(ierr);
1741d6ab1dc0SHong Zhang   buf_si = buf_s;  /* points to the beginning of k-th msg to be sent */
1742d6ab1dc0SHong Zhang   for (proc=0,k=0; proc<size; proc++) {
1743d6ab1dc0SHong Zhang     if (!len_s[proc]) continue;
1744d6ab1dc0SHong Zhang     /* form outgoing message for i-structure:
1745d6ab1dc0SHong Zhang          buf_si[0]:                 nrows to be sent
1746d6ab1dc0SHong Zhang                [1:nrows]:           row index (global)
1747d6ab1dc0SHong Zhang                [nrows+1:2*nrows+1]: i-structure index
1748d6ab1dc0SHong Zhang     */
1749d6ab1dc0SHong Zhang     /*-------------------------------------------*/
1750d6ab1dc0SHong Zhang     nrows       = len_si[proc]/2 - 1;
1751d6ab1dc0SHong Zhang     buf_si_i    = buf_si + nrows+1;
1752d6ab1dc0SHong Zhang     buf_si[0]   = nrows;
1753d6ab1dc0SHong Zhang     buf_si_i[0] = 0;
1754d6ab1dc0SHong Zhang     nrows       = 0;
1755d6ab1dc0SHong Zhang     for (i=owners_co[proc]; i<owners_co[proc+1]; i++) {
1756d6ab1dc0SHong Zhang       nzi               = coi[i+1] - coi[i];
1757d6ab1dc0SHong Zhang       buf_si_i[nrows+1] = buf_si_i[nrows] + nzi;  /* i-structure */
1758d6ab1dc0SHong Zhang       buf_si[nrows+1]   = prmap[i] -owners[proc]; /* local row index */
1759d6ab1dc0SHong Zhang       nrows++;
1760d6ab1dc0SHong Zhang     }
1761d6ab1dc0SHong Zhang     ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr);
1762d6ab1dc0SHong Zhang     k++;
1763d6ab1dc0SHong Zhang     buf_si += len_si[proc];
1764d6ab1dc0SHong Zhang   }
1765d6ab1dc0SHong Zhang   i = merge->nrecv;
1766d6ab1dc0SHong Zhang   while (i--) {
1767c280ed6aSJed Brown     PetscMPIInt icompleted;
1768c280ed6aSJed Brown     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
1769d6ab1dc0SHong Zhang   }
1770d6ab1dc0SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
1771d6ab1dc0SHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
1772d6ab1dc0SHong Zhang   ierr = PetscFree(len_si);CHKERRQ(ierr);
1773d6ab1dc0SHong Zhang   ierr = PetscFree(len_ri);CHKERRQ(ierr);
1774d6ab1dc0SHong Zhang   ierr = PetscFree(swaits);CHKERRQ(ierr);
1775d6ab1dc0SHong Zhang   ierr = PetscFree(sstatus);CHKERRQ(ierr);
1776d6ab1dc0SHong Zhang   ierr = PetscFree(buf_s);CHKERRQ(ierr);
1777d6ab1dc0SHong Zhang 
1778d6ab1dc0SHong Zhang   /* compute the local portion of C (mpi mat) */
1779d6ab1dc0SHong Zhang   /*------------------------------------------*/
1780d6ab1dc0SHong Zhang   /* allocate bi array and free space for accumulating nonzero column info */
1781785e854fSJed Brown   ierr  = PetscMalloc1((pn+1),&bi);CHKERRQ(ierr);
1782d6ab1dc0SHong Zhang   bi[0] = 0;
1783d6ab1dc0SHong Zhang 
1784d6ab1dc0SHong Zhang   /* set initial free space to be fill*(nnz(P) + nnz(AP)) */
1785d6ab1dc0SHong Zhang   nnz           = fill*(pdti[pn] + poti[pon] + ai[am]);
1786a2ea699eSBarry Smith   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
1787d6ab1dc0SHong Zhang   current_space = free_space;
1788d6ab1dc0SHong Zhang 
1789dcca6d9dSJed Brown   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
1790d6ab1dc0SHong Zhang   for (k=0; k<merge->nrecv; k++) {
1791d6ab1dc0SHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
1792d6ab1dc0SHong Zhang     nrows       = *buf_ri_k[k];
1793d6ab1dc0SHong Zhang     nextrow[k]  = buf_ri_k[k] + 1;  /* next row number of k-th recved i-structure */
17942205254eSKarl Rupp     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* points to the next i-structure of k-th recieved i-structure  */
1795d6ab1dc0SHong Zhang   }
1796d6ab1dc0SHong Zhang 
1797d6ab1dc0SHong Zhang   ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr);
1798d6ab1dc0SHong Zhang   rmax = 0;
1799d6ab1dc0SHong Zhang   for (i=0; i<pn; i++) {
1800d6ab1dc0SHong Zhang     /* add pdt[i,:]*AP into lnk */
1801d6ab1dc0SHong Zhang     pnz = pdti[i+1] - pdti[i];
1802d6ab1dc0SHong Zhang     ptJ = pdtj + pdti[i];
1803d6ab1dc0SHong Zhang     for (j=0; j<pnz; j++) {
1804d6ab1dc0SHong Zhang       row  = ptJ[j];  /* row of AP == col of Pt */
1805d6ab1dc0SHong Zhang       anz  = ai[row+1] - ai[row];
1806d6ab1dc0SHong Zhang       Jptr = aj + ai[row];
1807d6ab1dc0SHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
1808d6ab1dc0SHong Zhang       ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr);
1809d6ab1dc0SHong Zhang     }
1810d6ab1dc0SHong Zhang 
1811d6ab1dc0SHong Zhang     /* add received col data into lnk */
1812d6ab1dc0SHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
1813d6ab1dc0SHong Zhang       if (i == *nextrow[k]) { /* i-th row */
1814d6ab1dc0SHong Zhang         nzi  = *(nextci[k]+1) - *nextci[k];
1815d6ab1dc0SHong Zhang         Jptr = buf_rj[k] + *nextci[k];
1816d6ab1dc0SHong Zhang         ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr);
1817d6ab1dc0SHong Zhang         nextrow[k]++; nextci[k]++;
1818d6ab1dc0SHong Zhang       }
1819d6ab1dc0SHong Zhang     }
1820d6ab1dc0SHong Zhang     nnz = lnk[0];
1821d6ab1dc0SHong Zhang 
1822d6ab1dc0SHong Zhang     /* if free space is not available, make more free space */
1823d6ab1dc0SHong Zhang     if (current_space->local_remaining<nnz) {
1824d6ab1dc0SHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
1825d6ab1dc0SHong Zhang       nspacedouble++;
1826d6ab1dc0SHong Zhang     }
1827d6ab1dc0SHong Zhang     /* copy data into free space, then initialize lnk */
1828d6ab1dc0SHong Zhang     ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr);
1829d6ab1dc0SHong Zhang     ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr);
18302205254eSKarl Rupp 
1831d6ab1dc0SHong Zhang     current_space->array           += nnz;
1832d6ab1dc0SHong Zhang     current_space->local_used      += nnz;
1833d6ab1dc0SHong Zhang     current_space->local_remaining -= nnz;
18342205254eSKarl Rupp 
1835d6ab1dc0SHong Zhang     bi[i+1] = bi[i] + nnz;
1836d6ab1dc0SHong Zhang     if (nnz > rmax) rmax = nnz;
1837d6ab1dc0SHong Zhang   }
1838d6ab1dc0SHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
1839d6ab1dc0SHong Zhang 
1840785e854fSJed Brown   ierr      = PetscMalloc1((bi[pn]+1),&bj);CHKERRQ(ierr);
1841d6ab1dc0SHong Zhang   ierr      = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr);
1842118727c9SMark F. Adams   afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1);
1843d6ab1dc0SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
1844d6ab1dc0SHong Zhang   ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr);
1845d6ab1dc0SHong Zhang   ierr = MatDestroy(&POt);CHKERRQ(ierr);
1846d6ab1dc0SHong Zhang   ierr = MatDestroy(&PDt);CHKERRQ(ierr);
1847d6ab1dc0SHong Zhang 
1848d6ab1dc0SHong Zhang   /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part   */
1849d6ab1dc0SHong Zhang   /*----------------------------------------------------------------------------------*/
18501795a4d1SJed Brown   ierr = PetscCalloc1(rmax+1,&vals);CHKERRQ(ierr);
1851d6ab1dc0SHong Zhang 
1852d6ab1dc0SHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
1853d6ab1dc0SHong Zhang   ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
185433d57670SJed Brown   ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(A->cmap->bs));CHKERRQ(ierr);
1855d6ab1dc0SHong Zhang   ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr);
1856d6ab1dc0SHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
1857d6ab1dc0SHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
1858d6ab1dc0SHong Zhang   ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr);
1859d6ab1dc0SHong Zhang   for (i=0; i<pn; i++) {
1860d6ab1dc0SHong Zhang     row  = i + rstart;
1861d6ab1dc0SHong Zhang     nnz  = bi[i+1] - bi[i];
1862d6ab1dc0SHong Zhang     Jptr = bj + bi[i];
1863d6ab1dc0SHong Zhang     ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,vals,INSERT_VALUES);CHKERRQ(ierr);
1864d6ab1dc0SHong Zhang   }
1865d6ab1dc0SHong Zhang   ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1866d6ab1dc0SHong Zhang   ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1867d6ab1dc0SHong Zhang   ierr = PetscFree(vals);CHKERRQ(ierr);
1868d6ab1dc0SHong Zhang 
1869d6ab1dc0SHong Zhang   merge->bi        = bi;
1870d6ab1dc0SHong Zhang   merge->bj        = bj;
1871d6ab1dc0SHong Zhang   merge->coi       = coi;
1872d6ab1dc0SHong Zhang   merge->coj       = coj;
1873d6ab1dc0SHong Zhang   merge->buf_ri    = buf_ri;
1874d6ab1dc0SHong Zhang   merge->buf_rj    = buf_rj;
1875d6ab1dc0SHong Zhang   merge->owners_co = owners_co;
1876d6ab1dc0SHong Zhang   merge->destroy   = Cmpi->ops->destroy;
1877d6ab1dc0SHong Zhang   merge->duplicate = Cmpi->ops->duplicate;
1878d6ab1dc0SHong Zhang 
18796da69ca6SHong Zhang   Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ;
1880d6ab1dc0SHong Zhang   Cmpi->ops->destroy                 = MatDestroy_MPIAIJ_PtAP;
1881d6ab1dc0SHong Zhang 
1882d6ab1dc0SHong Zhang   /* attach the supporting struct to Cmpi for reuse */
1883d6ab1dc0SHong Zhang   c = (Mat_MPIAIJ*)Cmpi->data;
18842205254eSKarl Rupp 
1885d6ab1dc0SHong Zhang   c->ptap     = ptap;
18860298fd71SBarry Smith   ptap->api   = NULL;
18870298fd71SBarry Smith   ptap->apj   = NULL;
1888d6ab1dc0SHong Zhang   ptap->merge = merge;
1889d6ab1dc0SHong Zhang   ptap->rmax  = rmax;
18900298fd71SBarry Smith   ptap->apa   = NULL;
1891f96d37fcSHong Zhang 
1892f96d37fcSHong Zhang   *C = Cmpi;
1893f96d37fcSHong Zhang #if defined(PETSC_USE_INFO)
1894f96d37fcSHong Zhang   if (bi[pn] != 0) {
189557622a8eSBarry Smith     ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr);
189657622a8eSBarry Smith     ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr);
1897f96d37fcSHong Zhang   } else {
1898f96d37fcSHong Zhang     ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr);
1899f96d37fcSHong Zhang   }
1900f96d37fcSHong Zhang #endif
1901f96d37fcSHong Zhang   PetscFunctionReturn(0);
1902f96d37fcSHong Zhang }
1903