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

oshmem: spml ucx: on error print ucx error string

Просмотр исходного кода 
Signed-off-by: Alex Mikheev <alexm@mellanox.com>
Этот коммит содержится в:
Alex Mikheev 2017-01-29 10:28:24 +02:00
родитель 986ca000f8
Коммит 9da9e6260d
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 0F964A1EF0579522
1 изменённых файлов: 6 добавлений и 6 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

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

@ -289,7 +289,7 @@ int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs)
&ep_params, &ep_params,
&mca_spml_ucx.ucp_peers[i].ucp_conn); &mca_spml_ucx.ucp_peers[i].ucp_conn);
if (UCS_OK != err) { if (UCS_OK != err) {
SPML_ERROR("ucp_ep_create failed!!!\n"); SPML_ERROR("ucp_ep_create failed: %s\n", ucs_status_string(err));
goto error2; goto error2;
} }
OSHMEM_PROC_DATA(procs[i])->num_transports = 1; OSHMEM_PROC_DATA(procs[i])->num_transports = 1;
@ -372,7 +372,7 @@ void mca_spml_ucx_rmkey_unpack(sshmem_mkey_t *mkey, uint32_t segno, int pe, int
mkey->u.data, mkey->u.data,
&ucx_mkey->rkey); &ucx_mkey->rkey);
if (UCS_OK != err) { if (UCS_OK != err) {
SPML_ERROR("failed to unpack rkey"); SPML_ERROR("failed to unpack rkey: %s", ucs_status_string(err));
goto error_fatal; goto error_fatal;
} }
@ -408,8 +408,8 @@ void mca_spml_ucx_memuse_hook(void *addr, size_t length)
status = ucp_mem_advise(mca_spml_ucx.ucp_context, ucx_mkey->mem_h, &params); status = ucp_mem_advise(mca_spml_ucx.ucp_context, ucx_mkey->mem_h, &params);
if (UCS_OK != status) { if (UCS_OK != status) {
SPML_ERROR("ucp_mem_advise failed addr %p len %llu", SPML_ERROR("ucp_mem_advise failed addr %p len %llu : %s",
addr, (unsigned long long)length); addr, (unsigned long long)length, ucs_status_string(status));
} }
} }
@ -568,7 +568,7 @@ int mca_spml_ucx_fence(void)
err = ucp_worker_flush(mca_spml_ucx.ucp_worker); err = ucp_worker_flush(mca_spml_ucx.ucp_worker);
if (UCS_OK != err) { if (UCS_OK != err) {
SPML_ERROR("fence failed"); SPML_ERROR("fence failed: %s", ucs_status_string(err));
oshmem_shmem_abort(-1); oshmem_shmem_abort(-1);
return OSHMEM_ERROR; return OSHMEM_ERROR;
} }
@ -581,7 +581,7 @@ int mca_spml_ucx_quiet(void)
err = ucp_worker_flush(mca_spml_ucx.ucp_worker); err = ucp_worker_flush(mca_spml_ucx.ucp_worker);
if (UCS_OK != err) { if (UCS_OK != err) {
SPML_ERROR("fence failed"); SPML_ERROR("fence failed: %s", ucs_status_string(err));
oshmem_shmem_abort(-1); oshmem_shmem_abort(-1);
return OSHMEM_ERROR; return OSHMEM_ERROR;
} }