Top Fields Constructors Methods

io.netty5.resolver.dns

pack-priv abstract Class DnsQueryContext

Class Inheritance

extends Object
implements FutureListener<AddressedEnvelope<DnsResponse, InetSocketAddress>>

java.lang.Object
io.netty5.resolver.dns.DnsQueryContext

All Implemented Interfaces

io.netty5.util.concurrent.FutureListener

Known Direct Subclasses

io.netty5.resolver.dns.DatagramDnsQueryContext, io.netty5.resolver.dns.TcpDnsQueryContext

Imports

io.netty5.channel.AddressedEnvelope, .Channel, io.netty5.handler.codec.dns.AbstractDnsOptPseudoRrRecord, .DnsOptPseudoRecord, .DnsQuery, .DnsQuestion, .DnsRecord, .DnsRecordType, .DnsResponse, .DnsSection, io.netty5.util.Resource, io.netty5.util.concurrent.Future, .FutureListener, .Promise, io.netty5.util.internal.SilentDispose, io.netty5.util.internal.logging.InternalLogger, .InternalLoggerFactory, java.net.InetSocketAddress, java.util.concurrent.TimeUnit

Field Summary

Modifier and Type	Field and Description
private final DnsRecord[]	additionals
private final int	id
private static final InternalLogger	logger
private final InetSocketAddress	nameServerAddr
private final DnsRecord	optResource
private final DnsNameResolver	parent
private final Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>>	promise
private final DnsQuestion	question
private final boolean	recursionDesired
private volatile Future<?>	timeoutFuture

Constructor Summary

Access	Constructor and Description
pack-priv	DnsQueryContext(DnsNameResolver parent, InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>> promise)

Method Summary

Modifier and Type	Method and Description
protected abstract Channel	channel()
private void	failQuery(DnsQuery query, Throwable cause, Promise<Void> writePromise)
pack-priv void	finish(AddressedEnvelope<? extends DnsResponse, InetSocketAddress> envelope) Takes ownership of passed envelope
private static boolean	hasOptRecord(DnsRecord[] additionals)
pack-priv InetSocketAddress	nameServerAddr()
protected abstract DnsQuery	newQuery(int id)
private void	onQueryWriteCompletion(Future<?> writeFuture, Promise<Void> writePromise)
public void	operationComplete(Future<? extends AddressedEnvelope<DnsResponse, InetSocketAddress>> the source `Future` which called this callback future) Implements io.netty5.util.concurrent.FutureListener.operationComplete. Invoked when the operation associated with the `Future` has been completed.
pack-priv DnsNameResolver	parent()
protected abstract String	protocol()
pack-priv void	query(boolean flush, Promise<Void> writePromise)
pack-priv DnsQuestion	question()
private void	sendQuery(final DnsQuery query, final boolean flush, final Promise<Void> writePromise)
pack-priv boolean	tryFailure(String message, Throwable cause, boolean timeout)
private boolean	trySuccess(AddressedEnvelope<? extends DnsResponse, InetSocketAddress> envelope)
private void	writeQuery(final DnsQuery query, final boolean flush, final Promise<Void> writePromise)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

additionals	back to summary
private final DnsRecord[] additionals

id	back to summary
private final int id

logger	back to summary
private static final InternalLogger logger

nameServerAddr	back to summary
private final InetSocketAddress nameServerAddr

optResource	back to summary
private final DnsRecord optResource

parent	back to summary
private final DnsNameResolver parent

promise	back to summary
private final Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>> promise

question	back to summary
private final DnsQuestion question

recursionDesired	back to summary
private final boolean recursionDesired

timeoutFuture	back to summary
private volatile Future<?> timeoutFuture

Constructor Detail

DnsQueryContext	back to summary
pack-priv DnsQueryContext(DnsNameResolver parent, InetSocketAddress nameServerAddr, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse, InetSocketAddress>> promise)

Method Detail

channel	back to summary
protected abstract Channel channel()

failQuery	back to summary
private void failQuery(DnsQuery query, Throwable cause, Promise<Void> writePromise)

finish	back to summary
pack-priv void finish(AddressedEnvelope<? extends DnsResponse, InetSocketAddress> envelope) Takes ownership of passed envelope

hasOptRecord	back to summary
private static boolean hasOptRecord(DnsRecord[] additionals)

nameServerAddr	back to summary
pack-priv InetSocketAddress nameServerAddr()

newQuery	back to summary
protected abstract DnsQuery newQuery(int id)

onQueryWriteCompletion	back to summary
private void onQueryWriteCompletion(Future<?> writeFuture, Promise<Void> writePromise)

operationComplete back to summary

public void operationComplete(Future<? extends AddressedEnvelope<DnsResponse, InetSocketAddress>> future)

Implements io.netty5.util.concurrent.FutureListener.operationComplete.

Doc from io.netty5.util.concurrent.FutureListener.operationComplete.

Invoked when the operation associated with the Future has been completed.

Parameters

future:Future<? extends AddressedEnvelope<DnsResponse, InetSocketAddress>>: the source Future which called this callback

Annotations

@Override

parent	back to summary
pack-priv DnsNameResolver parent()

protocol	back to summary
protected abstract String protocol()

query	back to summary
pack-priv void query(boolean flush, Promise<Void> writePromise)

question	back to summary
pack-priv DnsQuestion question()

sendQuery	back to summary
private void sendQuery(final DnsQuery query, final boolean flush, final Promise<Void> writePromise)

tryFailure	back to summary
pack-priv boolean tryFailure(String message, Throwable cause, boolean timeout)

trySuccess	back to summary
private boolean trySuccess(AddressedEnvelope<? extends DnsResponse, InetSocketAddress> envelope) Annotations @SuppressWarnings:unchecked

writeQuery	back to summary
private void writeQuery(final DnsQuery query, final boolean flush, final Promise<Void> writePromise)