doResolveAllRec() — netty Function Reference

Architecture documentation for the doResolveAllRec() function in CompositeNameResolver.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ doResolveAllRec() — netty Function Reference

Dependency Diagram

graph TD
  74b968c4_c9a6_a534_9864_0a52599b8f23["doResolveAllRec()"]
  75d4943c_966e_29f6_2ec2_09e480037a9d["CompositeNameResolver"]
  74b968c4_c9a6_a534_9864_0a52599b8f23 -->|defined in| 75d4943c_966e_29f6_2ec2_09e480037a9d
  17598bdd_0804_f702_741b_12c60b0fc8de["doResolveAll()"]
  17598bdd_0804_f702_741b_12c60b0fc8de -->|calls| 74b968c4_c9a6_a534_9864_0a52599b8f23
  style 74b968c4_c9a6_a534_9864_0a52599b8f23 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

resolver/src/main/java/io/netty/resolver/CompositeNameResolver.java lines 84–100

    private void doResolveAllRec(final String inetHost,
                              final Promise<List<T>> promise,
                              final int resolverIndex,
                              Throwable lastFailure) throws Exception {
        if (resolverIndex >= resolvers.length) {
            promise.setFailure(lastFailure);
        } else {
            NameResolver<T> resolver = resolvers[resolverIndex];
            resolver.resolveAll(inetHost).addListener((FutureListener<List<T>>) future -> {
                if (future.isSuccess()) {
                    promise.setSuccess(future.getNow());
                } else {
                    doResolveAllRec(inetHost, promise, resolverIndex + 1, future.cause());
                }
            });
        }
    }