xref: /petsc/src/mat/impls/dense/mpi/mpidense.c (revision 323b833ffd2abbc021b1f705dc98117c2173689c)
1 /*$Id: mpidense.c,v 1.147 2001/01/15 21:45:32 bsmith Exp balay $*/
2 
3 /*
4    Basic functions for basic parallel dense matrices.
5 */
6 
7 #include "src/mat/impls/dense/mpi/mpidense.h"
8 #include "src/vec/vecimpl.h"
9 
10 EXTERN_C_BEGIN
11 #undef __FUNC__
12 #define __FUNC__ "MatGetDiagonalBlock_MPIDense"
13 int MatGetDiagonalBlock_MPIDense(Mat A,PetscTruth *iscopy,MatReuse reuse,Mat *B)
14 {
15   Mat_MPIDense *mdn = (Mat_MPIDense*)A->data;
16   int          m = A->m,rstart = mdn->rstart,rank,ierr;
17   Scalar       *array;
18   MPI_Comm     comm;
19 
20   PetscFunctionBegin;
21   if (A->M != A->N) SETERRQ(PETSC_ERR_SUP,"Only square matrices supported.");
22 
23   /* The reuse aspect is not implemented efficiently */
24   if (reuse) { ierr = MatDestroy(*B);CHKERRQ(ierr);}
25 
26   ierr = MPI_Comm_rank(A->comm,&rank);CHKERRQ(ierr);
27   ierr = PetscObjectGetComm((PetscObject)(mdn->A),&comm);CHKERRQ(ierr);
28   ierr = MatGetArray(mdn->A,&array);CHKERRQ(ierr);
29   ierr = MatCreateSeqDense(comm,m,m,array+m*rstart,B);CHKERRQ(ierr);
30   ierr = MatRestoreArray(mdn->A,&array);CHKERRQ(ierr);
31   ierr = MatAssemblyBegin(*B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
32   ierr = MatAssemblyEnd(*B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
33 
34   *iscopy = PETSC_TRUE;
35   PetscFunctionReturn(0);
36 }
37 EXTERN_C_END
38 
39 EXTERN int MatSetUpMultiply_MPIDense(Mat);
40 
41 #undef __FUNC__
42 #define __FUNC__ "MatSetValues_MPIDense"
43 int MatSetValues_MPIDense(Mat mat,int m,int *idxm,int n,int *idxn,Scalar *v,InsertMode addv)
44 {
45   Mat_MPIDense *A = (Mat_MPIDense*)mat->data;
46   int          ierr,i,j,rstart = A->rstart,rend = A->rend,row;
47   PetscTruth   roworiented = A->roworiented;
48 
49   PetscFunctionBegin;
50   for (i=0; i<m; i++) {
51     if (idxm[i] < 0) continue;
52     if (idxm[i] >= mat->M) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Row too large");
53     if (idxm[i] >= rstart && idxm[i] < rend) {
54       row = idxm[i] - rstart;
55       if (roworiented) {
56         ierr = MatSetValues(A->A,1,&row,n,idxn,v+i*n,addv);CHKERRQ(ierr);
57       } else {
58         for (j=0; j<n; j++) {
59           if (idxn[j] < 0) continue;
60           if (idxn[j] >= mat->N) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Column too large");
61           ierr = MatSetValues(A->A,1,&row,1,&idxn[j],v+i+j*m,addv);CHKERRQ(ierr);
62         }
63       }
64     } else {
65       if (!A->donotstash) {
66         if (roworiented) {
67           ierr = MatStashValuesRow_Private(&mat->stash,idxm[i],n,idxn,v+i*n);CHKERRQ(ierr);
68         } else {
69           ierr = MatStashValuesCol_Private(&mat->stash,idxm[i],n,idxn,v+i,m);CHKERRQ(ierr);
70         }
71       }
72     }
73   }
74   PetscFunctionReturn(0);
75 }
76 
77 #undef __FUNC__
78 #define __FUNC__ "MatGetValues_MPIDense"
79 int MatGetValues_MPIDense(Mat mat,int m,int *idxm,int n,int *idxn,Scalar *v)
80 {
81   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
82   int          ierr,i,j,rstart = mdn->rstart,rend = mdn->rend,row;
83 
84   PetscFunctionBegin;
85   for (i=0; i<m; i++) {
86     if (idxm[i] < 0) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Negative row");
87     if (idxm[i] >= mat->M) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Row too large");
88     if (idxm[i] >= rstart && idxm[i] < rend) {
89       row = idxm[i] - rstart;
90       for (j=0; j<n; j++) {
91         if (idxn[j] < 0) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Negative column");
92         if (idxn[j] >= mat->N) {
93           SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Column too large");
94         }
95         ierr = MatGetValues(mdn->A,1,&row,1,&idxn[j],v+i*n+j);CHKERRQ(ierr);
96       }
97     } else {
98       SETERRQ(PETSC_ERR_SUP,"Only local values currently supported");
99     }
100   }
101   PetscFunctionReturn(0);
102 }
103 
104 #undef __FUNC__
105 #define __FUNC__ "MatGetArray_MPIDense"
106 int MatGetArray_MPIDense(Mat A,Scalar **array)
107 {
108   Mat_MPIDense *a = (Mat_MPIDense*)A->data;
109   int          ierr;
110 
111   PetscFunctionBegin;
112   ierr = MatGetArray(a->A,array);CHKERRQ(ierr);
113   PetscFunctionReturn(0);
114 }
115 
116 #undef __FUNC__
117 #define __FUNC__ "MatGetSubMatrix_MPIDense"
118 static int MatGetSubMatrix_MPIDense(Mat A,IS isrow,IS iscol,int cs,MatReuse scall,Mat *B)
119 {
120   Mat_MPIDense *mat = (Mat_MPIDense*)A->data,*newmatd;
121   Mat_SeqDense *lmat = (Mat_SeqDense*)mat->A->data;
122   int          i,j,ierr,*irow,*icol,rstart,rend,nrows,ncols,nlrows,nlcols,rank;
123   Scalar       *av,*bv,*v = lmat->v;
124   Mat          newmat;
125 
126   PetscFunctionBegin;
127   ierr = MPI_Comm_rank(A->comm,&rank);CHKERRQ(ierr);
128   ierr = ISGetIndices(isrow,&irow);CHKERRQ(ierr);
129   ierr = ISGetIndices(iscol,&icol);CHKERRQ(ierr);
130   ierr = ISGetLocalSize(isrow,&nrows);CHKERRQ(ierr);
131   ierr = ISGetLocalSize(iscol,&ncols);CHKERRQ(ierr);
132 
133   /* No parallel redistribution currently supported! Should really check each index set
134      to comfirm that it is OK.  ... Currently supports only submatrix same partitioning as
135      original matrix! */
136 
137   ierr = MatGetLocalSize(A,&nlrows,&nlcols);CHKERRQ(ierr);
138   ierr = MatGetOwnershipRange(A,&rstart,&rend);CHKERRQ(ierr);
139 
140   /* Check submatrix call */
141   if (scall == MAT_REUSE_MATRIX) {
142     /* SETERRQ(PETSC_ERR_ARG_SIZ,"Reused submatrix wrong size"); */
143     /* Really need to test rows and column sizes! */
144     newmat = *B;
145   } else {
146     /* Create and fill new matrix */
147     ierr = MatCreateMPIDense(A->comm,nrows,cs,PETSC_DECIDE,ncols,PETSC_NULL,&newmat);CHKERRQ(ierr);
148   }
149 
150   /* Now extract the data pointers and do the copy, column at a time */
151   newmatd = (Mat_MPIDense*)newmat->data;
152   bv      = ((Mat_SeqDense *)newmatd->A->data)->v;
153 
154   for (i=0; i<ncols; i++) {
155     av = v + nlrows*icol[i];
156     for (j=0; j<nrows; j++) {
157       *bv++ = av[irow[j] - rstart];
158     }
159   }
160 
161   /* Assemble the matrices so that the correct flags are set */
162   ierr = MatAssemblyBegin(newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
163   ierr = MatAssemblyEnd(newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
164 
165   /* Free work space */
166   ierr = ISRestoreIndices(isrow,&irow);CHKERRQ(ierr);
167   ierr = ISRestoreIndices(iscol,&icol);CHKERRQ(ierr);
168   *B = newmat;
169   PetscFunctionReturn(0);
170 }
171 
172 #undef __FUNC__
173 #define __FUNC__ "MatRestoreArray_MPIDense"
174 int MatRestoreArray_MPIDense(Mat A,Scalar **array)
175 {
176   PetscFunctionBegin;
177   PetscFunctionReturn(0);
178 }
179 
180 #undef __FUNC__
181 #define __FUNC__ "MatAssemblyBegin_MPIDense"
182 int MatAssemblyBegin_MPIDense(Mat mat,MatAssemblyType mode)
183 {
184   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
185   MPI_Comm     comm = mat->comm;
186   int          ierr,nstash,reallocs;
187   InsertMode   addv;
188 
189   PetscFunctionBegin;
190   /* make sure all processors are either in INSERTMODE or ADDMODE */
191   ierr = MPI_Allreduce(&mat->insertmode,&addv,1,MPI_INT,MPI_BOR,comm);CHKERRQ(ierr);
192   if (addv == (ADD_VALUES|INSERT_VALUES)) {
193     SETERRQ(PETSC_ERR_ARG_WRONGSTATE,"Cannot mix adds/inserts on different procs");
194   }
195   mat->insertmode = addv; /* in case this processor had no cache */
196 
197   ierr = MatStashScatterBegin_Private(&mat->stash,mdn->rowners);CHKERRQ(ierr);
198   ierr = MatStashGetInfo_Private(&mat->stash,&nstash,&reallocs);CHKERRQ(ierr);
199   PetscLogInfo(mdn->A,"MatAssemblyBegin_MPIDense:Stash has %d entries, uses %d mallocs.\n",nstash,reallocs);
200   PetscFunctionReturn(0);
201 }
202 
203 #undef __FUNC__
204 #define __FUNC__ "MatAssemblyEnd_MPIDense"
205 int MatAssemblyEnd_MPIDense(Mat mat,MatAssemblyType mode)
206 {
207   Mat_MPIDense *mdn=(Mat_MPIDense*)mat->data;
208   int          i,n,ierr,*row,*col,flg,j,rstart,ncols;
209   Scalar       *val;
210   InsertMode   addv=mat->insertmode;
211 
212   PetscFunctionBegin;
213   /*  wait on receives */
214   while (1) {
215     ierr = MatStashScatterGetMesg_Private(&mat->stash,&n,&row,&col,&val,&flg);CHKERRQ(ierr);
216     if (!flg) break;
217 
218     for (i=0; i<n;) {
219       /* Now identify the consecutive vals belonging to the same row */
220       for (j=i,rstart=row[j]; j<n; j++) { if (row[j] != rstart) break; }
221       if (j < n) ncols = j-i;
222       else       ncols = n-i;
223       /* Now assemble all these values with a single function call */
224       ierr = MatSetValues_MPIDense(mat,1,row+i,ncols,col+i,val+i,addv);CHKERRQ(ierr);
225       i = j;
226     }
227   }
228   ierr = MatStashScatterEnd_Private(&mat->stash);CHKERRQ(ierr);
229 
230   ierr = MatAssemblyBegin(mdn->A,mode);CHKERRQ(ierr);
231   ierr = MatAssemblyEnd(mdn->A,mode);CHKERRQ(ierr);
232 
233   if (!mat->was_assembled && mode == MAT_FINAL_ASSEMBLY) {
234     ierr = MatSetUpMultiply_MPIDense(mat);CHKERRQ(ierr);
235   }
236   PetscFunctionReturn(0);
237 }
238 
239 #undef __FUNC__
240 #define __FUNC__ "MatZeroEntries_MPIDense"
241 int MatZeroEntries_MPIDense(Mat A)
242 {
243   int          ierr;
244   Mat_MPIDense *l = (Mat_MPIDense*)A->data;
245 
246   PetscFunctionBegin;
247   ierr = MatZeroEntries(l->A);CHKERRQ(ierr);
248   PetscFunctionReturn(0);
249 }
250 
251 #undef __FUNC__
252 #define __FUNC__ "MatGetBlockSize_MPIDense"
253 int MatGetBlockSize_MPIDense(Mat A,int *bs)
254 {
255   PetscFunctionBegin;
256   *bs = 1;
257   PetscFunctionReturn(0);
258 }
259 
260 /* the code does not do the diagonal entries correctly unless the
261    matrix is square and the column and row owerships are identical.
262    This is a BUG. The only way to fix it seems to be to access
263    mdn->A and mdn->B directly and not through the MatZeroRows()
264    routine.
265 */
266 #undef __FUNC__
267 #define __FUNC__ "MatZeroRows_MPIDense"
268 int MatZeroRows_MPIDense(Mat A,IS is,Scalar *diag)
269 {
270   Mat_MPIDense   *l = (Mat_MPIDense*)A->data;
271   int            i,ierr,N,*rows,*owners = l->rowners,size = l->size;
272   int            *procs,*nprocs,j,idx,nsends,*work;
273   int            nmax,*svalues,*starts,*owner,nrecvs,rank = l->rank;
274   int            *rvalues,tag = A->tag,count,base,slen,n,*source;
275   int            *lens,imdex,*lrows,*values;
276   MPI_Comm       comm = A->comm;
277   MPI_Request    *send_waits,*recv_waits;
278   MPI_Status     recv_status,*send_status;
279   IS             istmp;
280   PetscTruth     found;
281 
282   PetscFunctionBegin;
283   ierr = ISGetLocalSize(is,&N);CHKERRQ(ierr);
284   ierr = ISGetIndices(is,&rows);CHKERRQ(ierr);
285 
286   /*  first count number of contributors to each processor */
287   ierr  = PetscMalloc(2*size*sizeof(int),&nprocs);CHKERRQ(ierr);
288   ierr  = PetscMemzero(nprocs,2*size*sizeof(int));CHKERRQ(ierr);
289   procs = nprocs + size;
290   ierr  = PetscMalloc((N+1)*sizeof(int),&owner);CHKERRQ(ierr); /* see note*/
291   for (i=0; i<N; i++) {
292     idx = rows[i];
293     found = PETSC_FALSE;
294     for (j=0; j<size; j++) {
295       if (idx >= owners[j] && idx < owners[j+1]) {
296         nprocs[j]++; procs[j] = 1; owner[i] = j; found = PETSC_TRUE; break;
297       }
298     }
299     if (!found) SETERRQ(PETSC_ERR_ARG_OUTOFRANGE,"Index out of range");
300   }
301   nsends = 0;  for (i=0; i<size; i++) { nsends += procs[i];}
302 
303   /* inform other processors of number of messages and max length*/
304   ierr   = PetscMalloc(2*size*sizeof(int),&work);CHKERRQ(ierr);
305   ierr   = MPI_Allreduce(nprocs,work,2*size,MPI_INT,PetscMaxSum_Op,comm);CHKERRQ(ierr);
306   nmax   = work[rank];
307   nrecvs = work[size+rank];
308   ierr   = PetscFree(work);CHKERRQ(ierr);
309 
310   /* post receives:   */
311   ierr = PetscMalloc((nrecvs+1)*(nmax+1)*sizeof(int),&rvalues);CHKERRQ(ierr);
312   ierr = PetscMalloc((nrecvs+1)*sizeof(MPI_Request),&recv_waits);CHKERRQ(ierr);
313   for (i=0; i<nrecvs; i++) {
314     ierr = MPI_Irecv(rvalues+nmax*i,nmax,MPI_INT,MPI_ANY_SOURCE,tag,comm,recv_waits+i);CHKERRQ(ierr);
315   }
316 
317   /* do sends:
318       1) starts[i] gives the starting index in svalues for stuff going to
319          the ith processor
320   */
321   ierr = PetscMalloc((N+1)*sizeof(int),&svalues);CHKERRQ(ierr);
322   ierr = PetscMalloc((nsends+1)*sizeof(MPI_Request),&send_waits);CHKERRQ(ierr);
323   ierr = PetscMalloc((size+1)*sizeof(int),&starts);CHKERRQ(ierr);
324   starts[0]  = 0;
325   for (i=1; i<size; i++) { starts[i] = starts[i-1] + nprocs[i-1];}
326   for (i=0; i<N; i++) {
327     svalues[starts[owner[i]]++] = rows[i];
328   }
329   ISRestoreIndices(is,&rows);
330 
331   starts[0] = 0;
332   for (i=1; i<size+1; i++) { starts[i] = starts[i-1] + nprocs[i-1];}
333   count = 0;
334   for (i=0; i<size; i++) {
335     if (procs[i]) {
336       ierr = MPI_Isend(svalues+starts[i],nprocs[i],MPI_INT,i,tag,comm,send_waits+count++);CHKERRQ(ierr);
337     }
338   }
339   ierr = PetscFree(starts);CHKERRQ(ierr);
340 
341   base = owners[rank];
342 
343   /*  wait on receives */
344   ierr   = PetscMalloc(2*(nrecvs+1)*sizeof(int),&lens);CHKERRQ(ierr);
345   source = lens + nrecvs;
346   count  = nrecvs; slen = 0;
347   while (count) {
348     ierr = MPI_Waitany(nrecvs,recv_waits,&imdex,&recv_status);CHKERRQ(ierr);
349     /* unpack receives into our local space */
350     ierr = MPI_Get_count(&recv_status,MPI_INT,&n);CHKERRQ(ierr);
351     source[imdex]  = recv_status.MPI_SOURCE;
352     lens[imdex]  = n;
353     slen += n;
354     count--;
355   }
356   ierr = PetscFree(recv_waits);CHKERRQ(ierr);
357 
358   /* move the data into the send scatter */
359   ierr = PetscMalloc((slen+1)*sizeof(int),&lrows);CHKERRQ(ierr);
360   count = 0;
361   for (i=0; i<nrecvs; i++) {
362     values = rvalues + i*nmax;
363     for (j=0; j<lens[i]; j++) {
364       lrows[count++] = values[j] - base;
365     }
366   }
367   ierr = PetscFree(rvalues);CHKERRQ(ierr);
368   ierr = PetscFree(lens);CHKERRQ(ierr);
369   ierr = PetscFree(owner);CHKERRQ(ierr);
370   ierr = PetscFree(nprocs);CHKERRQ(ierr);
371 
372   /* actually zap the local rows */
373   ierr = ISCreateGeneral(PETSC_COMM_SELF,slen,lrows,&istmp);CHKERRQ(ierr);
374   PetscLogObjectParent(A,istmp);
375   ierr = PetscFree(lrows);CHKERRQ(ierr);
376   ierr = MatZeroRows(l->A,istmp,diag);CHKERRQ(ierr);
377   ierr = ISDestroy(istmp);CHKERRQ(ierr);
378 
379   /* wait on sends */
380   if (nsends) {
381     ierr = PetscMalloc(nsends*sizeof(MPI_Status),&send_status);CHKERRQ(ierr);
382     ierr = MPI_Waitall(nsends,send_waits,send_status);CHKERRQ(ierr);
383     ierr = PetscFree(send_status);CHKERRQ(ierr);
384   }
385   ierr = PetscFree(send_waits);CHKERRQ(ierr);
386   ierr = PetscFree(svalues);CHKERRQ(ierr);
387 
388   PetscFunctionReturn(0);
389 }
390 
391 #undef __FUNC__
392 #define __FUNC__ "MatMult_MPIDense"
393 int MatMult_MPIDense(Mat mat,Vec xx,Vec yy)
394 {
395   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
396   int          ierr;
397 
398   PetscFunctionBegin;
399   ierr = VecScatterBegin(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr);
400   ierr = VecScatterEnd(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr);
401   ierr = MatMult_SeqDense(mdn->A,mdn->lvec,yy);CHKERRQ(ierr);
402   PetscFunctionReturn(0);
403 }
404 
405 #undef __FUNC__
406 #define __FUNC__ "MatMultAdd_MPIDense"
407 int MatMultAdd_MPIDense(Mat mat,Vec xx,Vec yy,Vec zz)
408 {
409   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
410   int          ierr;
411 
412   PetscFunctionBegin;
413   ierr = VecScatterBegin(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr);
414   ierr = VecScatterEnd(xx,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr);
415   ierr = MatMultAdd_SeqDense(mdn->A,mdn->lvec,yy,zz);CHKERRQ(ierr);
416   PetscFunctionReturn(0);
417 }
418 
419 #undef __FUNC__
420 #define __FUNC__ "MatMultTranspose_MPIDense"
421 int MatMultTranspose_MPIDense(Mat A,Vec xx,Vec yy)
422 {
423   Mat_MPIDense *a = (Mat_MPIDense*)A->data;
424   int          ierr;
425   Scalar       zero = 0.0;
426 
427   PetscFunctionBegin;
428   ierr = VecSet(&zero,yy);CHKERRQ(ierr);
429   ierr = MatMultTranspose_SeqDense(a->A,xx,a->lvec);CHKERRQ(ierr);
430   ierr = VecScatterBegin(a->lvec,yy,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr);
431   ierr = VecScatterEnd(a->lvec,yy,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr);
432   PetscFunctionReturn(0);
433 }
434 
435 #undef __FUNC__
436 #define __FUNC__ "MatMultTransposeAdd_MPIDense"
437 int MatMultTransposeAdd_MPIDense(Mat A,Vec xx,Vec yy,Vec zz)
438 {
439   Mat_MPIDense *a = (Mat_MPIDense*)A->data;
440   int          ierr;
441 
442   PetscFunctionBegin;
443   ierr = VecCopy(yy,zz);CHKERRQ(ierr);
444   ierr = MatMultTranspose_SeqDense(a->A,xx,a->lvec);CHKERRQ(ierr);
445   ierr = VecScatterBegin(a->lvec,zz,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr);
446   ierr = VecScatterEnd(a->lvec,zz,ADD_VALUES,SCATTER_REVERSE,a->Mvctx);CHKERRQ(ierr);
447   PetscFunctionReturn(0);
448 }
449 
450 #undef __FUNC__
451 #define __FUNC__ "MatGetDiagonal_MPIDense"
452 int MatGetDiagonal_MPIDense(Mat A,Vec v)
453 {
454   Mat_MPIDense *a = (Mat_MPIDense*)A->data;
455   Mat_SeqDense *aloc = (Mat_SeqDense*)a->A->data;
456   int          ierr,len,i,n,m = A->m,radd;
457   Scalar       *x,zero = 0.0;
458 
459   PetscFunctionBegin;
460   ierr = VecSet(&zero,v);CHKERRQ(ierr);
461   ierr = VecGetArray(v,&x);CHKERRQ(ierr);
462   ierr = VecGetSize(v,&n);CHKERRQ(ierr);
463   if (n != A->M) SETERRQ(PETSC_ERR_ARG_SIZ,"Nonconforming mat and vec");
464   len  = PetscMin(a->A->m,a->A->n);
465   radd = a->rstart*m;
466   for (i=0; i<len; i++) {
467     x[i] = aloc->v[radd + i*m + i];
468   }
469   ierr = VecRestoreArray(v,&x);CHKERRQ(ierr);
470   PetscFunctionReturn(0);
471 }
472 
473 #undef __FUNC__
474 #define __FUNC__ "MatDestroy_MPIDense"
475 int MatDestroy_MPIDense(Mat mat)
476 {
477   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
478   int          ierr;
479 
480   PetscFunctionBegin;
481 
482 #if defined(PETSC_USE_LOG)
483   PetscLogObjectState((PetscObject)mat,"Rows=%d, Cols=%d",mat->M,mat->N);
484 #endif
485   ierr = MatStashDestroy_Private(&mat->stash);CHKERRQ(ierr);
486   ierr = PetscFree(mdn->rowners);CHKERRQ(ierr);
487   ierr = MatDestroy(mdn->A);CHKERRQ(ierr);
488   if (mdn->lvec)   VecDestroy(mdn->lvec);
489   if (mdn->Mvctx)  VecScatterDestroy(mdn->Mvctx);
490   if (mdn->factor) {
491     if (mdn->factor->temp)   {ierr = PetscFree(mdn->factor->temp);CHKERRQ(ierr);}
492     if (mdn->factor->tag)    {ierr = PetscFree(mdn->factor->tag);CHKERRQ(ierr);}
493     if (mdn->factor->pivots) {ierr = PetscFree(mdn->factor->pivots);CHKERRQ(ierr);}
494     ierr = PetscFree(mdn->factor);CHKERRQ(ierr);
495   }
496   ierr = PetscFree(mdn);CHKERRQ(ierr);
497   PetscFunctionReturn(0);
498 }
499 
500 #undef __FUNC__
501 #define __FUNC__ "MatView_MPIDense_Binary"
502 static int MatView_MPIDense_Binary(Mat mat,PetscViewer viewer)
503 {
504   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
505   int          ierr;
506 
507   PetscFunctionBegin;
508   if (mdn->size == 1) {
509     ierr = MatView(mdn->A,viewer);CHKERRQ(ierr);
510   }
511   else SETERRQ(PETSC_ERR_SUP,"Only uniprocessor output supported");
512   PetscFunctionReturn(0);
513 }
514 
515 #undef __FUNC__
516 #define __FUNC__ "MatView_MPIDense_ASCIIorDraworSocket"
517 static int MatView_MPIDense_ASCIIorDraworSocket(Mat mat,PetscViewer viewer)
518 {
519   Mat_MPIDense *mdn = (Mat_MPIDense*)mat->data;
520   int          ierr,format,size = mdn->size,rank = mdn->rank;
521   PetscViewerType   vtype;
522   PetscTruth   isascii,isdraw;
523   PetscViewer       sviewer;
524 
525   PetscFunctionBegin;
526   ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_ASCII,&isascii);CHKERRQ(ierr);
527   ierr = PetscTypeCompare((PetscObject)viewer,PETSC_DRAW_VIEWER,&isdraw);CHKERRQ(ierr);
528   if (isascii) {
529     ierr = PetscViewerGetType(viewer,&vtype);CHKERRQ(ierr);
530     ierr = PetscViewerGetFormat(viewer,&format);CHKERRQ(ierr);
531     if (format == PETSC_VIEWER_FORMAT_ASCII_INFO_LONG) {
532       MatInfo info;
533       ierr = MatGetInfo(mat,MAT_LOCAL,&info);CHKERRQ(ierr);
534       ierr = PetscViewerASCIISynchronizedPrintf(viewer,"  [%d] local rows %d nz %d nz alloced %d mem %d \n",rank,mat->m,
535                    (int)info.nz_used,(int)info.nz_allocated,(int)info.memory);CHKERRQ(ierr);
536       ierr = PetscViewerFlush(viewer);CHKERRQ(ierr);
537       ierr = VecScatterView(mdn->Mvctx,viewer);CHKERRQ(ierr);
538       PetscFunctionReturn(0);
539     } else if (format == PETSC_VIEWER_FORMAT_ASCII_INFO) {
540       PetscFunctionReturn(0);
541     }
542   } else if (isdraw) {
543     PetscDraw       draw;
544     PetscTruth isnull;
545 
546     ierr = PetscViewerDrawGetDraw(viewer,0,&draw);CHKERRQ(ierr);
547     ierr = PetscDrawIsNull(draw,&isnull);CHKERRQ(ierr);
548     if (isnull) PetscFunctionReturn(0);
549   }
550 
551   if (size == 1) {
552     ierr = MatView(mdn->A,viewer);CHKERRQ(ierr);
553   } else {
554     /* assemble the entire matrix onto first processor. */
555     Mat          A;
556     int          M = mat->M,N = mat->N,m,row,i,nz,*cols;
557     Scalar       *vals;
558 
559     if (!rank) {
560       ierr = MatCreateMPIDense(mat->comm,M,N,M,N,PETSC_NULL,&A);CHKERRQ(ierr);
561     } else {
562       ierr = MatCreateMPIDense(mat->comm,0,0,M,N,PETSC_NULL,&A);CHKERRQ(ierr);
563     }
564     PetscLogObjectParent(mat,A);
565 
566     /* Copy the matrix ... This isn't the most efficient means,
567        but it's quick for now */
568     row = mdn->rstart; m = mdn->A->m;
569     for (i=0; i<m; i++) {
570       ierr = MatGetRow(mat,row,&nz,&cols,&vals);CHKERRQ(ierr);
571       ierr = MatSetValues(A,1,&row,nz,cols,vals,INSERT_VALUES);CHKERRQ(ierr);
572       ierr = MatRestoreRow(mat,row,&nz,&cols,&vals);CHKERRQ(ierr);
573       row++;
574     }
575 
576     ierr = MatAssemblyBegin(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
577     ierr = MatAssemblyEnd(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
578     ierr = PetscViewerGetSingleton(viewer,&sviewer);CHKERRQ(ierr);
579     if (!rank) {
580       ierr = MatView(((Mat_MPIDense*)(A->data))->A,sviewer);CHKERRQ(ierr);
581     }
582     ierr = PetscViewerRestoreSingleton(viewer,&sviewer);CHKERRQ(ierr);
583     ierr = PetscViewerFlush(viewer);CHKERRQ(ierr);
584     ierr = MatDestroy(A);CHKERRQ(ierr);
585   }
586   PetscFunctionReturn(0);
587 }
588 
589 #undef __FUNC__
590 #define __FUNC__ "MatView_MPIDense"
591 int MatView_MPIDense(Mat mat,PetscViewer viewer)
592 {
593   int        ierr;
594   PetscTruth isascii,isbinary,isdraw,issocket;
595 
596   PetscFunctionBegin;
597 
598   ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_ASCII,&isascii);CHKERRQ(ierr);
599   ierr = PetscTypeCompare((PetscObject)viewer,PETSC_BINARY_VIEWER,&isbinary);CHKERRQ(ierr);
600   ierr = PetscTypeCompare((PetscObject)viewer,PETSC_VIEWER_SOCKET,&issocket);CHKERRQ(ierr);
601   ierr = PetscTypeCompare((PetscObject)viewer,PETSC_DRAW_VIEWER,&isdraw);CHKERRQ(ierr);
602 
603   if (isascii || issocket || isdraw) {
604     ierr = MatView_MPIDense_ASCIIorDraworSocket(mat,viewer);CHKERRQ(ierr);
605   } else if (isbinary) {
606     ierr = MatView_MPIDense_Binary(mat,viewer);CHKERRQ(ierr);
607   } else {
608     SETERRQ1(1,"Viewer type %s not supported by MPI dense matrix",((PetscObject)viewer)->type_name);
609   }
610   PetscFunctionReturn(0);
611 }
612 
613 #undef __FUNC__
614 #define __FUNC__ "MatGetInfo_MPIDense"
615 int MatGetInfo_MPIDense(Mat A,MatInfoType flag,MatInfo *info)
616 {
617   Mat_MPIDense *mat = (Mat_MPIDense*)A->data;
618   Mat          mdn = mat->A;
619   int          ierr;
620   PetscReal    isend[5],irecv[5];
621 
622   PetscFunctionBegin;
623   info->rows_global    = (double)A->M;
624   info->columns_global = (double)A->N;
625   info->rows_local     = (double)A->m;
626   info->columns_local  = (double)A->N;
627   info->block_size     = 1.0;
628   ierr = MatGetInfo(mdn,MAT_LOCAL,info);CHKERRQ(ierr);
629   isend[0] = info->nz_used; isend[1] = info->nz_allocated; isend[2] = info->nz_unneeded;
630   isend[3] = info->memory;  isend[4] = info->mallocs;
631   if (flag == MAT_LOCAL) {
632     info->nz_used      = isend[0];
633     info->nz_allocated = isend[1];
634     info->nz_unneeded  = isend[2];
635     info->memory       = isend[3];
636     info->mallocs      = isend[4];
637   } else if (flag == MAT_GLOBAL_MAX) {
638     ierr = MPI_Allreduce(isend,irecv,5,MPI_DOUBLE,MPI_MAX,A->comm);CHKERRQ(ierr);
639     info->nz_used      = irecv[0];
640     info->nz_allocated = irecv[1];
641     info->nz_unneeded  = irecv[2];
642     info->memory       = irecv[3];
643     info->mallocs      = irecv[4];
644   } else if (flag == MAT_GLOBAL_SUM) {
645     ierr = MPI_Allreduce(isend,irecv,5,MPI_DOUBLE,MPI_SUM,A->comm);CHKERRQ(ierr);
646     info->nz_used      = irecv[0];
647     info->nz_allocated = irecv[1];
648     info->nz_unneeded  = irecv[2];
649     info->memory       = irecv[3];
650     info->mallocs      = irecv[4];
651   }
652   info->fill_ratio_given  = 0; /* no parallel LU/ILU/Cholesky */
653   info->fill_ratio_needed = 0;
654   info->factor_mallocs    = 0;
655   PetscFunctionReturn(0);
656 }
657 
658 #undef __FUNC__
659 #define __FUNC__ "MatSetOption_MPIDense"
660 int MatSetOption_MPIDense(Mat A,MatOption op)
661 {
662   Mat_MPIDense *a = (Mat_MPIDense*)A->data;
663   int          ierr;
664 
665   PetscFunctionBegin;
666   if (op == MAT_NO_NEW_NONZERO_LOCATIONS ||
667       op == MAT_YES_NEW_NONZERO_LOCATIONS ||
668       op == MAT_NEW_NONZERO_LOCATION_ERR ||
669       op == MAT_NEW_NONZERO_ALLOCATION_ERR ||
670       op == MAT_COLUMNS_SORTED ||
671       op == MAT_COLUMNS_UNSORTED) {
672         ierr = MatSetOption(a->A,op);CHKERRQ(ierr);
673   } else if (op == MAT_ROW_ORIENTED) {
674         a->roworiented = PETSC_TRUE;
675         ierr = MatSetOption(a->A,op);CHKERRQ(ierr);
676   } else if (op == MAT_ROWS_SORTED ||
677              op == MAT_ROWS_UNSORTED ||
678              op == MAT_SYMMETRIC ||
679              op == MAT_STRUCTURALLY_SYMMETRIC ||
680              op == MAT_YES_NEW_DIAGONALS ||
681              op == MAT_USE_HASH_TABLE) {
682     PetscLogInfo(A,"MatSetOption_MPIDense:Option ignored\n");
683   } else if (op == MAT_COLUMN_ORIENTED) {
684     a->roworiented = PETSC_FALSE;
685     ierr = MatSetOption(a->A,op);CHKERRQ(ierr);
686   } else if (op == MAT_IGNORE_OFF_PROC_ENTRIES) {
687     a->donotstash = PETSC_TRUE;
688   } else if (op == MAT_NO_NEW_DIAGONALS) {
689     SETERRQ(PETSC_ERR_SUP,"MAT_NO_NEW_DIAGONALS");
690   } else {
691     SETERRQ(PETSC_ERR_SUP,"unknown option");
692   }
693   PetscFunctionReturn(0);
694 }
695 
696 #undef __FUNC__
697 #define __FUNC__ "MatGetOwnershipRange_MPIDense"
698 int MatGetOwnershipRange_MPIDense(Mat A,int *m,int *n)
699 {
700   Mat_MPIDense *mat = (Mat_MPIDense*)A->data;
701 
702   PetscFunctionBegin;
703   if (m) *m = mat->rstart;
704   if (n) *n = mat->rend;
705   PetscFunctionReturn(0);
706 }
707 
708 #undef __FUNC__
709 #define __FUNC__ "MatGetRow_MPIDense"
710 int MatGetRow_MPIDense(Mat A,int row,int *nz,int **idx,Scalar **v)
711 {
712   Mat_MPIDense *mat = (Mat_MPIDense*)A->data;
713   int          lrow,rstart = mat->rstart,rend = mat->rend,ierr;
714 
715   PetscFunctionBegin;
716   if (row < rstart || row >= rend) SETERRQ(PETSC_ERR_SUP,"only local rows")
717   lrow = row - rstart;
718   ierr = MatGetRow(mat->A,lrow,nz,idx,v);CHKERRQ(ierr);
719   PetscFunctionReturn(0);
720 }
721 
722 #undef __FUNC__
723 #define __FUNC__ "MatRestoreRow_MPIDense"
724 int MatRestoreRow_MPIDense(Mat mat,int row,int *nz,int **idx,Scalar **v)
725 {
726   int ierr;
727 
728   PetscFunctionBegin;
729   if (idx) {ierr = PetscFree(*idx);CHKERRQ(ierr);}
730   if (v) {ierr = PetscFree(*v);CHKERRQ(ierr);}
731   PetscFunctionReturn(0);
732 }
733 
734 #undef __FUNC__
735 #define __FUNC__ "MatDiagonalScale_MPIDense"
736 int MatDiagonalScale_MPIDense(Mat A,Vec ll,Vec rr)
737 {
738   Mat_MPIDense *mdn = (Mat_MPIDense*)A->data;
739   Mat_SeqDense *mat = (Mat_SeqDense*)mdn->A->data;
740   Scalar       *l,*r,x,*v;
741   int          ierr,i,j,s2a,s3a,s2,s3,m=mdn->A->m,n=mdn->A->n;
742 
743   PetscFunctionBegin;
744   ierr = MatGetLocalSize(A,&s2,&s3);CHKERRQ(ierr);
745   if (ll) {
746     ierr = VecGetLocalSize(ll,&s2a);CHKERRQ(ierr);
747     if (s2a != s2) SETERRQ(PETSC_ERR_ARG_SIZ,"Left scaling vector non-conforming local size");
748     ierr = VecGetArray(ll,&l);CHKERRQ(ierr);
749     for (i=0; i<m; i++) {
750       x = l[i];
751       v = mat->v + i;
752       for (j=0; j<n; j++) { (*v) *= x; v+= m;}
753     }
754     ierr = VecRestoreArray(ll,&l);CHKERRQ(ierr);
755     PetscLogFlops(n*m);
756   }
757   if (rr) {
758     ierr = VecGetSize(rr,&s3a);CHKERRQ(ierr);
759     if (s3a != s3) SETERRQ(PETSC_ERR_ARG_SIZ,"Right scaling vec non-conforming local size");
760     ierr = VecScatterBegin(rr,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr);
761     ierr = VecScatterEnd(rr,mdn->lvec,INSERT_VALUES,SCATTER_FORWARD,mdn->Mvctx);CHKERRQ(ierr);
762     ierr = VecGetArray(mdn->lvec,&r);CHKERRQ(ierr);
763     for (i=0; i<n; i++) {
764       x = r[i];
765       v = mat->v + i*m;
766       for (j=0; j<m; j++) { (*v++) *= x;}
767     }
768     ierr = VecRestoreArray(mdn->lvec,&r);CHKERRQ(ierr);
769     PetscLogFlops(n*m);
770   }
771   PetscFunctionReturn(0);
772 }
773 
774 #undef __FUNC__
775 #define __FUNC__ "MatNorm_MPIDense"
776 int MatNorm_MPIDense(Mat A,NormType type,PetscReal *norm)
777 {
778   Mat_MPIDense *mdn = (Mat_MPIDense*)A->data;
779   Mat_SeqDense *mat = (Mat_SeqDense*)mdn->A->data;
780   int          ierr,i,j;
781   PetscReal    sum = 0.0;
782   Scalar       *v = mat->v;
783 
784   PetscFunctionBegin;
785   if (mdn->size == 1) {
786     ierr =  MatNorm(mdn->A,type,norm);CHKERRQ(ierr);
787   } else {
788     if (type == NORM_FROBENIUS) {
789       for (i=0; i<mdn->A->n*mdn->A->m; i++) {
790 #if defined(PETSC_USE_COMPLEX)
791         sum += PetscRealPart(PetscConj(*v)*(*v)); v++;
792 #else
793         sum += (*v)*(*v); v++;
794 #endif
795       }
796       ierr = MPI_Allreduce(&sum,norm,1,MPI_DOUBLE,MPI_SUM,A->comm);CHKERRQ(ierr);
797       *norm = sqrt(*norm);
798       PetscLogFlops(2*mdn->A->n*mdn->A->m);
799     } else if (type == NORM_1) {
800       PetscReal *tmp,*tmp2;
801       ierr = PetscMalloc(2*A->N*sizeof(PetscReal),&tmp);CHKERRQ(ierr);
802       tmp2 = tmp + A->N;
803       ierr = PetscMemzero(tmp,2*A->N*sizeof(PetscReal));CHKERRQ(ierr);
804       *norm = 0.0;
805       v = mat->v;
806       for (j=0; j<mdn->A->n; j++) {
807         for (i=0; i<mdn->A->m; i++) {
808           tmp[j] += PetscAbsScalar(*v);  v++;
809         }
810       }
811       ierr = MPI_Allreduce(tmp,tmp2,A->N,MPI_DOUBLE,MPI_SUM,A->comm);CHKERRQ(ierr);
812       for (j=0; j<A->N; j++) {
813         if (tmp2[j] > *norm) *norm = tmp2[j];
814       }
815       ierr = PetscFree(tmp);CHKERRQ(ierr);
816       PetscLogFlops(A->n*A->m);
817     } else if (type == NORM_INFINITY) { /* max row norm */
818       PetscReal ntemp;
819       ierr = MatNorm(mdn->A,type,&ntemp);CHKERRQ(ierr);
820       ierr = MPI_Allreduce(&ntemp,norm,1,MPI_DOUBLE,MPI_MAX,A->comm);CHKERRQ(ierr);
821     } else {
822       SETERRQ(PETSC_ERR_SUP,"No support for two norm");
823     }
824   }
825   PetscFunctionReturn(0);
826 }
827 
828 #undef __FUNC__
829 #define __FUNC__ "MatTranspose_MPIDense"
830 int MatTranspose_MPIDense(Mat A,Mat *matout)
831 {
832   Mat_MPIDense *a = (Mat_MPIDense*)A->data;
833   Mat_SeqDense *Aloc = (Mat_SeqDense*)a->A->data;
834   Mat          B;
835   int          M = A->M,N = A->N,m,n,*rwork,rstart = a->rstart;
836   int          j,i,ierr;
837   Scalar       *v;
838 
839   PetscFunctionBegin;
840   if (!matout && M != N) {
841     SETERRQ(PETSC_ERR_SUP,"Supports square matrix only in-place");
842   }
843   ierr = MatCreateMPIDense(A->comm,PETSC_DECIDE,PETSC_DECIDE,N,M,PETSC_NULL,&B);CHKERRQ(ierr);
844 
845   m = a->A->m; n = a->A->n; v = Aloc->v;
846   ierr = PetscMalloc(n*sizeof(int),&rwork);CHKERRQ(ierr);
847   for (j=0; j<n; j++) {
848     for (i=0; i<m; i++) rwork[i] = rstart + i;
849     ierr = MatSetValues(B,1,&j,m,rwork,v,INSERT_VALUES);CHKERRQ(ierr);
850     v   += m;
851   }
852   ierr = PetscFree(rwork);CHKERRQ(ierr);
853   ierr = MatAssemblyBegin(B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
854   ierr = MatAssemblyEnd(B,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
855   if (matout) {
856     *matout = B;
857   } else {
858     ierr = MatHeaderCopy(A,B);CHKERRQ(ierr);
859   }
860   PetscFunctionReturn(0);
861 }
862 
863 #include "petscblaslapack.h"
864 #undef __FUNC__
865 #define __FUNC__ "MatScale_MPIDense"
866 int MatScale_MPIDense(Scalar *alpha,Mat inA)
867 {
868   Mat_MPIDense *A = (Mat_MPIDense*)inA->data;
869   Mat_SeqDense *a = (Mat_SeqDense*)A->A->data;
870   int          one = 1,nz;
871 
872   PetscFunctionBegin;
873   nz = inA->m*inA->N;
874   BLscal_(&nz,alpha,a->v,&one);
875   PetscLogFlops(nz);
876   PetscFunctionReturn(0);
877 }
878 
879 static int MatDuplicate_MPIDense(Mat,MatDuplicateOption,Mat *);
880 EXTERN int MatGetSubMatrices_MPIDense(Mat,int,IS *,IS *,MatReuse,Mat **);
881 
882 #undef __FUNC__
883 #define __FUNC__ "MatSetUpPreallocation_MPIDense"
884 int MatSetUpPreallocation_MPIDense(Mat A)
885 {
886   int        ierr;
887 
888   PetscFunctionBegin;
889   ierr =  MatMPIDenseSetPreallocation(A,0);CHKERRQ(ierr);
890   PetscFunctionReturn(0);
891 }
892 
893 /* -------------------------------------------------------------------*/
894 static struct _MatOps MatOps_Values = {MatSetValues_MPIDense,
895        MatGetRow_MPIDense,
896        MatRestoreRow_MPIDense,
897        MatMult_MPIDense,
898        MatMultAdd_MPIDense,
899        MatMultTranspose_MPIDense,
900        MatMultTransposeAdd_MPIDense,
901        0,
902        0,
903        0,
904        0,
905        0,
906        0,
907        0,
908        MatTranspose_MPIDense,
909        MatGetInfo_MPIDense,0,
910        MatGetDiagonal_MPIDense,
911        MatDiagonalScale_MPIDense,
912        MatNorm_MPIDense,
913        MatAssemblyBegin_MPIDense,
914        MatAssemblyEnd_MPIDense,
915        0,
916        MatSetOption_MPIDense,
917        MatZeroEntries_MPIDense,
918        MatZeroRows_MPIDense,
919        0,
920        0,
921        0,
922        0,
923        MatSetUpPreallocation_MPIDense,
924        0,
925        MatGetOwnershipRange_MPIDense,
926        0,
927        0,
928        MatGetArray_MPIDense,
929        MatRestoreArray_MPIDense,
930        MatDuplicate_MPIDense,
931        0,
932        0,
933        0,
934        0,
935        0,
936        MatGetSubMatrices_MPIDense,
937        0,
938        MatGetValues_MPIDense,
939        0,
940        0,
941        MatScale_MPIDense,
942        0,
943        0,
944        0,
945        MatGetBlockSize_MPIDense,
946        0,
947        0,
948        0,
949        0,
950        0,
951        0,
952        0,
953        0,
954        0,
955        MatGetSubMatrix_MPIDense,
956        MatDestroy_MPIDense,
957        MatView_MPIDense,
958        MatGetMaps_Petsc};
959 
960 EXTERN_C_BEGIN
961 #undef __FUNC__
962 #define __FUNC__ "MatCreate_MPIDense"
963 int MatCreate_MPIDense(Mat mat)
964 {
965   Mat_MPIDense *a;
966   int          ierr,i;
967 
968   PetscFunctionBegin;
969   ierr              = PetscNew(Mat_MPIDense,&a);CHKERRQ(ierr);
970   mat->data         = (void*)a;
971   ierr              = PetscMemcpy(mat->ops,&MatOps_Values,sizeof(struct _MatOps));CHKERRQ(ierr);
972   mat->factor       = 0;
973   mat->mapping      = 0;
974 
975   a->factor       = 0;
976   mat->insertmode = NOT_SET_VALUES;
977   ierr = MPI_Comm_rank(mat->comm,&a->rank);CHKERRQ(ierr);
978   ierr = MPI_Comm_size(mat->comm,&a->size);CHKERRQ(ierr);
979 
980   ierr = PetscSplitOwnership(mat->comm,&mat->m,&mat->M);CHKERRQ(ierr);
981   ierr = PetscSplitOwnership(mat->comm,&mat->n,&mat->N);CHKERRQ(ierr);
982   a->nvec = mat->n;
983 
984   /* the information in the maps duplicates the information computed below, eventually
985      we should remove the duplicate information that is not contained in the maps */
986   ierr = MapCreateMPI(mat->comm,mat->m,mat->M,&mat->rmap);CHKERRQ(ierr);
987   ierr = MapCreateMPI(mat->comm,mat->n,mat->N,&mat->cmap);CHKERRQ(ierr);
988 
989   /* build local table of row and column ownerships */
990   ierr       = PetscMalloc(2*(a->size+2)*sizeof(int),&a->rowners);CHKERRQ(ierr);
991   a->cowners = a->rowners + a->size + 1;
992   PetscLogObjectMemory(mat,2*(a->size+2)*sizeof(int)+sizeof(struct _p_Mat)+sizeof(Mat_MPIDense));
993   ierr = MPI_Allgather(&mat->m,1,MPI_INT,a->rowners+1,1,MPI_INT,mat->comm);CHKERRQ(ierr);
994   a->rowners[0] = 0;
995   for (i=2; i<=a->size; i++) {
996     a->rowners[i] += a->rowners[i-1];
997   }
998   a->rstart = a->rowners[a->rank];
999   a->rend   = a->rowners[a->rank+1];
1000   ierr      = MPI_Allgather(&mat->n,1,MPI_INT,a->cowners+1,1,MPI_INT,mat->comm);CHKERRQ(ierr);
1001   a->cowners[0] = 0;
1002   for (i=2; i<=a->size; i++) {
1003     a->cowners[i] += a->cowners[i-1];
1004   }
1005 
1006   /* build cache for off array entries formed */
1007   a->donotstash = PETSC_FALSE;
1008   ierr = MatStashCreate_Private(mat->comm,1,&mat->stash);CHKERRQ(ierr);
1009 
1010   /* stuff used for matrix vector multiply */
1011   a->lvec        = 0;
1012   a->Mvctx       = 0;
1013   a->roworiented = PETSC_TRUE;
1014 
1015   ierr = PetscObjectComposeFunctionDynamic((PetscObject)mat,"MatGetDiagonalBlock_C",
1016                                      "MatGetDiagonalBlock_MPIDense",
1017                                      MatGetDiagonalBlock_MPIDense);CHKERRQ(ierr);
1018   PetscFunctionReturn(0);
1019 }
1020 EXTERN_C_END
1021 
1022 #undef __FUNC__
1023 #define __FUNC__ "MatMPIDenseSetPreallocation"
1024 /*@C
1025    MatMPIDenseSetPreallocation - Sets the array used to store the matrix entries
1026 
1027    Not collective
1028 
1029    Input Parameters:
1030 .  A - the matrix
1031 -  data - optional location of matrix data.  Set data=PETSC_NULL for PETSc
1032    to control all matrix memory allocation.
1033 
1034    Notes:
1035    The dense format is fully compatible with standard Fortran 77
1036    storage by columns.
1037 
1038    The data input variable is intended primarily for Fortran programmers
1039    who wish to allocate their own matrix memory space.  Most users should
1040    set data=PETSC_NULL.
1041 
1042    Level: intermediate
1043 
1044 .keywords: matrix,dense, parallel
1045 
1046 .seealso: MatCreate(), MatCreateSeqDense(), MatSetValues()
1047 @*/
1048 int MatMPIDenseSetPreallocation(Mat mat,Scalar *data)
1049 {
1050   Mat_MPIDense *a;
1051   int          ierr;
1052   PetscTruth   flg2;
1053 
1054   PetscFunctionBegin;
1055   ierr = PetscTypeCompare((PetscObject)mat,MATMPIDENSE,&flg2);CHKERRQ(ierr);
1056   if (!flg2) PetscFunctionReturn(0);
1057   mat->preallocated = PETSC_TRUE;
1058   /* Note:  For now, when data is specified above, this assumes the user correctly
1059    allocates the local dense storage space.  We should add error checking. */
1060 
1061   a    = (Mat_MPIDense*)mat->data;
1062   ierr = MatCreateSeqDense(PETSC_COMM_SELF,mat->m,mat->N,data,&a->A);CHKERRQ(ierr);
1063   PetscLogObjectParent(mat,a->A);
1064   PetscFunctionReturn(0);
1065 }
1066 
1067 #undef __FUNC__
1068 #define __FUNC__ "MatCreateMPIDense"
1069 /*@C
1070    MatCreateMPIDense - Creates a sparse parallel matrix in dense format.
1071 
1072    Collective on MPI_Comm
1073 
1074    Input Parameters:
1075 +  comm - MPI communicator
1076 .  m - number of local rows (or PETSC_DECIDE to have calculated if M is given)
1077 .  n - number of local columns (or PETSC_DECIDE to have calculated if N is given)
1078 .  M - number of global rows (or PETSC_DECIDE to have calculated if m is given)
1079 .  N - number of global columns (or PETSC_DECIDE to have calculated if n is given)
1080 -  data - optional location of matrix data.  Set data=PETSC_NULL for PETSc
1081    to control all matrix memory allocation.
1082 
1083    Output Parameter:
1084 .  A - the matrix
1085 
1086    Notes:
1087    The dense format is fully compatible with standard Fortran 77
1088    storage by columns.
1089 
1090    The data input variable is intended primarily for Fortran programmers
1091    who wish to allocate their own matrix memory space.  Most users should
1092    set data=PETSC_NULL.
1093 
1094    The user MUST specify either the local or global matrix dimensions
1095    (possibly both).
1096 
1097    Level: intermediate
1098 
1099 .keywords: matrix,dense, parallel
1100 
1101 .seealso: MatCreate(), MatCreateSeqDense(), MatSetValues()
1102 @*/
1103 int MatCreateMPIDense(MPI_Comm comm,int m,int n,int M,int N,Scalar *data,Mat *A)
1104 {
1105   int ierr,size;
1106 
1107   PetscFunctionBegin;
1108   ierr = MatCreate(comm,m,n,M,N,A);CHKERRQ(ierr);
1109   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1110   if (size > 1) {
1111     ierr = MatSetType(*A,MATMPIDENSE);CHKERRQ(ierr);
1112     ierr = MatMPIDenseSetPreallocation(*A,data);CHKERRQ(ierr);
1113   } else {
1114     ierr = MatSetType(*A,MATSEQDENSE);CHKERRQ(ierr);
1115     ierr = MatSeqDenseSetPreallocation(*A,data);CHKERRQ(ierr);
1116   }
1117   PetscFunctionReturn(0);
1118 }
1119 
1120 #undef __FUNC__
1121 #define __FUNC__ "MatDuplicate_MPIDense"
1122 static int MatDuplicate_MPIDense(Mat A,MatDuplicateOption cpvalues,Mat *newmat)
1123 {
1124   Mat          mat;
1125   Mat_MPIDense *a,*oldmat = (Mat_MPIDense*)A->data;
1126   int          ierr;
1127 
1128   PetscFunctionBegin;
1129   *newmat       = 0;
1130   ierr = MatCreate(A->comm,A->m,A->n,A->M,A->N,&mat);CHKERRQ(ierr);
1131   ierr = MatSetType(mat,MATMPIDENSE);CHKERRQ(ierr);
1132   ierr              = PetscNew(Mat_MPIDense,&a);CHKERRQ(ierr);
1133   mat->data         = (void*)a;
1134   ierr              = PetscMemcpy(mat->ops,&MatOps_Values,sizeof(struct _MatOps));CHKERRQ(ierr);
1135   mat->factor       = A->factor;
1136   mat->assembled    = PETSC_TRUE;
1137   mat->preallocated = PETSC_TRUE;
1138 
1139   a->rstart       = oldmat->rstart;
1140   a->rend         = oldmat->rend;
1141   a->size         = oldmat->size;
1142   a->rank         = oldmat->rank;
1143   mat->insertmode = NOT_SET_VALUES;
1144   a->nvec         = oldmat->nvec;
1145   a->donotstash   = oldmat->donotstash;
1146   ierr            = PetscMalloc((a->size+1)*sizeof(int),&a->rowners);CHKERRQ(ierr);
1147   PetscLogObjectMemory(mat,(a->size+1)*sizeof(int)+sizeof(struct _p_Mat)+sizeof(Mat_MPIDense));
1148   ierr = PetscMemcpy(a->rowners,oldmat->rowners,(a->size+1)*sizeof(int));CHKERRQ(ierr);
1149   ierr = MatStashCreate_Private(A->comm,1,&mat->stash);CHKERRQ(ierr);
1150 
1151   ierr = MatSetUpMultiply_MPIDense(mat);CHKERRQ(ierr);
1152   ierr = MatDuplicate(oldmat->A,cpvalues,&a->A);CHKERRQ(ierr);
1153   PetscLogObjectParent(mat,a->A);
1154   *newmat = mat;
1155   PetscFunctionReturn(0);
1156 }
1157 
1158 #include "petscsys.h"
1159 
1160 #undef __FUNC__
1161 #define __FUNC__ "MatLoad_MPIDense_DenseInFile"
1162 int MatLoad_MPIDense_DenseInFile(MPI_Comm comm,int fd,int M,int N,Mat *newmat)
1163 {
1164   int        *rowners,i,size,rank,m,ierr,nz,j;
1165   Scalar     *array,*vals,*vals_ptr;
1166   MPI_Status status;
1167 
1168   PetscFunctionBegin;
1169   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1170   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1171 
1172   /* determine ownership of all rows */
1173   m          = M/size + ((M % size) > rank);
1174   ierr       = PetscMalloc((size+2)*sizeof(int),&rowners);CHKERRQ(ierr);
1175   ierr       = MPI_Allgather(&m,1,MPI_INT,rowners+1,1,MPI_INT,comm);CHKERRQ(ierr);
1176   rowners[0] = 0;
1177   for (i=2; i<=size; i++) {
1178     rowners[i] += rowners[i-1];
1179   }
1180 
1181   ierr = MatCreateMPIDense(comm,m,PETSC_DECIDE,M,N,PETSC_NULL,newmat);CHKERRQ(ierr);
1182   ierr = MatGetArray(*newmat,&array);CHKERRQ(ierr);
1183 
1184   if (!rank) {
1185     ierr = PetscMalloc(m*N*sizeof(Scalar),&vals);CHKERRQ(ierr);
1186 
1187     /* read in my part of the matrix numerical values  */
1188     ierr = PetscBinaryRead(fd,vals,m*N,PETSC_SCALAR);CHKERRQ(ierr);
1189 
1190     /* insert into matrix-by row (this is why cannot directly read into array */
1191     vals_ptr = vals;
1192     for (i=0; i<m; i++) {
1193       for (j=0; j<N; j++) {
1194         array[i + j*m] = *vals_ptr++;
1195       }
1196     }
1197 
1198     /* read in other processors and ship out */
1199     for (i=1; i<size; i++) {
1200       nz   = (rowners[i+1] - rowners[i])*N;
1201       ierr = PetscBinaryRead(fd,vals,nz,PETSC_SCALAR);CHKERRQ(ierr);
1202       ierr = MPI_Send(vals,nz,MPIU_SCALAR,i,(*newmat)->tag,comm);CHKERRQ(ierr);
1203     }
1204   } else {
1205     /* receive numeric values */
1206     ierr = PetscMalloc(m*N*sizeof(Scalar),&vals);CHKERRQ(ierr);
1207 
1208     /* receive message of values*/
1209     ierr = MPI_Recv(vals,m*N,MPIU_SCALAR,0,(*newmat)->tag,comm,&status);CHKERRQ(ierr);
1210 
1211     /* insert into matrix-by row (this is why cannot directly read into array */
1212     vals_ptr = vals;
1213     for (i=0; i<m; i++) {
1214       for (j=0; j<N; j++) {
1215         array[i + j*m] = *vals_ptr++;
1216       }
1217     }
1218   }
1219   ierr = PetscFree(rowners);CHKERRQ(ierr);
1220   ierr = PetscFree(vals);CHKERRQ(ierr);
1221   ierr = MatAssemblyBegin(*newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1222   ierr = MatAssemblyEnd(*newmat,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1223   PetscFunctionReturn(0);
1224 }
1225 
1226 EXTERN_C_BEGIN
1227 #undef __FUNC__
1228 #define __FUNC__ "MatLoad_MPIDense"
1229 int MatLoad_MPIDense(PetscViewer viewer,MatType type,Mat *newmat)
1230 {
1231   Mat          A;
1232   Scalar       *vals,*svals;
1233   MPI_Comm     comm = ((PetscObject)viewer)->comm;
1234   MPI_Status   status;
1235   int          header[4],rank,size,*rowlengths = 0,M,N,m,*rowners,maxnz,*cols;
1236   int          *ourlens,*sndcounts = 0,*procsnz = 0,*offlens,jj,*mycols,*smycols;
1237   int          tag = ((PetscObject)viewer)->tag;
1238   int          i,nz,ierr,j,rstart,rend,fd;
1239 
1240   PetscFunctionBegin;
1241   ierr = MPI_Comm_size(comm,&size);CHKERRQ(ierr);
1242   ierr = MPI_Comm_rank(comm,&rank);CHKERRQ(ierr);
1243   if (!rank) {
1244     ierr = PetscViewerBinaryGetDescriptor(viewer,&fd);CHKERRQ(ierr);
1245     ierr = PetscBinaryRead(fd,(char *)header,4,PETSC_INT);CHKERRQ(ierr);
1246     if (header[0] != MAT_COOKIE) SETERRQ(PETSC_ERR_FILE_UNEXPECTED,"not matrix object");
1247   }
1248 
1249   ierr = MPI_Bcast(header+1,3,MPI_INT,0,comm);CHKERRQ(ierr);
1250   M = header[1]; N = header[2]; nz = header[3];
1251 
1252   /*
1253        Handle case where matrix is stored on disk as a dense matrix
1254   */
1255   if (nz == MATRIX_BINARY_FORMAT_DENSE) {
1256     ierr = MatLoad_MPIDense_DenseInFile(comm,fd,M,N,newmat);CHKERRQ(ierr);
1257     PetscFunctionReturn(0);
1258   }
1259 
1260   /* determine ownership of all rows */
1261   m          = M/size + ((M % size) > rank);
1262   ierr       = PetscMalloc((size+2)*sizeof(int),&rowners);CHKERRQ(ierr);
1263   ierr       = MPI_Allgather(&m,1,MPI_INT,rowners+1,1,MPI_INT,comm);CHKERRQ(ierr);
1264   rowners[0] = 0;
1265   for (i=2; i<=size; i++) {
1266     rowners[i] += rowners[i-1];
1267   }
1268   rstart = rowners[rank];
1269   rend   = rowners[rank+1];
1270 
1271   /* distribute row lengths to all processors */
1272   ierr    = PetscMalloc(2*(rend-rstart)*sizeof(int),&ourlens);CHKERRQ(ierr);
1273   offlens = ourlens + (rend-rstart);
1274   if (!rank) {
1275     ierr = PetscMalloc(M*sizeof(int),&rowlengths);CHKERRQ(ierr);
1276     ierr = PetscBinaryRead(fd,rowlengths,M,PETSC_INT);CHKERRQ(ierr);
1277     ierr = PetscMalloc(size*sizeof(int),&sndcounts);CHKERRQ(ierr);
1278     for (i=0; i<size; i++) sndcounts[i] = rowners[i+1] - rowners[i];
1279     ierr = MPI_Scatterv(rowlengths,sndcounts,rowners,MPI_INT,ourlens,rend-rstart,MPI_INT,0,comm);CHKERRQ(ierr);
1280     ierr = PetscFree(sndcounts);CHKERRQ(ierr);
1281   } else {
1282     ierr = MPI_Scatterv(0,0,0,MPI_INT,ourlens,rend-rstart,MPI_INT,0,comm);CHKERRQ(ierr);
1283   }
1284 
1285   if (!rank) {
1286     /* calculate the number of nonzeros on each processor */
1287     ierr = PetscMalloc(size*sizeof(int),&procsnz);CHKERRQ(ierr);
1288     ierr = PetscMemzero(procsnz,size*sizeof(int));CHKERRQ(ierr);
1289     for (i=0; i<size; i++) {
1290       for (j=rowners[i]; j< rowners[i+1]; j++) {
1291         procsnz[i] += rowlengths[j];
1292       }
1293     }
1294     ierr = PetscFree(rowlengths);CHKERRQ(ierr);
1295 
1296     /* determine max buffer needed and allocate it */
1297     maxnz = 0;
1298     for (i=0; i<size; i++) {
1299       maxnz = PetscMax(maxnz,procsnz[i]);
1300     }
1301     ierr = PetscMalloc(maxnz*sizeof(int),&cols);CHKERRQ(ierr);
1302 
1303     /* read in my part of the matrix column indices  */
1304     nz = procsnz[0];
1305     ierr = PetscMalloc(nz*sizeof(int),&mycols);CHKERRQ(ierr);
1306     ierr = PetscBinaryRead(fd,mycols,nz,PETSC_INT);CHKERRQ(ierr);
1307 
1308     /* read in every one elses and ship off */
1309     for (i=1; i<size; i++) {
1310       nz   = procsnz[i];
1311       ierr = PetscBinaryRead(fd,cols,nz,PETSC_INT);CHKERRQ(ierr);
1312       ierr = MPI_Send(cols,nz,MPI_INT,i,tag,comm);CHKERRQ(ierr);
1313     }
1314     ierr = PetscFree(cols);CHKERRQ(ierr);
1315   } else {
1316     /* determine buffer space needed for message */
1317     nz = 0;
1318     for (i=0; i<m; i++) {
1319       nz += ourlens[i];
1320     }
1321     ierr = PetscMalloc(nz*sizeof(int),&mycols);CHKERRQ(ierr);
1322 
1323     /* receive message of column indices*/
1324     ierr = MPI_Recv(mycols,nz,MPI_INT,0,tag,comm,&status);CHKERRQ(ierr);
1325     ierr = MPI_Get_count(&status,MPI_INT,&maxnz);CHKERRQ(ierr);
1326     if (maxnz != nz) SETERRQ(PETSC_ERR_FILE_UNEXPECTED,"something is wrong with file");
1327   }
1328 
1329   /* loop over local rows, determining number of off diagonal entries */
1330   ierr = PetscMemzero(offlens,m*sizeof(int));CHKERRQ(ierr);
1331   jj = 0;
1332   for (i=0; i<m; i++) {
1333     for (j=0; j<ourlens[i]; j++) {
1334       if (mycols[jj] < rstart || mycols[jj] >= rend) offlens[i]++;
1335       jj++;
1336     }
1337   }
1338 
1339   /* create our matrix */
1340   for (i=0; i<m; i++) {
1341     ourlens[i] -= offlens[i];
1342   }
1343   ierr = MatCreateMPIDense(comm,m,PETSC_DECIDE,M,N,PETSC_NULL,newmat);CHKERRQ(ierr);
1344   A = *newmat;
1345   for (i=0; i<m; i++) {
1346     ourlens[i] += offlens[i];
1347   }
1348 
1349   if (!rank) {
1350     ierr = PetscMalloc(maxnz*sizeof(Scalar),&vals);CHKERRQ(ierr);
1351 
1352     /* read in my part of the matrix numerical values  */
1353     nz = procsnz[0];
1354     ierr = PetscBinaryRead(fd,vals,nz,PETSC_SCALAR);CHKERRQ(ierr);
1355 
1356     /* insert into matrix */
1357     jj      = rstart;
1358     smycols = mycols;
1359     svals   = vals;
1360     for (i=0; i<m; i++) {
1361       ierr = MatSetValues(A,1,&jj,ourlens[i],smycols,svals,INSERT_VALUES);CHKERRQ(ierr);
1362       smycols += ourlens[i];
1363       svals   += ourlens[i];
1364       jj++;
1365     }
1366 
1367     /* read in other processors and ship out */
1368     for (i=1; i<size; i++) {
1369       nz   = procsnz[i];
1370       ierr = PetscBinaryRead(fd,vals,nz,PETSC_SCALAR);CHKERRQ(ierr);
1371       ierr = MPI_Send(vals,nz,MPIU_SCALAR,i,A->tag,comm);CHKERRQ(ierr);
1372     }
1373     ierr = PetscFree(procsnz);CHKERRQ(ierr);
1374   } else {
1375     /* receive numeric values */
1376     ierr = PetscMalloc(nz*sizeof(Scalar),&vals);CHKERRQ(ierr);
1377 
1378     /* receive message of values*/
1379     ierr = MPI_Recv(vals,nz,MPIU_SCALAR,0,A->tag,comm,&status);CHKERRQ(ierr);
1380     ierr = MPI_Get_count(&status,MPIU_SCALAR,&maxnz);CHKERRQ(ierr);
1381     if (maxnz != nz) SETERRQ(PETSC_ERR_FILE_UNEXPECTED,"something is wrong with file");
1382 
1383     /* insert into matrix */
1384     jj      = rstart;
1385     smycols = mycols;
1386     svals   = vals;
1387     for (i=0; i<m; i++) {
1388       ierr = MatSetValues(A,1,&jj,ourlens[i],smycols,svals,INSERT_VALUES);CHKERRQ(ierr);
1389       smycols += ourlens[i];
1390       svals   += ourlens[i];
1391       jj++;
1392     }
1393   }
1394   ierr = PetscFree(ourlens);CHKERRQ(ierr);
1395   ierr = PetscFree(vals);CHKERRQ(ierr);
1396   ierr = PetscFree(mycols);CHKERRQ(ierr);
1397   ierr = PetscFree(rowners);CHKERRQ(ierr);
1398 
1399   ierr = MatAssemblyBegin(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1400   ierr = MatAssemblyEnd(A,MAT_FINAL_ASSEMBLY);CHKERRQ(ierr);
1401   PetscFunctionReturn(0);
1402 }
1403 EXTERN_C_END
1404 
1405 
1406 
1407 
1408 
1409