channelRead() — netty Function Reference

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

Function java NativeResolver JavaResolver

Entity Profile

NativeResolver→ JavaResolver→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  f073c95f_965a_fe6b_127f_a8bdf50d8068["channelRead()"]
  8c108031_e3e7_14e2_222f_1bd939b4c08d["DnsResponseHandler"]
  f073c95f_965a_fe6b_127f_a8bdf50d8068 -->|defined in| 8c108031_e3e7_14e2_222f_1bd939b4c08d
  style f073c95f_965a_fe6b_127f_a8bdf50d8068 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

resolver-dns/src/main/java/io/netty/resolver/dns/DnsNameResolver.java lines 1509–1531

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) {
            final Channel qCh = ctx.channel();
            final DatagramDnsResponse res = (DatagramDnsResponse) msg;
            final int queryId = res.id();
            logger.debug("{} RECEIVED: UDP [{}: {}], {}", qCh, queryId, res.sender(), res);

            final DnsQueryContext qCtx = queryContextManager.get(res.sender(), queryId);
            if (qCtx == null) {
                logger.debug("{} Received a DNS response with an unknown ID: UDP [{}: {}]",
                        qCh, queryId, res.sender());
                res.release();
                return;
            } else if (qCtx.isDone()) {
                logger.debug("{} Received a DNS response for a query that was timed out or cancelled: UDP [{}: {}]",
                        qCh, queryId, res.sender());
                res.release();
                return;
            }

            // The context will handle truncation itself.
            qCtx.finishSuccess(res, res.isTruncated());
        }