From baad0af7739212d4c99aab2f0081b78ea5333f5c Mon Sep 17 00:00:00 2001 From: Tim Woodall Date: Fri, 18 Jun 2004 21:40:06 +0000 Subject: [PATCH] adding comments :) This commit was SVN r1418. --- src/mca/pml/teg/src/pml_teg_isend.c | 2 +- src/mca/pml/teg/src/pml_teg_recvreq.c | 5 +++++ src/mca/pml/teg/src/pml_teg_sendreq.c | 10 ++++++++++ 3 files changed, 16 insertions(+), 1 deletion(-) diff --git a/src/mca/pml/teg/src/pml_teg_isend.c b/src/mca/pml/teg/src/pml_teg_isend.c index 859c170dea..1087c1a1fd 100644 --- a/src/mca/pml/teg/src/pml_teg_isend.c +++ b/src/mca/pml/teg/src/pml_teg_isend.c @@ -107,7 +107,7 @@ int mca_pml_teg_send( sendmode, false ); - + if((rc = mca_pml_teg_send_request_start(sendreq)) != OMPI_SUCCESS) { MCA_PML_TEG_FREE((ompi_request_t**)&sendreq); return rc; diff --git a/src/mca/pml/teg/src/pml_teg_recvreq.c b/src/mca/pml/teg/src/pml_teg_recvreq.c index c845e676ae..9173819896 100644 --- a/src/mca/pml/teg/src/pml_teg_recvreq.c +++ b/src/mca/pml/teg/src/pml_teg_recvreq.c @@ -2,6 +2,11 @@ #include "pml_teg_recvreq.h" +/* + * Update the recv request status to reflect the number of bytes + * received and actually delivered to the application. + */ + void mca_pml_teg_recv_request_progress( struct mca_ptl_t* ptl, mca_ptl_base_recv_request_t* req, diff --git a/src/mca/pml/teg/src/pml_teg_sendreq.c b/src/mca/pml/teg/src/pml_teg_sendreq.c index b51bcb6c28..20fa729a59 100644 --- a/src/mca/pml/teg/src/pml_teg_sendreq.c +++ b/src/mca/pml/teg/src/pml_teg_sendreq.c @@ -70,6 +70,16 @@ void mca_pml_teg_send_request_schedule(mca_ptl_base_send_request_t* req) } +/** + * Update the status of the send request to reflect the number of bytes + * "actually" sent (and acknowledged). This should be called by the + * lower layer PTL after the fragment is actually delivered and has been + * acknowledged (if required). Note that this routine should NOT be called + * directly by the PTL, a function pointer is setup on the PTL at init to + * enable upcalls into the PML w/out directly linking to a specific PML + * implementation. + */ + void mca_pml_teg_send_request_progress( struct mca_ptl_t* ptl, mca_ptl_base_send_request_t* req,