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> 123515ee7fSJunchao Zhang #include <petsc/private/vecscatterimpl.h> 131634b032SHong Zhang 145e5acdf2Sstefano_zampini #if defined(PETSC_HAVE_HYPRE) 155e5acdf2Sstefano_zampini PETSC_INTERN PetscErrorCode MatMatMultSymbolic_AIJ_AIJ_wHYPRE(Mat,Mat,PetscReal,Mat*); 165e5acdf2Sstefano_zampini #endif 175e5acdf2Sstefano_zampini 18150d2497SBarry Smith PETSC_INTERN PetscErrorCode MatMatMult_MPIAIJ_MPIAIJ(Mat A,Mat B,MatReuse scall,PetscReal fill, Mat *C) 192499ec78SHong Zhang { 202499ec78SHong Zhang PetscErrorCode ierr; 215e5acdf2Sstefano_zampini #if defined(PETSC_HAVE_HYPRE) 22a9d7e0ccSandi selinger const char *algTypes[4] = {"scalable","nonscalable","seqmpi","hypre"}; 23a9d7e0ccSandi selinger PetscInt nalg = 4; 245e5acdf2Sstefano_zampini #else 25a9d7e0ccSandi selinger const char *algTypes[3] = {"scalable","nonscalable","seqmpi"}; 26a9d7e0ccSandi selinger PetscInt nalg = 3; 275e5acdf2Sstefano_zampini #endif 2860106aa7SHong Zhang PetscInt alg = 1; /* set nonscalable algorithm as default */ 29e55be12dSHong Zhang MPI_Comm comm; 305e68f438SHong Zhang PetscBool flg; 312499ec78SHong Zhang 322499ec78SHong Zhang PetscFunctionBegin; 332499ec78SHong Zhang if (scall == MAT_INITIAL_MATRIX) { 34e55be12dSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 356c4ed002SBarry 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); 36e55be12dSHong Zhang 37715a5346SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)A),((PetscObject)A)->prefix,"MatMatMult","Mat");CHKERRQ(ierr); 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 case 2: 65a9d7e0ccSandi selinger ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ_seqMPI(A,B,fill,C);CHKERRQ(ierr); 66a9d7e0ccSandi selinger break; 67a9d7e0ccSandi selinger #if defined(PETSC_HAVE_HYPRE) 68a9d7e0ccSandi selinger case 3: 695e5acdf2Sstefano_zampini ierr = MatMatMultSymbolic_AIJ_AIJ_wHYPRE(A,B,fill,C);CHKERRQ(ierr); 705e5acdf2Sstefano_zampini break; 715e5acdf2Sstefano_zampini #endif 720fc8cf34SHong Zhang default: 73b2405163SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ(A,B,fill,C);CHKERRQ(ierr); 740fc8cf34SHong Zhang break; 750fc8cf34SHong Zhang } 763ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 777d0a89b7SHong Zhang 787d0a89b7SHong Zhang if (alg == 0 || alg == 1) { 797d0a89b7SHong Zhang Mat_MPIAIJ *c = (Mat_MPIAIJ*)(*C)->data; 807d0a89b7SHong Zhang Mat_APMPI *ap = c->ap; 817d0a89b7SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)(*C)),((PetscObject)(*C))->prefix,"MatFreeIntermediateDataStructures","Mat");CHKERRQ(ierr); 827d0a89b7SHong Zhang ap->freestruct = PETSC_FALSE; 837d0a89b7SHong Zhang ierr = PetscOptionsBool("-mat_freeintermediatedatastructures","Free intermediate data structures", "MatFreeIntermediateDataStructures",ap->freestruct,&ap->freestruct, NULL);CHKERRQ(ierr); 847d0a89b7SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 852499ec78SHong Zhang } 867d0a89b7SHong Zhang } 877d0a89b7SHong Zhang 883ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 89598bc09dSHong Zhang ierr = (*(*C)->ops->matmultnumeric)(A,B,*C);CHKERRQ(ierr); 903ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 912499ec78SHong Zhang PetscFunctionReturn(0); 922499ec78SHong Zhang } 932499ec78SHong Zhang 94a1a4e84aSHong Zhang PetscErrorCode MatDestroy_MPIAIJ_MatMatMult(Mat A) 95598bc09dSHong Zhang { 96598bc09dSHong Zhang PetscErrorCode ierr; 97598bc09dSHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data; 983cdca5ebSHong Zhang Mat_APMPI *ptap = a->ap; 99598bc09dSHong Zhang 100598bc09dSHong Zhang PetscFunctionBegin; 101b7f45c76SHong Zhang ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr); 102598bc09dSHong Zhang ierr = PetscFree(ptap->bufa);CHKERRQ(ierr); 103a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr); 104a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr); 105ab1b013aSHong Zhang ierr = MatDestroy(&ptap->Pt);CHKERRQ(ierr); 106a1a4e84aSHong Zhang ierr = PetscFree(ptap->api);CHKERRQ(ierr); 107a1a4e84aSHong Zhang ierr = PetscFree(ptap->apj);CHKERRQ(ierr); 108598bc09dSHong Zhang ierr = PetscFree(ptap->apa);CHKERRQ(ierr); 109598bc09dSHong Zhang ierr = ptap->destroy(A);CHKERRQ(ierr); 110598bc09dSHong Zhang ierr = PetscFree(ptap);CHKERRQ(ierr); 111598bc09dSHong Zhang PetscFunctionReturn(0); 112598bc09dSHong Zhang } 113598bc09dSHong Zhang 114f8efd71cSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,Mat C) 115598bc09dSHong Zhang { 116598bc09dSHong Zhang PetscErrorCode ierr; 1174ae0847bSHong Zhang Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 118598bc09dSHong Zhang Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 119598bc09dSHong Zhang Mat_SeqAIJ *cd =(Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 120c12557a1SHong Zhang PetscScalar *cda=cd->a,*coa=co->a; 121598bc09dSHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 1229ce11a7cSHong Zhang PetscScalar *apa,*ca; 123c12557a1SHong Zhang PetscInt cm =C->rmap->n; 1243cdca5ebSHong Zhang Mat_APMPI *ptap=c->ap; 125c12557a1SHong Zhang PetscInt *api,*apj,*apJ,i,k; 12629825010SHong Zhang PetscInt cstart=C->cmap->rstart; 127598bc09dSHong Zhang PetscInt cdnz,conz,k0,k1; 1289467f45fSHong Zhang MPI_Comm comm; 1299467f45fSHong Zhang PetscMPIInt size; 130598bc09dSHong Zhang 131598bc09dSHong Zhang PetscFunctionBegin; 1329467f45fSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1339467f45fSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1349467f45fSHong Zhang 135fa2a5dcfSHong Zhang if (!ptap->P_oth && size>1) SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"AP cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'"); 13680da8df7SHong Zhang 137a1a4e84aSHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 138598bc09dSHong Zhang /*-----------------------------------------------------*/ 139a1a4e84aSHong Zhang /* update numerical values of P_oth and P_loc */ 140b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 141a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 142598bc09dSHong Zhang 143598bc09dSHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 144598bc09dSHong Zhang /*----------------------------------------------------------*/ 145598bc09dSHong Zhang /* get data from symbolic products */ 146a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 147c12557a1SHong Zhang p_oth = NULL; 1489467f45fSHong Zhang if (size >1) { 1499467f45fSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 1509467f45fSHong Zhang } 151598bc09dSHong Zhang 152598bc09dSHong Zhang /* get apa for storing dense row A[i,:]*P */ 153598bc09dSHong Zhang apa = ptap->apa; 154598bc09dSHong Zhang 15529825010SHong Zhang api = ptap->api; 15629825010SHong Zhang apj = ptap->apj; 157598bc09dSHong Zhang for (i=0; i<cm; i++) { 158c12557a1SHong Zhang /* compute apa = A[i,:]*P */ 159e497d3c8SHong Zhang AProw_nonscalable(i,ad,ao,p_loc,p_oth,apa); 160598bc09dSHong Zhang 161598bc09dSHong Zhang /* set values in C */ 162598bc09dSHong Zhang apJ = apj + api[i]; 163598bc09dSHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 164598bc09dSHong Zhang conz = co->i[i+1] - co->i[i]; 165598bc09dSHong Zhang 166598bc09dSHong Zhang /* 1st off-diagoanl part of C */ 167598bc09dSHong Zhang ca = coa + co->i[i]; 168598bc09dSHong Zhang k = 0; 169598bc09dSHong Zhang for (k0=0; k0<conz; k0++) { 170598bc09dSHong Zhang if (apJ[k] >= cstart) break; 171598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 1725cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 173598bc09dSHong Zhang } 174598bc09dSHong Zhang 175598bc09dSHong Zhang /* diagonal part of C */ 176598bc09dSHong Zhang ca = cda + cd->i[i]; 177598bc09dSHong Zhang for (k1=0; k1<cdnz; k1++) { 178598bc09dSHong Zhang ca[k1] = apa[apJ[k]]; 1795cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 180598bc09dSHong Zhang } 181598bc09dSHong Zhang 182598bc09dSHong Zhang /* 2nd off-diagoanl part of C */ 183598bc09dSHong Zhang ca = coa + co->i[i]; 184598bc09dSHong Zhang for (; k0<conz; k0++) { 185598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 1865cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 187598bc09dSHong Zhang } 188598bc09dSHong Zhang } 189598bc09dSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 190598bc09dSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 19180da8df7SHong Zhang 1927d0a89b7SHong Zhang if (ptap->freestruct) { 19380da8df7SHong Zhang ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr); 19480da8df7SHong Zhang } 195598bc09dSHong Zhang PetscFunctionReturn(0); 196598bc09dSHong Zhang } 197598bc09dSHong Zhang 1980fc8cf34SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,PetscReal fill,Mat *C) 199598bc09dSHong Zhang { 200598bc09dSHong Zhang PetscErrorCode ierr; 201ce94432eSBarry Smith MPI_Comm comm; 2029467f45fSHong Zhang PetscMPIInt size; 203bfcd1a73SHong Zhang Mat Cmpi; 2043cdca5ebSHong Zhang Mat_APMPI *ptap; 2050298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 2064ae0847bSHong Zhang Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data,*c; 207bfcd1a73SHong Zhang Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 2087dbaa2c6Sandi selinger PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 2094ae0847bSHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 210d14fa243SHong Zhang PetscInt *lnk,i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi; 2115cab4f04SHong Zhang PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n; 212598bc09dSHong Zhang PetscBT lnkbt; 213bfcd1a73SHong Zhang PetscReal afill; 214b92f168fSBarry Smith MatType mtype; 215598bc09dSHong Zhang 216598bc09dSHong Zhang PetscFunctionBegin; 217ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 2189467f45fSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 2199467f45fSHong Zhang 2203cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 221b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 222598bc09dSHong Zhang 223598bc09dSHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 224b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 22519f0e57aSHong Zhang 226598bc09dSHong Zhang /* get P_loc by taking all local rows of P */ 227a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 228598bc09dSHong Zhang 229a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 230598bc09dSHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 2319467f45fSHong Zhang if (size > 1) { 2329467f45fSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 233598bc09dSHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 23420e3dc75SHong Zhang } else { 23520e3dc75SHong Zhang p_oth = NULL; 23620e3dc75SHong Zhang pi_oth = NULL; pj_oth = NULL; 2379467f45fSHong Zhang } 238598bc09dSHong Zhang 239598bc09dSHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 240598bc09dSHong Zhang /*-------------------------------------------------------------------*/ 241854ce69bSBarry Smith ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 242a1a4e84aSHong Zhang ptap->api = api; 243598bc09dSHong Zhang api[0] = 0; 244598bc09dSHong Zhang 2455cab4f04SHong Zhang /* create and initialize a linked list */ 2465cab4f04SHong Zhang ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr); 247598bc09dSHong Zhang 248bfcd1a73SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 249f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space);CHKERRQ(ierr); 250598bc09dSHong Zhang current_space = free_space; 251598bc09dSHong Zhang 252598bc09dSHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 253598bc09dSHong Zhang for (i=0; i<am; i++) { 254598bc09dSHong Zhang /* diagonal portion of A */ 255598bc09dSHong Zhang nzi = adi[i+1] - adi[i]; 256598bc09dSHong Zhang for (j=0; j<nzi; j++) { 257598bc09dSHong Zhang row = *adj++; 258598bc09dSHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 259598bc09dSHong Zhang Jptr = pj_loc + pi_loc[row]; 260598bc09dSHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 2611fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 262598bc09dSHong Zhang } 263598bc09dSHong Zhang /* off-diagonal portion of A */ 264598bc09dSHong Zhang nzi = aoi[i+1] - aoi[i]; 265598bc09dSHong Zhang for (j=0; j<nzi; j++) { 266598bc09dSHong Zhang row = *aoj++; 267598bc09dSHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 268598bc09dSHong Zhang Jptr = pj_oth + pi_oth[row]; 2691fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 270598bc09dSHong Zhang } 271598bc09dSHong Zhang 272d14fa243SHong Zhang apnz = lnk[0]; 273598bc09dSHong Zhang api[i+1] = api[i] + apnz; 274598bc09dSHong Zhang 275598bc09dSHong Zhang /* if free space is not available, double the total space in the list */ 276598bc09dSHong Zhang if (current_space->local_remaining<apnz) { 277f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 278598bc09dSHong Zhang nspacedouble++; 279598bc09dSHong Zhang } 280598bc09dSHong Zhang 281598bc09dSHong Zhang /* Copy data into free space, then initialize lnk */ 2821fbbb359SHong Zhang ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 283598bc09dSHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 2842205254eSKarl Rupp 285598bc09dSHong Zhang current_space->array += apnz; 286598bc09dSHong Zhang current_space->local_used += apnz; 287598bc09dSHong Zhang current_space->local_remaining -= apnz; 288598bc09dSHong Zhang } 289598bc09dSHong Zhang 290598bc09dSHong Zhang /* Allocate space for apj, initialize apj, and */ 291598bc09dSHong Zhang /* destroy list of free space and other temporary array(s) */ 292854ce69bSBarry Smith ierr = PetscMalloc1(api[am]+1,&ptap->apj);CHKERRQ(ierr); 293a1a4e84aSHong Zhang apj = ptap->apj; 294a1a4e84aSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 295598bc09dSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 296598bc09dSHong Zhang 297f84c536bSHong Zhang /* malloc apa to store dense row A[i,:]*P */ 298071fcb05SBarry Smith ierr = PetscCalloc1(pN,&ptap->apa);CHKERRQ(ierr); 299f84c536bSHong Zhang 300bfcd1a73SHong Zhang /* create and assemble symbolic parallel matrix Cmpi */ 301598bc09dSHong Zhang /*----------------------------------------------------*/ 302bfcd1a73SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 303bfcd1a73SHong Zhang ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 30433d57670SJed Brown ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr); 305a2f3521dSMark F. Adams 306b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 307b92f168fSBarry Smith ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr); 308bfcd1a73SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 30917f75172Sandi selinger 310904d1e70Sandi selinger ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat_Symbolic(Cmpi, apj, api);CHKERRQ(ierr); 311bfcd1a73SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 312bfcd1a73SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 3137dbaa2c6Sandi selinger ierr = MatPreallocateFinalize(dnz,onz);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; 3194624976aSHong Zhang Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP; 320598bc09dSHong Zhang 321bfcd1a73SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 322bfcd1a73SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 3233cdca5ebSHong Zhang c->ap = 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 { 362*87753ddeSHong Zhang Mat workB,Bb,Cb,workB1,Bb1,Cb1; 3634324174eSBarry Smith MPI_Request *rwaits,*swaits; 364*87753ddeSHong Zhang PetscInt numBb; /* num of Bb matrices */ 365*87753ddeSHong Zhang PetscInt nsends,nrecvs; 366*87753ddeSHong Zhang MPI_Datatype *stype,*rtype; 3674324174eSBarry Smith } MPIAIJ_MPIDense; 3684324174eSBarry Smith 36996b95a6bSBarry Smith PetscErrorCode MatMPIAIJ_MPIDenseDestroy(void *ctx) 3704324174eSBarry Smith { 3714324174eSBarry Smith MPIAIJ_MPIDense *contents = (MPIAIJ_MPIDense*)ctx; 3724324174eSBarry Smith PetscErrorCode ierr; 373*87753ddeSHong Zhang PetscInt i; 3744324174eSBarry Smith 3754324174eSBarry Smith PetscFunctionBegin; 3766bf464f9SBarry Smith ierr = MatDestroy(&contents->workB);CHKERRQ(ierr); 377*87753ddeSHong Zhang 378*87753ddeSHong Zhang if (contents->numBb) { 379*87753ddeSHong Zhang ierr = MatDestroy(&contents->Bb);CHKERRQ(ierr); 380*87753ddeSHong Zhang ierr = MatDestroy(&contents->Cb);CHKERRQ(ierr); 381*87753ddeSHong Zhang 382*87753ddeSHong Zhang ierr = MatDestroy(&contents->workB1);CHKERRQ(ierr); 383*87753ddeSHong Zhang ierr = MatDestroy(&contents->Bb1);CHKERRQ(ierr); 384*87753ddeSHong Zhang ierr = MatDestroy(&contents->Cb1);CHKERRQ(ierr); 385*87753ddeSHong Zhang } 386*87753ddeSHong Zhang for (i=0; i<contents->nsends; i++) { 387*87753ddeSHong Zhang ierr = MPI_Type_free(&contents->stype[i]);CHKERRQ(ierr); 388*87753ddeSHong Zhang } 389*87753ddeSHong Zhang for (i=0; i<contents->nrecvs; i++) { 390*87753ddeSHong Zhang ierr = MPI_Type_free(&contents->rtype[i]);CHKERRQ(ierr); 391*87753ddeSHong Zhang } 392*87753ddeSHong Zhang ierr = PetscFree4(contents->stype,contents->rtype,contents->rwaits,contents->swaits);CHKERRQ(ierr); 3934324174eSBarry Smith ierr = PetscFree(contents);CHKERRQ(ierr); 3944324174eSBarry Smith PetscFunctionReturn(0); 3954324174eSBarry Smith } 3964324174eSBarry Smith 397fd4e9aacSBarry Smith /* 398fd4e9aacSBarry Smith This is a "dummy function" that handles the case where matrix C was created as a dense matrix 399fd4e9aacSBarry Smith directly by the user and passed to MatMatMult() with the MAT_REUSE_MATRIX option 400fd4e9aacSBarry Smith 401fd4e9aacSBarry Smith It is the same as MatMatMultSymbolic_MPIAIJ_MPIDense() except does not create C 402fd4e9aacSBarry Smith */ 403fd4e9aacSBarry Smith PetscErrorCode MatMatMultNumeric_MPIDense(Mat A,Mat B,Mat C) 404fd4e9aacSBarry Smith { 405fd4e9aacSBarry Smith PetscErrorCode ierr; 406fd4e9aacSBarry Smith PetscBool flg; 407fd4e9aacSBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*) A->data; 4083515ee7fSJunchao Zhang PetscInt nz = aij->B->cmap->n,to_n,to_entries,from_n,from_entries; 409fd4e9aacSBarry Smith PetscContainer container; 410fd4e9aacSBarry Smith MPIAIJ_MPIDense *contents; 411fd4e9aacSBarry Smith VecScatter ctx = aij->Mvctx; 412fd4e9aacSBarry Smith 413fd4e9aacSBarry Smith PetscFunctionBegin; 414fd4e9aacSBarry Smith ierr = PetscObjectTypeCompare((PetscObject)B,MATMPIDENSE,&flg);CHKERRQ(ierr); 415fd4e9aacSBarry Smith if (!flg) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG,"Second matrix must be mpidense"); 416fd4e9aacSBarry Smith 417fd4e9aacSBarry Smith /* Handle case where where user provided the final C matrix rather than calling MatMatMult() with MAT_INITIAL_MATRIX*/ 418fd4e9aacSBarry Smith ierr = PetscObjectTypeCompare((PetscObject)A,MATMPIAIJ,&flg);CHKERRQ(ierr); 419fd4e9aacSBarry Smith if (!flg) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG,"First matrix must be MPIAIJ"); 420fd4e9aacSBarry Smith 421fd4e9aacSBarry Smith C->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense; 422fd4e9aacSBarry Smith 423fd4e9aacSBarry Smith ierr = PetscNew(&contents);CHKERRQ(ierr); 424fd4e9aacSBarry Smith /* Create work matrix used to store off processor rows of B needed for local product */ 425fd4e9aacSBarry Smith ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,B->cmap->N,NULL,&contents->workB);CHKERRQ(ierr); 426fd4e9aacSBarry Smith /* Create work arrays needed */ 4273515ee7fSJunchao Zhang ierr = VecScatterGetRemoteCount_Private(ctx,PETSC_TRUE/*send*/,&to_n,&to_entries);CHKERRQ(ierr); 4283515ee7fSJunchao Zhang ierr = VecScatterGetRemoteCount_Private(ctx,PETSC_FALSE/*recv*/,&from_n,&from_entries);CHKERRQ(ierr); 429*87753ddeSHong Zhang ierr = PetscMalloc2(from_n,&contents->rwaits,to_n,&contents->swaits);CHKERRQ(ierr); 430fd4e9aacSBarry Smith 431fd4e9aacSBarry Smith ierr = PetscContainerCreate(PetscObjectComm((PetscObject)A),&container);CHKERRQ(ierr); 432fd4e9aacSBarry Smith ierr = PetscContainerSetPointer(container,contents);CHKERRQ(ierr); 433fd4e9aacSBarry Smith ierr = PetscContainerSetUserDestroy(container,MatMPIAIJ_MPIDenseDestroy);CHKERRQ(ierr); 434fd4e9aacSBarry Smith ierr = PetscObjectCompose((PetscObject)C,"workB",(PetscObject)container);CHKERRQ(ierr); 435fd4e9aacSBarry Smith ierr = PetscContainerDestroy(&container);CHKERRQ(ierr); 436fd4e9aacSBarry Smith 437fd4e9aacSBarry Smith ierr = (*C->ops->matmultnumeric)(A,B,C);CHKERRQ(ierr); 438fd4e9aacSBarry Smith PetscFunctionReturn(0); 439fd4e9aacSBarry Smith } 440fd4e9aacSBarry Smith 441*87753ddeSHong Zhang /* 442*87753ddeSHong Zhang Create Bb, Cb, Bb1 and Cb1 matrices to be used by MatMatMult_MPIAIJ_MPIDense(). 443*87753ddeSHong Zhang These matrices are used as wrappers for sub-columns of B and C, thus their own matrix operations are not used. 444*87753ddeSHong Zhang Modified from MatCreateDense(). 445*87753ddeSHong Zhang */ 446*87753ddeSHong Zhang PETSC_STATIC_INLINE PetscErrorCode MatCreateSubMPIDense_private(MPI_Comm comm,PetscInt m,PetscInt n,PetscInt M,PetscInt N,PetscInt rbs,PetscInt cbs,PetscScalar *data,Mat *A) 447*87753ddeSHong Zhang { 448*87753ddeSHong Zhang PetscErrorCode ierr; 449*87753ddeSHong Zhang 450*87753ddeSHong Zhang PetscFunctionBegin; 451*87753ddeSHong Zhang ierr = MatCreate(comm,A);CHKERRQ(ierr); 452*87753ddeSHong Zhang ierr = MatSetSizes(*A,m,n,M,N);CHKERRQ(ierr); 453*87753ddeSHong Zhang ierr = MatSetBlockSizes(*A,rbs,cbs);CHKERRQ(ierr); 454*87753ddeSHong Zhang ierr = MatSetType(*A,MATMPIDENSE);CHKERRQ(ierr); 455*87753ddeSHong Zhang ierr = MatMPIDenseSetPreallocation(*A,data);CHKERRQ(ierr); 456*87753ddeSHong Zhang (*A)->assembled = PETSC_TRUE; 457*87753ddeSHong Zhang PetscFunctionReturn(0); 458*87753ddeSHong Zhang } 459*87753ddeSHong Zhang 4609123193aSHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIDense(Mat A,Mat B,PetscReal fill,Mat *C) 4619123193aSHong Zhang { 4629123193aSHong Zhang PetscErrorCode ierr; 463f32d5d43SBarry Smith Mat_MPIAIJ *aij=(Mat_MPIAIJ*)A->data; 464*87753ddeSHong Zhang PetscInt nz=aij->B->cmap->n,nsends,nrecvs,i,nrows_to,j; 465bf0cc555SLisandro Dalcin PetscContainer container; 4664324174eSBarry Smith MPIAIJ_MPIDense *contents; 4674324174eSBarry Smith VecScatter ctx=aij->Mvctx; 468*87753ddeSHong Zhang PetscInt Am=A->rmap->n,Bm=B->rmap->n,Bn=B->cmap->n,BN=B->cmap->N,Bbn,Bbn1,bs,nrows_from; 469*87753ddeSHong Zhang MPI_Comm comm; 470*87753ddeSHong Zhang MPI_Datatype type1,*stype,*rtype; 471*87753ddeSHong Zhang const PetscInt *sindices,*sstarts,*rstarts; 472*87753ddeSHong Zhang PetscMPIInt *disp; 4739123193aSHong Zhang 4749123193aSHong Zhang PetscFunctionBegin; 475*87753ddeSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 476*87753ddeSHong Zhang 477*87753ddeSHong Zhang ierr = MatCreate(comm,C);CHKERRQ(ierr); 478*87753ddeSHong Zhang ierr = MatSetSizes(*C,Am,Bn,A->rmap->N,BN);CHKERRQ(ierr); 47933d57670SJed Brown ierr = MatSetBlockSizesFromMats(*C,A,B);CHKERRQ(ierr); 480cb2480eaSBarry Smith ierr = MatSetType(*C,MATMPIDENSE);CHKERRQ(ierr); 4810298fd71SBarry Smith ierr = MatMPIDenseSetPreallocation(*C,NULL);CHKERRQ(ierr); 482cb2480eaSBarry Smith ierr = MatAssemblyBegin(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 483cb2480eaSBarry Smith ierr = MatAssemblyEnd(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 4842205254eSKarl Rupp 485d73949e8SHong Zhang (*C)->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense; 486f32d5d43SBarry Smith 487b00a9115SJed Brown ierr = PetscNew(&contents);CHKERRQ(ierr); 488*87753ddeSHong Zhang contents->numBb = 0; 4894324174eSBarry Smith 490*87753ddeSHong Zhang ierr = VecScatterGetRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,NULL,NULL);CHKERRQ(ierr); 491*87753ddeSHong Zhang ierr = VecScatterGetRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,NULL,NULL);CHKERRQ(ierr); 492*87753ddeSHong Zhang 493*87753ddeSHong Zhang /* Create column block of B and C for memory scalability when BN is too large */ 494*87753ddeSHong Zhang /* Estimate Bbn, column size of Bb */ 495*87753ddeSHong Zhang if (nz) { 496*87753ddeSHong Zhang Bbn1 = 2*Am*BN/nz; 497*87753ddeSHong Zhang } else Bbn1 = BN; 498*87753ddeSHong Zhang 499*87753ddeSHong Zhang bs = PetscAbs(B->cmap->bs); 500*87753ddeSHong Zhang Bbn1 = Bbn1/bs *bs; /* Bbn1 is a multiple of bs */ 501*87753ddeSHong Zhang if (Bbn1 > BN) Bbn1 = BN; 502*87753ddeSHong Zhang ierr = MPI_Allreduce(&Bbn1,&Bbn,1,MPIU_INT,MPI_MAX,comm);CHKERRQ(ierr); 503*87753ddeSHong Zhang 504*87753ddeSHong Zhang /* Enable runtime option for Bbn */ 505*87753ddeSHong Zhang ierr = PetscOptionsBegin(comm,((PetscObject)*C)->prefix,"MatMatMult","Mat");CHKERRQ(ierr); 506*87753ddeSHong Zhang ierr = PetscOptionsInt("-matmatmult_Bbn","Number of columns in Bb","MatMatMult",Bbn,&Bbn,NULL);CHKERRQ(ierr); 507*87753ddeSHong Zhang if (Bbn > BN) SETERRQ2(comm,PETSC_ERR_ARG_SIZ,"Bbn=%D cannot be larger than %D, column size of B",Bbn,BN); 508*87753ddeSHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 509*87753ddeSHong Zhang 510*87753ddeSHong Zhang if (Bbn < BN) { 511*87753ddeSHong Zhang contents->numBb = BN/Bbn; 512*87753ddeSHong Zhang Bbn1 = BN - contents->numBb*Bbn; 513*87753ddeSHong Zhang } 514*87753ddeSHong Zhang 515*87753ddeSHong Zhang if (contents->numBb) { 516*87753ddeSHong Zhang PetscScalar data[1]; /* fake array for Bb and Cb */ 517*87753ddeSHong Zhang ierr = PetscInfo3(*C,"use Bb, BN=%D, Bbn=%D; numBb=%D\n",BN,Bbn,contents->numBb);CHKERRQ(ierr); 518*87753ddeSHong Zhang ierr = MatCreateSubMPIDense_private(comm,B->rmap->n,PETSC_DECIDE,A->rmap->N,Bbn,B->rmap->bs,B->cmap->bs,data,&contents->Bb);CHKERRQ(ierr); 519*87753ddeSHong Zhang ierr = MatCreateSubMPIDense_private(comm,Am,PETSC_DECIDE,A->rmap->N,Bbn,(*C)->rmap->bs,(*C)->cmap->bs,data,&contents->Cb);CHKERRQ(ierr); 520*87753ddeSHong Zhang 521*87753ddeSHong Zhang if (Bbn1) { /* Create Bb1 and Cb1 for the remaining columns */ 522*87753ddeSHong Zhang ierr = PetscInfo2(*C,"use Bb1, BN=%D, Bbn1=%D\n",BN,Bbn1);CHKERRQ(ierr); 523*87753ddeSHong Zhang ierr = MatCreateSubMPIDense_private(comm,B->rmap->n,PETSC_DECIDE,A->rmap->N,Bbn1,B->rmap->bs,B->cmap->bs,data,&contents->Bb1);CHKERRQ(ierr); 524*87753ddeSHong Zhang ierr = MatCreateSubMPIDense_private(comm,Am,PETSC_DECIDE,A->rmap->N,Bbn1,(*C)->rmap->bs,(*C)->cmap->bs,data,&contents->Cb1);CHKERRQ(ierr); 525*87753ddeSHong Zhang 526*87753ddeSHong Zhang /* Create work matrix used to store off processor rows of B needed for local product */ 527*87753ddeSHong Zhang ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,Bbn1,NULL,&contents->workB1);CHKERRQ(ierr); 528*87753ddeSHong Zhang } 529*87753ddeSHong Zhang } 530*87753ddeSHong Zhang 531*87753ddeSHong Zhang /* Create work matrix used to store off processor rows of B needed for local product */ 532*87753ddeSHong Zhang ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,Bbn,NULL,&contents->workB);CHKERRQ(ierr); 533*87753ddeSHong Zhang 534*87753ddeSHong Zhang /* Use MPI derived data type to reduce memory required by the send/recv buffers */ 535*87753ddeSHong Zhang ierr = PetscMalloc4(nsends,&stype,nrecvs,&rtype,nrecvs,&contents->rwaits,nsends,&contents->swaits);CHKERRQ(ierr); 536*87753ddeSHong Zhang contents->stype = stype; 537*87753ddeSHong Zhang contents->nsends = nsends; 538*87753ddeSHong Zhang 539*87753ddeSHong Zhang contents->rtype = rtype; 540*87753ddeSHong Zhang contents->nrecvs = nrecvs; 541*87753ddeSHong Zhang 542*87753ddeSHong Zhang ierr = PetscMalloc1(Bm+1,&disp);CHKERRQ(ierr); 543*87753ddeSHong Zhang for (i=0; i<nsends; i++) { 544*87753ddeSHong Zhang nrows_to = sstarts[i+1]-sstarts[i]; 545*87753ddeSHong Zhang for (j=0; j<nrows_to; j++){ 546*87753ddeSHong Zhang disp[j] = sindices[sstarts[i]+j]; /* rowB to be sent */ 547*87753ddeSHong Zhang } 548*87753ddeSHong Zhang ierr = MPI_Type_create_indexed_block(nrows_to,1,(const PetscMPIInt *)disp,MPIU_SCALAR,&type1);CHKERRQ(ierr); 549*87753ddeSHong Zhang ierr = MPI_Type_create_resized(type1,0,Bm*sizeof(PetscScalar),&stype[i]);CHKERRQ(ierr); 550*87753ddeSHong Zhang ierr = MPI_Type_commit(&stype[i]);CHKERRQ(ierr); 551*87753ddeSHong Zhang ierr = MPI_Type_free(&type1);CHKERRQ(ierr); 552*87753ddeSHong Zhang } 553*87753ddeSHong Zhang 554*87753ddeSHong Zhang for (i=0; i<nrecvs; i++) { 555*87753ddeSHong Zhang /* received values from a process form a (nrows_from x Bbn) row block in workB (column-wise) */ 556*87753ddeSHong Zhang nrows_from = rstarts[i+1]-rstarts[i]; 557*87753ddeSHong Zhang disp[0] = 0; 558*87753ddeSHong Zhang ierr = MPI_Type_create_indexed_block(1, nrows_from, (const PetscMPIInt *)disp, MPIU_SCALAR, &type1);CHKERRQ(ierr); 559*87753ddeSHong Zhang ierr = MPI_Type_create_resized(type1, 0, nz*sizeof(PetscScalar), &rtype[i]);CHKERRQ(ierr); 560*87753ddeSHong Zhang ierr = MPI_Type_commit(&rtype[i]);CHKERRQ(ierr); 561*87753ddeSHong Zhang ierr = MPI_Type_free(&type1);CHKERRQ(ierr); 562*87753ddeSHong Zhang } 563*87753ddeSHong Zhang 564*87753ddeSHong Zhang ierr = PetscFree(disp);CHKERRQ(ierr); 565*87753ddeSHong Zhang ierr = VecScatterRestoreRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,NULL,NULL);CHKERRQ(ierr); 566*87753ddeSHong Zhang ierr = VecScatterRestoreRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,NULL,NULL);CHKERRQ(ierr); 567*87753ddeSHong Zhang 568*87753ddeSHong Zhang ierr = PetscContainerCreate(comm,&container);CHKERRQ(ierr); 569bf0cc555SLisandro Dalcin ierr = PetscContainerSetPointer(container,contents);CHKERRQ(ierr); 57096b95a6bSBarry Smith ierr = PetscContainerSetUserDestroy(container,MatMPIAIJ_MPIDenseDestroy);CHKERRQ(ierr); 571bf0cc555SLisandro Dalcin ierr = PetscObjectCompose((PetscObject)(*C),"workB",(PetscObject)container);CHKERRQ(ierr); 572bf0cc555SLisandro Dalcin ierr = PetscContainerDestroy(&container);CHKERRQ(ierr); 5739123193aSHong Zhang PetscFunctionReturn(0); 5749123193aSHong Zhang } 5759123193aSHong Zhang 576*87753ddeSHong Zhang extern PetscErrorCode MatMatMultNumericAdd_SeqAIJ_SeqDense(Mat,Mat,Mat); 577f32d5d43SBarry Smith /* 5782636ff26SBarry Smith Performs an efficient scatter on the rows of B needed by this process; this is 5792636ff26SBarry Smith a modification of the VecScatterBegin_() routines. 580*87753ddeSHong Zhang 581*87753ddeSHong Zhang Input: Bbidx = 0: B = Bb 582*87753ddeSHong Zhang = 1: B = Bb1, see MatMatMultSymbolic_MPIAIJ_MPIDense() 583f32d5d43SBarry Smith */ 584*87753ddeSHong Zhang PetscErrorCode MatMPIDenseScatter(Mat A,Mat B,PetscInt Bbidx,Mat C,Mat *outworkB) 585f32d5d43SBarry Smith { 586f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 587f32d5d43SBarry Smith PetscErrorCode ierr; 5881683a169SBarry Smith const PetscScalar *b; 589*87753ddeSHong Zhang PetscScalar *rvalues; 590f32d5d43SBarry Smith VecScatter ctx = aij->Mvctx; 591*87753ddeSHong Zhang const PetscInt *sindices,*sstarts,*rstarts; 5923515ee7fSJunchao Zhang const PetscMPIInt *sprocs,*rprocs; 593*87753ddeSHong Zhang PetscInt i,nsends,nrecvs,nrecvs2; 594f32d5d43SBarry Smith MPI_Request *swaits,*rwaits; 595ce94432eSBarry Smith MPI_Comm comm; 596*87753ddeSHong Zhang PetscMPIInt tag=((PetscObject)ctx)->tag,ncols=B->cmap->N,nrows=aij->B->cmap->n,imdex,nsends_mpi,nrecvs_mpi; 597f32d5d43SBarry Smith MPI_Status status; 5984324174eSBarry Smith MPIAIJ_MPIDense *contents; 599bf0cc555SLisandro Dalcin PetscContainer container; 6004324174eSBarry Smith Mat workB; 601*87753ddeSHong Zhang MPI_Datatype *stype,*rtype; 602f32d5d43SBarry Smith 603f32d5d43SBarry Smith PetscFunctionBegin; 604ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 605bf0cc555SLisandro Dalcin ierr = PetscObjectQuery((PetscObject)C,"workB",(PetscObject*)&container);CHKERRQ(ierr); 60629825010SHong Zhang if (!container) SETERRQ(comm,PETSC_ERR_PLIB,"Container does not exist"); 607bf0cc555SLisandro Dalcin ierr = PetscContainerGetPointer(container,(void**)&contents);CHKERRQ(ierr); 6084324174eSBarry Smith 6093515ee7fSJunchao Zhang ierr = VecScatterGetRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,&sprocs,NULL/*bs*/);CHKERRQ(ierr); 610*87753ddeSHong Zhang ierr = VecScatterGetRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,&rprocs,NULL/*bs*/);CHKERRQ(ierr); 6113515ee7fSJunchao Zhang ierr = PetscMPIIntCast(nsends,&nsends_mpi);CHKERRQ(ierr); 6123515ee7fSJunchao Zhang ierr = PetscMPIIntCast(nrecvs,&nrecvs_mpi);CHKERRQ(ierr); 613*87753ddeSHong Zhang if (Bbidx == 0) { 614*87753ddeSHong Zhang workB = *outworkB = contents->workB; 615*87753ddeSHong Zhang } else { 616*87753ddeSHong Zhang workB = *outworkB = contents->workB1; 617*87753ddeSHong Zhang } 618*87753ddeSHong 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); 6193515ee7fSJunchao Zhang swaits = contents->swaits; 6203515ee7fSJunchao Zhang rwaits = contents->rwaits; 621f32d5d43SBarry Smith 6221683a169SBarry Smith ierr = MatDenseGetArrayRead(B,&b);CHKERRQ(ierr); 623*87753ddeSHong Zhang ierr = MatDenseGetArray(workB,&rvalues);CHKERRQ(ierr); 624f32d5d43SBarry Smith 625*87753ddeSHong Zhang /* Post recv, use MPI derived data type to save memory */ 626*87753ddeSHong Zhang rtype = contents->rtype; 6273515ee7fSJunchao Zhang for (i=0; i<nrecvs; i++) { 628*87753ddeSHong Zhang ierr = MPI_Irecv(rvalues+(rstarts[i]-rstarts[0]),ncols,rtype[i],rprocs[i],tag,comm,rwaits+i);CHKERRQ(ierr); 629f32d5d43SBarry Smith } 630f32d5d43SBarry Smith 631*87753ddeSHong Zhang stype = contents->stype; 6323515ee7fSJunchao Zhang for (i=0; i<nsends; i++) { 633*87753ddeSHong Zhang ierr = MPI_Isend(b,ncols,stype[i],sprocs[i],tag,comm,swaits+i);CHKERRQ(ierr); 634f32d5d43SBarry Smith } 6352636ff26SBarry Smith 6363515ee7fSJunchao Zhang nrecvs2 = nrecvs; 6373515ee7fSJunchao Zhang while (nrecvs2) { 6383515ee7fSJunchao Zhang ierr = MPI_Waitany(nrecvs_mpi,rwaits,&imdex,&status);CHKERRQ(ierr); 6393515ee7fSJunchao Zhang nrecvs2--; 640f32d5d43SBarry Smith } 6413515ee7fSJunchao Zhang if (nsends) {ierr = MPI_Waitall(nsends_mpi,swaits,MPI_STATUSES_IGNORE);CHKERRQ(ierr);} 642f32d5d43SBarry Smith 643*87753ddeSHong Zhang ierr = VecScatterRestoreRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,&sprocs,NULL);CHKERRQ(ierr); 644*87753ddeSHong Zhang ierr = VecScatterRestoreRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,&rprocs,NULL);CHKERRQ(ierr); 6451683a169SBarry Smith ierr = MatDenseRestoreArrayRead(B,&b);CHKERRQ(ierr); 646*87753ddeSHong Zhang ierr = MatDenseRestoreArray(workB,&rvalues);CHKERRQ(ierr); 647f32d5d43SBarry Smith ierr = MatAssemblyBegin(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 648f32d5d43SBarry Smith ierr = MatAssemblyEnd(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 649f32d5d43SBarry Smith PetscFunctionReturn(0); 650f32d5d43SBarry Smith } 651*87753ddeSHong Zhang 652*87753ddeSHong Zhang /* 653*87753ddeSHong Zhang Compute Cb = A*Bb 654*87753ddeSHong Zhang */ 655*87753ddeSHong Zhang PETSC_STATIC_INLINE PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense_private(Mat A,Mat Bb,PetscInt Bbidx,PetscInt start,Mat C,const PetscScalar *barray,PetscScalar *carray,Mat Cb) 656*87753ddeSHong Zhang { 657*87753ddeSHong Zhang PetscErrorCode ierr; 658*87753ddeSHong Zhang PetscInt start1; 659*87753ddeSHong Zhang Mat workB; 660*87753ddeSHong Zhang Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 661*87753ddeSHong Zhang Mat_MPIDense *cbdense = (Mat_MPIDense*)Cb->data; 662*87753ddeSHong Zhang 663*87753ddeSHong Zhang PetscFunctionBegin; 664*87753ddeSHong Zhang /* Place barray to Bb */ 665*87753ddeSHong Zhang start1 = start*Bb->rmap->n; 666*87753ddeSHong Zhang ierr = MatDensePlaceArray(Bb,barray+start1);CHKERRQ(ierr); 667*87753ddeSHong Zhang 668*87753ddeSHong Zhang /* get off processor parts of Bb needed to complete Cb=A*Bb */ 669*87753ddeSHong Zhang ierr = MatMPIDenseScatter(A,Bb,Bbidx,C,&workB);CHKERRQ(ierr); 670*87753ddeSHong Zhang ierr = MatDenseResetArray(Bb);CHKERRQ(ierr); 671*87753ddeSHong Zhang 672*87753ddeSHong Zhang /* off-diagonal block of A times nonlocal rows of Bb */ 673*87753ddeSHong Zhang /* Place carray to Cb */ 674*87753ddeSHong Zhang start1 = start*Cb->rmap->n; 675*87753ddeSHong Zhang ierr = MatDensePlaceArray(Cb,carray+start1);CHKERRQ(ierr); 676*87753ddeSHong Zhang ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cbdense->A);CHKERRQ(ierr); 677*87753ddeSHong Zhang ierr = MatDenseResetArray(Cb);CHKERRQ(ierr); 678*87753ddeSHong Zhang PetscFunctionReturn(0); 679*87753ddeSHong Zhang } 680f32d5d43SBarry Smith 6819123193aSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense(Mat A,Mat B,Mat C) 6829123193aSHong Zhang { 6839123193aSHong Zhang PetscErrorCode ierr; 684f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 685f32d5d43SBarry Smith Mat_MPIDense *bdense = (Mat_MPIDense*)B->data; 686f32d5d43SBarry Smith Mat_MPIDense *cdense = (Mat_MPIDense*)C->data; 687f32d5d43SBarry Smith Mat workB; 688*87753ddeSHong Zhang MPIAIJ_MPIDense *contents; 689*87753ddeSHong Zhang PetscContainer container; 690*87753ddeSHong Zhang MPI_Comm comm; 691*87753ddeSHong Zhang PetscInt numBb; 6929123193aSHong Zhang 6939123193aSHong Zhang PetscFunctionBegin; 694f32d5d43SBarry Smith /* diagonal block of A times all local rows of B*/ 695f32d5d43SBarry Smith ierr = MatMatMultNumeric_SeqAIJ_SeqDense(aij->A,bdense->A,cdense->A);CHKERRQ(ierr); 696f32d5d43SBarry Smith 697*87753ddeSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 698*87753ddeSHong Zhang ierr = PetscObjectQuery((PetscObject)C,"workB",(PetscObject*)&container);CHKERRQ(ierr); 699*87753ddeSHong Zhang if (!container) SETERRQ(comm,PETSC_ERR_PLIB,"Container does not exist"); 700*87753ddeSHong Zhang ierr = PetscContainerGetPointer(container,(void**)&contents);CHKERRQ(ierr); 701*87753ddeSHong Zhang numBb = contents->numBb; 702*87753ddeSHong Zhang 703*87753ddeSHong Zhang if (!numBb) { 704*87753ddeSHong Zhang /* get off processor parts of B needed to complete C=A*B */ 705*87753ddeSHong Zhang ierr = MatMPIDenseScatter(A,B,0,C,&workB);CHKERRQ(ierr); 706f32d5d43SBarry Smith 707f32d5d43SBarry Smith /* off-diagonal block of A times nonlocal rows of B */ 708f32d5d43SBarry Smith ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cdense->A);CHKERRQ(ierr); 709*87753ddeSHong Zhang 710*87753ddeSHong Zhang } else { 711*87753ddeSHong Zhang const PetscScalar *barray; 712*87753ddeSHong Zhang PetscScalar *carray; 713*87753ddeSHong Zhang Mat Bb=contents->Bb,Cb=contents->Cb; 714*87753ddeSHong Zhang PetscInt BbN=Bb->cmap->N,start,i; 715*87753ddeSHong Zhang 716*87753ddeSHong Zhang ierr = MatDenseGetArrayRead(B,&barray);CHKERRQ(ierr); 717*87753ddeSHong Zhang ierr = MatDenseGetArray(C,&carray);CHKERRQ(ierr); 718*87753ddeSHong Zhang for (i=0; i<numBb; i++) { 719*87753ddeSHong Zhang start = i*BbN; 720*87753ddeSHong Zhang ierr = MatMatMultNumeric_MPIAIJ_MPIDense_private(A,Bb,0,start,C,barray,carray,Cb);CHKERRQ(ierr); 721*87753ddeSHong Zhang } 722*87753ddeSHong Zhang 723*87753ddeSHong Zhang if (contents->Bb1) { 724*87753ddeSHong Zhang Bb = contents->Bb1; Cb = contents->Cb1; 725*87753ddeSHong Zhang start = i*BbN; 726*87753ddeSHong Zhang ierr = MatMatMultNumeric_MPIAIJ_MPIDense_private(A,Bb,1,start,C,barray,carray,Cb);CHKERRQ(ierr); 727*87753ddeSHong Zhang } 728*87753ddeSHong Zhang ierr = MatDenseRestoreArrayRead(B,&barray);CHKERRQ(ierr); 729*87753ddeSHong Zhang ierr = MatDenseRestoreArray(C,&carray);CHKERRQ(ierr); 730*87753ddeSHong Zhang } 7319123193aSHong Zhang PetscFunctionReturn(0); 7329123193aSHong Zhang } 733cf1a0672SHong Zhang 734f8efd71cSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ(Mat A,Mat P,Mat C) 7351634b032SHong Zhang { 7361634b032SHong Zhang PetscErrorCode ierr; 737cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 738cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 739cf1a0672SHong Zhang Mat_SeqAIJ *cd = (Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 740cf1a0672SHong Zhang PetscInt *adi = ad->i,*adj,*aoi=ao->i,*aoj; 741cf1a0672SHong Zhang PetscScalar *ada,*aoa,*cda=cd->a,*coa=co->a; 742cf1a0672SHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 743cf1a0672SHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj; 74429825010SHong Zhang PetscScalar *pa_loc,*pa_oth,*pa,valtmp,*ca; 74529825010SHong Zhang PetscInt cm = C->rmap->n,anz,pnz; 7463cdca5ebSHong Zhang Mat_APMPI *ptap = c->ap; 74780da8df7SHong Zhang PetscScalar *apa_sparse; 748cf1a0672SHong Zhang PetscInt *api,*apj,*apJ,i,j,k,row; 74929825010SHong Zhang PetscInt cstart = C->cmap->rstart; 75029825010SHong Zhang PetscInt cdnz,conz,k0,k1,nextp; 751a7c7454dSHong Zhang MPI_Comm comm; 752a7c7454dSHong Zhang PetscMPIInt size; 7531634b032SHong Zhang 7541634b032SHong Zhang PetscFunctionBegin; 75580da8df7SHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 756a7c7454dSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 757a7c7454dSHong Zhang 758fa2a5dcfSHong Zhang if (!ptap->P_oth && size>1) { 75980da8df7SHong Zhang SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"AP cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'"); 76080da8df7SHong Zhang } 76180da8df7SHong Zhang apa_sparse = ptap->apa; 76280da8df7SHong Zhang 763cf1a0672SHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 764cf1a0672SHong Zhang /*-----------------------------------------------------*/ 765cf1a0672SHong Zhang /* update numerical values of P_oth and P_loc */ 766b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 767cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 768cf1a0672SHong Zhang 769cf1a0672SHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 770cf1a0672SHong Zhang /*----------------------------------------------------------*/ 771cf1a0672SHong Zhang /* get data from symbolic products */ 772cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 773cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; pa_loc = p_loc->a; 774a7c7454dSHong Zhang if (size >1) { 775a7c7454dSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 776cf1a0672SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; pa_oth = p_oth->a; 77720e3dc75SHong Zhang } else { 77820e3dc75SHong Zhang p_oth = NULL; pi_oth = NULL; pj_oth = NULL; pa_oth = NULL; 779a7c7454dSHong Zhang } 780cf1a0672SHong Zhang 78129825010SHong Zhang api = ptap->api; 78229825010SHong Zhang apj = ptap->apj; 783cf1a0672SHong Zhang for (i=0; i<cm; i++) { 78429825010SHong Zhang apJ = apj + api[i]; 78529825010SHong Zhang 786cf1a0672SHong Zhang /* diagonal portion of A */ 787cf1a0672SHong Zhang anz = adi[i+1] - adi[i]; 788cf1a0672SHong Zhang adj = ad->j + adi[i]; 789cf1a0672SHong Zhang ada = ad->a + adi[i]; 790cf1a0672SHong Zhang for (j=0; j<anz; j++) { 791cf1a0672SHong Zhang row = adj[j]; 792cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 793cf1a0672SHong Zhang pj = pj_loc + pi_loc[row]; 794cf1a0672SHong Zhang pa = pa_loc + pi_loc[row]; 79529825010SHong Zhang /* perform sparse axpy */ 796cf1a0672SHong Zhang valtmp = ada[j]; 79729825010SHong Zhang nextp = 0; 79829825010SHong Zhang for (k=0; nextp<pnz; k++) { 79929825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 80029825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 80129825010SHong Zhang } 8021634b032SHong Zhang } 803cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 804cf1a0672SHong Zhang } 8051634b032SHong Zhang 806cf1a0672SHong Zhang /* off-diagonal portion of A */ 807cf1a0672SHong Zhang anz = aoi[i+1] - aoi[i]; 808cf1a0672SHong Zhang aoj = ao->j + aoi[i]; 809cf1a0672SHong Zhang aoa = ao->a + aoi[i]; 810cf1a0672SHong Zhang for (j=0; j<anz; j++) { 811cf1a0672SHong Zhang row = aoj[j]; 812cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 813cf1a0672SHong Zhang pj = pj_oth + pi_oth[row]; 814cf1a0672SHong Zhang pa = pa_oth + pi_oth[row]; 81529825010SHong Zhang /* perform sparse axpy */ 816cf1a0672SHong Zhang valtmp = aoa[j]; 81729825010SHong Zhang nextp = 0; 81829825010SHong Zhang for (k=0; nextp<pnz; k++) { 81929825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 82029825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 82129825010SHong Zhang } 822cf1a0672SHong Zhang } 823cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 824cf1a0672SHong Zhang } 8251634b032SHong Zhang 826cf1a0672SHong Zhang /* set values in C */ 827cf1a0672SHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 828cf1a0672SHong Zhang conz = co->i[i+1] - co->i[i]; 8291634b032SHong Zhang 830cf1a0672SHong Zhang /* 1st off-diagoanl part of C */ 831cf1a0672SHong Zhang ca = coa + co->i[i]; 832cf1a0672SHong Zhang k = 0; 833cf1a0672SHong Zhang for (k0=0; k0<conz; k0++) { 834cf1a0672SHong Zhang if (apJ[k] >= cstart) break; 83529825010SHong Zhang ca[k0] = apa_sparse[k]; 83629825010SHong Zhang apa_sparse[k] = 0.0; 837cf1a0672SHong Zhang k++; 838cf1a0672SHong Zhang } 8391634b032SHong Zhang 840cf1a0672SHong Zhang /* diagonal part of C */ 841cf1a0672SHong Zhang ca = cda + cd->i[i]; 842cf1a0672SHong Zhang for (k1=0; k1<cdnz; k1++) { 84329825010SHong Zhang ca[k1] = apa_sparse[k]; 84429825010SHong Zhang apa_sparse[k] = 0.0; 845cf1a0672SHong Zhang k++; 846cf1a0672SHong Zhang } 847cf1a0672SHong Zhang 848cf1a0672SHong Zhang /* 2nd off-diagoanl part of C */ 849cf1a0672SHong Zhang ca = coa + co->i[i]; 850cf1a0672SHong Zhang for (; k0<conz; k0++) { 85129825010SHong Zhang ca[k0] = apa_sparse[k]; 85229825010SHong Zhang apa_sparse[k] = 0.0; 853cf1a0672SHong Zhang k++; 854cf1a0672SHong Zhang } 855cf1a0672SHong Zhang } 856cf1a0672SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 857cf1a0672SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 85880da8df7SHong Zhang 8597d0a89b7SHong Zhang if (ptap->freestruct) { 86080da8df7SHong Zhang ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr); 86180da8df7SHong Zhang } 862cf1a0672SHong Zhang PetscFunctionReturn(0); 863cf1a0672SHong Zhang } 864cf1a0672SHong Zhang 8650fc8cf34SHong Zhang /* same as MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(), except using LLCondensed to avoid O(BN) memory requirement */ 866b2405163SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat *C) 867cf1a0672SHong Zhang { 868cf1a0672SHong Zhang PetscErrorCode ierr; 869ce94432eSBarry Smith MPI_Comm comm; 870a7c7454dSHong Zhang PetscMPIInt size; 871cf1a0672SHong Zhang Mat Cmpi; 8723cdca5ebSHong Zhang Mat_APMPI *ptap; 8730298fd71SBarry Smith PetscFreeSpaceList free_space = NULL,current_space=NULL; 874cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c; 875cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 8767dbaa2c6Sandi selinger PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 877cf1a0672SHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 8788a210135Sandi selinger PetscInt i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi,*lnk,apnz_max=0; 879e5ab8c0aSKarl Rupp PetscInt am=A->rmap->n,pn=P->cmap->n,pm=P->rmap->n,lsize=pn+20; 880cf1a0672SHong Zhang PetscReal afill; 881b92f168fSBarry Smith MatType mtype; 882cf1a0672SHong Zhang 883cf1a0672SHong Zhang PetscFunctionBegin; 884ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 885a7c7454dSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 886a7c7454dSHong Zhang 8873cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 888b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 889cf1a0672SHong Zhang 890cf1a0672SHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 891b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 89219f0e57aSHong Zhang 893cf1a0672SHong Zhang /* get P_loc by taking all local rows of P */ 894cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 895cf1a0672SHong Zhang 896cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 897cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 898a7c7454dSHong Zhang if (size > 1) { 899a7c7454dSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 90020e3dc75SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 901968382fdSHong Zhang } else { 90220e3dc75SHong Zhang p_oth = NULL; 90320e3dc75SHong Zhang pi_oth = NULL; pj_oth = NULL; 904a7c7454dSHong Zhang } 905cf1a0672SHong Zhang 906cf1a0672SHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 907cf1a0672SHong Zhang /*-------------------------------------------------------------------*/ 908854ce69bSBarry Smith ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 909cf1a0672SHong Zhang ptap->api = api; 910cf1a0672SHong Zhang api[0] = 0; 911cf1a0672SHong Zhang 9128a210135Sandi selinger ierr = PetscLLCondensedCreate_Scalable(lsize,&lnk);CHKERRQ(ierr); 913cf1a0672SHong Zhang 914cf1a0672SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 915f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space);CHKERRQ(ierr); 916cf1a0672SHong Zhang current_space = free_space; 917cf1a0672SHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 918cf1a0672SHong Zhang for (i=0; i<am; i++) { 919cf1a0672SHong Zhang /* diagonal portion of A */ 920cf1a0672SHong Zhang nzi = adi[i+1] - adi[i]; 921cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 922cf1a0672SHong Zhang row = *adj++; 923cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 924cf1a0672SHong Zhang Jptr = pj_loc + pi_loc[row]; 9258a210135Sandi selinger /* Expand list if it is not long enough */ 9268328dd82Sandi selinger if (pnz+apnz_max > lsize) { 9278328dd82Sandi selinger lsize = pnz+apnz_max; 92826465080Sandi selinger ierr = PetscLLCondensedExpand_Scalable(lsize, &lnk);CHKERRQ(ierr); 9298a210135Sandi selinger } 930cf1a0672SHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 931f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 9328a210135Sandi selinger apnz = *lnk; /* The first element in the list is the number of items in the list */ 9338a210135Sandi selinger api[i+1] = api[i] + apnz; 9348a210135Sandi selinger if (apnz > apnz_max) apnz_max = apnz; 935cf1a0672SHong Zhang } 936cf1a0672SHong Zhang /* off-diagonal portion of A */ 937cf1a0672SHong Zhang nzi = aoi[i+1] - aoi[i]; 938cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 939cf1a0672SHong Zhang row = *aoj++; 940cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 941cf1a0672SHong Zhang Jptr = pj_oth + pi_oth[row]; 9428a210135Sandi selinger /* Expand list if it is not long enough */ 9438328dd82Sandi selinger if (pnz+apnz_max > lsize) { 9448328dd82Sandi selinger lsize = pnz + apnz_max; 94526465080Sandi selinger ierr = PetscLLCondensedExpand_Scalable(lsize, &lnk);CHKERRQ(ierr); 9468a210135Sandi selinger } 9478a210135Sandi selinger /* add non-zero cols of P into the sorted linked list lnk */ 948f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 9498a210135Sandi selinger apnz = *lnk; /* The first element in the list is the number of items in the list */ 9508a210135Sandi selinger api[i+1] = api[i] + apnz; 9518a210135Sandi selinger if (apnz > apnz_max) apnz_max = apnz; 952cf1a0672SHong Zhang } 953f84c536bSHong Zhang apnz = *lnk; 954cf1a0672SHong Zhang api[i+1] = api[i] + apnz; 9558a210135Sandi selinger if (apnz > apnz_max) apnz_max = apnz; 956cf1a0672SHong Zhang 957cf1a0672SHong Zhang /* if free space is not available, double the total space in the list */ 958cf1a0672SHong Zhang if (current_space->local_remaining<apnz) { 959f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 960cf1a0672SHong Zhang nspacedouble++; 961cf1a0672SHong Zhang } 962cf1a0672SHong Zhang 963cf1a0672SHong Zhang /* Copy data into free space, then initialize lnk */ 964f84c536bSHong Zhang ierr = PetscLLCondensedClean_Scalable(apnz,current_space->array,lnk);CHKERRQ(ierr); 965cf1a0672SHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 9662205254eSKarl Rupp 967cf1a0672SHong Zhang current_space->array += apnz; 968cf1a0672SHong Zhang current_space->local_used += apnz; 969cf1a0672SHong Zhang current_space->local_remaining -= apnz; 970cf1a0672SHong Zhang } 971cf1a0672SHong Zhang 972cf1a0672SHong Zhang /* Allocate space for apj, initialize apj, and */ 973cf1a0672SHong Zhang /* destroy list of free space and other temporary array(s) */ 974854ce69bSBarry Smith ierr = PetscMalloc1(api[am]+1,&ptap->apj);CHKERRQ(ierr); 975cf1a0672SHong Zhang apj = ptap->apj; 976cf1a0672SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 977f84c536bSHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 978cf1a0672SHong Zhang 979cf1a0672SHong Zhang /* create and assemble symbolic parallel matrix Cmpi */ 980cf1a0672SHong Zhang /*----------------------------------------------------*/ 981cf1a0672SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 982cf1a0672SHong Zhang ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 98333d57670SJed Brown ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr); 984b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 985b92f168fSBarry Smith ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr); 986cf1a0672SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 987cf1a0672SHong Zhang 98829825010SHong Zhang /* malloc apa for assembly Cmpi */ 989071fcb05SBarry Smith ierr = PetscCalloc1(apnz_max,&ptap->apa);CHKERRQ(ierr); 99017f75172Sandi selinger 991904d1e70Sandi selinger ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat_Symbolic(Cmpi, apj, api);CHKERRQ(ierr); 992cf1a0672SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 993cf1a0672SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 9947dbaa2c6Sandi selinger ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 995cf1a0672SHong Zhang 996cf1a0672SHong Zhang ptap->destroy = Cmpi->ops->destroy; 997cf1a0672SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 998f8efd71cSHong Zhang Cmpi->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ; 999cf1a0672SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_MatMatMult; 10004624976aSHong Zhang Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP; 1001cf1a0672SHong Zhang 1002cf1a0672SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 1003cf1a0672SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 10043cdca5ebSHong Zhang c->ap = ptap; 1005cf1a0672SHong Zhang *C = Cmpi; 1006cf1a0672SHong Zhang 1007cf1a0672SHong Zhang /* set MatInfo */ 1008118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 1009cf1a0672SHong Zhang if (afill < 1.0) afill = 1.0; 1010cf1a0672SHong Zhang Cmpi->info.mallocs = nspacedouble; 1011cf1a0672SHong Zhang Cmpi->info.fill_ratio_given = fill; 1012cf1a0672SHong Zhang Cmpi->info.fill_ratio_needed = afill; 1013cf1a0672SHong Zhang 1014cf1a0672SHong Zhang #if defined(PETSC_USE_INFO) 1015cf1a0672SHong Zhang if (api[am]) { 101657622a8eSBarry Smith ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 101757622a8eSBarry Smith ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 1018cf1a0672SHong Zhang } else { 1019cf1a0672SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 1020cf1a0672SHong Zhang } 1021cf1a0672SHong Zhang #endif 10221634b032SHong Zhang PetscFunctionReturn(0); 10231634b032SHong Zhang } 1024f96d37fcSHong Zhang 1025a9d7e0ccSandi selinger /* This function is needed for the seqMPI matrix-matrix multiplication. */ 1026a9d7e0ccSandi selinger /* Three input arrays are merged to one output array. The size of the */ 1027a9d7e0ccSandi selinger /* output array is also output. Duplicate entries only show up once. */ 1028a9d7e0ccSandi selinger static void Merge3SortedArrays(PetscInt size1, PetscInt *in1, 1029a9d7e0ccSandi selinger PetscInt size2, PetscInt *in2, 1030a9d7e0ccSandi selinger PetscInt size3, PetscInt *in3, 1031a9d7e0ccSandi selinger PetscInt *size4, PetscInt *out) 1032a9d7e0ccSandi selinger { 1033a9d7e0ccSandi selinger int i = 0, j = 0, k = 0, l = 0; 1034a9d7e0ccSandi selinger 1035a9d7e0ccSandi selinger /* Traverse all three arrays */ 1036a9d7e0ccSandi selinger while (i<size1 && j<size2 && k<size3) { 1037a9d7e0ccSandi selinger if (in1[i] < in2[j] && in1[i] < in3[k]) { 1038a9d7e0ccSandi selinger out[l++] = in1[i++]; 1039a9d7e0ccSandi selinger } 1040a9d7e0ccSandi selinger else if(in2[j] < in1[i] && in2[j] < in3[k]) { 1041a9d7e0ccSandi selinger out[l++] = in2[j++]; 1042a9d7e0ccSandi selinger } 1043a9d7e0ccSandi selinger else if(in3[k] < in1[i] && in3[k] < in2[j]) { 1044a9d7e0ccSandi selinger out[l++] = in3[k++]; 1045a9d7e0ccSandi selinger } 1046a9d7e0ccSandi selinger else if(in1[i] == in2[j] && in1[i] < in3[k]) { 1047a9d7e0ccSandi selinger out[l++] = in1[i]; 1048a9d7e0ccSandi selinger i++, j++; 1049a9d7e0ccSandi selinger } 1050a9d7e0ccSandi selinger else if(in1[i] == in3[k] && in1[i] < in2[j]) { 1051a9d7e0ccSandi selinger out[l++] = in1[i]; 1052a9d7e0ccSandi selinger i++, k++; 1053a9d7e0ccSandi selinger } 1054a9d7e0ccSandi selinger else if(in3[k] == in2[j] && in2[j] < in1[i]) { 1055a9d7e0ccSandi selinger out[l++] = in2[j]; 1056a9d7e0ccSandi selinger k++, j++; 1057a9d7e0ccSandi selinger } 1058a9d7e0ccSandi selinger else if(in1[i] == in2[j] && in1[i] == in3[k]) { 1059a9d7e0ccSandi selinger out[l++] = in1[i]; 1060a9d7e0ccSandi selinger i++, j++, k++; 1061a9d7e0ccSandi selinger } 1062a9d7e0ccSandi selinger } 1063a9d7e0ccSandi selinger 1064a9d7e0ccSandi selinger /* Traverse two remaining arrays */ 1065a9d7e0ccSandi selinger while (i<size1 && j<size2) { 1066a9d7e0ccSandi selinger if (in1[i] < in2[j]) { 1067a9d7e0ccSandi selinger out[l++] = in1[i++]; 1068a9d7e0ccSandi selinger } 1069a9d7e0ccSandi selinger else if(in1[i] > in2[j]) { 1070a9d7e0ccSandi selinger out[l++] = in2[j++]; 1071a9d7e0ccSandi selinger } 1072a9d7e0ccSandi selinger else { 1073a9d7e0ccSandi selinger out[l++] = in1[i]; 1074a9d7e0ccSandi selinger i++, j++; 1075a9d7e0ccSandi selinger } 1076a9d7e0ccSandi selinger } 1077a9d7e0ccSandi selinger 1078a9d7e0ccSandi selinger while (i<size1 && k<size3) { 1079a9d7e0ccSandi selinger if (in1[i] < in3[k]) { 1080a9d7e0ccSandi selinger out[l++] = in1[i++]; 1081a9d7e0ccSandi selinger } 1082a9d7e0ccSandi selinger else if(in1[i] > in3[k]) { 1083a9d7e0ccSandi selinger out[l++] = in3[k++]; 1084a9d7e0ccSandi selinger } 1085a9d7e0ccSandi selinger else { 1086a9d7e0ccSandi selinger out[l++] = in1[i]; 1087a9d7e0ccSandi selinger i++, k++; 1088a9d7e0ccSandi selinger } 1089a9d7e0ccSandi selinger } 1090a9d7e0ccSandi selinger 1091a9d7e0ccSandi selinger while (k<size3 && j<size2) { 1092a9d7e0ccSandi selinger if (in3[k] < in2[j]) { 1093a9d7e0ccSandi selinger out[l++] = in3[k++]; 1094a9d7e0ccSandi selinger } 1095a9d7e0ccSandi selinger else if(in3[k] > in2[j]) { 1096a9d7e0ccSandi selinger out[l++] = in2[j++]; 1097a9d7e0ccSandi selinger } 1098a9d7e0ccSandi selinger else { 1099a9d7e0ccSandi selinger out[l++] = in3[k]; 1100a9d7e0ccSandi selinger k++, j++; 1101a9d7e0ccSandi selinger } 1102a9d7e0ccSandi selinger } 1103a9d7e0ccSandi selinger 1104a9d7e0ccSandi selinger /* Traverse one remaining array */ 1105a9d7e0ccSandi selinger while (i<size1) out[l++] = in1[i++]; 1106a9d7e0ccSandi selinger while (j<size2) out[l++] = in2[j++]; 1107a9d7e0ccSandi selinger while (k<size3) out[l++] = in3[k++]; 1108a9d7e0ccSandi selinger 1109a9d7e0ccSandi selinger *size4 = l; 1110a9d7e0ccSandi selinger } 1111a9d7e0ccSandi selinger 111273b67375Sandi selinger /* This matrix-matrix multiplication algorithm divides the multiplication into three multiplications and */ 111373b67375Sandi selinger /* adds up the products. Two of these three multiplications are performed with existing (sequential) */ 111473b67375Sandi selinger /* matrix-matrix multiplications. */ 1115a9d7e0ccSandi selinger PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_seqMPI(Mat A, Mat P, PetscReal fill, Mat *C) 1116a9d7e0ccSandi selinger { 1117a9d7e0ccSandi selinger PetscErrorCode ierr; 1118a9d7e0ccSandi selinger MPI_Comm comm; 1119a9d7e0ccSandi selinger PetscMPIInt size; 1120a9d7e0ccSandi selinger Mat Cmpi; 11213cdca5ebSHong Zhang Mat_APMPI *ptap; 1122a9d7e0ccSandi selinger PetscFreeSpaceList free_space_diag=NULL, current_space=NULL; 1123a9d7e0ccSandi selinger Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data; 1124a9d7e0ccSandi selinger Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc; 1125a9d7e0ccSandi selinger Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data; 1126a9d7e0ccSandi selinger Mat_MPIAIJ *c; 1127a9d7e0ccSandi selinger Mat_SeqAIJ *adpd_seq, *p_off, *aopoth_seq; 1128a9d7e0ccSandi selinger PetscInt adponz, adpdnz; 11297dbaa2c6Sandi selinger PetscInt *pi_loc,*dnz,*onz; 1130a9d7e0ccSandi selinger PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,rstart=A->rmap->rstart; 1131a9d7e0ccSandi selinger PetscInt *lnk,i, i1=0,pnz,row,*adpoi,*adpoj, *api, *adpoJ, *aopJ, *apJ,*Jptr, aopnz, nspacedouble=0,j,nzi, 1132a9d7e0ccSandi selinger *apj,apnz, *adpdi, *adpdj, *adpdJ, *poff_i, *poff_j, *j_temp, *aopothi, *aopothj; 1133a016958eSandi selinger PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n, p_colstart, p_colend; 1134a9d7e0ccSandi selinger PetscBT lnkbt; 1135a9d7e0ccSandi selinger PetscReal afill; 1136a9d7e0ccSandi selinger PetscMPIInt rank; 1137a9d7e0ccSandi selinger Mat adpd, aopoth; 1138b92f168fSBarry Smith MatType mtype; 1139e83e5f86SFande Kong const char *prefix; 1140a9d7e0ccSandi selinger 1141a9d7e0ccSandi selinger PetscFunctionBegin; 1142a9d7e0ccSandi selinger ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1143a9d7e0ccSandi selinger ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 114473b67375Sandi selinger ierr = MPI_Comm_rank(comm, &rank);CHKERRQ(ierr); 1145a016958eSandi selinger ierr = MatGetOwnershipRangeColumn(P, &p_colstart, &p_colend); CHKERRQ(ierr); 1146a9d7e0ccSandi selinger 11473cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 1148a9d7e0ccSandi selinger ierr = PetscNew(&ptap);CHKERRQ(ierr); 1149a9d7e0ccSandi selinger 1150a9d7e0ccSandi selinger /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 1151a9d7e0ccSandi selinger ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 1152a9d7e0ccSandi selinger 1153a9d7e0ccSandi selinger /* get P_loc by taking all local rows of P */ 1154a9d7e0ccSandi selinger ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 1155a9d7e0ccSandi selinger 1156a9d7e0ccSandi selinger 1157a9d7e0ccSandi selinger p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 1158a9d7e0ccSandi selinger pi_loc = p_loc->i; 1159a9d7e0ccSandi selinger 1160a9d7e0ccSandi selinger /* Allocate memory for the i arrays of the matrices A*P, A_diag*P_off and A_offd * P */ 1161a9d7e0ccSandi selinger ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 1162a9d7e0ccSandi selinger ierr = PetscMalloc1(am+2,&adpoi);CHKERRQ(ierr); 1163a9d7e0ccSandi selinger 1164a9d7e0ccSandi selinger adpoi[0] = 0; 1165a9d7e0ccSandi selinger ptap->api = api; 1166a9d7e0ccSandi selinger api[0] = 0; 1167a9d7e0ccSandi selinger 1168a9d7e0ccSandi selinger /* create and initialize a linked list, will be used for both A_diag * P_loc_off and A_offd * P_oth */ 1169a9d7e0ccSandi selinger ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr); 1170a9d7e0ccSandi selinger ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 1171a9d7e0ccSandi selinger 1172a9d7e0ccSandi selinger /* Symbolic calc of A_loc_diag * P_loc_diag */ 1173e83e5f86SFande Kong ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr); 1174e83e5f86SFande Kong ierr = MatSetOptionsPrefix(a->A,prefix);CHKERRQ(ierr); 1175e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(a->A,"inner_diag_");CHKERRQ(ierr); 117673b67375Sandi selinger ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(a->A, p->A, fill, &adpd);CHKERRQ(ierr); 1177a9d7e0ccSandi selinger adpd_seq = (Mat_SeqAIJ*)((adpd)->data); 1178a9d7e0ccSandi selinger adpdi = adpd_seq->i; adpdj = adpd_seq->j; 1179a9d7e0ccSandi selinger p_off = (Mat_SeqAIJ*)((p->B)->data); 1180a9d7e0ccSandi selinger poff_i = p_off->i; poff_j = p_off->j; 1181a9d7e0ccSandi selinger 118273b67375Sandi selinger /* j_temp stores indices of a result row before they are added to the linked list */ 1183a9d7e0ccSandi selinger ierr = PetscMalloc1(pN+2,&j_temp);CHKERRQ(ierr); 1184a9d7e0ccSandi selinger 1185a9d7e0ccSandi selinger 1186a9d7e0ccSandi selinger /* Symbolic calc of the A_diag * p_loc_off */ 1187a9d7e0ccSandi selinger /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 1188a9d7e0ccSandi selinger ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space_diag);CHKERRQ(ierr); 1189a9d7e0ccSandi selinger current_space = free_space_diag; 1190a9d7e0ccSandi selinger 1191a9d7e0ccSandi selinger for (i=0; i<am; i++) { 1192a9d7e0ccSandi selinger /* A_diag * P_loc_off */ 1193a9d7e0ccSandi selinger nzi = adi[i+1] - adi[i]; 1194a9d7e0ccSandi selinger for (j=0; j<nzi; j++) { 1195a9d7e0ccSandi selinger row = *adj++; 1196a9d7e0ccSandi selinger pnz = poff_i[row+1] - poff_i[row]; 1197a9d7e0ccSandi selinger Jptr = poff_j + poff_i[row]; 1198a9d7e0ccSandi selinger for(i1 = 0; i1 < pnz; i1++) { 1199a9d7e0ccSandi selinger j_temp[i1] = p->garray[Jptr[i1]]; 1200a9d7e0ccSandi selinger } 1201a9d7e0ccSandi selinger /* add non-zero cols of P into the sorted linked list lnk */ 1202a9d7e0ccSandi selinger ierr = PetscLLCondensedAddSorted(pnz,j_temp,lnk,lnkbt);CHKERRQ(ierr); 1203a9d7e0ccSandi selinger } 1204a9d7e0ccSandi selinger 1205a9d7e0ccSandi selinger adponz = lnk[0]; 1206a9d7e0ccSandi selinger adpoi[i+1] = adpoi[i] + adponz; 1207a9d7e0ccSandi selinger 1208a9d7e0ccSandi selinger /* if free space is not available, double the total space in the list */ 1209a9d7e0ccSandi selinger if (current_space->local_remaining<adponz) { 1210a9d7e0ccSandi selinger ierr = PetscFreeSpaceGet(PetscIntSumTruncate(adponz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 1211a9d7e0ccSandi selinger nspacedouble++; 1212a9d7e0ccSandi selinger } 1213a9d7e0ccSandi selinger 1214a9d7e0ccSandi selinger /* Copy data into free space, then initialize lnk */ 1215a9d7e0ccSandi selinger ierr = PetscLLCondensedClean(pN,adponz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1216a9d7e0ccSandi selinger 1217a9d7e0ccSandi selinger current_space->array += adponz; 1218a9d7e0ccSandi selinger current_space->local_used += adponz; 1219a9d7e0ccSandi selinger current_space->local_remaining -= adponz; 1220a9d7e0ccSandi selinger } 1221a9d7e0ccSandi selinger 1222a9d7e0ccSandi selinger /* Symbolic calc of A_off * P_oth */ 1223e83e5f86SFande Kong ierr = MatSetOptionsPrefix(a->B,prefix);CHKERRQ(ierr); 1224e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(a->B,"inner_offdiag_");CHKERRQ(ierr); 122573b67375Sandi selinger ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(a->B, ptap->P_oth, fill, &aopoth);CHKERRQ(ierr); 1226a9d7e0ccSandi selinger aopoth_seq = (Mat_SeqAIJ*)((aopoth)->data); 1227a9d7e0ccSandi selinger aopothi = aopoth_seq->i; aopothj = aopoth_seq->j; 1228a9d7e0ccSandi selinger 1229a9d7e0ccSandi selinger /* Allocate space for apj, adpj, aopj, ... */ 1230a9d7e0ccSandi selinger /* destroy lists of free space and other temporary array(s) */ 1231a9d7e0ccSandi selinger 1232a9d7e0ccSandi selinger ierr = PetscMalloc1(aopothi[am] + adpoi[am] + adpdi[am]+2, &ptap->apj);CHKERRQ(ierr); 1233a9d7e0ccSandi selinger ierr = PetscMalloc1(adpoi[am]+2, &adpoj);CHKERRQ(ierr); 1234a9d7e0ccSandi selinger 1235a9d7e0ccSandi selinger /* Copy from linked list to j-array */ 1236a9d7e0ccSandi selinger ierr = PetscFreeSpaceContiguous(&free_space_diag,adpoj);CHKERRQ(ierr); 1237a9d7e0ccSandi selinger ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 1238a9d7e0ccSandi selinger 1239a9d7e0ccSandi selinger adpoJ = adpoj; 1240a9d7e0ccSandi selinger adpdJ = adpdj; 1241a9d7e0ccSandi selinger aopJ = aopothj; 1242a9d7e0ccSandi selinger apj = ptap->apj; 1243a9d7e0ccSandi selinger apJ = apj; /* still empty */ 1244a9d7e0ccSandi selinger 1245a9d7e0ccSandi selinger /* Merge j-arrays of A_off * P, A_diag * P_loc_off, and */ 1246a9d7e0ccSandi selinger /* A_diag * P_loc_diag to get A*P */ 1247a9d7e0ccSandi selinger for (i = 0; i < am; i++) { 1248a9d7e0ccSandi selinger aopnz = aopothi[i+1] - aopothi[i]; 1249a9d7e0ccSandi selinger adponz = adpoi[i+1] - adpoi[i]; 1250a9d7e0ccSandi selinger adpdnz = adpdi[i+1] - adpdi[i]; 1251a9d7e0ccSandi selinger 1252a9d7e0ccSandi selinger /* Correct indices from A_diag*P_diag */ 1253a9d7e0ccSandi selinger for(i1 = 0; i1 < adpdnz; i1++) { 1254a016958eSandi selinger adpdJ[i1] += p_colstart; 1255a9d7e0ccSandi selinger } 1256a9d7e0ccSandi selinger /* Merge j-arrays of A_diag * P_loc_off and A_diag * P_loc_diag and A_off * P_oth */ 1257a9d7e0ccSandi selinger Merge3SortedArrays(adponz, adpoJ, adpdnz, adpdJ, aopnz, aopJ, &apnz, apJ); 1258a9d7e0ccSandi selinger ierr = MatPreallocateSet(i+rstart, apnz, apJ, dnz, onz); CHKERRQ(ierr); 1259a9d7e0ccSandi selinger 1260a9d7e0ccSandi selinger aopJ += aopnz; 1261a9d7e0ccSandi selinger adpoJ += adponz; 1262a9d7e0ccSandi selinger adpdJ += adpdnz; 1263a9d7e0ccSandi selinger apJ += apnz; 1264a9d7e0ccSandi selinger api[i+1] = api[i] + apnz; 1265a9d7e0ccSandi selinger } 1266a9d7e0ccSandi selinger 1267a9d7e0ccSandi selinger /* malloc apa to store dense row A[i,:]*P */ 1268071fcb05SBarry Smith ierr = PetscCalloc1(pN+2,&ptap->apa);CHKERRQ(ierr); 1269a9d7e0ccSandi selinger 1270a9d7e0ccSandi selinger /* create and assemble symbolic parallel matrix Cmpi */ 1271a9d7e0ccSandi selinger ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 1272a9d7e0ccSandi selinger ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 1273a9d7e0ccSandi selinger ierr = MatSetBlockSizesFromMats(Cmpi,A,P);CHKERRQ(ierr); 1274b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 1275b92f168fSBarry Smith ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr); 1276a9d7e0ccSandi selinger ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 127717f75172Sandi selinger 127817f75172Sandi selinger 1279904d1e70Sandi selinger ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat_Symbolic(Cmpi, apj, api);CHKERRQ(ierr); 1280a9d7e0ccSandi selinger ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1281a9d7e0ccSandi selinger ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 12827dbaa2c6Sandi selinger ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1283a9d7e0ccSandi selinger 128417f75172Sandi selinger 1285a9d7e0ccSandi selinger ptap->destroy = Cmpi->ops->destroy; 1286a9d7e0ccSandi selinger ptap->duplicate = Cmpi->ops->duplicate; 1287a9d7e0ccSandi selinger Cmpi->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 1288a9d7e0ccSandi selinger Cmpi->ops->destroy = MatDestroy_MPIAIJ_MatMatMult; 1289a9d7e0ccSandi selinger 1290a9d7e0ccSandi selinger /* attach the supporting struct to Cmpi for reuse */ 1291a9d7e0ccSandi selinger c = (Mat_MPIAIJ*)Cmpi->data; 12923cdca5ebSHong Zhang c->ap = ptap; 1293a9d7e0ccSandi selinger *C = Cmpi; 1294a9d7e0ccSandi selinger 1295a9d7e0ccSandi selinger /* set MatInfo */ 129673b67375Sandi selinger afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 129773b67375Sandi selinger if (afill < 1.0) afill = 1.0; 1298a9d7e0ccSandi selinger Cmpi->info.mallocs = nspacedouble; 1299a9d7e0ccSandi selinger Cmpi->info.fill_ratio_given = fill; 1300a9d7e0ccSandi selinger Cmpi->info.fill_ratio_needed = afill; 1301a9d7e0ccSandi selinger 1302a9d7e0ccSandi selinger #if defined(PETSC_USE_INFO) 1303a9d7e0ccSandi selinger if (api[am]) { 1304a9d7e0ccSandi selinger ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 1305a9d7e0ccSandi selinger ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 1306a9d7e0ccSandi selinger } else { 1307a9d7e0ccSandi selinger ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 1308a9d7e0ccSandi selinger } 1309a9d7e0ccSandi selinger #endif 1310a9d7e0ccSandi selinger 131173b67375Sandi selinger ierr = MatDestroy(&aopoth);CHKERRQ(ierr); 131273b67375Sandi selinger ierr = MatDestroy(&adpd);CHKERRQ(ierr); 131373b67375Sandi selinger ierr = PetscFree(j_temp);CHKERRQ(ierr); 131473b67375Sandi selinger ierr = PetscFree(adpoj);CHKERRQ(ierr); 131573b67375Sandi selinger ierr = PetscFree(adpoi);CHKERRQ(ierr); 1316a9d7e0ccSandi selinger PetscFunctionReturn(0); 1317a9d7e0ccSandi selinger } 1318a9d7e0ccSandi selinger 1319a9d7e0ccSandi selinger 1320f96d37fcSHong Zhang /*-------------------------------------------------------------------------*/ 1321c5af039cSHong Zhang PetscErrorCode MatTransposeMatMult_MPIAIJ_MPIAIJ(Mat P,Mat A,MatReuse scall,PetscReal fill,Mat *C) 1322f96d37fcSHong Zhang { 1323f96d37fcSHong Zhang PetscErrorCode ierr; 1324c216dbf3SHong Zhang const char *algTypes[3] = {"scalable","nonscalable","matmatmult"}; 13254ede91e3SHong Zhang PetscInt aN=A->cmap->N,alg=1; /* set default algorithm */ 13264ede91e3SHong Zhang PetscBool flg; 1327f96d37fcSHong Zhang 1328f96d37fcSHong Zhang PetscFunctionBegin; 1329c216dbf3SHong Zhang if (scall == MAT_INITIAL_MATRIX) { 1330715a5346SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)A),((PetscObject)A)->prefix,"MatTransposeMatMult","Mat");CHKERRQ(ierr); 13314ede91e3SHong Zhang ierr = PetscOptionsEList("-mattransposematmult_via","Algorithmic approach","MatTransposeMatMult",algTypes,3,algTypes[1],&alg,&flg);CHKERRQ(ierr); 1332c216dbf3SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 1333c216dbf3SHong Zhang 1334669e9c86SHong Zhang ierr = PetscLogEventBegin(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr); 1335c216dbf3SHong Zhang switch (alg) { 1336c216dbf3SHong Zhang case 1: 13374ede91e3SHong Zhang if (!flg && aN > 100000) { /* may switch to scalable algorithm as default */ 13384ede91e3SHong Zhang MatInfo Ainfo,Pinfo; 13394ede91e3SHong Zhang PetscInt nz_local; 13404ede91e3SHong Zhang PetscBool alg_scalable_loc=PETSC_FALSE,alg_scalable; 13414ede91e3SHong Zhang MPI_Comm comm; 13424ede91e3SHong Zhang 13434ede91e3SHong Zhang ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr); 13444ede91e3SHong Zhang ierr = MatGetInfo(P,MAT_LOCAL,&Pinfo);CHKERRQ(ierr); 13454ede91e3SHong Zhang nz_local = (PetscInt)(Ainfo.nz_allocated + Pinfo.nz_allocated); /* estimated local nonzero entries */ 13464ede91e3SHong Zhang 13474ede91e3SHong Zhang if (aN > fill*nz_local) alg_scalable_loc = PETSC_TRUE; 13484ede91e3SHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 13494ede91e3SHong Zhang ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr); 13504ede91e3SHong Zhang 13514ede91e3SHong Zhang if (alg_scalable) { 13524ede91e3SHong Zhang alg = 0; /* scalable algorithm would slower than nonscalable algorithm */ 13534ede91e3SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(P,A,fill,C);CHKERRQ(ierr); 13544ede91e3SHong Zhang break; 13554ede91e3SHong Zhang } 13564ede91e3SHong Zhang } 13572bbb1c24SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(P,A,fill,C);CHKERRQ(ierr); 1358c216dbf3SHong Zhang break; 1359c216dbf3SHong Zhang case 2: 1360275476c6SMatthew G. Knepley { 1361ab1b013aSHong Zhang Mat Pt; 13623cdca5ebSHong Zhang Mat_APMPI *ptap; 1363ab1b013aSHong Zhang Mat_MPIAIJ *c; 1364ab1b013aSHong Zhang ierr = MatTranspose(P,MAT_INITIAL_MATRIX,&Pt);CHKERRQ(ierr); 1365ab1b013aSHong Zhang ierr = MatMatMult(Pt,A,MAT_INITIAL_MATRIX,fill,C);CHKERRQ(ierr); 1366ab1b013aSHong Zhang c = (Mat_MPIAIJ*)(*C)->data; 13673cdca5ebSHong Zhang ptap = c->ap; 13687d0a89b7SHong Zhang if (ptap) { 1369ab1b013aSHong Zhang ptap->Pt = Pt; 137060552ceaSHong Zhang (*C)->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP; 13717d0a89b7SHong Zhang } 13727d0a89b7SHong Zhang (*C)->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult; 1373c216dbf3SHong Zhang PetscFunctionReturn(0); 1374275476c6SMatthew G. Knepley } 1375c216dbf3SHong Zhang break; 13764ede91e3SHong Zhang default: /* scalable algorithm */ 13776da69ca6SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(P,A,fill,C);CHKERRQ(ierr); 1378c216dbf3SHong Zhang break; 1379c216dbf3SHong Zhang } 1380669e9c86SHong Zhang ierr = PetscLogEventEnd(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr); 13817d0a89b7SHong Zhang 13827d0a89b7SHong Zhang { 13837d0a89b7SHong Zhang Mat_MPIAIJ *c = (Mat_MPIAIJ*)(*C)->data; 13847d0a89b7SHong Zhang Mat_APMPI *ap = c->ap; 13857d0a89b7SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)(*C)),((PetscObject)(*C))->prefix,"MatFreeIntermediateDataStructures","Mat");CHKERRQ(ierr); 13867d0a89b7SHong Zhang ap->freestruct = PETSC_FALSE; 13877d0a89b7SHong Zhang ierr = PetscOptionsBool("-mat_freeintermediatedatastructures","Free intermediate data structures", "MatFreeIntermediateDataStructures",ap->freestruct,&ap->freestruct, NULL);CHKERRQ(ierr); 13887d0a89b7SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 1389c216dbf3SHong Zhang } 13907d0a89b7SHong Zhang } 13917d0a89b7SHong Zhang 1392669e9c86SHong Zhang ierr = PetscLogEventBegin(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr); 1393c216dbf3SHong Zhang ierr = (*(*C)->ops->mattransposemultnumeric)(P,A,*C);CHKERRQ(ierr); 1394669e9c86SHong Zhang ierr = PetscLogEventEnd(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr); 1395ab1b013aSHong Zhang PetscFunctionReturn(0); 1396ab1b013aSHong Zhang } 1397ab1b013aSHong Zhang 1398c216dbf3SHong Zhang /* This routine only works when scall=MAT_REUSE_MATRIX! */ 1399c216dbf3SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult(Mat P,Mat A,Mat C) 1400c216dbf3SHong Zhang { 1401c216dbf3SHong Zhang PetscErrorCode ierr; 14022bbb1c24SHong Zhang Mat_MPIAIJ *c=(Mat_MPIAIJ*)C->data; 14033cdca5ebSHong Zhang Mat_APMPI *ptap= c->ap; 140460552ceaSHong Zhang Mat Pt; 1405c216dbf3SHong Zhang 1406c216dbf3SHong Zhang PetscFunctionBegin; 1407bb9bda99SHong Zhang if (!ptap->Pt) { 140860552ceaSHong Zhang MPI_Comm comm; 140960552ceaSHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 141060552ceaSHong Zhang SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtA cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'"); 141160552ceaSHong Zhang } 141260552ceaSHong Zhang 141360552ceaSHong Zhang Pt=ptap->Pt; 1414c216dbf3SHong Zhang ierr = MatTranspose(P,MAT_REUSE_MATRIX,&Pt);CHKERRQ(ierr); 1415c216dbf3SHong Zhang ierr = MatMatMultNumeric(Pt,A,C);CHKERRQ(ierr); 141660552ceaSHong Zhang 141760552ceaSHong Zhang /* supporting struct ptap consumes almost same amount of memory as C=PtAP, release it if C will not be updated by A and P */ 14187d0a89b7SHong Zhang if (ptap->freestruct) { 141960552ceaSHong Zhang ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr); 142060552ceaSHong Zhang } 1421f96d37fcSHong Zhang PetscFunctionReturn(0); 1422f96d37fcSHong Zhang } 1423f96d37fcSHong Zhang 1424c5af039cSHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ() */ 1425912837bbSHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,PetscReal fill,Mat *C) 1426912837bbSHong Zhang { 1427912837bbSHong Zhang PetscErrorCode ierr; 14283cdca5ebSHong Zhang Mat_APMPI *ptap; 14297f3e1f30SHong Zhang Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data,*c; 1430912837bbSHong Zhang MPI_Comm comm; 1431912837bbSHong Zhang PetscMPIInt size,rank; 1432912837bbSHong Zhang Mat Cmpi; 1433912837bbSHong Zhang PetscFreeSpaceList free_space=NULL,current_space=NULL; 14344ede91e3SHong Zhang PetscInt pn=P->cmap->n,aN=A->cmap->N,an=A->cmap->n; 14357f3e1f30SHong Zhang PetscInt *lnk,i,k,nsend; 1436912837bbSHong Zhang PetscBT lnkbt; 1437912837bbSHong Zhang PetscMPIInt tagi,tagj,*len_si,*len_s,*len_ri,icompleted=0,nrecv; 1438912837bbSHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 14397f3e1f30SHong Zhang PetscInt len,proc,*dnz,*onz,*owners,nzi; 1440912837bbSHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1441912837bbSHong Zhang MPI_Request *swaits,*rwaits; 1442912837bbSHong Zhang MPI_Status *sstatus,rstatus; 1443912837bbSHong Zhang PetscLayout rowmap; 1444912837bbSHong Zhang PetscInt *owners_co,*coi,*coj; /* i and j array of (p->B)^T*A*P - used in the communication */ 1445912837bbSHong Zhang PetscMPIInt *len_r,*id_r; /* array of length of comm->size, store send/recv matrix values */ 14467f3e1f30SHong Zhang PetscInt *Jptr,*prmap=p->garray,con,j,Crmax; 14474ede91e3SHong Zhang Mat_SeqAIJ *a_loc,*c_loc,*c_oth; 1448912837bbSHong Zhang PetscTable ta; 1449b92f168fSBarry Smith MatType mtype; 1450e83e5f86SFande Kong const char *prefix; 1451912837bbSHong Zhang 1452912837bbSHong Zhang PetscFunctionBegin; 1453912837bbSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1454912837bbSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1455912837bbSHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1456912837bbSHong Zhang 1457912837bbSHong Zhang /* create symbolic parallel matrix Cmpi */ 1458912837bbSHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 1459b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 1460b92f168fSBarry Smith ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr); 1461912837bbSHong Zhang 1462912837bbSHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 1463912837bbSHong Zhang 14643cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 1465912837bbSHong Zhang ierr = PetscNew(&ptap);CHKERRQ(ierr); 1466912837bbSHong Zhang ptap->reuse = MAT_INITIAL_MATRIX; 1467912837bbSHong Zhang 1468912837bbSHong Zhang /* (0) compute Rd = Pd^T, Ro = Po^T */ 1469912837bbSHong Zhang /* --------------------------------- */ 1470912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->A,MAT_INITIAL_MATRIX,&ptap->Rd);CHKERRQ(ierr); 1471912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->B,MAT_INITIAL_MATRIX,&ptap->Ro);CHKERRQ(ierr); 1472912837bbSHong Zhang 1473669e9c86SHong Zhang /* (1) compute symbolic A_loc */ 1474669e9c86SHong Zhang /* ---------------------------*/ 14754ede91e3SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&ptap->A_loc);CHKERRQ(ierr); 1476912837bbSHong Zhang 14774ede91e3SHong Zhang /* (2-1) compute symbolic C_oth = Ro*A_loc */ 1478912837bbSHong Zhang /* ------------------------------------ */ 1479e83e5f86SFande Kong ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr); 1480e83e5f86SFande Kong ierr = MatSetOptionsPrefix(ptap->Ro,prefix);CHKERRQ(ierr); 1481e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(ptap->Ro,"inner_offdiag_");CHKERRQ(ierr); 14824ede91e3SHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Ro,ptap->A_loc,fill,&ptap->C_oth);CHKERRQ(ierr); 1483912837bbSHong Zhang 1484912837bbSHong Zhang /* (3) send coj of C_oth to other processors */ 1485912837bbSHong Zhang /* ------------------------------------------ */ 1486912837bbSHong Zhang /* determine row ownership */ 1487912837bbSHong Zhang ierr = PetscLayoutCreate(comm,&rowmap);CHKERRQ(ierr); 1488912837bbSHong Zhang rowmap->n = pn; 1489912837bbSHong Zhang rowmap->bs = 1; 1490912837bbSHong Zhang ierr = PetscLayoutSetUp(rowmap);CHKERRQ(ierr); 1491912837bbSHong Zhang owners = rowmap->range; 1492912837bbSHong Zhang 1493912837bbSHong Zhang /* determine the number of messages to send, their lengths */ 1494912837bbSHong Zhang ierr = PetscMalloc4(size,&len_s,size,&len_si,size,&sstatus,size+2,&owners_co);CHKERRQ(ierr); 1495580bdb30SBarry Smith ierr = PetscArrayzero(len_s,size);CHKERRQ(ierr); 1496580bdb30SBarry Smith ierr = PetscArrayzero(len_si,size);CHKERRQ(ierr); 1497912837bbSHong Zhang 1498912837bbSHong Zhang c_oth = (Mat_SeqAIJ*)ptap->C_oth->data; 1499912837bbSHong Zhang coi = c_oth->i; coj = c_oth->j; 1500912837bbSHong Zhang con = ptap->C_oth->rmap->n; 1501912837bbSHong Zhang proc = 0; 1502912837bbSHong Zhang for (i=0; i<con; i++) { 1503912837bbSHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 15047f3e1f30SHong Zhang len_si[proc]++; /* num of rows in Co(=Pt*A) to be sent to [proc] */ 1505912837bbSHong Zhang len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */ 1506912837bbSHong Zhang } 1507912837bbSHong Zhang 1508912837bbSHong Zhang len = 0; /* max length of buf_si[], see (4) */ 1509912837bbSHong Zhang owners_co[0] = 0; 1510912837bbSHong Zhang nsend = 0; 1511912837bbSHong Zhang for (proc=0; proc<size; proc++) { 1512912837bbSHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1513912837bbSHong Zhang if (len_s[proc]) { 1514912837bbSHong Zhang nsend++; 1515912837bbSHong Zhang len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */ 1516912837bbSHong Zhang len += len_si[proc]; 1517912837bbSHong Zhang } 1518912837bbSHong Zhang } 1519912837bbSHong Zhang 1520912837bbSHong Zhang /* determine the number and length of messages to receive for coi and coj */ 1521912837bbSHong Zhang ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&nrecv);CHKERRQ(ierr); 1522912837bbSHong Zhang ierr = PetscGatherMessageLengths2(comm,nsend,nrecv,len_s,len_si,&id_r,&len_r,&len_ri);CHKERRQ(ierr); 1523912837bbSHong Zhang 1524912837bbSHong Zhang /* post the Irecv and Isend of coj */ 1525912837bbSHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1526912837bbSHong Zhang ierr = PetscPostIrecvInt(comm,tagj,nrecv,id_r,len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1527912837bbSHong Zhang ierr = PetscMalloc1(nsend+1,&swaits);CHKERRQ(ierr); 1528912837bbSHong Zhang for (proc=0, k=0; proc<size; proc++) { 1529912837bbSHong Zhang if (!len_s[proc]) continue; 1530912837bbSHong Zhang i = owners_co[proc]; 1531912837bbSHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 1532912837bbSHong Zhang k++; 1533912837bbSHong Zhang } 1534912837bbSHong Zhang 15357f3e1f30SHong Zhang /* (2-2) compute symbolic C_loc = Rd*A_loc */ 1536912837bbSHong Zhang /* ---------------------------------------- */ 1537e83e5f86SFande Kong ierr = MatSetOptionsPrefix(ptap->Rd,prefix);CHKERRQ(ierr); 1538e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(ptap->Rd,"inner_diag_");CHKERRQ(ierr); 15394ede91e3SHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Rd,ptap->A_loc,fill,&ptap->C_loc);CHKERRQ(ierr); 1540912837bbSHong Zhang c_loc = (Mat_SeqAIJ*)ptap->C_loc->data; 1541912837bbSHong Zhang 1542912837bbSHong Zhang /* receives coj are complete */ 1543912837bbSHong Zhang for (i=0; i<nrecv; i++) { 1544912837bbSHong Zhang ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1545912837bbSHong Zhang } 1546912837bbSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1547912837bbSHong Zhang if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);} 1548912837bbSHong Zhang 1549912837bbSHong Zhang /* add received column indices into ta to update Crmax */ 15504ede91e3SHong Zhang a_loc = (Mat_SeqAIJ*)(ptap->A_loc)->data; 1551669e9c86SHong Zhang 1552669e9c86SHong Zhang /* create and initialize a linked list */ 15534ede91e3SHong Zhang ierr = PetscTableCreate(an,aN,&ta);CHKERRQ(ierr); /* for compute Crmax */ 15544ede91e3SHong Zhang MatRowMergeMax_SeqAIJ(a_loc,ptap->A_loc->rmap->N,ta); 1555669e9c86SHong Zhang 1556912837bbSHong Zhang for (k=0; k<nrecv; k++) {/* k-th received message */ 1557912837bbSHong Zhang Jptr = buf_rj[k]; 1558912837bbSHong Zhang for (j=0; j<len_r[k]; j++) { 1559912837bbSHong Zhang ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr); 1560912837bbSHong Zhang } 1561912837bbSHong Zhang } 1562912837bbSHong Zhang ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr); 1563912837bbSHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 1564912837bbSHong Zhang 1565912837bbSHong Zhang /* (4) send and recv coi */ 1566912837bbSHong Zhang /*-----------------------*/ 1567912837bbSHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1568912837bbSHong Zhang ierr = PetscPostIrecvInt(comm,tagi,nrecv,id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1569912837bbSHong Zhang ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 1570912837bbSHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1571912837bbSHong Zhang for (proc=0,k=0; proc<size; proc++) { 1572912837bbSHong Zhang if (!len_s[proc]) continue; 1573912837bbSHong Zhang /* form outgoing message for i-structure: 1574912837bbSHong Zhang buf_si[0]: nrows to be sent 1575912837bbSHong Zhang [1:nrows]: row index (global) 1576912837bbSHong Zhang [nrows+1:2*nrows+1]: i-structure index 1577912837bbSHong Zhang */ 1578912837bbSHong Zhang /*-------------------------------------------*/ 1579912837bbSHong Zhang nrows = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */ 1580912837bbSHong Zhang buf_si_i = buf_si + nrows+1; 1581912837bbSHong Zhang buf_si[0] = nrows; 1582912837bbSHong Zhang buf_si_i[0] = 0; 1583912837bbSHong Zhang nrows = 0; 1584912837bbSHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1585912837bbSHong Zhang nzi = coi[i+1] - coi[i]; 1586912837bbSHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1587912837bbSHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1588912837bbSHong Zhang nrows++; 1589912837bbSHong Zhang } 1590912837bbSHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 1591912837bbSHong Zhang k++; 1592912837bbSHong Zhang buf_si += len_si[proc]; 1593912837bbSHong Zhang } 1594912837bbSHong Zhang for (i=0; i<nrecv; i++) { 1595912837bbSHong Zhang ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1596912837bbSHong Zhang } 1597912837bbSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1598912837bbSHong Zhang if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRQ(ierr);} 1599912837bbSHong Zhang 1600912837bbSHong Zhang ierr = PetscFree4(len_s,len_si,sstatus,owners_co);CHKERRQ(ierr); 1601912837bbSHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1602912837bbSHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1603912837bbSHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1604912837bbSHong Zhang 1605912837bbSHong Zhang /* (5) compute the local portion of Cmpi */ 1606912837bbSHong Zhang /* ------------------------------------------ */ 1607912837bbSHong Zhang /* set initial free space to be Crmax, sufficient for holding nozeros in each row of Cmpi */ 1608912837bbSHong Zhang ierr = PetscFreeSpaceGet(Crmax,&free_space);CHKERRQ(ierr); 1609912837bbSHong Zhang current_space = free_space; 1610912837bbSHong Zhang 1611912837bbSHong Zhang ierr = PetscMalloc3(nrecv,&buf_ri_k,nrecv,&nextrow,nrecv,&nextci);CHKERRQ(ierr); 1612912837bbSHong Zhang for (k=0; k<nrecv; k++) { 1613912837bbSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1614912837bbSHong Zhang nrows = *buf_ri_k[k]; 1615912837bbSHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 1616912837bbSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1617912837bbSHong Zhang } 1618912837bbSHong Zhang 16194ede91e3SHong Zhang ierr = MatPreallocateInitialize(comm,pn,an,dnz,onz);CHKERRQ(ierr); 16204ede91e3SHong Zhang ierr = PetscLLCondensedCreate(Crmax,aN,&lnk,&lnkbt);CHKERRQ(ierr); 1621912837bbSHong Zhang for (i=0; i<pn; i++) { 1622912837bbSHong Zhang /* add C_loc into Cmpi */ 1623912837bbSHong Zhang nzi = c_loc->i[i+1] - c_loc->i[i]; 1624912837bbSHong Zhang Jptr = c_loc->j + c_loc->i[i]; 1625912837bbSHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1626912837bbSHong Zhang 1627912837bbSHong Zhang /* add received col data into lnk */ 1628912837bbSHong Zhang for (k=0; k<nrecv; k++) { /* k-th received message */ 1629912837bbSHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1630912837bbSHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1631912837bbSHong Zhang Jptr = buf_rj[k] + *nextci[k]; 1632912837bbSHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1633912837bbSHong Zhang nextrow[k]++; nextci[k]++; 1634912837bbSHong Zhang } 1635912837bbSHong Zhang } 1636912837bbSHong Zhang nzi = lnk[0]; 1637912837bbSHong Zhang 1638912837bbSHong Zhang /* copy data into free space, then initialize lnk */ 16394ede91e3SHong Zhang ierr = PetscLLCondensedClean(aN,nzi,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1640912837bbSHong Zhang ierr = MatPreallocateSet(i+owners[rank],nzi,current_space->array,dnz,onz);CHKERRQ(ierr); 1641912837bbSHong Zhang } 1642912837bbSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1643912837bbSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 1644912837bbSHong Zhang ierr = PetscFreeSpaceDestroy(free_space);CHKERRQ(ierr); 1645912837bbSHong Zhang 1646912837bbSHong Zhang /* local sizes and preallocation */ 16474ede91e3SHong Zhang ierr = MatSetSizes(Cmpi,pn,an,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 1648e338c498STristan Konolige if (P->cmap->bs > 0) {ierr = PetscLayoutSetBlockSize(Cmpi->rmap,P->cmap->bs);CHKERRQ(ierr);} 1649e338c498STristan Konolige if (A->cmap->bs > 0) {ierr = PetscLayoutSetBlockSize(Cmpi->cmap,A->cmap->bs);CHKERRQ(ierr);} 1650912837bbSHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 1651912837bbSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1652912837bbSHong Zhang 1653912837bbSHong Zhang /* members in merge */ 1654912837bbSHong Zhang ierr = PetscFree(id_r);CHKERRQ(ierr); 1655912837bbSHong Zhang ierr = PetscFree(len_r);CHKERRQ(ierr); 1656912837bbSHong Zhang ierr = PetscFree(buf_ri[0]);CHKERRQ(ierr); 1657912837bbSHong Zhang ierr = PetscFree(buf_ri);CHKERRQ(ierr); 1658912837bbSHong Zhang ierr = PetscFree(buf_rj[0]);CHKERRQ(ierr); 1659912837bbSHong Zhang ierr = PetscFree(buf_rj);CHKERRQ(ierr); 1660912837bbSHong Zhang ierr = PetscLayoutDestroy(&rowmap);CHKERRQ(ierr); 1661912837bbSHong Zhang 1662912837bbSHong Zhang /* attach the supporting struct to Cmpi for reuse */ 1663912837bbSHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 16643cdca5ebSHong Zhang c->ap = ptap; 1665912837bbSHong Zhang ptap->destroy = Cmpi->ops->destroy; 1666912837bbSHong Zhang 1667912837bbSHong Zhang /* Cmpi is not ready for use - assembly will be done by MatPtAPNumeric() */ 1668912837bbSHong Zhang Cmpi->assembled = PETSC_FALSE; 1669912837bbSHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 16704624976aSHong Zhang Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP; 16718a9b8717SHong Zhang 1672912837bbSHong Zhang *C = Cmpi; 1673912837bbSHong Zhang PetscFunctionReturn(0); 1674912837bbSHong Zhang } 1675912837bbSHong Zhang 1676912837bbSHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,Mat C) 1677912837bbSHong Zhang { 1678912837bbSHong Zhang PetscErrorCode ierr; 1679669e9c86SHong Zhang Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 1680669e9c86SHong Zhang Mat_SeqAIJ *c_seq; 16813cdca5ebSHong Zhang Mat_APMPI *ptap = c->ap; 1682669e9c86SHong Zhang Mat A_loc,C_loc,C_oth; 1683912837bbSHong Zhang PetscInt i,rstart,rend,cm,ncols,row; 1684912837bbSHong Zhang const PetscInt *cols; 1685912837bbSHong Zhang const PetscScalar *vals; 1686912837bbSHong Zhang 1687912837bbSHong Zhang PetscFunctionBegin; 16880bbc151aSHong Zhang if (!ptap->A_loc) { 16898a9b8717SHong Zhang MPI_Comm comm; 16908a9b8717SHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 16918a9b8717SHong Zhang SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtA cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'"); 16928a9b8717SHong Zhang } 16938a9b8717SHong Zhang 1694912837bbSHong Zhang ierr = MatZeroEntries(C);CHKERRQ(ierr); 1695912837bbSHong Zhang 1696912837bbSHong Zhang if (ptap->reuse == MAT_REUSE_MATRIX) { 1697669e9c86SHong Zhang /* These matrices are obtained in MatTransposeMatMultSymbolic() */ 1698669e9c86SHong Zhang /* 1) get R = Pd^T, Ro = Po^T */ 1699669e9c86SHong Zhang /*----------------------------*/ 1700912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->A,MAT_REUSE_MATRIX,&ptap->Rd);CHKERRQ(ierr); 1701912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->B,MAT_REUSE_MATRIX,&ptap->Ro);CHKERRQ(ierr); 1702669e9c86SHong Zhang 1703669e9c86SHong Zhang /* 2) compute numeric A_loc */ 1704669e9c86SHong Zhang /*--------------------------*/ 17054ede91e3SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&ptap->A_loc);CHKERRQ(ierr); 1706912837bbSHong Zhang } 1707912837bbSHong Zhang 1708669e9c86SHong Zhang /* 3) C_loc = Rd*A_loc, C_oth = Ro*A_loc */ 17094ede91e3SHong Zhang A_loc = ptap->A_loc; 1710669e9c86SHong Zhang ierr = ((ptap->C_loc)->ops->matmultnumeric)(ptap->Rd,A_loc,ptap->C_loc);CHKERRQ(ierr); 1711669e9c86SHong Zhang ierr = ((ptap->C_oth)->ops->matmultnumeric)(ptap->Ro,A_loc,ptap->C_oth);CHKERRQ(ierr); 1712912837bbSHong Zhang C_loc = ptap->C_loc; 1713912837bbSHong Zhang C_oth = ptap->C_oth; 1714912837bbSHong Zhang 1715912837bbSHong Zhang /* add C_loc and Co to to C */ 1716912837bbSHong Zhang ierr = MatGetOwnershipRange(C,&rstart,&rend);CHKERRQ(ierr); 1717912837bbSHong Zhang 1718912837bbSHong Zhang /* C_loc -> C */ 1719912837bbSHong Zhang cm = C_loc->rmap->N; 1720912837bbSHong Zhang c_seq = (Mat_SeqAIJ*)C_loc->data; 1721912837bbSHong Zhang cols = c_seq->j; 1722912837bbSHong Zhang vals = c_seq->a; 1723912837bbSHong Zhang for (i=0; i<cm; i++) { 1724912837bbSHong Zhang ncols = c_seq->i[i+1] - c_seq->i[i]; 1725912837bbSHong Zhang row = rstart + i; 1726912837bbSHong Zhang ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr); 1727912837bbSHong Zhang cols += ncols; vals += ncols; 1728912837bbSHong Zhang } 1729912837bbSHong Zhang 1730912837bbSHong Zhang /* Co -> C, off-processor part */ 1731912837bbSHong Zhang cm = C_oth->rmap->N; 1732912837bbSHong Zhang c_seq = (Mat_SeqAIJ*)C_oth->data; 1733912837bbSHong Zhang cols = c_seq->j; 1734912837bbSHong Zhang vals = c_seq->a; 1735912837bbSHong Zhang for (i=0; i<cm; i++) { 1736912837bbSHong Zhang ncols = c_seq->i[i+1] - c_seq->i[i]; 1737912837bbSHong Zhang row = p->garray[i]; 1738912837bbSHong Zhang ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr); 1739912837bbSHong Zhang cols += ncols; vals += ncols; 1740912837bbSHong Zhang } 1741912837bbSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1742912837bbSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1743912837bbSHong Zhang 1744912837bbSHong Zhang ptap->reuse = MAT_REUSE_MATRIX; 17458a9b8717SHong Zhang 17468a9b8717SHong Zhang /* supporting struct ptap consumes almost same amount of memory as C=PtAP, release it if C will not be updated by A and P */ 17477d0a89b7SHong Zhang if (ptap->freestruct) { 17488a9b8717SHong Zhang ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr); 17498a9b8717SHong Zhang } 1750912837bbSHong Zhang PetscFunctionReturn(0); 1751912837bbSHong Zhang } 1752912837bbSHong Zhang 17536da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ(Mat P,Mat A,Mat C) 1754d6ab1dc0SHong Zhang { 1755d6ab1dc0SHong Zhang PetscErrorCode ierr; 1756d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 1757d6ab1dc0SHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 1758d6ab1dc0SHong Zhang Mat_SeqAIJ *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data; 17593cdca5ebSHong Zhang Mat_APMPI *ptap; 1760e745005bSHong Zhang PetscInt *adj; 1761e745005bSHong Zhang PetscInt i,j,k,anz,pnz,row,*cj,nexta; 1762e745005bSHong Zhang MatScalar *ada,*ca,valtmp; 1763d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n; 1764ce94432eSBarry Smith MPI_Comm comm; 1765d6ab1dc0SHong Zhang PetscMPIInt size,rank,taga,*len_s; 1766d6ab1dc0SHong Zhang PetscInt *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci; 1767d6ab1dc0SHong Zhang PetscInt **buf_ri,**buf_rj; 1768d6ab1dc0SHong Zhang PetscInt cnz=0,*bj_i,*bi,*bj,bnz,nextcj; /* bi,bj,ba: local array of C(mpi mat) */ 1769d6ab1dc0SHong Zhang MPI_Request *s_waits,*r_waits; 1770d6ab1dc0SHong Zhang MPI_Status *status; 1771d6ab1dc0SHong Zhang MatScalar **abuf_r,*ba_i,*pA,*coa,*ba; 17724e201bd7SHong Zhang PetscInt *ai,*aj,*coi,*coj,*poJ,*pdJ; 1773d6ab1dc0SHong Zhang Mat A_loc; 1774d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc; 1775d6ab1dc0SHong Zhang 1776d6ab1dc0SHong Zhang PetscFunctionBegin; 1777ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 1778d6ab1dc0SHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1779d6ab1dc0SHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1780d6ab1dc0SHong Zhang 17813cdca5ebSHong Zhang ptap = c->ap; 17820bbc151aSHong Zhang if (!ptap->A_loc) SETERRQ(comm,PETSC_ERR_ARG_WRONGSTATE,"PtA cannot be reused. Do not call MatFreeIntermediateDataStructures() or use '-mat_freeintermediatedatastructures'"); 1783d6ab1dc0SHong Zhang merge = ptap->merge; 1784d6ab1dc0SHong Zhang 1785e745005bSHong Zhang /* 2) compute numeric C_seq = P_loc^T*A_loc */ 1786e745005bSHong Zhang /*------------------------------------------*/ 1787d6ab1dc0SHong Zhang /* get data from symbolic products */ 1788d6ab1dc0SHong Zhang coi = merge->coi; coj = merge->coj; 1789854ce69bSBarry Smith ierr = PetscCalloc1(coi[pon]+1,&coa);CHKERRQ(ierr); 1790d6ab1dc0SHong Zhang bi = merge->bi; bj = merge->bj; 1791d6ab1dc0SHong Zhang owners = merge->rowmap->range; 17921795a4d1SJed Brown ierr = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr); 1793d6ab1dc0SHong Zhang 1794d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1795d6ab1dc0SHong Zhang A_loc = ptap->A_loc; 1796d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr); 1797d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1798d6ab1dc0SHong Zhang ai = a_loc->i; 1799d6ab1dc0SHong Zhang aj = a_loc->j; 1800d6ab1dc0SHong Zhang 1801d6ab1dc0SHong Zhang for (i=0; i<am; i++) { 1802d6ab1dc0SHong Zhang anz = ai[i+1] - ai[i]; 1803d6ab1dc0SHong Zhang adj = aj + ai[i]; 1804d6ab1dc0SHong Zhang ada = a_loc->a + ai[i]; 1805d6ab1dc0SHong Zhang 1806d6ab1dc0SHong Zhang /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */ 1807e745005bSHong Zhang /*-------------------------------------------------------------*/ 1808d6ab1dc0SHong Zhang /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */ 1809d6ab1dc0SHong Zhang pnz = po->i[i+1] - po->i[i]; 1810d6ab1dc0SHong Zhang poJ = po->j + po->i[i]; 1811d6ab1dc0SHong Zhang pA = po->a + po->i[i]; 1812d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1813d6ab1dc0SHong Zhang row = poJ[j]; 1814d6ab1dc0SHong Zhang cj = coj + coi[row]; 1815d6ab1dc0SHong Zhang ca = coa + coi[row]; 1816e745005bSHong Zhang /* perform sparse axpy */ 1817e745005bSHong Zhang nexta = 0; 1818d6ab1dc0SHong Zhang valtmp = pA[j]; 1819e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1820e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1821e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1822e745005bSHong Zhang nexta++; 1823d6ab1dc0SHong Zhang } 1824e745005bSHong Zhang } 1825e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1826d6ab1dc0SHong Zhang } 1827d6ab1dc0SHong Zhang 1828d6ab1dc0SHong Zhang /* put the value into Cd (diagonal part) */ 1829d6ab1dc0SHong Zhang pnz = pd->i[i+1] - pd->i[i]; 1830d6ab1dc0SHong Zhang pdJ = pd->j + pd->i[i]; 1831d6ab1dc0SHong Zhang pA = pd->a + pd->i[i]; 1832d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1833d6ab1dc0SHong Zhang row = pdJ[j]; 1834d6ab1dc0SHong Zhang cj = bj + bi[row]; 1835d6ab1dc0SHong Zhang ca = ba + bi[row]; 1836e745005bSHong Zhang /* perform sparse axpy */ 1837e745005bSHong Zhang nexta = 0; 1838d6ab1dc0SHong Zhang valtmp = pA[j]; 1839e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1840e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1841e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1842e745005bSHong Zhang nexta++; 1843d6ab1dc0SHong Zhang } 1844e745005bSHong Zhang } 1845e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1846d6ab1dc0SHong Zhang } 1847d6ab1dc0SHong Zhang } 1848d6ab1dc0SHong Zhang 1849d6ab1dc0SHong Zhang /* 3) send and recv matrix values coa */ 1850d6ab1dc0SHong Zhang /*------------------------------------*/ 1851d6ab1dc0SHong Zhang buf_ri = merge->buf_ri; 1852d6ab1dc0SHong Zhang buf_rj = merge->buf_rj; 1853d6ab1dc0SHong Zhang len_s = merge->len_s; 1854d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr); 1855d6ab1dc0SHong Zhang ierr = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr); 1856d6ab1dc0SHong Zhang 1857dcca6d9dSJed Brown ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr); 1858d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 1859d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1860d6ab1dc0SHong Zhang i = merge->owners_co[proc]; 1861d6ab1dc0SHong Zhang ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr); 1862d6ab1dc0SHong Zhang k++; 1863d6ab1dc0SHong Zhang } 1864d6ab1dc0SHong Zhang if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);} 1865d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);} 1866d6ab1dc0SHong Zhang 1867d6ab1dc0SHong Zhang ierr = PetscFree2(s_waits,status);CHKERRQ(ierr); 1868d6ab1dc0SHong Zhang ierr = PetscFree(r_waits);CHKERRQ(ierr); 1869d6ab1dc0SHong Zhang ierr = PetscFree(coa);CHKERRQ(ierr); 1870d6ab1dc0SHong Zhang 1871d6ab1dc0SHong Zhang /* 4) insert local Cseq and received values into Cmpi */ 1872d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1873dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1874d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 1875e745005bSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1876d6ab1dc0SHong Zhang nrows = *(buf_ri_k[k]); 1877d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k]+1; /* next row number of k-th recved i-structure */ 1878d6ab1dc0SHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1879d6ab1dc0SHong Zhang } 1880d6ab1dc0SHong Zhang 1881d6ab1dc0SHong Zhang for (i=0; i<cm; i++) { 1882d6ab1dc0SHong Zhang row = owners[rank] + i; /* global row index of C_seq */ 1883d6ab1dc0SHong Zhang bj_i = bj + bi[i]; /* col indices of the i-th row of C */ 1884d6ab1dc0SHong Zhang ba_i = ba + bi[i]; 1885d6ab1dc0SHong Zhang bnz = bi[i+1] - bi[i]; 1886d6ab1dc0SHong Zhang /* add received vals into ba */ 1887d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1888d6ab1dc0SHong Zhang /* i-th row */ 1889d6ab1dc0SHong Zhang if (i == *nextrow[k]) { 1890d6ab1dc0SHong Zhang cnz = *(nextci[k]+1) - *nextci[k]; 1891d6ab1dc0SHong Zhang cj = buf_rj[k] + *(nextci[k]); 1892d6ab1dc0SHong Zhang ca = abuf_r[k] + *(nextci[k]); 1893d6ab1dc0SHong Zhang nextcj = 0; 1894d6ab1dc0SHong Zhang for (j=0; nextcj<cnz; j++) { 1895d6ab1dc0SHong Zhang if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */ 1896d6ab1dc0SHong Zhang ba_i[j] += ca[nextcj++]; 1897d6ab1dc0SHong Zhang } 1898d6ab1dc0SHong Zhang } 1899d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 1900d6ab1dc0SHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1901d6ab1dc0SHong Zhang } 1902d6ab1dc0SHong Zhang } 1903d6ab1dc0SHong Zhang ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr); 1904d6ab1dc0SHong Zhang } 1905d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1906d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1907d6ab1dc0SHong Zhang 1908d6ab1dc0SHong Zhang ierr = PetscFree(ba);CHKERRQ(ierr); 1909d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr); 1910d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r);CHKERRQ(ierr); 1911d6ab1dc0SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 19128a9b8717SHong Zhang 19137d0a89b7SHong Zhang if (ptap->freestruct) { 19148a9b8717SHong Zhang ierr = MatFreeIntermediateDataStructures(C);CHKERRQ(ierr); 19158a9b8717SHong Zhang } 1916d6ab1dc0SHong Zhang PetscFunctionReturn(0); 1917d6ab1dc0SHong Zhang } 1918d6ab1dc0SHong Zhang 19196da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(Mat P,Mat A,PetscReal fill,Mat *C) 1920d6ab1dc0SHong Zhang { 1921d6ab1dc0SHong Zhang PetscErrorCode ierr; 1922d6ab1dc0SHong Zhang Mat Cmpi,A_loc,POt,PDt; 19233cdca5ebSHong Zhang Mat_APMPI *ptap; 19240298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 192533ba5e2fSHong Zhang Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data,*a=(Mat_MPIAIJ*)A->data,*c; 1926d6ab1dc0SHong Zhang PetscInt *pdti,*pdtj,*poti,*potj,*ptJ; 1927d6ab1dc0SHong Zhang PetscInt nnz; 1928d6ab1dc0SHong Zhang PetscInt *lnk,*owners_co,*coi,*coj,i,k,pnz,row; 1929d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,pn=P->cmap->n; 1930ce94432eSBarry Smith MPI_Comm comm; 1931d6ab1dc0SHong Zhang PetscMPIInt size,rank,tagi,tagj,*len_si,*len_s,*len_ri; 1932d6ab1dc0SHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 1933d6ab1dc0SHong Zhang PetscInt len,proc,*dnz,*onz,*owners; 1934d6ab1dc0SHong Zhang PetscInt nzi,*bi,*bj; 1935d6ab1dc0SHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1936d6ab1dc0SHong Zhang MPI_Request *swaits,*rwaits; 1937d6ab1dc0SHong Zhang MPI_Status *sstatus,rstatus; 1938d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 1939d6ab1dc0SHong Zhang PetscInt *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j; 1940d6ab1dc0SHong Zhang PetscReal afill =1.0,afill_tmp; 19414b38b95cSHong Zhang PetscInt rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Armax; 1942d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc,*pdt,*pot; 19430acc65b4SHong Zhang PetscTable ta; 1944b92f168fSBarry Smith MatType mtype; 1945d6ab1dc0SHong Zhang 1946d6ab1dc0SHong Zhang PetscFunctionBegin; 1947ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1948d6ab1dc0SHong Zhang /* check if matrix local sizes are compatible */ 19496c4ed002SBarry 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); 1950d6ab1dc0SHong Zhang 1951d6ab1dc0SHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1952d6ab1dc0SHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1953d6ab1dc0SHong Zhang 19543cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 1955b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 1956d6ab1dc0SHong Zhang 1957d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1958d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr); 19592205254eSKarl Rupp 1960d6ab1dc0SHong Zhang ptap->A_loc = A_loc; 1961d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1962d6ab1dc0SHong Zhang ai = a_loc->i; 1963d6ab1dc0SHong Zhang aj = a_loc->j; 1964d6ab1dc0SHong Zhang 1965d6ab1dc0SHong Zhang /* determine symbolic Co=(p->B)^T*A - send to others */ 1966d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1967d6ab1dc0SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr); 1968d6ab1dc0SHong Zhang pdt = (Mat_SeqAIJ*)PDt->data; 1969d6ab1dc0SHong Zhang pdti = pdt->i; pdtj = pdt->j; 1970d6ab1dc0SHong Zhang 1971d6ab1dc0SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr); 1972d6ab1dc0SHong Zhang pot = (Mat_SeqAIJ*)POt->data; 1973d6ab1dc0SHong Zhang poti = pot->i; potj = pot->j; 1974d6ab1dc0SHong Zhang 1975d6ab1dc0SHong Zhang /* then, compute symbolic Co = (p->B)^T*A */ 1976d6ab1dc0SHong Zhang pon = (p->B)->cmap->n; /* total num of rows to be sent to other processors 1977d6ab1dc0SHong Zhang >= (num of nonzero rows of C_seq) - pn */ 1978854ce69bSBarry Smith ierr = PetscMalloc1(pon+1,&coi);CHKERRQ(ierr); 1979d6ab1dc0SHong Zhang coi[0] = 0; 1980d6ab1dc0SHong Zhang 1981d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */ 1982f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(poti[pon],ai[am])); 1983a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1984d6ab1dc0SHong Zhang current_space = free_space; 198519f0e57aSHong Zhang 1986d6ab1dc0SHong Zhang /* create and initialize a linked list */ 198733ba5e2fSHong Zhang ierr = PetscTableCreate(A->cmap->n + a->B->cmap->N,aN,&ta);CHKERRQ(ierr); 19884b38b95cSHong Zhang MatRowMergeMax_SeqAIJ(a_loc,am,ta); 19890acc65b4SHong Zhang ierr = PetscTableGetCount(ta,&Armax);CHKERRQ(ierr); 199033ba5e2fSHong Zhang 19910acc65b4SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Armax,&lnk);CHKERRQ(ierr); 1992d6ab1dc0SHong Zhang 1993d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 1994d6ab1dc0SHong Zhang pnz = poti[i+1] - poti[i]; 1995d6ab1dc0SHong Zhang ptJ = potj + poti[i]; 1996d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1997d6ab1dc0SHong Zhang row = ptJ[j]; /* row of A_loc == col of Pot */ 1998d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1999d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 2000d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 2001d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 2002d6ab1dc0SHong Zhang } 2003d6ab1dc0SHong Zhang nnz = lnk[0]; 2004d6ab1dc0SHong Zhang 2005d6ab1dc0SHong Zhang /* If free space is not available, double the total space in the list */ 2006d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 2007f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 2008d6ab1dc0SHong Zhang nspacedouble++; 2009d6ab1dc0SHong Zhang } 2010d6ab1dc0SHong Zhang 2011d6ab1dc0SHong Zhang /* Copy data into free space, and zero out denserows */ 2012d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 20132205254eSKarl Rupp 2014d6ab1dc0SHong Zhang current_space->array += nnz; 2015d6ab1dc0SHong Zhang current_space->local_used += nnz; 2016d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 20172205254eSKarl Rupp 2018d6ab1dc0SHong Zhang coi[i+1] = coi[i] + nnz; 2019d6ab1dc0SHong Zhang } 2020d6ab1dc0SHong Zhang 2021854ce69bSBarry Smith ierr = PetscMalloc1(coi[pon]+1,&coj);CHKERRQ(ierr); 2022d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr); 20230acc65b4SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); /* must destroy to get a new one for C */ 20242205254eSKarl Rupp 2025118727c9SMark F. Adams afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1); 2026d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 2027d6ab1dc0SHong Zhang 2028d6ab1dc0SHong Zhang /* send j-array (coj) of Co to other processors */ 2029d6ab1dc0SHong Zhang /*----------------------------------------------*/ 2030d6ab1dc0SHong Zhang /* determine row ownership */ 2031b00a9115SJed Brown ierr = PetscNew(&merge);CHKERRQ(ierr); 2032d6ab1dc0SHong Zhang ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr); 20332205254eSKarl Rupp 2034d6ab1dc0SHong Zhang merge->rowmap->n = pn; 2035d6ab1dc0SHong Zhang merge->rowmap->bs = 1; 20362205254eSKarl Rupp 2037d6ab1dc0SHong Zhang ierr = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr); 2038d6ab1dc0SHong Zhang owners = merge->rowmap->range; 2039d6ab1dc0SHong Zhang 2040d6ab1dc0SHong Zhang /* determine the number of messages to send, their lengths */ 20411795a4d1SJed Brown ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr); 2042580bdb30SBarry Smith ierr = PetscCalloc1(size,&merge->len_s);CHKERRQ(ierr); 20432205254eSKarl Rupp 2044d6ab1dc0SHong Zhang len_s = merge->len_s; 2045d6ab1dc0SHong Zhang merge->nsend = 0; 2046d6ab1dc0SHong Zhang 2047854ce69bSBarry Smith ierr = PetscMalloc1(size+2,&owners_co);CHKERRQ(ierr); 2048d6ab1dc0SHong Zhang 2049d6ab1dc0SHong Zhang proc = 0; 2050d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 2051d6ab1dc0SHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 2052d6ab1dc0SHong Zhang len_si[proc]++; /* num of rows in Co to be sent to [proc] */ 2053d6ab1dc0SHong Zhang len_s[proc] += coi[i+1] - coi[i]; 2054d6ab1dc0SHong Zhang } 2055d6ab1dc0SHong Zhang 2056d6ab1dc0SHong Zhang len = 0; /* max length of buf_si[] */ 2057d6ab1dc0SHong Zhang owners_co[0] = 0; 2058d6ab1dc0SHong Zhang for (proc=0; proc<size; proc++) { 2059d6ab1dc0SHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 2060d6ab1dc0SHong Zhang if (len_si[proc]) { 2061d6ab1dc0SHong Zhang merge->nsend++; 2062d6ab1dc0SHong Zhang len_si[proc] = 2*(len_si[proc] + 1); 2063d6ab1dc0SHong Zhang len += len_si[proc]; 2064d6ab1dc0SHong Zhang } 2065d6ab1dc0SHong Zhang } 2066d6ab1dc0SHong Zhang 2067d6ab1dc0SHong Zhang /* determine the number and length of messages to receive for coi and coj */ 20680298fd71SBarry Smith ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr); 2069d6ab1dc0SHong Zhang ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr); 2070d6ab1dc0SHong Zhang 2071d6ab1dc0SHong Zhang /* post the Irecv and Isend of coj */ 2072d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 2073d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 2074854ce69bSBarry Smith ierr = PetscMalloc1(merge->nsend+1,&swaits);CHKERRQ(ierr); 2075d6ab1dc0SHong Zhang for (proc=0, k=0; proc<size; proc++) { 2076d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 2077d6ab1dc0SHong Zhang i = owners_co[proc]; 2078d6ab1dc0SHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 2079d6ab1dc0SHong Zhang k++; 2080d6ab1dc0SHong Zhang } 2081d6ab1dc0SHong Zhang 2082d6ab1dc0SHong Zhang /* receives and sends of coj are complete */ 2083785e854fSJed Brown ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr); 2084d6ab1dc0SHong Zhang for (i=0; i<merge->nrecv; i++) { 2085c280ed6aSJed Brown PetscMPIInt icompleted; 2086c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 2087d6ab1dc0SHong Zhang } 2088d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 2089d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 2090d6ab1dc0SHong Zhang 20910acc65b4SHong Zhang /* add received column indices into table to update Armax */ 209233ba5e2fSHong Zhang /* Armax can be as large as aN if a P[row,:] is dense, see src/ksp/ksp/examples/tutorials/ex56.c! */ 20930acc65b4SHong Zhang for (k=0; k<merge->nrecv; k++) {/* k-th received message */ 20940acc65b4SHong Zhang Jptr = buf_rj[k]; 20950acc65b4SHong Zhang for (j=0; j<merge->len_r[k]; j++) { 20960acc65b4SHong Zhang ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr); 20970acc65b4SHong Zhang } 20980acc65b4SHong Zhang } 20990acc65b4SHong Zhang ierr = PetscTableGetCount(ta,&Armax);CHKERRQ(ierr); 210033ba5e2fSHong 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); */ 21010acc65b4SHong Zhang 2102d6ab1dc0SHong Zhang /* send and recv coi */ 2103d6ab1dc0SHong Zhang /*-------------------*/ 2104d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 2105d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 2106854ce69bSBarry Smith ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 2107d6ab1dc0SHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 2108d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 2109d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 2110d6ab1dc0SHong Zhang /* form outgoing message for i-structure: 2111d6ab1dc0SHong Zhang buf_si[0]: nrows to be sent 2112d6ab1dc0SHong Zhang [1:nrows]: row index (global) 2113d6ab1dc0SHong Zhang [nrows+1:2*nrows+1]: i-structure index 2114d6ab1dc0SHong Zhang */ 2115d6ab1dc0SHong Zhang /*-------------------------------------------*/ 2116d6ab1dc0SHong Zhang nrows = len_si[proc]/2 - 1; 2117d6ab1dc0SHong Zhang buf_si_i = buf_si + nrows+1; 2118d6ab1dc0SHong Zhang buf_si[0] = nrows; 2119d6ab1dc0SHong Zhang buf_si_i[0] = 0; 2120d6ab1dc0SHong Zhang nrows = 0; 2121d6ab1dc0SHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 2122d6ab1dc0SHong Zhang nzi = coi[i+1] - coi[i]; 2123d6ab1dc0SHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 2124d6ab1dc0SHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 2125d6ab1dc0SHong Zhang nrows++; 2126d6ab1dc0SHong Zhang } 2127d6ab1dc0SHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 2128d6ab1dc0SHong Zhang k++; 2129d6ab1dc0SHong Zhang buf_si += len_si[proc]; 2130d6ab1dc0SHong Zhang } 2131d6ab1dc0SHong Zhang i = merge->nrecv; 2132d6ab1dc0SHong Zhang while (i--) { 2133c280ed6aSJed Brown PetscMPIInt icompleted; 2134c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 2135d6ab1dc0SHong Zhang } 2136d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 2137d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 2138d6ab1dc0SHong Zhang ierr = PetscFree(len_si);CHKERRQ(ierr); 2139d6ab1dc0SHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 2140d6ab1dc0SHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 2141d6ab1dc0SHong Zhang ierr = PetscFree(sstatus);CHKERRQ(ierr); 2142d6ab1dc0SHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 2143d6ab1dc0SHong Zhang 2144d6ab1dc0SHong Zhang /* compute the local portion of C (mpi mat) */ 2145d6ab1dc0SHong Zhang /*------------------------------------------*/ 2146d6ab1dc0SHong Zhang /* allocate bi array and free space for accumulating nonzero column info */ 2147854ce69bSBarry Smith ierr = PetscMalloc1(pn+1,&bi);CHKERRQ(ierr); 2148d6ab1dc0SHong Zhang bi[0] = 0; 2149d6ab1dc0SHong Zhang 2150d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(P) + nnz(AP)) */ 2151f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(pdti[pn],PetscIntSumTruncate(poti[pon],ai[am]))); 2152a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 2153d6ab1dc0SHong Zhang current_space = free_space; 2154d6ab1dc0SHong Zhang 2155dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 2156d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 2157d6ab1dc0SHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 2158d6ab1dc0SHong Zhang nrows = *buf_ri_k[k]; 2159d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 21602205254eSKarl Rupp nextci[k] = buf_ri_k[k] + (nrows + 1); /* points to the next i-structure of k-th recieved i-structure */ 2161d6ab1dc0SHong Zhang } 2162d6ab1dc0SHong Zhang 21630acc65b4SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Armax,&lnk);CHKERRQ(ierr); 2164d6ab1dc0SHong Zhang ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr); 2165d6ab1dc0SHong Zhang rmax = 0; 2166d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 2167d6ab1dc0SHong Zhang /* add pdt[i,:]*AP into lnk */ 2168d6ab1dc0SHong Zhang pnz = pdti[i+1] - pdti[i]; 2169d6ab1dc0SHong Zhang ptJ = pdtj + pdti[i]; 2170d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 2171d6ab1dc0SHong Zhang row = ptJ[j]; /* row of AP == col of Pt */ 2172d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 2173d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 2174d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 2175d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 2176d6ab1dc0SHong Zhang } 2177d6ab1dc0SHong Zhang 2178d6ab1dc0SHong Zhang /* add received col data into lnk */ 2179d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 2180d6ab1dc0SHong Zhang if (i == *nextrow[k]) { /* i-th row */ 2181d6ab1dc0SHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 2182d6ab1dc0SHong Zhang Jptr = buf_rj[k] + *nextci[k]; 2183d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr); 2184d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 2185d6ab1dc0SHong Zhang } 2186d6ab1dc0SHong Zhang } 2187d6ab1dc0SHong Zhang nnz = lnk[0]; 2188d6ab1dc0SHong Zhang 2189d6ab1dc0SHong Zhang /* if free space is not available, make more free space */ 2190d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 2191f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 2192d6ab1dc0SHong Zhang nspacedouble++; 2193d6ab1dc0SHong Zhang } 2194d6ab1dc0SHong Zhang /* copy data into free space, then initialize lnk */ 2195d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 2196d6ab1dc0SHong Zhang ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr); 21972205254eSKarl Rupp 2198d6ab1dc0SHong Zhang current_space->array += nnz; 2199d6ab1dc0SHong Zhang current_space->local_used += nnz; 2200d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 22012205254eSKarl Rupp 2202d6ab1dc0SHong Zhang bi[i+1] = bi[i] + nnz; 2203d6ab1dc0SHong Zhang if (nnz > rmax) rmax = nnz; 2204d6ab1dc0SHong Zhang } 2205f671be37SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 2206d6ab1dc0SHong Zhang 2207854ce69bSBarry Smith ierr = PetscMalloc1(bi[pn]+1,&bj);CHKERRQ(ierr); 2208d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr); 2209118727c9SMark F. Adams afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1); 2210d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 2211d6ab1dc0SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 22120acc65b4SHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 22130acc65b4SHong Zhang 2214d6ab1dc0SHong Zhang ierr = MatDestroy(&POt);CHKERRQ(ierr); 2215d6ab1dc0SHong Zhang ierr = MatDestroy(&PDt);CHKERRQ(ierr); 2216d6ab1dc0SHong Zhang 2217d6ab1dc0SHong Zhang /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part */ 2218d6ab1dc0SHong Zhang /*----------------------------------------------------------------------------------*/ 2219d6ab1dc0SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 2220d6ab1dc0SHong Zhang ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 222133d57670SJed Brown ierr = MatSetBlockSizes(Cmpi,PetscAbs(P->cmap->bs),PetscAbs(A->cmap->bs));CHKERRQ(ierr); 2222b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 2223b92f168fSBarry Smith ierr = MatSetType(Cmpi,mtype);CHKERRQ(ierr); 2224d6ab1dc0SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 2225d6ab1dc0SHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 2226d6ab1dc0SHong Zhang ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr); 2227d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 2228d6ab1dc0SHong Zhang row = i + rstart; 2229d6ab1dc0SHong Zhang nnz = bi[i+1] - bi[i]; 2230d6ab1dc0SHong Zhang Jptr = bj + bi[i]; 2231071fcb05SBarry Smith ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,NULL,INSERT_VALUES);CHKERRQ(ierr); 2232d6ab1dc0SHong Zhang } 2233d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 2234d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 2235d6ab1dc0SHong Zhang merge->bi = bi; 2236d6ab1dc0SHong Zhang merge->bj = bj; 2237d6ab1dc0SHong Zhang merge->coi = coi; 2238d6ab1dc0SHong Zhang merge->coj = coj; 2239d6ab1dc0SHong Zhang merge->buf_ri = buf_ri; 2240d6ab1dc0SHong Zhang merge->buf_rj = buf_rj; 2241d6ab1dc0SHong Zhang merge->owners_co = owners_co; 2242d6ab1dc0SHong Zhang 2243d6ab1dc0SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 2244d6ab1dc0SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 22452205254eSKarl Rupp 22463cdca5ebSHong Zhang c->ap = ptap; 22470298fd71SBarry Smith ptap->api = NULL; 22480298fd71SBarry Smith ptap->apj = NULL; 2249d6ab1dc0SHong Zhang ptap->merge = merge; 22500298fd71SBarry Smith ptap->apa = NULL; 2251a560ef98SHong Zhang ptap->destroy = Cmpi->ops->destroy; 2252a560ef98SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 2253a560ef98SHong Zhang 2254a560ef98SHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ; 2255a560ef98SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 22564624976aSHong Zhang Cmpi->ops->freeintermediatedatastructures = MatFreeIntermediateDataStructures_MPIAIJ_AP; 2257f96d37fcSHong Zhang 2258f96d37fcSHong Zhang *C = Cmpi; 2259f96d37fcSHong Zhang #if defined(PETSC_USE_INFO) 2260f96d37fcSHong Zhang if (bi[pn] != 0) { 226157622a8eSBarry Smith ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 226257622a8eSBarry Smith ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr); 2263f96d37fcSHong Zhang } else { 2264f96d37fcSHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 2265f96d37fcSHong Zhang } 2266f96d37fcSHong Zhang #endif 2267f96d37fcSHong Zhang PetscFunctionReturn(0); 2268f96d37fcSHong Zhang } 2269