fill in request status
This commit was SVN r3711.
Этот коммит содержится в:
родитель
ac0f63c3d8
Коммит
52ff849ecb
@ -827,14 +827,11 @@ int mca_ptl_sm_send_continue(
|
|||||||
|
|
||||||
/* pack data in payload buffer */
|
/* pack data in payload buffer */
|
||||||
convertor = &sendreq->req_convertor;
|
convertor = &sendreq->req_convertor;
|
||||||
#if 0
|
|
||||||
ompi_convertor_copy(&sendreq->req_convertor, convertor);
|
|
||||||
ompi_convertor_init_for_send( convertor, 0,
|
ompi_convertor_init_for_send( convertor, 0,
|
||||||
sendreq->req_datatype,
|
sendreq->req_datatype,
|
||||||
sendreq->req_count,
|
sendreq->req_count,
|
||||||
sendreq->req_addr,
|
sendreq->req_addr,
|
||||||
offset, NULL);
|
offset, NULL);
|
||||||
#endif
|
|
||||||
sm_data_ptr=send_frag->buff;
|
sm_data_ptr=send_frag->buff;
|
||||||
|
|
||||||
/* set up the shared memory iovec */
|
/* set up the shared memory iovec */
|
||||||
|
@ -372,10 +372,14 @@ int mca_ptl_sm_component_progress(mca_ptl_tstamp_t tstamp)
|
|||||||
(mca_ptl_base_recv_frag_t *)header_ptr);
|
(mca_ptl_base_recv_frag_t *)header_ptr);
|
||||||
if( frag_matched ) {
|
if( frag_matched ) {
|
||||||
/* deliver data, and ack */
|
/* deliver data, and ack */
|
||||||
|
mca_ptl_base_match_header_t *hdr = &header_ptr->super.frag_base.frag_header.hdr_match;
|
||||||
|
mca_pml_base_recv_request_t *request = header_ptr->super.frag_request;
|
||||||
|
request->req_bytes_packed = hdr->hdr_msg_length;
|
||||||
|
request->req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_src;
|
||||||
|
request->req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_tag;
|
||||||
mca_ptl_sm_matched_same_base_addr(
|
mca_ptl_sm_matched_same_base_addr(
|
||||||
(mca_ptl_base_module_t *)&mca_ptl_sm,
|
(mca_ptl_base_module_t *)&mca_ptl_sm,
|
||||||
(mca_ptl_base_recv_frag_t *)header_ptr);
|
(mca_ptl_base_recv_frag_t *)header_ptr);
|
||||||
|
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
@ -482,9 +486,13 @@ int mca_ptl_sm_component_progress(mca_ptl_tstamp_t tstamp)
|
|||||||
(mca_ptl_base_recv_frag_t *)header_ptr);
|
(mca_ptl_base_recv_frag_t *)header_ptr);
|
||||||
if( frag_matched ) {
|
if( frag_matched ) {
|
||||||
/* deliver data, and ack */
|
/* deliver data, and ack */
|
||||||
|
mca_ptl_base_match_header_t *hdr = &header_ptr->super.frag_base.frag_header.hdr_match;
|
||||||
|
mca_pml_base_recv_request_t *request = header_ptr->super.frag_request;
|
||||||
|
request->req_bytes_packed = hdr->hdr_msg_length;
|
||||||
|
request->req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_src;
|
||||||
|
request->req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_tag;
|
||||||
mca_ptl_sm_matched((mca_ptl_base_module_t *)&mca_ptl_sm,
|
mca_ptl_sm_matched((mca_ptl_base_module_t *)&mca_ptl_sm,
|
||||||
(mca_ptl_base_recv_frag_t *)header_ptr);
|
(mca_ptl_base_recv_frag_t *)header_ptr);
|
||||||
|
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user