| /dports/net/mpich/mpich-3.4.3/src/include/ |
| H A D | mpir_coll.h | 25 int MPIC_Sendrecv(const void *sendbuf, MPI_Aint sendcount, MPI_Datatype sendtype,
58 int MPIR_Allgather_intra_recursive_doubling(const void *sendbuf, int sendcount,
95 int MPIR_Allgatherv_intra_recursive_doubling(const void *sendbuf, int sendcount,
126 int MPIR_Allreduce_allcomm_auto(const void *sendbuf, void *recvbuf, int count,
186 int MPIR_Alltoallv(const void *sendbuf, const int *sendcounts, const int *sdispls,
515 int MPIR_Iallreduce_allcomm_auto(const void *sendbuf, void *recvbuf, int count,
593 int MPIR_Ialltoall_intra_gentran_scattered(const void *sendbuf, int sendcount,
970 int MPIR_Ineighbor_allgatherv_allcomm_auto(const void *sendbuf, int sendcount,
1105 int MPIR_Ineighbor_alltoallw_impl(const void *sendbuf, const int sendcounts[],
1316 int MPIR_Iscan_intra_sched_auto(const void *sendbuf, void *recvbuf, int count,
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/include/ |
| H A D | netmod_am_fallback_coll.h | 33 return MPIR_Allgather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_allgather()
43 return MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_allgatherv()
52 return MPIR_Gather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gather()
62 return MPIR_Gatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gatherv()
71 return MPIR_Scatter_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_scatter()
81 return MPIR_Scatterv_impl(sendbuf, sendcounts, displs, sendtype, in MPIDI_NM_mpi_scatterv()
90 return MPIR_Alltoall_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_alltoall()
100 return MPIR_Alltoallv_impl(sendbuf, sendcounts, sdispls, sendtype, in MPIDI_NM_mpi_alltoallv()
159 return MPIR_Neighbor_allgather_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_neighbor_allgather()
179 return MPIR_Neighbor_alltoall_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_neighbor_alltoall()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/shm/src/ |
| H A D | shm_am_fallback_coll.h | 33 return MPIR_Allgather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_SHM_mpi_allgather()
43 return MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_SHM_mpi_allgatherv()
52 return MPIR_Gather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_SHM_mpi_gather()
62 return MPIR_Gatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_SHM_mpi_gatherv()
71 return MPIR_Scatter_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_SHM_mpi_scatter()
81 return MPIR_Scatterv_impl(sendbuf, sendcounts, displs, sendtype, in MPIDI_SHM_mpi_scatterv()
90 return MPIR_Alltoall_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_SHM_mpi_alltoall()
100 return MPIR_Alltoallv_impl(sendbuf, sendcounts, sdispls, sendtype, in MPIDI_SHM_mpi_alltoallv()
160 return MPIR_Neighbor_allgather_impl(sendbuf, sendcount, sendtype, in MPIDI_SHM_mpi_neighbor_allgather()
180 return MPIR_Neighbor_alltoall_impl(sendbuf, sendcount, sendtype, in MPIDI_SHM_mpi_neighbor_alltoall()
[all …]
|
| H A D | shm_coll.h | 40 MPL_STATIC_INLINE_PREFIX int MPIDI_SHM_mpi_allreduce(const void *sendbuf, void *recvbuf, in MPIDI_SHM_mpi_allreduce() argument
65 ret = MPIDI_POSIX_mpi_allgather(sendbuf, sendcount, sendtype, recvbuf, recvcount, in MPIDI_SHM_mpi_allgather()
90 MPL_STATIC_INLINE_PREFIX int MPIDI_SHM_mpi_scatter(const void *sendbuf, int sendcount, in MPIDI_SHM_mpi_scatter() argument
100 ret = MPIDI_POSIX_mpi_scatter(sendbuf, sendcount, sendtype, recvbuf, recvcount, in MPIDI_SHM_mpi_scatter()
118 ret = MPIDI_POSIX_mpi_scatterv(sendbuf, sendcounts, displs, sendtype, recvbuf, in MPIDI_SHM_mpi_scatterv()
135 ret = MPIDI_POSIX_mpi_gather(sendbuf, sendcount, sendtype, recvbuf, recvcount, in MPIDI_SHM_mpi_gather()
153 ret = MPIDI_POSIX_mpi_gatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, in MPIDI_SHM_mpi_gatherv()
170 ret = MPIDI_POSIX_mpi_alltoall(sendbuf, sendcount, sendtype, recvbuf, recvcount, in MPIDI_SHM_mpi_alltoall()
334 MPL_STATIC_INLINE_PREFIX int MPIDI_SHM_mpi_neighbor_alltoallv(const void *sendbuf, in MPIDI_SHM_mpi_neighbor_alltoallv() argument
356 MPL_STATIC_INLINE_PREFIX int MPIDI_SHM_mpi_neighbor_alltoallw(const void *sendbuf, in MPIDI_SHM_mpi_neighbor_alltoallw() argument
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/ |
| H A D | mpid_coll.h | 33 static inline int MPID_Allreduce(const void *sendbuf, void *recvbuf, int count, in MPID_Allreduce() argument
49 if (MPI_SUCCESS == hcoll_Allgather(sendbuf, sendcount, sendtype, recvbuf, in MPID_Allgather()
53 return MPIR_Allgather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPID_Allgather()
63 mpi_errno = MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPID_Allgatherv()
76 mpi_errno = MPIR_Scatter_impl(sendbuf, sendcount, sendtype, recvbuf, in MPID_Scatter()
89 mpi_errno = MPIR_Scatterv_impl(sendbuf, sendcounts, displs, sendtype, in MPID_Scatterv()
102 mpi_errno = MPIR_Gather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPID_Gather()
115 mpi_errno = MPIR_Gatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPID_Gatherv()
128 mpi_errno = MPIR_Alltoall_impl(sendbuf, sendcount, sendtype, recvbuf, in MPID_Alltoall()
181 mpi_errno = MPIR_Reduce_scatter_impl(sendbuf, recvbuf, recvcounts, in MPID_Reduce_scatter()
[all …]
|
| /dports/science/py-pyscf/pyscf-2.0.1/pyscf/agf2/ |
| H A D | mpi_helper.py | 79 sendbuf = np.asarray(sendbuf, order='C')
80 sendbuf = sendbuf.astype(sendbuf.dtype.char)
81 shape, mpi_dtype = comm.bcast((sendbuf.shape, sendbuf.dtype.char))
82 assert sendbuf.shape == shape and sendbuf.dtype.char == mpi_dtype
85 send_seg = np.ndarray(sendbuf.size, dtype=sendbuf.dtype, buffer=sendbuf)
93 return sendbuf if is_array else sendbuf.ravel()[0]
101 sendbuf = np.asarray(sendbuf, order='C')
102 sendbuf = sendbuf.astype(sendbuf.dtype.char)
103 shape, mpi_dtype = comm.bcast((sendbuf.shape, sendbuf.dtype.char))
104 assert sendbuf.shape == shape and sendbuf.dtype.char == mpi_dtype
[all …]
|
| /dports/science/py-pyscf/pyscf-2.0.1/pyscf/pbc/mpitools/ |
| H A D | mpi.py | 184 sendbuf = numpy.asarray(sendbuf, order='C')
185 shape, mpi_dtype = comm.bcast((sendbuf.shape, sendbuf.dtype.char))
196 sendbuf = numpy.asarray(sendbuf, order='C')
216 sendbuf = numpy.asarray(sendbuf, order='C')
233 sendbuf = numpy.asarray(sendbuf, order='C')
235 _assert(sendbuf.dtype.char == mpi_dtype or sendbuf.size == 0)
246 sendbuf = numpy.asarray(sendbuf, mpi_dtype, 'C')
251 sdispls[sdispls>sendbuf.size] = sendbuf.size
259 sendbuf = numpy.hstack(sendbuf)
277 sendbuf = numpy.asarray(sendbuf, order='C')
[all …]
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/include/ |
| H A D | mpicolltest.h | 81 mpi_errno = MPI_Iscatter(sendbuf, sendcount, sendtype, recvbuf, recvcount, in MTest_Scatter()
96 mpi_errno = MPI_Iscatterv(sendbuf, sendcounts, displs, sendtype, recvbuf, in MTest_Scatterv()
237 mpi_errno = MPI_Iscan(sendbuf, recvbuf, count, datatype, op, comm, &req); in MTest_Scan()
297 return MPI_Scatterv(sendbuf, sendcounts, displs, sendtype, recvbuf, in MTest_Scatterv()
312 return MPI_Allgatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, in MTest_Allgatherv()
326 return MPI_Alltoallv(sendbuf, sendcounts, sdispls, sendtype, recvbuf, in MTest_Alltoallv()
335 return MPI_Alltoallw(sendbuf, sendcounts, sdispls, sendtypes, recvbuf, in MTest_Alltoallw()
342 return MPI_Reduce(sendbuf, recvbuf, count, datatype, op, root, comm); in MTest_Reduce()
348 return MPI_Allreduce(sendbuf, recvbuf, count, datatype, op, comm); in MTest_Allreduce()
366 return MPI_Scan(sendbuf, recvbuf, count, datatype, op, comm); in MTest_Scan()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallreduce/ |
| H A D | iallreduce.c | 154 .u.iallreduce.sendbuf = sendbuf, in MPIR_Iallreduce_allcomm_auto()
177 sendbuf, recvbuf, count, datatype, op); in MPIR_Iallreduce_allcomm_auto()
339 int MPIR_Iallreduce_impl(const void *sendbuf, void *recvbuf, int count, in MPIR_Iallreduce_impl() argument
401 (sendbuf, recvbuf, count, datatype, op, comm_ptr, in MPIR_Iallreduce_impl()
480 int MPIR_Iallreduce(const void *sendbuf, void *recvbuf, int count, in MPIR_Iallreduce() argument
490 sendbuf = host_sendbuf; in MPIR_Iallreduce()
531 int MPI_Iallreduce(const void *sendbuf, void *recvbuf, int count, in MPI_Iallreduce() argument
590 MPIR_ERRTEST_SENDBUF_INPLACE(sendbuf, count, mpi_errno); in MPI_Iallreduce()
592 if (sendbuf != MPI_IN_PLACE) in MPI_Iallreduce()
598 sendbuf != MPI_IN_PLACE) in MPI_Iallreduce()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/stubnm/ |
| H A D | stubnm_coll.h | 60 mpi_errno = MPIR_Allgather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_allgather()
77 mpi_errno = MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_allgatherv()
93 mpi_errno = MPIR_Gather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gather()
110 mpi_errno = MPIR_Gatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gatherv()
126 mpi_errno = MPIR_Scatter_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_scatter()
143 mpi_errno = MPIR_Scatterv_impl(sendbuf, sendcounts, displs, sendtype, in MPIDI_NM_mpi_scatterv()
159 mpi_errno = MPIR_Alltoall_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_alltoall()
225 mpi_errno = MPIR_Reduce_scatter_impl(sendbuf, recvbuf, recvcounts, in MPIDI_NM_mpi_reduce_scatter()
319 mpi_errno = MPIR_Neighbor_alltoall_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_neighbor_alltoall()
614 mpi_errno = MPIR_Igather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_igather()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ucx/ |
| H A D | ucx_coll.h | 82 mpi_errno = hcoll_Allgather(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_allgather()
105 mpi_errno = MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_allgatherv()
121 mpi_errno = MPIR_Gather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gather()
138 mpi_errno = MPIR_Gatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gatherv()
154 mpi_errno = MPIR_Scatter_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_scatter()
171 mpi_errno = MPIR_Scatterv_impl(sendbuf, sendcounts, displs, sendtype, in MPIDI_NM_mpi_scatterv()
188 mpi_errno = hcoll_Alltoall(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_alltoall()
271 mpi_errno = MPIR_Reduce_scatter_impl(sendbuf, recvbuf, recvcounts, in MPIDI_NM_mpi_reduce_scatter()
365 mpi_errno = MPIR_Neighbor_alltoall_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_neighbor_alltoall()
659 mpi_errno = MPIR_Igather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_igather()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/src/ |
| H A D | ch4_coll.h | 117 .u.allreduce.sendbuf = sendbuf, in MPID_Allreduce()
176 .u.allgather.sendbuf = sendbuf, in MPID_Allgather()
230 .u.allgatherv.sendbuf = sendbuf, in MPID_Allgatherv()
284 .u.scatter.sendbuf = sendbuf, in MPID_Scatter()
336 .u.scatterv.sendbuf = sendbuf, in MPID_Scatterv()
389 .u.gather.sendbuf = sendbuf, in MPID_Gather()
443 .u.gatherv.sendbuf = sendbuf, in MPID_Gatherv()
497 .u.alltoall.sendbuf = sendbuf, in MPID_Alltoall()
659 .u.reduce.sendbuf = sendbuf, in MPID_Reduce()
819 .u.scan.sendbuf = sendbuf, in MPID_Scan()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter_block/ |
| H A D | ireduce_scatter_block.c | 102 .u.ireduce_scatter_block.sendbuf = sendbuf, in MPIR_Ireduce_scatter_block_allcomm_auto()
124 sendbuf, recvbuf, recvcount, datatype, op); in MPIR_Ireduce_scatter_block_allcomm_auto()
134 sendbuf, recvbuf, recvcount, datatype, op); in MPIR_Ireduce_scatter_block_allcomm_auto()
149 sendbuf, recvbuf, recvcount, datatype, op); in MPIR_Ireduce_scatter_block_allcomm_auto()
255 int MPIR_Ireduce_scatter_block_impl(const void *sendbuf, void *recvbuf, in MPIR_Ireduce_scatter_block_impl() argument
346 sendbuf, recvbuf, recvcount, datatype, op); in MPIR_Ireduce_scatter_block_impl()
349 sendbuf, recvbuf, recvcount, datatype, op); in MPIR_Ireduce_scatter_block_impl()
358 int MPIR_Ireduce_scatter_block(const void *sendbuf, void *recvbuf, in MPIR_Ireduce_scatter_block() argument
370 sendbuf = host_sendbuf; in MPIR_Ireduce_scatter_block()
414 int MPI_Ireduce_scatter_block(const void *sendbuf, void *recvbuf, in MPI_Ireduce_scatter_block() argument
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ialltoall/ |
| H A D | ialltoall.c | 138 .u.ialltoall.sendbuf = sendbuf, in MPIR_Ialltoall_allcomm_auto()
232 if (sendbuf == MPI_IN_PLACE) { in MPIR_Ialltoall_intra_sched_auto()
264 mpi_errno = MPIR_Ialltoall_inter_sched_pairwise_exchange(sendbuf, sendcount, in MPIR_Ialltoall_inter_sched_auto()
288 int MPIR_Ialltoall_impl(const void *sendbuf, int sendcount, in MPIR_Ialltoall_impl() argument
321 MPIR_Ialltoall_intra_gentran_scattered(sendbuf, sendcount, in MPIR_Ialltoall_impl()
394 int MPIR_Ialltoall(const void *sendbuf, int sendcount, MPI_Datatype sendtype, in MPIR_Ialltoall() argument
437 int MPI_Ialltoall(const void *sendbuf, int sendcount, MPI_Datatype sendtype, in MPI_Ialltoall() argument
454 if (sendbuf != MPI_IN_PLACE) { in MPI_Ialltoall()
480 if (sendbuf != MPI_IN_PLACE && !HANDLE_IS_BUILTIN(sendtype)) { in MPI_Ialltoall()
505 sendbuf != MPI_IN_PLACE && in MPI_Ialltoall()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ |
| H A D | test_p2p_rma.cc | 18 return uct_ep_put_short(ep, sendbuf.ptr(), sendbuf.length(), in put_short()
29 EXPECT_EQ(sendbuf.length(), (size_t)packed_len); in put_bcopy()
39 UCS_TEST_GET_BUFFER_IOV(iov, iovcnt, sendbuf.ptr(), sendbuf.length(), in put_zcopy()
48 return uct_ep_get_short(ep, sendbuf.ptr(), sendbuf.length(), in get_short()
56 sendbuf.length(), recvbuf.addr(), in get_bcopy()
63 UCS_TEST_GET_BUFFER_IOV(iov, iovcnt, sendbuf.ptr(), sendbuf.length(), in get_zcopy()
83 sendbuf.pattern_fill(SEED3); in test_xfer()
88 sendbuf.pattern_check(SEED2); in test_xfer()
139 mapped_buffer sendbuf(4096, 0, sender());
144 sender_ep(), sendbuf, recvbuf, true);
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/ |
| H A D | ofi_coll.h | 83 mpi_errno = MPIR_Allgather_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_allgather()
107 mpi_errno = MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_allgatherv()
130 mpi_errno = MPIR_Gather_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gather()
154 mpi_errno = MPIR_Gatherv_impl(sendbuf, sendcount, sendtype, recvbuf, in MPIDI_NM_mpi_gatherv()
225 mpi_errno = MPIR_Alltoall_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_alltoall()
249 mpi_errno = MPIR_Alltoallv_impl(sendbuf, sendcounts, sdispls, in MPIDI_NM_mpi_alltoallv()
275 mpi_errno = MPIR_Alltoallw_impl(sendbuf, sendcounts, sdispls, in MPIDI_NM_mpi_alltoallw()
629 mpi_errno = MPIR_Iallgatherv_impl(sendbuf, sendcount, sendtype, in MPIDI_NM_mpi_iallgatherv()
676 mpi_errno = MPIR_Ialltoallv_impl(sendbuf, sendcounts, sdispls, in MPIDI_NM_mpi_ialltoallv()
694 mpi_errno = MPIR_Ialltoallw_impl(sendbuf, sendcounts, sdispls, in MPIDI_NM_mpi_ialltoallw()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ialltoallw/ |
| H A D | ialltoallw.c | 67 int MPI_Ialltoallw(const void *sendbuf, const int sendcounts[], const int sdispls[],
92 .u.ialltoallw.sendbuf = sendbuf, in MPIR_Ialltoallw_allcomm_auto()
162 int MPIR_Ialltoallw_intra_sched_auto(const void *sendbuf, const int sendcounts[], in MPIR_Ialltoallw_intra_sched_auto() argument
170 if (sendbuf == MPI_IN_PLACE) { in MPIR_Ialltoallw_intra_sched_auto()
171 mpi_errno = MPIR_Ialltoallw_intra_sched_inplace(sendbuf, sendcounts, sdispls, in MPIR_Ialltoallw_intra_sched_auto()
183 int MPIR_Ialltoallw_inter_sched_auto(const void *sendbuf, const int sendcounts[], in MPIR_Ialltoallw_inter_sched_auto() argument
206 mpi_errno = MPIR_Ialltoallw_intra_sched_auto(sendbuf, sendcounts, sdispls, in MPIR_Ialltoallw_sched_auto()
210 mpi_errno = MPIR_Ialltoallw_inter_sched_auto(sendbuf, sendcounts, sdispls, in MPIR_Ialltoallw_sched_auto()
407 if (sendbuf != MPI_IN_PLACE) { in MPI_Ialltoallw()
414 MPIR_ERRTEST_ALIAS_COLL(sendbuf, recvbuf, mpi_errno); in MPI_Ialltoallw()
[all …]
|
| /dports/databases/pecl-memcache/memcache-8.0/src/ |
| H A D | memcache_ascii_protocol.c | 246 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_append_get()
303 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_store()
305 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_store()
307 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_store()
309 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_store()
313 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_store()
331 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_delete()
335 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_delete()
354 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_mutate()
356 smart_string_appendl(&(request->sendbuf.value), " ", 1); in mmc_ascii_mutate()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgather/ |
| H A D | iallgather.c | 157 .u.iallgather.sendbuf = sendbuf, in MPIR_Iallgather_allcomm_auto()
250 if (((sendcount == 0) && (sendbuf != MPI_IN_PLACE)) || (recvcount == 0)) in MPIR_Iallgather_intra_sched_auto()
279 int MPIR_Iallgather_inter_sched_auto(const void *sendbuf, int sendcount, in MPIR_Iallgather_inter_sched_auto() argument
292 int MPIR_Iallgather_sched_auto(const void *sendbuf, int sendcount, in MPIR_Iallgather_sched_auto() argument
303 mpi_errno = MPIR_Iallgather_inter_sched_auto(sendbuf, sendcount, sendtype, in MPIR_Iallgather_sched_auto()
310 int MPIR_Iallgather_impl(const void *sendbuf, int sendcount, in MPIR_Iallgather_impl() argument
420 int MPIR_Iallgather(const void *sendbuf, int sendcount, MPI_Datatype sendtype, in MPIR_Iallgather() argument
464 int MPI_Iallgather(const void *sendbuf, int sendcount, MPI_Datatype sendtype, in MPI_Iallgather() argument
481 if (sendbuf != MPI_IN_PLACE) { in MPI_Iallgather()
504 if (sendbuf != MPI_IN_PLACE && !HANDLE_IS_BUILTIN(sendtype)) { in MPI_Iallgather()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce/ |
| H A D | ireduce.c | 150 .u.ireduce.sendbuf = sendbuf, in MPIR_Ireduce_allcomm_auto()
194 sendbuf, recvbuf, count, datatype, op, root); in MPIR_Ireduce_allcomm_auto()
232 mpi_errno = MPIR_Ireduce_intra_sched_smp(sendbuf, recvbuf, count, in MPIR_Ireduce_intra_sched_auto()
266 int MPIR_Ireduce_inter_sched_auto(const void *sendbuf, void *recvbuf, in MPIR_Ireduce_inter_sched_auto() argument
284 mpi_errno = MPIR_Ireduce_intra_sched_auto(sendbuf, recvbuf, count, in MPIR_Ireduce_sched_auto()
287 mpi_errno = MPIR_Ireduce_inter_sched_auto(sendbuf, recvbuf, count, in MPIR_Ireduce_sched_auto()
294 int MPIR_Ireduce_impl(const void *sendbuf, void *recvbuf, int count, in MPIR_Ireduce_impl() argument
396 int MPIR_Ireduce(const void *sendbuf, void *recvbuf, int count, in MPIR_Ireduce() argument
407 sendbuf = host_sendbuf; in MPIR_Ireduce()
513 if (sendbuf != MPI_IN_PLACE) in MPI_Ireduce()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ialltoallv/ |
| H A D | ialltoallv.c | 90 int MPI_Ialltoallv(const void *sendbuf, const int sendcounts[], const int sdispls[],
116 .u.ialltoallv.sendbuf = sendbuf, in MPIR_Ialltoallv_allcomm_auto()
197 int MPIR_Ialltoallv_intra_sched_auto(const void *sendbuf, const int sendcounts[], in MPIR_Ialltoallv_intra_sched_auto() argument
206 if (sendbuf == MPI_IN_PLACE) { in MPIR_Ialltoallv_intra_sched_auto()
219 int MPIR_Ialltoallv_inter_sched_auto(const void *sendbuf, const int sendcounts[], in MPIR_Ialltoallv_inter_sched_auto() argument
241 mpi_errno = MPIR_Ialltoallv_intra_sched_auto(sendbuf, sendcounts, sdispls, in MPIR_Ialltoallv_sched_auto()
245 mpi_errno = MPIR_Ialltoallv_inter_sched_auto(sendbuf, sendcounts, sdispls, in MPIR_Ialltoallv_sched_auto()
438 if (sendbuf != MPI_IN_PLACE) in MPI_Ialltoallv()
461 if (sendbuf != MPI_IN_PLACE) { in MPI_Ialltoallv()
493 MPIR_ERRTEST_ALIAS_COLL(sendbuf, recvbuf, mpi_errno); in MPI_Ialltoallv()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter/ |
| H A D | ireduce_scatter.c | 101 .u.ireduce_scatter.sendbuf = sendbuf, in MPIR_Ireduce_scatter_allcomm_auto()
119 sendbuf, recvbuf, recvcounts, datatype, op); in MPIR_Ireduce_scatter_allcomm_auto()
124 sendbuf, recvbuf, recvcounts, datatype, op); in MPIR_Ireduce_scatter_allcomm_auto()
166 int MPIR_Ireduce_scatter_intra_sched_auto(const void *sendbuf, void *recvbuf, in MPIR_Ireduce_scatter_intra_sched_auto() argument
231 int MPIR_Ireduce_scatter_inter_sched_auto(const void *sendbuf, void *recvbuf, in MPIR_Ireduce_scatter_inter_sched_auto() argument
251 mpi_errno = MPIR_Ireduce_scatter_intra_sched_auto(sendbuf, recvbuf, in MPIR_Ireduce_scatter_sched_auto()
350 sendbuf, recvbuf, recvcounts, datatype, op); in MPIR_Ireduce_scatter_impl()
353 sendbuf, recvbuf, recvcounts, datatype, op); in MPIR_Ireduce_scatter_impl()
377 sendbuf = host_sendbuf; in MPIR_Ireduce_scatter()
489 MPIR_ERRTEST_ALIAS_COLL(sendbuf, recvbuf, mpi_errno) in MPI_Ireduce_scatter()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpid/ch4/shm/posix/ |
| H A D | posix_coll.h | 206 .u.allreduce.sendbuf = sendbuf, in MPIDI_POSIX_mpi_allreduce()
278 mpi_errno = MPIR_Allgather_impl(sendbuf, sendcount, sendtype, in MPIDI_POSIX_mpi_allgather()
302 mpi_errno = MPIR_Allgatherv_impl(sendbuf, sendcount, sendtype, in MPIDI_POSIX_mpi_allgatherv()
420 mpi_errno = MPIR_Alltoall_impl(sendbuf, sendcount, sendtype, in MPIDI_POSIX_mpi_alltoall()
444 mpi_errno = MPIR_Alltoallv_impl(sendbuf, sendcounts, sdispls, in MPIDI_POSIX_mpi_alltoallv()
471 mpi_errno = MPIR_Alltoallw_impl(sendbuf, sendcounts, sdispls, in MPIDI_POSIX_mpi_alltoallw()
493 .u.reduce.sendbuf = sendbuf, in MPIDI_POSIX_mpi_reduce()
891 mpi_errno = MPIR_Iallgatherv_impl(sendbuf, sendcount, sendtype, in MPIDI_POSIX_mpi_iallgatherv()
924 mpi_errno = MPIR_Ialltoallv_impl(sendbuf, sendcounts, sdispls, in MPIDI_POSIX_mpi_ialltoallv()
943 mpi_errno = MPIR_Ialltoallw_impl(sendbuf, sendcounts, sdispls, in MPIDI_POSIX_mpi_ialltoallw()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgatherv/ |
| H A D | iallgatherv.c | 152 .u.iallgatherv.sendbuf = sendbuf, in MPIR_Iallgatherv_allcomm_auto()
310 mpi_errno = MPIR_Iallgatherv_intra_sched_auto(sendbuf, sendcount, sendtype, in MPIR_Iallgatherv_sched_auto()
314 mpi_errno = MPIR_Iallgatherv_inter_sched_auto(sendbuf, sendcount, sendtype, in MPIR_Iallgatherv_sched_auto()
322 int MPIR_Iallgatherv_impl(const void *sendbuf, int sendcount, MPI_Datatype sendtype, in MPIR_Iallgatherv_impl() argument
368 MPIR_Iallgatherv_intra_gentran_ring(sendbuf, sendcount, sendtype, in MPIR_Iallgatherv_impl()
375 MPIR_Iallgatherv_intra_gentran_brucks(sendbuf, sendcount, sendtype, in MPIR_Iallgatherv_impl()
454 int MPIR_Iallgatherv(const void *sendbuf, int sendcount, MPI_Datatype sendtype, in MPIR_Iallgatherv() argument
516 if (sendbuf != MPI_IN_PLACE) { in MPI_Iallgatherv()
541 if (sendbuf != MPI_IN_PLACE) { in MPI_Iallgatherv()
558 MPIR_ERRTEST_ALIAS_COLL(sendbuf, in MPI_Iallgatherv()
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mpi/java/java/ |
| H A D | Comm.java | 460 sendbuf = ((Buffer)sendbuf).array(); in sendRecv()
1327 sendbuf = ((Buffer)sendbuf).array(); in gather()
1464 sendbuf = ((Buffer)sendbuf).array(); in gatherv()
1533 sendbuf = ((Buffer)sendbuf).array(); in gatherv()
1662 sendbuf = ((Buffer)sendbuf).array(); in scatter()
1797 sendbuf = ((Buffer)sendbuf).array(); in scatterv()
1835 sendbuf = ((Buffer)sendbuf).array(); in scatterv()
1989 sendbuf = ((Buffer)sendbuf).array(); in allGather()
2114 sendbuf = ((Buffer)sendbuf).array(); in allGatherv()
2247 sendbuf = ((Buffer)sendbuf).array(); in allToAll()
[all …]
|