mxm 361 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_recv(&rreq->mxm); mxm 430 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.state = mxm_sreq->base.state; mxm 431 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.mq = mxm_sreq->base.mq; mxm 432 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.conn = mxm_sreq->base.conn; mxm 434 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data_type = MXM_REQ_DATA_BUFFER; mxm 438 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.ptr = mca_pml_base_bsend_request_alloc_buf(length); mxm 439 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.length = length; mxm 440 ompi/mca/pml/yalla/pml_yalla.c memcpy(bsreq->mxm.base.data.buffer.ptr, mxm_sreq->base.data.buffer.ptr, length); mxm 444 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.ptr = mca_pml_base_bsend_request_alloc_buf(length); mxm 445 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.data.buffer.length = length; mxm 446 ompi/mca/pml/yalla/pml_yalla.c mxm_sreq->base.data.stream.cb(bsreq->mxm.base.data.buffer.ptr, length, mxm 453 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.opcode = mxm_sreq->opcode; mxm 454 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.flags = mxm_sreq->flags; mxm 455 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.op.send = mxm_sreq->op.send; mxm 457 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&bsreq->mxm); mxm 486 ompi/mca/pml/yalla/pml_yalla.c rc = mca_pml_yalla_bsend(&sreq->mxm); mxm 493 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&sreq->mxm); mxm 649 ompi/mca/pml/yalla/pml_yalla.c error = mxm_message_recv(&rreq->mxm, (*message)->req_ptr); mxm 714 ompi/mca/pml/yalla/pml_yalla.c rc = mca_pml_yalla_bsend(&sreq->mxm); mxm 722 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_send(&sreq->mxm); mxm 733 ompi/mca/pml/yalla/pml_yalla.c error = mxm_req_recv(&rreq->mxm); mxm 74 ompi/mca/pml/yalla/pml_yalla_request.c error = mxm_req_cancel_send(&sreq->mxm); mxm 104 ompi/mca/pml/yalla/pml_yalla_request.c error = mxm_req_cancel_recv(&rreq->mxm); mxm 163 ompi/mca/pml/yalla/pml_yalla_request.c switch (sreq->mxm.base.error) { mxm 176 ompi/mca/pml/yalla/pml_yalla_request.c mxm_error_string(sreq->mxm.base.error)); mxm 190 ompi/mca/pml/yalla/pml_yalla_request.c mxm_error_string(bsreq->mxm.base.error)); mxm 192 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_base_bsend_request_free(bsreq->mxm.base.data.buffer.ptr); mxm 200 ompi/mca/pml/yalla/pml_yalla_request.c PML_YALLA_SET_RECV_STATUS(&rreq->mxm, rreq->mxm.completion.actual_len, mxm 204 ompi/mca/pml/yalla/pml_yalla_request.c (void *)rreq, mxm_error_string(rreq->mxm.base.error), mxm 205 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.completion.sender_imm, rreq->mxm.completion.sender_tag, mxm 206 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.tag, rreq->mxm.tag_mask, mxm 207 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.completion.actual_len); mxm 219 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_send_req(&sreq->mxm); mxm 222 ompi/mca/pml/yalla/pml_yalla_request.c sreq->mxm.base.context = sreq; mxm 223 ompi/mca/pml/yalla/pml_yalla_request.c sreq->mxm.base.completed_cb = mca_pml_yalla_send_completion_cb; mxm 233 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_send_req(&bsreq->mxm); mxm 234 ompi/mca/pml/yalla/pml_yalla_request.c bsreq->mxm.base.context = bsreq; mxm 235 ompi/mca/pml/yalla/pml_yalla_request.c bsreq->mxm.base.completed_cb = mca_pml_yalla_bsend_completion_cb; mxm 241 ompi/mca/pml/yalla/pml_yalla_request.c init_mxm_recv_req(&rreq->mxm); mxm 244 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.base.context = rreq; mxm 245 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.base.completed_cb = mca_pml_yalla_recv_completion_cb; mxm 32 ompi/mca/pml/yalla/pml_yalla_request.h mxm_send_req_t mxm; mxm 37 ompi/mca/pml/yalla/pml_yalla_request.h mxm_send_req_t mxm; mxm 42 ompi/mca/pml/yalla/pml_yalla_request.h mxm_recv_req_t mxm; mxm 52 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_MXM_REQBASE( x ) ( &((x)->mxm.base) ) mxm 135 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_RECV_REQ(&rreq->mxm, _buf, _count, _datatype, _src, _tag, _comm, irecv, rreq); mxm 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);