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> 1297929ea7SJunchao Zhang #include <petsc/private/sfimpl.h> 131634b032SHong Zhang 145e5acdf2Sstefano_zampini #if defined(PETSC_HAVE_HYPRE) 154222ddf1SHong Zhang PETSC_INTERN PetscErrorCode MatMatMultSymbolic_AIJ_AIJ_wHYPRE(Mat,Mat,PetscReal,Mat); 165e5acdf2Sstefano_zampini #endif 175e5acdf2Sstefano_zampini 184222ddf1SHong Zhang PETSC_INTERN PetscErrorCode MatProductSymbolic_AB_MPIAIJ_MPIAIJ(Mat C) 192499ec78SHong Zhang { 202499ec78SHong Zhang PetscErrorCode ierr; 214222ddf1SHong Zhang Mat_Product *product = C->product; 224222ddf1SHong Zhang Mat A=product->A,B=product->B; 234222ddf1SHong Zhang MatProductAlgorithm alg=product->alg; 244222ddf1SHong Zhang PetscReal fill=product->fill; 255e68f438SHong Zhang PetscBool flg; 262499ec78SHong Zhang 272499ec78SHong Zhang PetscFunctionBegin; 284222ddf1SHong Zhang /* scalable */ 294222ddf1SHong Zhang ierr = PetscStrcmp(alg,"scalable",&flg);CHKERRQ(ierr); 304222ddf1SHong Zhang if (flg) { 31b2405163SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ(A,B,fill,C);CHKERRQ(ierr); 326718818eSStefano Zampini PetscFunctionReturn(0); 330fc8cf34SHong Zhang } 347d0a89b7SHong Zhang 354222ddf1SHong Zhang /* nonscalable */ 364222ddf1SHong Zhang ierr = PetscStrcmp(alg,"nonscalable",&flg);CHKERRQ(ierr); 374222ddf1SHong Zhang if (flg) { 384222ddf1SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(A,B,fill,C);CHKERRQ(ierr); 396718818eSStefano Zampini PetscFunctionReturn(0); 404222ddf1SHong Zhang } 414222ddf1SHong Zhang 424222ddf1SHong Zhang /* seqmpi */ 434222ddf1SHong Zhang ierr = PetscStrcmp(alg,"seqmpi",&flg);CHKERRQ(ierr); 444222ddf1SHong Zhang if (flg) { 454222ddf1SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ_seqMPI(A,B,fill,C);CHKERRQ(ierr); 466718818eSStefano Zampini PetscFunctionReturn(0); 474222ddf1SHong Zhang } 484222ddf1SHong Zhang 49*4e84afc0SStefano Zampini /* backend general code */ 50*4e84afc0SStefano Zampini ierr = PetscStrcmp(alg,"backend",&flg);CHKERRQ(ierr); 51*4e84afc0SStefano Zampini if (flg) { 52*4e84afc0SStefano Zampini ierr = MatProductSymbolic_MPIAIJBACKEND(C);CHKERRQ(ierr); 53*4e84afc0SStefano Zampini PetscFunctionReturn(0); 54*4e84afc0SStefano Zampini } 55*4e84afc0SStefano Zampini 564222ddf1SHong Zhang #if defined(PETSC_HAVE_HYPRE) 574222ddf1SHong Zhang ierr = PetscStrcmp(alg,"hypre",&flg);CHKERRQ(ierr); 584222ddf1SHong Zhang if (flg) { 594222ddf1SHong Zhang ierr = MatMatMultSymbolic_AIJ_AIJ_wHYPRE(A,B,fill,C);CHKERRQ(ierr); 604222ddf1SHong Zhang PetscFunctionReturn(0); 614222ddf1SHong Zhang } 624222ddf1SHong Zhang #endif 634222ddf1SHong Zhang SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_SUP,"Mat Product Algorithm is not supported"); 642499ec78SHong Zhang } 652499ec78SHong Zhang 666718818eSStefano Zampini PetscErrorCode MatDestroy_MPIAIJ_MatMatMult(void *data) 67598bc09dSHong Zhang { 68598bc09dSHong Zhang PetscErrorCode ierr; 696718818eSStefano Zampini Mat_APMPI *ptap = (Mat_APMPI*)data; 70598bc09dSHong Zhang 71598bc09dSHong Zhang PetscFunctionBegin; 72b7f45c76SHong Zhang ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr); 73598bc09dSHong Zhang ierr = PetscFree(ptap->bufa);CHKERRQ(ierr); 74a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr); 75a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr); 76ab1b013aSHong Zhang ierr = MatDestroy(&ptap->Pt);CHKERRQ(ierr); 77a1a4e84aSHong Zhang ierr = PetscFree(ptap->api);CHKERRQ(ierr); 78a1a4e84aSHong Zhang ierr = PetscFree(ptap->apj);CHKERRQ(ierr); 79598bc09dSHong Zhang ierr = PetscFree(ptap->apa);CHKERRQ(ierr); 80598bc09dSHong Zhang ierr = PetscFree(ptap);CHKERRQ(ierr); 81598bc09dSHong Zhang PetscFunctionReturn(0); 82598bc09dSHong Zhang } 83598bc09dSHong Zhang 84f8efd71cSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,Mat C) 85598bc09dSHong Zhang { 86598bc09dSHong Zhang PetscErrorCode ierr; 874ae0847bSHong Zhang Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 88598bc09dSHong Zhang Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 89598bc09dSHong Zhang Mat_SeqAIJ *cd =(Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 90c12557a1SHong Zhang PetscScalar *cda=cd->a,*coa=co->a; 91598bc09dSHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 929ce11a7cSHong Zhang PetscScalar *apa,*ca; 93c12557a1SHong Zhang PetscInt cm =C->rmap->n; 946718818eSStefano Zampini Mat_APMPI *ptap; 95c12557a1SHong Zhang PetscInt *api,*apj,*apJ,i,k; 9629825010SHong Zhang PetscInt cstart=C->cmap->rstart; 97598bc09dSHong Zhang PetscInt cdnz,conz,k0,k1; 989467f45fSHong Zhang MPI_Comm comm; 999467f45fSHong Zhang PetscMPIInt size; 100598bc09dSHong Zhang 101598bc09dSHong Zhang PetscFunctionBegin; 1026718818eSStefano Zampini MatCheckProduct(C,3); 1036718818eSStefano Zampini ptap = (Mat_APMPI*)C->product->data; 1046718818eSStefano Zampini if (!ptap) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be computed. Missing data"); 1059467f45fSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 106ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 1079467f45fSHong Zhang 1086718818eSStefano Zampini if (!ptap->P_oth && size>1) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"AP cannot be reused. Do not call MatProductClear()"); 10980da8df7SHong Zhang 110a1a4e84aSHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 111598bc09dSHong Zhang /*-----------------------------------------------------*/ 112a1a4e84aSHong Zhang /* update numerical values of P_oth and P_loc */ 113b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 114a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 115598bc09dSHong Zhang 116598bc09dSHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 117598bc09dSHong Zhang /*----------------------------------------------------------*/ 118598bc09dSHong Zhang /* get data from symbolic products */ 119a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 120c12557a1SHong Zhang p_oth = NULL; 1219467f45fSHong Zhang if (size >1) { 1229467f45fSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 1239467f45fSHong Zhang } 124598bc09dSHong Zhang 125598bc09dSHong Zhang /* get apa for storing dense row A[i,:]*P */ 126598bc09dSHong Zhang apa = ptap->apa; 127598bc09dSHong Zhang 12829825010SHong Zhang api = ptap->api; 12929825010SHong Zhang apj = ptap->apj; 130598bc09dSHong Zhang for (i=0; i<cm; i++) { 131c12557a1SHong Zhang /* compute apa = A[i,:]*P */ 132e497d3c8SHong Zhang AProw_nonscalable(i,ad,ao,p_loc,p_oth,apa); 133598bc09dSHong Zhang 134598bc09dSHong Zhang /* set values in C */ 135598bc09dSHong Zhang apJ = apj + api[i]; 136598bc09dSHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 137598bc09dSHong Zhang conz = co->i[i+1] - co->i[i]; 138598bc09dSHong Zhang 139910cf402Sprj- /* 1st off-diagonal part of C */ 140598bc09dSHong Zhang ca = coa + co->i[i]; 141598bc09dSHong Zhang k = 0; 142598bc09dSHong Zhang for (k0=0; k0<conz; k0++) { 143598bc09dSHong Zhang if (apJ[k] >= cstart) break; 144598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 1455cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 146598bc09dSHong Zhang } 147598bc09dSHong Zhang 148598bc09dSHong Zhang /* diagonal part of C */ 149598bc09dSHong Zhang ca = cda + cd->i[i]; 150598bc09dSHong Zhang for (k1=0; k1<cdnz; k1++) { 151598bc09dSHong Zhang ca[k1] = apa[apJ[k]]; 1525cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 153598bc09dSHong Zhang } 154598bc09dSHong Zhang 155910cf402Sprj- /* 2nd off-diagonal part of C */ 156598bc09dSHong Zhang ca = coa + co->i[i]; 157598bc09dSHong Zhang for (; k0<conz; k0++) { 158598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 1595cab4f04SHong Zhang apa[apJ[k++]] = 0.0; 160598bc09dSHong Zhang } 161598bc09dSHong Zhang } 162598bc09dSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 163598bc09dSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 164598bc09dSHong Zhang PetscFunctionReturn(0); 165598bc09dSHong Zhang } 166598bc09dSHong Zhang 1674222ddf1SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,PetscReal fill,Mat C) 168598bc09dSHong Zhang { 169598bc09dSHong Zhang PetscErrorCode ierr; 170ce94432eSBarry Smith MPI_Comm comm; 1719467f45fSHong Zhang PetscMPIInt size; 1723cdca5ebSHong Zhang Mat_APMPI *ptap; 1730298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 1746718818eSStefano Zampini Mat_MPIAIJ *a=(Mat_MPIAIJ*)A->data; 175bfcd1a73SHong Zhang Mat_SeqAIJ *ad=(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 1767dbaa2c6Sandi selinger PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 1774ae0847bSHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 178d14fa243SHong Zhang PetscInt *lnk,i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi; 1795cab4f04SHong Zhang PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n; 180598bc09dSHong Zhang PetscBT lnkbt; 181bfcd1a73SHong Zhang PetscReal afill; 182b92f168fSBarry Smith MatType mtype; 183598bc09dSHong Zhang 184598bc09dSHong Zhang PetscFunctionBegin; 1856718818eSStefano Zampini MatCheckProduct(C,4); 1866718818eSStefano Zampini if (C->product->data) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_PLIB,"Extra product struct not empty"); 187ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 188ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 1899467f45fSHong Zhang 1903cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 191b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 192598bc09dSHong Zhang 193598bc09dSHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 194b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 19519f0e57aSHong Zhang 196598bc09dSHong Zhang /* get P_loc by taking all local rows of P */ 197a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 198598bc09dSHong Zhang 199a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 200598bc09dSHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 2019467f45fSHong Zhang if (size > 1) { 2029467f45fSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 203598bc09dSHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 20420e3dc75SHong Zhang } else { 20520e3dc75SHong Zhang p_oth = NULL; 20620e3dc75SHong Zhang pi_oth = NULL; pj_oth = NULL; 2079467f45fSHong Zhang } 208598bc09dSHong Zhang 209598bc09dSHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 210598bc09dSHong Zhang /*-------------------------------------------------------------------*/ 211854ce69bSBarry Smith ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 212a1a4e84aSHong Zhang ptap->api = api; 213598bc09dSHong Zhang api[0] = 0; 214598bc09dSHong Zhang 2155cab4f04SHong Zhang /* create and initialize a linked list */ 2165cab4f04SHong Zhang ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr); 217598bc09dSHong Zhang 218bfcd1a73SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 219f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space);CHKERRQ(ierr); 220598bc09dSHong Zhang current_space = free_space; 221598bc09dSHong Zhang 222598bc09dSHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 223598bc09dSHong Zhang for (i=0; i<am; i++) { 224598bc09dSHong Zhang /* diagonal portion of A */ 225598bc09dSHong Zhang nzi = adi[i+1] - adi[i]; 226598bc09dSHong Zhang for (j=0; j<nzi; j++) { 227598bc09dSHong Zhang row = *adj++; 228598bc09dSHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 229598bc09dSHong Zhang Jptr = pj_loc + pi_loc[row]; 230598bc09dSHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 2311fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 232598bc09dSHong Zhang } 233598bc09dSHong Zhang /* off-diagonal portion of A */ 234598bc09dSHong Zhang nzi = aoi[i+1] - aoi[i]; 235598bc09dSHong Zhang for (j=0; j<nzi; j++) { 236598bc09dSHong Zhang row = *aoj++; 237598bc09dSHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 238598bc09dSHong Zhang Jptr = pj_oth + pi_oth[row]; 2391fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 240598bc09dSHong Zhang } 2418c78258cSHong Zhang /* add possible missing diagonal entry */ 2428c78258cSHong Zhang if (C->force_diagonals) { 2438c78258cSHong Zhang j = i + rstart; /* column index */ 2448c78258cSHong Zhang ierr = PetscLLCondensedAddSorted(1,&j,lnk,lnkbt);CHKERRQ(ierr); 2458c78258cSHong Zhang } 246598bc09dSHong Zhang 247d14fa243SHong Zhang apnz = lnk[0]; 248598bc09dSHong Zhang api[i+1] = api[i] + apnz; 249598bc09dSHong Zhang 250598bc09dSHong Zhang /* if free space is not available, double the total space in the list */ 251598bc09dSHong Zhang if (current_space->local_remaining<apnz) { 252f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 253598bc09dSHong Zhang nspacedouble++; 254598bc09dSHong Zhang } 255598bc09dSHong Zhang 256598bc09dSHong Zhang /* Copy data into free space, then initialize lnk */ 2571fbbb359SHong Zhang ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 258598bc09dSHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 2592205254eSKarl Rupp 260598bc09dSHong Zhang current_space->array += apnz; 261598bc09dSHong Zhang current_space->local_used += apnz; 262598bc09dSHong Zhang current_space->local_remaining -= apnz; 263598bc09dSHong Zhang } 264598bc09dSHong Zhang 265598bc09dSHong Zhang /* Allocate space for apj, initialize apj, and */ 266598bc09dSHong Zhang /* destroy list of free space and other temporary array(s) */ 267854ce69bSBarry Smith ierr = PetscMalloc1(api[am]+1,&ptap->apj);CHKERRQ(ierr); 268a1a4e84aSHong Zhang apj = ptap->apj; 269a1a4e84aSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 270598bc09dSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 271598bc09dSHong Zhang 272f84c536bSHong Zhang /* malloc apa to store dense row A[i,:]*P */ 273071fcb05SBarry Smith ierr = PetscCalloc1(pN,&ptap->apa);CHKERRQ(ierr); 274f84c536bSHong Zhang 2754222ddf1SHong Zhang /* set and assemble symbolic parallel matrix C */ 2764222ddf1SHong Zhang /*---------------------------------------------*/ 2774222ddf1SHong Zhang ierr = MatSetSizes(C,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 2784222ddf1SHong Zhang ierr = MatSetBlockSizesFromMats(C,A,P);CHKERRQ(ierr); 279a2f3521dSMark F. Adams 280b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 2814222ddf1SHong Zhang ierr = MatSetType(C,mtype);CHKERRQ(ierr); 2824222ddf1SHong Zhang ierr = MatMPIAIJSetPreallocation(C,0,dnz,0,onz);CHKERRQ(ierr); 2830926fe31SStefano Zampini ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 28417f75172Sandi selinger 2854222ddf1SHong Zhang ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat_Symbolic(C, apj, api);CHKERRQ(ierr); 2864222ddf1SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 2874222ddf1SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 2880926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 289598bc09dSHong Zhang 2904222ddf1SHong Zhang C->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 2914222ddf1SHong Zhang C->ops->productnumeric = MatProductNumeric_AB; 292598bc09dSHong Zhang 2934222ddf1SHong Zhang /* attach the supporting struct to C for reuse */ 2946718818eSStefano Zampini C->product->data = ptap; 2956718818eSStefano Zampini C->product->destroy = MatDestroy_MPIAIJ_MatMatMult; 296598bc09dSHong Zhang 297bfcd1a73SHong Zhang /* set MatInfo */ 298118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 299bfcd1a73SHong Zhang if (afill < 1.0) afill = 1.0; 3004222ddf1SHong Zhang C->info.mallocs = nspacedouble; 3014222ddf1SHong Zhang C->info.fill_ratio_given = fill; 3024222ddf1SHong Zhang C->info.fill_ratio_needed = afill; 303bfcd1a73SHong Zhang 304bfcd1a73SHong Zhang #if defined(PETSC_USE_INFO) 305bfcd1a73SHong Zhang if (api[am]) { 3064222ddf1SHong Zhang ierr = PetscInfo3(C,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 3074222ddf1SHong Zhang ierr = PetscInfo1(C,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 308bfcd1a73SHong Zhang } else { 3094222ddf1SHong Zhang ierr = PetscInfo(C,"Empty matrix product\n");CHKERRQ(ierr); 310bfcd1a73SHong Zhang } 311bfcd1a73SHong Zhang #endif 312598bc09dSHong Zhang PetscFunctionReturn(0); 313598bc09dSHong Zhang } 314598bc09dSHong Zhang 3154222ddf1SHong Zhang /* ------------------------------------------------------- */ 3166718818eSStefano Zampini static PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIDense(Mat,Mat,PetscReal,Mat); 3176718818eSStefano Zampini static PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense(Mat,Mat,Mat); 3186718818eSStefano Zampini 3194222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_MPIDense_AB(Mat C) 3209123193aSHong Zhang { 3214222ddf1SHong Zhang Mat_Product *product = C->product; 3224222ddf1SHong Zhang Mat A = product->A,B=product->B; 3239123193aSHong Zhang 3249123193aSHong Zhang PetscFunctionBegin; 3254222ddf1SHong Zhang if (A->cmap->rstart != B->rmap->rstart || A->cmap->rend != B->rmap->rend) 3264222ddf1SHong Zhang SETERRQ4(PETSC_COMM_SELF,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); 3274222ddf1SHong Zhang 3284222ddf1SHong Zhang C->ops->matmultsymbolic = MatMatMultSymbolic_MPIAIJ_MPIDense; 3294222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_AB; 3309123193aSHong Zhang PetscFunctionReturn(0); 3319123193aSHong Zhang } 3324222ddf1SHong Zhang /* -------------------------------------------------------------------- */ 3334222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_MPIDense_AtB(Mat C) 3344222ddf1SHong Zhang { 3354222ddf1SHong Zhang Mat_Product *product = C->product; 3364222ddf1SHong Zhang Mat A = product->A,B=product->B; 3374222ddf1SHong Zhang 3384222ddf1SHong Zhang PetscFunctionBegin; 3394222ddf1SHong Zhang if (A->rmap->rstart != B->rmap->rstart || A->rmap->rend != B->rmap->rend) 3404222ddf1SHong Zhang SETERRQ4(PETSC_COMM_SELF,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, (%D, %D) != (%D,%D)",A->rmap->rstart,A->rmap->rend,B->rmap->rstart,B->rmap->rend); 3414222ddf1SHong Zhang 3424222ddf1SHong Zhang C->ops->transposematmultsymbolic = MatTransposeMatMultSymbolic_MPIAIJ_MPIDense; 3434222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_AtB; 3444222ddf1SHong Zhang PetscFunctionReturn(0); 3454222ddf1SHong Zhang } 3464222ddf1SHong Zhang 3474222ddf1SHong Zhang /* --------------------------------------------------------------------- */ 3484222ddf1SHong Zhang PETSC_INTERN PetscErrorCode MatProductSetFromOptions_MPIAIJ_MPIDense(Mat C) 3494222ddf1SHong Zhang { 3504222ddf1SHong Zhang PetscErrorCode ierr; 3514222ddf1SHong Zhang Mat_Product *product = C->product; 3524222ddf1SHong Zhang 3534222ddf1SHong Zhang PetscFunctionBegin; 3544222ddf1SHong Zhang switch (product->type) { 3554222ddf1SHong Zhang case MATPRODUCT_AB: 3564222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_MPIDense_AB(C);CHKERRQ(ierr); 3574222ddf1SHong Zhang break; 3584222ddf1SHong Zhang case MATPRODUCT_AtB: 3594222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_MPIDense_AtB(C);CHKERRQ(ierr); 3604222ddf1SHong Zhang break; 3614222ddf1SHong Zhang default: 3626718818eSStefano Zampini break; 3634222ddf1SHong Zhang } 3644222ddf1SHong Zhang PetscFunctionReturn(0); 3654222ddf1SHong Zhang } 3664222ddf1SHong Zhang /* ------------------------------------------------------- */ 3679123193aSHong Zhang 3684324174eSBarry Smith typedef struct { 3695ea7661aSPierre Jolivet Mat workB,workB1; 3704324174eSBarry Smith MPI_Request *rwaits,*swaits; 37187753ddeSHong Zhang PetscInt nsends,nrecvs; 37287753ddeSHong Zhang MPI_Datatype *stype,*rtype; 3736718818eSStefano Zampini PetscInt blda; 3744324174eSBarry Smith } MPIAIJ_MPIDense; 3754324174eSBarry Smith 37696b95a6bSBarry Smith PetscErrorCode MatMPIAIJ_MPIDenseDestroy(void *ctx) 3774324174eSBarry Smith { 3784324174eSBarry Smith MPIAIJ_MPIDense *contents = (MPIAIJ_MPIDense*)ctx; 3794324174eSBarry Smith PetscErrorCode ierr; 38087753ddeSHong Zhang PetscInt i; 3814324174eSBarry Smith 3824324174eSBarry Smith PetscFunctionBegin; 3836bf464f9SBarry Smith ierr = MatDestroy(&contents->workB);CHKERRQ(ierr); 38487753ddeSHong Zhang ierr = MatDestroy(&contents->workB1);CHKERRQ(ierr); 38587753ddeSHong Zhang for (i=0; i<contents->nsends; i++) { 386ffc4695bSBarry Smith ierr = MPI_Type_free(&contents->stype[i]);CHKERRMPI(ierr); 38787753ddeSHong Zhang } 38887753ddeSHong Zhang for (i=0; i<contents->nrecvs; i++) { 389ffc4695bSBarry Smith ierr = MPI_Type_free(&contents->rtype[i]);CHKERRMPI(ierr); 39087753ddeSHong Zhang } 39187753ddeSHong Zhang ierr = PetscFree4(contents->stype,contents->rtype,contents->rwaits,contents->swaits);CHKERRQ(ierr); 3924324174eSBarry Smith ierr = PetscFree(contents);CHKERRQ(ierr); 3934324174eSBarry Smith PetscFunctionReturn(0); 3944324174eSBarry Smith } 3954324174eSBarry Smith 3966718818eSStefano Zampini static PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIDense(Mat A,Mat B,PetscReal fill,Mat C) 3979123193aSHong Zhang { 3989123193aSHong Zhang PetscErrorCode ierr; 399f32d5d43SBarry Smith Mat_MPIAIJ *aij=(Mat_MPIAIJ*)A->data; 4006718818eSStefano Zampini PetscInt nz=aij->B->cmap->n,nsends,nrecvs,i,nrows_to,j,blda,clda; 4014324174eSBarry Smith MPIAIJ_MPIDense *contents; 4024324174eSBarry Smith VecScatter ctx=aij->Mvctx; 4035ea7661aSPierre Jolivet PetscInt Am=A->rmap->n,Bm=B->rmap->n,BN=B->cmap->N,Bbn,Bbn1,bs,nrows_from,numBb; 40487753ddeSHong Zhang MPI_Comm comm; 40587753ddeSHong Zhang MPI_Datatype type1,*stype,*rtype; 40687753ddeSHong Zhang const PetscInt *sindices,*sstarts,*rstarts; 40787753ddeSHong Zhang PetscMPIInt *disp; 4086718818eSStefano Zampini PetscBool cisdense; 4099123193aSHong Zhang 4109123193aSHong Zhang PetscFunctionBegin; 4116718818eSStefano Zampini MatCheckProduct(C,4); 4126718818eSStefano Zampini if (C->product->data) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_PLIB,"Product data not empty"); 41387753ddeSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 4145ea7661aSPierre Jolivet ierr = PetscObjectBaseTypeCompare((PetscObject)C,MATMPIDENSE,&cisdense);CHKERRQ(ierr); 4156718818eSStefano Zampini if (!cisdense) { 4166718818eSStefano Zampini ierr = MatSetType(C,((PetscObject)B)->type_name);CHKERRQ(ierr); 4176718818eSStefano Zampini } 4184222ddf1SHong Zhang ierr = MatSetSizes(C,Am,B->cmap->n,A->rmap->N,BN);CHKERRQ(ierr); 4194222ddf1SHong Zhang ierr = MatSetBlockSizesFromMats(C,A,B);CHKERRQ(ierr); 4206718818eSStefano Zampini ierr = MatSetUp(C);CHKERRQ(ierr); 4216718818eSStefano Zampini ierr = MatDenseGetLDA(B,&blda);CHKERRQ(ierr); 4226718818eSStefano Zampini ierr = MatDenseGetLDA(C,&clda);CHKERRQ(ierr); 423b00a9115SJed Brown ierr = PetscNew(&contents);CHKERRQ(ierr); 4244324174eSBarry Smith 42587753ddeSHong Zhang ierr = VecScatterGetRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,NULL,NULL);CHKERRQ(ierr); 42687753ddeSHong Zhang ierr = VecScatterGetRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,NULL,NULL);CHKERRQ(ierr); 42787753ddeSHong Zhang 42887753ddeSHong Zhang /* Create column block of B and C for memory scalability when BN is too large */ 42987753ddeSHong Zhang /* Estimate Bbn, column size of Bb */ 43087753ddeSHong Zhang if (nz) { 43187753ddeSHong Zhang Bbn1 = 2*Am*BN/nz; 43287753ddeSHong Zhang } else Bbn1 = BN; 43387753ddeSHong Zhang 43487753ddeSHong Zhang bs = PetscAbs(B->cmap->bs); 43587753ddeSHong Zhang Bbn1 = Bbn1/bs *bs; /* Bbn1 is a multiple of bs */ 43687753ddeSHong Zhang if (Bbn1 > BN) Bbn1 = BN; 437ffc4695bSBarry Smith ierr = MPI_Allreduce(&Bbn1,&Bbn,1,MPIU_INT,MPI_MAX,comm);CHKERRMPI(ierr); 43887753ddeSHong Zhang 43987753ddeSHong Zhang /* Enable runtime option for Bbn */ 4404222ddf1SHong Zhang ierr = PetscOptionsBegin(comm,((PetscObject)C)->prefix,"MatMatMult","Mat");CHKERRQ(ierr); 44187753ddeSHong Zhang ierr = PetscOptionsInt("-matmatmult_Bbn","Number of columns in Bb","MatMatMult",Bbn,&Bbn,NULL);CHKERRQ(ierr); 44287753ddeSHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 4436718818eSStefano Zampini Bbn = PetscMin(Bbn,BN); 44487753ddeSHong Zhang 4456718818eSStefano Zampini if (Bbn > 0 && Bbn < BN) { 4465ea7661aSPierre Jolivet numBb = BN/Bbn; 4475ea7661aSPierre Jolivet Bbn1 = BN - numBb*Bbn; 4485ea7661aSPierre Jolivet } else numBb = 0; 44987753ddeSHong Zhang 4505ea7661aSPierre Jolivet if (numBb) { 4515ea7661aSPierre Jolivet ierr = PetscInfo3(C,"use Bb, BN=%D, Bbn=%D; numBb=%D\n",BN,Bbn,numBb);CHKERRQ(ierr); 4525ea7661aSPierre Jolivet if (Bbn1) { /* Create workB1 for the remaining columns */ 4534222ddf1SHong Zhang ierr = PetscInfo2(C,"use Bb1, BN=%D, Bbn1=%D\n",BN,Bbn1);CHKERRQ(ierr); 45487753ddeSHong Zhang /* Create work matrix used to store off processor rows of B needed for local product */ 45587753ddeSHong Zhang ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,Bbn1,NULL,&contents->workB1);CHKERRQ(ierr); 4565ea7661aSPierre Jolivet } else contents->workB1 = NULL; 45787753ddeSHong Zhang } 45887753ddeSHong Zhang 45987753ddeSHong Zhang /* Create work matrix used to store off processor rows of B needed for local product */ 46087753ddeSHong Zhang ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,Bbn,NULL,&contents->workB);CHKERRQ(ierr); 46187753ddeSHong Zhang 46287753ddeSHong Zhang /* Use MPI derived data type to reduce memory required by the send/recv buffers */ 46387753ddeSHong Zhang ierr = PetscMalloc4(nsends,&stype,nrecvs,&rtype,nrecvs,&contents->rwaits,nsends,&contents->swaits);CHKERRQ(ierr); 46487753ddeSHong Zhang contents->stype = stype; 46587753ddeSHong Zhang contents->nsends = nsends; 46687753ddeSHong Zhang 46787753ddeSHong Zhang contents->rtype = rtype; 46887753ddeSHong Zhang contents->nrecvs = nrecvs; 4696718818eSStefano Zampini contents->blda = blda; 47087753ddeSHong Zhang 47187753ddeSHong Zhang ierr = PetscMalloc1(Bm+1,&disp);CHKERRQ(ierr); 47287753ddeSHong Zhang for (i=0; i<nsends; i++) { 47387753ddeSHong Zhang nrows_to = sstarts[i+1]-sstarts[i]; 47487753ddeSHong Zhang for (j=0; j<nrows_to; j++){ 47587753ddeSHong Zhang disp[j] = sindices[sstarts[i]+j]; /* rowB to be sent */ 47687753ddeSHong Zhang } 477ffc4695bSBarry Smith ierr = MPI_Type_create_indexed_block(nrows_to,1,(const PetscMPIInt *)disp,MPIU_SCALAR,&type1);CHKERRMPI(ierr); 478905b3b74SHong Zhang 479ffc4695bSBarry Smith ierr = MPI_Type_create_resized(type1,0,blda*sizeof(PetscScalar),&stype[i]);CHKERRMPI(ierr); 480ffc4695bSBarry Smith ierr = MPI_Type_commit(&stype[i]);CHKERRMPI(ierr); 481ffc4695bSBarry Smith ierr = MPI_Type_free(&type1);CHKERRMPI(ierr); 48287753ddeSHong Zhang } 48387753ddeSHong Zhang 48487753ddeSHong Zhang for (i=0; i<nrecvs; i++) { 48587753ddeSHong Zhang /* received values from a process form a (nrows_from x Bbn) row block in workB (column-wise) */ 48687753ddeSHong Zhang nrows_from = rstarts[i+1]-rstarts[i]; 48787753ddeSHong Zhang disp[0] = 0; 488ffc4695bSBarry Smith ierr = MPI_Type_create_indexed_block(1, nrows_from, (const PetscMPIInt *)disp, MPIU_SCALAR, &type1);CHKERRMPI(ierr); 489ffc4695bSBarry Smith ierr = MPI_Type_create_resized(type1, 0, nz*sizeof(PetscScalar), &rtype[i]);CHKERRMPI(ierr); 490ffc4695bSBarry Smith ierr = MPI_Type_commit(&rtype[i]);CHKERRMPI(ierr); 491ffc4695bSBarry Smith ierr = MPI_Type_free(&type1);CHKERRMPI(ierr); 49287753ddeSHong Zhang } 49387753ddeSHong Zhang 49487753ddeSHong Zhang ierr = PetscFree(disp);CHKERRQ(ierr); 49587753ddeSHong Zhang ierr = VecScatterRestoreRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,NULL,NULL);CHKERRQ(ierr); 49687753ddeSHong Zhang ierr = VecScatterRestoreRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,NULL,NULL);CHKERRQ(ierr); 497910cf402Sprj- ierr = MatSetOption(C,MAT_NO_OFF_PROC_ENTRIES,PETSC_TRUE);CHKERRQ(ierr); 4984222ddf1SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 4994222ddf1SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 5000926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 5016718818eSStefano Zampini 5026718818eSStefano Zampini C->product->data = contents; 5036718818eSStefano Zampini C->product->destroy = MatMPIAIJ_MPIDenseDestroy; 5044222ddf1SHong Zhang C->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense; 5059123193aSHong Zhang PetscFunctionReturn(0); 5069123193aSHong Zhang } 5079123193aSHong Zhang 50893aa15f2SStefano Zampini PETSC_INTERN PetscErrorCode MatMatMultNumericAdd_SeqAIJ_SeqDense(Mat,Mat,Mat,const PetscBool); 509f32d5d43SBarry Smith /* 5102636ff26SBarry Smith Performs an efficient scatter on the rows of B needed by this process; this is 5112636ff26SBarry Smith a modification of the VecScatterBegin_() routines. 51287753ddeSHong Zhang 51387753ddeSHong Zhang Input: Bbidx = 0: B = Bb 51487753ddeSHong Zhang = 1: B = Bb1, see MatMatMultSymbolic_MPIAIJ_MPIDense() 515f32d5d43SBarry Smith */ 51687753ddeSHong Zhang PetscErrorCode MatMPIDenseScatter(Mat A,Mat B,PetscInt Bbidx,Mat C,Mat *outworkB) 517f32d5d43SBarry Smith { 518f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 519f32d5d43SBarry Smith PetscErrorCode ierr; 5201683a169SBarry Smith const PetscScalar *b; 52187753ddeSHong Zhang PetscScalar *rvalues; 522f32d5d43SBarry Smith VecScatter ctx = aij->Mvctx; 52387753ddeSHong Zhang const PetscInt *sindices,*sstarts,*rstarts; 5243515ee7fSJunchao Zhang const PetscMPIInt *sprocs,*rprocs; 5256718818eSStefano Zampini PetscInt i,nsends,nrecvs; 526f32d5d43SBarry Smith MPI_Request *swaits,*rwaits; 527ce94432eSBarry Smith MPI_Comm comm; 5286718818eSStefano Zampini PetscMPIInt tag=((PetscObject)ctx)->tag,ncols=B->cmap->N,nrows=aij->B->cmap->n,nsends_mpi,nrecvs_mpi; 5294324174eSBarry Smith MPIAIJ_MPIDense *contents; 5304324174eSBarry Smith Mat workB; 53187753ddeSHong Zhang MPI_Datatype *stype,*rtype; 5326718818eSStefano Zampini PetscInt blda; 533f32d5d43SBarry Smith 534f32d5d43SBarry Smith PetscFunctionBegin; 5356718818eSStefano Zampini MatCheckProduct(C,4); 5366718818eSStefano Zampini if (!C->product->data) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_PLIB,"Product data empty"); 5376718818eSStefano Zampini contents = (MPIAIJ_MPIDense*)C->product->data; 5383515ee7fSJunchao Zhang ierr = VecScatterGetRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,&sprocs,NULL/*bs*/);CHKERRQ(ierr); 53987753ddeSHong Zhang ierr = VecScatterGetRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,&rprocs,NULL/*bs*/);CHKERRQ(ierr); 5403515ee7fSJunchao Zhang ierr = PetscMPIIntCast(nsends,&nsends_mpi);CHKERRQ(ierr); 5413515ee7fSJunchao Zhang ierr = PetscMPIIntCast(nrecvs,&nrecvs_mpi);CHKERRQ(ierr); 54287753ddeSHong Zhang if (Bbidx == 0) { 54387753ddeSHong Zhang workB = *outworkB = contents->workB; 54487753ddeSHong Zhang } else { 54587753ddeSHong Zhang workB = *outworkB = contents->workB1; 54687753ddeSHong Zhang } 5476718818eSStefano Zampini if (nrows != workB->rmap->n) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_PLIB,"Number of rows of workB %D not equal to columns of aij->B %D",workB->cmap->n,nrows); 5483515ee7fSJunchao Zhang swaits = contents->swaits; 5493515ee7fSJunchao Zhang rwaits = contents->rwaits; 550f32d5d43SBarry Smith 5511683a169SBarry Smith ierr = MatDenseGetArrayRead(B,&b);CHKERRQ(ierr); 5526718818eSStefano Zampini ierr = MatDenseGetLDA(B,&blda);CHKERRQ(ierr); 5536718818eSStefano Zampini if (blda != contents->blda) SETERRQ2(PETSC_COMM_SELF,PETSC_ERR_ARG_WRONG,"Cannot reuse an input matrix with lda %D != %D",blda,contents->blda); 55487753ddeSHong Zhang ierr = MatDenseGetArray(workB,&rvalues);CHKERRQ(ierr); 555f32d5d43SBarry Smith 55687753ddeSHong Zhang /* Post recv, use MPI derived data type to save memory */ 5576718818eSStefano Zampini ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 55887753ddeSHong Zhang rtype = contents->rtype; 5593515ee7fSJunchao Zhang for (i=0; i<nrecvs; i++) { 560ffc4695bSBarry Smith ierr = MPI_Irecv(rvalues+(rstarts[i]-rstarts[0]),ncols,rtype[i],rprocs[i],tag,comm,rwaits+i);CHKERRMPI(ierr); 561f32d5d43SBarry Smith } 562f32d5d43SBarry Smith 56387753ddeSHong Zhang stype = contents->stype; 5643515ee7fSJunchao Zhang for (i=0; i<nsends; i++) { 565ffc4695bSBarry Smith ierr = MPI_Isend(b,ncols,stype[i],sprocs[i],tag,comm,swaits+i);CHKERRMPI(ierr); 566f32d5d43SBarry Smith } 5672636ff26SBarry Smith 568ffc4695bSBarry Smith if (nrecvs) {ierr = MPI_Waitall(nrecvs_mpi,rwaits,MPI_STATUSES_IGNORE);CHKERRMPI(ierr);} 569ffc4695bSBarry Smith if (nsends) {ierr = MPI_Waitall(nsends_mpi,swaits,MPI_STATUSES_IGNORE);CHKERRMPI(ierr);} 570f32d5d43SBarry Smith 57187753ddeSHong Zhang ierr = VecScatterRestoreRemote_Private(ctx,PETSC_TRUE/*send*/,&nsends,&sstarts,&sindices,&sprocs,NULL);CHKERRQ(ierr); 57287753ddeSHong Zhang ierr = VecScatterRestoreRemoteOrdered_Private(ctx,PETSC_FALSE/*recv*/,&nrecvs,&rstarts,NULL,&rprocs,NULL);CHKERRQ(ierr); 5731683a169SBarry Smith ierr = MatDenseRestoreArrayRead(B,&b);CHKERRQ(ierr); 57487753ddeSHong Zhang ierr = MatDenseRestoreArray(workB,&rvalues);CHKERRQ(ierr); 57587753ddeSHong Zhang PetscFunctionReturn(0); 57687753ddeSHong Zhang } 577f32d5d43SBarry Smith 5786718818eSStefano Zampini static PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense(Mat A,Mat B,Mat C) 5799123193aSHong Zhang { 5809123193aSHong Zhang PetscErrorCode ierr; 581f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 582f32d5d43SBarry Smith Mat_MPIDense *bdense = (Mat_MPIDense*)B->data; 583f32d5d43SBarry Smith Mat_MPIDense *cdense = (Mat_MPIDense*)C->data; 584f32d5d43SBarry Smith Mat workB; 58587753ddeSHong Zhang MPIAIJ_MPIDense *contents; 5869123193aSHong Zhang 5879123193aSHong Zhang PetscFunctionBegin; 5886718818eSStefano Zampini MatCheckProduct(C,3); 5896718818eSStefano Zampini if (!C->product->data) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_PLIB,"Product data empty"); 5906718818eSStefano Zampini contents = (MPIAIJ_MPIDense*)C->product->data; 591f32d5d43SBarry Smith /* diagonal block of A times all local rows of B */ 5925ea7661aSPierre Jolivet /* TODO: this calls a symbolic multiplication every time, which could be avoided */ 5936718818eSStefano Zampini ierr = MatMatMult(aij->A,bdense->A,MAT_REUSE_MATRIX,PETSC_DEFAULT,&cdense->A);CHKERRQ(ierr); 5945ea7661aSPierre Jolivet if (contents->workB->cmap->n == B->cmap->N) { 59587753ddeSHong Zhang /* get off processor parts of B needed to complete C=A*B */ 59687753ddeSHong Zhang ierr = MatMPIDenseScatter(A,B,0,C,&workB);CHKERRQ(ierr); 597f32d5d43SBarry Smith 598f32d5d43SBarry Smith /* off-diagonal block of A times nonlocal rows of B */ 59993aa15f2SStefano Zampini ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cdense->A,PETSC_TRUE);CHKERRQ(ierr); 60087753ddeSHong Zhang } else { 6015ea7661aSPierre Jolivet Mat Bb,Cb; 6025ea7661aSPierre Jolivet PetscInt BN=B->cmap->N,n=contents->workB->cmap->n,i; 60387753ddeSHong Zhang 6045ea7661aSPierre Jolivet for (i=0; i<BN; i+=n) { 6055ea7661aSPierre Jolivet ierr = MatDenseGetSubMatrix(B,i,PetscMin(i+n,BN),&Bb);CHKERRQ(ierr); 6065ea7661aSPierre Jolivet ierr = MatDenseGetSubMatrix(C,i,PetscMin(i+n,BN),&Cb);CHKERRQ(ierr); 60787753ddeSHong Zhang 6085ea7661aSPierre Jolivet /* get off processor parts of B needed to complete C=A*B */ 6095ea7661aSPierre Jolivet ierr = MatMPIDenseScatter(A,Bb,i+n>BN,C,&workB);CHKERRQ(ierr); 6105ea7661aSPierre Jolivet 6115ea7661aSPierre Jolivet /* off-diagonal block of A times nonlocal rows of B */ 6125ea7661aSPierre Jolivet cdense = (Mat_MPIDense*)Cb->data; 61393aa15f2SStefano Zampini ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cdense->A,PETSC_TRUE);CHKERRQ(ierr); 6145ea7661aSPierre Jolivet 6155ea7661aSPierre Jolivet ierr = MatDenseRestoreSubMatrix(B,&Bb);CHKERRQ(ierr); 6165ea7661aSPierre Jolivet ierr = MatDenseRestoreSubMatrix(C,&Cb);CHKERRQ(ierr); 61787753ddeSHong Zhang } 61887753ddeSHong Zhang } 6199123193aSHong Zhang PetscFunctionReturn(0); 6209123193aSHong Zhang } 621cf1a0672SHong Zhang 622f8efd71cSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ(Mat A,Mat P,Mat C) 6231634b032SHong Zhang { 6241634b032SHong Zhang PetscErrorCode ierr; 625cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 626cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 627cf1a0672SHong Zhang Mat_SeqAIJ *cd = (Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 628cf1a0672SHong Zhang PetscInt *adi = ad->i,*adj,*aoi=ao->i,*aoj; 629cf1a0672SHong Zhang PetscScalar *ada,*aoa,*cda=cd->a,*coa=co->a; 630cf1a0672SHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 631cf1a0672SHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj; 63229825010SHong Zhang PetscScalar *pa_loc,*pa_oth,*pa,valtmp,*ca; 63329825010SHong Zhang PetscInt cm = C->rmap->n,anz,pnz; 6346718818eSStefano Zampini Mat_APMPI *ptap; 63580da8df7SHong Zhang PetscScalar *apa_sparse; 636cf1a0672SHong Zhang PetscInt *api,*apj,*apJ,i,j,k,row; 63729825010SHong Zhang PetscInt cstart = C->cmap->rstart; 63829825010SHong Zhang PetscInt cdnz,conz,k0,k1,nextp; 639a7c7454dSHong Zhang MPI_Comm comm; 640a7c7454dSHong Zhang PetscMPIInt size; 6411634b032SHong Zhang 6421634b032SHong Zhang PetscFunctionBegin; 6436718818eSStefano Zampini MatCheckProduct(C,3); 6446718818eSStefano Zampini ptap = (Mat_APMPI*)C->product->data; 6456718818eSStefano Zampini if (!ptap) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be computed. Missing data"); 64680da8df7SHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 647ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 6486718818eSStefano Zampini if (!ptap->P_oth && size>1) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"AP cannot be reused. Do not call MatProductClear()"); 649a7c7454dSHong Zhang 65080da8df7SHong Zhang apa_sparse = ptap->apa; 65180da8df7SHong Zhang 652cf1a0672SHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 653cf1a0672SHong Zhang /*-----------------------------------------------------*/ 654cf1a0672SHong Zhang /* update numerical values of P_oth and P_loc */ 655b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 656cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 657cf1a0672SHong Zhang 658cf1a0672SHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 659cf1a0672SHong Zhang /*----------------------------------------------------------*/ 660cf1a0672SHong Zhang /* get data from symbolic products */ 661cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 662cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; pa_loc = p_loc->a; 663a7c7454dSHong Zhang if (size >1) { 664a7c7454dSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 665cf1a0672SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; pa_oth = p_oth->a; 66620e3dc75SHong Zhang } else { 66720e3dc75SHong Zhang p_oth = NULL; pi_oth = NULL; pj_oth = NULL; pa_oth = NULL; 668a7c7454dSHong Zhang } 669cf1a0672SHong Zhang 67029825010SHong Zhang api = ptap->api; 67129825010SHong Zhang apj = ptap->apj; 672cf1a0672SHong Zhang for (i=0; i<cm; i++) { 67329825010SHong Zhang apJ = apj + api[i]; 67429825010SHong Zhang 675cf1a0672SHong Zhang /* diagonal portion of A */ 676cf1a0672SHong Zhang anz = adi[i+1] - adi[i]; 677cf1a0672SHong Zhang adj = ad->j + adi[i]; 678cf1a0672SHong Zhang ada = ad->a + adi[i]; 679cf1a0672SHong Zhang for (j=0; j<anz; j++) { 680cf1a0672SHong Zhang row = adj[j]; 681cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 682cf1a0672SHong Zhang pj = pj_loc + pi_loc[row]; 683cf1a0672SHong Zhang pa = pa_loc + pi_loc[row]; 68429825010SHong Zhang /* perform sparse axpy */ 685cf1a0672SHong Zhang valtmp = ada[j]; 68629825010SHong Zhang nextp = 0; 68729825010SHong Zhang for (k=0; nextp<pnz; k++) { 68829825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 68929825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 69029825010SHong Zhang } 6911634b032SHong Zhang } 692cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 693cf1a0672SHong Zhang } 6941634b032SHong Zhang 695cf1a0672SHong Zhang /* off-diagonal portion of A */ 696cf1a0672SHong Zhang anz = aoi[i+1] - aoi[i]; 697cf1a0672SHong Zhang aoj = ao->j + aoi[i]; 698cf1a0672SHong Zhang aoa = ao->a + aoi[i]; 699cf1a0672SHong Zhang for (j=0; j<anz; j++) { 700cf1a0672SHong Zhang row = aoj[j]; 701cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 702cf1a0672SHong Zhang pj = pj_oth + pi_oth[row]; 703cf1a0672SHong Zhang pa = pa_oth + pi_oth[row]; 70429825010SHong Zhang /* perform sparse axpy */ 705cf1a0672SHong Zhang valtmp = aoa[j]; 70629825010SHong Zhang nextp = 0; 70729825010SHong Zhang for (k=0; nextp<pnz; k++) { 70829825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 70929825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 71029825010SHong Zhang } 711cf1a0672SHong Zhang } 712cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 713cf1a0672SHong Zhang } 7141634b032SHong Zhang 715cf1a0672SHong Zhang /* set values in C */ 716cf1a0672SHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 717cf1a0672SHong Zhang conz = co->i[i+1] - co->i[i]; 7181634b032SHong Zhang 719910cf402Sprj- /* 1st off-diagonal part of C */ 720cf1a0672SHong Zhang ca = coa + co->i[i]; 721cf1a0672SHong Zhang k = 0; 722cf1a0672SHong Zhang for (k0=0; k0<conz; k0++) { 723cf1a0672SHong Zhang if (apJ[k] >= cstart) break; 72429825010SHong Zhang ca[k0] = apa_sparse[k]; 72529825010SHong Zhang apa_sparse[k] = 0.0; 726cf1a0672SHong Zhang k++; 727cf1a0672SHong Zhang } 7281634b032SHong Zhang 729cf1a0672SHong Zhang /* diagonal part of C */ 730cf1a0672SHong Zhang ca = cda + cd->i[i]; 731cf1a0672SHong Zhang for (k1=0; k1<cdnz; k1++) { 73229825010SHong Zhang ca[k1] = apa_sparse[k]; 73329825010SHong Zhang apa_sparse[k] = 0.0; 734cf1a0672SHong Zhang k++; 735cf1a0672SHong Zhang } 736cf1a0672SHong Zhang 737910cf402Sprj- /* 2nd off-diagonal part of C */ 738cf1a0672SHong Zhang ca = coa + co->i[i]; 739cf1a0672SHong Zhang for (; k0<conz; k0++) { 74029825010SHong Zhang ca[k0] = apa_sparse[k]; 74129825010SHong Zhang apa_sparse[k] = 0.0; 742cf1a0672SHong Zhang k++; 743cf1a0672SHong Zhang } 744cf1a0672SHong Zhang } 745cf1a0672SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 746cf1a0672SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 747cf1a0672SHong Zhang PetscFunctionReturn(0); 748cf1a0672SHong Zhang } 749cf1a0672SHong Zhang 7500fc8cf34SHong Zhang /* same as MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(), except using LLCondensed to avoid O(BN) memory requirement */ 7514222ddf1SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat C) 752cf1a0672SHong Zhang { 753cf1a0672SHong Zhang PetscErrorCode ierr; 754ce94432eSBarry Smith MPI_Comm comm; 755a7c7454dSHong Zhang PetscMPIInt size; 7563cdca5ebSHong Zhang Mat_APMPI *ptap; 7570298fd71SBarry Smith PetscFreeSpaceList free_space = NULL,current_space=NULL; 7586718818eSStefano Zampini Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data; 759cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 7607dbaa2c6Sandi selinger PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 761cf1a0672SHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 7628c78258cSHong Zhang PetscInt i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi,*lnk,apnz_max=1; 763e5ab8c0aSKarl Rupp PetscInt am=A->rmap->n,pn=P->cmap->n,pm=P->rmap->n,lsize=pn+20; 764cf1a0672SHong Zhang PetscReal afill; 765b92f168fSBarry Smith MatType mtype; 766cf1a0672SHong Zhang 767cf1a0672SHong Zhang PetscFunctionBegin; 7686718818eSStefano Zampini MatCheckProduct(C,4); 7696718818eSStefano Zampini if (C->product->data) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_PLIB,"Extra product struct not empty"); 770ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 771ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 772a7c7454dSHong Zhang 7733cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 774b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 775cf1a0672SHong Zhang 776cf1a0672SHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 777b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 77819f0e57aSHong Zhang 779cf1a0672SHong Zhang /* get P_loc by taking all local rows of P */ 780cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 781cf1a0672SHong Zhang 782cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 783cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 784a7c7454dSHong Zhang if (size > 1) { 785a7c7454dSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 78620e3dc75SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 787968382fdSHong Zhang } else { 78820e3dc75SHong Zhang p_oth = NULL; 78920e3dc75SHong Zhang pi_oth = NULL; pj_oth = NULL; 790a7c7454dSHong Zhang } 791cf1a0672SHong Zhang 792cf1a0672SHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 793cf1a0672SHong Zhang /*-------------------------------------------------------------------*/ 794854ce69bSBarry Smith ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 795cf1a0672SHong Zhang ptap->api = api; 796cf1a0672SHong Zhang api[0] = 0; 797cf1a0672SHong Zhang 7988a210135Sandi selinger ierr = PetscLLCondensedCreate_Scalable(lsize,&lnk);CHKERRQ(ierr); 799cf1a0672SHong Zhang 800cf1a0672SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 801f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space);CHKERRQ(ierr); 802cf1a0672SHong Zhang current_space = free_space; 803cf1a0672SHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 804cf1a0672SHong Zhang for (i=0; i<am; i++) { 805cf1a0672SHong Zhang /* diagonal portion of A */ 806cf1a0672SHong Zhang nzi = adi[i+1] - adi[i]; 807cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 808cf1a0672SHong Zhang row = *adj++; 809cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 810cf1a0672SHong Zhang Jptr = pj_loc + pi_loc[row]; 8118a210135Sandi selinger /* Expand list if it is not long enough */ 8128328dd82Sandi selinger if (pnz+apnz_max > lsize) { 8138328dd82Sandi selinger lsize = pnz+apnz_max; 81426465080Sandi selinger ierr = PetscLLCondensedExpand_Scalable(lsize, &lnk);CHKERRQ(ierr); 8158a210135Sandi selinger } 816cf1a0672SHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 817f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 8188a210135Sandi selinger apnz = *lnk; /* The first element in the list is the number of items in the list */ 8198a210135Sandi selinger api[i+1] = api[i] + apnz; 8208c78258cSHong Zhang if (apnz > apnz_max) apnz_max = apnz + 1; /* '1' for diagonal entry */ 821cf1a0672SHong Zhang } 822cf1a0672SHong Zhang /* off-diagonal portion of A */ 823cf1a0672SHong Zhang nzi = aoi[i+1] - aoi[i]; 824cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 825cf1a0672SHong Zhang row = *aoj++; 826cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 827cf1a0672SHong Zhang Jptr = pj_oth + pi_oth[row]; 8288a210135Sandi selinger /* Expand list if it is not long enough */ 8298328dd82Sandi selinger if (pnz+apnz_max > lsize) { 8308328dd82Sandi selinger lsize = pnz + apnz_max; 83126465080Sandi selinger ierr = PetscLLCondensedExpand_Scalable(lsize, &lnk);CHKERRQ(ierr); 8328a210135Sandi selinger } 8338a210135Sandi selinger /* add non-zero cols of P into the sorted linked list lnk */ 834f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 8358a210135Sandi selinger apnz = *lnk; /* The first element in the list is the number of items in the list */ 8368a210135Sandi selinger api[i+1] = api[i] + apnz; 8378c78258cSHong Zhang if (apnz > apnz_max) apnz_max = apnz + 1; /* '1' for diagonal entry */ 838cf1a0672SHong Zhang } 8398c78258cSHong Zhang 8408c78258cSHong Zhang /* add missing diagonal entry */ 8418c78258cSHong Zhang if (C->force_diagonals) { 8428c78258cSHong Zhang j = i + rstart; /* column index */ 8438c78258cSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(1,&j,lnk);CHKERRQ(ierr); 8448c78258cSHong Zhang } 8458c78258cSHong Zhang 846f84c536bSHong Zhang apnz = *lnk; 847cf1a0672SHong Zhang api[i+1] = api[i] + apnz; 8488a210135Sandi selinger if (apnz > apnz_max) apnz_max = apnz; 849cf1a0672SHong Zhang 850cf1a0672SHong Zhang /* if free space is not available, double the total space in the list */ 851cf1a0672SHong Zhang if (current_space->local_remaining<apnz) { 852f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(apnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 853cf1a0672SHong Zhang nspacedouble++; 854cf1a0672SHong Zhang } 855cf1a0672SHong Zhang 856cf1a0672SHong Zhang /* Copy data into free space, then initialize lnk */ 857f84c536bSHong Zhang ierr = PetscLLCondensedClean_Scalable(apnz,current_space->array,lnk);CHKERRQ(ierr); 858cf1a0672SHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 8592205254eSKarl Rupp 860cf1a0672SHong Zhang current_space->array += apnz; 861cf1a0672SHong Zhang current_space->local_used += apnz; 862cf1a0672SHong Zhang current_space->local_remaining -= apnz; 863cf1a0672SHong Zhang } 864cf1a0672SHong Zhang 865cf1a0672SHong Zhang /* Allocate space for apj, initialize apj, and */ 866cf1a0672SHong Zhang /* destroy list of free space and other temporary array(s) */ 867854ce69bSBarry Smith ierr = PetscMalloc1(api[am]+1,&ptap->apj);CHKERRQ(ierr); 868cf1a0672SHong Zhang apj = ptap->apj; 869cf1a0672SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 870f84c536bSHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 871cf1a0672SHong Zhang 8724222ddf1SHong Zhang /* create and assemble symbolic parallel matrix C */ 873cf1a0672SHong Zhang /*----------------------------------------------------*/ 8744222ddf1SHong Zhang ierr = MatSetSizes(C,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 8754222ddf1SHong Zhang ierr = MatSetBlockSizesFromMats(C,A,P);CHKERRQ(ierr); 876b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 8774222ddf1SHong Zhang ierr = MatSetType(C,mtype);CHKERRQ(ierr); 8784222ddf1SHong Zhang ierr = MatMPIAIJSetPreallocation(C,0,dnz,0,onz);CHKERRQ(ierr); 8790926fe31SStefano Zampini ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 880cf1a0672SHong Zhang 8814222ddf1SHong Zhang /* malloc apa for assembly C */ 882071fcb05SBarry Smith ierr = PetscCalloc1(apnz_max,&ptap->apa);CHKERRQ(ierr); 88317f75172Sandi selinger 8844222ddf1SHong Zhang ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat_Symbolic(C, apj, api);CHKERRQ(ierr); 8854222ddf1SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 8864222ddf1SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 8870926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 888cf1a0672SHong Zhang 8894222ddf1SHong Zhang C->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ; 8904222ddf1SHong Zhang C->ops->productnumeric = MatProductNumeric_AB; 891cf1a0672SHong Zhang 8924222ddf1SHong Zhang /* attach the supporting struct to C for reuse */ 8936718818eSStefano Zampini C->product->data = ptap; 8946718818eSStefano Zampini C->product->destroy = MatDestroy_MPIAIJ_MatMatMult; 895cf1a0672SHong Zhang 896cf1a0672SHong Zhang /* set MatInfo */ 897118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 898cf1a0672SHong Zhang if (afill < 1.0) afill = 1.0; 8994222ddf1SHong Zhang C->info.mallocs = nspacedouble; 9004222ddf1SHong Zhang C->info.fill_ratio_given = fill; 9014222ddf1SHong Zhang C->info.fill_ratio_needed = afill; 902cf1a0672SHong Zhang 903cf1a0672SHong Zhang #if defined(PETSC_USE_INFO) 904cf1a0672SHong Zhang if (api[am]) { 9054222ddf1SHong Zhang ierr = PetscInfo3(C,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 9064222ddf1SHong Zhang ierr = PetscInfo1(C,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 907cf1a0672SHong Zhang } else { 9084222ddf1SHong Zhang ierr = PetscInfo(C,"Empty matrix product\n");CHKERRQ(ierr); 909cf1a0672SHong Zhang } 910cf1a0672SHong Zhang #endif 9111634b032SHong Zhang PetscFunctionReturn(0); 9121634b032SHong Zhang } 913f96d37fcSHong Zhang 914a9d7e0ccSandi selinger /* This function is needed for the seqMPI matrix-matrix multiplication. */ 915a9d7e0ccSandi selinger /* Three input arrays are merged to one output array. The size of the */ 916a9d7e0ccSandi selinger /* output array is also output. Duplicate entries only show up once. */ 917a9d7e0ccSandi selinger static void Merge3SortedArrays(PetscInt size1, PetscInt *in1, 918a9d7e0ccSandi selinger PetscInt size2, PetscInt *in2, 919a9d7e0ccSandi selinger PetscInt size3, PetscInt *in3, 920a9d7e0ccSandi selinger PetscInt *size4, PetscInt *out) 921a9d7e0ccSandi selinger { 922a9d7e0ccSandi selinger int i = 0, j = 0, k = 0, l = 0; 923a9d7e0ccSandi selinger 924a9d7e0ccSandi selinger /* Traverse all three arrays */ 925a9d7e0ccSandi selinger while (i<size1 && j<size2 && k<size3) { 926a9d7e0ccSandi selinger if (in1[i] < in2[j] && in1[i] < in3[k]) { 927a9d7e0ccSandi selinger out[l++] = in1[i++]; 928a9d7e0ccSandi selinger } 929a9d7e0ccSandi selinger else if (in2[j] < in1[i] && in2[j] < in3[k]) { 930a9d7e0ccSandi selinger out[l++] = in2[j++]; 931a9d7e0ccSandi selinger } 932a9d7e0ccSandi selinger else if (in3[k] < in1[i] && in3[k] < in2[j]) { 933a9d7e0ccSandi selinger out[l++] = in3[k++]; 934a9d7e0ccSandi selinger } 935a9d7e0ccSandi selinger else if (in1[i] == in2[j] && in1[i] < in3[k]) { 936a9d7e0ccSandi selinger out[l++] = in1[i]; 937a9d7e0ccSandi selinger i++, j++; 938a9d7e0ccSandi selinger } 939a9d7e0ccSandi selinger else if (in1[i] == in3[k] && in1[i] < in2[j]) { 940a9d7e0ccSandi selinger out[l++] = in1[i]; 941a9d7e0ccSandi selinger i++, k++; 942a9d7e0ccSandi selinger } 943a9d7e0ccSandi selinger else if (in3[k] == in2[j] && in2[j] < in1[i]) { 944a9d7e0ccSandi selinger out[l++] = in2[j]; 945a9d7e0ccSandi selinger k++, j++; 946a9d7e0ccSandi selinger } 947a9d7e0ccSandi selinger else if (in1[i] == in2[j] && in1[i] == in3[k]) { 948a9d7e0ccSandi selinger out[l++] = in1[i]; 949a9d7e0ccSandi selinger i++, j++, k++; 950a9d7e0ccSandi selinger } 951a9d7e0ccSandi selinger } 952a9d7e0ccSandi selinger 953a9d7e0ccSandi selinger /* Traverse two remaining arrays */ 954a9d7e0ccSandi selinger while (i<size1 && j<size2) { 955a9d7e0ccSandi selinger if (in1[i] < in2[j]) { 956a9d7e0ccSandi selinger out[l++] = in1[i++]; 957a9d7e0ccSandi selinger } 958a9d7e0ccSandi selinger else if (in1[i] > in2[j]) { 959a9d7e0ccSandi selinger out[l++] = in2[j++]; 960a9d7e0ccSandi selinger } 961a9d7e0ccSandi selinger else { 962a9d7e0ccSandi selinger out[l++] = in1[i]; 963a9d7e0ccSandi selinger i++, j++; 964a9d7e0ccSandi selinger } 965a9d7e0ccSandi selinger } 966a9d7e0ccSandi selinger 967a9d7e0ccSandi selinger while (i<size1 && k<size3) { 968a9d7e0ccSandi selinger if (in1[i] < in3[k]) { 969a9d7e0ccSandi selinger out[l++] = in1[i++]; 970a9d7e0ccSandi selinger } 971a9d7e0ccSandi selinger else if (in1[i] > in3[k]) { 972a9d7e0ccSandi selinger out[l++] = in3[k++]; 973a9d7e0ccSandi selinger } 974a9d7e0ccSandi selinger else { 975a9d7e0ccSandi selinger out[l++] = in1[i]; 976a9d7e0ccSandi selinger i++, k++; 977a9d7e0ccSandi selinger } 978a9d7e0ccSandi selinger } 979a9d7e0ccSandi selinger 980a9d7e0ccSandi selinger while (k<size3 && j<size2) { 981a9d7e0ccSandi selinger if (in3[k] < in2[j]) { 982a9d7e0ccSandi selinger out[l++] = in3[k++]; 983a9d7e0ccSandi selinger } 984a9d7e0ccSandi selinger else if (in3[k] > in2[j]) { 985a9d7e0ccSandi selinger out[l++] = in2[j++]; 986a9d7e0ccSandi selinger } 987a9d7e0ccSandi selinger else { 988a9d7e0ccSandi selinger out[l++] = in3[k]; 989a9d7e0ccSandi selinger k++, j++; 990a9d7e0ccSandi selinger } 991a9d7e0ccSandi selinger } 992a9d7e0ccSandi selinger 993a9d7e0ccSandi selinger /* Traverse one remaining array */ 994a9d7e0ccSandi selinger while (i<size1) out[l++] = in1[i++]; 995a9d7e0ccSandi selinger while (j<size2) out[l++] = in2[j++]; 996a9d7e0ccSandi selinger while (k<size3) out[l++] = in3[k++]; 997a9d7e0ccSandi selinger 998a9d7e0ccSandi selinger *size4 = l; 999a9d7e0ccSandi selinger } 1000a9d7e0ccSandi selinger 100173b67375Sandi selinger /* This matrix-matrix multiplication algorithm divides the multiplication into three multiplications and */ 100273b67375Sandi selinger /* adds up the products. Two of these three multiplications are performed with existing (sequential) */ 100373b67375Sandi selinger /* matrix-matrix multiplications. */ 10044222ddf1SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_seqMPI(Mat A, Mat P, PetscReal fill, Mat C) 1005a9d7e0ccSandi selinger { 1006a9d7e0ccSandi selinger PetscErrorCode ierr; 1007a9d7e0ccSandi selinger MPI_Comm comm; 1008a9d7e0ccSandi selinger PetscMPIInt size; 10093cdca5ebSHong Zhang Mat_APMPI *ptap; 1010a9d7e0ccSandi selinger PetscFreeSpaceList free_space_diag=NULL, current_space=NULL; 1011a9d7e0ccSandi selinger Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data; 1012a9d7e0ccSandi selinger Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc; 1013a9d7e0ccSandi selinger Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data; 1014a9d7e0ccSandi selinger Mat_SeqAIJ *adpd_seq, *p_off, *aopoth_seq; 1015a9d7e0ccSandi selinger PetscInt adponz, adpdnz; 10167dbaa2c6Sandi selinger PetscInt *pi_loc,*dnz,*onz; 1017a9d7e0ccSandi selinger PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,rstart=A->rmap->rstart; 1018a9d7e0ccSandi selinger PetscInt *lnk,i, i1=0,pnz,row,*adpoi,*adpoj, *api, *adpoJ, *aopJ, *apJ,*Jptr, aopnz, nspacedouble=0,j,nzi, 1019a9d7e0ccSandi selinger *apj,apnz, *adpdi, *adpdj, *adpdJ, *poff_i, *poff_j, *j_temp, *aopothi, *aopothj; 1020a016958eSandi selinger PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n, p_colstart, p_colend; 1021a9d7e0ccSandi selinger PetscBT lnkbt; 1022a9d7e0ccSandi selinger PetscReal afill; 1023a9d7e0ccSandi selinger PetscMPIInt rank; 1024a9d7e0ccSandi selinger Mat adpd, aopoth; 1025b92f168fSBarry Smith MatType mtype; 1026e83e5f86SFande Kong const char *prefix; 1027a9d7e0ccSandi selinger 1028a9d7e0ccSandi selinger PetscFunctionBegin; 10296718818eSStefano Zampini MatCheckProduct(C,4); 10306718818eSStefano Zampini if (C->product->data) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_PLIB,"Extra product struct not empty"); 1031a9d7e0ccSandi selinger ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1032ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 1033ffc4695bSBarry Smith ierr = MPI_Comm_rank(comm, &rank);CHKERRMPI(ierr); 1034a016958eSandi selinger ierr = MatGetOwnershipRangeColumn(P, &p_colstart, &p_colend);CHKERRQ(ierr); 1035a9d7e0ccSandi selinger 10363cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 1037a9d7e0ccSandi selinger ierr = PetscNew(&ptap);CHKERRQ(ierr); 1038a9d7e0ccSandi selinger 1039a9d7e0ccSandi selinger /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 1040a9d7e0ccSandi selinger ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 1041a9d7e0ccSandi selinger 1042a9d7e0ccSandi selinger /* get P_loc by taking all local rows of P */ 1043a9d7e0ccSandi selinger ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 1044a9d7e0ccSandi selinger 1045a9d7e0ccSandi selinger 1046a9d7e0ccSandi selinger p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 1047a9d7e0ccSandi selinger pi_loc = p_loc->i; 1048a9d7e0ccSandi selinger 1049a9d7e0ccSandi selinger /* Allocate memory for the i arrays of the matrices A*P, A_diag*P_off and A_offd * P */ 1050a9d7e0ccSandi selinger ierr = PetscMalloc1(am+2,&api);CHKERRQ(ierr); 1051a9d7e0ccSandi selinger ierr = PetscMalloc1(am+2,&adpoi);CHKERRQ(ierr); 1052a9d7e0ccSandi selinger 1053a9d7e0ccSandi selinger adpoi[0] = 0; 1054a9d7e0ccSandi selinger ptap->api = api; 1055a9d7e0ccSandi selinger api[0] = 0; 1056a9d7e0ccSandi selinger 1057a9d7e0ccSandi selinger /* create and initialize a linked list, will be used for both A_diag * P_loc_off and A_offd * P_oth */ 1058a9d7e0ccSandi selinger ierr = PetscLLCondensedCreate(pN,pN,&lnk,&lnkbt);CHKERRQ(ierr); 1059a9d7e0ccSandi selinger ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 1060a9d7e0ccSandi selinger 1061a9d7e0ccSandi selinger /* Symbolic calc of A_loc_diag * P_loc_diag */ 1062e83e5f86SFande Kong ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr); 10634222ddf1SHong Zhang ierr = MatProductCreate(a->A,p->A,NULL,&adpd);CHKERRQ(ierr); 10644222ddf1SHong Zhang ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr); 10654222ddf1SHong Zhang ierr = MatSetOptionsPrefix(adpd,prefix);CHKERRQ(ierr); 10664222ddf1SHong Zhang ierr = MatAppendOptionsPrefix(adpd,"inner_diag_");CHKERRQ(ierr); 10674222ddf1SHong Zhang 10684222ddf1SHong Zhang ierr = MatProductSetType(adpd,MATPRODUCT_AB);CHKERRQ(ierr); 10694222ddf1SHong Zhang ierr = MatProductSetAlgorithm(adpd,"sorted");CHKERRQ(ierr); 10704222ddf1SHong Zhang ierr = MatProductSetFill(adpd,fill);CHKERRQ(ierr); 10714222ddf1SHong Zhang ierr = MatProductSetFromOptions(adpd);CHKERRQ(ierr); 10728c78258cSHong Zhang 10738c78258cSHong Zhang adpd->force_diagonals = C->force_diagonals; 10744222ddf1SHong Zhang ierr = MatProductSymbolic(adpd);CHKERRQ(ierr); 10754222ddf1SHong Zhang 1076a9d7e0ccSandi selinger adpd_seq = (Mat_SeqAIJ*)((adpd)->data); 1077a9d7e0ccSandi selinger adpdi = adpd_seq->i; adpdj = adpd_seq->j; 1078a9d7e0ccSandi selinger p_off = (Mat_SeqAIJ*)((p->B)->data); 1079a9d7e0ccSandi selinger poff_i = p_off->i; poff_j = p_off->j; 1080a9d7e0ccSandi selinger 108173b67375Sandi selinger /* j_temp stores indices of a result row before they are added to the linked list */ 1082a9d7e0ccSandi selinger ierr = PetscMalloc1(pN+2,&j_temp);CHKERRQ(ierr); 1083a9d7e0ccSandi selinger 1084a9d7e0ccSandi selinger 1085a9d7e0ccSandi selinger /* Symbolic calc of the A_diag * p_loc_off */ 1086a9d7e0ccSandi selinger /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 1087a9d7e0ccSandi selinger ierr = PetscFreeSpaceGet(PetscRealIntMultTruncate(fill,PetscIntSumTruncate(adi[am],PetscIntSumTruncate(aoi[am],pi_loc[pm]))),&free_space_diag);CHKERRQ(ierr); 1088a9d7e0ccSandi selinger current_space = free_space_diag; 1089a9d7e0ccSandi selinger 1090a9d7e0ccSandi selinger for (i=0; i<am; i++) { 1091a9d7e0ccSandi selinger /* A_diag * P_loc_off */ 1092a9d7e0ccSandi selinger nzi = adi[i+1] - adi[i]; 1093a9d7e0ccSandi selinger for (j=0; j<nzi; j++) { 1094a9d7e0ccSandi selinger row = *adj++; 1095a9d7e0ccSandi selinger pnz = poff_i[row+1] - poff_i[row]; 1096a9d7e0ccSandi selinger Jptr = poff_j + poff_i[row]; 1097a9d7e0ccSandi selinger for (i1 = 0; i1 < pnz; i1++) { 1098a9d7e0ccSandi selinger j_temp[i1] = p->garray[Jptr[i1]]; 1099a9d7e0ccSandi selinger } 1100a9d7e0ccSandi selinger /* add non-zero cols of P into the sorted linked list lnk */ 1101a9d7e0ccSandi selinger ierr = PetscLLCondensedAddSorted(pnz,j_temp,lnk,lnkbt);CHKERRQ(ierr); 1102a9d7e0ccSandi selinger } 1103a9d7e0ccSandi selinger 1104a9d7e0ccSandi selinger adponz = lnk[0]; 1105a9d7e0ccSandi selinger adpoi[i+1] = adpoi[i] + adponz; 1106a9d7e0ccSandi selinger 1107a9d7e0ccSandi selinger /* if free space is not available, double the total space in the list */ 1108a9d7e0ccSandi selinger if (current_space->local_remaining<adponz) { 1109a9d7e0ccSandi selinger ierr = PetscFreeSpaceGet(PetscIntSumTruncate(adponz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 1110a9d7e0ccSandi selinger nspacedouble++; 1111a9d7e0ccSandi selinger } 1112a9d7e0ccSandi selinger 1113a9d7e0ccSandi selinger /* Copy data into free space, then initialize lnk */ 1114a9d7e0ccSandi selinger ierr = PetscLLCondensedClean(pN,adponz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1115a9d7e0ccSandi selinger 1116a9d7e0ccSandi selinger current_space->array += adponz; 1117a9d7e0ccSandi selinger current_space->local_used += adponz; 1118a9d7e0ccSandi selinger current_space->local_remaining -= adponz; 1119a9d7e0ccSandi selinger } 1120a9d7e0ccSandi selinger 1121a9d7e0ccSandi selinger /* Symbolic calc of A_off * P_oth */ 1122e83e5f86SFande Kong ierr = MatSetOptionsPrefix(a->B,prefix);CHKERRQ(ierr); 1123e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(a->B,"inner_offdiag_");CHKERRQ(ierr); 11244222ddf1SHong Zhang ierr = MatCreate(PETSC_COMM_SELF,&aopoth);CHKERRQ(ierr); 11254222ddf1SHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(a->B, ptap->P_oth, fill, aopoth);CHKERRQ(ierr); 1126a9d7e0ccSandi selinger aopoth_seq = (Mat_SeqAIJ*)((aopoth)->data); 1127a9d7e0ccSandi selinger aopothi = aopoth_seq->i; aopothj = aopoth_seq->j; 1128a9d7e0ccSandi selinger 1129a9d7e0ccSandi selinger /* Allocate space for apj, adpj, aopj, ... */ 1130a9d7e0ccSandi selinger /* destroy lists of free space and other temporary array(s) */ 1131a9d7e0ccSandi selinger 1132a9d7e0ccSandi selinger ierr = PetscMalloc1(aopothi[am] + adpoi[am] + adpdi[am]+2, &ptap->apj);CHKERRQ(ierr); 1133a9d7e0ccSandi selinger ierr = PetscMalloc1(adpoi[am]+2, &adpoj);CHKERRQ(ierr); 1134a9d7e0ccSandi selinger 1135a9d7e0ccSandi selinger /* Copy from linked list to j-array */ 1136a9d7e0ccSandi selinger ierr = PetscFreeSpaceContiguous(&free_space_diag,adpoj);CHKERRQ(ierr); 1137a9d7e0ccSandi selinger ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 1138a9d7e0ccSandi selinger 1139a9d7e0ccSandi selinger adpoJ = adpoj; 1140a9d7e0ccSandi selinger adpdJ = adpdj; 1141a9d7e0ccSandi selinger aopJ = aopothj; 1142a9d7e0ccSandi selinger apj = ptap->apj; 1143a9d7e0ccSandi selinger apJ = apj; /* still empty */ 1144a9d7e0ccSandi selinger 1145a9d7e0ccSandi selinger /* Merge j-arrays of A_off * P, A_diag * P_loc_off, and */ 1146a9d7e0ccSandi selinger /* A_diag * P_loc_diag to get A*P */ 1147a9d7e0ccSandi selinger for (i = 0; i < am; i++) { 1148a9d7e0ccSandi selinger aopnz = aopothi[i+1] - aopothi[i]; 1149a9d7e0ccSandi selinger adponz = adpoi[i+1] - adpoi[i]; 1150a9d7e0ccSandi selinger adpdnz = adpdi[i+1] - adpdi[i]; 1151a9d7e0ccSandi selinger 1152a9d7e0ccSandi selinger /* Correct indices from A_diag*P_diag */ 1153a9d7e0ccSandi selinger for (i1 = 0; i1 < adpdnz; i1++) { 1154a016958eSandi selinger adpdJ[i1] += p_colstart; 1155a9d7e0ccSandi selinger } 1156a9d7e0ccSandi selinger /* Merge j-arrays of A_diag * P_loc_off and A_diag * P_loc_diag and A_off * P_oth */ 1157a9d7e0ccSandi selinger Merge3SortedArrays(adponz, adpoJ, adpdnz, adpdJ, aopnz, aopJ, &apnz, apJ); 1158a9d7e0ccSandi selinger ierr = MatPreallocateSet(i+rstart, apnz, apJ, dnz, onz);CHKERRQ(ierr); 1159a9d7e0ccSandi selinger 1160a9d7e0ccSandi selinger aopJ += aopnz; 1161a9d7e0ccSandi selinger adpoJ += adponz; 1162a9d7e0ccSandi selinger adpdJ += adpdnz; 1163a9d7e0ccSandi selinger apJ += apnz; 1164a9d7e0ccSandi selinger api[i+1] = api[i] + apnz; 1165a9d7e0ccSandi selinger } 1166a9d7e0ccSandi selinger 1167a9d7e0ccSandi selinger /* malloc apa to store dense row A[i,:]*P */ 1168071fcb05SBarry Smith ierr = PetscCalloc1(pN+2,&ptap->apa);CHKERRQ(ierr); 1169a9d7e0ccSandi selinger 11704222ddf1SHong Zhang /* create and assemble symbolic parallel matrix C */ 11714222ddf1SHong Zhang ierr = MatSetSizes(C,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 11724222ddf1SHong Zhang ierr = MatSetBlockSizesFromMats(C,A,P);CHKERRQ(ierr); 1173b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 11744222ddf1SHong Zhang ierr = MatSetType(C,mtype);CHKERRQ(ierr); 11754222ddf1SHong Zhang ierr = MatMPIAIJSetPreallocation(C,0,dnz,0,onz);CHKERRQ(ierr); 11760926fe31SStefano Zampini ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 117717f75172Sandi selinger 11784222ddf1SHong Zhang ierr = MatSetValues_MPIAIJ_CopyFromCSRFormat_Symbolic(C, apj, api);CHKERRQ(ierr); 11794222ddf1SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 11804222ddf1SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 11810926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 118217f75172Sandi selinger 11834222ddf1SHong Zhang C->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 11844222ddf1SHong Zhang C->ops->productnumeric = MatProductNumeric_AB; 1185a9d7e0ccSandi selinger 11864222ddf1SHong Zhang /* attach the supporting struct to C for reuse */ 11876718818eSStefano Zampini C->product->data = ptap; 11886718818eSStefano Zampini C->product->destroy = MatDestroy_MPIAIJ_MatMatMult; 1189a9d7e0ccSandi selinger 1190a9d7e0ccSandi selinger /* set MatInfo */ 119173b67375Sandi selinger afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 119273b67375Sandi selinger if (afill < 1.0) afill = 1.0; 11934222ddf1SHong Zhang C->info.mallocs = nspacedouble; 11944222ddf1SHong Zhang C->info.fill_ratio_given = fill; 11954222ddf1SHong Zhang C->info.fill_ratio_needed = afill; 1196a9d7e0ccSandi selinger 1197a9d7e0ccSandi selinger #if defined(PETSC_USE_INFO) 1198a9d7e0ccSandi selinger if (api[am]) { 11994222ddf1SHong Zhang ierr = PetscInfo3(C,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 12004222ddf1SHong Zhang ierr = PetscInfo1(C,"Use MatMatMult(A,B,MatReuse,%g,&C) for best performance.;\n",(double)afill);CHKERRQ(ierr); 1201a9d7e0ccSandi selinger } else { 12024222ddf1SHong Zhang ierr = PetscInfo(C,"Empty matrix product\n");CHKERRQ(ierr); 1203a9d7e0ccSandi selinger } 1204a9d7e0ccSandi selinger #endif 1205a9d7e0ccSandi selinger 120673b67375Sandi selinger ierr = MatDestroy(&aopoth);CHKERRQ(ierr); 120773b67375Sandi selinger ierr = MatDestroy(&adpd);CHKERRQ(ierr); 120873b67375Sandi selinger ierr = PetscFree(j_temp);CHKERRQ(ierr); 120973b67375Sandi selinger ierr = PetscFree(adpoj);CHKERRQ(ierr); 121073b67375Sandi selinger ierr = PetscFree(adpoi);CHKERRQ(ierr); 1211a9d7e0ccSandi selinger PetscFunctionReturn(0); 1212a9d7e0ccSandi selinger } 1213a9d7e0ccSandi selinger 1214f96d37fcSHong Zhang /*-------------------------------------------------------------------------*/ 1215c216dbf3SHong Zhang /* This routine only works when scall=MAT_REUSE_MATRIX! */ 1216c216dbf3SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult(Mat P,Mat A,Mat C) 1217c216dbf3SHong Zhang { 1218c216dbf3SHong Zhang PetscErrorCode ierr; 12196718818eSStefano Zampini Mat_APMPI *ptap; 122060552ceaSHong Zhang Mat Pt; 1221c216dbf3SHong Zhang 1222c216dbf3SHong Zhang PetscFunctionBegin; 12236718818eSStefano Zampini MatCheckProduct(C,3); 12246718818eSStefano Zampini ptap = (Mat_APMPI*)C->product->data; 12256718818eSStefano Zampini if (!ptap) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be computed. Missing data"); 12266718818eSStefano Zampini if (!ptap->Pt) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtA cannot be reused. Do not call MatProductClear()"); 122760552ceaSHong Zhang 122860552ceaSHong Zhang Pt = ptap->Pt; 1229c216dbf3SHong Zhang ierr = MatTranspose(P,MAT_REUSE_MATRIX,&Pt);CHKERRQ(ierr); 12304222ddf1SHong Zhang ierr = MatMatMultNumeric_MPIAIJ_MPIAIJ(Pt,A,C);CHKERRQ(ierr); 1231f96d37fcSHong Zhang PetscFunctionReturn(0); 1232f96d37fcSHong Zhang } 1233f96d37fcSHong Zhang 1234c5af039cSHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ() */ 12354222ddf1SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,PetscReal fill,Mat C) 1236912837bbSHong Zhang { 1237912837bbSHong Zhang PetscErrorCode ierr; 12383cdca5ebSHong Zhang Mat_APMPI *ptap; 12396718818eSStefano Zampini Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data; 1240912837bbSHong Zhang MPI_Comm comm; 1241912837bbSHong Zhang PetscMPIInt size,rank; 1242912837bbSHong Zhang PetscFreeSpaceList free_space=NULL,current_space=NULL; 12434ede91e3SHong Zhang PetscInt pn=P->cmap->n,aN=A->cmap->N,an=A->cmap->n; 124469be949aSStefano Zampini PetscInt *lnk,i,k,nsend,rstart; 1245912837bbSHong Zhang PetscBT lnkbt; 1246ec4bef21SJose E. Roman PetscMPIInt tagi,tagj,*len_si,*len_s,*len_ri,nrecv; 1247ec4bef21SJose E. Roman PETSC_UNUSED PetscMPIInt icompleted=0; 12488c78258cSHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k,row,ncols,*cols; 12497f3e1f30SHong Zhang PetscInt len,proc,*dnz,*onz,*owners,nzi; 1250912837bbSHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1251912837bbSHong Zhang MPI_Request *swaits,*rwaits; 1252912837bbSHong Zhang MPI_Status *sstatus,rstatus; 1253912837bbSHong Zhang PetscLayout rowmap; 1254912837bbSHong Zhang PetscInt *owners_co,*coi,*coj; /* i and j array of (p->B)^T*A*P - used in the communication */ 1255912837bbSHong Zhang PetscMPIInt *len_r,*id_r; /* array of length of comm->size, store send/recv matrix values */ 12567f3e1f30SHong Zhang PetscInt *Jptr,*prmap=p->garray,con,j,Crmax; 12574ede91e3SHong Zhang Mat_SeqAIJ *a_loc,*c_loc,*c_oth; 1258912837bbSHong Zhang PetscTable ta; 1259b92f168fSBarry Smith MatType mtype; 1260e83e5f86SFande Kong const char *prefix; 1261912837bbSHong Zhang 1262912837bbSHong Zhang PetscFunctionBegin; 1263912837bbSHong Zhang ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1264ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 1265ffc4695bSBarry Smith ierr = MPI_Comm_rank(comm,&rank);CHKERRMPI(ierr); 1266912837bbSHong Zhang 12674222ddf1SHong Zhang /* create symbolic parallel matrix C */ 1268b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 12694222ddf1SHong Zhang ierr = MatSetType(C,mtype);CHKERRQ(ierr); 1270912837bbSHong Zhang 12714222ddf1SHong Zhang C->ops->transposematmultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 1272912837bbSHong Zhang 12733cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 1274912837bbSHong Zhang ierr = PetscNew(&ptap);CHKERRQ(ierr); 1275912837bbSHong Zhang ptap->reuse = MAT_INITIAL_MATRIX; 1276912837bbSHong Zhang 1277912837bbSHong Zhang /* (0) compute Rd = Pd^T, Ro = Po^T */ 1278912837bbSHong Zhang /* --------------------------------- */ 1279912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->A,MAT_INITIAL_MATRIX,&ptap->Rd);CHKERRQ(ierr); 1280912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->B,MAT_INITIAL_MATRIX,&ptap->Ro);CHKERRQ(ierr); 1281912837bbSHong Zhang 1282669e9c86SHong Zhang /* (1) compute symbolic A_loc */ 1283669e9c86SHong Zhang /* ---------------------------*/ 12844ede91e3SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&ptap->A_loc);CHKERRQ(ierr); 1285912837bbSHong Zhang 12864ede91e3SHong Zhang /* (2-1) compute symbolic C_oth = Ro*A_loc */ 1287912837bbSHong Zhang /* ------------------------------------ */ 1288e83e5f86SFande Kong ierr = MatGetOptionsPrefix(A,&prefix);CHKERRQ(ierr); 1289e83e5f86SFande Kong ierr = MatSetOptionsPrefix(ptap->Ro,prefix);CHKERRQ(ierr); 1290e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(ptap->Ro,"inner_offdiag_");CHKERRQ(ierr); 12914222ddf1SHong Zhang ierr = MatCreate(PETSC_COMM_SELF,&ptap->C_oth);CHKERRQ(ierr); 12924222ddf1SHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Ro,ptap->A_loc,fill,ptap->C_oth);CHKERRQ(ierr); 1293912837bbSHong Zhang 1294912837bbSHong Zhang /* (3) send coj of C_oth to other processors */ 1295912837bbSHong Zhang /* ------------------------------------------ */ 1296912837bbSHong Zhang /* determine row ownership */ 1297912837bbSHong Zhang ierr = PetscLayoutCreate(comm,&rowmap);CHKERRQ(ierr); 1298912837bbSHong Zhang rowmap->n = pn; 1299912837bbSHong Zhang rowmap->bs = 1; 1300912837bbSHong Zhang ierr = PetscLayoutSetUp(rowmap);CHKERRQ(ierr); 1301912837bbSHong Zhang owners = rowmap->range; 1302912837bbSHong Zhang 1303912837bbSHong Zhang /* determine the number of messages to send, their lengths */ 1304912837bbSHong Zhang ierr = PetscMalloc4(size,&len_s,size,&len_si,size,&sstatus,size+2,&owners_co);CHKERRQ(ierr); 1305580bdb30SBarry Smith ierr = PetscArrayzero(len_s,size);CHKERRQ(ierr); 1306580bdb30SBarry Smith ierr = PetscArrayzero(len_si,size);CHKERRQ(ierr); 1307912837bbSHong Zhang 1308912837bbSHong Zhang c_oth = (Mat_SeqAIJ*)ptap->C_oth->data; 1309912837bbSHong Zhang coi = c_oth->i; coj = c_oth->j; 1310912837bbSHong Zhang con = ptap->C_oth->rmap->n; 1311912837bbSHong Zhang proc = 0; 1312912837bbSHong Zhang for (i=0; i<con; i++) { 1313912837bbSHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 13147f3e1f30SHong Zhang len_si[proc]++; /* num of rows in Co(=Pt*A) to be sent to [proc] */ 1315912837bbSHong Zhang len_s[proc] += coi[i+1] - coi[i]; /* num of nonzeros in Co to be sent to [proc] */ 1316912837bbSHong Zhang } 1317912837bbSHong Zhang 1318912837bbSHong Zhang len = 0; /* max length of buf_si[], see (4) */ 1319912837bbSHong Zhang owners_co[0] = 0; 1320912837bbSHong Zhang nsend = 0; 1321912837bbSHong Zhang for (proc=0; proc<size; proc++) { 1322912837bbSHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1323912837bbSHong Zhang if (len_s[proc]) { 1324912837bbSHong Zhang nsend++; 1325912837bbSHong Zhang len_si[proc] = 2*(len_si[proc] + 1); /* length of buf_si to be sent to [proc] */ 1326912837bbSHong Zhang len += len_si[proc]; 1327912837bbSHong Zhang } 1328912837bbSHong Zhang } 1329912837bbSHong Zhang 1330912837bbSHong Zhang /* determine the number and length of messages to receive for coi and coj */ 1331912837bbSHong Zhang ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&nrecv);CHKERRQ(ierr); 1332912837bbSHong Zhang ierr = PetscGatherMessageLengths2(comm,nsend,nrecv,len_s,len_si,&id_r,&len_r,&len_ri);CHKERRQ(ierr); 1333912837bbSHong Zhang 1334912837bbSHong Zhang /* post the Irecv and Isend of coj */ 1335912837bbSHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1336912837bbSHong Zhang ierr = PetscPostIrecvInt(comm,tagj,nrecv,id_r,len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1337912837bbSHong Zhang ierr = PetscMalloc1(nsend+1,&swaits);CHKERRQ(ierr); 1338912837bbSHong Zhang for (proc=0, k=0; proc<size; proc++) { 1339912837bbSHong Zhang if (!len_s[proc]) continue; 1340912837bbSHong Zhang i = owners_co[proc]; 1341ffc4695bSBarry Smith ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRMPI(ierr); 1342912837bbSHong Zhang k++; 1343912837bbSHong Zhang } 1344912837bbSHong Zhang 13457f3e1f30SHong Zhang /* (2-2) compute symbolic C_loc = Rd*A_loc */ 1346912837bbSHong Zhang /* ---------------------------------------- */ 1347e83e5f86SFande Kong ierr = MatSetOptionsPrefix(ptap->Rd,prefix);CHKERRQ(ierr); 1348e83e5f86SFande Kong ierr = MatAppendOptionsPrefix(ptap->Rd,"inner_diag_");CHKERRQ(ierr); 13494222ddf1SHong Zhang ierr = MatCreate(PETSC_COMM_SELF,&ptap->C_loc);CHKERRQ(ierr); 13504222ddf1SHong Zhang ierr = MatMatMultSymbolic_SeqAIJ_SeqAIJ(ptap->Rd,ptap->A_loc,fill,ptap->C_loc);CHKERRQ(ierr); 1351912837bbSHong Zhang c_loc = (Mat_SeqAIJ*)ptap->C_loc->data; 1352912837bbSHong Zhang 1353912837bbSHong Zhang /* receives coj are complete */ 1354912837bbSHong Zhang for (i=0; i<nrecv; i++) { 1355ffc4695bSBarry Smith ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRMPI(ierr); 1356912837bbSHong Zhang } 1357912837bbSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1358ffc4695bSBarry Smith if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRMPI(ierr);} 1359912837bbSHong Zhang 1360912837bbSHong Zhang /* add received column indices into ta to update Crmax */ 13614ede91e3SHong Zhang a_loc = (Mat_SeqAIJ*)(ptap->A_loc)->data; 1362669e9c86SHong Zhang 1363669e9c86SHong Zhang /* create and initialize a linked list */ 13644ede91e3SHong Zhang ierr = PetscTableCreate(an,aN,&ta);CHKERRQ(ierr); /* for compute Crmax */ 13654ede91e3SHong Zhang MatRowMergeMax_SeqAIJ(a_loc,ptap->A_loc->rmap->N,ta); 1366669e9c86SHong Zhang 1367912837bbSHong Zhang for (k=0; k<nrecv; k++) {/* k-th received message */ 1368912837bbSHong Zhang Jptr = buf_rj[k]; 1369912837bbSHong Zhang for (j=0; j<len_r[k]; j++) { 1370912837bbSHong Zhang ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr); 1371912837bbSHong Zhang } 1372912837bbSHong Zhang } 1373912837bbSHong Zhang ierr = PetscTableGetCount(ta,&Crmax);CHKERRQ(ierr); 1374912837bbSHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 1375912837bbSHong Zhang 1376912837bbSHong Zhang /* (4) send and recv coi */ 1377912837bbSHong Zhang /*-----------------------*/ 1378912837bbSHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1379912837bbSHong Zhang ierr = PetscPostIrecvInt(comm,tagi,nrecv,id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1380912837bbSHong Zhang ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 1381912837bbSHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1382912837bbSHong Zhang for (proc=0,k=0; proc<size; proc++) { 1383912837bbSHong Zhang if (!len_s[proc]) continue; 1384912837bbSHong Zhang /* form outgoing message for i-structure: 1385912837bbSHong Zhang buf_si[0]: nrows to be sent 1386912837bbSHong Zhang [1:nrows]: row index (global) 1387912837bbSHong Zhang [nrows+1:2*nrows+1]: i-structure index 1388912837bbSHong Zhang */ 1389912837bbSHong Zhang /*-------------------------------------------*/ 1390912837bbSHong Zhang nrows = len_si[proc]/2 - 1; /* num of rows in Co to be sent to [proc] */ 1391912837bbSHong Zhang buf_si_i = buf_si + nrows+1; 1392912837bbSHong Zhang buf_si[0] = nrows; 1393912837bbSHong Zhang buf_si_i[0] = 0; 1394912837bbSHong Zhang nrows = 0; 1395912837bbSHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1396912837bbSHong Zhang nzi = coi[i+1] - coi[i]; 1397912837bbSHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1398912837bbSHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1399912837bbSHong Zhang nrows++; 1400912837bbSHong Zhang } 1401ffc4695bSBarry Smith ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRMPI(ierr); 1402912837bbSHong Zhang k++; 1403912837bbSHong Zhang buf_si += len_si[proc]; 1404912837bbSHong Zhang } 1405912837bbSHong Zhang for (i=0; i<nrecv; i++) { 1406ffc4695bSBarry Smith ierr = MPI_Waitany(nrecv,rwaits,&icompleted,&rstatus);CHKERRMPI(ierr); 1407912837bbSHong Zhang } 1408912837bbSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1409ffc4695bSBarry Smith if (nsend) {ierr = MPI_Waitall(nsend,swaits,sstatus);CHKERRMPI(ierr);} 1410912837bbSHong Zhang 1411912837bbSHong Zhang ierr = PetscFree4(len_s,len_si,sstatus,owners_co);CHKERRQ(ierr); 1412912837bbSHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1413912837bbSHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1414912837bbSHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1415912837bbSHong Zhang 14164222ddf1SHong Zhang /* (5) compute the local portion of C */ 1417912837bbSHong Zhang /* ------------------------------------------ */ 14184222ddf1SHong Zhang /* set initial free space to be Crmax, sufficient for holding nozeros in each row of C */ 1419912837bbSHong Zhang ierr = PetscFreeSpaceGet(Crmax,&free_space);CHKERRQ(ierr); 1420912837bbSHong Zhang current_space = free_space; 1421912837bbSHong Zhang 1422912837bbSHong Zhang ierr = PetscMalloc3(nrecv,&buf_ri_k,nrecv,&nextrow,nrecv,&nextci);CHKERRQ(ierr); 1423912837bbSHong Zhang for (k=0; k<nrecv; k++) { 1424912837bbSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1425912837bbSHong Zhang nrows = *buf_ri_k[k]; 1426912837bbSHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 1427912837bbSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1428912837bbSHong Zhang } 1429912837bbSHong Zhang 14304ede91e3SHong Zhang ierr = MatPreallocateInitialize(comm,pn,an,dnz,onz);CHKERRQ(ierr); 14314ede91e3SHong Zhang ierr = PetscLLCondensedCreate(Crmax,aN,&lnk,&lnkbt);CHKERRQ(ierr); 14328c78258cSHong Zhang for (i=0; i<pn; i++) { /* for each local row of C */ 14334222ddf1SHong Zhang /* add C_loc into C */ 1434912837bbSHong Zhang nzi = c_loc->i[i+1] - c_loc->i[i]; 1435912837bbSHong Zhang Jptr = c_loc->j + c_loc->i[i]; 1436912837bbSHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1437912837bbSHong Zhang 1438912837bbSHong Zhang /* add received col data into lnk */ 1439912837bbSHong Zhang for (k=0; k<nrecv; k++) { /* k-th received message */ 1440912837bbSHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1441912837bbSHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1442912837bbSHong Zhang Jptr = buf_rj[k] + *nextci[k]; 1443912837bbSHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1444912837bbSHong Zhang nextrow[k]++; nextci[k]++; 1445912837bbSHong Zhang } 1446912837bbSHong Zhang } 14478c78258cSHong Zhang 14488c78258cSHong Zhang /* add missing diagonal entry */ 14498c78258cSHong Zhang if (C->force_diagonals) { 14508c78258cSHong Zhang k = i + owners[rank]; /* column index */ 14518c78258cSHong Zhang ierr = PetscLLCondensedAddSorted(1,&k,lnk,lnkbt);CHKERRQ(ierr); 14528c78258cSHong Zhang } 14538c78258cSHong Zhang 1454912837bbSHong Zhang nzi = lnk[0]; 1455912837bbSHong Zhang 1456912837bbSHong Zhang /* copy data into free space, then initialize lnk */ 14574ede91e3SHong Zhang ierr = PetscLLCondensedClean(aN,nzi,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1458912837bbSHong Zhang ierr = MatPreallocateSet(i+owners[rank],nzi,current_space->array,dnz,onz);CHKERRQ(ierr); 1459912837bbSHong Zhang } 1460912837bbSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1461912837bbSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 1462912837bbSHong Zhang ierr = PetscFreeSpaceDestroy(free_space);CHKERRQ(ierr); 1463912837bbSHong Zhang 1464912837bbSHong Zhang /* local sizes and preallocation */ 14654222ddf1SHong Zhang ierr = MatSetSizes(C,pn,an,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 14664222ddf1SHong Zhang if (P->cmap->bs > 0) {ierr = PetscLayoutSetBlockSize(C->rmap,P->cmap->bs);CHKERRQ(ierr);} 14674222ddf1SHong Zhang if (A->cmap->bs > 0) {ierr = PetscLayoutSetBlockSize(C->cmap,A->cmap->bs);CHKERRQ(ierr);} 14684222ddf1SHong Zhang ierr = MatMPIAIJSetPreallocation(C,0,dnz,0,onz);CHKERRQ(ierr); 1469912837bbSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1470912837bbSHong Zhang 147169be949aSStefano Zampini /* add C_loc and C_oth to C */ 147269be949aSStefano Zampini ierr = MatGetOwnershipRange(C,&rstart,NULL);CHKERRQ(ierr); 147369be949aSStefano Zampini for (i=0; i<pn; i++) { 14748c78258cSHong Zhang ncols = c_loc->i[i+1] - c_loc->i[i]; 14758c78258cSHong Zhang cols = c_loc->j + c_loc->i[i]; 14768c78258cSHong Zhang row = rstart + i; 147798ebff05SHong Zhang ierr = MatSetValues(C,1,(const PetscInt*)&row,ncols,(const PetscInt*)cols,NULL,INSERT_VALUES);CHKERRQ(ierr); 14788c78258cSHong Zhang 14798c78258cSHong Zhang if (C->force_diagonals) { 14808c78258cSHong Zhang ierr = MatSetValues(C,1,(const PetscInt*)&row,1,(const PetscInt*)&row,NULL,INSERT_VALUES);CHKERRQ(ierr); 14818c78258cSHong Zhang } 148269be949aSStefano Zampini } 148369be949aSStefano Zampini for (i=0; i<con; i++) { 14848c78258cSHong Zhang ncols = c_oth->i[i+1] - c_oth->i[i]; 14858c78258cSHong Zhang cols = c_oth->j + c_oth->i[i]; 14868c78258cSHong Zhang row = prmap[i]; 148798ebff05SHong Zhang ierr = MatSetValues(C,1,(const PetscInt*)&row,ncols,(const PetscInt*)cols,NULL,INSERT_VALUES);CHKERRQ(ierr); 148869be949aSStefano Zampini } 148969be949aSStefano Zampini ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 149069be949aSStefano Zampini ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 14910926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 149269be949aSStefano Zampini 1493912837bbSHong Zhang /* members in merge */ 1494912837bbSHong Zhang ierr = PetscFree(id_r);CHKERRQ(ierr); 1495912837bbSHong Zhang ierr = PetscFree(len_r);CHKERRQ(ierr); 1496912837bbSHong Zhang ierr = PetscFree(buf_ri[0]);CHKERRQ(ierr); 1497912837bbSHong Zhang ierr = PetscFree(buf_ri);CHKERRQ(ierr); 1498912837bbSHong Zhang ierr = PetscFree(buf_rj[0]);CHKERRQ(ierr); 1499912837bbSHong Zhang ierr = PetscFree(buf_rj);CHKERRQ(ierr); 1500912837bbSHong Zhang ierr = PetscLayoutDestroy(&rowmap);CHKERRQ(ierr); 1501912837bbSHong Zhang 15024222ddf1SHong Zhang /* attach the supporting struct to C for reuse */ 15036718818eSStefano Zampini C->product->data = ptap; 15046718818eSStefano Zampini C->product->destroy = MatDestroy_MPIAIJ_PtAP; 1505912837bbSHong Zhang PetscFunctionReturn(0); 1506912837bbSHong Zhang } 1507912837bbSHong Zhang 1508912837bbSHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,Mat C) 1509912837bbSHong Zhang { 1510912837bbSHong Zhang PetscErrorCode ierr; 15116718818eSStefano Zampini Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data; 1512669e9c86SHong Zhang Mat_SeqAIJ *c_seq; 15136718818eSStefano Zampini Mat_APMPI *ptap; 1514669e9c86SHong Zhang Mat A_loc,C_loc,C_oth; 1515912837bbSHong Zhang PetscInt i,rstart,rend,cm,ncols,row; 1516912837bbSHong Zhang const PetscInt *cols; 1517912837bbSHong Zhang const PetscScalar *vals; 1518912837bbSHong Zhang 1519912837bbSHong Zhang PetscFunctionBegin; 15206718818eSStefano Zampini MatCheckProduct(C,3); 15216718818eSStefano Zampini ptap = (Mat_APMPI*)C->product->data; 15226718818eSStefano Zampini if (!ptap) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be computed. Missing data"); 15236718818eSStefano Zampini if (!ptap->A_loc) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtA cannot be reused. Do not call MatProductClear()"); 1524912837bbSHong Zhang ierr = MatZeroEntries(C);CHKERRQ(ierr); 1525912837bbSHong Zhang 1526912837bbSHong Zhang if (ptap->reuse == MAT_REUSE_MATRIX) { 1527669e9c86SHong Zhang /* These matrices are obtained in MatTransposeMatMultSymbolic() */ 1528669e9c86SHong Zhang /* 1) get R = Pd^T, Ro = Po^T */ 1529669e9c86SHong Zhang /*----------------------------*/ 1530912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->A,MAT_REUSE_MATRIX,&ptap->Rd);CHKERRQ(ierr); 1531912837bbSHong Zhang ierr = MatTranspose_SeqAIJ(p->B,MAT_REUSE_MATRIX,&ptap->Ro);CHKERRQ(ierr); 1532669e9c86SHong Zhang 1533669e9c86SHong Zhang /* 2) compute numeric A_loc */ 1534669e9c86SHong Zhang /*--------------------------*/ 15354ede91e3SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&ptap->A_loc);CHKERRQ(ierr); 1536912837bbSHong Zhang } 1537912837bbSHong Zhang 1538669e9c86SHong Zhang /* 3) C_loc = Rd*A_loc, C_oth = Ro*A_loc */ 15394ede91e3SHong Zhang A_loc = ptap->A_loc; 1540669e9c86SHong Zhang ierr = ((ptap->C_loc)->ops->matmultnumeric)(ptap->Rd,A_loc,ptap->C_loc);CHKERRQ(ierr); 1541669e9c86SHong Zhang ierr = ((ptap->C_oth)->ops->matmultnumeric)(ptap->Ro,A_loc,ptap->C_oth);CHKERRQ(ierr); 1542912837bbSHong Zhang C_loc = ptap->C_loc; 1543912837bbSHong Zhang C_oth = ptap->C_oth; 1544912837bbSHong Zhang 154569be949aSStefano Zampini /* add C_loc and C_oth to C */ 1546912837bbSHong Zhang ierr = MatGetOwnershipRange(C,&rstart,&rend);CHKERRQ(ierr); 1547912837bbSHong Zhang 1548912837bbSHong Zhang /* C_loc -> C */ 1549912837bbSHong Zhang cm = C_loc->rmap->N; 1550912837bbSHong Zhang c_seq = (Mat_SeqAIJ*)C_loc->data; 1551912837bbSHong Zhang cols = c_seq->j; 1552912837bbSHong Zhang vals = c_seq->a; 1553912837bbSHong Zhang for (i=0; i<cm; i++) { 1554912837bbSHong Zhang ncols = c_seq->i[i+1] - c_seq->i[i]; 1555912837bbSHong Zhang row = rstart + i; 1556912837bbSHong Zhang ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr); 1557912837bbSHong Zhang cols += ncols; vals += ncols; 1558912837bbSHong Zhang } 1559912837bbSHong Zhang 1560912837bbSHong Zhang /* Co -> C, off-processor part */ 1561912837bbSHong Zhang cm = C_oth->rmap->N; 1562912837bbSHong Zhang c_seq = (Mat_SeqAIJ*)C_oth->data; 1563912837bbSHong Zhang cols = c_seq->j; 1564912837bbSHong Zhang vals = c_seq->a; 1565912837bbSHong Zhang for (i=0; i<cm; i++) { 1566912837bbSHong Zhang ncols = c_seq->i[i+1] - c_seq->i[i]; 1567912837bbSHong Zhang row = p->garray[i]; 1568912837bbSHong Zhang ierr = MatSetValues(C,1,&row,ncols,cols,vals,ADD_VALUES);CHKERRQ(ierr); 1569912837bbSHong Zhang cols += ncols; vals += ncols; 1570912837bbSHong Zhang } 1571912837bbSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1572912837bbSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 15730926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 1574912837bbSHong Zhang 1575912837bbSHong Zhang ptap->reuse = MAT_REUSE_MATRIX; 1576912837bbSHong Zhang PetscFunctionReturn(0); 1577912837bbSHong Zhang } 1578912837bbSHong Zhang 15796da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ(Mat P,Mat A,Mat C) 1580d6ab1dc0SHong Zhang { 1581d6ab1dc0SHong Zhang PetscErrorCode ierr; 1582d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 15836718818eSStefano Zampini Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data; 1584d6ab1dc0SHong Zhang Mat_SeqAIJ *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data; 15853cdca5ebSHong Zhang Mat_APMPI *ptap; 1586e745005bSHong Zhang PetscInt *adj; 1587e745005bSHong Zhang PetscInt i,j,k,anz,pnz,row,*cj,nexta; 1588e745005bSHong Zhang MatScalar *ada,*ca,valtmp; 1589d6ab1dc0SHong Zhang PetscInt am=A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n; 1590ce94432eSBarry Smith MPI_Comm comm; 1591d6ab1dc0SHong Zhang PetscMPIInt size,rank,taga,*len_s; 1592d6ab1dc0SHong Zhang PetscInt *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci; 1593d6ab1dc0SHong Zhang PetscInt **buf_ri,**buf_rj; 1594d6ab1dc0SHong Zhang PetscInt cnz=0,*bj_i,*bi,*bj,bnz,nextcj; /* bi,bj,ba: local array of C(mpi mat) */ 1595d6ab1dc0SHong Zhang MPI_Request *s_waits,*r_waits; 1596d6ab1dc0SHong Zhang MPI_Status *status; 1597d6ab1dc0SHong Zhang MatScalar **abuf_r,*ba_i,*pA,*coa,*ba; 15984e201bd7SHong Zhang PetscInt *ai,*aj,*coi,*coj,*poJ,*pdJ; 1599d6ab1dc0SHong Zhang Mat A_loc; 1600d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc; 1601d6ab1dc0SHong Zhang 1602d6ab1dc0SHong Zhang PetscFunctionBegin; 16036718818eSStefano Zampini MatCheckProduct(C,3); 16046718818eSStefano Zampini ptap = (Mat_APMPI*)C->product->data; 16056718818eSStefano Zampini if (!ptap) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtAP cannot be computed. Missing data"); 16066718818eSStefano Zampini if (!ptap->A_loc) SETERRQ(PetscObjectComm((PetscObject)C),PETSC_ERR_ARG_WRONGSTATE,"PtA cannot be reused. Do not call MatProductClear()"); 1607ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 1608ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 1609ffc4695bSBarry Smith ierr = MPI_Comm_rank(comm,&rank);CHKERRMPI(ierr); 1610d6ab1dc0SHong Zhang 1611d6ab1dc0SHong Zhang merge = ptap->merge; 1612d6ab1dc0SHong Zhang 1613e745005bSHong Zhang /* 2) compute numeric C_seq = P_loc^T*A_loc */ 1614e745005bSHong Zhang /*------------------------------------------*/ 1615d6ab1dc0SHong Zhang /* get data from symbolic products */ 1616d6ab1dc0SHong Zhang coi = merge->coi; coj = merge->coj; 1617854ce69bSBarry Smith ierr = PetscCalloc1(coi[pon]+1,&coa);CHKERRQ(ierr); 1618d6ab1dc0SHong Zhang bi = merge->bi; bj = merge->bj; 1619d6ab1dc0SHong Zhang owners = merge->rowmap->range; 16201795a4d1SJed Brown ierr = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr); 1621d6ab1dc0SHong Zhang 1622d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1623d6ab1dc0SHong Zhang A_loc = ptap->A_loc; 1624d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr); 1625d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1626d6ab1dc0SHong Zhang ai = a_loc->i; 1627d6ab1dc0SHong Zhang aj = a_loc->j; 1628d6ab1dc0SHong Zhang 1629d6ab1dc0SHong Zhang for (i=0; i<am; i++) { 1630d6ab1dc0SHong Zhang anz = ai[i+1] - ai[i]; 1631d6ab1dc0SHong Zhang adj = aj + ai[i]; 1632d6ab1dc0SHong Zhang ada = a_loc->a + ai[i]; 1633d6ab1dc0SHong Zhang 1634d6ab1dc0SHong Zhang /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */ 1635e745005bSHong Zhang /*-------------------------------------------------------------*/ 1636d6ab1dc0SHong Zhang /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */ 1637d6ab1dc0SHong Zhang pnz = po->i[i+1] - po->i[i]; 1638d6ab1dc0SHong Zhang poJ = po->j + po->i[i]; 1639d6ab1dc0SHong Zhang pA = po->a + po->i[i]; 1640d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1641d6ab1dc0SHong Zhang row = poJ[j]; 1642d6ab1dc0SHong Zhang cj = coj + coi[row]; 1643d6ab1dc0SHong Zhang ca = coa + coi[row]; 1644e745005bSHong Zhang /* perform sparse axpy */ 1645e745005bSHong Zhang nexta = 0; 1646d6ab1dc0SHong Zhang valtmp = pA[j]; 1647e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1648e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1649e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1650e745005bSHong Zhang nexta++; 1651d6ab1dc0SHong Zhang } 1652e745005bSHong Zhang } 1653e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1654d6ab1dc0SHong Zhang } 1655d6ab1dc0SHong Zhang 1656d6ab1dc0SHong Zhang /* put the value into Cd (diagonal part) */ 1657d6ab1dc0SHong Zhang pnz = pd->i[i+1] - pd->i[i]; 1658d6ab1dc0SHong Zhang pdJ = pd->j + pd->i[i]; 1659d6ab1dc0SHong Zhang pA = pd->a + pd->i[i]; 1660d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1661d6ab1dc0SHong Zhang row = pdJ[j]; 1662d6ab1dc0SHong Zhang cj = bj + bi[row]; 1663d6ab1dc0SHong Zhang ca = ba + bi[row]; 1664e745005bSHong Zhang /* perform sparse axpy */ 1665e745005bSHong Zhang nexta = 0; 1666d6ab1dc0SHong Zhang valtmp = pA[j]; 1667e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1668e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1669e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1670e745005bSHong Zhang nexta++; 1671d6ab1dc0SHong Zhang } 1672e745005bSHong Zhang } 1673e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1674d6ab1dc0SHong Zhang } 1675d6ab1dc0SHong Zhang } 1676d6ab1dc0SHong Zhang 1677d6ab1dc0SHong Zhang /* 3) send and recv matrix values coa */ 1678d6ab1dc0SHong Zhang /*------------------------------------*/ 1679d6ab1dc0SHong Zhang buf_ri = merge->buf_ri; 1680d6ab1dc0SHong Zhang buf_rj = merge->buf_rj; 1681d6ab1dc0SHong Zhang len_s = merge->len_s; 1682d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr); 1683d6ab1dc0SHong Zhang ierr = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr); 1684d6ab1dc0SHong Zhang 1685dcca6d9dSJed Brown ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr); 1686d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 1687d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1688d6ab1dc0SHong Zhang i = merge->owners_co[proc]; 1689ffc4695bSBarry Smith ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRMPI(ierr); 1690d6ab1dc0SHong Zhang k++; 1691d6ab1dc0SHong Zhang } 1692ffc4695bSBarry Smith if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRMPI(ierr);} 1693ffc4695bSBarry Smith if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRMPI(ierr);} 1694d6ab1dc0SHong Zhang 1695d6ab1dc0SHong Zhang ierr = PetscFree2(s_waits,status);CHKERRQ(ierr); 1696d6ab1dc0SHong Zhang ierr = PetscFree(r_waits);CHKERRQ(ierr); 1697d6ab1dc0SHong Zhang ierr = PetscFree(coa);CHKERRQ(ierr); 1698d6ab1dc0SHong Zhang 1699d6ab1dc0SHong Zhang /* 4) insert local Cseq and received values into Cmpi */ 1700d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1701dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1702d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 1703e745005bSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1704d6ab1dc0SHong Zhang nrows = *(buf_ri_k[k]); 1705d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k]+1; /* next row number of k-th recved i-structure */ 1706d6ab1dc0SHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1707d6ab1dc0SHong Zhang } 1708d6ab1dc0SHong Zhang 1709d6ab1dc0SHong Zhang for (i=0; i<cm; i++) { 1710d6ab1dc0SHong Zhang row = owners[rank] + i; /* global row index of C_seq */ 1711d6ab1dc0SHong Zhang bj_i = bj + bi[i]; /* col indices of the i-th row of C */ 1712d6ab1dc0SHong Zhang ba_i = ba + bi[i]; 1713d6ab1dc0SHong Zhang bnz = bi[i+1] - bi[i]; 1714d6ab1dc0SHong Zhang /* add received vals into ba */ 1715d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1716d6ab1dc0SHong Zhang /* i-th row */ 1717d6ab1dc0SHong Zhang if (i == *nextrow[k]) { 1718d6ab1dc0SHong Zhang cnz = *(nextci[k]+1) - *nextci[k]; 1719d6ab1dc0SHong Zhang cj = buf_rj[k] + *(nextci[k]); 1720d6ab1dc0SHong Zhang ca = abuf_r[k] + *(nextci[k]); 1721d6ab1dc0SHong Zhang nextcj = 0; 1722d6ab1dc0SHong Zhang for (j=0; nextcj<cnz; j++) { 1723d6ab1dc0SHong Zhang if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */ 1724d6ab1dc0SHong Zhang ba_i[j] += ca[nextcj++]; 1725d6ab1dc0SHong Zhang } 1726d6ab1dc0SHong Zhang } 1727d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 1728d6ab1dc0SHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1729d6ab1dc0SHong Zhang } 1730d6ab1dc0SHong Zhang } 1731d6ab1dc0SHong Zhang ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr); 1732d6ab1dc0SHong Zhang } 1733d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1734d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1735d6ab1dc0SHong Zhang 1736d6ab1dc0SHong Zhang ierr = PetscFree(ba);CHKERRQ(ierr); 1737d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr); 1738d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r);CHKERRQ(ierr); 1739d6ab1dc0SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1740d6ab1dc0SHong Zhang PetscFunctionReturn(0); 1741d6ab1dc0SHong Zhang } 1742d6ab1dc0SHong Zhang 17434222ddf1SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(Mat P,Mat A,PetscReal fill,Mat C) 1744d6ab1dc0SHong Zhang { 1745d6ab1dc0SHong Zhang PetscErrorCode ierr; 1746b419842dSStefano Zampini Mat A_loc; 17473cdca5ebSHong Zhang Mat_APMPI *ptap; 17480298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 17496718818eSStefano Zampini Mat_MPIAIJ *p=(Mat_MPIAIJ*)P->data,*a=(Mat_MPIAIJ*)A->data; 1750d6ab1dc0SHong Zhang PetscInt *pdti,*pdtj,*poti,*potj,*ptJ; 1751d6ab1dc0SHong Zhang PetscInt nnz; 1752d6ab1dc0SHong Zhang PetscInt *lnk,*owners_co,*coi,*coj,i,k,pnz,row; 1753d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,pn=P->cmap->n; 1754ce94432eSBarry Smith MPI_Comm comm; 1755d6ab1dc0SHong Zhang PetscMPIInt size,rank,tagi,tagj,*len_si,*len_s,*len_ri; 1756d6ab1dc0SHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 1757d6ab1dc0SHong Zhang PetscInt len,proc,*dnz,*onz,*owners; 1758d6ab1dc0SHong Zhang PetscInt nzi,*bi,*bj; 1759d6ab1dc0SHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1760d6ab1dc0SHong Zhang MPI_Request *swaits,*rwaits; 1761d6ab1dc0SHong Zhang MPI_Status *sstatus,rstatus; 1762d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 1763d6ab1dc0SHong Zhang PetscInt *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j; 1764d6ab1dc0SHong Zhang PetscReal afill =1.0,afill_tmp; 17654b38b95cSHong Zhang PetscInt rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Armax; 1766b419842dSStefano Zampini Mat_SeqAIJ *a_loc; 17670acc65b4SHong Zhang PetscTable ta; 1768b92f168fSBarry Smith MatType mtype; 1769d6ab1dc0SHong Zhang 1770d6ab1dc0SHong Zhang PetscFunctionBegin; 1771ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1772d6ab1dc0SHong Zhang /* check if matrix local sizes are compatible */ 17736c4ed002SBarry 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); 1774d6ab1dc0SHong Zhang 1775ffc4695bSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRMPI(ierr); 1776ffc4695bSBarry Smith ierr = MPI_Comm_rank(comm,&rank);CHKERRMPI(ierr); 1777d6ab1dc0SHong Zhang 17783cdca5ebSHong Zhang /* create struct Mat_APMPI and attached it to C later */ 1779b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 1780d6ab1dc0SHong Zhang 1781d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1782d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr); 17832205254eSKarl Rupp 1784d6ab1dc0SHong Zhang ptap->A_loc = A_loc; 1785d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1786d6ab1dc0SHong Zhang ai = a_loc->i; 1787d6ab1dc0SHong Zhang aj = a_loc->j; 1788d6ab1dc0SHong Zhang 1789d6ab1dc0SHong Zhang /* determine symbolic Co=(p->B)^T*A - send to others */ 1790d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1791b419842dSStefano Zampini ierr = MatGetSymbolicTranspose_SeqAIJ(p->A,&pdti,&pdtj);CHKERRQ(ierr); 1792b419842dSStefano Zampini ierr = MatGetSymbolicTranspose_SeqAIJ(p->B,&poti,&potj);CHKERRQ(ierr); 1793d6ab1dc0SHong Zhang pon = (p->B)->cmap->n; /* total num of rows to be sent to other processors 1794d6ab1dc0SHong Zhang >= (num of nonzero rows of C_seq) - pn */ 1795854ce69bSBarry Smith ierr = PetscMalloc1(pon+1,&coi);CHKERRQ(ierr); 1796d6ab1dc0SHong Zhang coi[0] = 0; 1797d6ab1dc0SHong Zhang 1798d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */ 1799f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(poti[pon],ai[am])); 1800a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1801d6ab1dc0SHong Zhang current_space = free_space; 180219f0e57aSHong Zhang 1803d6ab1dc0SHong Zhang /* create and initialize a linked list */ 180433ba5e2fSHong Zhang ierr = PetscTableCreate(A->cmap->n + a->B->cmap->N,aN,&ta);CHKERRQ(ierr); 18054b38b95cSHong Zhang MatRowMergeMax_SeqAIJ(a_loc,am,ta); 18060acc65b4SHong Zhang ierr = PetscTableGetCount(ta,&Armax);CHKERRQ(ierr); 180733ba5e2fSHong Zhang 18080acc65b4SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Armax,&lnk);CHKERRQ(ierr); 1809d6ab1dc0SHong Zhang 1810d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 1811d6ab1dc0SHong Zhang pnz = poti[i+1] - poti[i]; 1812d6ab1dc0SHong Zhang ptJ = potj + poti[i]; 1813d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1814d6ab1dc0SHong Zhang row = ptJ[j]; /* row of A_loc == col of Pot */ 1815d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1816d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1817d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1818d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 1819d6ab1dc0SHong Zhang } 1820d6ab1dc0SHong Zhang nnz = lnk[0]; 1821d6ab1dc0SHong Zhang 1822d6ab1dc0SHong Zhang /* If free space is not available, double the total space in the list */ 1823d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 1824f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 1825d6ab1dc0SHong Zhang nspacedouble++; 1826d6ab1dc0SHong Zhang } 1827d6ab1dc0SHong Zhang 1828d6ab1dc0SHong Zhang /* Copy data into free space, and zero out denserows */ 1829d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 18302205254eSKarl Rupp 1831d6ab1dc0SHong Zhang current_space->array += nnz; 1832d6ab1dc0SHong Zhang current_space->local_used += nnz; 1833d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 18342205254eSKarl Rupp 1835d6ab1dc0SHong Zhang coi[i+1] = coi[i] + nnz; 1836d6ab1dc0SHong Zhang } 1837d6ab1dc0SHong Zhang 1838854ce69bSBarry Smith ierr = PetscMalloc1(coi[pon]+1,&coj);CHKERRQ(ierr); 1839d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr); 18400acc65b4SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); /* must destroy to get a new one for C */ 18412205254eSKarl Rupp 1842118727c9SMark F. Adams afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1); 1843d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1844d6ab1dc0SHong Zhang 1845d6ab1dc0SHong Zhang /* send j-array (coj) of Co to other processors */ 1846d6ab1dc0SHong Zhang /*----------------------------------------------*/ 1847d6ab1dc0SHong Zhang /* determine row ownership */ 1848b00a9115SJed Brown ierr = PetscNew(&merge);CHKERRQ(ierr); 1849d6ab1dc0SHong Zhang ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr); 18502205254eSKarl Rupp 1851d6ab1dc0SHong Zhang merge->rowmap->n = pn; 1852d6ab1dc0SHong Zhang merge->rowmap->bs = 1; 18532205254eSKarl Rupp 1854d6ab1dc0SHong Zhang ierr = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr); 1855d6ab1dc0SHong Zhang owners = merge->rowmap->range; 1856d6ab1dc0SHong Zhang 1857d6ab1dc0SHong Zhang /* determine the number of messages to send, their lengths */ 18581795a4d1SJed Brown ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr); 1859580bdb30SBarry Smith ierr = PetscCalloc1(size,&merge->len_s);CHKERRQ(ierr); 18602205254eSKarl Rupp 1861d6ab1dc0SHong Zhang len_s = merge->len_s; 1862d6ab1dc0SHong Zhang merge->nsend = 0; 1863d6ab1dc0SHong Zhang 1864854ce69bSBarry Smith ierr = PetscMalloc1(size+2,&owners_co);CHKERRQ(ierr); 1865d6ab1dc0SHong Zhang 1866d6ab1dc0SHong Zhang proc = 0; 1867d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 1868d6ab1dc0SHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 1869d6ab1dc0SHong Zhang len_si[proc]++; /* num of rows in Co to be sent to [proc] */ 1870d6ab1dc0SHong Zhang len_s[proc] += coi[i+1] - coi[i]; 1871d6ab1dc0SHong Zhang } 1872d6ab1dc0SHong Zhang 1873d6ab1dc0SHong Zhang len = 0; /* max length of buf_si[] */ 1874d6ab1dc0SHong Zhang owners_co[0] = 0; 1875d6ab1dc0SHong Zhang for (proc=0; proc<size; proc++) { 1876d6ab1dc0SHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1877d6ab1dc0SHong Zhang if (len_si[proc]) { 1878d6ab1dc0SHong Zhang merge->nsend++; 1879d6ab1dc0SHong Zhang len_si[proc] = 2*(len_si[proc] + 1); 1880d6ab1dc0SHong Zhang len += len_si[proc]; 1881d6ab1dc0SHong Zhang } 1882d6ab1dc0SHong Zhang } 1883d6ab1dc0SHong Zhang 1884d6ab1dc0SHong Zhang /* determine the number and length of messages to receive for coi and coj */ 18850298fd71SBarry Smith ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr); 1886d6ab1dc0SHong Zhang ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr); 1887d6ab1dc0SHong Zhang 1888d6ab1dc0SHong Zhang /* post the Irecv and Isend of coj */ 1889d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1890d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1891854ce69bSBarry Smith ierr = PetscMalloc1(merge->nsend+1,&swaits);CHKERRQ(ierr); 1892d6ab1dc0SHong Zhang for (proc=0, k=0; proc<size; proc++) { 1893d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1894d6ab1dc0SHong Zhang i = owners_co[proc]; 1895ffc4695bSBarry Smith ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRMPI(ierr); 1896d6ab1dc0SHong Zhang k++; 1897d6ab1dc0SHong Zhang } 1898d6ab1dc0SHong Zhang 1899d6ab1dc0SHong Zhang /* receives and sends of coj are complete */ 1900785e854fSJed Brown ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr); 1901d6ab1dc0SHong Zhang for (i=0; i<merge->nrecv; i++) { 1902ec4bef21SJose E. Roman PETSC_UNUSED PetscMPIInt icompleted; 1903ffc4695bSBarry Smith ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRMPI(ierr); 1904d6ab1dc0SHong Zhang } 1905d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1906ffc4695bSBarry Smith if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRMPI(ierr);} 1907d6ab1dc0SHong Zhang 19080acc65b4SHong Zhang /* add received column indices into table to update Armax */ 1909c4762a1bSJed Brown /* Armax can be as large as aN if a P[row,:] is dense, see src/ksp/ksp/tutorials/ex56.c! */ 19100acc65b4SHong Zhang for (k=0; k<merge->nrecv; k++) {/* k-th received message */ 19110acc65b4SHong Zhang Jptr = buf_rj[k]; 19120acc65b4SHong Zhang for (j=0; j<merge->len_r[k]; j++) { 19130acc65b4SHong Zhang ierr = PetscTableAdd(ta,*(Jptr+j)+1,1,INSERT_VALUES);CHKERRQ(ierr); 19140acc65b4SHong Zhang } 19150acc65b4SHong Zhang } 19160acc65b4SHong Zhang ierr = PetscTableGetCount(ta,&Armax);CHKERRQ(ierr); 191733ba5e2fSHong 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); */ 19180acc65b4SHong Zhang 1919d6ab1dc0SHong Zhang /* send and recv coi */ 1920d6ab1dc0SHong Zhang /*-------------------*/ 1921d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1922d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1923854ce69bSBarry Smith ierr = PetscMalloc1(len+1,&buf_s);CHKERRQ(ierr); 1924d6ab1dc0SHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1925d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 1926d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1927d6ab1dc0SHong Zhang /* form outgoing message for i-structure: 1928d6ab1dc0SHong Zhang buf_si[0]: nrows to be sent 1929d6ab1dc0SHong Zhang [1:nrows]: row index (global) 1930d6ab1dc0SHong Zhang [nrows+1:2*nrows+1]: i-structure index 1931d6ab1dc0SHong Zhang */ 1932d6ab1dc0SHong Zhang /*-------------------------------------------*/ 1933d6ab1dc0SHong Zhang nrows = len_si[proc]/2 - 1; 1934d6ab1dc0SHong Zhang buf_si_i = buf_si + nrows+1; 1935d6ab1dc0SHong Zhang buf_si[0] = nrows; 1936d6ab1dc0SHong Zhang buf_si_i[0] = 0; 1937d6ab1dc0SHong Zhang nrows = 0; 1938d6ab1dc0SHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1939d6ab1dc0SHong Zhang nzi = coi[i+1] - coi[i]; 1940d6ab1dc0SHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1941d6ab1dc0SHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1942d6ab1dc0SHong Zhang nrows++; 1943d6ab1dc0SHong Zhang } 1944ffc4695bSBarry Smith ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRMPI(ierr); 1945d6ab1dc0SHong Zhang k++; 1946d6ab1dc0SHong Zhang buf_si += len_si[proc]; 1947d6ab1dc0SHong Zhang } 1948d6ab1dc0SHong Zhang i = merge->nrecv; 1949d6ab1dc0SHong Zhang while (i--) { 1950ec4bef21SJose E. Roman PETSC_UNUSED PetscMPIInt icompleted; 1951ffc4695bSBarry Smith ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRMPI(ierr); 1952d6ab1dc0SHong Zhang } 1953d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1954ffc4695bSBarry Smith if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRMPI(ierr);} 1955d6ab1dc0SHong Zhang ierr = PetscFree(len_si);CHKERRQ(ierr); 1956d6ab1dc0SHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1957d6ab1dc0SHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1958d6ab1dc0SHong Zhang ierr = PetscFree(sstatus);CHKERRQ(ierr); 1959d6ab1dc0SHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1960d6ab1dc0SHong Zhang 1961d6ab1dc0SHong Zhang /* compute the local portion of C (mpi mat) */ 1962d6ab1dc0SHong Zhang /*------------------------------------------*/ 1963d6ab1dc0SHong Zhang /* allocate bi array and free space for accumulating nonzero column info */ 1964854ce69bSBarry Smith ierr = PetscMalloc1(pn+1,&bi);CHKERRQ(ierr); 1965d6ab1dc0SHong Zhang bi[0] = 0; 1966d6ab1dc0SHong Zhang 1967d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(P) + nnz(AP)) */ 1968f91af8c7SBarry Smith nnz = PetscRealIntMultTruncate(fill,PetscIntSumTruncate(pdti[pn],PetscIntSumTruncate(poti[pon],ai[am]))); 1969a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1970d6ab1dc0SHong Zhang current_space = free_space; 1971d6ab1dc0SHong Zhang 1972dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1973d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 1974d6ab1dc0SHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1975d6ab1dc0SHong Zhang nrows = *buf_ri_k[k]; 1976d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 19772d4ee042Sprj- nextci[k] = buf_ri_k[k] + (nrows + 1); /* points to the next i-structure of k-th received i-structure */ 1978d6ab1dc0SHong Zhang } 1979d6ab1dc0SHong Zhang 19800acc65b4SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Armax,&lnk);CHKERRQ(ierr); 1981d6ab1dc0SHong Zhang ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr); 1982d6ab1dc0SHong Zhang rmax = 0; 1983d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 1984d6ab1dc0SHong Zhang /* add pdt[i,:]*AP into lnk */ 1985d6ab1dc0SHong Zhang pnz = pdti[i+1] - pdti[i]; 1986d6ab1dc0SHong Zhang ptJ = pdtj + pdti[i]; 1987d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1988d6ab1dc0SHong Zhang row = ptJ[j]; /* row of AP == col of Pt */ 1989d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1990d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1991d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1992d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 1993d6ab1dc0SHong Zhang } 1994d6ab1dc0SHong Zhang 1995d6ab1dc0SHong Zhang /* add received col data into lnk */ 1996d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1997d6ab1dc0SHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1998d6ab1dc0SHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1999d6ab1dc0SHong Zhang Jptr = buf_rj[k] + *nextci[k]; 2000d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr); 2001d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 2002d6ab1dc0SHong Zhang } 2003d6ab1dc0SHong Zhang } 20048c78258cSHong Zhang 20058c78258cSHong Zhang /* add missing diagonal entry */ 20068c78258cSHong Zhang if (C->force_diagonals) { 20078c78258cSHong Zhang k = i + owners[rank]; /* column index */ 20088c78258cSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(1,&k,lnk);CHKERRQ(ierr); 20098c78258cSHong Zhang } 20108c78258cSHong Zhang 2011d6ab1dc0SHong Zhang nnz = lnk[0]; 2012d6ab1dc0SHong Zhang 2013d6ab1dc0SHong Zhang /* if free space is not available, make more free space */ 2014d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 2015f91af8c7SBarry Smith ierr = PetscFreeSpaceGet(PetscIntSumTruncate(nnz,current_space->total_array_size),¤t_space);CHKERRQ(ierr); 2016d6ab1dc0SHong Zhang nspacedouble++; 2017d6ab1dc0SHong Zhang } 2018d6ab1dc0SHong Zhang /* copy data into free space, then initialize lnk */ 2019d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 2020d6ab1dc0SHong Zhang ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr); 20212205254eSKarl Rupp 2022d6ab1dc0SHong Zhang current_space->array += nnz; 2023d6ab1dc0SHong Zhang current_space->local_used += nnz; 2024d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 20252205254eSKarl Rupp 2026d6ab1dc0SHong Zhang bi[i+1] = bi[i] + nnz; 2027d6ab1dc0SHong Zhang if (nnz > rmax) rmax = nnz; 2028d6ab1dc0SHong Zhang } 2029f671be37SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 2030d6ab1dc0SHong Zhang 2031854ce69bSBarry Smith ierr = PetscMalloc1(bi[pn]+1,&bj);CHKERRQ(ierr); 2032d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr); 2033118727c9SMark F. Adams afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1); 2034d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 2035d6ab1dc0SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 20360acc65b4SHong Zhang ierr = PetscTableDestroy(&ta);CHKERRQ(ierr); 2037b419842dSStefano Zampini ierr = MatRestoreSymbolicTranspose_SeqAIJ(p->A,&pdti,&pdtj);CHKERRQ(ierr); 2038b419842dSStefano Zampini ierr = MatRestoreSymbolicTranspose_SeqAIJ(p->B,&poti,&potj);CHKERRQ(ierr); 2039d6ab1dc0SHong Zhang 20404222ddf1SHong Zhang /* create symbolic parallel matrix C - why cannot be assembled in Numeric part */ 20414222ddf1SHong Zhang /*-------------------------------------------------------------------------------*/ 20424222ddf1SHong Zhang ierr = MatSetSizes(C,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 20434222ddf1SHong Zhang ierr = MatSetBlockSizes(C,PetscAbs(P->cmap->bs),PetscAbs(A->cmap->bs));CHKERRQ(ierr); 2044b92f168fSBarry Smith ierr = MatGetType(A,&mtype);CHKERRQ(ierr); 20454222ddf1SHong Zhang ierr = MatSetType(C,mtype);CHKERRQ(ierr); 20464222ddf1SHong Zhang ierr = MatMPIAIJSetPreallocation(C,0,dnz,0,onz);CHKERRQ(ierr); 2047d6ab1dc0SHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 20484222ddf1SHong Zhang ierr = MatSetBlockSize(C,1);CHKERRQ(ierr); 204969be949aSStefano Zampini ierr = MatSetOption(C,MAT_NO_OFF_PROC_ENTRIES,PETSC_TRUE);CHKERRQ(ierr); 2050d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 2051d6ab1dc0SHong Zhang row = i + rstart; 2052d6ab1dc0SHong Zhang nnz = bi[i+1] - bi[i]; 2053d6ab1dc0SHong Zhang Jptr = bj + bi[i]; 20544222ddf1SHong Zhang ierr = MatSetValues(C,1,&row,nnz,Jptr,NULL,INSERT_VALUES);CHKERRQ(ierr); 2055d6ab1dc0SHong Zhang } 20564222ddf1SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 20574222ddf1SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 20580926fe31SStefano Zampini ierr = MatSetOption(C,MAT_NEW_NONZERO_LOCATION_ERR,PETSC_TRUE);CHKERRQ(ierr); 2059d6ab1dc0SHong Zhang merge->bi = bi; 2060d6ab1dc0SHong Zhang merge->bj = bj; 2061d6ab1dc0SHong Zhang merge->coi = coi; 2062d6ab1dc0SHong Zhang merge->coj = coj; 2063d6ab1dc0SHong Zhang merge->buf_ri = buf_ri; 2064d6ab1dc0SHong Zhang merge->buf_rj = buf_rj; 2065d6ab1dc0SHong Zhang merge->owners_co = owners_co; 2066d6ab1dc0SHong Zhang 20674222ddf1SHong Zhang /* attach the supporting struct to C for reuse */ 20686718818eSStefano Zampini C->product->data = ptap; 20696718818eSStefano Zampini C->product->destroy = MatDestroy_MPIAIJ_PtAP; 2070d6ab1dc0SHong Zhang ptap->merge = merge; 2071a560ef98SHong Zhang 20724222ddf1SHong Zhang C->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ; 2073f96d37fcSHong Zhang 2074f96d37fcSHong Zhang #if defined(PETSC_USE_INFO) 2075f96d37fcSHong Zhang if (bi[pn] != 0) { 20764222ddf1SHong Zhang ierr = PetscInfo3(C,"Reallocs %D; Fill ratio: given %g needed %g.\n",nspacedouble,(double)fill,(double)afill);CHKERRQ(ierr); 20774222ddf1SHong Zhang ierr = PetscInfo1(C,"Use MatTransposeMatMult(A,B,MatReuse,%g,&C) for best performance.\n",(double)afill);CHKERRQ(ierr); 2078f96d37fcSHong Zhang } else { 20794222ddf1SHong Zhang ierr = PetscInfo(C,"Empty matrix product\n");CHKERRQ(ierr); 2080f96d37fcSHong Zhang } 2081f96d37fcSHong Zhang #endif 2082f96d37fcSHong Zhang PetscFunctionReturn(0); 2083f96d37fcSHong Zhang } 20844222ddf1SHong Zhang 20854222ddf1SHong Zhang /* ---------------------------------------------------------------- */ 20864222ddf1SHong Zhang static PetscErrorCode MatProductSymbolic_AtB_MPIAIJ_MPIAIJ(Mat C) 20874222ddf1SHong Zhang { 20884222ddf1SHong Zhang PetscErrorCode ierr; 20894222ddf1SHong Zhang Mat_Product *product = C->product; 20904222ddf1SHong Zhang Mat A=product->A,B=product->B; 20914222ddf1SHong Zhang PetscReal fill=product->fill; 20924222ddf1SHong Zhang PetscBool flg; 20934222ddf1SHong Zhang 20944222ddf1SHong Zhang PetscFunctionBegin; 20954222ddf1SHong Zhang /* scalable */ 20964222ddf1SHong Zhang ierr = PetscStrcmp(product->alg,"scalable",&flg);CHKERRQ(ierr); 20974222ddf1SHong Zhang if (flg) { 20984222ddf1SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(A,B,fill,C);CHKERRQ(ierr); 20994222ddf1SHong Zhang goto next; 21004222ddf1SHong Zhang } 21014222ddf1SHong Zhang 21024222ddf1SHong Zhang /* nonscalable */ 21034222ddf1SHong Zhang ierr = PetscStrcmp(product->alg,"nonscalable",&flg);CHKERRQ(ierr); 21044222ddf1SHong Zhang if (flg) { 21054222ddf1SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(A,B,fill,C);CHKERRQ(ierr); 21064222ddf1SHong Zhang goto next; 21074222ddf1SHong Zhang } 21084222ddf1SHong Zhang 21094222ddf1SHong Zhang /* matmatmult */ 21104222ddf1SHong Zhang ierr = PetscStrcmp(product->alg,"at*b",&flg);CHKERRQ(ierr); 21114222ddf1SHong Zhang if (flg) { 21124222ddf1SHong Zhang Mat At; 21134222ddf1SHong Zhang Mat_APMPI *ptap; 21144222ddf1SHong Zhang 21156718818eSStefano Zampini ierr = MatTranspose(A,MAT_INITIAL_MATRIX,&At);CHKERRQ(ierr); 21164222ddf1SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ(At,B,fill,C);CHKERRQ(ierr); 21176718818eSStefano Zampini ptap = (Mat_APMPI*)C->product->data; 21184222ddf1SHong Zhang if (ptap) { 21194222ddf1SHong Zhang ptap->Pt = At; 21206718818eSStefano Zampini C->product->destroy = MatDestroy_MPIAIJ_PtAP; 21214222ddf1SHong Zhang } 21224222ddf1SHong Zhang C->ops->transposematmultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult; 21234222ddf1SHong Zhang goto next; 21244222ddf1SHong Zhang } 21254222ddf1SHong Zhang 2126*4e84afc0SStefano Zampini /* backend general code */ 2127*4e84afc0SStefano Zampini ierr = PetscStrcmp(product->alg,"backend",&flg);CHKERRQ(ierr); 2128*4e84afc0SStefano Zampini if (flg) { 2129*4e84afc0SStefano Zampini ierr = MatProductSymbolic_MPIAIJBACKEND(C);CHKERRQ(ierr); 2130*4e84afc0SStefano Zampini PetscFunctionReturn(0); 2131*4e84afc0SStefano Zampini } 2132*4e84afc0SStefano Zampini 21334222ddf1SHong Zhang SETERRQ(PETSC_COMM_SELF,PETSC_ERR_SUP,"MatProduct type is not supported"); 21344222ddf1SHong Zhang 21354222ddf1SHong Zhang next: 21364222ddf1SHong Zhang C->ops->productnumeric = MatProductNumeric_AtB; 21374222ddf1SHong Zhang PetscFunctionReturn(0); 21384222ddf1SHong Zhang } 21394222ddf1SHong Zhang 21404222ddf1SHong Zhang /* ---------------------------------------------------------------- */ 21414222ddf1SHong Zhang /* Set options for MatMatMultxxx_MPIAIJ_MPIAIJ */ 21424222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_AB(Mat C) 21434222ddf1SHong Zhang { 21444222ddf1SHong Zhang PetscErrorCode ierr; 21454222ddf1SHong Zhang Mat_Product *product = C->product; 21464222ddf1SHong Zhang Mat A=product->A,B=product->B; 21474222ddf1SHong Zhang #if defined(PETSC_HAVE_HYPRE) 2148*4e84afc0SStefano Zampini const char *algTypes[5] = {"scalable","nonscalable","seqmpi","backend","hypre"}; 2149*4e84afc0SStefano Zampini PetscInt nalg = 5; 21504222ddf1SHong Zhang #else 2151*4e84afc0SStefano Zampini const char *algTypes[4] = {"scalable","nonscalable","seqmpi","backend",}; 2152*4e84afc0SStefano Zampini PetscInt nalg = 4; 21534222ddf1SHong Zhang #endif 21544222ddf1SHong Zhang PetscInt alg = 1; /* set nonscalable algorithm as default */ 21554222ddf1SHong Zhang PetscBool flg; 21564222ddf1SHong Zhang MPI_Comm comm; 21574222ddf1SHong Zhang 21584222ddf1SHong Zhang PetscFunctionBegin; 21594222ddf1SHong Zhang /* Check matrix local sizes */ 21604222ddf1SHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 21614222ddf1SHong Zhang if (A->cmap->rstart != B->rmap->rstart || A->cmap->rend != B->rmap->rend) SETERRQ4(PETSC_COMM_SELF,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); 21624222ddf1SHong Zhang 21634222ddf1SHong Zhang /* Set "nonscalable" as default algorithm */ 21644222ddf1SHong Zhang ierr = PetscStrcmp(C->product->alg,"default",&flg);CHKERRQ(ierr); 21654222ddf1SHong Zhang if (flg) { 21664222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 21674222ddf1SHong Zhang 21684222ddf1SHong Zhang /* Set "scalable" as default if BN and local nonzeros of A and B are large */ 21694222ddf1SHong Zhang if (B->cmap->N > 100000) { /* may switch to scalable algorithm as default */ 21704222ddf1SHong Zhang MatInfo Ainfo,Binfo; 21714222ddf1SHong Zhang PetscInt nz_local; 21724222ddf1SHong Zhang PetscBool alg_scalable_loc=PETSC_FALSE,alg_scalable; 21734222ddf1SHong Zhang 21744222ddf1SHong Zhang ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr); 21754222ddf1SHong Zhang ierr = MatGetInfo(B,MAT_LOCAL,&Binfo);CHKERRQ(ierr); 21764222ddf1SHong Zhang nz_local = (PetscInt)(Ainfo.nz_allocated + Binfo.nz_allocated); 21774222ddf1SHong Zhang 21784222ddf1SHong Zhang if (B->cmap->N > product->fill*nz_local) alg_scalable_loc = PETSC_TRUE; 21794222ddf1SHong Zhang ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr); 21804222ddf1SHong Zhang 21814222ddf1SHong Zhang if (alg_scalable) { 21824222ddf1SHong Zhang alg = 0; /* scalable algorithm would 50% slower than nonscalable algorithm */ 21834222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 21844222ddf1SHong Zhang ierr = PetscInfo2(B,"Use scalable algorithm, BN %D, fill*nz_allocated %g\n",B->cmap->N,product->fill*nz_local);CHKERRQ(ierr); 21854222ddf1SHong Zhang } 21864222ddf1SHong Zhang } 21874222ddf1SHong Zhang } 21884222ddf1SHong Zhang 21894222ddf1SHong Zhang /* Get runtime option */ 21904222ddf1SHong Zhang if (product->api_user) { 21914222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatMatMult","Mat");CHKERRQ(ierr); 21924222ddf1SHong Zhang ierr = PetscOptionsEList("-matmatmult_via","Algorithmic approach","MatMatMult",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 21934222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 21944222ddf1SHong Zhang } else { 21954222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatProduct_AB","Mat");CHKERRQ(ierr); 21964222ddf1SHong Zhang ierr = PetscOptionsEList("-matproduct_ab_via","Algorithmic approach","MatMatMult",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 21974222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 21984222ddf1SHong Zhang } 21994222ddf1SHong Zhang if (flg) { 22004222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 22014222ddf1SHong Zhang } 22024222ddf1SHong Zhang 22034222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_AB_MPIAIJ_MPIAIJ; 22044222ddf1SHong Zhang PetscFunctionReturn(0); 22054222ddf1SHong Zhang } 22064222ddf1SHong Zhang 22074222ddf1SHong Zhang /* Set options for MatTransposeMatMultXXX_MPIAIJ_MPIAIJ */ 22084222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_AtB(Mat C) 22094222ddf1SHong Zhang { 22104222ddf1SHong Zhang PetscErrorCode ierr; 22114222ddf1SHong Zhang Mat_Product *product = C->product; 22124222ddf1SHong Zhang Mat A=product->A,B=product->B; 2213*4e84afc0SStefano Zampini const char *algTypes[4] = {"scalable","nonscalable","at*b","backend"}; 2214*4e84afc0SStefano Zampini PetscInt nalg = 4; 22154222ddf1SHong Zhang PetscInt alg = 1; /* set default algorithm */ 22164222ddf1SHong Zhang PetscBool flg; 22174222ddf1SHong Zhang MPI_Comm comm; 22184222ddf1SHong Zhang 22194222ddf1SHong Zhang PetscFunctionBegin; 22204222ddf1SHong Zhang /* Check matrix local sizes */ 22214222ddf1SHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 22224222ddf1SHong Zhang if (A->rmap->rstart != B->rmap->rstart || A->rmap->rend != B->rmap->rend) SETERRQ4(PETSC_COMM_SELF,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, A (%D, %D) != B (%D,%D)",A->rmap->rstart,A->rmap->rend,B->rmap->rstart,B->rmap->rend); 22234222ddf1SHong Zhang 22244222ddf1SHong Zhang /* Set default algorithm */ 22254222ddf1SHong Zhang ierr = PetscStrcmp(C->product->alg,"default",&flg);CHKERRQ(ierr); 22264222ddf1SHong Zhang if (flg) { 22274222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 22284222ddf1SHong Zhang } 22294222ddf1SHong Zhang 22304222ddf1SHong Zhang /* Set "scalable" as default if BN and local nonzeros of A and B are large */ 22314222ddf1SHong Zhang if (alg && B->cmap->N > 100000) { /* may switch to scalable algorithm as default */ 22324222ddf1SHong Zhang MatInfo Ainfo,Binfo; 22334222ddf1SHong Zhang PetscInt nz_local; 22344222ddf1SHong Zhang PetscBool alg_scalable_loc=PETSC_FALSE,alg_scalable; 22354222ddf1SHong Zhang 22364222ddf1SHong Zhang ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr); 22374222ddf1SHong Zhang ierr = MatGetInfo(B,MAT_LOCAL,&Binfo);CHKERRQ(ierr); 22384222ddf1SHong Zhang nz_local = (PetscInt)(Ainfo.nz_allocated + Binfo.nz_allocated); 22394222ddf1SHong Zhang 22404222ddf1SHong Zhang if (B->cmap->N > product->fill*nz_local) alg_scalable_loc = PETSC_TRUE; 22414222ddf1SHong Zhang ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr); 22424222ddf1SHong Zhang 22434222ddf1SHong Zhang if (alg_scalable) { 22444222ddf1SHong Zhang alg = 0; /* scalable algorithm would 50% slower than nonscalable algorithm */ 22454222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 22464222ddf1SHong Zhang ierr = PetscInfo2(B,"Use scalable algorithm, BN %D, fill*nz_allocated %g\n",B->cmap->N,product->fill*nz_local);CHKERRQ(ierr); 22474222ddf1SHong Zhang } 22484222ddf1SHong Zhang } 22494222ddf1SHong Zhang 22504222ddf1SHong Zhang /* Get runtime option */ 22514222ddf1SHong Zhang if (product->api_user) { 22524222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatTransposeMatMult","Mat");CHKERRQ(ierr); 22534222ddf1SHong Zhang ierr = PetscOptionsEList("-mattransposematmult_via","Algorithmic approach","MatTransposeMatMult",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 22544222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 22554222ddf1SHong Zhang } else { 22564222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatProduct_AtB","Mat");CHKERRQ(ierr); 22574222ddf1SHong Zhang ierr = PetscOptionsEList("-matproduct_atb_via","Algorithmic approach","MatTransposeMatMult",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 22584222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 22594222ddf1SHong Zhang } 22604222ddf1SHong Zhang if (flg) { 22614222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 22624222ddf1SHong Zhang } 22634222ddf1SHong Zhang 22644222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_AtB_MPIAIJ_MPIAIJ; 22654222ddf1SHong Zhang PetscFunctionReturn(0); 22664222ddf1SHong Zhang } 22674222ddf1SHong Zhang 22684222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_PtAP(Mat C) 22694222ddf1SHong Zhang { 22704222ddf1SHong Zhang PetscErrorCode ierr; 22714222ddf1SHong Zhang Mat_Product *product = C->product; 22724222ddf1SHong Zhang Mat A=product->A,P=product->B; 22734222ddf1SHong Zhang MPI_Comm comm; 22744222ddf1SHong Zhang PetscBool flg; 22754222ddf1SHong Zhang PetscInt alg=1; /* set default algorithm */ 22764222ddf1SHong Zhang #if !defined(PETSC_HAVE_HYPRE) 2277*4e84afc0SStefano Zampini const char *algTypes[5] = {"scalable","nonscalable","allatonce","allatonce_merged","backend"}; 22784222ddf1SHong Zhang PetscInt nalg=5; 2279*4e84afc0SStefano Zampini #else 2280*4e84afc0SStefano Zampini const char *algTypes[6] = {"scalable","nonscalable","allatonce","allatonce_merged","backend","hypre"}; 2281*4e84afc0SStefano Zampini PetscInt nalg=6; 22824222ddf1SHong Zhang #endif 22834222ddf1SHong Zhang PetscInt pN=P->cmap->N; 22844222ddf1SHong Zhang 22854222ddf1SHong Zhang PetscFunctionBegin; 22864222ddf1SHong Zhang /* Check matrix local sizes */ 22874222ddf1SHong Zhang ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 22884222ddf1SHong Zhang if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) SETERRQ4(PETSC_COMM_SELF,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Arow (%D, %D) != Prow (%D,%D)",A->rmap->rstart,A->rmap->rend,P->rmap->rstart,P->rmap->rend); 22894222ddf1SHong Zhang if (A->cmap->rstart != P->rmap->rstart || A->cmap->rend != P->rmap->rend) SETERRQ4(PETSC_COMM_SELF,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, Acol (%D, %D) != Prow (%D,%D)",A->cmap->rstart,A->cmap->rend,P->rmap->rstart,P->rmap->rend); 22904222ddf1SHong Zhang 22914222ddf1SHong Zhang /* Set "nonscalable" as default algorithm */ 22924222ddf1SHong Zhang ierr = PetscStrcmp(C->product->alg,"default",&flg);CHKERRQ(ierr); 22934222ddf1SHong Zhang if (flg) { 22944222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 22954222ddf1SHong Zhang 22964222ddf1SHong Zhang /* Set "scalable" as default if BN and local nonzeros of A and B are large */ 22974222ddf1SHong Zhang if (pN > 100000) { 22984222ddf1SHong Zhang MatInfo Ainfo,Pinfo; 22994222ddf1SHong Zhang PetscInt nz_local; 23004222ddf1SHong Zhang PetscBool alg_scalable_loc=PETSC_FALSE,alg_scalable; 23014222ddf1SHong Zhang 23024222ddf1SHong Zhang ierr = MatGetInfo(A,MAT_LOCAL,&Ainfo);CHKERRQ(ierr); 23034222ddf1SHong Zhang ierr = MatGetInfo(P,MAT_LOCAL,&Pinfo);CHKERRQ(ierr); 23044222ddf1SHong Zhang nz_local = (PetscInt)(Ainfo.nz_allocated + Pinfo.nz_allocated); 23054222ddf1SHong Zhang 23064222ddf1SHong Zhang if (pN > product->fill*nz_local) alg_scalable_loc = PETSC_TRUE; 23074222ddf1SHong Zhang ierr = MPIU_Allreduce(&alg_scalable_loc,&alg_scalable,1,MPIU_BOOL,MPI_LOR,comm);CHKERRQ(ierr); 23084222ddf1SHong Zhang 23094222ddf1SHong Zhang if (alg_scalable) { 23104222ddf1SHong Zhang alg = 0; /* scalable algorithm would 50% slower than nonscalable algorithm */ 23114222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 23124222ddf1SHong Zhang } 23134222ddf1SHong Zhang } 23144222ddf1SHong Zhang } 23154222ddf1SHong Zhang 23164222ddf1SHong Zhang /* Get runtime option */ 23174222ddf1SHong Zhang if (product->api_user) { 23184222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatPtAP","Mat");CHKERRQ(ierr); 23194222ddf1SHong Zhang ierr = PetscOptionsEList("-matptap_via","Algorithmic approach","MatPtAP",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 23204222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 23214222ddf1SHong Zhang } else { 23224222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatProduct_PtAP","Mat");CHKERRQ(ierr); 23234222ddf1SHong Zhang ierr = PetscOptionsEList("-matproduct_ptap_via","Algorithmic approach","MatPtAP",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 23244222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 23254222ddf1SHong Zhang } 23264222ddf1SHong Zhang if (flg) { 23274222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 23284222ddf1SHong Zhang } 23294222ddf1SHong Zhang 23304222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_PtAP_MPIAIJ_MPIAIJ; 23314222ddf1SHong Zhang PetscFunctionReturn(0); 23324222ddf1SHong Zhang } 23334222ddf1SHong Zhang 23344222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_RARt(Mat C) 23354222ddf1SHong Zhang { 23364222ddf1SHong Zhang Mat_Product *product = C->product; 23374222ddf1SHong Zhang Mat A = product->A,R=product->B; 23384222ddf1SHong Zhang 23394222ddf1SHong Zhang PetscFunctionBegin; 23404222ddf1SHong Zhang /* Check matrix local sizes */ 23414222ddf1SHong Zhang if (A->cmap->n != R->cmap->n || A->rmap->n != R->cmap->n) SETERRQ4(PETSC_COMM_SELF,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, A local (%D, %D), R local (%D,%D)",A->rmap->n,A->rmap->n,R->rmap->n,R->cmap->n); 23424222ddf1SHong Zhang 23434222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_RARt_MPIAIJ_MPIAIJ; 23444222ddf1SHong Zhang PetscFunctionReturn(0); 23454222ddf1SHong Zhang } 23464222ddf1SHong Zhang 23474222ddf1SHong Zhang /* 23484222ddf1SHong Zhang Set options for ABC = A*B*C = A*(B*C); ABC's algorithm must be chosen from AB's algorithm 23494222ddf1SHong Zhang */ 23504222ddf1SHong Zhang static PetscErrorCode MatProductSetFromOptions_MPIAIJ_ABC(Mat C) 23514222ddf1SHong Zhang { 23524222ddf1SHong Zhang PetscErrorCode ierr; 23534222ddf1SHong Zhang Mat_Product *product = C->product; 23544222ddf1SHong Zhang PetscBool flg = PETSC_FALSE; 23554222ddf1SHong Zhang PetscInt alg = 1; /* default algorithm */ 23564222ddf1SHong Zhang const char *algTypes[3] = {"scalable","nonscalable","seqmpi"}; 23574222ddf1SHong Zhang PetscInt nalg = 3; 23584222ddf1SHong Zhang 23594222ddf1SHong Zhang PetscFunctionBegin; 23604222ddf1SHong Zhang /* Set default algorithm */ 23614222ddf1SHong Zhang ierr = PetscStrcmp(C->product->alg,"default",&flg);CHKERRQ(ierr); 23624222ddf1SHong Zhang if (flg) { 23634222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 23644222ddf1SHong Zhang } 23654222ddf1SHong Zhang 23664222ddf1SHong Zhang /* Get runtime option */ 23674222ddf1SHong Zhang if (product->api_user) { 23684222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatMatMatMult","Mat");CHKERRQ(ierr); 23694222ddf1SHong Zhang ierr = PetscOptionsEList("-matmatmatmult_via","Algorithmic approach","MatMatMatMult",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 23704222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 23714222ddf1SHong Zhang } else { 23724222ddf1SHong Zhang ierr = PetscOptionsBegin(PetscObjectComm((PetscObject)C),((PetscObject)C)->prefix,"MatProduct_ABC","Mat");CHKERRQ(ierr); 23734222ddf1SHong Zhang ierr = PetscOptionsEList("-matproduct_abc_via","Algorithmic approach","MatProduct_ABC",algTypes,nalg,algTypes[alg],&alg,&flg);CHKERRQ(ierr); 23744222ddf1SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 23754222ddf1SHong Zhang } 23764222ddf1SHong Zhang if (flg) { 23774222ddf1SHong Zhang ierr = MatProductSetAlgorithm(C,(MatProductAlgorithm)algTypes[alg]);CHKERRQ(ierr); 23784222ddf1SHong Zhang } 23794222ddf1SHong Zhang 23804222ddf1SHong Zhang C->ops->matmatmultsymbolic = MatMatMatMultSymbolic_MPIAIJ_MPIAIJ_MPIAIJ; 23814222ddf1SHong Zhang C->ops->productsymbolic = MatProductSymbolic_ABC; 23824222ddf1SHong Zhang PetscFunctionReturn(0); 23834222ddf1SHong Zhang } 23844222ddf1SHong Zhang 23854222ddf1SHong Zhang PETSC_INTERN PetscErrorCode MatProductSetFromOptions_MPIAIJ(Mat C) 23864222ddf1SHong Zhang { 23874222ddf1SHong Zhang PetscErrorCode ierr; 23884222ddf1SHong Zhang Mat_Product *product = C->product; 23894222ddf1SHong Zhang 23904222ddf1SHong Zhang PetscFunctionBegin; 23914222ddf1SHong Zhang switch (product->type) { 23924222ddf1SHong Zhang case MATPRODUCT_AB: 23934222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_AB(C);CHKERRQ(ierr); 23944222ddf1SHong Zhang break; 23954222ddf1SHong Zhang case MATPRODUCT_AtB: 23964222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_AtB(C);CHKERRQ(ierr); 23974222ddf1SHong Zhang break; 23984222ddf1SHong Zhang case MATPRODUCT_PtAP: 23994222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_PtAP(C);CHKERRQ(ierr); 24004222ddf1SHong Zhang break; 24014222ddf1SHong Zhang case MATPRODUCT_RARt: 24024222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_RARt(C);CHKERRQ(ierr); 24034222ddf1SHong Zhang break; 24044222ddf1SHong Zhang case MATPRODUCT_ABC: 24054222ddf1SHong Zhang ierr = MatProductSetFromOptions_MPIAIJ_ABC(C);CHKERRQ(ierr); 24064222ddf1SHong Zhang break; 24076718818eSStefano Zampini default: 24086718818eSStefano Zampini break; 24094222ddf1SHong Zhang } 24104222ddf1SHong Zhang PetscFunctionReturn(0); 24114222ddf1SHong Zhang } 2412