Top Fields Constructors Methods
io.netty.resolver.dns

pack-priv final Class InflightNameResolver<T>

extends Object
implements NameResolver<T>
Class Inheritance
All Implemented Interfaces
io.netty.resolver.NameResolver, java.io.Closeable, java.lang.AutoCloseable
Imports
io.netty.resolver.NameResolver, io.netty.util.concurrent.EventExecutor, .Future, .FutureListener, .Promise, io.netty.util.internal.StringUtil, java.util.List, java.util.concurrent.ConcurrentMap

Field Summary

Modifier and TypeField and 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

AccessConstructor and Description
pack-priv
InflightNameResolver(EventExecutor executor, NameResolver<T> delegate, ConcurrentMap<String, Promise<T>> resolvesInProgress, ConcurrentMap<String, Promise<List<T>>> resolveAllsInProgress)

Method Summary

Modifier and TypeMethod and Description
public void
close()

Implements io.netty.resolver.NameResolver.close.

Closes all the resources allocated and used by this resolver.
public Future<T>
resolve(String
the name to resolve
inetHost)

Implements io.netty.resolver.NameResolver.resolve.

Resolves the specified name into an address.
public Promise<T>
resolve(String
the name to resolve
inetHost, Promise<T>
the Promise which will be fulfilled when the name resolution is finished
promise)

Implements io.netty.resolver.NameResolver.resolve.

Resolves the specified name into an address.
private <U> Promise<U>
resolve(final ConcurrentMap<String, Promise<U>> resolveMap, final String inetHost, final Promise<U> promise, boolean resolveAll)

public Future<List<T>>
resolveAll(String
the name to resolve
inetHost)

Implements io.netty.resolver.NameResolver.resolveAll.

Resolves the specified host name and port into a list of address.
public Promise<List<T>>
resolveAll(String
the name to resolve
inetHost, Promise<List<T>>
the Promise which will be fulfilled when the name resolution is finished
promise)

Implements io.netty.resolver.NameResolver.resolveAll.

Resolves the specified host name and port into a list of address.
public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.
private static <T> void
transferResult(Future<T> src, Promise<T> dst)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Field Detail

delegateback to summary
private final NameResolver<T> delegate
executorback to summary
private final EventExecutor executor
resolveAllsInProgressback to summary
private final ConcurrentMap<String, Promise<List<T>>> resolveAllsInProgress
resolvesInProgressback to summary
private final ConcurrentMap<String, Promise<T>> resolvesInProgress

Constructor Detail

InflightNameResolverback to summary
pack-priv InflightNameResolver(EventExecutor executor, NameResolver<T> delegate, ConcurrentMap<String, Promise<T>> resolvesInProgress, ConcurrentMap<String, Promise<List<T>>> resolveAllsInProgress)

Method Detail

closeback to summary
public void close()

Implements io.netty.resolver.NameResolver.close.

Doc from io.netty.resolver.NameResolver.close.

Closes all the resources allocated and used by this resolver.

Annotations
@Override
resolveback to summary
public Future<T> resolve(String inetHost)

Implements io.netty.resolver.NameResolver.resolve.

Doc from io.netty.resolver.NameResolver.resolve.

Resolves the specified name into an address.

Parameters
inetHost:String

the name to resolve

Returns:Future<T>

the address as the result of the resolution

Annotations
@Override
resolveback to summary
public Promise<T> resolve(String inetHost, Promise<T> promise)

Implements io.netty.resolver.NameResolver.resolve.

Doc from io.netty.resolver.NameResolver.resolve.

Resolves the specified name into an address.

Parameters
inetHost:String

the name to resolve

promise:Promise<T>

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

Returns:Promise<T>

the address as the result of the resolution

Annotations
@Override
resolveback to summary
private <U> Promise<U> resolve(final ConcurrentMap<String, Promise<U>> resolveMap, final String inetHost, final Promise<U> promise, boolean resolveAll)
resolveAllback to summary
public Future<List<T>> resolveAll(String inetHost)

Implements io.netty.resolver.NameResolver.resolveAll.

Doc from io.netty.resolver.NameResolver.resolveAll.

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

Parameters
inetHost:String

the name to resolve

Returns:Future<List<T>>

the list of the address as the result of the resolution

Annotations
@Override
resolveAllback to summary
public Promise<List<T>> resolveAll(String inetHost, Promise<List<T>> promise)

Implements io.netty.resolver.NameResolver.resolveAll.

Doc from io.netty.resolver.NameResolver.resolveAll.

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

Parameters
inetHost:String

the name to resolve

promise:Promise<List<T>>

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

Returns:Promise<List<T>>

the list of the address as the result of the resolution

Annotations
@Override
toStringback to summary
public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object

Annotations
@Override
transferResultback to summary
private static <T> void transferResult(Future<T> src, Promise<T> dst)