xref: /petsc/src/mat/impls/aij/mpi/mpiptap.c (revision cc31e402b36765f4f9aa302ebce13387729bbc9c)
182412ba7SHong Zhang 
242c57489SHong Zhang /*
342c57489SHong Zhang   Defines projective product routines where A is a MPIAIJ matrix
442c57489SHong Zhang           C = P^T * A * P
542c57489SHong Zhang */
642c57489SHong Zhang 
7c6db04a5SJed Brown #include <../src/mat/impls/aij/seq/aij.h>   /*I "petscmat.h" I*/
8c6db04a5SJed Brown #include <../src/mat/utils/freespace.h>
9c6db04a5SJed Brown #include <../src/mat/impls/aij/mpi/mpiaij.h>
10c6db04a5SJed Brown #include <petscbt.h>
118563dfccSBarry Smith #include <petsctime.h>
1242c57489SHong Zhang 
139516a85cSHong Zhang #define PTAP_PROFILE
1424ecddacSHong Zhang 
1509573ac7SBarry Smith extern PetscErrorCode MatDestroy_MPIAIJ(Mat);
16cc6cb787SHong Zhang #undef __FUNCT__
17f8487c73SHong Zhang #define __FUNCT__ "MatDestroy_MPIAIJ_PtAP"
18f8487c73SHong Zhang PetscErrorCode MatDestroy_MPIAIJ_PtAP(Mat A)
19cc6cb787SHong Zhang {
20cc6cb787SHong Zhang   PetscErrorCode ierr;
21f8487c73SHong Zhang   Mat_MPIAIJ     *a   =(Mat_MPIAIJ*)A->data;
22f8487c73SHong Zhang   Mat_PtAPMPI    *ptap=a->ptap;
23cc6cb787SHong Zhang 
24cc6cb787SHong Zhang   PetscFunctionBegin;
25f8487c73SHong Zhang   if (ptap) {
26c8b0795cSMark F. Adams     Mat_Merge_SeqsToMPI *merge=ptap->merge;
27b7f45c76SHong Zhang     ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr);
28f8487c73SHong Zhang     ierr = PetscFree(ptap->bufa);CHKERRQ(ierr);
29a1a4e84aSHong Zhang     ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr);
30a1a4e84aSHong Zhang     ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr);
31c5af039cSHong Zhang     ierr = MatDestroy(&ptap->A_loc);CHKERRQ(ierr); /* used by MatTransposeMatMult() */
320d3441aeSHong Zhang 
3305d62848SHong Zhang     ierr = MatDestroy(&ptap->Rd);CHKERRQ(ierr);
3405d62848SHong Zhang     ierr = MatDestroy(&ptap->Ro);CHKERRQ(ierr);
350d3441aeSHong Zhang     ierr = MatDestroy(&ptap->AP_loc);CHKERRQ(ierr);
362259aa2eSHong Zhang     ierr = MatDestroy(&ptap->C_loc);CHKERRQ(ierr);
372259aa2eSHong Zhang     ierr = MatDestroy(&ptap->C_oth);CHKERRQ(ierr);
380d3441aeSHong Zhang 
39c5af039cSHong Zhang     if (ptap->api) {ierr = PetscFree(ptap->api);CHKERRQ(ierr);}
40c5af039cSHong Zhang     if (ptap->apj) {ierr = PetscFree(ptap->apj);CHKERRQ(ierr);}
41414894bdSHong Zhang     if (ptap->apa) {ierr = PetscFree(ptap->apa);CHKERRQ(ierr);}
42c8b0795cSMark F. Adams     if (merge) {
43cc6cb787SHong Zhang       ierr = PetscFree(merge->id_r);CHKERRQ(ierr);
44cc6cb787SHong Zhang       ierr = PetscFree(merge->len_s);CHKERRQ(ierr);
45cc6cb787SHong Zhang       ierr = PetscFree(merge->len_r);CHKERRQ(ierr);
46cc6cb787SHong Zhang       ierr = PetscFree(merge->bi);CHKERRQ(ierr);
47cc6cb787SHong Zhang       ierr = PetscFree(merge->bj);CHKERRQ(ierr);
48c05d87d6SBarry Smith       ierr = PetscFree(merge->buf_ri[0]);CHKERRQ(ierr);
49cc6cb787SHong Zhang       ierr = PetscFree(merge->buf_ri);CHKERRQ(ierr);
50c05d87d6SBarry Smith       ierr = PetscFree(merge->buf_rj[0]);CHKERRQ(ierr);
51cc6cb787SHong Zhang       ierr = PetscFree(merge->buf_rj);CHKERRQ(ierr);
52*cc31e402SHong Zhang       if (merge->coi) {ierr = PetscFree(merge->coi);CHKERRQ(ierr);}
53*cc31e402SHong Zhang       if (merge->coj) {ierr = PetscFree(merge->coj);CHKERRQ(ierr);}
5405b42c5fSBarry Smith       ierr = PetscFree(merge->owners_co);CHKERRQ(ierr);
556bf464f9SBarry Smith       ierr = PetscLayoutDestroy(&merge->rowmap);CHKERRQ(ierr);
56dce485f0SBarry Smith       ierr = merge->destroy(A);CHKERRQ(ierr);
57f8487c73SHong Zhang       ierr = PetscFree(ptap->merge);CHKERRQ(ierr);
58bf0cc555SLisandro Dalcin     }
59f8487c73SHong Zhang     ierr = PetscFree(ptap);CHKERRQ(ierr);
60c8b0795cSMark F. Adams   }
61cc6cb787SHong Zhang   PetscFunctionReturn(0);
62cc6cb787SHong Zhang }
63cc6cb787SHong Zhang 
64cc6cb787SHong Zhang #undef __FUNCT__
65cc6cb787SHong Zhang #define __FUNCT__ "MatDuplicate_MPIAIJ_MatPtAP"
66f0c0a3a6SBarry Smith PetscErrorCode MatDuplicate_MPIAIJ_MatPtAP(Mat A, MatDuplicateOption op, Mat *M)
67f0c0a3a6SBarry Smith {
68cc6cb787SHong Zhang   PetscErrorCode      ierr;
6911a6856fSHong Zhang   Mat_MPIAIJ          *a     = (Mat_MPIAIJ*)A->data;
7011a6856fSHong Zhang   Mat_PtAPMPI         *ptap  = a->ptap;
7111a6856fSHong Zhang   Mat_Merge_SeqsToMPI *merge = ptap->merge;
72cc6cb787SHong Zhang 
73cc6cb787SHong Zhang   PetscFunctionBegin;
74dce485f0SBarry Smith   ierr = (*merge->duplicate)(A,op,M);CHKERRQ(ierr);
752205254eSKarl Rupp 
7611a6856fSHong Zhang   (*M)->ops->destroy   = merge->destroy;
7711a6856fSHong Zhang   (*M)->ops->duplicate = merge->duplicate;
78cc6cb787SHong Zhang   PetscFunctionReturn(0);
79cc6cb787SHong Zhang }
80cc6cb787SHong Zhang 
8142c57489SHong Zhang #undef __FUNCT__
82cf3ca8ceSHong Zhang #define __FUNCT__ "MatPtAP_MPIAIJ_MPIAIJ"
83cf3ca8ceSHong Zhang PetscErrorCode MatPtAP_MPIAIJ_MPIAIJ(Mat A,Mat P,MatReuse scall,PetscReal fill,Mat *C)
8442c57489SHong Zhang {
8542c57489SHong Zhang   PetscErrorCode ierr;
860d3441aeSHong Zhang   PetscBool      newalg=PETSC_FALSE;
8742c57489SHong Zhang 
8842c57489SHong Zhang   PetscFunctionBegin;
890d3441aeSHong Zhang   ierr = PetscOptionsGetBool(NULL,"-matptap_new",&newalg,NULL);CHKERRQ(ierr);
90cf3ca8ceSHong Zhang   if (scall == MAT_INITIAL_MATRIX) {
913ff4c91cSHong Zhang     ierr = PetscLogEventBegin(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
920d3441aeSHong Zhang     if (newalg) {
930d3441aeSHong Zhang       ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ_new(A,P,fill,C);CHKERRQ(ierr);
940d3441aeSHong Zhang     } else {
95cf3ca8ceSHong Zhang       ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ(A,P,fill,C);CHKERRQ(ierr);
960d3441aeSHong Zhang     }
973ff4c91cSHong Zhang     ierr = PetscLogEventEnd(MAT_PtAPSymbolic,A,P,0,0);CHKERRQ(ierr);
987a7894deSKris Buschelman   }
993ff4c91cSHong Zhang   ierr = PetscLogEventBegin(MAT_PtAPNumeric,A,P,0,0);CHKERRQ(ierr);
1000d3441aeSHong Zhang   if (newalg) {
1010d3441aeSHong Zhang     ierr = MatPtAPNumeric_MPIAIJ_MPIAIJ_new(A,P,*C);CHKERRQ(ierr);
1020d3441aeSHong Zhang   } else {
103cf3ca8ceSHong Zhang     ierr = MatPtAPNumeric_MPIAIJ_MPIAIJ(A,P,*C);CHKERRQ(ierr);
1040d3441aeSHong Zhang   }
1053ff4c91cSHong Zhang   ierr = PetscLogEventEnd(MAT_PtAPNumeric,A,P,0,0);CHKERRQ(ierr);
10642c57489SHong Zhang   PetscFunctionReturn(0);
10742c57489SHong Zhang }
10842c57489SHong Zhang 
10942c57489SHong Zhang #undef __FUNCT__
1100d3441aeSHong Zhang #define __FUNCT__ "MatPtAPSymbolic_MPIAIJ_MPIAIJ_new"
1110d3441aeSHong Zhang PetscErrorCode MatPtAPSymbolic_MPIAIJ_MPIAIJ_new(Mat A,Mat P,PetscReal fill,Mat *C)
1120d3441aeSHong Zhang {
1130d3441aeSHong Zhang   PetscErrorCode ierr;
1140d3441aeSHong Zhang   Mat_PtAPMPI    *ptap;
1152259aa2eSHong Zhang   Mat_MPIAIJ     *p=(Mat_MPIAIJ*)P->data;
1169ce11a7cSHong Zhang   Mat            AP;
1172259aa2eSHong Zhang   Mat_MPIAIJ     *c;
1182259aa2eSHong Zhang   MPI_Comm       comm;
1192259aa2eSHong Zhang   PetscMPIInt    size,rank;
12080bb4639SHong Zhang   PetscLogDouble      t0,t1,t2,t3,t4;
12180bb4639SHong Zhang 
12280bb4639SHong Zhang   PetscFunctionBegin;
1232259aa2eSHong Zhang   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
1242259aa2eSHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1252259aa2eSHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1262259aa2eSHong Zhang 
1272259aa2eSHong Zhang   /* check if matrix local sizes are compatible -- MV! */
1282259aa2eSHong Zhang   if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) {
1292259aa2eSHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Arow (%D, %D) != Prow (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend);
1302259aa2eSHong Zhang   }
1312259aa2eSHong Zhang   if (A->cmap->rstart != P->rmap->rstart || A->cmap->rend != P->rmap->rend) {
1322259aa2eSHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Acol (%D, %D) != Prow (%D,%D)",A->cmap->rstart,A->cmap->rend,P->rmap->rstart,P->rmap->rend);
1332259aa2eSHong Zhang   }
1342259aa2eSHong Zhang 
13515a3b8e2SHong Zhang   //ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ(A,P,fill,C);CHKERRQ(ierr); //rm later !!!
13615a3b8e2SHong Zhang   //=============================================================================
13715a3b8e2SHong Zhang   Mat                 Cmpi;
13815a3b8e2SHong Zhang   PetscFreeSpaceList  free_space=NULL,current_space=NULL;
139de817e96SHong Zhang   Mat_SeqAIJ          *p_loc;
140de817e96SHong Zhang   PetscInt            *pi_loc;
141de817e96SHong Zhang   PetscInt            *pdti,*pdtj,*poti,*potj,*ptJ,nnz;
14215a3b8e2SHong Zhang   PetscInt            *lnk,*owners_co,*coi,*coj,i,k,pnz,row;
14315a3b8e2SHong Zhang   PetscInt            am=A->rmap->n,pN=P->cmap->N,pm=P->rmap->n,pn=P->cmap->n;
14415a3b8e2SHong Zhang   PetscBT             lnkbt;
14515a3b8e2SHong Zhang   PetscMPIInt         tagi,tagj,*len_si,*len_s,*len_ri,icompleted=0;
14615a3b8e2SHong Zhang   PetscInt            **buf_rj,**buf_ri,**buf_ri_k;
14715a3b8e2SHong Zhang   PetscInt            len,proc,*dnz,*onz,*owners;
14815a3b8e2SHong Zhang   PetscInt            nzi,*pti,*ptj;
14915a3b8e2SHong Zhang   PetscInt            nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci;
15015a3b8e2SHong Zhang   MPI_Request         *swaits,*rwaits;
15115a3b8e2SHong Zhang   MPI_Status          *sstatus,rstatus;
15215a3b8e2SHong Zhang   Mat_Merge_SeqsToMPI *merge;
15315a3b8e2SHong Zhang   PetscInt            *api,*apj,*Jptr,apnz,*prmap=p->garray,pon,nspacedouble=0,j,ap_rmax=0;
15415a3b8e2SHong Zhang   PetscReal           afill=1.0,afill_tmp;
15515a3b8e2SHong Zhang   PetscInt            rmax;
15615a3b8e2SHong Zhang 
15780bb4639SHong Zhang   ierr = PetscTime(&t0);CHKERRQ(ierr);
15815a3b8e2SHong Zhang   /* create struct Mat_PtAPMPI and attached it to C later */
15915a3b8e2SHong Zhang   ierr        = PetscNew(&ptap);CHKERRQ(ierr);
16015a3b8e2SHong Zhang   ierr        = PetscNew(&merge);CHKERRQ(ierr);
16115a3b8e2SHong Zhang   ptap->merge = merge;
16215a3b8e2SHong Zhang   ptap->reuse = MAT_INITIAL_MATRIX;
16315a3b8e2SHong Zhang 
16415a3b8e2SHong Zhang   /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
16515a3b8e2SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
16615a3b8e2SHong Zhang 
16715a3b8e2SHong Zhang   /* get P_loc by taking all local rows of P */
16815a3b8e2SHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
16915a3b8e2SHong Zhang 
170de817e96SHong Zhang   ptap->reuse = MAT_INITIAL_MATRIX;
17115a3b8e2SHong Zhang 
172de817e96SHong Zhang   /* (1) compute symbolic AP = A*P, then get AP_loc */
17315a3b8e2SHong Zhang   /*--------------------------------------------------------------------------*/
174de817e96SHong Zhang   ierr = MatTranspose_SeqAIJ(p->A,MAT_INITIAL_MATRIX,&ptap->Rd);CHKERRQ(ierr);
175de817e96SHong Zhang   ierr = MatTranspose_SeqAIJ(p->B,MAT_INITIAL_MATRIX,&ptap->Ro);CHKERRQ(ierr);
17615a3b8e2SHong Zhang 
177de817e96SHong Zhang   ierr = MatMatMult(A,P,MAT_INITIAL_MATRIX,2.0,&AP);CHKERRQ(ierr);
178de817e96SHong Zhang   ierr = MatMPIAIJGetLocalMat(AP,MAT_INITIAL_MATRIX,&ptap->AP_loc);CHKERRQ(ierr);
179de817e96SHong Zhang   ierr = MatDestroy(&AP);CHKERRQ(ierr);
18015a3b8e2SHong Zhang 
181de817e96SHong Zhang   /* (2) compute C_loc=Rd*AP_loc, Co=Ro*AP_loc */
182de817e96SHong Zhang   ierr = MatMatMult_SeqAIJ_SeqAIJ(ptap->Rd,ptap->AP_loc,MAT_INITIAL_MATRIX,2.0,&ptap->C_loc);CHKERRQ(ierr);
183de817e96SHong Zhang   ierr = MatMatMult_SeqAIJ_SeqAIJ(ptap->Ro,ptap->AP_loc,MAT_INITIAL_MATRIX,2.0,&ptap->C_oth);CHKERRQ(ierr);
18480bb4639SHong Zhang   ierr = PetscTime(&t1);CHKERRQ(ierr);
18515a3b8e2SHong Zhang 
186de817e96SHong Zhang   p_loc  = (Mat_SeqAIJ*)(ptap->P_loc)->data;
187de817e96SHong Zhang   pi_loc = p_loc->i;
18815a3b8e2SHong Zhang 
189de817e96SHong Zhang   Mat_SeqAIJ *ap = (Mat_SeqAIJ*)ptap->AP_loc->data;
190748c7196SHong Zhang   Mat_SeqAIJ *c_oth  = (Mat_SeqAIJ*)ptap->C_oth->data;
191748c7196SHong Zhang   api = ap->i; apj = ap->j;
19215a3b8e2SHong Zhang 
19315a3b8e2SHong Zhang   /* (2) determine symbolic Co=(p->B)^T*AP - send to others (coi,coj)*/
19415a3b8e2SHong Zhang   /*-----------------------------------------------------------------*/
195*cc31e402SHong Zhang   coi = c_oth->i; coj =  c_oth->j;
196748c7196SHong Zhang 
19780bb4639SHong Zhang   Mat_SeqAIJ *po = (Mat_SeqAIJ *)ptap->Ro->data;
19880bb4639SHong Zhang   poti = po->i; potj = po->j;
19915a3b8e2SHong Zhang 
20015a3b8e2SHong Zhang   /* then, compute symbolic Co = (p->B)^T*AP */
20115a3b8e2SHong Zhang   pon    = (p->B)->cmap->n; /* total num of rows to be sent to other processors
20215a3b8e2SHong Zhang                          >= (num of nonzero rows of C_seq) - pn */
20315a3b8e2SHong Zhang 
204de817e96SHong Zhang   /* create and initialize a linked list */
205de817e96SHong Zhang   ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr);
206de817e96SHong Zhang 
20715a3b8e2SHong Zhang   afill_tmp = (PetscReal)coi[pon]/(poti[pon] + api[am]+1);
20815a3b8e2SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
20915a3b8e2SHong Zhang 
21015a3b8e2SHong Zhang   /* (3) send j-array (coj) of Co to other processors */
21115a3b8e2SHong Zhang   /*--------------------------------------------------*/
21215a3b8e2SHong Zhang   ierr = PetscCalloc1(size,&merge->len_s);CHKERRQ(ierr);
21315a3b8e2SHong Zhang   len_s        = merge->len_s;
21415a3b8e2SHong Zhang   merge->nsend = 0;
21515a3b8e2SHong Zhang 
21615a3b8e2SHong Zhang   /* determine row ownership */
21715a3b8e2SHong Zhang   ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr);
21815a3b8e2SHong Zhang   merge->rowmap->n  = pn;
21915a3b8e2SHong Zhang   merge->rowmap->bs = 1;
22015a3b8e2SHong Zhang 
22115a3b8e2SHong Zhang   ierr   = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr);
22215a3b8e2SHong Zhang   owners = merge->rowmap->range;
22315a3b8e2SHong Zhang 
22415a3b8e2SHong Zhang   /* determine the number of messages to send, their lengths */
22515a3b8e2SHong Zhang   ierr = PetscMalloc2(size,&len_si,size,&sstatus);CHKERRQ(ierr);
22615a3b8e2SHong Zhang   ierr = PetscMemzero(len_si,size*sizeof(PetscMPIInt));CHKERRQ(ierr);
22715a3b8e2SHong Zhang   ierr = PetscMalloc1(size+2,&owners_co);CHKERRQ(ierr);
22815a3b8e2SHong Zhang 
22915a3b8e2SHong Zhang   proc = 0;
23015a3b8e2SHong Zhang   for (i=0; i<pon; i++) {
23115a3b8e2SHong Zhang     while (prmap[i] >= owners[proc+1]) proc++;
23215a3b8e2SHong Zhang     len_si[proc]++;               /* num of rows in Co(=Pt*AP) to be sent to [proc] */
23315a3b8e2SHong Zhang     len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */
23415a3b8e2SHong Zhang   }
23515a3b8e2SHong Zhang 
23615a3b8e2SHong Zhang   len          = 0; /* max length of buf_si[], see (4) */
23715a3b8e2SHong Zhang   owners_co[0] = 0;
23815a3b8e2SHong Zhang   for (proc=0; proc<size; proc++) {
23915a3b8e2SHong Zhang     owners_co[proc+1] = owners_co[proc] + len_si[proc];
24015a3b8e2SHong Zhang     if (len_s[proc]) {
24115a3b8e2SHong Zhang       merge->nsend++;
24215a3b8e2SHong Zhang       len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */
24315a3b8e2SHong Zhang       len         += len_si[proc];
24415a3b8e2SHong Zhang     }
24515a3b8e2SHong Zhang   }
24615a3b8e2SHong Zhang 
24715a3b8e2SHong Zhang   /* determine the number and length of messages to receive for coi and coj  */
24815a3b8e2SHong Zhang   ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr);
24915a3b8e2SHong Zhang   ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr);
25015a3b8e2SHong Zhang 
25115a3b8e2SHong Zhang   /* post the Irecv and Isend of coj */
25215a3b8e2SHong Zhang   ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr);
25315a3b8e2SHong Zhang   ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr);
25415a3b8e2SHong Zhang   ierr = PetscMalloc1(merge->nsend+1,&swaits);CHKERRQ(ierr);
25515a3b8e2SHong Zhang   for (proc=0, k=0; proc<size; proc++) {
25615a3b8e2SHong Zhang     if (!len_s[proc]) continue;
25715a3b8e2SHong Zhang     i    = owners_co[proc];
25815a3b8e2SHong Zhang     ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr);
25915a3b8e2SHong Zhang     k++;
26015a3b8e2SHong Zhang   }
26115a3b8e2SHong Zhang 
26215a3b8e2SHong Zhang   /* receives and sends of coj are complete */
26315a3b8e2SHong Zhang   for (i=0; i<merge->nrecv; i++) {
26415a3b8e2SHong Zhang     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
26515a3b8e2SHong Zhang   }
26615a3b8e2SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
26715a3b8e2SHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
26815a3b8e2SHong Zhang 
26915a3b8e2SHong Zhang   /* (4) send and recv coi */
27015a3b8e2SHong Zhang   /*-----------------------*/
27115a3b8e2SHong Zhang   ierr   = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr);
27215a3b8e2SHong Zhang   ierr   = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr);
27315a3b8e2SHong Zhang   ierr   = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr);
27415a3b8e2SHong Zhang   buf_si = buf_s;  /* points to the beginning of k-th msg to be sent */
27515a3b8e2SHong Zhang   for (proc=0,k=0; proc<size; proc++) {
27615a3b8e2SHong Zhang     if (!len_s[proc]) continue;
27715a3b8e2SHong Zhang     /* form outgoing message for i-structure:
27815a3b8e2SHong Zhang          buf_si[0]:                 nrows to be sent
27915a3b8e2SHong Zhang                [1:nrows]:           row index (global)
28015a3b8e2SHong Zhang                [nrows+1:2*nrows+1]: i-structure index
28115a3b8e2SHong Zhang     */
28215a3b8e2SHong Zhang     /*-------------------------------------------*/
28315a3b8e2SHong Zhang     nrows       = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */
28415a3b8e2SHong Zhang     buf_si_i    = buf_si + nrows+1;
28515a3b8e2SHong Zhang     buf_si[0]   = nrows;
28615a3b8e2SHong Zhang     buf_si_i[0] = 0;
28715a3b8e2SHong Zhang     nrows       = 0;
28815a3b8e2SHong Zhang     for (i=owners_co[proc]; i<owners_co[proc+1]; i++) {
28915a3b8e2SHong Zhang       nzi = coi[i+1] - coi[i];
29015a3b8e2SHong Zhang       buf_si_i[nrows+1] = buf_si_i[nrows] + nzi;  /* i-structure */
29115a3b8e2SHong Zhang       buf_si[nrows+1]   = prmap[i] -owners[proc]; /* local row index */
29215a3b8e2SHong Zhang       nrows++;
29315a3b8e2SHong Zhang     }
29415a3b8e2SHong Zhang     ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr);
29515a3b8e2SHong Zhang     k++;
29615a3b8e2SHong Zhang     buf_si += len_si[proc];
29715a3b8e2SHong Zhang   }
29815a3b8e2SHong Zhang   i = merge->nrecv;
29915a3b8e2SHong Zhang   while (i--) {
30015a3b8e2SHong Zhang     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
30115a3b8e2SHong Zhang   }
30215a3b8e2SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
30315a3b8e2SHong Zhang   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
30415a3b8e2SHong Zhang 
30515a3b8e2SHong Zhang   ierr = PetscFree2(len_si,sstatus);CHKERRQ(ierr);
30615a3b8e2SHong Zhang   ierr = PetscFree(len_ri);CHKERRQ(ierr);
30715a3b8e2SHong Zhang   ierr = PetscFree(swaits);CHKERRQ(ierr);
30815a3b8e2SHong Zhang   ierr = PetscFree(buf_s);CHKERRQ(ierr);
30915a3b8e2SHong Zhang 
31080bb4639SHong Zhang   ierr = PetscTime(&t2);CHKERRQ(ierr);
31180bb4639SHong Zhang 
312*cc31e402SHong Zhang   //ierr = MPI_Barrier(comm);
313*cc31e402SHong Zhang 
31415a3b8e2SHong Zhang   /* (5) compute the local portion of C (mpi mat) */
31515a3b8e2SHong Zhang   /*----------------------------------------------*/
316*cc31e402SHong Zhang 
31780bb4639SHong Zhang   Mat_SeqAIJ *pd = (Mat_SeqAIJ *)ptap->Rd->data;
31880bb4639SHong Zhang   pdti = pd->i; pdtj = pd->j;
31915a3b8e2SHong Zhang 
32015a3b8e2SHong Zhang   /* allocate pti array and free space for accumulating nonzero column info */
32115a3b8e2SHong Zhang   ierr   = PetscMalloc1(pn+1,&pti);CHKERRQ(ierr);
32215a3b8e2SHong Zhang   pti[0] = 0;
32315a3b8e2SHong Zhang 
32415a3b8e2SHong Zhang   /* set initial free space to be fill*(nnz(P) + nnz(AP)) */
32515a3b8e2SHong Zhang   nnz           = fill*(pi_loc[pm] + api[am]);
32615a3b8e2SHong Zhang   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
32715a3b8e2SHong Zhang   current_space = free_space;
32815a3b8e2SHong Zhang 
32915a3b8e2SHong Zhang   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
33015a3b8e2SHong Zhang   for (k=0; k<merge->nrecv; k++) {
33115a3b8e2SHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
33215a3b8e2SHong Zhang     nrows       = *buf_ri_k[k];
33315a3b8e2SHong Zhang     nextrow[k]  = buf_ri_k[k] + 1;  /* next row number of k-th recved i-structure */
33415a3b8e2SHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
33515a3b8e2SHong Zhang   }
33615a3b8e2SHong Zhang   ierr = MatPreallocateInitialize(comm,pn,pn,dnz,onz);CHKERRQ(ierr);
33715a3b8e2SHong Zhang   rmax = 0;
33815a3b8e2SHong Zhang   for (i=0; i<pn; i++) {
33915a3b8e2SHong Zhang     /* add pdt[i,:]*AP into lnk */
34015a3b8e2SHong Zhang     pnz = pdti[i+1] - pdti[i];
34115a3b8e2SHong Zhang     ptJ = pdtj + pdti[i];
34215a3b8e2SHong Zhang     for (j=0; j<pnz; j++) {
34315a3b8e2SHong Zhang       row  = ptJ[j];  /* row of AP == col of Pt */
34415a3b8e2SHong Zhang       apnz = api[row+1] - api[row];
34515a3b8e2SHong Zhang       Jptr = apj + api[row];
34615a3b8e2SHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
34715a3b8e2SHong Zhang       ierr = PetscLLCondensedAddSorted(apnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
34815a3b8e2SHong Zhang     }
34915a3b8e2SHong Zhang 
35015a3b8e2SHong Zhang     /* add received col data into lnk */
35115a3b8e2SHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
35215a3b8e2SHong Zhang       if (i == *nextrow[k]) { /* i-th row */
35315a3b8e2SHong Zhang         nzi  = *(nextci[k]+1) - *nextci[k];
35415a3b8e2SHong Zhang         Jptr = buf_rj[k] + *nextci[k];
35515a3b8e2SHong Zhang         ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr);
35615a3b8e2SHong Zhang         nextrow[k]++; nextci[k]++;
35715a3b8e2SHong Zhang       }
35815a3b8e2SHong Zhang     }
35915a3b8e2SHong Zhang     nnz = lnk[0];
36015a3b8e2SHong Zhang 
36115a3b8e2SHong Zhang     /* if free space is not available, make more free space */
36215a3b8e2SHong Zhang     if (current_space->local_remaining<nnz) {
36315a3b8e2SHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
36415a3b8e2SHong Zhang       nspacedouble++;
36515a3b8e2SHong Zhang     }
36615a3b8e2SHong Zhang     /* copy data into free space, then initialize lnk */
36715a3b8e2SHong Zhang     ierr = PetscLLCondensedClean(pN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
36815a3b8e2SHong Zhang     ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr);
36915a3b8e2SHong Zhang 
37015a3b8e2SHong Zhang     current_space->array           += nnz;
37115a3b8e2SHong Zhang     current_space->local_used      += nnz;
37215a3b8e2SHong Zhang     current_space->local_remaining -= nnz;
37315a3b8e2SHong Zhang 
37415a3b8e2SHong Zhang     pti[i+1] = pti[i] + nnz;
37515a3b8e2SHong Zhang     if (nnz > rmax) rmax = nnz;
37615a3b8e2SHong Zhang   }
37715a3b8e2SHong Zhang   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
37815a3b8e2SHong Zhang 
37915a3b8e2SHong Zhang   ierr      = PetscMalloc1(pti[pn]+1,&ptj);CHKERRQ(ierr);
38015a3b8e2SHong Zhang   ierr      = PetscFreeSpaceContiguous(&free_space,ptj);CHKERRQ(ierr);
38115a3b8e2SHong Zhang   afill_tmp = (PetscReal)pti[pn]/(pi_loc[pm] + api[am]+1);
38215a3b8e2SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
38315a3b8e2SHong Zhang   ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr);
38415a3b8e2SHong Zhang 
38580bb4639SHong Zhang   ierr = PetscTime(&t3);CHKERRQ(ierr);
38680bb4639SHong Zhang 
38715a3b8e2SHong Zhang   /* (6) create symbolic parallel matrix Cmpi */
38815a3b8e2SHong Zhang   /*------------------------------------------*/
38915a3b8e2SHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
39015a3b8e2SHong Zhang   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
39115a3b8e2SHong Zhang   ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(P->cmap->bs));CHKERRQ(ierr);
39215a3b8e2SHong Zhang   ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr);
39315a3b8e2SHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
39415a3b8e2SHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
39515a3b8e2SHong Zhang 
39615a3b8e2SHong Zhang   merge->bi        = pti;      /* Cseq->i */
39715a3b8e2SHong Zhang   merge->bj        = ptj;      /* Cseq->j */
398*cc31e402SHong Zhang   merge->coi = NULL; //merge->coi       = coi;      /* Co->i   */
399*cc31e402SHong Zhang   merge->coj = NULL; //merge->coj       = coj;      /* Co->j   */
40015a3b8e2SHong Zhang   merge->buf_ri    = buf_ri;
40115a3b8e2SHong Zhang   merge->buf_rj    = buf_rj;
40215a3b8e2SHong Zhang   merge->owners_co = owners_co;
40315a3b8e2SHong Zhang   merge->destroy   = Cmpi->ops->destroy;
40415a3b8e2SHong Zhang   merge->duplicate = Cmpi->ops->duplicate;
40515a3b8e2SHong Zhang 
40615a3b8e2SHong Zhang   /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */
40715a3b8e2SHong Zhang   Cmpi->assembled        = PETSC_FALSE;
40815a3b8e2SHong Zhang   Cmpi->ops->destroy     = MatDestroy_MPIAIJ_PtAP;
40915a3b8e2SHong Zhang   Cmpi->ops->duplicate   = MatDuplicate_MPIAIJ_MatPtAP;
410748c7196SHong Zhang   Cmpi->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_new;
41115a3b8e2SHong Zhang 
41215a3b8e2SHong Zhang   /* attach the supporting struct to Cmpi for reuse */
41315a3b8e2SHong Zhang   c           = (Mat_MPIAIJ*)Cmpi->data;
41415a3b8e2SHong Zhang   c->ptap     = ptap;
415de817e96SHong Zhang   ptap->api   = NULL;
416de817e96SHong Zhang   ptap->apj   = NULL;
41715a3b8e2SHong Zhang   ptap->rmax  = ap_rmax;
41815a3b8e2SHong Zhang   *C          = Cmpi;
41915a3b8e2SHong Zhang 
4202259aa2eSHong Zhang   /* flag 'scalable' determines which implementations to be used:
4212259aa2eSHong Zhang        0: do dense axpy in MatPtAPNumeric() - fast, but requires storage of a nonscalable dense array apa;
4222259aa2eSHong Zhang        1: do sparse axpy in MatPtAPNumeric() - might slow, uses a sparse array apa */
4232259aa2eSHong Zhang   /* set default scalable */
4242259aa2eSHong Zhang   ptap->scalable = PETSC_FALSE; //PETSC_TRUE;
4252259aa2eSHong Zhang 
42615a3b8e2SHong Zhang   ierr = PetscOptionsGetBool(((PetscObject)(*C))->prefix,"-matptap_scalable",&ptap->scalable,NULL);CHKERRQ(ierr);
4272259aa2eSHong Zhang   if (!ptap->scalable) {  /* Do dense axpy */
4282259aa2eSHong Zhang     ierr = PetscCalloc1(P->cmap->N,&ptap->apa);CHKERRQ(ierr);
4292259aa2eSHong Zhang   } else {
4302259aa2eSHong Zhang     //ierr = PetscCalloc1(ap_rmax+1,&ptap->apa);CHKERRQ(ierr);
4312259aa2eSHong Zhang   }
4322259aa2eSHong Zhang 
43380bb4639SHong Zhang   ierr = PetscTime(&t4);CHKERRQ(ierr);
43480bb4639SHong Zhang   if (rank == 1) printf("PtAPSym: %g + %g + %g = %g\n",t1-t0,t2-t1,t3-t2,t4-t3);
4350d3441aeSHong Zhang   PetscFunctionReturn(0);
4360d3441aeSHong Zhang }
4370d3441aeSHong Zhang 
4380d3441aeSHong Zhang #undef __FUNCT__
4390d3441aeSHong Zhang #define __FUNCT__ "MatPtAPNumeric_MPIAIJ_MPIAIJ_new"
4400d3441aeSHong Zhang PetscErrorCode MatPtAPNumeric_MPIAIJ_MPIAIJ_new(Mat A,Mat P,Mat C)
4410d3441aeSHong Zhang {
4420d3441aeSHong Zhang   PetscErrorCode    ierr;
4430d3441aeSHong Zhang   Mat_MPIAIJ        *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
4440d3441aeSHong Zhang   Mat_SeqAIJ        *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
4450d3441aeSHong Zhang   Mat_PtAPMPI       *ptap = c->ptap;
4469ce11a7cSHong Zhang   Mat               AP_loc,C_loc,C_oth;
4470d3441aeSHong Zhang   PetscInt          i,rstart,rend,cm,ncols,row;
4480d3441aeSHong Zhang   PetscMPIInt       rank;
4490d3441aeSHong Zhang   MPI_Comm          comm;
4500d3441aeSHong Zhang   const PetscInt    *cols;
4510d3441aeSHong Zhang   const PetscScalar *vals;
4520d3441aeSHong Zhang   PetscLogDouble    t0,t1,t2,t3,t4,eR,eAP,eCseq,eCmpi;
4530d3441aeSHong Zhang 
4540d3441aeSHong Zhang   PetscFunctionBegin;
4550d3441aeSHong Zhang   ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr);
4560d3441aeSHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
4570d3441aeSHong Zhang 
4580d3441aeSHong Zhang   ierr = MatZeroEntries(C);CHKERRQ(ierr);
4590d3441aeSHong Zhang 
460e497d3c8SHong Zhang   /* 1) get R = Pd^T,Ro = Po^T */
4610d3441aeSHong Zhang   ierr = PetscTime(&t0);CHKERRQ(ierr);
462748c7196SHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
4630d3441aeSHong Zhang     ierr = MatTranspose_SeqAIJ(p->A,MAT_REUSE_MATRIX,&ptap->Rd);CHKERRQ(ierr);
4640d3441aeSHong Zhang     ierr = MatTranspose_SeqAIJ(p->B,MAT_REUSE_MATRIX,&ptap->Ro);CHKERRQ(ierr);
465748c7196SHong Zhang   }
4660d3441aeSHong Zhang   ierr = PetscTime(&t1);CHKERRQ(ierr);
4670d3441aeSHong Zhang   eR = t1 - t0;
4680d3441aeSHong Zhang 
469e497d3c8SHong Zhang   /* 2) get AP_loc */
4700d3441aeSHong Zhang   AP_loc = ptap->AP_loc;
471e497d3c8SHong Zhang   Mat_SeqAIJ    *ap=(Mat_SeqAIJ*)AP_loc->data;
4720d3441aeSHong Zhang 
473e497d3c8SHong Zhang   /* 2-1) get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
4740d3441aeSHong Zhang   /*-----------------------------------------------------*/
475748c7196SHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
476748c7196SHong Zhang     /* P_oth and P_loc are obtained in MatPtASymbolic() when reuse == MAT_INITIAL_MATRIX */
4770d3441aeSHong Zhang     ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
4780d3441aeSHong Zhang     ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
479e497d3c8SHong Zhang   }
4800d3441aeSHong Zhang 
481e497d3c8SHong Zhang   /* 2-2) compute numeric C_seq = P_loc^T*A_loc*P - dominating part */
4820d3441aeSHong Zhang   /*--------------------------------------------------------------*/
4830d3441aeSHong Zhang   /* get data from symbolic products */
4840d3441aeSHong Zhang   Mat_SeqAIJ  *p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data;
4850d3441aeSHong Zhang   Mat_SeqAIJ  *p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data;
486e497d3c8SHong Zhang   PetscInt    *api,*apj,am = A->rmap->n,j,col,apnz;
487e497d3c8SHong Zhang   PetscScalar *apa = ptap->apa;
488748c7196SHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
4892259aa2eSHong Zhang     api = ap->i;
4902259aa2eSHong Zhang     apj = ap->j;
491e497d3c8SHong Zhang     for (i=0; i<am; i++) {
492e497d3c8SHong Zhang       /* AP[i,:] = A[i,:]*P = Ad*P_loc Ao*P_oth */
493e497d3c8SHong Zhang       AProw_nonscalable(i,ad,ao,p_loc,p_oth,apa);
494e497d3c8SHong Zhang       apnz = api[i+1] - api[i];
495e497d3c8SHong Zhang       for (j=0; j<apnz; j++) {
496e497d3c8SHong Zhang         col = apj[j+api[i]];
497e497d3c8SHong Zhang         ap->a[j+ap->i[i]] = apa[col];
498e497d3c8SHong Zhang         apa[col] = 0.0;
4990d3441aeSHong Zhang       }
5000d3441aeSHong Zhang     }
501748c7196SHong Zhang   }
5020d3441aeSHong Zhang 
5030d3441aeSHong Zhang   ierr = PetscTime(&t2);CHKERRQ(ierr);
5040d3441aeSHong Zhang   eAP = t2 - t1;
5050d3441aeSHong Zhang 
506e497d3c8SHong Zhang   /* 3) C_loc = R*AP_loc, Co = Ro*AP_loc */
507748c7196SHong Zhang   if (ptap->reuse == MAT_REUSE_MATRIX) {
5089ce11a7cSHong Zhang     ierr = MatMatMult_SeqAIJ_SeqAIJ(ptap->Rd,AP_loc,MAT_REUSE_MATRIX,2.0,&ptap->C_loc);CHKERRQ(ierr);
5099ce11a7cSHong Zhang     ierr = MatMatMult_SeqAIJ_SeqAIJ(ptap->Ro,AP_loc,MAT_REUSE_MATRIX,2.0,&ptap->C_oth);CHKERRQ(ierr);
510748c7196SHong Zhang   }
5119ce11a7cSHong Zhang   C_loc = ptap->C_loc;
5129ce11a7cSHong Zhang   C_oth = ptap->C_oth;
5130d3441aeSHong Zhang   //printf("[%d] Co %d, %d\n", rank,Co->rmap->N,Co->cmap->N);
5140d3441aeSHong Zhang   ierr = PetscTime(&t3);CHKERRQ(ierr);
5150d3441aeSHong Zhang   eCseq = t3 - t2;
5160d3441aeSHong Zhang 
5170d3441aeSHong Zhang   /* add C_loc and Co to to C */
5180d3441aeSHong Zhang   ierr = MatGetOwnershipRange(C,&rstart,&rend);CHKERRQ(ierr);
5190d3441aeSHong Zhang 
5200d3441aeSHong Zhang   /* C_loc -> C */
5210d3441aeSHong Zhang   cm = C_loc->rmap->N;
5229ce11a7cSHong Zhang   Mat_SeqAIJ *c_seq;
5239ce11a7cSHong Zhang   c_seq = (Mat_SeqAIJ*)C_loc->data;
5240d3441aeSHong Zhang   for (i=0; i<cm; i++) {
5259ce11a7cSHong Zhang     ncols = c_seq->i[i+1] - c_seq->i[i];
5260d3441aeSHong Zhang     row = rstart + i;
5279ce11a7cSHong Zhang     cols = c_seq->j + c_seq->i[i];
5289ce11a7cSHong Zhang     vals = c_seq->a + c_seq->i[i];
5290d3441aeSHong Zhang     ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr);
5300d3441aeSHong Zhang   }
5310d3441aeSHong Zhang 
5320d3441aeSHong Zhang   /* Co -> C, off-processor part */
5330d3441aeSHong Zhang   //printf("[%d] p->B %d, %d\n",rank,p->B->rmap->N,p->B->cmap->N);
5349ce11a7cSHong Zhang   cm = C_oth->rmap->N;
5359ce11a7cSHong Zhang   c_seq = (Mat_SeqAIJ*)C_oth->data;
5369ce11a7cSHong Zhang   for (i=0; i<cm; i++) {
5379ce11a7cSHong Zhang     ncols = c_seq->i[i+1] - c_seq->i[i];
5380d3441aeSHong Zhang     row = p->garray[i];
5399ce11a7cSHong Zhang     cols = c_seq->j + c_seq->i[i];
5409ce11a7cSHong Zhang     vals = c_seq->a + c_seq->i[i];
5410d3441aeSHong Zhang     //printf("[%d] row[%d] = %d\n",rank,i,row);
5420d3441aeSHong Zhang     ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr);
5430d3441aeSHong Zhang   }
5440d3441aeSHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
5450d3441aeSHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
5460d3441aeSHong Zhang   ierr = PetscTime(&t4);CHKERRQ(ierr);
5470d3441aeSHong Zhang   eCmpi = t4 - t3;
5480d3441aeSHong Zhang 
5490d3441aeSHong Zhang   if (rank==1) {
5500d3441aeSHong Zhang     ierr = PetscPrintf(MPI_COMM_SELF," R %g, AP %g, Cseq %g, Cmpi %g = %g\n", eR,eAP,eCseq,eCmpi,eR+eAP+eCseq+eCmpi);CHKERRQ(ierr);
5510d3441aeSHong Zhang   }
552748c7196SHong Zhang   ptap->reuse = MAT_REUSE_MATRIX;
5530d3441aeSHong Zhang   PetscFunctionReturn(0);
5540d3441aeSHong Zhang }
5550d3441aeSHong Zhang 
5560d3441aeSHong Zhang #undef __FUNCT__
55742c57489SHong Zhang #define __FUNCT__ "MatPtAPSymbolic_MPIAIJ_MPIAIJ"
55842c57489SHong Zhang PetscErrorCode MatPtAPSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat *C)
55942c57489SHong Zhang {
56042c57489SHong Zhang   PetscErrorCode      ierr;
56177584fe6SHong Zhang   Mat                 Cmpi;
562f8487c73SHong Zhang   Mat_PtAPMPI         *ptap;
5630298fd71SBarry Smith   PetscFreeSpaceList  free_space=NULL,current_space=NULL;
564f8487c73SHong Zhang   Mat_MPIAIJ          *a        =(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c;
56542c57489SHong Zhang   Mat_SeqAIJ          *ad       =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
56642c57489SHong Zhang   Mat_SeqAIJ          *p_loc,*p_oth;
567ded4f561SHong Zhang   PetscInt            *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pdti,*pdtj,*poti,*potj,*ptJ;
56877584fe6SHong Zhang   PetscInt            *adi=ad->i,*aj,*aoi=ao->i,nnz;
569a914927fSHong Zhang   PetscInt            *lnk,*owners_co,*coi,*coj,i,k,pnz,row;
570d16ca5f0SHong Zhang   PetscInt            am=A->rmap->n,pN=P->cmap->N,pm=P->rmap->n,pn=P->cmap->n;
57142c57489SHong Zhang   PetscBT             lnkbt;
572ce94432eSBarry Smith   MPI_Comm            comm;
573a914927fSHong Zhang   PetscMPIInt         size,rank,tagi,tagj,*len_si,*len_s,*len_ri,icompleted=0;
57442c57489SHong Zhang   PetscInt            **buf_rj,**buf_ri,**buf_ri_k;
57542c57489SHong Zhang   PetscInt            len,proc,*dnz,*onz,*owners;
57624ecddacSHong Zhang   PetscInt            nzi,*pti,*ptj;
57742c57489SHong Zhang   PetscInt            nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci;
578ded4f561SHong Zhang   MPI_Request         *swaits,*rwaits;
579ded4f561SHong Zhang   MPI_Status          *sstatus,rstatus;
58042c57489SHong Zhang   Mat_Merge_SeqsToMPI *merge;
58177584fe6SHong Zhang   PetscInt            *api,*apj,*Jptr,apnz,*prmap=p->garray,pon,nspacedouble=0,j,ap_rmax=0;
582d16ca5f0SHong Zhang   PetscReal           afill=1.0,afill_tmp;
583a914927fSHong Zhang   PetscInt            rmax;
58442c57489SHong Zhang 
58542c57489SHong Zhang   PetscFunctionBegin;
586ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr);
58724ecddacSHong Zhang 
588c5af039cSHong Zhang   /* check if matrix local sizes are compatible */
589c5af039cSHong Zhang   if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) {
590c5af039cSHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Arow (%D, %D) != Prow (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend);
591c5af039cSHong Zhang   }
592c5af039cSHong Zhang   if (A->cmap->rstart != P->rmap->rstart || A->cmap->rend != P->rmap->rend) {
593c5af039cSHong Zhang     SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Acol (%D, %D) != Prow (%D,%D)",A->cmap->rstart,A->cmap->rend,P->rmap->rstart,P->rmap->rend);
594c5af039cSHong Zhang   }
595c5af039cSHong Zhang 
59683445d95SHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
59783445d95SHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
59883445d95SHong Zhang 
599f8487c73SHong Zhang   /* create struct Mat_PtAPMPI and attached it to C later */
600b00a9115SJed Brown   ierr        = PetscNew(&ptap);CHKERRQ(ierr);
601b00a9115SJed Brown   ierr        = PetscNew(&merge);CHKERRQ(ierr);
6029f4155fbSHong Zhang   ptap->merge = merge;
603f8487c73SHong Zhang   ptap->reuse = MAT_INITIAL_MATRIX;
6046c6e00e0SHong Zhang 
6056c6e00e0SHong Zhang   /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */
606b7f45c76SHong Zhang   ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
607fe615159SHong Zhang 
6086c6e00e0SHong Zhang   /* get P_loc by taking all local rows of P */
609a1a4e84aSHong Zhang   ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
6106c6e00e0SHong Zhang 
611a1a4e84aSHong Zhang   p_loc  = (Mat_SeqAIJ*)(ptap->P_loc)->data;
612a1a4e84aSHong Zhang   p_oth  = (Mat_SeqAIJ*)(ptap->P_oth)->data;
6136c6e00e0SHong Zhang   pi_loc = p_loc->i; pj_loc = p_loc->j;
6146c6e00e0SHong Zhang   pi_oth = p_oth->i; pj_oth = p_oth->j;
61542c57489SHong Zhang 
6162addb229SHong Zhang   /* (1) compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth (api,apj) */
6172addb229SHong Zhang   /*--------------------------------------------------------------------------*/
618854ce69bSBarry Smith   ierr   = PetscMalloc1(am+1,&api);CHKERRQ(ierr);
61982412ba7SHong Zhang   api[0] = 0;
62083445d95SHong Zhang 
62183445d95SHong Zhang   /* create and initialize a linked list */
622a914927fSHong Zhang   ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr);
62383445d95SHong Zhang 
624a914927fSHong Zhang   /* Initial FreeSpace size is fill*(nnz(A) + nnz(P)) -OOM for ex56, np=8k on Intrepid! */
625d16ca5f0SHong Zhang   ierr = PetscFreeSpaceGet((PetscInt)(fill*(adi[am]+aoi[am]+pi_loc[pm])),&free_space);CHKERRQ(ierr);
6262205254eSKarl Rupp 
627f4a743e1SHong Zhang   current_space = free_space;
628f4a743e1SHong Zhang 
629f4a743e1SHong Zhang   for (i=0; i<am; i++) {
630f4a743e1SHong Zhang     /* diagonal portion of A */
631ded4f561SHong Zhang     nzi = adi[i+1] - adi[i];
63277584fe6SHong Zhang     aj  = ad->j + adi[i];
633ded4f561SHong Zhang     for (j=0; j<nzi; j++) {
63477584fe6SHong Zhang       row  = aj[j];
63582412ba7SHong Zhang       pnz  = pi_loc[row+1] - pi_loc[row];
636ded4f561SHong Zhang       Jptr = pj_loc + pi_loc[row];
63783445d95SHong Zhang       /* add non-zero cols of P into the sorted linked list lnk */
638a914927fSHong Zhang       ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
639f4a743e1SHong Zhang     }
640f4a743e1SHong Zhang     /* off-diagonal portion of A */
641ded4f561SHong Zhang     nzi = aoi[i+1] - aoi[i];
64277584fe6SHong Zhang     aj  = ao->j + aoi[i];
643ded4f561SHong Zhang     for (j=0; j<nzi; j++) {
64477584fe6SHong Zhang       row  = aj[j];
64582412ba7SHong Zhang       pnz  = pi_oth[row+1] - pi_oth[row];
646ded4f561SHong Zhang       Jptr = pj_oth + pi_oth[row];
647a914927fSHong Zhang       ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
648f4a743e1SHong Zhang     }
649a914927fSHong Zhang     apnz     = lnk[0];
65082412ba7SHong Zhang     api[i+1] = api[i] + apnz;
65177584fe6SHong Zhang     if (ap_rmax < apnz) ap_rmax = apnz;
652f4a743e1SHong Zhang 
65383445d95SHong Zhang     /* if free space is not available, double the total space in the list */
65482412ba7SHong Zhang     if (current_space->local_remaining<apnz) {
6552ba1acd5SHong Zhang       ierr = PetscFreeSpaceGet(apnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
656f2b054eeSHong Zhang       nspacedouble++;
657f4a743e1SHong Zhang     }
658f4a743e1SHong Zhang 
659f4a743e1SHong Zhang     /* Copy data into free space, then initialize lnk */
660a914927fSHong Zhang     ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
6612205254eSKarl Rupp 
66282412ba7SHong Zhang     current_space->array           += apnz;
66382412ba7SHong Zhang     current_space->local_used      += apnz;
66482412ba7SHong Zhang     current_space->local_remaining -= apnz;
665f4a743e1SHong Zhang   }
666a914927fSHong Zhang 
66782412ba7SHong Zhang   /* Allocate space for apj, initialize apj, and */
668f4a743e1SHong Zhang   /* destroy list of free space and other temporary array(s) */
669854ce69bSBarry Smith   ierr      = PetscMalloc1(api[am]+1,&apj);CHKERRQ(ierr);
67077584fe6SHong Zhang   ierr      = PetscFreeSpaceContiguous(&free_space,apj);CHKERRQ(ierr);
671118727c9SMark F. Adams   afill_tmp = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1);
672d16ca5f0SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
673f4a743e1SHong Zhang 
6742addb229SHong Zhang   /* (2) determine symbolic Co=(p->B)^T*AP - send to others (coi,coj)*/
6752addb229SHong Zhang   /*-----------------------------------------------------------------*/
676de0260b3SHong Zhang   ierr = MatGetSymbolicTranspose_SeqAIJ(p->B,&poti,&potj);CHKERRQ(ierr);
67742c57489SHong Zhang 
678ded4f561SHong Zhang   /* then, compute symbolic Co = (p->B)^T*AP */
679d0f46423SBarry Smith   pon    = (p->B)->cmap->n; /* total num of rows to be sent to other processors
68083445d95SHong Zhang                          >= (num of nonzero rows of C_seq) - pn */
681854ce69bSBarry Smith   ierr   = PetscMalloc1(pon+1,&coi);CHKERRQ(ierr);
682de0260b3SHong Zhang   coi[0] = 0;
68342c57489SHong Zhang 
684d16ca5f0SHong Zhang   /* set initial free space to be fill*(nnz(p->B) + nnz(AP)) */
685d16ca5f0SHong Zhang   nnz           = fill*(poti[pon] + api[am]);
68622d28d08SBarry Smith   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
68742c57489SHong Zhang   current_space = free_space;
68842c57489SHong Zhang 
689de0260b3SHong Zhang   for (i=0; i<pon; i++) {
69082412ba7SHong Zhang     pnz = poti[i+1] - poti[i];
69177584fe6SHong Zhang     ptJ = potj + poti[i];
69277584fe6SHong Zhang     for (j=0; j<pnz; j++) {
69377584fe6SHong Zhang       row  = ptJ[j]; /* row of AP == col of Pot */
69482412ba7SHong Zhang       apnz = api[row+1] - api[row];
695ded4f561SHong Zhang       Jptr = apj + api[row];
69683445d95SHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
697a914927fSHong Zhang       ierr = PetscLLCondensedAddSorted(apnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
69842c57489SHong Zhang     }
699a914927fSHong Zhang     nnz = lnk[0];
70042c57489SHong Zhang 
70183445d95SHong Zhang     /* If free space is not available, double the total space in the list */
702ded4f561SHong Zhang     if (current_space->local_remaining<nnz) {
7034238b7adSHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
704d16ca5f0SHong Zhang       nspacedouble++;
70542c57489SHong Zhang     }
70642c57489SHong Zhang 
70742c57489SHong Zhang     /* Copy data into free space, and zero out denserows */
708a914927fSHong Zhang     ierr = PetscLLCondensedClean(pN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
7092205254eSKarl Rupp 
710ded4f561SHong Zhang     current_space->array           += nnz;
711ded4f561SHong Zhang     current_space->local_used      += nnz;
712ded4f561SHong Zhang     current_space->local_remaining -= nnz;
7132205254eSKarl Rupp 
714ded4f561SHong Zhang     coi[i+1] = coi[i] + nnz;
71542c57489SHong Zhang   }
7166b911d16SHong Zhang 
7176b911d16SHong Zhang   ierr      = PetscMalloc1(coi[pon],&coj);CHKERRQ(ierr);
718a1a86e44SBarry Smith   ierr      = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr);
719118727c9SMark F. Adams   afill_tmp = (PetscReal)coi[pon]/(poti[pon] + api[am]+1);
720d16ca5f0SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
721de0260b3SHong Zhang   ierr = MatRestoreSymbolicTranspose_SeqAIJ(p->B,&poti,&potj);CHKERRQ(ierr);
72242c57489SHong Zhang 
7236b911d16SHong Zhang   /* (3) send j-array (coj) of Co to other processors */
7246b911d16SHong Zhang   /*--------------------------------------------------*/
7256b911d16SHong Zhang   ierr = PetscCalloc1(size,&merge->len_s);CHKERRQ(ierr);
7266b911d16SHong Zhang   len_s        = merge->len_s;
7276b911d16SHong Zhang   merge->nsend = 0;
7286b911d16SHong Zhang 
7296b911d16SHong Zhang 
73042c57489SHong Zhang   /* determine row ownership */
73126283091SBarry Smith   ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr);
7327a2fc3feSBarry Smith   merge->rowmap->n  = pn;
7337a2fc3feSBarry Smith   merge->rowmap->bs = 1;
7342205254eSKarl Rupp 
73526283091SBarry Smith   ierr   = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr);
7367a2fc3feSBarry Smith   owners = merge->rowmap->range;
73742c57489SHong Zhang 
73842c57489SHong Zhang   /* determine the number of messages to send, their lengths */
739dcca6d9dSJed Brown   ierr = PetscMalloc2(size,&len_si,size,&sstatus);CHKERRQ(ierr);
74083445d95SHong Zhang   ierr = PetscMemzero(len_si,size*sizeof(PetscMPIInt));CHKERRQ(ierr);
741854ce69bSBarry Smith   ierr = PetscMalloc1(size+2,&owners_co);CHKERRQ(ierr);
742de0260b3SHong Zhang 
74383445d95SHong Zhang   proc = 0;
744de0260b3SHong Zhang   for (i=0; i<pon; i++) {
745de0260b3SHong Zhang     while (prmap[i] >= owners[proc+1]) proc++;
7462addb229SHong Zhang     len_si[proc]++;               /* num of rows in Co(=Pt*AP) to be sent to [proc] */
747ee6e4b5bSHong Zhang     len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */
74883445d95SHong Zhang   }
749de0260b3SHong Zhang 
7502addb229SHong Zhang   len          = 0; /* max length of buf_si[], see (4) */
751de0260b3SHong Zhang   owners_co[0] = 0;
75242c57489SHong Zhang   for (proc=0; proc<size; proc++) {
753de0260b3SHong Zhang     owners_co[proc+1] = owners_co[proc] + len_si[proc];
754ee6e4b5bSHong Zhang     if (len_s[proc]) {
75542c57489SHong Zhang       merge->nsend++;
7562addb229SHong Zhang       len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */
75742c57489SHong Zhang       len         += len_si[proc];
75842c57489SHong Zhang     }
75942c57489SHong Zhang   }
76042c57489SHong Zhang 
761ded4f561SHong Zhang   /* determine the number and length of messages to receive for coi and coj  */
7620298fd71SBarry Smith   ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr);
76342c57489SHong Zhang   ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr);
76442c57489SHong Zhang 
765ded4f561SHong Zhang   /* post the Irecv and Isend of coj */
766529bc5dcSHong Zhang   ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr);
767529bc5dcSHong Zhang   ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr);
768854ce69bSBarry Smith   ierr = PetscMalloc1(merge->nsend+1,&swaits);CHKERRQ(ierr);
76942c57489SHong Zhang   for (proc=0, k=0; proc<size; proc++) {
77042c57489SHong Zhang     if (!len_s[proc]) continue;
771de0260b3SHong Zhang     i    = owners_co[proc];
772529bc5dcSHong Zhang     ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr);
77342c57489SHong Zhang     k++;
77442c57489SHong Zhang   }
77542c57489SHong Zhang 
776ded4f561SHong Zhang   /* receives and sends of coj are complete */
77777584fe6SHong Zhang   for (i=0; i<merge->nrecv; i++) {
778c280ed6aSJed Brown     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
779ded4f561SHong Zhang   }
780ded4f561SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
7810c468ba9SBarry Smith   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
78282412ba7SHong Zhang 
7836b911d16SHong Zhang   /* (4) send and recv coi */
7846b911d16SHong Zhang   /*-----------------------*/
785529bc5dcSHong Zhang   ierr   = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr);
786529bc5dcSHong Zhang   ierr   = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr);
787854ce69bSBarry Smith   ierr   = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr);
78842c57489SHong Zhang   buf_si = buf_s;  /* points to the beginning of k-th msg to be sent */
78942c57489SHong Zhang   for (proc=0,k=0; proc<size; proc++) {
79042c57489SHong Zhang     if (!len_s[proc]) continue;
79142c57489SHong Zhang     /* form outgoing message for i-structure:
79242c57489SHong Zhang          buf_si[0]:                 nrows to be sent
79342c57489SHong Zhang                [1:nrows]:           row index (global)
79442c57489SHong Zhang                [nrows+1:2*nrows+1]: i-structure index
79542c57489SHong Zhang     */
79642c57489SHong Zhang     /*-------------------------------------------*/
7972addb229SHong Zhang     nrows       = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */
79842c57489SHong Zhang     buf_si_i    = buf_si + nrows+1;
79942c57489SHong Zhang     buf_si[0]   = nrows;
80042c57489SHong Zhang     buf_si_i[0] = 0;
80142c57489SHong Zhang     nrows       = 0;
802de0260b3SHong Zhang     for (i=owners_co[proc]; i<owners_co[proc+1]; i++) {
803ded4f561SHong Zhang       nzi = coi[i+1] - coi[i];
804ded4f561SHong Zhang       buf_si_i[nrows+1] = buf_si_i[nrows] + nzi;  /* i-structure */
805de0260b3SHong Zhang       buf_si[nrows+1]   = prmap[i] -owners[proc]; /* local row index */
80642c57489SHong Zhang       nrows++;
80742c57489SHong Zhang     }
808529bc5dcSHong Zhang     ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr);
80942c57489SHong Zhang     k++;
81042c57489SHong Zhang     buf_si += len_si[proc];
81142c57489SHong Zhang   }
812ded4f561SHong Zhang   i = merge->nrecv;
813ded4f561SHong Zhang   while (i--) {
814c280ed6aSJed Brown     ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr);
815ded4f561SHong Zhang   }
816ded4f561SHong Zhang   ierr = PetscFree(rwaits);CHKERRQ(ierr);
8170c468ba9SBarry Smith   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);}
818a914927fSHong Zhang 
81924ecddacSHong Zhang   ierr = PetscFree2(len_si,sstatus);CHKERRQ(ierr);
82042c57489SHong Zhang   ierr = PetscFree(len_ri);CHKERRQ(ierr);
821ded4f561SHong Zhang   ierr = PetscFree(swaits);CHKERRQ(ierr);
82242c57489SHong Zhang   ierr = PetscFree(buf_s);CHKERRQ(ierr);
82342c57489SHong Zhang 
8246b911d16SHong Zhang   /* (5) compute the local portion of C (mpi mat) */
8256b911d16SHong Zhang   /*----------------------------------------------*/
826ded4f561SHong Zhang   ierr = MatGetSymbolicTranspose_SeqAIJ(p->A,&pdti,&pdtj);CHKERRQ(ierr);
827ded4f561SHong Zhang 
82824ecddacSHong Zhang   /* allocate pti array and free space for accumulating nonzero column info */
829854ce69bSBarry Smith   ierr   = PetscMalloc1(pn+1,&pti);CHKERRQ(ierr);
83024ecddacSHong Zhang   pti[0] = 0;
83142c57489SHong Zhang 
832d16ca5f0SHong Zhang   /* set initial free space to be fill*(nnz(P) + nnz(AP)) */
833d16ca5f0SHong Zhang   nnz           = fill*(pi_loc[pm] + api[am]);
83422d28d08SBarry Smith   ierr          = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr);
83542c57489SHong Zhang   current_space = free_space;
83642c57489SHong Zhang 
837dcca6d9dSJed Brown   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
83842c57489SHong Zhang   for (k=0; k<merge->nrecv; k++) {
83942c57489SHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
84042c57489SHong Zhang     nrows       = *buf_ri_k[k];
84142c57489SHong Zhang     nextrow[k]  = buf_ri_k[k] + 1;  /* next row number of k-th recved i-structure */
84242c57489SHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
84342c57489SHong Zhang   }
84442c57489SHong Zhang   ierr = MatPreallocateInitialize(comm,pn,pn,dnz,onz);CHKERRQ(ierr);
84508cb4532SHong Zhang   rmax = 0;
84642c57489SHong Zhang   for (i=0; i<pn; i++) {
847ded4f561SHong Zhang     /* add pdt[i,:]*AP into lnk */
848ded4f561SHong Zhang     pnz = pdti[i+1] - pdti[i];
84977584fe6SHong Zhang     ptJ = pdtj + pdti[i];
85077584fe6SHong Zhang     for (j=0; j<pnz; j++) {
85177584fe6SHong Zhang       row  = ptJ[j];  /* row of AP == col of Pt */
852ded4f561SHong Zhang       apnz = api[row+1] - api[row];
853ded4f561SHong Zhang       Jptr = apj + api[row];
854ded4f561SHong Zhang       /* add non-zero cols of AP into the sorted linked list lnk */
855a914927fSHong Zhang       ierr = PetscLLCondensedAddSorted(apnz,Jptr,lnk,lnkbt);CHKERRQ(ierr);
856ded4f561SHong Zhang     }
857a914927fSHong Zhang 
85842c57489SHong Zhang     /* add received col data into lnk */
85942c57489SHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
86042c57489SHong Zhang       if (i == *nextrow[k]) { /* i-th row */
861ded4f561SHong Zhang         nzi  = *(nextci[k]+1) - *nextci[k];
862ded4f561SHong Zhang         Jptr = buf_rj[k] + *nextci[k];
863a914927fSHong Zhang         ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr);
86442c57489SHong Zhang         nextrow[k]++; nextci[k]++;
86542c57489SHong Zhang       }
86642c57489SHong Zhang     }
867a914927fSHong Zhang     nnz = lnk[0];
86842c57489SHong Zhang 
86942c57489SHong Zhang     /* if free space is not available, make more free space */
870ded4f561SHong Zhang     if (current_space->local_remaining<nnz) {
8714238b7adSHong Zhang       ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,&current_space);CHKERRQ(ierr);
872d16ca5f0SHong Zhang       nspacedouble++;
87342c57489SHong Zhang     }
87442c57489SHong Zhang     /* copy data into free space, then initialize lnk */
875a914927fSHong Zhang     ierr = PetscLLCondensedClean(pN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr);
876ded4f561SHong Zhang     ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr);
8772205254eSKarl Rupp 
878ded4f561SHong Zhang     current_space->array           += nnz;
879ded4f561SHong Zhang     current_space->local_used      += nnz;
880ded4f561SHong Zhang     current_space->local_remaining -= nnz;
8812205254eSKarl Rupp 
88224ecddacSHong Zhang     pti[i+1] = pti[i] + nnz;
88308cb4532SHong Zhang     if (nnz > rmax) rmax = nnz;
88442c57489SHong Zhang   }
885ded4f561SHong Zhang   ierr = MatRestoreSymbolicTranspose_SeqAIJ(p->A,&pdti,&pdtj);CHKERRQ(ierr);
8860572522cSBarry Smith   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
88742c57489SHong Zhang 
888854ce69bSBarry Smith   ierr      = PetscMalloc1(pti[pn]+1,&ptj);CHKERRQ(ierr);
88924ecddacSHong Zhang   ierr      = PetscFreeSpaceContiguous(&free_space,ptj);CHKERRQ(ierr);
89024ecddacSHong Zhang   afill_tmp = (PetscReal)pti[pn]/(pi_loc[pm] + api[am]+1);
891d16ca5f0SHong Zhang   if (afill_tmp > afill) afill = afill_tmp;
89242c57489SHong Zhang   ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr);
89342c57489SHong Zhang 
8946b911d16SHong Zhang   /* (6) create symbolic parallel matrix Cmpi */
8956b911d16SHong Zhang   /*------------------------------------------*/
89677584fe6SHong Zhang   ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr);
89777584fe6SHong Zhang   ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr);
89833d57670SJed Brown   ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(P->cmap->bs));CHKERRQ(ierr);
89977584fe6SHong Zhang   ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr);
90077584fe6SHong Zhang   ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr);
90142c57489SHong Zhang   ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr);
902a2f3521dSMark F. Adams 
903b091e509SHong Zhang   merge->bi        = pti;      /* Cseq->i */
904b091e509SHong Zhang   merge->bj        = ptj;      /* Cseq->j */
905b091e509SHong Zhang   merge->coi       = coi;      /* Co->i   */
906b091e509SHong Zhang   merge->coj       = coj;      /* Co->j   */
90742c57489SHong Zhang   merge->buf_ri    = buf_ri;
90842c57489SHong Zhang   merge->buf_rj    = buf_rj;
909de0260b3SHong Zhang   merge->owners_co = owners_co;
91077584fe6SHong Zhang   merge->destroy   = Cmpi->ops->destroy;
91177584fe6SHong Zhang   merge->duplicate = Cmpi->ops->duplicate;
912cc6cb787SHong Zhang 
91377584fe6SHong Zhang   /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */
914a914927fSHong Zhang   Cmpi->assembled      = PETSC_FALSE;
91577584fe6SHong Zhang   Cmpi->ops->destroy   = MatDestroy_MPIAIJ_PtAP;
91677584fe6SHong Zhang   Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatPtAP;
91742c57489SHong Zhang 
91877584fe6SHong Zhang   /* attach the supporting struct to Cmpi for reuse */
91977584fe6SHong Zhang   c           = (Mat_MPIAIJ*)Cmpi->data;
920f8487c73SHong Zhang   c->ptap     = ptap;
92177584fe6SHong Zhang   ptap->api   = api;
92277584fe6SHong Zhang   ptap->apj   = apj;
923d6ab1dc0SHong Zhang   ptap->rmax  = ap_rmax;
92477584fe6SHong Zhang   *C          = Cmpi;
925414894bdSHong Zhang 
926414894bdSHong Zhang   /* flag 'scalable' determines which implementations to be used:
927414894bdSHong Zhang        0: do dense axpy in MatPtAPNumeric() - fast, but requires storage of a nonscalable dense array apa;
928414894bdSHong Zhang        1: do sparse axpy in MatPtAPNumeric() - might slow, uses a sparse array apa */
929414894bdSHong Zhang   /* set default scalable */
9309516a85cSHong Zhang   ptap->scalable = PETSC_FALSE; //PETSC_TRUE;
9312205254eSKarl Rupp 
9320298fd71SBarry Smith   ierr = PetscOptionsGetBool(((PetscObject)Cmpi)->prefix,"-matptap_scalable",&ptap->scalable,NULL);CHKERRQ(ierr);
933414894bdSHong Zhang   if (!ptap->scalable) {  /* Do dense axpy */
9341795a4d1SJed Brown     ierr = PetscCalloc1(pN,&ptap->apa);CHKERRQ(ierr);
935414894bdSHong Zhang   } else {
9361795a4d1SJed Brown     ierr = PetscCalloc1(ap_rmax+1,&ptap->apa);CHKERRQ(ierr);
937414894bdSHong Zhang   }
938414894bdSHong Zhang 
939f2b054eeSHong Zhang #if defined(PETSC_USE_INFO)
94024ecddacSHong Zhang   if (pti[pn] != 0) {
94157622a8eSBarry Smith     ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr);
94257622a8eSBarry Smith     ierr = PetscInfo1(Cmpi,"Use MatPtAP(A,P,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr);
943f2b054eeSHong Zhang   } else {
94477584fe6SHong Zhang     ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr);
945f2b054eeSHong Zhang   }
946f2b054eeSHong Zhang #endif
94742c57489SHong Zhang   PetscFunctionReturn(0);
94842c57489SHong Zhang }
94942c57489SHong Zhang 
95042c57489SHong Zhang #undef __FUNCT__
95142c57489SHong Zhang #define __FUNCT__ "MatPtAPNumeric_MPIAIJ_MPIAIJ"
95242c57489SHong Zhang PetscErrorCode MatPtAPNumeric_MPIAIJ_MPIAIJ(Mat A,Mat P,Mat C)
95342c57489SHong Zhang {
95442c57489SHong Zhang   PetscErrorCode      ierr;
955f8487c73SHong Zhang   Mat_MPIAIJ          *a =(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data;
95642c57489SHong Zhang   Mat_SeqAIJ          *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data;
957de0260b3SHong Zhang   Mat_SeqAIJ          *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data;
95842c57489SHong Zhang   Mat_SeqAIJ          *p_loc,*p_oth;
959f8487c73SHong Zhang   Mat_PtAPMPI         *ptap;
9609f4155fbSHong Zhang   Mat_Merge_SeqsToMPI *merge;
9611d633602SHong Zhang   PetscInt            *adi=ad->i,*aoi=ao->i,*adj,*aoj,*apJ,nextp;
96282412ba7SHong Zhang   PetscInt            *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pJ,*pj;
96382412ba7SHong Zhang   PetscInt            i,j,k,anz,pnz,apnz,nextap,row,*cj;
964e900a757SHong Zhang   MatScalar           *ada,*aoa,*apa,*pa,*ca,*pa_loc,*pa_oth,valtmp;
965d0f46423SBarry Smith   PetscInt            am  =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n;
966ce94432eSBarry Smith   MPI_Comm            comm;
96742c57489SHong Zhang   PetscMPIInt         size,rank,taga,*len_s;
96882412ba7SHong Zhang   PetscInt            *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci;
96942c57489SHong Zhang   PetscInt            **buf_ri,**buf_rj;
97050f5bf86SHong Zhang   PetscInt            cnz=0,*bj_i,*bi,*bj,bnz,nextcj;  /* bi,bj,ba: local array of C(mpi mat) */
97142c57489SHong Zhang   MPI_Request         *s_waits,*r_waits;
97242c57489SHong Zhang   MPI_Status          *status;
97382412ba7SHong Zhang   MatScalar           **abuf_r,*ba_i,*pA,*coa,*ba;
97482412ba7SHong Zhang   PetscInt            *api,*apj,*coi,*coj;
975d0f46423SBarry Smith   PetscInt            *poJ=po->j,*pdJ=pd->j,pcstart=P->cmap->rstart,pcend=P->cmap->rend;
9766ce94e8fSHong Zhang   PetscBool           scalable;
97738571addSHong Zhang #if defined(PTAP_PROFILE)
978e497d3c8SHong Zhang   PetscLogDouble t0,t1,t2,eP,t3,t4,et2_AP=0.0,ePtAP=0.0,t2_0,t2_1,t2_2;
97938571addSHong Zhang #endif
98042c57489SHong Zhang 
98142c57489SHong Zhang   PetscFunctionBegin;
982ce94432eSBarry Smith   ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr);
98338571addSHong Zhang #if defined(PTAP_PROFILE)
9848563dfccSBarry Smith   ierr = PetscTime(&t0);CHKERRQ(ierr);
98538571addSHong Zhang #endif
98642c57489SHong Zhang   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
98742c57489SHong Zhang   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
98842c57489SHong Zhang 
989f8487c73SHong Zhang   ptap = c->ptap;
990ce94432eSBarry Smith   if (!ptap) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_INCOMP,"MatPtAP() has not been called to create matrix C yet, cannot use MAT_REUSE_MATRIX");
991f8487c73SHong Zhang   merge    = ptap->merge;
992414894bdSHong Zhang   apa      = ptap->apa;
9936ce94e8fSHong Zhang   scalable = ptap->scalable;
9946c6e00e0SHong Zhang 
995a1a4e84aSHong Zhang   /* 1) get P_oth = ptap->P_oth  and P_loc = ptap->P_loc */
9966b911d16SHong Zhang   /*-----------------------------------------------------*/
997f8487c73SHong Zhang   if (ptap->reuse == MAT_INITIAL_MATRIX) {
9989f4155fbSHong Zhang     /* P_oth and P_loc are obtained in MatPtASymbolic(), skip calling MatGetBrowsOfAoCols() and MatMPIAIJGetLocalMat() */
999f8487c73SHong Zhang     ptap->reuse = MAT_REUSE_MATRIX;
10006c6e00e0SHong Zhang   } else { /* update numerical values of P_oth and P_loc */
1001b7f45c76SHong Zhang     ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr);
1002a1a4e84aSHong Zhang     ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr);
10036c6e00e0SHong Zhang   }
100438571addSHong Zhang #if defined(PTAP_PROFILE)
10058563dfccSBarry Smith   ierr = PetscTime(&t1);CHKERRQ(ierr);
100605d62848SHong Zhang   eP = t1-t0;
100738571addSHong Zhang #endif
100805d62848SHong Zhang   /*
100905d62848SHong Zhang   printf("[%d] Ad: %d, %d; Ao: %d, %d; P_loc: %d, %d; P_oth %d, %d;\n",rank,
101005d62848SHong Zhang          a->A->rmap->N,a->A->cmap->N,a->B->rmap->N,a->B->cmap->N,
101105d62848SHong Zhang          ptap->P_loc->rmap->N,ptap->P_loc->cmap->N,
101205d62848SHong Zhang          ptap->P_oth->rmap->N,ptap->P_oth->cmap->N);
101305d62848SHong Zhang    */
1014f8487c73SHong Zhang 
1015f9473cf7SHong Zhang   /* 2) compute numeric C_seq = P_loc^T*A_loc*P - dominating part */
1016f9473cf7SHong Zhang   /*--------------------------------------------------------------*/
101742c57489SHong Zhang   /* get data from symbolic products */
1018a1a4e84aSHong Zhang   p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data;
1019a1a4e84aSHong Zhang   p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data;
1020a9d06231SHong Zhang   pi_loc=p_loc->i; pj_loc=p_loc->j; pJ=pj_loc; pa_loc=p_loc->a;
102142c57489SHong Zhang   pi_oth=p_oth->i; pj_oth=p_oth->j; pa_oth=p_oth->a;
102242c57489SHong Zhang 
1023de0260b3SHong Zhang   coi  = merge->coi; coj = merge->coj;
10241795a4d1SJed Brown   ierr = PetscCalloc1(coi[pon]+1,&coa);CHKERRQ(ierr);
1025de0260b3SHong Zhang 
1026de0260b3SHong Zhang   bi     = merge->bi; bj = merge->bj;
10277a2fc3feSBarry Smith   owners = merge->rowmap->range;
10281795a4d1SJed Brown   ierr   = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr);  /* ba: Cseq->a */
102942c57489SHong Zhang 
1030a1a4e84aSHong Zhang   api = ptap->api; apj = ptap->apj;
1031d9824c15SHong Zhang 
10329516a85cSHong Zhang   if (!scalable) { /* Do dense axpy on apa (length of pN, stores A[i,:]*P) - nonscalable, but faster (could take 1/3 scalable time) */
1033b38d1a2dSJed Brown     ierr = PetscInfo(C,"Using non-scalable dense axpy\n");CHKERRQ(ierr);
103405d62848SHong Zhang #if 0
10350d3441aeSHong Zhang     /* ------ 10x slower -------------- */
10360d3441aeSHong Zhang     /*==================================*/
10379516a85cSHong Zhang     Mat         R = ptap->R;
10389516a85cSHong Zhang     Mat_SeqAIJ  *r = (Mat_SeqAIJ*)R->data;
10399516a85cSHong Zhang     PetscInt    *ri=r->i,*rj=r->j,rnz,arow,l,prow,pcol,pN=P->cmap->N;
10409516a85cSHong Zhang     PetscScalar *ra=r->a,tmp,cdense[pN];
10419516a85cSHong Zhang 
10429516a85cSHong Zhang     ierr = PetscMemzero(cdense,pN*sizeof(PetscScalar));CHKERRQ(ierr);
10439516a85cSHong Zhang     for (i=0; i<cm; i++) { /* each row of C or R */
10449516a85cSHong Zhang       rnz = ri[i+1] - ri[i];
10459516a85cSHong Zhang 
10469516a85cSHong Zhang       for (j=0; j<rnz; j++) { /* each nz of R */
10479516a85cSHong Zhang         arow = rj[ri[i] + j];
10489516a85cSHong Zhang 
10499516a85cSHong Zhang         /* diagonal portion of A */
10509516a85cSHong Zhang         anz  = ad->i[arow+1] - ad->i[arow];
10519516a85cSHong Zhang         for (k=0; k<anz; k++) { /* each nz of Ad */
10529516a85cSHong Zhang           tmp  = ra[ri[i] + j]*ad->a[ad->i[arow] + k];
10539516a85cSHong Zhang           prow = ad->j[ad->i[arow] + k];
10549516a85cSHong Zhang           pnz  = pi_loc[prow+1] - pi_loc[prow];
10559516a85cSHong Zhang 
10569516a85cSHong Zhang           for (l=0; l<pnz; l++) { /* each nz of P_loc */
10579516a85cSHong Zhang             pcol = pj_loc[pi_loc[prow] + l];
10589516a85cSHong Zhang             cdense[pcol] += tmp*pa_loc[pi_loc[prow] + l];
10599516a85cSHong Zhang           }
10609516a85cSHong Zhang         }
10619516a85cSHong Zhang 
10629516a85cSHong Zhang         /* off-diagonal portion of A */
10639516a85cSHong Zhang         anz  = ao->i[arow+1] - ao->i[arow];
10649516a85cSHong Zhang         for (k=0; k<anz; k++) { /* each nz of Ao */
10659516a85cSHong Zhang           tmp  = ra[ri[i] + j]*ao->a[ao->i[arow] + k];
10669516a85cSHong Zhang           prow = ao->j[ao->i[arow] + k];
10679516a85cSHong Zhang           pnz  = pi_oth[prow+1] - pi_oth[prow];
10689516a85cSHong Zhang 
10699516a85cSHong Zhang           for (l=0; l<pnz; l++) { /* each nz of P_oth */
10709516a85cSHong Zhang             pcol = pj_oth[pi_oth[prow] + l];
10719516a85cSHong Zhang             cdense[pcol] += tmp*pa_oth[pi_oth[prow] + l];
10729516a85cSHong Zhang           }
10739516a85cSHong Zhang         }
10749516a85cSHong Zhang 
10759516a85cSHong Zhang       } //for (j=0; j<rnz; j++)
10769516a85cSHong Zhang 
10779516a85cSHong Zhang       /* copy cdense[] into ca; zero cdense[] */
10789516a85cSHong Zhang       cnz = bi[i+1] - bi[i];
10799516a85cSHong Zhang       cj  = bj + bi[i];
10809516a85cSHong Zhang       ca  = ba + bi[i];
10819516a85cSHong Zhang       for (j=0; j<cnz; j++) {
10829516a85cSHong Zhang         ca[j] += cdense[cj[j]];
10839516a85cSHong Zhang         cdense[cj[j]] = 0.0;
10849516a85cSHong Zhang       }
10859516a85cSHong Zhang #if 0
10869516a85cSHong Zhang       if (rank == 0) {
10879516a85cSHong Zhang         printf("[%d] row %d: ",rank,i);
10889516a85cSHong Zhang         for (j=0; j<pN; j++) printf(" %g,",cdense[j]);
10899516a85cSHong Zhang         printf("\n");
10909516a85cSHong Zhang       }
10919516a85cSHong Zhang       for (j=0; j<pN; j++) cdense[j]=0.0; // zero cdnese[]
10929516a85cSHong Zhang #endif
10939516a85cSHong Zhang     } //for (i=0; i<cm; i++) {
109405d62848SHong Zhang #endif
10959516a85cSHong Zhang 
10969516a85cSHong Zhang     //==========================================
10979516a85cSHong Zhang 
109805d62848SHong Zhang     ierr = PetscTime(&t1);CHKERRQ(ierr);
1099a9d06231SHong Zhang     for (i=0; i<am; i++) {
1100b091e509SHong Zhang #if defined(PTAP_PROFILE)
11018563dfccSBarry Smith       ierr = PetscTime(&t2_0);CHKERRQ(ierr);
1102b091e509SHong Zhang #endif
1103a9d06231SHong Zhang       /* 2-a) form i-th sparse row of A_loc*P = Ad*P_loc + Ao*P_oth */
1104a9d06231SHong Zhang       /*------------------------------------------------------------*/
1105a9d06231SHong Zhang       apJ = apj + api[i];
1106a9d06231SHong Zhang 
1107a9d06231SHong Zhang       /* diagonal portion of A */
1108a9d06231SHong Zhang       anz = adi[i+1] - adi[i];
1109a9d06231SHong Zhang       adj = ad->j + adi[i];
1110a9d06231SHong Zhang       ada = ad->a + adi[i];
1111a9d06231SHong Zhang       for (j=0; j<anz; j++) {
1112a9d06231SHong Zhang         row = adj[j];
1113a9d06231SHong Zhang         pnz = pi_loc[row+1] - pi_loc[row];
1114a9d06231SHong Zhang         pj  = pj_loc + pi_loc[row];
1115a9d06231SHong Zhang         pa  = pa_loc + pi_loc[row];
1116a9d06231SHong Zhang 
1117a9d06231SHong Zhang         /* perform dense axpy */
1118e900a757SHong Zhang         valtmp = ada[j];
1119a9d06231SHong Zhang         for (k=0; k<pnz; k++) {
1120e900a757SHong Zhang           apa[pj[k]] += valtmp*pa[k];
1121a9d06231SHong Zhang         }
1122a9d06231SHong Zhang         ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
1123a9d06231SHong Zhang       }
1124a9d06231SHong Zhang 
1125a9d06231SHong Zhang       /* off-diagonal portion of A */
1126a9d06231SHong Zhang       anz = aoi[i+1] - aoi[i];
1127a9d06231SHong Zhang       aoj = ao->j + aoi[i];
1128a9d06231SHong Zhang       aoa = ao->a + aoi[i];
1129a9d06231SHong Zhang       for (j=0; j<anz; j++) {
1130a9d06231SHong Zhang         row = aoj[j];
1131a9d06231SHong Zhang         pnz = pi_oth[row+1] - pi_oth[row];
1132a9d06231SHong Zhang         pj  = pj_oth + pi_oth[row];
1133a9d06231SHong Zhang         pa  = pa_oth + pi_oth[row];
1134a9d06231SHong Zhang 
1135a9d06231SHong Zhang         /* perform dense axpy */
1136e900a757SHong Zhang         valtmp = aoa[j];
1137a9d06231SHong Zhang         for (k=0; k<pnz; k++) {
1138e900a757SHong Zhang           apa[pj[k]] += valtmp*pa[k];
1139a9d06231SHong Zhang         }
1140a9d06231SHong Zhang         ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
1141a9d06231SHong Zhang       }
1142b091e509SHong Zhang #if defined(PTAP_PROFILE)
11438563dfccSBarry Smith       ierr    = PetscTime(&t2_1);CHKERRQ(ierr);
1144b091e509SHong Zhang       et2_AP += t2_1 - t2_0;
1145b091e509SHong Zhang #endif
1146a9d06231SHong Zhang 
1147a9d06231SHong Zhang       /* 2-b) Compute Cseq = P_loc[i,:]^T*AP[i,:] using outer product */
1148a9d06231SHong Zhang       /*--------------------------------------------------------------*/
1149a9d06231SHong Zhang       apnz = api[i+1] - api[i];
1150a9d06231SHong Zhang       /* put the value into Co=(p->B)^T*AP (off-diagonal part, send to others) */
1151a9d06231SHong Zhang       pnz = po->i[i+1] - po->i[i];
1152e900a757SHong Zhang       poJ = po->j + po->i[i];
1153a9d06231SHong Zhang       pA  = po->a + po->i[i];
1154a9d06231SHong Zhang       for (j=0; j<pnz; j++) {
1155e900a757SHong Zhang         row = poJ[j];
1156e900a757SHong Zhang         cnz = coi[row+1] - coi[row];
1157e900a757SHong Zhang         cj  = coj + coi[row];
1158e900a757SHong Zhang         ca  = coa + coi[row];
1159a9d06231SHong Zhang         /* perform dense axpy */
1160e900a757SHong Zhang         valtmp = pA[j];
1161a9d06231SHong Zhang         for (k=0; k<cnz; k++) {
1162e900a757SHong Zhang           ca[k] += valtmp*apa[cj[k]];
1163a9d06231SHong Zhang         }
1164a9d06231SHong Zhang         ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
1165a9d06231SHong Zhang       }
116605d62848SHong Zhang #if 1
1167a9d06231SHong Zhang       /* put the value into Cd (diagonal part) */
1168a9d06231SHong Zhang       pnz = pd->i[i+1] - pd->i[i];
1169e900a757SHong Zhang       pdJ = pd->j + pd->i[i];
1170a9d06231SHong Zhang       pA  = pd->a + pd->i[i];
1171a9d06231SHong Zhang       for (j=0; j<pnz; j++) {
1172e900a757SHong Zhang         row = pdJ[j];
1173e900a757SHong Zhang         cnz = bi[row+1] - bi[row];
1174e900a757SHong Zhang         cj  = bj + bi[row];
1175e900a757SHong Zhang         ca  = ba + bi[row];
1176a9d06231SHong Zhang         /* perform dense axpy */
1177e900a757SHong Zhang         valtmp = pA[j];
1178a9d06231SHong Zhang         for (k=0; k<cnz; k++) {
1179e900a757SHong Zhang           ca[k] += valtmp*apa[cj[k]];
1180a9d06231SHong Zhang         }
1181a9d06231SHong Zhang         ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
1182a9d06231SHong Zhang       }
11839516a85cSHong Zhang #endif
1184a9d06231SHong Zhang       /* zero the current row of A*P */
1185a9d06231SHong Zhang       for (k=0; k<apnz; k++) apa[apJ[k]] = 0.0;
1186b091e509SHong Zhang #if defined(PTAP_PROFILE)
11878563dfccSBarry Smith       ierr      = PetscTime(&t2_2);CHKERRQ(ierr);
118805d62848SHong Zhang       ePtAP += t2_2 - t2_1;
1189b091e509SHong Zhang #endif
1190a9d06231SHong Zhang     }
11919516a85cSHong Zhang 
11929516a85cSHong Zhang     if (rank == 100) {
11939516a85cSHong Zhang     for (row=0; row<cm; row++) {
11949516a85cSHong Zhang       printf("[%d] row %d: ",rank,row);
11959516a85cSHong Zhang       cnz = bi[row+1] - bi[row];
11969516a85cSHong Zhang       for (j=0; j<cnz; j++) printf(" %g,",ba[bi[row]+j]);
11979516a85cSHong Zhang       printf("\n");
11989516a85cSHong Zhang     }
11999516a85cSHong Zhang     }
12009516a85cSHong Zhang 
120138571addSHong Zhang   } else { /* Do sparse axpy on apa (length of ap_rmax, stores A[i,:]*P) - scalable, but slower */
1202b38d1a2dSJed Brown     ierr = PetscInfo(C,"Using scalable sparse axpy\n");CHKERRQ(ierr);
120338571addSHong Zhang     /*-----------------------------------------------------------------------------------------*/
1204a9d06231SHong Zhang     pA=pa_loc;
120542c57489SHong Zhang     for (i=0; i<am; i++) {
1206b091e509SHong Zhang #if defined(PTAP_PROFILE)
12078563dfccSBarry Smith       ierr = PetscTime(&t2_0);CHKERRQ(ierr);
1208b091e509SHong Zhang #endif
1209f4a743e1SHong Zhang       /* form i-th sparse row of A*P */
121082412ba7SHong Zhang       apnz = api[i+1] - api[i];
121182412ba7SHong Zhang       apJ  = apj + api[i];
121242c57489SHong Zhang       /* diagonal portion of A */
121382412ba7SHong Zhang       anz = adi[i+1] - adi[i];
12141d633602SHong Zhang       adj = ad->j + adi[i];
12151d633602SHong Zhang       ada = ad->a + adi[i];
121682412ba7SHong Zhang       for (j=0; j<anz; j++) {
12171d633602SHong Zhang         row    = adj[j];
121882412ba7SHong Zhang         pnz    = pi_loc[row+1] - pi_loc[row];
121982412ba7SHong Zhang         pj     = pj_loc + pi_loc[row];
122082412ba7SHong Zhang         pa     = pa_loc + pi_loc[row];
1221e900a757SHong Zhang         valtmp = ada[j];
1222f4a743e1SHong Zhang         nextp  = 0;
122382412ba7SHong Zhang         for (k=0; nextp<pnz; k++) {
122482412ba7SHong Zhang           if (apJ[k] == pj[nextp]) { /* col of AP == col of P */
1225e900a757SHong Zhang             apa[k] += valtmp*pa[nextp++];
122642c57489SHong Zhang           }
122742c57489SHong Zhang         }
1228dc0b31edSSatish Balay         ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
122942c57489SHong Zhang       }
123042c57489SHong Zhang       /* off-diagonal portion of A */
123182412ba7SHong Zhang       anz = aoi[i+1] - aoi[i];
12321d633602SHong Zhang       aoj = ao->j + aoi[i];
12331d633602SHong Zhang       aoa = ao->a + aoi[i];
123482412ba7SHong Zhang       for (j=0; j<anz; j++) {
12351d633602SHong Zhang         row    = aoj[j];
123682412ba7SHong Zhang         pnz    = pi_oth[row+1] - pi_oth[row];
123782412ba7SHong Zhang         pj     = pj_oth + pi_oth[row];
123882412ba7SHong Zhang         pa     = pa_oth + pi_oth[row];
1239e900a757SHong Zhang         valtmp = aoa[j];
1240f4a743e1SHong Zhang         nextp  = 0;
124182412ba7SHong Zhang         for (k=0; nextp<pnz; k++) {
124282412ba7SHong Zhang           if (apJ[k] == pj[nextp]) { /* col of AP == col of P */
1243e900a757SHong Zhang             apa[k] += valtmp*pa[nextp++];
124442c57489SHong Zhang           }
124542c57489SHong Zhang         }
1246dc0b31edSSatish Balay         ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr);
124742c57489SHong Zhang       }
1248b091e509SHong Zhang #if defined(PTAP_PROFILE)
12498563dfccSBarry Smith       ierr    = PetscTime(&t2_1);CHKERRQ(ierr);
1250b091e509SHong Zhang       et2_AP += t2_1 - t2_0;
1251b091e509SHong Zhang #endif
125242c57489SHong Zhang 
1253a9d06231SHong Zhang       /* 2-b) Compute Cseq = P_loc[i,:]^T*AP[i,:] using outer product */
1254a9d06231SHong Zhang       /*--------------------------------------------------------------*/
125582412ba7SHong Zhang       pnz = pi_loc[i+1] - pi_loc[i];
1256f9473cf7SHong Zhang       pJ  = pj_loc + pi_loc[i];
125782412ba7SHong Zhang       for (j=0; j<pnz; j++) {
125842c57489SHong Zhang         nextap = 0;
1259f9473cf7SHong Zhang         row    = pJ[j]; /* global index */
126082412ba7SHong Zhang         if (row < pcstart || row >=pcend) { /* put the value into Co */
1261e900a757SHong Zhang           row = *poJ;
1262e900a757SHong Zhang           cj  = coj + coi[row];
1263e900a757SHong Zhang           ca  = coa + coi[row]; poJ++;
126482412ba7SHong Zhang         } else {                            /* put the value into Cd */
1265e900a757SHong Zhang           row = *pdJ;
1266e900a757SHong Zhang           cj  = bj + bi[row];
1267e900a757SHong Zhang           ca  = ba + bi[row]; pdJ++;
126842c57489SHong Zhang         }
1269e900a757SHong Zhang         valtmp = pA[j];
127082412ba7SHong Zhang         for (k=0; nextap<apnz; k++) {
1271e900a757SHong Zhang           if (cj[k]==apJ[nextap]) ca[k] += valtmp*apa[nextap++];
127242c57489SHong Zhang         }
1273dc0b31edSSatish Balay         ierr = PetscLogFlops(2.0*apnz);CHKERRQ(ierr);
1274de0260b3SHong Zhang       }
12750496f32cSHong Zhang       pA += pnz;
127642c57489SHong Zhang       /* zero the current row info for A*P */
127782412ba7SHong Zhang       ierr = PetscMemzero(apa,apnz*sizeof(MatScalar));CHKERRQ(ierr);
1278b091e509SHong Zhang #if defined(PTAP_PROFILE)
12798563dfccSBarry Smith       ierr      = PetscTime(&t2_2);CHKERRQ(ierr);
128005d62848SHong Zhang       ePtAP += t2_2 - t2_1;
1281b091e509SHong Zhang #endif
128242c57489SHong Zhang     }
1283d9824c15SHong Zhang   }
128438571addSHong Zhang #if defined(PTAP_PROFILE)
12858563dfccSBarry Smith   ierr = PetscTime(&t2);CHKERRQ(ierr);
128638571addSHong Zhang #endif
128742c57489SHong Zhang 
1288a9d06231SHong Zhang   /* 3) send and recv matrix values coa */
1289a9d06231SHong Zhang   /*------------------------------------*/
129042c57489SHong Zhang   buf_ri = merge->buf_ri;
129142c57489SHong Zhang   buf_rj = merge->buf_rj;
129242c57489SHong Zhang   len_s  = merge->len_s;
1293fc42d0c8SSatish Balay   ierr   = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr);
129442c57489SHong Zhang   ierr   = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr);
129542c57489SHong Zhang 
1296dcca6d9dSJed Brown   ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr);
129742c57489SHong Zhang   for (proc=0,k=0; proc<size; proc++) {
129842c57489SHong Zhang     if (!len_s[proc]) continue;
1299de0260b3SHong Zhang     i    = merge->owners_co[proc];
1300de0260b3SHong Zhang     ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr);
130142c57489SHong Zhang     k++;
130242c57489SHong Zhang   }
13030c468ba9SBarry Smith   if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);}
13040c468ba9SBarry Smith   if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);}
130542c57489SHong Zhang 
1306a9d06231SHong Zhang   ierr = PetscFree2(s_waits,status);CHKERRQ(ierr);
130742c57489SHong Zhang   ierr = PetscFree(r_waits);CHKERRQ(ierr);
130882412ba7SHong Zhang   ierr = PetscFree(coa);CHKERRQ(ierr);
130938571addSHong Zhang #if defined(PTAP_PROFILE)
13108563dfccSBarry Smith   ierr = PetscTime(&t3);CHKERRQ(ierr);
131138571addSHong Zhang #endif
131242c57489SHong Zhang 
1313a9d06231SHong Zhang   /* 4) insert local Cseq and received values into Cmpi */
1314a9d06231SHong Zhang   /*------------------------------------------------------*/
1315dcca6d9dSJed Brown   ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr);
131642c57489SHong Zhang   for (k=0; k<merge->nrecv; k++) {
131742c57489SHong Zhang     buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */
131842c57489SHong Zhang     nrows       = *(buf_ri_k[k]);
131942c57489SHong Zhang     nextrow[k]  = buf_ri_k[k]+1;  /* next row number of k-th recved i-structure */
132082412ba7SHong Zhang     nextci[k]   = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure  */
132142c57489SHong Zhang   }
132242c57489SHong Zhang 
1323de0260b3SHong Zhang   for (i=0; i<cm; i++) {
132482412ba7SHong Zhang     row  = owners[rank] + i; /* global row index of C_seq */
132542c57489SHong Zhang     bj_i = bj + bi[i];  /* col indices of the i-th row of C */
1326de0260b3SHong Zhang     ba_i = ba + bi[i];
132782412ba7SHong Zhang     bnz  = bi[i+1] - bi[i];
132842c57489SHong Zhang     /* add received vals into ba */
132942c57489SHong Zhang     for (k=0; k<merge->nrecv; k++) { /* k-th received message */
133042c57489SHong Zhang       /* i-th row */
133142c57489SHong Zhang       if (i == *nextrow[k]) {
133282412ba7SHong Zhang         cnz    = *(nextci[k]+1) - *nextci[k];
133382412ba7SHong Zhang         cj     = buf_rj[k] + *(nextci[k]);
133482412ba7SHong Zhang         ca     = abuf_r[k] + *(nextci[k]);
133582412ba7SHong Zhang         nextcj = 0;
133682412ba7SHong Zhang         for (j=0; nextcj<cnz; j++) {
133782412ba7SHong Zhang           if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */
133882412ba7SHong Zhang             ba_i[j] += ca[nextcj++];
133942c57489SHong Zhang           }
134042c57489SHong Zhang         }
134182412ba7SHong Zhang         nextrow[k]++; nextci[k]++;
1342c5af039cSHong Zhang         ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr);
134342c57489SHong Zhang       }
134442c57489SHong Zhang     }
134582412ba7SHong Zhang     ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr);
134642c57489SHong Zhang   }
134742c57489SHong Zhang   ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
134842c57489SHong Zhang   ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
134942c57489SHong Zhang 
1350de0260b3SHong Zhang   ierr = PetscFree(ba);CHKERRQ(ierr);
1351c05d87d6SBarry Smith   ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr);
135242c57489SHong Zhang   ierr = PetscFree(abuf_r);CHKERRQ(ierr);
13530572522cSBarry Smith   ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr);
135438571addSHong Zhang #if defined(PTAP_PROFILE)
13558563dfccSBarry Smith   ierr = PetscTime(&t4);CHKERRQ(ierr);
13569516a85cSHong Zhang   if (rank==1) {
135705d62848SHong Zhang     ierr = PetscPrintf(MPI_COMM_SELF,"  [%d] PtAPNum %g/P + %g/PtAP( %g/A*P + %g/Pt*AP ) + %g/comm + %g/Cloc = %g\n\n",rank,eP,t2-t1,et2_AP,ePtAP,t3-t2,t4-t3,t4-t0);CHKERRQ(ierr);
13589516a85cSHong Zhang   }
135938571addSHong Zhang #endif
136042c57489SHong Zhang   PetscFunctionReturn(0);
136142c57489SHong Zhang }
1362