COLL/TUNED: Minor var names/comments fixes
Signed-off-by: Mikhail Brinskii <mikhailb@mellanox.com>
Этот коммит содержится в:
родитель
404c480068
Коммит
65618f8db8
@ -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_intermediate_msg;
|
||||||
extern int ompi_coll_tuned_alltoall_large_msg;
|
extern int ompi_coll_tuned_alltoall_large_msg;
|
||||||
extern int ompi_coll_tuned_alltoall_min_procs;
|
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 */
|
/* forced algorithm choices */
|
||||||
/* this structure is for storing the indexes to the forced algorithm mca params... */
|
/* 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,
|
(void) mca_base_component_var_register(&mca_coll_tuned_component.super.collm_version,
|
||||||
"alltoall_large_msg",
|
"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,
|
MCA_BASE_VAR_TYPE_INT, NULL, 0, 0,
|
||||||
OPAL_INFO_LVL_6,
|
OPAL_INFO_LVL_6,
|
||||||
MCA_BASE_VAR_SCOPE_READONLY,
|
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,
|
(void) mca_base_component_var_register(&mca_coll_tuned_component.super.collm_version,
|
||||||
"alltoall_min_procs",
|
"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,
|
MCA_BASE_VAR_TYPE_INT, NULL, 0, 0,
|
||||||
OPAL_INFO_LVL_6,
|
OPAL_INFO_LVL_6,
|
||||||
MCA_BASE_VAR_SCOPE_READONLY,
|
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,
|
MCA_BASE_VAR_TYPE_INT, NULL, 0, MCA_BASE_VAR_FLAG_SETTABLE,
|
||||||
OPAL_INFO_LVL_5,
|
OPAL_INFO_LVL_5,
|
||||||
MCA_BASE_VAR_SCOPE_ALL,
|
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) {
|
if (mca_param_indices->max_requests_param_index < 0) {
|
||||||
return mca_param_indices->max_requests_param_index;
|
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 ) ) {
|
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");
|
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);
|
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_small_msg = 200;
|
||||||
int ompi_coll_tuned_alltoall_intermediate_msg = 3000;
|
int ompi_coll_tuned_alltoall_intermediate_msg = 3000;
|
||||||
|
|
||||||
/* Set it to intermediate value by default, so it does not affect default
|
/* Set it to the same value as intermediate msg by default, so it does not affect
|
||||||
* algorithm selection. Changing this value will force using linear with sync
|
* default algorithm selection. Changing this value will force using linear with
|
||||||
* algorithm on certain message sizes. */
|
* sync algorithm on certain message sizes. */
|
||||||
int ompi_coll_tuned_alltoall_large_msg = 3000;
|
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_min_procs = 0; /* disable by default */
|
||||||
int ompi_coll_tuned_alltoall_max_reqs = 0; /* no limit for alltoall by default */
|
int ompi_coll_tuned_alltoall_max_requests = 0; /* no limit for alltoall by default */
|
||||||
|
|
||||||
/* forced alogrithm variables */
|
/* forced alogrithm variables */
|
||||||
/* indices for the MCA parameters */
|
/* 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,
|
return ompi_coll_base_alltoall_intra_linear_sync(sbuf, scount, sdtype,
|
||||||
rbuf, rcount, rdtype,
|
rbuf, rcount, rdtype,
|
||||||
comm, module,
|
comm, module,
|
||||||
ompi_coll_tuned_alltoall_max_reqs);
|
ompi_coll_tuned_alltoall_max_requests);
|
||||||
}
|
}
|
||||||
|
|
||||||
return ompi_coll_base_alltoall_intra_pairwise(sbuf, scount, sdtype,
|
return ompi_coll_base_alltoall_intra_pairwise(sbuf, scount, sdtype,
|
||||||
|
Загрузка…
Ссылка в новой задаче
Block a user