18965ea79SLois Curfman McInnes #ifndef lint 2*bcd2baecSBarry Smith static char vcid[] = "$Id: mpidense.c,v 1.30 1996/03/06 21:47:19 balay Exp bsmith $"; 38965ea79SLois Curfman McInnes #endif 48965ea79SLois Curfman McInnes 5ed3cc1f0SBarry Smith /* 6ed3cc1f0SBarry Smith Basic functions for basic parallel dense matrices. 7ed3cc1f0SBarry Smith */ 8ed3cc1f0SBarry Smith 98965ea79SLois Curfman McInnes #include "mpidense.h" 108965ea79SLois Curfman McInnes #include "vec/vecimpl.h" 118965ea79SLois Curfman McInnes 1239ddd567SLois Curfman McInnes static int MatSetValues_MPIDense(Mat mat,int m,int *idxm,int n, 138965ea79SLois Curfman McInnes int *idxn,Scalar *v,InsertMode addv) 148965ea79SLois Curfman McInnes { 1539b7565bSBarry Smith Mat_MPIDense *A = (Mat_MPIDense *) mat->data; 1639b7565bSBarry Smith int ierr, i, j, rstart = A->rstart, rend = A->rend, row; 1739b7565bSBarry Smith int roworiented = A->roworiented; 188965ea79SLois Curfman McInnes 1939b7565bSBarry Smith if (A->insertmode != NOT_SET_VALUES && A->insertmode != addv) { 2039ddd567SLois Curfman McInnes SETERRQ(1,"MatSetValues_MPIDense:Cannot mix inserts and adds"); 218965ea79SLois Curfman McInnes } 2239b7565bSBarry Smith A->insertmode = addv; 238965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 2439ddd567SLois Curfman McInnes if (idxm[i] < 0) SETERRQ(1,"MatSetValues_MPIDense:Negative row"); 2539b7565bSBarry Smith if (idxm[i] >= A->M) SETERRQ(1,"MatSetValues_MPIDense:Row too large"); 268965ea79SLois Curfman McInnes if (idxm[i] >= rstart && idxm[i] < rend) { 278965ea79SLois Curfman McInnes row = idxm[i] - rstart; 2839b7565bSBarry Smith if (roworiented) { 2939b7565bSBarry Smith ierr = MatSetValues(A->A,1,&row,n,idxn,v+i*n,addv); CHKERRQ(ierr); 3039b7565bSBarry Smith } 3139b7565bSBarry Smith else { 328965ea79SLois Curfman McInnes for ( j=0; j<n; j++ ) { 3339ddd567SLois Curfman McInnes if (idxn[j] < 0) SETERRQ(1,"MatSetValues_MPIDense:Negative column"); 3439b7565bSBarry Smith if (idxn[j] >= A->N) SETERRQ(1,"MatSetValues_MPIDense:Column too large"); 3539b7565bSBarry Smith ierr = MatSetValues(A->A,1,&row,1,&idxn[j],v+i+j*m,addv); CHKERRQ(ierr); 3639b7565bSBarry Smith } 378965ea79SLois Curfman McInnes } 388965ea79SLois Curfman McInnes } 398965ea79SLois Curfman McInnes else { 4039b7565bSBarry Smith if (roworiented) { 4139b7565bSBarry Smith ierr = StashValues_Private(&A->stash,idxm[i],n,idxn,v+i*n,addv); CHKERRQ(ierr); 4239b7565bSBarry Smith } 4339b7565bSBarry Smith else { /* must stash each seperately */ 4439b7565bSBarry Smith row = idxm[i]; 4539b7565bSBarry Smith for ( j=0; j<n; j++ ) { 4639b7565bSBarry Smith ierr = StashValues_Private(&A->stash,row,1,&idxn[j],v+i+j*m,addv); 4739b7565bSBarry Smith CHKERRQ(ierr); 4839b7565bSBarry Smith } 4939b7565bSBarry Smith } 50b49de8d1SLois Curfman McInnes } 51b49de8d1SLois Curfman McInnes } 52b49de8d1SLois Curfman McInnes return 0; 53b49de8d1SLois Curfman McInnes } 54b49de8d1SLois Curfman McInnes 55b49de8d1SLois Curfman McInnes static int MatGetValues_MPIDense(Mat mat,int m,int *idxm,int n,int *idxn,Scalar *v) 56b49de8d1SLois Curfman McInnes { 57b49de8d1SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 58b49de8d1SLois Curfman McInnes int ierr, i, j, rstart = mdn->rstart, rend = mdn->rend, row; 59b49de8d1SLois Curfman McInnes 60b49de8d1SLois Curfman McInnes for ( i=0; i<m; i++ ) { 61b49de8d1SLois Curfman McInnes if (idxm[i] < 0) SETERRQ(1,"MatGetValues_MPIDense:Negative row"); 62b49de8d1SLois Curfman McInnes if (idxm[i] >= mdn->M) SETERRQ(1,"MatGetValues_MPIDense:Row too large"); 63b49de8d1SLois Curfman McInnes if (idxm[i] >= rstart && idxm[i] < rend) { 64b49de8d1SLois Curfman McInnes row = idxm[i] - rstart; 65b49de8d1SLois Curfman McInnes for ( j=0; j<n; j++ ) { 66b49de8d1SLois Curfman McInnes if (idxn[j] < 0) SETERRQ(1,"MatGetValues_MPIDense:Negative column"); 67b49de8d1SLois Curfman McInnes if (idxn[j] >= mdn->N) 68b49de8d1SLois Curfman McInnes SETERRQ(1,"MatGetValues_MPIDense:Column too large"); 69b49de8d1SLois Curfman McInnes ierr = MatGetValues(mdn->A,1,&row,1,&idxn[j],v+i*n+j); CHKERRQ(ierr); 70b49de8d1SLois Curfman McInnes } 71b49de8d1SLois Curfman McInnes } 72b49de8d1SLois Curfman McInnes else { 73b49de8d1SLois Curfman McInnes SETERRQ(1,"MatGetValues_MPIDense:Only local values currently supported"); 748965ea79SLois Curfman McInnes } 758965ea79SLois Curfman McInnes } 768965ea79SLois Curfman McInnes return 0; 778965ea79SLois Curfman McInnes } 788965ea79SLois Curfman McInnes 79ff14e315SSatish Balay static int MatGetArray_MPIDense(Mat A,Scalar **array) 80ff14e315SSatish Balay { 81ff14e315SSatish Balay Mat_MPIDense *a = (Mat_MPIDense *) A->data; 82ff14e315SSatish Balay int ierr; 83ff14e315SSatish Balay 84ff14e315SSatish Balay ierr = MatGetArray(a->A,array); CHKERRQ(ierr); 85ff14e315SSatish Balay return 0; 86ff14e315SSatish Balay } 87ff14e315SSatish Balay 88ff14e315SSatish Balay static int MatRestoreArray_MPIDense(Mat A,Scalar **array) 89ff14e315SSatish Balay { 90ff14e315SSatish Balay return 0; 91ff14e315SSatish Balay } 92ff14e315SSatish Balay 9339ddd567SLois Curfman McInnes static int MatAssemblyBegin_MPIDense(Mat mat,MatAssemblyType mode) 948965ea79SLois Curfman McInnes { 9539ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 968965ea79SLois Curfman McInnes MPI_Comm comm = mat->comm; 9739ddd567SLois Curfman McInnes int size = mdn->size, *owners = mdn->rowners, rank = mdn->rank; 988965ea79SLois Curfman McInnes int *nprocs,i,j,idx,*procs,nsends,nreceives,nmax,*work; 9939ddd567SLois Curfman McInnes int tag = mat->tag, *owner,*starts,count,ierr; 1008965ea79SLois Curfman McInnes InsertMode addv; 10139ddd567SLois Curfman McInnes MPI_Request *send_waits,*recv_waits; 1028965ea79SLois Curfman McInnes Scalar *rvalues,*svalues; 1038965ea79SLois Curfman McInnes 1048965ea79SLois Curfman McInnes /* make sure all processors are either in INSERTMODE or ADDMODE */ 1056d84be18SBarry Smith MPI_Allreduce(&mdn->insertmode,&addv,1,MPI_INT,MPI_BOR,comm); 10639ddd567SLois Curfman McInnes if (addv == (ADD_VALUES|INSERT_VALUES)) { SETERRQ(1, 10739ddd567SLois Curfman McInnes "MatAssemblyBegin_MPIDense:Cannot mix adds/inserts on different procs"); 1088965ea79SLois Curfman McInnes } 10939ddd567SLois Curfman McInnes mdn->insertmode = addv; /* in case this processor had no cache */ 1108965ea79SLois Curfman McInnes 1118965ea79SLois Curfman McInnes /* first count number of contributors to each processor */ 1120452661fSBarry Smith nprocs = (int *) PetscMalloc( 2*size*sizeof(int) ); CHKPTRQ(nprocs); 113cddf8d76SBarry Smith PetscMemzero(nprocs,2*size*sizeof(int)); procs = nprocs + size; 1140452661fSBarry Smith owner = (int *) PetscMalloc( (mdn->stash.n+1)*sizeof(int) ); CHKPTRQ(owner); 11539ddd567SLois Curfman McInnes for ( i=0; i<mdn->stash.n; i++ ) { 11639ddd567SLois Curfman McInnes idx = mdn->stash.idx[i]; 1178965ea79SLois Curfman McInnes for ( j=0; j<size; j++ ) { 1188965ea79SLois Curfman McInnes if (idx >= owners[j] && idx < owners[j+1]) { 1198965ea79SLois Curfman McInnes nprocs[j]++; procs[j] = 1; owner[i] = j; break; 1208965ea79SLois Curfman McInnes } 1218965ea79SLois Curfman McInnes } 1228965ea79SLois Curfman McInnes } 1238965ea79SLois Curfman McInnes nsends = 0; for ( i=0; i<size; i++ ) { nsends += procs[i];} 1248965ea79SLois Curfman McInnes 1258965ea79SLois Curfman McInnes /* inform other processors of number of messages and max length*/ 1260452661fSBarry Smith work = (int *) PetscMalloc( size*sizeof(int) ); CHKPTRQ(work); 1276d84be18SBarry Smith MPI_Allreduce(procs,work,size,MPI_INT,MPI_SUM,comm); 1288965ea79SLois Curfman McInnes nreceives = work[rank]; 1296d84be18SBarry Smith MPI_Allreduce(nprocs,work,size,MPI_INT,MPI_MAX,comm); 1308965ea79SLois Curfman McInnes nmax = work[rank]; 1310452661fSBarry Smith PetscFree(work); 1328965ea79SLois Curfman McInnes 1338965ea79SLois Curfman McInnes /* post receives: 1348965ea79SLois Curfman McInnes 1) each message will consist of ordered pairs 1358965ea79SLois Curfman McInnes (global index,value) we store the global index as a double 1368965ea79SLois Curfman McInnes to simplify the message passing. 1378965ea79SLois Curfman McInnes 2) since we don't know how long each individual message is we 1388965ea79SLois Curfman McInnes allocate the largest needed buffer for each receive. Potentially 1398965ea79SLois Curfman McInnes this is a lot of wasted space. 1408965ea79SLois Curfman McInnes 1418965ea79SLois Curfman McInnes This could be done better. 1428965ea79SLois Curfman McInnes */ 1430452661fSBarry Smith rvalues = (Scalar *) PetscMalloc(3*(nreceives+1)*(nmax+1)*sizeof(Scalar)); 1448965ea79SLois Curfman McInnes CHKPTRQ(rvalues); 1450452661fSBarry Smith recv_waits = (MPI_Request *) PetscMalloc((nreceives+1)*sizeof(MPI_Request)); 1468965ea79SLois Curfman McInnes CHKPTRQ(recv_waits); 1478965ea79SLois Curfman McInnes for ( i=0; i<nreceives; i++ ) { 1486d84be18SBarry Smith MPI_Irecv(rvalues+3*nmax*i,3*nmax,MPIU_SCALAR,MPI_ANY_SOURCE,tag, 1498965ea79SLois Curfman McInnes comm,recv_waits+i); 1508965ea79SLois Curfman McInnes } 1518965ea79SLois Curfman McInnes 1528965ea79SLois Curfman McInnes /* do sends: 1538965ea79SLois Curfman McInnes 1) starts[i] gives the starting index in svalues for stuff going to 1548965ea79SLois Curfman McInnes the ith processor 1558965ea79SLois Curfman McInnes */ 1560452661fSBarry Smith svalues = (Scalar *) PetscMalloc( 3*(mdn->stash.n+1)*sizeof(Scalar) ); 15739ddd567SLois Curfman McInnes CHKPTRQ(svalues); 1580452661fSBarry Smith send_waits = (MPI_Request *) PetscMalloc( (nsends+1)*sizeof(MPI_Request)); 1598965ea79SLois Curfman McInnes CHKPTRQ(send_waits); 1600452661fSBarry Smith starts = (int *) PetscMalloc( size*sizeof(int) ); CHKPTRQ(starts); 1618965ea79SLois Curfman McInnes starts[0] = 0; 1628965ea79SLois Curfman McInnes for ( i=1; i<size; i++ ) { starts[i] = starts[i-1] + nprocs[i-1];} 16339ddd567SLois Curfman McInnes for ( i=0; i<mdn->stash.n; i++ ) { 16439ddd567SLois Curfman McInnes svalues[3*starts[owner[i]]] = (Scalar) mdn->stash.idx[i]; 16539ddd567SLois Curfman McInnes svalues[3*starts[owner[i]]+1] = (Scalar) mdn->stash.idy[i]; 16639ddd567SLois Curfman McInnes svalues[3*(starts[owner[i]]++)+2] = mdn->stash.array[i]; 1678965ea79SLois Curfman McInnes } 1680452661fSBarry Smith PetscFree(owner); 1698965ea79SLois Curfman McInnes starts[0] = 0; 1708965ea79SLois Curfman McInnes for ( i=1; i<size; i++ ) { starts[i] = starts[i-1] + nprocs[i-1];} 1718965ea79SLois Curfman McInnes count = 0; 1728965ea79SLois Curfman McInnes for ( i=0; i<size; i++ ) { 1738965ea79SLois Curfman McInnes if (procs[i]) { 1746d84be18SBarry Smith MPI_Isend(svalues+3*starts[i],3*nprocs[i],MPIU_SCALAR,i,tag, 1758965ea79SLois Curfman McInnes comm,send_waits+count++); 1768965ea79SLois Curfman McInnes } 1778965ea79SLois Curfman McInnes } 1780452661fSBarry Smith PetscFree(starts); PetscFree(nprocs); 1798965ea79SLois Curfman McInnes 1808965ea79SLois Curfman McInnes /* Free cache space */ 18139ddd567SLois Curfman McInnes ierr = StashDestroy_Private(&mdn->stash); CHKERRQ(ierr); 1828965ea79SLois Curfman McInnes 18339ddd567SLois Curfman McInnes mdn->svalues = svalues; mdn->rvalues = rvalues; 18439ddd567SLois Curfman McInnes mdn->nsends = nsends; mdn->nrecvs = nreceives; 18539ddd567SLois Curfman McInnes mdn->send_waits = send_waits; mdn->recv_waits = recv_waits; 18639ddd567SLois Curfman McInnes mdn->rmax = nmax; 1878965ea79SLois Curfman McInnes 1888965ea79SLois Curfman McInnes return 0; 1898965ea79SLois Curfman McInnes } 19039ddd567SLois Curfman McInnes extern int MatSetUpMultiply_MPIDense(Mat); 1918965ea79SLois Curfman McInnes 19239ddd567SLois Curfman McInnes static int MatAssemblyEnd_MPIDense(Mat mat,MatAssemblyType mode) 1938965ea79SLois Curfman McInnes { 19439ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 1958965ea79SLois Curfman McInnes MPI_Status *send_status,recv_status; 19639ddd567SLois Curfman McInnes int imdex, nrecvs=mdn->nrecvs, count=nrecvs, i, n, ierr, row, col; 1978965ea79SLois Curfman McInnes Scalar *values,val; 19839ddd567SLois Curfman McInnes InsertMode addv = mdn->insertmode; 1998965ea79SLois Curfman McInnes 2008965ea79SLois Curfman McInnes /* wait on receives */ 2018965ea79SLois Curfman McInnes while (count) { 20239ddd567SLois Curfman McInnes MPI_Waitany(nrecvs,mdn->recv_waits,&imdex,&recv_status); 2038965ea79SLois Curfman McInnes /* unpack receives into our local space */ 20439ddd567SLois Curfman McInnes values = mdn->rvalues + 3*imdex*mdn->rmax; 2058965ea79SLois Curfman McInnes MPI_Get_count(&recv_status,MPIU_SCALAR,&n); 2068965ea79SLois Curfman McInnes n = n/3; 2078965ea79SLois Curfman McInnes for ( i=0; i<n; i++ ) { 208227d817aSBarry Smith row = (int) PetscReal(values[3*i]) - mdn->rstart; 209227d817aSBarry Smith col = (int) PetscReal(values[3*i+1]); 2108965ea79SLois Curfman McInnes val = values[3*i+2]; 21139ddd567SLois Curfman McInnes if (col >= 0 && col < mdn->N) { 21239ddd567SLois Curfman McInnes MatSetValues(mdn->A,1,&row,1,&col,&val,addv); 2138965ea79SLois Curfman McInnes } 21439ddd567SLois Curfman McInnes else {SETERRQ(1,"MatAssemblyEnd_MPIDense:Invalid column");} 2158965ea79SLois Curfman McInnes } 2168965ea79SLois Curfman McInnes count--; 2178965ea79SLois Curfman McInnes } 2180452661fSBarry Smith PetscFree(mdn->recv_waits); PetscFree(mdn->rvalues); 2198965ea79SLois Curfman McInnes 2208965ea79SLois Curfman McInnes /* wait on sends */ 22139ddd567SLois Curfman McInnes if (mdn->nsends) { 2220452661fSBarry Smith send_status = (MPI_Status *) PetscMalloc( mdn->nsends*sizeof(MPI_Status) ); 2238965ea79SLois Curfman McInnes CHKPTRQ(send_status); 22439ddd567SLois Curfman McInnes MPI_Waitall(mdn->nsends,mdn->send_waits,send_status); 2250452661fSBarry Smith PetscFree(send_status); 2268965ea79SLois Curfman McInnes } 2270452661fSBarry Smith PetscFree(mdn->send_waits); PetscFree(mdn->svalues); 2288965ea79SLois Curfman McInnes 22939ddd567SLois Curfman McInnes mdn->insertmode = NOT_SET_VALUES; 23039ddd567SLois Curfman McInnes ierr = MatAssemblyBegin(mdn->A,mode); CHKERRQ(ierr); 23139ddd567SLois Curfman McInnes ierr = MatAssemblyEnd(mdn->A,mode); CHKERRQ(ierr); 2328965ea79SLois Curfman McInnes 233227d817aSBarry Smith if (!mat->was_assembled && mode == FINAL_ASSEMBLY) { 23439ddd567SLois Curfman McInnes ierr = MatSetUpMultiply_MPIDense(mat); CHKERRQ(ierr); 2358965ea79SLois Curfman McInnes } 2368965ea79SLois Curfman McInnes return 0; 2378965ea79SLois Curfman McInnes } 2388965ea79SLois Curfman McInnes 23939ddd567SLois Curfman McInnes static int MatZeroEntries_MPIDense(Mat A) 2408965ea79SLois Curfman McInnes { 24139ddd567SLois Curfman McInnes Mat_MPIDense *l = (Mat_MPIDense *) A->data; 24239ddd567SLois Curfman McInnes return MatZeroEntries(l->A); 2438965ea79SLois Curfman McInnes } 2448965ea79SLois Curfman McInnes 2458965ea79SLois Curfman McInnes /* the code does not do the diagonal entries correctly unless the 2468965ea79SLois Curfman McInnes matrix is square and the column and row owerships are identical. 2478965ea79SLois Curfman McInnes This is a BUG. The only way to fix it seems to be to access 2483501a2bdSLois Curfman McInnes mdn->A and mdn->B directly and not through the MatZeroRows() 2498965ea79SLois Curfman McInnes routine. 2508965ea79SLois Curfman McInnes */ 25139ddd567SLois Curfman McInnes static int MatZeroRows_MPIDense(Mat A,IS is,Scalar *diag) 2528965ea79SLois Curfman McInnes { 25339ddd567SLois Curfman McInnes Mat_MPIDense *l = (Mat_MPIDense *) A->data; 2548965ea79SLois Curfman McInnes int i,ierr,N, *rows,*owners = l->rowners,size = l->size; 2558965ea79SLois Curfman McInnes int *procs,*nprocs,j,found,idx,nsends,*work; 2568965ea79SLois Curfman McInnes int nmax,*svalues,*starts,*owner,nrecvs,rank = l->rank; 2578965ea79SLois Curfman McInnes int *rvalues,tag = A->tag,count,base,slen,n,*source; 2588965ea79SLois Curfman McInnes int *lens,imdex,*lrows,*values; 2598965ea79SLois Curfman McInnes MPI_Comm comm = A->comm; 2608965ea79SLois Curfman McInnes MPI_Request *send_waits,*recv_waits; 2618965ea79SLois Curfman McInnes MPI_Status recv_status,*send_status; 2628965ea79SLois Curfman McInnes IS istmp; 2638965ea79SLois Curfman McInnes 2648965ea79SLois Curfman McInnes ierr = ISGetLocalSize(is,&N); CHKERRQ(ierr); 2658965ea79SLois Curfman McInnes ierr = ISGetIndices(is,&rows); CHKERRQ(ierr); 2668965ea79SLois Curfman McInnes 2678965ea79SLois Curfman McInnes /* first count number of contributors to each processor */ 2680452661fSBarry Smith nprocs = (int *) PetscMalloc( 2*size*sizeof(int) ); CHKPTRQ(nprocs); 269cddf8d76SBarry Smith PetscMemzero(nprocs,2*size*sizeof(int)); procs = nprocs + size; 2700452661fSBarry Smith owner = (int *) PetscMalloc((N+1)*sizeof(int)); CHKPTRQ(owner); /* see note*/ 2718965ea79SLois Curfman McInnes for ( i=0; i<N; i++ ) { 2728965ea79SLois Curfman McInnes idx = rows[i]; 2738965ea79SLois Curfman McInnes found = 0; 2748965ea79SLois Curfman McInnes for ( j=0; j<size; j++ ) { 2758965ea79SLois Curfman McInnes if (idx >= owners[j] && idx < owners[j+1]) { 2768965ea79SLois Curfman McInnes nprocs[j]++; procs[j] = 1; owner[i] = j; found = 1; break; 2778965ea79SLois Curfman McInnes } 2788965ea79SLois Curfman McInnes } 27939ddd567SLois Curfman McInnes if (!found) SETERRQ(1,"MatZeroRows_MPIDense:Index out of range"); 2808965ea79SLois Curfman McInnes } 2818965ea79SLois Curfman McInnes nsends = 0; for ( i=0; i<size; i++ ) { nsends += procs[i];} 2828965ea79SLois Curfman McInnes 2838965ea79SLois Curfman McInnes /* inform other processors of number of messages and max length*/ 2840452661fSBarry Smith work = (int *) PetscMalloc( size*sizeof(int) ); CHKPTRQ(work); 2858965ea79SLois Curfman McInnes MPI_Allreduce( procs, work,size,MPI_INT,MPI_SUM,comm); 2868965ea79SLois Curfman McInnes nrecvs = work[rank]; 2878965ea79SLois Curfman McInnes MPI_Allreduce( nprocs, work,size,MPI_INT,MPI_MAX,comm); 2888965ea79SLois Curfman McInnes nmax = work[rank]; 2890452661fSBarry Smith PetscFree(work); 2908965ea79SLois Curfman McInnes 2918965ea79SLois Curfman McInnes /* post receives: */ 2920452661fSBarry Smith rvalues = (int *) PetscMalloc((nrecvs+1)*(nmax+1)*sizeof(int)); /*see note */ 2938965ea79SLois Curfman McInnes CHKPTRQ(rvalues); 2940452661fSBarry Smith recv_waits = (MPI_Request *) PetscMalloc((nrecvs+1)*sizeof(MPI_Request)); 2958965ea79SLois Curfman McInnes CHKPTRQ(recv_waits); 2968965ea79SLois Curfman McInnes for ( i=0; i<nrecvs; i++ ) { 2978965ea79SLois Curfman McInnes MPI_Irecv(rvalues+nmax*i,nmax,MPI_INT,MPI_ANY_SOURCE,tag,comm,recv_waits+i); 2988965ea79SLois Curfman McInnes } 2998965ea79SLois Curfman McInnes 3008965ea79SLois Curfman McInnes /* do sends: 3018965ea79SLois Curfman McInnes 1) starts[i] gives the starting index in svalues for stuff going to 3028965ea79SLois Curfman McInnes the ith processor 3038965ea79SLois Curfman McInnes */ 3040452661fSBarry Smith svalues = (int *) PetscMalloc( (N+1)*sizeof(int) ); CHKPTRQ(svalues); 3050452661fSBarry Smith send_waits = (MPI_Request *) PetscMalloc( (nsends+1)*sizeof(MPI_Request)); 3068965ea79SLois Curfman McInnes CHKPTRQ(send_waits); 3070452661fSBarry Smith starts = (int *) PetscMalloc( (size+1)*sizeof(int) ); CHKPTRQ(starts); 3088965ea79SLois Curfman McInnes starts[0] = 0; 3098965ea79SLois Curfman McInnes for ( i=1; i<size; i++ ) { starts[i] = starts[i-1] + nprocs[i-1];} 3108965ea79SLois Curfman McInnes for ( i=0; i<N; i++ ) { 3118965ea79SLois Curfman McInnes svalues[starts[owner[i]]++] = rows[i]; 3128965ea79SLois Curfman McInnes } 3138965ea79SLois Curfman McInnes ISRestoreIndices(is,&rows); 3148965ea79SLois Curfman McInnes 3158965ea79SLois Curfman McInnes starts[0] = 0; 3168965ea79SLois Curfman McInnes for ( i=1; i<size+1; i++ ) { starts[i] = starts[i-1] + nprocs[i-1];} 3178965ea79SLois Curfman McInnes count = 0; 3188965ea79SLois Curfman McInnes for ( i=0; i<size; i++ ) { 3198965ea79SLois Curfman McInnes if (procs[i]) { 3208965ea79SLois Curfman McInnes MPI_Isend(svalues+starts[i],nprocs[i],MPI_INT,i,tag,comm,send_waits+count++); 3218965ea79SLois Curfman McInnes } 3228965ea79SLois Curfman McInnes } 3230452661fSBarry Smith PetscFree(starts); 3248965ea79SLois Curfman McInnes 3258965ea79SLois Curfman McInnes base = owners[rank]; 3268965ea79SLois Curfman McInnes 3278965ea79SLois Curfman McInnes /* wait on receives */ 3280452661fSBarry Smith lens = (int *) PetscMalloc( 2*(nrecvs+1)*sizeof(int) ); CHKPTRQ(lens); 3298965ea79SLois Curfman McInnes source = lens + nrecvs; 3308965ea79SLois Curfman McInnes count = nrecvs; slen = 0; 3318965ea79SLois Curfman McInnes while (count) { 3328965ea79SLois Curfman McInnes MPI_Waitany(nrecvs,recv_waits,&imdex,&recv_status); 3338965ea79SLois Curfman McInnes /* unpack receives into our local space */ 3348965ea79SLois Curfman McInnes MPI_Get_count(&recv_status,MPI_INT,&n); 3358965ea79SLois Curfman McInnes source[imdex] = recv_status.MPI_SOURCE; 3368965ea79SLois Curfman McInnes lens[imdex] = n; 3378965ea79SLois Curfman McInnes slen += n; 3388965ea79SLois Curfman McInnes count--; 3398965ea79SLois Curfman McInnes } 3400452661fSBarry Smith PetscFree(recv_waits); 3418965ea79SLois Curfman McInnes 3428965ea79SLois Curfman McInnes /* move the data into the send scatter */ 3430452661fSBarry Smith lrows = (int *) PetscMalloc( (slen+1)*sizeof(int) ); CHKPTRQ(lrows); 3448965ea79SLois Curfman McInnes count = 0; 3458965ea79SLois Curfman McInnes for ( i=0; i<nrecvs; i++ ) { 3468965ea79SLois Curfman McInnes values = rvalues + i*nmax; 3478965ea79SLois Curfman McInnes for ( j=0; j<lens[i]; j++ ) { 3488965ea79SLois Curfman McInnes lrows[count++] = values[j] - base; 3498965ea79SLois Curfman McInnes } 3508965ea79SLois Curfman McInnes } 3510452661fSBarry Smith PetscFree(rvalues); PetscFree(lens); 3520452661fSBarry Smith PetscFree(owner); PetscFree(nprocs); 3538965ea79SLois Curfman McInnes 3548965ea79SLois Curfman McInnes /* actually zap the local rows */ 3558965ea79SLois Curfman McInnes ierr = ISCreateSeq(MPI_COMM_SELF,slen,lrows,&istmp);CHKERRQ(ierr); 3568965ea79SLois Curfman McInnes PLogObjectParent(A,istmp); 3570452661fSBarry Smith PetscFree(lrows); 3588965ea79SLois Curfman McInnes ierr = MatZeroRows(l->A,istmp,diag); CHKERRQ(ierr); 3598965ea79SLois Curfman McInnes ierr = ISDestroy(istmp); CHKERRQ(ierr); 3608965ea79SLois Curfman McInnes 3618965ea79SLois Curfman McInnes /* wait on sends */ 3628965ea79SLois Curfman McInnes if (nsends) { 3630452661fSBarry Smith send_status = (MPI_Status *) PetscMalloc(nsends*sizeof(MPI_Status)); 3648965ea79SLois Curfman McInnes CHKPTRQ(send_status); 3658965ea79SLois Curfman McInnes MPI_Waitall(nsends,send_waits,send_status); 3660452661fSBarry Smith PetscFree(send_status); 3678965ea79SLois Curfman McInnes } 3680452661fSBarry Smith PetscFree(send_waits); PetscFree(svalues); 3698965ea79SLois Curfman McInnes 3708965ea79SLois Curfman McInnes return 0; 3718965ea79SLois Curfman McInnes } 3728965ea79SLois Curfman McInnes 37339ddd567SLois Curfman McInnes static int MatMult_MPIDense(Mat mat,Vec xx,Vec yy) 3748965ea79SLois Curfman McInnes { 37539ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 3768965ea79SLois Curfman McInnes int ierr; 377c456f294SBarry Smith 37839ddd567SLois Curfman McInnes ierr = VecScatterBegin(xx,mdn->lvec,INSERT_VALUES,SCATTER_ALL,mdn->Mvctx); 37939ddd567SLois Curfman McInnes CHKERRQ(ierr); 38039ddd567SLois Curfman McInnes ierr = VecScatterEnd(xx,mdn->lvec,INSERT_VALUES,SCATTER_ALL,mdn->Mvctx); 38139ddd567SLois Curfman McInnes CHKERRQ(ierr); 38239ddd567SLois Curfman McInnes ierr = MatMult(mdn->A,mdn->lvec,yy); CHKERRQ(ierr); 3838965ea79SLois Curfman McInnes return 0; 3848965ea79SLois Curfman McInnes } 3858965ea79SLois Curfman McInnes 38639ddd567SLois Curfman McInnes static int MatMultAdd_MPIDense(Mat mat,Vec xx,Vec yy,Vec zz) 3878965ea79SLois Curfman McInnes { 38839ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 3898965ea79SLois Curfman McInnes int ierr; 390c456f294SBarry Smith 391c456f294SBarry Smith ierr = VecScatterBegin(xx,mdn->lvec,INSERT_VALUES,SCATTER_ALL,mdn->Mvctx);CHKERRQ(ierr); 392c456f294SBarry Smith ierr = VecScatterEnd(xx,mdn->lvec,INSERT_VALUES,SCATTER_ALL,mdn->Mvctx);CHKERRQ(ierr); 39339ddd567SLois Curfman McInnes ierr = MatMultAdd(mdn->A,mdn->lvec,yy,zz); CHKERRQ(ierr); 3948965ea79SLois Curfman McInnes return 0; 3958965ea79SLois Curfman McInnes } 3968965ea79SLois Curfman McInnes 397096963f5SLois Curfman McInnes static int MatMultTrans_MPIDense(Mat A,Vec xx,Vec yy) 398096963f5SLois Curfman McInnes { 399096963f5SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense *) A->data; 400096963f5SLois Curfman McInnes int ierr; 4013501a2bdSLois Curfman McInnes Scalar zero = 0.0; 402096963f5SLois Curfman McInnes 4033501a2bdSLois Curfman McInnes ierr = VecSet(&zero,yy); CHKERRQ(ierr); 404096963f5SLois Curfman McInnes ierr = MatMultTrans(a->A,xx,a->lvec); CHKERRQ(ierr); 405096963f5SLois Curfman McInnes ierr = VecScatterBegin(a->lvec,yy,ADD_VALUES, 406096963f5SLois Curfman McInnes (ScatterMode)(SCATTER_ALL|SCATTER_REVERSE),a->Mvctx); CHKERRQ(ierr); 407096963f5SLois Curfman McInnes ierr = VecScatterEnd(a->lvec,yy,ADD_VALUES, 408096963f5SLois Curfman McInnes (ScatterMode)(SCATTER_ALL|SCATTER_REVERSE),a->Mvctx); CHKERRQ(ierr); 409096963f5SLois Curfman McInnes return 0; 410096963f5SLois Curfman McInnes } 411096963f5SLois Curfman McInnes 412096963f5SLois Curfman McInnes static int MatMultTransAdd_MPIDense(Mat A,Vec xx,Vec yy,Vec zz) 413096963f5SLois Curfman McInnes { 414096963f5SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense *) A->data; 415096963f5SLois Curfman McInnes int ierr; 416096963f5SLois Curfman McInnes 4173501a2bdSLois Curfman McInnes ierr = VecCopy(yy,zz); CHKERRQ(ierr); 4183501a2bdSLois Curfman McInnes ierr = MatMultTrans(a->A,xx,a->lvec); CHKERRQ(ierr); 419096963f5SLois Curfman McInnes ierr = VecScatterBegin(a->lvec,zz,ADD_VALUES, 420096963f5SLois Curfman McInnes (ScatterMode)(SCATTER_ALL|SCATTER_REVERSE),a->Mvctx); CHKERRQ(ierr); 421096963f5SLois Curfman McInnes ierr = VecScatterEnd(a->lvec,zz,ADD_VALUES, 422096963f5SLois Curfman McInnes (ScatterMode)(SCATTER_ALL|SCATTER_REVERSE),a->Mvctx); CHKERRQ(ierr); 423096963f5SLois Curfman McInnes return 0; 424096963f5SLois Curfman McInnes } 425096963f5SLois Curfman McInnes 42639ddd567SLois Curfman McInnes static int MatGetDiagonal_MPIDense(Mat A,Vec v) 4278965ea79SLois Curfman McInnes { 42839ddd567SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense *) A->data; 429096963f5SLois Curfman McInnes Mat_SeqDense *aloc = (Mat_SeqDense *) a->A->data; 430096963f5SLois Curfman McInnes int ierr, i, n, m = a->m, radd; 431096963f5SLois Curfman McInnes Scalar *x; 432ed3cc1f0SBarry Smith 433096963f5SLois Curfman McInnes ierr = VecGetArray(v,&x); CHKERRQ(ierr); 434096963f5SLois Curfman McInnes ierr = VecGetSize(v,&n); CHKERRQ(ierr); 435096963f5SLois Curfman McInnes if (n != a->M) SETERRQ(1,"MatGetDiagonal_SeqDense:Nonconforming mat and vec"); 436096963f5SLois Curfman McInnes radd = a->rstart*m*m; 437096963f5SLois Curfman McInnes for ( i=0; i<m; i++ ) { 438096963f5SLois Curfman McInnes x[i] = aloc->v[radd + i*m + i]; 439096963f5SLois Curfman McInnes } 440096963f5SLois Curfman McInnes return 0; 4418965ea79SLois Curfman McInnes } 4428965ea79SLois Curfman McInnes 44339ddd567SLois Curfman McInnes static int MatDestroy_MPIDense(PetscObject obj) 4448965ea79SLois Curfman McInnes { 4458965ea79SLois Curfman McInnes Mat mat = (Mat) obj; 4463501a2bdSLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 4478965ea79SLois Curfman McInnes int ierr; 448ed3cc1f0SBarry Smith 4498965ea79SLois Curfman McInnes #if defined(PETSC_LOG) 4503501a2bdSLois Curfman McInnes PLogObjectState(obj,"Rows=%d, Cols=%d",mdn->M,mdn->N); 4518965ea79SLois Curfman McInnes #endif 4520452661fSBarry Smith PetscFree(mdn->rowners); 4533501a2bdSLois Curfman McInnes ierr = MatDestroy(mdn->A); CHKERRQ(ierr); 4543501a2bdSLois Curfman McInnes if (mdn->lvec) VecDestroy(mdn->lvec); 4553501a2bdSLois Curfman McInnes if (mdn->Mvctx) VecScatterDestroy(mdn->Mvctx); 456622d7880SLois Curfman McInnes if (mdn->factor) { 457622d7880SLois Curfman McInnes if (mdn->factor->temp) PetscFree(mdn->factor->temp); 458622d7880SLois Curfman McInnes if (mdn->factor->tag) PetscFree(mdn->factor->tag); 459622d7880SLois Curfman McInnes if (mdn->factor->pivots) PetscFree(mdn->factor->pivots); 460622d7880SLois Curfman McInnes PetscFree(mdn->factor); 461622d7880SLois Curfman McInnes } 4620452661fSBarry Smith PetscFree(mdn); 4638965ea79SLois Curfman McInnes PLogObjectDestroy(mat); 4640452661fSBarry Smith PetscHeaderDestroy(mat); 4658965ea79SLois Curfman McInnes return 0; 4668965ea79SLois Curfman McInnes } 46739ddd567SLois Curfman McInnes 4688965ea79SLois Curfman McInnes #include "pinclude/pviewer.h" 4698965ea79SLois Curfman McInnes 47039ddd567SLois Curfman McInnes static int MatView_MPIDense_Binary(Mat mat,Viewer viewer) 4718965ea79SLois Curfman McInnes { 47239ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 4738965ea79SLois Curfman McInnes int ierr; 47439ddd567SLois Curfman McInnes if (mdn->size == 1) { 47539ddd567SLois Curfman McInnes ierr = MatView(mdn->A,viewer); CHKERRQ(ierr); 4768965ea79SLois Curfman McInnes } 47739ddd567SLois Curfman McInnes else SETERRQ(1,"MatView_MPIDense_Binary:Only uniprocessor output supported"); 4788965ea79SLois Curfman McInnes return 0; 4798965ea79SLois Curfman McInnes } 4808965ea79SLois Curfman McInnes 48139ddd567SLois Curfman McInnes static int MatView_MPIDense_ASCII(Mat mat,Viewer viewer) 4828965ea79SLois Curfman McInnes { 48339ddd567SLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) mat->data; 48439ddd567SLois Curfman McInnes int ierr, format; 4858965ea79SLois Curfman McInnes PetscObject vobj = (PetscObject) viewer; 4868965ea79SLois Curfman McInnes FILE *fd; 4878965ea79SLois Curfman McInnes 488227d817aSBarry Smith ierr = ViewerFileGetPointer(viewer,&fd); CHKERRQ(ierr); 4898965ea79SLois Curfman McInnes if (vobj->type == ASCII_FILE_VIEWER || vobj->type == ASCII_FILES_VIEWER) { 4908965ea79SLois Curfman McInnes ierr = ViewerFileGetFormat_Private(viewer,&format); 4913501a2bdSLois Curfman McInnes if (format == FILE_FORMAT_INFO_DETAILED) { 492096963f5SLois Curfman McInnes int nz, nzalloc, mem, rank; 493096963f5SLois Curfman McInnes MPI_Comm_rank(mat->comm,&rank); 494096963f5SLois Curfman McInnes ierr = MatGetInfo(mat,MAT_LOCAL,&nz,&nzalloc,&mem); 495096963f5SLois Curfman McInnes MPIU_Seq_begin(mat->comm,1); 4963501a2bdSLois Curfman McInnes fprintf(fd," [%d] local rows %d nz %d nz alloced %d mem %d \n", 497096963f5SLois Curfman McInnes rank,mdn->m,nz,nzalloc,mem); 498096963f5SLois Curfman McInnes fflush(fd); 499096963f5SLois Curfman McInnes MPIU_Seq_end(mat->comm,1); 5003501a2bdSLois Curfman McInnes ierr = VecScatterView(mdn->Mvctx,viewer); CHKERRQ(ierr); 5013501a2bdSLois Curfman McInnes return 0; 5023501a2bdSLois Curfman McInnes } 5033501a2bdSLois Curfman McInnes else if (format == FILE_FORMAT_INFO) { 504096963f5SLois Curfman McInnes return 0; 5058965ea79SLois Curfman McInnes } 5068965ea79SLois Curfman McInnes } 5078965ea79SLois Curfman McInnes if (vobj->type == ASCII_FILE_VIEWER) { 5088965ea79SLois Curfman McInnes MPIU_Seq_begin(mat->comm,1); 50939ddd567SLois Curfman McInnes fprintf(fd,"[%d] rows %d starts %d ends %d cols %d\n", 51039ddd567SLois Curfman McInnes mdn->rank,mdn->m,mdn->rstart,mdn->rend,mdn->n); 51139ddd567SLois Curfman McInnes ierr = MatView(mdn->A,viewer); CHKERRQ(ierr); 5128965ea79SLois Curfman McInnes fflush(fd); 5138965ea79SLois Curfman McInnes MPIU_Seq_end(mat->comm,1); 5148965ea79SLois Curfman McInnes } 5158965ea79SLois Curfman McInnes else { 51639ddd567SLois Curfman McInnes int size = mdn->size, rank = mdn->rank; 5178965ea79SLois Curfman McInnes if (size == 1) { 51839ddd567SLois Curfman McInnes ierr = MatView(mdn->A,viewer); CHKERRQ(ierr); 5198965ea79SLois Curfman McInnes } 5208965ea79SLois Curfman McInnes else { 5218965ea79SLois Curfman McInnes /* assemble the entire matrix onto first processor. */ 5228965ea79SLois Curfman McInnes Mat A; 52339ddd567SLois Curfman McInnes int M = mdn->M, N = mdn->N,m,row,i, nz, *cols; 52439ddd567SLois Curfman McInnes Scalar *vals; 52539ddd567SLois Curfman McInnes Mat_SeqDense *Amdn = (Mat_SeqDense*) mdn->A->data; 5268965ea79SLois Curfman McInnes 5278965ea79SLois Curfman McInnes if (!rank) { 528b4fd4287SBarry Smith ierr = MatCreateMPIDense(mat->comm,M,M,N,N,PETSC_NULL,&A); CHKERRQ(ierr); 5298965ea79SLois Curfman McInnes } 5308965ea79SLois Curfman McInnes else { 531b4fd4287SBarry Smith ierr = MatCreateMPIDense(mat->comm,0,M,N,N,PETSC_NULL,&A); CHKERRQ(ierr); 5328965ea79SLois Curfman McInnes } 5338965ea79SLois Curfman McInnes PLogObjectParent(mat,A); 5348965ea79SLois Curfman McInnes 53539ddd567SLois Curfman McInnes /* Copy the matrix ... This isn't the most efficient means, 53639ddd567SLois Curfman McInnes but it's quick for now */ 53739ddd567SLois Curfman McInnes row = mdn->rstart; m = Amdn->m; 5388965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 53939ddd567SLois Curfman McInnes ierr = MatGetRow(mat,row,&nz,&cols,&vals); CHKERRQ(ierr); 54039ddd567SLois Curfman McInnes ierr = MatSetValues(A,1,&row,nz,cols,vals,INSERT_VALUES); CHKERRQ(ierr); 54139ddd567SLois Curfman McInnes ierr = MatRestoreRow(mat,row,&nz,&cols,&vals); CHKERRQ(ierr); 54239ddd567SLois Curfman McInnes row++; 5438965ea79SLois Curfman McInnes } 5448965ea79SLois Curfman McInnes 5458965ea79SLois Curfman McInnes ierr = MatAssemblyBegin(A,FINAL_ASSEMBLY); CHKERRQ(ierr); 5468965ea79SLois Curfman McInnes ierr = MatAssemblyEnd(A,FINAL_ASSEMBLY); CHKERRQ(ierr); 5478965ea79SLois Curfman McInnes if (!rank) { 54839ddd567SLois Curfman McInnes ierr = MatView(((Mat_MPIDense*)(A->data))->A,viewer); CHKERRQ(ierr); 5498965ea79SLois Curfman McInnes } 5508965ea79SLois Curfman McInnes ierr = MatDestroy(A); CHKERRQ(ierr); 5518965ea79SLois Curfman McInnes } 5528965ea79SLois Curfman McInnes } 5538965ea79SLois Curfman McInnes return 0; 5548965ea79SLois Curfman McInnes } 5558965ea79SLois Curfman McInnes 55639ddd567SLois Curfman McInnes static int MatView_MPIDense(PetscObject obj,Viewer viewer) 5578965ea79SLois Curfman McInnes { 5588965ea79SLois Curfman McInnes Mat mat = (Mat) obj; 5598965ea79SLois Curfman McInnes PetscObject vobj = (PetscObject) viewer; 56039ddd567SLois Curfman McInnes int ierr; 561*bcd2baecSBarry Smith ViewerType vtype; 5628965ea79SLois Curfman McInnes 5638965ea79SLois Curfman McInnes if (!viewer) { 5648965ea79SLois Curfman McInnes viewer = STDOUT_VIEWER_SELF; vobj = (PetscObject) viewer; 5658965ea79SLois Curfman McInnes } 566*bcd2baecSBarry Smith ierr = ViewerGetType(viewer,&vtype); CHKERRQ(ierr); 567*bcd2baecSBarry Smith if (vtype == ASCII_FILE_VIEWER) { 56839ddd567SLois Curfman McInnes ierr = MatView_MPIDense_ASCII(mat,viewer); CHKERRQ(ierr); 5698965ea79SLois Curfman McInnes } 570*bcd2baecSBarry Smith else if (vtype == ASCII_FILES_VIEWER) { 57139ddd567SLois Curfman McInnes ierr = MatView_MPIDense_ASCII(mat,viewer); CHKERRQ(ierr); 5728965ea79SLois Curfman McInnes } 573*bcd2baecSBarry Smith else if (vtype == BINARY_FILE_VIEWER) { 57439ddd567SLois Curfman McInnes return MatView_MPIDense_Binary(mat,viewer); 5758965ea79SLois Curfman McInnes } 5768965ea79SLois Curfman McInnes return 0; 5778965ea79SLois Curfman McInnes } 5788965ea79SLois Curfman McInnes 5793501a2bdSLois Curfman McInnes static int MatGetInfo_MPIDense(Mat A,MatInfoType flag,int *nz, 5808965ea79SLois Curfman McInnes int *nzalloc,int *mem) 5818965ea79SLois Curfman McInnes { 5823501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense *) A->data; 5833501a2bdSLois Curfman McInnes Mat mdn = mat->A; 58439ddd567SLois Curfman McInnes int ierr, isend[3], irecv[3]; 5858965ea79SLois Curfman McInnes 5863501a2bdSLois Curfman McInnes ierr = MatGetInfo(mdn,MAT_LOCAL,&isend[0],&isend[1],&isend[2]); CHKERRQ(ierr); 5878965ea79SLois Curfman McInnes if (flag == MAT_LOCAL) { 588*bcd2baecSBarry Smith if (nz) *nz = isend[0]; 589*bcd2baecSBarry Smith if (nzalloc) *nzalloc = isend[1]; 590*bcd2baecSBarry Smith if (mem) *mem = isend[2]; 5918965ea79SLois Curfman McInnes } else if (flag == MAT_GLOBAL_MAX) { 5923501a2bdSLois Curfman McInnes MPI_Allreduce(isend,irecv,3,MPI_INT,MPI_MAX,A->comm); 593*bcd2baecSBarry Smith if (nz) *nz = irecv[0]; 594*bcd2baecSBarry Smith if (nzalloc) *nzalloc = irecv[1]; 595*bcd2baecSBarry Smith if (mem) *mem = irecv[2]; 5968965ea79SLois Curfman McInnes } else if (flag == MAT_GLOBAL_SUM) { 5973501a2bdSLois Curfman McInnes MPI_Allreduce(isend,irecv,3,MPI_INT,MPI_SUM,A->comm); 598*bcd2baecSBarry Smith if (nz) *nz = irecv[0]; 599*bcd2baecSBarry Smith if (nzalloc) *nzalloc = irecv[1]; 600*bcd2baecSBarry Smith if (mem) *mem = irecv[2]; 6018965ea79SLois Curfman McInnes } 6028965ea79SLois Curfman McInnes return 0; 6038965ea79SLois Curfman McInnes } 6048965ea79SLois Curfman McInnes 6058c469469SLois Curfman McInnes /* extern int MatLUFactorSymbolic_MPIDense(Mat,IS,IS,double,Mat*); 6068aaee692SLois Curfman McInnes extern int MatLUFactorNumeric_MPIDense(Mat,Mat*); 6078aaee692SLois Curfman McInnes extern int MatLUFactor_MPIDense(Mat,IS,IS,double); 6088aaee692SLois Curfman McInnes extern int MatSolve_MPIDense(Mat,Vec,Vec); 6098c469469SLois Curfman McInnes extern int MatSolveAdd_MPIDense(Mat,Vec,Vec,Vec); 6108aaee692SLois Curfman McInnes extern int MatSolveTrans_MPIDense(Mat,Vec,Vec); 6118aaee692SLois Curfman McInnes extern int MatSolveTransAdd_MPIDense(Mat,Vec,Vec,Vec); */ 6128aaee692SLois Curfman McInnes 61339ddd567SLois Curfman McInnes static int MatSetOption_MPIDense(Mat A,MatOption op) 6148965ea79SLois Curfman McInnes { 61539ddd567SLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense *) A->data; 6168965ea79SLois Curfman McInnes 6178965ea79SLois Curfman McInnes if (op == NO_NEW_NONZERO_LOCATIONS || 6188965ea79SLois Curfman McInnes op == YES_NEW_NONZERO_LOCATIONS || 6198965ea79SLois Curfman McInnes op == COLUMNS_SORTED || 6208965ea79SLois Curfman McInnes op == ROW_ORIENTED) { 6218965ea79SLois Curfman McInnes MatSetOption(a->A,op); 6228965ea79SLois Curfman McInnes } 6238965ea79SLois Curfman McInnes else if (op == ROWS_SORTED || 6248965ea79SLois Curfman McInnes op == SYMMETRIC_MATRIX || 6258965ea79SLois Curfman McInnes op == STRUCTURALLY_SYMMETRIC_MATRIX || 6268965ea79SLois Curfman McInnes op == YES_NEW_DIAGONALS) 62739ddd567SLois Curfman McInnes PLogInfo((PetscObject)A,"Info:MatSetOption_MPIDense:Option ignored\n"); 6288965ea79SLois Curfman McInnes else if (op == COLUMN_ORIENTED) 62939b7565bSBarry Smith { a->roworiented = 0; MatSetOption(a->A,op);} 6308965ea79SLois Curfman McInnes else if (op == NO_NEW_DIAGONALS) 63139ddd567SLois Curfman McInnes {SETERRQ(PETSC_ERR_SUP,"MatSetOption_MPIDense:NO_NEW_DIAGONALS");} 6328965ea79SLois Curfman McInnes else 63339ddd567SLois Curfman McInnes {SETERRQ(PETSC_ERR_SUP,"MatSetOption_MPIDense:unknown option");} 6348965ea79SLois Curfman McInnes return 0; 6358965ea79SLois Curfman McInnes } 6368965ea79SLois Curfman McInnes 6373501a2bdSLois Curfman McInnes static int MatGetSize_MPIDense(Mat A,int *m,int *n) 6388965ea79SLois Curfman McInnes { 6393501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense *) A->data; 6408965ea79SLois Curfman McInnes *m = mat->M; *n = mat->N; 6418965ea79SLois Curfman McInnes return 0; 6428965ea79SLois Curfman McInnes } 6438965ea79SLois Curfman McInnes 6443501a2bdSLois Curfman McInnes static int MatGetLocalSize_MPIDense(Mat A,int *m,int *n) 6458965ea79SLois Curfman McInnes { 6463501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense *) A->data; 6478965ea79SLois Curfman McInnes *m = mat->m; *n = mat->N; 6488965ea79SLois Curfman McInnes return 0; 6498965ea79SLois Curfman McInnes } 6508965ea79SLois Curfman McInnes 6513501a2bdSLois Curfman McInnes static int MatGetOwnershipRange_MPIDense(Mat A,int *m,int *n) 6528965ea79SLois Curfman McInnes { 6533501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense *) A->data; 6548965ea79SLois Curfman McInnes *m = mat->rstart; *n = mat->rend; 6558965ea79SLois Curfman McInnes return 0; 6568965ea79SLois Curfman McInnes } 6578965ea79SLois Curfman McInnes 6583501a2bdSLois Curfman McInnes static int MatGetRow_MPIDense(Mat A,int row,int *nz,int **idx,Scalar **v) 6598965ea79SLois Curfman McInnes { 6603501a2bdSLois Curfman McInnes Mat_MPIDense *mat = (Mat_MPIDense *) A->data; 66139ddd567SLois Curfman McInnes int lrow, rstart = mat->rstart, rend = mat->rend; 6628965ea79SLois Curfman McInnes 66339ddd567SLois Curfman McInnes if (row < rstart || row >= rend) SETERRQ(1,"MatGetRow_MPIDense:only local rows") 6648965ea79SLois Curfman McInnes lrow = row - rstart; 66539ddd567SLois Curfman McInnes return MatGetRow(mat->A,lrow,nz,idx,v); 6668965ea79SLois Curfman McInnes } 6678965ea79SLois Curfman McInnes 66839ddd567SLois Curfman McInnes static int MatRestoreRow_MPIDense(Mat mat,int row,int *nz,int **idx,Scalar **v) 6698965ea79SLois Curfman McInnes { 6700452661fSBarry Smith if (idx) PetscFree(*idx); 6710452661fSBarry Smith if (v) PetscFree(*v); 6728965ea79SLois Curfman McInnes return 0; 6738965ea79SLois Curfman McInnes } 6748965ea79SLois Curfman McInnes 675cddf8d76SBarry Smith static int MatNorm_MPIDense(Mat A,NormType type,double *norm) 676096963f5SLois Curfman McInnes { 6773501a2bdSLois Curfman McInnes Mat_MPIDense *mdn = (Mat_MPIDense *) A->data; 6783501a2bdSLois Curfman McInnes Mat_SeqDense *mat = (Mat_SeqDense*) mdn->A->data; 6793501a2bdSLois Curfman McInnes int ierr, i, j; 6803501a2bdSLois Curfman McInnes double sum = 0.0; 6813501a2bdSLois Curfman McInnes Scalar *v = mat->v; 6823501a2bdSLois Curfman McInnes 6833501a2bdSLois Curfman McInnes if (mdn->size == 1) { 6843501a2bdSLois Curfman McInnes ierr = MatNorm(mdn->A,type,norm); CHKERRQ(ierr); 6853501a2bdSLois Curfman McInnes } else { 6863501a2bdSLois Curfman McInnes if (type == NORM_FROBENIUS) { 6873501a2bdSLois Curfman McInnes for (i=0; i<mat->n*mat->m; i++ ) { 6883501a2bdSLois Curfman McInnes #if defined(PETSC_COMPLEX) 6893501a2bdSLois Curfman McInnes sum += real(conj(*v)*(*v)); v++; 6903501a2bdSLois Curfman McInnes #else 6913501a2bdSLois Curfman McInnes sum += (*v)*(*v); v++; 6923501a2bdSLois Curfman McInnes #endif 6933501a2bdSLois Curfman McInnes } 6946d84be18SBarry Smith MPI_Allreduce(&sum,norm,1,MPI_DOUBLE,MPI_SUM,A->comm); 6953501a2bdSLois Curfman McInnes *norm = sqrt(*norm); 6963501a2bdSLois Curfman McInnes PLogFlops(2*mat->n*mat->m); 6973501a2bdSLois Curfman McInnes } 6983501a2bdSLois Curfman McInnes else if (type == NORM_1) { 6993501a2bdSLois Curfman McInnes double *tmp, *tmp2; 7000452661fSBarry Smith tmp = (double *) PetscMalloc( 2*mdn->N*sizeof(double) ); CHKPTRQ(tmp); 7013501a2bdSLois Curfman McInnes tmp2 = tmp + mdn->N; 702cddf8d76SBarry Smith PetscMemzero(tmp,2*mdn->N*sizeof(double)); 703096963f5SLois Curfman McInnes *norm = 0.0; 7043501a2bdSLois Curfman McInnes v = mat->v; 7053501a2bdSLois Curfman McInnes for ( j=0; j<mat->n; j++ ) { 7063501a2bdSLois Curfman McInnes for ( i=0; i<mat->m; i++ ) { 70767e560aaSBarry Smith tmp[j] += PetscAbsScalar(*v); v++; 7083501a2bdSLois Curfman McInnes } 7093501a2bdSLois Curfman McInnes } 7106d84be18SBarry Smith MPI_Allreduce(tmp,tmp2,mdn->N,MPI_DOUBLE,MPI_SUM,A->comm); 7113501a2bdSLois Curfman McInnes for ( j=0; j<mdn->N; j++ ) { 7123501a2bdSLois Curfman McInnes if (tmp2[j] > *norm) *norm = tmp2[j]; 7133501a2bdSLois Curfman McInnes } 7140452661fSBarry Smith PetscFree(tmp); 7153501a2bdSLois Curfman McInnes PLogFlops(mat->n*mat->m); 7163501a2bdSLois Curfman McInnes } 7173501a2bdSLois Curfman McInnes else if (type == NORM_INFINITY) { /* max row norm */ 7183501a2bdSLois Curfman McInnes double ntemp; 7193501a2bdSLois Curfman McInnes ierr = MatNorm(mdn->A,type,&ntemp); CHKERRQ(ierr); 7206d84be18SBarry Smith MPI_Allreduce(&ntemp,norm,1,MPI_DOUBLE,MPI_MAX,A->comm); 7213501a2bdSLois Curfman McInnes } 7223501a2bdSLois Curfman McInnes else { 7233501a2bdSLois Curfman McInnes SETERRQ(1,"MatNorm_MPIDense:No support for two norm"); 7243501a2bdSLois Curfman McInnes } 7253501a2bdSLois Curfman McInnes } 7263501a2bdSLois Curfman McInnes return 0; 7273501a2bdSLois Curfman McInnes } 7283501a2bdSLois Curfman McInnes 7293501a2bdSLois Curfman McInnes static int MatTranspose_MPIDense(Mat A,Mat *matout) 7303501a2bdSLois Curfman McInnes { 7313501a2bdSLois Curfman McInnes Mat_MPIDense *a = (Mat_MPIDense *) A->data; 7323501a2bdSLois Curfman McInnes Mat_SeqDense *Aloc = (Mat_SeqDense *) a->A->data; 7333501a2bdSLois Curfman McInnes Mat B; 7343501a2bdSLois Curfman McInnes int M = a->M, N = a->N, m, n, *rwork, rstart = a->rstart; 7353501a2bdSLois Curfman McInnes int j, i, ierr; 7363501a2bdSLois Curfman McInnes Scalar *v; 7373501a2bdSLois Curfman McInnes 7383638b69dSLois Curfman McInnes if (matout == PETSC_NULL && M != N) 7393501a2bdSLois Curfman McInnes SETERRQ(1,"MatTranspose_MPIDense:Supports square matrix only in-place"); 740b4fd4287SBarry Smith ierr = MatCreateMPIDense(A->comm,PETSC_DECIDE,PETSC_DECIDE,N,M,PETSC_NULL,&B); 741ed2daf61SLois Curfman McInnes CHKERRQ(ierr); 7423501a2bdSLois Curfman McInnes 7433501a2bdSLois Curfman McInnes m = Aloc->m; n = Aloc->n; v = Aloc->v; 7440452661fSBarry Smith rwork = (int *) PetscMalloc(n*sizeof(int)); CHKPTRQ(rwork); 7453501a2bdSLois Curfman McInnes for ( j=0; j<n; j++ ) { 7463501a2bdSLois Curfman McInnes for (i=0; i<m; i++) rwork[i] = rstart + i; 7473501a2bdSLois Curfman McInnes ierr = MatSetValues(B,1,&j,m,rwork,v,INSERT_VALUES); CHKERRQ(ierr); 7483501a2bdSLois Curfman McInnes v += m; 7493501a2bdSLois Curfman McInnes } 7500452661fSBarry Smith PetscFree(rwork); 7513501a2bdSLois Curfman McInnes ierr = MatAssemblyBegin(B,FINAL_ASSEMBLY); CHKERRQ(ierr); 7523501a2bdSLois Curfman McInnes ierr = MatAssemblyEnd(B,FINAL_ASSEMBLY); CHKERRQ(ierr); 7533638b69dSLois Curfman McInnes if (matout != PETSC_NULL) { 7543501a2bdSLois Curfman McInnes *matout = B; 7553501a2bdSLois Curfman McInnes } else { 7563501a2bdSLois Curfman McInnes /* This isn't really an in-place transpose, but free data struct from a */ 7570452661fSBarry Smith PetscFree(a->rowners); 7583501a2bdSLois Curfman McInnes ierr = MatDestroy(a->A); CHKERRQ(ierr); 7593501a2bdSLois Curfman McInnes if (a->lvec) VecDestroy(a->lvec); 7603501a2bdSLois Curfman McInnes if (a->Mvctx) VecScatterDestroy(a->Mvctx); 7610452661fSBarry Smith PetscFree(a); 7623501a2bdSLois Curfman McInnes PetscMemcpy(A,B,sizeof(struct _Mat)); 7630452661fSBarry Smith PetscHeaderDestroy(B); 7643501a2bdSLois Curfman McInnes } 765096963f5SLois Curfman McInnes return 0; 766096963f5SLois Curfman McInnes } 767096963f5SLois Curfman McInnes 7683d1612f7SBarry Smith static int MatConvertSameType_MPIDense(Mat,Mat *,int); 7698965ea79SLois Curfman McInnes 7708965ea79SLois Curfman McInnes /* -------------------------------------------------------------------*/ 77139ddd567SLois Curfman McInnes static struct _MatOps MatOps = {MatSetValues_MPIDense, 77239ddd567SLois Curfman McInnes MatGetRow_MPIDense,MatRestoreRow_MPIDense, 77339ddd567SLois Curfman McInnes MatMult_MPIDense,MatMultAdd_MPIDense, 774096963f5SLois Curfman McInnes MatMultTrans_MPIDense,MatMultTransAdd_MPIDense, 775e7ca0642SLois Curfman McInnes /* MatSolve_MPIDense,0, */ 776e7ca0642SLois Curfman McInnes 0,0, 77739ddd567SLois Curfman McInnes 0,0, 7788c469469SLois Curfman McInnes 0,0, 7798c469469SLois Curfman McInnes /* MatLUFactor_MPIDense,0, */ 7808aaee692SLois Curfman McInnes 0,MatTranspose_MPIDense, 78139ddd567SLois Curfman McInnes MatGetInfo_MPIDense,0, 782096963f5SLois Curfman McInnes MatGetDiagonal_MPIDense,0,MatNorm_MPIDense, 78339ddd567SLois Curfman McInnes MatAssemblyBegin_MPIDense,MatAssemblyEnd_MPIDense, 7848965ea79SLois Curfman McInnes 0, 78539ddd567SLois Curfman McInnes MatSetOption_MPIDense,MatZeroEntries_MPIDense,MatZeroRows_MPIDense, 7868c469469SLois Curfman McInnes 0,0,0, 7878c469469SLois Curfman McInnes /* 0,MatLUFactorSymbolic_MPIDense,MatLUFactorNumeric_MPIDense, */ 7888aaee692SLois Curfman McInnes 0,0, 78939ddd567SLois Curfman McInnes MatGetSize_MPIDense,MatGetLocalSize_MPIDense, 79039ddd567SLois Curfman McInnes MatGetOwnershipRange_MPIDense, 791ff14e315SSatish Balay 0,0, MatGetArray_MPIDense, MatRestoreArray_MPIDense, 792ff14e315SSatish Balay 0,0,0,MatConvertSameType_MPIDense, 793b49de8d1SLois Curfman McInnes 0,0,0,0,0, 794b49de8d1SLois Curfman McInnes 0,0,MatGetValues_MPIDense}; 7958965ea79SLois Curfman McInnes 7968965ea79SLois Curfman McInnes /*@C 79739ddd567SLois Curfman McInnes MatCreateMPIDense - Creates a sparse parallel matrix in dense format. 7988965ea79SLois Curfman McInnes 7998965ea79SLois Curfman McInnes Input Parameters: 8008965ea79SLois Curfman McInnes . comm - MPI communicator 8018965ea79SLois Curfman McInnes . m - number of local rows (or PETSC_DECIDE to have calculated if M is given) 8028965ea79SLois Curfman McInnes . n - number of local columns (or PETSC_DECIDE to have calculated 8038965ea79SLois Curfman McInnes if N is given) 8048965ea79SLois Curfman McInnes . M - number of global rows (or PETSC_DECIDE to have calculated if m is given) 8058965ea79SLois Curfman McInnes . N - number of global columns (or PETSC_DECIDE to have calculated 8068965ea79SLois Curfman McInnes if n is given) 807b4fd4287SBarry Smith . data - optional location of matrix data. Set data=PETSC_NULL for PETSc 808dfc5480cSLois Curfman McInnes to control all matrix memory allocation. 8098965ea79SLois Curfman McInnes 8108965ea79SLois Curfman McInnes Output Parameter: 8118965ea79SLois Curfman McInnes . newmat - the matrix 8128965ea79SLois Curfman McInnes 8138965ea79SLois Curfman McInnes Notes: 81439ddd567SLois Curfman McInnes The dense format is fully compatible with standard Fortran 77 81539ddd567SLois Curfman McInnes storage by columns. 8168965ea79SLois Curfman McInnes 81718f449edSLois Curfman McInnes The data input variable is intended primarily for Fortran programmers 81818f449edSLois Curfman McInnes who wish to allocate their own matrix memory space. Most users should 819b4fd4287SBarry Smith set data=PETSC_NULL. 82018f449edSLois Curfman McInnes 8218965ea79SLois Curfman McInnes The user MUST specify either the local or global matrix dimensions 8228965ea79SLois Curfman McInnes (possibly both). 8238965ea79SLois Curfman McInnes 8243501a2bdSLois Curfman McInnes Currently, the only parallel dense matrix decomposition is by rows, 8253501a2bdSLois Curfman McInnes so that n=N and each submatrix owns all of the global columns. 8263501a2bdSLois Curfman McInnes 82739ddd567SLois Curfman McInnes .keywords: matrix, dense, parallel 8288965ea79SLois Curfman McInnes 82939ddd567SLois Curfman McInnes .seealso: MatCreate(), MatCreateSeqDense(), MatSetValues() 8308965ea79SLois Curfman McInnes @*/ 83118f449edSLois Curfman McInnes int MatCreateMPIDense(MPI_Comm comm,int m,int n,int M,int N,Scalar *data,Mat *newmat) 8328965ea79SLois Curfman McInnes { 8338965ea79SLois Curfman McInnes Mat mat; 83439ddd567SLois Curfman McInnes Mat_MPIDense *a; 83525cdf11fSBarry Smith int ierr, i,flg; 8368965ea79SLois Curfman McInnes 837ed2daf61SLois Curfman McInnes /* Note: For now, when data is specified above, this assumes the user correctly 838ed2daf61SLois Curfman McInnes allocates the local dense storage space. We should add error checking. */ 83918f449edSLois Curfman McInnes 8408965ea79SLois Curfman McInnes *newmat = 0; 8410452661fSBarry Smith PetscHeaderCreate(mat,_Mat,MAT_COOKIE,MATMPIDENSE,comm); 8428965ea79SLois Curfman McInnes PLogObjectCreate(mat); 8430452661fSBarry Smith mat->data = (void *) (a = PetscNew(Mat_MPIDense)); CHKPTRQ(a); 8448965ea79SLois Curfman McInnes PetscMemcpy(&mat->ops,&MatOps,sizeof(struct _MatOps)); 84539ddd567SLois Curfman McInnes mat->destroy = MatDestroy_MPIDense; 84639ddd567SLois Curfman McInnes mat->view = MatView_MPIDense; 8478965ea79SLois Curfman McInnes mat->factor = 0; 8488965ea79SLois Curfman McInnes 849622d7880SLois Curfman McInnes a->factor = 0; 8508965ea79SLois Curfman McInnes a->insertmode = NOT_SET_VALUES; 8518965ea79SLois Curfman McInnes MPI_Comm_rank(comm,&a->rank); 8528965ea79SLois Curfman McInnes MPI_Comm_size(comm,&a->size); 8538965ea79SLois Curfman McInnes 85439ddd567SLois Curfman McInnes if (M == PETSC_DECIDE) MPI_Allreduce(&m,&M,1,MPI_INT,MPI_SUM,comm); 8558965ea79SLois Curfman McInnes if (m == PETSC_DECIDE) {m = M/a->size + ((M % a->size) > a->rank);} 85639ddd567SLois Curfman McInnes 85739ddd567SLois Curfman McInnes /* each row stores all columns */ 85839ddd567SLois Curfman McInnes if (N == PETSC_DECIDE) N = n; 859d7e8b826SBarry Smith if (n == PETSC_DECIDE) {n = N/a->size + ((N % a->size) > a->rank);} 860d7e8b826SBarry Smith /* if (n != N) SETERRQ(1,"MatCreateMPIDense:For now, only n=N is supported"); */ 8618965ea79SLois Curfman McInnes a->N = N; 8628965ea79SLois Curfman McInnes a->M = M; 86339ddd567SLois Curfman McInnes a->m = m; 86439ddd567SLois Curfman McInnes a->n = n; 8658965ea79SLois Curfman McInnes 8668965ea79SLois Curfman McInnes /* build local table of row and column ownerships */ 867d7e8b826SBarry Smith a->rowners = (int *) PetscMalloc(2*(a->size+2)*sizeof(int)); CHKPTRQ(a->rowners); 868d7e8b826SBarry Smith a->cowners = a->rowners + a->size + 1; 869d7e8b826SBarry Smith PLogObjectMemory(mat,2*(a->size+2)*sizeof(int)+sizeof(struct _Mat)+ 87039ddd567SLois Curfman McInnes sizeof(Mat_MPIDense)); 8718965ea79SLois Curfman McInnes MPI_Allgather(&m,1,MPI_INT,a->rowners+1,1,MPI_INT,comm); 8728965ea79SLois Curfman McInnes a->rowners[0] = 0; 8738965ea79SLois Curfman McInnes for ( i=2; i<=a->size; i++ ) { 8748965ea79SLois Curfman McInnes a->rowners[i] += a->rowners[i-1]; 8758965ea79SLois Curfman McInnes } 8768965ea79SLois Curfman McInnes a->rstart = a->rowners[a->rank]; 8778965ea79SLois Curfman McInnes a->rend = a->rowners[a->rank+1]; 878d7e8b826SBarry Smith MPI_Allgather(&n,1,MPI_INT,a->cowners+1,1,MPI_INT,comm); 879d7e8b826SBarry Smith a->cowners[0] = 0; 880d7e8b826SBarry Smith for ( i=2; i<=a->size; i++ ) { 881d7e8b826SBarry Smith a->cowners[i] += a->cowners[i-1]; 882d7e8b826SBarry Smith } 8838965ea79SLois Curfman McInnes 88418f449edSLois Curfman McInnes ierr = MatCreateSeqDense(MPI_COMM_SELF,m,N,data,&a->A); CHKERRQ(ierr); 8858965ea79SLois Curfman McInnes PLogObjectParent(mat,a->A); 8868965ea79SLois Curfman McInnes 8878965ea79SLois Curfman McInnes /* build cache for off array entries formed */ 8888965ea79SLois Curfman McInnes ierr = StashBuild_Private(&a->stash); CHKERRQ(ierr); 8898965ea79SLois Curfman McInnes 8908965ea79SLois Curfman McInnes /* stuff used for matrix vector multiply */ 8918965ea79SLois Curfman McInnes a->lvec = 0; 8928965ea79SLois Curfman McInnes a->Mvctx = 0; 89339b7565bSBarry Smith a->roworiented = 1; 8948965ea79SLois Curfman McInnes 8958965ea79SLois Curfman McInnes *newmat = mat; 89625cdf11fSBarry Smith ierr = OptionsHasName(PETSC_NULL,"-help",&flg); CHKERRQ(ierr); 89725cdf11fSBarry Smith if (flg) { 8988c469469SLois Curfman McInnes ierr = MatPrintHelp(mat); CHKERRQ(ierr); 8998c469469SLois Curfman McInnes } 9008965ea79SLois Curfman McInnes return 0; 9018965ea79SLois Curfman McInnes } 9028965ea79SLois Curfman McInnes 9033d1612f7SBarry Smith static int MatConvertSameType_MPIDense(Mat A,Mat *newmat,int cpvalues) 9048965ea79SLois Curfman McInnes { 9058965ea79SLois Curfman McInnes Mat mat; 9063501a2bdSLois Curfman McInnes Mat_MPIDense *a,*oldmat = (Mat_MPIDense *) A->data; 90739ddd567SLois Curfman McInnes int ierr; 9082ba99913SLois Curfman McInnes FactorCtx *factor; 9098965ea79SLois Curfman McInnes 9108965ea79SLois Curfman McInnes *newmat = 0; 9110452661fSBarry Smith PetscHeaderCreate(mat,_Mat,MAT_COOKIE,MATMPIDENSE,A->comm); 9128965ea79SLois Curfman McInnes PLogObjectCreate(mat); 9130452661fSBarry Smith mat->data = (void *) (a = PetscNew(Mat_MPIDense)); CHKPTRQ(a); 9148965ea79SLois Curfman McInnes PetscMemcpy(&mat->ops,&MatOps,sizeof(struct _MatOps)); 91539ddd567SLois Curfman McInnes mat->destroy = MatDestroy_MPIDense; 91639ddd567SLois Curfman McInnes mat->view = MatView_MPIDense; 9173501a2bdSLois Curfman McInnes mat->factor = A->factor; 918c456f294SBarry Smith mat->assembled = PETSC_TRUE; 9198965ea79SLois Curfman McInnes 9208965ea79SLois Curfman McInnes a->m = oldmat->m; 9218965ea79SLois Curfman McInnes a->n = oldmat->n; 9228965ea79SLois Curfman McInnes a->M = oldmat->M; 9238965ea79SLois Curfman McInnes a->N = oldmat->N; 9242ba99913SLois Curfman McInnes if (oldmat->factor) { 9252ba99913SLois Curfman McInnes a->factor = (FactorCtx *) (factor = PetscNew(FactorCtx)); CHKPTRQ(factor); 9262ba99913SLois Curfman McInnes /* copy factor contents ... add this code! */ 9272ba99913SLois Curfman McInnes } else a->factor = 0; 9288965ea79SLois Curfman McInnes 9298965ea79SLois Curfman McInnes a->rstart = oldmat->rstart; 9308965ea79SLois Curfman McInnes a->rend = oldmat->rend; 9318965ea79SLois Curfman McInnes a->size = oldmat->size; 9328965ea79SLois Curfman McInnes a->rank = oldmat->rank; 9338965ea79SLois Curfman McInnes a->insertmode = NOT_SET_VALUES; 9348965ea79SLois Curfman McInnes 9350452661fSBarry Smith a->rowners = (int *) PetscMalloc((a->size+1)*sizeof(int)); CHKPTRQ(a->rowners); 93639ddd567SLois Curfman McInnes PLogObjectMemory(mat,(a->size+1)*sizeof(int)+sizeof(struct _Mat)+sizeof(Mat_MPIDense)); 9378965ea79SLois Curfman McInnes PetscMemcpy(a->rowners,oldmat->rowners,(a->size+1)*sizeof(int)); 9388965ea79SLois Curfman McInnes ierr = StashInitialize_Private(&a->stash); CHKERRQ(ierr); 9398965ea79SLois Curfman McInnes 9408965ea79SLois Curfman McInnes ierr = VecDuplicate(oldmat->lvec,&a->lvec); CHKERRQ(ierr); 9418965ea79SLois Curfman McInnes PLogObjectParent(mat,a->lvec); 94255659b69SBarry Smith ierr = VecScatterCopy(oldmat->Mvctx,&a->Mvctx); CHKERRQ(ierr); 9438965ea79SLois Curfman McInnes PLogObjectParent(mat,a->Mvctx); 9448965ea79SLois Curfman McInnes ierr = MatConvert(oldmat->A,MATSAME,&a->A); CHKERRQ(ierr); 9458965ea79SLois Curfman McInnes PLogObjectParent(mat,a->A); 9468965ea79SLois Curfman McInnes *newmat = mat; 9478965ea79SLois Curfman McInnes return 0; 9488965ea79SLois Curfman McInnes } 9498965ea79SLois Curfman McInnes 9508965ea79SLois Curfman McInnes #include "sysio.h" 9518965ea79SLois Curfman McInnes 95239ddd567SLois Curfman McInnes int MatLoad_MPIDense(Viewer bview,MatType type,Mat *newmat) 9538965ea79SLois Curfman McInnes { 9548965ea79SLois Curfman McInnes Mat A; 9558965ea79SLois Curfman McInnes int i, nz, ierr, j,rstart, rend, fd; 9568965ea79SLois Curfman McInnes Scalar *vals,*svals; 9578965ea79SLois Curfman McInnes PetscObject vobj = (PetscObject) bview; 9588965ea79SLois Curfman McInnes MPI_Comm comm = vobj->comm; 9598965ea79SLois Curfman McInnes MPI_Status status; 9608965ea79SLois Curfman McInnes int header[4],rank,size,*rowlengths = 0,M,N,m,*rowners,maxnz,*cols; 9618965ea79SLois Curfman McInnes int *ourlens,*sndcounts = 0,*procsnz = 0, *offlens,jj,*mycols,*smycols; 9628965ea79SLois Curfman McInnes int tag = ((PetscObject)bview)->tag; 9638965ea79SLois Curfman McInnes 9648965ea79SLois Curfman McInnes MPI_Comm_size(comm,&size); MPI_Comm_rank(comm,&rank); 9658965ea79SLois Curfman McInnes if (!rank) { 9668965ea79SLois Curfman McInnes ierr = ViewerFileGetDescriptor_Private(bview,&fd); CHKERRQ(ierr); 9678965ea79SLois Curfman McInnes ierr = SYRead(fd,(char *)header,4,SYINT); CHKERRQ(ierr); 96839ddd567SLois Curfman McInnes if (header[0] != MAT_COOKIE) SETERRQ(1,"MatLoad_MPIDenseorMPIRow:not matrix object"); 9698965ea79SLois Curfman McInnes } 9708965ea79SLois Curfman McInnes 9718965ea79SLois Curfman McInnes MPI_Bcast(header+1,3,MPI_INT,0,comm); 9728965ea79SLois Curfman McInnes M = header[1]; N = header[2]; 9738965ea79SLois Curfman McInnes /* determine ownership of all rows */ 9748965ea79SLois Curfman McInnes m = M/size + ((M % size) > rank); 9750452661fSBarry Smith rowners = (int *) PetscMalloc((size+2)*sizeof(int)); CHKPTRQ(rowners); 9768965ea79SLois Curfman McInnes MPI_Allgather(&m,1,MPI_INT,rowners+1,1,MPI_INT,comm); 9778965ea79SLois Curfman McInnes rowners[0] = 0; 9788965ea79SLois Curfman McInnes for ( i=2; i<=size; i++ ) { 9798965ea79SLois Curfman McInnes rowners[i] += rowners[i-1]; 9808965ea79SLois Curfman McInnes } 9818965ea79SLois Curfman McInnes rstart = rowners[rank]; 9828965ea79SLois Curfman McInnes rend = rowners[rank+1]; 9838965ea79SLois Curfman McInnes 9848965ea79SLois Curfman McInnes /* distribute row lengths to all processors */ 9850452661fSBarry Smith ourlens = (int*) PetscMalloc( 2*(rend-rstart)*sizeof(int) ); CHKPTRQ(ourlens); 9868965ea79SLois Curfman McInnes offlens = ourlens + (rend-rstart); 9878965ea79SLois Curfman McInnes if (!rank) { 9880452661fSBarry Smith rowlengths = (int*) PetscMalloc( M*sizeof(int) ); CHKPTRQ(rowlengths); 9898965ea79SLois Curfman McInnes ierr = SYRead(fd,rowlengths,M,SYINT); CHKERRQ(ierr); 9900452661fSBarry Smith sndcounts = (int*) PetscMalloc( size*sizeof(int) ); CHKPTRQ(sndcounts); 9918965ea79SLois Curfman McInnes for ( i=0; i<size; i++ ) sndcounts[i] = rowners[i+1] - rowners[i]; 9928965ea79SLois Curfman McInnes MPI_Scatterv(rowlengths,sndcounts,rowners,MPI_INT,ourlens,rend-rstart,MPI_INT,0,comm); 9930452661fSBarry Smith PetscFree(sndcounts); 9948965ea79SLois Curfman McInnes } 9958965ea79SLois Curfman McInnes else { 9968965ea79SLois Curfman McInnes MPI_Scatterv(0,0,0,MPI_INT,ourlens,rend-rstart,MPI_INT, 0,comm); 9978965ea79SLois Curfman McInnes } 9988965ea79SLois Curfman McInnes 9998965ea79SLois Curfman McInnes if (!rank) { 10008965ea79SLois Curfman McInnes /* calculate the number of nonzeros on each processor */ 10010452661fSBarry Smith procsnz = (int*) PetscMalloc( size*sizeof(int) ); CHKPTRQ(procsnz); 1002cddf8d76SBarry Smith PetscMemzero(procsnz,size*sizeof(int)); 10038965ea79SLois Curfman McInnes for ( i=0; i<size; i++ ) { 10048965ea79SLois Curfman McInnes for ( j=rowners[i]; j< rowners[i+1]; j++ ) { 10058965ea79SLois Curfman McInnes procsnz[i] += rowlengths[j]; 10068965ea79SLois Curfman McInnes } 10078965ea79SLois Curfman McInnes } 10080452661fSBarry Smith PetscFree(rowlengths); 10098965ea79SLois Curfman McInnes 10108965ea79SLois Curfman McInnes /* determine max buffer needed and allocate it */ 10118965ea79SLois Curfman McInnes maxnz = 0; 10128965ea79SLois Curfman McInnes for ( i=0; i<size; i++ ) { 10130452661fSBarry Smith maxnz = PetscMax(maxnz,procsnz[i]); 10148965ea79SLois Curfman McInnes } 10150452661fSBarry Smith cols = (int *) PetscMalloc( maxnz*sizeof(int) ); CHKPTRQ(cols); 10168965ea79SLois Curfman McInnes 10178965ea79SLois Curfman McInnes /* read in my part of the matrix column indices */ 10188965ea79SLois Curfman McInnes nz = procsnz[0]; 10190452661fSBarry Smith mycols = (int *) PetscMalloc( nz*sizeof(int) ); CHKPTRQ(mycols); 10208965ea79SLois Curfman McInnes ierr = SYRead(fd,mycols,nz,SYINT); CHKERRQ(ierr); 10218965ea79SLois Curfman McInnes 10228965ea79SLois Curfman McInnes /* read in every one elses and ship off */ 10238965ea79SLois Curfman McInnes for ( i=1; i<size; i++ ) { 10248965ea79SLois Curfman McInnes nz = procsnz[i]; 10258965ea79SLois Curfman McInnes ierr = SYRead(fd,cols,nz,SYINT); CHKERRQ(ierr); 10268965ea79SLois Curfman McInnes MPI_Send(cols,nz,MPI_INT,i,tag,comm); 10278965ea79SLois Curfman McInnes } 10280452661fSBarry Smith PetscFree(cols); 10298965ea79SLois Curfman McInnes } 10308965ea79SLois Curfman McInnes else { 10318965ea79SLois Curfman McInnes /* determine buffer space needed for message */ 10328965ea79SLois Curfman McInnes nz = 0; 10338965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 10348965ea79SLois Curfman McInnes nz += ourlens[i]; 10358965ea79SLois Curfman McInnes } 10360452661fSBarry Smith mycols = (int*) PetscMalloc( nz*sizeof(int) ); CHKPTRQ(mycols); 10378965ea79SLois Curfman McInnes 10388965ea79SLois Curfman McInnes /* receive message of column indices*/ 10398965ea79SLois Curfman McInnes MPI_Recv(mycols,nz,MPI_INT,0,tag,comm,&status); 10408965ea79SLois Curfman McInnes MPI_Get_count(&status,MPI_INT,&maxnz); 104139ddd567SLois Curfman McInnes if (maxnz != nz) SETERRQ(1,"MatLoad_MPIDenseorMPIRow:something is wrong with file"); 10428965ea79SLois Curfman McInnes } 10438965ea79SLois Curfman McInnes 10448965ea79SLois Curfman McInnes /* loop over local rows, determining number of off diagonal entries */ 1045cddf8d76SBarry Smith PetscMemzero(offlens,m*sizeof(int)); 10468965ea79SLois Curfman McInnes jj = 0; 10478965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 10488965ea79SLois Curfman McInnes for ( j=0; j<ourlens[i]; j++ ) { 10498965ea79SLois Curfman McInnes if (mycols[jj] < rstart || mycols[jj] >= rend) offlens[i]++; 10508965ea79SLois Curfman McInnes jj++; 10518965ea79SLois Curfman McInnes } 10528965ea79SLois Curfman McInnes } 10538965ea79SLois Curfman McInnes 10548965ea79SLois Curfman McInnes /* create our matrix */ 10558965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 10568965ea79SLois Curfman McInnes ourlens[i] -= offlens[i]; 10578965ea79SLois Curfman McInnes } 105839ddd567SLois Curfman McInnes if (type == MATMPIDENSE) { 1059b4fd4287SBarry Smith ierr = MatCreateMPIDense(comm,m,PETSC_DECIDE,M,N,PETSC_NULL,newmat);CHKERRQ(ierr); 10608965ea79SLois Curfman McInnes } 10618965ea79SLois Curfman McInnes A = *newmat; 10628965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 10638965ea79SLois Curfman McInnes ourlens[i] += offlens[i]; 10648965ea79SLois Curfman McInnes } 10658965ea79SLois Curfman McInnes 10668965ea79SLois Curfman McInnes if (!rank) { 10670452661fSBarry Smith vals = (Scalar *) PetscMalloc( maxnz*sizeof(Scalar) ); CHKPTRQ(vals); 10688965ea79SLois Curfman McInnes 10698965ea79SLois Curfman McInnes /* read in my part of the matrix numerical values */ 10708965ea79SLois Curfman McInnes nz = procsnz[0]; 10718965ea79SLois Curfman McInnes ierr = SYRead(fd,vals,nz,SYSCALAR); CHKERRQ(ierr); 10728965ea79SLois Curfman McInnes 10738965ea79SLois Curfman McInnes /* insert into matrix */ 10748965ea79SLois Curfman McInnes jj = rstart; 10758965ea79SLois Curfman McInnes smycols = mycols; 10768965ea79SLois Curfman McInnes svals = vals; 10778965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 10788965ea79SLois Curfman McInnes ierr = MatSetValues(A,1,&jj,ourlens[i],smycols,svals,INSERT_VALUES);CHKERRQ(ierr); 10798965ea79SLois Curfman McInnes smycols += ourlens[i]; 10808965ea79SLois Curfman McInnes svals += ourlens[i]; 10818965ea79SLois Curfman McInnes jj++; 10828965ea79SLois Curfman McInnes } 10838965ea79SLois Curfman McInnes 10848965ea79SLois Curfman McInnes /* read in other processors and ship out */ 10858965ea79SLois Curfman McInnes for ( i=1; i<size; i++ ) { 10868965ea79SLois Curfman McInnes nz = procsnz[i]; 10878965ea79SLois Curfman McInnes ierr = SYRead(fd,vals,nz,SYSCALAR); CHKERRQ(ierr); 10888965ea79SLois Curfman McInnes MPI_Send(vals,nz,MPIU_SCALAR,i,A->tag,comm); 10898965ea79SLois Curfman McInnes } 10900452661fSBarry Smith PetscFree(procsnz); 10918965ea79SLois Curfman McInnes } 10928965ea79SLois Curfman McInnes else { 10938965ea79SLois Curfman McInnes /* receive numeric values */ 10940452661fSBarry Smith vals = (Scalar*) PetscMalloc( nz*sizeof(Scalar) ); CHKPTRQ(vals); 10958965ea79SLois Curfman McInnes 10968965ea79SLois Curfman McInnes /* receive message of values*/ 10978965ea79SLois Curfman McInnes MPI_Recv(vals,nz,MPIU_SCALAR,0,A->tag,comm,&status); 10988965ea79SLois Curfman McInnes MPI_Get_count(&status,MPIU_SCALAR,&maxnz); 109939ddd567SLois Curfman McInnes if (maxnz != nz) SETERRQ(1,"MatLoad_MPIDenseorMPIRow:something is wrong with file"); 11008965ea79SLois Curfman McInnes 11018965ea79SLois Curfman McInnes /* insert into matrix */ 11028965ea79SLois Curfman McInnes jj = rstart; 11038965ea79SLois Curfman McInnes smycols = mycols; 11048965ea79SLois Curfman McInnes svals = vals; 11058965ea79SLois Curfman McInnes for ( i=0; i<m; i++ ) { 11068965ea79SLois Curfman McInnes ierr = MatSetValues(A,1,&jj,ourlens[i],smycols,svals,INSERT_VALUES);CHKERRQ(ierr); 11078965ea79SLois Curfman McInnes smycols += ourlens[i]; 11088965ea79SLois Curfman McInnes svals += ourlens[i]; 11098965ea79SLois Curfman McInnes jj++; 11108965ea79SLois Curfman McInnes } 11118965ea79SLois Curfman McInnes } 11120452661fSBarry Smith PetscFree(ourlens); PetscFree(vals); PetscFree(mycols); PetscFree(rowners); 11138965ea79SLois Curfman McInnes 11148965ea79SLois Curfman McInnes ierr = MatAssemblyBegin(A,FINAL_ASSEMBLY); CHKERRQ(ierr); 11158965ea79SLois Curfman McInnes ierr = MatAssemblyEnd(A,FINAL_ASSEMBLY); CHKERRQ(ierr); 11168965ea79SLois Curfman McInnes return 0; 11178965ea79SLois Curfman McInnes } 1118