diff --git a/ompi/mca/pml/ucx/pml_ucx.h b/ompi/mca/pml/ucx/pml_ucx.h index 8a696e8111..d684ecb462 100644 --- a/ompi/mca/pml/ucx/pml_ucx.h +++ b/ompi/mca/pml/ucx/pml_ucx.h @@ -69,13 +69,15 @@ extern mca_pml_ucx_module_t ompi_pml_ucx; _PML_UCX_QUOTE(_x) #define PML_UCX_ERROR(...) \ - opal_output_verbose(0, ompi_pml_ucx.output, "Error: " __FILE__ ":" \ - PML_UCX_QUOTE(__LINE__) __VA_ARGS__) + opal_output_verbose(0, ompi_pml_ucx.output, \ + __FILE__ ":" PML_UCX_QUOTE(__LINE__) \ + " Error: " __VA_ARGS__) #define PML_UCX_VERBOSE(_level, ... ) \ if (((_level) <= PML_UCX_MAX_VERBOSE) && ((_level) <= ompi_pml_ucx.verbose)) { \ - opal_output_verbose(_level, ompi_pml_ucx.output, __FILE__ ":" \ - PML_UCX_QUOTE(__LINE__) __VA_ARGS__); \ + opal_output_verbose(_level, ompi_pml_ucx.output, \ + __FILE__ ":" PML_UCX_QUOTE(__LINE__) " " \ + __VA_ARGS__); \ } int mca_pml_ucx_open(void); diff --git a/ompi/mca/pml/ucx/pml_ucx_request.c b/ompi/mca/pml/ucx/pml_ucx_request.c index e1ad331c90..2fca2a6144 100644 --- a/ompi/mca/pml/ucx/pml_ucx_request.c +++ b/ompi/mca/pml/ucx/pml_ucx_request.c @@ -108,11 +108,10 @@ static void mca_pml_ucx_request_init_common(ompi_request_t* ompi_req, ompi_request_free_fn_t req_free, ompi_request_cancel_fn_t req_cancel) { + OBJ_CONSTRUCT(ompi_req, ompi_request_t); OMPI_REQUEST_INIT(ompi_req, req_persistent); ompi_req->req_type = OMPI_REQUEST_PML; ompi_req->req_state = state; - ompi_req->req_complete_cb = NULL; - ompi_req->req_complete_cb_data = NULL; ompi_req->req_free = req_free; ompi_req->req_cancel = req_cancel; } @@ -128,6 +127,7 @@ void mca_pml_ucx_request_cleanup(void *request) { ompi_request_t* ompi_req = request; OMPI_REQUEST_FINI(ompi_req); + OBJ_DESTRUCT(ompi_req); } static int mca_pml_ucx_persistent_request_free(ompi_request_t **rptr)