Package io.netty.resolver.dns

Class DnsQueryContext

java.lang.Object

io.netty.resolver.dns.DnsQueryContext

Direct Known Subclasses:

DatagramDnsQueryContext, TcpDnsQueryContext

abstract class DnsQueryContext
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private DnsRecord[]	additionals
private Channel	channel
private Future<? extends Channel>	channelReadyFuture
private int	id
private static long	ID_REUSE_ON_TIMEOUT_DELAY_MILLIS
private static InternalLogger	logger
private java.net.InetSocketAddress	nameServerAddr
private DnsRecord	optResource
private Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>	promise
private DnsQueryContextManager	queryContextManager
private DnsQuestion	question
private boolean	recursionDesired
private Future<?>	timeoutFuture

Constructor Summary

Constructors

Constructor	Description
DnsQueryContext(Channel channel, Future<? extends Channel> channelReadyFuture, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)

Method Summary

Modifier and Type	Method	Description
private void	failQuery(DnsQuery query, java.lang.Throwable cause, ChannelPromise writePromise)
(package private) boolean	finishFailure(java.lang.String message, java.lang.Throwable cause, boolean timeout)	Notifies the original Promise that the query completes because of an failure.
(package private) void	finishSuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope)	Notifies the original Promise that the response for the query was received.
private static boolean	hasOptRecord(DnsRecord[] additionals)
(package private) boolean	isDone()	Returns true if the query was completed already.
protected abstract DnsQuery	newQuery(int id, java.net.InetSocketAddress nameServerAddr)	Creates and returns a new DnsQuery.
private void	onQueryWriteCompletion(long queryTimeoutMillis, ChannelFuture writeFuture)
protected abstract java.lang.String	protocol()	Returns the protocol that is used for the query.
(package private) DnsQuestion	question()	Returns the DnsQuestion that will be written as part of the DnsQuery.
private void	removeFromContextManager(java.net.InetSocketAddress nameServerAddr)
private ChannelFuture	sendQuery(java.net.InetSocketAddress nameServerAddr, DnsQuery query, long queryTimeoutMillis, boolean flush)
private boolean	trySuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope)
(package private) ChannelFuture	writeQuery(long queryTimeoutMillis, boolean flush)	Write the query and return the ChannelFuture that is completed once the write completes.
private void	writeQuery(java.net.InetSocketAddress nameServerAddr, DnsQuery query, long queryTimeoutMillis, boolean flush, ChannelPromise promise)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static final InternalLogger logger

ID_REUSE_ON_TIMEOUT_DELAY_MILLIS

private static final long ID_REUSE_ON_TIMEOUT_DELAY_MILLIS

channelReadyFuture

private final Future<? extends Channel> channelReadyFuture

channel

private final Channel channel

nameServerAddr

private final java.net.InetSocketAddress nameServerAddr

queryContextManager

private final DnsQueryContextManager queryContextManager

promise

private final Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise

question

private final DnsQuestion question

additionals

private final DnsRecord[] additionals

optResource

private final DnsRecord optResource

recursionDesired

private final boolean recursionDesired

timeoutFuture

private volatile Future<?> timeoutFuture

id

private int id

Constructor Detail

DnsQueryContext

DnsQueryContext(Channel channel,
                Future<? extends Channel> channelReadyFuture,
                java.net.InetSocketAddress nameServerAddr,
                DnsQueryContextManager queryContextManager,
                int maxPayLoadSize,
                boolean recursionDesired,
                DnsQuestion question,
                DnsRecord[] additionals,
                Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)

Method Detail

hasOptRecord

private static boolean hasOptRecord(DnsRecord[] additionals)

isDone

final boolean isDone()

Returns true if the query was completed already.

Returns:

true if done.

question

final DnsQuestion question()

Returns the DnsQuestion that will be written as part of the DnsQuery.

Returns:

the question.

newQuery

protected abstract DnsQuery newQuery(int id,
                                     java.net.InetSocketAddress nameServerAddr)

Creates and returns a new DnsQuery.

Parameters:

id - the transaction id to use.

nameServerAddr - the nameserver to which the query will be send.

Returns:

the new query.

protocol

protected abstract java.lang.String protocol()

Returns the protocol that is used for the query.

Returns:

the protocol.

writeQuery

final ChannelFuture writeQuery(long queryTimeoutMillis,
                               boolean flush)

Write the query and return the ChannelFuture that is completed once the write completes.

Parameters:

queryTimeoutMillis - the timeout after which the query is considered timeout and the original Promise will be failed.

flush - true if Channel.flush() should be called as well.

Returns:

the ChannelFuture that is notified once once the write completes.

removeFromContextManager

private void removeFromContextManager(java.net.InetSocketAddress nameServerAddr)

sendQuery

private ChannelFuture sendQuery(java.net.InetSocketAddress nameServerAddr,
                                DnsQuery query,
                                long queryTimeoutMillis,
                                boolean flush)

failQuery

private void failQuery(DnsQuery query,
                       java.lang.Throwable cause,
                       ChannelPromise writePromise)

writeQuery

private void writeQuery(java.net.InetSocketAddress nameServerAddr,
                        DnsQuery query,
                        long queryTimeoutMillis,
                        boolean flush,
                        ChannelPromise promise)

onQueryWriteCompletion

private void onQueryWriteCompletion(long queryTimeoutMillis,
                                    ChannelFuture writeFuture)

finishSuccess

void finishSuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope)

Notifies the original Promise that the response for the query was received. This method takes ownership of passed AddressedEnvelope.

trySuccess

private boolean trySuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope)

finishFailure

final boolean finishFailure(java.lang.String message,
                            java.lang.Throwable cause,
                            boolean timeout)

Notifies the original Promise that the query completes because of an failure.