Home
last modified time | relevance | path

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

/libevent-2.1.12/test/
H A Dregress_listener.c175 tt_assert(listener); in regress_listener_error()
179 tt_assert(listener); in regress_listener_error()
185 if (listener) in regress_listener_error()
186 evconnlistener_free(listener); in regress_listener_error()
199 evconnlistener_free(listener); in acceptcb_free()
222 tt_assert(listener); in regress_listener_close_accepted_fd()
255 tt_assert(listener); in regress_listener_immediate_close()
268 if (listener) in regress_listener_immediate_close()
269 evconnlistener_free(listener); in regress_listener_immediate_close()
286 tt_assert(listener); in regress_listener_error_unlock()
[all …]
H A Dtest-fdleak.c108 listener_accept_cb(struct evconnlistener *listener, evutil_socket_t sock, in listener_accept_cb() argument
111 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()
160 evconnlistener_free(listener); in start_loop()
H A Dregress_ssl.c609 evconnlistener_disable(listener); in acceptcb()
733 struct evconnlistener *listener; in regress_bufferevent_openssl_connect() local
755 tt_assert(listener); in regress_bufferevent_openssl_connect()
756 tt_assert(evconnlistener_get_fd(listener) >= 0); in regress_bufferevent_openssl_connect()
770 tt_assert(getsockname(evconnlistener_get_fd(listener), in regress_bufferevent_openssl_connect()
796 evconnlistener_free(listener); in regress_bufferevent_openssl_connect()
879 evconnlistener_disable(listener); in wm_acceptcb()
887 struct evconnlistener *listener; in regress_bufferevent_openssl_wm() local
940 tt_assert(listener); in regress_bufferevent_openssl_wm()
941 tt_assert(evconnlistener_get_fd(listener) >= 0); in regress_bufferevent_openssl_wm()
[all …]
H A Dtest-ratelim.c190 echo_listenercb(struct evconnlistener *listener, evutil_socket_t newsock, in echo_listenercb() argument
326 struct evconnlistener *listener; in test_ratelimiting() local
381 listener = evconnlistener_new_bind(base, echo_listenercb, base, in test_ratelimiting()
384 if (! listener) { in test_ratelimiting()
390 if (getsockname(evconnlistener_get_fd(listener), (struct sockaddr *)&ss, in test_ratelimiting()
469 evconnlistener_free(listener); in test_ratelimiting()
H A Dregress_dns.c1256 struct evconnlistener *listener = NULL; in test_bufferevent_connect_hostname() local
1278 listener = evconnlistener_new_bind(data->base, nil_accept_cb, in test_bufferevent_connect_hostname()
1282 tt_assert(listener); in test_bufferevent_connect_hostname()
1284 evconnlistener_get_fd(listener)); in test_bufferevent_connect_hostname()
1384 if (listener) in test_bufferevent_connect_hostname()
1385 evconnlistener_free(listener); in test_bufferevent_connect_hostname()
H A Dregress_bufferevent.c641 listen_cb(struct evconnlistener *listener, evutil_socket_t fd, in listen_cb() argument
/libevent-2.1.12/
H A Dlistener.c90 struct event listener; member
106 #define LOCK(listener) EVLOCK_LOCK((listener)->lock, 0) argument
107 #define UNLOCK(listener) EVLOCK_UNLOCK((listener)->lock, 0) argument
124 LOCK(listener);
125 ++listener->refcnt;
134 listener->ops->destroy(listener); in listener_decref_and_unlock()
135 UNLOCK(listener); in listener_decref_and_unlock()
137 mm_free(listener); in listener_decref_and_unlock()
140 UNLOCK(listener); in listener_decref_and_unlock()
260 if (!listener) in evconnlistener_new_bind()
[all …]
H A Devutil.c227 evutil_socket_t listener = -1; in evutil_ersatz_socketpair_() local
250 listener = socket(AF_INET, type, 0); in evutil_ersatz_socketpair_()
251 if (listener < 0) in evutil_ersatz_socketpair_()
257 if (bind(listener, (struct sockaddr *) &listen_addr, sizeof (listen_addr)) in evutil_ersatz_socketpair_()
260 if (listen(listener, 1) == -1) in evutil_ersatz_socketpair_()
271 if (getsockname(listener, (struct sockaddr *) &connect_addr, &size) == -1) in evutil_ersatz_socketpair_()
280 acceptor = accept(listener, (struct sockaddr *) &listen_addr, &size); in evutil_ersatz_socketpair_()
294 evutil_closesocket(listener); in evutil_ersatz_socketpair_()
305 if (listener != -1) in evutil_ersatz_socketpair_()
306 evutil_closesocket(listener); in evutil_ersatz_socketpair_()
H A Dhttp-internal.h124 struct evconnlistener *listener; member
H A DMakefile.nmake33 bufferevent_pair.obj listener.obj evmap.obj log.obj evutil.obj \
H A Dhttp.c3612 struct evconnlistener *listener; in evhttp_accept_socket_with_handle() local
3616 listener = evconnlistener_new(http->base, NULL, NULL, in evhttp_accept_socket_with_handle()
3620 if (!listener) in evhttp_accept_socket_with_handle()
3623 bound = evhttp_bind_listener(http, listener); in evhttp_accept_socket_with_handle()
3625 evconnlistener_free(listener); in evhttp_accept_socket_with_handle()
3640 bound->listener = listener; in evhttp_bind_listener()
3643 evconnlistener_set_cb(listener, accept_socket_cb, http); in evhttp_bind_listener()
3650 return evconnlistener_get_fd(bound->listener); in evhttp_bound_socket_get_fd()
3656 return bound->listener; in evhttp_bound_socket_get_listener()
3663 evconnlistener_free(bound->listener); in evhttp_del_accept_socket()
[all …]
H A DMakefile.am244 listener.c \
H A Dwhatsnew-2.1.txt400 flag. Previously, it would apply to the listener sockets, but not to
402 Now, it applies both to the listener and the accepted sockets.
428 every listener on an evhttp object.
504 The evutil_make_tcp_listen_socket_deferred() can make a tcp listener socket
H A DDoxyfile78 $(SRCDIR)/include/event2/listener.h \
H A DChangeLog256 listener:
258 o Merge branch 'listener-immediate-close' (df2ed13f)
498 o listener: unlock lev on error in listener_read_cb() (2a71b33 Azat Khuzhin)
521 o test/listener: regression for missing unlock in listener_read_cb() (7d85651 Azat Khuzhin)
1103 o le-proxy: Fail more gracefully if opening listener fails (44b2491)
1440 …o iocp: Close IOCP listener socket on free when LEV_OPT_CLOSE_ON_FREE is set (cb853ea Juan Pablo F…
1914 o Minimize syscalls during socket creation in listener.c (7e9e289)
1918 o Save syscalls when constructing listener sockets for evhttp (af6c9d8)
2008 o The LEV_OPT_CLOSE_ON_EXEC flag now applies to accepted listener
H A Dwhatsnew-2.0.txt561 event2/listener.h header.
563 The listener code supports IOCP on Windows if available.
H A DCMakeLists.txt790 include/event2/listener.h
814 listener.c
H A DChangeLog-2.011 …o iocp: Close IOCP listener socket on free when LEV_OPT_CLOSE_ON_FREE is set (cb853ea Juan Pablo F…
406 o Add a function to change a listener's callback. (46ee061)
544 o Make iocp/listener/error work; don't accept again if lev is disabled. (62b429a Christopher Davis)
554 o Unit tests for listener error callbacks (045eef4)
1028 o New evconnlistener_get_fd function to expose a listener's associated socket.
1051 o Fix compilation for listener.h for C++ - missing extern "C". Patch from Ferenc Szalai.
/libevent-2.1.12/sample/
H A Dhello-world.c42 struct evconnlistener *listener; in main() local
60 listener = evconnlistener_new_bind(base, listener_cb, (void *)base, in main()
65 if (!listener) { in main()
79 evconnlistener_free(listener); in main()
88 listener_cb(struct evconnlistener *listener, evutil_socket_t fd, in listener_cb() argument
H A Dle-proxy.c159 accept_cb(struct evconnlistener *listener, evutil_socket_t fd, in accept_cb() argument
217 struct evconnlistener *listener; in main() local
286 listener = evconnlistener_new_bind(base, accept_cb, NULL, in main()
290 if (! listener) { in main()
297 evconnlistener_free(listener); in main()
/libevent-2.1.12/include/
H A Dinclude.am25 include/event2/listener.h \
/libevent-2.1.12/cmake/
H A DUseDoxygen.cmake67 include/event2/listener.h
/libevent-2.1.12/include/event2/
H A Dhttp.h155 …ct evhttp_bound_socket *evhttp_bind_listener(struct evhttp *http, struct evconnlistener *listener);