mxm_sreq 422 ompi/mca/pml/yalla/pml_yalla.c static int mca_pml_yalla_bsend(mxm_send_req_t *mxm_sreq) mxm_sreq 430 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.state = mxm_sreq->base.state; mxm_sreq 431 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.mq = mxm_sreq->base.mq; mxm_sreq 432 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.conn = mxm_sreq->base.conn; mxm_sreq 435 ompi/mca/pml/yalla/pml_yalla.c switch (mxm_sreq->base.data_type) { mxm_sreq 437 ompi/mca/pml/yalla/pml_yalla.c length = mxm_sreq->base.data.buffer.length; mxm_sreq 440 ompi/mca/pml/yalla/pml_yalla.c memcpy(bsreq->mxm.base.data.buffer.ptr, mxm_sreq->base.data.buffer.ptr, length); mxm_sreq 443 ompi/mca/pml/yalla/pml_yalla.c length = mxm_sreq->base.data.stream.length; mxm_sreq 446 ompi/mca/pml/yalla/pml_yalla.c mxm_sreq->base.data.stream.cb(bsreq->mxm.base.data.buffer.ptr, length, mxm_sreq 447 ompi/mca/pml/yalla/pml_yalla.c 0, mxm_sreq->base.context); mxm_sreq 453 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.opcode = mxm_sreq->opcode; mxm_sreq 454 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.flags = mxm_sreq->flags; mxm_sreq 455 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.op.send = mxm_sreq->op.send; mxm_sreq 463 ompi/mca/pml/yalla/pml_yalla.c mxm_sreq->base.state = MXM_REQ_COMPLETED; mxm_sreq 128 ompi/mca/pml/yalla/pml_yalla_request.c static void init_mxm_send_req(mxm_send_req_t *mxm_sreq) mxm_sreq 130 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_base_req(&mxm_sreq->base); mxm_sreq 131 ompi/mca/pml/yalla/pml_yalla_request.c mxm_sreq->opcode = MXM_REQ_OP_SEND; mxm_sreq 132 ompi/mca/pml/yalla/pml_yalla_request.c mxm_sreq->op.send.imm_data = 0; mxm_sreq 133 ompi/mca/pml/yalla/pml_yalla_request.c mxm_sreq->op.send.tag = 0; mxm_sreq 135 ompi/mca/pml/yalla/pml_yalla_request.c mxm_sreq->flags = MXM_REQ_SEND_FLAG_REENTRANT; mxm_sreq 137 ompi/mca/pml/yalla/pml_yalla_request.c mxm_sreq->flags = 0;