sreq 580 ompi/mca/coll/base/coll_base_alltoall.c ompi_request_t **req, **sreq, **rreq; sreq 648 ompi/mca/coll/base/coll_base_alltoall.c sreq = rreq; sreq 650 ompi/mca/coll/base/coll_base_alltoall.c i = (i + size - 1) % size, ++sreq) { sreq 655 ompi/mca/coll/base/coll_base_alltoall.c MCA_PML_BASE_SEND_STANDARD, comm, sreq)); sreq 73 ompi/mca/coll/base/coll_base_reduce.c ompi_request_t **sreq = NULL, *reqs[2] = {MPI_REQUEST_NULL, MPI_REQUEST_NULL}; sreq 294 ompi/mca/coll/base/coll_base_reduce.c sreq = ompi_coll_base_comm_get_reqs(module->base_data, max_outstanding_reqs); sreq 295 ompi/mca/coll/base/coll_base_reduce.c if (NULL == sreq) { line = __LINE__; ret = -1; goto error_hndl; } sreq 305 ompi/mca/coll/base/coll_base_reduce.c &sreq[segindex]) ); sreq 313 ompi/mca/coll/base/coll_base_reduce.c ret = ompi_request_wait(&sreq[creq], MPI_STATUS_IGNORE); sreq 325 ompi/mca/coll/base/coll_base_reduce.c &sreq[creq]) ); sreq 333 ompi/mca/coll/base/coll_base_reduce.c ret = ompi_request_wait_all( max_outstanding_reqs, sreq, sreq 351 ompi/mca/coll/base/coll_base_reduce.c if( NULL != sreq ) { sreq 354 ompi/mca/coll/base/coll_base_reduce.c if (MPI_REQUEST_NULL == sreq[i]) continue; sreq 355 ompi/mca/coll/base/coll_base_reduce.c if (MPI_ERR_PENDING == sreq[i]->req_status.MPI_ERROR) continue; sreq 356 ompi/mca/coll/base/coll_base_reduce.c ret = sreq[i]->req_status.MPI_ERROR; sreq 360 ompi/mca/coll/base/coll_base_reduce.c ompi_coll_base_free_reqs(sreq, max_outstanding_reqs); sreq 61 ompi/mca/coll/basic/coll_basic_alltoall.c ompi_request_t **req, **sreq, **rreq; sreq 83 ompi/mca/coll/basic/coll_basic_alltoall.c sreq = rreq + size; sreq 99 ompi/mca/coll/basic/coll_basic_alltoall.c for (i = 0; i < size; i++, ++sreq) { sreq 102 ompi/mca/coll/basic/coll_basic_alltoall.c MCA_PML_BASE_SEND_STANDARD, comm, sreq)); sreq 406 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_send_request_t *sreq; sreq 408 ompi/mca/pml/yalla/pml_yalla.c sreq = MCA_PML_YALLA_SREQ_INIT((void *)buf, count, datatype, dst, tag, mode, comm, sreq 410 ompi/mca/pml/yalla/pml_yalla.c sreq->super.ompi.req_persistent = true; sreq 411 ompi/mca/pml/yalla/pml_yalla.c sreq->super.flags = MCA_PML_YALLA_REQUEST_FLAG_SEND; sreq 413 ompi/mca/pml/yalla/pml_yalla.c sreq->super.flags |= MCA_PML_YALLA_REQUEST_FLAG_BSEND; sreq 416 ompi/mca/pml/yalla/pml_yalla.c *request = &sreq->super.ompi; sreq 473 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_send_request_t *sreq; sreq 477 ompi/mca/pml/yalla/pml_yalla.c sreq = MCA_PML_YALLA_SREQ_INIT((void *)buf, count, datatype, dst, tag, mode, comm, sreq 479 ompi/mca/pml/yalla/pml_yalla.c sreq->super.ompi.req_persistent = false; sreq 480 ompi/mca/pml/yalla/pml_yalla.c sreq->super.flags = 0; sreq 483 ompi/mca/pml/yalla/pml_yalla.c (void *)request, (void *)sreq, dst, mode, tag, datatype->name, count); sreq 486 ompi/mca/pml/yalla/pml_yalla.c rc = mca_pml_yalla_bsend(&sreq->mxm); sreq 487 ompi/mca/pml/yalla/pml_yalla.c sreq->super.ompi.req_status.MPI_ERROR = rc; sreq 488 ompi/mca/pml/yalla/pml_yalla.c ompi_request_complete(&sreq->super.ompi, true); sreq 489 ompi/mca/pml/yalla/pml_yalla.c *request = &sreq->super.ompi; sreq 493 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&sreq->mxm); sreq 498 ompi/mca/pml/yalla/pml_yalla.c *request = &sreq->super.ompi; sreq 506 ompi/mca/pml/yalla/pml_yalla.c mxm_send_req_t sreq; sreq 509 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_MXM_SEND_REQ(&sreq, (void *)buf, count, datatype, dst, tag, mode, comm, send); sreq 510 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_INIT_BLOCKING_MXM_SEND_REQ(&sreq); sreq 516 ompi/mca/pml/yalla/pml_yalla.c return mca_pml_yalla_bsend(&sreq); sreq 519 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&sreq); sreq 524 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_WAIT_MXM_REQ(&sreq.base); sreq 525 ompi/mca/pml/yalla/pml_yalla.c if (MXM_OK != sreq.base.error) { sreq 529 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_FREE_BLOCKING_MXM_REQ(&sreq.base); sreq 708 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_send_request_t *sreq; sreq 709 ompi/mca/pml/yalla/pml_yalla.c sreq = (mca_pml_yalla_send_request_t *)req; sreq 710 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_RESET_PML_REQ(req, PML_YALLA_MXM_REQBASE(sreq)); sreq 713 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_VERBOSE(8, "start bsend request %p", (void *)sreq); sreq 714 ompi/mca/pml/yalla/pml_yalla.c rc = mca_pml_yalla_bsend(&sreq->mxm); sreq 715 ompi/mca/pml/yalla/pml_yalla.c sreq->super.ompi.req_status.MPI_ERROR = rc; sreq 716 ompi/mca/pml/yalla/pml_yalla.c ompi_request_complete(&sreq->super.ompi, true); sreq 721 ompi/mca/pml/yalla/pml_yalla.c PML_YALLA_VERBOSE(8, "start send request %p", (void *)sreq); sreq 722 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&sreq->mxm); sreq 130 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_send_request_t *sreq) sreq 132 ompi/mca/pml/yalla/pml_yalla_datatype.c sreq->super.convertor = mca_pml_yalla_get_send_convertor(buf, count, datatype); sreq 133 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_noncontig_req_init(mxm_req, sreq->super.convertor, mxm_pml_yalla_isend_stream_cb); sreq 68 ompi/mca/pml/yalla/pml_yalla_datatype.h mca_pml_yalla_send_request_t *sreq); sreq 48 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_send_request_t *sreq = (mca_pml_yalla_send_request_t*)(*request); sreq 52 ompi/mca/pml/yalla/pml_yalla_request.c if (mca_pml_yalla_check_request_state(&sreq->super, PML_YALLA_MXM_REQBASE(sreq))) { sreq 53 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_request_release(&sreq->super, &ompi_pml_yalla.send_reqs); sreq 62 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_send_request_t *sreq = (mca_pml_yalla_send_request_t*)request; sreq 74 ompi/mca/pml/yalla/pml_yalla_request.c error = mxm_req_cancel_send(&sreq->mxm); sreq 161 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_send_request_t* sreq = context; sreq 163 ompi/mca/pml/yalla/pml_yalla_request.c switch (sreq->mxm.base.error) { sreq 165 ompi/mca/pml/yalla/pml_yalla_request.c sreq->super.ompi.req_status.MPI_ERROR = OMPI_SUCCESS; sreq 168 ompi/mca/pml/yalla/pml_yalla_request.c sreq->super.ompi.req_status._cancelled = true; sreq 171 ompi/mca/pml/yalla/pml_yalla_request.c sreq->super.ompi.req_status.MPI_ERROR = MPI_ERR_INTERN; sreq 175 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_VERBOSE(8, "send request %p completed with status %s", (void *)sreq, sreq 176 ompi/mca/pml/yalla/pml_yalla_request.c mxm_error_string(sreq->mxm.base.error)); sreq 178 ompi/mca/pml/yalla/pml_yalla_request.c ompi_request_complete(&sreq->super.ompi, true); sreq 179 ompi/mca/pml/yalla/pml_yalla_request.c if (sreq->super.flags & MCA_PML_YALLA_REQUEST_FLAG_FREE_CALLED) { sreq 180 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_VERBOSE(7, "release request %p because free was already called", (void *)sreq); sreq 181 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_request_release(&sreq->super, &ompi_pml_yalla.send_reqs); sreq 216 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_send_request_construct(mca_pml_yalla_send_request_t* sreq) sreq 218 ompi/mca/pml/yalla/pml_yalla_request.c init_base_req(&sreq->super); sreq 219 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_send_req(&sreq->mxm); sreq 220 ompi/mca/pml/yalla/pml_yalla_request.c sreq->super.ompi.req_free = mca_pml_yalla_send_request_free; sreq 221 ompi/mca/pml/yalla/pml_yalla_request.c sreq->super.ompi.req_cancel = mca_pml_yalla_send_request_cancel; sreq 222 ompi/mca/pml/yalla/pml_yalla_request.c sreq->mxm.base.context = sreq; sreq 223 ompi/mca/pml/yalla/pml_yalla_request.c sreq->mxm.base.completed_cb = mca_pml_yalla_send_completion_cb; sreq 226 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_send_request_destruct(mca_pml_yalla_send_request_t *sreq) sreq 228 ompi/mca/pml/yalla/pml_yalla_request.c OMPI_REQUEST_FINI(&sreq->super.ompi); sreq 142 ompi/mca/pml/yalla/pml_yalla_request.h mca_pml_yalla_send_request_t *sreq = (mca_pml_yalla_send_request_t *)PML_YALLA_FREELIST_GET(&ompi_pml_yalla.send_reqs); sreq 143 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_OMPI_REQ(&sreq->super.ompi, _comm, _state); sreq 144 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_SEND_REQ(&sreq->mxm, _buf, _count, _datatype, _dst, _tag, _mode, _comm, isend, sreq); sreq 145 ompi/mca/pml/yalla/pml_yalla_request.h sreq->super.ompi.req_status.MPI_TAG = _tag; sreq 146 ompi/mca/pml/yalla/pml_yalla_request.h sreq->super.ompi.req_status.MPI_SOURCE = (_comm)->c_my_rank; sreq 147 ompi/mca/pml/yalla/pml_yalla_request.h sreq->super.ompi.req_status._ucount = _count; sreq 148 ompi/mca/pml/yalla/pml_yalla_request.h return sreq; sreq 100 oshmem/mca/atomic/mxm/atomic_mxm.h static inline void mca_atomic_mxm_req_init(mxm_send_req_t *sreq, int pe, void *target, size_t nlong) sreq 111 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.state = MXM_REQ_NEW; sreq 112 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.mq = mca_atomic_mxm_spml_self->mxm_mq; sreq 113 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.conn = mca_atomic_mxm_spml_self->mxm_peers[pe].mxm_hw_rdma_conn; sreq 114 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.completed_cb = NULL; sreq 115 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.data_type = MXM_REQ_DATA_BUFFER; sreq 117 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.data.buffer.memh = MXM_INVALID_MEM_HANDLE; sreq 118 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.data.buffer.length = nlong; sreq 120 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->op.atomic.remote_vaddr = (uintptr_t) remote_addr; sreq 121 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->op.atomic.remote_mkey = mkey; sreq 122 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->op.atomic.order = nlong_order; sreq 124 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->flags = 0; sreq 127 oshmem/mca/atomic/mxm/atomic_mxm.h static inline void mca_atomic_mxm_post(mxm_send_req_t *sreq) sreq 131 oshmem/mca/atomic/mxm/atomic_mxm.h mxm_err = mxm_req_send(sreq); sreq 138 oshmem/mca/atomic/mxm/atomic_mxm.h mxm_req_wait(&sreq->base); sreq 139 oshmem/mca/atomic/mxm/atomic_mxm.h if (OPAL_UNLIKELY(MXM_OK != sreq->base.error)) { sreq 141 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.error); sreq 34 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c mxm_send_req_t sreq; sreq 36 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c mca_atomic_mxm_req_init(&sreq, pe, target, nlong); sreq 39 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c sreq.base.data.buffer.ptr = prev; sreq 40 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c sreq.opcode = MXM_REQ_OP_ATOMIC_SWAP; sreq 42 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c mca_atomic_mxm_post(&sreq); sreq 55 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c mxm_send_req_t sreq; sreq 57 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c mca_atomic_mxm_req_init(&sreq, pe, target, nlong); sreq 60 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c sreq.op.atomic.value = cond; sreq 61 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c sreq.base.data.buffer.ptr = prev; sreq 62 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c sreq.opcode = MXM_REQ_OP_ATOMIC_CSWAP; sreq 64 oshmem/mca/atomic/mxm/atomic_mxm_cswap.c mca_atomic_mxm_post(&sreq); sreq 34 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c mxm_send_req_t sreq; sreq 37 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c mca_atomic_mxm_req_init(&sreq, pe, target, size); sreq 39 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c sreq.op.atomic.value = value; sreq 40 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c sreq.opcode = MXM_REQ_OP_ATOMIC_FADD; sreq 41 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c sreq.base.data.buffer.ptr = dummy_buf; sreq 43 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c mca_atomic_mxm_post(&sreq); sreq 55 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c mxm_send_req_t sreq; sreq 57 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c mca_atomic_mxm_req_init(&sreq, pe, target, size); sreq 59 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c sreq.op.atomic.value = value; sreq 60 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c sreq.opcode = MXM_REQ_OP_ATOMIC_FADD; sreq 61 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c sreq.base.data.buffer.ptr = prev; sreq 63 oshmem/mca/atomic/mxm/atomic_mxm_fadd.c mca_atomic_mxm_post(&sreq); sreq 44 oshmem/mca/spml/ikrit/spml_ikrit.c #define SPML_IKRIT_MXM_POST_SEND(sreq) \ sreq 47 oshmem/mca/spml/ikrit/spml_ikrit.c err = mxm_req_send(&sreq); \ sreq 50 oshmem/mca/spml/ikrit/spml_ikrit.c sreq.opcode, \ sreq 591 oshmem/mca/spml/ikrit/spml_ikrit.c static inline int mca_spml_ikrit_get_helper(mxm_send_req_t *sreq, sreq 609 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.mq = mca_spml_ikrit.mxm_mq; sreq 610 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.conn = mca_spml_ikrit.mxm_peers[src].mxm_conn; sreq 611 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.data_type = MXM_REQ_DATA_BUFFER; sreq 612 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.data.buffer.ptr = dst_addr; sreq 613 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.data.buffer.length = size; sreq 614 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->op.mem.remote_mkey = mkey; sreq 615 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->opcode = MXM_REQ_OP_GET; sreq 616 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->op.mem.remote_vaddr = (intptr_t) rva; sreq 617 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.state = MXM_REQ_NEW; sreq 661 oshmem/mca/spml/ikrit/spml_ikrit.c mxm_send_req_t sreq; sreq 671 oshmem/mca/spml/ikrit/spml_ikrit.c != mca_spml_ikrit_get_helper(&sreq, sreq 680 oshmem/mca/spml/ikrit/spml_ikrit.c sreq.base.completed_cb = NULL; sreq 681 oshmem/mca/spml/ikrit/spml_ikrit.c sreq.flags = 0; sreq 683 oshmem/mca/spml/ikrit/spml_ikrit.c SPML_IKRIT_MXM_POST_SEND(sreq); sreq 685 oshmem/mca/spml/ikrit/spml_ikrit.c mca_spml_irkit_req_wait(&sreq.base); sreq 686 oshmem/mca/spml/ikrit/spml_ikrit.c if (MXM_OK != sreq.base.error) { sreq 688 oshmem/mca/spml/ikrit/spml_ikrit.c mxm_error_string(sreq.base.error)); sreq 263 test/datatype/to_self.c MPI_Request sreq, rreq; sreq 277 test/datatype/to_self.c MPI_Isend( sbuf, scount, sdt, myself, tag, MPI_COMM_WORLD, &sreq ); sreq 279 test/datatype/to_self.c MPI_Wait( &sreq, &status ); sreq 284 test/datatype/to_self.c ftmpi_mpi_isend( sbuf, scount, sdt, myself, tag, MPI_COMM_WORLD, &sreq ); sreq 286 test/datatype/to_self.c ftmpi_wait( &sreq, &status ); sreq 287 test/datatype/to_self.c ftmpi_request_free( &sreq ); sreq 301 test/datatype/to_self.c MPI_Request sreq, rreq; sreq 316 test/datatype/to_self.c MPI_Isend( sbuf, scount, sdt, myself, tag, MPI_COMM_WORLD, &sreq ); sreq 317 test/datatype/to_self.c MPI_Wait( &sreq, &status ); sreq 323 test/datatype/to_self.c ftmpi_mpi_isend( sbuf, scount, sdt, myself, tag, MPI_COMM_WORLD, &sreq ); sreq 324 test/datatype/to_self.c ftmpi_wait( &sreq, &status ); sreq 325 test/datatype/to_self.c ftmpi_request_free( &sreq );