pml_ucx: fix debug macros, and initialize mpi request properly.
Этот коммит содержится в:
родитель
d667e53b30
Коммит
41b6230be3
@ -69,13 +69,15 @@ extern mca_pml_ucx_module_t ompi_pml_ucx;
|
|||||||
_PML_UCX_QUOTE(_x)
|
_PML_UCX_QUOTE(_x)
|
||||||
|
|
||||||
#define PML_UCX_ERROR(...) \
|
#define PML_UCX_ERROR(...) \
|
||||||
opal_output_verbose(0, ompi_pml_ucx.output, "Error: " __FILE__ ":" \
|
opal_output_verbose(0, ompi_pml_ucx.output, \
|
||||||
PML_UCX_QUOTE(__LINE__) __VA_ARGS__)
|
__FILE__ ":" PML_UCX_QUOTE(__LINE__) \
|
||||||
|
" Error: " __VA_ARGS__)
|
||||||
|
|
||||||
#define PML_UCX_VERBOSE(_level, ... ) \
|
#define PML_UCX_VERBOSE(_level, ... ) \
|
||||||
if (((_level) <= PML_UCX_MAX_VERBOSE) && ((_level) <= ompi_pml_ucx.verbose)) { \
|
if (((_level) <= PML_UCX_MAX_VERBOSE) && ((_level) <= ompi_pml_ucx.verbose)) { \
|
||||||
opal_output_verbose(_level, ompi_pml_ucx.output, __FILE__ ":" \
|
opal_output_verbose(_level, ompi_pml_ucx.output, \
|
||||||
PML_UCX_QUOTE(__LINE__) __VA_ARGS__); \
|
__FILE__ ":" PML_UCX_QUOTE(__LINE__) " " \
|
||||||
|
__VA_ARGS__); \
|
||||||
}
|
}
|
||||||
|
|
||||||
int mca_pml_ucx_open(void);
|
int mca_pml_ucx_open(void);
|
||||||
|
@ -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_free_fn_t req_free,
|
||||||
ompi_request_cancel_fn_t req_cancel)
|
ompi_request_cancel_fn_t req_cancel)
|
||||||
{
|
{
|
||||||
|
OBJ_CONSTRUCT(ompi_req, ompi_request_t);
|
||||||
OMPI_REQUEST_INIT(ompi_req, req_persistent);
|
OMPI_REQUEST_INIT(ompi_req, req_persistent);
|
||||||
ompi_req->req_type = OMPI_REQUEST_PML;
|
ompi_req->req_type = OMPI_REQUEST_PML;
|
||||||
ompi_req->req_state = state;
|
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_free = req_free;
|
||||||
ompi_req->req_cancel = req_cancel;
|
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_t* ompi_req = request;
|
||||||
OMPI_REQUEST_FINI(ompi_req);
|
OMPI_REQUEST_FINI(ompi_req);
|
||||||
|
OBJ_DESTRUCT(ompi_req);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int mca_pml_ucx_persistent_request_free(ompi_request_t **rptr)
|
static int mca_pml_ucx_persistent_request_free(ompi_request_t **rptr)
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user