| /src/external/mpl/dhcp/dist/omapip/ |
| test.c | 48 omapi_object_t *listener = (omapi_object_t*)0; local
72 status = omapi_generic_new (&listener, MDL);
78 status = omapi_protocol_listen (listener,
|
| listener.c | 1 /* $NetBSD: listener.c,v 1.3 2022/04/03 01:10:59 christos Exp $ */
3 /* listener.c
5 Subroutines that support the generic listener object. */
32 __RCSID("$NetBSD: listener.c,v 1.3 2022/04/03 01:10:59 christos Exp $");
118 on the trace listener queue. */
205 to read, for a listener object. */
217 /* Reader callback for a listener object. Accept an incoming connection. */
223 omapi_listener_object_t *listener; local
229 listener = (omapi_listener_object_t *)h;
233 socket = accept (listener -> socket
[all...] |
| connection.c | 298 int32_t listener_index [-1 means no listener]
306 if (obj -> listener)
307 listener_index = htonl (obj -> listener -> index);
365 /* If this was a connect to a listener, then we just slap together
368 omapi_listener_object_t *listener; local
369 listener = (omapi_listener_object_t *)0;
373 omapi_listener_reference (&listener, lp, MDL);
379 if (!listener) {
381 "Spurious traced listener connect - index ",
388 status = omapi_listener_connect (&obj, listener, -1, &remote)
[all...] |
| /src/crypto/external/apache2/openssl/dist/demos/quic/server/ |
| server.c | 120 * listener) by default, this call is also blocking.
143 SSL *listener = NULL, *conn = NULL; local
145 /* Create a new QUIC listener. */
146 if ((listener = SSL_new_listener(ctx, 0)) == NULL)
149 /* Provide the listener with our UDP socket. */
150 if (!SSL_set_fd(listener, fd))
154 if (!SSL_listen(listener))
162 if (!SSL_set_blocking_mode(listener, 1))
167 conn = SSL_accept_connection(listener, 0);
197 SSL_free(listener);
[all...] |
| /src/external/bsd/libevent/dist/sample/ |
| hello-world.c | 25 #include <event2/listener.h>
43 struct evconnlistener *listener; local
61 listener = evconnlistener_new_bind(base, listener_cb, (void *)base,
66 if (!listener) {
67 fprintf(stderr, "Could not create a listener!\n");
80 evconnlistener_free(listener);
89 listener_cb(struct evconnlistener *listener, evutil_socket_t fd,
|
| le-proxy.c | 31 #include <event2/listener.h>
160 accept_cb(struct evconnlistener *listener, evutil_socket_t fd,
218 struct evconnlistener *listener; local
287 listener = evconnlistener_new_bind(base, accept_cb, NULL,
291 if (! listener) {
292 fprintf(stderr, "Couldn't open listener.\n");
298 evconnlistener_free(listener);
|
| /src/external/apache2/mDNSResponder/dist/ServiceRegistration/test/tests/ |
| listen-longevity.c | 37 // Find the UDP listener if there is one.
65 comm_t *listener = test_listen_longevity_dnssd_udp_listener_find(); local
66 TEST_FAIL_CHECK(state, listener != NULL && listener->io.fd != -1, "listener was canceled.");
165 " The goal of this test is to see that when we start the dnssd proxy UDP listener and deliver\n"
166 " an SRP registration to it, that the listener is not canceled after 30 seconds. This test is\n"
170 " after 30 seconds the listener has been canceled.\n";
171 test_state_t *state = test_state_create(srp_servers, "Listener Longevity test", NULL, description, NULL);
179 // Use the UDP listener as the SRP listener
[all...] |
| /src/crypto/external/apache2/openssl/dist/demos/guide/ |
| quic-server-block.c | 211 SSL *listener, *conn; local
217 * Create a new QUIC listener. Listeners, and other QUIC objects, default
221 if ((listener = SSL_new_listener(ctx, 0)) == NULL)
224 /* Provide the listener with our UDP socket. */
225 if (!SSL_set_fd(listener, fd))
229 if (!SSL_listen(listener))
242 conn = SSL_accept_connection(listener, 0);
276 SSL_free(listener);
|
| quic-server-non-block.c | 364 SSL *listener, *conn = NULL; local
368 /* Create a new QUIC listener */
369 if ((listener = SSL_new_listener(ctx, 0)) == NULL)
372 /* Provide the listener with our UDP socket. */
373 if (!SSL_set_fd(listener, fd))
377 * Set the listener mode to non-blocking, which is inherited by
380 if (!SSL_set_blocking_mode(listener, 0))
389 if (!SSL_listen(listener))
406 while ((conn = SSL_accept_connection(listener, 0)) == NULL)
407 wait_for_activity(listener);
[all...] |
| /src/external/bsd/libevent/dist/test/ |
| test-fdleak.c | 52 #include "event2/listener.h"
111 listener_accept_cb(struct evconnlistener *listener, evutil_socket_t sock,
114 struct event_base *base = evconnlistener_get_base(listener);
126 struct evconnlistener *listener; local
137 listener = evconnlistener_new_bind(base, listener_accept_cb, NULL,
140 if (listener == NULL) {
141 my_perror("Could not create listener!");
144 fd = evconnlistener_get_fd(listener);
146 puts("Couldn't get fd from listener");
163 evconnlistener_free(listener);
[all...] |
| regress_listener.c | 51 #include "event2/listener.h"
60 acceptcb(struct evconnlistener *listener, evutil_socket_t fd,
69 evconnlistener_disable(listener);
162 struct evconnlistener *listener = NULL; local
173 /* Start a listener with a bogus socket. */
174 listener = evconnlistener_new(base, acceptcb, &count,
177 tt_assert(listener);
179 evconnlistener_set_error_cb(listener, errorcb);
181 tt_assert(listener);
187 if (listener)
208 struct evconnlistener *listener = NULL; local
241 struct evconnlistener *listener = NULL; local
280 struct evconnlistener *listener = NULL; local
[all...] |
| /src/external/bsd/ntp/dist/sntp/libevent/test/ |
| test-fdleak.c | 51 #include "event2/listener.h"
110 listener_accept_cb(struct evconnlistener *listener, evutil_socket_t sock,
113 struct event_base *base = evconnlistener_get_base(listener);
125 struct evconnlistener *listener; local
136 listener = evconnlistener_new_bind(base, listener_accept_cb, NULL,
139 if (listener == NULL) {
140 my_perror("Could not create listener!");
143 fd = evconnlistener_get_fd(listener);
145 puts("Couldn't get fd from listener");
162 evconnlistener_free(listener);
[all...] |
| regress_listener.c | 51 #include "event2/listener.h"
60 acceptcb(struct evconnlistener *listener, evutil_socket_t fd,
69 evconnlistener_disable(listener);
162 struct evconnlistener *listener = NULL; local
173 /* Start a listener with a bogus socket. */
174 listener = evconnlistener_new(base, acceptcb, &count,
177 tt_assert(listener);
179 evconnlistener_set_error_cb(listener, errorcb);
181 tt_assert(listener);
187 if (listener)
208 struct evconnlistener *listener = NULL; local
241 struct evconnlistener *listener = NULL; local
280 struct evconnlistener *listener = NULL; local
[all...] |
| /src/external/bsd/openldap/dist/servers/slapd/ |
| slapacl.c | 86 Listener listener; local
122 conn.c_listener = &listener;
|
| /src/crypto/external/apache2/openssl/dist/test/quic-openssl-docker/hq-interop/ |
| quic-hq-interop-server.c | 568 * This function initializes a QUIC listener, binds it to the provided UDP
579 * - Creates a QUIC listener using the provided SSL_CTX and associates it
588 * - If listener creation or connection acceptance fails, the function logs
590 * - Cleans up allocated resources (e.g., listener, connection) on failure.
597 * - Uses blocking operations for listener, connection, and stream handling.
604 SSL *listener, *conn, *stream; local
610 * then disable address validation on our listener
616 * Create a new QUIC listener. Listeners, and other QUIC objects, default
620 if ((listener = SSL_new_listener(ctx, flags)) == NULL)
623 /* Provide the listener with our UDP socket. *
[all...] |
| /src/external/bsd/libbind/dist/isc/ |
| ev_connects.c | 59 static void listener(evContext ctx, void *uap, int fd, int evmask);
92 if (evSelectFD(opaqueCtx, fd, EV_READ, listener, new, &new->file) < 0){
232 ret = evSelectFD(opaqueCtx, this->fd, EV_READ, listener, this,
282 listener(evContext opaqueCtx, void *uap, int fd, int evmask) { function
|
| /src/tests/net/net/ |
| t_unix.c | 456 int listener, conn, acc; local
465 RL(listener = socket(PF_LOCAL, SOCK_STREAM|SOCK_NONBLOCK, 0));
466 RL(bind(listener, (const struct sockaddr *)&sun, sizeof(sun)));
467 RL(listen(listener, 5));
472 ATF_REQUIRE_ERRNO(EAGAIN, accept(listener, NULL, NULL) == -1);
486 RL(acc = accept(listener, NULL, NULL));
506 RL(acc = accept(listener, NULL, NULL));
522 RL(close(listener));
|
| /src/crypto/external/apache2/openssl/dist/ssl/quic/ |
| quic_local.h | 124 QUIC_LISTENER *listener; member in struct:quic_conn_st
132 /* The QUIC port representing the QUIC listener and socket. */
233 * QUIC listener SSL object (QLSO) type. This implements the API personality
246 /* The QUIC port representing the QUIC listener and socket. */
|
| /src/external/apache2/mDNSResponder/dist/ServiceRegistration/ |
| dnssd-relay.c | 458 comm_t *listener[4 + MAX_ADDRS]; local
485 listener[num_listeners] = setup_listener_socket(AF_UNSPEC, IPPROTO_TCP, true,
486 tls_port, listen_addrs[i], "DNS TLS Listener", dns_input,
488 if (listener[num_listeners] == NULL) {
489 ERROR("TLS4 listener: fail.");
497 listener[num_listeners] = setup_listener_socket(AF_INET, IPPROTO_TCP, true, tls_port, NULL,
498 "IPv4 DNS TLS Listener", dns_input, 0, 0);
499 if (listener[num_listeners] == NULL) {
500 ERROR("UDP4 listener: fail.");
505 listener[num_listeners] = setup_listener_socket(AF_INET6, IPPROTO_TCP, true, tls_port, NULL
[all...] |
| /src/external/mpl/bind/dist/lib/isc/netmgr/ |
| proxyudp.c | 326 isc_nmsocket_t *listener = NULL; local
337 listener = proxyudp_sock_new(worker, isc_nm_proxyudplistener, iface,
339 listener->recv_cb = cb;
340 listener->recv_cbarg = cbarg;
342 for (size_t i = 0; i < listener->proxy.udp_server_socks_num; i++) {
343 listener->proxy.udp_server_socks[i] = proxyudp_sock_new(
346 listener->proxy.udp_server_socks[i]->recv_cb =
347 listener->recv_cb;
349 listener->proxy.udp_server_socks[i]->recv_cbarg =
350 listener->recv_cbarg
496 isc_nmsocket_t *listener = NULL; local
[all...] |
| proxystream.c | 205 isc__nmsocket_detach(&sock->listener);
303 isc__nmsocket_attach(listensock, &nsock->listener);
325 isc_nmsocket_t *listener = NULL; local
336 listener = proxystream_sock_new(worker, isc_nm_proxystreamlistener,
338 listener->accept_cb = accept_cb;
339 listener->accept_cbarg = accept_cbarg;
343 proxystream_accept_cb, listener,
344 backlog, quota, &listener->outer);
347 mgr, workers, iface, proxystream_accept_cb, listener,
348 backlog, quota, tlsctx, false, &listener->outer)
[all...] |
| streamdns.c | 748 isc__nmsocket_attach(handle->sock, &nsock->listener);
760 isc__nmsocket_detach(&nsock->listener);
787 isc_nmsocket_t *listener = NULL; local
799 listener = streamdns_sock_new(worker, isc_nm_streamdnslistener, iface,
801 listener->accept_cb = accept_cb;
802 listener->accept_cbarg = accept_cbarg;
803 listener->recv_cb = recv_cb;
804 listener->recv_cbarg = recv_cbarg;
811 listener, backlog, quota, &listener->outer)
[all...] |
| /src/external/apache2/mDNSResponder/dist/DSO/ |
| dso-transport.h | 122 TCPListener *listener; member in struct:dso_connect_state
156 TCPListener *listener; member in struct:__anon5975
|
| /src/external/bsd/libevent/dist/ |
| http-internal.h | 125 struct evconnlistener *listener; member in struct:evhttp_bound_socket
|
| /src/external/bsd/ntp/dist/sntp/libevent/ |
| http-internal.h | 126 struct evconnlistener *listener; member in struct:evhttp_bound_socket
|
