| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/base/ |
| H A D | coll_base_alltoallv.c | 66 size_t size = opal_datatype_span(&rdtype->super, rcounts[i], &gap); in mca_coll_base_alltoallv_intra_basic_inplace()
86 if (i == rank && 0 != rcounts[j]) { in mca_coll_base_alltoallv_intra_basic_inplace()
88 err = ompi_datatype_copy_content_same_ddt (rdtype, rcounts[j], in mca_coll_base_alltoallv_intra_basic_inplace()
99 } else if (j == rank && 0 != rcounts[i]) { in mca_coll_base_alltoallv_intra_basic_inplace()
101 err = ompi_datatype_copy_content_same_ddt (rdtype, rcounts[i], in mca_coll_base_alltoallv_intra_basic_inplace()
127 void* rbuf, const int *rcounts, const int *rdisps, in ompi_coll_base_alltoallv_intra_pairwise() argument
137 return mca_coll_base_alltoallv_intra_basic_inplace (rbuf, rcounts, rdisps, in ompi_coll_base_alltoallv_intra_pairwise()
164 prcv, rcounts[recvfrom], rdtype, recvfrom, in ompi_coll_base_alltoallv_intra_pairwise()
204 return mca_coll_base_alltoallv_intra_basic_inplace (rbuf, rcounts, rdisps, in ompi_coll_base_alltoallv_intra_basic_linear()
222 prcv, rcounts[rank], rdtype); in ompi_coll_base_alltoallv_intra_basic_linear()
[all …]
|
| H A D | coll_base_reduce_scatter.c | 96 displs[i] = displs[i-1] + rcounts[i-1]; in ompi_coll_base_reduce_scatter_intra_nonoverlapping()
157 disps[i + 1] = disps[i] + rcounts[i]; in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
159 count = disps[size - 1] + rcounts[size - 1]; in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
253 tmp_rcounts[i] = rcounts[i * 2 + 1] + rcounts[i * 2]; in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
347 if (0 != rcounts[rank]) { in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
366 if (rcounts[rank]) { in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
373 if (rcounts[rank - 1]) { in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
481 total_count = rcounts[0]; in ompi_coll_base_reduce_scatter_intra_ring()
482 max_block_count = rcounts[0]; in ompi_coll_base_reduce_scatter_intra_ring()
485 total_count += rcounts[i]; in ompi_coll_base_reduce_scatter_intra_ring()
[all …]
|
| H A D | coll_base_allgatherv.c | 127 tmprecv, rcounts[rank], rdtype); in ompi_coll_base_allgatherv_intra_bruck()
167 new_scounts[i] = rcounts[tmp_srank]; in ompi_coll_base_allgatherv_intra_bruck()
169 new_rcounts[i] = rcounts[tmp_rrank]; in ompi_coll_base_allgatherv_intra_bruck()
431 err = ompi_coll_base_sendrecv(tmpsend, rcounts[rank], rdtype, in ompi_coll_base_allgatherv_intra_neighborexchange()
455 new_scounts[0] = rcounts[send_data_from]; in ompi_coll_base_allgatherv_intra_neighborexchange()
456 new_scounts[1] = rcounts[(send_data_from + 1)]; in ompi_coll_base_allgatherv_intra_neighborexchange()
465 new_rcounts[0] = rcounts[recv_data_from[i_parity]]; in ompi_coll_base_allgatherv_intra_neighborexchange()
538 scount = rcounts[rank]; in ompi_coll_base_allgatherv_intra_two_procs()
554 rcounts[rank], rdtype); in ompi_coll_base_allgatherv_intra_two_procs()
620 scount = rcounts[rank]; in ompi_coll_base_allgatherv_intra_basic_default()
[all …]
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/base/ |
| H A D | coll_base_reduce_scatter.c | 97 displs[i] = displs[i-1] + rcounts[i-1]; in ompi_coll_base_reduce_scatter_intra_nonoverlapping()
158 disps[i + 1] = disps[i] + rcounts[i]; in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
160 count = disps[size - 1] + rcounts[size - 1]; in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
254 tmp_rcounts[i] = rcounts[i * 2 + 1] + rcounts[i * 2]; in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
348 if (0 != rcounts[rank]) { in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
367 if (rcounts[rank]) { in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
374 if (rcounts[rank - 1]) { in ompi_coll_base_reduce_scatter_intra_basic_recursivehalving()
482 total_count = rcounts[0]; in ompi_coll_base_reduce_scatter_intra_ring()
483 max_block_count = rcounts[0]; in ompi_coll_base_reduce_scatter_intra_ring()
486 total_count += rcounts[i]; in ompi_coll_base_reduce_scatter_intra_ring()
[all …]
|
| H A D | coll_base_alltoallv.c | 66 size_t size = opal_datatype_span(&rdtype->super, rcounts[i], &gap); in mca_coll_base_alltoallv_intra_basic_inplace()
86 if (i == rank && 0 != rcounts[j]) { in mca_coll_base_alltoallv_intra_basic_inplace()
88 err = ompi_datatype_copy_content_same_ddt (rdtype, rcounts[j], in mca_coll_base_alltoallv_intra_basic_inplace()
99 } else if (j == rank && 0 != rcounts[i]) { in mca_coll_base_alltoallv_intra_basic_inplace()
101 err = ompi_datatype_copy_content_same_ddt (rdtype, rcounts[i], in mca_coll_base_alltoallv_intra_basic_inplace()
127 void* rbuf, const int *rcounts, const int *rdisps, in ompi_coll_base_alltoallv_intra_pairwise() argument
137 return mca_coll_base_alltoallv_intra_basic_inplace (rbuf, rcounts, rdisps, in ompi_coll_base_alltoallv_intra_pairwise()
164 prcv, rcounts[recvfrom], rdtype, recvfrom, in ompi_coll_base_alltoallv_intra_pairwise()
204 return mca_coll_base_alltoallv_intra_basic_inplace (rbuf, rcounts, rdisps, in ompi_coll_base_alltoallv_intra_basic_linear()
222 prcv, rcounts[rank], rdtype); in ompi_coll_base_alltoallv_intra_basic_linear()
[all …]
|
| H A D | coll_base_allgatherv.c | 124 tmprecv, rcounts[rank], rdtype); in ompi_coll_base_allgatherv_intra_bruck()
164 new_scounts[i] = rcounts[tmp_srank]; in ompi_coll_base_allgatherv_intra_bruck()
166 new_rcounts[i] = rcounts[tmp_rrank]; in ompi_coll_base_allgatherv_intra_bruck()
422 err = ompi_coll_base_sendrecv(tmpsend, rcounts[rank], rdtype, in ompi_coll_base_allgatherv_intra_neighborexchange()
446 new_scounts[0] = rcounts[send_data_from]; in ompi_coll_base_allgatherv_intra_neighborexchange()
447 new_scounts[1] = rcounts[(send_data_from + 1)]; in ompi_coll_base_allgatherv_intra_neighborexchange()
456 new_rcounts[0] = rcounts[recv_data_from[i_parity]]; in ompi_coll_base_allgatherv_intra_neighborexchange()
526 scount = rcounts[rank]; in ompi_coll_base_allgatherv_intra_two_procs()
542 rcounts[rank], rdtype); in ompi_coll_base_allgatherv_intra_two_procs()
608 scount = rcounts[rank]; in ompi_coll_base_allgatherv_intra_basic_default()
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/basic/ |
| H A D | coll_basic_alltoallw.c | 62 ext = opal_datatype_span(&rdtypes[i]->super, rcounts[i], &gap); in mca_coll_basic_alltoallw_intra_inplace()
78 msg_size_i *= rcounts[i]; in mca_coll_basic_alltoallw_intra_inplace()
82 msg_size_j *= rcounts[j]; in mca_coll_basic_alltoallw_intra_inplace()
87 err = ompi_datatype_copy_content_same_ddt (rdtypes[j], rcounts[j], in mca_coll_basic_alltoallw_intra_inplace()
145 void *rbuf, const int *rcounts, const int *rdisps, in mca_coll_basic_alltoallw_intra() argument
156 return mca_coll_basic_alltoallw_intra_inplace (rbuf, rcounts, rdisps, in mca_coll_basic_alltoallw_intra()
169 prcv, rcounts[rank], rdtypes[rank]); in mca_coll_basic_alltoallw_intra()
191 msg_size *= rcounts[i]; in mca_coll_basic_alltoallw_intra()
197 err = MCA_PML_CALL(irecv_init(prcv, rcounts[i], rdtypes[i], in mca_coll_basic_alltoallw_intra()
280 msg_size *= rcounts[i]; in mca_coll_basic_alltoallw_inter()
[all …]
|
| H A D | coll_basic_reduce_scatter.c | 88 disps[i + 1] = disps[i] + rcounts[i]; in mca_coll_basic_reduce_scatter_intra()
90 count = disps[size - 1] + rcounts[size - 1]; in mca_coll_basic_reduce_scatter_intra()
189 tmp_rcounts[i] = rcounts[i * 2 + 1] + rcounts[i * 2]; in mca_coll_basic_reduce_scatter_intra()
191 tmp_rcounts[i] = rcounts[i + remain]; in mca_coll_basic_reduce_scatter_intra()
283 if (0 != rcounts[rank]) { in mca_coll_basic_reduce_scatter_intra()
285 rcounts[rank], dtype, in mca_coll_basic_reduce_scatter_intra()
286 rbuf, rcounts[rank], dtype); in mca_coll_basic_reduce_scatter_intra()
302 if (rcounts[rank]) { in mca_coll_basic_reduce_scatter_intra()
309 if (rcounts[rank - 1]) { in mca_coll_basic_reduce_scatter_intra()
380 totalcounts += rcounts[i]; in mca_coll_basic_reduce_scatter_inter()
[all …]
|
| H A D | coll_basic_gatherv.c | 43 void *rbuf, const int *rcounts, const int *disps, in mca_coll_basic_gatherv_intra() argument
82 if (MPI_IN_PLACE != sbuf && (0 < scount) && (0 < rcounts[i])) { in mca_coll_basic_gatherv_intra()
84 ptmp, rcounts[i], rdtype); in mca_coll_basic_gatherv_intra()
88 if (rcounts[i] > 0) { in mca_coll_basic_gatherv_intra()
89 err = MCA_PML_CALL(recv(ptmp, rcounts[i], rdtype, i, in mca_coll_basic_gatherv_intra()
116 void *rbuf, const int *rcounts, const int *disps, in mca_coll_basic_gatherv_inter() argument
151 err = MCA_PML_CALL(irecv(ptmp, rcounts[i], rdtype, i, in mca_coll_basic_gatherv_inter()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/basic/ |
| H A D | coll_basic_alltoallw.c | 62 ext = opal_datatype_span(&rdtypes[i]->super, rcounts[i], &gap); in mca_coll_basic_alltoallw_intra_inplace()
78 msg_size_i *= rcounts[i]; in mca_coll_basic_alltoallw_intra_inplace()
82 msg_size_j *= rcounts[j]; in mca_coll_basic_alltoallw_intra_inplace()
87 err = ompi_datatype_copy_content_same_ddt (rdtypes[j], rcounts[j], in mca_coll_basic_alltoallw_intra_inplace()
145 void *rbuf, const int *rcounts, const int *rdisps, in mca_coll_basic_alltoallw_intra() argument
156 return mca_coll_basic_alltoallw_intra_inplace (rbuf, rcounts, rdisps, in mca_coll_basic_alltoallw_intra()
169 prcv, rcounts[rank], rdtypes[rank]); in mca_coll_basic_alltoallw_intra()
191 msg_size *= rcounts[i]; in mca_coll_basic_alltoallw_intra()
197 err = MCA_PML_CALL(irecv_init(prcv, rcounts[i], rdtypes[i], in mca_coll_basic_alltoallw_intra()
280 msg_size *= rcounts[i]; in mca_coll_basic_alltoallw_inter()
[all …]
|
| H A D | coll_basic_reduce_scatter.c | 88 disps[i + 1] = disps[i] + rcounts[i]; in mca_coll_basic_reduce_scatter_intra()
90 count = disps[size - 1] + rcounts[size - 1]; in mca_coll_basic_reduce_scatter_intra()
189 tmp_rcounts[i] = rcounts[i * 2 + 1] + rcounts[i * 2]; in mca_coll_basic_reduce_scatter_intra()
191 tmp_rcounts[i] = rcounts[i + remain]; in mca_coll_basic_reduce_scatter_intra()
283 if (0 != rcounts[rank]) { in mca_coll_basic_reduce_scatter_intra()
285 rcounts[rank], dtype, in mca_coll_basic_reduce_scatter_intra()
286 rbuf, rcounts[rank], dtype); in mca_coll_basic_reduce_scatter_intra()
302 if (rcounts[rank]) { in mca_coll_basic_reduce_scatter_intra()
309 if (rcounts[rank - 1]) { in mca_coll_basic_reduce_scatter_intra()
380 totalcounts += rcounts[i]; in mca_coll_basic_reduce_scatter_inter()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/coll/ |
| H A D | nonblocking.c | 34 int *rcounts = NULL; in main() local
56 rcounts = malloc(size * sizeof(int)); in main()
57 my_assert(rcounts); in main()
71 rcounts[i] = NUM_INTS; in main()
92 MPI_Igatherv(sbuf, NUM_INTS, MPI_INT, rbuf, rcounts, rdispls, MPI_INT, 0, comm, &req); in main()
99 MPI_Igatherv(sbuf, NUM_INTS, MPI_INT, rbuf, rcounts, rdispls, MPI_INT, 0, comm, &req); in main()
127 MPI_Iallgatherv(sbuf, NUM_INTS, MPI_INT, rbuf, rcounts, rdispls, MPI_INT, comm, &req); in main()
168 MPI_Ireduce_scatter(sbuf, rbuf, rcounts, MPI_INT, MPI_SUM, comm, &req); in main()
171 MPI_Ireduce_scatter(MPI_IN_PLACE, rbuf, rcounts, MPI_INT, MPI_SUM, comm, &req); in main()
198 if (rcounts) in main()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/f77/coll/ |
| H A D | vw_inplacef.f | 15 integer rdispls(MAX_SIZE), rcounts(MAX_SIZE), rtypes(MAX_SIZE)
55 rcounts(i) = (i-1) + rank
57 do j=0,rcounts(i)-1
62 $ rbuf, rcounts, rdispls, MPI_INTEGER,
65 do j=0,rcounts(i)-1
82 rcounts(i) = (i-1) + rank
85 do j=0,rcounts(i)-1
91 $ rbuf, rcounts, rdispls, rtypes,
94 do j=0,rcounts(i)-1
|
| H A D | nonblocking_inpf.f | 15 integer rdispls(MAX_SIZE), rcounts(MAX_SIZE), rtypes(MAX_SIZE)
50 rcounts(i) = i-1 + rank
52 do j=0,rcounts(i)-1
57 . rbuf, rcounts, rdispls, MPI_INTEGER,
61 do j=0,rcounts(i)-1
77 rcounts(i) = i-1 + rank
80 do j=0,rcounts(i)-1
86 . rbuf, rcounts, rdispls, rtypes,
90 do j=0,rcounts(i)-1
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/f90/coll/ |
| H A D | vw_inplacef90.f90 | 15 integer rdispls(MAX_SIZE), rcounts(MAX_SIZE), rtypes(MAX_SIZE) variable
55 rcounts(i) = (i-1) + rank
57 do j=0,rcounts(i)-1
62 & rbuf, rcounts, rdispls, MPI_INTEGER, &
65 do j=0,rcounts(i)-1
82 rcounts(i) = (i-1) + rank
85 do j=0,rcounts(i)-1
91 & rbuf, rcounts, rdispls, rtypes, &
94 do j=0,rcounts(i)-1
|
| H A D | nonblocking_inpf90.f90 | 15 integer rdispls(MAX_SIZE), rcounts(MAX_SIZE), rtypes(MAX_SIZE) variable
50 rcounts(i) = i-1 + rank
52 do j=0,rcounts(i)-1
57 & rbuf, rcounts, rdispls, MPI_INTEGER, &
61 do j=0,rcounts(i)-1
77 rcounts(i) = i-1 + rank
80 do j=0,rcounts(i)-1
86 & rbuf, rcounts, rdispls, rtypes, &
90 do j=0,rcounts(i)-1
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/f08/coll/ |
| H A D | vw_inplacef08.f90 | 16 integer rdispls(MAX_SIZE), rcounts(MAX_SIZE) variable
58 rcounts(i) = (i-1) + rank
60 do j=0,rcounts(i)-1
65 & rbuf, rcounts, rdispls, MPI_INTEGER, &
68 do j=0,rcounts(i)-1
85 rcounts(i) = (i-1) + rank
88 do j=0,rcounts(i)-1
94 & rbuf, rcounts, rdispls, rtypes, &
97 do j=0,rcounts(i)-1
|
| H A D | nonblocking_inpf08.f90 | 16 integer rdispls(MAX_SIZE), rcounts(MAX_SIZE) variable
54 rcounts(i) = i-1 + rank
56 do j=0,rcounts(i)-1
61 & rbuf, rcounts, rdispls, MPI_INTEGER, &
65 do j=0,rcounts(i)-1
81 rcounts(i) = i-1 + rank
84 do j=0,rcounts(i)-1
90 & rbuf, rcounts, rdispls, rtypes, &
94 do j=0,rcounts(i)-1
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/errors/coll/ |
| H A D | noalias2.c | 29 int *rcounts = NULL; in main() local
52 rcounts = malloc(size * sizeof(int)); in main()
53 my_assert(rcounts); in main()
67 rcounts[i] = NUM_INTS; in main()
78 MPI_Gatherv(sbuf, NUM_INTS, MPI_INT, sbuf, rcounts, rdispls, MPI_INT, 0, comm)) in main()
93 MPI_Allgatherv(&sbuf[rank * rcounts[rank]], rcounts[rank], MPI_INT, sbuf, rcounts, rdispls, in main()
114 if (MPI_SUCCESS == MPI_Reduce_scatter(sbuf, sbuf, rcounts, MPI_INT, MPI_SUM, comm)) in main()
132 if (rcounts) in main()
133 free(rcounts); in main()
|
| H A D | noalias3.c | 34 int *rcounts = NULL; in main() local
58 rcounts = malloc(size * sizeof(int)); in main()
59 my_assert(rcounts); in main()
73 rcounts[i] = NUM_INTS; in main()
84 MPI_Igatherv(sbuf, NUM_INTS, MPI_INT, sbuf, rcounts, rdispls, MPI_INT, 0, comm, &req)) in main()
99 MPI_Iallgatherv(&sbuf[rank * rcounts[rank]], rcounts[rank], MPI_INT, sbuf, rcounts, rdispls, in main()
122 if (MPI_SUCCESS == MPI_Ireduce_scatter(sbuf, sbuf, rcounts, MPI_INT, MPI_SUM, comm, &req)) in main()
141 if (rcounts) in main()
142 free(rcounts); in main()
|
| /dports/net/mpich2/mpich2-1.5/test/mpi/coll/ |
| H A D | nonblocking.c | 37 int *rcounts = NULL; in main() local
63 rcounts = malloc(size*sizeof(int)); in main()
64 my_assert(rcounts); in main()
78 rcounts[i] = NUM_INTS; in main()
98 MPIX_Igatherv(sbuf, NUM_INTS, MPI_INT, rbuf, rcounts, rdispls, MPI_INT, 0, comm, &req); in main()
110 MPIX_Iallgatherv(sbuf, NUM_INTS, MPI_INT, rbuf, rcounts, rdispls, MPI_INT, comm, &req); in main()
116 MPIX_Ialltoallv(sbuf, scounts, sdispls, MPI_INT, rbuf, rcounts, rdispls, MPI_INT, comm, &req); in main()
119 MPIX_Ialltoallw(sbuf, scounts, sdispls, types, rbuf, rcounts, rdispls, types, comm, &req); in main()
128 MPIX_Ireduce_scatter(sbuf, rbuf, rcounts, MPI_INT, MPI_SUM, comm, &req); in main()
145 if (rcounts) free(rcounts); in main()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/monitoring/ |
| H A D | coll_monitoring.h | 58 void *rbuf, const int *rcounts,
80 void *rbuf, const int *rcounts,
89 void *rbuf, const int *rcounts,
132 const int *rcounts,
178 void *rbuf, const int *rcounts,
203 void *rbuf, const int *rcounts,
213 void *rbuf, const int *rcounts,
263 const int *rcounts,
327 void *rbuf, const int *rcounts,
336 void *rbuf, const int *rcounts,
[all …]
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/monitoring/ |
| H A D | coll_monitoring.h | 58 void *rbuf, const int *rcounts,
80 void *rbuf, const int *rcounts,
89 void *rbuf, const int *rcounts,
132 const int *rcounts,
178 void *rbuf, const int *rcounts,
203 void *rbuf, const int *rcounts,
213 void *rbuf, const int *rcounts,
263 const int *rcounts,
327 void *rbuf, const int *rcounts,
336 void *rbuf, const int *rcounts,
[all …]
|
| /dports/dns/dnsdist/dnsdist-1.6.1/ |
| H A D | dnsdist-rings.cc | 61 ret_t rcounts; in getTopBandwidth() local
62 rcounts.reserve(counts.size()); in getTopBandwidth()
64 rcounts.push_back({p.second, p.first}); in getTopBandwidth()
65 numentries = rcounts.size() < numentries ? rcounts.size() : numentries; in getTopBandwidth()
66 …partial_sort(rcounts.begin(), rcounts.begin()+numentries, rcounts.end(), [](const ret_t::value_typ… in getTopBandwidth()
73 for(const auto& rc : rcounts) { in getTopBandwidth()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/tuned/ |
| H A D | coll_tuned_allgatherv_decision.c | 124 void *rbuf, const int *rcounts, in ompi_coll_tuned_allgatherv_intra_do_this() argument
139 rbuf, rcounts, rdispls, rdtype, in ompi_coll_tuned_allgatherv_intra_do_this()
143 rbuf, rcounts, rdispls, rdtype, in ompi_coll_tuned_allgatherv_intra_do_this()
147 rbuf, rcounts, rdispls, rdtype, in ompi_coll_tuned_allgatherv_intra_do_this()
151 rbuf, rcounts, rdispls, rdtype, in ompi_coll_tuned_allgatherv_intra_do_this()
155 rbuf, rcounts, rdispls, rdtype, in ompi_coll_tuned_allgatherv_intra_do_this()
159 rbuf, rcounts, rdispls, rdtype, in ompi_coll_tuned_allgatherv_intra_do_this()
|