| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgatherv/ |
| H A D | iallgatherv_tsp_recexch_algos.h | 66 int MPIR_TSP_Iallgatherv_sched_intra_recexch_step1(int step1_sendto, int *step1_recvfrom, in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1() argument
92 recv_offset = displs[step1_recvfrom[i]] * recv_extent; in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1()
93 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), recvcounts[step1_recvfrom[i]], in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1()
94 recvtype, step1_recvfrom[i], tag, comm, sched, n_invtcs, invtx); in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1()
184 int MPIR_TSP_Iallgatherv_sched_intra_recexch_step3(int step1_sendto, int *step1_recvfrom, in MPIR_TSP_Iallgatherv_sched_intra_recexch_step3() argument
207 MPIR_TSP_sched_isend(recvbuf, total_count, recvtype, step1_recvfrom[i], in MPIR_TSP_Iallgatherv_sched_intra_recexch_step3()
231 int *step1_recvfrom = NULL; in MPIR_TSP_Iallgatherv_sched_intra_recexch() local
262 &step1_recvfrom, &step1_nrecvs, in MPIR_TSP_Iallgatherv_sched_intra_recexch()
282 MPIR_TSP_Iallgatherv_sched_intra_recexch_step1(step1_sendto, step1_recvfrom, step1_nrecvs, in MPIR_TSP_Iallgatherv_sched_intra_recexch()
308 MPIR_TSP_Iallgatherv_sched_intra_recexch_step3(step1_sendto, step1_recvfrom, step1_nrecvs, in MPIR_TSP_Iallgatherv_sched_intra_recexch()
[all …]
|
| H A D | iallgatherv_tsp_recexch_algos_prototypes.h | 33 int MPIR_TSP_Iallgatherv_sched_intra_recexch_step1(int step1_sendto, int *step1_recvfrom,
50 int MPIR_TSP_Iallgatherv_sched_intra_recexch_step3(int step1_sendto, int *step1_recvfrom,
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgather/ |
| H A D | iallgather_tsp_recexch_algos.h | 55 int MPIR_TSP_Iallgather_sched_intra_recexch_step1(int step1_sendto, int *step1_recvfrom, in MPIR_TSP_Iallgather_sched_intra_recexch_step1() argument
80 recv_offset = step1_recvfrom[i] * recv_extent * recvcount; in MPIR_TSP_Iallgather_sched_intra_recexch_step1()
82 step1_recvfrom[i], tag, comm, sched, n_invtcs, invtx); in MPIR_TSP_Iallgather_sched_intra_recexch_step1()
164 int MPIR_TSP_Iallgather_sched_intra_recexch_step3(int step1_sendto, int *step1_recvfrom, in MPIR_TSP_Iallgather_sched_intra_recexch_step3() argument
183 MPIR_TSP_sched_isend(recvbuf, recvcount * nranks, recvtype, step1_recvfrom[i], in MPIR_TSP_Iallgather_sched_intra_recexch_step3()
214 int *step1_recvfrom; in MPIR_TSP_Iallgather_sched_intra_recexch() local
239 &step1_recvfrom, &step1_nrecvs, in MPIR_TSP_Iallgather_sched_intra_recexch()
259 MPIR_TSP_Iallgather_sched_intra_recexch_step1(step1_sendto, step1_recvfrom, step1_nrecvs, in MPIR_TSP_Iallgather_sched_intra_recexch()
284 MPIR_TSP_Iallgather_sched_intra_recexch_step3(step1_sendto, step1_recvfrom, step1_nrecvs, in MPIR_TSP_Iallgather_sched_intra_recexch()
292 MPL_free(step1_recvfrom); in MPIR_TSP_Iallgather_sched_intra_recexch()
|
| H A D | iallgather_tsp_recexch_algos_prototypes.h | 32 int MPIR_TSP_Iallgather_sched_intra_recexch_step1(int step1_sendto, int *step1_recvfrom,
47 int MPIR_TSP_Iallgather_sched_intra_recexch_step3(int step1_sendto, int *step1_recvfrom,
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter/ |
| H A D | ireduce_scatter_tsp_recexch_algos.h | 141 int *step1_recvfrom = NULL; in MPIR_TSP_Ireduce_scatter_sched_intra_recexch() local
194 &step1_recvfrom, &step1_nrecvs, in MPIR_TSP_Ireduce_scatter_sched_intra_recexch()
230 step1_recvfrom[i], tag, comm, sched, nvtcs, vtcs); in MPIR_TSP_Ireduce_scatter_sched_intra_recexch()
268 MPIR_TSP_sched_isend((char *) tmp_results + displs[step1_recvfrom[i]] * extent, in MPIR_TSP_Ireduce_scatter_sched_intra_recexch()
269 recvcounts[step1_recvfrom[i]], datatype, step1_recvfrom[i], tag, comm, in MPIR_TSP_Ireduce_scatter_sched_intra_recexch()
279 MPL_free(step1_recvfrom); in MPIR_TSP_Ireduce_scatter_sched_intra_recexch()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter_block/ |
| H A D | ireduce_scatter_block_tsp_recexch_algos.h | 26 int *step1_recvfrom = NULL; in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch() local
69 &step1_recvfrom, &step1_nrecvs, in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch()
106 step1_recvfrom[i], tag, comm, sched, nvtcs, vtcs); in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch()
183 MPIR_TSP_sched_isend((char *) tmp_results + recvcount * step1_recvfrom[i] * extent, in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch()
184 recvcount, datatype, step1_recvfrom[i], tag, comm, sched, nvtcs, vtcs); in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch()
194 MPL_free(step1_recvfrom); in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch()
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallreduce/ |
| H A D | iallreduce_tsp_recexch_reduce_scatter_recexch_allgatherv_algos.h | 34 int step1_sendto = -1, step1_nrecvs, *step1_recvfrom = NULL; in MPIR_TSP_Iallreduce_sched_intra_recexch_reduce_scatter_recexch_allgatherv() local
78 &step1_recvfrom, &step1_nrecvs, in MPIR_TSP_Iallreduce_sched_intra_recexch_reduce_scatter_recexch_allgatherv()
102 step1_recvfrom, per_nbr_buffer, &step1_recvbuf, in MPIR_TSP_Iallreduce_sched_intra_recexch_reduce_scatter_recexch_allgatherv()
153 MPIR_TSP_sched_isend(recvbuf, count, datatype, step1_recvfrom[i], tag, comm, sched, in MPIR_TSP_Iallreduce_sched_intra_recexch_reduce_scatter_recexch_allgatherv()
166 MPL_free(step1_recvfrom); in MPIR_TSP_Iallreduce_sched_intra_recexch_reduce_scatter_recexch_allgatherv()
|
| H A D | iallreduce_tsp_recexch_algos.h | 28 int step1_sendto = -1, step1_nrecvs = 0, *step1_recvfrom; in MPIR_TSP_Iallreduce_sched_intra_recexch() local
71 &step1_recvfrom, &step1_nrecvs, in MPIR_TSP_Iallreduce_sched_intra_recexch()
92 step1_recvfrom, per_nbr_buffer, &step1_recvbuf, in MPIR_TSP_Iallreduce_sched_intra_recexch()
286 MPIR_TSP_sched_isend(recvbuf, count, datatype, step1_recvfrom[i], tag, comm, sched, in MPIR_TSP_Iallreduce_sched_intra_recexch()
297 MPL_free(step1_recvfrom); in MPIR_TSP_Iallreduce_sched_intra_recexch()
|
| H A D | iallreduce_tsp_recursive_exchange_common.h | 51 int *step1_recvfrom, int per_nbr_buffer, in MPIR_TSP_Iallreduce_sched_intra_recexch_step1() argument
94 step1_recvfrom[i], tag, comm, sched, nvtcs, vtcs); in MPIR_TSP_Iallreduce_sched_intra_recexch_step1()
|
| H A D | iallreduce_tsp_recursive_exchange_common_prototypes.h | 23 int *step1_recvfrom, int per_nbr_buffer,
|
| /dports/net/mpich/mpich-3.4.3/src/mpi/coll/algorithms/recexchalgo/ |
| H A D | recexchalgo.c | 51 int *step1_recvfrom; in MPII_Recexchalgo_get_neighbors() local
71 step1_recvfrom = *step1_recvfrom_ = (int *) MPL_malloc(sizeof(int) * (k - 1), MPL_MEM_COLL); in MPII_Recexchalgo_get_neighbors()
73 MPIR_Assert(step1_recvfrom != NULL && *step1_recvfrom_ != NULL && step2_nbrs != NULL && in MPII_Recexchalgo_get_neighbors()
112 step1_recvfrom[i] = rank - i - 1; in MPII_Recexchalgo_get_neighbors()
124 step1_recvfrom[nsenders - 1 - j] = T - nsenders + j; in MPII_Recexchalgo_get_neighbors()
|