ompi_req 186 ompi/communicator/comm_request.c static int ompi_comm_request_cancel (struct ompi_request_t *ompi_req, int complete) ompi_req 188 ompi/communicator/comm_request.c ompi_comm_request_t *tmp, *request = (ompi_comm_request_t *) ompi_req; ompi_req 215 ompi/communicator/comm_request.c static int ompi_comm_request_free (struct ompi_request_t **ompi_req) ompi_req 217 ompi/communicator/comm_request.c ompi_comm_request_t *request = (ompi_comm_request_t *) *ompi_req; ompi_req 219 ompi/communicator/comm_request.c if( !REQUEST_COMPLETE(*ompi_req) ) { ompi_req 223 ompi/communicator/comm_request.c OMPI_REQUEST_FINI(*ompi_req); ompi_req 226 ompi/communicator/comm_request.c *ompi_req = MPI_REQUEST_NULL; ompi_req 193 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *ompi_req; ompi_req 205 ompi/mca/coll/hcoll/coll_hcoll_rte.c tag,comm,&ompi_req))) ompi_req 209 ompi/mca/coll/hcoll/coll_hcoll_rte.c req->data = (void *)ompi_req; ompi_req 234 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *ompi_req; ompi_req 244 ompi/mca/coll/hcoll/coll_hcoll_rte.c tag,MCA_PML_BASE_SEND_STANDARD,comm,&ompi_req))) ompi_req 248 ompi/mca/coll/hcoll/coll_hcoll_rte.c req->data = (void *)ompi_req; ompi_req 256 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t * ompi_req = (ompi_request_t *)request->data; ompi_req 263 ompi/mca/coll/hcoll/coll_hcoll_rte.c *completed = REQUEST_COMPLETE(ompi_req); ompi_req 265 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_free(&ompi_req); ompi_req 339 ompi/mca/coll/hcoll/coll_hcoll_rte.c request_free(struct ompi_request_t **ompi_req) ompi_req 341 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *req = *ompi_req; ompi_req 346 ompi/mca/coll/hcoll/coll_hcoll_rte.c *ompi_req = &ompi_request_empty; ompi_req 352 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *ompi_req; ompi_req 359 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_req = (ompi_request_t *)item; ompi_req 360 ompi/mca/coll/hcoll/coll_hcoll_rte.c OMPI_REQUEST_INIT(ompi_req,false); ompi_req 361 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_req->req_complete_cb = NULL; ompi_req 362 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_req->req_status.MPI_ERROR = MPI_SUCCESS; ompi_req 363 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_req->req_state = OMPI_REQUEST_ACTIVE; ompi_req 364 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_req->req_free = request_free; ompi_req 365 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_req->req_type = OMPI_REQUEST_COLL; ompi_req 366 ompi/mca/coll/hcoll/coll_hcoll_rte.c return (void *)ompi_req; ompi_req 371 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *ompi_req = (ompi_request_t *)handle; ompi_req 372 ompi/mca/coll/hcoll/coll_hcoll_rte.c return REQUEST_COMPLETE(ompi_req);; ompi_req 376 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *ompi_req = (ompi_request_t *)handle; ompi_req 378 ompi/mca/coll/hcoll/coll_hcoll_rte.c (opal_free_list_item_t *)ompi_req); ompi_req 383 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_t *ompi_req = (ompi_request_t *)handle; ompi_req 384 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_request_complete(ompi_req,true); ompi_req 554 ompi/mca/coll/libnbc/coll_libnbc_component.c request_free(struct ompi_request_t **ompi_req) ompi_req 557 ompi/mca/coll/libnbc/coll_libnbc_component.c (ompi_coll_libnbc_request_t*) *ompi_req; ompi_req 564 ompi/mca/coll/libnbc/coll_libnbc_component.c *ompi_req = MPI_REQUEST_NULL; ompi_req 273 ompi/mca/coll/portals4/coll_portals4_barrier.c ompi_request_t **ompi_req, ompi_req 289 ompi/mca/coll/portals4/coll_portals4_barrier.c *ompi_req = &request->super; ompi_req 25 ompi/mca/coll/portals4/coll_portals4_request.c request_free(struct ompi_request_t **ompi_req) ompi_req 28 ompi/mca/coll/portals4/coll_portals4_request.c (ompi_coll_portals4_request_t*) *ompi_req; ompi_req 36 ompi/mca/coll/portals4/coll_portals4_request.c *ompi_req = MPI_REQUEST_NULL; ompi_req 55 ompi/mca/mtl/mtl.h struct ompi_request_t *ompi_req; ompi_req 319 ompi/mca/mtl/ofi/mtl_ofi.h ofi_req->super.ompi_req->req_status.MPI_ERROR = ompi_req 630 ompi/mca/mtl/ofi/mtl_ofi.h assert(ofi_req->super.ompi_req); ompi_req 631 ompi/mca/mtl/ofi/mtl_ofi.h status = &ofi_req->super.ompi_req->req_status; ompi_req 729 ompi/mca/mtl/ofi/mtl_ofi.h assert(ofi_req->super.ompi_req); ompi_req 730 ompi/mca/mtl/ofi/mtl_ofi.h status = &ofi_req->super.ompi_req->req_status; ompi_req 834 ompi/mca/mtl/ofi/mtl_ofi.h ompi_status_public_t *status = &mrecv_req->ompi_req->req_status; ompi_req 855 ompi/mca/mtl/ofi/mtl_ofi.h ompi_status_public_t *status = &mrecv_req->ompi_req->req_status; ompi_req 1207 ompi/mca/mtl/ofi/mtl_ofi.h ofi_req->super.ompi_req->req_status._cancelled = false; ompi_req 51 ompi/mca/mtl/portals4/mtl_portals4_cancel.c recvreq->super.super.ompi_req->req_status._cancelled = true; ompi_req 143 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_SOURCE = ompi_req 145 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_TAG = ompi_req 151 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = MPI_ERR_TRUNCATE; ompi_req 162 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount = ev->mlength; ompi_req 188 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = ret; ompi_req 213 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_SOURCE = ompi_req 215 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_TAG = ompi_req 222 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = MPI_ERR_TRUNCATE; ompi_req 232 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount = ev->mlength; ompi_req 283 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount = 0; ompi_req 312 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = ompi_req 382 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount += ev->mlength; ompi_req 405 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount); ompi_req 410 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = ret; ompi_req 421 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = ompi_req 479 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = OMPI_SUCCESS; ompi_req 561 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = OMPI_SUCCESS; ompi_req 222 ompi/mca/mtl/portals4/mtl_portals4_send.c ptl_request->super.super.ompi_req->req_status.MPI_ERROR = ret; ompi_req 443 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request->super.ompi_req->req_status.MPI_SOURCE = ompi_req 445 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request->super.ompi_req->req_status.MPI_TAG = ompi_req 447 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request->super.ompi_req->req_status._ucount = ompi_req 459 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request->super.ompi_req->req_status.MPI_ERROR = ompi_req 463 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request->super.ompi_req->req_status.MPI_ERROR = ompi_req 467 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request->super.ompi_req->req_status.MPI_ERROR = ompi_req 43 ompi/mca/mtl/psm/mtl_psm_cancel.c mtl_request->ompi_req->req_status._cancelled = true; ompi_req 432 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request->super.ompi_req->req_status.MPI_SOURCE = ompi_req 434 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request->super.ompi_req->req_status.MPI_TAG = ompi_req 436 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request->super.ompi_req->req_status._ucount = ompi_req 452 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request->super.ompi_req->req_status.MPI_ERROR = ompi_req 456 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request->super.ompi_req->req_status.MPI_ERROR = ompi_req 460 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request->super.ompi_req->req_status.MPI_ERROR = ompi_req 44 ompi/mca/mtl/psm2/mtl_psm2_cancel.c mtl_request->ompi_req->req_status._cancelled = true; ompi_req 2020 ompi/mca/osc/portals4/osc_portals4_comm.c struct ompi_request_t **ompi_req) ompi_req 2039 ompi/mca/osc/portals4/osc_portals4_comm.c *ompi_req = &request->super; ompi_req 2132 ompi/mca/osc/portals4/osc_portals4_comm.c struct ompi_request_t **ompi_req) ompi_req 2151 ompi/mca/osc/portals4/osc_portals4_comm.c *ompi_req = &request->super; ompi_req 2238 ompi/mca/osc/portals4/osc_portals4_comm.c struct ompi_request_t **ompi_req) ompi_req 2260 ompi/mca/osc/portals4/osc_portals4_comm.c *ompi_req = &request->super; ompi_req 2449 ompi/mca/osc/portals4/osc_portals4_comm.c struct ompi_request_t **ompi_req) ompi_req 2473 ompi/mca/osc/portals4/osc_portals4_comm.c *ompi_req = &request->super; ompi_req 27 ompi/mca/osc/portals4/osc_portals4_request.c request_free(struct ompi_request_t **ompi_req) ompi_req 30 ompi/mca/osc/portals4/osc_portals4_request.c (ompi_osc_portals4_request_t*) *ompi_req; ompi_req 38 ompi/mca/osc/portals4/osc_portals4_request.c *ompi_req = MPI_REQUEST_NULL; ompi_req 33 ompi/mca/osc/pt2pt/osc_pt2pt_request.c request_free(struct ompi_request_t **ompi_req) ompi_req 36 ompi/mca/osc/pt2pt/osc_pt2pt_request.c (ompi_osc_pt2pt_request_t*) *ompi_req; ompi_req 44 ompi/mca/osc/pt2pt/osc_pt2pt_request.c *ompi_req = MPI_REQUEST_NULL; ompi_req 31 ompi/mca/osc/rdma/osc_rdma_request.c static int request_free(struct ompi_request_t **ompi_req) ompi_req 34 ompi/mca/osc/rdma/osc_rdma_request.c (ompi_osc_rdma_request_t*) *ompi_req; ompi_req 42 ompi/mca/osc/rdma/osc_rdma_request.c *ompi_req = MPI_REQUEST_NULL; ompi_req 32 ompi/mca/osc/sm/osc_sm_comm.c struct ompi_request_t **ompi_req) ompi_req 57 ompi/mca/osc/sm/osc_sm_comm.c *ompi_req = &ompi_request_empty; ompi_req 72 ompi/mca/osc/sm/osc_sm_comm.c struct ompi_request_t **ompi_req) ompi_req 97 ompi/mca/osc/sm/osc_sm_comm.c *ompi_req = &ompi_request_empty; ompi_req 113 ompi/mca/osc/sm/osc_sm_comm.c struct ompi_request_t **ompi_req) ompi_req 144 ompi/mca/osc/sm/osc_sm_comm.c *ompi_req = &ompi_request_empty; ompi_req 164 ompi/mca/osc/sm/osc_sm_comm.c struct ompi_request_t **ompi_req) ompi_req 202 ompi/mca/osc/sm/osc_sm_comm.c *ompi_req = &ompi_request_empty; ompi_req 25 ompi/mca/osc/ucx/osc_ucx_request.c static int request_free(struct ompi_request_t **ompi_req) ompi_req 27 ompi/mca/osc/ucx/osc_ucx_request.c ompi_osc_ucx_request_t *request = (ompi_osc_ucx_request_t*) *ompi_req; ompi_req 35 ompi/mca/osc/ucx/osc_ucx_request.c *ompi_req = MPI_REQUEST_NULL; ompi_req 138 ompi/mca/pml/cm/pml_cm.h ompi_request_complete(mtl_request->ompi_req, true); ompi_req 162 ompi/mca/pml/cm/pml_cm.h req_mtl->ompi_req = &req.req_ompi; ompi_req 23 ompi/mca/pml/cm/pml_cm_cancel.c mca_pml_cm_cancel(struct ompi_request_t *ompi_req, int flag) ompi_req 27 ompi/mca/pml/cm/pml_cm_cancel.c (mca_pml_cm_request_t*) ompi_req; ompi_req 48 ompi/mca/pml/cm/pml_cm_recvreq.c (mca_pml_cm_request_t*) mtl_request->ompi_req; ompi_req 64 ompi/mca/pml/cm/pml_cm_recvreq.h recvreq->req_mtl.ompi_req = (ompi_request_t*) recvreq; \ ompi_req 73 ompi/mca/pml/cm/pml_cm_recvreq.h recvreq->req_mtl.ompi_req = (ompi_request_t*) recvreq; \ ompi_req 55 ompi/mca/pml/cm/pml_cm_sendreq.c (mca_pml_cm_send_request_t*) mtl_request->ompi_req; ompi_req 77 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_mtl.ompi_req = (ompi_request_t*) sendreq; \ ompi_req 88 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_mtl.ompi_req = (ompi_request_t*) sendreq; \ ompi_req 105 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_mtl.ompi_req = (ompi_request_t*) sendreq; \ ompi_req 116 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_mtl.ompi_req = (ompi_request_t*) sendreq; \ ompi_req 130 ompi/mca/pml/ucx/pml_ucx_request.c static void mca_pml_ucx_request_init_common(ompi_request_t* ompi_req, ompi_req 136 ompi/mca/pml/ucx/pml_ucx_request.c OMPI_REQUEST_INIT(ompi_req, req_persistent); ompi_req 137 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_type = OMPI_REQUEST_PML; ompi_req 138 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_state = state; ompi_req 139 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_start = mca_pml_ucx_start; ompi_req 140 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_free = req_free; ompi_req 141 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_cancel = req_cancel; ompi_req 147 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_complete_cb_data = NULL; ompi_req 152 ompi/mca/pml/ucx/pml_ucx_request.c ompi_request_t* ompi_req = request; ompi_req 153 ompi/mca/pml/ucx/pml_ucx_request.c OBJ_CONSTRUCT(ompi_req, ompi_request_t); ompi_req 154 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_request_init_common(ompi_req, false, OMPI_REQUEST_ACTIVE, ompi_req 161 ompi/mca/pml/ucx/pml_ucx_request.c ompi_request_t* ompi_req = request; ompi_req 162 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_state = OMPI_REQUEST_INVALID; ompi_req 163 ompi/mca/pml/ucx/pml_ucx_request.c OMPI_REQUEST_FINI(ompi_req); ompi_req 164 ompi/mca/pml/ucx/pml_ucx_request.c OBJ_DESTRUCT(ompi_req); ompi_req 221 ompi/mca/pml/ucx/pml_ucx_request.c static int mca_pml_completed_request_cancel(struct ompi_request_t* ompi_req, int flag) ompi_req 226 ompi/mca/pml/ucx/pml_ucx_request.c void mca_pml_ucx_completed_request_init(ompi_request_t *ompi_req) ompi_req 228 ompi/mca/pml/ucx/pml_ucx_request.c mca_pml_ucx_request_init_common(ompi_req, false, OMPI_REQUEST_ACTIVE, ompi_req 231 ompi/mca/pml/ucx/pml_ucx_request.c ompi_req->req_mpi_object.comm = &ompi_mpi_comm_world.comm; ompi_req 232 ompi/mca/pml/ucx/pml_ucx_request.c ompi_request_complete(ompi_req, false); ompi_req 132 ompi/mca/pml/ucx/pml_ucx_request.h void mca_pml_ucx_completed_request_init(ompi_request_t *ompi_req);