onQueryWriteCompletion() — netty Function Reference

Architecture documentation for the onQueryWriteCompletion() function in DnsQueryContext.java from the netty codebase.

Function java NativeResolver JavaResolver calls 2 called by 1

Entity Profile

NativeResolver→ JavaResolver→ onQueryWriteCompletion() — netty Function Reference

Dependency Diagram

graph TD
  02e54375_a4b8_ba90_af41_190cf641d5e4["onQueryWriteCompletion()"]
  360b8eed_0666_8e3d_9331_e795bb312381["DnsQueryContext"]
  02e54375_a4b8_ba90_af41_190cf641d5e4 -->|defined in| 360b8eed_0666_8e3d_9331_e795bb312381
  d553b80a_9410_aa58_ac6c_ad8bcdf2e222["writeQuery()"]
  d553b80a_9410_aa58_ac6c_ad8bcdf2e222 -->|calls| 02e54375_a4b8_ba90_af41_190cf641d5e4
  c1b3ef8a_d203_e5e3_4c2f_67fdad9bbd92["finishFailure()"]
  02e54375_a4b8_ba90_af41_190cf641d5e4 -->|calls| c1b3ef8a_d203_e5e3_4c2f_67fdad9bbd92
  74bccd11_01b5_da96_3a42_7c9f607f3a24["isDone()"]
  02e54375_a4b8_ba90_af41_190cf641d5e4 -->|calls| 74bccd11_01b5_da96_3a42_7c9f607f3a24
  style 02e54375_a4b8_ba90_af41_190cf641d5e4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

resolver-dns/src/main/java/io/netty/resolver/dns/DnsQueryContext.java lines 257–279

    private void onQueryWriteCompletion(final long queryTimeoutMillis,
                                        ChannelFuture writeFuture) {
        if (!writeFuture.isSuccess()) {
            finishFailure("failed to send a query '" + id + "' via " + protocol(), writeFuture.cause(), false);
            return;
        }

        // Schedule a query timeout task if necessary.
        if (queryTimeoutMillis > 0) {
            timeoutFuture = channel.eventLoop().schedule(new Runnable() {
                @Override
                public void run() {
                    if (promise.isDone()) {
                        // Received a response before the query times out.
                        return;
                    }

                    finishFailure("query '" + id + "' via " + protocol() + " timed out after " +
                            queryTimeoutMillis + " milliseconds", null, true);
                }
            }, queryTimeoutMillis, TimeUnit.MILLISECONDS);
        }
    }