1be1d678aSKris Buschelman 22499ec78SHong Zhang /* 32499ec78SHong Zhang Defines matrix-matrix product routines for pairs of MPIAIJ matrices 42499ec78SHong Zhang C = A * B 52499ec78SHong Zhang */ 6c6db04a5SJed Brown #include <../src/mat/impls/aij/seq/aij.h> /*I "petscmat.h" I*/ 7c6db04a5SJed Brown #include <../src/mat/utils/freespace.h> 8c6db04a5SJed Brown #include <../src/mat/impls/aij/mpi/mpiaij.h> 9c6db04a5SJed Brown #include <petscbt.h> 10c6db04a5SJed Brown #include <../src/mat/impls/dense/mpi/mpidense.h> 11af0996ceSBarry Smith #include <petsc/private/vecimpl.h> 121634b032SHong Zhang 135e5acdf2Sstefano_zampini #if defined(PETSC_HAVE_HYPRE) 145e5acdf2Sstefano_zampini PETSC_INTERN PetscErrorCode MatMatMultSymbolic_AIJ_AIJ_wHYPRE(Mat,Mat,PetscReal,Mat*); 155e5acdf2Sstefano_zampini #endif 165e5acdf2Sstefano_zampini 17150d2497SBarry Smith PETSC_INTERN PetscErrorCode MatMatMult_MPIAIJ_MPIAIJ(Mat A,Mat B,MatReuse scall,PetscReal fill, Mat *C) 182499ec78SHong Zhang { 192499ec78SHong Zhang PetscErrorCode ierr; 205e5acdf2Sstefano_zampini #if defined(PETSC_HAVE_HYPRE) 215e5acdf2Sstefano_zampini const char *algTypes[3] = {"scalable","nonscalable","hypre"}; 225e5acdf2Sstefano_zampini PetscInt nalg = 3; 235e5acdf2Sstefano_zampini #else 240fc8cf34SHong Zhang const char *algTypes[2] = {"scalable","nonscalable"}; 255e5acdf2Sstefano_zampini PetscInt nalg = 2; 265e5acdf2Sstefano_zampini #endif 2760106aa7SHong Zhang PetscInt alg = 1; /* set nonscalable algorithm as default */ 28e55be12dSHong Zhang MPI_Comm comm; 295e68f438SHong Zhang PetscBool flg; 302499ec78SHong Zhang 312499ec78SHong Zhang PetscFunctionBegin; 322499ec78SHong Zhang if (scall == MAT_INITIAL_MATRIX) { 33e55be12dSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 346c4ed002SBarry Smith if (A->cmap->rstart != B->rmap->rstart || A->cmap->rend != B->rmap->rend) SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, (%D, %D) != (%D,%D)",A->cmap->rstart,A->cmap->rend,B->rmap->rstart,B->rmap->rend); 35e55be12dSHong Zhang 360fc8cf34SHong Zhang ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr); 3768eacb73SHong Zhang PetscOptionsObject->alreadyprinted = PETSC_FALSE; /* a hack to ensure the option shows in '-help' */ 385e68f438SHong Zhang ierr = PetscOptionsEList("-matmatmult_via","Algorithmic approach","MatMatMult",algTypes,nalg,algTypes[1],&alg,&flg);CHKERRQ(ierr); 390fc8cf34SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 400fc8cf34SHong Zhang 4160106aa7SHong Zhang if (!flg && B->cmap->N > 100000) { /* may switch to scalable algorithm as default */ 425e68f438SHong Zhang MatInfo Ainfo,Binfo; 4360106aa7SHong Zhang PetscInt nz_local; 4460106aa7SHong Zhang PetscBool alg_scalable_loc=PETSC_FALSE,alg_scalable; 455e68f438SHong Zhang 465e68f438SHong Zhang ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr); 475e68f438SHong Zhang ierr = MatGetInfo(B,MAT_LOCAL,&Binfo);CHKERRQ(ierr); 485e68f438SHong Zhang nz_local = (PetscInt)(Ainfo.nz_allocated + Binfo.nz_allocated); 495e68f438SHong Zhang 5060106aa7SHong Zhang if (B->cmap->N > fill*nz_local) alg_scalable_loc = PETSC_TRUE; 5160106aa7SHong Zhang ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr); 5260106aa7SHong Zhang 5360106aa7SHong Zhang if (alg_scalable) { 5460106aa7SHong Zhang alg = 0; /* scalable algorithm would 50% slower than nonscalable algorithm */ 5560106aa7SHong Zhang ierr = PetscInfo2(B,"Use scalable algorithm, BN %D, fill*nz_allocated %g\n",B->cmap->N,fill*nz_local);CHKERRQ(ierr); 5660106aa7SHong Zhang } 575e68f438SHong Zhang } 585e68f438SHong Zhang 593ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 600fc8cf34SHong Zhang switch (alg) { 610fc8cf34SHong Zhang case 1: 620fc8cf34SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(A,B,fill,C);CHKERRQ(ierr); 630fc8cf34SHong Zhang break; 645e5acdf2Sstefano_zampini #if defined(PETSC_HAVE_HYPRE) 655e5acdf2Sstefano_zampini case 2: 665e5acdf2Sstefano_zampini ierr = MatMatMultSymbolic_AIJ_AIJ_wHYPRE(A,B,fill,C);CHKERRQ(ierr); 675e5acdf2Sstefano_zampini break; 685e5acdf2Sstefano_zampini #endif 690fc8cf34SHong Zhang default: 70b2405163SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ(A,B,fill,C);CHKERRQ(ierr); 710fc8cf34SHong Zhang break; 720fc8cf34SHong Zhang } 733ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 742499ec78SHong Zhang } 753ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 76598bc09dSHong Zhang ierr = (*(*C)->ops->matmultnumeric)(A,B,*C);CHKERRQ(ierr); 773ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 782499ec78SHong Zhang PetscFunctionReturn(0); 792499ec78SHong Zhang } 802499ec78SHong Zhang 81a1a4e84aSHong Zhang PetscErrorCode MatDestroy_MPIAIJ_MatMatMult(Mat A) 82598bc09dSHong Zhang { 83598bc09dSHong Zhang PetscErrorCode ierr; 84598bc09dSHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data; 85598bc09dSHong Zhang Mat_PtAPMPI *ptap = a->ptap; 86598bc09dSHong Zhang 87598bc09dSHong Zhang PetscFunctionBegin; 88b7f45c76SHong Zhang ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr); 89598bc09dSHong Zhang ierr = PetscFree(ptap->bufa);CHKERRQ(ierr); 90a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr); 91a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr); 92ab1b013aSHong Zhang ierr = MatDestroy(&ptap->Pt);CHKERRQ(ierr); 93a1a4e84aSHong Zhang ierr = PetscFree(ptap->api);CHKERRQ(ierr); 94a1a4e84aSHong Zhang ierr = PetscFree(ptap->apj);CHKERRQ(ierr); 95598bc09dSHong Zhang ierr = PetscFree(ptap->apa);CHKERRQ(ierr); 96598bc09dSHong Zhang ierr = ptap->destroy(A);CHKERRQ(ierr); 97598bc09dSHong Zhang ierr = PetscFree(ptap);CHKERRQ(ierr); 98598bc09dSHong Zhang PetscFunctionReturn(0); 99598bc09dSHong Zhang } 100598bc09dSHong Zhang 101a1a4e84aSHong Zhang PetscErrorCode MatDuplicate_MPIAIJ_MatMatMult(Mat A, MatDuplicateOption op, Mat *M) 1024ae0847bSHong Zhang { 1034ae0847bSHong Zhang PetscErrorCode ierr; 1044ae0847bSHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data; 1054ae0847bSHong Zhang Mat_PtAPMPI *ptap = a->ptap; 1064ae0847bSHong Zhang 1074ae0847bSHong Zhang PetscFunctionBegin; 1084ae0847bSHong Zhang ierr = (*ptap->duplicate)(A,op,M);CHKERRQ(ierr); 10926fbe8dcSKarl Rupp 1104ae0847bSHong Zhang (*M)->ops->destroy = ptap->destroy; /* = MatDestroy_MPIAIJ, *M doesn't duplicate A's special structure! */ 1114ae0847bSHong Zhang (*M)->ops->duplicate = ptap->duplicate; /* = MatDuplicate_MPIAIJ */ 1124ae0847bSHong Zhang PetscFunctionReturn(0); 1134ae0847bSHong Zhang } 1144ae0847bSHong Zhang 115f8efd71cSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,Mat C) 116598bc09dSHong Zhang { 117598bc09dSHong Zhang PetscErrorCode ierr; 1184ae0847bSHong Zhang Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 119598bc09dSHong Zhang Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 120598bc09dSHong Zhang Mat_SeqAIJ *cd =(Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 121c12557a1SHong Zhang PetscScalar *cda=cd->a,*coa=co->a; 122598bc09dSHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 1239ce11a7cSHong Zhang PetscScalar *apa,*ca; 124c12557a1SHong Zhang PetscInt cm =C->rmap->n; 125598bc09dSHong Zhang Mat_PtAPMPI *ptap=c->ptap; 126c12557a1SHong Zhang PetscInt *api,*apj,*apJ,i,k; 12729825010SHong Zhang PetscInt cstart=C->cmap->rstart; 128598bc09dSHong Zhang PetscInt cdnz,conz,k0,k1; 1299467f45fSHong Zhang MPI_Comm comm; 1309467f45fSHong Zhang PetscMPIInt size; 131598bc09dSHong Zhang 132598bc09dSHong Zhang PetscFunctionBegin; 1339467f45fSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1349467f45fSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1359467f45fSHong Zhang 136a1a4e84aSHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 137598bc09dSHong Zhang /*-----------------------------------------------------*/ 138a1a4e84aSHong Zhang /* update numerical values of P_oth and P_loc */ 139b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 140a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 141598bc09dSHong Zhang 142598bc09dSHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 143598bc09dSHong Zhang /*----------------------------------------------------------*/ 144598bc09dSHong Zhang /* get data from symbolic products */ 145a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 146c12557a1SHong Zhang p_oth = NULL; 1479467f45fSHong Zhang if (size >1) { 1489467f45fSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 1499467f45fSHong Zhang } 150598bc09dSHong Zhang 151598bc09dSHong Zhang /* get apa for storing dense row A[i,:]*P */ 152598bc09dSHong Zhang apa = ptap->apa; 153598bc09dSHong Zhang 15429825010SHong Zhang api = ptap->api; 15529825010SHong Zhang apj = ptap->apj; 156598bc09dSHong Zhang for (i=0; i<cm; i++) { 157c12557a1SHong Zhang /* compute apa = A[i,:]*P */ 158e497d3c8SHong Zhang AProw_nonscalable(i,ad,ao,p_loc,p_oth,apa); 159598bc09dSHong Zhang 160598bc09dSHong Zhang /* set values in C */ 161598bc09dSHong Zhang apJ = apj + api[i]; 162598bc09dSHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 163598bc09dSHong Zhang conz = co->i[i+1] - co->i[i]; 164598bc09dSHong Zhang 165598bc09dSHong Zhang /* 1st off-diagoanl part of C */ 166598bc09dSHong Zhang ca = coa + co->i[i]; 167598bc09dSHong Zhang k = 0; 168598bc09dSHong Zhang for (k0=0; k0<conz; k0++) { 169598bc09dSHong Zhang if (apJ[k] >= cstart) break; 170598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 1715cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 172598bc09dSHong Zhang } 173598bc09dSHong Zhang 174598bc09dSHong Zhang /* diagonal part of C */ 175598bc09dSHong Zhang ca = cda + cd->i[i]; 176598bc09dSHong Zhang for (k1=0; k1<cdnz; k1++) { 177598bc09dSHong Zhang ca[k1] = apa[apJ[k]]; 1785cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 179598bc09dSHong Zhang } 180598bc09dSHong Zhang 181598bc09dSHong Zhang /* 2nd off-diagoanl part of C */ 182598bc09dSHong Zhang ca = coa + co->i[i]; 183598bc09dSHong Zhang for (; k0<conz; k0++) { 184598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 1855cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 186598bc09dSHong Zhang } 187598bc09dSHong Zhang } 188598bc09dSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 189598bc09dSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 190598bc09dSHong Zhang PetscFunctionReturn(0); 191598bc09dSHong Zhang } 192598bc09dSHong Zhang 1930fc8cf34SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,PetscReal fill,Mat *C) 194598bc09dSHong Zhang { 195598bc09dSHong Zhang PetscErrorCode ierr; 196ce94432eSBarry Smith MPI_Comm comm; 1979467f45fSHong Zhang PetscMPIInt size; 198bfcd1a73SHong Zhang Mat Cmpi; 199598bc09dSHong Zhang Mat_PtAPMPI *ptap; 2000298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 2014ae0847bSHong Zhang Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data,*c; 202bfcd1a73SHong Zhang Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 2034ae0847bSHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 2044ae0847bSHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 205d14fa243SHong Zhang PetscInt *lnk,i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi; 2065cab4f04SHong Zhang PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n; 207598bc09dSHong Zhang PetscBT lnkbt; 208598bc09dSHong Zhang PetscScalar *apa; 209bfcd1a73SHong Zhang PetscReal afill; 210598bc09dSHong Zhang 211598bc09dSHong Zhang PetscFunctionBegin; 212ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 2139467f45fSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 2149467f45fSHong Zhang 215598bc09dSHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 216b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 217598bc09dSHong Zhang 218598bc09dSHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 219b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 22019f0e57aSHong Zhang 221598bc09dSHong Zhang /* get P_loc by taking all local rows of P */ 222a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 223598bc09dSHong Zhang 224a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 225598bc09dSHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 2269467f45fSHong Zhang if (size > 1) { 2279467f45fSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 228598bc09dSHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 22920e3dc75SHong Zhang } else { 23020e3dc75SHong Zhang p_oth = NULL; 23120e3dc75SHong Zhang pi_oth = NULL; pj_oth = NULL; 2329467f45fSHong Zhang } 233598bc09dSHong Zhang 234598bc09dSHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 235598bc09dSHong Zhang /*-------------------------------------------------------------------*/ 236854ce69bSBarry Smith ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 237a1a4e84aSHong Zhang ptap->api = api; 238598bc09dSHong Zhang api[0] = 0; 239598bc09dSHong Zhang 2405cab4f04SHong Zhang /* create and initialize a linked list */ 2415cab4f04SHong Zhang ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr); 242598bc09dSHong Zhang 243bfcd1a73SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 244f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space);CHKERRQ(ierr); 245598bc09dSHong Zhang current_space = free_space; 246598bc09dSHong Zhang 247598bc09dSHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 248598bc09dSHong Zhang for (i=0; i<am; i++) { 249598bc09dSHong Zhang /* diagonal portion of A */ 250598bc09dSHong Zhang nzi = adi[i+1] - adi[i]; 251598bc09dSHong Zhang for (j=0; j<nzi; j++) { 252598bc09dSHong Zhang row = *adj++; 253598bc09dSHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 254598bc09dSHong Zhang Jptr = pj_loc + pi_loc[row]; 255598bc09dSHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 2561fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 257598bc09dSHong Zhang } 258598bc09dSHong Zhang /* off-diagonal portion of A */ 259598bc09dSHong Zhang nzi = aoi[i+1] - aoi[i]; 260598bc09dSHong Zhang for (j=0; j<nzi; j++) { 261598bc09dSHong Zhang row = *aoj++; 262598bc09dSHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 263598bc09dSHong Zhang Jptr = pj_oth + pi_oth[row]; 2641fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 265598bc09dSHong Zhang } 266598bc09dSHong Zhang 267d14fa243SHong Zhang apnz = lnk[0]; 268598bc09dSHong Zhang api[i+1] = api[i] + apnz; 269598bc09dSHong Zhang 270598bc09dSHong Zhang /* if free space is not available, double the total space in the list */ 271598bc09dSHong Zhang if (current_space->local_remaining<apnz) { 272f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 273598bc09dSHong Zhang nspacedouble++; 274598bc09dSHong Zhang } 275598bc09dSHong Zhang 276598bc09dSHong Zhang /* Copy data into free space, then initialize lnk */ 2771fbbb359SHong Zhang ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 278598bc09dSHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 2792205254eSKarl Rupp 280598bc09dSHong Zhang current_space->array += apnz; 281598bc09dSHong Zhang current_space->local_used += apnz; 282598bc09dSHong Zhang current_space->local_remaining -= apnz; 283598bc09dSHong Zhang } 284598bc09dSHong Zhang 285598bc09dSHong Zhang /* Allocate space for apj, initialize apj, and */ 286598bc09dSHong Zhang /* destroy list of free space and other temporary array(s) */ 287854ce69bSBarry Smith ierr = PetscMalloc1(api[am]+1,&ptap->apj);CHKERRQ(ierr); 288a1a4e84aSHong Zhang apj = ptap->apj; 289a1a4e84aSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 290598bc09dSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 291598bc09dSHong Zhang 292f84c536bSHong Zhang /* malloc apa to store dense row A[i,:]*P */ 2931795a4d1SJed Brown ierr = PetscCalloc1(pN,&apa);CHKERRQ(ierr); 2942205254eSKarl Rupp 295f84c536bSHong Zhang ptap->apa = apa; 296f84c536bSHong Zhang 297bfcd1a73SHong Zhang /* create and assemble symbolic parallel matrix Cmpi */ 298598bc09dSHong Zhang /*----------------------------------------------------*/ 299bfcd1a73SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 300bfcd1a73SHong Zhang ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 30133d57670SJed Brown ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr); 302a2f3521dSMark F. Adams 303bfcd1a73SHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 304bfcd1a73SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 305598bc09dSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 306598bc09dSHong Zhang for (i=0; i<am; i++) { 307598bc09dSHong Zhang row = i + rstart; 308598bc09dSHong Zhang apnz = api[i+1] - api[i]; 309bfcd1a73SHong Zhang ierr = MatSetValues(Cmpi,1,&row,apnz,apj,apa,INSERT_VALUES);CHKERRQ(ierr); 310598bc09dSHong Zhang apj += apnz; 311598bc09dSHong Zhang } 312bfcd1a73SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 313bfcd1a73SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 314598bc09dSHong Zhang 315bfcd1a73SHong Zhang ptap->destroy = Cmpi->ops->destroy; 316bfcd1a73SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 317f8efd71cSHong Zhang Cmpi->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 318bfcd1a73SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_MatMatMult; 319bfcd1a73SHong Zhang Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatMatMult; 320598bc09dSHong Zhang 321bfcd1a73SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 322bfcd1a73SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 323598bc09dSHong Zhang c->ptap = ptap; 324598bc09dSHong Zhang 325bfcd1a73SHong Zhang *C = Cmpi; 326bfcd1a73SHong Zhang 327bfcd1a73SHong Zhang /* set MatInfo */ 328118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 329bfcd1a73SHong Zhang if (afill < 1.0) afill = 1.0; 330bfcd1a73SHong Zhang Cmpi->info.mallocs = nspacedouble; 331bfcd1a73SHong Zhang Cmpi->info.fill_ratio_given = fill; 332bfcd1a73SHong Zhang Cmpi->info.fill_ratio_needed = afill; 333bfcd1a73SHong Zhang 334bfcd1a73SHong Zhang #if defined(PETSC_USE_INFO) 335bfcd1a73SHong Zhang if (api[am]) { 33657622a8eSBarry Smith ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 33757622a8eSBarry Smith ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 338bfcd1a73SHong Zhang } else { 339bfcd1a73SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 340bfcd1a73SHong Zhang } 341bfcd1a73SHong Zhang #endif 342598bc09dSHong Zhang PetscFunctionReturn(0); 343598bc09dSHong Zhang } 344598bc09dSHong Zhang 345150d2497SBarry Smith PETSC_INTERN PetscErrorCode MatMatMult_MPIAIJ_MPIDense(Mat A,Mat B,MatReuse scall,PetscReal fill,Mat *C) 3469123193aSHong Zhang { 3479123193aSHong Zhang PetscErrorCode ierr; 3489123193aSHong Zhang 3499123193aSHong Zhang PetscFunctionBegin; 3509123193aSHong Zhang if (scall == MAT_INITIAL_MATRIX) { 3513ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 3529123193aSHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIDense(A,B,fill,C);CHKERRQ(ierr); 3533ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 3549123193aSHong Zhang } 3553ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 3569123193aSHong Zhang ierr = MatMatMultNumeric_MPIAIJ_MPIDense(A,B,*C);CHKERRQ(ierr); 3573ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 3589123193aSHong Zhang PetscFunctionReturn(0); 3599123193aSHong Zhang } 3609123193aSHong Zhang 3614324174eSBarry Smith typedef struct { 3624324174eSBarry Smith Mat workB; 3634324174eSBarry Smith PetscScalar *rvalues,*svalues; 3644324174eSBarry Smith MPI_Request *rwaits,*swaits; 3654324174eSBarry Smith } MPIAIJ_MPIDense; 3664324174eSBarry Smith 36796b95a6bSBarry Smith PetscErrorCode MatMPIAIJ_MPIDenseDestroy(void *ctx) 3684324174eSBarry Smith { 3694324174eSBarry Smith MPIAIJ_MPIDense *contents = (MPIAIJ_MPIDense*) ctx; 3704324174eSBarry Smith PetscErrorCode ierr; 3714324174eSBarry Smith 3724324174eSBarry Smith PetscFunctionBegin; 3736bf464f9SBarry Smith ierr = MatDestroy(&contents->workB);CHKERRQ(ierr); 3744324174eSBarry Smith ierr = PetscFree4(contents->rvalues,contents->svalues,contents->rwaits,contents->swaits);CHKERRQ(ierr); 3754324174eSBarry Smith ierr = PetscFree(contents);CHKERRQ(ierr); 3764324174eSBarry Smith PetscFunctionReturn(0); 3774324174eSBarry Smith } 3784324174eSBarry Smith 379fd4e9aacSBarry Smith /* 380fd4e9aacSBarry Smith This is a "dummy function" that handles the case where matrix C was created as a dense matrix 381fd4e9aacSBarry Smith directly by the user and passed to MatMatMult() with the MAT_REUSE_MATRIX option 382fd4e9aacSBarry Smith 383fd4e9aacSBarry Smith It is the same as MatMatMultSymbolic_MPIAIJ_MPIDense() except does not create C 384fd4e9aacSBarry Smith */ 385fd4e9aacSBarry Smith PetscErrorCode MatMatMultNumeric_MPIDense(Mat A,Mat B,Mat C) 386fd4e9aacSBarry Smith { 387fd4e9aacSBarry Smith PetscErrorCode ierr; 388fd4e9aacSBarry Smith PetscBool flg; 389fd4e9aacSBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*) A->data; 390fd4e9aacSBarry Smith PetscInt nz = aij->B->cmap->n; 391fd4e9aacSBarry Smith PetscContainer container; 392fd4e9aacSBarry Smith MPIAIJ_MPIDense *contents; 393fd4e9aacSBarry Smith VecScatter ctx = aij->Mvctx; 394fd4e9aacSBarry Smith VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata; 395fd4e9aacSBarry Smith VecScatter_MPI_General *to = (VecScatter_MPI_General*) ctx->todata; 396fd4e9aacSBarry Smith 397fd4e9aacSBarry Smith PetscFunctionBegin; 398fd4e9aacSBarry Smith ierr = PetscObjectTypeCompare((PetscObject)B,MATMPIDENSE,&flg);CHKERRQ(ierr); 399fd4e9aacSBarry Smith if (!flg) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG,"Second matrix must be mpidense"); 400fd4e9aacSBarry Smith 401fd4e9aacSBarry Smith /* Handle case where where user provided the final C matrix rather than calling MatMatMult() with MAT_INITIAL_MATRIX*/ 402fd4e9aacSBarry Smith ierr = PetscObjectTypeCompare((PetscObject)A,MATMPIAIJ,&flg);CHKERRQ(ierr); 403fd4e9aacSBarry Smith if (!flg) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG,"First matrix must be MPIAIJ"); 404fd4e9aacSBarry Smith 405fd4e9aacSBarry Smith C->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense; 406fd4e9aacSBarry Smith 407fd4e9aacSBarry Smith ierr = PetscNew(&contents);CHKERRQ(ierr); 408fd4e9aacSBarry Smith /* Create work matrix used to store off processor rows of B needed for local product */ 409fd4e9aacSBarry Smith ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,B->cmap->N,NULL,&contents->workB);CHKERRQ(ierr); 410fd4e9aacSBarry Smith /* Create work arrays needed */ 411fd4e9aacSBarry Smith ierr = PetscMalloc4(B->cmap->N*from->starts[from->n],&contents->rvalues, 412fd4e9aacSBarry Smith B->cmap->N*to->starts[to->n],&contents->svalues, 413fd4e9aacSBarry Smith from->n,&contents->rwaits, 414fd4e9aacSBarry Smith to->n,&contents->swaits);CHKERRQ(ierr); 415fd4e9aacSBarry Smith 416fd4e9aacSBarry Smith ierr = PetscContainerCreate(PetscObjectComm((PetscObject)A),&container);CHKERRQ(ierr); 417fd4e9aacSBarry Smith ierr = PetscContainerSetPointer(container,contents);CHKERRQ(ierr); 418fd4e9aacSBarry Smith ierr = PetscContainerSetUserDestroy(container,MatMPIAIJ_MPIDenseDestroy);CHKERRQ(ierr); 419fd4e9aacSBarry Smith ierr = PetscObjectCompose((PetscObject)C,"workB",(PetscObject)container);CHKERRQ(ierr); 420fd4e9aacSBarry Smith ierr = PetscContainerDestroy(&container);CHKERRQ(ierr); 421fd4e9aacSBarry Smith 422fd4e9aacSBarry Smith ierr = (*C->ops->matmultnumeric)(A,B,C);CHKERRQ(ierr); 423fd4e9aacSBarry Smith PetscFunctionReturn(0); 424fd4e9aacSBarry Smith } 425fd4e9aacSBarry Smith 4269123193aSHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIDense(Mat A,Mat B,PetscReal fill,Mat *C) 4279123193aSHong Zhang { 4289123193aSHong Zhang PetscErrorCode ierr; 429f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*) A->data; 430d0f46423SBarry Smith PetscInt nz = aij->B->cmap->n; 431bf0cc555SLisandro Dalcin PetscContainer container; 4324324174eSBarry Smith MPIAIJ_MPIDense *contents; 4334324174eSBarry Smith VecScatter ctx = aij->Mvctx; 4344324174eSBarry Smith VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata; 4354324174eSBarry Smith VecScatter_MPI_General *to = (VecScatter_MPI_General*) ctx->todata; 436d0f46423SBarry Smith PetscInt m = A->rmap->n,n=B->cmap->n; 4379123193aSHong Zhang 4389123193aSHong Zhang PetscFunctionBegin; 439ce94432eSBarry Smith ierr = MatCreate(PetscObjectComm((PetscObject)B),C);CHKERRQ(ierr); 440d0f46423SBarry Smith ierr = MatSetSizes(*C,m,n,A->rmap->N,B->cmap->N);CHKERRQ(ierr); 44133d57670SJed Brown ierr = MatSetBlockSizesFromMats(*C,A,B);CHKERRQ(ierr); 442cb2480eaSBarry Smith ierr = MatSetType(*C,MATMPIDENSE);CHKERRQ(ierr); 4430298fd71SBarry Smith ierr = MatMPIDenseSetPreallocation(*C,NULL);CHKERRQ(ierr); 444cb2480eaSBarry Smith ierr = MatAssemblyBegin(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 445cb2480eaSBarry Smith ierr = MatAssemblyEnd(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 4462205254eSKarl Rupp 447d73949e8SHong Zhang (*C)->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense; 448f32d5d43SBarry Smith 449b00a9115SJed Brown ierr = PetscNew(&contents);CHKERRQ(ierr); 450f32d5d43SBarry Smith /* Create work matrix used to store off processor rows of B needed for local product */ 4510298fd71SBarry Smith ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,B->cmap->N,NULL,&contents->workB);CHKERRQ(ierr); 4524324174eSBarry Smith /* Create work arrays needed */ 453dcca6d9dSJed Brown ierr = PetscMalloc4(B->cmap->N*from->starts[from->n],&contents->rvalues, 454dcca6d9dSJed Brown B->cmap->N*to->starts[to->n],&contents->svalues, 455dcca6d9dSJed Brown from->n,&contents->rwaits, 456dcca6d9dSJed Brown to->n,&contents->swaits);CHKERRQ(ierr); 4574324174eSBarry Smith 458ce94432eSBarry Smith ierr = PetscContainerCreate(PetscObjectComm((PetscObject)A),&container);CHKERRQ(ierr); 459bf0cc555SLisandro Dalcin ierr = PetscContainerSetPointer(container,contents);CHKERRQ(ierr); 46096b95a6bSBarry Smith ierr = PetscContainerSetUserDestroy(container,MatMPIAIJ_MPIDenseDestroy);CHKERRQ(ierr); 461bf0cc555SLisandro Dalcin ierr = PetscObjectCompose((PetscObject)(*C),"workB",(PetscObject)container);CHKERRQ(ierr); 462bf0cc555SLisandro Dalcin ierr = PetscContainerDestroy(&container);CHKERRQ(ierr); 4639123193aSHong Zhang PetscFunctionReturn(0); 4649123193aSHong Zhang } 4659123193aSHong Zhang 466f32d5d43SBarry Smith /* 4672636ff26SBarry Smith Performs an efficient scatter on the rows of B needed by this process; this is 4682636ff26SBarry Smith a modification of the VecScatterBegin_() routines. 469f32d5d43SBarry Smith */ 4704324174eSBarry Smith PetscErrorCode MatMPIDenseScatter(Mat A,Mat B,Mat C,Mat *outworkB) 471f32d5d43SBarry Smith { 472f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 473f32d5d43SBarry Smith PetscErrorCode ierr; 474f32d5d43SBarry Smith PetscScalar *b,*w,*svalues,*rvalues; 475f32d5d43SBarry Smith VecScatter ctx = aij->Mvctx; 476f32d5d43SBarry Smith VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata; 477f32d5d43SBarry Smith VecScatter_MPI_General *to = (VecScatter_MPI_General*) ctx->todata; 478f32d5d43SBarry Smith PetscInt i,j,k; 479aa5bb8c0SSatish Balay PetscInt *sindices,*sstarts,*rindices,*rstarts; 480aa5bb8c0SSatish Balay PetscMPIInt *sprocs,*rprocs,nrecvs; 481f32d5d43SBarry Smith MPI_Request *swaits,*rwaits; 482ce94432eSBarry Smith MPI_Comm comm; 483d0f46423SBarry Smith PetscMPIInt tag = ((PetscObject)ctx)->tag,ncols = B->cmap->N, nrows = aij->B->cmap->n,imdex,nrowsB = B->rmap->n; 484f32d5d43SBarry Smith MPI_Status status; 4854324174eSBarry Smith MPIAIJ_MPIDense *contents; 486bf0cc555SLisandro Dalcin PetscContainer container; 4874324174eSBarry Smith Mat workB; 488f32d5d43SBarry Smith 489f32d5d43SBarry Smith PetscFunctionBegin; 490ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 491bf0cc555SLisandro Dalcin ierr = PetscObjectQuery((PetscObject)C,"workB",(PetscObject*)&container);CHKERRQ(ierr); 49229825010SHong Zhang if (!container) SETERRQ(comm,PETSC_ERR_PLIB,"Container does not exist"); 493bf0cc555SLisandro Dalcin ierr = PetscContainerGetPointer(container,(void**)&contents);CHKERRQ(ierr); 4944324174eSBarry Smith 4954324174eSBarry Smith workB = *outworkB = contents->workB; 496cf1a0672SHong Zhang if (nrows != workB->rmap->n) SETERRQ2(comm,PETSC_ERR_PLIB,"Number of rows of workB %D not equal to columns of aij->B %D",nrows,workB->cmap->n); 497f32d5d43SBarry Smith sindices = to->indices; 498f32d5d43SBarry Smith sstarts = to->starts; 499f32d5d43SBarry Smith sprocs = to->procs; 5004324174eSBarry Smith swaits = contents->swaits; 5014324174eSBarry Smith svalues = contents->svalues; 502f32d5d43SBarry Smith 503f32d5d43SBarry Smith rindices = from->indices; 504f32d5d43SBarry Smith rstarts = from->starts; 505f32d5d43SBarry Smith rprocs = from->procs; 5064324174eSBarry Smith rwaits = contents->rwaits; 5074324174eSBarry Smith rvalues = contents->rvalues; 508f32d5d43SBarry Smith 5098c778c55SBarry Smith ierr = MatDenseGetArray(B,&b);CHKERRQ(ierr); 5108c778c55SBarry Smith ierr = MatDenseGetArray(workB,&w);CHKERRQ(ierr); 511f32d5d43SBarry Smith 512f32d5d43SBarry Smith for (i=0; i<from->n; i++) { 513f32d5d43SBarry Smith ierr = MPI_Irecv(rvalues+ncols*rstarts[i],ncols*(rstarts[i+1]-rstarts[i]),MPIU_SCALAR,rprocs[i],tag,comm,rwaits+i);CHKERRQ(ierr); 514f32d5d43SBarry Smith } 515f32d5d43SBarry Smith 516f32d5d43SBarry Smith for (i=0; i<to->n; i++) { 517f32d5d43SBarry Smith /* pack a message at a time */ 518f32d5d43SBarry Smith for (j=0; j<sstarts[i+1]-sstarts[i]; j++) { 519f32d5d43SBarry Smith for (k=0; k<ncols; k++) { 520f32d5d43SBarry Smith svalues[ncols*(sstarts[i] + j) + k] = b[sindices[sstarts[i]+j] + nrowsB*k]; 5212636ff26SBarry Smith } 5222636ff26SBarry Smith } 523f32d5d43SBarry Smith ierr = MPI_Isend(svalues+ncols*sstarts[i],ncols*(sstarts[i+1]-sstarts[i]),MPIU_SCALAR,sprocs[i],tag,comm,swaits+i);CHKERRQ(ierr); 524f32d5d43SBarry Smith } 5252636ff26SBarry Smith 526f32d5d43SBarry Smith nrecvs = from->n; 527f32d5d43SBarry Smith while (nrecvs) { 528f32d5d43SBarry Smith ierr = MPI_Waitany(from->n,rwaits,&imdex,&status);CHKERRQ(ierr); 529f32d5d43SBarry Smith nrecvs--; 530f32d5d43SBarry Smith /* unpack a message at a time */ 531f32d5d43SBarry Smith for (j=0; j<rstarts[imdex+1]-rstarts[imdex]; j++) { 532f32d5d43SBarry Smith for (k=0; k<ncols; k++) { 533f32d5d43SBarry Smith w[rindices[rstarts[imdex]+j] + nrows*k] = rvalues[ncols*(rstarts[imdex] + j) + k]; 5342636ff26SBarry Smith } 5352636ff26SBarry Smith } 536f32d5d43SBarry Smith } 537cb9801acSJed Brown if (to->n) {ierr = MPI_Waitall(to->n,swaits,to->sstatus);CHKERRQ(ierr);} 538f32d5d43SBarry Smith 5398c778c55SBarry Smith ierr = MatDenseRestoreArray(B,&b);CHKERRQ(ierr); 5408c778c55SBarry Smith ierr = MatDenseRestoreArray(workB,&w);CHKERRQ(ierr); 541f32d5d43SBarry Smith ierr = MatAssemblyBegin(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 542f32d5d43SBarry Smith ierr = MatAssemblyEnd(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 543f32d5d43SBarry Smith PetscFunctionReturn(0); 544f32d5d43SBarry Smith } 545f32d5d43SBarry Smith extern PetscErrorCode MatMatMultNumericAdd_SeqAIJ_SeqDense(Mat,Mat,Mat); 546f32d5d43SBarry Smith 5479123193aSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense(Mat A,Mat B,Mat C) 5489123193aSHong Zhang { 5499123193aSHong Zhang PetscErrorCode ierr; 550f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 551f32d5d43SBarry Smith Mat_MPIDense *bdense = (Mat_MPIDense*)B->data; 552f32d5d43SBarry Smith Mat_MPIDense *cdense = (Mat_MPIDense*)C->data; 553f32d5d43SBarry Smith Mat workB; 5549123193aSHong Zhang 5559123193aSHong Zhang PetscFunctionBegin; 556f32d5d43SBarry Smith /* diagonal block of A times all local rows of B*/ 557f32d5d43SBarry Smith ierr = MatMatMultNumeric_SeqAIJ_SeqDense(aij->A,bdense->A,cdense->A);CHKERRQ(ierr); 558f32d5d43SBarry Smith 559f32d5d43SBarry Smith /* get off processor parts of B needed to complete the product */ 5604324174eSBarry Smith ierr = MatMPIDenseScatter(A,B,C,&workB);CHKERRQ(ierr); 561f32d5d43SBarry Smith 562f32d5d43SBarry Smith /* off-diagonal block of A times nonlocal rows of B */ 563f32d5d43SBarry Smith ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cdense->A);CHKERRQ(ierr); 5649123193aSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 5659123193aSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 5669123193aSHong Zhang PetscFunctionReturn(0); 5679123193aSHong Zhang } 568cf1a0672SHong Zhang 569f8efd71cSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ(Mat A,Mat P,Mat C) 5701634b032SHong Zhang { 5711634b032SHong Zhang PetscErrorCode ierr; 572cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 573cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 574cf1a0672SHong Zhang Mat_SeqAIJ *cd = (Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 575cf1a0672SHong Zhang PetscInt *adi = ad->i,*adj,*aoi=ao->i,*aoj; 576cf1a0672SHong Zhang PetscScalar *ada,*aoa,*cda=cd->a,*coa=co->a; 577cf1a0672SHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 578cf1a0672SHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj; 57929825010SHong Zhang PetscScalar *pa_loc,*pa_oth,*pa,valtmp,*ca; 58029825010SHong Zhang PetscInt cm = C->rmap->n,anz,pnz; 581cf1a0672SHong Zhang Mat_PtAPMPI *ptap = c->ptap; 58229825010SHong Zhang PetscScalar *apa_sparse = ptap->apa; 583cf1a0672SHong Zhang PetscInt *api,*apj,*apJ,i,j,k,row; 58429825010SHong Zhang PetscInt cstart = C->cmap->rstart; 58529825010SHong Zhang PetscInt cdnz,conz,k0,k1,nextp; 586a7c7454dSHong Zhang MPI_Comm comm; 587a7c7454dSHong Zhang PetscMPIInt size; 5881634b032SHong Zhang 5891634b032SHong Zhang PetscFunctionBegin; 590a7c7454dSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 591a7c7454dSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 592a7c7454dSHong Zhang 593cf1a0672SHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 594cf1a0672SHong Zhang /*-----------------------------------------------------*/ 595cf1a0672SHong Zhang /* update numerical values of P_oth and P_loc */ 596b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 597cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 598cf1a0672SHong Zhang 599cf1a0672SHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 600cf1a0672SHong Zhang /*----------------------------------------------------------*/ 601cf1a0672SHong Zhang /* get data from symbolic products */ 602cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 603cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; pa_loc = p_loc->a; 604a7c7454dSHong Zhang if (size >1) { 605a7c7454dSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 606cf1a0672SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; pa_oth = p_oth->a; 60720e3dc75SHong Zhang } else { 60820e3dc75SHong Zhang p_oth = NULL; pi_oth = NULL; pj_oth = NULL; pa_oth = NULL; 609a7c7454dSHong Zhang } 610cf1a0672SHong Zhang 61129825010SHong Zhang api = ptap->api; 61229825010SHong Zhang apj = ptap->apj; 613cf1a0672SHong Zhang for (i=0; i<cm; i++) { 61429825010SHong Zhang apJ = apj + api[i]; 61529825010SHong Zhang 616cf1a0672SHong Zhang /* diagonal portion of A */ 617cf1a0672SHong Zhang anz = adi[i+1] - adi[i]; 618cf1a0672SHong Zhang adj = ad->j + adi[i]; 619cf1a0672SHong Zhang ada = ad->a + adi[i]; 620cf1a0672SHong Zhang for (j=0; j<anz; j++) { 621cf1a0672SHong Zhang row = adj[j]; 622cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 623cf1a0672SHong Zhang pj = pj_loc + pi_loc[row]; 624cf1a0672SHong Zhang pa = pa_loc + pi_loc[row]; 62529825010SHong Zhang /* perform sparse axpy */ 626cf1a0672SHong Zhang valtmp = ada[j]; 62729825010SHong Zhang nextp = 0; 62829825010SHong Zhang for (k=0; nextp<pnz; k++) { 62929825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 63029825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 63129825010SHong Zhang } 6321634b032SHong Zhang } 633cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 634cf1a0672SHong Zhang } 6351634b032SHong Zhang 636cf1a0672SHong Zhang /* off-diagonal portion of A */ 637cf1a0672SHong Zhang anz = aoi[i+1] - aoi[i]; 638cf1a0672SHong Zhang aoj = ao->j + aoi[i]; 639cf1a0672SHong Zhang aoa = ao->a + aoi[i]; 640cf1a0672SHong Zhang for (j=0; j<anz; j++) { 641cf1a0672SHong Zhang row = aoj[j]; 642cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 643cf1a0672SHong Zhang pj = pj_oth + pi_oth[row]; 644cf1a0672SHong Zhang pa = pa_oth + pi_oth[row]; 64529825010SHong Zhang /* perform sparse axpy */ 646cf1a0672SHong Zhang valtmp = aoa[j]; 64729825010SHong Zhang nextp = 0; 64829825010SHong Zhang for (k=0; nextp<pnz; k++) { 64929825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 65029825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 65129825010SHong Zhang } 652cf1a0672SHong Zhang } 653cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 654cf1a0672SHong Zhang } 6551634b032SHong Zhang 656cf1a0672SHong Zhang /* set values in C */ 657cf1a0672SHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 658cf1a0672SHong Zhang conz = co->i[i+1] - co->i[i]; 6591634b032SHong Zhang 660cf1a0672SHong Zhang /* 1st off-diagoanl part of C */ 661cf1a0672SHong Zhang ca = coa + co->i[i]; 662cf1a0672SHong Zhang k = 0; 663cf1a0672SHong Zhang for (k0=0; k0<conz; k0++) { 664cf1a0672SHong Zhang if (apJ[k] >= cstart) break; 66529825010SHong Zhang ca[k0] = apa_sparse[k]; 66629825010SHong Zhang apa_sparse[k] = 0.0; 667cf1a0672SHong Zhang k++; 668cf1a0672SHong Zhang } 6691634b032SHong Zhang 670cf1a0672SHong Zhang /* diagonal part of C */ 671cf1a0672SHong Zhang ca = cda + cd->i[i]; 672cf1a0672SHong Zhang for (k1=0; k1<cdnz; k1++) { 67329825010SHong Zhang ca[k1] = apa_sparse[k]; 67429825010SHong Zhang apa_sparse[k] = 0.0; 675cf1a0672SHong Zhang k++; 676cf1a0672SHong Zhang } 677cf1a0672SHong Zhang 678cf1a0672SHong Zhang /* 2nd off-diagoanl part of C */ 679cf1a0672SHong Zhang ca = coa + co->i[i]; 680cf1a0672SHong Zhang for (; k0<conz; k0++) { 68129825010SHong Zhang ca[k0] = apa_sparse[k]; 68229825010SHong Zhang apa_sparse[k] = 0.0; 683cf1a0672SHong Zhang k++; 684cf1a0672SHong Zhang } 685cf1a0672SHong Zhang } 686cf1a0672SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 687cf1a0672SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 688cf1a0672SHong Zhang PetscFunctionReturn(0); 689cf1a0672SHong Zhang } 690cf1a0672SHong Zhang 6910fc8cf34SHong Zhang /* same as MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(), except using LLCondensed to avoid O(BN) memory requirement */ 692b2405163SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat *C) 693cf1a0672SHong Zhang { 694cf1a0672SHong Zhang PetscErrorCode ierr; 695ce94432eSBarry Smith MPI_Comm comm; 696a7c7454dSHong Zhang PetscMPIInt size; 697cf1a0672SHong Zhang Mat Cmpi; 698cf1a0672SHong Zhang Mat_PtAPMPI *ptap; 6990298fd71SBarry Smith PetscFreeSpaceList free_space = NULL,current_space=NULL; 700cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c; 701cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 702cf1a0672SHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 703cf1a0672SHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 7040ca7d551SHong Zhang PetscInt i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi,*lnk,apnz_max; 7050ca7d551SHong Zhang PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n; 706cf1a0672SHong Zhang PetscReal afill; 707cf1a0672SHong Zhang PetscScalar *apa; 708eca6b86aSHong Zhang PetscTable ta; 709cf1a0672SHong Zhang 710cf1a0672SHong Zhang PetscFunctionBegin; 711ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 712a7c7454dSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 713a7c7454dSHong Zhang 714cf1a0672SHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 715b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 716cf1a0672SHong Zhang 717cf1a0672SHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 718b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 71919f0e57aSHong Zhang 720cf1a0672SHong Zhang /* get P_loc by taking all local rows of P */ 721cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 722cf1a0672SHong Zhang 723cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 724cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 725a7c7454dSHong Zhang if (size > 1) { 726a7c7454dSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 72720e3dc75SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 728968382fdSHong Zhang } else { 72920e3dc75SHong Zhang p_oth = NULL; 73020e3dc75SHong Zhang pi_oth = NULL; pj_oth = NULL; 731a7c7454dSHong Zhang } 732cf1a0672SHong Zhang 733cf1a0672SHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 734cf1a0672SHong Zhang /*-------------------------------------------------------------------*/ 735854ce69bSBarry Smith ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 736cf1a0672SHong Zhang ptap->api = api; 737cf1a0672SHong Zhang api[0] = 0; 738cf1a0672SHong Zhang 739cf1a0672SHong Zhang /* create and initialize a linked list */ 74045d00d1dSHong Zhang ierr = PetscTableCreate(pn,pN,&ta);CHKERRQ(ierr); 7410ca7d551SHong Zhang 7420ca7d551SHong Zhang /* Calculate apnz_max */ 7430ca7d551SHong Zhang apnz_max = 0; 7440ca7d551SHong Zhang for (i=0; i<am; i++) { 7450ca7d551SHong Zhang ierr = PetscTableRemoveAll(ta);CHKERRQ(ierr); 7460ca7d551SHong Zhang /* diagonal portion of A */ 7470ca7d551SHong Zhang nzi = adi[i+1] - adi[i]; 7480ca7d551SHong Zhang Jptr = adj+adi[i]; /* cols of A_diag */ 7490ca7d551SHong Zhang MatMergeRows_SeqAIJ(p_loc,nzi,Jptr,ta); 7500ca7d551SHong Zhang ierr = PetscTableGetCount(ta,&apnz);CHKERRQ(ierr); 7510ca7d551SHong Zhang if (apnz_max < apnz) apnz_max = apnz; 7520ca7d551SHong Zhang 7530ca7d551SHong Zhang /* off-diagonal portion of A */ 7540ca7d551SHong Zhang nzi = aoi[i+1] - aoi[i]; 7550ca7d551SHong Zhang Jptr = aoj+aoi[i]; /* cols of A_off */ 7560ca7d551SHong Zhang MatMergeRows_SeqAIJ(p_oth,nzi,Jptr,ta); 7570ca7d551SHong Zhang ierr = PetscTableGetCount(ta,&apnz);CHKERRQ(ierr); 7580ca7d551SHong Zhang if (apnz_max < apnz) apnz_max = apnz; 7590ca7d551SHong Zhang } 760eca6b86aSHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 761eca6b86aSHong Zhang 7620ca7d551SHong Zhang ierr = PetscLLCondensedCreate_Scalable(apnz_max,&lnk);CHKERRQ(ierr); 763cf1a0672SHong Zhang 764cf1a0672SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 765f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space);CHKERRQ(ierr); 766cf1a0672SHong Zhang current_space = free_space; 767cf1a0672SHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 768cf1a0672SHong Zhang for (i=0; i<am; i++) { 769cf1a0672SHong Zhang /* diagonal portion of A */ 770cf1a0672SHong Zhang nzi = adi[i+1] - adi[i]; 771cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 772cf1a0672SHong Zhang row = *adj++; 773cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 774cf1a0672SHong Zhang Jptr = pj_loc + pi_loc[row]; 775cf1a0672SHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 776f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 777cf1a0672SHong Zhang } 778cf1a0672SHong Zhang /* off-diagonal portion of A */ 779cf1a0672SHong Zhang nzi = aoi[i+1] - aoi[i]; 780cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 781cf1a0672SHong Zhang row = *aoj++; 782cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 783cf1a0672SHong Zhang Jptr = pj_oth + pi_oth[row]; 784f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 785cf1a0672SHong Zhang } 786cf1a0672SHong Zhang 787f84c536bSHong Zhang apnz = *lnk; 788cf1a0672SHong Zhang api[i+1] = api[i] + apnz; 789cf1a0672SHong Zhang 790cf1a0672SHong Zhang /* if free space is not available, double the total space in the list */ 791cf1a0672SHong Zhang if (current_space->local_remaining<apnz) { 792f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 793cf1a0672SHong Zhang nspacedouble++; 794cf1a0672SHong Zhang } 795cf1a0672SHong Zhang 796cf1a0672SHong Zhang /* Copy data into free space, then initialize lnk */ 797f84c536bSHong Zhang ierr = PetscLLCondensedClean_Scalable(apnz,current_space->array,lnk);CHKERRQ(ierr); 798cf1a0672SHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 7992205254eSKarl Rupp 800cf1a0672SHong Zhang current_space->array += apnz; 801cf1a0672SHong Zhang current_space->local_used += apnz; 802cf1a0672SHong Zhang current_space->local_remaining -= apnz; 803cf1a0672SHong Zhang } 804cf1a0672SHong Zhang 805cf1a0672SHong Zhang /* Allocate space for apj, initialize apj, and */ 806cf1a0672SHong Zhang /* destroy list of free space and other temporary array(s) */ 807854ce69bSBarry Smith ierr = PetscMalloc1(api[am]+1,&ptap->apj);CHKERRQ(ierr); 808cf1a0672SHong Zhang apj = ptap->apj; 809cf1a0672SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 810f84c536bSHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 811cf1a0672SHong Zhang 812cf1a0672SHong Zhang /* create and assemble symbolic parallel matrix Cmpi */ 813cf1a0672SHong Zhang /*----------------------------------------------------*/ 814cf1a0672SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 815cf1a0672SHong Zhang ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 81633d57670SJed Brown ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr); 817cf1a0672SHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 818cf1a0672SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 819cf1a0672SHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 820cf1a0672SHong Zhang 82129825010SHong Zhang /* malloc apa for assembly Cmpi */ 8221795a4d1SJed Brown ierr = PetscCalloc1(apnz_max,&apa);CHKERRQ(ierr); 8232205254eSKarl Rupp 82429825010SHong Zhang ptap->apa = apa; 825cf1a0672SHong Zhang for (i=0; i<am; i++) { 826cf1a0672SHong Zhang row = i + rstart; 827cf1a0672SHong Zhang apnz = api[i+1] - api[i]; 828cf1a0672SHong Zhang ierr = MatSetValues(Cmpi,1,&row,apnz,apj,apa,INSERT_VALUES);CHKERRQ(ierr); 829cf1a0672SHong Zhang apj += apnz; 830cf1a0672SHong Zhang } 831cf1a0672SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 832cf1a0672SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 833cf1a0672SHong Zhang 834cf1a0672SHong Zhang ptap->destroy = Cmpi->ops->destroy; 835cf1a0672SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 836f8efd71cSHong Zhang Cmpi->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ; 837cf1a0672SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_MatMatMult; 838cf1a0672SHong Zhang Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatMatMult; 839cf1a0672SHong Zhang 840cf1a0672SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 841cf1a0672SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 842cf1a0672SHong Zhang c->ptap = ptap; 843cf1a0672SHong Zhang 844cf1a0672SHong Zhang *C = Cmpi; 845cf1a0672SHong Zhang 846cf1a0672SHong Zhang /* set MatInfo */ 847118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 848cf1a0672SHong Zhang if (afill < 1.0) afill = 1.0; 849cf1a0672SHong Zhang Cmpi->info.mallocs = nspacedouble; 850cf1a0672SHong Zhang Cmpi->info.fill_ratio_given = fill; 851cf1a0672SHong Zhang Cmpi->info.fill_ratio_needed = afill; 852cf1a0672SHong Zhang 853cf1a0672SHong Zhang #if defined(PETSC_USE_INFO) 854cf1a0672SHong Zhang if (api[am]) { 85557622a8eSBarry Smith ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 85657622a8eSBarry Smith ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 857cf1a0672SHong Zhang } else { 858cf1a0672SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 859cf1a0672SHong Zhang } 860cf1a0672SHong Zhang #endif 8611634b032SHong Zhang PetscFunctionReturn(0); 8621634b032SHong Zhang } 863f96d37fcSHong Zhang 864f96d37fcSHong Zhang /*-------------------------------------------------------------------------*/ 865c5af039cSHong Zhang PetscErrorCode MatTransposeMatMult_MPIAIJ_MPIAIJ(Mat P,Mat A,MatReuse scall,PetscReal fill,Mat *C) 866f96d37fcSHong Zhang { 867f96d37fcSHong Zhang PetscErrorCode ierr; 868c216dbf3SHong Zhang const char *algTypes[3] = {"scalable","nonscalable","matmatmult"}; 869c216dbf3SHong Zhang PetscInt alg=0; /* set default algorithm */ 870f96d37fcSHong Zhang 871f96d37fcSHong Zhang PetscFunctionBegin; 872c216dbf3SHong Zhang if (scall == MAT_INITIAL_MATRIX) { 873c216dbf3SHong Zhang ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr); 87468eacb73SHong Zhang PetscOptionsObject->alreadyprinted = PETSC_FALSE; /* a hack to ensure the option shows in '-help' */ 875c216dbf3SHong Zhang ierr = PetscOptionsEList("-mattransposematmult_via","Algorithmic approach","MatTransposeMatMult",algTypes,3,algTypes[0],&alg,NULL);CHKERRQ(ierr); 876c216dbf3SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 877c216dbf3SHong Zhang 878912837bbSHong Zhang //ierr = PetscLogEventBegin(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr); 879c216dbf3SHong Zhang switch (alg) { 880c216dbf3SHong Zhang case 1: 8812bbb1c24SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(P,A,fill,C);CHKERRQ(ierr); 882c216dbf3SHong Zhang break; 883c216dbf3SHong Zhang case 2: 884275476c6SMatthew G. Knepley { 885ab1b013aSHong Zhang Mat Pt; 886ab1b013aSHong Zhang Mat_PtAPMPI *ptap; 887ab1b013aSHong Zhang Mat_MPIAIJ *c; 888ab1b013aSHong Zhang ierr = MatTranspose(P,MAT_INITIAL_MATRIX,&Pt);CHKERRQ(ierr); 889ab1b013aSHong Zhang ierr = MatMatMult(Pt,A,MAT_INITIAL_MATRIX,fill,C);CHKERRQ(ierr); 890ab1b013aSHong Zhang c = (Mat_MPIAIJ*)(*C)->data; 891ab1b013aSHong Zhang ptap = c->ptap; 892ab1b013aSHong Zhang ptap->Pt = Pt; 893c216dbf3SHong Zhang (*C)->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult; 894c216dbf3SHong Zhang PetscFunctionReturn(0); 895275476c6SMatthew G. Knepley } 896c216dbf3SHong Zhang break; 897c216dbf3SHong Zhang default: 8986da69ca6SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(P,A,fill,C);CHKERRQ(ierr); 899c216dbf3SHong Zhang break; 900c216dbf3SHong Zhang } 901912837bbSHong Zhang //ierr = PetscLogEventEnd(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr); 902c216dbf3SHong Zhang } 903912837bbSHong Zhang //ierr = PetscLogEventBegin(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr); 904c216dbf3SHong Zhang ierr = (*(*C)->ops->mattransposemultnumeric)(P,A,*C);CHKERRQ(ierr); 905912837bbSHong Zhang //ierr = PetscLogEventEnd(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr); 906ab1b013aSHong Zhang PetscFunctionReturn(0); 907ab1b013aSHong Zhang } 908ab1b013aSHong Zhang 909c216dbf3SHong Zhang /* This routine only works when scall=MAT_REUSE_MATRIX! */ 910c216dbf3SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult(Mat P,Mat A,Mat C) 911c216dbf3SHong Zhang { 912c216dbf3SHong Zhang PetscErrorCode ierr; 9132bbb1c24SHong Zhang Mat_MPIAIJ *c=(Mat_MPIAIJ*)C->data; 9142bbb1c24SHong Zhang Mat_PtAPMPI *ptap= c->ptap; 9152bbb1c24SHong Zhang Mat Pt=ptap->Pt; 916c216dbf3SHong Zhang 917c216dbf3SHong Zhang PetscFunctionBegin; 918c216dbf3SHong Zhang ierr = MatTranspose(P,MAT_REUSE_MATRIX,&Pt);CHKERRQ(ierr); 919c216dbf3SHong Zhang ierr = MatMatMultNumeric(Pt,A,C);CHKERRQ(ierr); 920f96d37fcSHong Zhang PetscFunctionReturn(0); 921f96d37fcSHong Zhang } 922f96d37fcSHong Zhang 9236da69ca6SHong Zhang /* Non-scalable version, use dense axpy */ 924912837bbSHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable_old(Mat P,Mat A,Mat C) 925f96d37fcSHong Zhang { 926c5af039cSHong Zhang PetscErrorCode ierr; 927c5af039cSHong Zhang Mat_Merge_SeqsToMPI *merge; 928497f5370SHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 929c5af039cSHong Zhang Mat_SeqAIJ *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data; 930c5af039cSHong Zhang Mat_PtAPMPI *ptap; 931d6ab1dc0SHong Zhang PetscInt *adj,*aJ; 932497f5370SHong Zhang PetscInt i,j,k,anz,pnz,row,*cj; 933e745005bSHong Zhang MatScalar *ada,*aval,*ca,valtmp; 934c5af039cSHong Zhang PetscInt am =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n; 935ce94432eSBarry Smith MPI_Comm comm; 936c5af039cSHong Zhang PetscMPIInt size,rank,taga,*len_s; 937c5af039cSHong Zhang PetscInt *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci; 938c5af039cSHong Zhang PetscInt **buf_ri,**buf_rj; 939c5af039cSHong Zhang PetscInt cnz=0,*bj_i,*bi,*bj,bnz,nextcj; /* bi,bj,ba: local array of C(mpi mat) */ 940c5af039cSHong Zhang MPI_Request *s_waits,*r_waits; 941c5af039cSHong Zhang MPI_Status *status; 942c5af039cSHong Zhang MatScalar **abuf_r,*ba_i,*pA,*coa,*ba; 943d6ab1dc0SHong Zhang PetscInt *ai,*aj,*coi,*coj; 944a2ea699eSBarry Smith PetscInt *poJ,*pdJ; 945c5af039cSHong Zhang Mat A_loc; 946c5af039cSHong Zhang Mat_SeqAIJ *a_loc; 947f96d37fcSHong Zhang 948f96d37fcSHong Zhang PetscFunctionBegin; 949ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 950c5af039cSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 951c5af039cSHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 952c5af039cSHong Zhang 953c5af039cSHong Zhang ptap = c->ptap; 954c5af039cSHong Zhang merge = ptap->merge; 955c5af039cSHong Zhang 956070e40ebSHong Zhang /* 2) compute numeric C_seq = P_loc^T*A_loc - dominating part */ 957070e40ebSHong Zhang /*------------------------------------------------------------*/ 958c5af039cSHong Zhang /* get data from symbolic products */ 959c5af039cSHong Zhang coi = merge->coi; coj = merge->coj; 960854ce69bSBarry Smith ierr = PetscCalloc1(coi[pon]+1,&coa);CHKERRQ(ierr); 961c5af039cSHong Zhang 962c5af039cSHong Zhang bi = merge->bi; bj = merge->bj; 963c5af039cSHong Zhang owners = merge->rowmap->range; 964854ce69bSBarry Smith ierr = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr); 965c5af039cSHong Zhang 966c5af039cSHong Zhang /* get A_loc by taking all local rows of A */ 967c5af039cSHong Zhang A_loc = ptap->A_loc; 968c5af039cSHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr); 969c5af039cSHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 970d6ab1dc0SHong Zhang ai = a_loc->i; 971d6ab1dc0SHong Zhang aj = a_loc->j; 972c5af039cSHong Zhang 973854ce69bSBarry Smith ierr = PetscCalloc1(A->cmap->N,&aval);CHKERRQ(ierr); /* non-scalable!!! */ 974c5af039cSHong Zhang 975c5af039cSHong Zhang for (i=0; i<am; i++) { 976e745005bSHong Zhang /* 2-a) put A[i,:] to dense array aval */ 977d6ab1dc0SHong Zhang anz = ai[i+1] - ai[i]; 978d6ab1dc0SHong Zhang adj = aj + ai[i]; 979d6ab1dc0SHong Zhang ada = a_loc->a + ai[i]; 980c5af039cSHong Zhang for (j=0; j<anz; j++) { 981e745005bSHong Zhang aval[adj[j]] = ada[j]; 982c5af039cSHong Zhang } 983c5af039cSHong Zhang 984c5af039cSHong Zhang /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */ 985c5af039cSHong Zhang /*--------------------------------------------------------------*/ 986c5af039cSHong Zhang /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */ 987c5af039cSHong Zhang pnz = po->i[i+1] - po->i[i]; 988c5af039cSHong Zhang poJ = po->j + po->i[i]; 989c5af039cSHong Zhang pA = po->a + po->i[i]; 990c5af039cSHong Zhang for (j=0; j<pnz; j++) { 991c5af039cSHong Zhang row = poJ[j]; 992c5af039cSHong Zhang cnz = coi[row+1] - coi[row]; 993c5af039cSHong Zhang cj = coj + coi[row]; 994c5af039cSHong Zhang ca = coa + coi[row]; 995c5af039cSHong Zhang /* perform dense axpy */ 996c5af039cSHong Zhang valtmp = pA[j]; 997c5af039cSHong Zhang for (k=0; k<cnz; k++) { 998e745005bSHong Zhang ca[k] += valtmp*aval[cj[k]]; 999c5af039cSHong Zhang } 1000c5af039cSHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1001c5af039cSHong Zhang } 1002c5af039cSHong Zhang 1003c5af039cSHong Zhang /* put the value into Cd (diagonal part) */ 1004c5af039cSHong Zhang pnz = pd->i[i+1] - pd->i[i]; 1005c5af039cSHong Zhang pdJ = pd->j + pd->i[i]; 1006c5af039cSHong Zhang pA = pd->a + pd->i[i]; 1007c5af039cSHong Zhang for (j=0; j<pnz; j++) { 1008c5af039cSHong Zhang row = pdJ[j]; 1009c5af039cSHong Zhang cnz = bi[row+1] - bi[row]; 1010c5af039cSHong Zhang cj = bj + bi[row]; 1011c5af039cSHong Zhang ca = ba + bi[row]; 1012c5af039cSHong Zhang /* perform dense axpy */ 1013c5af039cSHong Zhang valtmp = pA[j]; 1014c5af039cSHong Zhang for (k=0; k<cnz; k++) { 1015e745005bSHong Zhang ca[k] += valtmp*aval[cj[k]]; 1016c5af039cSHong Zhang } 1017c5af039cSHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1018c5af039cSHong Zhang } 1019c5af039cSHong Zhang 1020d6ab1dc0SHong Zhang /* zero the current row of Pt*A */ 1021d6ab1dc0SHong Zhang aJ = aj + ai[i]; 1022e745005bSHong Zhang for (k=0; k<anz; k++) aval[aJ[k]] = 0.0; 1023c5af039cSHong Zhang } 1024c5af039cSHong Zhang 1025c5af039cSHong Zhang /* 3) send and recv matrix values coa */ 1026c5af039cSHong Zhang /*------------------------------------*/ 1027c5af039cSHong Zhang buf_ri = merge->buf_ri; 1028c5af039cSHong Zhang buf_rj = merge->buf_rj; 1029c5af039cSHong Zhang len_s = merge->len_s; 1030c5af039cSHong Zhang ierr = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr); 1031c5af039cSHong Zhang ierr = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr); 1032c5af039cSHong Zhang 1033dcca6d9dSJed Brown ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr); 1034c5af039cSHong Zhang for (proc=0,k=0; proc<size; proc++) { 1035c5af039cSHong Zhang if (!len_s[proc]) continue; 1036c5af039cSHong Zhang i = merge->owners_co[proc]; 1037c5af039cSHong Zhang ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr); 1038c5af039cSHong Zhang k++; 1039c5af039cSHong Zhang } 1040c5af039cSHong Zhang if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);} 1041c5af039cSHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);} 1042c5af039cSHong Zhang 1043c5af039cSHong Zhang ierr = PetscFree2(s_waits,status);CHKERRQ(ierr); 1044c5af039cSHong Zhang ierr = PetscFree(r_waits);CHKERRQ(ierr); 1045c5af039cSHong Zhang ierr = PetscFree(coa);CHKERRQ(ierr); 1046c5af039cSHong Zhang 1047c5af039cSHong Zhang /* 4) insert local Cseq and received values into Cmpi */ 1048c5af039cSHong Zhang /*----------------------------------------------------*/ 1049dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1050c5af039cSHong Zhang for (k=0; k<merge->nrecv; k++) { 1051c36aecf5SHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1052c5af039cSHong Zhang nrows = *(buf_ri_k[k]); 1053c5af039cSHong Zhang nextrow[k] = buf_ri_k[k]+1; /* next row number of k-th recved i-structure */ 1054c5af039cSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1055c5af039cSHong Zhang } 1056c5af039cSHong Zhang 1057c5af039cSHong Zhang for (i=0; i<cm; i++) { 1058c5af039cSHong Zhang row = owners[rank] + i; /* global row index of C_seq */ 1059c5af039cSHong Zhang bj_i = bj + bi[i]; /* col indices of the i-th row of C */ 1060c5af039cSHong Zhang ba_i = ba + bi[i]; 1061c5af039cSHong Zhang bnz = bi[i+1] - bi[i]; 1062c5af039cSHong Zhang /* add received vals into ba */ 1063c5af039cSHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1064c5af039cSHong Zhang /* i-th row */ 1065c5af039cSHong Zhang if (i == *nextrow[k]) { 1066c5af039cSHong Zhang cnz = *(nextci[k]+1) - *nextci[k]; 1067c5af039cSHong Zhang cj = buf_rj[k] + *(nextci[k]); 1068c5af039cSHong Zhang ca = abuf_r[k] + *(nextci[k]); 1069c5af039cSHong Zhang nextcj = 0; 1070c5af039cSHong Zhang for (j=0; nextcj<cnz; j++) { 1071c5af039cSHong Zhang if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */ 1072c5af039cSHong Zhang ba_i[j] += ca[nextcj++]; 1073c5af039cSHong Zhang } 1074c5af039cSHong Zhang } 1075c5af039cSHong Zhang nextrow[k]++; nextci[k]++; 1076c5af039cSHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1077c5af039cSHong Zhang } 1078c5af039cSHong Zhang } 1079c5af039cSHong Zhang ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr); 1080c5af039cSHong Zhang } 1081c5af039cSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1082c5af039cSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1083c5af039cSHong Zhang 1084c5af039cSHong Zhang ierr = PetscFree(ba);CHKERRQ(ierr); 1085c5af039cSHong Zhang ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr); 1086c5af039cSHong Zhang ierr = PetscFree(abuf_r);CHKERRQ(ierr); 1087c5af039cSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1088e745005bSHong Zhang ierr = PetscFree(aval);CHKERRQ(ierr); 1089f96d37fcSHong Zhang PetscFunctionReturn(0); 1090f96d37fcSHong Zhang } 1091f96d37fcSHong Zhang 1092c9ba551fSBarry Smith PetscErrorCode MatDuplicate_MPIAIJ_MatPtAP(Mat, MatDuplicateOption,Mat*); 1093c5af039cSHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ() */ 1094912837bbSHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable_old(Mat P,Mat A,PetscReal fill,Mat *C) 1095f96d37fcSHong Zhang { 1096f96d37fcSHong Zhang PetscErrorCode ierr; 10974e938277SHong Zhang Mat Cmpi,A_loc,POt,PDt; 1098f96d37fcSHong Zhang Mat_PtAPMPI *ptap; 10990298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 1100f96d37fcSHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c; 1101f96d37fcSHong Zhang PetscInt *pdti,*pdtj,*poti,*potj,*ptJ; 1102f96d37fcSHong Zhang PetscInt nnz; 11034e938277SHong Zhang PetscInt *lnk,*owners_co,*coi,*coj,i,k,pnz,row; 1104497f5370SHong Zhang PetscInt am=A->rmap->n,pn=P->cmap->n; 1105f96d37fcSHong Zhang PetscBT lnkbt; 1106ce94432eSBarry Smith MPI_Comm comm; 1107f96d37fcSHong Zhang PetscMPIInt size,rank,tagi,tagj,*len_si,*len_s,*len_ri; 1108f96d37fcSHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 1109f96d37fcSHong Zhang PetscInt len,proc,*dnz,*onz,*owners; 1110f96d37fcSHong Zhang PetscInt nzi,*bi,*bj; 1111f96d37fcSHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1112f96d37fcSHong Zhang MPI_Request *swaits,*rwaits; 1113f96d37fcSHong Zhang MPI_Status *sstatus,rstatus; 1114f96d37fcSHong Zhang Mat_Merge_SeqsToMPI *merge; 1115d6ab1dc0SHong Zhang PetscInt *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j; 1116f96d37fcSHong Zhang PetscReal afill =1.0,afill_tmp; 1117438d860cSHong Zhang PetscInt rstart = P->cmap->rstart,rmax,aN=A->cmap->N; 1118f96d37fcSHong Zhang PetscScalar *vals; 11194e938277SHong Zhang Mat_SeqAIJ *a_loc, *pdt,*pot; 1120f96d37fcSHong Zhang 1121f96d37fcSHong Zhang PetscFunctionBegin; 1122ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1123c5af039cSHong Zhang /* check if matrix local sizes are compatible */ 11246c4ed002SBarry Smith if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, A (%D, %D) != P (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend); 1125c5af039cSHong Zhang 1126f96d37fcSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1127f96d37fcSHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1128f96d37fcSHong Zhang 1129f96d37fcSHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 1130b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 1131f96d37fcSHong Zhang 1132f96d37fcSHong Zhang /* get A_loc by taking all local rows of A */ 1133f96d37fcSHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr); 11342205254eSKarl Rupp 1135c5af039cSHong Zhang ptap->A_loc = A_loc; 11362205254eSKarl Rupp 11371c7d5954SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1138d6ab1dc0SHong Zhang ai = a_loc->i; 1139d6ab1dc0SHong Zhang aj = a_loc->j; 1140f96d37fcSHong Zhang 1141f96d37fcSHong Zhang /* determine symbolic Co=(p->B)^T*A - send to others */ 1142f96d37fcSHong Zhang /*----------------------------------------------------*/ 11434e938277SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr); 11444e938277SHong Zhang pdt = (Mat_SeqAIJ*)PDt->data; 11454e938277SHong Zhang pdti = pdt->i; pdtj = pdt->j; 11464e938277SHong Zhang 11474e938277SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr); 11484e938277SHong Zhang pot = (Mat_SeqAIJ*)POt->data; 11494e938277SHong Zhang poti = pot->i; potj = pot->j; 1150f96d37fcSHong Zhang 1151f96d37fcSHong Zhang /* then, compute symbolic Co = (p->B)^T*A */ 11522205254eSKarl Rupp pon = (p->B)->cmap->n; /* total num of rows to be sent to other processors >= (num of nonzero rows of C_seq) - pn */ 1153854ce69bSBarry Smith ierr = PetscMalloc1(pon+1,&coi);CHKERRQ(ierr); 1154f96d37fcSHong Zhang coi[0] = 0; 1155f96d37fcSHong Zhang 1156f96d37fcSHong Zhang /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */ 1157f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(poti[pon],ai[am])); 1158a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1159f96d37fcSHong Zhang current_space = free_space; 116019f0e57aSHong Zhang 1161f96d37fcSHong Zhang /* create and initialize a linked list */ 1162438d860cSHong Zhang ierr = PetscLLCondensedCreate(aN,aN,&lnk,&lnkbt);CHKERRQ(ierr); 1163f96d37fcSHong Zhang 1164f96d37fcSHong Zhang for (i=0; i<pon; i++) { 1165f96d37fcSHong Zhang pnz = poti[i+1] - poti[i]; 1166f96d37fcSHong Zhang ptJ = potj + poti[i]; 1167f96d37fcSHong Zhang for (j=0; j<pnz; j++) { 1168f96d37fcSHong Zhang row = ptJ[j]; /* row of A_loc == col of Pot */ 1169d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1170d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1171f96d37fcSHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1172d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted(anz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1173f96d37fcSHong Zhang } 11744e938277SHong Zhang nnz = lnk[0]; 1175f96d37fcSHong Zhang 1176f96d37fcSHong Zhang /* If free space is not available, double the total space in the list */ 1177f96d37fcSHong Zhang if (current_space->local_remaining<nnz) { 1178f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 1179f96d37fcSHong Zhang nspacedouble++; 1180f96d37fcSHong Zhang } 1181f96d37fcSHong Zhang 1182f96d37fcSHong Zhang /* Copy data into free space, and zero out denserows */ 11834e938277SHong Zhang ierr = PetscLLCondensedClean(aN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 11842205254eSKarl Rupp 1185f96d37fcSHong Zhang current_space->array += nnz; 1186f96d37fcSHong Zhang current_space->local_used += nnz; 1187f96d37fcSHong Zhang current_space->local_remaining -= nnz; 11882205254eSKarl Rupp 1189f96d37fcSHong Zhang coi[i+1] = coi[i] + nnz; 1190f96d37fcSHong Zhang } 1191f96d37fcSHong Zhang 1192854ce69bSBarry Smith ierr = PetscMalloc1(coi[pon]+1,&coj);CHKERRQ(ierr); 1193f96d37fcSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr); 11942205254eSKarl Rupp 1195118727c9SMark F. Adams afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1); 1196f96d37fcSHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1197f96d37fcSHong Zhang 1198f96d37fcSHong Zhang /* send j-array (coj) of Co to other processors */ 1199f96d37fcSHong Zhang /*----------------------------------------------*/ 1200f96d37fcSHong Zhang /* determine row ownership */ 1201b00a9115SJed Brown ierr = PetscNew(&merge);CHKERRQ(ierr); 1202f96d37fcSHong Zhang ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr); 12032205254eSKarl Rupp 1204f96d37fcSHong Zhang merge->rowmap->n = pn; 1205f96d37fcSHong Zhang merge->rowmap->bs = 1; 12062205254eSKarl Rupp 1207f96d37fcSHong Zhang ierr = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr); 1208f96d37fcSHong Zhang owners = merge->rowmap->range; 1209f96d37fcSHong Zhang 1210f96d37fcSHong Zhang /* determine the number of messages to send, their lengths */ 12111795a4d1SJed Brown ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr); 1212785e854fSJed Brown ierr = PetscMalloc1(size,&merge->len_s);CHKERRQ(ierr); 12132205254eSKarl Rupp 1214f96d37fcSHong Zhang len_s = merge->len_s; 1215f96d37fcSHong Zhang merge->nsend = 0; 1216f96d37fcSHong Zhang 1217854ce69bSBarry Smith ierr = PetscMalloc1(size+2,&owners_co);CHKERRQ(ierr); 1218f96d37fcSHong Zhang ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr); 1219f96d37fcSHong Zhang 1220f96d37fcSHong Zhang proc = 0; 1221f96d37fcSHong Zhang for (i=0; i<pon; i++) { 1222f96d37fcSHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 1223f96d37fcSHong Zhang len_si[proc]++; /* num of rows in Co to be sent to [proc] */ 1224f96d37fcSHong Zhang len_s[proc] += coi[i+1] - coi[i]; 1225f96d37fcSHong Zhang } 1226f96d37fcSHong Zhang 1227f96d37fcSHong Zhang len = 0; /* max length of buf_si[] */ 1228f96d37fcSHong Zhang owners_co[0] = 0; 1229f96d37fcSHong Zhang for (proc=0; proc<size; proc++) { 1230f96d37fcSHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1231f96d37fcSHong Zhang if (len_si[proc]) { 1232f96d37fcSHong Zhang merge->nsend++; 1233f96d37fcSHong Zhang len_si[proc] = 2*(len_si[proc] + 1); 1234f96d37fcSHong Zhang len += len_si[proc]; 1235f96d37fcSHong Zhang } 1236f96d37fcSHong Zhang } 1237f96d37fcSHong Zhang 1238f96d37fcSHong Zhang /* determine the number and length of messages to receive for coi and coj */ 12390298fd71SBarry Smith ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr); 1240f96d37fcSHong Zhang ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr); 1241f96d37fcSHong Zhang 1242f96d37fcSHong Zhang /* post the Irecv and Isend of coj */ 1243f96d37fcSHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1244f96d37fcSHong Zhang ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1245854ce69bSBarry Smith ierr = PetscMalloc1(merge->nsend+1,&swaits);CHKERRQ(ierr); 1246f96d37fcSHong Zhang for (proc=0, k=0; proc<size; proc++) { 1247f96d37fcSHong Zhang if (!len_s[proc]) continue; 1248f96d37fcSHong Zhang i = owners_co[proc]; 1249f96d37fcSHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 1250f96d37fcSHong Zhang k++; 1251f96d37fcSHong Zhang } 1252f96d37fcSHong Zhang 1253f96d37fcSHong Zhang /* receives and sends of coj are complete */ 1254785e854fSJed Brown ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr); 1255f96d37fcSHong Zhang for (i=0; i<merge->nrecv; i++) { 1256c280ed6aSJed Brown PetscMPIInt icompleted; 1257c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1258f96d37fcSHong Zhang } 1259f96d37fcSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1260f96d37fcSHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 1261f96d37fcSHong Zhang 1262f96d37fcSHong Zhang /* send and recv coi */ 1263f96d37fcSHong Zhang /*-------------------*/ 1264f96d37fcSHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1265f96d37fcSHong Zhang ierr = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1266854ce69bSBarry Smith ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 1267f96d37fcSHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1268f96d37fcSHong Zhang for (proc=0,k=0; proc<size; proc++) { 1269f96d37fcSHong Zhang if (!len_s[proc]) continue; 1270f96d37fcSHong Zhang /* form outgoing message for i-structure: 1271f96d37fcSHong Zhang buf_si[0]: nrows to be sent 1272f96d37fcSHong Zhang [1:nrows]: row index (global) 1273f96d37fcSHong Zhang [nrows+1:2*nrows+1]: i-structure index 1274f96d37fcSHong Zhang */ 1275f96d37fcSHong Zhang /*-------------------------------------------*/ 1276f96d37fcSHong Zhang nrows = len_si[proc]/2 - 1; 1277f96d37fcSHong Zhang buf_si_i = buf_si + nrows+1; 1278f96d37fcSHong Zhang buf_si[0] = nrows; 1279f96d37fcSHong Zhang buf_si_i[0] = 0; 1280f96d37fcSHong Zhang nrows = 0; 1281f96d37fcSHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1282f96d37fcSHong Zhang nzi = coi[i+1] - coi[i]; 1283f96d37fcSHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1284f96d37fcSHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1285f96d37fcSHong Zhang nrows++; 1286f96d37fcSHong Zhang } 1287f96d37fcSHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 1288f96d37fcSHong Zhang k++; 1289f96d37fcSHong Zhang buf_si += len_si[proc]; 1290f96d37fcSHong Zhang } 1291f96d37fcSHong Zhang i = merge->nrecv; 1292f96d37fcSHong Zhang while (i--) { 1293c280ed6aSJed Brown PetscMPIInt icompleted; 1294c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1295f96d37fcSHong Zhang } 1296f96d37fcSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1297f96d37fcSHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 1298f96d37fcSHong Zhang ierr = PetscFree(len_si);CHKERRQ(ierr); 1299f96d37fcSHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1300f96d37fcSHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1301f96d37fcSHong Zhang ierr = PetscFree(sstatus);CHKERRQ(ierr); 1302f96d37fcSHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1303f96d37fcSHong Zhang 1304f96d37fcSHong Zhang /* compute the local portion of C (mpi mat) */ 1305f96d37fcSHong Zhang /*------------------------------------------*/ 1306f96d37fcSHong Zhang /* allocate bi array and free space for accumulating nonzero column info */ 1307854ce69bSBarry Smith ierr = PetscMalloc1(pn+1,&bi);CHKERRQ(ierr); 1308f96d37fcSHong Zhang bi[0] = 0; 1309f96d37fcSHong Zhang 1310c36aecf5SHong Zhang /* set initial free space to be fill*(nnz(P) + nnz(A)) */ 1311f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(pdti[pn],PetscIntSumTruncate(poti[pon],ai[am]))); 1312a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1313f96d37fcSHong Zhang current_space = free_space; 1314f96d37fcSHong Zhang 1315dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1316f96d37fcSHong Zhang for (k=0; k<merge->nrecv; k++) { 1317f96d37fcSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1318f96d37fcSHong Zhang nrows = *buf_ri_k[k]; 1319f96d37fcSHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 1320f96d37fcSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1321f96d37fcSHong Zhang } 1322f96d37fcSHong Zhang 13231c7d5954SHong Zhang ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr); 1324f96d37fcSHong Zhang rmax = 0; 1325f96d37fcSHong Zhang for (i=0; i<pn; i++) { 1326f96d37fcSHong Zhang /* add pdt[i,:]*AP into lnk */ 1327f96d37fcSHong Zhang pnz = pdti[i+1] - pdti[i]; 1328f96d37fcSHong Zhang ptJ = pdtj + pdti[i]; 1329f96d37fcSHong Zhang for (j=0; j<pnz; j++) { 1330f96d37fcSHong Zhang row = ptJ[j]; /* row of AP == col of Pt */ 1331d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1332d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1333f96d37fcSHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1334d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted(anz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1335f96d37fcSHong Zhang } 13364e938277SHong Zhang 1337f96d37fcSHong Zhang /* add received col data into lnk */ 1338f96d37fcSHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1339f96d37fcSHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1340f96d37fcSHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1341f96d37fcSHong Zhang Jptr = buf_rj[k] + *nextci[k]; 13424e938277SHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1343f96d37fcSHong Zhang nextrow[k]++; nextci[k]++; 1344f96d37fcSHong Zhang } 1345f96d37fcSHong Zhang } 13464e938277SHong Zhang nnz = lnk[0]; 1347f96d37fcSHong Zhang 1348f96d37fcSHong Zhang /* if free space is not available, make more free space */ 1349f96d37fcSHong Zhang if (current_space->local_remaining<nnz) { 1350f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 1351f96d37fcSHong Zhang nspacedouble++; 1352f96d37fcSHong Zhang } 1353f96d37fcSHong Zhang /* copy data into free space, then initialize lnk */ 13544e938277SHong Zhang ierr = PetscLLCondensedClean(aN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1355f96d37fcSHong Zhang ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr); 13562205254eSKarl Rupp 1357f96d37fcSHong Zhang current_space->array += nnz; 1358f96d37fcSHong Zhang current_space->local_used += nnz; 1359f96d37fcSHong Zhang current_space->local_remaining -= nnz; 13602205254eSKarl Rupp 1361f96d37fcSHong Zhang bi[i+1] = bi[i] + nnz; 1362f96d37fcSHong Zhang if (nnz > rmax) rmax = nnz; 1363f96d37fcSHong Zhang } 1364f96d37fcSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1365f96d37fcSHong Zhang 1366854ce69bSBarry Smith ierr = PetscMalloc1(bi[pn]+1,&bj);CHKERRQ(ierr); 1367f96d37fcSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr); 13682205254eSKarl Rupp 1369118727c9SMark F. Adams afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1); 1370f96d37fcSHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1371d6ab1dc0SHong Zhang ierr = PetscLLCondensedDestroy(lnk,lnkbt);CHKERRQ(ierr); 13724e938277SHong Zhang ierr = MatDestroy(&POt);CHKERRQ(ierr); 13734e938277SHong Zhang ierr = MatDestroy(&PDt);CHKERRQ(ierr); 1374f96d37fcSHong Zhang 13751c7d5954SHong Zhang /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part */ 13761c7d5954SHong Zhang /*----------------------------------------------------------------------------------*/ 13771795a4d1SJed Brown ierr = PetscCalloc1(rmax+1,&vals);CHKERRQ(ierr); 1378f96d37fcSHong Zhang 1379f96d37fcSHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 1380f96d37fcSHong Zhang ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 138133d57670SJed Brown ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(A->cmap->bs));CHKERRQ(ierr); 1382f96d37fcSHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 1383f96d37fcSHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 1384f96d37fcSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1385f96d37fcSHong Zhang ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr); 1386f96d37fcSHong Zhang for (i=0; i<pn; i++) { 1387f96d37fcSHong Zhang row = i + rstart; 1388f96d37fcSHong Zhang nnz = bi[i+1] - bi[i]; 1389f96d37fcSHong Zhang Jptr = bj + bi[i]; 1390f96d37fcSHong Zhang ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,vals,INSERT_VALUES);CHKERRQ(ierr); 1391f96d37fcSHong Zhang } 1392f96d37fcSHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1393f96d37fcSHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1394f96d37fcSHong Zhang ierr = PetscFree(vals);CHKERRQ(ierr); 1395f96d37fcSHong Zhang 1396f96d37fcSHong Zhang merge->bi = bi; 1397f96d37fcSHong Zhang merge->bj = bj; 1398f96d37fcSHong Zhang merge->coi = coi; 1399f96d37fcSHong Zhang merge->coj = coj; 1400f96d37fcSHong Zhang merge->buf_ri = buf_ri; 1401f96d37fcSHong Zhang merge->buf_rj = buf_rj; 1402f96d37fcSHong Zhang merge->owners_co = owners_co; 1403f96d37fcSHong Zhang 1404f96d37fcSHong Zhang /* attach the supporting struct to Cmpi for reuse */ 1405f96d37fcSHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 1406f96d37fcSHong Zhang c->ptap = ptap; 14070298fd71SBarry Smith ptap->api = NULL; 14080298fd71SBarry Smith ptap->apj = NULL; 1409f96d37fcSHong Zhang ptap->merge = merge; 1410375ed354SHong Zhang ptap->destroy = Cmpi->ops->destroy; 1411375ed354SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 1412375ed354SHong Zhang 1413912837bbSHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable_old; 1414375ed354SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 1415375ed354SHong Zhang Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatPtAP; 1416d6ab1dc0SHong Zhang 1417d6ab1dc0SHong Zhang *C = Cmpi; 1418d6ab1dc0SHong Zhang #if defined(PETSC_USE_INFO) 1419d6ab1dc0SHong Zhang if (bi[pn] != 0) { 142057622a8eSBarry Smith ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 142157622a8eSBarry Smith ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr); 1422d6ab1dc0SHong Zhang } else { 1423d6ab1dc0SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 1424d6ab1dc0SHong Zhang } 1425d6ab1dc0SHong Zhang #endif 1426d6ab1dc0SHong Zhang PetscFunctionReturn(0); 1427d6ab1dc0SHong Zhang } 1428d6ab1dc0SHong Zhang 1429912837bbSHong Zhang //================================ 1430912837bbSHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,PetscReal fill,Mat *C) 1431912837bbSHong Zhang { 1432912837bbSHong Zhang PetscErrorCode ierr; 1433912837bbSHong Zhang Mat_PtAPMPI *ptap; 1434*7f3e1f30SHong Zhang Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data,*c; 1435912837bbSHong Zhang MPI_Comm comm; 1436912837bbSHong Zhang PetscMPIInt size,rank; 1437912837bbSHong Zhang Mat Cmpi; 1438912837bbSHong Zhang PetscFreeSpaceList free_space=NULL,current_space=NULL; 1439*7f3e1f30SHong Zhang PetscInt pN=P->cmap->N,pn=P->cmap->n; 1440*7f3e1f30SHong Zhang PetscInt *lnk,i,k,nsend; 1441912837bbSHong Zhang PetscBT lnkbt; 1442912837bbSHong Zhang PetscMPIInt tagi,tagj,*len_si,*len_s,*len_ri,icompleted=0,nrecv; 1443912837bbSHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 1444*7f3e1f30SHong Zhang PetscInt len,proc,*dnz,*onz,*owners,nzi; 1445912837bbSHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1446912837bbSHong Zhang MPI_Request *swaits,*rwaits; 1447912837bbSHong Zhang MPI_Status *sstatus,rstatus; 1448912837bbSHong Zhang PetscLayout rowmap; 1449912837bbSHong Zhang PetscInt *owners_co,*coi,*coj; /* i and j array of (p->B)^T*A*P - used in the communication */ 1450912837bbSHong Zhang PetscMPIInt *len_r,*id_r; /* array of length of comm->size, store send/recv matrix values */ 1451*7f3e1f30SHong Zhang PetscInt *Jptr,*prmap=p->garray,con,j,Crmax; 1452*7f3e1f30SHong Zhang Mat_SeqAIJ *p_loc,*p_oth=NULL,*c_loc,*c_oth; 1453912837bbSHong Zhang PetscTable ta; 1454912837bbSHong Zhang #if defined(PETSC_HAVE_HYPRE) 1455912837bbSHong Zhang const char *algTypes[3] = {"scalable","nonscalable","hypre"}; 1456912837bbSHong Zhang PetscInt nalg = 3; 1457912837bbSHong Zhang #else 1458912837bbSHong Zhang const char *algTypes[2] = {"scalable","nonscalable"}; 1459912837bbSHong Zhang PetscInt nalg = 2; 1460912837bbSHong Zhang #endif 1461912837bbSHong Zhang PetscInt alg = 1; /* set default algorithm */ 1462912837bbSHong Zhang #if defined(PETSC_USE_INFO) 1463912837bbSHong Zhang PetscReal apfill; 1464912837bbSHong Zhang #endif 1465912837bbSHong Zhang PetscBool flg; 1466912837bbSHong Zhang 1467912837bbSHong Zhang PetscFunctionBegin; 1468912837bbSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1469912837bbSHong Zhang printf("MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable..\n"); 1470912837bbSHong Zhang #if 0 1471912837bbSHong Zhang /* pick an algorithm */ 1472912837bbSHong Zhang ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr); 1473912837bbSHong Zhang PetscOptionsObject->alreadyprinted = PETSC_FALSE; /* a hack to ensure the option shows in '-help' */ 1474912837bbSHong Zhang ierr = PetscOptionsEList("-matptap_via","Algorithmic approach","MatPtAP",algTypes,nalg,algTypes[1],&alg,&flg);CHKERRQ(ierr); 1475912837bbSHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 1476912837bbSHong Zhang 1477912837bbSHong Zhang if (!flg && pN > 100000) { /* may switch to scalable algorithm as default */ 1478912837bbSHong Zhang MatInfo Ainfo,Pinfo; 1479912837bbSHong Zhang PetscInt nz_local; 1480912837bbSHong Zhang PetscBool alg_scalable_loc=PETSC_FALSE,alg_scalable; 1481912837bbSHong Zhang 1482912837bbSHong Zhang ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr); 1483912837bbSHong Zhang ierr = MatGetInfo(P,MAT_LOCAL,&Pinfo);CHKERRQ(ierr); 1484912837bbSHong Zhang nz_local = (PetscInt)(Ainfo.nz_allocated + Pinfo.nz_allocated); 1485912837bbSHong Zhang 1486912837bbSHong Zhang if (pN > fill*nz_local) alg_scalable_loc = PETSC_TRUE; 1487912837bbSHong Zhang ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr); 1488912837bbSHong Zhang 1489912837bbSHong Zhang if (alg_scalable) { 1490912837bbSHong Zhang alg = 0; /* scalable algorithm would 50% slower than nonscalable algorithm */ 1491912837bbSHong Zhang } 1492912837bbSHong Zhang } 1493912837bbSHong Zhang 1494912837bbSHong Zhang if (alg == 0) { 1495912837bbSHong Zhang ierr = MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable(A,P,fill,C);CHKERRQ(ierr); 1496912837bbSHong Zhang (*C)->ops->ptapnumeric = MatPtAPNumeric_MPIAIJ_MPIAIJ_scalable; 1497912837bbSHong Zhang PetscFunctionReturn(0); 1498912837bbSHong Zhang 1499912837bbSHong Zhang #if defined(PETSC_HAVE_HYPRE) 1500912837bbSHong Zhang } else if (alg == 2) { 1501912837bbSHong Zhang /* Use boomerAMGBuildCoarseOperator */ 1502912837bbSHong Zhang ierr = MatPtAPSymbolic_AIJ_AIJ_wHYPRE(A,P,fill,C);CHKERRQ(ierr); 1503912837bbSHong Zhang PetscFunctionReturn(0); 1504912837bbSHong Zhang #endif 1505912837bbSHong Zhang } 1506912837bbSHong Zhang 1507912837bbSHong Zhang #endif 1508912837bbSHong Zhang 1509912837bbSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1510912837bbSHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1511912837bbSHong Zhang 1512912837bbSHong Zhang /* create symbolic parallel matrix Cmpi */ 1513912837bbSHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 1514912837bbSHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 1515912837bbSHong Zhang 1516912837bbSHong Zhang /* Do dense axpy in MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ() */ 1517912837bbSHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 1518912837bbSHong Zhang 1519912837bbSHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 1520912837bbSHong Zhang ierr = PetscNew(&ptap);CHKERRQ(ierr); 1521912837bbSHong Zhang ptap->reuse = MAT_INITIAL_MATRIX; 1522912837bbSHong Zhang ptap->algType = alg; 1523912837bbSHong Zhang 1524912837bbSHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 1525912837bbSHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 1526912837bbSHong Zhang /* get P_loc by taking all local rows of P */ 1527912837bbSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 1528912837bbSHong Zhang 1529912837bbSHong Zhang /* (0) compute Rd = Pd^T, Ro = Po^T */ 1530912837bbSHong Zhang /* --------------------------------- */ 1531912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->A,MAT_INITIAL_MATRIX,&ptap->Rd);CHKERRQ(ierr); 1532912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->B,MAT_INITIAL_MATRIX,&ptap->Ro);CHKERRQ(ierr); 1533912837bbSHong Zhang 1534*7f3e1f30SHong Zhang /* (1) compute symbolic A_loc (A_loc = P_loc in ex209!!!) */ 1535*7f3e1f30SHong Zhang /* -------------------------------------------------------*/ 1536912837bbSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 1537912837bbSHong Zhang if (ptap->P_oth) p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 1538912837bbSHong Zhang 1539*7f3e1f30SHong Zhang /* create and initialize a linked list ??? */ 1540912837bbSHong Zhang ierr = PetscTableCreate(pn,pN,&ta);CHKERRQ(ierr); /* for compute AP_loc and Cmpi */ 1541912837bbSHong Zhang MatRowMergeMax_SeqAIJ(p_loc,ptap->P_loc->rmap->N,ta); 1542912837bbSHong Zhang MatRowMergeMax_SeqAIJ(p_oth,ptap->P_oth->rmap->N,ta); 1543912837bbSHong Zhang ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr); /* Crmax = nnz(sum of Prows) */ 1544912837bbSHong Zhang /* printf("[%d] est %d, Crmax %d; pN %d\n",rank,5*(p_loc->rmax+p_oth->rmax + (PetscInt)(1.e-2*pN)),Crmax,pN); */ 1545912837bbSHong Zhang 1546*7f3e1f30SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->AP_loc);CHKERRQ(ierr); //ptap->AP_loc = A_loc 1547912837bbSHong Zhang 1548*7f3e1f30SHong Zhang /* (2-1) compute symbolic Co = Ro*A_loc */ 1549912837bbSHong Zhang /* ------------------------------------ */ 1550912837bbSHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Ro,ptap->AP_loc,fill,&ptap->C_oth);CHKERRQ(ierr); 1551912837bbSHong Zhang 1552912837bbSHong Zhang /* (3) send coj of C_oth to other processors */ 1553912837bbSHong Zhang /* ------------------------------------------ */ 1554912837bbSHong Zhang /* determine row ownership */ 1555912837bbSHong Zhang ierr = PetscLayoutCreate(comm,&rowmap);CHKERRQ(ierr); 1556912837bbSHong Zhang rowmap->n = pn; 1557912837bbSHong Zhang rowmap->bs = 1; 1558912837bbSHong Zhang ierr = PetscLayoutSetUp(rowmap);CHKERRQ(ierr); 1559912837bbSHong Zhang owners = rowmap->range; 1560912837bbSHong Zhang 1561912837bbSHong Zhang /* determine the number of messages to send, their lengths */ 1562912837bbSHong Zhang ierr = PetscMalloc4(size,&len_s,size,&len_si,size,&sstatus,size+2,&owners_co);CHKERRQ(ierr); 1563912837bbSHong Zhang ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr); 1564912837bbSHong Zhang ierr = PetscMemzero(len_si,size*sizeof(PetscMPIInt));CHKERRQ(ierr); 1565912837bbSHong Zhang 1566912837bbSHong Zhang c_oth = (Mat_SeqAIJ*)ptap->C_oth->data; 1567912837bbSHong Zhang coi = c_oth->i; coj = c_oth->j; 1568912837bbSHong Zhang con = ptap->C_oth->rmap->n; 1569912837bbSHong Zhang proc = 0; 1570912837bbSHong Zhang for (i=0; i<con; i++) { 1571912837bbSHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 1572*7f3e1f30SHong Zhang len_si[proc]++; /* num of rows in Co(=Pt*A) to be sent to [proc] */ 1573912837bbSHong Zhang len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */ 1574912837bbSHong Zhang } 1575912837bbSHong Zhang 1576912837bbSHong Zhang len = 0; /* max length of buf_si[], see (4) */ 1577912837bbSHong Zhang owners_co[0] = 0; 1578912837bbSHong Zhang nsend = 0; 1579912837bbSHong Zhang for (proc=0; proc<size; proc++) { 1580912837bbSHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1581912837bbSHong Zhang if (len_s[proc]) { 1582912837bbSHong Zhang nsend++; 1583912837bbSHong Zhang len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */ 1584912837bbSHong Zhang len += len_si[proc]; 1585912837bbSHong Zhang } 1586912837bbSHong Zhang } 1587912837bbSHong Zhang 1588912837bbSHong Zhang /* determine the number and length of messages to receive for coi and coj */ 1589912837bbSHong Zhang ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&nrecv);CHKERRQ(ierr); 1590912837bbSHong Zhang ierr = PetscGatherMessageLengths2(comm,nsend,nrecv,len_s,len_si,&id_r,&len_r,&len_ri);CHKERRQ(ierr); 1591912837bbSHong Zhang 1592912837bbSHong Zhang /* post the Irecv and Isend of coj */ 1593912837bbSHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1594912837bbSHong Zhang ierr = PetscPostIrecvInt(comm,tagj,nrecv,id_r,len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1595912837bbSHong Zhang ierr = PetscMalloc1(nsend+1,&swaits);CHKERRQ(ierr); 1596912837bbSHong Zhang for (proc=0, k=0; proc<size; proc++) { 1597912837bbSHong Zhang if (!len_s[proc]) continue; 1598912837bbSHong Zhang i = owners_co[proc]; 1599912837bbSHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 1600912837bbSHong Zhang k++; 1601912837bbSHong Zhang } 1602912837bbSHong Zhang 1603*7f3e1f30SHong Zhang /* (2-2) compute symbolic C_loc = Rd*A_loc */ 1604912837bbSHong Zhang /* ---------------------------------------- */ 1605912837bbSHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Rd,ptap->AP_loc,fill,&ptap->C_loc);CHKERRQ(ierr); 1606912837bbSHong Zhang c_loc = (Mat_SeqAIJ*)ptap->C_loc->data; 1607912837bbSHong Zhang 1608912837bbSHong Zhang /* receives coj are complete */ 1609912837bbSHong Zhang for (i=0; i<nrecv; i++) { 1610912837bbSHong Zhang ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1611912837bbSHong Zhang } 1612912837bbSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1613912837bbSHong Zhang if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);} 1614912837bbSHong Zhang 1615912837bbSHong Zhang /* add received column indices into ta to update Crmax */ 1616912837bbSHong Zhang for (k=0; k<nrecv; k++) {/* k-th received message */ 1617912837bbSHong Zhang Jptr = buf_rj[k]; 1618912837bbSHong Zhang for (j=0; j<len_r[k]; j++) { 1619912837bbSHong Zhang ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr); 1620912837bbSHong Zhang } 1621912837bbSHong Zhang } 1622912837bbSHong Zhang ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr); 1623912837bbSHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 1624912837bbSHong Zhang 1625912837bbSHong Zhang /* (4) send and recv coi */ 1626912837bbSHong Zhang /*-----------------------*/ 1627912837bbSHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1628912837bbSHong Zhang ierr = PetscPostIrecvInt(comm,tagi,nrecv,id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1629912837bbSHong Zhang ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 1630912837bbSHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1631912837bbSHong Zhang for (proc=0,k=0; proc<size; proc++) { 1632912837bbSHong Zhang if (!len_s[proc]) continue; 1633912837bbSHong Zhang /* form outgoing message for i-structure: 1634912837bbSHong Zhang buf_si[0]: nrows to be sent 1635912837bbSHong Zhang [1:nrows]: row index (global) 1636912837bbSHong Zhang [nrows+1:2*nrows+1]: i-structure index 1637912837bbSHong Zhang */ 1638912837bbSHong Zhang /*-------------------------------------------*/ 1639912837bbSHong Zhang nrows = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */ 1640912837bbSHong Zhang buf_si_i = buf_si + nrows+1; 1641912837bbSHong Zhang buf_si[0] = nrows; 1642912837bbSHong Zhang buf_si_i[0] = 0; 1643912837bbSHong Zhang nrows = 0; 1644912837bbSHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1645912837bbSHong Zhang nzi = coi[i+1] - coi[i]; 1646912837bbSHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1647912837bbSHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1648912837bbSHong Zhang nrows++; 1649912837bbSHong Zhang } 1650912837bbSHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 1651912837bbSHong Zhang k++; 1652912837bbSHong Zhang buf_si += len_si[proc]; 1653912837bbSHong Zhang } 1654912837bbSHong Zhang for (i=0; i<nrecv; i++) { 1655912837bbSHong Zhang ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1656912837bbSHong Zhang } 1657912837bbSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1658912837bbSHong Zhang if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);} 1659912837bbSHong Zhang 1660912837bbSHong Zhang ierr = PetscFree4(len_s,len_si,sstatus,owners_co);CHKERRQ(ierr); 1661912837bbSHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1662912837bbSHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1663912837bbSHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1664912837bbSHong Zhang 1665912837bbSHong Zhang /* (5) compute the local portion of Cmpi */ 1666912837bbSHong Zhang /* ------------------------------------------ */ 1667912837bbSHong Zhang /* set initial free space to be Crmax, sufficient for holding nozeros in each row of Cmpi */ 1668912837bbSHong Zhang ierr = PetscFreeSpaceGet(Crmax,&free_space);CHKERRQ(ierr); 1669912837bbSHong Zhang current_space = free_space; 1670912837bbSHong Zhang 1671912837bbSHong Zhang ierr = PetscMalloc3(nrecv,&buf_ri_k,nrecv,&nextrow,nrecv,&nextci);CHKERRQ(ierr); 1672912837bbSHong Zhang for (k=0; k<nrecv; k++) { 1673912837bbSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1674912837bbSHong Zhang nrows = *buf_ri_k[k]; 1675912837bbSHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 1676912837bbSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1677912837bbSHong Zhang } 1678912837bbSHong Zhang 1679912837bbSHong Zhang ierr = MatPreallocateInitialize(comm,pn,pn,dnz,onz);CHKERRQ(ierr); 1680912837bbSHong Zhang ierr = PetscLLCondensedCreate(Crmax,pN,&lnk,&lnkbt);CHKERRQ(ierr); 1681912837bbSHong Zhang for (i=0; i<pn; i++) { 1682912837bbSHong Zhang /* add C_loc into Cmpi */ 1683912837bbSHong Zhang nzi = c_loc->i[i+1] - c_loc->i[i]; 1684912837bbSHong Zhang Jptr = c_loc->j + c_loc->i[i]; 1685912837bbSHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1686912837bbSHong Zhang 1687912837bbSHong Zhang /* add received col data into lnk */ 1688912837bbSHong Zhang for (k=0; k<nrecv; k++) { /* k-th received message */ 1689912837bbSHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1690912837bbSHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1691912837bbSHong Zhang Jptr = buf_rj[k] + *nextci[k]; 1692912837bbSHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1693912837bbSHong Zhang nextrow[k]++; nextci[k]++; 1694912837bbSHong Zhang } 1695912837bbSHong Zhang } 1696912837bbSHong Zhang nzi = lnk[0]; 1697912837bbSHong Zhang 1698912837bbSHong Zhang /* copy data into free space, then initialize lnk */ 1699912837bbSHong Zhang ierr = PetscLLCondensedClean(pN,nzi,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1700912837bbSHong Zhang ierr = MatPreallocateSet(i+owners[rank],nzi,current_space->array,dnz,onz);CHKERRQ(ierr); 1701912837bbSHong Zhang } 1702912837bbSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1703912837bbSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 1704912837bbSHong Zhang ierr = PetscFreeSpaceDestroy(free_space);CHKERRQ(ierr); 1705912837bbSHong Zhang 1706912837bbSHong Zhang /* local sizes and preallocation */ 1707912837bbSHong Zhang ierr = MatSetSizes(Cmpi,pn,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 1708912837bbSHong Zhang ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(P->cmap->bs));CHKERRQ(ierr); 1709912837bbSHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 1710912837bbSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1711912837bbSHong Zhang 1712912837bbSHong Zhang /* members in merge */ 1713912837bbSHong Zhang ierr = PetscFree(id_r);CHKERRQ(ierr); 1714912837bbSHong Zhang ierr = PetscFree(len_r);CHKERRQ(ierr); 1715912837bbSHong Zhang ierr = PetscFree(buf_ri[0]);CHKERRQ(ierr); 1716912837bbSHong Zhang ierr = PetscFree(buf_ri);CHKERRQ(ierr); 1717912837bbSHong Zhang ierr = PetscFree(buf_rj[0]);CHKERRQ(ierr); 1718912837bbSHong Zhang ierr = PetscFree(buf_rj);CHKERRQ(ierr); 1719912837bbSHong Zhang ierr = PetscLayoutDestroy(&rowmap);CHKERRQ(ierr); 1720912837bbSHong Zhang 1721912837bbSHong Zhang /* attach the supporting struct to Cmpi for reuse */ 1722912837bbSHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 1723912837bbSHong Zhang c->ptap = ptap; 1724912837bbSHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 1725912837bbSHong Zhang ptap->destroy = Cmpi->ops->destroy; 1726912837bbSHong Zhang ptap->view = Cmpi->ops->view; 1727912837bbSHong Zhang 1728912837bbSHong Zhang if (alg == 1) { 1729912837bbSHong Zhang ierr = PetscCalloc1(pN,&ptap->apa);CHKERRQ(ierr); 1730912837bbSHong Zhang } 1731912837bbSHong Zhang 1732912837bbSHong Zhang /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */ 1733912837bbSHong Zhang Cmpi->assembled = PETSC_FALSE; 1734912837bbSHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 1735912837bbSHong Zhang //Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatPtAP; 1736912837bbSHong Zhang //Cmpi->ops->view = MatView_MPIAIJ_PtAP; 1737912837bbSHong Zhang *C = Cmpi; 1738912837bbSHong Zhang PetscFunctionReturn(0); 1739912837bbSHong Zhang } 1740912837bbSHong Zhang 1741912837bbSHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,Mat C) 1742912837bbSHong Zhang { 1743912837bbSHong Zhang PetscErrorCode ierr; 1744912837bbSHong Zhang Mat_MPIAIJ *a=(Mat_MPIAIJ*)A->data,*p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 1745912837bbSHong Zhang Mat_SeqAIJ *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 1746912837bbSHong Zhang Mat_SeqAIJ *ap,*p_loc,*p_oth=NULL,*c_seq; 1747912837bbSHong Zhang Mat_PtAPMPI *ptap = c->ptap; 1748912837bbSHong Zhang Mat AP_loc,C_loc,C_oth; 1749912837bbSHong Zhang PetscInt i,rstart,rend,cm,ncols,row; 1750912837bbSHong Zhang PetscInt *api,*apj,am = A->rmap->n,j,col,apnz; 1751912837bbSHong Zhang PetscScalar *apa; 1752912837bbSHong Zhang const PetscInt *cols; 1753912837bbSHong Zhang const PetscScalar *vals; 1754912837bbSHong Zhang 1755912837bbSHong Zhang PetscFunctionBegin; 1756912837bbSHong Zhang ierr = MatZeroEntries(C);CHKERRQ(ierr); 1757912837bbSHong Zhang printf("MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable...\n"); 1758912837bbSHong Zhang 1759912837bbSHong Zhang /* 1) get R = Pd^T,Ro = Po^T */ 1760912837bbSHong Zhang if (ptap->reuse == MAT_REUSE_MATRIX) { 1761912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->A,MAT_REUSE_MATRIX,&ptap->Rd);CHKERRQ(ierr); 1762912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->B,MAT_REUSE_MATRIX,&ptap->Ro);CHKERRQ(ierr); 1763912837bbSHong Zhang } 1764912837bbSHong Zhang 1765912837bbSHong Zhang /* 2) get AP_loc */ 1766912837bbSHong Zhang AP_loc = ptap->AP_loc; 1767912837bbSHong Zhang ap = (Mat_SeqAIJ*)AP_loc->data; 1768912837bbSHong Zhang 1769912837bbSHong Zhang /* 2-1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 1770912837bbSHong Zhang /*-----------------------------------------------------*/ 1771912837bbSHong Zhang if (ptap->reuse == MAT_REUSE_MATRIX) { 1772912837bbSHong Zhang /* P_oth and P_loc are obtained in MatPtASymbolic() when reuse == MAT_INITIAL_MATRIX */ 1773912837bbSHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 1774912837bbSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 1775912837bbSHong Zhang } 1776912837bbSHong Zhang 1777912837bbSHong Zhang /* 2-2) compute numeric A_loc*P - dominating part */ 1778912837bbSHong Zhang /* ---------------------------------------------- */ 1779912837bbSHong Zhang /* get data from symbolic products */ 1780912837bbSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 1781912837bbSHong Zhang if (ptap->P_oth) { 1782912837bbSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 1783912837bbSHong Zhang } 1784912837bbSHong Zhang apa = ptap->apa; 1785912837bbSHong Zhang api = ap->i; 1786912837bbSHong Zhang apj = ap->j; 1787912837bbSHong Zhang 1788912837bbSHong Zhang for (i=0; i<am; i++) { 1789912837bbSHong Zhang /* AP[i,:] = A[i,:]*P = Ad*P_loc Ao*P_oth */ 1790912837bbSHong Zhang AProw_nonscalable(i,ad,ao,p_loc,p_oth,apa); 1791912837bbSHong Zhang apnz = api[i+1] - api[i]; 1792912837bbSHong Zhang for (j=0; j<apnz; j++) { 1793912837bbSHong Zhang col = apj[j+api[i]]; 1794912837bbSHong Zhang ap->a[j+ap->i[i]] = apa[col]; 1795912837bbSHong Zhang apa[col] = 0.0; 1796912837bbSHong Zhang } 1797912837bbSHong Zhang ierr = PetscLogFlops(2.0*apnz);CHKERRQ(ierr); 1798912837bbSHong Zhang } 1799912837bbSHong Zhang 1800912837bbSHong Zhang /* 3) C_loc = Rd*AP_loc, C_oth = Ro*AP_loc */ 1801912837bbSHong Zhang ierr = ((ptap->C_loc)->ops->matmultnumeric)(ptap->Rd,AP_loc,ptap->C_loc);CHKERRQ(ierr); 1802912837bbSHong Zhang ierr = ((ptap->C_oth)->ops->matmultnumeric)(ptap->Ro,AP_loc,ptap->C_oth);CHKERRQ(ierr); 1803912837bbSHong Zhang C_loc = ptap->C_loc; 1804912837bbSHong Zhang C_oth = ptap->C_oth; 1805912837bbSHong Zhang 1806912837bbSHong Zhang /* add C_loc and Co to to C */ 1807912837bbSHong Zhang ierr = MatGetOwnershipRange(C,&rstart,&rend);CHKERRQ(ierr); 1808912837bbSHong Zhang 1809912837bbSHong Zhang /* C_loc -> C */ 1810912837bbSHong Zhang cm = C_loc->rmap->N; 1811912837bbSHong Zhang c_seq = (Mat_SeqAIJ*)C_loc->data; 1812912837bbSHong Zhang cols = c_seq->j; 1813912837bbSHong Zhang vals = c_seq->a; 1814912837bbSHong Zhang for (i=0; i<cm; i++) { 1815912837bbSHong Zhang ncols = c_seq->i[i+1] - c_seq->i[i]; 1816912837bbSHong Zhang row = rstart + i; 1817912837bbSHong Zhang ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr); 1818912837bbSHong Zhang cols += ncols; vals += ncols; 1819912837bbSHong Zhang } 1820912837bbSHong Zhang 1821912837bbSHong Zhang /* Co -> C, off-processor part */ 1822912837bbSHong Zhang cm = C_oth->rmap->N; 1823912837bbSHong Zhang c_seq = (Mat_SeqAIJ*)C_oth->data; 1824912837bbSHong Zhang cols = c_seq->j; 1825912837bbSHong Zhang vals = c_seq->a; 1826912837bbSHong Zhang for (i=0; i<cm; i++) { 1827912837bbSHong Zhang ncols = c_seq->i[i+1] - c_seq->i[i]; 1828912837bbSHong Zhang row = p->garray[i]; 1829912837bbSHong Zhang ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr); 1830912837bbSHong Zhang cols += ncols; vals += ncols; 1831912837bbSHong Zhang } 1832912837bbSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1833912837bbSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1834912837bbSHong Zhang 1835912837bbSHong Zhang ptap->reuse = MAT_REUSE_MATRIX; 1836912837bbSHong Zhang PetscFunctionReturn(0); 1837912837bbSHong Zhang } 1838912837bbSHong Zhang //============================= 1839912837bbSHong Zhang 18406da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ(Mat P,Mat A,Mat C) 1841d6ab1dc0SHong Zhang { 1842d6ab1dc0SHong Zhang PetscErrorCode ierr; 1843d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 1844d6ab1dc0SHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 1845d6ab1dc0SHong Zhang Mat_SeqAIJ *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data; 1846d6ab1dc0SHong Zhang Mat_PtAPMPI *ptap; 1847e745005bSHong Zhang PetscInt *adj; 1848e745005bSHong Zhang PetscInt i,j,k,anz,pnz,row,*cj,nexta; 1849e745005bSHong Zhang MatScalar *ada,*ca,valtmp; 1850d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n; 1851ce94432eSBarry Smith MPI_Comm comm; 1852d6ab1dc0SHong Zhang PetscMPIInt size,rank,taga,*len_s; 1853d6ab1dc0SHong Zhang PetscInt *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci; 1854d6ab1dc0SHong Zhang PetscInt **buf_ri,**buf_rj; 1855d6ab1dc0SHong Zhang PetscInt cnz=0,*bj_i,*bi,*bj,bnz,nextcj; /* bi,bj,ba: local array of C(mpi mat) */ 1856d6ab1dc0SHong Zhang MPI_Request *s_waits,*r_waits; 1857d6ab1dc0SHong Zhang MPI_Status *status; 1858d6ab1dc0SHong Zhang MatScalar **abuf_r,*ba_i,*pA,*coa,*ba; 1859d6ab1dc0SHong Zhang PetscInt *ai,*aj,*coi,*coj; 1860a2ea699eSBarry Smith PetscInt *poJ,*pdJ; 1861d6ab1dc0SHong Zhang Mat A_loc; 1862d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc; 1863d6ab1dc0SHong Zhang 1864d6ab1dc0SHong Zhang PetscFunctionBegin; 1865ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 1866d6ab1dc0SHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1867d6ab1dc0SHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1868d6ab1dc0SHong Zhang 1869d6ab1dc0SHong Zhang ptap = c->ptap; 1870d6ab1dc0SHong Zhang merge = ptap->merge; 1871d6ab1dc0SHong Zhang 1872e745005bSHong Zhang /* 2) compute numeric C_seq = P_loc^T*A_loc */ 1873e745005bSHong Zhang /*------------------------------------------*/ 1874d6ab1dc0SHong Zhang /* get data from symbolic products */ 1875d6ab1dc0SHong Zhang coi = merge->coi; coj = merge->coj; 1876854ce69bSBarry Smith ierr = PetscCalloc1(coi[pon]+1,&coa);CHKERRQ(ierr); 1877d6ab1dc0SHong Zhang bi = merge->bi; bj = merge->bj; 1878d6ab1dc0SHong Zhang owners = merge->rowmap->range; 18791795a4d1SJed Brown ierr = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr); 1880d6ab1dc0SHong Zhang 1881d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1882d6ab1dc0SHong Zhang A_loc = ptap->A_loc; 1883d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr); 1884d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1885d6ab1dc0SHong Zhang ai = a_loc->i; 1886d6ab1dc0SHong Zhang aj = a_loc->j; 1887d6ab1dc0SHong Zhang 1888d6ab1dc0SHong Zhang for (i=0; i<am; i++) { 1889d6ab1dc0SHong Zhang anz = ai[i+1] - ai[i]; 1890d6ab1dc0SHong Zhang adj = aj + ai[i]; 1891d6ab1dc0SHong Zhang ada = a_loc->a + ai[i]; 1892d6ab1dc0SHong Zhang 1893d6ab1dc0SHong Zhang /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */ 1894e745005bSHong Zhang /*-------------------------------------------------------------*/ 1895d6ab1dc0SHong Zhang /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */ 1896d6ab1dc0SHong Zhang pnz = po->i[i+1] - po->i[i]; 1897d6ab1dc0SHong Zhang poJ = po->j + po->i[i]; 1898d6ab1dc0SHong Zhang pA = po->a + po->i[i]; 1899d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1900d6ab1dc0SHong Zhang row = poJ[j]; 1901d6ab1dc0SHong Zhang cj = coj + coi[row]; 1902d6ab1dc0SHong Zhang ca = coa + coi[row]; 1903e745005bSHong Zhang /* perform sparse axpy */ 1904e745005bSHong Zhang nexta = 0; 1905d6ab1dc0SHong Zhang valtmp = pA[j]; 1906e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1907e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1908e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1909e745005bSHong Zhang nexta++; 1910d6ab1dc0SHong Zhang } 1911e745005bSHong Zhang } 1912e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1913d6ab1dc0SHong Zhang } 1914d6ab1dc0SHong Zhang 1915d6ab1dc0SHong Zhang /* put the value into Cd (diagonal part) */ 1916d6ab1dc0SHong Zhang pnz = pd->i[i+1] - pd->i[i]; 1917d6ab1dc0SHong Zhang pdJ = pd->j + pd->i[i]; 1918d6ab1dc0SHong Zhang pA = pd->a + pd->i[i]; 1919d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1920d6ab1dc0SHong Zhang row = pdJ[j]; 1921d6ab1dc0SHong Zhang cj = bj + bi[row]; 1922d6ab1dc0SHong Zhang ca = ba + bi[row]; 1923e745005bSHong Zhang /* perform sparse axpy */ 1924e745005bSHong Zhang nexta = 0; 1925d6ab1dc0SHong Zhang valtmp = pA[j]; 1926e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1927e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1928e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1929e745005bSHong Zhang nexta++; 1930d6ab1dc0SHong Zhang } 1931e745005bSHong Zhang } 1932e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1933d6ab1dc0SHong Zhang } 1934d6ab1dc0SHong Zhang } 1935d6ab1dc0SHong Zhang 1936d6ab1dc0SHong Zhang /* 3) send and recv matrix values coa */ 1937d6ab1dc0SHong Zhang /*------------------------------------*/ 1938d6ab1dc0SHong Zhang buf_ri = merge->buf_ri; 1939d6ab1dc0SHong Zhang buf_rj = merge->buf_rj; 1940d6ab1dc0SHong Zhang len_s = merge->len_s; 1941d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr); 1942d6ab1dc0SHong Zhang ierr = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr); 1943d6ab1dc0SHong Zhang 1944dcca6d9dSJed Brown ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr); 1945d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 1946d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1947d6ab1dc0SHong Zhang i = merge->owners_co[proc]; 1948d6ab1dc0SHong Zhang ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr); 1949d6ab1dc0SHong Zhang k++; 1950d6ab1dc0SHong Zhang } 1951d6ab1dc0SHong Zhang if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);} 1952d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);} 1953d6ab1dc0SHong Zhang 1954d6ab1dc0SHong Zhang ierr = PetscFree2(s_waits,status);CHKERRQ(ierr); 1955d6ab1dc0SHong Zhang ierr = PetscFree(r_waits);CHKERRQ(ierr); 1956d6ab1dc0SHong Zhang ierr = PetscFree(coa);CHKERRQ(ierr); 1957d6ab1dc0SHong Zhang 1958d6ab1dc0SHong Zhang /* 4) insert local Cseq and received values into Cmpi */ 1959d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1960dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1961d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 1962e745005bSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1963d6ab1dc0SHong Zhang nrows = *(buf_ri_k[k]); 1964d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k]+1; /* next row number of k-th recved i-structure */ 1965d6ab1dc0SHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1966d6ab1dc0SHong Zhang } 1967d6ab1dc0SHong Zhang 1968d6ab1dc0SHong Zhang for (i=0; i<cm; i++) { 1969d6ab1dc0SHong Zhang row = owners[rank] + i; /* global row index of C_seq */ 1970d6ab1dc0SHong Zhang bj_i = bj + bi[i]; /* col indices of the i-th row of C */ 1971d6ab1dc0SHong Zhang ba_i = ba + bi[i]; 1972d6ab1dc0SHong Zhang bnz = bi[i+1] - bi[i]; 1973d6ab1dc0SHong Zhang /* add received vals into ba */ 1974d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1975d6ab1dc0SHong Zhang /* i-th row */ 1976d6ab1dc0SHong Zhang if (i == *nextrow[k]) { 1977d6ab1dc0SHong Zhang cnz = *(nextci[k]+1) - *nextci[k]; 1978d6ab1dc0SHong Zhang cj = buf_rj[k] + *(nextci[k]); 1979d6ab1dc0SHong Zhang ca = abuf_r[k] + *(nextci[k]); 1980d6ab1dc0SHong Zhang nextcj = 0; 1981d6ab1dc0SHong Zhang for (j=0; nextcj<cnz; j++) { 1982d6ab1dc0SHong Zhang if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */ 1983d6ab1dc0SHong Zhang ba_i[j] += ca[nextcj++]; 1984d6ab1dc0SHong Zhang } 1985d6ab1dc0SHong Zhang } 1986d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 1987d6ab1dc0SHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1988d6ab1dc0SHong Zhang } 1989d6ab1dc0SHong Zhang } 1990d6ab1dc0SHong Zhang ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr); 1991d6ab1dc0SHong Zhang } 1992d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1993d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1994d6ab1dc0SHong Zhang 1995d6ab1dc0SHong Zhang ierr = PetscFree(ba);CHKERRQ(ierr); 1996d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr); 1997d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r);CHKERRQ(ierr); 1998d6ab1dc0SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1999d6ab1dc0SHong Zhang PetscFunctionReturn(0); 2000d6ab1dc0SHong Zhang } 2001d6ab1dc0SHong Zhang 20022bbb1c24SHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ(); 20032bbb1c24SHong Zhang differ from MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable in using LLCondensedCreate_Scalable() */ 20046da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(Mat P,Mat A,PetscReal fill,Mat *C) 2005d6ab1dc0SHong Zhang { 2006d6ab1dc0SHong Zhang PetscErrorCode ierr; 2007d6ab1dc0SHong Zhang Mat Cmpi,A_loc,POt,PDt; 2008d6ab1dc0SHong Zhang Mat_PtAPMPI *ptap; 20090298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 201033ba5e2fSHong Zhang Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data,*a=(Mat_MPIAIJ*)A->data,*c; 2011d6ab1dc0SHong Zhang PetscInt *pdti,*pdtj,*poti,*potj,*ptJ; 2012d6ab1dc0SHong Zhang PetscInt nnz; 2013d6ab1dc0SHong Zhang PetscInt *lnk,*owners_co,*coi,*coj,i,k,pnz,row; 2014d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,pn=P->cmap->n; 2015ce94432eSBarry Smith MPI_Comm comm; 2016d6ab1dc0SHong Zhang PetscMPIInt size,rank,tagi,tagj,*len_si,*len_s,*len_ri; 2017d6ab1dc0SHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 2018d6ab1dc0SHong Zhang PetscInt len,proc,*dnz,*onz,*owners; 2019d6ab1dc0SHong Zhang PetscInt nzi,*bi,*bj; 2020d6ab1dc0SHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 2021d6ab1dc0SHong Zhang MPI_Request *swaits,*rwaits; 2022d6ab1dc0SHong Zhang MPI_Status *sstatus,rstatus; 2023d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 2024d6ab1dc0SHong Zhang PetscInt *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j; 2025d6ab1dc0SHong Zhang PetscReal afill =1.0,afill_tmp; 20264b38b95cSHong Zhang PetscInt rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Armax; 2027d6ab1dc0SHong Zhang PetscScalar *vals; 2028d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc,*pdt,*pot; 20290acc65b4SHong Zhang PetscTable ta; 2030d6ab1dc0SHong Zhang 2031d6ab1dc0SHong Zhang PetscFunctionBegin; 2032ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 2033d6ab1dc0SHong Zhang /* check if matrix local sizes are compatible */ 20346c4ed002SBarry Smith if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, A (%D, %D) != P (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend); 2035d6ab1dc0SHong Zhang 2036d6ab1dc0SHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 2037d6ab1dc0SHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 2038d6ab1dc0SHong Zhang 2039d6ab1dc0SHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 2040b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 2041d6ab1dc0SHong Zhang 2042d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 2043d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr); 20442205254eSKarl Rupp 2045d6ab1dc0SHong Zhang ptap->A_loc = A_loc; 2046d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 2047d6ab1dc0SHong Zhang ai = a_loc->i; 2048d6ab1dc0SHong Zhang aj = a_loc->j; 2049d6ab1dc0SHong Zhang 2050d6ab1dc0SHong Zhang /* determine symbolic Co=(p->B)^T*A - send to others */ 2051d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 2052d6ab1dc0SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr); 2053d6ab1dc0SHong Zhang pdt = (Mat_SeqAIJ*)PDt->data; 2054d6ab1dc0SHong Zhang pdti = pdt->i; pdtj = pdt->j; 2055d6ab1dc0SHong Zhang 2056d6ab1dc0SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr); 2057d6ab1dc0SHong Zhang pot = (Mat_SeqAIJ*)POt->data; 2058d6ab1dc0SHong Zhang poti = pot->i; potj = pot->j; 2059d6ab1dc0SHong Zhang 2060d6ab1dc0SHong Zhang /* then, compute symbolic Co = (p->B)^T*A */ 2061d6ab1dc0SHong Zhang pon = (p->B)->cmap->n; /* total num of rows to be sent to other processors 2062d6ab1dc0SHong Zhang >= (num of nonzero rows of C_seq) - pn */ 2063854ce69bSBarry Smith ierr = PetscMalloc1(pon+1,&coi);CHKERRQ(ierr); 2064d6ab1dc0SHong Zhang coi[0] = 0; 2065d6ab1dc0SHong Zhang 2066d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */ 2067f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(poti[pon],ai[am])); 2068a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 2069d6ab1dc0SHong Zhang current_space = free_space; 207019f0e57aSHong Zhang 2071d6ab1dc0SHong Zhang /* create and initialize a linked list */ 207233ba5e2fSHong Zhang ierr = PetscTableCreate(A->cmap->n + a->B->cmap->N,aN,&ta);CHKERRQ(ierr); 20734b38b95cSHong Zhang MatRowMergeMax_SeqAIJ(a_loc,am,ta); 20740acc65b4SHong Zhang ierr = PetscTableGetCount(ta,&Armax);CHKERRQ(ierr); 207533ba5e2fSHong Zhang 20760acc65b4SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Armax,&lnk);CHKERRQ(ierr); 2077d6ab1dc0SHong Zhang 2078d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 2079d6ab1dc0SHong Zhang pnz = poti[i+1] - poti[i]; 2080d6ab1dc0SHong Zhang ptJ = potj + poti[i]; 2081d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 2082d6ab1dc0SHong Zhang row = ptJ[j]; /* row of A_loc == col of Pot */ 2083d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 2084d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 2085d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 2086d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 2087d6ab1dc0SHong Zhang } 2088d6ab1dc0SHong Zhang nnz = lnk[0]; 2089d6ab1dc0SHong Zhang 2090d6ab1dc0SHong Zhang /* If free space is not available, double the total space in the list */ 2091d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 2092f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 2093d6ab1dc0SHong Zhang nspacedouble++; 2094d6ab1dc0SHong Zhang } 2095d6ab1dc0SHong Zhang 2096d6ab1dc0SHong Zhang /* Copy data into free space, and zero out denserows */ 2097d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 20982205254eSKarl Rupp 2099d6ab1dc0SHong Zhang current_space->array += nnz; 2100d6ab1dc0SHong Zhang current_space->local_used += nnz; 2101d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 21022205254eSKarl Rupp 2103d6ab1dc0SHong Zhang coi[i+1] = coi[i] + nnz; 2104d6ab1dc0SHong Zhang } 2105d6ab1dc0SHong Zhang 2106854ce69bSBarry Smith ierr = PetscMalloc1(coi[pon]+1,&coj);CHKERRQ(ierr); 2107d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr); 21080acc65b4SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); /* must destroy to get a new one for C */ 21092205254eSKarl Rupp 2110118727c9SMark F. Adams afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1); 2111d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 2112d6ab1dc0SHong Zhang 2113d6ab1dc0SHong Zhang /* send j-array (coj) of Co to other processors */ 2114d6ab1dc0SHong Zhang /*----------------------------------------------*/ 2115d6ab1dc0SHong Zhang /* determine row ownership */ 2116b00a9115SJed Brown ierr = PetscNew(&merge);CHKERRQ(ierr); 2117d6ab1dc0SHong Zhang ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr); 21182205254eSKarl Rupp 2119d6ab1dc0SHong Zhang merge->rowmap->n = pn; 2120d6ab1dc0SHong Zhang merge->rowmap->bs = 1; 21212205254eSKarl Rupp 2122d6ab1dc0SHong Zhang ierr = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr); 2123d6ab1dc0SHong Zhang owners = merge->rowmap->range; 2124d6ab1dc0SHong Zhang 2125d6ab1dc0SHong Zhang /* determine the number of messages to send, their lengths */ 21261795a4d1SJed Brown ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr); 2127785e854fSJed Brown ierr = PetscMalloc1(size,&merge->len_s);CHKERRQ(ierr); 21282205254eSKarl Rupp 2129d6ab1dc0SHong Zhang len_s = merge->len_s; 2130d6ab1dc0SHong Zhang merge->nsend = 0; 2131d6ab1dc0SHong Zhang 2132854ce69bSBarry Smith ierr = PetscMalloc1(size+2,&owners_co);CHKERRQ(ierr); 2133d6ab1dc0SHong Zhang ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr); 2134d6ab1dc0SHong Zhang 2135d6ab1dc0SHong Zhang proc = 0; 2136d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 2137d6ab1dc0SHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 2138d6ab1dc0SHong Zhang len_si[proc]++; /* num of rows in Co to be sent to [proc] */ 2139d6ab1dc0SHong Zhang len_s[proc] += coi[i+1] - coi[i]; 2140d6ab1dc0SHong Zhang } 2141d6ab1dc0SHong Zhang 2142d6ab1dc0SHong Zhang len = 0; /* max length of buf_si[] */ 2143d6ab1dc0SHong Zhang owners_co[0] = 0; 2144d6ab1dc0SHong Zhang for (proc=0; proc<size; proc++) { 2145d6ab1dc0SHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 2146d6ab1dc0SHong Zhang if (len_si[proc]) { 2147d6ab1dc0SHong Zhang merge->nsend++; 2148d6ab1dc0SHong Zhang len_si[proc] = 2*(len_si[proc] + 1); 2149d6ab1dc0SHong Zhang len += len_si[proc]; 2150d6ab1dc0SHong Zhang } 2151d6ab1dc0SHong Zhang } 2152d6ab1dc0SHong Zhang 2153d6ab1dc0SHong Zhang /* determine the number and length of messages to receive for coi and coj */ 21540298fd71SBarry Smith ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr); 2155d6ab1dc0SHong Zhang ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr); 2156d6ab1dc0SHong Zhang 2157d6ab1dc0SHong Zhang /* post the Irecv and Isend of coj */ 2158d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 2159d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 2160854ce69bSBarry Smith ierr = PetscMalloc1(merge->nsend+1,&swaits);CHKERRQ(ierr); 2161d6ab1dc0SHong Zhang for (proc=0, k=0; proc<size; proc++) { 2162d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 2163d6ab1dc0SHong Zhang i = owners_co[proc]; 2164d6ab1dc0SHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 2165d6ab1dc0SHong Zhang k++; 2166d6ab1dc0SHong Zhang } 2167d6ab1dc0SHong Zhang 2168d6ab1dc0SHong Zhang /* receives and sends of coj are complete */ 2169785e854fSJed Brown ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr); 2170d6ab1dc0SHong Zhang for (i=0; i<merge->nrecv; i++) { 2171c280ed6aSJed Brown PetscMPIInt icompleted; 2172c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 2173d6ab1dc0SHong Zhang } 2174d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 2175d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 2176d6ab1dc0SHong Zhang 21770acc65b4SHong Zhang /* add received column indices into table to update Armax */ 217833ba5e2fSHong Zhang /* Armax can be as large as aN if a P[row,:] is dense, see src/ksp/ksp/examples/tutorials/ex56.c! */ 21790acc65b4SHong Zhang for (k=0; k<merge->nrecv; k++) {/* k-th received message */ 21800acc65b4SHong Zhang Jptr = buf_rj[k]; 21810acc65b4SHong Zhang for (j=0; j<merge->len_r[k]; j++) { 21820acc65b4SHong Zhang ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr); 21830acc65b4SHong Zhang } 21840acc65b4SHong Zhang } 21850acc65b4SHong Zhang ierr = PetscTableGetCount(ta,&Armax);CHKERRQ(ierr); 218633ba5e2fSHong Zhang /* printf("Armax %d, an %d + Bn %d = %d, aN %d\n",Armax,A->cmap->n,a->B->cmap->N,A->cmap->n+a->B->cmap->N,aN); */ 21870acc65b4SHong Zhang 2188d6ab1dc0SHong Zhang /* send and recv coi */ 2189d6ab1dc0SHong Zhang /*-------------------*/ 2190d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 2191d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 2192854ce69bSBarry Smith ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 2193d6ab1dc0SHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 2194d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 2195d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 2196d6ab1dc0SHong Zhang /* form outgoing message for i-structure: 2197d6ab1dc0SHong Zhang buf_si[0]: nrows to be sent 2198d6ab1dc0SHong Zhang [1:nrows]: row index (global) 2199d6ab1dc0SHong Zhang [nrows+1:2*nrows+1]: i-structure index 2200d6ab1dc0SHong Zhang */ 2201d6ab1dc0SHong Zhang /*-------------------------------------------*/ 2202d6ab1dc0SHong Zhang nrows = len_si[proc]/2 - 1; 2203d6ab1dc0SHong Zhang buf_si_i = buf_si + nrows+1; 2204d6ab1dc0SHong Zhang buf_si[0] = nrows; 2205d6ab1dc0SHong Zhang buf_si_i[0] = 0; 2206d6ab1dc0SHong Zhang nrows = 0; 2207d6ab1dc0SHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 2208d6ab1dc0SHong Zhang nzi = coi[i+1] - coi[i]; 2209d6ab1dc0SHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 2210d6ab1dc0SHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 2211d6ab1dc0SHong Zhang nrows++; 2212d6ab1dc0SHong Zhang } 2213d6ab1dc0SHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 2214d6ab1dc0SHong Zhang k++; 2215d6ab1dc0SHong Zhang buf_si += len_si[proc]; 2216d6ab1dc0SHong Zhang } 2217d6ab1dc0SHong Zhang i = merge->nrecv; 2218d6ab1dc0SHong Zhang while (i--) { 2219c280ed6aSJed Brown PetscMPIInt icompleted; 2220c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 2221d6ab1dc0SHong Zhang } 2222d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 2223d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 2224d6ab1dc0SHong Zhang ierr = PetscFree(len_si);CHKERRQ(ierr); 2225d6ab1dc0SHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 2226d6ab1dc0SHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 2227d6ab1dc0SHong Zhang ierr = PetscFree(sstatus);CHKERRQ(ierr); 2228d6ab1dc0SHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 2229d6ab1dc0SHong Zhang 2230d6ab1dc0SHong Zhang /* compute the local portion of C (mpi mat) */ 2231d6ab1dc0SHong Zhang /*------------------------------------------*/ 2232d6ab1dc0SHong Zhang /* allocate bi array and free space for accumulating nonzero column info */ 2233854ce69bSBarry Smith ierr = PetscMalloc1(pn+1,&bi);CHKERRQ(ierr); 2234d6ab1dc0SHong Zhang bi[0] = 0; 2235d6ab1dc0SHong Zhang 2236d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(P) + nnz(AP)) */ 2237f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(pdti[pn],PetscIntSumTruncate(poti[pon],ai[am]))); 2238a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 2239d6ab1dc0SHong Zhang current_space = free_space; 2240d6ab1dc0SHong Zhang 2241dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 2242d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 2243d6ab1dc0SHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 2244d6ab1dc0SHong Zhang nrows = *buf_ri_k[k]; 2245d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 22462205254eSKarl Rupp nextci[k] = buf_ri_k[k] + (nrows + 1); /* points to the next i-structure of k-th recieved i-structure */ 2247d6ab1dc0SHong Zhang } 2248d6ab1dc0SHong Zhang 22490acc65b4SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Armax,&lnk);CHKERRQ(ierr); 2250d6ab1dc0SHong Zhang ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr); 2251d6ab1dc0SHong Zhang rmax = 0; 2252d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 2253d6ab1dc0SHong Zhang /* add pdt[i,:]*AP into lnk */ 2254d6ab1dc0SHong Zhang pnz = pdti[i+1] - pdti[i]; 2255d6ab1dc0SHong Zhang ptJ = pdtj + pdti[i]; 2256d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 2257d6ab1dc0SHong Zhang row = ptJ[j]; /* row of AP == col of Pt */ 2258d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 2259d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 2260d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 2261d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 2262d6ab1dc0SHong Zhang } 2263d6ab1dc0SHong Zhang 2264d6ab1dc0SHong Zhang /* add received col data into lnk */ 2265d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 2266d6ab1dc0SHong Zhang if (i == *nextrow[k]) { /* i-th row */ 2267d6ab1dc0SHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 2268d6ab1dc0SHong Zhang Jptr = buf_rj[k] + *nextci[k]; 2269d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr); 2270d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 2271d6ab1dc0SHong Zhang } 2272d6ab1dc0SHong Zhang } 2273d6ab1dc0SHong Zhang nnz = lnk[0]; 2274d6ab1dc0SHong Zhang 2275d6ab1dc0SHong Zhang /* if free space is not available, make more free space */ 2276d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 2277f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 2278d6ab1dc0SHong Zhang nspacedouble++; 2279d6ab1dc0SHong Zhang } 2280d6ab1dc0SHong Zhang /* copy data into free space, then initialize lnk */ 2281d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 2282d6ab1dc0SHong Zhang ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr); 22832205254eSKarl Rupp 2284d6ab1dc0SHong Zhang current_space->array += nnz; 2285d6ab1dc0SHong Zhang current_space->local_used += nnz; 2286d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 22872205254eSKarl Rupp 2288d6ab1dc0SHong Zhang bi[i+1] = bi[i] + nnz; 2289d6ab1dc0SHong Zhang if (nnz > rmax) rmax = nnz; 2290d6ab1dc0SHong Zhang } 2291f671be37SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 2292d6ab1dc0SHong Zhang 2293854ce69bSBarry Smith ierr = PetscMalloc1(bi[pn]+1,&bj);CHKERRQ(ierr); 2294d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr); 2295118727c9SMark F. Adams afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1); 2296d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 2297d6ab1dc0SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 22980acc65b4SHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 22990acc65b4SHong Zhang 2300d6ab1dc0SHong Zhang ierr = MatDestroy(&POt);CHKERRQ(ierr); 2301d6ab1dc0SHong Zhang ierr = MatDestroy(&PDt);CHKERRQ(ierr); 2302d6ab1dc0SHong Zhang 2303d6ab1dc0SHong Zhang /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part */ 2304d6ab1dc0SHong Zhang /*----------------------------------------------------------------------------------*/ 23051795a4d1SJed Brown ierr = PetscCalloc1(rmax+1,&vals);CHKERRQ(ierr); 2306d6ab1dc0SHong Zhang 2307d6ab1dc0SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 2308d6ab1dc0SHong Zhang ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 230933d57670SJed Brown ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(A->cmap->bs));CHKERRQ(ierr); 2310d6ab1dc0SHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 2311d6ab1dc0SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 2312d6ab1dc0SHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 2313d6ab1dc0SHong Zhang ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr); 2314d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 2315d6ab1dc0SHong Zhang row = i + rstart; 2316d6ab1dc0SHong Zhang nnz = bi[i+1] - bi[i]; 2317d6ab1dc0SHong Zhang Jptr = bj + bi[i]; 2318d6ab1dc0SHong Zhang ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,vals,INSERT_VALUES);CHKERRQ(ierr); 2319d6ab1dc0SHong Zhang } 2320d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 2321d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 2322d6ab1dc0SHong Zhang ierr = PetscFree(vals);CHKERRQ(ierr); 2323d6ab1dc0SHong Zhang 2324d6ab1dc0SHong Zhang merge->bi = bi; 2325d6ab1dc0SHong Zhang merge->bj = bj; 2326d6ab1dc0SHong Zhang merge->coi = coi; 2327d6ab1dc0SHong Zhang merge->coj = coj; 2328d6ab1dc0SHong Zhang merge->buf_ri = buf_ri; 2329d6ab1dc0SHong Zhang merge->buf_rj = buf_rj; 2330d6ab1dc0SHong Zhang merge->owners_co = owners_co; 2331d6ab1dc0SHong Zhang 2332d6ab1dc0SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 2333d6ab1dc0SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 23342205254eSKarl Rupp 2335d6ab1dc0SHong Zhang c->ptap = ptap; 23360298fd71SBarry Smith ptap->api = NULL; 23370298fd71SBarry Smith ptap->apj = NULL; 2338d6ab1dc0SHong Zhang ptap->merge = merge; 23390298fd71SBarry Smith ptap->apa = NULL; 2340a560ef98SHong Zhang ptap->destroy = Cmpi->ops->destroy; 2341a560ef98SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 2342a560ef98SHong Zhang 2343a560ef98SHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ; 2344a560ef98SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 2345a560ef98SHong Zhang Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatPtAP; 2346f96d37fcSHong Zhang 2347f96d37fcSHong Zhang *C = Cmpi; 2348f96d37fcSHong Zhang #if defined(PETSC_USE_INFO) 2349f96d37fcSHong Zhang if (bi[pn] != 0) { 235057622a8eSBarry Smith ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 235157622a8eSBarry Smith ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr); 2352f96d37fcSHong Zhang } else { 2353f96d37fcSHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 2354f96d37fcSHong Zhang } 2355f96d37fcSHong Zhang #endif 2356f96d37fcSHong Zhang PetscFunctionReturn(0); 2357f96d37fcSHong Zhang } 2358