284 	struct evdns_server_port *port; /* Which port received this request on? */  member
413 static void server_port_free(struct evdns_server_port *port);
1233 request_parse(u8 *packet, int length, struct evdns_server_port *port, struct sockaddr *addr, ev_soc…  in request_parse()  argument
1243 	ASSERT_LOCKED(port);  in request_parse()
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()
1449 server_port_flush(struct evdns_server_port *port)  in server_port_flush()  argument
1451 	struct server_request *req = port->pending_replies;  in server_port_flush()
1452 	ASSERT_LOCKED(port);  in server_port_flush()
1454 		int r = sendto(port->socket, req->response, (int)req->response_len, 0,  in server_port_flush()
1457 			int err = evutil_socket_geterror(port->socket);  in server_port_flush()
1466 			EVUTIL_ASSERT(req != port->pending_replies);  in server_port_flush()
1467 			req = port->pending_replies;  in server_port_flush()
1472 	(void) event_del(&port->event);  in server_port_flush()
1473 	event_assign(&port->event, port->event_base,  in server_port_flush()
1474 				 port->socket, EV_READ | EV_PERSIST,  in server_port_flush()
1475 				 server_port_ready_callback, port);  in server_port_flush()
1477 	if (event_add(&port->event, NULL) < 0) {  in server_port_flush()
1530 	struct evdns_server_port *port = (struct evdns_server_port *) arg;  in server_port_ready_callback()  local
1533 	EVDNS_LOCK(port);  in server_port_ready_callback()
1535 		port->choked = 0;  in server_port_ready_callback()
1536 		server_port_flush(port);  in server_port_ready_callback()
1539 		server_port_read(port);  in server_port_ready_callback()
1541 	EVDNS_UNLOCK(port);  in server_port_ready_callback()
1725 	struct evdns_server_port *port;  in evdns_add_server_port_with_base()  local
1728 	if (!(port = mm_malloc(sizeof(struct evdns_server_port))))  in evdns_add_server_port_with_base()
1730 	memset(port, 0, sizeof(struct evdns_server_port));  in evdns_add_server_port_with_base()
1733 	port->socket = socket;  in evdns_add_server_port_with_base()
1734 	port->refcnt = 1;  in evdns_add_server_port_with_base()
1735 	port->choked = 0;  in evdns_add_server_port_with_base()
1736 	port->closing = 0;  in evdns_add_server_port_with_base()
1737 	port->user_callback = cb;  in evdns_add_server_port_with_base()
1738 	port->user_data = user_data;  in evdns_add_server_port_with_base()
1739 	port->pending_replies = NULL;  in evdns_add_server_port_with_base()
1740 	port->event_base = base;  in evdns_add_server_port_with_base()
1742 	event_assign(&port->event, port->event_base,  in evdns_add_server_port_with_base()
1743 				 port->socket, EV_READ | EV_PERSIST,  in evdns_add_server_port_with_base()
1744 				 server_port_ready_callback, port);  in evdns_add_server_port_with_base()
1745 	if (event_add(&port->event, NULL) < 0) {  in evdns_add_server_port_with_base()
1746 		mm_free(port);  in evdns_add_server_port_with_base()
1749 	EVTHREAD_ALLOC_LOCK(port->lock, EVTHREAD_LOCKTYPE_RECURSIVE);  in evdns_add_server_port_with_base()
1750 	return port;  in evdns_add_server_port_with_base()
1761 evdns_close_server_port(struct evdns_server_port *port)  in evdns_close_server_port()  argument
1763 	EVDNS_LOCK(port);  in evdns_close_server_port()
1764 	if (--port->refcnt == 0) {  in evdns_close_server_port()
1765 		EVDNS_UNLOCK(port);  in evdns_close_server_port()
1766 		server_port_free(port);  in evdns_close_server_port()
1768 		port->closing = 1;  in evdns_close_server_port()
1769 		EVDNS_UNLOCK(port);  in evdns_close_server_port()
1782 	EVDNS_LOCK(req->port);  in evdns_server_request_add_reply()
1842 	EVDNS_UNLOCK(req->port);  in evdns_server_request_add_reply()
2008 	struct evdns_server_port *port = req->port;  in evdns_server_request_respond()  local
2011 	EVDNS_LOCK(port);  in evdns_server_request_respond()
2017 	r = sendto(port->socket, req->response, (int)req->response_len, 0,  in evdns_server_request_respond()
2020 		int sock_err = evutil_socket_geterror(port->socket);  in evdns_server_request_respond()
2024 		if (port->pending_replies) {  in evdns_server_request_respond()
2025 			req->prev_pending = port->pending_replies->prev_pending;  in evdns_server_request_respond()
2026 			req->next_pending = port->pending_replies;  in evdns_server_request_respond()
2031 			port->pending_replies = req;  in evdns_server_request_respond()
2032 			port->choked = 1;  in evdns_server_request_respond()
2034 			(void) event_del(&port->event);  in evdns_server_request_respond()
2035 …ent_assign(&port->event, port->event_base, port->socket, (port->closing?0:EV_READ) | EV_WRITE | EV…  in evdns_server_request_respond()
2037 			if (event_add(&port->event, NULL) < 0) {  in evdns_server_request_respond()
2051 	if (port->pending_replies)  in evdns_server_request_respond()
2052 		server_port_flush(port);  in evdns_server_request_respond()
2056 	EVDNS_UNLOCK(port);  in evdns_server_request_respond()
2099 	if (req->port) {  in server_request_free()
2100 		EVDNS_LOCK(req->port);  in server_request_free()
2102 		if (req->port->pending_replies == req) {  in server_request_free()
2104 				req->port->pending_replies = req->next_pending;  in server_request_free()
2106 				req->port->pending_replies = NULL;  in server_request_free()
2108 		rc = --req->port->refcnt;  in server_request_free()
2123 		EVDNS_UNLOCK(req->port); /* ????? nickm */  in server_request_free()
2124 		server_port_free(req->port);  in server_request_free()
2129 		EVDNS_UNLOCK(req->port);  in server_request_free()
2136 server_port_free(struct evdns_server_port *port)  in server_port_free()  argument
2138 	EVUTIL_ASSERT(port);  in server_port_free()
2139 	EVUTIL_ASSERT(!port->refcnt);  in server_port_free()
2140 	EVUTIL_ASSERT(!port->pending_replies);  in server_port_free()
2141 	if (port->socket > 0) {  in server_port_free()
2142 		evutil_closesocket(port->socket);  in server_port_free()
2143 		port->socket = -1;  in server_port_free()
2145 	(void) event_del(&port->event);  in server_port_free()
2146 	event_debug_unassign(&port->event);  in server_port_free()
2147 	EVTHREAD_FREE_LOCK(port->lock, EVTHREAD_LOCKTYPE_RECURSIVE);  in server_port_free()
2148 	mm_free(port);  in server_port_free()
2624 sockaddr_setport(struct sockaddr *sa, ev_uint16_t port)  in sockaddr_setport()  argument
2627 		((struct sockaddr_in *)sa)->sin_port = htons(port);  in sockaddr_setport()
2629 		((struct sockaddr_in6 *)sa)->sin6_port = htons(port);  in sockaddr_setport()
4314 	ev_uint16_t port;  member
4577 		sin.sin_port = htons(data->port);  in evdns_getaddrinfo_gotresolve()
4586 		sin6.sin6_port = htons(data->port);  in evdns_getaddrinfo_gotresolve()
4662     const char *nodename, struct evutil_addrinfo *hints, ev_uint16_t port,  in evdns_getaddrinfo_fromhosts()  argument
4683 		sockaddr_setport(ai_new->ai_addr, port);  in evdns_getaddrinfo_fromhosts()
4710 	int port = 0;  in evdns_getaddrinfo()  local
4747 	err = evutil_getaddrinfo_common_(nodename, servname, &hints, &res, &port);  in evdns_getaddrinfo()
4754 	if (!evdns_getaddrinfo_fromhosts(dns_base, nodename, &hints, port, &res)) {  in evdns_getaddrinfo()
4769 	data->port = (ev_uint16_t)port;  in evdns_getaddrinfo()