_sreq 83 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_SEND_REQ(_sreq, _buf, _count, _dtype, _rank, _tag, _mode, _comm, _stream_type, ...) \ _sreq 85 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_REQ_BASE(&(_sreq)->base, _comm); \ _sreq 86 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_REQ_DATA(&(_sreq)->base, _buf, _count, _dtype, _stream_type, ## __VA_ARGS__); \ _sreq 87 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->base.conn = PML_YALLA_PEER_CONN(_comm, _rank); \ _sreq 88 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->opcode = ((_mode) == MCA_PML_BASE_SEND_SYNCHRONOUS) ? MXM_REQ_OP_SEND_SYNC : MXM_REQ_OP_SEND; \ _sreq 89 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->op.send.tag = _tag; \ _sreq 90 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->op.send.imm_data = ompi_comm_rank(_comm); \ _sreq 112 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_BLOCKING_MXM_SEND_REQ(_sreq) \ _sreq 114 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->base.completed_cb = NULL; \ _sreq 115 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->flags = MXM_REQ_SEND_FLAG_BLOCKING; \