conn 227 ompi/mca/pml/yalla/pml_yalla.c mxm_conn_h conn; conn 251 ompi/mca/pml/yalla/pml_yalla.c error = mxm_ep_connect(ompi_pml_yalla.mxm_ep, address, &conn); conn 259 ompi/mca/pml/yalla/pml_yalla.c procs[i]->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PML] = conn; conn 432 ompi/mca/pml/yalla/pml_yalla.c bsreq->mxm.base.conn = mxm_sreq->base.conn; conn 119 ompi/mca/pml/yalla/pml_yalla_request.c mxm_req_base->conn = NULL; conn 87 ompi/mca/pml/yalla/pml_yalla_request.h (_sreq)->base.conn = PML_YALLA_PEER_CONN(_comm, _rank); \ conn 95 ompi/mca/pml/yalla/pml_yalla_request.h (_rreq)->base.conn = ((_rank) == MPI_ANY_SOURCE) ? NULL : PML_YALLA_PEER_CONN(_comm, _rank); \ conn 3564 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_get_base(struct evhttp_connection *conn) conn 3566 opal/mca/event/libevent2022/libevent/http.c return conn->base; conn 262 opal/mca/pmix/pmix4x/pmix/include/pmi2.h PMIX_EXPORT int PMI2_Job_Connect(const char jobid[], PMI2_Connect_comm_t *conn); conn 324 opal/mca/pmix/pmix4x/pmix/src/client/pmi2.c PMIX_EXPORT int PMI2_Job_Connect(const char jobid[], PMI2_Connect_comm_t *conn) conn 331 opal/mca/pmix/pmix4x/pmix/src/client/pmi2.c if (NULL == conn) { conn 479 opal/mca/pmix/s2/pmix_s2.c PMI2_Connect_comm_t conn; conn 490 opal/mca/pmix/s2/pmix_s2.c rc = PMI2_Job_Connect(jobid, &conn); conn 191 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_listener_t *conn; conn 388 orte/mca/oob/tcp/oob_tcp_listener.c conn = OBJ_NEW(mca_oob_tcp_listener_t); conn 389 orte/mca/oob/tcp/oob_tcp_listener.c conn->sd = sd; conn 390 orte/mca/oob/tcp/oob_tcp_listener.c conn->port = ntohs(((struct sockaddr_in*) &inaddr)->sin_port); conn 393 orte/mca/oob/tcp/oob_tcp_listener.c orte_process_info.my_port = conn->port; conn 395 orte/mca/oob/tcp/oob_tcp_listener.c opal_list_append(&mca_oob_tcp_component.listeners, &conn->item); conn 444 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_listener_t *conn; conn 632 orte/mca/oob/tcp/oob_tcp_listener.c conn = OBJ_NEW(mca_oob_tcp_listener_t); conn 633 orte/mca/oob/tcp/oob_tcp_listener.c conn->tcp6 = true; conn 634 orte/mca/oob/tcp/oob_tcp_listener.c conn->sd = sd; conn 635 orte/mca/oob/tcp/oob_tcp_listener.c conn->port = ntohs(((struct sockaddr_in6*) &inaddr)->sin6_port); conn 636 orte/mca/oob/tcp/oob_tcp_listener.c opal_list_append(&mca_oob_tcp_component.listeners, &conn->item); conn 92 orte/util/listener.c orte_listener_t *conn; conn 170 orte/util/listener.c conn = OBJ_NEW(orte_listener_t); conn 171 orte/util/listener.c conn->sd = sd; conn 172 orte/util/listener.c conn->evbase = evbase; conn 173 orte/util/listener.c conn->handler = handler; conn 174 orte/util/listener.c opal_list_append(&mylisteners, &conn->item); conn 113 oshmem/mca/atomic/mxm/atomic_mxm.h sreq->base.conn = mca_atomic_mxm_spml_self->mxm_peers[pe].mxm_hw_rdma_conn; conn 610 oshmem/mca/spml/ikrit/spml_ikrit.c sreq->base.conn = mca_spml_ikrit.mxm_peers[src].mxm_conn; conn 750 oshmem/mca/spml/ikrit/spml_ikrit.c fence_req->mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn; conn 862 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn; conn 929 oshmem/mca/spml/ikrit/spml_ikrit.c mxm_req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn; conn 1049 oshmem/mca/spml/ikrit/spml_ikrit.c req.base.conn = NULL; conn 1090 oshmem/mca/spml/ikrit/spml_ikrit.c req.base.conn = mca_spml_ikrit.mxm_peers[dst].mxm_conn;