public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler extends java.lang.Object
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle NOOP_HANDLE;
private static final java.util.concurrent.atomic.AtomicInteger ID_GENERATOR;
private static final int OWN_THREAD_ID;
private static final int DEFAULT_INITIAL_MAX_CAPACITY_PER_THREAD;
private static final int DEFAULT_MAX_CAPACITY_PER_THREAD;
private static final int INITIAL_CAPACITY;
private static final int MAX_SHARED_CAPACITY_FACTOR;
private static final int MAX_DELAYED_QUEUES_PER_THREAD;
private static final int LINK_CAPACITY;
private static final int RATIO;
private final int maxCapacityPerThread;
private final int maxSharedCapacityFactor;
private final int interval;
private final int maxDelayedQueuesPerThread;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal threadLocal;
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal DELAYED_RECYCLED;
protected void <init>()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int DEFAULT_MAX_CAPACITY_PER_THREAD>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: void <init>(int)>(v);
return;
}
protected void <init>(int)
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v := @parameter: int;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int MAX_SHARED_CAPACITY_FACTOR>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: void <init>(int,int)>(v, v);
return;
}
protected void <init>(int, int)
{
int v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v := @parameter: int;
v := @parameter: int;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int RATIO>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int MAX_DELAYED_QUEUES_PER_THREAD>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: void <init>(int,int,int,int)>(v, v, v, v);
return;
}
protected void <init>(int, int, int, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$2 v;
int v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal threadLocal> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.MathUtil: int safeFindNextPositivePowerOfTwo(int)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int interval> = v;
if v > 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxCapacityPerThread> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxSharedCapacityFactor> = 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxDelayedQueuesPerThread> = 0;
goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxCapacityPerThread> = v;
v = staticinvoke <java.lang.Math: int max(int,int)>(1, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxSharedCapacityFactor> = v;
v = staticinvoke <java.lang.Math: int max(int,int)>(0, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxDelayedQueuesPerThread> = v;
label:
return;
}
public final java.lang.Object get()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal v;
int v;
java.lang.Object v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int maxCapacityPerThread>;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle NOOP_HANDLE>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: java.lang.Object newObject(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle)>(v);
return v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal threadLocal>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle pop()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle newHandle()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: java.lang.Object newObject(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle: java.lang.Object value> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle: java.lang.Object value>;
return v;
}
public final boolean recycle(java.lang.Object, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle NOOP_HANDLE>;
if v != v goto label;
return 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack stack>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler parent>;
if v == v goto label;
return 0;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle: void recycle(java.lang.Object)>(v);
return 1;
}
final int threadLocalCapacity()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal v;
int v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle[] v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal threadLocal>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal: java.lang.Object get()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$DefaultHandle[] elements>;
v = lengthof v;
return v;
}
final int threadLocalSize()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal v;
int v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal threadLocal>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal: java.lang.Object get()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Stack: int size>;
return v;
}
protected abstract java.lang.Object newObject(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle);
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$3 v;
java.lang.Integer v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$1 v;
java.util.concurrent.atomic.AtomicInteger v, v;
boolean v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/util/Recycler;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$1: void <init>()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$Handle NOOP_HANDLE> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(-2147483648);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: java.util.concurrent.atomic.AtomicInteger ID_GENERATOR> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: java.util.concurrent.atomic.AtomicInteger ID_GENERATOR>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int getAndIncrement()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int OWN_THREAD_ID> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.recycler.maxCapacity", 4096);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.recycler.maxCapacityPerThread", v);
if v >= 0 goto label;
v = 4096;
label:
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int DEFAULT_MAX_CAPACITY_PER_THREAD> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.recycler.maxSharedCapacityFactor", 2);
v = staticinvoke <java.lang.Math: int max(int,int)>(2, v);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int MAX_SHARED_CAPACITY_FACTOR> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NettyRuntime: int availableProcessors()>();
v = v * 2;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.recycler.maxDelayedQueuesPerThread", v);
v = staticinvoke <java.lang.Math: int max(int,int)>(0, v);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int MAX_DELAYED_QUEUES_PER_THREAD> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.recycler.linkCapacity", 16);
v = staticinvoke <java.lang.Math: int max(int,int)>(v, 16);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.MathUtil: int safeFindNextPositivePowerOfTwo(int)>(v);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int LINK_CAPACITY> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.recycler.ratio", 8);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.MathUtil: int safeFindNextPositivePowerOfTwo(int)>(v);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int RATIO> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int DEFAULT_MAX_CAPACITY_PER_THREAD>;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String)>("-Dio.netty.recycler.maxCapacityPerThread: disabled");
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String)>("-Dio.netty.recycler.maxSharedCapacityFactor: disabled");
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String)>("-Dio.netty.recycler.linkCapacity: disabled");
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String)>("-Dio.netty.recycler.ratio: disabled");
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int DEFAULT_MAX_CAPACITY_PER_THREAD>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String,java.lang.Object)>("-Dio.netty.recycler.maxCapacityPerThread: {}", v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int MAX_SHARED_CAPACITY_FACTOR>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String,java.lang.Object)>("-Dio.netty.recycler.maxSharedCapacityFactor: {}", v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int LINK_CAPACITY>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String,java.lang.Object)>("-Dio.netty.recycler.linkCapacity: {}", v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int RATIO>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void debug(java.lang.String,java.lang.Object)>("-Dio.netty.recycler.ratio: {}", v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int DEFAULT_MAX_CAPACITY_PER_THREAD>;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, 256);
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: int INITIAL_CAPACITY> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler$3: void <init>()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Recycler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.FastThreadLocal DELAYED_RECYCLED> = v;
return;
}
}