_rreq 93 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_RECV_REQ_ENVELOPE(_rreq, _rank, _tag, _comm) \ _rreq 95 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->base.conn = ((_rank) == MPI_ANY_SOURCE) ? NULL : PML_YALLA_PEER_CONN(_comm, _rank); \ _rreq 97 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->tag = 0; \ _rreq 98 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->tag_mask = 0x80000000u; \ _rreq 100 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->tag = _tag; \ _rreq 101 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->tag_mask = 0xffffffffu; \ _rreq 105 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_RECV_REQ(_rreq, _buf, _count, _dtype, _rank, _tag, _comm, _stream_type, ...) \ _rreq 107 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_REQ_BASE(&(_rreq)->base, _comm); \ _rreq 108 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_REQ_DATA(&(_rreq)->base, _buf, _count, _dtype, _stream_type, ## __VA_ARGS__); \ _rreq 109 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_RECV_REQ_ENVELOPE(_rreq, _rank, _tag, _comm); \ _rreq 118 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_BLOCKING_MXM_RECV_REQ(_rreq) \ _rreq 120 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->base.completed_cb = NULL; \ _rreq 151 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_PROBE_REQ(_rreq, _rank, _tag, _comm) \ _rreq 153 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_REQ_BASE(&(_rreq)->base, _comm); \ _rreq 154 ompi/mca/pml/yalla/pml_yalla_request.h PML_YALLA_INIT_MXM_RECV_REQ_ENVELOPE(_rreq, _rank, _tag, _comm); \ _rreq 178 ompi/mca/pml/yalla/pml_yalla_request.h static inline int PML_YALLA_SET_RECV_STATUS(mxm_recv_req_t *_rreq, _rreq 184 ompi/mca/pml/yalla/pml_yalla_request.h switch (_rreq->base.error) { _rreq 202 ompi/mca/pml/yalla/pml_yalla_request.h if (MXM_ERR_CANCELED == _rreq->base.error) { _rreq 205 ompi/mca/pml/yalla/pml_yalla_request.h _mpi_status->MPI_TAG = _rreq->completion.sender_tag; _rreq 206 ompi/mca/pml/yalla/pml_yalla_request.h _mpi_status->MPI_SOURCE = _rreq->completion.sender_imm; _rreq 212 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_SET_MESSAGE(_rreq, _comm, _mxm_msg, _message) \ _rreq 216 ompi/mca/pml/yalla/pml_yalla_request.h (*(_message))->count = (_rreq)->completion.sender_len; \ _rreq 217 ompi/mca/pml/yalla/pml_yalla_request.h (*(_message))->peer = (_rreq)->completion.sender_imm; \