final class DnsQueryContext
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private DnsRecord[] |
additionals |
private int |
id |
private static InternalLogger |
logger |
private java.net.InetSocketAddress |
nameServerAddr |
private DnsRecord |
optResource |
private DnsNameResolver |
parent |
private Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
promise |
private DnsQuestion |
question |
private boolean |
recursionDesired |
private ScheduledFuture<?> |
timeoutFuture |
Constructor and Description |
---|
DnsQueryContext(DnsNameResolver parent,
java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
finish(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope) |
(package private) java.net.InetSocketAddress |
nameServerAddr() |
private void |
onQueryWriteCompletion(ChannelFuture writeFuture) |
(package private) void |
query(ChannelPromise writePromise) |
(package private) DnsQuestion |
question() |
private void |
sendQuery(DnsQuery query,
ChannelPromise writePromise) |
private void |
setFailure(java.lang.String message,
java.lang.Throwable cause) |
private void |
setSuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope) |
private void |
writeQuery(DnsQuery query,
ChannelPromise writePromise) |
private static final InternalLogger logger
private final DnsNameResolver parent
private final Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise
private final int id
private final DnsQuestion question
private final DnsRecord[] additionals
private final DnsRecord optResource
private final java.net.InetSocketAddress nameServerAddr
private final boolean recursionDesired
private volatile ScheduledFuture<?> timeoutFuture
DnsQueryContext(DnsNameResolver parent, java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)
java.net.InetSocketAddress nameServerAddr()
DnsQuestion question()
void query(ChannelPromise writePromise)
private void sendQuery(DnsQuery query, ChannelPromise writePromise)
private void writeQuery(DnsQuery query, ChannelPromise writePromise)
private void onQueryWriteCompletion(ChannelFuture writeFuture)
void finish(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope)
private void setSuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope)
private void setFailure(java.lang.String message, java.lang.Throwable cause)