pending_connection 186 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_pending_connection_t *pending_connection; pending_connection 250 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection = PMIX_NEW(pmix_pending_connection_t); pending_connection 251 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->protocol = lt->protocol; pending_connection 252 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->ptl = lt->ptl; pending_connection 253 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_event_assign(&pending_connection->ev, pmix_globals.evbase, -1, pending_connection 254 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c EV_WRITE, lt->cbfunc, pending_connection); pending_connection 255 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->sd = accept(lt->socket, pending_connection 256 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c (struct sockaddr*)&(pending_connection->addr), pending_connection 258 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (pending_connection->sd < 0) { pending_connection 259 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c PMIX_RELEASE(pending_connection); pending_connection 284 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->sd, pmix_socket_errno); pending_connection 286 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c PMIX_POST_OBJECT(pending_connection); pending_connection 288 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_event_active(&pending_connection->ev, EV_WRITE, 1); pending_connection 325 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_pending_connection_t *pending_connection; pending_connection 331 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pending_connection = PMIX_NEW(pmix_pending_connection_t); pending_connection 332 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pending_connection->sd = incoming_sd; pending_connection 333 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_assign(&pending_connection->ev, pmix_globals.evbase, -1, pending_connection 334 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c EV_WRITE, connection_handler, pending_connection); pending_connection 335 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_active(&pending_connection->ev, EV_WRITE, 1); pending_connection 677 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_pending_connection_t *pending_connection; pending_connection 746 orte/mca/oob/tcp/oob_tcp_listener.c pending_connection = OBJ_NEW(mca_oob_tcp_pending_connection_t); pending_connection 747 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set(orte_oob_base.ev_base, &pending_connection->ev, -1, pending_connection 748 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_EV_WRITE, connection_handler, pending_connection); pending_connection 749 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set_priority(&pending_connection->ev, ORTE_MSG_PRI); pending_connection 750 orte/mca/oob/tcp/oob_tcp_listener.c pending_connection->fd = accept(sd, pending_connection 751 orte/mca/oob/tcp/oob_tcp_listener.c (struct sockaddr*)&(pending_connection->addr), pending_connection 755 orte/mca/oob/tcp/oob_tcp_listener.c if (pending_connection->fd < 0) { pending_connection 756 orte/mca/oob/tcp/oob_tcp_listener.c OBJ_RELEASE(pending_connection); pending_connection 798 orte/mca/oob/tcp/oob_tcp_listener.c pending_connection->fd, opal_socket_errno, pending_connection 799 orte/mca/oob/tcp/oob_tcp_listener.c opal_net_get_hostname((struct sockaddr*) &pending_connection->addr), pending_connection 800 orte/mca/oob/tcp/oob_tcp_listener.c opal_net_get_port((struct sockaddr*) &pending_connection->addr)); pending_connection 807 orte/mca/oob/tcp/oob_tcp_listener.c inport = opal_net_get_port((struct sockaddr*) &pending_connection->addr); pending_connection 814 orte/mca/oob/tcp/oob_tcp_listener.c opal_net_get_hostname((struct sockaddr*) &pending_connection->addr), pending_connection 816 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(pending_connection->fd); pending_connection 817 orte/mca/oob/tcp/oob_tcp_listener.c OBJ_RELEASE(pending_connection); pending_connection 823 orte/mca/oob/tcp/oob_tcp_listener.c ORTE_POST_OBJECT(pending_connection); pending_connection 824 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_active(&pending_connection->ev, OPAL_EV_WRITE, 1); pending_connection 238 orte/util/listener.c orte_pending_connection_t *pending_connection; pending_connection 300 orte/util/listener.c pending_connection = OBJ_NEW(orte_pending_connection_t); pending_connection 301 orte/util/listener.c opal_event_set(listener->evbase, &pending_connection->ev, -1, pending_connection 302 orte/util/listener.c OPAL_EV_WRITE, listener->handler, pending_connection); pending_connection 303 orte/util/listener.c opal_event_set_priority(&pending_connection->ev, ORTE_MSG_PRI); pending_connection 304 orte/util/listener.c pending_connection->fd = accept(sd, pending_connection 305 orte/util/listener.c (struct sockaddr*)&(pending_connection->addr), pending_connection 307 orte/util/listener.c if (pending_connection->fd < 0) { pending_connection 308 orte/util/listener.c OBJ_RELEASE(pending_connection); pending_connection 348 orte/util/listener.c opal_event_active(&pending_connection->ev, OPAL_EV_WRITE, 1);