_comm              28 ompi/mca/pml/ucx/pml_ucx.c #define PML_UCX_TRACE_SEND(_msg, _buf, _count, _datatype, _dst, _tag, _mode, _comm, ...) \
_comm              32 ompi/mca/pml/ucx/pml_ucx.c                     mca_pml_ucx_send_mode_name(_mode), (_comm)->c_contextid, \
_comm              33 ompi/mca/pml/ucx/pml_ucx.c                     (_comm)->c_name);
_comm              35 ompi/mca/pml/ucx/pml_ucx.c #define PML_UCX_TRACE_RECV(_msg, _buf, _count, _datatype, _src, _tag, _comm, ...) \
_comm              39 ompi/mca/pml/ucx/pml_ucx.c                     (_comm)->c_contextid, (_comm)->c_name);
_comm              41 ompi/mca/pml/ucx/pml_ucx.c #define PML_UCX_TRACE_PROBE(_msg, _src, _tag, _comm) \
_comm              43 ompi/mca/pml/ucx/pml_ucx.c                     _src, (_tag), (_comm)->c_contextid, (_comm)->c_name);
_comm              42 ompi/mca/pml/ucx/pml_ucx_request.h #define PML_UCX_MAKE_SEND_TAG(_tag, _comm) \
_comm              44 ompi/mca/pml/ucx/pml_ucx_request.h      (((uint64_t)(_comm)->c_my_rank ) << PML_UCX_CONTEXT_BITS) | \
_comm              45 ompi/mca/pml/ucx/pml_ucx_request.h      ((uint64_t)(_comm)->c_contextid))
_comm              48 ompi/mca/pml/ucx/pml_ucx_request.h #define PML_UCX_MAKE_RECV_TAG(_ucp_tag, _ucp_tag_mask, _tag, _src, _comm) \
_comm              57 ompi/mca/pml/ucx/pml_ucx_request.h                    (_comm)->c_contextid; \
_comm              73 ompi/mca/pml/ucx/pml_ucx_request.h #define PML_UCX_MESSAGE_NEW(_comm, _ucp_msg, _info, _message) \
_comm              81 ompi/mca/pml/ucx/pml_ucx_request.h         msg->comm    = (_comm); \
_comm              61 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_OMPI_REQ(_ompi_req, _comm, _state) \
_comm              64 ompi/mca/pml/yalla/pml_yalla_request.h         (_ompi_req)->req_mpi_object.comm = _comm; \
_comm              65 ompi/mca/pml/yalla/pml_yalla_request.h         OBJ_RETAIN(_comm); \
_comm              74 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_REQ_BASE(_req_base, _comm) \
_comm              77 ompi/mca/pml/yalla/pml_yalla_request.h         (_req_base)->mq    = (mxm_mq_h)(_comm)->c_pml_comm; \
_comm              80 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_PEER_CONN(_comm, _rank) \
_comm              81 ompi/mca/pml/yalla/pml_yalla_request.h     ompi_comm_peer_lookup(_comm, _rank)->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PML]
_comm              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, ...) \
_comm              85 ompi/mca/pml/yalla/pml_yalla_request.h         PML_YALLA_INIT_MXM_REQ_BASE(&(_sreq)->base, _comm); \
_comm              87 ompi/mca/pml/yalla/pml_yalla_request.h         (_sreq)->base.conn        = PML_YALLA_PEER_CONN(_comm, _rank); \
_comm              90 ompi/mca/pml/yalla/pml_yalla_request.h         (_sreq)->op.send.imm_data = ompi_comm_rank(_comm); \
_comm              93 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_RECV_REQ_ENVELOPE(_rreq, _rank, _tag, _comm) \
_comm              95 ompi/mca/pml/yalla/pml_yalla_request.h         (_rreq)->base.conn = ((_rank) == MPI_ANY_SOURCE) ? NULL : PML_YALLA_PEER_CONN(_comm, _rank); \
_comm             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, ...) \
_comm             107 ompi/mca/pml/yalla/pml_yalla_request.h         PML_YALLA_INIT_MXM_REQ_BASE(&(_rreq)->base, _comm); \
_comm             109 ompi/mca/pml/yalla/pml_yalla_request.h         PML_YALLA_INIT_MXM_RECV_REQ_ENVELOPE(_rreq, _rank, _tag, _comm); \
_comm             131 ompi/mca/pml/yalla/pml_yalla_request.h         int _src, int _tag, struct ompi_communicator_t* _comm, int _state)
_comm             134 ompi/mca/pml/yalla/pml_yalla_request.h     PML_YALLA_INIT_OMPI_REQ(&rreq->super.ompi, _comm, _state);
_comm             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);
_comm             140 ompi/mca/pml/yalla/pml_yalla_request.h         int _dst, int _tag, mca_pml_base_send_mode_t _mode, struct ompi_communicator_t* _comm, int _state)
_comm             143 ompi/mca/pml/yalla/pml_yalla_request.h     PML_YALLA_INIT_OMPI_REQ(&sreq->super.ompi, _comm, _state);
_comm             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);
_comm             146 ompi/mca/pml/yalla/pml_yalla_request.h     sreq->super.ompi.req_status.MPI_SOURCE = (_comm)->c_my_rank;
_comm             151 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_INIT_MXM_PROBE_REQ(_rreq, _rank, _tag, _comm) \
_comm             153 ompi/mca/pml/yalla/pml_yalla_request.h         PML_YALLA_INIT_MXM_REQ_BASE(&(_rreq)->base, _comm); \
_comm             154 ompi/mca/pml/yalla/pml_yalla_request.h         PML_YALLA_INIT_MXM_RECV_REQ_ENVELOPE(_rreq, _rank, _tag, _comm); \
_comm             212 ompi/mca/pml/yalla/pml_yalla_request.h #define PML_YALLA_SET_MESSAGE(_rreq, _comm, _mxm_msg, _message) \
_comm             215 ompi/mca/pml/yalla/pml_yalla_request.h         (*(_message))->comm    = (_comm); \