listener 136 opal/mca/btl/usnic/btl_usnic_cagent.c agent_udp_port_listener_t *listener; listener 264 opal/mca/btl/usnic/btl_usnic_cagent.c obj->listener = NULL; listener 345 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_handle_ping(agent_udp_port_listener_t *listener, listener 350 opal/mca/btl/usnic/btl_usnic_cagent.c agent_udp_message_t *msg = (agent_udp_message_t*) listener->buffer; listener 415 opal/mca/btl/usnic/btl_usnic_cagent.c agent_sendto(listener->fd, (char*) listener->buffer, sizeof(*msg), from); listener 421 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_handle_ack(agent_udp_port_listener_t *listener, listener 430 opal/mca/btl/usnic/btl_usnic_cagent.c agent_udp_message_t *msg = (agent_udp_message_t*) listener->buffer; listener 475 opal/mca/btl/usnic/btl_usnic_cagent.c agent_udp_port_listener_t *listener = listener 477 opal/mca/btl/usnic/btl_usnic_cagent.c assert(NULL != listener); listener 486 opal/mca/btl/usnic/btl_usnic_cagent.c numbytes = recvfrom(listener->fd, listener->buffer, listener->max_msg_size, 0, listener 502 opal/mca/btl/usnic/btl_usnic_cagent.c msg = (agent_udp_message_t *) listener->buffer; listener 505 opal/mca/btl/usnic/btl_usnic_cagent.c agent_thread_handle_ping(listener, numbytes, &src_addr); listener 508 opal/mca/btl/usnic/btl_usnic_cagent.c agent_thread_handle_ack(listener, numbytes, &src_addr); listener 523 opal/mca/btl/usnic/btl_usnic_cagent.c agent_udp_port_listener_t *listener; listener 524 opal/mca/btl/usnic/btl_usnic_cagent.c OPAL_LIST_FOREACH(listener, &udp_port_listeners, agent_udp_port_listener_t) { listener 525 opal/mca/btl/usnic/btl_usnic_cagent.c if (listener->ipv4_addr == ipv4_addr) { listener 526 opal/mca/btl/usnic/btl_usnic_cagent.c *udp_port = listener->udp_port; listener 527 opal/mca/btl/usnic/btl_usnic_cagent.c return listener; listener 730 opal/mca/btl/usnic/btl_usnic_cagent.c ap->listener->ipv4_addr_str, listener 766 opal/mca/btl/usnic/btl_usnic_cagent.c ap->listener->ipv4_addr_str, listener 767 opal/mca/btl/usnic/btl_usnic_cagent.c ap->listener->usnic_name, listener 782 opal/mca/btl/usnic/btl_usnic_cagent.c ap->listener->ipv4_addr_str, listener 783 opal/mca/btl/usnic/btl_usnic_cagent.c ap->listener->usnic_name, listener 788 opal/mca/btl/usnic/btl_usnic_cagent.c agent_sendto(ap->listener->fd, (char*) ap->buffers[i], ap->sizes[i], listener 864 opal/mca/btl/usnic/btl_usnic_cagent.c ap->listener = udp_listener; listener 993 opal/mca/btl/usnic/btl_usnic_cagent.c agent_ipc_listener_t *listener = NULL; listener 1027 opal/mca/btl/usnic/btl_usnic_cagent.c listener = OBJ_NEW(agent_ipc_listener_t); listener 1028 opal/mca/btl/usnic/btl_usnic_cagent.c listener->client_fd = client_fd; listener 1041 opal/mca/btl/usnic/btl_usnic_cagent.c &listener->event, client_fd, listener 1043 opal/mca/btl/usnic/btl_usnic_cagent.c agent_thread_ipc_receive, listener); listener 1044 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_add(&listener->event, 0); listener 1047 opal/mca/btl/usnic/btl_usnic_cagent.c opal_list_append(&ipc_listeners, &listener->super); listener 1049 opal/mca/btl/usnic/btl_usnic_cagent.c listener->active = true; listener 208 opal/mca/event/libevent2022/libevent/evutil.c evutil_socket_t listener = -1; listener 230 opal/mca/event/libevent2022/libevent/evutil.c listener = socket(AF_INET, type, 0); listener 231 opal/mca/event/libevent2022/libevent/evutil.c if (listener < 0) listener 237 opal/mca/event/libevent2022/libevent/evutil.c if (bind(listener, (struct sockaddr *) &listen_addr, sizeof (listen_addr)) listener 240 opal/mca/event/libevent2022/libevent/evutil.c if (listen(listener, 1) == -1) listener 248 opal/mca/event/libevent2022/libevent/evutil.c if (getsockname(listener, (struct sockaddr *) &connect_addr, &size) == -1) listener 257 opal/mca/event/libevent2022/libevent/evutil.c acceptor = accept(listener, (struct sockaddr *) &listen_addr, &size); listener 271 opal/mca/event/libevent2022/libevent/evutil.c evutil_closesocket(listener); listener 282 opal/mca/event/libevent2022/libevent/evutil.c if (listener != -1) listener 283 opal/mca/event/libevent2022/libevent/evutil.c evutil_closesocket(listener); listener 126 opal/mca/event/libevent2022/libevent/http-internal.h struct evconnlistener *listener; listener 3079 opal/mca/event/libevent2022/libevent/http.c accept_socket_cb(struct evconnlistener *listener, evutil_socket_t nfd, struct sockaddr *peer_sa, int peer_socklen, void *arg) listener 3137 opal/mca/event/libevent2022/libevent/http.c struct evconnlistener *listener; listener 3141 opal/mca/event/libevent2022/libevent/http.c listener = evconnlistener_new(http->base, NULL, NULL, listener 3145 opal/mca/event/libevent2022/libevent/http.c if (!listener) listener 3148 opal/mca/event/libevent2022/libevent/http.c bound = evhttp_bind_listener(http, listener); listener 3150 opal/mca/event/libevent2022/libevent/http.c evconnlistener_free(listener); listener 3157 opal/mca/event/libevent2022/libevent/http.c evhttp_bind_listener(struct evhttp *http, struct evconnlistener *listener) listener 3165 opal/mca/event/libevent2022/libevent/http.c bound->listener = listener; listener 3168 opal/mca/event/libevent2022/libevent/http.c evconnlistener_set_cb(listener, accept_socket_cb, http); listener 3175 opal/mca/event/libevent2022/libevent/http.c return evconnlistener_get_fd(bound->listener); listener 3181 opal/mca/event/libevent2022/libevent/http.c return bound->listener; listener 3188 opal/mca/event/libevent2022/libevent/http.c evconnlistener_free(bound->listener); listener 3267 opal/mca/event/libevent2022/libevent/http.c evconnlistener_free(bound->listener); listener 144 opal/mca/event/libevent2022/libevent/include/event2/http.h struct evhttp_bound_socket *evhttp_bind_listener(struct evhttp *http, struct evconnlistener *listener); listener 87 opal/mca/event/libevent2022/libevent/listener.c struct event listener; listener 103 opal/mca/event/libevent2022/libevent/listener.c #define LOCK(listener) EVLOCK_LOCK((listener)->lock, 0) listener 104 opal/mca/event/libevent2022/libevent/listener.c #define UNLOCK(listener) EVLOCK_UNLOCK((listener)->lock, 0) listener 119 opal/mca/event/libevent2022/libevent/listener.c listener_incref_and_lock(struct evconnlistener *listener) listener 121 opal/mca/event/libevent2022/libevent/listener.c LOCK(listener); listener 122 opal/mca/event/libevent2022/libevent/listener.c ++listener->refcnt; listener 127 opal/mca/event/libevent2022/libevent/listener.c listener_decref_and_unlock(struct evconnlistener *listener) listener 129 opal/mca/event/libevent2022/libevent/listener.c int refcnt = --listener->refcnt; listener 131 opal/mca/event/libevent2022/libevent/listener.c listener->ops->destroy(listener); listener 132 opal/mca/event/libevent2022/libevent/listener.c UNLOCK(listener); listener 133 opal/mca/event/libevent2022/libevent/listener.c EVTHREAD_FREE_LOCK(listener->lock, EVTHREAD_LOCKTYPE_RECURSIVE); listener 134 opal/mca/event/libevent2022/libevent/listener.c mm_free(listener); listener 137 opal/mca/event/libevent2022/libevent/listener.c UNLOCK(listener); listener 192 opal/mca/event/libevent2022/libevent/listener.c event_assign(&lev->listener, base, fd, EV_READ|EV_PERSIST, listener 205 opal/mca/event/libevent2022/libevent/listener.c struct evconnlistener *listener; listener 247 opal/mca/event/libevent2022/libevent/listener.c listener = evconnlistener_new(base, cb, ptr, flags, backlog, fd); listener 248 opal/mca/event/libevent2022/libevent/listener.c if (!listener) { listener 253 opal/mca/event/libevent2022/libevent/listener.c return listener; listener 273 opal/mca/event/libevent2022/libevent/listener.c event_del(&lev_e->listener); listener 275 opal/mca/event/libevent2022/libevent/listener.c evutil_closesocket(event_get_fd(&lev_e->listener)); listener 276 opal/mca/event/libevent2022/libevent/listener.c event_debug_unassign(&lev_e->listener); listener 309 opal/mca/event/libevent2022/libevent/listener.c return event_add(&lev_e->listener, NULL); listener 317 opal/mca/event/libevent2022/libevent/listener.c return event_del(&lev_e->listener); listener 335 opal/mca/event/libevent2022/libevent/listener.c return event_get_fd(&lev_e->listener); listener 353 opal/mca/event/libevent2022/libevent/listener.c return event_get_base(&lev_e->listener); listener 42 opal/mca/event/libevent2022/libevent/sample/hello-world.c struct evconnlistener *listener; listener 61 opal/mca/event/libevent2022/libevent/sample/hello-world.c listener = evconnlistener_new_bind(base, listener_cb, (void *)base, listener 66 opal/mca/event/libevent2022/libevent/sample/hello-world.c if (!listener) { listener 80 opal/mca/event/libevent2022/libevent/sample/hello-world.c evconnlistener_free(listener); listener 89 opal/mca/event/libevent2022/libevent/sample/hello-world.c listener_cb(struct evconnlistener *listener, evutil_socket_t fd, listener 152 opal/mca/event/libevent2022/libevent/sample/le-proxy.c accept_cb(struct evconnlistener *listener, evutil_socket_t fd, listener 209 opal/mca/event/libevent2022/libevent/sample/le-proxy.c struct evconnlistener *listener; listener 268 opal/mca/event/libevent2022/libevent/sample/le-proxy.c listener = evconnlistener_new_bind(base, accept_cb, NULL, listener 274 opal/mca/event/libevent2022/libevent/sample/le-proxy.c evconnlistener_free(listener); listener 427 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c listen_cb(struct evconnlistener *listener, evutil_socket_t fd, listener 1044 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct evconnlistener *listener = NULL; listener 1064 opal/mca/event/libevent2022/libevent/test/regress_dns.c listener = evconnlistener_new_bind(data->base, nil_accept_cb, listener 1068 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(listener); listener 1070 opal/mca/event/libevent2022/libevent/test/regress_dns.c evconnlistener_get_fd(listener)); listener 1150 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (listener) listener 1151 opal/mca/event/libevent2022/libevent/test/regress_dns.c evconnlistener_free(listener); listener 55 opal/mca/event/libevent2022/libevent/test/regress_listener.c acceptcb(struct evconnlistener *listener, evutil_socket_t fd, listener 64 opal/mca/event/libevent2022/libevent/test/regress_listener.c evconnlistener_disable(listener); listener 156 opal/mca/event/libevent2022/libevent/test/regress_listener.c struct evconnlistener *listener = NULL; listener 168 opal/mca/event/libevent2022/libevent/test/regress_listener.c listener = evconnlistener_new(base, acceptcb, &count, listener 171 opal/mca/event/libevent2022/libevent/test/regress_listener.c tt_assert(listener); listener 173 opal/mca/event/libevent2022/libevent/test/regress_listener.c evconnlistener_set_error_cb(listener, errorcb); listener 175 opal/mca/event/libevent2022/libevent/test/regress_listener.c tt_assert(listener); listener 181 opal/mca/event/libevent2022/libevent/test/regress_listener.c if (listener) listener 182 opal/mca/event/libevent2022/libevent/test/regress_listener.c evconnlistener_free(listener); listener 370 opal/mca/event/libevent2022/libevent/test/regress_ssl.c acceptcb(struct evconnlistener *listener, evutil_socket_t fd, listener 393 opal/mca/event/libevent2022/libevent/test/regress_ssl.c evconnlistener_disable(listener); listener 403 opal/mca/event/libevent2022/libevent/test/regress_ssl.c struct evconnlistener *listener; listener 418 opal/mca/event/libevent2022/libevent/test/regress_ssl.c listener = evconnlistener_new_bind(base, acceptcb, data, listener 422 opal/mca/event/libevent2022/libevent/test/regress_ssl.c tt_assert(listener); listener 423 opal/mca/event/libevent2022/libevent/test/regress_ssl.c tt_assert(evconnlistener_get_fd(listener) >= 0); listener 434 opal/mca/event/libevent2022/libevent/test/regress_ssl.c tt_assert(getsockname(evconnlistener_get_fd(listener), listener 153 opal/mca/event/libevent2022/libevent/test/test-ratelim.c echo_listenercb(struct evconnlistener *listener, evutil_socket_t newsock, listener 175 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct evconnlistener *listener; listener 215 opal/mca/event/libevent2022/libevent/test/test-ratelim.c listener = evconnlistener_new_bind(base, echo_listenercb, base, listener 220 opal/mca/event/libevent2022/libevent/test/test-ratelim.c if (getsockname(evconnlistener_get_fd(listener), (struct sockaddr *)&ss, listener 284 opal/mca/event/libevent2022/libevent/test/test-ratelim.c evconnlistener_free(listener); listener 103 opal/mca/pmix/ext1x/pmix1x_server_north.c .listener = server_listener_fn listener 777 opal/mca/pmix/ext1x/pmix1x_server_north.c if (NULL == host_module || NULL == host_module->listener) { listener 781 opal/mca/pmix/ext1x/pmix1x_server_north.c rc = host_module->listener(listening_sd, cbfunc); listener 536 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h pmix_server_listener_fn_t listener; listener 307 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (NULL != pmix_host_server.listener) { listener 308 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c rc = pmix_host_server.listener(lt->socket, listener_cb, (void*)lt); listener 276 opal/mca/pmix/pmix_server.h opal_pmix_server_listener_fn_t listener; listener 31 opal/win32/opal_socket.c int listener = -1; listener 53 opal/win32/opal_socket.c listener = socket(AF_INET, type, 0); listener 54 opal/win32/opal_socket.c if (listener < 0) listener 60 opal/win32/opal_socket.c if (bind(listener, (struct sockaddr *) &listen_addr, sizeof (listen_addr)) listener 63 opal/win32/opal_socket.c if (listen(listener, 1) == -1) listener 71 opal/win32/opal_socket.c if (getsockname(listener, (struct sockaddr *) &connect_addr, &size) == -1) listener 80 opal/win32/opal_socket.c acceptor = accept(listener, (struct sockaddr *) &listen_addr, &size); listener 85 opal/win32/opal_socket.c closesocket(listener); listener 105 opal/win32/opal_socket.c if (listener != -1) listener 106 opal/win32/opal_socket.c closesocket(listener); listener 102 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_listener_t *listener; listener 158 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { listener 159 orte/mca/oob/tcp/oob_tcp_listener.c listener->ev_active = true; listener 160 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set(orte_oob_base.ev_base, &listener->event, listener 161 orte/mca/oob/tcp/oob_tcp_listener.c listener->sd, listener 165 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set_priority(&listener->event, ORTE_MSG_PRI); listener 166 orte/mca/oob/tcp/oob_tcp_listener.c ORTE_POST_OBJECT(listener); listener 167 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_add(&listener->event, 0); listener 680 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_listener_t *listener; listener 690 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { listener 691 orte/mca/oob/tcp/oob_tcp_listener.c FD_SET(listener->sd, &readfds); listener 692 orte/mca/oob/tcp/oob_tcp_listener.c max = (listener->sd > max) ? listener->sd : max; listener 725 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { listener 726 orte/mca/oob/tcp/oob_tcp_listener.c sd = listener->sd; listener 805 orte/mca/oob/tcp/oob_tcp_listener.c if (1024 >= listener->port) { listener 813 orte/mca/oob/tcp/oob_tcp_listener.c opal_process_info.nodename, listener->port, listener 844 orte/mca/oob/tcp/oob_tcp_listener.c OPAL_LIST_FOREACH(listener, &mca_oob_tcp_component.listeners, mca_oob_tcp_listener_t) { listener 845 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set(orte_event_base, listener->event, listener 846 orte/mca/oob/tcp/oob_tcp_listener.c listener->sd, listener 850 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set_priority(listener->event, ORTE_MSG_PRI); listener 851 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_add(listener->event, 0); listener 241 orte/util/listener.c orte_listener_t *listener; listener 246 orte/util/listener.c OPAL_LIST_FOREACH(listener, &mylisteners, orte_listener_t) { listener 247 orte/util/listener.c FD_SET(listener->sd, &readfds); listener 248 orte/util/listener.c max = (listener->sd > max) ? listener->sd : max; listener 279 orte/util/listener.c OPAL_LIST_FOREACH(listener, &mylisteners, orte_listener_t) { listener 280 orte/util/listener.c sd = listener->sd; listener 301 orte/util/listener.c opal_event_set(listener->evbase, &pending_connection->ev, -1, listener 302 orte/util/listener.c OPAL_EV_WRITE, listener->handler, pending_connection);