close() — netty Function Reference

Architecture documentation for the close() function in AddressResolverGroup.java from the netty codebase.

Function java Buffer Search called by 1

Entity Profile

Buffer→ Search→ close() — netty Function Reference

Dependency Diagram

graph TD
  b8905cd7_5a5f_3cc8_f2ff_e58e1e2384fa["close()"]
  994fafa0_81fa_00f6_95d1_4a01e226525f["AddressResolverGroup"]
  b8905cd7_5a5f_3cc8_f2ff_e58e1e2384fa -->|defined in| 994fafa0_81fa_00f6_95d1_4a01e226525f
  25197d51_0fdb_072b_6fd1_a80c532cc94b["getResolver()"]
  25197d51_0fdb_072b_6fd1_a80c532cc94b -->|calls| b8905cd7_5a5f_3cc8_f2ff_e58e1e2384fa
  style b8905cd7_5a5f_3cc8_f2ff_e58e1e2384fa fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

resolver/src/main/java/io/netty/resolver/AddressResolverGroup.java lines 103–127

    @Override
    @SuppressWarnings({ "unchecked", "SuspiciousToArrayCall" })
    public void close() {
        final AddressResolver<T>[] rArray;
        final Map.Entry<EventExecutor, GenericFutureListener<Future<Object>>>[] listeners;

        synchronized (resolvers) {
            rArray = (AddressResolver<T>[]) resolvers.values().toArray(new AddressResolver[0]);
            resolvers.clear();
            listeners = executorTerminationListeners.entrySet().toArray(new Map.Entry[0]);
            executorTerminationListeners.clear();
        }

        for (final Map.Entry<EventExecutor, GenericFutureListener<Future<Object>>> entry : listeners) {
            entry.getKey().terminationFuture().removeListener(entry.getValue());
        }

        for (final AddressResolver<T> r: rArray) {
            try {
                r.close();
            } catch (Throwable t) {
                logger.warn("Failed to close a resolver:", t);
            }
        }
    }