put_req 97 oshmem/mca/spml/ikrit/spml_ikrit.c static inline void free_put_req(mca_spml_ikrit_put_request_t *put_req) put_req 100 oshmem/mca/spml/ikrit/spml_ikrit.c (opal_free_list_item_t*)put_req); put_req 101 oshmem/mca/spml/ikrit/spml_ikrit.c opal_memchecker_base_mem_noaccess(put_req, sizeof(*put_req)); put_req 769 oshmem/mca/spml/ikrit/spml_ikrit.c mca_spml_ikrit_put_request_t *put_req = (mca_spml_ikrit_put_request_t *) ctx; put_req 774 oshmem/mca/spml/ikrit/spml_ikrit.c peer = &mca_spml_ikrit.mxm_peers[put_req->pe]; put_req 781 oshmem/mca/spml/ikrit/spml_ikrit.c SPML_VERBOSE(1, "pe %d n_active_puts %d", put_req->pe, peer->n_active_puts); put_req 785 oshmem/mca/spml/ikrit/spml_ikrit.c if (put_req->mxm_req.base.state != MXM_REQ_COMPLETED) put_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); put_req 792 oshmem/mca/spml/ikrit/spml_ikrit.c (put_req->mxm_req.opcode == MXM_REQ_OP_PUT_SYNC)) { put_req 798 oshmem/mca/spml/ikrit/spml_ikrit.c free_put_req(put_req); put_req 812 oshmem/mca/spml/ikrit/spml_ikrit.c mca_spml_ikrit_put_request_t *put_req; put_req 836 oshmem/mca/spml/ikrit/spml_ikrit.c put_req = alloc_put_req(); put_req 839 oshmem/mca/spml/ikrit/spml_ikrit.c *handle = put_req; put_req 842 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.mq = mca_spml_ikrit.mxm_mq; put_req 845 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.flags = 0; put_req 850 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.opcode = MXM_REQ_OP_PUT_SYNC; put_req 852 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.opcode = MXM_REQ_OP_PUT; put_req 856 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.flags |= MXM_REQ_SEND_FLAG_BLOCKING; put_req 858 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.opcode = MXM_REQ_OP_PUT_SYNC; put_req 862 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn; put_req 863 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.data_type = MXM_REQ_DATA_BUFFER; put_req 864 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.data.buffer.ptr = src_addr; put_req 865 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.data.buffer.length = size; put_req 866 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.completed_cb = put_completion_cb; put_req 867 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.context = put_req; put_req 868 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.op.mem.remote_vaddr = (intptr_t) rva; put_req 869 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.state = MXM_REQ_NEW; put_req 870 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->pe = dst; put_req 872 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.op.mem.remote_mkey = mkey; put_req 883 oshmem/mca/spml/ikrit/spml_ikrit.c SPML_IKRIT_MXM_POST_SEND(put_req->mxm_req); put_req 979 oshmem/mca/spml/ikrit/spml_ikrit.c mca_spml_ikrit_put_request_t *put_req; put_req 982 oshmem/mca/spml/ikrit/spml_ikrit.c put_req = 0; put_req 987 oshmem/mca/spml/ikrit/spml_ikrit.c (void **) &put_req, put_req 994 oshmem/mca/spml/ikrit/spml_ikrit.c if (!put_req) put_req 997 oshmem/mca/spml/ikrit/spml_ikrit.c wait.req = &put_req->mxm_req.base;