Skip to content

Commit ce7b311

Browse files
committed
coll: reduce_scatter_block: rename and MCA parameter description fix
- rename ompi_coll_base_reduce_scatter_block_basic to more self descriptive ompi_coll_base_reduce_scatter_block_basic_linear - fix the description of the coll_tuned_reduce_scatter_block_algorithm MCA param this fixes and documents previous 0e8b35b MPI_Reduce_scatter_block used to be implemented by the coll/basic module only. A new algo (recursive doubling) was recently introduced and can be used via the coll/tuned module, but we never intended to make it the default algo. In order to "restore" the previous default, the initial algo was moved from coll/basic to coll/base, and is now used by default by coll/tuned. Signed-off-by: Gilles Gouaillardet <[email protected]>
1 parent b39bbfb commit ce7b311

File tree

5 files changed

+14
-14
lines changed

5 files changed

+14
-14
lines changed

ompi/mca/coll/base/coll_base_functions.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ int ompi_coll_base_reduce_scatter_intra_basic_recursivehalving(REDUCESCATTER_ARG
250250
int ompi_coll_base_reduce_scatter_intra_ring(REDUCESCATTER_ARGS);
251251

252252
/* Reduce_scatter_block */
253-
int ompi_coll_base_reduce_scatter_block_basic(REDUCESCATTERBLOCK_ARGS);
253+
int ompi_coll_base_reduce_scatter_block_basic_linear(REDUCESCATTERBLOCK_ARGS);
254254
int ompi_coll_base_reduce_scatter_block_intra_recursivedoubling(REDUCESCATTERBLOCK_ARGS);
255255

256256
/* Scan */

ompi/mca/coll/base/coll_base_reduce_scatter_block.c

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@
4141
#include "coll_base_util.h"
4242

4343
/*
44-
* ompi_reduce_scatter_block_basic
44+
* ompi_reduce_scatter_block_basic_linear
4545
*
4646
* Function: - reduce then scatter
4747
* Accepts: - same as MPI_Reduce_scatter_block()
@@ -52,11 +52,11 @@
5252
* up at some point)
5353
*/
5454
int
55-
ompi_coll_base_reduce_scatter_block_basic(const void *sbuf, void *rbuf, int rcount,
56-
struct ompi_datatype_t *dtype,
57-
struct ompi_op_t *op,
58-
struct ompi_communicator_t *comm,
59-
mca_coll_base_module_t *module)
55+
ompi_coll_base_reduce_scatter_block_basic_linear(const void *sbuf, void *rbuf, int rcount,
56+
struct ompi_datatype_t *dtype,
57+
struct ompi_op_t *op,
58+
struct ompi_communicator_t *comm,
59+
mca_coll_base_module_t *module)
6060
{
6161
int rank, size, count, err = OMPI_SUCCESS;
6262
ptrdiff_t gap, span;

ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ mca_coll_basic_reduce_scatter_block_intra(const void *sbuf, void *rbuf, int rcou
5757
struct ompi_communicator_t *comm,
5858
mca_coll_base_module_t *module)
5959
{
60-
return ompi_coll_base_reduce_scatter_block_basic(sbuf, rbuf, rcount, dtype, op, comm, module);
60+
return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount, dtype, op, comm, module);
6161
}
6262

6363
/*

ompi/mca/coll/tuned/coll_tuned_decision_fixed.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -516,8 +516,8 @@ int ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed(const void *sbuf, void
516516
mca_coll_base_module_t *module)
517517
{
518518
OPAL_OUTPUT((ompi_coll_tuned_stream, "ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed"));
519-
return ompi_coll_base_reduce_scatter_block_basic(sbuf, rbuf, rcount,
520-
dtype, op, comm, module);
519+
return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount,
520+
dtype, op, comm, module);
521521
}
522522

523523
/*

ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ static int coll_tuned_reduce_scatter_block_tree_fanout;
3333
/* valid values for coll_tuned_reduce_scatter_blokc_forced_algorithm */
3434
static mca_base_var_enum_value_t reduce_scatter_block_algorithms[] = {
3535
{0, "ignore"},
36-
{1, "basic"},
36+
{1, "basic_linear"},
3737
{2, "recursive_doubling"},
3838
{0, NULL}
3939
};
@@ -74,7 +74,7 @@ int ompi_coll_tuned_reduce_scatter_block_intra_check_forced_init (coll_tuned_for
7474
mca_base_component_var_register(&mca_coll_tuned_component.super.collm_version,
7575
"reduce_scatter_block_algorithm",
7676
"Which reduce reduce_scatter_block algorithm is used. "
77-
"Can be locked down to choice of: 0 ignore, 1 recursive doubling",
77+
"Can be locked down to choice of: 0 ignore, 1 basic_linear, 2 recursive_doubling",
7878
MCA_BASE_VAR_TYPE_INT, new_enum, 0, MCA_BASE_VAR_FLAG_SETTABLE,
7979
OPAL_INFO_LVL_5,
8080
MCA_BASE_VAR_SCOPE_ALL,
@@ -121,8 +121,8 @@ int ompi_coll_tuned_reduce_scatter_block_intra_do_this(const void *sbuf, void *r
121121
switch (algorithm) {
122122
case (0): return ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed(sbuf, rbuf, rcount,
123123
dtype, op, comm, module);
124-
case (1): return ompi_coll_base_reduce_scatter_block_basic(sbuf, rbuf, rcount,
125-
dtype, op, comm, module);
124+
case (1): return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount,
125+
dtype, op, comm, module);
126126
case (2): return ompi_coll_base_reduce_scatter_block_intra_recursivedoubling(sbuf, rbuf, rcount,
127127
dtype, op, comm, module);
128128
} /* switch */

0 commit comments

Comments
 (0)