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

Merge pull request #7680 from janjust/oshmem-default-nb-params

Просмотр исходного кода 
oshmem spml ucx: set default nonblocking put/get progress thresholds
Этот коммит содержится в:
Austen Lauria 2020-06-30 13:56:15 -04:00 коммит произвёл GitHub
родитель 9b86f1442a 9d26bb0d48
Коммит 410596ee1c
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
1 изменённых файлов: 9 добавлений и 5 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

14
oshmem/mca/spml/ucx/spml_ucx_component.c
Просмотреть файл

@ -162,15 +162,15 @@ static int mca_spml_ucx_component_register(void)
&mca_spml_ucx.synchronized_quiet);
mca_spml_ucx_param_register_ulong("nb_progress_thresh_global", 0,
"Number of nb_put or nb_get operations before ucx progress is triggered. Disabled by default (0)",
"Number of nb_put or nb_get operations before ucx progress is triggered. Disabled by default (0). Setting this value will override nb_put/get_progress_thresh.",
&mca_spml_ucx.nb_progress_thresh_global);
mca_spml_ucx_param_register_ulong("nb_put_progress_thresh", mca_spml_ucx.nb_progress_thresh_global,
"Number of nb_put operations before ucx progress is triggered. Disabled by default (0), setting this value will override nb_progress_thresh_global",
mca_spml_ucx_param_register_ulong("nb_put_progress_thresh", 2048,
"Number of nb_put operations before ucx progress is triggered. Default (2048).",
&mca_spml_ucx.nb_put_progress_thresh);
mca_spml_ucx_param_register_ulong("nb_get_progress_thresh", mca_spml_ucx.nb_progress_thresh_global,
"Number of nb_get operations before ucx progress is triggered. Disabled by default (0), setting this value will override nb_progress_thresh_global ",
mca_spml_ucx_param_register_ulong("nb_get_progress_thresh", 4096,
"Number of nb_get operations before ucx progress is triggered. Default (4096).",
&mca_spml_ucx.nb_get_progress_thresh);
mca_spml_ucx_param_register_ulong("nb_ucp_worker_progress", 32,
@ -351,6 +351,10 @@ static int spml_ucx_init(void)
mca_spml_ucx.aux_ctx = NULL;
mca_spml_ucx.aux_refcnt = 0;
if (mca_spml_ucx.nb_progress_thresh_global) {
mca_spml_ucx.nb_put_progress_thresh = mca_spml_ucx.nb_progress_thresh_global;
mca_spml_ucx.nb_get_progress_thresh = mca_spml_ucx.nb_progress_thresh_global;
}
if (mca_spml_ucx.nb_put_progress_thresh) {
mca_spml_ucx.super.spml_put_nb = &mca_spml_ucx_put_nb_wprogress;
}