rreq 580 ompi/mca/coll/base/coll_base_alltoall.c ompi_request_t **req, **sreq, **rreq; rreq 627 ompi/mca/coll/base/coll_base_alltoall.c req = rreq = ompi_coll_base_comm_get_reqs(data, (size - 1) * 2); rreq 636 ompi/mca/coll/base/coll_base_alltoall.c i = (i + 1) % size, ++rreq) { rreq 640 ompi/mca/coll/base/coll_base_alltoall.c MCA_COLL_BASE_TAG_ALLTOALL, comm, rreq)); rreq 648 ompi/mca/coll/base/coll_base_alltoall.c sreq = rreq; rreq 61 ompi/mca/coll/basic/coll_basic_alltoall.c ompi_request_t **req, **sreq, **rreq; rreq 81 ompi/mca/coll/basic/coll_basic_alltoall.c req = rreq = ompi_coll_base_comm_get_reqs( module->base_data, nreqs); rreq 83 ompi/mca/coll/basic/coll_basic_alltoall.c sreq = rreq + size; rreq 89 ompi/mca/coll/basic/coll_basic_alltoall.c for (i = 0; i < size; i++, ++rreq) { rreq 91 ompi/mca/coll/basic/coll_basic_alltoall.c MCA_COLL_BASE_TAG_ALLTOALL, comm, rreq)); rreq 47 ompi/mca/pml/ob1/pml_ob1_cuda.c int mca_pml_ob1_cuda_need_buffers(void * rreq, rreq 156 ompi/mca/pml/ob1/pml_ob1_cuda.c int mca_pml_ob1_cuda_need_buffers(void * rreq, rreq 159 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_pml_ob1_recv_request_t* recvreq = (mca_pml_ob1_recv_request_t*)rreq; rreq 334 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_recv_request_t *rreq; rreq 336 ompi/mca/pml/yalla/pml_yalla.c rreq = MCA_PML_YALLA_RREQ_INIT(buf, count, datatype, src, tag, comm, rreq 338 ompi/mca/pml/yalla/pml_yalla.c rreq->super.ompi.req_persistent = true; rreq 339 ompi/mca/pml/yalla/pml_yalla.c rreq->super.flags = 0; rreq 340 ompi/mca/pml/yalla/pml_yalla.c *request = &rreq->super.ompi; rreq 350 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_recv_request_t *rreq; rreq 353 ompi/mca/pml/yalla/pml_yalla.c rreq = MCA_PML_YALLA_RREQ_INIT(buf, count, datatype, src, tag, comm, rreq 355 ompi/mca/pml/yalla/pml_yalla.c rreq->super.ompi.req_persistent = false; rreq 356 ompi/mca/pml/yalla/pml_yalla.c rreq->super.flags = 0; rreq 359 ompi/mca/pml/yalla/pml_yalla.c (void *)request, (void *)rreq, src, tag, datatype->name, count); rreq 361 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_recv(&rreq->mxm); rreq 366 ompi/mca/pml/yalla/pml_yalla.c *request = &rreq->super.ompi; rreq 374 ompi/mca/pml/yalla/pml_yalla.c mxm_recv_req_t rreq; rreq 378 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_RECV_REQ(&rreq, buf, count, datatype, src, tag, comm, recv); rreq 379 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_BLOCKING_MXM_RECV_REQ(&rreq); rreq 384 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_recv(&rreq); rreq 389 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_WAIT_MXM_REQ(&rreq.base); rreq 391 ompi/mca/pml/yalla/pml_yalla.c mxm_error_string(rreq.base.error), rreq 392 ompi/mca/pml/yalla/pml_yalla.c rreq.completion.sender_imm, rreq.completion.sender_tag, rreq 393 ompi/mca/pml/yalla/pml_yalla.c rreq.tag, rreq.tag_mask, rreq 394 ompi/mca/pml/yalla/pml_yalla.c rreq.completion.actual_len); rreq 395 ompi/mca/pml/yalla/pml_yalla.c rc = PML_YALLA_SET_RECV_STATUS(&rreq, rreq.completion.actual_len, status); rreq 396 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_FREE_BLOCKING_MXM_REQ(&rreq.base); rreq 537 ompi/mca/pml/yalla/pml_yalla.c mxm_recv_req_t rreq; rreq 540 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_PROBE_REQ(&rreq, src, tag, comm); rreq 542 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_probe(&rreq); rreq 546 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_SET_RECV_STATUS(&rreq, rreq.completion.sender_len, status); rreq 561 ompi/mca/pml/yalla/pml_yalla.c mxm_recv_req_t rreq; rreq 564 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_PROBE_REQ(&rreq, src, tag, comm); rreq 566 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_probe(&rreq); rreq 569 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_SET_RECV_STATUS(&rreq, rreq.completion.sender_len, status); rreq 585 ompi/mca/pml/yalla/pml_yalla.c mxm_recv_req_t rreq; rreq 589 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_PROBE_REQ(&rreq, src, tag, comm); rreq 591 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_mprobe(&rreq, &mxm_msg); rreq 595 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_SET_RECV_STATUS(&rreq, rreq.completion.sender_len, status); rreq 596 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_SET_MESSAGE(&rreq, comm, mxm_msg, message); rreq 612 ompi/mca/pml/yalla/pml_yalla.c mxm_recv_req_t rreq; rreq 616 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_PROBE_REQ(&rreq, src, tag, comm); rreq 618 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_mprobe(&rreq, &mxm_msg); rreq 621 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_SET_RECV_STATUS(&rreq, rreq.completion.sender_len, status); rreq 622 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_SET_MESSAGE(&rreq, comm, mxm_msg, message); rreq 638 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_recv_request_t *rreq; rreq 641 ompi/mca/pml/yalla/pml_yalla.c rreq = MCA_PML_YALLA_RREQ_INIT(buf, count, datatype, -1, 0, (*message)->comm, rreq 643 ompi/mca/pml/yalla/pml_yalla.c rreq->super.ompi.req_persistent = false; rreq 644 ompi/mca/pml/yalla/pml_yalla.c rreq->super.flags = 0; rreq 647 ompi/mca/pml/yalla/pml_yalla.c (void *)request, (void *)rreq, (void *)message, (void *)(*message), datatype->name, count); rreq 649 ompi/mca/pml/yalla/pml_yalla.c error = mxm_message_recv(&rreq->mxm, (*message)->req_ptr); rreq 656 ompi/mca/pml/yalla/pml_yalla.c *request = &rreq->super.ompi; rreq 664 ompi/mca/pml/yalla/pml_yalla.c mxm_recv_req_t rreq; rreq 667 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_RECV_REQ(&rreq, buf, count, datatype, -1, 0, (*message)->comm, recv); rreq 668 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_BLOCKING_MXM_RECV_REQ(&rreq); rreq 673 ompi/mca/pml/yalla/pml_yalla.c error = mxm_message_recv(&rreq, (*message)->req_ptr); rreq 680 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_WAIT_MXM_REQ(&rreq.base); rreq 682 ompi/mca/pml/yalla/pml_yalla.c mxm_error_string(rreq.base.error), rreq 683 ompi/mca/pml/yalla/pml_yalla.c rreq.completion.sender_imm, rreq.completion.sender_tag, rreq 684 ompi/mca/pml/yalla/pml_yalla.c rreq.tag, rreq.tag_mask, rreq 685 ompi/mca/pml/yalla/pml_yalla.c rreq.completion.actual_len); rreq 686 ompi/mca/pml/yalla/pml_yalla.c return PML_YALLA_SET_RECV_STATUS(&rreq, rreq.completion.actual_len, status); rreq 728 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_recv_request_t *rreq; rreq 729 ompi/mca/pml/yalla/pml_yalla.c rreq = (mca_pml_yalla_recv_request_t *)req; rreq 730 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_RESET_PML_REQ(req, PML_YALLA_MXM_REQBASE(rreq)); rreq 733 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_recv(&rreq->mxm); rreq 112 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_recv_request_t *rreq) rreq 114 ompi/mca/pml/yalla/pml_yalla_datatype.c rreq->super.convertor = mca_pml_yalla_get_recv_convertor(buf, count, datatype); rreq 115 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_noncontig_req_init(mxm_req, rreq->super.convertor, mxm_pml_yalla_irecv_stream_cb); rreq 61 ompi/mca/pml/yalla/pml_yalla_datatype.h mca_pml_yalla_recv_request_t *rreq); rreq 87 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_recv_request_t *rreq = (mca_pml_yalla_recv_request_t*)(*request); rreq 91 ompi/mca/pml/yalla/pml_yalla_request.c if (mca_pml_yalla_check_request_state(&rreq->super, PML_YALLA_MXM_REQBASE(rreq))) { rreq 92 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_request_release(&rreq->super, &ompi_pml_yalla.recv_reqs); rreq 101 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_recv_request_t *rreq = (mca_pml_yalla_recv_request_t*)request; rreq 104 ompi/mca/pml/yalla/pml_yalla_request.c error = mxm_req_cancel_recv(&rreq->mxm); rreq 198 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_recv_request_t* rreq = context; rreq 200 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_SET_RECV_STATUS(&rreq->mxm, rreq->mxm.completion.actual_len, rreq 201 ompi/mca/pml/yalla/pml_yalla_request.c &rreq->super.ompi.req_status); rreq 204 ompi/mca/pml/yalla/pml_yalla_request.c (void *)rreq, mxm_error_string(rreq->mxm.base.error), rreq 205 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.completion.sender_imm, rreq->mxm.completion.sender_tag, rreq 206 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.tag, rreq->mxm.tag_mask, rreq 207 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.completion.actual_len); rreq 209 ompi/mca/pml/yalla/pml_yalla_request.c ompi_request_complete(&rreq->super.ompi, true); rreq 210 ompi/mca/pml/yalla/pml_yalla_request.c if (rreq->super.flags & MCA_PML_YALLA_REQUEST_FLAG_FREE_CALLED) { rreq 211 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_VERBOSE(7, "release request %p because free was already called", (void *)rreq); rreq 212 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_request_release(&rreq->super, &ompi_pml_yalla.recv_reqs); rreq 238 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_recv_request_construct(mca_pml_yalla_recv_request_t* rreq) rreq 240 ompi/mca/pml/yalla/pml_yalla_request.c init_base_req(&rreq->super); rreq 241 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_recv_req(&rreq->mxm); rreq 242 ompi/mca/pml/yalla/pml_yalla_request.c rreq->super.ompi.req_free = mca_pml_yalla_recv_request_free; rreq 243 ompi/mca/pml/yalla/pml_yalla_request.c rreq->super.ompi.req_cancel = mca_pml_yalla_recv_request_cancel; rreq 244 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.base.context = rreq; rreq 245 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.base.completed_cb = mca_pml_yalla_recv_completion_cb; rreq 248 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_recv_request_destruct(mca_pml_yalla_recv_request_t *rreq) rreq 250 ompi/mca/pml/yalla/pml_yalla_request.c OMPI_REQUEST_FINI(&rreq->super.ompi); rreq 133 ompi/mca/pml/yalla/pml_yalla_request.h mca_pml_yalla_recv_request_t *rreq = (mca_pml_yalla_recv_request_t *)PML_YALLA_FREELIST_GET(&ompi_pml_yalla.recv_reqs); rreq 134 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_OMPI_REQ(&rreq->super.ompi, _comm, _state); rreq 135 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_RECV_REQ(&rreq->mxm, _buf, _count, _datatype, _src, _tag, _comm, irecv, rreq); rreq 136 ompi/mca/pml/yalla/pml_yalla_request.h return rreq; rreq 263 test/datatype/to_self.c MPI_Request sreq, rreq; rreq 278 test/datatype/to_self.c MPI_Irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rreq 280 test/datatype/to_self.c MPI_Wait( &rreq, &status ); rreq 285 test/datatype/to_self.c ftmpi_mpi_irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rreq 288 test/datatype/to_self.c ftmpi_request_free( &rreq ); rreq 301 test/datatype/to_self.c MPI_Request sreq, rreq; rreq 315 test/datatype/to_self.c MPI_Irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rreq 318 test/datatype/to_self.c MPI_Wait( &rreq, &status ); rreq 322 test/datatype/to_self.c ftmpi_mpi_irecv( rbuf, rcount, rdt, myself, tag, MPI_COMM_WORLD, &rreq ); rreq 326 test/datatype/to_self.c ftmpi_request_free( &rreq );