Netty 4.1.107.Final · io.netty.resolver.dns.DnsResolveContext

Modifier and Type	Class and Description
private static class	DnsResolveContext.AuthoritativeNameServer
private static class	DnsResolveContext.AuthoritativeNameServerList Holds the closed DNS Servers for a domain.
private class	DnsResolveContext.CombinedDnsServerAddressStream
private static class	DnsResolveContext.DnsAddressStreamList
pack-priv static class	DnsResolveContext.DnsResolveContextException
private static class	DnsResolveContext.RedirectAuthoritativeDnsServerCache
private static class	DnsResolveContext.SearchDomainUnknownHostException

Modifier and Type	Field and Description
pack-priv final DnsRecord[]	additionals
private int	allowedQueries
private final Channel	channel
private final Future<? extends Channel>	channelReadyFuture
private static final RuntimeException	CNAME_NOT_FOUND_QUERY_FAILED_EXCEPTION
private boolean	completeEarly
private final int	dnsClass
private final DnsRecordType[]	expectedTypes
private List<T>	finalResult
private final String	hostname
private static final InternalLogger	logger
private static final RuntimeException	NAME_SERVERS_EXHAUSTED_EXCEPTION
private final DnsServerAddressStream	nameServerAddrs
private static final RuntimeException	NO_MATCHING_RECORD_QUERY_FAILED_EXCEPTION
private static final RuntimeException	NXDOMAIN_CAUSE_QUERY_FAILED_EXCEPTION
private static final RuntimeException	NXDOMAIN_QUERY_FAILED_EXCEPTION
private final Promise<?>	originalPromise
pack-priv final DnsNameResolver	parent
private final Set<Future<AddressedEnvelope<DnsResponse, InetSocketAddress>>>	queriesInProgress
private static final RuntimeException	SERVFAIL_QUERY_FAILED_EXCEPTION
private boolean	triedCNAME
private static final RuntimeException	UNRECOGNIZED_TYPE_QUERY_FAILED_EXCEPTION

Access	Constructor and Description
pack-priv	DnsResolveContext(DnsNameResolver parent, Channel channel, Future<? extends Channel> channelReadyFuture, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)

Method Summary

Modifier and Type	Method and Description
pack-priv AuthoritativeDnsServerCache	authoritativeDnsServerCache() The `AuthoritativeDnsServerCache` to use while resolving.
private static Map<String, String>	buildAliasMap(DnsResponse response, DnsCnameCache cache, EventLoop loop)
pack-priv abstract void	cache(String hostname, DnsRecord[] additionals, DnsRecord result, T convertedResult) Caches a successful resolution.
pack-priv abstract void	cache(String hostname, DnsRecord[] additionals, UnknownHostException cause) Caches a failed resolution.
private static Throwable	cause(final DnsResponseCode code)
pack-priv Channel	channel() The `Channel` used.
private static void	checkCnameLoop(String hostname, String first, String second)
pack-priv DnsCnameCache	cnameCache() The `DnsCnameCache` that is used for resolving.
pack-priv static String	cnameResolveFromCache(DnsCnameCache cnameCache, String name)
private static String	cnameResolveFromCacheLoop(DnsCnameCache cnameCache, String hostname, String first, String mapping)
pack-priv abstract T	convertRecord(DnsRecord record, String hostname, DnsRecord[] additionals, EventLoop eventLoop) Converts the given `DnsRecord` into `T`.
pack-priv static String	decodeDomainName(ByteBuf in)
pack-priv void	doSearchDomainQuery(String hostname, Promise<List<T>> nextPromise)
private static DnsResolveContext.AuthoritativeNameServerList	extractAuthoritativeNameServers(String questionName, DnsResponse res) Returns the {@code `AuthoritativeNameServerList` which were included in `DnsSection#AUTHORITY` or `null` if non are found.
pack-priv abstract List<T>	filterResults(List<T> unfiltered) Returns a filtered list of results which should be the final result of DNS resolution.
private void	finishResolve(Promise<List<T>> promise, Throwable cause)
private void	followCname(DnsQuestion question, String cname, DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise)
private DnsServerAddressStream	getNameServers(String name)
private DnsServerAddressStream	getNameServersFromCache(String hostname) Returns the `DnsServerAddressStream` that was cached for the given hostname or `null` if non could be found.
private boolean	handleRedirect(DnsQuestion question, AddressedEnvelope<DnsResponse, InetSocketAddress> envelope, final DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise) Handles a redirect answer if needed and returns `true` if a redirect query has been made.
private boolean	hasNDots()
private static String	hostnameWithDot(String name)
private void	internalResolve(String name, Promise<List<T>> promise)
pack-priv abstract boolean	isCompleteEarly(T resolved)
pack-priv abstract boolean	isDuplicateAllowed() Returns `true` if we should allow duplicates in the result or `false` if no duplicates should be included.
private DnsQueryLifecycleObserver	newDnsQueryLifecycleObserver(DnsQuestion question)
pack-priv abstract DnsResolveContext<T>	newResolverContext(DnsNameResolver parent, Channel channel, Future<? extends Channel> channelReadyFuture, Promise<?> originalPromise, String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries) Creates a new context with the given parameters.
private void	onExpectedResponse(DnsQuestion question, AddressedEnvelope<DnsResponse, InetSocketAddress> envelope, final DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise)
private void	onResponse(final DnsServerAddressStream nameServerAddrStream, final int nameServerAddrStreamIndex, final DnsQuestion question, AddressedEnvelope<DnsResponse, InetSocketAddress> envelope, final DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise)
private void	onResponseCNAME(DnsQuestion question, Map<String, String> cnames, final DnsQueryLifecycleObserver queryLifecycleObserver, Promise<List<T>> promise)
private void	query(final DnsServerAddressStream nameServerAddrStream, final int nameServerAddrStreamIndex, final DnsQuestion question, final DnsQueryLifecycleObserver queryLifecycleObserver, final boolean flush, final Promise<List<T>> promise, final Throwable cause)
private boolean	query(String hostname, DnsRecordType type, DnsServerAddressStream dnsServerAddressStream, boolean flush, Promise<List<T>> promise)
private void	queryUnresolvedNameServer(final InetSocketAddress nameServerAddr, final DnsServerAddressStream nameServerAddrStream, final int nameServerAddrStreamIndex, final DnsQuestion question, final DnsQueryLifecycleObserver queryLifecycleObserver, final Promise<List<T>> promise, final Throwable cause)
private static AuthoritativeDnsServerCache	redirectAuthoritativeDnsServerCache(AuthoritativeDnsServerCache authoritativeDnsServerCache)
pack-priv void	resolve(final Promise<List<T>> promise)
pack-priv DnsCache	resolveCache() The `DnsCache` to use while resolving.
private void	tryToFinishResolve(final DnsServerAddressStream nameServerAddrStream, final int nameServerAddrStreamIndex, final DnsQuestion question, final DnsQueryLifecycleObserver queryLifecycleObserver, final Promise<List<T>> promise, final Throwable cause)

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

pack-priv abstract Class DnsResolveContext<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary