preq 199 ompi/mca/coll/base/coll_base_alltoallv.c ompi_request_t **preq, **reqs; preq 235 ompi/mca/coll/base/coll_base_alltoallv.c reqs = preq = ompi_coll_base_comm_get_reqs(data, 2 * size); preq 248 ompi/mca/coll/base/coll_base_alltoallv.c preq++)); preq 263 ompi/mca/coll/base/coll_base_alltoallv.c preq++)); preq 630 ompi/mca/coll/base/coll_base_bcast.c ompi_request_t **preq, **reqs; preq 648 ompi/mca/coll/base/coll_base_bcast.c preq = reqs = ompi_coll_base_comm_get_reqs(module->base_data, size-1); preq 661 ompi/mca/coll/base/coll_base_bcast.c comm, preq++)); preq 679 ompi/mca/coll/base/coll_base_bcast.c for( preq = reqs; preq < reqs+i; preq++ ) { preq 680 ompi/mca/coll/base/coll_base_bcast.c if (MPI_REQUEST_NULL == *preq) continue; preq 681 ompi/mca/coll/base/coll_base_bcast.c if (MPI_ERR_PENDING == (*preq)->req_status.MPI_ERROR) continue; preq 682 ompi/mca/coll/base/coll_base_bcast.c err = (*preq)->req_status.MPI_ERROR; preq 61 ompi/mca/coll/basic/coll_basic_alltoallv.c ompi_request_t **preq; preq 72 ompi/mca/coll/basic/coll_basic_alltoallv.c preq = ompi_coll_base_comm_get_reqs(module->base_data, nreqs); preq 73 ompi/mca/coll/basic/coll_basic_alltoallv.c if( NULL == preq ) { return OMPI_ERR_OUT_OF_RESOURCE; } preq 82 ompi/mca/coll/basic/coll_basic_alltoallv.c &preq[i])); preq 84 ompi/mca/coll/basic/coll_basic_alltoallv.c ompi_coll_base_free_reqs(preq, i + 1); preq 97 ompi/mca/coll/basic/coll_basic_alltoallv.c &preq[rsize + i])); preq 99 ompi/mca/coll/basic/coll_basic_alltoallv.c ompi_coll_base_free_reqs(preq, rsize + i + 1); preq 105 ompi/mca/coll/basic/coll_basic_alltoallv.c err = ompi_request_wait_all(nreqs, preq, MPI_STATUSES_IGNORE); preq 107 ompi/mca/coll/basic/coll_basic_alltoallv.c ompi_coll_base_free_reqs(preq, nreqs); preq 152 ompi/mca/coll/basic/coll_basic_alltoallw.c ompi_request_t **preq, **reqs; preq 183 ompi/mca/coll/basic/coll_basic_alltoallw.c reqs = preq = ompi_coll_base_comm_get_reqs(module->base_data, 2 * size); preq 199 ompi/mca/coll/basic/coll_basic_alltoallw.c preq++)); preq 221 ompi/mca/coll/basic/coll_basic_alltoallw.c preq++)); preq 266 ompi/mca/coll/basic/coll_basic_alltoallw.c ompi_request_t **preq, **reqs; preq 273 ompi/mca/coll/basic/coll_basic_alltoallw.c reqs = preq = ompi_coll_base_comm_get_reqs(module->base_data, 2 * size); preq 288 ompi/mca/coll/basic/coll_basic_alltoallw.c comm, preq++)); preq 309 ompi/mca/coll/basic/coll_basic_alltoallw.c preq++)); preq 59 ompi/mca/coll/basic/coll_basic_bcast.c ompi_request_t **preq, **reqs; preq 89 ompi/mca/coll/basic/coll_basic_bcast.c preq = reqs; preq 100 ompi/mca/coll/basic/coll_basic_bcast.c comm, preq++)); preq 996 ompi/mca/pml/ucx/pml_ucx.c mca_pml_ucx_persistent_request_t *preq; preq 1001 ompi/mca/pml/ucx/pml_ucx.c preq = (mca_pml_ucx_persistent_request_t *)requests[i]; preq 1003 ompi/mca/pml/ucx/pml_ucx.c if ((preq == NULL) || (OMPI_REQUEST_PML != preq->ompi.req_type)) { preq 1008 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_ASSERT(preq->ompi.req_state != OMPI_REQUEST_INVALID); preq 1009 ompi/mca/pml/ucx/pml_ucx.c preq->ompi.req_state = OMPI_REQUEST_ACTIVE; preq 1010 ompi/mca/pml/ucx/pml_ucx.c mca_pml_ucx_request_reset(&preq->ompi); preq 1012 ompi/mca/pml/ucx/pml_ucx.c if (preq->flags & MCA_PML_UCX_REQUEST_FLAG_SEND) { preq 1013 ompi/mca/pml/ucx/pml_ucx.c tmp_req = (ompi_request_t*)mca_pml_ucx_common_send(preq->send.ep, preq 1014 ompi/mca/pml/ucx/pml_ucx.c preq->buffer, preq 1015 ompi/mca/pml/ucx/pml_ucx.c preq->count, preq 1016 ompi/mca/pml/ucx/pml_ucx.c preq->datatype.ompi_datatype, preq 1017 ompi/mca/pml/ucx/pml_ucx.c preq->datatype.datatype, preq 1018 ompi/mca/pml/ucx/pml_ucx.c preq->tag, preq 1019 ompi/mca/pml/ucx/pml_ucx.c preq->send.mode, preq 1022 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_VERBOSE(8, "start recv request %p", (void*)preq); preq 1024 ompi/mca/pml/ucx/pml_ucx.c preq->buffer, preq->count, preq 1025 ompi/mca/pml/ucx/pml_ucx.c preq->datatype.datatype, preq 1026 ompi/mca/pml/ucx/pml_ucx.c preq->tag, preq 1027 ompi/mca/pml/ucx/pml_ucx.c preq->recv.tag_mask, preq 1033 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_ASSERT(preq->flags & MCA_PML_UCX_REQUEST_FLAG_SEND); preq 1036 ompi/mca/pml/ucx/pml_ucx.c (void*)preq); preq 1037 ompi/mca/pml/ucx/pml_ucx.c mca_pml_ucx_set_send_status(&preq->ompi.req_status, UCS_OK); preq 1038 ompi/mca/pml/ucx/pml_ucx.c ompi_request_complete(&preq->ompi, true); preq 1042 ompi/mca/pml/ucx/pml_ucx.c PML_UCX_VERBOSE(8, "completing persistent request %p", (void*)preq); preq 1043 ompi/mca/pml/ucx/pml_ucx.c mca_pml_ucx_persistent_request_complete(preq, tmp_req); preq 1048 ompi/mca/pml/ucx/pml_ucx.c (void*)tmp_req, (void*)preq); preq 1049 ompi/mca/pml/ucx/pml_ucx.c tmp_req->req_complete_cb_data = preq; preq 1050 ompi/mca/pml/ucx/pml_ucx.c preq->tmp_req = tmp_req; preq 1054 ompi/mca/pml/ucx/pml_ucx.c (preq->flags & MCA_PML_UCX_REQUEST_FLAG_SEND) ? "send" : "recv", preq 76 ompi/mca/pml/ucx/pml_ucx_request.c static void mca_pml_ucx_persistent_request_detach(mca_pml_ucx_persistent_request_t *preq, preq 80 ompi/mca/pml/ucx/pml_ucx_request.c preq->tmp_req = NULL; preq 84 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_complete(mca_pml_ucx_persistent_request_t *preq, preq 87 ompi/mca/pml/ucx/pml_ucx_request.c preq->ompi.req_status = tmp_req->req_status; preq 89 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_detach(preq, tmp_req); preq 91 ompi/mca/pml/ucx/pml_ucx_request.c ompi_request_complete(&preq->ompi, true); preq 96 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_t *preq; preq 99 ompi/mca/pml/ucx/pml_ucx_request.c preq = (mca_pml_ucx_persistent_request_t*)tmp_req->req_complete_cb_data; preq 100 ompi/mca/pml/ucx/pml_ucx_request.c if (preq != NULL) { preq 101 ompi/mca/pml/ucx/pml_ucx_request.c PML_UCX_ASSERT(preq->tmp_req != NULL); preq 102 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_complete(preq, tmp_req); preq 169 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_t* preq = (mca_pml_ucx_persistent_request_t*)*rptr; preq 170 ompi/mca/pml/ucx/pml_ucx_request.c ompi_request_t *tmp_req = preq->tmp_req; preq 172 ompi/mca/pml/ucx/pml_ucx_request.c preq->ompi.req_state = OMPI_REQUEST_INVALID; preq 174 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_detach(preq, tmp_req); preq 177 ompi/mca/pml/ucx/pml_ucx_request.c if ((preq->flags & MCA_PML_UCX_REQUEST_FLAG_SEND) && preq 178 ompi/mca/pml/ucx/pml_ucx_request.c (MCA_PML_BASE_SEND_BUFFERED == preq->send.mode)) { preq 179 ompi/mca/pml/ucx/pml_ucx_request.c OBJ_RELEASE(preq->datatype.ompi_datatype); preq 181 ompi/mca/pml/ucx/pml_ucx_request.c PML_UCX_FREELIST_RETURN(&ompi_pml_ucx.persistent_reqs, &preq->ompi.super); preq 188 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_persistent_request_t* preq = (mca_pml_ucx_persistent_request_t*)req; preq 190 ompi/mca/pml/ucx/pml_ucx_request.c if (preq->tmp_req != NULL) { preq 191 ompi/mca/pml/ucx/pml_ucx_request.c ucp_request_cancel(ompi_pml_ucx.ucp_worker, preq->tmp_req); preq 129 ompi/mca/pml/ucx/pml_ucx_request.h void mca_pml_ucx_persistent_request_complete(mca_pml_ucx_persistent_request_t *preq, preq 783 ompi/mpi/java/java/Comm.java Prequest preq = new Prequest(sendInit(handle, buf, count, type.handle, dest, tag)); preq 784 ompi/mpi/java/java/Comm.java preq.addSendBufRef(buf); preq 785 ompi/mpi/java/java/Comm.java return preq; preq 810 ompi/mpi/java/java/Comm.java Prequest preq = new Prequest(bSendInit(handle, buf, count, type.handle, dest, tag)); preq 811 ompi/mpi/java/java/Comm.java preq.addSendBufRef(buf); preq 812 ompi/mpi/java/java/Comm.java return preq; preq 837 ompi/mpi/java/java/Comm.java Prequest preq = new Prequest(sSendInit(handle, buf, count, type.handle, dest, tag)); preq 838 ompi/mpi/java/java/Comm.java preq.addSendBufRef(buf); preq 839 ompi/mpi/java/java/Comm.java return preq; preq 864 ompi/mpi/java/java/Comm.java Prequest preq = new Prequest(rSendInit(handle, buf, count, type.handle, dest, tag)); preq 865 ompi/mpi/java/java/Comm.java preq.addSendBufRef(buf); preq 866 ompi/mpi/java/java/Comm.java return preq; preq 891 ompi/mpi/java/java/Comm.java Prequest preq = new Prequest(recvInit(handle, buf, count, type.handle, source, tag)); preq 892 ompi/mpi/java/java/Comm.java preq.addRecvBufRef(buf); preq 893 ompi/mpi/java/java/Comm.java return preq;