ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Do not generate the XFER_BEGIN and XFER_END events if the length of

Просмотр исходного кода 
the data is zero, for both the receives and the sends.

This commit was SVN r10670.
Этот коммит содержится в:
George Bosilca 2006-07-05 23:39:13 +00:00
родитель c793ad0a3d
Коммит 01a59d68da
4 изменённых файлов: 26 добавлений и 14 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

2
ompi/mca/pml/ob1/pml_ob1_recvreq.c
Просмотреть файл

@ -614,7 +614,7 @@ void mca_pml_ob1_recv_request_schedule(mca_pml_ob1_recv_request_t* recvreq)
/* /*
* Select the next btl out of the list w/ preregistered * Select the next btl out of the list w/ preregistered
* memory. * memory.
*/ */
bml_btl = recvreq->req_rdma[recvreq->req_rdma_idx].bml_btl; bml_btl = recvreq->req_rdma[recvreq->req_rdma_idx].bml_btl;
num_btl_avail = recvreq->req_rdma_cnt - recvreq->req_rdma_idx; num_btl_avail = recvreq->req_rdma_cnt - recvreq->req_rdma_idx;
reg = recvreq->req_rdma[recvreq->req_rdma_idx].btl_reg; reg = recvreq->req_rdma[recvreq->req_rdma_idx].btl_reg;

6
ompi/mca/pml/ob1/pml_ob1_recvreq.h
Просмотреть файл

@ -139,8 +139,10 @@ do {
\ \
assert( false == recvreq->req_recv.req_base.req_pml_complete ); \ assert( false == recvreq->req_recv.req_base.req_pml_complete ); \
\ \
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_END, \ if((recvreq)->req_recv.req_bytes_packed > 0) { \
&(recvreq->req_recv.req_base), PERUSE_RECV ); \ PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_END, \
&(recvreq->req_recv.req_base), PERUSE_RECV ); \
} \
\ \
for( r = 0; r < recvreq->req_rdma_cnt; r++ ) { \ for( r = 0; r < recvreq->req_rdma_cnt; r++ ) { \
mca_mpool_base_registration_t* btl_reg = recvreq->req_rdma[r].btl_reg; \ mca_mpool_base_registration_t* btl_reg = recvreq->req_rdma[r].btl_reg; \

24
ompi/mca/pml/ob1/pml_ob1_sendreq.c
Просмотреть файл

@ -98,8 +98,10 @@ void mca_pml_ob1_match_completion_cache(
mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)descriptor->des_cbdata; mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)descriptor->des_cbdata;
mca_bml_base_btl_t* bml_btl = (mca_bml_base_btl_t*) descriptor->des_context; mca_bml_base_btl_t* bml_btl = (mca_bml_base_btl_t*) descriptor->des_context;
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN, if( sendreq->req_send.req_bytes_packed > 0 ) {
&(sendreq->req_send.req_base), PERUSE_SEND ); PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN,
&(sendreq->req_send.req_base), PERUSE_SEND );
}
/* check completion status */ /* check completion status */
if(OMPI_SUCCESS != status) { if(OMPI_SUCCESS != status) {
@ -128,8 +130,10 @@ void mca_pml_ob1_match_completion_free(
mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)descriptor->des_cbdata; mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)descriptor->des_cbdata;
mca_bml_base_btl_t* bml_btl = (mca_bml_base_btl_t*) descriptor->des_context; mca_bml_base_btl_t* bml_btl = (mca_bml_base_btl_t*) descriptor->des_context;
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN, if( sendreq->req_send.req_bytes_packed > 0 ) {
&(sendreq->req_send.req_base), PERUSE_SEND ); PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN,
&(sendreq->req_send.req_base), PERUSE_SEND );
}
/* check completion status */ /* check completion status */
if(OMPI_SUCCESS != status) { if(OMPI_SUCCESS != status) {
@ -158,8 +162,10 @@ static void mca_pml_ob1_rndv_completion(
mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)descriptor->des_cbdata; mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)descriptor->des_cbdata;
mca_bml_base_btl_t* bml_btl = (mca_bml_base_btl_t*) descriptor->des_context; mca_bml_base_btl_t* bml_btl = (mca_bml_base_btl_t*) descriptor->des_context;
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN, if( sendreq->req_send.req_bytes_packed > 0 ) {
&(sendreq->req_send.req_base), PERUSE_SEND ); PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN,
&(sendreq->req_send.req_base), PERUSE_SEND );
}
/* check completion status */ /* check completion status */
if(OMPI_SUCCESS != status) { if(OMPI_SUCCESS != status) {
@ -635,8 +641,10 @@ int mca_pml_ob1_send_request_start_rdma(
* If we generate the PERUSE event here, at least we will know when do we * If we generate the PERUSE event here, at least we will know when do we
* sent the GET message ... * sent the GET message ...
*/ */
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN, if( sendreq->req_send.req_bytes_packed > 0 ) {
&(sendreq->req_send.req_base), PERUSE_SEND ); PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_BEGIN,
&(sendreq->req_send.req_base), PERUSE_SEND );
}
} else { } else {

8
ompi/mca/pml/ob1/pml_ob1_sendreq.h
Просмотреть файл

@ -269,9 +269,11 @@ do {
\ \
assert( false == sendreq->req_send.req_base.req_pml_complete ); \ assert( false == sendreq->req_send.req_base.req_pml_complete ); \
\ \
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_END, \ if( sendreq->req_send.req_bytes_packed > 0 ) { \
&(sendreq->req_send.req_base), \ PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_XFER_END, \
PERUSE_SEND ); \ &(sendreq->req_send.req_base), \
PERUSE_SEND ); \
} \
\ \
/* return mpool resources */ \ /* return mpool resources */ \
for( r = 0; r < sendreq->req_rdma_cnt; r++ ) { \ for( r = 0; r < sendreq->req_rdma_cnt; r++ ) { \