internalResolve() — netty Function Reference

Architecture documentation for the internalResolve() function in DnsResolveContext.java from the netty codebase.

Function java NativeResolver JavaResolver calls 1 called by 2

Entity Profile

NativeResolver→ JavaResolver→ internalResolve() — netty Function Reference

Dependency Diagram

graph TD
  9f561f45_6801_ce1e_316a_a956c08ce604["internalResolve()"]
  3bc002ec_f54e_a55f_0b37_77eac88c60db["DnsResolveContext"]
  9f561f45_6801_ce1e_316a_a956c08ce604 -->|defined in| 3bc002ec_f54e_a55f_0b37_77eac88c60db
  19225515_ce5b_59bc_9042_d989b77e8911["resolve()"]
  19225515_ce5b_59bc_9042_d989b77e8911 -->|calls| 9f561f45_6801_ce1e_316a_a956c08ce604
  04601a99_7b74_c57b_d385_a444bf92ae20["doSearchDomainQuery()"]
  04601a99_7b74_c57b_d385_a444bf92ae20 -->|calls| 9f561f45_6801_ce1e_316a_a956c08ce604
  07f53a31_718c_c4a3_04b0_19d21f5a6af4["query()"]
  9f561f45_6801_ce1e_316a_a956c08ce604 -->|calls| 07f53a31_718c_c4a3_04b0_19d21f5a6af4
  style 9f561f45_6801_ce1e_316a_a956c08ce604 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

resolver-dns/src/main/java/io/netty/resolver/dns/DnsResolveContext.java lines 365–388

    private void internalResolve(String name, Promise<List<T>> promise) {
        try {
            // Resolve from cnameCache() until there is no more cname entry cached.
            name = cnameResolveFromCache(cnameCache(), name);
        } catch (Throwable cause) {
            promise.tryFailure(cause);
            return;
        }

        try {
            DnsServerAddressStream nameServerAddressStream = getNameServers(name);

            final int end = expectedTypes.length - 1;
            for (int i = 0; i < end; ++i) {
                if (!query(name, expectedTypes[i], nameServerAddressStream.duplicate(), false, promise)) {
                    return;
                }
            }
            query(name, expectedTypes[end], nameServerAddressStream, false, promise);
        } finally {
            // Now flush everything we submitted before for the Channel.
            channel.flush();
        }
    }