public abstract class io.netty.resolver.AbstractAddressResolver extends java.lang.Object implements io.netty.resolver.AddressResolver
{
private final io.netty.util.concurrent.EventExecutor executor;
private final io.netty.util.internal.TypeParameterMatcher matcher;
protected void <init>(io.netty.util.concurrent.EventExecutor)
{
io.netty.util.concurrent.EventExecutor v;
io.netty.util.internal.TypeParameterMatcher v;
java.lang.Object v;
io.netty.resolver.AbstractAddressResolver v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: io.netty.util.concurrent.EventExecutor;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "executor");
v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor> = v;
v = staticinvoke <io.netty.util.internal.TypeParameterMatcher: io.netty.util.internal.TypeParameterMatcher find(java.lang.Object,java.lang.Class,java.lang.String)>(v, class "Lio/netty/resolver/AbstractAddressResolver;", "T");
v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.internal.TypeParameterMatcher matcher> = v;
return;
}
protected void <init>(io.netty.util.concurrent.EventExecutor, java.lang.Class)
{
io.netty.util.concurrent.EventExecutor v;
io.netty.util.internal.TypeParameterMatcher v;
java.lang.Class v;
java.lang.Object v;
io.netty.resolver.AbstractAddressResolver v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: io.netty.util.concurrent.EventExecutor;
v := @parameter: java.lang.Class;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "executor");
v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor> = v;
v = staticinvoke <io.netty.util.internal.TypeParameterMatcher: io.netty.util.internal.TypeParameterMatcher get(java.lang.Class)>(v);
v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.internal.TypeParameterMatcher matcher> = v;
return;
}
protected io.netty.util.concurrent.EventExecutor executor()
{
io.netty.util.concurrent.EventExecutor v;
io.netty.resolver.AbstractAddressResolver v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v = v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor>;
return v;
}
public boolean isSupported(java.net.SocketAddress)
{
java.net.SocketAddress v;
io.netty.util.internal.TypeParameterMatcher v;
io.netty.resolver.AbstractAddressResolver v;
boolean v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: java.net.SocketAddress;
v = v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.internal.TypeParameterMatcher matcher>;
v = virtualinvoke v.<io.netty.util.internal.TypeParameterMatcher: boolean match(java.lang.Object)>(v);
return v;
}
public final boolean isResolved(java.net.SocketAddress)
{
java.net.SocketAddress v;
java.nio.channels.UnsupportedAddressTypeException v;
io.netty.resolver.AbstractAddressResolver v;
boolean v, v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: java.net.SocketAddress;
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isSupported(java.net.SocketAddress)>(v);
if v != 0 goto label;
v = new java.nio.channels.UnsupportedAddressTypeException;
specialinvoke v.<java.nio.channels.UnsupportedAddressTypeException: void <init>()>();
throw v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean doIsResolved(java.net.SocketAddress)>(v);
return v;
}
protected abstract boolean doIsResolved(java.net.SocketAddress);
public final io.netty.util.concurrent.Future resolve(java.net.SocketAddress)
{
io.netty.util.concurrent.EventExecutor v, v, v, v;
io.netty.util.concurrent.Promise v;
java.net.SocketAddress v;
java.nio.channels.UnsupportedAddressTypeException v;
io.netty.resolver.AbstractAddressResolver v;
java.lang.Exception v;
java.lang.Object v;
io.netty.util.concurrent.Future v, v, v;
boolean v, v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: java.net.SocketAddress;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "address");
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isSupported(java.net.SocketAddress)>(v);
if v != 0 goto label;
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor()>();
v = new java.nio.channels.UnsupportedAddressTypeException;
specialinvoke v.<java.nio.channels.UnsupportedAddressTypeException: void <init>()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Future newFailedFuture(java.lang.Throwable)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isResolved(java.net.SocketAddress)>(v);
if v == 0 goto label;
v = v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor>;
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Future newSucceededFuture(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Promise newPromise()>();
virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: void doResolve(java.net.SocketAddress,io.netty.util.concurrent.Promise)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Future newFailedFuture(java.lang.Throwable)>(v);
return v;
catch java.lang.Exception from label to label with label;
}
public final io.netty.util.concurrent.Future resolve(java.net.SocketAddress, io.netty.util.concurrent.Promise)
{
io.netty.util.concurrent.Promise v, v, v, v;
java.net.SocketAddress v;
java.nio.channels.UnsupportedAddressTypeException v;
io.netty.resolver.AbstractAddressResolver v;
java.lang.Exception v;
boolean v, v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: java.net.SocketAddress;
v := @parameter: io.netty.util.concurrent.Promise;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "address");
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "promise");
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isSupported(java.net.SocketAddress)>(v);
if v != 0 goto label;
v = new java.nio.channels.UnsupportedAddressTypeException;
specialinvoke v.<java.nio.channels.UnsupportedAddressTypeException: void <init>()>();
v = interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isResolved(java.net.SocketAddress)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise setSuccess(java.lang.Object)>(v);
return v;
label:
virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: void doResolve(java.net.SocketAddress,io.netty.util.concurrent.Promise)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise setFailure(java.lang.Throwable)>(v);
return v;
catch java.lang.Exception from label to label with label;
}
public final io.netty.util.concurrent.Future resolveAll(java.net.SocketAddress)
{
io.netty.util.concurrent.EventExecutor v, v, v, v;
java.net.SocketAddress v;
io.netty.resolver.AbstractAddressResolver v;
boolean v, v;
io.netty.util.concurrent.Promise v;
java.nio.channels.UnsupportedAddressTypeException v;
java.lang.Exception v;
java.util.List v;
java.lang.Object v;
io.netty.util.concurrent.Future v, v, v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: java.net.SocketAddress;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "address");
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isSupported(java.net.SocketAddress)>(v);
if v != 0 goto label;
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor()>();
v = new java.nio.channels.UnsupportedAddressTypeException;
specialinvoke v.<java.nio.channels.UnsupportedAddressTypeException: void <init>()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Future newFailedFuture(java.lang.Throwable)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isResolved(java.net.SocketAddress)>(v);
if v == 0 goto label;
v = v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor>;
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Future newSucceededFuture(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Promise newPromise()>();
virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: void doResolveAll(java.net.SocketAddress,io.netty.util.concurrent.Promise)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.Future newFailedFuture(java.lang.Throwable)>(v);
return v;
catch java.lang.Exception from label to label with label;
}
public final io.netty.util.concurrent.Future resolveAll(java.net.SocketAddress, io.netty.util.concurrent.Promise)
{
io.netty.util.concurrent.Promise v, v, v, v;
java.net.SocketAddress v;
java.nio.channels.UnsupportedAddressTypeException v;
io.netty.resolver.AbstractAddressResolver v;
java.lang.Exception v;
java.util.List v;
boolean v, v;
v := @this: io.netty.resolver.AbstractAddressResolver;
v := @parameter: java.net.SocketAddress;
v := @parameter: io.netty.util.concurrent.Promise;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "address");
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "promise");
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isSupported(java.net.SocketAddress)>(v);
if v != 0 goto label;
v = new java.nio.channels.UnsupportedAddressTypeException;
specialinvoke v.<java.nio.channels.UnsupportedAddressTypeException: void <init>()>();
v = interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: boolean isResolved(java.net.SocketAddress)>(v);
if v == 0 goto label;
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise setSuccess(java.lang.Object)>(v);
return v;
label:
virtualinvoke v.<io.netty.resolver.AbstractAddressResolver: void doResolveAll(java.net.SocketAddress,io.netty.util.concurrent.Promise)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise setFailure(java.lang.Throwable)>(v);
return v;
catch java.lang.Exception from label to label with label;
}
protected abstract void doResolve(java.net.SocketAddress, io.netty.util.concurrent.Promise) throws java.lang.Exception;
protected abstract void doResolveAll(java.net.SocketAddress, io.netty.util.concurrent.Promise) throws java.lang.Exception;
public void close()
{
io.netty.resolver.AbstractAddressResolver v;
v := @this: io.netty.resolver.AbstractAddressResolver;
return;
}
}