From 0332ab4d8bd5bc7d55d43cc17501b11d99992e37 Mon Sep 17 00:00:00 2001 From: yosefe Date: Wed, 25 Feb 2015 12:08:49 +0200 Subject: [PATCH] Initialize pml_yalla bsend request status. --- ompi/mca/pml/yalla/pml_yalla.c | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ompi/mca/pml/yalla/pml_yalla.c b/ompi/mca/pml/yalla/pml_yalla.c index b61abd1248..2cfa6ca8a3 100644 --- a/ompi/mca/pml/yalla/pml_yalla.c +++ b/ompi/mca/pml/yalla/pml_yalla.c @@ -438,7 +438,10 @@ int mca_pml_yalla_isend(void *buf, size_t count, ompi_datatype_t *datatype, if (mode == MCA_PML_BASE_SEND_BUFFERED) { rc = mca_pml_yalla_bsend(&sreq->mxm); + OPAL_THREAD_LOCK(&ompi_request_lock); + sreq->super.ompi.req_status.MPI_ERROR = rc; ompi_request_complete(&sreq->super.ompi, true); + OPAL_THREAD_UNLOCK(&ompi_request_lock); *request = &sreq->super.ompi; return rc; } @@ -665,7 +668,10 @@ int mca_pml_yalla_start(size_t count, ompi_request_t** requests) if (req->flags & MCA_PML_YALLA_REQUEST_FLAG_BSEND) { PML_YALLA_VERBOSE(8, "start bsend request %p", sreq); rc = mca_pml_yalla_bsend(&sreq->mxm); + OPAL_THREAD_LOCK(&ompi_request_lock); + sreq->super.ompi.req_status.MPI_ERROR = rc; ompi_request_complete(&sreq->super.ompi, true); + OPAL_THREAD_UNLOCK(&ompi_request_lock); if (OMPI_SUCCESS != rc) { return rc; }