diff --git a/ompi/mca/pml/uniq/pml_uniq_recvreq.c b/ompi/mca/pml/uniq/pml_uniq_recvreq.c index b486cf493e..90c562a8ef 100644 --- a/ompi/mca/pml/uniq/pml_uniq_recvreq.c +++ b/ompi/mca/pml/uniq/pml_uniq_recvreq.c @@ -75,6 +75,7 @@ static int mca_pml_uniq_recv_request_cancel(struct ompi_request_t* request, int * broadcast the condition on the request in order to allow the other threads * to complete their test/wait functions. */ + ompi_request_completed++; if(ompi_request_waiting) { opal_condition_broadcast(&ompi_request_cond); } @@ -119,6 +120,7 @@ void mca_pml_uniq_recv_request_progress( req->req_recv.req_base.req_ompi.req_status._count = req->req_bytes_delivered; req->req_recv.req_base.req_pml_complete = true; req->req_recv.req_base.req_ompi.req_complete = true; + ompi_request_completed++; if(ompi_request_waiting) { opal_condition_broadcast(&ompi_request_cond); } diff --git a/ompi/mca/pml/uniq/pml_uniq_sendreq.c b/ompi/mca/pml/uniq/pml_uniq_sendreq.c index 8a18163417..9ddfe32e6f 100644 --- a/ompi/mca/pml/uniq/pml_uniq_sendreq.c +++ b/ompi/mca/pml/uniq/pml_uniq_sendreq.c @@ -160,6 +160,7 @@ void mca_pml_uniq_send_request_progress( req->req_send.req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; req->req_send.req_base.req_ompi.req_status._count = req->req_bytes_sent; req->req_send.req_base.req_ompi.req_complete = true; + ompi_request_completed++; if(ompi_request_waiting) { opal_condition_broadcast(&ompi_request_cond); }