_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); \