req_recv 551 ompi/mca/pml/ob1/pml_ob1.c mca_pml_base_request_t *req = &(((mca_pml_ob1_recv_request_t*)item)->req_recv.req_base); req_recv 160 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_endpoint_t* bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_proc); req_recv 170 ompi/mca/pml/ob1/pml_ob1_cuda.c if ((recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) && req_recv 172 ompi/mca/pml/ob1/pml_ob1_cuda.c recvreq->req_recv.req_base.req_convertor.flags &= ~CONVERTOR_CUDA; req_recv 173 ompi/mca/pml/ob1/pml_ob1_cuda.c if(opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == true) { req_recv 174 ompi/mca/pml/ob1/pml_ob1_cuda.c recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; req_recv 177 ompi/mca/pml/ob1/pml_ob1_cuda.c recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; req_recv 36 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; req_recv 37 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_IPROBE; req_recv 42 ompi/mca/pml/ob1/pml_ob1_iprobe.c if( REQUEST_COMPLETE( &(recvreq.req_recv.req_base.req_ompi)) ) { req_recv 44 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq.req_recv.req_base.req_ompi.req_status; req_recv 46 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq.req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_recv 52 ompi/mca/pml/ob1/pml_ob1_iprobe.c MCA_PML_BASE_RECV_REQUEST_FINI( &recvreq.req_recv ); req_recv 66 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; req_recv 67 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_PROBE; req_recv 72 ompi/mca/pml/ob1/pml_ob1_iprobe.c ompi_request_wait_completion(&recvreq.req_recv.req_base.req_ompi); req_recv 73 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq.req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_recv 75 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq.req_recv.req_base.req_ompi.req_status; req_recv 78 ompi/mca/pml/ob1/pml_ob1_iprobe.c MCA_PML_BASE_RECV_REQUEST_FINI( &recvreq.req_recv ); req_recv 102 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_IMPROBE; req_recv 109 ompi/mca/pml/ob1/pml_ob1_iprobe.c if( REQUEST_COMPLETE( &(recvreq->req_recv.req_base.req_ompi)) ) { req_recv 111 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_recv 117 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->peer = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_recv 118 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->count = recvreq->req_recv.req_base.req_ompi.req_status._ucount; req_recv 120 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_recv 156 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_MPROBE; req_recv 163 ompi/mca/pml/ob1/pml_ob1_iprobe.c ompi_request_wait_completion(&recvreq->req_recv.req_base.req_ompi); req_recv 164 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_recv 167 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_recv 172 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->peer = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_recv 173 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->count = recvreq->req_recv.req_base.req_ompi.req_status._ucount; req_recv 57 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_recv 63 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_recv 70 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_pml_complete = true; req_recv 89 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_recv 95 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_recv 126 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_recv 131 ompi/mca/pml/ob1/pml_ob1_irecv.c &(recvreq->req_recv.req_base), req_recv 135 ompi/mca/pml/ob1/pml_ob1_irecv.c ompi_request_wait_completion(&recvreq->req_recv.req_base.req_ompi); req_recv 137 ompi/mca/pml/ob1/pml_ob1_irecv.c if( true == recvreq->req_recv.req_base.req_pml_complete ) { req_recv 141 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_addr, req_recv 142 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_count, req_recv 143 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_datatype); req_recv 148 ompi/mca/pml/ob1/pml_ob1_irecv.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_recv 151 ompi/mca/pml/ob1/pml_ob1_irecv.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_recv 153 ompi/mca/pml/ob1/pml_ob1_irecv.c if (recvreq->req_recv.req_base.req_pml_complete) { req_recv 158 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_addr, req_recv 159 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_count, req_recv 160 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_datatype); req_recv 193 ompi/mca/pml/ob1/pml_ob1_irecv.c frag = (mca_pml_ob1_recv_frag_t*) recvreq->req_recv.req_base.req_addr; req_recv 194 ompi/mca/pml/ob1/pml_ob1_irecv.c src = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_recv 195 ompi/mca/pml/ob1/pml_ob1_irecv.c tag = recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG; req_recv 197 ompi/mca/pml/ob1/pml_ob1_irecv.c seq = recvreq->req_recv.req_base.req_sequence; req_recv 208 ompi/mca/pml/ob1/pml_ob1_irecv.c MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); req_recv 209 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_recv 217 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_recv 229 ompi/mca/pml/ob1/pml_ob1_irecv.c MCA_PML_BASE_RECV_START(&recvreq->req_recv); req_recv 232 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_sequence = seq; req_recv 234 ompi/mca/pml/ob1/pml_ob1_irecv.c proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); req_recv 235 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_proc = proc->ompi_proc; req_recv 287 ompi/mca/pml/ob1/pml_ob1_irecv.c frag = (mca_pml_ob1_recv_frag_t*) recvreq->req_recv.req_base.req_addr; req_recv 288 ompi/mca/pml/ob1/pml_ob1_irecv.c src = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_recv 289 ompi/mca/pml/ob1/pml_ob1_irecv.c tag = recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG; req_recv 290 ompi/mca/pml/ob1/pml_ob1_irecv.c seq = recvreq->req_recv.req_base.req_sequence; req_recv 301 ompi/mca/pml/ob1/pml_ob1_irecv.c MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); req_recv 302 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_recv 310 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_recv 321 ompi/mca/pml/ob1/pml_ob1_irecv.c MCA_PML_BASE_RECV_START(&recvreq->req_recv); req_recv 324 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_sequence = seq; req_recv 326 ompi/mca/pml/ob1/pml_ob1_irecv.c proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); req_recv 327 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_proc = proc->ompi_proc; req_recv 353 ompi/mca/pml/ob1/pml_ob1_irecv.c ompi_request_wait_completion(&(recvreq->req_recv.req_base.req_ompi)); req_recv 358 ompi/mca/pml/ob1/pml_ob1_irecv.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_recv 360 ompi/mca/pml/ob1/pml_ob1_irecv.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_recv 446 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_bytes_packed = bytes_received + (num_segments-1); req_recv 458 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_addr, req_recv 459 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_count, req_recv 460 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_datatype); req_recv 472 ompi/mca/pml/ob1/pml_ob1_recvfrag.c opal_convertor_unpack( &match->req_recv.req_base.req_convertor, req_recv 477 ompi/mca/pml/ob1/pml_ob1_recvfrag.c SPC_USER_OR_MPI(match->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_recv 484 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_addr, req_recv 485 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_count, req_recv 486 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_datatype); req_recv 574 ompi/mca/pml/ob1/pml_ob1_recvfrag.c sendreq->req_recv = hdr->hdr_ack.hdr_dst_req; req_recv 643 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if (recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA_ASYNC) { req_recv 736 ompi/mca/pml/ob1/pml_ob1_recvfrag.c wild_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; req_recv 738 ompi/mca/pml/ob1/pml_ob1_recvfrag.c specific_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; req_recv 757 ompi/mca/pml/ob1/pml_ob1_recvfrag.c req_tag = (*match)->req_recv.req_base.req_tag; req_recv 761 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &((*match)->req_recv.req_base), PERUSE_RECV); req_recv 766 ompi/mca/pml/ob1/pml_ob1_recvfrag.c *seq = (*match) ? (*match)->req_recv.req_base.req_sequence : PML_MAX_SEQ; req_recv 784 ompi/mca/pml/ob1/pml_ob1_recvfrag.c int req_tag = recv_req->req_recv.req_base.req_tag; req_recv 789 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &(recv_req->req_recv.req_base), PERUSE_RECV); req_recv 826 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_proc = proc->ompi_proc; req_recv 828 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if(OPAL_UNLIKELY(MCA_PML_REQUEST_PROBE == match->req_recv.req_base.req_type)) { req_recv 834 ompi/mca/pml/ob1/pml_ob1_recvfrag.c } else if (MCA_PML_REQUEST_MPROBE == match->req_recv.req_base.req_type) { req_recv 846 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_addr = tmp; req_recv 856 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &(match->req_recv.req_base), PERUSE_RECV); req_recv 76 ompi/mca/pml/ob1/pml_ob1_recvreq.c assert (false == recvreq->req_recv.req_base.req_free_called); req_recv 78 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_free_called = true; req_recv 80 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(recvreq->req_recv.req_base), PERUSE_RECV ); req_recv 82 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( true == recvreq->req_recv.req_base.req_pml_complete ) { req_recv 87 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 88 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 89 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 102 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_communicator_t *comm = request->req_recv.req_base.req_comm; req_recv 116 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( request->req_recv.req_base.req_peer == OMPI_ANY_SOURCE ) { req_recv 119 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_comm_proc_t* proc = mca_pml_ob1_peer_lookup (comm, request->req_recv.req_base.req_peer); req_recv 124 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(request->req_recv.req_base), PERUSE_RECV ); req_recv 129 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_pml_complete = true; req_recv 143 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_addr, req_recv 144 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_count, req_recv 145 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_datatype); req_recv 153 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_ompi.req_start = mca_pml_ob1_start; req_recv 154 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_ompi.req_free = mca_pml_ob1_recv_request_free; req_recv 155 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_ompi.req_cancel = mca_pml_ob1_recv_request_cancel; req_recv 209 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)rdma_size, req_recv 267 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_proc_t* proc = (ompi_proc_t*)recvreq->req_recv.req_base.req_proc; req_recv 281 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == 0 && req_recv 285 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer( &recvreq->req_recv.req_base.req_convertor, (void**)&(base) ); req_recv 289 ompi/mca/pml/ob1/pml_ob1_recvreq.c base, recvreq->req_recv.req_bytes_packed, req_recv 308 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position(&recvreq->req_recv.req_base.req_convertor, req_recv 339 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_proc_t *proc = (ompi_proc_t *) recvreq->req_recv.req_base.req_proc; req_recv 394 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_tag, (ompi_spc_value_t)frag->rdma_length, req_recv 397 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_send_fin (recvreq->req_recv.req_base.req_proc, req_recv 414 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_proc_t* proc = (ompi_proc_t*)recvreq->req_recv.req_base.req_proc; req_recv 453 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(recvreq->req_recv.req_base), frag->rdma_length, req_recv 494 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(((mca_pml_ob1_recv_request_t *) frag->rdma_req)->req_recv.req_base), req_recv 536 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 537 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 538 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 552 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 553 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 554 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 558 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_recv 637 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_recv 666 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_bytes_packed = hdr->hdr_rndv.hdr_msg_length; req_recv 676 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == true) { req_recv 687 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_proc); req_recv 692 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) { req_recv 723 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) { req_recv 732 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position( &recvreq->req_recv.req_base.req_convertor, &offset); req_recv 733 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer (&recvreq->req_recv.req_base.req_convertor, &data_ptr); req_recv 770 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position( &recvreq->req_recv.req_base.req_convertor, &offset); req_recv 771 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer (&recvreq->req_recv.req_base.req_convertor, &frag->local_address); req_recv 820 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_bytes_packed = hdr->hdr_rndv.hdr_msg_length; req_recv 833 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 834 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 835 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 846 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 847 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 848 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 851 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_recv 864 ompi/mca/pml/ob1/pml_ob1_recvreq.c if ((recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) && req_recv 867 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_cuda_set_copy_function_async(&recvreq->req_recv.req_base.req_convertor, strm); req_recv 889 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_bytes_packed = bytes_received; req_recv 897 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 898 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 899 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 913 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_recv 914 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_recv 915 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_recv 923 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_recv 954 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_match.hdr_tag; req_recv 955 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_match.hdr_src; req_recv 1037 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position (&recvreq->req_recv.req_base.req_convertor, req_recv 1039 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer (&recvreq->req_recv.req_base.req_convertor, &data_ptr); req_recv 1075 ompi/mca/pml/ob1/pml_ob1_recvreq.c ((MCA_PML_REQUEST_IPROBE == (R)->req_recv.req_base.req_type) || \ req_recv 1076 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_PROBE == (R)->req_recv.req_base.req_type) || \ req_recv 1077 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_IMPROBE == (R)->req_recv.req_base.req_type) || \ req_recv 1078 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_MPROBE == (R)->req_recv.req_base.req_type)) req_recv 1080 ompi/mca/pml/ob1/pml_ob1_recvreq.c ((MCA_PML_REQUEST_IMPROBE == (R)->req_recv.req_base.req_type) || \ req_recv 1081 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_MPROBE == (R)->req_recv.req_base.req_type)) req_recv 1092 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (req->req_recv.req_base.req_type != MCA_PML_REQUEST_PROBE && req_recv 1093 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_type != MCA_PML_REQUEST_MPROBE) { req_recv 1095 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_recv 1124 ompi/mca/pml/ob1/pml_ob1_recvreq.c int tag = req->req_recv.req_base.req_tag; req_recv 1145 ompi/mca/pml/ob1/pml_ob1_recvreq.c return custom_match_umq_find_verify_hold(req->req_recv.req_base.req_comm->c_pml_comm->umq, req_recv 1146 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_tag, req_recv 1147 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer, req_recv 1169 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_comm_t* comm = req->req_recv.req_base.req_comm->c_pml_comm; req_recv 1174 ompi/mca/pml/ob1/pml_ob1_recvreq.c frag = custom_match_umq_find_verify_hold (comm->umq, req->req_recv.req_base.req_tag, req_recv 1175 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer, req_recv 1180 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[frag->hdr.hdr_match.hdr_src]->ompi_proc; req_recv 1204 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[i]->ompi_proc; req_recv 1216 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[i]->ompi_proc; req_recv 1230 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_communicator_t *comm = req->req_recv.req_base.req_comm; req_recv 1253 ompi/mca/pml/ob1/pml_ob1_recvreq.c MCA_PML_BASE_RECV_START(&req->req_recv); req_recv 1261 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_recv 1264 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_sequence = ob1_comm->recv_sequence++; req_recv 1267 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(req->req_recv.req_base.req_peer == OMPI_ANY_SOURCE) { req_recv 1281 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = ompi_proc_local_proc; req_recv 1286 ompi/mca/pml/ob1/pml_ob1_recvreq.c proc = mca_pml_ob1_peer_lookup (comm, req->req_recv.req_base.req_peer); req_recv 1287 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = proc->ompi_proc; req_recv 1300 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_recv 1303 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(OPAL_LIKELY(req->req_recv.req_base.req_type != MCA_PML_REQUEST_IPROBE && req_recv 1304 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_type != MCA_PML_REQUEST_IMPROBE)) req_recv 1307 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_tag, req_recv 1308 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer); req_recv 1317 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_recv 1321 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_comm, req_recv 1327 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_recv 1330 ompi/mca/pml/ob1/pml_ob1_recvreq.c custom_match_umq_remove_hold(req->req_recv.req_base.req_comm->c_pml_comm->umq, hold_prev, hold_elem, hold_index); req_recv 1366 ompi/mca/pml/ob1/pml_ob1_recvreq.c custom_match_umq_remove_hold(req->req_recv.req_base.req_comm->c_pml_comm->umq, hold_prev, hold_elem, hold_index); req_recv 1374 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_addr = frag; req_recv 42 ompi/mca/pml/ob1/pml_ob1_recvreq.h mca_pml_base_recv_request_t req_recv; req_recv 109 ompi/mca/pml/ob1/pml_ob1_recvreq.h MCA_PML_BASE_RECV_REQUEST_INIT( &(request)->req_recv, \ req_recv 127 ompi/mca/pml/ob1/pml_ob1_recvreq.h &(recvreq->req_recv.req_base), PERUSE_RECV ); \ req_recv 128 ompi/mca/pml/ob1/pml_ob1_recvreq.h ompi_request_complete( &(recvreq->req_recv.req_base.req_ompi), true ); \ req_recv 133 ompi/mca/pml/ob1/pml_ob1_recvreq.h MCA_PML_BASE_RECV_REQUEST_FINI(&recvreq->req_recv); req_recv 161 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(false == recvreq->req_recv.req_base.req_pml_complete){ req_recv 163 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(recvreq->req_recv.req_bytes_packed > 0) { req_recv 165 ompi/mca/pml/ob1/pml_ob1_recvreq.h &recvreq->req_recv.req_base, PERUSE_RECV ); req_recv 179 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(true == recvreq->req_recv.req_base.req_free_called) { req_recv 180 ompi/mca/pml/ob1/pml_ob1_recvreq.h if( MPI_SUCCESS != recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR ) { req_recv 186 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_pml_complete = true; req_recv 187 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_ompi.req_status._ucount = req_recv 189 ompi/mca/pml/ob1/pml_ob1_recvreq.h if (recvreq->req_recv.req_bytes_packed > recvreq->req_bytes_expected) { req_recv 190 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_ompi.req_status._ucount = req_recv 191 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_bytes_packed; req_recv 192 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR = req_recv 211 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_bytes_received >= recvreq->req_recv.req_bytes_packed && req_recv 225 ompi/mca/pml/ob1/pml_ob1_recvreq.h if( req->req_recv.req_base.req_datatype->super.size | req->req_recv.req_base.req_count ) { req_recv 227 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_proc->super.proc_convertor, req_recv 228 ompi/mca/pml/ob1/pml_ob1_recvreq.h &(req->req_recv.req_base.req_datatype->super), req_recv 229 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_count, req_recv 230 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_addr, req_recv 232 ompi/mca/pml/ob1/pml_ob1_recvreq.h &req->req_recv.req_base.req_convertor); req_recv 233 ompi/mca/pml/ob1/pml_ob1_recvreq.h opal_convertor_get_unpacked_size(&req->req_recv.req_base.req_convertor, req_recv 244 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_src; req_recv 245 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_tag; req_recv 250 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(req->req_recv.req_bytes_packed > 0) { req_recv 252 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(MPI_ANY_SOURCE == req->req_recv.req_base.req_peer) { req_recv 258 ompi/mca/pml/ob1/pml_ob1_recvreq.h &req->req_recv.req_base, PERUSE_RECV); req_recv 276 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(request->req_recv.req_bytes_packed > 0) { \ req_recv 296 ompi/mca/pml/ob1/pml_ob1_recvreq.h &(request->req_recv.req_base), max_data, \ req_recv 298 ompi/mca/pml/ob1/pml_ob1_recvreq.h opal_convertor_set_position( &(request->req_recv.req_base.req_convertor), \ req_recv 300 ompi/mca/pml/ob1/pml_ob1_recvreq.h opal_convertor_unpack( &(request)->req_recv.req_base.req_convertor, \ req_recv 1041 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_recv.lval); req_recv 1123 ompi/mca/pml/ob1/pml_ob1_sendreq.c if (NULL != sendreq->req_recv.pval) req_recv 1231 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_recv.pval = hdr->hdr_recv_req.pval; req_recv 48 ompi/mca/pml/ob1/pml_ob1_sendreq.h opal_ptr_t req_recv; req_recv 157 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_recv.pval = NULL; \