From d9cb8165a5864b51203a9b57bcd09b5362d4abca Mon Sep 17 00:00:00 2001 From: Tim Woodall Date: Sat, 23 Oct 2004 16:21:49 +0000 Subject: [PATCH] progress pending requests This commit was SVN r3298. --- src/mca/pml/teg/src/pml_teg_sendreq.c | 23 +++++++++++------------ 1 file changed, 11 insertions(+), 12 deletions(-) diff --git a/src/mca/pml/teg/src/pml_teg_sendreq.c b/src/mca/pml/teg/src/pml_teg_sendreq.c index e239beef64..ae0a19721d 100644 --- a/src/mca/pml/teg/src/pml_teg_sendreq.c +++ b/src/mca/pml/teg/src/pml_teg_sendreq.c @@ -147,18 +147,6 @@ void mca_pml_teg_send_request_progress( MCA_PML_TEG_FREE((ompi_request_t**)&req); } OMPI_THREAD_UNLOCK(&ompi_request_lock); - - /* check for pending requests that need to be progressed */ - while(ompi_list_get_size(&mca_pml_teg.teg_send_pending) != 0) { - OMPI_THREAD_LOCK(&mca_pml_teg.teg_lock); - req = (mca_pml_base_send_request_t*)ompi_list_remove_first(&mca_pml_teg.teg_send_pending); - OMPI_THREAD_UNLOCK(&mca_pml_teg.teg_lock); - if(req == NULL) - break; - if(mca_pml_teg_send_request_schedule(req) != OMPI_SUCCESS) - break; - } - return; } OMPI_THREAD_UNLOCK(&ompi_request_lock); @@ -166,5 +154,16 @@ void mca_pml_teg_send_request_progress( if(first_frag == true) { mca_pml_teg_send_request_schedule(req); } + + /* check for pending requests that need to be progressed */ + while(ompi_list_get_size(&mca_pml_teg.teg_send_pending) != 0) { + OMPI_THREAD_LOCK(&mca_pml_teg.teg_lock); + req = (mca_pml_base_send_request_t*)ompi_list_remove_first(&mca_pml_teg.teg_send_pending); + OMPI_THREAD_UNLOCK(&mca_pml_teg.teg_lock); + if(req == NULL) + break; + if(mca_pml_teg_send_request_schedule(req) != OMPI_SUCCESS) + break; + } }