From 011e46017f9a4953e970313f5323d7c6fd3f7950 Mon Sep 17 00:00:00 2001 From: George Bosilca Date: Sat, 26 Nov 2005 21:06:37 +0000 Subject: [PATCH] Match the latest changes on the TEG PML (increase ompi_request_completed when a request is finished). This commit was SVN r8259. --- ompi/mca/pml/uniq/pml_uniq_recvreq.c | 2 ++ ompi/mca/pml/uniq/pml_uniq_sendreq.c | 1 + 2 files changed, 3 insertions(+) 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); }