1
1

Merge pull request #1936 from hjelmn/osc_pt2pt_fix

osc/pt2pt: do not set rdma_frag after start
Этот коммит содержится в:
Nathan Hjelm 2016-08-08 14:17:40 -06:00 коммит произвёл GitHub
родитель e4d7ea75a9 11c853d05e
Коммит 2788083b98

Просмотреть файл

@ -1718,30 +1718,31 @@ int ompi_osc_pt2pt_irecv_w_cb (void *ptr, int count, ompi_datatype_t *datatype,
ompi_communicator_t *comm, ompi_request_t **request_out, ompi_communicator_t *comm, ompi_request_t **request_out,
ompi_request_complete_fn_t cb, void *ctx) ompi_request_complete_fn_t cb, void *ctx)
{ {
ompi_request_t *request; ompi_request_t *dummy;
int ret; int ret;
if (NULL == request_out) {
request_out = &dummy;
}
OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output, OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output,
"osc pt2pt: ompi_osc_pt2pt_irecv_w_cb receiving %d bytes from %d with tag %d", "osc pt2pt: ompi_osc_pt2pt_irecv_w_cb receiving %d bytes from %d with tag %d",
count, target, tag)); count, target, tag));
ret = MCA_PML_CALL(irecv_init(ptr, count, datatype, target, tag, comm, &request)); ret = MCA_PML_CALL(irecv_init(ptr, count, datatype, target, tag, comm, request_out));
if (OMPI_SUCCESS != ret) { if (OMPI_SUCCESS != ret) {
OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output, OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output,
"error posting receive. ret = %d", ret)); "error posting receive. ret = %d", ret));
return ret; return ret;
} }
request->req_complete_cb = cb; (*request_out)->req_complete_cb = cb;
request->req_complete_cb_data = ctx; (*request_out)->req_complete_cb_data = ctx;
ret = MCA_PML_CALL(start(1, &request)); ret = MCA_PML_CALL(start(1, request_out));
if (request_out && MPI_REQUEST_NULL != request) {
*request_out = request;
}
OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output, OPAL_OUTPUT_VERBOSE((50, ompi_osc_base_framework.framework_output,
"osc pt2pt: pml start returned %d. state: %d", ret, request->req_state)); "osc pt2pt: pml start returned %d", ret));
return ret; return ret;
} }