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> 119a6d0b0bSJed Brown #include <petsc-private/vecimpl.h> 121634b032SHong Zhang 132499ec78SHong Zhang #undef __FUNCT__ 142499ec78SHong Zhang #define __FUNCT__ "MatMatMult_MPIAIJ_MPIAIJ" 152499ec78SHong Zhang PetscErrorCode MatMatMult_MPIAIJ_MPIAIJ(Mat A,Mat B,MatReuse scall,PetscReal fill, Mat *C) 162499ec78SHong Zhang { 172499ec78SHong Zhang PetscErrorCode ierr; 180fc8cf34SHong Zhang const char *algTypes[2] = {"scalable","nonscalable"}; 190fc8cf34SHong Zhang PetscInt alg=0; /* set default algorithm */ 202499ec78SHong Zhang 212499ec78SHong Zhang PetscFunctionBegin; 222499ec78SHong Zhang if (scall == MAT_INITIAL_MATRIX) { 230fc8cf34SHong Zhang ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr); 240fc8cf34SHong Zhang ierr = PetscOptionsEList("-matmatmult_via","Algorithmic approach","MatMatMult",algTypes,2,algTypes[0],&alg,NULL);CHKERRQ(ierr); 250fc8cf34SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 260fc8cf34SHong Zhang 273ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 280fc8cf34SHong Zhang switch (alg) { 290fc8cf34SHong Zhang case 1: 300fc8cf34SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(A,B,fill,C);CHKERRQ(ierr); 310fc8cf34SHong Zhang break; 320fc8cf34SHong Zhang default: 33b2405163SHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIAIJ(A,B,fill,C);CHKERRQ(ierr); 340fc8cf34SHong Zhang break; 350fc8cf34SHong Zhang } 363ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 372499ec78SHong Zhang } 383ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 39598bc09dSHong Zhang ierr = (*(*C)->ops->matmultnumeric)(A,B,*C);CHKERRQ(ierr); 403ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 412499ec78SHong Zhang PetscFunctionReturn(0); 422499ec78SHong Zhang } 432499ec78SHong Zhang 44f33d1a9aSHong Zhang #undef __FUNCT__ 45a1a4e84aSHong Zhang #define __FUNCT__ "MatDestroy_MPIAIJ_MatMatMult" 46a1a4e84aSHong Zhang PetscErrorCode MatDestroy_MPIAIJ_MatMatMult(Mat A) 47598bc09dSHong Zhang { 48598bc09dSHong Zhang PetscErrorCode ierr; 49598bc09dSHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data; 50598bc09dSHong Zhang Mat_PtAPMPI *ptap = a->ptap; 51598bc09dSHong Zhang 52598bc09dSHong Zhang PetscFunctionBegin; 53b7f45c76SHong Zhang ierr = PetscFree2(ptap->startsj_s,ptap->startsj_r);CHKERRQ(ierr); 54598bc09dSHong Zhang ierr = PetscFree(ptap->bufa);CHKERRQ(ierr); 55a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_loc);CHKERRQ(ierr); 56a1a4e84aSHong Zhang ierr = MatDestroy(&ptap->P_oth);CHKERRQ(ierr); 57ab1b013aSHong Zhang ierr = MatDestroy(&ptap->Pt);CHKERRQ(ierr); 58a1a4e84aSHong Zhang ierr = PetscFree(ptap->api);CHKERRQ(ierr); 59a1a4e84aSHong Zhang ierr = PetscFree(ptap->apj);CHKERRQ(ierr); 60598bc09dSHong Zhang ierr = PetscFree(ptap->apa);CHKERRQ(ierr); 61598bc09dSHong Zhang ierr = ptap->destroy(A);CHKERRQ(ierr); 62598bc09dSHong Zhang ierr = PetscFree(ptap);CHKERRQ(ierr); 63598bc09dSHong Zhang PetscFunctionReturn(0); 64598bc09dSHong Zhang } 65598bc09dSHong Zhang 662499ec78SHong Zhang #undef __FUNCT__ 67a1a4e84aSHong Zhang #define __FUNCT__ "MatDuplicate_MPIAIJ_MatMatMult" 68a1a4e84aSHong Zhang PetscErrorCode MatDuplicate_MPIAIJ_MatMatMult(Mat A, MatDuplicateOption op, Mat *M) 694ae0847bSHong Zhang { 704ae0847bSHong Zhang PetscErrorCode ierr; 714ae0847bSHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data; 724ae0847bSHong Zhang Mat_PtAPMPI *ptap = a->ptap; 734ae0847bSHong Zhang 744ae0847bSHong Zhang PetscFunctionBegin; 754ae0847bSHong Zhang ierr = (*ptap->duplicate)(A,op,M);CHKERRQ(ierr); 7626fbe8dcSKarl Rupp 774ae0847bSHong Zhang (*M)->ops->destroy = ptap->destroy; /* = MatDestroy_MPIAIJ, *M doesn't duplicate A's special structure! */ 784ae0847bSHong Zhang (*M)->ops->duplicate = ptap->duplicate; /* = MatDuplicate_MPIAIJ */ 794ae0847bSHong Zhang PetscFunctionReturn(0); 804ae0847bSHong Zhang } 814ae0847bSHong Zhang 824ae0847bSHong Zhang #undef __FUNCT__ 83a1a4e84aSHong Zhang #define __FUNCT__ "MatMatMultNumeric_MPIAIJ_MPIAIJ" 84a1a4e84aSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ(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; 90598bc09dSHong Zhang PetscInt *adi=ad->i,*adj,*aoi=ao->i,*aoj; 91598bc09dSHong Zhang PetscScalar *ada,*aoa,*cda=cd->a,*coa=co->a; 92598bc09dSHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 93598bc09dSHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj; 94598bc09dSHong Zhang PetscScalar *pa_loc,*pa_oth,*pa,*apa,valtmp,*ca; 95598bc09dSHong Zhang PetscInt cm =C->rmap->n,anz,pnz; 96598bc09dSHong Zhang Mat_PtAPMPI *ptap=c->ptap; 9765a57a32SSean Farley PetscInt *api,*apj,*apJ,i,j,k,row; 9829825010SHong Zhang PetscInt cstart=C->cmap->rstart; 99598bc09dSHong Zhang PetscInt cdnz,conz,k0,k1; 100598bc09dSHong Zhang 101598bc09dSHong Zhang PetscFunctionBegin; 102a1a4e84aSHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 103598bc09dSHong Zhang /*-----------------------------------------------------*/ 104a1a4e84aSHong Zhang /* update numerical values of P_oth and P_loc */ 105b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 106a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 107598bc09dSHong Zhang 108598bc09dSHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 109598bc09dSHong Zhang /*----------------------------------------------------------*/ 110598bc09dSHong Zhang /* get data from symbolic products */ 111a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 112a1a4e84aSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 113598bc09dSHong Zhang pi_loc=p_loc->i; pj_loc=p_loc->j; pa_loc=p_loc->a; 114598bc09dSHong Zhang pi_oth=p_oth->i; pj_oth=p_oth->j; pa_oth=p_oth->a; 115598bc09dSHong Zhang 116598bc09dSHong Zhang /* get apa for storing dense row A[i,:]*P */ 117598bc09dSHong Zhang apa = ptap->apa; 118598bc09dSHong Zhang 11929825010SHong Zhang api = ptap->api; 12029825010SHong Zhang apj = ptap->apj; 121598bc09dSHong Zhang for (i=0; i<cm; i++) { 122598bc09dSHong Zhang /* diagonal portion of A */ 123598bc09dSHong Zhang anz = adi[i+1] - adi[i]; 124598bc09dSHong Zhang adj = ad->j + adi[i]; 125598bc09dSHong Zhang ada = ad->a + adi[i]; 126598bc09dSHong Zhang for (j=0; j<anz; j++) { 127598bc09dSHong Zhang row = adj[j]; 128598bc09dSHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 129598bc09dSHong Zhang pj = pj_loc + pi_loc[row]; 130598bc09dSHong Zhang pa = pa_loc + pi_loc[row]; 131598bc09dSHong Zhang 132598bc09dSHong Zhang /* perform dense axpy */ 133598bc09dSHong Zhang valtmp = ada[j]; 134598bc09dSHong Zhang for (k=0; k<pnz; k++) { 135598bc09dSHong Zhang apa[pj[k]] += valtmp*pa[k]; 136598bc09dSHong Zhang } 137598bc09dSHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 138598bc09dSHong Zhang } 139598bc09dSHong Zhang 140598bc09dSHong Zhang /* off-diagonal portion of A */ 141598bc09dSHong Zhang anz = aoi[i+1] - aoi[i]; 142598bc09dSHong Zhang aoj = ao->j + aoi[i]; 143598bc09dSHong Zhang aoa = ao->a + aoi[i]; 144598bc09dSHong Zhang for (j=0; j<anz; j++) { 145598bc09dSHong Zhang row = aoj[j]; 146598bc09dSHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 147598bc09dSHong Zhang pj = pj_oth + pi_oth[row]; 148598bc09dSHong Zhang pa = pa_oth + pi_oth[row]; 149598bc09dSHong Zhang 150598bc09dSHong Zhang /* perform dense axpy */ 151598bc09dSHong Zhang valtmp = aoa[j]; 152598bc09dSHong Zhang for (k=0; k<pnz; k++) { 153598bc09dSHong Zhang apa[pj[k]] += valtmp*pa[k]; 154598bc09dSHong Zhang } 155598bc09dSHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 156598bc09dSHong Zhang } 157598bc09dSHong Zhang 158598bc09dSHong Zhang /* set values in C */ 159598bc09dSHong Zhang apJ = apj + api[i]; 160598bc09dSHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 161598bc09dSHong Zhang conz = co->i[i+1] - co->i[i]; 162598bc09dSHong Zhang 163598bc09dSHong Zhang /* 1st off-diagoanl part of C */ 164598bc09dSHong Zhang ca = coa + co->i[i]; 165598bc09dSHong Zhang k = 0; 166598bc09dSHong Zhang for (k0=0; k0<conz; k0++) { 167598bc09dSHong Zhang if (apJ[k] >= cstart) break; 168598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 169598bc09dSHong Zhang apa[apJ[k]] = 0.0; 170598bc09dSHong Zhang k++; 171598bc09dSHong Zhang } 172598bc09dSHong Zhang 173598bc09dSHong Zhang /* diagonal part of C */ 174598bc09dSHong Zhang ca = cda + cd->i[i]; 175598bc09dSHong Zhang for (k1=0; k1<cdnz; k1++) { 176598bc09dSHong Zhang ca[k1] = apa[apJ[k]]; 177598bc09dSHong Zhang apa[apJ[k]] = 0.0; 178598bc09dSHong Zhang k++; 179598bc09dSHong Zhang } 180598bc09dSHong Zhang 181598bc09dSHong Zhang /* 2nd off-diagoanl part of C */ 182598bc09dSHong Zhang ca = coa + co->i[i]; 183598bc09dSHong Zhang for (; k0<conz; k0++) { 184598bc09dSHong Zhang ca[k0] = apa[apJ[k]]; 185598bc09dSHong Zhang apa[apJ[k]] = 0.0; 186598bc09dSHong Zhang k++; 187598bc09dSHong Zhang } 188598bc09dSHong Zhang } 189598bc09dSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 190598bc09dSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 191598bc09dSHong Zhang PetscFunctionReturn(0); 192598bc09dSHong Zhang } 193598bc09dSHong Zhang 194598bc09dSHong Zhang #undef __FUNCT__ 1950fc8cf34SHong Zhang #define __FUNCT__ "MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable" 1960fc8cf34SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat A,Mat P,PetscReal fill,Mat *C) 197598bc09dSHong Zhang { 198598bc09dSHong Zhang PetscErrorCode ierr; 199ce94432eSBarry Smith MPI_Comm comm; 200bfcd1a73SHong Zhang Mat Cmpi; 201598bc09dSHong Zhang Mat_PtAPMPI *ptap; 2020298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 2034ae0847bSHong Zhang Mat_MPIAIJ *a =(Mat_MPIAIJ*)A->data,*c; 204bfcd1a73SHong Zhang Mat_SeqAIJ *ad =(Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 2054ae0847bSHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 2064ae0847bSHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 207d14fa243SHong Zhang PetscInt *lnk,i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi; 208bfcd1a73SHong Zhang PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n; 209598bc09dSHong Zhang PetscBT lnkbt; 210598bc09dSHong Zhang PetscScalar *apa; 211bfcd1a73SHong Zhang PetscReal afill; 212f84c536bSHong Zhang PetscInt nlnk_max,armax,prmax; 213598bc09dSHong Zhang 214598bc09dSHong Zhang PetscFunctionBegin; 215ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 216a1a4e84aSHong Zhang if (A->cmap->rstart != P->rmap->rstart || A->cmap->rend != P->rmap->rend) { 217cf1a0672SHong Zhang SETERRQ4(comm,PETSC_ERR_ARG_SIZ,"Matrix local dimensions are incompatible, (%D, %D) != (%D,%D)",A->cmap->rstart,A->cmap->rend,P->rmap->rstart,P->rmap->rend); 218a1a4e84aSHong Zhang } 219152983bfSHong Zhang 220598bc09dSHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 221*b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 222598bc09dSHong Zhang 223598bc09dSHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 224b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 22519f0e57aSHong Zhang 226598bc09dSHong Zhang /* get P_loc by taking all local rows of P */ 227a1a4e84aSHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 228598bc09dSHong Zhang 229a1a4e84aSHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 230a1a4e84aSHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 231598bc09dSHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 232598bc09dSHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 233598bc09dSHong Zhang 234598bc09dSHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 235598bc09dSHong Zhang /*-------------------------------------------------------------------*/ 236785e854fSJed Brown ierr = PetscMalloc1((am+2),&api);CHKERRQ(ierr); 237a1a4e84aSHong Zhang ptap->api = api; 238598bc09dSHong Zhang api[0] = 0; 239598bc09dSHong Zhang 240598bc09dSHong Zhang /* create and initialize a linked list */ 241f84c536bSHong Zhang armax = ad->rmax+ao->rmax; 242f84c536bSHong Zhang prmax = PetscMax(p_loc->rmax,p_oth->rmax); 243f84c536bSHong Zhang nlnk_max = armax*prmax; 244f84c536bSHong Zhang if (!nlnk_max || nlnk_max > pN) nlnk_max = pN; 2450d3134e9SHong Zhang ierr = PetscLLCondensedCreate(nlnk_max,pN,&lnk,&lnkbt);CHKERRQ(ierr); 246598bc09dSHong Zhang 247bfcd1a73SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 248bfcd1a73SHong Zhang ierr = PetscFreeSpaceGet((PetscInt)(fill*(adi[am]+aoi[am]+pi_loc[pm])),&free_space);CHKERRQ(ierr); 2492205254eSKarl Rupp 250598bc09dSHong Zhang current_space = free_space; 251598bc09dSHong Zhang 252598bc09dSHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 253598bc09dSHong Zhang for (i=0; i<am; i++) { 254598bc09dSHong Zhang /* diagonal portion of A */ 255598bc09dSHong Zhang nzi = adi[i+1] - adi[i]; 256598bc09dSHong Zhang for (j=0; j<nzi; j++) { 257598bc09dSHong Zhang row = *adj++; 258598bc09dSHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 259598bc09dSHong Zhang Jptr = pj_loc + pi_loc[row]; 260598bc09dSHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 2611fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 262598bc09dSHong Zhang } 263598bc09dSHong Zhang /* off-diagonal portion of A */ 264598bc09dSHong Zhang nzi = aoi[i+1] - aoi[i]; 265598bc09dSHong Zhang for (j=0; j<nzi; j++) { 266598bc09dSHong Zhang row = *aoj++; 267598bc09dSHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 268598bc09dSHong Zhang Jptr = pj_oth + pi_oth[row]; 2691fbbb359SHong Zhang ierr = PetscLLCondensedAddSorted(pnz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 270598bc09dSHong Zhang } 271598bc09dSHong Zhang 272d14fa243SHong Zhang apnz = lnk[0]; 273598bc09dSHong Zhang api[i+1] = api[i] + apnz; 274598bc09dSHong Zhang 275598bc09dSHong Zhang /* if free space is not available, double the total space in the list */ 276598bc09dSHong Zhang if (current_space->local_remaining<apnz) { 277598bc09dSHong Zhang ierr = PetscFreeSpaceGet(apnz+current_space->total_array_size,¤t_space);CHKERRQ(ierr); 278598bc09dSHong Zhang nspacedouble++; 279598bc09dSHong Zhang } 280598bc09dSHong Zhang 281598bc09dSHong Zhang /* Copy data into free space, then initialize lnk */ 2821fbbb359SHong Zhang ierr = PetscLLCondensedClean(pN,apnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 283598bc09dSHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 2842205254eSKarl Rupp 285598bc09dSHong Zhang current_space->array += apnz; 286598bc09dSHong Zhang current_space->local_used += apnz; 287598bc09dSHong Zhang current_space->local_remaining -= apnz; 288598bc09dSHong Zhang } 289598bc09dSHong Zhang 290598bc09dSHong Zhang /* Allocate space for apj, initialize apj, and */ 291598bc09dSHong Zhang /* destroy list of free space and other temporary array(s) */ 292785e854fSJed Brown ierr = PetscMalloc1((api[am]+1),&ptap->apj);CHKERRQ(ierr); 293a1a4e84aSHong Zhang apj = ptap->apj; 294a1a4e84aSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 295598bc09dSHong Zhang ierr = PetscLLDestroy(lnk,lnkbt);CHKERRQ(ierr); 296598bc09dSHong Zhang 297f84c536bSHong Zhang /* malloc apa to store dense row A[i,:]*P */ 2981795a4d1SJed Brown ierr = PetscCalloc1(pN,&apa);CHKERRQ(ierr); 2992205254eSKarl Rupp 300f84c536bSHong Zhang ptap->apa = apa; 301f84c536bSHong Zhang 302bfcd1a73SHong Zhang /* create and assemble symbolic parallel matrix Cmpi */ 303598bc09dSHong Zhang /*----------------------------------------------------*/ 304bfcd1a73SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 305bfcd1a73SHong Zhang ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 306a2f3521dSMark F. Adams ierr = MatSetBlockSizes(Cmpi,A->rmap->bs,P->cmap->bs);CHKERRQ(ierr); 307a2f3521dSMark F. Adams 308bfcd1a73SHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 309bfcd1a73SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 310598bc09dSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 311598bc09dSHong Zhang for (i=0; i<am; i++) { 312598bc09dSHong Zhang row = i + rstart; 313598bc09dSHong Zhang apnz = api[i+1] - api[i]; 314bfcd1a73SHong Zhang ierr = MatSetValues(Cmpi,1,&row,apnz,apj,apa,INSERT_VALUES);CHKERRQ(ierr); 315598bc09dSHong Zhang apj += apnz; 316598bc09dSHong Zhang } 317bfcd1a73SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 318bfcd1a73SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 319598bc09dSHong Zhang 320bfcd1a73SHong Zhang ptap->destroy = Cmpi->ops->destroy; 321bfcd1a73SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 322bfcd1a73SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_MatMatMult; 323bfcd1a73SHong Zhang Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatMatMult; 324598bc09dSHong Zhang 325bfcd1a73SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 326bfcd1a73SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 327598bc09dSHong Zhang c->ptap = ptap; 328598bc09dSHong Zhang 329bfcd1a73SHong Zhang *C = Cmpi; 330bfcd1a73SHong Zhang 331bfcd1a73SHong Zhang /* set MatInfo */ 332118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 333bfcd1a73SHong Zhang if (afill < 1.0) afill = 1.0; 334bfcd1a73SHong Zhang Cmpi->info.mallocs = nspacedouble; 335bfcd1a73SHong Zhang Cmpi->info.fill_ratio_given = fill; 336bfcd1a73SHong Zhang Cmpi->info.fill_ratio_needed = afill; 337bfcd1a73SHong Zhang 338bfcd1a73SHong Zhang #if defined(PETSC_USE_INFO) 339bfcd1a73SHong Zhang if (api[am]) { 340bfcd1a73SHong Zhang ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %G needed %G.\n",nspacedouble,fill,afill);CHKERRQ(ierr); 341bfcd1a73SHong Zhang ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%G,&C) for best performance.;\n",afill);CHKERRQ(ierr); 342bfcd1a73SHong Zhang } else { 343bfcd1a73SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 344bfcd1a73SHong Zhang } 345bfcd1a73SHong Zhang #endif 346598bc09dSHong Zhang PetscFunctionReturn(0); 347598bc09dSHong Zhang } 348598bc09dSHong Zhang 3499123193aSHong Zhang #undef __FUNCT__ 3509123193aSHong Zhang #define __FUNCT__ "MatMatMult_MPIAIJ_MPIDense" 3519123193aSHong Zhang PetscErrorCode MatMatMult_MPIAIJ_MPIDense(Mat A,Mat B,MatReuse scall,PetscReal fill,Mat *C) 3529123193aSHong Zhang { 3539123193aSHong Zhang PetscErrorCode ierr; 3549123193aSHong Zhang 3559123193aSHong Zhang PetscFunctionBegin; 3569123193aSHong Zhang if (scall == MAT_INITIAL_MATRIX) { 3573ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 3589123193aSHong Zhang ierr = MatMatMultSymbolic_MPIAIJ_MPIDense(A,B,fill,C);CHKERRQ(ierr); 3593ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultSymbolic,A,B,0,0);CHKERRQ(ierr); 3609123193aSHong Zhang } 3613ff4c91cSHong Zhang ierr = PetscLogEventBegin(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 3629123193aSHong Zhang ierr = MatMatMultNumeric_MPIAIJ_MPIDense(A,B,*C);CHKERRQ(ierr); 3633ff4c91cSHong Zhang ierr = PetscLogEventEnd(MAT_MatMultNumeric,A,B,0,0);CHKERRQ(ierr); 3649123193aSHong Zhang PetscFunctionReturn(0); 3659123193aSHong Zhang } 3669123193aSHong Zhang 3674324174eSBarry Smith typedef struct { 3684324174eSBarry Smith Mat workB; 3694324174eSBarry Smith PetscScalar *rvalues,*svalues; 3704324174eSBarry Smith MPI_Request *rwaits,*swaits; 3714324174eSBarry Smith } MPIAIJ_MPIDense; 3724324174eSBarry Smith 3737af9e4fdSHong Zhang #undef __FUNCT__ 37496b95a6bSBarry Smith #define __FUNCT__ "MatMPIAIJ_MPIDenseDestroy" 37596b95a6bSBarry Smith PetscErrorCode MatMPIAIJ_MPIDenseDestroy(void *ctx) 3764324174eSBarry Smith { 3774324174eSBarry Smith MPIAIJ_MPIDense *contents = (MPIAIJ_MPIDense*) ctx; 3784324174eSBarry Smith PetscErrorCode ierr; 3794324174eSBarry Smith 3804324174eSBarry Smith PetscFunctionBegin; 3816bf464f9SBarry Smith ierr = MatDestroy(&contents->workB);CHKERRQ(ierr); 3824324174eSBarry Smith ierr = PetscFree4(contents->rvalues,contents->svalues,contents->rwaits,contents->swaits);CHKERRQ(ierr); 3834324174eSBarry Smith ierr = PetscFree(contents);CHKERRQ(ierr); 3844324174eSBarry Smith PetscFunctionReturn(0); 3854324174eSBarry Smith } 3864324174eSBarry Smith 3879123193aSHong Zhang #undef __FUNCT__ 3889123193aSHong Zhang #define __FUNCT__ "MatMatMultSymbolic_MPIAIJ_MPIDense" 3899123193aSHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIDense(Mat A,Mat B,PetscReal fill,Mat *C) 3909123193aSHong Zhang { 3919123193aSHong Zhang PetscErrorCode ierr; 392f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*) A->data; 393d0f46423SBarry Smith PetscInt nz = aij->B->cmap->n; 394bf0cc555SLisandro Dalcin PetscContainer container; 3954324174eSBarry Smith MPIAIJ_MPIDense *contents; 3964324174eSBarry Smith VecScatter ctx = aij->Mvctx; 3974324174eSBarry Smith VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata; 3984324174eSBarry Smith VecScatter_MPI_General *to = (VecScatter_MPI_General*) ctx->todata; 399d0f46423SBarry Smith PetscInt m = A->rmap->n,n=B->cmap->n; 4009123193aSHong Zhang 4019123193aSHong Zhang PetscFunctionBegin; 402ce94432eSBarry Smith ierr = MatCreate(PetscObjectComm((PetscObject)B),C);CHKERRQ(ierr); 403d0f46423SBarry Smith ierr = MatSetSizes(*C,m,n,A->rmap->N,B->cmap->N);CHKERRQ(ierr); 404a2f3521dSMark F. Adams ierr = MatSetBlockSizes(*C,A->rmap->bs,B->cmap->bs);CHKERRQ(ierr); 405cb2480eaSBarry Smith ierr = MatSetType(*C,MATMPIDENSE);CHKERRQ(ierr); 4060298fd71SBarry Smith ierr = MatMPIDenseSetPreallocation(*C,NULL);CHKERRQ(ierr); 407cb2480eaSBarry Smith ierr = MatAssemblyBegin(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 408cb2480eaSBarry Smith ierr = MatAssemblyEnd(*C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 4092205254eSKarl Rupp 410d73949e8SHong Zhang (*C)->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIDense; 411f32d5d43SBarry Smith 412*b00a9115SJed Brown ierr = PetscNew(&contents);CHKERRQ(ierr); 413f32d5d43SBarry Smith /* Create work matrix used to store off processor rows of B needed for local product */ 4140298fd71SBarry Smith ierr = MatCreateSeqDense(PETSC_COMM_SELF,nz,B->cmap->N,NULL,&contents->workB);CHKERRQ(ierr); 4154324174eSBarry Smith /* Create work arrays needed */ 416dcca6d9dSJed Brown ierr = PetscMalloc4(B->cmap->N*from->starts[from->n],&contents->rvalues, 417dcca6d9dSJed Brown B->cmap->N*to->starts[to->n],&contents->svalues, 418dcca6d9dSJed Brown from->n,&contents->rwaits, 419dcca6d9dSJed Brown to->n,&contents->swaits);CHKERRQ(ierr); 4204324174eSBarry Smith 421ce94432eSBarry Smith ierr = PetscContainerCreate(PetscObjectComm((PetscObject)A),&container);CHKERRQ(ierr); 422bf0cc555SLisandro Dalcin ierr = PetscContainerSetPointer(container,contents);CHKERRQ(ierr); 42396b95a6bSBarry Smith ierr = PetscContainerSetUserDestroy(container,MatMPIAIJ_MPIDenseDestroy);CHKERRQ(ierr); 424bf0cc555SLisandro Dalcin ierr = PetscObjectCompose((PetscObject)(*C),"workB",(PetscObject)container);CHKERRQ(ierr); 425bf0cc555SLisandro Dalcin ierr = PetscContainerDestroy(&container);CHKERRQ(ierr); 4269123193aSHong Zhang PetscFunctionReturn(0); 4279123193aSHong Zhang } 4289123193aSHong Zhang 4297af9e4fdSHong Zhang #undef __FUNCT__ 4307af9e4fdSHong Zhang #define __FUNCT__ "MatMPIDenseScatter" 431f32d5d43SBarry Smith /* 4322636ff26SBarry Smith Performs an efficient scatter on the rows of B needed by this process; this is 4332636ff26SBarry Smith a modification of the VecScatterBegin_() routines. 434f32d5d43SBarry Smith */ 4354324174eSBarry Smith PetscErrorCode MatMPIDenseScatter(Mat A,Mat B,Mat C,Mat *outworkB) 436f32d5d43SBarry Smith { 437f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 438f32d5d43SBarry Smith PetscErrorCode ierr; 439f32d5d43SBarry Smith PetscScalar *b,*w,*svalues,*rvalues; 440f32d5d43SBarry Smith VecScatter ctx = aij->Mvctx; 441f32d5d43SBarry Smith VecScatter_MPI_General *from = (VecScatter_MPI_General*) ctx->fromdata; 442f32d5d43SBarry Smith VecScatter_MPI_General *to = (VecScatter_MPI_General*) ctx->todata; 443f32d5d43SBarry Smith PetscInt i,j,k; 444aa5bb8c0SSatish Balay PetscInt *sindices,*sstarts,*rindices,*rstarts; 445aa5bb8c0SSatish Balay PetscMPIInt *sprocs,*rprocs,nrecvs; 446f32d5d43SBarry Smith MPI_Request *swaits,*rwaits; 447ce94432eSBarry Smith MPI_Comm comm; 448d0f46423SBarry Smith PetscMPIInt tag = ((PetscObject)ctx)->tag,ncols = B->cmap->N, nrows = aij->B->cmap->n,imdex,nrowsB = B->rmap->n; 449f32d5d43SBarry Smith MPI_Status status; 4504324174eSBarry Smith MPIAIJ_MPIDense *contents; 451bf0cc555SLisandro Dalcin PetscContainer container; 4524324174eSBarry Smith Mat workB; 453f32d5d43SBarry Smith 454f32d5d43SBarry Smith PetscFunctionBegin; 455ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 456bf0cc555SLisandro Dalcin ierr = PetscObjectQuery((PetscObject)C,"workB",(PetscObject*)&container);CHKERRQ(ierr); 45729825010SHong Zhang if (!container) SETERRQ(comm,PETSC_ERR_PLIB,"Container does not exist"); 458bf0cc555SLisandro Dalcin ierr = PetscContainerGetPointer(container,(void**)&contents);CHKERRQ(ierr); 4594324174eSBarry Smith 4604324174eSBarry Smith workB = *outworkB = contents->workB; 461cf1a0672SHong Zhang if (nrows != workB->rmap->n) SETERRQ2(comm,PETSC_ERR_PLIB,"Number of rows of workB %D not equal to columns of aij->B %D",nrows,workB->cmap->n); 462f32d5d43SBarry Smith sindices = to->indices; 463f32d5d43SBarry Smith sstarts = to->starts; 464f32d5d43SBarry Smith sprocs = to->procs; 4654324174eSBarry Smith swaits = contents->swaits; 4664324174eSBarry Smith svalues = contents->svalues; 467f32d5d43SBarry Smith 468f32d5d43SBarry Smith rindices = from->indices; 469f32d5d43SBarry Smith rstarts = from->starts; 470f32d5d43SBarry Smith rprocs = from->procs; 4714324174eSBarry Smith rwaits = contents->rwaits; 4724324174eSBarry Smith rvalues = contents->rvalues; 473f32d5d43SBarry Smith 4748c778c55SBarry Smith ierr = MatDenseGetArray(B,&b);CHKERRQ(ierr); 4758c778c55SBarry Smith ierr = MatDenseGetArray(workB,&w);CHKERRQ(ierr); 476f32d5d43SBarry Smith 477f32d5d43SBarry Smith for (i=0; i<from->n; i++) { 478f32d5d43SBarry Smith ierr = MPI_Irecv(rvalues+ncols*rstarts[i],ncols*(rstarts[i+1]-rstarts[i]),MPIU_SCALAR,rprocs[i],tag,comm,rwaits+i);CHKERRQ(ierr); 479f32d5d43SBarry Smith } 480f32d5d43SBarry Smith 481f32d5d43SBarry Smith for (i=0; i<to->n; i++) { 482f32d5d43SBarry Smith /* pack a message at a time */ 483f32d5d43SBarry Smith for (j=0; j<sstarts[i+1]-sstarts[i]; j++) { 484f32d5d43SBarry Smith for (k=0; k<ncols; k++) { 485f32d5d43SBarry Smith svalues[ncols*(sstarts[i] + j) + k] = b[sindices[sstarts[i]+j] + nrowsB*k]; 4862636ff26SBarry Smith } 4872636ff26SBarry Smith } 488f32d5d43SBarry Smith ierr = MPI_Isend(svalues+ncols*sstarts[i],ncols*(sstarts[i+1]-sstarts[i]),MPIU_SCALAR,sprocs[i],tag,comm,swaits+i);CHKERRQ(ierr); 489f32d5d43SBarry Smith } 4902636ff26SBarry Smith 491f32d5d43SBarry Smith nrecvs = from->n; 492f32d5d43SBarry Smith while (nrecvs) { 493f32d5d43SBarry Smith ierr = MPI_Waitany(from->n,rwaits,&imdex,&status);CHKERRQ(ierr); 494f32d5d43SBarry Smith nrecvs--; 495f32d5d43SBarry Smith /* unpack a message at a time */ 496f32d5d43SBarry Smith for (j=0; j<rstarts[imdex+1]-rstarts[imdex]; j++) { 497f32d5d43SBarry Smith for (k=0; k<ncols; k++) { 498f32d5d43SBarry Smith w[rindices[rstarts[imdex]+j] + nrows*k] = rvalues[ncols*(rstarts[imdex] + j) + k]; 4992636ff26SBarry Smith } 5002636ff26SBarry Smith } 501f32d5d43SBarry Smith } 502cb9801acSJed Brown if (to->n) {ierr = MPI_Waitall(to->n,swaits,to->sstatus);CHKERRQ(ierr);} 503f32d5d43SBarry Smith 5048c778c55SBarry Smith ierr = MatDenseRestoreArray(B,&b);CHKERRQ(ierr); 5058c778c55SBarry Smith ierr = MatDenseRestoreArray(workB,&w);CHKERRQ(ierr); 506f32d5d43SBarry Smith ierr = MatAssemblyBegin(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 507f32d5d43SBarry Smith ierr = MatAssemblyEnd(workB,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 508f32d5d43SBarry Smith PetscFunctionReturn(0); 509f32d5d43SBarry Smith } 510f32d5d43SBarry Smith extern PetscErrorCode MatMatMultNumericAdd_SeqAIJ_SeqDense(Mat,Mat,Mat); 511f32d5d43SBarry Smith 5129123193aSHong Zhang #undef __FUNCT__ 5139123193aSHong Zhang #define __FUNCT__ "MatMatMultNumeric_MPIAIJ_MPIDense" 5149123193aSHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIDense(Mat A,Mat B,Mat C) 5159123193aSHong Zhang { 5169123193aSHong Zhang PetscErrorCode ierr; 517f32d5d43SBarry Smith Mat_MPIAIJ *aij = (Mat_MPIAIJ*)A->data; 518f32d5d43SBarry Smith Mat_MPIDense *bdense = (Mat_MPIDense*)B->data; 519f32d5d43SBarry Smith Mat_MPIDense *cdense = (Mat_MPIDense*)C->data; 520f32d5d43SBarry Smith Mat workB; 5219123193aSHong Zhang 5229123193aSHong Zhang PetscFunctionBegin; 523f32d5d43SBarry Smith /* diagonal block of A times all local rows of B*/ 524f32d5d43SBarry Smith ierr = MatMatMultNumeric_SeqAIJ_SeqDense(aij->A,bdense->A,cdense->A);CHKERRQ(ierr); 525f32d5d43SBarry Smith 526f32d5d43SBarry Smith /* get off processor parts of B needed to complete the product */ 5274324174eSBarry Smith ierr = MatMPIDenseScatter(A,B,C,&workB);CHKERRQ(ierr); 528f32d5d43SBarry Smith 529f32d5d43SBarry Smith /* off-diagonal block of A times nonlocal rows of B */ 530f32d5d43SBarry Smith ierr = MatMatMultNumericAdd_SeqAIJ_SeqDense(aij->B,workB,cdense->A);CHKERRQ(ierr); 5319123193aSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 5329123193aSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 5339123193aSHong Zhang PetscFunctionReturn(0); 5349123193aSHong Zhang } 535cf1a0672SHong Zhang 5361634b032SHong Zhang #undef __FUNCT__ 537cf1a0672SHong Zhang #define __FUNCT__ "MatMatMultNumeric_MPIAIJ_MPIAIJ_Scalable" 538cf1a0672SHong Zhang PetscErrorCode MatMatMultNumeric_MPIAIJ_MPIAIJ_Scalable(Mat A,Mat P,Mat C) 5391634b032SHong Zhang { 5401634b032SHong Zhang PetscErrorCode ierr; 541cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c=(Mat_MPIAIJ*)C->data; 542cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data; 543cf1a0672SHong Zhang Mat_SeqAIJ *cd = (Mat_SeqAIJ*)(c->A)->data,*co=(Mat_SeqAIJ*)(c->B)->data; 544cf1a0672SHong Zhang PetscInt *adi = ad->i,*adj,*aoi=ao->i,*aoj; 545cf1a0672SHong Zhang PetscScalar *ada,*aoa,*cda=cd->a,*coa=co->a; 546cf1a0672SHong Zhang Mat_SeqAIJ *p_loc,*p_oth; 547cf1a0672SHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*pj; 54829825010SHong Zhang PetscScalar *pa_loc,*pa_oth,*pa,valtmp,*ca; 54929825010SHong Zhang PetscInt cm = C->rmap->n,anz,pnz; 550cf1a0672SHong Zhang Mat_PtAPMPI *ptap = c->ptap; 55129825010SHong Zhang PetscScalar *apa_sparse = ptap->apa; 552cf1a0672SHong Zhang PetscInt *api,*apj,*apJ,i,j,k,row; 55329825010SHong Zhang PetscInt cstart = C->cmap->rstart; 55429825010SHong Zhang PetscInt cdnz,conz,k0,k1,nextp; 5551634b032SHong Zhang 5561634b032SHong Zhang PetscFunctionBegin; 557cf1a0672SHong Zhang /* 1) get P_oth = ptap->P_oth and P_loc = ptap->P_loc */ 558cf1a0672SHong Zhang /*-----------------------------------------------------*/ 559cf1a0672SHong Zhang /* update numerical values of P_oth and P_loc */ 560b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_REUSE_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 561cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_REUSE_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 562cf1a0672SHong Zhang 563cf1a0672SHong Zhang /* 2) compute numeric C_loc = A_loc*P = Ad*P_loc + Ao*P_oth */ 564cf1a0672SHong Zhang /*----------------------------------------------------------*/ 565cf1a0672SHong Zhang /* get data from symbolic products */ 566cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 567cf1a0672SHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 568cf1a0672SHong Zhang pi_loc=p_loc->i; pj_loc=p_loc->j; pa_loc=p_loc->a; 569cf1a0672SHong Zhang pi_oth=p_oth->i; pj_oth=p_oth->j; pa_oth=p_oth->a; 570cf1a0672SHong Zhang 57129825010SHong Zhang api = ptap->api; 57229825010SHong Zhang apj = ptap->apj; 573cf1a0672SHong Zhang for (i=0; i<cm; i++) { 57429825010SHong Zhang apJ = apj + api[i]; 57529825010SHong Zhang 576cf1a0672SHong Zhang /* diagonal portion of A */ 577cf1a0672SHong Zhang anz = adi[i+1] - adi[i]; 578cf1a0672SHong Zhang adj = ad->j + adi[i]; 579cf1a0672SHong Zhang ada = ad->a + adi[i]; 580cf1a0672SHong Zhang for (j=0; j<anz; j++) { 581cf1a0672SHong Zhang row = adj[j]; 582cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 583cf1a0672SHong Zhang pj = pj_loc + pi_loc[row]; 584cf1a0672SHong Zhang pa = pa_loc + pi_loc[row]; 58529825010SHong Zhang /* perform sparse axpy */ 586cf1a0672SHong Zhang valtmp = ada[j]; 58729825010SHong Zhang nextp = 0; 58829825010SHong Zhang for (k=0; nextp<pnz; k++) { 58929825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 59029825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 59129825010SHong Zhang } 5921634b032SHong Zhang } 593cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 594cf1a0672SHong Zhang } 5951634b032SHong Zhang 596cf1a0672SHong Zhang /* off-diagonal portion of A */ 597cf1a0672SHong Zhang anz = aoi[i+1] - aoi[i]; 598cf1a0672SHong Zhang aoj = ao->j + aoi[i]; 599cf1a0672SHong Zhang aoa = ao->a + aoi[i]; 600cf1a0672SHong Zhang for (j=0; j<anz; j++) { 601cf1a0672SHong Zhang row = aoj[j]; 602cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 603cf1a0672SHong Zhang pj = pj_oth + pi_oth[row]; 604cf1a0672SHong Zhang pa = pa_oth + pi_oth[row]; 60529825010SHong Zhang /* perform sparse axpy */ 606cf1a0672SHong Zhang valtmp = aoa[j]; 60729825010SHong Zhang nextp = 0; 60829825010SHong Zhang for (k=0; nextp<pnz; k++) { 60929825010SHong Zhang if (apJ[k] == pj[nextp]) { /* column of AP == column of P */ 61029825010SHong Zhang apa_sparse[k] += valtmp*pa[nextp++]; 61129825010SHong Zhang } 612cf1a0672SHong Zhang } 613cf1a0672SHong Zhang ierr = PetscLogFlops(2.0*pnz);CHKERRQ(ierr); 614cf1a0672SHong Zhang } 6151634b032SHong Zhang 616cf1a0672SHong Zhang /* set values in C */ 617cf1a0672SHong Zhang cdnz = cd->i[i+1] - cd->i[i]; 618cf1a0672SHong Zhang conz = co->i[i+1] - co->i[i]; 6191634b032SHong Zhang 620cf1a0672SHong Zhang /* 1st off-diagoanl part of C */ 621cf1a0672SHong Zhang ca = coa + co->i[i]; 622cf1a0672SHong Zhang k = 0; 623cf1a0672SHong Zhang for (k0=0; k0<conz; k0++) { 624cf1a0672SHong Zhang if (apJ[k] >= cstart) break; 62529825010SHong Zhang ca[k0] = apa_sparse[k]; 62629825010SHong Zhang apa_sparse[k] = 0.0; 627cf1a0672SHong Zhang k++; 628cf1a0672SHong Zhang } 6291634b032SHong Zhang 630cf1a0672SHong Zhang /* diagonal part of C */ 631cf1a0672SHong Zhang ca = cda + cd->i[i]; 632cf1a0672SHong Zhang for (k1=0; k1<cdnz; k1++) { 63329825010SHong Zhang ca[k1] = apa_sparse[k]; 63429825010SHong Zhang apa_sparse[k] = 0.0; 635cf1a0672SHong Zhang k++; 636cf1a0672SHong Zhang } 637cf1a0672SHong Zhang 638cf1a0672SHong Zhang /* 2nd off-diagoanl part of C */ 639cf1a0672SHong Zhang ca = coa + co->i[i]; 640cf1a0672SHong Zhang for (; k0<conz; k0++) { 64129825010SHong Zhang ca[k0] = apa_sparse[k]; 64229825010SHong Zhang apa_sparse[k] = 0.0; 643cf1a0672SHong Zhang k++; 644cf1a0672SHong Zhang } 645cf1a0672SHong Zhang } 646cf1a0672SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 647cf1a0672SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 648cf1a0672SHong Zhang PetscFunctionReturn(0); 649cf1a0672SHong Zhang } 650cf1a0672SHong Zhang 6510fc8cf34SHong Zhang /* same as MatMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(), except using LLCondensed to avoid O(BN) memory requirement */ 652cf1a0672SHong Zhang #undef __FUNCT__ 653b2405163SHong Zhang #define __FUNCT__ "MatMatMultSymbolic_MPIAIJ_MPIAIJ" 654b2405163SHong Zhang PetscErrorCode MatMatMultSymbolic_MPIAIJ_MPIAIJ(Mat A,Mat P,PetscReal fill,Mat *C) 655cf1a0672SHong Zhang { 656cf1a0672SHong Zhang PetscErrorCode ierr; 657ce94432eSBarry Smith MPI_Comm comm; 658cf1a0672SHong Zhang Mat Cmpi; 659cf1a0672SHong Zhang Mat_PtAPMPI *ptap; 6600298fd71SBarry Smith PetscFreeSpaceList free_space = NULL,current_space=NULL; 661cf1a0672SHong Zhang Mat_MPIAIJ *a = (Mat_MPIAIJ*)A->data,*c; 662cf1a0672SHong Zhang Mat_SeqAIJ *ad = (Mat_SeqAIJ*)(a->A)->data,*ao=(Mat_SeqAIJ*)(a->B)->data,*p_loc,*p_oth; 663cf1a0672SHong Zhang PetscInt *pi_loc,*pj_loc,*pi_oth,*pj_oth,*dnz,*onz; 664cf1a0672SHong Zhang PetscInt *adi=ad->i,*adj=ad->j,*aoi=ao->i,*aoj=ao->j,rstart=A->rmap->rstart; 665f84c536bSHong Zhang PetscInt i,pnz,row,*api,*apj,*Jptr,apnz,nspacedouble=0,j,nzi,*lnk,apnz_max=0; 666cf1a0672SHong Zhang PetscInt am=A->rmap->n,pN=P->cmap->N,pn=P->cmap->n,pm=P->rmap->n; 667cf1a0672SHong Zhang PetscInt nlnk_max,armax,prmax; 668cf1a0672SHong Zhang PetscReal afill; 669cf1a0672SHong Zhang PetscScalar *apa; 670cf1a0672SHong Zhang 671cf1a0672SHong Zhang PetscFunctionBegin; 672ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 673cf1a0672SHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 674*b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 675cf1a0672SHong Zhang 676cf1a0672SHong Zhang /* get P_oth by taking rows of P (= non-zero cols of local A) from other processors */ 677b7f45c76SHong Zhang ierr = MatGetBrowsOfAoCols_MPIAIJ(A,P,MAT_INITIAL_MATRIX,&ptap->startsj_s,&ptap->startsj_r,&ptap->bufa,&ptap->P_oth);CHKERRQ(ierr); 67819f0e57aSHong Zhang 679cf1a0672SHong Zhang /* get P_loc by taking all local rows of P */ 680cf1a0672SHong Zhang ierr = MatMPIAIJGetLocalMat(P,MAT_INITIAL_MATRIX,&ptap->P_loc);CHKERRQ(ierr); 681cf1a0672SHong Zhang 682cf1a0672SHong Zhang p_loc = (Mat_SeqAIJ*)(ptap->P_loc)->data; 683cf1a0672SHong Zhang p_oth = (Mat_SeqAIJ*)(ptap->P_oth)->data; 684cf1a0672SHong Zhang pi_loc = p_loc->i; pj_loc = p_loc->j; 685cf1a0672SHong Zhang pi_oth = p_oth->i; pj_oth = p_oth->j; 686cf1a0672SHong Zhang 687cf1a0672SHong Zhang /* first, compute symbolic AP = A_loc*P = A_diag*P_loc + A_off*P_oth */ 688cf1a0672SHong Zhang /*-------------------------------------------------------------------*/ 689785e854fSJed Brown ierr = PetscMalloc1((am+2),&api);CHKERRQ(ierr); 690cf1a0672SHong Zhang ptap->api = api; 691cf1a0672SHong Zhang api[0] = 0; 692cf1a0672SHong Zhang 693cf1a0672SHong Zhang /* create and initialize a linked list */ 694cf1a0672SHong Zhang armax = ad->rmax+ao->rmax; 695cf1a0672SHong Zhang prmax = PetscMax(p_loc->rmax,p_oth->rmax); 696cf1a0672SHong Zhang nlnk_max = armax*prmax; 697cf1a0672SHong Zhang if (!nlnk_max || nlnk_max > pN) nlnk_max = pN; 698f84c536bSHong Zhang ierr = PetscLLCondensedCreate_Scalable(nlnk_max,&lnk);CHKERRQ(ierr); 699cf1a0672SHong Zhang 700cf1a0672SHong Zhang /* Initial FreeSpace size is fill*(nnz(A)+nnz(P)) */ 701cf1a0672SHong Zhang ierr = PetscFreeSpaceGet((PetscInt)(fill*(adi[am]+aoi[am]+pi_loc[pm])),&free_space);CHKERRQ(ierr); 7022205254eSKarl Rupp 703cf1a0672SHong Zhang current_space = free_space; 704cf1a0672SHong Zhang 705cf1a0672SHong Zhang ierr = MatPreallocateInitialize(comm,am,pn,dnz,onz);CHKERRQ(ierr); 706cf1a0672SHong Zhang for (i=0; i<am; i++) { 707cf1a0672SHong Zhang /* diagonal portion of A */ 708cf1a0672SHong Zhang nzi = adi[i+1] - adi[i]; 709cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 710cf1a0672SHong Zhang row = *adj++; 711cf1a0672SHong Zhang pnz = pi_loc[row+1] - pi_loc[row]; 712cf1a0672SHong Zhang Jptr = pj_loc + pi_loc[row]; 713cf1a0672SHong Zhang /* add non-zero cols of P into the sorted linked list lnk */ 714f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 715cf1a0672SHong Zhang } 716cf1a0672SHong Zhang /* off-diagonal portion of A */ 717cf1a0672SHong Zhang nzi = aoi[i+1] - aoi[i]; 718cf1a0672SHong Zhang for (j=0; j<nzi; j++) { 719cf1a0672SHong Zhang row = *aoj++; 720cf1a0672SHong Zhang pnz = pi_oth[row+1] - pi_oth[row]; 721cf1a0672SHong Zhang Jptr = pj_oth + pi_oth[row]; 722f84c536bSHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(pnz,Jptr,lnk);CHKERRQ(ierr); 723cf1a0672SHong Zhang } 724cf1a0672SHong Zhang 725f84c536bSHong Zhang apnz = *lnk; 726cf1a0672SHong Zhang api[i+1] = api[i] + apnz; 727cf1a0672SHong Zhang if (apnz > apnz_max) apnz_max = apnz; 728cf1a0672SHong Zhang 729cf1a0672SHong Zhang /* if free space is not available, double the total space in the list */ 730cf1a0672SHong Zhang if (current_space->local_remaining<apnz) { 731cf1a0672SHong Zhang ierr = PetscFreeSpaceGet(apnz+current_space->total_array_size,¤t_space);CHKERRQ(ierr); 732cf1a0672SHong Zhang nspacedouble++; 733cf1a0672SHong Zhang } 734cf1a0672SHong Zhang 735cf1a0672SHong Zhang /* Copy data into free space, then initialize lnk */ 736f84c536bSHong Zhang ierr = PetscLLCondensedClean_Scalable(apnz,current_space->array,lnk);CHKERRQ(ierr); 737cf1a0672SHong Zhang ierr = MatPreallocateSet(i+rstart,apnz,current_space->array,dnz,onz);CHKERRQ(ierr); 7382205254eSKarl Rupp 739cf1a0672SHong Zhang current_space->array += apnz; 740cf1a0672SHong Zhang current_space->local_used += apnz; 741cf1a0672SHong Zhang current_space->local_remaining -= apnz; 742cf1a0672SHong Zhang } 743cf1a0672SHong Zhang 744cf1a0672SHong Zhang /* Allocate space for apj, initialize apj, and */ 745cf1a0672SHong Zhang /* destroy list of free space and other temporary array(s) */ 746785e854fSJed Brown ierr = PetscMalloc1((api[am]+1),&ptap->apj);CHKERRQ(ierr); 747cf1a0672SHong Zhang apj = ptap->apj; 748cf1a0672SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,ptap->apj);CHKERRQ(ierr); 749f84c536bSHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 750cf1a0672SHong Zhang 751cf1a0672SHong Zhang /* create and assemble symbolic parallel matrix Cmpi */ 752cf1a0672SHong Zhang /*----------------------------------------------------*/ 753cf1a0672SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 754cf1a0672SHong Zhang ierr = MatSetSizes(Cmpi,am,pn,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 755a2f3521dSMark F. Adams ierr = MatSetBlockSizes(Cmpi,A->rmap->bs,P->cmap->bs);CHKERRQ(ierr); 756cf1a0672SHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 757cf1a0672SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 758cf1a0672SHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 759cf1a0672SHong Zhang 76029825010SHong Zhang /* malloc apa for assembly Cmpi */ 7611795a4d1SJed Brown ierr = PetscCalloc1(apnz_max,&apa);CHKERRQ(ierr); 7622205254eSKarl Rupp 76329825010SHong Zhang ptap->apa = apa; 764cf1a0672SHong Zhang for (i=0; i<am; i++) { 765cf1a0672SHong Zhang row = i + rstart; 766cf1a0672SHong Zhang apnz = api[i+1] - api[i]; 767cf1a0672SHong Zhang ierr = MatSetValues(Cmpi,1,&row,apnz,apj,apa,INSERT_VALUES);CHKERRQ(ierr); 768cf1a0672SHong Zhang apj += apnz; 769cf1a0672SHong Zhang } 770cf1a0672SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 771cf1a0672SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 772cf1a0672SHong Zhang 773cf1a0672SHong Zhang ptap->destroy = Cmpi->ops->destroy; 774cf1a0672SHong Zhang ptap->duplicate = Cmpi->ops->duplicate; 775cf1a0672SHong Zhang Cmpi->ops->matmultnumeric = MatMatMultNumeric_MPIAIJ_MPIAIJ_Scalable; 776cf1a0672SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_MatMatMult; 777cf1a0672SHong Zhang Cmpi->ops->duplicate = MatDuplicate_MPIAIJ_MatMatMult; 778cf1a0672SHong Zhang 779cf1a0672SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 780cf1a0672SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 781cf1a0672SHong Zhang c->ptap = ptap; 782cf1a0672SHong Zhang 783cf1a0672SHong Zhang *C = Cmpi; 784cf1a0672SHong Zhang 785cf1a0672SHong Zhang /* set MatInfo */ 786118727c9SMark F. Adams afill = (PetscReal)api[am]/(adi[am]+aoi[am]+pi_loc[pm]+1) + 1.e-5; 787cf1a0672SHong Zhang if (afill < 1.0) afill = 1.0; 788cf1a0672SHong Zhang Cmpi->info.mallocs = nspacedouble; 789cf1a0672SHong Zhang Cmpi->info.fill_ratio_given = fill; 790cf1a0672SHong Zhang Cmpi->info.fill_ratio_needed = afill; 791cf1a0672SHong Zhang 792cf1a0672SHong Zhang #if defined(PETSC_USE_INFO) 793cf1a0672SHong Zhang if (api[am]) { 794cf1a0672SHong Zhang ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %G needed %G.\n",nspacedouble,fill,afill);CHKERRQ(ierr); 795cf1a0672SHong Zhang ierr = PetscInfo1(Cmpi,"Use MatMatMult(A,B,MatReuse,%G,&C) for best performance.;\n",afill);CHKERRQ(ierr); 796cf1a0672SHong Zhang } else { 797cf1a0672SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 798cf1a0672SHong Zhang } 799cf1a0672SHong Zhang #endif 8001634b032SHong Zhang PetscFunctionReturn(0); 8011634b032SHong Zhang } 802f96d37fcSHong Zhang 803f96d37fcSHong Zhang /*-------------------------------------------------------------------------*/ 804f96d37fcSHong Zhang #undef __FUNCT__ 805f96d37fcSHong Zhang #define __FUNCT__ "MatTransposeMatMult_MPIAIJ_MPIAIJ" 806c5af039cSHong Zhang PetscErrorCode MatTransposeMatMult_MPIAIJ_MPIAIJ(Mat P,Mat A,MatReuse scall,PetscReal fill,Mat *C) 807f96d37fcSHong Zhang { 808f96d37fcSHong Zhang PetscErrorCode ierr; 809c216dbf3SHong Zhang const char *algTypes[3] = {"scalable","nonscalable","matmatmult"}; 810c216dbf3SHong Zhang PetscInt alg=0; /* set default algorithm */ 811f96d37fcSHong Zhang 812f96d37fcSHong Zhang PetscFunctionBegin; 813c216dbf3SHong Zhang if (scall == MAT_INITIAL_MATRIX) { 814c216dbf3SHong Zhang ierr = PetscObjectOptionsBegin((PetscObject)A);CHKERRQ(ierr); 815c216dbf3SHong Zhang ierr = PetscOptionsEList("-mattransposematmult_via","Algorithmic approach","MatTransposeMatMult",algTypes,3,algTypes[0],&alg,NULL);CHKERRQ(ierr); 816c216dbf3SHong Zhang ierr = PetscOptionsEnd();CHKERRQ(ierr); 817c216dbf3SHong Zhang 818c216dbf3SHong Zhang ierr = PetscLogEventBegin(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr); 819c216dbf3SHong Zhang switch (alg) { 820c216dbf3SHong Zhang case 1: 8212bbb1c24SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(P,A,fill,C);CHKERRQ(ierr); 822c216dbf3SHong Zhang break; 823c216dbf3SHong Zhang case 2: 824275476c6SMatthew G. Knepley { 825ab1b013aSHong Zhang Mat Pt; 826ab1b013aSHong Zhang Mat_PtAPMPI *ptap; 827ab1b013aSHong Zhang Mat_MPIAIJ *c; 828ab1b013aSHong Zhang ierr = MatTranspose(P,MAT_INITIAL_MATRIX,&Pt);CHKERRQ(ierr); 829ab1b013aSHong Zhang ierr = MatMatMult(Pt,A,MAT_INITIAL_MATRIX,fill,C);CHKERRQ(ierr); 830ab1b013aSHong Zhang c = (Mat_MPIAIJ*)(*C)->data; 831ab1b013aSHong Zhang ptap = c->ptap; 832ab1b013aSHong Zhang ptap->Pt = Pt; 833c216dbf3SHong Zhang (*C)->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult; 834c216dbf3SHong Zhang PetscFunctionReturn(0); 835275476c6SMatthew G. Knepley } 836c216dbf3SHong Zhang break; 837c216dbf3SHong Zhang default: 8386da69ca6SHong Zhang ierr = MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(P,A,fill,C);CHKERRQ(ierr); 839c216dbf3SHong Zhang break; 840c216dbf3SHong Zhang } 841c216dbf3SHong Zhang ierr = PetscLogEventEnd(MAT_TransposeMatMultSymbolic,P,A,0,0);CHKERRQ(ierr); 842c216dbf3SHong Zhang } 843c216dbf3SHong Zhang ierr = PetscLogEventBegin(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr); 844c216dbf3SHong Zhang ierr = (*(*C)->ops->mattransposemultnumeric)(P,A,*C);CHKERRQ(ierr); 845c216dbf3SHong Zhang ierr = PetscLogEventEnd(MAT_TransposeMatMultNumeric,P,A,0,0);CHKERRQ(ierr); 846ab1b013aSHong Zhang PetscFunctionReturn(0); 847ab1b013aSHong Zhang } 848ab1b013aSHong Zhang 849c216dbf3SHong Zhang /* This routine only works when scall=MAT_REUSE_MATRIX! */ 850c216dbf3SHong Zhang #undef __FUNCT__ 851c216dbf3SHong Zhang #define __FUNCT__ "MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult" 852c216dbf3SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_matmatmult(Mat P,Mat A,Mat C) 853c216dbf3SHong Zhang { 854c216dbf3SHong Zhang PetscErrorCode ierr; 8552bbb1c24SHong Zhang Mat_MPIAIJ *c=(Mat_MPIAIJ*)C->data; 8562bbb1c24SHong Zhang Mat_PtAPMPI *ptap= c->ptap; 8572bbb1c24SHong Zhang Mat Pt=ptap->Pt; 858c216dbf3SHong Zhang 859c216dbf3SHong Zhang PetscFunctionBegin; 860c216dbf3SHong Zhang ierr = MatTranspose(P,MAT_REUSE_MATRIX,&Pt);CHKERRQ(ierr); 861c216dbf3SHong Zhang ierr = MatMatMultNumeric(Pt,A,C);CHKERRQ(ierr); 862f96d37fcSHong Zhang PetscFunctionReturn(0); 863f96d37fcSHong Zhang } 864f96d37fcSHong Zhang 8656da69ca6SHong Zhang /* Non-scalable version, use dense axpy */ 866f96d37fcSHong Zhang #undef __FUNCT__ 8676da69ca6SHong Zhang #define __FUNCT__ "MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable" 8686da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,Mat C) 869f96d37fcSHong Zhang { 870c5af039cSHong Zhang PetscErrorCode ierr; 871c5af039cSHong Zhang Mat_Merge_SeqsToMPI *merge; 872497f5370SHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 873c5af039cSHong Zhang Mat_SeqAIJ *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data; 874c5af039cSHong Zhang Mat_PtAPMPI *ptap; 875d6ab1dc0SHong Zhang PetscInt *adj,*aJ; 876497f5370SHong Zhang PetscInt i,j,k,anz,pnz,row,*cj; 877e745005bSHong Zhang MatScalar *ada,*aval,*ca,valtmp; 878c5af039cSHong Zhang PetscInt am =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n; 879ce94432eSBarry Smith MPI_Comm comm; 880c5af039cSHong Zhang PetscMPIInt size,rank,taga,*len_s; 881c5af039cSHong Zhang PetscInt *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci; 882c5af039cSHong Zhang PetscInt **buf_ri,**buf_rj; 883c5af039cSHong Zhang PetscInt cnz=0,*bj_i,*bi,*bj,bnz,nextcj; /* bi,bj,ba: local array of C(mpi mat) */ 884c5af039cSHong Zhang MPI_Request *s_waits,*r_waits; 885c5af039cSHong Zhang MPI_Status *status; 886c5af039cSHong Zhang MatScalar **abuf_r,*ba_i,*pA,*coa,*ba; 887d6ab1dc0SHong Zhang PetscInt *ai,*aj,*coi,*coj; 888a2ea699eSBarry Smith PetscInt *poJ,*pdJ; 889c5af039cSHong Zhang Mat A_loc; 890c5af039cSHong Zhang Mat_SeqAIJ *a_loc; 891f96d37fcSHong Zhang 892f96d37fcSHong Zhang PetscFunctionBegin; 893ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 894c5af039cSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 895c5af039cSHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 896c5af039cSHong Zhang 897c5af039cSHong Zhang ptap = c->ptap; 898c5af039cSHong Zhang merge = ptap->merge; 899c5af039cSHong Zhang 900c5af039cSHong Zhang /* 2) compute numeric C_seq = P_loc^T*A_loc*P - dominating part */ 901c5af039cSHong Zhang /*--------------------------------------------------------------*/ 902c5af039cSHong Zhang /* get data from symbolic products */ 903c5af039cSHong Zhang coi = merge->coi; coj = merge->coj; 9041795a4d1SJed Brown ierr = PetscCalloc1((coi[pon]+1),&coa);CHKERRQ(ierr); 905c5af039cSHong Zhang 906c5af039cSHong Zhang bi = merge->bi; bj = merge->bj; 907c5af039cSHong Zhang owners = merge->rowmap->range; 9081795a4d1SJed Brown ierr = PetscCalloc1((bi[cm]+1),&ba);CHKERRQ(ierr); 909c5af039cSHong Zhang 910c5af039cSHong Zhang /* get A_loc by taking all local rows of A */ 911c5af039cSHong Zhang A_loc = ptap->A_loc; 912c5af039cSHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr); 913c5af039cSHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 914d6ab1dc0SHong Zhang ai = a_loc->i; 915d6ab1dc0SHong Zhang aj = a_loc->j; 916c5af039cSHong Zhang 9171795a4d1SJed Brown ierr = PetscCalloc1((A->cmap->N),&aval);CHKERRQ(ierr); /* non-scalable!!! */ 918c5af039cSHong Zhang 919c5af039cSHong Zhang for (i=0; i<am; i++) { 920e745005bSHong Zhang /* 2-a) put A[i,:] to dense array aval */ 921d6ab1dc0SHong Zhang anz = ai[i+1] - ai[i]; 922d6ab1dc0SHong Zhang adj = aj + ai[i]; 923d6ab1dc0SHong Zhang ada = a_loc->a + ai[i]; 924c5af039cSHong Zhang for (j=0; j<anz; j++) { 925e745005bSHong Zhang aval[adj[j]] = ada[j]; 926c5af039cSHong Zhang } 927c5af039cSHong Zhang 928c5af039cSHong Zhang /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */ 929c5af039cSHong Zhang /*--------------------------------------------------------------*/ 930c5af039cSHong Zhang /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */ 931c5af039cSHong Zhang pnz = po->i[i+1] - po->i[i]; 932c5af039cSHong Zhang poJ = po->j + po->i[i]; 933c5af039cSHong Zhang pA = po->a + po->i[i]; 934c5af039cSHong Zhang for (j=0; j<pnz; j++) { 935c5af039cSHong Zhang row = poJ[j]; 936c5af039cSHong Zhang cnz = coi[row+1] - coi[row]; 937c5af039cSHong Zhang cj = coj + coi[row]; 938c5af039cSHong Zhang ca = coa + coi[row]; 939c5af039cSHong Zhang /* perform dense axpy */ 940c5af039cSHong Zhang valtmp = pA[j]; 941c5af039cSHong Zhang for (k=0; k<cnz; k++) { 942e745005bSHong Zhang ca[k] += valtmp*aval[cj[k]]; 943c5af039cSHong Zhang } 944c5af039cSHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 945c5af039cSHong Zhang } 946c5af039cSHong Zhang 947c5af039cSHong Zhang /* put the value into Cd (diagonal part) */ 948c5af039cSHong Zhang pnz = pd->i[i+1] - pd->i[i]; 949c5af039cSHong Zhang pdJ = pd->j + pd->i[i]; 950c5af039cSHong Zhang pA = pd->a + pd->i[i]; 951c5af039cSHong Zhang for (j=0; j<pnz; j++) { 952c5af039cSHong Zhang row = pdJ[j]; 953c5af039cSHong Zhang cnz = bi[row+1] - bi[row]; 954c5af039cSHong Zhang cj = bj + bi[row]; 955c5af039cSHong Zhang ca = ba + bi[row]; 956c5af039cSHong Zhang /* perform dense axpy */ 957c5af039cSHong Zhang valtmp = pA[j]; 958c5af039cSHong Zhang for (k=0; k<cnz; k++) { 959e745005bSHong Zhang ca[k] += valtmp*aval[cj[k]]; 960c5af039cSHong Zhang } 961c5af039cSHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 962c5af039cSHong Zhang } 963c5af039cSHong Zhang 964d6ab1dc0SHong Zhang /* zero the current row of Pt*A */ 965d6ab1dc0SHong Zhang aJ = aj + ai[i]; 966e745005bSHong Zhang for (k=0; k<anz; k++) aval[aJ[k]] = 0.0; 967c5af039cSHong Zhang } 968c5af039cSHong Zhang 969c5af039cSHong Zhang /* 3) send and recv matrix values coa */ 970c5af039cSHong Zhang /*------------------------------------*/ 971c5af039cSHong Zhang buf_ri = merge->buf_ri; 972c5af039cSHong Zhang buf_rj = merge->buf_rj; 973c5af039cSHong Zhang len_s = merge->len_s; 974c5af039cSHong Zhang ierr = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr); 975c5af039cSHong Zhang ierr = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr); 976c5af039cSHong Zhang 977dcca6d9dSJed Brown ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr); 978c5af039cSHong Zhang for (proc=0,k=0; proc<size; proc++) { 979c5af039cSHong Zhang if (!len_s[proc]) continue; 980c5af039cSHong Zhang i = merge->owners_co[proc]; 981c5af039cSHong Zhang ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr); 982c5af039cSHong Zhang k++; 983c5af039cSHong Zhang } 984c5af039cSHong Zhang if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);} 985c5af039cSHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);} 986c5af039cSHong Zhang 987c5af039cSHong Zhang ierr = PetscFree2(s_waits,status);CHKERRQ(ierr); 988c5af039cSHong Zhang ierr = PetscFree(r_waits);CHKERRQ(ierr); 989c5af039cSHong Zhang ierr = PetscFree(coa);CHKERRQ(ierr); 990c5af039cSHong Zhang 991c5af039cSHong Zhang /* 4) insert local Cseq and received values into Cmpi */ 992c5af039cSHong Zhang /*----------------------------------------------------*/ 993dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 994c5af039cSHong Zhang for (k=0; k<merge->nrecv; k++) { 995c36aecf5SHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 996c5af039cSHong Zhang nrows = *(buf_ri_k[k]); 997c5af039cSHong Zhang nextrow[k] = buf_ri_k[k]+1; /* next row number of k-th recved i-structure */ 998c5af039cSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 999c5af039cSHong Zhang } 1000c5af039cSHong Zhang 1001c5af039cSHong Zhang for (i=0; i<cm; i++) { 1002c5af039cSHong Zhang row = owners[rank] + i; /* global row index of C_seq */ 1003c5af039cSHong Zhang bj_i = bj + bi[i]; /* col indices of the i-th row of C */ 1004c5af039cSHong Zhang ba_i = ba + bi[i]; 1005c5af039cSHong Zhang bnz = bi[i+1] - bi[i]; 1006c5af039cSHong Zhang /* add received vals into ba */ 1007c5af039cSHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1008c5af039cSHong Zhang /* i-th row */ 1009c5af039cSHong Zhang if (i == *nextrow[k]) { 1010c5af039cSHong Zhang cnz = *(nextci[k]+1) - *nextci[k]; 1011c5af039cSHong Zhang cj = buf_rj[k] + *(nextci[k]); 1012c5af039cSHong Zhang ca = abuf_r[k] + *(nextci[k]); 1013c5af039cSHong Zhang nextcj = 0; 1014c5af039cSHong Zhang for (j=0; nextcj<cnz; j++) { 1015c5af039cSHong Zhang if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */ 1016c5af039cSHong Zhang ba_i[j] += ca[nextcj++]; 1017c5af039cSHong Zhang } 1018c5af039cSHong Zhang } 1019c5af039cSHong Zhang nextrow[k]++; nextci[k]++; 1020c5af039cSHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1021c5af039cSHong Zhang } 1022c5af039cSHong Zhang } 1023c5af039cSHong Zhang ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr); 1024c5af039cSHong Zhang } 1025c5af039cSHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1026c5af039cSHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1027c5af039cSHong Zhang 1028c5af039cSHong Zhang ierr = PetscFree(ba);CHKERRQ(ierr); 1029c5af039cSHong Zhang ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr); 1030c5af039cSHong Zhang ierr = PetscFree(abuf_r);CHKERRQ(ierr); 1031c5af039cSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1032e745005bSHong Zhang ierr = PetscFree(aval);CHKERRQ(ierr); 1033f96d37fcSHong Zhang PetscFunctionReturn(0); 1034f96d37fcSHong Zhang } 1035f96d37fcSHong Zhang 1036c5af039cSHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ() */ 1037f96d37fcSHong Zhang #undef __FUNCT__ 10382bbb1c24SHong Zhang #define __FUNCT__ "MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable" 10392bbb1c24SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable(Mat P,Mat A,PetscReal fill,Mat *C) 1040f96d37fcSHong Zhang { 1041f96d37fcSHong Zhang PetscErrorCode ierr; 10424e938277SHong Zhang Mat Cmpi,A_loc,POt,PDt; 1043f96d37fcSHong Zhang Mat_PtAPMPI *ptap; 10440298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 1045f96d37fcSHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c; 1046f96d37fcSHong Zhang PetscInt *pdti,*pdtj,*poti,*potj,*ptJ; 1047f96d37fcSHong Zhang PetscInt nnz; 10484e938277SHong Zhang PetscInt *lnk,*owners_co,*coi,*coj,i,k,pnz,row; 1049497f5370SHong Zhang PetscInt am=A->rmap->n,pn=P->cmap->n; 1050f96d37fcSHong Zhang PetscBT lnkbt; 1051ce94432eSBarry Smith MPI_Comm comm; 1052f96d37fcSHong Zhang PetscMPIInt size,rank,tagi,tagj,*len_si,*len_s,*len_ri; 1053f96d37fcSHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 1054f96d37fcSHong Zhang PetscInt len,proc,*dnz,*onz,*owners; 1055f96d37fcSHong Zhang PetscInt nzi,*bi,*bj; 1056f96d37fcSHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1057f96d37fcSHong Zhang MPI_Request *swaits,*rwaits; 1058f96d37fcSHong Zhang MPI_Status *sstatus,rstatus; 1059f96d37fcSHong Zhang Mat_Merge_SeqsToMPI *merge; 1060d6ab1dc0SHong Zhang PetscInt *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j; 1061f96d37fcSHong Zhang PetscReal afill =1.0,afill_tmp; 1062c36aecf5SHong Zhang PetscInt rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Crmax; 1063f96d37fcSHong Zhang PetscScalar *vals; 10644e938277SHong Zhang Mat_SeqAIJ *a_loc, *pdt,*pot; 1065f96d37fcSHong Zhang 1066f96d37fcSHong Zhang PetscFunctionBegin; 1067ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1068c5af039cSHong Zhang /* check if matrix local sizes are compatible */ 1069c5af039cSHong Zhang if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) { 1070c5af039cSHong Zhang 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); 1071c5af039cSHong Zhang } 1072c5af039cSHong Zhang 1073f96d37fcSHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1074f96d37fcSHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1075f96d37fcSHong Zhang 1076f96d37fcSHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 1077*b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 1078f96d37fcSHong Zhang 1079f96d37fcSHong Zhang /* get A_loc by taking all local rows of A */ 1080f96d37fcSHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr); 10812205254eSKarl Rupp 1082c5af039cSHong Zhang ptap->A_loc = A_loc; 10832205254eSKarl Rupp 10841c7d5954SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1085d6ab1dc0SHong Zhang ai = a_loc->i; 1086d6ab1dc0SHong Zhang aj = a_loc->j; 1087f96d37fcSHong Zhang 1088f96d37fcSHong Zhang /* determine symbolic Co=(p->B)^T*A - send to others */ 1089f96d37fcSHong Zhang /*----------------------------------------------------*/ 10904e938277SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr); 10914e938277SHong Zhang pdt = (Mat_SeqAIJ*)PDt->data; 10924e938277SHong Zhang pdti = pdt->i; pdtj = pdt->j; 10934e938277SHong Zhang 10944e938277SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr); 10954e938277SHong Zhang pot = (Mat_SeqAIJ*)POt->data; 10964e938277SHong Zhang poti = pot->i; potj = pot->j; 1097f96d37fcSHong Zhang 1098f96d37fcSHong Zhang /* then, compute symbolic Co = (p->B)^T*A */ 10992205254eSKarl Rupp pon = (p->B)->cmap->n; /* total num of rows to be sent to other processors >= (num of nonzero rows of C_seq) - pn */ 1100785e854fSJed Brown ierr = PetscMalloc1((pon+1),&coi);CHKERRQ(ierr); 1101f96d37fcSHong Zhang coi[0] = 0; 1102f96d37fcSHong Zhang 1103f96d37fcSHong Zhang /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */ 1104d6ab1dc0SHong Zhang nnz = fill*(poti[pon] + ai[am]); 1105a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1106f96d37fcSHong Zhang current_space = free_space; 110719f0e57aSHong Zhang 1108f96d37fcSHong Zhang /* create and initialize a linked list */ 11094e938277SHong Zhang i = PetscMax(pdt->rmax,pot->rmax); 1110c36aecf5SHong Zhang Crmax = i*a_loc->rmax*size; 11114e938277SHong Zhang if (!Crmax || Crmax > aN) Crmax = aN; 11124e938277SHong Zhang ierr = PetscLLCondensedCreate(Crmax,aN,&lnk,&lnkbt);CHKERRQ(ierr); 1113f96d37fcSHong Zhang 1114f96d37fcSHong Zhang for (i=0; i<pon; i++) { 1115f96d37fcSHong Zhang pnz = poti[i+1] - poti[i]; 1116f96d37fcSHong Zhang ptJ = potj + poti[i]; 1117f96d37fcSHong Zhang for (j=0; j<pnz; j++) { 1118f96d37fcSHong Zhang row = ptJ[j]; /* row of A_loc == col of Pot */ 1119d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1120d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1121f96d37fcSHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1122d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted(anz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1123f96d37fcSHong Zhang } 11244e938277SHong Zhang nnz = lnk[0]; 1125f96d37fcSHong Zhang 1126f96d37fcSHong Zhang /* If free space is not available, double the total space in the list */ 1127f96d37fcSHong Zhang if (current_space->local_remaining<nnz) { 1128f96d37fcSHong Zhang ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,¤t_space);CHKERRQ(ierr); 1129f96d37fcSHong Zhang nspacedouble++; 1130f96d37fcSHong Zhang } 1131f96d37fcSHong Zhang 1132f96d37fcSHong Zhang /* Copy data into free space, and zero out denserows */ 11334e938277SHong Zhang ierr = PetscLLCondensedClean(aN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 11342205254eSKarl Rupp 1135f96d37fcSHong Zhang current_space->array += nnz; 1136f96d37fcSHong Zhang current_space->local_used += nnz; 1137f96d37fcSHong Zhang current_space->local_remaining -= nnz; 11382205254eSKarl Rupp 1139f96d37fcSHong Zhang coi[i+1] = coi[i] + nnz; 1140f96d37fcSHong Zhang } 1141f96d37fcSHong Zhang 1142785e854fSJed Brown ierr = PetscMalloc1((coi[pon]+1),&coj);CHKERRQ(ierr); 1143f96d37fcSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr); 11442205254eSKarl Rupp 1145118727c9SMark F. Adams afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1); 1146f96d37fcSHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1147f96d37fcSHong Zhang 1148f96d37fcSHong Zhang /* send j-array (coj) of Co to other processors */ 1149f96d37fcSHong Zhang /*----------------------------------------------*/ 1150f96d37fcSHong Zhang /* determine row ownership */ 1151*b00a9115SJed Brown ierr = PetscNew(&merge);CHKERRQ(ierr); 1152f96d37fcSHong Zhang ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr); 11532205254eSKarl Rupp 1154f96d37fcSHong Zhang merge->rowmap->n = pn; 1155f96d37fcSHong Zhang merge->rowmap->bs = 1; 11562205254eSKarl Rupp 1157f96d37fcSHong Zhang ierr = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr); 1158f96d37fcSHong Zhang owners = merge->rowmap->range; 1159f96d37fcSHong Zhang 1160f96d37fcSHong Zhang /* determine the number of messages to send, their lengths */ 11611795a4d1SJed Brown ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr); 1162785e854fSJed Brown ierr = PetscMalloc1(size,&merge->len_s);CHKERRQ(ierr); 11632205254eSKarl Rupp 1164f96d37fcSHong Zhang len_s = merge->len_s; 1165f96d37fcSHong Zhang merge->nsend = 0; 1166f96d37fcSHong Zhang 1167785e854fSJed Brown ierr = PetscMalloc1((size+2),&owners_co);CHKERRQ(ierr); 1168f96d37fcSHong Zhang ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr); 1169f96d37fcSHong Zhang 1170f96d37fcSHong Zhang proc = 0; 1171f96d37fcSHong Zhang for (i=0; i<pon; i++) { 1172f96d37fcSHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 1173f96d37fcSHong Zhang len_si[proc]++; /* num of rows in Co to be sent to [proc] */ 1174f96d37fcSHong Zhang len_s[proc] += coi[i+1] - coi[i]; 1175f96d37fcSHong Zhang } 1176f96d37fcSHong Zhang 1177f96d37fcSHong Zhang len = 0; /* max length of buf_si[] */ 1178f96d37fcSHong Zhang owners_co[0] = 0; 1179f96d37fcSHong Zhang for (proc=0; proc<size; proc++) { 1180f96d37fcSHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1181f96d37fcSHong Zhang if (len_si[proc]) { 1182f96d37fcSHong Zhang merge->nsend++; 1183f96d37fcSHong Zhang len_si[proc] = 2*(len_si[proc] + 1); 1184f96d37fcSHong Zhang len += len_si[proc]; 1185f96d37fcSHong Zhang } 1186f96d37fcSHong Zhang } 1187f96d37fcSHong Zhang 1188f96d37fcSHong Zhang /* determine the number and length of messages to receive for coi and coj */ 11890298fd71SBarry Smith ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr); 1190f96d37fcSHong Zhang ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr); 1191f96d37fcSHong Zhang 1192f96d37fcSHong Zhang /* post the Irecv and Isend of coj */ 1193f96d37fcSHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1194f96d37fcSHong Zhang ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1195785e854fSJed Brown ierr = PetscMalloc1((merge->nsend+1),&swaits);CHKERRQ(ierr); 1196f96d37fcSHong Zhang for (proc=0, k=0; proc<size; proc++) { 1197f96d37fcSHong Zhang if (!len_s[proc]) continue; 1198f96d37fcSHong Zhang i = owners_co[proc]; 1199f96d37fcSHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 1200f96d37fcSHong Zhang k++; 1201f96d37fcSHong Zhang } 1202f96d37fcSHong Zhang 1203f96d37fcSHong Zhang /* receives and sends of coj are complete */ 1204785e854fSJed Brown ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr); 1205f96d37fcSHong Zhang for (i=0; i<merge->nrecv; i++) { 1206c280ed6aSJed Brown PetscMPIInt icompleted; 1207c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1208f96d37fcSHong Zhang } 1209f96d37fcSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1210f96d37fcSHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 1211f96d37fcSHong Zhang 1212f96d37fcSHong Zhang /* send and recv coi */ 1213f96d37fcSHong Zhang /*-------------------*/ 1214f96d37fcSHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1215f96d37fcSHong Zhang ierr = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1216785e854fSJed Brown ierr = PetscMalloc1((len+1),&buf_s);CHKERRQ(ierr); 1217f96d37fcSHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1218f96d37fcSHong Zhang for (proc=0,k=0; proc<size; proc++) { 1219f96d37fcSHong Zhang if (!len_s[proc]) continue; 1220f96d37fcSHong Zhang /* form outgoing message for i-structure: 1221f96d37fcSHong Zhang buf_si[0]: nrows to be sent 1222f96d37fcSHong Zhang [1:nrows]: row index (global) 1223f96d37fcSHong Zhang [nrows+1:2*nrows+1]: i-structure index 1224f96d37fcSHong Zhang */ 1225f96d37fcSHong Zhang /*-------------------------------------------*/ 1226f96d37fcSHong Zhang nrows = len_si[proc]/2 - 1; 1227f96d37fcSHong Zhang buf_si_i = buf_si + nrows+1; 1228f96d37fcSHong Zhang buf_si[0] = nrows; 1229f96d37fcSHong Zhang buf_si_i[0] = 0; 1230f96d37fcSHong Zhang nrows = 0; 1231f96d37fcSHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1232f96d37fcSHong Zhang nzi = coi[i+1] - coi[i]; 1233f96d37fcSHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1234f96d37fcSHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1235f96d37fcSHong Zhang nrows++; 1236f96d37fcSHong Zhang } 1237f96d37fcSHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 1238f96d37fcSHong Zhang k++; 1239f96d37fcSHong Zhang buf_si += len_si[proc]; 1240f96d37fcSHong Zhang } 1241f96d37fcSHong Zhang i = merge->nrecv; 1242f96d37fcSHong Zhang while (i--) { 1243c280ed6aSJed Brown PetscMPIInt icompleted; 1244c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1245f96d37fcSHong Zhang } 1246f96d37fcSHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1247f96d37fcSHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 1248f96d37fcSHong Zhang ierr = PetscFree(len_si);CHKERRQ(ierr); 1249f96d37fcSHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1250f96d37fcSHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1251f96d37fcSHong Zhang ierr = PetscFree(sstatus);CHKERRQ(ierr); 1252f96d37fcSHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1253f96d37fcSHong Zhang 1254f96d37fcSHong Zhang /* compute the local portion of C (mpi mat) */ 1255f96d37fcSHong Zhang /*------------------------------------------*/ 1256f96d37fcSHong Zhang /* allocate bi array and free space for accumulating nonzero column info */ 1257785e854fSJed Brown ierr = PetscMalloc1((pn+1),&bi);CHKERRQ(ierr); 1258f96d37fcSHong Zhang bi[0] = 0; 1259f96d37fcSHong Zhang 1260c36aecf5SHong Zhang /* set initial free space to be fill*(nnz(P) + nnz(A)) */ 1261d6ab1dc0SHong Zhang nnz = fill*(pdti[pn] + poti[pon] + ai[am]); 1262a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1263f96d37fcSHong Zhang current_space = free_space; 1264f96d37fcSHong Zhang 1265dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1266f96d37fcSHong Zhang for (k=0; k<merge->nrecv; k++) { 1267f96d37fcSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1268f96d37fcSHong Zhang nrows = *buf_ri_k[k]; 1269f96d37fcSHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 1270f96d37fcSHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1271f96d37fcSHong Zhang } 1272f96d37fcSHong Zhang 12731c7d5954SHong Zhang ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr); 1274f96d37fcSHong Zhang rmax = 0; 1275f96d37fcSHong Zhang for (i=0; i<pn; i++) { 1276f96d37fcSHong Zhang /* add pdt[i,:]*AP into lnk */ 1277f96d37fcSHong Zhang pnz = pdti[i+1] - pdti[i]; 1278f96d37fcSHong Zhang ptJ = pdtj + pdti[i]; 1279f96d37fcSHong Zhang for (j=0; j<pnz; j++) { 1280f96d37fcSHong Zhang row = ptJ[j]; /* row of AP == col of Pt */ 1281d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1282d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1283f96d37fcSHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1284d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted(anz,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1285f96d37fcSHong Zhang } 12864e938277SHong Zhang 1287f96d37fcSHong Zhang /* add received col data into lnk */ 1288f96d37fcSHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1289f96d37fcSHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1290f96d37fcSHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1291f96d37fcSHong Zhang Jptr = buf_rj[k] + *nextci[k]; 12924e938277SHong Zhang ierr = PetscLLCondensedAddSorted(nzi,Jptr,lnk,lnkbt);CHKERRQ(ierr); 1293f96d37fcSHong Zhang nextrow[k]++; nextci[k]++; 1294f96d37fcSHong Zhang } 1295f96d37fcSHong Zhang } 12964e938277SHong Zhang nnz = lnk[0]; 1297f96d37fcSHong Zhang 1298f96d37fcSHong Zhang /* if free space is not available, make more free space */ 1299f96d37fcSHong Zhang if (current_space->local_remaining<nnz) { 1300f96d37fcSHong Zhang ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,¤t_space);CHKERRQ(ierr); 1301f96d37fcSHong Zhang nspacedouble++; 1302f96d37fcSHong Zhang } 1303f96d37fcSHong Zhang /* copy data into free space, then initialize lnk */ 13044e938277SHong Zhang ierr = PetscLLCondensedClean(aN,nnz,current_space->array,lnk,lnkbt);CHKERRQ(ierr); 1305f96d37fcSHong Zhang ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr); 13062205254eSKarl Rupp 1307f96d37fcSHong Zhang current_space->array += nnz; 1308f96d37fcSHong Zhang current_space->local_used += nnz; 1309f96d37fcSHong Zhang current_space->local_remaining -= nnz; 13102205254eSKarl Rupp 1311f96d37fcSHong Zhang bi[i+1] = bi[i] + nnz; 1312f96d37fcSHong Zhang if (nnz > rmax) rmax = nnz; 1313f96d37fcSHong Zhang } 1314f96d37fcSHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1315f96d37fcSHong Zhang 1316785e854fSJed Brown ierr = PetscMalloc1((bi[pn]+1),&bj);CHKERRQ(ierr); 1317f96d37fcSHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr); 13182205254eSKarl Rupp 1319118727c9SMark F. Adams afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1); 1320f96d37fcSHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1321d6ab1dc0SHong Zhang ierr = PetscLLCondensedDestroy(lnk,lnkbt);CHKERRQ(ierr); 13224e938277SHong Zhang ierr = MatDestroy(&POt);CHKERRQ(ierr); 13234e938277SHong Zhang ierr = MatDestroy(&PDt);CHKERRQ(ierr); 1324f96d37fcSHong Zhang 13251c7d5954SHong Zhang /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part */ 13261c7d5954SHong Zhang /*----------------------------------------------------------------------------------*/ 13271795a4d1SJed Brown ierr = PetscCalloc1(rmax+1,&vals);CHKERRQ(ierr); 1328f96d37fcSHong Zhang 1329f96d37fcSHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 1330f96d37fcSHong Zhang ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 1331a2f3521dSMark F. Adams ierr = MatSetBlockSizes(Cmpi,P->cmap->bs,A->cmap->bs);CHKERRQ(ierr); 1332f96d37fcSHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 1333f96d37fcSHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 1334f96d37fcSHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1335f96d37fcSHong Zhang ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr); 1336f96d37fcSHong Zhang for (i=0; i<pn; i++) { 1337f96d37fcSHong Zhang row = i + rstart; 1338f96d37fcSHong Zhang nnz = bi[i+1] - bi[i]; 1339f96d37fcSHong Zhang Jptr = bj + bi[i]; 1340f96d37fcSHong Zhang ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,vals,INSERT_VALUES);CHKERRQ(ierr); 1341f96d37fcSHong Zhang } 1342f96d37fcSHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1343f96d37fcSHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1344f96d37fcSHong Zhang ierr = PetscFree(vals);CHKERRQ(ierr); 1345f96d37fcSHong Zhang 1346f96d37fcSHong Zhang merge->bi = bi; 1347f96d37fcSHong Zhang merge->bj = bj; 1348f96d37fcSHong Zhang merge->coi = coi; 1349f96d37fcSHong Zhang merge->coj = coj; 1350f96d37fcSHong Zhang merge->buf_ri = buf_ri; 1351f96d37fcSHong Zhang merge->buf_rj = buf_rj; 1352f96d37fcSHong Zhang merge->owners_co = owners_co; 1353f96d37fcSHong Zhang merge->destroy = Cmpi->ops->destroy; 1354f96d37fcSHong Zhang merge->duplicate = Cmpi->ops->duplicate; 1355f96d37fcSHong Zhang 13566da69ca6SHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ_nonscalable; 1357c5af039cSHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 1358f96d37fcSHong Zhang 1359f96d37fcSHong Zhang /* attach the supporting struct to Cmpi for reuse */ 1360f96d37fcSHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 1361f96d37fcSHong Zhang c->ptap = ptap; 13620298fd71SBarry Smith ptap->api = NULL; 13630298fd71SBarry Smith ptap->apj = NULL; 1364f96d37fcSHong Zhang ptap->merge = merge; 1365d6ab1dc0SHong Zhang ptap->rmax = rmax; 1366d6ab1dc0SHong Zhang 1367d6ab1dc0SHong Zhang *C = Cmpi; 1368d6ab1dc0SHong Zhang #if defined(PETSC_USE_INFO) 1369d6ab1dc0SHong Zhang if (bi[pn] != 0) { 1370d6ab1dc0SHong Zhang ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %G needed %G.\n",nspacedouble,fill,afill);CHKERRQ(ierr); 1371d6ab1dc0SHong Zhang ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%G,&C) for best performance.\n",afill);CHKERRQ(ierr); 1372d6ab1dc0SHong Zhang } else { 1373d6ab1dc0SHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 1374d6ab1dc0SHong Zhang } 1375d6ab1dc0SHong Zhang #endif 1376d6ab1dc0SHong Zhang PetscFunctionReturn(0); 1377d6ab1dc0SHong Zhang } 1378d6ab1dc0SHong Zhang 1379d6ab1dc0SHong Zhang #undef __FUNCT__ 13806da69ca6SHong Zhang #define __FUNCT__ "MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ" 13816da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ(Mat P,Mat A,Mat C) 1382d6ab1dc0SHong Zhang { 1383d6ab1dc0SHong Zhang PetscErrorCode ierr; 1384d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 1385d6ab1dc0SHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c=(Mat_MPIAIJ*)C->data; 1386d6ab1dc0SHong Zhang Mat_SeqAIJ *pd=(Mat_SeqAIJ*)(p->A)->data,*po=(Mat_SeqAIJ*)(p->B)->data; 1387d6ab1dc0SHong Zhang Mat_PtAPMPI *ptap; 1388e745005bSHong Zhang PetscInt *adj; 1389e745005bSHong Zhang PetscInt i,j,k,anz,pnz,row,*cj,nexta; 1390e745005bSHong Zhang MatScalar *ada,*ca,valtmp; 1391d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,cm=C->rmap->n,pon=(p->B)->cmap->n; 1392ce94432eSBarry Smith MPI_Comm comm; 1393d6ab1dc0SHong Zhang PetscMPIInt size,rank,taga,*len_s; 1394d6ab1dc0SHong Zhang PetscInt *owners,proc,nrows,**buf_ri_k,**nextrow,**nextci; 1395d6ab1dc0SHong Zhang PetscInt **buf_ri,**buf_rj; 1396d6ab1dc0SHong Zhang PetscInt cnz=0,*bj_i,*bi,*bj,bnz,nextcj; /* bi,bj,ba: local array of C(mpi mat) */ 1397d6ab1dc0SHong Zhang MPI_Request *s_waits,*r_waits; 1398d6ab1dc0SHong Zhang MPI_Status *status; 1399d6ab1dc0SHong Zhang MatScalar **abuf_r,*ba_i,*pA,*coa,*ba; 1400d6ab1dc0SHong Zhang PetscInt *ai,*aj,*coi,*coj; 1401a2ea699eSBarry Smith PetscInt *poJ,*pdJ; 1402d6ab1dc0SHong Zhang Mat A_loc; 1403d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc; 1404d6ab1dc0SHong Zhang 1405d6ab1dc0SHong Zhang PetscFunctionBegin; 1406ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)C,&comm);CHKERRQ(ierr); 1407d6ab1dc0SHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1408d6ab1dc0SHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1409d6ab1dc0SHong Zhang 1410d6ab1dc0SHong Zhang ptap = c->ptap; 1411d6ab1dc0SHong Zhang merge = ptap->merge; 1412d6ab1dc0SHong Zhang 1413e745005bSHong Zhang /* 2) compute numeric C_seq = P_loc^T*A_loc */ 1414e745005bSHong Zhang /*------------------------------------------*/ 1415d6ab1dc0SHong Zhang /* get data from symbolic products */ 1416d6ab1dc0SHong Zhang coi = merge->coi; coj = merge->coj; 14171795a4d1SJed Brown ierr = PetscCalloc1((coi[pon]+1),&coa);CHKERRQ(ierr); 1418d6ab1dc0SHong Zhang bi = merge->bi; bj = merge->bj; 1419d6ab1dc0SHong Zhang owners = merge->rowmap->range; 14201795a4d1SJed Brown ierr = PetscCalloc1(bi[cm]+1,&ba);CHKERRQ(ierr); 1421d6ab1dc0SHong Zhang 1422d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1423d6ab1dc0SHong Zhang A_loc = ptap->A_loc; 1424d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_REUSE_MATRIX,&A_loc);CHKERRQ(ierr); 1425d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1426d6ab1dc0SHong Zhang ai = a_loc->i; 1427d6ab1dc0SHong Zhang aj = a_loc->j; 1428d6ab1dc0SHong Zhang 1429d6ab1dc0SHong Zhang for (i=0; i<am; i++) { 1430d6ab1dc0SHong Zhang anz = ai[i+1] - ai[i]; 1431d6ab1dc0SHong Zhang adj = aj + ai[i]; 1432d6ab1dc0SHong Zhang ada = a_loc->a + ai[i]; 1433d6ab1dc0SHong Zhang 1434d6ab1dc0SHong Zhang /* 2-b) Compute Cseq = P_loc[i,:]^T*A[i,:] using outer product */ 1435e745005bSHong Zhang /*-------------------------------------------------------------*/ 1436d6ab1dc0SHong Zhang /* put the value into Co=(p->B)^T*A (off-diagonal part, send to others) */ 1437d6ab1dc0SHong Zhang pnz = po->i[i+1] - po->i[i]; 1438d6ab1dc0SHong Zhang poJ = po->j + po->i[i]; 1439d6ab1dc0SHong Zhang pA = po->a + po->i[i]; 1440d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1441d6ab1dc0SHong Zhang row = poJ[j]; 1442d6ab1dc0SHong Zhang cj = coj + coi[row]; 1443d6ab1dc0SHong Zhang ca = coa + coi[row]; 1444e745005bSHong Zhang /* perform sparse axpy */ 1445e745005bSHong Zhang nexta = 0; 1446d6ab1dc0SHong Zhang valtmp = pA[j]; 1447e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1448e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1449e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1450e745005bSHong Zhang nexta++; 1451d6ab1dc0SHong Zhang } 1452e745005bSHong Zhang } 1453e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1454d6ab1dc0SHong Zhang } 1455d6ab1dc0SHong Zhang 1456d6ab1dc0SHong Zhang /* put the value into Cd (diagonal part) */ 1457d6ab1dc0SHong Zhang pnz = pd->i[i+1] - pd->i[i]; 1458d6ab1dc0SHong Zhang pdJ = pd->j + pd->i[i]; 1459d6ab1dc0SHong Zhang pA = pd->a + pd->i[i]; 1460d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1461d6ab1dc0SHong Zhang row = pdJ[j]; 1462d6ab1dc0SHong Zhang cj = bj + bi[row]; 1463d6ab1dc0SHong Zhang ca = ba + bi[row]; 1464e745005bSHong Zhang /* perform sparse axpy */ 1465e745005bSHong Zhang nexta = 0; 1466d6ab1dc0SHong Zhang valtmp = pA[j]; 1467e745005bSHong Zhang for (k=0; nexta<anz; k++) { 1468e745005bSHong Zhang if (cj[k] == adj[nexta]) { 1469e745005bSHong Zhang ca[k] += valtmp*ada[nexta]; 1470e745005bSHong Zhang nexta++; 1471d6ab1dc0SHong Zhang } 1472e745005bSHong Zhang } 1473e745005bSHong Zhang ierr = PetscLogFlops(2.0*anz);CHKERRQ(ierr); 1474d6ab1dc0SHong Zhang } 1475d6ab1dc0SHong Zhang } 1476d6ab1dc0SHong Zhang 1477d6ab1dc0SHong Zhang /* 3) send and recv matrix values coa */ 1478d6ab1dc0SHong Zhang /*------------------------------------*/ 1479d6ab1dc0SHong Zhang buf_ri = merge->buf_ri; 1480d6ab1dc0SHong Zhang buf_rj = merge->buf_rj; 1481d6ab1dc0SHong Zhang len_s = merge->len_s; 1482d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&taga);CHKERRQ(ierr); 1483d6ab1dc0SHong Zhang ierr = PetscPostIrecvScalar(comm,taga,merge->nrecv,merge->id_r,merge->len_r,&abuf_r,&r_waits);CHKERRQ(ierr); 1484d6ab1dc0SHong Zhang 1485dcca6d9dSJed Brown ierr = PetscMalloc2(merge->nsend+1,&s_waits,size,&status);CHKERRQ(ierr); 1486d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 1487d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1488d6ab1dc0SHong Zhang i = merge->owners_co[proc]; 1489d6ab1dc0SHong Zhang ierr = MPI_Isend(coa+coi[i],len_s[proc],MPIU_MATSCALAR,proc,taga,comm,s_waits+k);CHKERRQ(ierr); 1490d6ab1dc0SHong Zhang k++; 1491d6ab1dc0SHong Zhang } 1492d6ab1dc0SHong Zhang if (merge->nrecv) {ierr = MPI_Waitall(merge->nrecv,r_waits,status);CHKERRQ(ierr);} 1493d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,s_waits,status);CHKERRQ(ierr);} 1494d6ab1dc0SHong Zhang 1495d6ab1dc0SHong Zhang ierr = PetscFree2(s_waits,status);CHKERRQ(ierr); 1496d6ab1dc0SHong Zhang ierr = PetscFree(r_waits);CHKERRQ(ierr); 1497d6ab1dc0SHong Zhang ierr = PetscFree(coa);CHKERRQ(ierr); 1498d6ab1dc0SHong Zhang 1499d6ab1dc0SHong Zhang /* 4) insert local Cseq and received values into Cmpi */ 1500d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1501dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1502d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 1503e745005bSHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1504d6ab1dc0SHong Zhang nrows = *(buf_ri_k[k]); 1505d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k]+1; /* next row number of k-th recved i-structure */ 1506d6ab1dc0SHong Zhang nextci[k] = buf_ri_k[k] + (nrows + 1); /* poins to the next i-structure of k-th recved i-structure */ 1507d6ab1dc0SHong Zhang } 1508d6ab1dc0SHong Zhang 1509d6ab1dc0SHong Zhang for (i=0; i<cm; i++) { 1510d6ab1dc0SHong Zhang row = owners[rank] + i; /* global row index of C_seq */ 1511d6ab1dc0SHong Zhang bj_i = bj + bi[i]; /* col indices of the i-th row of C */ 1512d6ab1dc0SHong Zhang ba_i = ba + bi[i]; 1513d6ab1dc0SHong Zhang bnz = bi[i+1] - bi[i]; 1514d6ab1dc0SHong Zhang /* add received vals into ba */ 1515d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1516d6ab1dc0SHong Zhang /* i-th row */ 1517d6ab1dc0SHong Zhang if (i == *nextrow[k]) { 1518d6ab1dc0SHong Zhang cnz = *(nextci[k]+1) - *nextci[k]; 1519d6ab1dc0SHong Zhang cj = buf_rj[k] + *(nextci[k]); 1520d6ab1dc0SHong Zhang ca = abuf_r[k] + *(nextci[k]); 1521d6ab1dc0SHong Zhang nextcj = 0; 1522d6ab1dc0SHong Zhang for (j=0; nextcj<cnz; j++) { 1523d6ab1dc0SHong Zhang if (bj_i[j] == cj[nextcj]) { /* bcol == ccol */ 1524d6ab1dc0SHong Zhang ba_i[j] += ca[nextcj++]; 1525d6ab1dc0SHong Zhang } 1526d6ab1dc0SHong Zhang } 1527d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 1528d6ab1dc0SHong Zhang ierr = PetscLogFlops(2.0*cnz);CHKERRQ(ierr); 1529d6ab1dc0SHong Zhang } 1530d6ab1dc0SHong Zhang } 1531d6ab1dc0SHong Zhang ierr = MatSetValues(C,1,&row,bnz,bj_i,ba_i,INSERT_VALUES);CHKERRQ(ierr); 1532d6ab1dc0SHong Zhang } 1533d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1534d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(C,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1535d6ab1dc0SHong Zhang 1536d6ab1dc0SHong Zhang ierr = PetscFree(ba);CHKERRQ(ierr); 1537d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r[0]);CHKERRQ(ierr); 1538d6ab1dc0SHong Zhang ierr = PetscFree(abuf_r);CHKERRQ(ierr); 1539d6ab1dc0SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1540d6ab1dc0SHong Zhang PetscFunctionReturn(0); 1541d6ab1dc0SHong Zhang } 1542d6ab1dc0SHong Zhang 15432bbb1c24SHong Zhang /* This routine is modified from MatPtAPSymbolic_MPIAIJ_MPIAIJ(); 15442bbb1c24SHong Zhang differ from MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable in using LLCondensedCreate_Scalable() */ 1545d6ab1dc0SHong Zhang #undef __FUNCT__ 15466da69ca6SHong Zhang #define __FUNCT__ "MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ" 15476da69ca6SHong Zhang PetscErrorCode MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ(Mat P,Mat A,PetscReal fill,Mat *C) 1548d6ab1dc0SHong Zhang { 1549d6ab1dc0SHong Zhang PetscErrorCode ierr; 1550d6ab1dc0SHong Zhang Mat Cmpi,A_loc,POt,PDt; 1551d6ab1dc0SHong Zhang Mat_PtAPMPI *ptap; 15520298fd71SBarry Smith PetscFreeSpaceList free_space=NULL,current_space=NULL; 1553d6ab1dc0SHong Zhang Mat_MPIAIJ *p =(Mat_MPIAIJ*)P->data,*c; 1554d6ab1dc0SHong Zhang PetscInt *pdti,*pdtj,*poti,*potj,*ptJ; 1555d6ab1dc0SHong Zhang PetscInt nnz; 1556d6ab1dc0SHong Zhang PetscInt *lnk,*owners_co,*coi,*coj,i,k,pnz,row; 1557d6ab1dc0SHong Zhang PetscInt am =A->rmap->n,pn=P->cmap->n; 1558ce94432eSBarry Smith MPI_Comm comm; 1559d6ab1dc0SHong Zhang PetscMPIInt size,rank,tagi,tagj,*len_si,*len_s,*len_ri; 1560d6ab1dc0SHong Zhang PetscInt **buf_rj,**buf_ri,**buf_ri_k; 1561d6ab1dc0SHong Zhang PetscInt len,proc,*dnz,*onz,*owners; 1562d6ab1dc0SHong Zhang PetscInt nzi,*bi,*bj; 1563d6ab1dc0SHong Zhang PetscInt nrows,*buf_s,*buf_si,*buf_si_i,**nextrow,**nextci; 1564d6ab1dc0SHong Zhang MPI_Request *swaits,*rwaits; 1565d6ab1dc0SHong Zhang MPI_Status *sstatus,rstatus; 1566d6ab1dc0SHong Zhang Mat_Merge_SeqsToMPI *merge; 1567d6ab1dc0SHong Zhang PetscInt *ai,*aj,*Jptr,anz,*prmap=p->garray,pon,nspacedouble=0,j; 1568d6ab1dc0SHong Zhang PetscReal afill =1.0,afill_tmp; 1569c36aecf5SHong Zhang PetscInt rstart = P->cmap->rstart,rmax,aN=A->cmap->N,Crmax; 1570d6ab1dc0SHong Zhang PetscScalar *vals; 1571d6ab1dc0SHong Zhang Mat_SeqAIJ *a_loc, *pdt,*pot; 1572d6ab1dc0SHong Zhang 1573d6ab1dc0SHong Zhang PetscFunctionBegin; 1574ce94432eSBarry Smith ierr = PetscObjectGetComm((PetscObject)A,&comm);CHKERRQ(ierr); 1575d6ab1dc0SHong Zhang /* check if matrix local sizes are compatible */ 1576d6ab1dc0SHong Zhang if (A->rmap->rstart != P->rmap->rstart || A->rmap->rend != P->rmap->rend) { 1577d6ab1dc0SHong Zhang 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); 1578d6ab1dc0SHong Zhang } 1579d6ab1dc0SHong Zhang 1580d6ab1dc0SHong Zhang ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1581d6ab1dc0SHong Zhang ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1582d6ab1dc0SHong Zhang 1583d6ab1dc0SHong Zhang /* create struct Mat_PtAPMPI and attached it to C later */ 1584*b00a9115SJed Brown ierr = PetscNew(&ptap);CHKERRQ(ierr); 1585d6ab1dc0SHong Zhang 1586d6ab1dc0SHong Zhang /* get A_loc by taking all local rows of A */ 1587d6ab1dc0SHong Zhang ierr = MatMPIAIJGetLocalMat(A,MAT_INITIAL_MATRIX,&A_loc);CHKERRQ(ierr); 15882205254eSKarl Rupp 1589d6ab1dc0SHong Zhang ptap->A_loc = A_loc; 1590d6ab1dc0SHong Zhang a_loc = (Mat_SeqAIJ*)(A_loc)->data; 1591d6ab1dc0SHong Zhang ai = a_loc->i; 1592d6ab1dc0SHong Zhang aj = a_loc->j; 1593d6ab1dc0SHong Zhang 1594d6ab1dc0SHong Zhang /* determine symbolic Co=(p->B)^T*A - send to others */ 1595d6ab1dc0SHong Zhang /*----------------------------------------------------*/ 1596d6ab1dc0SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->A,&PDt);CHKERRQ(ierr); 1597d6ab1dc0SHong Zhang pdt = (Mat_SeqAIJ*)PDt->data; 1598d6ab1dc0SHong Zhang pdti = pdt->i; pdtj = pdt->j; 1599d6ab1dc0SHong Zhang 1600d6ab1dc0SHong Zhang ierr = MatTransposeSymbolic_SeqAIJ(p->B,&POt);CHKERRQ(ierr); 1601d6ab1dc0SHong Zhang pot = (Mat_SeqAIJ*)POt->data; 1602d6ab1dc0SHong Zhang poti = pot->i; potj = pot->j; 1603d6ab1dc0SHong Zhang 1604d6ab1dc0SHong Zhang /* then, compute symbolic Co = (p->B)^T*A */ 1605d6ab1dc0SHong Zhang pon = (p->B)->cmap->n; /* total num of rows to be sent to other processors 1606d6ab1dc0SHong Zhang >= (num of nonzero rows of C_seq) - pn */ 1607785e854fSJed Brown ierr = PetscMalloc1((pon+1),&coi);CHKERRQ(ierr); 1608d6ab1dc0SHong Zhang coi[0] = 0; 1609d6ab1dc0SHong Zhang 1610d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(p->B) + nnz(A)) */ 1611d6ab1dc0SHong Zhang nnz = fill*(poti[pon] + ai[am]); 1612a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1613d6ab1dc0SHong Zhang current_space = free_space; 161419f0e57aSHong Zhang 1615d6ab1dc0SHong Zhang /* create and initialize a linked list */ 1616d6ab1dc0SHong Zhang i = PetscMax(pdt->rmax,pot->rmax); 1617c36aecf5SHong Zhang Crmax = i*a_loc->rmax*size; /* non-scalable! */ 1618d6ab1dc0SHong Zhang if (!Crmax || Crmax > aN) Crmax = aN; 1619d6ab1dc0SHong Zhang ierr = PetscLLCondensedCreate_Scalable(Crmax,&lnk);CHKERRQ(ierr); 1620d6ab1dc0SHong Zhang 1621d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 1622d6ab1dc0SHong Zhang pnz = poti[i+1] - poti[i]; 1623d6ab1dc0SHong Zhang ptJ = potj + poti[i]; 1624d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1625d6ab1dc0SHong Zhang row = ptJ[j]; /* row of A_loc == col of Pot */ 1626d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1627d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1628d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1629d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 1630d6ab1dc0SHong Zhang } 1631d6ab1dc0SHong Zhang nnz = lnk[0]; 1632d6ab1dc0SHong Zhang 1633d6ab1dc0SHong Zhang /* If free space is not available, double the total space in the list */ 1634d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 1635d6ab1dc0SHong Zhang ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,¤t_space);CHKERRQ(ierr); 1636d6ab1dc0SHong Zhang nspacedouble++; 1637d6ab1dc0SHong Zhang } 1638d6ab1dc0SHong Zhang 1639d6ab1dc0SHong Zhang /* Copy data into free space, and zero out denserows */ 1640d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 16412205254eSKarl Rupp 1642d6ab1dc0SHong Zhang current_space->array += nnz; 1643d6ab1dc0SHong Zhang current_space->local_used += nnz; 1644d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 16452205254eSKarl Rupp 1646d6ab1dc0SHong Zhang coi[i+1] = coi[i] + nnz; 1647d6ab1dc0SHong Zhang } 1648d6ab1dc0SHong Zhang 1649785e854fSJed Brown ierr = PetscMalloc1((coi[pon]+1),&coj);CHKERRQ(ierr); 1650d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,coj);CHKERRQ(ierr); 16512205254eSKarl Rupp 1652118727c9SMark F. Adams afill_tmp = (PetscReal)coi[pon]/(poti[pon] + ai[am]+1); 1653d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1654d6ab1dc0SHong Zhang 1655d6ab1dc0SHong Zhang /* send j-array (coj) of Co to other processors */ 1656d6ab1dc0SHong Zhang /*----------------------------------------------*/ 1657d6ab1dc0SHong Zhang /* determine row ownership */ 1658*b00a9115SJed Brown ierr = PetscNew(&merge);CHKERRQ(ierr); 1659d6ab1dc0SHong Zhang ierr = PetscLayoutCreate(comm,&merge->rowmap);CHKERRQ(ierr); 16602205254eSKarl Rupp 1661d6ab1dc0SHong Zhang merge->rowmap->n = pn; 1662d6ab1dc0SHong Zhang merge->rowmap->bs = 1; 16632205254eSKarl Rupp 1664d6ab1dc0SHong Zhang ierr = PetscLayoutSetUp(merge->rowmap);CHKERRQ(ierr); 1665d6ab1dc0SHong Zhang owners = merge->rowmap->range; 1666d6ab1dc0SHong Zhang 1667d6ab1dc0SHong Zhang /* determine the number of messages to send, their lengths */ 16681795a4d1SJed Brown ierr = PetscCalloc1(size,&len_si);CHKERRQ(ierr); 1669785e854fSJed Brown ierr = PetscMalloc1(size,&merge->len_s);CHKERRQ(ierr); 16702205254eSKarl Rupp 1671d6ab1dc0SHong Zhang len_s = merge->len_s; 1672d6ab1dc0SHong Zhang merge->nsend = 0; 1673d6ab1dc0SHong Zhang 1674785e854fSJed Brown ierr = PetscMalloc1((size+2),&owners_co);CHKERRQ(ierr); 1675d6ab1dc0SHong Zhang ierr = PetscMemzero(len_s,size*sizeof(PetscMPIInt));CHKERRQ(ierr); 1676d6ab1dc0SHong Zhang 1677d6ab1dc0SHong Zhang proc = 0; 1678d6ab1dc0SHong Zhang for (i=0; i<pon; i++) { 1679d6ab1dc0SHong Zhang while (prmap[i] >= owners[proc+1]) proc++; 1680d6ab1dc0SHong Zhang len_si[proc]++; /* num of rows in Co to be sent to [proc] */ 1681d6ab1dc0SHong Zhang len_s[proc] += coi[i+1] - coi[i]; 1682d6ab1dc0SHong Zhang } 1683d6ab1dc0SHong Zhang 1684d6ab1dc0SHong Zhang len = 0; /* max length of buf_si[] */ 1685d6ab1dc0SHong Zhang owners_co[0] = 0; 1686d6ab1dc0SHong Zhang for (proc=0; proc<size; proc++) { 1687d6ab1dc0SHong Zhang owners_co[proc+1] = owners_co[proc] + len_si[proc]; 1688d6ab1dc0SHong Zhang if (len_si[proc]) { 1689d6ab1dc0SHong Zhang merge->nsend++; 1690d6ab1dc0SHong Zhang len_si[proc] = 2*(len_si[proc] + 1); 1691d6ab1dc0SHong Zhang len += len_si[proc]; 1692d6ab1dc0SHong Zhang } 1693d6ab1dc0SHong Zhang } 1694d6ab1dc0SHong Zhang 1695d6ab1dc0SHong Zhang /* determine the number and length of messages to receive for coi and coj */ 16960298fd71SBarry Smith ierr = PetscGatherNumberOfMessages(comm,NULL,len_s,&merge->nrecv);CHKERRQ(ierr); 1697d6ab1dc0SHong Zhang ierr = PetscGatherMessageLengths2(comm,merge->nsend,merge->nrecv,len_s,len_si,&merge->id_r,&merge->len_r,&len_ri);CHKERRQ(ierr); 1698d6ab1dc0SHong Zhang 1699d6ab1dc0SHong Zhang /* post the Irecv and Isend of coj */ 1700d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagj);CHKERRQ(ierr); 1701d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagj,merge->nrecv,merge->id_r,merge->len_r,&buf_rj,&rwaits);CHKERRQ(ierr); 1702785e854fSJed Brown ierr = PetscMalloc1((merge->nsend+1),&swaits);CHKERRQ(ierr); 1703d6ab1dc0SHong Zhang for (proc=0, k=0; proc<size; proc++) { 1704d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1705d6ab1dc0SHong Zhang i = owners_co[proc]; 1706d6ab1dc0SHong Zhang ierr = MPI_Isend(coj+coi[i],len_s[proc],MPIU_INT,proc,tagj,comm,swaits+k);CHKERRQ(ierr); 1707d6ab1dc0SHong Zhang k++; 1708d6ab1dc0SHong Zhang } 1709d6ab1dc0SHong Zhang 1710d6ab1dc0SHong Zhang /* receives and sends of coj are complete */ 1711785e854fSJed Brown ierr = PetscMalloc1(size,&sstatus);CHKERRQ(ierr); 1712d6ab1dc0SHong Zhang for (i=0; i<merge->nrecv; i++) { 1713c280ed6aSJed Brown PetscMPIInt icompleted; 1714c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1715d6ab1dc0SHong Zhang } 1716d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1717d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 1718d6ab1dc0SHong Zhang 1719d6ab1dc0SHong Zhang /* send and recv coi */ 1720d6ab1dc0SHong Zhang /*-------------------*/ 1721d6ab1dc0SHong Zhang ierr = PetscCommGetNewTag(comm,&tagi);CHKERRQ(ierr); 1722d6ab1dc0SHong Zhang ierr = PetscPostIrecvInt(comm,tagi,merge->nrecv,merge->id_r,len_ri,&buf_ri,&rwaits);CHKERRQ(ierr); 1723785e854fSJed Brown ierr = PetscMalloc1((len+1),&buf_s);CHKERRQ(ierr); 1724d6ab1dc0SHong Zhang buf_si = buf_s; /* points to the beginning of k-th msg to be sent */ 1725d6ab1dc0SHong Zhang for (proc=0,k=0; proc<size; proc++) { 1726d6ab1dc0SHong Zhang if (!len_s[proc]) continue; 1727d6ab1dc0SHong Zhang /* form outgoing message for i-structure: 1728d6ab1dc0SHong Zhang buf_si[0]: nrows to be sent 1729d6ab1dc0SHong Zhang [1:nrows]: row index (global) 1730d6ab1dc0SHong Zhang [nrows+1:2*nrows+1]: i-structure index 1731d6ab1dc0SHong Zhang */ 1732d6ab1dc0SHong Zhang /*-------------------------------------------*/ 1733d6ab1dc0SHong Zhang nrows = len_si[proc]/2 - 1; 1734d6ab1dc0SHong Zhang buf_si_i = buf_si + nrows+1; 1735d6ab1dc0SHong Zhang buf_si[0] = nrows; 1736d6ab1dc0SHong Zhang buf_si_i[0] = 0; 1737d6ab1dc0SHong Zhang nrows = 0; 1738d6ab1dc0SHong Zhang for (i=owners_co[proc]; i<owners_co[proc+1]; i++) { 1739d6ab1dc0SHong Zhang nzi = coi[i+1] - coi[i]; 1740d6ab1dc0SHong Zhang buf_si_i[nrows+1] = buf_si_i[nrows] + nzi; /* i-structure */ 1741d6ab1dc0SHong Zhang buf_si[nrows+1] = prmap[i] -owners[proc]; /* local row index */ 1742d6ab1dc0SHong Zhang nrows++; 1743d6ab1dc0SHong Zhang } 1744d6ab1dc0SHong Zhang ierr = MPI_Isend(buf_si,len_si[proc],MPIU_INT,proc,tagi,comm,swaits+k);CHKERRQ(ierr); 1745d6ab1dc0SHong Zhang k++; 1746d6ab1dc0SHong Zhang buf_si += len_si[proc]; 1747d6ab1dc0SHong Zhang } 1748d6ab1dc0SHong Zhang i = merge->nrecv; 1749d6ab1dc0SHong Zhang while (i--) { 1750c280ed6aSJed Brown PetscMPIInt icompleted; 1751c280ed6aSJed Brown ierr = MPI_Waitany(merge->nrecv,rwaits,&icompleted,&rstatus);CHKERRQ(ierr); 1752d6ab1dc0SHong Zhang } 1753d6ab1dc0SHong Zhang ierr = PetscFree(rwaits);CHKERRQ(ierr); 1754d6ab1dc0SHong Zhang if (merge->nsend) {ierr = MPI_Waitall(merge->nsend,swaits,sstatus);CHKERRQ(ierr);} 1755d6ab1dc0SHong Zhang ierr = PetscFree(len_si);CHKERRQ(ierr); 1756d6ab1dc0SHong Zhang ierr = PetscFree(len_ri);CHKERRQ(ierr); 1757d6ab1dc0SHong Zhang ierr = PetscFree(swaits);CHKERRQ(ierr); 1758d6ab1dc0SHong Zhang ierr = PetscFree(sstatus);CHKERRQ(ierr); 1759d6ab1dc0SHong Zhang ierr = PetscFree(buf_s);CHKERRQ(ierr); 1760d6ab1dc0SHong Zhang 1761d6ab1dc0SHong Zhang /* compute the local portion of C (mpi mat) */ 1762d6ab1dc0SHong Zhang /*------------------------------------------*/ 1763d6ab1dc0SHong Zhang /* allocate bi array and free space for accumulating nonzero column info */ 1764785e854fSJed Brown ierr = PetscMalloc1((pn+1),&bi);CHKERRQ(ierr); 1765d6ab1dc0SHong Zhang bi[0] = 0; 1766d6ab1dc0SHong Zhang 1767d6ab1dc0SHong Zhang /* set initial free space to be fill*(nnz(P) + nnz(AP)) */ 1768d6ab1dc0SHong Zhang nnz = fill*(pdti[pn] + poti[pon] + ai[am]); 1769a2ea699eSBarry Smith ierr = PetscFreeSpaceGet(nnz,&free_space);CHKERRQ(ierr); 1770d6ab1dc0SHong Zhang current_space = free_space; 1771d6ab1dc0SHong Zhang 1772dcca6d9dSJed Brown ierr = PetscMalloc3(merge->nrecv,&buf_ri_k,merge->nrecv,&nextrow,merge->nrecv,&nextci);CHKERRQ(ierr); 1773d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { 1774d6ab1dc0SHong Zhang buf_ri_k[k] = buf_ri[k]; /* beginning of k-th recved i-structure */ 1775d6ab1dc0SHong Zhang nrows = *buf_ri_k[k]; 1776d6ab1dc0SHong Zhang nextrow[k] = buf_ri_k[k] + 1; /* next row number of k-th recved i-structure */ 17772205254eSKarl Rupp nextci[k] = buf_ri_k[k] + (nrows + 1); /* points to the next i-structure of k-th recieved i-structure */ 1778d6ab1dc0SHong Zhang } 1779d6ab1dc0SHong Zhang 1780d6ab1dc0SHong Zhang ierr = MatPreallocateInitialize(comm,pn,A->cmap->n,dnz,onz);CHKERRQ(ierr); 1781d6ab1dc0SHong Zhang rmax = 0; 1782d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 1783d6ab1dc0SHong Zhang /* add pdt[i,:]*AP into lnk */ 1784d6ab1dc0SHong Zhang pnz = pdti[i+1] - pdti[i]; 1785d6ab1dc0SHong Zhang ptJ = pdtj + pdti[i]; 1786d6ab1dc0SHong Zhang for (j=0; j<pnz; j++) { 1787d6ab1dc0SHong Zhang row = ptJ[j]; /* row of AP == col of Pt */ 1788d6ab1dc0SHong Zhang anz = ai[row+1] - ai[row]; 1789d6ab1dc0SHong Zhang Jptr = aj + ai[row]; 1790d6ab1dc0SHong Zhang /* add non-zero cols of AP into the sorted linked list lnk */ 1791d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(anz,Jptr,lnk);CHKERRQ(ierr); 1792d6ab1dc0SHong Zhang } 1793d6ab1dc0SHong Zhang 1794d6ab1dc0SHong Zhang /* add received col data into lnk */ 1795d6ab1dc0SHong Zhang for (k=0; k<merge->nrecv; k++) { /* k-th received message */ 1796d6ab1dc0SHong Zhang if (i == *nextrow[k]) { /* i-th row */ 1797d6ab1dc0SHong Zhang nzi = *(nextci[k]+1) - *nextci[k]; 1798d6ab1dc0SHong Zhang Jptr = buf_rj[k] + *nextci[k]; 1799d6ab1dc0SHong Zhang ierr = PetscLLCondensedAddSorted_Scalable(nzi,Jptr,lnk);CHKERRQ(ierr); 1800d6ab1dc0SHong Zhang nextrow[k]++; nextci[k]++; 1801d6ab1dc0SHong Zhang } 1802d6ab1dc0SHong Zhang } 1803d6ab1dc0SHong Zhang nnz = lnk[0]; 1804d6ab1dc0SHong Zhang 1805d6ab1dc0SHong Zhang /* if free space is not available, make more free space */ 1806d6ab1dc0SHong Zhang if (current_space->local_remaining<nnz) { 1807d6ab1dc0SHong Zhang ierr = PetscFreeSpaceGet(nnz+current_space->total_array_size,¤t_space);CHKERRQ(ierr); 1808d6ab1dc0SHong Zhang nspacedouble++; 1809d6ab1dc0SHong Zhang } 1810d6ab1dc0SHong Zhang /* copy data into free space, then initialize lnk */ 1811d6ab1dc0SHong Zhang ierr = PetscLLCondensedClean_Scalable(nnz,current_space->array,lnk);CHKERRQ(ierr); 1812d6ab1dc0SHong Zhang ierr = MatPreallocateSet(i+owners[rank],nnz,current_space->array,dnz,onz);CHKERRQ(ierr); 18132205254eSKarl Rupp 1814d6ab1dc0SHong Zhang current_space->array += nnz; 1815d6ab1dc0SHong Zhang current_space->local_used += nnz; 1816d6ab1dc0SHong Zhang current_space->local_remaining -= nnz; 18172205254eSKarl Rupp 1818d6ab1dc0SHong Zhang bi[i+1] = bi[i] + nnz; 1819d6ab1dc0SHong Zhang if (nnz > rmax) rmax = nnz; 1820d6ab1dc0SHong Zhang } 1821d6ab1dc0SHong Zhang ierr = PetscFree3(buf_ri_k,nextrow,nextci);CHKERRQ(ierr); 1822d6ab1dc0SHong Zhang 1823785e854fSJed Brown ierr = PetscMalloc1((bi[pn]+1),&bj);CHKERRQ(ierr); 1824d6ab1dc0SHong Zhang ierr = PetscFreeSpaceContiguous(&free_space,bj);CHKERRQ(ierr); 1825118727c9SMark F. Adams afill_tmp = (PetscReal)bi[pn]/(pdti[pn] + poti[pon] + ai[am]+1); 1826d6ab1dc0SHong Zhang if (afill_tmp > afill) afill = afill_tmp; 1827d6ab1dc0SHong Zhang ierr = PetscLLCondensedDestroy_Scalable(lnk);CHKERRQ(ierr); 1828d6ab1dc0SHong Zhang ierr = MatDestroy(&POt);CHKERRQ(ierr); 1829d6ab1dc0SHong Zhang ierr = MatDestroy(&PDt);CHKERRQ(ierr); 1830d6ab1dc0SHong Zhang 1831d6ab1dc0SHong Zhang /* create symbolic parallel matrix Cmpi - why cannot be assembled in Numeric part */ 1832d6ab1dc0SHong Zhang /*----------------------------------------------------------------------------------*/ 18331795a4d1SJed Brown ierr = PetscCalloc1(rmax+1,&vals);CHKERRQ(ierr); 1834d6ab1dc0SHong Zhang 1835d6ab1dc0SHong Zhang ierr = MatCreate(comm,&Cmpi);CHKERRQ(ierr); 1836d6ab1dc0SHong Zhang ierr = MatSetSizes(Cmpi,pn,A->cmap->n,PETSC_DETERMINE,PETSC_DETERMINE);CHKERRQ(ierr); 1837a2f3521dSMark F. Adams ierr = MatSetBlockSizes(Cmpi,P->cmap->bs,A->cmap->bs);CHKERRQ(ierr); 1838d6ab1dc0SHong Zhang ierr = MatSetType(Cmpi,MATMPIAIJ);CHKERRQ(ierr); 1839d6ab1dc0SHong Zhang ierr = MatMPIAIJSetPreallocation(Cmpi,0,dnz,0,onz);CHKERRQ(ierr); 1840d6ab1dc0SHong Zhang ierr = MatPreallocateFinalize(dnz,onz);CHKERRQ(ierr); 1841d6ab1dc0SHong Zhang ierr = MatSetBlockSize(Cmpi,1);CHKERRQ(ierr); 1842d6ab1dc0SHong Zhang for (i=0; i<pn; i++) { 1843d6ab1dc0SHong Zhang row = i + rstart; 1844d6ab1dc0SHong Zhang nnz = bi[i+1] - bi[i]; 1845d6ab1dc0SHong Zhang Jptr = bj + bi[i]; 1846d6ab1dc0SHong Zhang ierr = MatSetValues(Cmpi,1,&row,nnz,Jptr,vals,INSERT_VALUES);CHKERRQ(ierr); 1847d6ab1dc0SHong Zhang } 1848d6ab1dc0SHong Zhang ierr = MatAssemblyBegin(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1849d6ab1dc0SHong Zhang ierr = MatAssemblyEnd(Cmpi,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 1850d6ab1dc0SHong Zhang ierr = PetscFree(vals);CHKERRQ(ierr); 1851d6ab1dc0SHong Zhang 1852d6ab1dc0SHong Zhang merge->bi = bi; 1853d6ab1dc0SHong Zhang merge->bj = bj; 1854d6ab1dc0SHong Zhang merge->coi = coi; 1855d6ab1dc0SHong Zhang merge->coj = coj; 1856d6ab1dc0SHong Zhang merge->buf_ri = buf_ri; 1857d6ab1dc0SHong Zhang merge->buf_rj = buf_rj; 1858d6ab1dc0SHong Zhang merge->owners_co = owners_co; 1859d6ab1dc0SHong Zhang merge->destroy = Cmpi->ops->destroy; 1860d6ab1dc0SHong Zhang merge->duplicate = Cmpi->ops->duplicate; 1861d6ab1dc0SHong Zhang 18626da69ca6SHong Zhang Cmpi->ops->mattransposemultnumeric = MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ; 1863d6ab1dc0SHong Zhang Cmpi->ops->destroy = MatDestroy_MPIAIJ_PtAP; 1864d6ab1dc0SHong Zhang 1865d6ab1dc0SHong Zhang /* attach the supporting struct to Cmpi for reuse */ 1866d6ab1dc0SHong Zhang c = (Mat_MPIAIJ*)Cmpi->data; 18672205254eSKarl Rupp 1868d6ab1dc0SHong Zhang c->ptap = ptap; 18690298fd71SBarry Smith ptap->api = NULL; 18700298fd71SBarry Smith ptap->apj = NULL; 1871d6ab1dc0SHong Zhang ptap->merge = merge; 1872d6ab1dc0SHong Zhang ptap->rmax = rmax; 18730298fd71SBarry Smith ptap->apa = NULL; 1874f96d37fcSHong Zhang 1875f96d37fcSHong Zhang *C = Cmpi; 1876f96d37fcSHong Zhang #if defined(PETSC_USE_INFO) 1877f96d37fcSHong Zhang if (bi[pn] != 0) { 1878f96d37fcSHong Zhang ierr = PetscInfo3(Cmpi,"Reallocs %D; Fill ratio: given %G needed %G.\n",nspacedouble,fill,afill);CHKERRQ(ierr); 18791c7d5954SHong Zhang ierr = PetscInfo1(Cmpi,"Use MatTransposeMatMult(A,B,MatReuse,%G,&C) for best performance.\n",afill);CHKERRQ(ierr); 1880f96d37fcSHong Zhang } else { 1881f96d37fcSHong Zhang ierr = PetscInfo(Cmpi,"Empty matrix product\n");CHKERRQ(ierr); 1882f96d37fcSHong Zhang } 1883f96d37fcSHong Zhang #endif 1884f96d37fcSHong Zhang PetscFunctionReturn(0); 1885f96d37fcSHong Zhang } 1886