doResolveAllUncached() — netty Function Reference

Architecture documentation for the doResolveAllUncached() function in DnsNameResolver.java from the netty codebase.

Function java NativeResolver JavaResolver calls 1 called by 2

Entity Profile

NativeResolver→ JavaResolver→ doResolveAllUncached() — netty Function Reference

Dependency Diagram

graph TD
  ec46f075_dc46_9735_e431_9f2867daf501["doResolveAllUncached()"]
  a8faea52_3f45_7b36_4918_3dfb9bd6ee9b["DnsNameResolver"]
  ec46f075_dc46_9735_e431_9f2867daf501 -->|defined in| a8faea52_3f45_7b36_4918_3dfb9bd6ee9b
  495e6f3e_fd8f_4c49_8cf2_c9316bf78b03["doResolveUncached()"]
  495e6f3e_fd8f_4c49_8cf2_c9316bf78b03 -->|calls| ec46f075_dc46_9735_e431_9f2867daf501
  a881070c_3c3c_9438_beba_ec9a5e345568["doResolveAllNow()"]
  a881070c_3c3c_9438_beba_ec9a5e345568 -->|calls| ec46f075_dc46_9735_e431_9f2867daf501
  ff5ed0b1_a3bf_48f7_1f11_6a65ddeb7bd3["doResolveAllUncached0()"]
  ec46f075_dc46_9735_e431_9f2867daf501 -->|calls| ff5ed0b1_a3bf_48f7_1f11_6a65ddeb7bd3
  style ec46f075_dc46_9735_e431_9f2867daf501 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

resolver-dns/src/main/java/io/netty/resolver/dns/DnsNameResolver.java lines 1230–1252

    private void doResolveAllUncached(final Channel channel,
                                      final String hostname,
                                      final DnsRecord[] additionals,
                                      final Promise<?> originalPromise,
                                      final Promise<List<InetAddress>> promise,
                                      final DnsCache resolveCache,
                                      final boolean completeEarlyIfPossible) {
        // Call doResolveUncached0(...) in the EventLoop as we may need to submit multiple queries which would need
        // to submit multiple Runnable at the end if we are not already on the EventLoop.
        EventExecutor executor = executor();
        if (executor.inEventLoop()) {
            doResolveAllUncached0(channel, hostname, additionals, originalPromise,
                                  promise, resolveCache, completeEarlyIfPossible);
        } else {
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    doResolveAllUncached0(channel, hostname, additionals, originalPromise,
                                          promise, resolveCache, completeEarlyIfPossible);
                }
            });
        }
    }