bsreq 424 ompi/mca/pml/yalla/pml_yalla.c mca_pml_yalla_bsend_request_t *bsreq = (mca_pml_yalla_bsend_request_t *)PML_YALLA_FREELIST_GET(&ompi_pml_yalla.bsend_reqs); bsreq 430 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.state = mxm_sreq->base.state; bsreq 431 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.mq = mxm_sreq->base.mq; bsreq 432 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.conn = mxm_sreq->base.conn; bsreq 434 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data_type = MXM_REQ_DATA_BUFFER; bsreq 438 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.ptr = mca_pml_base_bsend_request_alloc_buf(length); bsreq 439 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.length = length; bsreq 440 ompi/mca/pml/yalla/pml_yalla.c memcpy(bsreq->mxm.base.data.buffer.ptr, mxm_sreq->base.data.buffer.ptr, length); bsreq 444 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.ptr = mca_pml_base_bsend_request_alloc_buf(length); bsreq 445 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.length = length; bsreq 446 ompi/mca/pml/yalla/pml_yalla.c mxm_sreq->base.data.stream.cb(bsreq->mxm.base.data.buffer.ptr, length, bsreq 453 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.opcode = mxm_sreq->opcode; bsreq 454 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.flags = mxm_sreq->flags; bsreq 455 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.op.send = mxm_sreq->op.send; bsreq 457 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&bsreq->mxm); bsreq 187 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_bsend_request_t *bsreq = context; bsreq 189 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_VERBOSE(8, "bsend request %p completed with status %s", (void *)bsreq, bsreq 190 ompi/mca/pml/yalla/pml_yalla_request.c mxm_error_string(bsreq->mxm.base.error)); bsreq 192 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_base_bsend_request_free(bsreq->mxm.base.data.buffer.ptr); bsreq 193 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_FREELIST_RETURN(&ompi_pml_yalla.bsend_reqs, &bsreq->super); bsreq 231 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_bsend_request_construct(mca_pml_yalla_bsend_request_t* bsreq) bsreq 233 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_send_req(&bsreq->mxm); bsreq 234 ompi/mca/pml/yalla/pml_yalla_request.c bsreq->mxm.base.context = bsreq; bsreq 235 ompi/mca/pml/yalla/pml_yalla_request.c bsreq->mxm.base.completed_cb = mca_pml_yalla_bsend_completion_cb;