Package io.netty.resolver.dns

Class InflightNameResolver<T>

java.lang.Object

io.netty.resolver.dns.InflightNameResolver<T>

All Implemented Interfaces:

NameResolver<T>, Closeable, AutoCloseable

final class InflightNameResolver<T>
extends Object
implements NameResolver<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final NameResolver<T>	delegate
private final EventExecutor	executor
private final ConcurrentMap<String,Promise<List<T>>>	resolveAllsInProgress
private final ConcurrentMap<String,Promise<T>>	resolvesInProgress

Constructor Summary

Constructors

Constructor	Description
InflightNameResolver(EventExecutor executor, NameResolver<T> delegate, ConcurrentMap<String,Promise<T>> resolvesInProgress, ConcurrentMap<String,Promise<List<T>>> resolveAllsInProgress)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes all the resources allocated and used by this resolver.
Future<T>	resolve(String inetHost)	Resolves the specified name into an address.
Promise<T>	resolve(String inetHost, Promise<T> promise)	Resolves the specified name into an address.
private <U> Promise<U>	resolve(ConcurrentMap<String,Promise<U>> resolveMap, String inetHost, Promise<U> promise, boolean resolveAll)
Future<List<T>>	resolveAll(String inetHost)	Resolves the specified host name and port into a list of address.
Promise<List<T>>	resolveAll(String inetHost, Promise<List<T>> promise)	Resolves the specified host name and port into a list of address.
String	toString()
private static <T> void	transferResult(Future<T> src, Promise<T> dst)

Methods inherited from class java.lang.Object

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

Field Details

executor

private final EventExecutor executor

delegate

private final NameResolver<T> delegate

resolvesInProgress

private final ConcurrentMap<String,Promise<T>> resolvesInProgress

resolveAllsInProgress

private final ConcurrentMap<String,Promise<List<T>>> resolveAllsInProgress

Constructor Details

InflightNameResolver

InflightNameResolver(EventExecutor executor,
 NameResolver<T> delegate,
 ConcurrentMap<String,Promise<T>> resolvesInProgress,
 ConcurrentMap<String,Promise<List<T>>> resolveAllsInProgress)

Method Details

resolve

public Future<T> resolve(String inetHost)

Description copied from interface: NameResolver

Resolves the specified name into an address.

Specified by:

resolve in interface NameResolver<T>

Parameters:

inetHost - the name to resolve

Returns:

the address as the result of the resolution

resolveAll

public Future<List<T>> resolveAll(String inetHost)

Description copied from interface: NameResolver

Resolves the specified host name and port into a list of address.

Specified by:

resolveAll in interface NameResolver<T>

Parameters:

inetHost - the name to resolve

Returns:

the list of the address as the result of the resolution

close

public void close()

Description copied from interface: NameResolver

Closes all the resources allocated and used by this resolver.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface NameResolver<T>

resolve

public Promise<T> resolve(String inetHost,
 Promise<T> promise)

Description copied from interface: NameResolver

Resolves the specified name into an address.

Specified by:

resolve in interface NameResolver<T>

Parameters:

inetHost - the name to resolve

promise - the Promise which will be fulfilled when the name resolution is finished

Returns:

the address as the result of the resolution

resolveAll

public Promise<List<T>> resolveAll(String inetHost,
 Promise<List<T>> promise)

Description copied from interface: NameResolver

Resolves the specified host name and port into a list of address.

Specified by:

resolveAll in interface NameResolver<T>

Parameters:

inetHost - the name to resolve

promise - the Promise which will be fulfilled when the name resolution is finished

Returns:

the list of the address as the result of the resolution

resolve

private <U> Promise<U> resolve(ConcurrentMap<String,Promise<U>> resolveMap,
 String inetHost,
 Promise<U> promise,
 boolean resolveAll)

transferResult

private static <T> void transferResult(Future<T> src,
 Promise<T> dst)

toString

public String toString()

Overrides:

toString in class Object