Snap for 5936682 from 2199df941f0466dfcda92a75e86df0033c27add0 to rvc-release (6f42efad) · Commits · e / os / android_packages_modules_DnsResolver

PrivateDnsConfiguration.cpp

+4 −1

Original line number	Diff line number	Diff line
		@@ -40,7 +40,10 @@ std::string addrToString(const sockaddr_storage* addr) {
		}

		bool parseServer(const char* server, sockaddr_storage* parsed) {
		addrinfo hints = {.ai_family = AF_UNSPEC, .ai_flags = AI_NUMERICHOST \| AI_NUMERICSERV};
		addrinfo hints = {
		.ai_flags = AI_NUMERICHOST \| AI_NUMERICSERV,
		.ai_family = AF_UNSPEC,
		};
		addrinfo* res;

		int err = getaddrinfo(server, "853", &hints, &res);

gethnamaddr.cpp

+1 −0

Original line number	Diff line number	Diff line
		@@ -76,6 +76,7 @@
		#include "netd_resolv/resolv.h"
		#include "resolv_cache.h"
		#include "resolv_private.h"
		#include "resolv_static.h"
		#include "stats.pb.h"

		using android::net::NetworkDnsEventReported;

res_cache.cpp

+6 −4

Original line number	Diff line number	Diff line
		@@ -59,7 +59,6 @@
		#include <server_configurable_flags/get_flags.h>

		#include "res_debug.h"
		#include "res_state_ext.h"
		#include "resolv_private.h"

		using android::base::StringAppendF;
		@@ -1488,7 +1487,10 @@ int resolv_set_nameservers(unsigned netid, const std::vector<std::string>& serve
		for (int i = 0; i < numservers; i++) {
		// The addrinfo structures allocated here are freed in free_nameservers_locked().
		const addrinfo hints = {
		.ai_family = AF_UNSPEC, .ai_socktype = SOCK_DGRAM, .ai_flags = AI_NUMERICHOST};
		.ai_flags = AI_NUMERICHOST,
		.ai_family = AF_UNSPEC,
		.ai_socktype = SOCK_DGRAM,
		};
		const int rt = getaddrinfo_numeric(nameservers[i].c_str(), "53", hints, &nsaddrinfo[i]);
		if (rt != 0) {
		for (int j = 0; j < i; j++) {
		@@ -1582,8 +1584,8 @@ void _resolv_populate_res_for_net(res_state statp) {
		break;
		}

		if ((size_t) ai->ai_addrlen <= sizeof(statp->_u._ext.ext->nsaddrs[0])) {
		memcpy(&statp->_u._ext.ext->nsaddrs[nserv], ai->ai_addr, ai->ai_addrlen);
		if ((size_t)ai->ai_addrlen <= sizeof(statp->nsaddrs[0])) {
		memcpy(&statp->nsaddrs[nserv], ai->ai_addr, ai->ai_addrlen);
		} else {
		LOG(INFO) << __func__ << ": found too long addrlen";
		}

res_init.cpp

+8 −17

Original line number	Diff line number	Diff line
		@@ -90,7 +90,6 @@
		#include <unistd.h>

		#include "netd_resolv/resolv.h"
		#include "res_state_ext.h"
		#include "resolv_private.h"

		// Set up Resolver state default settings.
		@@ -100,15 +99,13 @@ void res_init(res_state statp) {
		statp->id = arc4random_uniform(65536);
		statp->_mark = MARK_UNSET;

		statp->nscount = 0;
		statp->ndots = 1;
		statp->_vcsock = -1;
		statp->_flags = 0;
		statp->_u._ext.nscount = 0;
		statp->_u._ext.ext = (res_state_ext) malloc(sizeof(statp->_u._ext.ext));
		statp->netcontext_flags = 0;
		if (statp->_u._ext.ext != NULL) {
		memset(statp->_u._ext.ext, 0, sizeof(*statp->_u._ext.ext));

		for (int ns = 0; ns < MAXNS; ns++) {
		statp->nssocks[ns] = -1;
		}

		// The following dummy initialization is probably useless because
		@@ -119,7 +116,7 @@ void res_init(res_state statp) {
		.sin.sin_family = AF_INET,
		.sin.sin_port = htons(NAMESERVER_PORT),
		};
		memcpy(&statp->_u._ext.ext->nsaddrs[0], &u, sizeof(u));
		memcpy(&statp->nsaddrs, &u, sizeof(u));
		statp->nscount = 1;
		}

		@@ -138,18 +135,12 @@ void res_nclose(res_state statp) {
		statp->_vcsock = -1;
		statp->_flags &= ~RES_F_VC;
		}
		for (ns = 0; ns < statp->_u._ext.nscount; ns++) {
		if (statp->_u._ext.nssocks[ns] != -1) {
		(void) close(statp->_u._ext.nssocks[ns]);
		statp->_u._ext.nssocks[ns] = -1;
		}
		for (ns = 0; ns < MAXNS; ns++) {
		if (statp->nssocks[ns] != -1) {
		close(statp->nssocks[ns]);
		statp->nssocks[ns] = -1;
		}
		}

		void res_ndestroy(res_state statp) {
		res_nclose(statp);
		if (statp->_u._ext.ext != NULL) free(statp->_u._ext.ext);
		statp->_u._ext.ext = NULL;
		}

		void res_setnetcontext(res_state statp, const struct android_net_context* netcontext,

res_send.cpp

+14 −67

Original line number	Diff line number	Diff line
		@@ -107,7 +107,6 @@
		#include "netd_resolv/stats.h"
		#include "private/android_filesystem_config.h"
		#include "res_debug.h"
		#include "res_state_ext.h"
		#include "resolv_cache.h"
		#include "stats.pb.h"

		@@ -291,16 +290,8 @@ static void res_set_usable_server(int selectedServer, int nscount, bool usable_s
		}
		}

		/* int
		* res_isourserver(ina)
		* looks up "ina" in _res.ns_addr_list[]
		* returns:
		* 0 : not found
		* >0 : found
		* author:
		* paul vixie, 29may94
		*/
		static int res_ourserver_p(res_state statp, const sockaddr* sa) {
		// Looks up the nameserver address in res.nsaddrs[], returns true if found, otherwise false.
		static bool res_ourserver_p(res_state statp, const sockaddr* sa) {
		const sockaddr_in inp, srv;
		const sockaddr_in6 in6p, srv6;
		int ns;
		@@ -313,11 +304,10 @@ static int res_ourserver_p(res_state statp, const sockaddr* sa) {
		if (srv->sin_family == inp->sin_family && srv->sin_port == inp->sin_port &&
		(srv->sin_addr.s_addr == INADDR_ANY \|\|
		srv->sin_addr.s_addr == inp->sin_addr.s_addr))
		return 1;
		return true;
		}
		break;
		case AF_INET6:
		if (statp->_u._ext.ext == NULL) break;
		in6p = (const struct sockaddr_in6) (const void) sa;
		for (ns = 0; ns < statp->nscount; ns++) {
		srv6 = (struct sockaddr_in6) (void) get_nsaddr(statp, (size_t) ns);
		@@ -327,13 +317,13 @@ static int res_ourserver_p(res_state statp, const sockaddr* sa) {
		#endif
		(IN6_IS_ADDR_UNSPECIFIED(&srv6->sin6_addr) \|\|
		IN6_ARE_ADDR_EQUAL(&srv6->sin6_addr, &in6p->sin6_addr)))
		return 1;
		return true;
		}
		break;
		default:
		break;
		}
		return 0;
		return false;
		}

		/* int
		@@ -457,49 +447,6 @@ int res_nsend(res_state statp, const uint8_t* buf, int buflen, uint8_t* ans, int
		return -ESRCH;
		}

		/*
		* If the ns_addr_list in the resolver context has changed, then
		* invalidate our cached copy and the associated timing data.
		*/
		if (statp->_u._ext.nscount != 0) {
		int needclose = 0;
		struct sockaddr_storage peer;
		socklen_t peerlen;

		if (statp->_u._ext.nscount != statp->nscount) {
		needclose++;
		} else {
		for (int ns = 0; ns < statp->nscount; ns++) {
		if (statp->_u._ext.nssocks[ns] == -1) continue;
		peerlen = sizeof(peer);
		if (getpeername(statp->_u._ext.nssocks[ns], (struct sockaddr) (void) &peer,
		&peerlen) < 0) {
		needclose++;
		break;
		}
		if (!sock_eq((struct sockaddr) (void) &peer, get_nsaddr(statp, (size_t) ns))) {
		needclose++;
		break;
		}
		}
		}
		if (needclose) {
		res_nclose(statp);
		statp->_u._ext.nscount = 0;
		}
		}

		/*
		* Maybe initialize our private copy of the ns_addr_list.
		*/
		if (statp->_u._ext.nscount == 0) {
		for (int ns = 0; ns < statp->nscount; ns++) {
		statp->_u._ext.nstimes[ns] = RES_MAXTIME;
		statp->_u._ext.nssocks[ns] = -1;
		}
		statp->_u._ext.nscount = statp->nscount;
		}

		res_stats stats[MAXNS];
		res_params params;
		int revision_id = resolv_cache_get_resolver_stats(statp->netid, &params, stats);
		@@ -684,7 +631,7 @@ static int get_salen(const struct sockaddr* sa) {
		}

		static struct sockaddr* get_nsaddr(res_state statp, size_t n) {
		return (struct sockaddr)(void)&statp->_u._ext.ext->nsaddrs[n];
		return (struct sockaddr)(void)&statp->nsaddrs[n];
		}

		static struct timespec get_timeout(res_state statp, const res_params* params, const int ns) {
		@@ -991,9 +938,9 @@ static int send_dg(res_state statp, res_params* params, const uint8_t* buf, int

		nsap = get_nsaddr(statp, (size_t) ns);
		nsaplen = get_salen(nsap);
		if (statp->_u._ext.nssocks[ns] == -1) {
		statp->_u._ext.nssocks[ns] = socket(nsap->sa_family, SOCK_DGRAM \| SOCK_CLOEXEC, 0);
		if (statp->_u._ext.nssocks[ns] < 0) {
		if (statp->nssocks[ns] == -1) {
		statp->nssocks[ns] = socket(nsap->sa_family, SOCK_DGRAM \| SOCK_CLOEXEC, 0);
		if (statp->nssocks[ns] < 0) {
		switch (errno) {
		case EPROTONOSUPPORT:
		case EPFNOSUPPORT:
		@@ -1007,9 +954,9 @@ static int send_dg(res_state statp, res_params* params, const uint8_t* buf, int
		}
		}

		resolv_tag_socket(statp->_u._ext.nssocks[ns], statp->uid);
		resolv_tag_socket(statp->nssocks[ns], statp->uid);
		if (statp->_mark != MARK_UNSET) {
		if (setsockopt(statp->_u._ext.nssocks[ns], SOL_SOCKET, SO_MARK, &(statp->_mark),
		if (setsockopt(statp->nssocks[ns], SOL_SOCKET, SO_MARK, &(statp->_mark),
		sizeof(statp->_mark)) < 0) {
		res_nclose(statp);
		return -1;
		@@ -1019,19 +966,19 @@ static int send_dg(res_state statp, res_params* params, const uint8_t* buf, int
		// on the next socket operation when the server responds with an
		// ICMP port-unreachable error. This way we can detect the absence of
		// a nameserver without timing out.
		if (random_bind(statp->_u._ext.nssocks[ns], nsap->sa_family) < 0) {
		if (random_bind(statp->nssocks[ns], nsap->sa_family) < 0) {
		dump_error("bind(dg)", nsap, nsaplen);
		res_nclose(statp);
		return (0);
		}
		if (connect(statp->_u._ext.nssocks[ns], nsap, (socklen_t) nsaplen) < 0) {
		if (connect(statp->nssocks[ns], nsap, (socklen_t)nsaplen) < 0) {
		dump_error("connect(dg)", nsap, nsaplen);
		res_nclose(statp);
		return (0);
		}
		LOG(DEBUG) << __func__ << ": new DG socket";
		}
		s = statp->_u._ext.nssocks[ns];
		s = statp->nssocks[ns];
		if (send(s, (const char*) buf, (size_t) buflen, 0) != buflen) {
		PLOG(DEBUG) << __func__ << ": send: ";
		res_nclose(statp);