Merge pull request #5934 from hoopoepg/topic/suppressed-cov-warn-added-log-msg
COMMON/UCX: suppressed coverity warnings
Этот коммит содержится в:
Коммит
4c442f2601
@ -193,7 +193,10 @@ int ompi_osc_ucx_complete(struct ompi_win_t *win) {
|
|||||||
OSC_UCX_VERBOSE(1, "ucp_atomic_post failed: %d", status);
|
OSC_UCX_VERBOSE(1, "ucp_atomic_post failed: %d", status);
|
||||||
}
|
}
|
||||||
|
|
||||||
opal_common_ucx_ep_flush(ep, mca_osc_ucx_component.ucp_worker);
|
ret = opal_common_ucx_ep_flush(ep, mca_osc_ucx_component.ucp_worker);
|
||||||
|
if (OMPI_SUCCESS != ret) {
|
||||||
|
OSC_UCX_VERBOSE(1, "opal_common_ucx_ep_flush failed: %d", ret);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
OBJ_RELEASE(module->start_group);
|
OBJ_RELEASE(module->start_group);
|
||||||
|
@ -825,7 +825,10 @@ int ompi_osc_ucx_free(struct ompi_win_t *win) {
|
|||||||
ucp_worker_progress(mca_osc_ucx_component.ucp_worker);
|
ucp_worker_progress(mca_osc_ucx_component.ucp_worker);
|
||||||
}
|
}
|
||||||
|
|
||||||
opal_common_ucx_worker_flush(mca_osc_ucx_component.ucp_worker);
|
ret = opal_common_ucx_worker_flush(mca_osc_ucx_component.ucp_worker);
|
||||||
|
if (OMPI_SUCCESS != ret) {
|
||||||
|
OSC_UCX_VERBOSE(1, "opal_common_ucx_worker_flush failed: %d", ret);
|
||||||
|
}
|
||||||
|
|
||||||
ret = module->comm->c_coll->coll_barrier(module->comm,
|
ret = module->comm->c_coll->coll_barrier(module->comm,
|
||||||
module->comm->c_coll->coll_barrier_module);
|
module->comm->c_coll->coll_barrier_module);
|
||||||
|
@ -133,7 +133,7 @@ int mca_pml_ucx_datatype_attr_del_fn(ompi_datatype_t* datatype, int keyval,
|
|||||||
{
|
{
|
||||||
ucp_datatype_t ucp_datatype = (ucp_datatype_t)attr_val;
|
ucp_datatype_t ucp_datatype = (ucp_datatype_t)attr_val;
|
||||||
|
|
||||||
PML_UCX_ASSERT((void*)ucp_datatype == datatype->pml_data);
|
PML_UCX_ASSERT((uint64_t)ucp_datatype == datatype->pml_data);
|
||||||
|
|
||||||
ucp_dt_destroy(ucp_datatype);
|
ucp_dt_destroy(ucp_datatype);
|
||||||
datatype->pml_data = PML_UCX_DATATYPE_INVALID;
|
datatype->pml_data = PML_UCX_DATATYPE_INVALID;
|
||||||
|
@ -80,6 +80,8 @@ OPAL_DECLSPEC void opal_common_ucx_mca_var_register(const mca_base_component_t *
|
|||||||
|
|
||||||
OPAL_DECLSPEC void opal_common_ucx_mca_register(void)
|
OPAL_DECLSPEC void opal_common_ucx_mca_register(void)
|
||||||
{
|
{
|
||||||
|
int ret;
|
||||||
|
|
||||||
opal_common_ucx.registered++;
|
opal_common_ucx.registered++;
|
||||||
if (opal_common_ucx.registered > 1) {
|
if (opal_common_ucx.registered > 1) {
|
||||||
/* process once */
|
/* process once */
|
||||||
@ -89,7 +91,13 @@ OPAL_DECLSPEC void opal_common_ucx_mca_register(void)
|
|||||||
opal_common_ucx.output = opal_output_open(NULL);
|
opal_common_ucx.output = opal_output_open(NULL);
|
||||||
opal_output_set_verbosity(opal_common_ucx.output, opal_common_ucx.verbose);
|
opal_output_set_verbosity(opal_common_ucx.output, opal_common_ucx.verbose);
|
||||||
|
|
||||||
mca_base_framework_open(&opal_memory_base_framework, 0);
|
ret = mca_base_framework_open(&opal_memory_base_framework, 0);
|
||||||
|
if (OPAL_SUCCESS != ret) {
|
||||||
|
/* failed to initialize memory framework - just exit */
|
||||||
|
MCA_COMMON_UCX_VERBOSE(1, "failed to initialize memory base framework: %d, "
|
||||||
|
"memory hooks will not be used", ret);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
/* Set memory hooks */
|
/* Set memory hooks */
|
||||||
if (opal_common_ucx.opal_mem_hooks &&
|
if (opal_common_ucx.opal_mem_hooks &&
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user