From 7fdcca0b00ca81ee6f48ba5a52112dc5e34e560f Mon Sep 17 00:00:00 2001 From: George Bosilca Date: Mon, 14 Feb 2005 08:30:47 +0000 Subject: [PATCH] Set the flag to zero if no match was realized. And progress the engine on the iprobe. This commit was SVN r4423. --- src/mca/pml/teg/src/pml_teg_iprobe.c | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/mca/pml/teg/src/pml_teg_iprobe.c b/src/mca/pml/teg/src/pml_teg_iprobe.c index 8dc01a7e13..727736941d 100644 --- a/src/mca/pml/teg/src/pml_teg_iprobe.c +++ b/src/mca/pml/teg/src/pml_teg_iprobe.c @@ -29,10 +29,16 @@ int mca_pml_teg_iprobe(int src, recvreq.req_base.req_type = MCA_PML_REQUEST_IPROBE; MCA_PML_BASE_RECV_REQUEST_INIT(&recvreq, NULL, 0, &ompi_mpi_char, src, tag, comm, true); + *matched = 0; if ((rc = mca_pml_teg_recv_request_start(&recvreq)) == OMPI_SUCCESS) { - if ((*matched = recvreq.req_base.req_ompi.req_complete) == true - && (NULL != status)) { - *status = recvreq.req_base.req_ompi.req_status; + if( recvreq.req_base.req_ompi.req_complete == true ) { + if( NULL != status ) { + *status = recvreq.req_base.req_ompi.req_status; + } + *matched = 1; + } else { + /* we are supposed to progress ... */ + ompi_progress(); } } MCA_PML_BASE_RECV_REQUEST_RETURN( &recvreq );