MCA/COMMON/UCX: code beautify - alignment
Signed-off-by: Sergey Oblomov <sergeyo@mellanox.com>
Этот коммит содержится в:
родитель
bef47b792c
Коммит
240670152e
@ -16,8 +16,8 @@
|
|||||||
#include "ompi/communicator/communicator.h"
|
#include "ompi/communicator/communicator.h"
|
||||||
#include "opal/mca/common/ucx/common_ucx.h"
|
#include "opal/mca/common/ucx/common_ucx.h"
|
||||||
|
|
||||||
#define OSC_UCX_ASSERT MCA_COMMON_UCX_ASSERT
|
#define OSC_UCX_ASSERT MCA_COMMON_UCX_ASSERT
|
||||||
#define OSC_UCX_ERROR MCA_COMMON_UCX_ERROR
|
#define OSC_UCX_ERROR MCA_COMMON_UCX_ERROR
|
||||||
#define OSC_UCX_VERBOSE MCA_COMMON_UCX_VERBOSE
|
#define OSC_UCX_VERBOSE MCA_COMMON_UCX_VERBOSE
|
||||||
|
|
||||||
#define OMPI_OSC_UCX_POST_PEER_MAX 32
|
#define OMPI_OSC_UCX_POST_PEER_MAX 32
|
||||||
|
@ -22,8 +22,8 @@
|
|||||||
#include <ucp/api/ucp.h>
|
#include <ucp/api/ucp.h>
|
||||||
#include "pml_ucx_freelist.h"
|
#include "pml_ucx_freelist.h"
|
||||||
|
|
||||||
#define PML_UCX_ASSERT MCA_COMMON_UCX_ASSERT
|
#define PML_UCX_ASSERT MCA_COMMON_UCX_ASSERT
|
||||||
#define PML_UCX_ERROR MCA_COMMON_UCX_ERROR
|
#define PML_UCX_ERROR MCA_COMMON_UCX_ERROR
|
||||||
#define PML_UCX_VERBOSE MCA_COMMON_UCX_VERBOSE
|
#define PML_UCX_VERBOSE MCA_COMMON_UCX_VERBOSE
|
||||||
|
|
||||||
|
|
||||||
|
@ -150,7 +150,7 @@ int mca_spml_ucx_del_procs(ompi_proc_t** procs, size_t nprocs)
|
|||||||
if (dreq != NULL) {
|
if (dreq != NULL) {
|
||||||
if (UCS_PTR_IS_ERR(dreq)) {
|
if (UCS_PTR_IS_ERR(dreq)) {
|
||||||
SPML_UCX_ERROR("ucp_disconnect_nb(%zu) failed: %s", n,
|
SPML_UCX_ERROR("ucp_disconnect_nb(%zu) failed: %s", n,
|
||||||
ucs_status_string(UCS_PTR_STATUS(dreq)));
|
ucs_status_string(UCS_PTR_STATUS(dreq)));
|
||||||
continue;
|
continue;
|
||||||
} else {
|
} else {
|
||||||
dreqs[num_reqs++] = dreq;
|
dreqs[num_reqs++] = dreq;
|
||||||
@ -292,7 +292,7 @@ int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs)
|
|||||||
&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_UCX_ERROR("ucp_ep_create(proc=%zu/%zu) failed: %s", n, nprocs,
|
SPML_UCX_ERROR("ucp_ep_create(proc=%zu/%zu) failed: %s", n, nprocs,
|
||||||
ucs_status_string(err));
|
ucs_status_string(err));
|
||||||
goto error2;
|
goto error2;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -335,7 +335,7 @@ spml_ucx_mkey_t * mca_spml_ucx_get_mkey_slow(int pe, void *va, void **rva)
|
|||||||
r_mkey = mca_memheap_base_get_cached_mkey(pe, va, 0, rva);
|
r_mkey = mca_memheap_base_get_cached_mkey(pe, va, 0, rva);
|
||||||
if (OPAL_UNLIKELY(!r_mkey)) {
|
if (OPAL_UNLIKELY(!r_mkey)) {
|
||||||
SPML_UCX_ERROR("pe=%d: %p is not address of symmetric variable",
|
SPML_UCX_ERROR("pe=%d: %p is not address of symmetric variable",
|
||||||
pe, va);
|
pe, va);
|
||||||
oshmem_shmem_abort(-1);
|
oshmem_shmem_abort(-1);
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
@ -427,7 +427,7 @@ void mca_spml_ucx_memuse_hook(void *addr, size_t length)
|
|||||||
status = ucp_mem_advise(mca_spml_ucx.ucp_context, ucx_mkey->mem_h, ¶ms);
|
status = ucp_mem_advise(mca_spml_ucx.ucp_context, ucx_mkey->mem_h, ¶ms);
|
||||||
if (UCS_OK != status) {
|
if (UCS_OK != status) {
|
||||||
SPML_UCX_ERROR("ucp_mem_advise failed addr %p len %llu : %s",
|
SPML_UCX_ERROR("ucp_mem_advise failed addr %p len %llu : %s",
|
||||||
addr, (unsigned long long)length, ucs_status_string(status));
|
addr, (unsigned long long)length, ucs_status_string(status));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -38,8 +38,8 @@
|
|||||||
|
|
||||||
BEGIN_C_DECLS
|
BEGIN_C_DECLS
|
||||||
|
|
||||||
#define SPML_UCX_ASSERT MCA_COMMON_UCX_ASSERT
|
#define SPML_UCX_ASSERT MCA_COMMON_UCX_ASSERT
|
||||||
#define SPML_UCX_ERROR MCA_COMMON_UCX_ERROR
|
#define SPML_UCX_ERROR MCA_COMMON_UCX_ERROR
|
||||||
#define SPML_UCX_VERBOSE MCA_COMMON_UCX_VERBOSE
|
#define SPML_UCX_VERBOSE MCA_COMMON_UCX_VERBOSE
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
Загрузка…
Ссылка в новой задаче
Block a user