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,¤t_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,¤t_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,¤t_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,¤t_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