ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Merge pull request #5156 from ggouaillardet/topic/reduce_scatter_block

Просмотр исходного кода 
coll: reduce_scatter_block: rename and MCA parameter description fix
Этот коммит содержится в:
bosilca 2018-05-15 11:13:26 -04:00 коммит произвёл GitHub
родитель 9f353fe3d4 ce7b3113f6
Коммит d13b9a2e25
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
5 изменённых файлов: 14 добавлений и 14 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

2
ompi/mca/coll/base/coll_base_functions.h
Просмотреть файл

@ -250,7 +250,7 @@ int ompi_coll_base_reduce_scatter_intra_basic_recursivehalving(REDUCESCATTER_ARG
int ompi_coll_base_reduce_scatter_intra_ring(REDUCESCATTER_ARGS);
/* Reduce_scatter_block */
int ompi_coll_base_reduce_scatter_block_basic(REDUCESCATTERBLOCK_ARGS);
int ompi_coll_base_reduce_scatter_block_basic_linear(REDUCESCATTERBLOCK_ARGS);
int ompi_coll_base_reduce_scatter_block_intra_recursivedoubling(REDUCESCATTERBLOCK_ARGS);
int ompi_coll_base_reduce_scatter_block_intra_recursivehalving(REDUCESCATTERBLOCK_ARGS);

12
ompi/mca/coll/base/coll_base_reduce_scatter_block.c
Просмотреть файл

@ -42,7 +42,7 @@
/*
* ompi_reduce_scatter_block_basic
* ompi_reduce_scatter_block_basic_linear
*
* Function: - reduce then scatter
* Accepts: - same as MPI_Reduce_scatter_block()
@ -53,11 +53,11 @@
* up at some point)
*/
int
ompi_coll_base_reduce_scatter_block_basic(const void *sbuf, void *rbuf, int rcount,
struct ompi_datatype_t *dtype,
struct ompi_op_t *op,
struct ompi_communicator_t *comm,
mca_coll_base_module_t *module)
ompi_coll_base_reduce_scatter_block_basic_linear(const void *sbuf, void *rbuf, int rcount,
struct ompi_datatype_t *dtype,
struct ompi_op_t *op,
struct ompi_communicator_t *comm,
mca_coll_base_module_t *module)
{
int rank, size, count, err = OMPI_SUCCESS;
ptrdiff_t gap, span;

2
ompi/mca/coll/basic/coll_basic_reduce_scatter_block.c
Просмотреть файл

@ -57,7 +57,7 @@ mca_coll_basic_reduce_scatter_block_intra(const void *sbuf, void *rbuf, int rcou
struct ompi_communicator_t *comm,
mca_coll_base_module_t *module)
{
return ompi_coll_base_reduce_scatter_block_basic(sbuf, rbuf, rcount, dtype, op, comm, module);
return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount, dtype, op, comm, module);
}
/*

4
ompi/mca/coll/tuned/coll_tuned_decision_fixed.c
Просмотреть файл

@ -516,8 +516,8 @@ int ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed(const void *sbuf, void
mca_coll_base_module_t *module)
{
OPAL_OUTPUT((ompi_coll_tuned_stream, "ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed"));
return ompi_coll_base_reduce_scatter_block_basic(sbuf, rbuf, rcount,
dtype, op, comm, module);
return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount,
dtype, op, comm, module);
}
/*

8
ompi/mca/coll/tuned/coll_tuned_reduce_scatter_block_decision.c
Просмотреть файл

@ -33,7 +33,7 @@ static int coll_tuned_reduce_scatter_block_tree_fanout;
/* valid values for coll_tuned_reduce_scatter_blokc_forced_algorithm */
static mca_base_var_enum_value_t reduce_scatter_block_algorithms[] = {
{0, "ignore"},
{1, "basic"},
{1, "basic_linear"},
{2, "recursive_doubling"},
{3, "recursive_halving"},
{0, NULL}
@ -75,7 +75,7 @@ int ompi_coll_tuned_reduce_scatter_block_intra_check_forced_init (coll_tuned_for
mca_base_component_var_register(&mca_coll_tuned_component.super.collm_version,
"reduce_scatter_block_algorithm",
"Which reduce reduce_scatter_block algorithm is used. "
"Can be locked down to choice of: 0 ignore, 1 recursive doubling",
"Can be locked down to choice of: 0 ignore, 1 basic_linear, 2 recursive_doubling",
MCA_BASE_VAR_TYPE_INT, new_enum, 0, MCA_BASE_VAR_FLAG_SETTABLE,
OPAL_INFO_LVL_5,
MCA_BASE_VAR_SCOPE_ALL,
@ -122,8 +122,8 @@ int ompi_coll_tuned_reduce_scatter_block_intra_do_this(const void *sbuf, void *r
switch (algorithm) {
case (0): return ompi_coll_tuned_reduce_scatter_block_intra_dec_fixed(sbuf, rbuf, rcount,
dtype, op, comm, module);
case (1): return ompi_coll_base_reduce_scatter_block_basic(sbuf, rbuf, rcount,
dtype, op, comm, module);
case (1): return ompi_coll_base_reduce_scatter_block_basic_linear(sbuf, rbuf, rcount,
dtype, op, comm, module);
case (2): return ompi_coll_base_reduce_scatter_block_intra_recursivedoubling(sbuf, rbuf, rcount,
dtype, op, comm, module);
case (3): return ompi_coll_base_reduce_scatter_block_intra_recursivehalving(sbuf, rbuf, rcount,