mxm_req            43 ompi/mca/pml/yalla/pml_yalla_datatype.c static void mca_pml_yalla_noncontig_req_init(mxm_req_base_t *mxm_req,
mxm_req            47 ompi/mca/pml/yalla/pml_yalla_datatype.c     mxm_req->data_type      = MXM_REQ_DATA_STREAM;
mxm_req            48 ompi/mca/pml/yalla/pml_yalla_datatype.c     mxm_req->data.stream.cb = stream_cb;
mxm_req            49 ompi/mca/pml/yalla/pml_yalla_datatype.c     opal_convertor_get_packed_size(&convertor->convertor, &mxm_req->data.stream.length);
mxm_req           110 ompi/mca/pml/yalla/pml_yalla_datatype.c void mca_pml_yalla_set_noncontig_data_irecv(mxm_req_base_t *mxm_req, void *buf,
mxm_req           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);
mxm_req           118 ompi/mca/pml/yalla/pml_yalla_datatype.c void mca_pml_yalla_set_noncontig_data_recv(mxm_req_base_t *mxm_req, void *buf,
mxm_req           124 ompi/mca/pml/yalla/pml_yalla_datatype.c     mca_pml_yalla_noncontig_req_init(mxm_req, convertor, mxm_pml_yalla_recv_stream_cb);
mxm_req           125 ompi/mca/pml/yalla/pml_yalla_datatype.c     mxm_req->context = convertor;
mxm_req           128 ompi/mca/pml/yalla/pml_yalla_datatype.c void mca_pml_yalla_set_noncontig_data_isend(mxm_req_base_t *mxm_req, void *buf,
mxm_req           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);
mxm_req           136 ompi/mca/pml/yalla/pml_yalla_datatype.c void mca_pml_yalla_set_noncontig_data_send(mxm_req_base_t *mxm_req, void *buf,
mxm_req           142 ompi/mca/pml/yalla/pml_yalla_datatype.c     mca_pml_yalla_noncontig_req_init(mxm_req, convertor, mxm_pml_yalla_send_stream_cb);
mxm_req           143 ompi/mca/pml/yalla/pml_yalla_datatype.c     mxm_req->context = convertor;
mxm_req            59 ompi/mca/pml/yalla/pml_yalla_datatype.h void mca_pml_yalla_set_noncontig_data_irecv(mxm_req_base_t *mxm_req, void *buf,
mxm_req            63 ompi/mca/pml/yalla/pml_yalla_datatype.h void mca_pml_yalla_set_noncontig_data_recv(mxm_req_base_t *mxm_req, void *buf,
mxm_req            66 ompi/mca/pml/yalla/pml_yalla_datatype.h void mca_pml_yalla_set_noncontig_data_isend(mxm_req_base_t *mxm_req, void *buf,
mxm_req            70 ompi/mca/pml/yalla/pml_yalla_datatype.h void mca_pml_yalla_set_noncontig_data_send(mxm_req_base_t *mxm_req, void *buf,
mxm_req            66 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_send_req_t          mxm_req;
mxm_req           121 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_send_req_t          mxm_req;
mxm_req           715 oshmem/mca/spml/ikrit/spml_ikrit.c     if (OSHMEM_SUCCESS != mca_spml_ikrit_get_helper(&get_req->mxm_req,
mxm_req           724 oshmem/mca/spml/ikrit/spml_ikrit.c     get_req->mxm_req.flags = 0;
mxm_req           725 oshmem/mca/spml/ikrit/spml_ikrit.c     get_req->mxm_req.base.completed_cb = get_completion_cb;
mxm_req           726 oshmem/mca/spml/ikrit/spml_ikrit.c     get_req->mxm_req.base.context = get_req;
mxm_req           729 oshmem/mca/spml/ikrit/spml_ikrit.c     SPML_IKRIT_MXM_POST_SEND(get_req->mxm_req);
mxm_req           749 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.mq = mca_spml_ikrit.mxm_mq;
mxm_req           750 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn;
mxm_req           751 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.opcode = MXM_REQ_OP_PUT_SYNC;
mxm_req           752 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.flags  = MXM_REQ_SEND_FLAG_FENCE;
mxm_req           753 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.op.mem.remote_vaddr = 0;
mxm_req           754 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.op.mem.remote_mkey  = &mxm_empty_mem_key;
mxm_req           755 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.data_type      = MXM_REQ_DATA_BUFFER;
mxm_req           756 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.data.buffer.ptr    = 0;
mxm_req           757 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.data.buffer.length = 0;
mxm_req           758 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.state = MXM_REQ_NEW;
mxm_req           759 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.completed_cb = fence_completion_cb;
mxm_req           760 oshmem/mca/spml/ikrit/spml_ikrit.c     fence_req->mxm_req.base.context = fence_req;
mxm_req           763 oshmem/mca/spml/ikrit/spml_ikrit.c     SPML_IKRIT_MXM_POST_SEND(fence_req->mxm_req);
mxm_req           785 oshmem/mca/spml/ikrit/spml_ikrit.c     if (put_req->mxm_req.base.state != MXM_REQ_COMPLETED)
mxm_req           786 oshmem/mca/spml/ikrit/spml_ikrit.c     SPML_ERROR("oops: pe %d uncompleted request state %d", put_req->pe, put_req->mxm_req.base.state);
mxm_req           792 oshmem/mca/spml/ikrit/spml_ikrit.c                 (put_req->mxm_req.opcode == MXM_REQ_OP_PUT_SYNC)) {
mxm_req           842 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.mq = mca_spml_ikrit.mxm_mq;
mxm_req           845 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.flags = 0;
mxm_req           850 oshmem/mca/spml/ikrit/spml_ikrit.c         put_req->mxm_req.opcode = MXM_REQ_OP_PUT_SYNC;
mxm_req           852 oshmem/mca/spml/ikrit/spml_ikrit.c         put_req->mxm_req.opcode = MXM_REQ_OP_PUT;
mxm_req           856 oshmem/mca/spml/ikrit/spml_ikrit.c             put_req->mxm_req.flags |= MXM_REQ_SEND_FLAG_BLOCKING;
mxm_req           858 oshmem/mca/spml/ikrit/spml_ikrit.c             put_req->mxm_req.opcode = MXM_REQ_OP_PUT_SYNC;
mxm_req           862 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn;
mxm_req           863 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.data_type = MXM_REQ_DATA_BUFFER;
mxm_req           864 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.data.buffer.ptr = src_addr;
mxm_req           865 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.data.buffer.length = size;
mxm_req           866 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.completed_cb = put_completion_cb;
mxm_req           867 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.context = put_req;
mxm_req           868 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.op.mem.remote_vaddr = (intptr_t) rva;
mxm_req           869 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.base.state = MXM_REQ_NEW;
mxm_req           872 oshmem/mca/spml/ikrit/spml_ikrit.c     put_req->mxm_req.op.mem.remote_mkey = mkey; 
mxm_req           883 oshmem/mca/spml/ikrit/spml_ikrit.c     SPML_IKRIT_MXM_POST_SEND(put_req->mxm_req);
mxm_req           903 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_send_req_t mxm_req;
mxm_req           927 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.mq = mca_spml_ikrit.mxm_mq;
mxm_req           928 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.flags = MXM_REQ_SEND_FLAG_BLOCKING;
mxm_req           929 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn;
mxm_req           930 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.data_type = MXM_REQ_DATA_BUFFER;
mxm_req           931 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.data.buffer.ptr = src_addr;
mxm_req           932 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.data.buffer.length = size;
mxm_req           933 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.completed_cb = 0;
mxm_req           934 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.context = 0;
mxm_req           935 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.opcode = MXM_REQ_OP_PUT;
mxm_req           936 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.op.mem.remote_vaddr = (intptr_t) rva;
mxm_req           937 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.state = MXM_REQ_NEW;
mxm_req           938 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.base.error = MXM_OK;
mxm_req           940 oshmem/mca/spml/ikrit/spml_ikrit.c     mxm_req.op.mem.remote_mkey = mkey;
mxm_req           948 oshmem/mca/spml/ikrit/spml_ikrit.c     SPML_IKRIT_MXM_POST_SEND(mxm_req);
mxm_req           950 oshmem/mca/spml/ikrit/spml_ikrit.c     wait.req = &mxm_req.base;
mxm_req           997 oshmem/mca/spml/ikrit/spml_ikrit.c     wait.req = &put_req->mxm_req.base;