Home
last modified time | relevance | path

Searched refs:listener (Results 1 – 25 of 129) sorted by relevance

123456

/netbsd/external/mpl/bind/dist/bin/named/
H A Dcontrolconf.c155 free_controlkeylist(&listener->keys, listener->mctx); in free_listener()
161 isc_mem_putanddetach(&listener->mctx, listener, sizeof(*listener)); in free_listener()
166 if (listener->exiting && !listener->listening && in maybe_free_listener()
175 controllistener_t *listener = conn->listener; in maybe_free_connection() local
234 isc_socket_cancel(listener->sock, listener->task, in shutdown_listener()
293 controllistener_t *listener = conn->listener; in control_senddone() local
363 listener = conn->listener; in control_recvmessage()
607 conn->listener = listener; in newconnection()
990 listener = ISC_LIST_NEXT(listener, link)) in update_listener()
1141 listener = isc_mem_get(mctx, sizeof(*listener)); in add_listener()
[all …]
H A Dstatschannel.c3639 LOCK(&listener->lock); in client_ok()
3668 isc_mem_putanddetach(&listener->mctx, listener, sizeof(*listener)); in destroy_listener()
3683 listener = isc_mem_get(server->mctx, sizeof(*listener)); in add_listener()
3687 listener->acl = NULL; in add_listener()
3688 listener->mctx = NULL; in add_listener()
3781 *listenerp = listener; in add_listener()
3792 isc_mem_putanddetach(&listener->mctx, listener, in add_listener()
3815 for (listener = ISC_LIST_HEAD(server->statschannels); listener != NULL; in update_listener()
3816 listener = ISC_LIST_NEXT(listener, link)) in update_listener()
3855 *listenerp = listener; in update_listener()
[all …]
/netbsd/external/bsd/libevent/dist/test/
H A Dregress_listener.c177 tt_assert(listener); in regress_listener_error()
181 tt_assert(listener); in regress_listener_error()
187 if (listener) in regress_listener_error()
188 evconnlistener_free(listener); in regress_listener_error()
201 evconnlistener_free(listener); in acceptcb_free()
224 tt_assert(listener); in regress_listener_close_accepted_fd()
257 tt_assert(listener); in regress_listener_immediate_close()
270 if (listener) in regress_listener_immediate_close()
271 evconnlistener_free(listener); in regress_listener_immediate_close()
288 tt_assert(listener); in regress_listener_error_unlock()
[all …]
H A Dtest-fdleak.c111 listener_accept_cb(struct evconnlistener *listener, evutil_socket_t sock, in listener_accept_cb() argument
114 struct event_base *base = evconnlistener_get_base(listener); in listener_accept_cb()
126 struct evconnlistener *listener; in start_loop() local
137 listener = evconnlistener_new_bind(base, listener_accept_cb, NULL, in start_loop()
140 if (listener == NULL) { in start_loop()
144 fd = evconnlistener_get_fd(listener); in start_loop()
163 evconnlistener_free(listener); in start_loop()
H A Dregress_ssl.c611 evconnlistener_disable(listener); in acceptcb()
735 struct evconnlistener *listener; in regress_bufferevent_openssl_connect() local
757 tt_assert(listener); in regress_bufferevent_openssl_connect()
758 tt_assert(evconnlistener_get_fd(listener) >= 0); in regress_bufferevent_openssl_connect()
772 tt_assert(getsockname(evconnlistener_get_fd(listener), in regress_bufferevent_openssl_connect()
798 evconnlistener_free(listener); in regress_bufferevent_openssl_connect()
881 evconnlistener_disable(listener); in wm_acceptcb()
889 struct evconnlistener *listener; in regress_bufferevent_openssl_wm() local
942 tt_assert(listener); in regress_bufferevent_openssl_wm()
943 tt_assert(evconnlistener_get_fd(listener) >= 0); in regress_bufferevent_openssl_wm()
[all …]
H A Dtest-ratelim.c191 echo_listenercb(struct evconnlistener *listener, evutil_socket_t newsock, in echo_listenercb() argument
327 struct evconnlistener *listener; in test_ratelimiting() local
382 listener = evconnlistener_new_bind(base, echo_listenercb, base, in test_ratelimiting()
385 if (! listener) { in test_ratelimiting()
391 if (getsockname(evconnlistener_get_fd(listener), (struct sockaddr *)&ss, in test_ratelimiting()
470 evconnlistener_free(listener); in test_ratelimiting()
/netbsd/external/apache2/llvm/dist/llvm/utils/unittest/googlemock/include/gmock/
H A Dgmock-matchers.h344 if (!listener->IsInterested()) { in MatchPrintAndExplain()
1177 *listener << no_match_result;
1759 value, listener);
1826 value, listener);
1992 *listener
2220 *listener << "which is ";
2338 *listener << ", ";
2655 listener);
2668 *listener << ", ";
2670 *listener << "and ";
[all …]
/netbsd/external/apache2/llvm/dist/llvm/utils/unittest/googlemock/src/
H A Dgmock-matchers.cc391 if (listener->IsInterested()) { in VerifyMatchMatrix()
392 *listener << sep << "matcher #" << mi << ": "; in VerifyMatchMatrix()
393 matcher_describers_[mi]->DescribeTo(listener->stream()); in VerifyMatchMatrix()
409 if (listener->IsInterested()) { in VerifyMatchMatrix()
427 if (listener->IsInterested()) { in FindPairing()
432 LogElementMatcherPairVec(matches, listener->stream()); in FindPairing()
438 if (listener->IsInterested()) { in FindPairing()
439 *listener in FindPairing()
443 LogElementMatcherPairVec(matches, listener->stream()); in FindPairing()
449 if (listener->IsInterested()) { in FindPairing()
[all …]
/netbsd/external/bsd/ntp/dist/sntp/libevent/
H A Dlistener.c91 struct event listener; member
107 #define LOCK(listener) EVLOCK_LOCK((listener)->lock, 0) argument
108 #define UNLOCK(listener) EVLOCK_UNLOCK((listener)->lock, 0) argument
125 LOCK(listener);
126 ++listener->refcnt;
135 listener->ops->destroy(listener); in listener_decref_and_unlock()
136 UNLOCK(listener); in listener_decref_and_unlock()
138 mm_free(listener); in listener_decref_and_unlock()
141 UNLOCK(listener); in listener_decref_and_unlock()
256 if (!listener) in evconnlistener_new_bind()
[all …]
/netbsd/external/bsd/libevent/dist/
H A Dlistener.c93 struct event listener; member
109 #define LOCK(listener) EVLOCK_LOCK((listener)->lock, 0) argument
110 #define UNLOCK(listener) EVLOCK_UNLOCK((listener)->lock, 0) argument
127 LOCK(listener);
128 ++listener->refcnt;
137 listener->ops->destroy(listener); in listener_decref_and_unlock()
138 UNLOCK(listener); in listener_decref_and_unlock()
140 mm_free(listener); in listener_decref_and_unlock()
143 UNLOCK(listener); in listener_decref_and_unlock()
263 if (!listener) in evconnlistener_new_bind()
[all …]
/netbsd/external/apache2/llvm/dist/llvm/include/llvm/Testing/Support/
H A DError.h39 testing::MatchResultListener *listener) const override { in MatchAndExplain() argument
43 bool result = Matcher.MatchAndExplain(*Holder.Exp, listener); in MatchAndExplain()
45 if (result || !listener->IsInterested()) in MatchAndExplain()
47 *listener << "("; in MatchAndExplain()
48 Matcher.DescribeNegationTo(listener->stream()); in MatchAndExplain()
49 *listener << ")"; in MatchAndExplain()
91 testing::MatchResultListener *listener) const override { in MatchAndExplain() argument
96 *listener << "multiple errors"; in MatchAndExplain()
102 *listener << "Error was not of given type"; in MatchAndExplain()
109 return Matcher->MatchAndExplain(static_cast<InfoT &>(Info), listener); in MatchAndExplain()
[all …]
/netbsd/external/mpl/bind/dist/lib/dns/
H A Ddb.c293 for (listener = ISC_LIST_HEAD(db->update_listeners); listener != NULL; in dns_db_endload()
294 listener = ISC_LIST_NEXT(listener, link)) in dns_db_endload()
296 listener->onupdate(db, listener->onupdate_arg); in dns_db_endload()
419 listener != NULL; listener = ISC_LIST_NEXT(listener, link)) in dns_db_closeversion()
421 listener->onupdate(db, listener->onupdate_arg); in dns_db_closeversion()
1031 for (listener = ISC_LIST_HEAD(db->update_listeners); listener != NULL; in dns_db_updatenotify_register()
1032 listener = ISC_LIST_NEXT(listener, link)) in dns_db_updatenotify_register()
1043 listener->onupdate = fn; in dns_db_updatenotify_register()
1046 ISC_LINK_INIT(listener, link); in dns_db_updatenotify_register()
1059 for (listener = ISC_LIST_HEAD(db->update_listeners); listener != NULL; in dns_db_updatenotify_unregister()
[all …]
/netbsd/sys/kern/
H A Dkern_auth.c779 listener = kmem_alloc(sizeof(*listener), KM_SLEEP); in kauth_register_scope()
792 kmem_free(listener, sizeof(*listener)); in kauth_register_scope()
808 listener->refcnt = 0; in kauth_register_scope()
903 listener = kmem_alloc(sizeof(*listener), KM_SLEEP); in kauth_listen_scope()
912 kmem_free(listener, sizeof(*listener)); in kauth_listen_scope()
920 listener->refcnt = 0; in kauth_listen_scope()
927 listener->scope = scope; in kauth_listen_scope()
931 return (listener); in kauth_listen_scope()
943 if (listener != NULL) { in kauth_unlisten_scope()
945 SIMPLEQ_REMOVE(&listener->scope->listenq, listener, in kauth_unlisten_scope()
[all …]
/netbsd/external/bsd/ntp/dist/sntp/libevent/test/
H A Dregress_listener.c57 acceptcb(struct evconnlistener *listener, evutil_socket_t fd, in acceptcb() argument
66 evconnlistener_disable(listener); in acceptcb()
158 struct evconnlistener *listener = NULL; in regress_listener_error() local
170 listener = evconnlistener_new(base, acceptcb, &count, in regress_listener_error()
173 tt_assert(listener); in regress_listener_error()
175 evconnlistener_set_error_cb(listener, errorcb); in regress_listener_error()
177 tt_assert(listener); in regress_listener_error()
183 if (listener) in regress_listener_error()
184 evconnlistener_free(listener); in regress_listener_error()
H A Dtest-fdleak.c107 listener_accept_cb(struct evconnlistener *listener, evutil_socket_t sock, in listener_accept_cb() argument
110 struct event_base *base = evconnlistener_get_base(listener); in listener_accept_cb()
123 struct evconnlistener *listener; in start_loop() local
134 listener = evconnlistener_new_bind(base, listener_accept_cb, NULL, in start_loop()
137 if (listener == NULL) { in start_loop()
141 fd = evconnlistener_get_fd(listener); in start_loop()
H A Dregress_ssl.c392 acceptcb(struct evconnlistener *listener, evutil_socket_t fd, in acceptcb() argument
415 evconnlistener_disable(listener); in acceptcb()
425 struct evconnlistener *listener; in regress_bufferevent_openssl_connect() local
440 listener = evconnlistener_new_bind(base, acceptcb, data, in regress_bufferevent_openssl_connect()
444 tt_assert(listener); in regress_bufferevent_openssl_connect()
445 tt_assert(evconnlistener_get_fd(listener) >= 0); in regress_bufferevent_openssl_connect()
456 tt_assert(getsockname(evconnlistener_get_fd(listener), in regress_bufferevent_openssl_connect()
H A Dtest-ratelim.c176 echo_listenercb(struct evconnlistener *listener, evutil_socket_t newsock, in echo_listenercb() argument
254 struct evconnlistener *listener; in test_ratelimiting() local
296 listener = evconnlistener_new_bind(base, echo_listenercb, base, in test_ratelimiting()
299 if (! listener) { in test_ratelimiting()
305 if (getsockname(evconnlistener_get_fd(listener), (struct sockaddr *)&ss, in test_ratelimiting()
388 evconnlistener_free(listener); in test_ratelimiting()
/netbsd/external/mpl/dhcp/dist/omapip/
H A Dlistener.c223 omapi_listener_object_t *listener; in omapi_accept() local
229 listener = (omapi_listener_object_t *)h; in omapi_accept()
233 socket = accept (listener -> socket, in omapi_accept()
254 iov [2].buf = (char *)&listener -> address.sin_port; in omapi_accept()
255 iov [2].len = sizeof listener -> address.sin_port; in omapi_accept()
262 status = omapi_listener_connect (&obj, listener, socket, &addr); in omapi_accept()
284 omapi_listener_object_t *listener, in omapi_listener_connect() argument
289 omapi_object_t *h = (omapi_object_t *)listener; in omapi_listener_connect()
306 if (listener -> verify_addr) { in omapi_listener_connect()
313 status = (listener -> verify_addr) (h, &addr); in omapi_listener_connect()
[all …]
H A Dtest.c48 omapi_object_t *listener = (omapi_object_t*)0; in main() local
72 status = omapi_generic_new (&listener, MDL); in main()
78 status = omapi_protocol_listen (listener, in main()
H A Dconnection.c306 if (obj -> listener) in omapi_connection_register()
307 listener_index = htonl (obj -> listener -> index); in omapi_connection_register()
368 omapi_listener_object_t *listener; in trace_connect_input() local
369 listener = (omapi_listener_object_t *)0; in trace_connect_input()
373 omapi_listener_reference (&listener, lp, MDL); in trace_connect_input()
379 if (!listener) { in trace_connect_input()
388 status = omapi_listener_connect (&obj, listener, -1, &remote); in trace_connect_input()
395 omapi_listener_dereference (&listener, MDL); in trace_connect_input()
1054 if (c -> listener) in omapi_connection_destroy()
1055 omapi_listener_dereference (&c -> listener, file, line); in omapi_connection_destroy()
/netbsd/external/bsd/libevent/dist/sample/
H A Dhello-world.c43 struct evconnlistener *listener; in main() local
61 listener = evconnlistener_new_bind(base, listener_cb, (void *)base, in main()
66 if (!listener) { in main()
80 evconnlistener_free(listener); in main()
89 listener_cb(struct evconnlistener *listener, evutil_socket_t fd, in listener_cb() argument
H A Dle-proxy.c160 accept_cb(struct evconnlistener *listener, evutil_socket_t fd, in accept_cb() argument
218 struct evconnlistener *listener; in main() local
287 listener = evconnlistener_new_bind(base, accept_cb, NULL, in main()
291 if (! listener) { in main()
298 evconnlistener_free(listener); in main()
/netbsd/external/apache2/llvm/dist/llvm/utils/unittest/googletest/include/gtest/
H A Dgtest-matchers.h199 MatchResultListener* listener) const override { in MatchAndExplain() argument
200 return impl_->MatchAndExplain(x, listener); in MatchAndExplain()
263 bool MatchAndExplain(const T& x, MatchResultListener* listener) const { in MatchAndExplain() argument
264 return impl_->MatchAndExplain(x, listener); in MatchAndExplain()
283 StreamMatchResultListener listener(os); in ExplainMatchResultTo()
284 MatchAndExplain(x, &listener); in ExplainMatchResultTo()
484 return impl_.MatchAndExplain(x, listener); in MatchAndExplain()
625 MatchResultListener* listener) const { in MatchAndExplain() argument
626 return MatchAndExplain(std::string(s), listener); in MatchAndExplain()
636 bool MatchAndExplain(CharType* s, MatchResultListener* listener) const { in MatchAndExplain() argument
[all …]
/netbsd/external/bsd/tcpdump/dist/tests/
H A Dicmpv6.out23 … ff02::16: HBH (rtalert: 0x0000) (padn) [icmp6 sum ok] ICMP6, multicast listener report v2, 1 grou…
24 …> ff02::1: HBH (rtalert: 0x0000) (padn) [icmp6 sum ok] ICMP6, multicast listener query v2 [max res…
25 … ff02::16: HBH (rtalert: 0x0000) (padn) [icmp6 sum ok] ICMP6, multicast listener report v2, 4 grou…
26 … ff02::16: HBH (rtalert: 0x0000) (padn) [icmp6 sum ok] ICMP6, multicast listener report v2, 1 grou…
/netbsd/external/bsd/openldap/dist/servers/lloadd/
H A Ddaemon.c131 struct evconnlistener *listener; member
823 evconnlistener_free( lr->listener ); in destroy_listeners()
838 struct evconnlistener *listener, in lload_listener() argument
968 assert( l->listener == lev ); in listener_error_cb()
1008 evconnlistener_enable( lr->listener ); in listeners_reactivate()
1026 struct evconnlistener *listener; in lload_listener_activate() local
1145 if ( !listener ) { in lload_listener_activate()
1190 lload_listeners[l]->listener = listener; in lload_listener_activate()
1191 evconnlistener_set_error_cb( listener, listener_error_cb ); in lload_listener_activate()
1876 evconnlistener_disable( lload_listeners[i]->listener ); in lload_suspend_listeners()
[all …]

123456