COLL/TUNED: Minor var names/comments fixes
Signed-off-by: Mikhail Brinskii <mikhailb@mellanox.com>
(cherry picked from commit 65618f8db8
)
Этот коммит содержится в:
родитель
3d5b7b4a1b
Коммит
b9998a14dc
@ -40,7 +40,7 @@ extern int ompi_coll_tuned_alltoall_small_msg;
|
||||
extern int ompi_coll_tuned_alltoall_intermediate_msg;
|
||||
extern int ompi_coll_tuned_alltoall_large_msg;
|
||||
extern int ompi_coll_tuned_alltoall_min_procs;
|
||||
extern int ompi_coll_tuned_alltoall_max_reqs;
|
||||
extern int ompi_coll_tuned_alltoall_max_requests;
|
||||
|
||||
/* forced algorithm choices */
|
||||
/* this structure is for storing the indexes to the forced algorithm mca params... */
|
||||
|
@ -116,7 +116,7 @@ int ompi_coll_tuned_alltoall_intra_check_forced_init (coll_tuned_force_algorithm
|
||||
|
||||
(void) mca_base_component_var_register(&mca_coll_tuned_component.super.collm_version,
|
||||
"alltoall_large_msg",
|
||||
"threshold (if supported) to decide if large MSGs alltoall algorithm will be used",
|
||||
"use pairwise exchange algorithm for messages larger than this value",
|
||||
MCA_BASE_VAR_TYPE_INT, NULL, 0, 0,
|
||||
OPAL_INFO_LVL_6,
|
||||
MCA_BASE_VAR_SCOPE_READONLY,
|
||||
@ -124,7 +124,7 @@ int ompi_coll_tuned_alltoall_intra_check_forced_init (coll_tuned_force_algorithm
|
||||
|
||||
(void) mca_base_component_var_register(&mca_coll_tuned_component.super.collm_version,
|
||||
"alltoall_min_procs",
|
||||
"threshold (if supported) to decide if many processes alltoall algorithm will be used",
|
||||
"use pairwise exchange algorithm for communicators larger than this value",
|
||||
MCA_BASE_VAR_TYPE_INT, NULL, 0, 0,
|
||||
OPAL_INFO_LVL_6,
|
||||
MCA_BASE_VAR_SCOPE_READONLY,
|
||||
@ -137,16 +137,16 @@ int ompi_coll_tuned_alltoall_intra_check_forced_init (coll_tuned_force_algorithm
|
||||
MCA_BASE_VAR_TYPE_INT, NULL, 0, MCA_BASE_VAR_FLAG_SETTABLE,
|
||||
OPAL_INFO_LVL_5,
|
||||
MCA_BASE_VAR_SCOPE_ALL,
|
||||
&ompi_coll_tuned_alltoall_max_reqs);
|
||||
&ompi_coll_tuned_alltoall_max_requests);
|
||||
if (mca_param_indices->max_requests_param_index < 0) {
|
||||
return mca_param_indices->max_requests_param_index;
|
||||
}
|
||||
|
||||
if (ompi_coll_tuned_alltoall_max_reqs < 0) {
|
||||
if (ompi_coll_tuned_alltoall_max_requests < 0) {
|
||||
if( 0 == ompi_comm_rank( MPI_COMM_WORLD ) ) {
|
||||
opal_output( 0, "Maximum outstanding requests must be positive number greater than 1. Switching to 0 \n");
|
||||
}
|
||||
ompi_coll_tuned_alltoall_max_reqs = 0;
|
||||
ompi_coll_tuned_alltoall_max_requests = 0;
|
||||
}
|
||||
|
||||
return (MPI_SUCCESS);
|
||||
|
@ -57,12 +57,12 @@ int ompi_coll_tuned_init_max_requests = 128;
|
||||
int ompi_coll_tuned_alltoall_small_msg = 200;
|
||||
int ompi_coll_tuned_alltoall_intermediate_msg = 3000;
|
||||
|
||||
/* Set it to intermediate value by default, so it does not affect default
|
||||
* algorithm selection. Changing this value will force using linear with sync
|
||||
* algorithm on certain message sizes. */
|
||||
/* Set it to the same value as intermediate msg by default, so it does not affect
|
||||
* default algorithm selection. Changing this value will force using linear with
|
||||
* sync algorithm on certain message sizes. */
|
||||
int ompi_coll_tuned_alltoall_large_msg = 3000;
|
||||
int ompi_coll_tuned_alltoall_min_procs = 0; /* not used by default */
|
||||
int ompi_coll_tuned_alltoall_max_reqs = 0; /* no limit for alltoall by default */
|
||||
int ompi_coll_tuned_alltoall_min_procs = 0; /* disable by default */
|
||||
int ompi_coll_tuned_alltoall_max_requests = 0; /* no limit for alltoall by default */
|
||||
|
||||
/* forced alogrithm variables */
|
||||
/* indices for the MCA parameters */
|
||||
|
@ -141,7 +141,7 @@ int ompi_coll_tuned_alltoall_intra_dec_fixed(const void *sbuf, int scount,
|
||||
return ompi_coll_base_alltoall_intra_linear_sync(sbuf, scount, sdtype,
|
||||
rbuf, rcount, rdtype,
|
||||
comm, module,
|
||||
ompi_coll_tuned_alltoall_max_reqs);
|
||||
ompi_coll_tuned_alltoall_max_requests);
|
||||
}
|
||||
|
||||
return ompi_coll_base_alltoall_intra_pairwise(sbuf, scount, sdtype,
|
||||
|
Загрузка…
Ссылка в новой задаче
Block a user