Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 2a2a1c5d authored by Treehugger Robot's avatar Treehugger Robot Committed by Automerger Merge Worker
Browse files

Merge changes from topic "ResState-cleanups" am: ab5ec06d am: 2523ab05 

Original change: https://android-review.googlesource.com/c/platform/packages/modules/DnsResolver/+/1753145

Change-Id: I445e1fba721f4ad9016527f9080086f040d7047b
parents 7ba394a1 2523ab05

DnsTlsDispatcher.cpp

+3 −3
Original line number Diff line number Diff line
@@ -106,10 +106,10 @@ std::list<DnsTlsServer> DnsTlsDispatcher::getOrderedAndUsableServerList( 
}



DnsTlsTransport::Response DnsTlsDispatcher::query(const std::list<DnsTlsServer>& tlsServers,

                                                  res_state statp, const Slice query,

                                                  ResState* statp, const Slice query,

                                                  const Slice ans, int* resplen) {

    const std::list<DnsTlsServer> servers(

            getOrderedAndUsableServerList(tlsServers, statp->netid, statp->_mark));

            getOrderedAndUsableServerList(tlsServers, statp->netid, statp->mark));



    if (servers.empty()) LOG(WARNING) << "No usable DnsTlsServers";
@@ -121,7 +121,7 @@ DnsTlsTransport::Response DnsTlsDispatcher::query(const std::list<DnsTlsServer>& 


        bool connectTriggered = false;

        Stopwatch queryStopwatch;

        code = this->query(server, statp->netid, statp->_mark, query, ans, resplen,

        code = this->query(server, statp->netid, statp->mark, query, ans, resplen,

                           &connectTriggered);



        dnsQueryEvent->set_latency_micros(saturate_cast<int32_t>(queryStopwatch.timeTakenUs()));

DnsTlsDispatcher.h

+1 −1
Original line number Diff line number Diff line
@@ -51,7 +51,7 @@ class DnsTlsDispatcher : public PrivateDnsValidationObserver { 
    // The order in which servers from |tlsServers| are queried may not be the

    // order passed in by the caller.

    DnsTlsTransport::Response query(const std::list<DnsTlsServer>& tlsServers,

                                    res_state _Nonnull statp, const netdutils::Slice query,

                                    ResState* _Nonnull statp, const netdutils::Slice query,

                                    const netdutils::Slice ans, int* _Nonnull resplen);



    // Given a |query|, sends it to the server on the network indicated by |mark|,

getaddrinfo.cpp

+13 −13
Original line number Diff line number Diff line
@@ -151,9 +151,9 @@ static bool files_getaddrinfo(const size_t netid, const char* name, const addrin 
                              addrinfo** res);

static int _find_src_addr(const struct sockaddr*, struct sockaddr*, unsigned, uid_t);



static int res_queryN(const char* name, res_target* target, res_state res, int* herrno);

static int res_searchN(const char* name, res_target* target, res_state res, int* herrno);

static int res_querydomainN(const char* name, const char* domain, res_target* target, res_state res,

static int res_queryN(const char* name, res_target* target, ResState* res, int* herrno);

static int res_searchN(const char* name, res_target* target, ResState* res, int* herrno);

static int res_querydomainN(const char* name, const char* domain, res_target* target, ResState* res,

                            int* herrno);



const char* const ai_errlist[] = {
@@ -1437,7 +1437,7 @@ static int dns_getaddrinfo(const char* name, const addrinfo* pai, 


    ResState res(netcontext, event);



    setMdnsFlag(name, &(res._flags));

    setMdnsFlag(name, &(res.flags));



    int he;

    if (res_searchN(name, &q, &res, &he) < 0) {
@@ -1609,7 +1609,7 @@ struct QueryResult { 
    NetworkDnsEventReported event;

};



QueryResult doQuery(const char* name, res_target* t, res_state res,

QueryResult doQuery(const char* name, res_target* t, ResState* res,

                    std::chrono::milliseconds sleepTimeMs) {

    HEADER* hp = (HEADER*)(void*)t->answer.data();
@@ -1653,7 +1653,7 @@ QueryResult doQuery(const char* name, res_target* t, res_state res, 
        // if the query choked with EDNS0, retry without EDNS0

        if ((res_temp.netcontext_flags &

             (NET_CONTEXT_FLAG_USE_DNS_OVER_TLS | NET_CONTEXT_FLAG_USE_EDNS)) &&

            (res_temp._flags & RES_F_EDNS0ERR)) {

            (res_temp.flags & RES_F_EDNS0ERR)) {

            LOG(DEBUG) << __func__ << ": retry without EDNS0";

            n = res_nmkquery(QUERY, name, cl, type, /*data=*/nullptr, /*datalen=*/0, buf,

                             sizeof(buf), res_temp.netcontext_flags);
@@ -1674,7 +1674,7 @@ QueryResult doQuery(const char* name, res_target* t, res_state res, 


}  // namespace



static int res_queryN_parallel(const char* name, res_target* target, res_state res, int* herrno) {

static int res_queryN_parallel(const char* name, res_target* target, ResState* res, int* herrno) {

    std::vector<std::future<QueryResult>> results;

    results.reserve(2);

    std::chrono::milliseconds sleepTimeMs{};
@@ -1713,7 +1713,7 @@ static int res_queryN_parallel(const char* name, res_target* target, res_state r 
    return ancount;

}



static int res_queryN_wrapper(const char* name, res_target* target, res_state res, int* herrno) {

static int res_queryN_wrapper(const char* name, res_target* target, ResState* res, int* herrno) {

    const bool parallel_lookup =

            android::net::Experiments::getInstance()->getFlag("parallel_lookup_release", 1);

    if (parallel_lookup) return res_queryN_parallel(name, target, res, herrno);
@@ -1731,7 +1731,7 @@ static int res_queryN_wrapper(const char* name, res_target* target, res_state re 
 *

 * Caller must parse answer and determine whether it answers the question.

 */

static int res_queryN(const char* name, res_target* target, res_state res, int* herrno) {

static int res_queryN(const char* name, res_target* target, ResState* res, int* herrno) {

    uint8_t buf[MAXPACKET];

    int n;

    struct res_target* t;
@@ -1780,7 +1780,7 @@ static int res_queryN(const char* name, res_target* target, res_state res, int* 
            // we also has the same symptom if EDNS is enabled.

            if ((res->netcontext_flags &

                 (NET_CONTEXT_FLAG_USE_DNS_OVER_TLS | NET_CONTEXT_FLAG_USE_EDNS)) &&

                (res->_flags & RES_F_EDNS0ERR) && !retried) {

                (res->flags & RES_F_EDNS0ERR) && !retried) {

                LOG(DEBUG) << __func__ << ": retry without EDNS0";

                retried = true;

                goto again;
@@ -1807,7 +1807,7 @@ static int res_queryN(const char* name, res_target* target, res_state res, int* 
 * If enabled, implement search rules until answer or unrecoverable failure

 * is detected.  Error code, if any, is left in *herrno.

 */

static int res_searchN(const char* name, res_target* target, res_state res, int* herrno) {

static int res_searchN(const char* name, res_target* target, ResState* res, int* herrno) {

    const char* cp;

    HEADER* hp;

    uint32_t dots;
@@ -1843,7 +1843,7 @@ static int res_searchN(const char* name, res_target* target, res_state res, int* 
     *	 - there is at least one dot and there is no trailing dot.

     * - this is not a .local mDNS lookup.

     */

    if ((!dots || (dots && !trailing_dot)) && !isMdnsResolution(res->_flags)) {

    if ((!dots || (dots && !trailing_dot)) && !isMdnsResolution(res->flags)) {

        int done = 0;



        /* Unfortunately we need to set stuff up before
@@ -1924,7 +1924,7 @@ static int res_searchN(const char* name, res_target* target, res_state res, int* 


// Perform a call on res_query on the concatenation of name and domain,

// removing a trailing dot from name if domain is NULL.

static int res_querydomainN(const char* name, const char* domain, res_target* target, res_state res,

static int res_querydomainN(const char* name, const char* domain, res_target* target, ResState* res,

                            int* herrno) {

    char nbuf[MAXDNAME];

    const char* longname = nbuf;

gethnamaddr.cpp

+1 −1
Original line number Diff line number Diff line
@@ -375,7 +375,7 @@ int resolv_gethostbyname(const char* name, int af, hostent* hp, char* buf, size_ 
    getnamaddr info;

    ResState res(netcontext, event);



    setMdnsFlag(name, &(res._flags));

    setMdnsFlag(name, &(res.flags));



    size_t size;

    switch (af) {

res_mkquery.cpp

+2 −2
Original line number Diff line number Diff line
@@ -84,7 +84,7 @@ 


#include "res_comp.h"

#include "res_debug.h"

#include "resolv_private.h"  // res_state

#include "resolv_private.h"  // ResState*



// Queries will be padded to a multiple of this length when EDNS0 is active.

constexpr uint16_t kEdns0Padding = 128;
@@ -191,7 +191,7 @@ int res_nmkquery(int op, // opcode of query 
    return (cp - buf);

}



int res_nopt(res_state statp, int n0, /* current offset in buffer */

int res_nopt(ResState* statp, int n0, /* current offset in buffer */

             uint8_t* buf,            /* buffer to put query */

             int buflen,              /* size of buffer */

             int anslen)              /* UDP answer buffer size */