| /src/external/apache2/mDNSResponder/dist/ServiceRegistration/ |
| macos-ioloop.c | 56 static void listener_finalize(comm_t *listener);
260 if (comm->listener != NULL) {
261 nw_release(comm->listener);
263 comm->listener = NULL;
275 RELEASE_HERE(comm->listener_state, listener);
338 RETAIN_HERE(connection, listener);
343 RELEASE_HERE(connection, listener);
940 ioloop_udp_receive(comm_t *listener, dispatch_data_t content, nw_content_context_t context, bool UNUSED is_complete)
947 ERROR("%p: " PRI_S_SRP ": no memory for response state.", listener, listener->name)
1071 comm_t *listener = context; local
1467 comm_t *listener; local
[all...] |
| ioloop.c | 414 // One-time callback, used to call the listener ready callback after ioloop_listener_create() has
1081 ioloop_listener_retain_(comm_t *listener, const char *file, int line)
1083 RETAIN(&listener->io, comm);
1087 ioloop_listener_release_(comm_t *listener, const char *file, int line)
1089 RELEASE(&listener->io, comm);
1104 comm_t *listener = (comm_t *)io; local
1113 rv = accept(listener->io.fd, &addr.sa, &addr_len);
1116 close(listener->io.fd);
1117 listener->io.fd = -1;
1130 comm->datagram_callback = listener->datagram_callback
1164 comm_t *listener = (comm_t *)io; local
1177 comm_t *listener; local
[all...] |
| /src/external/mpl/bind/dist/bin/named/ |
| controlconf.c | 75 controllistener_t *listener; member in struct:controlconnection
175 free_listener(controllistener_t *listener) {
176 REQUIRE(listener->shuttingdown);
177 REQUIRE(ISC_LIST_EMPTY(listener->connections));
178 REQUIRE(listener->sock == NULL);
180 free_controlkeylist(&listener->keys, listener->mctx);
182 if (listener->acl != NULL) {
183 dns_acl_detach(&listener->acl);
186 isc_mem_putanddetach(&listener->mctx, listener, sizeof(*listener))
296 controllistener_t *listener = conn->listener; local
315 controllistener_t *listener = conn->listener; local
430 controllistener_t *listener = conn->listener; local
568 controllistener_t *listener = conn->listener; local
631 controllistener_t *listener = arg; local
658 controllistener_t *listener = NULL; local
938 controllistener_t *listener = NULL; local
1067 controllistener_t *listener = NULL; local
1172 controllistener_t *listener = NULL; local
[all...] |
| /src/external/bsd/libevent/dist/test/ |
| 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...] |
| 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...] |
| /src/external/bsd/ntp/dist/sntp/libevent/test/ |
| 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...] |
| 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...] |
| /src/tests/fs/nullfs/ |
| t_ipc.sh | 96 listener=$!
104 wait $listener
106 *) kill $listener
107 wait $listener
128 listener=$!
136 wait $listener
138 *) kill $listener
139 wait $listener
|
| /src/external/apache2/llvm/dist/llvm/utils/unittest/googlemock/src/ |
| gmock-matchers.cc | 368 // Returns false, writing an explanation to 'listener', if and only
372 const MatchMatrix& matrix, MatchResultListener* listener) const {
391 if (listener->IsInterested()) {
392 *listener << sep << "matcher #" << mi << ": ";
393 matcher_describers_[mi]->DescribeTo(listener->stream());
409 if (listener->IsInterested()) {
410 *listener << outer_sep << sep << "element #" << ei << ": "
421 const MatchMatrix& matrix, MatchResultListener* listener) const {
427 if (listener->IsInterested()) {
428 *listener << "where no permutation of the elements can satisfy all
[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,
|
| /src/external/mpl/bind/dist/bin/tests/system/checkconf/ |
| bad-doh-duplicates.conf | 21 listener-clients 100;
28 listener-clients 100;
36 http-listener-clients 100;
|
| bad-dot-nocert.conf | 20 listener-clients 100;
28 http-listener-clients 100;
|
| bad-dot-nokey.conf | 20 listener-clients 100;
28 http-listener-clients 100;
|
| good-doh-1.conf | 21 listener-clients 100;
29 http-listener-clients 100;
|
| /src/external/apache2/llvm/dist/llvm/include/llvm/Testing/Support/ |
| Error.h | 39 testing::MatchResultListener *listener) const override {
43 bool result = Matcher.MatchAndExplain(*Holder.Exp, listener);
45 if (result || !listener->IsInterested())
47 *listener << "(";
48 Matcher.DescribeNegationTo(listener->stream());
49 *listener << ")";
91 testing::MatchResultListener *listener) const override {
96 *listener << "multiple errors";
102 *listener << "Error was not of given type";
109 return Matcher->MatchAndExplain(static_cast<InfoT &>(Info), listener);
[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/mpl/bind/dist/lib/isc/netmgr/ |
| 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...] |
| 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...] |
| /src/external/apache2/llvm/dist/llvm/utils/unittest/googlemock/include/gmock/ |
| gmock-matchers.h | 96 // A match result listener that stores the explanation in a string.
206 bool MatchAndExplain(T x, MatchResultListener* listener) const override {
221 return source_matcher_.MatchAndExplain(static_cast<U>(x), listener);
337 // the match result to the listener. Returns the match result.
338 // 'listener' must not be NULL.
343 MatchResultListener* listener) {
344 if (!listener->IsInterested()) {
345 // If the listener is not interested, we do not need to construct the
353 UniversalPrint(value, listener->stream());
357 *listener->stream() << " (of type " << type_name << ")"
396 StringMatchResultListener listener; local
1336 StringMatchResultListener listener; local
[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/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,
|
| /src/external/mpl/dhcp/lib/omapip/ |
| Makefile | 7 listener.c dispatch.c generic.c support.c handle.c message.c \
|
| /src/external/mpl/dhcp/bind/dist/lib/dns/ |
| db.c | 283 dns_dbonupdatelistener_t *listener; local
293 for (listener = ISC_LIST_HEAD(db->update_listeners); listener != NULL;
294 listener = ISC_LIST_NEXT(listener, link))
296 listener->onupdate(db, listener->onupdate_arg);
405 dns_dbonupdatelistener_t *listener; local
418 for (listener = ISC_LIST_HEAD(db->update_listeners);
419 listener != NULL; listener = ISC_LIST_NEXT(listener, link)
1026 dns_dbonupdatelistener_t *listener; local
1055 dns_dbonupdatelistener_t *listener; local
[all...] |
| /src/sys/kern/ |
| kern_auth.c | 63 * Listener.
69 SIMPLEQ_ENTRY(kauth_listener) listener_next; /* listener list */
79 SIMPLEQ_HEAD(, kauth_listener) listenq; /* listener list */
765 * callback - the scope's default listener
766 * cookie - cookie to be passed to the listener(s)
773 kauth_listener_t listener = NULL; /* XXX gcc */ local
779 /* Allocate space for a new scope and listener. */
782 listener = kmem_alloc(sizeof(*listener), KM_SLEEP);
795 kmem_free(listener, sizeof(*listener))
904 kauth_listener_t listener; local
975 kauth_listener_t listener; local
[all...] |
