public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap extends java.lang.Object implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPoolMap, java.lang.Iterable, java.io.Closeable
{
private final java.util.concurrent.ConcurrentMap map;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: java.util.concurrent.ConcurrentMap newConcurrentHashMap()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map> = v;
return;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool get(java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
java.lang.Object v, v, v, v;
java.util.concurrent.ConcurrentMap v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "key");
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool newPool(java.lang.Object)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object putIfAbsent(java.lang.Object,java.lang.Object)>(v, v);
if v == null goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future poolCloseAsyncIfSupported(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool)>(v);
v = v;
label:
return v;
}
public final boolean remove(java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
java.lang.Object v, v, v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "key");
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future poolCloseAsyncIfSupported(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool)>(v);
return 1;
label:
return 0;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future removeAsyncIfSupported(java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap$1 v;
java.util.concurrent.ConcurrentMap v;
java.lang.Boolean v;
java.lang.Object v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "key");
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor INSTANCE>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise newPromise()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future poolCloseAsyncIfSupported(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise)>(v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor INSTANCE>;
v = <java.lang.Boolean: java.lang.Boolean FALSE>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future newSucceededFuture(java.lang.Object)>(v);
return v;
}
private static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future poolCloseAsyncIfSupported(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor v, v;
java.lang.Exception v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool v;
boolean v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.SimpleChannelPool;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.SimpleChannelPool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future closeAsync()>();
return v;
label:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool: void close()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor INSTANCE>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future newSucceededFuture(java.lang.Object)>(null);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor INSTANCE>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GlobalEventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future newFailedFuture(java.lang.Throwable)>(v);
return v;
catch java.lang.Exception from label to label with label;
}
public final java.util.Iterator iterator()
{
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ReadOnlyIterator v;
java.util.Set v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ReadOnlyIterator;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ReadOnlyIterator: void <init>(java.util.Iterator)>(v);
return v;
}
public final int size()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: int size()>();
return v;
}
public final boolean isEmpty()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
boolean v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean isEmpty()>();
return v;
}
public final boolean contains(java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
java.lang.Object v, v;
boolean v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "key");
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
return v;
}
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.ChannelPool newPool(java.lang.Object);
public final void close()
{
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
java.util.Set v;
java.lang.Object v;
boolean v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: java.util.concurrent.ConcurrentMap map>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.pool.AbstractChannelPoolMap: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future removeAsyncIfSupported(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future syncUninterruptibly()>();
goto label;
label:
return;
}
}