173f4d377SMatthew Knepley /*$Id: mpidense.c,v 1.159 2001/08/10 03:30:41 bsmith Exp $*/ 28965ea79SLois Curfman McInnes 3ed3cc1f0SBarry Smith /* 4ed3cc1f0SBarry Smith Basic functions for basic parallel dense matrices. 5ed3cc1f0SBarry Smith */ 6ed3cc1f0SBarry Smith 770f55243SBarry Smith #include "src/mat/impls/dense/mpi/mpidense.h" 8f5eb4b81SSatish Balay #include "src/vec/vecimpl.h" 98965ea79SLois Curfman McInnes 100de54da6SSatish Balay EXTERN_C_BEGIN 114a2ae208SSatish Balay #undef __FUNCT__ 124a2ae208SSatish Balay #define __FUNCT__ "MatGetDiagonalBlock_MPIDense" 130de54da6SSatish Balay int MatGetDiagonalBlock_MPIDense(Mat A,PetscTruth *iscopy,MatReuse reuse,Mat *B) 140de54da6SSatish Balay { 150de54da6SSatish Balay Mat_MPIDense *mdn = (Mat_MPIDense*)A->data; 16cfce73b9SSatish Balay int m = A->m,rstart = mdn->rstart,ierr; 1787828ca2SBarry Smith PetscScalar *array; 180de54da6SSatish Balay MPI_Comm comm; 190de54da6SSatish Balay 200de54da6SSatish Balay PetscFunctionBegin; 21273d9f13SBarry Smith if (A->M != A->N) SETERRQ(PETSC_ERR_SUP,"Only square matrices supported."); 220de54da6SSatish Balay 230de54da6SSatish Balay /* The reuse aspect is not implemented efficiently */ 240de54da6SSatish Balay if (reuse) { ierr = MatDestroy(*B);CHKERRQ(ierr);} 250de54da6SSatish Balay 260de54da6SSatish Balay ierr = PetscObjectGetComm((PetscObject)(mdn->A),&comm);CHKERRQ(ierr); 270de54da6SSatish Balay ierr = MatGetArray(mdn->A,&array);CHKERRQ(ierr); 280de54da6SSatish Balay ierr = MatCreateSeqDense(comm,m,m,array+m*rstart,B);CHKERRQ(ierr); 290de54da6SSatish Balay ierr = MatRestoreArray(mdn->A,&array);CHKERRQ(ierr); 300de54da6SSatish Balay ierr = MatAssemblyBegin(*B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 310de54da6SSatish Balay ierr = MatAssemblyEnd(*B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 320de54da6SSatish Balay 330de54da6SSatish Balay *iscopy = PETSC_TRUE; 340de54da6SSatish Balay PetscFunctionReturn(0); 350de54da6SSatish Balay } 360de54da6SSatish Balay EXTERN_C_END 370de54da6SSatish Balay 38ca44d042SBarry Smith EXTERN int MatSetUpMultiply_MPIDense(Mat); 397ef1d9bdSSatish Balay 404a2ae208SSatish Balay #undef __FUNCT__ 414a2ae208SSatish Balay #define __FUNCT__ "MatSetValues_MPIDense" 4287828ca2SBarry Smith int MatSetValues_MPIDense(Mat mat,int m,int *idxm,int n,int *idxn,PetscScalar *v,InsertMode addv) 438965ea79SLois Curfman McInnes { 4439b7565bSBarry Smith Mat_MPIDense *A = (Mat_MPIDense*)mat->data; 4539b7565bSBarry Smith int ierr,i,j,rstart = A->rstart,rend = A->rend,row; 46273d9f13SBarry Smith PetscTruth roworiented = A->roworiented; 478965ea79SLois Curfman McInnes 483a40ed3dSBarry Smith PetscFunctionBegin; 498965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 505ef9f2a5SBarry Smith if (idxm[i] < 0) continue; 51273d9f13SBarry Smith if (idxm[i] >= mat->M) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Row too large"); 528965ea79SLois Curfman McInnes if (idxm[i] >= rstart && idxm[i] < rend) { 538965ea79SLois Curfman McInnes row = idxm[i] - rstart; 5439b7565bSBarry Smith if (roworiented) { 5539b7565bSBarry Smith ierr = MatSetValues(A->A,1,&row,n,idxn,v+i*n,addv);CHKERRQ(ierr); 563a40ed3dSBarry Smith } else { 578965ea79SLois Curfman McInnes for (j=0; j<n; j++) { 585ef9f2a5SBarry Smith if (idxn[j] < 0) continue; 59273d9f13SBarry Smith if (idxn[j] >= mat->N) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Column too large"); 6039b7565bSBarry Smith ierr = MatSetValues(A->A,1,&row,1,&idxn[j],v+i+j*m,addv);CHKERRQ(ierr); 6139b7565bSBarry Smith } 628965ea79SLois Curfman McInnes } 633a40ed3dSBarry Smith } else { 643782ba37SSatish Balay if (!A->donotstash) { 6539b7565bSBarry Smith if (roworiented) { 668798bf22SSatish Balay ierr = MatStashValuesRow_Private(&mat->stash,idxm[i],n,idxn,v+i*n);CHKERRQ(ierr); 67d36fbae8SSatish Balay } else { 688798bf22SSatish Balay ierr = MatStashValuesCol_Private(&mat->stash,idxm[i],n,idxn,v+i,m);CHKERRQ(ierr); 6939b7565bSBarry Smith } 70b49de8d1SLois Curfman McInnes } 71b49de8d1SLois Curfman McInnes } 723782ba37SSatish Balay } 733a40ed3dSBarry Smith PetscFunctionReturn(0); 74b49de8d1SLois Curfman McInnes } 75b49de8d1SLois Curfman McInnes 764a2ae208SSatish Balay #undef __FUNCT__ 774a2ae208SSatish Balay #define __FUNCT__ "MatGetValues_MPIDense" 7887828ca2SBarry Smith int MatGetValues_MPIDense(Mat mat,int m,int *idxm,int n,int *idxn,PetscScalar *v) 79b49de8d1SLois Curfman McInnes { 80b49de8d1SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 81b49de8d1SLois Curfman McInnes int ierr,i,j,rstart = mdn->rstart,rend = mdn->rend,row; 82b49de8d1SLois Curfman McInnes 833a40ed3dSBarry Smith PetscFunctionBegin; 84b49de8d1SLois Curfman McInnes for (i=0; i<m; i++) { 8529bbc08cSBarry Smith if (idxm[i] < 0) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Negative row"); 86273d9f13SBarry Smith if (idxm[i] >= mat->M) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Row too large"); 87b49de8d1SLois Curfman McInnes if (idxm[i] >= rstart && idxm[i] < rend) { 88b49de8d1SLois Curfman McInnes row = idxm[i] - rstart; 89b49de8d1SLois Curfman McInnes for (j=0; j<n; j++) { 9029bbc08cSBarry Smith if (idxn[j] < 0) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Negative column"); 91273d9f13SBarry Smith if (idxn[j] >= mat->N) { 9229bbc08cSBarry Smith SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Column too large"); 93a8c6a408SBarry Smith } 94b49de8d1SLois Curfman McInnes ierr = MatGetValues(mdn->A,1,&row,1,&idxn[j],v+i*n+j);CHKERRQ(ierr); 95b49de8d1SLois Curfman McInnes } 96a8c6a408SBarry Smith } else { 9729bbc08cSBarry Smith SETERRQ(PETSC_ERR_SUP,"Only local values currently supported"); 988965ea79SLois Curfman McInnes } 998965ea79SLois Curfman McInnes } 1003a40ed3dSBarry Smith PetscFunctionReturn(0); 1018965ea79SLois Curfman McInnes } 1028965ea79SLois Curfman McInnes 1034a2ae208SSatish Balay #undef __FUNCT__ 1044a2ae208SSatish Balay #define __FUNCT__ "MatGetArray_MPIDense" 10587828ca2SBarry Smith int MatGetArray_MPIDense(Mat A,PetscScalar **array) 106ff14e315SSatish Balay { 107ff14e315SSatish Balay Mat_MPIDense *a = (Mat_MPIDense*)A->data; 108ff14e315SSatish Balay int ierr; 109ff14e315SSatish Balay 1103a40ed3dSBarry Smith PetscFunctionBegin; 111ff14e315SSatish Balay ierr = MatGetArray(a->A,array);CHKERRQ(ierr); 1123a40ed3dSBarry Smith PetscFunctionReturn(0); 113ff14e315SSatish Balay } 114ff14e315SSatish Balay 1154a2ae208SSatish Balay #undef __FUNCT__ 1164a2ae208SSatish Balay #define __FUNCT__ "MatGetSubMatrix_MPIDense" 117ca3fa75bSLois Curfman McInnes static int MatGetSubMatrix_MPIDense(Mat A,IS isrow,IS iscol,int cs,MatReuse scall,Mat *B) 118ca3fa75bSLois Curfman McInnes { 119ca3fa75bSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense*)A->data,*newmatd; 120ca3fa75bSLois Curfman McInnes Mat_SeqDense *lmat = (Mat_SeqDense*)mat->A->data; 121cfce73b9SSatish Balay int i,j,ierr,*irow,*icol,rstart,rend,nrows,ncols,nlrows,nlcols; 12287828ca2SBarry Smith PetscScalar *av,*bv,*v = lmat->v; 123ca3fa75bSLois Curfman McInnes Mat newmat; 124ca3fa75bSLois Curfman McInnes 125ca3fa75bSLois Curfman McInnes PetscFunctionBegin; 126ca3fa75bSLois Curfman McInnes ierr = ISGetIndices(isrow,&irow);CHKERRQ(ierr); 127ca3fa75bSLois Curfman McInnes ierr = ISGetIndices(iscol,&icol);CHKERRQ(ierr); 128b9b97703SBarry Smith ierr = ISGetLocalSize(isrow,&nrows);CHKERRQ(ierr); 129b9b97703SBarry Smith ierr = ISGetLocalSize(iscol,&ncols);CHKERRQ(ierr); 130ca3fa75bSLois Curfman McInnes 131ca3fa75bSLois Curfman McInnes /* No parallel redistribution currently supported! Should really check each index set 1327eba5e9cSLois Curfman McInnes to comfirm that it is OK. ... Currently supports only submatrix same partitioning as 1337eba5e9cSLois Curfman McInnes original matrix! */ 134ca3fa75bSLois Curfman McInnes 135ca3fa75bSLois Curfman McInnes ierr = MatGetLocalSize(A,&nlrows,&nlcols);CHKERRQ(ierr); 1367eba5e9cSLois Curfman McInnes ierr = MatGetOwnershipRange(A,&rstart,&rend);CHKERRQ(ierr); 137ca3fa75bSLois Curfman McInnes 138ca3fa75bSLois Curfman McInnes /* Check submatrix call */ 139ca3fa75bSLois Curfman McInnes if (scall == MAT_REUSE_MATRIX) { 14029bbc08cSBarry Smith /* SETERRQ(PETSC_ERR_ARG_SIZ,"Reused submatrix wrong size"); */ 1417eba5e9cSLois Curfman McInnes /* Really need to test rows and column sizes! */ 142ca3fa75bSLois Curfman McInnes newmat = *B; 143ca3fa75bSLois Curfman McInnes } else { 144ca3fa75bSLois Curfman McInnes /* Create and fill new matrix */ 14532828cfdSBarry Smith ierr = MatCreateMPIDense(A->comm,nrows,cs,PETSC_DECIDE,ncols,PETSC_NULL,&newmat);CHKERRQ(ierr); 146ca3fa75bSLois Curfman McInnes } 147ca3fa75bSLois Curfman McInnes 148ca3fa75bSLois Curfman McInnes /* Now extract the data pointers and do the copy, column at a time */ 149ca3fa75bSLois Curfman McInnes newmatd = (Mat_MPIDense*)newmat->data; 150ca3fa75bSLois Curfman McInnes bv = ((Mat_SeqDense *)newmatd->A->data)->v; 151ca3fa75bSLois Curfman McInnes 152ca3fa75bSLois Curfman McInnes for (i=0; i<ncols; i++) { 153ca3fa75bSLois Curfman McInnes av = v + nlrows*icol[i]; 154ca3fa75bSLois Curfman McInnes for (j=0; j<nrows; j++) { 1557eba5e9cSLois Curfman McInnes *bv++ = av[irow[j] - rstart]; 156ca3fa75bSLois Curfman McInnes } 157ca3fa75bSLois Curfman McInnes } 158ca3fa75bSLois Curfman McInnes 159ca3fa75bSLois Curfman McInnes /* Assemble the matrices so that the correct flags are set */ 160ca3fa75bSLois Curfman McInnes ierr = MatAssemblyBegin(newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 161ca3fa75bSLois Curfman McInnes ierr = MatAssemblyEnd(newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 162ca3fa75bSLois Curfman McInnes 163ca3fa75bSLois Curfman McInnes /* Free work space */ 164ca3fa75bSLois Curfman McInnes ierr = ISRestoreIndices(isrow,&irow);CHKERRQ(ierr); 165ca3fa75bSLois Curfman McInnes ierr = ISRestoreIndices(iscol,&icol);CHKERRQ(ierr); 166ca3fa75bSLois Curfman McInnes *B = newmat; 167ca3fa75bSLois Curfman McInnes PetscFunctionReturn(0); 168ca3fa75bSLois Curfman McInnes } 169ca3fa75bSLois Curfman McInnes 1704a2ae208SSatish Balay #undef __FUNCT__ 1714a2ae208SSatish Balay #define __FUNCT__ "MatRestoreArray_MPIDense" 17287828ca2SBarry Smith int MatRestoreArray_MPIDense(Mat A,PetscScalar **array) 173ff14e315SSatish Balay { 1743a40ed3dSBarry Smith PetscFunctionBegin; 1753a40ed3dSBarry Smith PetscFunctionReturn(0); 176ff14e315SSatish Balay } 177ff14e315SSatish Balay 1784a2ae208SSatish Balay #undef __FUNCT__ 1794a2ae208SSatish Balay #define __FUNCT__ "MatAssemblyBegin_MPIDense" 1808f6be9afSLois Curfman McInnes int MatAssemblyBegin_MPIDense(Mat mat,MatAssemblyType mode) 1818965ea79SLois Curfman McInnes { 18239ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 1838965ea79SLois Curfman McInnes MPI_Comm comm = mat->comm; 184d36fbae8SSatish Balay int ierr,nstash,reallocs; 1858965ea79SLois Curfman McInnes InsertMode addv; 1868965ea79SLois Curfman McInnes 1873a40ed3dSBarry Smith PetscFunctionBegin; 1888965ea79SLois Curfman McInnes /* make sure all processors are either in INSERTMODE or ADDMODE */ 189ca161407SBarry Smith ierr = MPI_Allreduce(&mat->insertmode,&addv,1,MPI_INT,MPI_BOR,comm);CHKERRQ(ierr); 1907056b6fcSBarry Smith if (addv == (ADD_VALUES|INSERT_VALUES)) { 19129bbc08cSBarry Smith SETERRQ(PETSC_ERR_ARG_WRONGSTATE,"Cannot mix adds/inserts on different procs"); 1928965ea79SLois Curfman McInnes } 193e0fa3b82SLois Curfman McInnes mat->insertmode = addv; /* in case this processor had no cache */ 1948965ea79SLois Curfman McInnes 1958798bf22SSatish Balay ierr = MatStashScatterBegin_Private(&mat->stash,mdn->rowners);CHKERRQ(ierr); 1968798bf22SSatish Balay ierr = MatStashGetInfo_Private(&mat->stash,&nstash,&reallocs);CHKERRQ(ierr); 197b0a32e0cSBarry Smith PetscLogInfo(mdn->A,"MatAssemblyBegin_MPIDense:Stash has %d entries, uses %d mallocs.\n",nstash,reallocs); 1983a40ed3dSBarry Smith PetscFunctionReturn(0); 1998965ea79SLois Curfman McInnes } 2008965ea79SLois Curfman McInnes 2014a2ae208SSatish Balay #undef __FUNCT__ 2024a2ae208SSatish Balay #define __FUNCT__ "MatAssemblyEnd_MPIDense" 2038f6be9afSLois Curfman McInnes int MatAssemblyEnd_MPIDense(Mat mat,MatAssemblyType mode) 2048965ea79SLois Curfman McInnes { 20539ddd567SLois Curfman McInnes Mat_MPIDense *mdn=(Mat_MPIDense*)mat->data; 2067ef1d9bdSSatish Balay int i,n,ierr,*row,*col,flg,j,rstart,ncols; 20787828ca2SBarry Smith PetscScalar *val; 208e0fa3b82SLois Curfman McInnes InsertMode addv=mat->insertmode; 2098965ea79SLois Curfman McInnes 2103a40ed3dSBarry Smith PetscFunctionBegin; 2118965ea79SLois Curfman McInnes /* wait on receives */ 2127ef1d9bdSSatish Balay while (1) { 2138798bf22SSatish Balay ierr = MatStashScatterGetMesg_Private(&mat->stash,&n,&row,&col,&val,&flg);CHKERRQ(ierr); 2147ef1d9bdSSatish Balay if (!flg) break; 2158965ea79SLois Curfman McInnes 2167ef1d9bdSSatish Balay for (i=0; i<n;) { 2177ef1d9bdSSatish Balay /* Now identify the consecutive vals belonging to the same row */ 2187ef1d9bdSSatish Balay for (j=i,rstart=row[j]; j<n; j++) { if (row[j] != rstart) break; } 2197ef1d9bdSSatish Balay if (j < n) ncols = j-i; 2207ef1d9bdSSatish Balay else ncols = n-i; 2217ef1d9bdSSatish Balay /* Now assemble all these values with a single function call */ 2227ef1d9bdSSatish Balay ierr = MatSetValues_MPIDense(mat,1,row+i,ncols,col+i,val+i,addv);CHKERRQ(ierr); 2237ef1d9bdSSatish Balay i = j; 2248965ea79SLois Curfman McInnes } 2257ef1d9bdSSatish Balay } 2268798bf22SSatish Balay ierr = MatStashScatterEnd_Private(&mat->stash);CHKERRQ(ierr); 2278965ea79SLois Curfman McInnes 22839ddd567SLois Curfman McInnes ierr = MatAssemblyBegin(mdn->A,mode);CHKERRQ(ierr); 22939ddd567SLois Curfman McInnes ierr = MatAssemblyEnd(mdn->A,mode);CHKERRQ(ierr); 2308965ea79SLois Curfman McInnes 2316d4a8577SBarry Smith if (!mat->was_assembled && mode == MAT_FINAL_ASSEMBLY) { 23239ddd567SLois Curfman McInnes ierr = MatSetUpMultiply_MPIDense(mat);CHKERRQ(ierr); 2338965ea79SLois Curfman McInnes } 2343a40ed3dSBarry Smith PetscFunctionReturn(0); 2358965ea79SLois Curfman McInnes } 2368965ea79SLois Curfman McInnes 2374a2ae208SSatish Balay #undef __FUNCT__ 2384a2ae208SSatish Balay #define __FUNCT__ "MatZeroEntries_MPIDense" 2398f6be9afSLois Curfman McInnes int MatZeroEntries_MPIDense(Mat A) 2408965ea79SLois Curfman McInnes { 2413a40ed3dSBarry Smith int ierr; 24239ddd567SLois Curfman McInnes Mat_MPIDense *l = (Mat_MPIDense*)A->data; 2433a40ed3dSBarry Smith 2443a40ed3dSBarry Smith PetscFunctionBegin; 2453a40ed3dSBarry Smith ierr = MatZeroEntries(l->A);CHKERRQ(ierr); 2463a40ed3dSBarry Smith PetscFunctionReturn(0); 2478965ea79SLois Curfman McInnes } 2488965ea79SLois Curfman McInnes 2494a2ae208SSatish Balay #undef __FUNCT__ 2504a2ae208SSatish Balay #define __FUNCT__ "MatGetBlockSize_MPIDense" 2518f6be9afSLois Curfman McInnes int MatGetBlockSize_MPIDense(Mat A,int *bs) 2524e220ebcSLois Curfman McInnes { 2533a40ed3dSBarry Smith PetscFunctionBegin; 2544e220ebcSLois Curfman McInnes *bs = 1; 2553a40ed3dSBarry Smith PetscFunctionReturn(0); 2564e220ebcSLois Curfman McInnes } 2574e220ebcSLois Curfman McInnes 2588965ea79SLois Curfman McInnes /* the code does not do the diagonal entries correctly unless the 2598965ea79SLois Curfman McInnes matrix is square and the column and row owerships are identical. 2608965ea79SLois Curfman McInnes This is a BUG. The only way to fix it seems to be to access 2613501a2bdSLois Curfman McInnes mdn->A and mdn->B directly and not through the MatZeroRows() 2628965ea79SLois Curfman McInnes routine. 2638965ea79SLois Curfman McInnes */ 2644a2ae208SSatish Balay #undef __FUNCT__ 2654a2ae208SSatish Balay #define __FUNCT__ "MatZeroRows_MPIDense" 26687828ca2SBarry Smith int MatZeroRows_MPIDense(Mat A,IS is,PetscScalar *diag) 2678965ea79SLois Curfman McInnes { 26839ddd567SLois Curfman McInnes Mat_MPIDense *l = (Mat_MPIDense*)A->data; 2698965ea79SLois Curfman McInnes int i,ierr,N,*rows,*owners = l->rowners,size = l->size; 270*c1dc657dSBarry Smith int *nprocs,j,idx,nsends; 2718965ea79SLois Curfman McInnes int nmax,*svalues,*starts,*owner,nrecvs,rank = l->rank; 2728965ea79SLois Curfman McInnes int *rvalues,tag = A->tag,count,base,slen,n,*source; 2738965ea79SLois Curfman McInnes int *lens,imdex,*lrows,*values; 2748965ea79SLois Curfman McInnes MPI_Comm comm = A->comm; 2758965ea79SLois Curfman McInnes MPI_Request *send_waits,*recv_waits; 2768965ea79SLois Curfman McInnes MPI_Status recv_status,*send_status; 2778965ea79SLois Curfman McInnes IS istmp; 27835d8aa7fSBarry Smith PetscTruth found; 2798965ea79SLois Curfman McInnes 2803a40ed3dSBarry Smith PetscFunctionBegin; 281b9b97703SBarry Smith ierr = ISGetLocalSize(is,&N);CHKERRQ(ierr); 2828965ea79SLois Curfman McInnes ierr = ISGetIndices(is,&rows);CHKERRQ(ierr); 2838965ea79SLois Curfman McInnes 2848965ea79SLois Curfman McInnes /* first count number of contributors to each processor */ 285b0a32e0cSBarry Smith ierr = PetscMalloc(2*size*sizeof(int),&nprocs);CHKERRQ(ierr); 286549d3d68SSatish Balay ierr = PetscMemzero(nprocs,2*size*sizeof(int));CHKERRQ(ierr); 287b0a32e0cSBarry Smith ierr = PetscMalloc((N+1)*sizeof(int),&owner);CHKERRQ(ierr); /* see note*/ 2888965ea79SLois Curfman McInnes for (i=0; i<N; i++) { 2898965ea79SLois Curfman McInnes idx = rows[i]; 29035d8aa7fSBarry Smith found = PETSC_FALSE; 2918965ea79SLois Curfman McInnes for (j=0; j<size; j++) { 2928965ea79SLois Curfman McInnes if (idx >= owners[j] && idx < owners[j+1]) { 293*c1dc657dSBarry Smith nprocs[2*j]++; nprocs[2*j+1] = 1; owner[i] = j; found = PETSC_TRUE; break; 2948965ea79SLois Curfman McInnes } 2958965ea79SLois Curfman McInnes } 29629bbc08cSBarry Smith if (!found) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Index out of range"); 2978965ea79SLois Curfman McInnes } 298*c1dc657dSBarry Smith nsends = 0; for (i=0; i<size; i++) { nsends += nprocs[2*i+1];} 2998965ea79SLois Curfman McInnes 3008965ea79SLois Curfman McInnes /* inform other processors of number of messages and max length*/ 301*c1dc657dSBarry Smith ierr = PetscMaxSum(comm,nprocs,&nmax,&nrecvs);CHKERRQ(ierr); 3028965ea79SLois Curfman McInnes 3038965ea79SLois Curfman McInnes /* post receives: */ 304b0a32e0cSBarry Smith ierr = PetscMalloc((nrecvs+1)*(nmax+1)*sizeof(int),&rvalues);CHKERRQ(ierr); 305b0a32e0cSBarry Smith ierr = PetscMalloc((nrecvs+1)*sizeof(MPI_Request),&recv_waits);CHKERRQ(ierr); 3068965ea79SLois Curfman McInnes for (i=0; i<nrecvs; i++) { 307ca161407SBarry Smith ierr = MPI_Irecv(rvalues+nmax*i,nmax,MPI_INT,MPI_ANY_SOURCE,tag,comm,recv_waits+i);CHKERRQ(ierr); 3088965ea79SLois Curfman McInnes } 3098965ea79SLois Curfman McInnes 3108965ea79SLois Curfman McInnes /* do sends: 3118965ea79SLois Curfman McInnes 1) starts[i] gives the starting index in svalues for stuff going to 3128965ea79SLois Curfman McInnes the ith processor 3138965ea79SLois Curfman McInnes */ 314b0a32e0cSBarry Smith ierr = PetscMalloc((N+1)*sizeof(int),&svalues);CHKERRQ(ierr); 315b0a32e0cSBarry Smith ierr = PetscMalloc((nsends+1)*sizeof(MPI_Request),&send_waits);CHKERRQ(ierr); 316b0a32e0cSBarry Smith ierr = PetscMalloc((size+1)*sizeof(int),&starts);CHKERRQ(ierr); 3178965ea79SLois Curfman McInnes starts[0] = 0; 318*c1dc657dSBarry Smith for (i=1; i<size; i++) { starts[i] = starts[i-1] + nprocs[2*i-2];} 3198965ea79SLois Curfman McInnes for (i=0; i<N; i++) { 3208965ea79SLois Curfman McInnes svalues[starts[owner[i]]++] = rows[i]; 3218965ea79SLois Curfman McInnes } 3228965ea79SLois Curfman McInnes ISRestoreIndices(is,&rows); 3238965ea79SLois Curfman McInnes 3248965ea79SLois Curfman McInnes starts[0] = 0; 325*c1dc657dSBarry Smith for (i=1; i<size+1; i++) { starts[i] = starts[i-1] + nprocs[2*i-2];} 3268965ea79SLois Curfman McInnes count = 0; 3278965ea79SLois Curfman McInnes for (i=0; i<size; i++) { 328*c1dc657dSBarry Smith if (nprocs[2*i+1]) { 329*c1dc657dSBarry Smith ierr = MPI_Isend(svalues+starts[i],nprocs[2*i],MPI_INT,i,tag,comm,send_waits+count++);CHKERRQ(ierr); 3308965ea79SLois Curfman McInnes } 3318965ea79SLois Curfman McInnes } 332606d414cSSatish Balay ierr = PetscFree(starts);CHKERRQ(ierr); 3338965ea79SLois Curfman McInnes 3348965ea79SLois Curfman McInnes base = owners[rank]; 3358965ea79SLois Curfman McInnes 3368965ea79SLois Curfman McInnes /* wait on receives */ 337b0a32e0cSBarry Smith ierr = PetscMalloc(2*(nrecvs+1)*sizeof(int),&lens);CHKERRQ(ierr); 3388965ea79SLois Curfman McInnes source = lens + nrecvs; 3398965ea79SLois Curfman McInnes count = nrecvs; slen = 0; 3408965ea79SLois Curfman McInnes while (count) { 341ca161407SBarry Smith ierr = MPI_Waitany(nrecvs,recv_waits,&imdex,&recv_status);CHKERRQ(ierr); 3428965ea79SLois Curfman McInnes /* unpack receives into our local space */ 343ca161407SBarry Smith ierr = MPI_Get_count(&recv_status,MPI_INT,&n);CHKERRQ(ierr); 3448965ea79SLois Curfman McInnes source[imdex] = recv_status.MPI_SOURCE; 3458965ea79SLois Curfman McInnes lens[imdex] = n; 3468965ea79SLois Curfman McInnes slen += n; 3478965ea79SLois Curfman McInnes count--; 3488965ea79SLois Curfman McInnes } 349606d414cSSatish Balay ierr = PetscFree(recv_waits);CHKERRQ(ierr); 3508965ea79SLois Curfman McInnes 3518965ea79SLois Curfman McInnes /* move the data into the send scatter */ 352b0a32e0cSBarry Smith ierr = PetscMalloc((slen+1)*sizeof(int),&lrows);CHKERRQ(ierr); 3538965ea79SLois Curfman McInnes count = 0; 3548965ea79SLois Curfman McInnes for (i=0; i<nrecvs; i++) { 3558965ea79SLois Curfman McInnes values = rvalues + i*nmax; 3568965ea79SLois Curfman McInnes for (j=0; j<lens[i]; j++) { 3578965ea79SLois Curfman McInnes lrows[count++] = values[j] - base; 3588965ea79SLois Curfman McInnes } 3598965ea79SLois Curfman McInnes } 360606d414cSSatish Balay ierr = PetscFree(rvalues);CHKERRQ(ierr); 361606d414cSSatish Balay ierr = PetscFree(lens);CHKERRQ(ierr); 362606d414cSSatish Balay ierr = PetscFree(owner);CHKERRQ(ierr); 363606d414cSSatish Balay ierr = PetscFree(nprocs);CHKERRQ(ierr); 3648965ea79SLois Curfman McInnes 3658965ea79SLois Curfman McInnes /* actually zap the local rows */ 366029af93fSBarry Smith ierr = ISCreateGeneral(PETSC_COMM_SELF,slen,lrows,&istmp);CHKERRQ(ierr); 367b0a32e0cSBarry Smith PetscLogObjectParent(A,istmp); 368606d414cSSatish Balay ierr = PetscFree(lrows);CHKERRQ(ierr); 3698965ea79SLois Curfman McInnes ierr = MatZeroRows(l->A,istmp,diag);CHKERRQ(ierr); 3708965ea79SLois Curfman McInnes ierr = ISDestroy(istmp);CHKERRQ(ierr); 3718965ea79SLois Curfman McInnes 3728965ea79SLois Curfman McInnes /* wait on sends */ 3738965ea79SLois Curfman McInnes if (nsends) { 374b0a32e0cSBarry Smith ierr = PetscMalloc(nsends*sizeof(MPI_Status),&send_status);CHKERRQ(ierr); 375ca161407SBarry Smith ierr = MPI_Waitall(nsends,send_waits,send_status);CHKERRQ(ierr); 376606d414cSSatish Balay ierr = PetscFree(send_status);CHKERRQ(ierr); 3778965ea79SLois Curfman McInnes } 378606d414cSSatish Balay ierr = PetscFree(send_waits);CHKERRQ(ierr); 379606d414cSSatish Balay ierr = PetscFree(svalues);CHKERRQ(ierr); 3808965ea79SLois Curfman McInnes 3813a40ed3dSBarry Smith PetscFunctionReturn(0); 3828965ea79SLois Curfman McInnes } 3838965ea79SLois Curfman McInnes 3844a2ae208SSatish Balay #undef __FUNCT__ 3854a2ae208SSatish Balay #define __FUNCT__ "MatMult_MPIDense" 3868f6be9afSLois Curfman McInnes int MatMult_MPIDense(Mat mat,Vec xx,Vec yy) 3878965ea79SLois Curfman McInnes { 38839ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 3898965ea79SLois Curfman McInnes int ierr; 390c456f294SBarry Smith 3913a40ed3dSBarry Smith PetscFunctionBegin; 39243a90d84SBarry Smith ierr = VecScatterBegin(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr); 39343a90d84SBarry Smith ierr = VecScatterEnd(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr); 39444cd7ae7SLois Curfman McInnes ierr = MatMult_SeqDense(mdn->A,mdn->lvec,yy);CHKERRQ(ierr); 3953a40ed3dSBarry Smith PetscFunctionReturn(0); 3968965ea79SLois Curfman McInnes } 3978965ea79SLois Curfman McInnes 3984a2ae208SSatish Balay #undef __FUNCT__ 3994a2ae208SSatish Balay #define __FUNCT__ "MatMultAdd_MPIDense" 4008f6be9afSLois Curfman McInnes int MatMultAdd_MPIDense(Mat mat,Vec xx,Vec yy,Vec zz) 4018965ea79SLois Curfman McInnes { 40239ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 4038965ea79SLois Curfman McInnes int ierr; 404c456f294SBarry Smith 4053a40ed3dSBarry Smith PetscFunctionBegin; 40643a90d84SBarry Smith ierr = VecScatterBegin(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr); 40743a90d84SBarry Smith ierr = VecScatterEnd(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr); 40844cd7ae7SLois Curfman McInnes ierr = MatMultAdd_SeqDense(mdn->A,mdn->lvec,yy,zz);CHKERRQ(ierr); 4093a40ed3dSBarry Smith PetscFunctionReturn(0); 4108965ea79SLois Curfman McInnes } 4118965ea79SLois Curfman McInnes 4124a2ae208SSatish Balay #undef __FUNCT__ 4134a2ae208SSatish Balay #define __FUNCT__ "MatMultTranspose_MPIDense" 4147c922b88SBarry Smith int MatMultTranspose_MPIDense(Mat A,Vec xx,Vec yy) 415096963f5SLois Curfman McInnes { 416096963f5SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense*)A->data; 417096963f5SLois Curfman McInnes int ierr; 41887828ca2SBarry Smith PetscScalar zero = 0.0; 419096963f5SLois Curfman McInnes 4203a40ed3dSBarry Smith PetscFunctionBegin; 4213501a2bdSLois Curfman McInnes ierr = VecSet(&zero,yy);CHKERRQ(ierr); 4227c922b88SBarry Smith ierr = MatMultTranspose_SeqDense(a->A,xx,a->lvec);CHKERRQ(ierr); 423537820f0SBarry Smith ierr = VecScatterBegin(a->lvec,yy,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr); 424537820f0SBarry Smith ierr = VecScatterEnd(a->lvec,yy,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr); 4253a40ed3dSBarry Smith PetscFunctionReturn(0); 426096963f5SLois Curfman McInnes } 427096963f5SLois Curfman McInnes 4284a2ae208SSatish Balay #undef __FUNCT__ 4294a2ae208SSatish Balay #define __FUNCT__ "MatMultTransposeAdd_MPIDense" 4307c922b88SBarry Smith int MatMultTransposeAdd_MPIDense(Mat A,Vec xx,Vec yy,Vec zz) 431096963f5SLois Curfman McInnes { 432096963f5SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense*)A->data; 433096963f5SLois Curfman McInnes int ierr; 434096963f5SLois Curfman McInnes 4353a40ed3dSBarry Smith PetscFunctionBegin; 4363501a2bdSLois Curfman McInnes ierr = VecCopy(yy,zz);CHKERRQ(ierr); 4377c922b88SBarry Smith ierr = MatMultTranspose_SeqDense(a->A,xx,a->lvec);CHKERRQ(ierr); 438537820f0SBarry Smith ierr = VecScatterBegin(a->lvec,zz,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr); 439537820f0SBarry Smith ierr = VecScatterEnd(a->lvec,zz,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr); 4403a40ed3dSBarry Smith PetscFunctionReturn(0); 441096963f5SLois Curfman McInnes } 442096963f5SLois Curfman McInnes 4434a2ae208SSatish Balay #undef __FUNCT__ 4444a2ae208SSatish Balay #define __FUNCT__ "MatGetDiagonal_MPIDense" 4458f6be9afSLois Curfman McInnes int MatGetDiagonal_MPIDense(Mat A,Vec v) 4468965ea79SLois Curfman McInnes { 44739ddd567SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense*)A->data; 448096963f5SLois Curfman McInnes Mat_SeqDense *aloc = (Mat_SeqDense*)a->A->data; 449273d9f13SBarry Smith int ierr,len,i,n,m = A->m,radd; 45087828ca2SBarry Smith PetscScalar *x,zero = 0.0; 451ed3cc1f0SBarry Smith 4523a40ed3dSBarry Smith PetscFunctionBegin; 453273d9f13SBarry Smith ierr = VecSet(&zero,v);CHKERRQ(ierr); 454096963f5SLois Curfman McInnes ierr = VecGetArray(v,&x);CHKERRQ(ierr); 455096963f5SLois Curfman McInnes ierr = VecGetSize(v,&n);CHKERRQ(ierr); 456273d9f13SBarry Smith if (n != A->M) SETERRQ(PETSC_ERR_ARG_SIZ,"Nonconforming mat and vec"); 457273d9f13SBarry Smith len = PetscMin(a->A->m,a->A->n); 4587ddc982cSLois Curfman McInnes radd = a->rstart*m; 45944cd7ae7SLois Curfman McInnes for (i=0; i<len; i++) { 460096963f5SLois Curfman McInnes x[i] = aloc->v[radd + i*m + i]; 461096963f5SLois Curfman McInnes } 4629a8c540fSSatish Balay ierr = VecRestoreArray(v,&x);CHKERRQ(ierr); 4633a40ed3dSBarry Smith PetscFunctionReturn(0); 4648965ea79SLois Curfman McInnes } 4658965ea79SLois Curfman McInnes 4664a2ae208SSatish Balay #undef __FUNCT__ 4674a2ae208SSatish Balay #define __FUNCT__ "MatDestroy_MPIDense" 468e1311b90SBarry Smith int MatDestroy_MPIDense(Mat mat) 4698965ea79SLois Curfman McInnes { 4703501a2bdSLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 4718965ea79SLois Curfman McInnes int ierr; 472ed3cc1f0SBarry Smith 4733a40ed3dSBarry Smith PetscFunctionBegin; 47494d884c6SBarry Smith 475aa482453SBarry Smith #if defined(PETSC_USE_LOG) 476b0a32e0cSBarry Smith PetscLogObjectState((PetscObject)mat,"Rows=%d, Cols=%d",mat->M,mat->N); 4778965ea79SLois Curfman McInnes #endif 4788798bf22SSatish Balay ierr = MatStashDestroy_Private(&mat->stash);CHKERRQ(ierr); 479606d414cSSatish Balay ierr = PetscFree(mdn->rowners);CHKERRQ(ierr); 4803501a2bdSLois Curfman McInnes ierr = MatDestroy(mdn->A);CHKERRQ(ierr); 4813501a2bdSLois Curfman McInnes if (mdn->lvec) VecDestroy(mdn->lvec); 4823501a2bdSLois Curfman McInnes if (mdn->Mvctx) VecScatterDestroy(mdn->Mvctx); 483622d7880SLois Curfman McInnes if (mdn->factor) { 484606d414cSSatish Balay if (mdn->factor->temp) {ierr = PetscFree(mdn->factor->temp);CHKERRQ(ierr);} 485606d414cSSatish Balay if (mdn->factor->tag) {ierr = PetscFree(mdn->factor->tag);CHKERRQ(ierr);} 486606d414cSSatish Balay if (mdn->factor->pivots) {ierr = PetscFree(mdn->factor->pivots);CHKERRQ(ierr);} 487606d414cSSatish Balay ierr = PetscFree(mdn->factor);CHKERRQ(ierr); 488622d7880SLois Curfman McInnes } 489606d414cSSatish Balay ierr = PetscFree(mdn);CHKERRQ(ierr); 4903a40ed3dSBarry Smith PetscFunctionReturn(0); 4918965ea79SLois Curfman McInnes } 49239ddd567SLois Curfman McInnes 4934a2ae208SSatish Balay #undef __FUNCT__ 4944a2ae208SSatish Balay #define __FUNCT__ "MatView_MPIDense_Binary" 495b0a32e0cSBarry Smith static int MatView_MPIDense_Binary(Mat mat,PetscViewer viewer) 4968965ea79SLois Curfman McInnes { 49739ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 4988965ea79SLois Curfman McInnes int ierr; 4997056b6fcSBarry Smith 5003a40ed3dSBarry Smith PetscFunctionBegin; 50139ddd567SLois Curfman McInnes if (mdn->size == 1) { 50239ddd567SLois Curfman McInnes ierr = MatView(mdn->A,viewer);CHKERRQ(ierr); 5038965ea79SLois Curfman McInnes } 50429bbc08cSBarry Smith else SETERRQ(PETSC_ERR_SUP,"Only uniprocessor output supported"); 5053a40ed3dSBarry Smith PetscFunctionReturn(0); 5068965ea79SLois Curfman McInnes } 5078965ea79SLois Curfman McInnes 5084a2ae208SSatish Balay #undef __FUNCT__ 5094a2ae208SSatish Balay #define __FUNCT__ "MatView_MPIDense_ASCIIorDraworSocket" 510b0a32e0cSBarry Smith static int MatView_MPIDense_ASCIIorDraworSocket(Mat mat,PetscViewer viewer) 5118965ea79SLois Curfman McInnes { 51239ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data; 513fb9695e5SSatish Balay int ierr,size = mdn->size,rank = mdn->rank; 514b0a32e0cSBarry Smith PetscViewerType vtype; 515f1af5d2fSBarry Smith PetscTruth isascii,isdraw; 516b0a32e0cSBarry Smith PetscViewer sviewer; 517f3ef73ceSBarry Smith PetscViewerFormat format; 5188965ea79SLois Curfman McInnes 5193a40ed3dSBarry Smith PetscFunctionBegin; 520b0a32e0cSBarry Smith ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_ASCII,&isascii);CHKERRQ(ierr); 521fb9695e5SSatish Balay ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_DRAW,&isdraw);CHKERRQ(ierr); 522f1af5d2fSBarry Smith if (isascii) { 523b0a32e0cSBarry Smith ierr = PetscViewerGetType(viewer,&vtype);CHKERRQ(ierr); 524b0a32e0cSBarry Smith ierr = PetscViewerGetFormat(viewer,&format);CHKERRQ(ierr); 525456192e2SBarry Smith if (format == PETSC_VIEWER_ASCII_INFO_DETAIL) { 5264e220ebcSLois Curfman McInnes MatInfo info; 527888f2ed8SSatish Balay ierr = MatGetInfo(mat,MAT_LOCAL,&info);CHKERRQ(ierr); 528b0a32e0cSBarry Smith ierr = PetscViewerASCIISynchronizedPrintf(viewer," [%d] local rows %d nz %d nz alloced %d mem %d \n",rank,mat->m, 5296831982aSBarry Smith (int)info.nz_used,(int)info.nz_allocated,(int)info.memory);CHKERRQ(ierr); 530b0a32e0cSBarry Smith ierr = PetscViewerFlush(viewer);CHKERRQ(ierr); 5313501a2bdSLois Curfman McInnes ierr = VecScatterView(mdn->Mvctx,viewer);CHKERRQ(ierr); 5323a40ed3dSBarry Smith PetscFunctionReturn(0); 533fb9695e5SSatish Balay } else if (format == PETSC_VIEWER_ASCII_INFO) { 5343a40ed3dSBarry Smith PetscFunctionReturn(0); 5358965ea79SLois Curfman McInnes } 536f1af5d2fSBarry Smith } else if (isdraw) { 537b0a32e0cSBarry Smith PetscDraw draw; 538f1af5d2fSBarry Smith PetscTruth isnull; 539f1af5d2fSBarry Smith 540b0a32e0cSBarry Smith ierr = PetscViewerDrawGetDraw(viewer,0,&draw);CHKERRQ(ierr); 541b0a32e0cSBarry Smith ierr = PetscDrawIsNull(draw,&isnull);CHKERRQ(ierr); 542f1af5d2fSBarry Smith if (isnull) PetscFunctionReturn(0); 543f1af5d2fSBarry Smith } 54477ed5343SBarry Smith 5458965ea79SLois Curfman McInnes if (size == 1) { 54639ddd567SLois Curfman McInnes ierr = MatView(mdn->A,viewer);CHKERRQ(ierr); 5473a40ed3dSBarry Smith } else { 5488965ea79SLois Curfman McInnes /* assemble the entire matrix onto first processor. */ 5498965ea79SLois Curfman McInnes Mat A; 550273d9f13SBarry Smith int M = mat->M,N = mat->N,m,row,i,nz,*cols; 55187828ca2SBarry Smith PetscScalar *vals; 5528965ea79SLois Curfman McInnes 5538965ea79SLois Curfman McInnes if (!rank) { 554f1af5d2fSBarry Smith ierr = MatCreateMPIDense(mat->comm,M,N,M,N,PETSC_NULL,&A);CHKERRQ(ierr); 5553a40ed3dSBarry Smith } else { 556f1af5d2fSBarry Smith ierr = MatCreateMPIDense(mat->comm,0,0,M,N,PETSC_NULL,&A);CHKERRQ(ierr); 5578965ea79SLois Curfman McInnes } 558b0a32e0cSBarry Smith PetscLogObjectParent(mat,A); 5598965ea79SLois Curfman McInnes 56039ddd567SLois Curfman McInnes /* Copy the matrix ... This isn't the most efficient means, 56139ddd567SLois Curfman McInnes but it's quick for now */ 562273d9f13SBarry Smith row = mdn->rstart; m = mdn->A->m; 5638965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 56439ddd567SLois Curfman McInnes ierr = MatGetRow(mat,row,&nz,&cols,&vals);CHKERRQ(ierr); 56539ddd567SLois Curfman McInnes ierr = MatSetValues(A,1,&row,nz,cols,vals,INSERT_VALUES);CHKERRQ(ierr); 56639ddd567SLois Curfman McInnes ierr = MatRestoreRow(mat,row,&nz,&cols,&vals);CHKERRQ(ierr); 56739ddd567SLois Curfman McInnes row++; 5688965ea79SLois Curfman McInnes } 5698965ea79SLois Curfman McInnes 5706d4a8577SBarry Smith ierr = MatAssemblyBegin(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 5716d4a8577SBarry Smith ierr = MatAssemblyEnd(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 572b0a32e0cSBarry Smith ierr = PetscViewerGetSingleton(viewer,&sviewer);CHKERRQ(ierr); 573b9b97703SBarry Smith if (!rank) { 5746831982aSBarry Smith ierr = MatView(((Mat_MPIDense*)(A->data))->A,sviewer);CHKERRQ(ierr); 5758965ea79SLois Curfman McInnes } 576b0a32e0cSBarry Smith ierr = PetscViewerRestoreSingleton(viewer,&sviewer);CHKERRQ(ierr); 577b0a32e0cSBarry Smith ierr = PetscViewerFlush(viewer);CHKERRQ(ierr); 5788965ea79SLois Curfman McInnes ierr = MatDestroy(A);CHKERRQ(ierr); 5798965ea79SLois Curfman McInnes } 5803a40ed3dSBarry Smith PetscFunctionReturn(0); 5818965ea79SLois Curfman McInnes } 5828965ea79SLois Curfman McInnes 5834a2ae208SSatish Balay #undef __FUNCT__ 5844a2ae208SSatish Balay #define __FUNCT__ "MatView_MPIDense" 585b0a32e0cSBarry Smith int MatView_MPIDense(Mat mat,PetscViewer viewer) 5868965ea79SLois Curfman McInnes { 58739ddd567SLois Curfman McInnes int ierr; 588f1af5d2fSBarry Smith PetscTruth isascii,isbinary,isdraw,issocket; 5898965ea79SLois Curfman McInnes 590433994e6SBarry Smith PetscFunctionBegin; 5910f5bd95cSBarry Smith 592b0a32e0cSBarry Smith ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_ASCII,&isascii);CHKERRQ(ierr); 593fb9695e5SSatish Balay ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_BINARY,&isbinary);CHKERRQ(ierr); 594b0a32e0cSBarry Smith ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_SOCKET,&issocket);CHKERRQ(ierr); 595fb9695e5SSatish Balay ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_DRAW,&isdraw);CHKERRQ(ierr); 5960f5bd95cSBarry Smith 597f1af5d2fSBarry Smith if (isascii || issocket || isdraw) { 598f1af5d2fSBarry Smith ierr = MatView_MPIDense_ASCIIorDraworSocket(mat,viewer);CHKERRQ(ierr); 5990f5bd95cSBarry Smith } else if (isbinary) { 6003a40ed3dSBarry Smith ierr = MatView_MPIDense_Binary(mat,viewer);CHKERRQ(ierr); 6015cd90555SBarry Smith } else { 60229bbc08cSBarry Smith SETERRQ1(1,"Viewer type %s not supported by MPI dense matrix",((PetscObject)viewer)->type_name); 6038965ea79SLois Curfman McInnes } 6043a40ed3dSBarry Smith PetscFunctionReturn(0); 6058965ea79SLois Curfman McInnes } 6068965ea79SLois Curfman McInnes 6074a2ae208SSatish Balay #undef __FUNCT__ 6084a2ae208SSatish Balay #define __FUNCT__ "MatGetInfo_MPIDense" 6098f6be9afSLois Curfman McInnes int MatGetInfo_MPIDense(Mat A,MatInfoType flag,MatInfo *info) 6108965ea79SLois Curfman McInnes { 6113501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense*)A->data; 6123501a2bdSLois Curfman McInnes Mat mdn = mat->A; 6134e220ebcSLois Curfman McInnes int ierr; 614329f5518SBarry Smith PetscReal isend[5],irecv[5]; 6158965ea79SLois Curfman McInnes 6163a40ed3dSBarry Smith PetscFunctionBegin; 617273d9f13SBarry Smith info->rows_global = (double)A->M; 618273d9f13SBarry Smith info->columns_global = (double)A->N; 619273d9f13SBarry Smith info->rows_local = (double)A->m; 620273d9f13SBarry Smith info->columns_local = (double)A->N; 6214e220ebcSLois Curfman McInnes info->block_size = 1.0; 6224e220ebcSLois Curfman McInnes ierr = MatGetInfo(mdn,MAT_LOCAL,info);CHKERRQ(ierr); 6234e220ebcSLois Curfman McInnes isend[0] = info->nz_used; isend[1] = info->nz_allocated; isend[2] = info->nz_unneeded; 6244e220ebcSLois Curfman McInnes isend[3] = info->memory; isend[4] = info->mallocs; 6258965ea79SLois Curfman McInnes if (flag == MAT_LOCAL) { 6264e220ebcSLois Curfman McInnes info->nz_used = isend[0]; 6274e220ebcSLois Curfman McInnes info->nz_allocated = isend[1]; 6284e220ebcSLois Curfman McInnes info->nz_unneeded = isend[2]; 6294e220ebcSLois Curfman McInnes info->memory = isend[3]; 6304e220ebcSLois Curfman McInnes info->mallocs = isend[4]; 6318965ea79SLois Curfman McInnes } else if (flag == MAT_GLOBAL_MAX) { 632d7d1e502SBarry Smith ierr = MPI_Allreduce(isend,irecv,5,MPIU_REAL,MPI_MAX,A->comm);CHKERRQ(ierr); 6334e220ebcSLois Curfman McInnes info->nz_used = irecv[0]; 6344e220ebcSLois Curfman McInnes info->nz_allocated = irecv[1]; 6354e220ebcSLois Curfman McInnes info->nz_unneeded = irecv[2]; 6364e220ebcSLois Curfman McInnes info->memory = irecv[3]; 6374e220ebcSLois Curfman McInnes info->mallocs = irecv[4]; 6388965ea79SLois Curfman McInnes } else if (flag == MAT_GLOBAL_SUM) { 639d7d1e502SBarry Smith ierr = MPI_Allreduce(isend,irecv,5,MPIU_REAL,MPI_SUM,A->comm);CHKERRQ(ierr); 6404e220ebcSLois Curfman McInnes info->nz_used = irecv[0]; 6414e220ebcSLois Curfman McInnes info->nz_allocated = irecv[1]; 6424e220ebcSLois Curfman McInnes info->nz_unneeded = irecv[2]; 6434e220ebcSLois Curfman McInnes info->memory = irecv[3]; 6444e220ebcSLois Curfman McInnes info->mallocs = irecv[4]; 6458965ea79SLois Curfman McInnes } 6464e220ebcSLois Curfman McInnes info->fill_ratio_given = 0; /* no parallel LU/ILU/Cholesky */ 6474e220ebcSLois Curfman McInnes info->fill_ratio_needed = 0; 6484e220ebcSLois Curfman McInnes info->factor_mallocs = 0; 6493a40ed3dSBarry Smith PetscFunctionReturn(0); 6508965ea79SLois Curfman McInnes } 6518965ea79SLois Curfman McInnes 6524a2ae208SSatish Balay #undef __FUNCT__ 6534a2ae208SSatish Balay #define __FUNCT__ "MatSetOption_MPIDense" 6548f6be9afSLois Curfman McInnes int MatSetOption_MPIDense(Mat A,MatOption op) 6558965ea79SLois Curfman McInnes { 65639ddd567SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense*)A->data; 657273d9f13SBarry Smith int ierr; 6588965ea79SLois Curfman McInnes 6593a40ed3dSBarry Smith PetscFunctionBegin; 66012c028f9SKris Buschelman switch (op) { 66112c028f9SKris Buschelman case MAT_NO_NEW_NONZERO_LOCATIONS: 66212c028f9SKris Buschelman case MAT_YES_NEW_NONZERO_LOCATIONS: 66312c028f9SKris Buschelman case MAT_NEW_NONZERO_LOCATION_ERR: 66412c028f9SKris Buschelman case MAT_NEW_NONZERO_ALLOCATION_ERR: 66512c028f9SKris Buschelman case MAT_COLUMNS_SORTED: 66612c028f9SKris Buschelman case MAT_COLUMNS_UNSORTED: 667273d9f13SBarry Smith ierr = MatSetOption(a->A,op);CHKERRQ(ierr); 66812c028f9SKris Buschelman break; 66912c028f9SKris Buschelman case MAT_ROW_ORIENTED: 670273d9f13SBarry Smith a->roworiented = PETSC_TRUE; 671273d9f13SBarry Smith ierr = MatSetOption(a->A,op);CHKERRQ(ierr); 67212c028f9SKris Buschelman break; 67312c028f9SKris Buschelman case MAT_ROWS_SORTED: 67412c028f9SKris Buschelman case MAT_ROWS_UNSORTED: 67512c028f9SKris Buschelman case MAT_YES_NEW_DIAGONALS: 67612c028f9SKris Buschelman case MAT_USE_HASH_TABLE: 677d03495bdSKris Buschelman case MAT_USE_SINGLE_PRECISION_SOLVES: 678b0a32e0cSBarry Smith PetscLogInfo(A,"MatSetOption_MPIDense:Option ignored\n"); 67912c028f9SKris Buschelman break; 68012c028f9SKris Buschelman case MAT_COLUMN_ORIENTED: 681273d9f13SBarry Smith a->roworiented = PETSC_FALSE; 682273d9f13SBarry Smith ierr = MatSetOption(a->A,op);CHKERRQ(ierr); 68312c028f9SKris Buschelman break; 68412c028f9SKris Buschelman case MAT_IGNORE_OFF_PROC_ENTRIES: 685273d9f13SBarry Smith a->donotstash = PETSC_TRUE; 68612c028f9SKris Buschelman break; 68712c028f9SKris Buschelman case MAT_NO_NEW_DIAGONALS: 68829bbc08cSBarry Smith SETERRQ(PETSC_ERR_SUP,"MAT_NO_NEW_DIAGONALS"); 68912c028f9SKris Buschelman default: 69029bbc08cSBarry Smith SETERRQ(PETSC_ERR_SUP,"unknown option"); 6913a40ed3dSBarry Smith } 6923a40ed3dSBarry Smith PetscFunctionReturn(0); 6938965ea79SLois Curfman McInnes } 6948965ea79SLois Curfman McInnes 6954a2ae208SSatish Balay #undef __FUNCT__ 6964a2ae208SSatish Balay #define __FUNCT__ "MatGetRow_MPIDense" 69787828ca2SBarry Smith int MatGetRow_MPIDense(Mat A,int row,int *nz,int **idx,PetscScalar **v) 6988965ea79SLois Curfman McInnes { 6993501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense*)A->data; 7003a40ed3dSBarry Smith int lrow,rstart = mat->rstart,rend = mat->rend,ierr; 7018965ea79SLois Curfman McInnes 7023a40ed3dSBarry Smith PetscFunctionBegin; 70329bbc08cSBarry Smith if (row < rstart || row >= rend) SETERRQ(PETSC_ERR_SUP,"only local rows") 7048965ea79SLois Curfman McInnes lrow = row - rstart; 7053a40ed3dSBarry Smith ierr = MatGetRow(mat->A,lrow,nz,idx,v);CHKERRQ(ierr); 7063a40ed3dSBarry Smith PetscFunctionReturn(0); 7078965ea79SLois Curfman McInnes } 7088965ea79SLois Curfman McInnes 7094a2ae208SSatish Balay #undef __FUNCT__ 7104a2ae208SSatish Balay #define __FUNCT__ "MatRestoreRow_MPIDense" 71187828ca2SBarry Smith int MatRestoreRow_MPIDense(Mat mat,int row,int *nz,int **idx,PetscScalar **v) 7128965ea79SLois Curfman McInnes { 713606d414cSSatish Balay int ierr; 714606d414cSSatish Balay 7153a40ed3dSBarry Smith PetscFunctionBegin; 716606d414cSSatish Balay if (idx) {ierr = PetscFree(*idx);CHKERRQ(ierr);} 717606d414cSSatish Balay if (v) {ierr = PetscFree(*v);CHKERRQ(ierr);} 7183a40ed3dSBarry Smith PetscFunctionReturn(0); 7198965ea79SLois Curfman McInnes } 7208965ea79SLois Curfman McInnes 7214a2ae208SSatish Balay #undef __FUNCT__ 7224a2ae208SSatish Balay #define __FUNCT__ "MatDiagonalScale_MPIDense" 7235b2fa520SLois Curfman McInnes int MatDiagonalScale_MPIDense(Mat A,Vec ll,Vec rr) 7245b2fa520SLois Curfman McInnes { 7255b2fa520SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)A->data; 7265b2fa520SLois Curfman McInnes Mat_SeqDense *mat = (Mat_SeqDense*)mdn->A->data; 72787828ca2SBarry Smith PetscScalar *l,*r,x,*v; 728273d9f13SBarry Smith int ierr,i,j,s2a,s3a,s2,s3,m=mdn->A->m,n=mdn->A->n; 7295b2fa520SLois Curfman McInnes 7305b2fa520SLois Curfman McInnes PetscFunctionBegin; 73172d926a5SLois Curfman McInnes ierr = MatGetLocalSize(A,&s2,&s3);CHKERRQ(ierr); 7325b2fa520SLois Curfman McInnes if (ll) { 73372d926a5SLois Curfman McInnes ierr = VecGetLocalSize(ll,&s2a);CHKERRQ(ierr); 73429bbc08cSBarry Smith if (s2a != s2) SETERRQ(PETSC_ERR_ARG_SIZ,"Left scaling vector non-conforming local size"); 7355b2fa520SLois Curfman McInnes ierr = VecGetArray(ll,&l);CHKERRQ(ierr); 7365b2fa520SLois Curfman McInnes for (i=0; i<m; i++) { 7375b2fa520SLois Curfman McInnes x = l[i]; 7385b2fa520SLois Curfman McInnes v = mat->v + i; 7395b2fa520SLois Curfman McInnes for (j=0; j<n; j++) { (*v) *= x; v+= m;} 7405b2fa520SLois Curfman McInnes } 7415b2fa520SLois Curfman McInnes ierr = VecRestoreArray(ll,&l);CHKERRQ(ierr); 742b0a32e0cSBarry Smith PetscLogFlops(n*m); 7435b2fa520SLois Curfman McInnes } 7445b2fa520SLois Curfman McInnes if (rr) { 74572d926a5SLois Curfman McInnes ierr = VecGetSize(rr,&s3a);CHKERRQ(ierr); 74629bbc08cSBarry Smith if (s3a != s3) SETERRQ(PETSC_ERR_ARG_SIZ,"Right scaling vec non-conforming local size"); 7475b2fa520SLois Curfman McInnes ierr = VecScatterBegin(rr,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr); 7485b2fa520SLois Curfman McInnes ierr = VecScatterEnd(rr,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr); 7495b2fa520SLois Curfman McInnes ierr = VecGetArray(mdn->lvec,&r);CHKERRQ(ierr); 7505b2fa520SLois Curfman McInnes for (i=0; i<n; i++) { 7515b2fa520SLois Curfman McInnes x = r[i]; 7525b2fa520SLois Curfman McInnes v = mat->v + i*m; 7535b2fa520SLois Curfman McInnes for (j=0; j<m; j++) { (*v++) *= x;} 7545b2fa520SLois Curfman McInnes } 75572d926a5SLois Curfman McInnes ierr = VecRestoreArray(mdn->lvec,&r);CHKERRQ(ierr); 756b0a32e0cSBarry Smith PetscLogFlops(n*m); 7575b2fa520SLois Curfman McInnes } 7585b2fa520SLois Curfman McInnes PetscFunctionReturn(0); 7595b2fa520SLois Curfman McInnes } 7605b2fa520SLois Curfman McInnes 7614a2ae208SSatish Balay #undef __FUNCT__ 7624a2ae208SSatish Balay #define __FUNCT__ "MatNorm_MPIDense" 763064f8208SBarry Smith int MatNorm_MPIDense(Mat A,NormType type,PetscReal *nrm) 764096963f5SLois Curfman McInnes { 7653501a2bdSLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense*)A->data; 7663501a2bdSLois Curfman McInnes Mat_SeqDense *mat = (Mat_SeqDense*)mdn->A->data; 7673501a2bdSLois Curfman McInnes int ierr,i,j; 768329f5518SBarry Smith PetscReal sum = 0.0; 76987828ca2SBarry Smith PetscScalar *v = mat->v; 7703501a2bdSLois Curfman McInnes 7713a40ed3dSBarry Smith PetscFunctionBegin; 7723501a2bdSLois Curfman McInnes if (mdn->size == 1) { 773064f8208SBarry Smith ierr = MatNorm(mdn->A,type,nrm);CHKERRQ(ierr); 7743501a2bdSLois Curfman McInnes } else { 7753501a2bdSLois Curfman McInnes if (type == NORM_FROBENIUS) { 776273d9f13SBarry Smith for (i=0; i<mdn->A->n*mdn->A->m; i++) { 777aa482453SBarry Smith #if defined(PETSC_USE_COMPLEX) 778329f5518SBarry Smith sum += PetscRealPart(PetscConj(*v)*(*v)); v++; 7793501a2bdSLois Curfman McInnes #else 7803501a2bdSLois Curfman McInnes sum += (*v)*(*v); v++; 7813501a2bdSLois Curfman McInnes #endif 7823501a2bdSLois Curfman McInnes } 783064f8208SBarry Smith ierr = MPI_Allreduce(&sum,nrm,1,MPIU_REAL,MPI_SUM,A->comm);CHKERRQ(ierr); 784064f8208SBarry Smith *nrm = sqrt(*nrm); 785b0a32e0cSBarry Smith PetscLogFlops(2*mdn->A->n*mdn->A->m); 7863a40ed3dSBarry Smith } else if (type == NORM_1) { 787329f5518SBarry Smith PetscReal *tmp,*tmp2; 788b0a32e0cSBarry Smith ierr = PetscMalloc(2*A->N*sizeof(PetscReal),&tmp);CHKERRQ(ierr); 789273d9f13SBarry Smith tmp2 = tmp + A->N; 790273d9f13SBarry Smith ierr = PetscMemzero(tmp,2*A->N*sizeof(PetscReal));CHKERRQ(ierr); 791064f8208SBarry Smith *nrm = 0.0; 7923501a2bdSLois Curfman McInnes v = mat->v; 793273d9f13SBarry Smith for (j=0; j<mdn->A->n; j++) { 794273d9f13SBarry Smith for (i=0; i<mdn->A->m; i++) { 79567e560aaSBarry Smith tmp[j] += PetscAbsScalar(*v); v++; 7963501a2bdSLois Curfman McInnes } 7973501a2bdSLois Curfman McInnes } 798d7d1e502SBarry Smith ierr = MPI_Allreduce(tmp,tmp2,A->N,MPIU_REAL,MPI_SUM,A->comm);CHKERRQ(ierr); 799273d9f13SBarry Smith for (j=0; j<A->N; j++) { 800064f8208SBarry Smith if (tmp2[j] > *nrm) *nrm = tmp2[j]; 8013501a2bdSLois Curfman McInnes } 802606d414cSSatish Balay ierr = PetscFree(tmp);CHKERRQ(ierr); 803b0a32e0cSBarry Smith PetscLogFlops(A->n*A->m); 8043a40ed3dSBarry Smith } else if (type == NORM_INFINITY) { /* max row norm */ 805329f5518SBarry Smith PetscReal ntemp; 8063501a2bdSLois Curfman McInnes ierr = MatNorm(mdn->A,type,&ntemp);CHKERRQ(ierr); 807064f8208SBarry Smith ierr = MPI_Allreduce(&ntemp,nrm,1,MPIU_REAL,MPI_MAX,A->comm);CHKERRQ(ierr); 8083a40ed3dSBarry Smith } else { 80929bbc08cSBarry Smith SETERRQ(PETSC_ERR_SUP,"No support for two norm"); 8103501a2bdSLois Curfman McInnes } 8113501a2bdSLois Curfman McInnes } 8123a40ed3dSBarry Smith PetscFunctionReturn(0); 8133501a2bdSLois Curfman McInnes } 8143501a2bdSLois Curfman McInnes 8154a2ae208SSatish Balay #undef __FUNCT__ 8164a2ae208SSatish Balay #define __FUNCT__ "MatTranspose_MPIDense" 8178f6be9afSLois Curfman McInnes int MatTranspose_MPIDense(Mat A,Mat *matout) 8183501a2bdSLois Curfman McInnes { 8193501a2bdSLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense*)A->data; 8203501a2bdSLois Curfman McInnes Mat_SeqDense *Aloc = (Mat_SeqDense*)a->A->data; 8213501a2bdSLois Curfman McInnes Mat B; 822273d9f13SBarry Smith int M = A->M,N = A->N,m,n,*rwork,rstart = a->rstart; 8233501a2bdSLois Curfman McInnes int j,i,ierr; 82487828ca2SBarry Smith PetscScalar *v; 8253501a2bdSLois Curfman McInnes 8263a40ed3dSBarry Smith PetscFunctionBegin; 8277c922b88SBarry Smith if (!matout && M != N) { 82829bbc08cSBarry Smith SETERRQ(PETSC_ERR_SUP,"Supports square matrix only in-place"); 8297056b6fcSBarry Smith } 8307056b6fcSBarry Smith ierr = MatCreateMPIDense(A->comm,PETSC_DECIDE,PETSC_DECIDE,N,M,PETSC_NULL,&B);CHKERRQ(ierr); 8313501a2bdSLois Curfman McInnes 832273d9f13SBarry Smith m = a->A->m; n = a->A->n; v = Aloc->v; 833b0a32e0cSBarry Smith ierr = PetscMalloc(n*sizeof(int),&rwork);CHKERRQ(ierr); 8343501a2bdSLois Curfman McInnes for (j=0; j<n; j++) { 8353501a2bdSLois Curfman McInnes for (i=0; i<m; i++) rwork[i] = rstart + i; 8363501a2bdSLois Curfman McInnes ierr = MatSetValues(B,1,&j,m,rwork,v,INSERT_VALUES);CHKERRQ(ierr); 8373501a2bdSLois Curfman McInnes v += m; 8383501a2bdSLois Curfman McInnes } 839606d414cSSatish Balay ierr = PetscFree(rwork);CHKERRQ(ierr); 8406d4a8577SBarry Smith ierr = MatAssemblyBegin(B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 8416d4a8577SBarry Smith ierr = MatAssemblyEnd(B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 8427c922b88SBarry Smith if (matout) { 8433501a2bdSLois Curfman McInnes *matout = B; 8443501a2bdSLois Curfman McInnes } else { 845273d9f13SBarry Smith ierr = MatHeaderCopy(A,B);CHKERRQ(ierr); 8463501a2bdSLois Curfman McInnes } 8473a40ed3dSBarry Smith PetscFunctionReturn(0); 848096963f5SLois Curfman McInnes } 849096963f5SLois Curfman McInnes 850d9eff348SSatish Balay #include "petscblaslapack.h" 8514a2ae208SSatish Balay #undef __FUNCT__ 8524a2ae208SSatish Balay #define __FUNCT__ "MatScale_MPIDense" 85387828ca2SBarry Smith int MatScale_MPIDense(PetscScalar *alpha,Mat inA) 85444cd7ae7SLois Curfman McInnes { 85544cd7ae7SLois Curfman McInnes Mat_MPIDense *A = (Mat_MPIDense*)inA->data; 85644cd7ae7SLois Curfman McInnes Mat_SeqDense *a = (Mat_SeqDense*)A->A->data; 85744cd7ae7SLois Curfman McInnes int one = 1,nz; 85844cd7ae7SLois Curfman McInnes 8593a40ed3dSBarry Smith PetscFunctionBegin; 860273d9f13SBarry Smith nz = inA->m*inA->N; 86144cd7ae7SLois Curfman McInnes BLscal_(&nz,alpha,a->v,&one); 862b0a32e0cSBarry Smith PetscLogFlops(nz); 8633a40ed3dSBarry Smith PetscFunctionReturn(0); 86444cd7ae7SLois Curfman McInnes } 86544cd7ae7SLois Curfman McInnes 8665609ef8eSBarry Smith static int MatDuplicate_MPIDense(Mat,MatDuplicateOption,Mat *); 867ca44d042SBarry Smith EXTERN int MatGetSubMatrices_MPIDense(Mat,int,IS *,IS *,MatReuse,Mat **); 8688965ea79SLois Curfman McInnes 8694a2ae208SSatish Balay #undef __FUNCT__ 8704a2ae208SSatish Balay #define __FUNCT__ "MatSetUpPreallocation_MPIDense" 871273d9f13SBarry Smith int MatSetUpPreallocation_MPIDense(Mat A) 872273d9f13SBarry Smith { 873273d9f13SBarry Smith int ierr; 874273d9f13SBarry Smith 875273d9f13SBarry Smith PetscFunctionBegin; 876273d9f13SBarry Smith ierr = MatMPIDenseSetPreallocation(A,0);CHKERRQ(ierr); 877273d9f13SBarry Smith PetscFunctionReturn(0); 878273d9f13SBarry Smith } 879273d9f13SBarry Smith 8808965ea79SLois Curfman McInnes /* -------------------------------------------------------------------*/ 88109dc0095SBarry Smith static struct _MatOps MatOps_Values = {MatSetValues_MPIDense, 88209dc0095SBarry Smith MatGetRow_MPIDense, 88309dc0095SBarry Smith MatRestoreRow_MPIDense, 88409dc0095SBarry Smith MatMult_MPIDense, 88509dc0095SBarry Smith MatMultAdd_MPIDense, 8867c922b88SBarry Smith MatMultTranspose_MPIDense, 8877c922b88SBarry Smith MatMultTransposeAdd_MPIDense, 8888965ea79SLois Curfman McInnes 0, 88909dc0095SBarry Smith 0, 89009dc0095SBarry Smith 0, 89109dc0095SBarry Smith 0, 89209dc0095SBarry Smith 0, 89309dc0095SBarry Smith 0, 89409dc0095SBarry Smith 0, 89509dc0095SBarry Smith MatTranspose_MPIDense, 89609dc0095SBarry Smith MatGetInfo_MPIDense,0, 89709dc0095SBarry Smith MatGetDiagonal_MPIDense, 8985b2fa520SLois Curfman McInnes MatDiagonalScale_MPIDense, 89909dc0095SBarry Smith MatNorm_MPIDense, 90009dc0095SBarry Smith MatAssemblyBegin_MPIDense, 90109dc0095SBarry Smith MatAssemblyEnd_MPIDense, 90209dc0095SBarry Smith 0, 90309dc0095SBarry Smith MatSetOption_MPIDense, 90409dc0095SBarry Smith MatZeroEntries_MPIDense, 90509dc0095SBarry Smith MatZeroRows_MPIDense, 90609dc0095SBarry Smith 0, 90709dc0095SBarry Smith 0, 90809dc0095SBarry Smith 0, 90909dc0095SBarry Smith 0, 910273d9f13SBarry Smith MatSetUpPreallocation_MPIDense, 911273d9f13SBarry Smith 0, 91209dc0095SBarry Smith 0, 91309dc0095SBarry Smith MatGetArray_MPIDense, 91409dc0095SBarry Smith MatRestoreArray_MPIDense, 9155609ef8eSBarry Smith MatDuplicate_MPIDense, 91609dc0095SBarry Smith 0, 91709dc0095SBarry Smith 0, 91809dc0095SBarry Smith 0, 91909dc0095SBarry Smith 0, 92009dc0095SBarry Smith 0, 9212ce60cd0SSatish Balay MatGetSubMatrices_MPIDense, 92209dc0095SBarry Smith 0, 92309dc0095SBarry Smith MatGetValues_MPIDense, 92409dc0095SBarry Smith 0, 92509dc0095SBarry Smith 0, 92609dc0095SBarry Smith MatScale_MPIDense, 92709dc0095SBarry Smith 0, 92809dc0095SBarry Smith 0, 92909dc0095SBarry Smith 0, 93009dc0095SBarry Smith MatGetBlockSize_MPIDense, 93109dc0095SBarry Smith 0, 93209dc0095SBarry Smith 0, 93309dc0095SBarry Smith 0, 93409dc0095SBarry Smith 0, 93509dc0095SBarry Smith 0, 93609dc0095SBarry Smith 0, 93709dc0095SBarry Smith 0, 93809dc0095SBarry Smith 0, 93909dc0095SBarry Smith 0, 940ca3fa75bSLois Curfman McInnes MatGetSubMatrix_MPIDense, 941b9b97703SBarry Smith MatDestroy_MPIDense, 942b9b97703SBarry Smith MatView_MPIDense, 9438a124369SBarry Smith MatGetPetscMaps_Petsc}; 9448965ea79SLois Curfman McInnes 945273d9f13SBarry Smith EXTERN_C_BEGIN 9464a2ae208SSatish Balay #undef __FUNCT__ 9474a2ae208SSatish Balay #define __FUNCT__ "MatCreate_MPIDense" 948273d9f13SBarry Smith int MatCreate_MPIDense(Mat mat) 949273d9f13SBarry Smith { 950273d9f13SBarry Smith Mat_MPIDense *a; 951273d9f13SBarry Smith int ierr,i; 952273d9f13SBarry Smith 953273d9f13SBarry Smith PetscFunctionBegin; 954b0a32e0cSBarry Smith ierr = PetscNew(Mat_MPIDense,&a);CHKERRQ(ierr); 955b0a32e0cSBarry Smith mat->data = (void*)a; 956273d9f13SBarry Smith ierr = PetscMemcpy(mat->ops,&MatOps_Values,sizeof(struct _MatOps));CHKERRQ(ierr); 957273d9f13SBarry Smith mat->factor = 0; 958273d9f13SBarry Smith mat->mapping = 0; 959273d9f13SBarry Smith 960273d9f13SBarry Smith a->factor = 0; 961273d9f13SBarry Smith mat->insertmode = NOT_SET_VALUES; 962273d9f13SBarry Smith ierr = MPI_Comm_rank(mat->comm,&a->rank);CHKERRQ(ierr); 963273d9f13SBarry Smith ierr = MPI_Comm_size(mat->comm,&a->size);CHKERRQ(ierr); 964273d9f13SBarry Smith 965273d9f13SBarry Smith ierr = PetscSplitOwnership(mat->comm,&mat->m,&mat->M);CHKERRQ(ierr); 966273d9f13SBarry Smith ierr = PetscSplitOwnership(mat->comm,&mat->n,&mat->N);CHKERRQ(ierr); 967273d9f13SBarry Smith a->nvec = mat->n; 968273d9f13SBarry Smith 969273d9f13SBarry Smith /* the information in the maps duplicates the information computed below, eventually 970273d9f13SBarry Smith we should remove the duplicate information that is not contained in the maps */ 9718a124369SBarry Smith ierr = PetscMapCreateMPI(mat->comm,mat->m,mat->M,&mat->rmap);CHKERRQ(ierr); 9728a124369SBarry Smith ierr = PetscMapCreateMPI(mat->comm,mat->n,mat->N,&mat->cmap);CHKERRQ(ierr); 973273d9f13SBarry Smith 974273d9f13SBarry Smith /* build local table of row and column ownerships */ 975b0a32e0cSBarry Smith ierr = PetscMalloc(2*(a->size+2)*sizeof(int),&a->rowners);CHKERRQ(ierr); 976273d9f13SBarry Smith a->cowners = a->rowners + a->size + 1; 977b0a32e0cSBarry Smith PetscLogObjectMemory(mat,2*(a->size+2)*sizeof(int)+sizeof(struct _p_Mat)+sizeof(Mat_MPIDense)); 978273d9f13SBarry Smith ierr = MPI_Allgather(&mat->m,1,MPI_INT,a->rowners+1,1,MPI_INT,mat->comm);CHKERRQ(ierr); 979273d9f13SBarry Smith a->rowners[0] = 0; 980273d9f13SBarry Smith for (i=2; i<=a->size; i++) { 981273d9f13SBarry Smith a->rowners[i] += a->rowners[i-1]; 982273d9f13SBarry Smith } 983273d9f13SBarry Smith a->rstart = a->rowners[a->rank]; 984273d9f13SBarry Smith a->rend = a->rowners[a->rank+1]; 985273d9f13SBarry Smith ierr = MPI_Allgather(&mat->n,1,MPI_INT,a->cowners+1,1,MPI_INT,mat->comm);CHKERRQ(ierr); 986273d9f13SBarry Smith a->cowners[0] = 0; 987273d9f13SBarry Smith for (i=2; i<=a->size; i++) { 988273d9f13SBarry Smith a->cowners[i] += a->cowners[i-1]; 989273d9f13SBarry Smith } 990273d9f13SBarry Smith 991273d9f13SBarry Smith /* build cache for off array entries formed */ 992273d9f13SBarry Smith a->donotstash = PETSC_FALSE; 993273d9f13SBarry Smith ierr = MatStashCreate_Private(mat->comm,1,&mat->stash);CHKERRQ(ierr); 994273d9f13SBarry Smith 995273d9f13SBarry Smith /* stuff used for matrix vector multiply */ 996273d9f13SBarry Smith a->lvec = 0; 997273d9f13SBarry Smith a->Mvctx = 0; 998273d9f13SBarry Smith a->roworiented = PETSC_TRUE; 999273d9f13SBarry Smith 1000273d9f13SBarry Smith ierr = PetscObjectComposeFunctionDynamic((PetscObject)mat,"MatGetDiagonalBlock_C", 1001273d9f13SBarry Smith "MatGetDiagonalBlock_MPIDense", 1002273d9f13SBarry Smith MatGetDiagonalBlock_MPIDense);CHKERRQ(ierr); 1003273d9f13SBarry Smith PetscFunctionReturn(0); 1004273d9f13SBarry Smith } 1005273d9f13SBarry Smith EXTERN_C_END 1006273d9f13SBarry Smith 10074a2ae208SSatish Balay #undef __FUNCT__ 10084a2ae208SSatish Balay #define __FUNCT__ "MatMPIDenseSetPreallocation" 1009273d9f13SBarry Smith /*@C 1010273d9f13SBarry Smith MatMPIDenseSetPreallocation - Sets the array used to store the matrix entries 1011273d9f13SBarry Smith 1012273d9f13SBarry Smith Not collective 1013273d9f13SBarry Smith 1014273d9f13SBarry Smith Input Parameters: 1015273d9f13SBarry Smith . A - the matrix 1016273d9f13SBarry Smith - data - optional location of matrix data. Set data=PETSC_NULL for PETSc 1017273d9f13SBarry Smith to control all matrix memory allocation. 1018273d9f13SBarry Smith 1019273d9f13SBarry Smith Notes: 1020273d9f13SBarry Smith The dense format is fully compatible with standard Fortran 77 1021273d9f13SBarry Smith storage by columns. 1022273d9f13SBarry Smith 1023273d9f13SBarry Smith The data input variable is intended primarily for Fortran programmers 1024273d9f13SBarry Smith who wish to allocate their own matrix memory space. Most users should 1025273d9f13SBarry Smith set data=PETSC_NULL. 1026273d9f13SBarry Smith 1027273d9f13SBarry Smith Level: intermediate 1028273d9f13SBarry Smith 1029273d9f13SBarry Smith .keywords: matrix,dense, parallel 1030273d9f13SBarry Smith 1031273d9f13SBarry Smith .seealso: MatCreate(), MatCreateSeqDense(), MatSetValues() 1032273d9f13SBarry Smith @*/ 103387828ca2SBarry Smith int MatMPIDenseSetPreallocation(Mat mat,PetscScalar *data) 1034273d9f13SBarry Smith { 1035273d9f13SBarry Smith Mat_MPIDense *a; 1036273d9f13SBarry Smith int ierr; 1037273d9f13SBarry Smith PetscTruth flg2; 1038273d9f13SBarry Smith 1039273d9f13SBarry Smith PetscFunctionBegin; 1040273d9f13SBarry Smith ierr = PetscTypeCompare((PetscObject)mat,MATMPIDENSE,&flg2);CHKERRQ(ierr); 1041273d9f13SBarry Smith if (!flg2) PetscFunctionReturn(0); 1042273d9f13SBarry Smith mat->preallocated = PETSC_TRUE; 1043273d9f13SBarry Smith /* Note: For now, when data is specified above, this assumes the user correctly 1044273d9f13SBarry Smith allocates the local dense storage space. We should add error checking. */ 1045273d9f13SBarry Smith 1046273d9f13SBarry Smith a = (Mat_MPIDense*)mat->data; 1047273d9f13SBarry Smith ierr = MatCreateSeqDense(PETSC_COMM_SELF,mat->m,mat->N,data,&a->A);CHKERRQ(ierr); 1048b0a32e0cSBarry Smith PetscLogObjectParent(mat,a->A); 1049273d9f13SBarry Smith PetscFunctionReturn(0); 1050273d9f13SBarry Smith } 1051273d9f13SBarry Smith 10524a2ae208SSatish Balay #undef __FUNCT__ 10534a2ae208SSatish Balay #define __FUNCT__ "MatCreateMPIDense" 10548965ea79SLois Curfman McInnes /*@C 105539ddd567SLois Curfman McInnes MatCreateMPIDense - Creates a sparse parallel matrix in dense format. 10568965ea79SLois Curfman McInnes 1057db81eaa0SLois Curfman McInnes Collective on MPI_Comm 1058db81eaa0SLois Curfman McInnes 10598965ea79SLois Curfman McInnes Input Parameters: 1060db81eaa0SLois Curfman McInnes + comm - MPI communicator 10618965ea79SLois Curfman McInnes . m - number of local rows (or PETSC_DECIDE to have calculated if M is given) 1062db81eaa0SLois Curfman McInnes . n - number of local columns (or PETSC_DECIDE to have calculated if N is given) 10638965ea79SLois Curfman McInnes . M - number of global rows (or PETSC_DECIDE to have calculated if m is given) 1064db81eaa0SLois Curfman McInnes . N - number of global columns (or PETSC_DECIDE to have calculated if n is given) 10657f5ff6fdSBarry Smith - data - optional location of matrix data. Set data=PETSC_NULL (PETSC_NULL_SCALAR for Fortran users) for PETSc 1066dfc5480cSLois Curfman McInnes to control all matrix memory allocation. 10678965ea79SLois Curfman McInnes 10688965ea79SLois Curfman McInnes Output Parameter: 1069477f1c0bSLois Curfman McInnes . A - the matrix 10708965ea79SLois Curfman McInnes 1071b259b22eSLois Curfman McInnes Notes: 107239ddd567SLois Curfman McInnes The dense format is fully compatible with standard Fortran 77 107339ddd567SLois Curfman McInnes storage by columns. 10748965ea79SLois Curfman McInnes 107518f449edSLois Curfman McInnes The data input variable is intended primarily for Fortran programmers 107618f449edSLois Curfman McInnes who wish to allocate their own matrix memory space. Most users should 10777f5ff6fdSBarry Smith set data=PETSC_NULL (PETSC_NULL_SCALAR for Fortran users). 107818f449edSLois Curfman McInnes 10798965ea79SLois Curfman McInnes The user MUST specify either the local or global matrix dimensions 10808965ea79SLois Curfman McInnes (possibly both). 10818965ea79SLois Curfman McInnes 1082027ccd11SLois Curfman McInnes Level: intermediate 1083027ccd11SLois Curfman McInnes 108439ddd567SLois Curfman McInnes .keywords: matrix,dense, parallel 10858965ea79SLois Curfman McInnes 108639ddd567SLois Curfman McInnes .seealso: MatCreate(), MatCreateSeqDense(), MatSetValues() 10878965ea79SLois Curfman McInnes @*/ 108887828ca2SBarry Smith int MatCreateMPIDense(MPI_Comm comm,int m,int n,int M,int N,PetscScalar *data,Mat *A) 10898965ea79SLois Curfman McInnes { 1090273d9f13SBarry Smith int ierr,size; 10918965ea79SLois Curfman McInnes 10923a40ed3dSBarry Smith PetscFunctionBegin; 1093273d9f13SBarry Smith ierr = MatCreate(comm,m,n,M,N,A);CHKERRQ(ierr); 1094273d9f13SBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1095273d9f13SBarry Smith if (size > 1) { 1096273d9f13SBarry Smith ierr = MatSetType(*A,MATMPIDENSE);CHKERRQ(ierr); 1097273d9f13SBarry Smith ierr = MatMPIDenseSetPreallocation(*A,data);CHKERRQ(ierr); 1098273d9f13SBarry Smith } else { 1099273d9f13SBarry Smith ierr = MatSetType(*A,MATSEQDENSE);CHKERRQ(ierr); 1100273d9f13SBarry Smith ierr = MatSeqDenseSetPreallocation(*A,data);CHKERRQ(ierr); 11018c469469SLois Curfman McInnes } 11023a40ed3dSBarry Smith PetscFunctionReturn(0); 11038965ea79SLois Curfman McInnes } 11048965ea79SLois Curfman McInnes 11054a2ae208SSatish Balay #undef __FUNCT__ 11064a2ae208SSatish Balay #define __FUNCT__ "MatDuplicate_MPIDense" 11075609ef8eSBarry Smith static int MatDuplicate_MPIDense(Mat A,MatDuplicateOption cpvalues,Mat *newmat) 11088965ea79SLois Curfman McInnes { 11098965ea79SLois Curfman McInnes Mat mat; 11103501a2bdSLois Curfman McInnes Mat_MPIDense *a,*oldmat = (Mat_MPIDense*)A->data; 111139ddd567SLois Curfman McInnes int ierr; 11128965ea79SLois Curfman McInnes 11133a40ed3dSBarry Smith PetscFunctionBegin; 11148965ea79SLois Curfman McInnes *newmat = 0; 1115273d9f13SBarry Smith ierr = MatCreate(A->comm,A->m,A->n,A->M,A->N,&mat);CHKERRQ(ierr); 1116273d9f13SBarry Smith ierr = MatSetType(mat,MATMPIDENSE);CHKERRQ(ierr); 1117b0a32e0cSBarry Smith ierr = PetscNew(Mat_MPIDense,&a);CHKERRQ(ierr); 1118b0a32e0cSBarry Smith mat->data = (void*)a; 1119549d3d68SSatish Balay ierr = PetscMemcpy(mat->ops,&MatOps_Values,sizeof(struct _MatOps));CHKERRQ(ierr); 11203501a2bdSLois Curfman McInnes mat->factor = A->factor; 1121c456f294SBarry Smith mat->assembled = PETSC_TRUE; 1122273d9f13SBarry Smith mat->preallocated = PETSC_TRUE; 11238965ea79SLois Curfman McInnes 11248965ea79SLois Curfman McInnes a->rstart = oldmat->rstart; 11258965ea79SLois Curfman McInnes a->rend = oldmat->rend; 11268965ea79SLois Curfman McInnes a->size = oldmat->size; 11278965ea79SLois Curfman McInnes a->rank = oldmat->rank; 1128e0fa3b82SLois Curfman McInnes mat->insertmode = NOT_SET_VALUES; 1129b9b97703SBarry Smith a->nvec = oldmat->nvec; 11303782ba37SSatish Balay a->donotstash = oldmat->donotstash; 1131b0a32e0cSBarry Smith ierr = PetscMalloc((a->size+1)*sizeof(int),&a->rowners);CHKERRQ(ierr); 1132b0a32e0cSBarry Smith PetscLogObjectMemory(mat,(a->size+1)*sizeof(int)+sizeof(struct _p_Mat)+sizeof(Mat_MPIDense)); 1133549d3d68SSatish Balay ierr = PetscMemcpy(a->rowners,oldmat->rowners,(a->size+1)*sizeof(int));CHKERRQ(ierr); 11348798bf22SSatish Balay ierr = MatStashCreate_Private(A->comm,1,&mat->stash);CHKERRQ(ierr); 11358965ea79SLois Curfman McInnes 1136329f5518SBarry Smith ierr = MatSetUpMultiply_MPIDense(mat);CHKERRQ(ierr); 11375609ef8eSBarry Smith ierr = MatDuplicate(oldmat->A,cpvalues,&a->A);CHKERRQ(ierr); 1138b0a32e0cSBarry Smith PetscLogObjectParent(mat,a->A); 11398965ea79SLois Curfman McInnes *newmat = mat; 11403a40ed3dSBarry Smith PetscFunctionReturn(0); 11418965ea79SLois Curfman McInnes } 11428965ea79SLois Curfman McInnes 1143e090d566SSatish Balay #include "petscsys.h" 11448965ea79SLois Curfman McInnes 11454a2ae208SSatish Balay #undef __FUNCT__ 11464a2ae208SSatish Balay #define __FUNCT__ "MatLoad_MPIDense_DenseInFile" 114790ace30eSBarry Smith int MatLoad_MPIDense_DenseInFile(MPI_Comm comm,int fd,int M,int N,Mat *newmat) 114890ace30eSBarry Smith { 114940011551SBarry Smith int *rowners,i,size,rank,m,ierr,nz,j; 115087828ca2SBarry Smith PetscScalar *array,*vals,*vals_ptr; 115190ace30eSBarry Smith MPI_Status status; 115290ace30eSBarry Smith 11533a40ed3dSBarry Smith PetscFunctionBegin; 1154d132466eSBarry Smith ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 1155d132466eSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 115690ace30eSBarry Smith 115790ace30eSBarry Smith /* determine ownership of all rows */ 115890ace30eSBarry Smith m = M/size + ((M % size) > rank); 1159b0a32e0cSBarry Smith ierr = PetscMalloc((size+2)*sizeof(int),&rowners);CHKERRQ(ierr); 1160ca161407SBarry Smith ierr = MPI_Allgather(&m,1,MPI_INT,rowners+1,1,MPI_INT,comm);CHKERRQ(ierr); 116190ace30eSBarry Smith rowners[0] = 0; 116290ace30eSBarry Smith for (i=2; i<=size; i++) { 116390ace30eSBarry Smith rowners[i] += rowners[i-1]; 116490ace30eSBarry Smith } 116590ace30eSBarry Smith 116690ace30eSBarry Smith ierr = MatCreateMPIDense(comm,m,PETSC_DECIDE,M,N,PETSC_NULL,newmat);CHKERRQ(ierr); 116790ace30eSBarry Smith ierr = MatGetArray(*newmat,&array);CHKERRQ(ierr); 116890ace30eSBarry Smith 116990ace30eSBarry Smith if (!rank) { 117087828ca2SBarry Smith ierr = PetscMalloc(m*N*sizeof(PetscScalar),&vals);CHKERRQ(ierr); 117190ace30eSBarry Smith 117290ace30eSBarry Smith /* read in my part of the matrix numerical values */ 11730752156aSBarry Smith ierr = PetscBinaryRead(fd,vals,m*N,PETSC_SCALAR);CHKERRQ(ierr); 117490ace30eSBarry Smith 117590ace30eSBarry Smith /* insert into matrix-by row (this is why cannot directly read into array */ 117690ace30eSBarry Smith vals_ptr = vals; 117790ace30eSBarry Smith for (i=0; i<m; i++) { 117890ace30eSBarry Smith for (j=0; j<N; j++) { 117990ace30eSBarry Smith array[i + j*m] = *vals_ptr++; 118090ace30eSBarry Smith } 118190ace30eSBarry Smith } 118290ace30eSBarry Smith 118390ace30eSBarry Smith /* read in other processors and ship out */ 118490ace30eSBarry Smith for (i=1; i<size; i++) { 118590ace30eSBarry Smith nz = (rowners[i+1] - rowners[i])*N; 11860752156aSBarry Smith ierr = PetscBinaryRead(fd,vals,nz,PETSC_SCALAR);CHKERRQ(ierr); 1187ca161407SBarry Smith ierr = MPI_Send(vals,nz,MPIU_SCALAR,i,(*newmat)->tag,comm);CHKERRQ(ierr); 118890ace30eSBarry Smith } 11893a40ed3dSBarry Smith } else { 119090ace30eSBarry Smith /* receive numeric values */ 119187828ca2SBarry Smith ierr = PetscMalloc(m*N*sizeof(PetscScalar),&vals);CHKERRQ(ierr); 119290ace30eSBarry Smith 119390ace30eSBarry Smith /* receive message of values*/ 1194ca161407SBarry Smith ierr = MPI_Recv(vals,m*N,MPIU_SCALAR,0,(*newmat)->tag,comm,&status);CHKERRQ(ierr); 119590ace30eSBarry Smith 119690ace30eSBarry Smith /* insert into matrix-by row (this is why cannot directly read into array */ 119790ace30eSBarry Smith vals_ptr = vals; 119890ace30eSBarry Smith for (i=0; i<m; i++) { 119990ace30eSBarry Smith for (j=0; j<N; j++) { 120090ace30eSBarry Smith array[i + j*m] = *vals_ptr++; 120190ace30eSBarry Smith } 120290ace30eSBarry Smith } 120390ace30eSBarry Smith } 1204606d414cSSatish Balay ierr = PetscFree(rowners);CHKERRQ(ierr); 1205606d414cSSatish Balay ierr = PetscFree(vals);CHKERRQ(ierr); 12066d4a8577SBarry Smith ierr = MatAssemblyBegin(*newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 12076d4a8577SBarry Smith ierr = MatAssemblyEnd(*newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 12083a40ed3dSBarry Smith PetscFunctionReturn(0); 120990ace30eSBarry Smith } 121090ace30eSBarry Smith 1211273d9f13SBarry Smith EXTERN_C_BEGIN 12124a2ae208SSatish Balay #undef __FUNCT__ 12134a2ae208SSatish Balay #define __FUNCT__ "MatLoad_MPIDense" 1214b0a32e0cSBarry Smith int MatLoad_MPIDense(PetscViewer viewer,MatType type,Mat *newmat) 12158965ea79SLois Curfman McInnes { 12168965ea79SLois Curfman McInnes Mat A; 121787828ca2SBarry Smith PetscScalar *vals,*svals; 121819bcc07fSBarry Smith MPI_Comm comm = ((PetscObject)viewer)->comm; 12198965ea79SLois Curfman McInnes MPI_Status status; 12208965ea79SLois Curfman McInnes int header[4],rank,size,*rowlengths = 0,M,N,m,*rowners,maxnz,*cols; 12218965ea79SLois Curfman McInnes int *ourlens,*sndcounts = 0,*procsnz = 0,*offlens,jj,*mycols,*smycols; 122219bcc07fSBarry Smith int tag = ((PetscObject)viewer)->tag; 12233a40ed3dSBarry Smith int i,nz,ierr,j,rstart,rend,fd; 12248965ea79SLois Curfman McInnes 12253a40ed3dSBarry Smith PetscFunctionBegin; 1226d132466eSBarry Smith ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr); 1227d132466eSBarry Smith ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr); 12288965ea79SLois Curfman McInnes if (!rank) { 1229b0a32e0cSBarry Smith ierr = PetscViewerBinaryGetDescriptor(viewer,&fd);CHKERRQ(ierr); 12300752156aSBarry Smith ierr = PetscBinaryRead(fd,(char *)header,4,PETSC_INT);CHKERRQ(ierr); 1231552e946dSBarry Smith if (header[0] != MAT_FILE_COOKIE) SETERRQ(PETSC_ERR_FILE_UNEXPECTED,"not matrix object"); 12328965ea79SLois Curfman McInnes } 12338965ea79SLois Curfman McInnes 1234ca161407SBarry Smith ierr = MPI_Bcast(header+1,3,MPI_INT,0,comm);CHKERRQ(ierr); 123590ace30eSBarry Smith M = header[1]; N = header[2]; nz = header[3]; 123690ace30eSBarry Smith 123790ace30eSBarry Smith /* 123890ace30eSBarry Smith Handle case where matrix is stored on disk as a dense matrix 123990ace30eSBarry Smith */ 124090ace30eSBarry Smith if (nz == MATRIX_BINARY_FORMAT_DENSE) { 12413a40ed3dSBarry Smith ierr = MatLoad_MPIDense_DenseInFile(comm,fd,M,N,newmat);CHKERRQ(ierr); 12423a40ed3dSBarry Smith PetscFunctionReturn(0); 124390ace30eSBarry Smith } 124490ace30eSBarry Smith 12458965ea79SLois Curfman McInnes /* determine ownership of all rows */ 12468965ea79SLois Curfman McInnes m = M/size + ((M % size) > rank); 1247b0a32e0cSBarry Smith ierr = PetscMalloc((size+2)*sizeof(int),&rowners);CHKERRQ(ierr); 1248ca161407SBarry Smith ierr = MPI_Allgather(&m,1,MPI_INT,rowners+1,1,MPI_INT,comm);CHKERRQ(ierr); 12498965ea79SLois Curfman McInnes rowners[0] = 0; 12508965ea79SLois Curfman McInnes for (i=2; i<=size; i++) { 12518965ea79SLois Curfman McInnes rowners[i] += rowners[i-1]; 12528965ea79SLois Curfman McInnes } 12538965ea79SLois Curfman McInnes rstart = rowners[rank]; 12548965ea79SLois Curfman McInnes rend = rowners[rank+1]; 12558965ea79SLois Curfman McInnes 12568965ea79SLois Curfman McInnes /* distribute row lengths to all processors */ 1257b0a32e0cSBarry Smith ierr = PetscMalloc(2*(rend-rstart)*sizeof(int),&ourlens);CHKERRQ(ierr); 12588965ea79SLois Curfman McInnes offlens = ourlens + (rend-rstart); 12598965ea79SLois Curfman McInnes if (!rank) { 1260b0a32e0cSBarry Smith ierr = PetscMalloc(M*sizeof(int),&rowlengths);CHKERRQ(ierr); 12610752156aSBarry Smith ierr = PetscBinaryRead(fd,rowlengths,M,PETSC_INT);CHKERRQ(ierr); 1262b0a32e0cSBarry Smith ierr = PetscMalloc(size*sizeof(int),&sndcounts);CHKERRQ(ierr); 12638965ea79SLois Curfman McInnes for (i=0; i<size; i++) sndcounts[i] = rowners[i+1] - rowners[i]; 1264ca161407SBarry Smith ierr = MPI_Scatterv(rowlengths,sndcounts,rowners,MPI_INT,ourlens,rend-rstart,MPI_INT,0,comm);CHKERRQ(ierr); 1265606d414cSSatish Balay ierr = PetscFree(sndcounts);CHKERRQ(ierr); 1266ca161407SBarry Smith } else { 1267ca161407SBarry Smith ierr = MPI_Scatterv(0,0,0,MPI_INT,ourlens,rend-rstart,MPI_INT,0,comm);CHKERRQ(ierr); 12688965ea79SLois Curfman McInnes } 12698965ea79SLois Curfman McInnes 12708965ea79SLois Curfman McInnes if (!rank) { 12718965ea79SLois Curfman McInnes /* calculate the number of nonzeros on each processor */ 1272b0a32e0cSBarry Smith ierr = PetscMalloc(size*sizeof(int),&procsnz);CHKERRQ(ierr); 1273549d3d68SSatish Balay ierr = PetscMemzero(procsnz,size*sizeof(int));CHKERRQ(ierr); 12748965ea79SLois Curfman McInnes for (i=0; i<size; i++) { 12758965ea79SLois Curfman McInnes for (j=rowners[i]; j< rowners[i+1]; j++) { 12768965ea79SLois Curfman McInnes procsnz[i] += rowlengths[j]; 12778965ea79SLois Curfman McInnes } 12788965ea79SLois Curfman McInnes } 1279606d414cSSatish Balay ierr = PetscFree(rowlengths);CHKERRQ(ierr); 12808965ea79SLois Curfman McInnes 12818965ea79SLois Curfman McInnes /* determine max buffer needed and allocate it */ 12828965ea79SLois Curfman McInnes maxnz = 0; 12838965ea79SLois Curfman McInnes for (i=0; i<size; i++) { 12840452661fSBarry Smith maxnz = PetscMax(maxnz,procsnz[i]); 12858965ea79SLois Curfman McInnes } 1286b0a32e0cSBarry Smith ierr = PetscMalloc(maxnz*sizeof(int),&cols);CHKERRQ(ierr); 12878965ea79SLois Curfman McInnes 12888965ea79SLois Curfman McInnes /* read in my part of the matrix column indices */ 12898965ea79SLois Curfman McInnes nz = procsnz[0]; 1290b0a32e0cSBarry Smith ierr = PetscMalloc(nz*sizeof(int),&mycols);CHKERRQ(ierr); 12910752156aSBarry Smith ierr = PetscBinaryRead(fd,mycols,nz,PETSC_INT);CHKERRQ(ierr); 12928965ea79SLois Curfman McInnes 12938965ea79SLois Curfman McInnes /* read in every one elses and ship off */ 12948965ea79SLois Curfman McInnes for (i=1; i<size; i++) { 12958965ea79SLois Curfman McInnes nz = procsnz[i]; 12960752156aSBarry Smith ierr = PetscBinaryRead(fd,cols,nz,PETSC_INT);CHKERRQ(ierr); 1297ca161407SBarry Smith ierr = MPI_Send(cols,nz,MPI_INT,i,tag,comm);CHKERRQ(ierr); 12988965ea79SLois Curfman McInnes } 1299606d414cSSatish Balay ierr = PetscFree(cols);CHKERRQ(ierr); 13003a40ed3dSBarry Smith } else { 13018965ea79SLois Curfman McInnes /* determine buffer space needed for message */ 13028965ea79SLois Curfman McInnes nz = 0; 13038965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 13048965ea79SLois Curfman McInnes nz += ourlens[i]; 13058965ea79SLois Curfman McInnes } 1306b0a32e0cSBarry Smith ierr = PetscMalloc(nz*sizeof(int),&mycols);CHKERRQ(ierr); 13078965ea79SLois Curfman McInnes 13088965ea79SLois Curfman McInnes /* receive message of column indices*/ 1309ca161407SBarry Smith ierr = MPI_Recv(mycols,nz,MPI_INT,0,tag,comm,&status);CHKERRQ(ierr); 1310ca161407SBarry Smith ierr = MPI_Get_count(&status,MPI_INT,&maxnz);CHKERRQ(ierr); 131129bbc08cSBarry Smith if (maxnz != nz) SETERRQ(PETSC_ERR_FILE_UNEXPECTED,"something is wrong with file"); 13128965ea79SLois Curfman McInnes } 13138965ea79SLois Curfman McInnes 13148965ea79SLois Curfman McInnes /* loop over local rows, determining number of off diagonal entries */ 1315549d3d68SSatish Balay ierr = PetscMemzero(offlens,m*sizeof(int));CHKERRQ(ierr); 13168965ea79SLois Curfman McInnes jj = 0; 13178965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 13188965ea79SLois Curfman McInnes for (j=0; j<ourlens[i]; j++) { 13198965ea79SLois Curfman McInnes if (mycols[jj] < rstart || mycols[jj] >= rend) offlens[i]++; 13208965ea79SLois Curfman McInnes jj++; 13218965ea79SLois Curfman McInnes } 13228965ea79SLois Curfman McInnes } 13238965ea79SLois Curfman McInnes 13248965ea79SLois Curfman McInnes /* create our matrix */ 13258965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 13268965ea79SLois Curfman McInnes ourlens[i] -= offlens[i]; 13278965ea79SLois Curfman McInnes } 1328b4fd4287SBarry Smith ierr = MatCreateMPIDense(comm,m,PETSC_DECIDE,M,N,PETSC_NULL,newmat);CHKERRQ(ierr); 13298965ea79SLois Curfman McInnes A = *newmat; 13308965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 13318965ea79SLois Curfman McInnes ourlens[i] += offlens[i]; 13328965ea79SLois Curfman McInnes } 13338965ea79SLois Curfman McInnes 13348965ea79SLois Curfman McInnes if (!rank) { 133587828ca2SBarry Smith ierr = PetscMalloc(maxnz*sizeof(PetscScalar),&vals);CHKERRQ(ierr); 13368965ea79SLois Curfman McInnes 13378965ea79SLois Curfman McInnes /* read in my part of the matrix numerical values */ 13388965ea79SLois Curfman McInnes nz = procsnz[0]; 13390752156aSBarry Smith ierr = PetscBinaryRead(fd,vals,nz,PETSC_SCALAR);CHKERRQ(ierr); 13408965ea79SLois Curfman McInnes 13418965ea79SLois Curfman McInnes /* insert into matrix */ 13428965ea79SLois Curfman McInnes jj = rstart; 13438965ea79SLois Curfman McInnes smycols = mycols; 13448965ea79SLois Curfman McInnes svals = vals; 13458965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 13468965ea79SLois Curfman McInnes ierr = MatSetValues(A,1,&jj,ourlens[i],smycols,svals,INSERT_VALUES);CHKERRQ(ierr); 13478965ea79SLois Curfman McInnes smycols += ourlens[i]; 13488965ea79SLois Curfman McInnes svals += ourlens[i]; 13498965ea79SLois Curfman McInnes jj++; 13508965ea79SLois Curfman McInnes } 13518965ea79SLois Curfman McInnes 13528965ea79SLois Curfman McInnes /* read in other processors and ship out */ 13538965ea79SLois Curfman McInnes for (i=1; i<size; i++) { 13548965ea79SLois Curfman McInnes nz = procsnz[i]; 13550752156aSBarry Smith ierr = PetscBinaryRead(fd,vals,nz,PETSC_SCALAR);CHKERRQ(ierr); 1356ca161407SBarry Smith ierr = MPI_Send(vals,nz,MPIU_SCALAR,i,A->tag,comm);CHKERRQ(ierr); 13578965ea79SLois Curfman McInnes } 1358606d414cSSatish Balay ierr = PetscFree(procsnz);CHKERRQ(ierr); 13593a40ed3dSBarry Smith } else { 13608965ea79SLois Curfman McInnes /* receive numeric values */ 136187828ca2SBarry Smith ierr = PetscMalloc(nz*sizeof(PetscScalar),&vals);CHKERRQ(ierr); 13628965ea79SLois Curfman McInnes 13638965ea79SLois Curfman McInnes /* receive message of values*/ 1364ca161407SBarry Smith ierr = MPI_Recv(vals,nz,MPIU_SCALAR,0,A->tag,comm,&status);CHKERRQ(ierr); 1365ca161407SBarry Smith ierr = MPI_Get_count(&status,MPIU_SCALAR,&maxnz);CHKERRQ(ierr); 136629bbc08cSBarry Smith if (maxnz != nz) SETERRQ(PETSC_ERR_FILE_UNEXPECTED,"something is wrong with file"); 13678965ea79SLois Curfman McInnes 13688965ea79SLois Curfman McInnes /* insert into matrix */ 13698965ea79SLois Curfman McInnes jj = rstart; 13708965ea79SLois Curfman McInnes smycols = mycols; 13718965ea79SLois Curfman McInnes svals = vals; 13728965ea79SLois Curfman McInnes for (i=0; i<m; i++) { 13738965ea79SLois Curfman McInnes ierr = MatSetValues(A,1,&jj,ourlens[i],smycols,svals,INSERT_VALUES);CHKERRQ(ierr); 13748965ea79SLois Curfman McInnes smycols += ourlens[i]; 13758965ea79SLois Curfman McInnes svals += ourlens[i]; 13768965ea79SLois Curfman McInnes jj++; 13778965ea79SLois Curfman McInnes } 13788965ea79SLois Curfman McInnes } 1379606d414cSSatish Balay ierr = PetscFree(ourlens);CHKERRQ(ierr); 1380606d414cSSatish Balay ierr = PetscFree(vals);CHKERRQ(ierr); 1381606d414cSSatish Balay ierr = PetscFree(mycols);CHKERRQ(ierr); 1382606d414cSSatish Balay ierr = PetscFree(rowners);CHKERRQ(ierr); 13838965ea79SLois Curfman McInnes 13846d4a8577SBarry Smith ierr = MatAssemblyBegin(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 13856d4a8577SBarry Smith ierr = MatAssemblyEnd(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr); 13863a40ed3dSBarry Smith PetscFunctionReturn(0); 13878965ea79SLois Curfman McInnes } 1388273d9f13SBarry Smith EXTERN_C_END 138990ace30eSBarry Smith 139090ace30eSBarry Smith 139190ace30eSBarry Smith 139290ace30eSBarry Smith 139390ace30eSBarry Smith 1394