| /petsc/src/vec/vec/utils/ |
| H A D | vscat.c | 933 PetscMPIInt nsend, nrecv, nreq, yrank, *sendto, *recvfrom, tag1, tag2; in VecScatterCreate() local
963 i = j = nsend = 0; in VecScatterCreate()
972 if (!slens[j]++) nsend++; in VecScatterCreate()
975 PetscCall(PetscMalloc2(nsend + 1, &sstart, nsend, &sendto)); in VecScatterCreate()
996 PetscCall(PetscGatherMessageLengths_Private(ycomm, nsend, nrecv, slens, &recvfrom, &rlens)); in VecScatterCreate()
1007 PetscCall(PetscMPIIntCast((nsend + nrecv) * 2, &nreq)); in VecScatterCreate()
1010 rreqs = PetscSafePointerPlusOffset(reqs, nsend * 2); in VecScatterCreate()
1019 for (i = 0; i < nsend; i++) { in VecScatterCreate()
1022 …IU_Isend(yindices_sorted + sstart[i], count, MPIU_INT, sendto[i], tag2, ycomm, sreqs + nsend + i)); in VecScatterCreate()
|
| /petsc/src/vec/vec/impls/mpi/ |
| H A D | pdvec.c | 965 PetscInt nsend = 0; /* Number of MPI ranks to send data to */ in VecSetPreallocationCOO_MPI() local
986 if (nsend >= maxNsend) { /* Double the remote ranks arrays if not long enough */ in VecSetPreallocationCOO_MPI()
999 sendto[nsend] = owner; in VecSetPreallocationCOO_MPI()
1000 PetscCall(PetscIntCast(p - k, &nentries[nsend])); in VecSetPreallocationCOO_MPI()
1001 nsend++; in VecSetPreallocationCOO_MPI()
1008 PetscInt nleaves = nsend, nleaves2 = 0; in VecSetPreallocationCOO_MPI()
1013 PetscCall(PetscMalloc1(nsend, &iremote)); in VecSetPreallocationCOO_MPI()
1014 PetscCall(PetscMalloc1(nsend, &offsets)); in VecSetPreallocationCOO_MPI()
1015 for (k = 0; k < nsend; k++) { in VecSetPreallocationCOO_MPI()
1035 for (k = 0; k < nsend; k++) { in VecSetPreallocationCOO_MPI()
|
| /petsc/src/mat/impls/aij/mpi/ |
| H A D | mpimatmatmult.c | 1274 PetscMPIInt tagi, tagj, *len_si, *len_s, *len_ri, nrecv, proc, nsend; in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable() local
1344 nsend = 0; in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable()
1348 nsend++; in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable()
1356 PetscCall(PetscGatherMessageLengths2(comm, nsend, nrecv, len_s, len_si, &id_r, &len_r, &len_ri)); in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable()
1361 PetscCall(PetscMalloc1(nsend, &swaits)); in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable()
1379 if (nsend) PetscCallMPI(MPI_Waitall(nsend, swaits, sstatus)); in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable()
1424 if (nsend) PetscCallMPI(MPI_Waitall(nsend, swaits, sstatus)); in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ_nonscalable()
1699 PetscCall(PetscMalloc2(merge->nsend, &s_waits, size, &status)); in MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ()
1707 if (merge->nsend) PetscCallMPI(MPI_Waitall(merge->nsend, s_waits, status)); in MatTransposeMatMultNumeric_MPIAIJ_MPIAIJ()
1874 merge->nsend = 0; in MatTransposeMatMultSymbolic_MPIAIJ_MPIAIJ()
[all …]
|
| H A D | mpiptap.c | 225 PetscMPIInt tagi, tagj, *len_si, *len_s, *len_ri, nrecv, nsend, proc; in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable() local
408 nsend = 0; in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable()
412 nsend++; in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable()
420 PetscCall(PetscGatherMessageLengths2(comm, nsend, nrecv, len_s, len_si, &id_r, &len_r, &len_ri)); in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable()
425 PetscCall(PetscMalloc1(nsend + 1, &swaits)); in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable()
451 if (nsend) PetscCallMPI(MPI_Waitall(nsend, swaits, sstatus)); in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable()
490 if (nsend) PetscCallMPI(MPI_Waitall(nsend, swaits, sstatus)); in MatPtAPSymbolic_MPIAIJ_MPIAIJ_scalable()
1508 PetscMPIInt size, rank, nsend, proc; in MatPtAPSymbolic_MPIAIJ_MPIAIJ() local
1697 nsend = 0; in MatPtAPSymbolic_MPIAIJ_MPIAIJ()
1701 nsend++; in MatPtAPSymbolic_MPIAIJ_MPIAIJ()
[all …]
|
| H A D | mpiaij.c | 4691 PetscCall(PetscMalloc1(merge->nsend + 1, &s_waits)); in MatCreateMPIAIJSumSeqAIJNumeric()
4700 if (merge->nsend) PetscCallMPI(MPI_Waitall(merge->nsend, s_waits, status)); in MatCreateMPIAIJSumSeqAIJNumeric()
4811 merge->nsend = 0; in MatCreateMPIAIJSumSeqAIJSymbolic()
4821 merge->nsend++; in MatCreateMPIAIJSumSeqAIJSymbolic()
4833 …PetscCall(PetscGatherMessageLengths2(comm, merge->nsend, merge->nrecv, len_s, len_si, &merge->id_r… in MatCreateMPIAIJSumSeqAIJSymbolic()
4840 PetscCall(PetscMalloc2(merge->nsend, &si_waits, merge->nsend, &sj_waits)); in MatCreateMPIAIJSumSeqAIJSymbolic()
4851 if (merge->nsend) PetscCallMPI(MPI_Waitall(merge->nsend, sj_waits, status)); in MatCreateMPIAIJSumSeqAIJSymbolic()
4885 if (merge->nsend) PetscCallMPI(MPI_Waitall(merge->nsend, si_waits, status)); in MatCreateMPIAIJSumSeqAIJSymbolic()
4887 PetscCall(PetscInfo(seqmat, "nsend: %d, nrecv: %d\n", merge->nsend, merge->nrecv)); in MatCreateMPIAIJSumSeqAIJSymbolic()
6407 PetscInt nsend = 0; /* Number of MPI ranks to send data to */ in MatSetPreallocationCOO_MPIAIJ() local
[all …]
|
| H A D | mpiaij.h | 9 PetscMPIInt nsend, nrecv; member
|
| /petsc/src/vec/is/sf/impls/basic/neighbor/ |
| H A D | sfneighbor.c | 34 static inline PetscErrorCode PetscLogMPIMessages(PetscInt nsend, PetscSFCount *sendcnts, MPI_Dataty… in PetscLogMPIMessages() argument
38 petsc_isend_ct += (PetscLogDouble)nsend; in PetscLogMPIMessages()
44 for (i = 0; i < nsend; i++) petsc_isend_len += (PetscLogDouble)(sendcnts[i] * typesize); in PetscLogMPIMessages()
|
| /petsc/src/dm/impls/plex/ |
| H A D | plexvtu.c | 445 PetscInt nsend; in DMPlexVTKWriteAll_VTU() local
509 nsend = piece.nvertices * 3; in DMPlexVTKWriteAll_VTU()
510 …comm, viewer, fp, r, 0, copy ? (const void *)y : (const void *)x, buffer, nsend, MPIU_VTUREAL, tag… in DMPlexVTKWriteAll_VTU()
|