| /libevent-2.1.12/ |
| H A D | event_iocp.c | 68 HANDLE p = port->port; in loop()
106 h = CreateIoCompletionPort((HANDLE)fd, port->port, key, port->n_threads); in event_iocp_port_associate_()
190 port->threads = mm_calloc(port->n_threads, sizeof(HANDLE)); in event_iocp_port_launch_()
196 port->ms = -1; in event_iocp_port_launch_()
197 if (!port->port) in event_iocp_port_launch_()
214 return port; in event_iocp_port_launch_()
216 if (port->port) in event_iocp_port_launch_()
217 CloseHandle(port->port); in event_iocp_port_launch_()
222 mm_free(port); in event_iocp_port_launch_()
230 CloseHandle(port->port); in event_iocp_port_unlock_and_free_()
[all …]
|
| H A D | evdns.c | 1293 server_req->port = port; in request_parse()
1294 port->refcnt++; in request_parse()
1302 port->user_callback(&(server_req->base), port->user_data); in request_parse()
1473 event_assign(&port->event, port->event_base, in server_port_flush()
1742 event_assign(&port->event, port->event_base, in evdns_add_server_port_with_base()
1750 return port; in evdns_add_server_port_with_base()
2008 struct evdns_server_port *port = req->port; in evdns_server_request_respond() local
2035 …ent_assign(&port->event, port->event_base, port->socket, (port->closing?0:EV_READ) | EV_WRITE | EV… in evdns_server_request_respond()
2148 mm_free(port); in server_port_free()
4710 int port = 0; in evdns_getaddrinfo() local
[all …]
|
| H A D | iocp-internal.h | 77 HANDLE port; member
172 int event_iocp_port_associate_(struct event_iocp_port *port, evutil_socket_t fd,
182 int event_iocp_shutdown_(struct event_iocp_port *port, long waitMsec);
186 int event_iocp_activate_overlapped_(struct event_iocp_port *port,
|
| H A D | http.c | 2392 evcon->port = port; in evhttp_connection_base_bufferevent_new()
2554 *port = evcon->port; in evhttp_connection_get_peer()
3580 port)); in evhttp_bind_socket_with_handle()
4656 for (port=eos-1; port >= cp && EVUTIL_ISDIGIT_(*port); --port) in parse_authority()
4658 if (port >= cp && *port == ':') { in parse_authority()
4662 else if ((uri->port = parse_port(port+1, eos))<0) in parse_authority()
4664 eos = port; in parse_authority()
4782 uri->port = -1; in evhttp_uri_parse_with_flags()
4908 uri->port = -1; in evhttp_uri_parse_authority()
5096 if (port < -1) in evhttp_uri_set_port()
[all …]
|
| H A D | evutil.c | 996 int port = 0; in evutil_getaddrinfo_common_() local
1016 if (port < 0) { in evutil_getaddrinfo_common_()
1108 *portnum = port; in evutil_getaddrinfo_common_()
1187 sin.sin_port = htons(port); in addrinfo_from_hostent()
1479 int port=0, err; in evutil_getaddrinfo()
2141 int port; in evutil_parse_sockaddr_port() local
2192 port = 0; in evutil_parse_sockaddr_port()
2194 port = atoi(port_part); in evutil_parse_sockaddr_port()
2195 if (port <= 0 || port > 65535) { in evutil_parse_sockaddr_port()
2233 sin.sin_port = htons(port); in evutil_parse_sockaddr_port()
[all …]
|
| H A D | bufferevent_sock.c | 495 struct evdns_base *evdns_base, int family, const char *hostname, int port) in bufferevent_socket_connect_hostname() argument
503 if (port < 1 || port > 65535) in bufferevent_socket_connect_hostname()
511 evutil_snprintf(portbuf, sizeof(portbuf), "%d", port); in bufferevent_socket_connect_hostname()
|
| H A D | listener.c | 98 struct event_iocp_port *port; member
567 if (event_iocp_port_associate_(as->lev->port, s, 1) < 0) { in start_accepting()
851 lev->port = event_base_get_iocp_(base); in evconnlistener_new_async()
856 if (event_iocp_port_associate_(lev->port, fd, 1) < 0) in evconnlistener_new_async()
|
| H A D | http-internal.h | 65 ev_uint16_t port; member
|
| H A D | util-internal.h | 309 ev_socklen_t *socklen, int port);
|
| H A D | event-config.h.cmake | 229 /* Define to 1 if you have the <port.h> header file. */
|
| H A D | ChangeLog-1.4 | 73 …o Allow setting of local port for evhttp connections to support millions of connections from a sin…
|
| /libevent-2.1.12/test/ |
| H A D | regress_iocp.c | 157 struct event_iocp_port *port = NULL; in test_iocp_port() local
173 port = event_iocp_port_launch_(0); in test_iocp_port()
174 tt_assert(port); in test_iocp_port()
190 tt_want(!event_iocp_shutdown_(port, 2000)); in test_iocp_port()
240 struct event_iocp_port *port = NULL; in test_iocp_evbuffer() local
258 port = event_iocp_port_launch_(0); in test_iocp_evbuffer()
259 tt_assert(port); in test_iocp_evbuffer()
286 tt_want(!event_iocp_shutdown_(port, 2000)); in test_iocp_evbuffer()
308 struct event_iocp_port *port = NULL; in test_iocp_bufferevent_async() local
314 port = event_base_get_iocp_(data->base); in test_iocp_bufferevent_async()
[all …]
|
| H A D | regress_rpc.c | 79 ev_uint16_t port; in http_setup() local
93 *pport = port; in http_setup()
139 ev_uint16_t port; in rpc_setup() local
150 *pport = port; in rpc_setup()
186 ev_uint16_t port; in rpc_basic_test() local
255 ev_uint16_t port; in rpc_basic_message() local
447 ev_uint16_t port; in rpc_basic_client() local
533 ev_uint16_t port; in rpc_basic_queued_client() local
633 ev_uint16_t port; in rpc_basic_client_with_pause() local
685 ev_uint16_t port; in rpc_client_timeout() local
[all …]
|
| H A D | regress_http.c | 95 int port; in http_bind() local
112 if (port < 0) in http_bind()
813 ev_uint16_t port = 0; in http_delete_test() local
897 ev_uint16_t port = 0; in http_on_complete_test() local
958 ev_uint16_t port = 0; in http_allowed_methods_test() local
1064 ev_uint16_t port = 0; in http_connection_test_() local
1190 ev_uint16_t port = 0; in http_connection_async_test() local
1284 ev_uint16_t port = 0; in http_autofree_connection_test() local
1496 port = 0; in http_cancel_test()
1509 port); in http_cancel_test()
[all …]
|
| H A D | regress_testutils.c | 99 struct evdns_server_port *port = NULL; in regress_get_dnsserver() local
118 port = evdns_add_server_port_with_base(base, sock, 0, cb, arg); in regress_get_dnsserver()
124 return port; in regress_get_dnsserver()
217 regress_dnsserver(struct event_base *base, ev_uint16_t *port, in regress_dnsserver() argument
220 dns_port = regress_get_dnsserver(base, port, &dns_sock, in regress_dnsserver()
|
| H A D | bench_http.c | 93 ev_uint16_t port = 8080; in main() local
124 port = (int)strtol(argv[i+1], &endptr, 10); in main()
181 (int)content_len, port, in main()
184 evhttp_bind_socket(http, "0.0.0.0", port); in main()
|
| H A D | regress_dns.c | 461 if (port) in dns_server()
462 evdns_close_server_port(port); in dns_server()
664 tt_assert(port); in dns_search_cancel_test()
686 if (port) in dns_search_cancel_test()
687 evdns_close_server_port(port); in dns_search_cancel_test()
741 tt_assert(port); in dns_retry_test_impl()
796 if (port) in dns_retry_test_impl()
1288 tt_assert(port); in test_bufferevent_connect_hostname()
1386 if (port) in test_bufferevent_connect_hostname()
1600 tt_assert(port); in test_getaddrinfo_async()
[all …]
|
| H A D | regress_testutils.h | 55 int regress_dnsserver(struct event_base *base, ev_uint16_t *port,
|
| H A D | regress_util.c | 277 int port; member
318 sin.sin_port = htons(ent->port); in regress_sockaddr_port_parse()
334 sin6.sin6_port = htons(ent->port); in regress_sockaddr_port_parse()
|
| /libevent-2.1.12/include/event2/ |
| H A D | http.h | 101 int evhttp_bind_socket(struct evhttp *http, const char *address, ev_uint16_t port);
115 …socket *evhttp_bind_socket_with_handle(struct evhttp *http, const char *address, ev_uint16_t port);
525 …*base, struct evdns_base *dnsbase, struct bufferevent* bev, const char *address, ev_uint16_t port);
647 const char *address, ev_uint16_t port);
732 ev_uint16_t port);
766 char **address, ev_uint16_t *port);
1090 int evhttp_uri_set_port(struct evhttp_uri *uri, int port);
|
| H A D | http_compat.h | 63 struct evhttp *evhttp_start(const char *address, ev_uint16_t port);
74 const char *address, ev_uint16_t port);
|
| H A D | dns.h | 658 void evdns_close_server_port(struct evdns_server_port *port);
|
| /libevent-2.1.12/sample/ |
| H A D | https-client.c | 224 int port; in main() local
324 port = evhttp_uri_get_port(http_uri); in main()
325 if (port == -1) { in main()
326 port = (strcasecmp(scheme, "http") == 0) ? 80 : 443; in main()
451 host, port); in main()
|
| H A D | http-server.c | 103 int port; member
368 case 'p': o.port = atoi(optarg); break; in parse_opts()
546 handle = evhttp_bind_socket_with_handle(http, "0.0.0.0", o.port); in main()
548 fprintf(stderr, "couldn't bind to port %d. Exiting.\n", o.port); in main()
|
| /libevent-2.1.12/m4/ |
| H A D | acx_pthread.m4 | 135 # lthread: LinuxThreads port on FreeBSD (also preferred to -pthread)
|