| /libevent-2.1.12/test/ |
| H A D | bench_httpclient.c | 114 frob_socket(evutil_socket_t sock) in frob_socket() argument
125 if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (void*)&l, sizeof(l))<0) in frob_socket()
133 evutil_socket_t sock; in launch_request() local
146 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) in launch_request()
148 if (evutil_make_socket_nonblocking(sock) < 0) { in launch_request()
149 evutil_closesocket(sock); in launch_request()
152 frob_socket(sock); in launch_request()
153 if (connect(sock, (struct sockaddr*)&sin, sizeof(sin)) < 0) { in launch_request()
154 int e = evutil_socket_geterror(sock); in launch_request()
156 evutil_closesocket(sock); in launch_request()
[all …]
|
| H A D | regress_testutils.c | 100 evutil_socket_t sock; in regress_get_dnsserver() local
103 sock = socket(AF_INET, SOCK_DGRAM, 0); in regress_get_dnsserver()
104 if (sock < 0) { in regress_get_dnsserver()
108 evutil_make_socket_nonblocking(sock); in regress_get_dnsserver()
114 if (bind(sock, (struct sockaddr*)&my_addr, sizeof(my_addr)) < 0) { in regress_get_dnsserver()
115 evutil_closesocket(sock); in regress_get_dnsserver()
118 port = evdns_add_server_port_with_base(base, sock, 0, cb, arg); in regress_get_dnsserver()
120 *portnum = regress_get_socket_port(sock); in regress_get_dnsserver()
122 *psock = sock; in regress_get_dnsserver()
|
| H A D | bench_cascade.c | 70 evutil_socket_t sock = (evutil_socket_t)(ev_intptr_t)arg; in read_cb() local
73 if (sock >= 0) { in read_cb()
74 if (send(sock, "e", 1, 0) < 0) in read_cb()
|
| H A D | test-fdleak.c | 108 listener_accept_cb(struct evconnlistener *listener, evutil_socket_t sock, in listener_accept_cb() argument
112 struct bufferevent *bev = bufferevent_socket_new(base, sock, in listener_accept_cb()
|
| H A D | regress_rpc.c | 80 struct evhttp_bound_socket *sock; in http_setup() local
87 sock = evhttp_bind_socket_with_handle(myhttp, "127.0.0.1", 0); in http_setup()
88 if (!sock) in http_setup()
91 port = regress_get_socket_port(evhttp_bound_socket_get_fd(sock)); in http_setup()
|
| H A D | regress_dns.c | 378 evutil_socket_t sock=-1; in dns_server() local
393 sock = socket(AF_INET, SOCK_DGRAM, 0); in dns_server()
394 if (sock<0) { in dns_server()
398 evutil_make_socket_nonblocking(sock); in dns_server()
404 if (bind(sock, (struct sockaddr*)&my_addr, sizeof(my_addr)) < 0) { in dns_server()
408 if (getsockname(sock, (struct sockaddr*)&ss, &slen) < 0) { in dns_server()
412 port = evdns_add_server_port(sock, 0, dns_server_request_cb, NULL); in dns_server()
463 if (sock >= 0) in dns_server()
464 evutil_closesocket(sock); in dns_server()
|
| H A D | regress.c | 3095 evutil_socket_t sock[MANY]; in test_many_events() local
3105 memset(sock, 0xff, sizeof(sock)); in test_many_events()
3113 sock[i] = socket(AF_INET, SOCK_DGRAM, 0); in test_many_events()
3114 tt_assert(sock[i] >= 0); in test_many_events()
3115 tt_assert(!evutil_make_socket_nonblocking(sock[i])); in test_many_events()
3117 ev[i] = event_new(base, sock[i], EV_WRITE|evflags, in test_many_events()
3137 if (sock[i] >= 0) in test_many_events()
3138 evutil_closesocket(sock[i]); in test_many_events()
|
| H A D | regress_http.c | 96 struct evhttp_bound_socket *sock; in http_bind() local
100 sock = evhttp_bind_socket_with_handle(myhttp, "::1", *pport); in http_bind()
102 sock = evhttp_bind_socket_with_handle(myhttp, "127.0.0.1", *pport); in http_bind()
104 if (sock == NULL) { in http_bind()
111 port = regress_get_socket_port(evhttp_bound_socket_get_fd(sock)); in http_bind()
|
| /libevent-2.1.12/include/event2/ |
| H A D | util.h | 397 int evutil_make_socket_nonblocking(evutil_socket_t sock);
411 int evutil_make_listen_socket_reuseable(evutil_socket_t sock);
424 int evutil_make_listen_socket_reuseable_port(evutil_socket_t sock);
436 int evutil_make_listen_socket_ipv6only(evutil_socket_t sock);
445 int evutil_make_socket_closeonexec(evutil_socket_t sock);
455 int evutil_closesocket(evutil_socket_t sock);
470 int evutil_make_tcp_listen_socket_deferred(evutil_socket_t sock);
480 int evutil_socket_geterror(evutil_socket_t sock);
505 #define evutil_socket_geterror(sock) ... argument
514 #define evutil_socket_geterror(sock) (errno) argument
|
| /libevent-2.1.12/sample/ |
| H A D | dns-example.c | 198 evutil_socket_t sock; in main() local
200 sock = socket(PF_INET, SOCK_DGRAM, 0); in main()
201 if (sock == -1) { in main()
205 evutil_make_socket_nonblocking(sock); in main()
209 if (bind(sock, (struct sockaddr*)&my_addr, sizeof(my_addr))<0) { in main()
213 evdns_add_server_port_with_base(event_base, sock, 0, evdns_server_callback, NULL); in main()
|
| /libevent-2.1.12/ |
| H A D | log.c | 123 event_sock_err(int eval, evutil_socket_t sock, const char *fmt, ...) in event_sock_err() argument
126 int err = evutil_socket_geterror(sock); in event_sock_err()
135 event_sock_warn(evutil_socket_t sock, const char *fmt, ...) in event_sock_warn() argument
138 int err = evutil_socket_geterror(sock); in event_sock_warn()
|
| H A D | log-internal.h | 62 void event_sock_err(int eval, evutil_socket_t sock, const char *fmt, ...) EV_CHECK_FMT(3,4) EV_NORE…
64 void event_sock_warn(evutil_socket_t sock, const char *fmt, ...) EV_CHECK_FMT(2,3);
|
| H A D | evutil.c | 365 evutil_make_listen_socket_reuseable(evutil_socket_t sock) in evutil_make_listen_socket_reuseable() argument
380 evutil_make_listen_socket_reuseable_port(evutil_socket_t sock) in evutil_make_listen_socket_reuseable_port() argument
394 evutil_make_listen_socket_ipv6only(evutil_socket_t sock) in evutil_make_listen_socket_ipv6only() argument
405 evutil_make_tcp_listen_socket_deferred(evutil_socket_t sock) in evutil_make_tcp_listen_socket_deferred() argument
412 return setsockopt(sock, IPPROTO_TCP, TCP_DEFER_ACCEPT, &one, in evutil_make_tcp_listen_socket_deferred()
454 evutil_closesocket(evutil_socket_t sock) in evutil_closesocket() argument
457 return close(sock); in evutil_closesocket()
459 return closesocket(sock); in evutil_closesocket()
525 evutil_socket_geterror(evutil_socket_t sock) in evutil_socket_geterror() argument
529 if (err == WSAEWOULDBLOCK && sock >= 0) { in evutil_socket_geterror()
[all …]
|
| H A D | listener.c | 614 evutil_socket_t sock=-1; in accepted_socket_invoke_user_cb() local
641 sock = as->s; in accepted_socket_invoke_user_cb()
648 setsockopt(sock, SOL_SOCKET, SO_UPDATE_ACCEPT_CONTEXT, in accepted_socket_invoke_user_cb()
660 cb(lev, sock, sa_remote, socklen_remote, data); in accepted_socket_invoke_user_cb()
|
| H A D | bufferevent_async.c | 438 evutil_socket_t sock; in connect_complete() local
444 sock = evbuffer_overlapped_get_fd_(bev_a->bev.bev.input); in connect_complete()
446 setsockopt(sock, SOL_SOCKET, SO_UPDATE_CONNECT_CONTEXT, NULL, 0); in connect_complete()
|
| H A D | ChangeLog | 567 o test/regress_be: basic coverage bufferevent_flush() for pair/sock layers (ad52602 Azat Khuzhin)
|