public class oadd.io.netty.buffer.PooledByteBufAllocatorL extends java.lang.Object
{
private static final org.slf4j.Logger memoryLogger;
private static final int MEMORY_LOGGER_FREQUENCY_SECONDS;
public static final java.lang.String METRIC_PREFIX;
private final oadd.com.codahale.metrics.MetricRegistry registry;
private final java.util.concurrent.atomic.AtomicLong hugeBufferSize;
private final java.util.concurrent.atomic.AtomicLong hugeBufferCount;
private final java.util.concurrent.atomic.AtomicLong normalBufferSize;
private final java.util.concurrent.atomic.AtomicLong normalBufferCount;
private final oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator allocator;
public final oadd.io.netty.buffer.UnsafeDirectLittleEndian empty;
public static final boolean ASSERT_ENABLED;
static final boolean $assertionsDisabled;
public void <init>(oadd.com.codahale.metrics.MetricRegistry)
{
oadd.com.codahale.metrics.MetricRegistry v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.PooledByteBufAllocatorL v;
oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator v;
java.util.concurrent.atomic.AtomicLong v, v, v, v;
oadd.io.netty.buffer.DuplicatedByteBuf v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.io.netty.buffer.PooledByteBufAllocatorL;
v := @parameter: oadd.com.codahale.metrics.MetricRegistry;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: java.util.concurrent.atomic.AtomicLong hugeBufferSize> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: java.util.concurrent.atomic.AtomicLong hugeBufferCount> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: java.util.concurrent.atomic.AtomicLong normalBufferSize> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: java.util.concurrent.atomic.AtomicLong normalBufferCount> = v;
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: oadd.com.codahale.metrics.MetricRegistry registry> = v;
v = new oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator;
specialinvoke v.<oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator: void <init>(oadd.io.netty.buffer.PooledByteBufAllocatorL)>(v);
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator allocator> = v;
v = new oadd.io.netty.buffer.UnsafeDirectLittleEndian;
v = new oadd.io.netty.buffer.DuplicatedByteBuf;
v = <oadd.io.netty.buffer.Unpooled: oadd.io.netty.buffer.ByteBuf EMPTY_BUFFER>;
specialinvoke v.<oadd.io.netty.buffer.DuplicatedByteBuf: void <init>(oadd.io.netty.buffer.ByteBuf)>(v);
specialinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: void <init>(oadd.io.netty.buffer.DuplicatedByteBuf)>(v);
v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: oadd.io.netty.buffer.UnsafeDirectLittleEndian empty> = v;
return;
}
public oadd.io.netty.buffer.UnsafeDirectLittleEndian allocate(int)
{
oadd.org.apache.drill.exec.exception.OutOfMemoryException v;
int v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.PooledByteBufAllocatorL v;
oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator v;
java.lang.OutOfMemoryError v;
v := @this: oadd.io.netty.buffer.PooledByteBufAllocatorL;
v := @parameter: int;
label:
v = v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator allocator>;
v = virtualinvoke v.<oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator: oadd.io.netty.buffer.UnsafeDirectLittleEndian directBuffer(int,int)>(v, 2147483647);
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.exec.exception.OutOfMemoryException;
specialinvoke v.<oadd.org.apache.drill.exec.exception.OutOfMemoryException: void <init>(java.lang.String,java.lang.Throwable)>("Failure allocating buffer.", v);
throw v;
catch java.lang.OutOfMemoryError from label to label with label;
}
public oadd.io.netty.buffer.ByteBuf allocateHeap(int, int)
{
oadd.org.apache.drill.exec.exception.OutOfMemoryException v;
int v, v;
oadd.io.netty.buffer.ByteBuf v;
oadd.io.netty.buffer.PooledByteBufAllocatorL v;
oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator v;
java.lang.OutOfMemoryError v;
v := @this: oadd.io.netty.buffer.PooledByteBufAllocatorL;
v := @parameter: int;
v := @parameter: int;
label:
v = v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator allocator>;
v = virtualinvoke v.<oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator: oadd.io.netty.buffer.ByteBuf heapBuffer(int,int)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.exec.exception.OutOfMemoryException;
specialinvoke v.<oadd.org.apache.drill.exec.exception.OutOfMemoryException: void <init>(java.lang.String,java.lang.Throwable)>("Failure allocating heap buffer.", v);
throw v;
catch java.lang.OutOfMemoryError from label to label with label;
}
public int getChunkSize()
{
int v;
oadd.io.netty.buffer.PooledByteBufAllocatorL v;
oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator v;
v := @this: oadd.io.netty.buffer.PooledByteBufAllocatorL;
v = v.<oadd.io.netty.buffer.PooledByteBufAllocatorL: oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator allocator>;
v = v.<oadd.io.netty.buffer.PooledByteBufAllocatorL$InnerAllocator: int chunkSize>;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.lang.Class v;
boolean v, v, v, v;
v = class "Loadd/io/netty/buffer/PooledByteBufAllocatorL;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<oadd.io.netty.buffer.PooledByteBufAllocatorL: boolean $assertionsDisabled> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("drill.allocator");
<oadd.io.netty.buffer.PooledByteBufAllocatorL: org.slf4j.Logger memoryLogger> = v;
v = 0;
v = <oadd.io.netty.buffer.PooledByteBufAllocatorL: boolean $assertionsDisabled>;
if v != 0 goto label;
v = 1;
label:
<oadd.io.netty.buffer.PooledByteBufAllocatorL: boolean ASSERT_ENABLED> = v;
return;
}
}