Lines Matching refs:req_recv

57     recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV;  in mca_pml_ob1_irecv_init()
63 &((recvreq)->req_recv.req_base), in mca_pml_ob1_irecv_init()
70 recvreq->req_recv.req_base.req_pml_complete = true; in mca_pml_ob1_irecv_init()
89 recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; in mca_pml_ob1_irecv()
95 &((recvreq)->req_recv.req_base), in mca_pml_ob1_irecv()
126 recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; in mca_pml_ob1_recv()
131 &(recvreq->req_recv.req_base), in mca_pml_ob1_recv()
135 ompi_request_wait_completion(&recvreq->req_recv.req_base.req_ompi); in mca_pml_ob1_recv()
137 if( true == recvreq->req_recv.req_base.req_pml_complete ) { in mca_pml_ob1_recv()
141 recvreq->req_recv.req_base.req_addr, in mca_pml_ob1_recv()
142 recvreq->req_recv.req_base.req_count, in mca_pml_ob1_recv()
143 recvreq->req_recv.req_base.req_datatype); in mca_pml_ob1_recv()
148 *status = recvreq->req_recv.req_base.req_ompi.req_status; in mca_pml_ob1_recv()
151 rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; in mca_pml_ob1_recv()
153 if (recvreq->req_recv.req_base.req_pml_complete) { in mca_pml_ob1_recv()
158 recvreq->req_recv.req_base.req_addr, in mca_pml_ob1_recv()
159 recvreq->req_recv.req_base.req_count, in mca_pml_ob1_recv()
160 recvreq->req_recv.req_base.req_datatype); in mca_pml_ob1_recv()
193 frag = (mca_pml_ob1_recv_frag_t*) recvreq->req_recv.req_base.req_addr; in mca_pml_ob1_imrecv()
194 src = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; in mca_pml_ob1_imrecv()
195 tag = recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG; in mca_pml_ob1_imrecv()
197 seq = recvreq->req_recv.req_base.req_sequence; in mca_pml_ob1_imrecv()
208 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_imrecv()
209 recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; in mca_pml_ob1_imrecv()
217 &((recvreq)->req_recv.req_base), in mca_pml_ob1_imrecv()
229 MCA_PML_BASE_RECV_START(&recvreq->req_recv); in mca_pml_ob1_imrecv()
232 recvreq->req_recv.req_base.req_sequence = seq; in mca_pml_ob1_imrecv()
234 proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); in mca_pml_ob1_imrecv()
235 recvreq->req_recv.req_base.req_proc = proc->ompi_proc; in mca_pml_ob1_imrecv()
287 frag = (mca_pml_ob1_recv_frag_t*) recvreq->req_recv.req_base.req_addr; in mca_pml_ob1_mrecv()
288 src = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; in mca_pml_ob1_mrecv()
289 tag = recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG; in mca_pml_ob1_mrecv()
290 seq = recvreq->req_recv.req_base.req_sequence; in mca_pml_ob1_mrecv()
301 MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); in mca_pml_ob1_mrecv()
302 recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; in mca_pml_ob1_mrecv()
310 &((recvreq)->req_recv.req_base), in mca_pml_ob1_mrecv()
321 MCA_PML_BASE_RECV_START(&recvreq->req_recv); in mca_pml_ob1_mrecv()
324 recvreq->req_recv.req_base.req_sequence = seq; in mca_pml_ob1_mrecv()
326 proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); in mca_pml_ob1_mrecv()
327 recvreq->req_recv.req_base.req_proc = proc->ompi_proc; in mca_pml_ob1_mrecv()
353 ompi_request_wait_completion(&(recvreq->req_recv.req_base.req_ompi)); in mca_pml_ob1_mrecv()
358 *status = recvreq->req_recv.req_base.req_ompi.req_status; in mca_pml_ob1_mrecv()
360 rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; in mca_pml_ob1_mrecv()