public final class oadd.io.netty.buffer.DrillBuf extends oadd.io.netty.buffer.AbstractByteBuf implements java.lang.AutoCloseable
{
private static final org.slf4j.Logger logger;
private static final java.util.concurrent.atomic.AtomicLong idGenerator;
private final long id;
private final java.util.concurrent.atomic.AtomicInteger refCnt;
private final oadd.io.netty.buffer.UnsafeDirectLittleEndian udle;
private final long addr;
private final int offset;
private final oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger;
private final oadd.org.apache.drill.exec.ops.BufferManager bufManager;
private final boolean isEmpty;
private volatile int length;
private final oadd.org.apache.drill.common.HistoricalLog historicalLog;
private static final int LOG_BYTES_PER_ROW;
private static final char[] HEX_CHAR;
public static final int LONG_NUM_BYTES;
public static final int INT_NUM_BYTES;
public static final int SHORT_NUM_BYTES;
public void <init>(java.util.concurrent.atomic.AtomicInteger, oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger, oadd.io.netty.buffer.UnsafeDirectLittleEndian, oadd.org.apache.drill.exec.ops.BufferManager, oadd.io.netty.buffer.ByteBufAllocator, int, int, boolean)
{
java.lang.Object[] v, v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
long v, v, v, v;
java.lang.Long v;
java.util.concurrent.atomic.AtomicInteger v;
int v, v, v;
oadd.io.netty.buffer.ByteBufAllocator v;
oadd.org.apache.drill.exec.ops.BufferManager v;
boolean v, v, v;
java.util.concurrent.atomic.AtomicLong v;
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.common.HistoricalLog v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: java.util.concurrent.atomic.AtomicInteger;
v := @parameter: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger;
v := @parameter: oadd.io.netty.buffer.UnsafeDirectLittleEndian;
v := @parameter: oadd.org.apache.drill.exec.ops.BufferManager;
v := @parameter: oadd.io.netty.buffer.ByteBufAllocator;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int maxCapacity()>();
specialinvoke v.<oadd.io.netty.buffer.AbstractByteBuf: void <init>(int)>(v);
v = <oadd.io.netty.buffer.DrillBuf: java.util.concurrent.atomic.AtomicLong idGenerator>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
v.<oadd.io.netty.buffer.DrillBuf: long id> = v;
v = <oadd.org.apache.drill.exec.memory.BaseAllocator: boolean DEBUG>;
if v == 0 goto label;
v = new oadd.org.apache.drill.common.HistoricalLog;
v = newarray (java.lang.Object)[1];
v = v.<oadd.io.netty.buffer.DrillBuf: long id>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
specialinvoke v.<oadd.org.apache.drill.common.HistoricalLog: void <init>(int,java.lang.String,java.lang.Object[])>(6, "DrillBuf[%d]", v);
goto label;
label:
v = null;
label:
v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.common.HistoricalLog historicalLog> = v;
v.<oadd.io.netty.buffer.DrillBuf: java.util.concurrent.atomic.AtomicInteger refCnt> = v;
v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle> = v;
v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty> = v;
v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.ops.BufferManager bufManager> = v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: long memoryAddress()>();
v = v + v;
v.<oadd.io.netty.buffer.DrillBuf: long addr> = v;
v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger> = v;
v.<oadd.io.netty.buffer.DrillBuf: int length> = v;
v.<oadd.io.netty.buffer.DrillBuf: int offset> = v;
v = <oadd.org.apache.drill.exec.memory.BaseAllocator: boolean DEBUG>;
if v == 0 goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.common.HistoricalLog historicalLog>;
v = newarray (java.lang.Object)[0];
virtualinvoke v.<oadd.org.apache.drill.common.HistoricalLog: void recordEvent(java.lang.String,java.lang.Object[])>("create()", v);
label:
return;
}
public oadd.io.netty.buffer.DrillBuf reallocIfNeeded(int)
{
java.lang.UnsupportedOperationException v;
oadd.io.netty.buffer.DrillBuf v, v;
int v, v;
oadd.org.apache.drill.exec.ops.BufferManager v, v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "reallocation size must be non-negative");
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int capacity()>();
if v < v goto label;
return v;
label:
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.ops.BufferManager bufManager>;
if v == null goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.ops.BufferManager bufManager>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.BufferManager: oadd.io.netty.buffer.DrillBuf replace(oadd.io.netty.buffer.DrillBuf,int)>(v, v);
return v;
label:
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Realloc is only available in the context of an operator\'s UDFs");
throw v;
}
public int refCnt()
{
oadd.io.netty.buffer.DrillBuf v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
return 1;
label:
v = v.<oadd.io.netty.buffer.DrillBuf: java.util.concurrent.atomic.AtomicInteger refCnt>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
public long addr()
{
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: long addr>;
return v;
}
private long addr(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: long addr>;
v = v + v;
return v;
}
private void chk(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void lengthCheck(oadd.io.netty.buffer.DrillBuf,int,int)>(v, v, v);
return;
}
public oadd.io.netty.buffer.DrillBuf retain(oadd.org.apache.drill.exec.memory.BufferAllocator)
{
java.lang.Object[] v;
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v, v;
oadd.io.netty.buffer.DrillBuf v, v;
int v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.String v;
oadd.org.apache.drill.common.HistoricalLog v;
boolean v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
return v;
label:
v = <oadd.org.apache.drill.exec.memory.BaseAllocator: boolean DEBUG>;
if v == 0 goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.common.HistoricalLog historicalLog>;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: java.lang.String getName()>();
v[0] = v;
virtualinvoke v.<oadd.org.apache.drill.common.HistoricalLog: void recordEvent(java.lang.String,java.lang.Object[])>("retain(%s)", v);
label:
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger getLedgerForAllocator(oadd.org.apache.drill.exec.memory.BufferAllocator)>(v);
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: oadd.io.netty.buffer.DrillBuf newDrillBuf(int,int,oadd.org.apache.drill.exec.ops.BufferManager)>(v, v, null);
return v;
}
public oadd.io.netty.buffer.DrillBuf$TransferResult transferOwnership(oadd.org.apache.drill.exec.memory.BufferAllocator)
{
oadd.io.netty.buffer.DrillBuf$TransferResult v, v;
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v, v, v;
oadd.io.netty.buffer.DrillBuf v, v;
int v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
boolean v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
v = new oadd.io.netty.buffer.DrillBuf$TransferResult;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf$TransferResult: void <init>(oadd.io.netty.buffer.DrillBuf,boolean,oadd.io.netty.buffer.DrillBuf)>(v, 1, v);
return v;
label:
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger getLedgerForAllocator(oadd.org.apache.drill.exec.memory.BufferAllocator)>(v);
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: oadd.io.netty.buffer.DrillBuf newDrillBuf(int,int,oadd.org.apache.drill.exec.ops.BufferManager)>(v, v, null);
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: boolean transferBalance(oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger)>(v);
v = new oadd.io.netty.buffer.DrillBuf$TransferResult;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf$TransferResult: void <init>(oadd.io.netty.buffer.DrillBuf,boolean,oadd.io.netty.buffer.DrillBuf)>(v, v, v);
return v;
}
public oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger getLedger()
{
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
return v;
}
public boolean release()
{
oadd.io.netty.buffer.DrillBuf v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release(int)>(1);
return v;
}
public boolean release(int)
{
java.lang.IllegalStateException v, v;
java.lang.Object[] v, v, v;
long v;
java.lang.Integer v, v, v;
java.lang.Long v;
int v, v, v;
java.lang.String v, v, v, v;
boolean v, v, v;
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.common.HistoricalLog v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
return 0;
label:
if v >= 1 goto label;
v = new java.lang.IllegalStateException;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.lang.String toVerboseString()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("release(%d) argument is not positive. Buffer Info: %s", v);
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: int decrement(int)>(v);
v = <oadd.org.apache.drill.exec.memory.BaseAllocator: boolean DEBUG>;
if v == 0 goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.common.HistoricalLog historicalLog>;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v + v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
virtualinvoke v.<oadd.org.apache.drill.common.HistoricalLog: void recordEvent(java.lang.String,java.lang.Object[])>("release(%d). original value: %d", v);
label:
if v >= 0 goto label;
v = new java.lang.IllegalStateException;
v = newarray (java.lang.Object)[2];
v = v.<oadd.io.netty.buffer.DrillBuf: long id>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.lang.String toVerboseString()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("DrillBuf[%d] refCnt has gone negative. Buffer Info: %s", v);
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int capacity()
{
int v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
return v;
}
public synchronized oadd.io.netty.buffer.DrillBuf capacity(int)
{
java.lang.UnsupportedOperationException v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
if v != v goto label;
return v;
label:
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
if v >= v goto label;
v.<oadd.io.netty.buffer.DrillBuf: int length> = v;
return v;
label:
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Buffers don\'t support resizing that increases the size.");
throw v;
}
public oadd.io.netty.buffer.ByteBufAllocator alloc()
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.ByteBufAllocator v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBufAllocator alloc()>();
return v;
}
public java.nio.ByteOrder order()
{
java.nio.ByteOrder v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = <java.nio.ByteOrder: java.nio.ByteOrder LITTLE_ENDIAN>;
return v;
}
public oadd.io.netty.buffer.ByteBuf order(java.nio.ByteOrder)
{
java.nio.ByteOrder v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: java.nio.ByteOrder;
return v;
}
public oadd.io.netty.buffer.ByteBuf unwrap()
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
return v;
}
public boolean isDirect()
{
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
return 1;
}
public oadd.io.netty.buffer.ByteBuf readBytes(int)
{
int v;
java.lang.UnsupportedOperationException v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public oadd.io.netty.buffer.ByteBuf readSlice(int)
{
oadd.io.netty.buffer.DrillBuf v, v;
int v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readerIndex()>();
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.DrillBuf slice(int,int)>(v, v);
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readerIndex()>();
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf readerIndex(int)>(v);
return v;
}
public oadd.io.netty.buffer.ByteBuf copy()
{
java.lang.UnsupportedOperationException v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public oadd.io.netty.buffer.ByteBuf copy(int, int)
{
java.lang.UnsupportedOperationException v;
oadd.io.netty.buffer.DrillBuf v;
int v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public oadd.io.netty.buffer.ByteBuf slice()
{
oadd.io.netty.buffer.DrillBuf v, v;
int v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readerIndex()>();
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readableBytes()>();
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.DrillBuf slice(int,int)>(v, v);
return v;
}
public static java.lang.String bufferState(oadd.io.netty.buffer.ByteBuf)
{
java.lang.Object[] v;
java.lang.Integer v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.String v;
oadd.io.netty.buffer.ByteBuf v;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int capacity()>();
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int maxCapacity()>();
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int readerIndex()>();
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int readableBytes()>();
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int writerIndex()>();
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int writableBytes()>();
v = newarray (java.lang.Object)[6];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[3] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[4] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[5] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("cap/max: %d/%d, ri: %d, rb: %d, wi: %d, wb: %d", v);
return v;
}
public oadd.io.netty.buffer.DrillBuf slice(int, int)
{
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v, v;
int v, v, v, v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
return v;
label:
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: oadd.io.netty.buffer.DrillBuf newDrillBuf(int,int)>(v, v);
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf writerIndex(int)>(v);
return v;
}
public oadd.io.netty.buffer.DrillBuf duplicate()
{
int v;
oadd.io.netty.buffer.DrillBuf v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.DrillBuf slice(int,int)>(0, v);
return v;
}
public int nioBufferCount()
{
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
return 1;
}
public java.nio.ByteBuffer nioBuffer()
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readerIndex()>();
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readableBytes()>();
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.nio.ByteBuffer nioBuffer(int,int)>(v, v);
return v;
}
public java.nio.ByteBuffer nioBuffer(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: java.nio.ByteBuffer nioBuffer(int,int)>(v, v);
return v;
}
public java.nio.ByteBuffer internalNioBuffer(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: java.nio.ByteBuffer internalNioBuffer(int,int)>(v, v);
return v;
}
public java.nio.ByteBuffer[] nioBuffers()
{
java.nio.ByteBuffer[] v;
oadd.io.netty.buffer.DrillBuf v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = newarray (java.nio.ByteBuffer)[1];
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.nio.ByteBuffer nioBuffer()>();
v[0] = v;
return v;
}
public java.nio.ByteBuffer[] nioBuffers(int, int)
{
java.nio.ByteBuffer[] v;
oadd.io.netty.buffer.DrillBuf v;
int v, v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v = newarray (java.nio.ByteBuffer)[1];
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.nio.ByteBuffer nioBuffer(int,int)>(v, v);
v[0] = v;
return v;
}
public boolean hasArray()
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: boolean hasArray()>();
return v;
}
public byte[] array()
{
byte[] v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: byte[] array()>();
return v;
}
public int arrayOffset()
{
int v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int arrayOffset()>();
return v;
}
public boolean hasMemoryAddress()
{
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
return 1;
}
public long memoryAddress()
{
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: long addr>;
return v;
}
public java.lang.String toString()
{
java.lang.Object[] v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
long v, v;
java.lang.Integer v, v;
oadd.io.netty.buffer.DrillBuf v;
java.lang.Long v, v;
int v, v, v, v;
java.lang.String v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = newarray (java.lang.Object)[4];
v = v.<oadd.io.netty.buffer.DrillBuf: long id>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: long id>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int capacity()>();
v = v + v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[3] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("DrillBuf[%d], udle: [%d %d..%d]", v);
return v;
}
public java.lang.String toString(java.nio.charset.Charset)
{
oadd.io.netty.buffer.DrillBuf v;
java.nio.charset.Charset v;
int v, v;
java.lang.String v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: java.nio.charset.Charset;
v = v.<oadd.io.netty.buffer.DrillBuf: int readerIndex>;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readableBytes()>();
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.lang.String toString(int,int,java.nio.charset.Charset)>(v, v, v);
return v;
}
public java.lang.String toString(int, int, java.nio.charset.Charset)
{
oadd.io.netty.buffer.DrillBuf v;
java.nio.charset.Charset v;
int v, v;
java.lang.String v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.nio.charset.Charset;
if v != 0 goto label;
return "";
label:
v = staticinvoke <oadd.io.netty.buffer.ByteBufUtil: java.lang.String decodeString(oadd.io.netty.buffer.ByteBuf,int,int,java.nio.charset.Charset)>(v, v, v, v);
return v;
}
public int hashCode()
{
int v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = staticinvoke <java.lang.System: int identityHashCode(java.lang.Object)>(v);
return v;
}
public boolean equals(java.lang.Object)
{
java.lang.Object v;
oadd.io.netty.buffer.DrillBuf v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: java.lang.Object;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public oadd.io.netty.buffer.ByteBuf retain(int)
{
java.lang.Object[] v;
java.lang.Integer v;
oadd.io.netty.buffer.DrillBuf v;
java.util.concurrent.atomic.AtomicInteger v;
int v, v;
oadd.org.apache.drill.common.HistoricalLog v;
boolean v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,int)>(v, "retain(%d) argument is not positive", v);
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
return v;
label:
v = <oadd.org.apache.drill.exec.memory.BaseAllocator: boolean DEBUG>;
if v == 0 goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.common.HistoricalLog historicalLog>;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
virtualinvoke v.<oadd.org.apache.drill.common.HistoricalLog: void recordEvent(java.lang.String,java.lang.Object[])>("retain(%d)", v);
label:
v = v.<oadd.io.netty.buffer.DrillBuf: java.util.concurrent.atomic.AtomicInteger refCnt>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int getAndAdd(int)>(v);
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
return v;
}
public oadd.io.netty.buffer.ByteBuf retain()
{
oadd.io.netty.buffer.DrillBuf v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf retain(int)>(1);
return v;
}
public oadd.io.netty.buffer.ByteBuf touch()
{
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
return v;
}
public oadd.io.netty.buffer.ByteBuf touch(java.lang.Object)
{
java.lang.Object v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: java.lang.Object;
return v;
}
public long getLong(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 8);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: long getLong(long)>(v);
return v;
}
public long getLongLE(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 8);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: long getLong(long)>(v);
v = staticinvoke <java.lang.Long: long reverseBytes(long)>(v);
return v;
}
public float getFloat(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
float v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int getInt(int)>(v);
v = staticinvoke <java.lang.Float: float intBitsToFloat(int)>(v);
return v;
}
public double getDouble(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v;
double v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: long getLong(int)>(v);
v = staticinvoke <java.lang.Double: double longBitsToDouble(long)>(v);
return v;
}
public char getChar(int)
{
int v;
short v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: short getShort(int)>(v);
return v;
}
public long getUnsignedInt(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int getInt(int)>(v);
v = v & 4294967295L;
return v;
}
public int getInt(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 4);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: int getInt(long)>(v);
return v;
}
public int getIntLE(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 4);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: int getInt(long)>(v);
v = staticinvoke <java.lang.Integer: int reverseBytes(int)>(v);
return v;
}
public int getUnsignedShort(int)
{
short v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: short getShort(int)>(v);
v = (int) 65535;
v = v & v;
return v;
}
public short getShort(int)
{
short v;
oadd.io.netty.buffer.DrillBuf v;
int v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 2);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: short getShort(long)>(v);
return v;
}
public short getShortLE(int)
{
short v, v;
oadd.io.netty.buffer.DrillBuf v;
int v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 2);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: short getShort(long)>(v);
v = staticinvoke <java.lang.Short: short reverseBytes(short)>(v);
return v;
}
public int getUnsignedMedium(int)
{
long v, v, v;
short v, v, v;
oadd.io.netty.buffer.DrillBuf v;
byte v, v, v;
int v, v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: byte getByte(long)>(v);
v = v & 255;
v = v << 16;
v = v + 1L;
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: byte getByte(long)>(v);
v = v & 255;
v = v << 8;
v = v | v;
v = v + 2L;
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: byte getByte(long)>(v);
v = v & 255;
v = v | v;
return v;
}
public int getUnsignedMediumLE(int)
{
long v, v;
short v, v, v;
oadd.io.netty.buffer.DrillBuf v;
byte v;
int v, v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: byte getByte(long)>(v);
v = v & 255;
v = v + 1L;
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: short getShort(long)>(v);
v = staticinvoke <java.lang.Short: short reverseBytes(short)>(v);
v = (int) 65535;
v = v & v;
v = v << 8;
v = v | v;
return v;
}
public oadd.io.netty.buffer.ByteBuf setShort(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 2);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setShortLE(int, int)
{
short v;
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 2);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Short: short reverseBytes(short)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setMedium(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 3);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = v >>> 16;
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putByte(long,byte)>(v, v);
v = v + 1L;
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setMediumLE(int, int)
{
short v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 3);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putByte(long,byte)>(v, v);
v = v + 1L;
v = v >>> 8;
v = staticinvoke <java.lang.Short: short reverseBytes(short)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setInt(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 4);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(long,int)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setIntLE(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 4);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Integer: int reverseBytes(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(long,int)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setLong(int, long)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: long;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 8);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(long,long)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setLongLE(int, long)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: long;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 4);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Long: long reverseBytes(long)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(long,long)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setChar(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 2);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setFloat(int, float)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
float v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: float;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 4);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Float: int floatToRawIntBits(float)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(long,int)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setDouble(int, double)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
long v, v;
double v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: double;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 8);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Double: long doubleToRawLongBits(double)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(long,long)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf writeShort(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void ensureWritable(oadd.io.netty.buffer.DrillBuf,int)>(v, 2);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = v + 2;
v.<oadd.io.netty.buffer.DrillBuf: int writerIndex> = v;
return v;
}
public oadd.io.netty.buffer.ByteBuf writeInt(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void ensureWritable(oadd.io.netty.buffer.DrillBuf,int)>(v, 4);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(long,int)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = v + 4;
v.<oadd.io.netty.buffer.DrillBuf: int writerIndex> = v;
return v;
}
public oadd.io.netty.buffer.ByteBuf writeLong(long)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: long;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void ensureWritable(oadd.io.netty.buffer.DrillBuf,int)>(v, 8);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(long,long)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = v + 8;
v.<oadd.io.netty.buffer.DrillBuf: int writerIndex> = v;
return v;
}
public oadd.io.netty.buffer.ByteBuf writeChar(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void ensureWritable(oadd.io.netty.buffer.DrillBuf,int)>(v, 2);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(long,short)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = v + 2;
v.<oadd.io.netty.buffer.DrillBuf: int writerIndex> = v;
return v;
}
public oadd.io.netty.buffer.ByteBuf writeFloat(float)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
float v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: float;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void ensureWritable(oadd.io.netty.buffer.DrillBuf,int)>(v, 4);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Float: int floatToRawIntBits(float)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(long,int)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = v + 4;
v.<oadd.io.netty.buffer.DrillBuf: int writerIndex> = v;
return v;
}
public oadd.io.netty.buffer.ByteBuf writeDouble(double)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
long v, v;
double v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: double;
staticinvoke <oadd.org.apache.drill.exec.memory.BoundsChecking: void ensureWritable(oadd.io.netty.buffer.DrillBuf,int)>(v, 8);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <java.lang.Double: long doubleToRawLongBits(double)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(long,long)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int writerIndex>;
v = v + 8;
v.<oadd.io.netty.buffer.DrillBuf: int writerIndex> = v;
return v;
}
public oadd.io.netty.buffer.ByteBuf getBytes(int, byte[], int, int)
{
byte[] v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf getBytes(int,byte[],int,int)>(v, v, v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf getBytes(int, java.nio.ByteBuffer)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.ByteBuffer;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf getBytes(int,java.nio.ByteBuffer)>(v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setByte(int, int)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 1);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putByte(long,byte)>(v, v);
return v;
}
public void setByte(int, byte)
{
oadd.io.netty.buffer.DrillBuf v;
byte v;
int v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: byte;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 1);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putByte(long,byte)>(v, v);
return;
}
public void writeByteUnsafe(byte)
{
oadd.io.netty.buffer.DrillBuf v;
byte v;
int v, v, v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: byte;
v = v.<oadd.io.netty.buffer.DrillBuf: int readerIndex>;
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putByte(long,byte)>(v, v);
v = v.<oadd.io.netty.buffer.DrillBuf: int readerIndex>;
v = v + 1;
v.<oadd.io.netty.buffer.DrillBuf: int readerIndex> = v;
return;
}
protected byte _getByte(int)
{
int v;
oadd.io.netty.buffer.DrillBuf v;
byte v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: byte getByte(int)>(v);
return v;
}
protected short _getShort(int)
{
int v;
short v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: short getShort(int)>(v);
return v;
}
protected short _getShortLE(int)
{
int v;
short v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: short getShortLE(int)>(v);
return v;
}
protected int _getInt(int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int getInt(int)>(v);
return v;
}
protected int _getIntLE(int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int getIntLE(int)>(v);
return v;
}
protected long _getLong(int)
{
int v;
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: long getLong(int)>(v);
return v;
}
protected long _getLongLE(int)
{
int v;
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: long getLongLE(int)>(v);
return v;
}
protected void _setByte(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setByte(int,int)>(v, v);
return;
}
protected void _setShort(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setShort(int,int)>(v, v);
return;
}
protected void _setShortLE(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setShortLE(int,int)>(v, v);
return;
}
protected void _setMedium(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setMedium(int,int)>(v, v);
return;
}
protected void _setMediumLE(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setMediumLE(int,int)>(v, v);
return;
}
protected void _setInt(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setInt(int,int)>(v, v);
return;
}
protected void _setIntLE(int, int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setIntLE(int,int)>(v, v);
return;
}
protected void _setLong(int, long)
{
int v;
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: long;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setLong(int,long)>(v, v);
return;
}
protected void _setLongLE(int, long)
{
int v;
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: long;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf setLongLE(int,long)>(v, v);
return;
}
public oadd.io.netty.buffer.ByteBuf getBytes(int, oadd.io.netty.buffer.ByteBuf, int, int)
{
java.lang.IndexOutOfBoundsException v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v, v;
long v, v, v;
byte v;
int v, v, v, v, v, v, v, v, v;
oadd.io.netty.buffer.ByteBuf v;
boolean v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v := @parameter: int;
v := @parameter: int;
if v >= 16 goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: boolean hasMemoryAddress()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: boolean hasMemoryAddress()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int capacity()>();
v = v + v;
if v >= v goto label;
v = new java.lang.IndexOutOfBoundsException;
specialinvoke v.<java.lang.IndexOutOfBoundsException: void <init>()>();
throw v;
label:
v = 0;
label:
if v >= v goto label;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: byte getByte(int)>(v);
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: long memoryAddress()>();
v = v + v;
v = v + v;
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putByte(long,byte)>(v, v);
v = v + 1;
goto label;
label:
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf getBytes(int,oadd.io.netty.buffer.ByteBuf,int,int)>(v, v, v, v);
label:
return v;
}
public oadd.io.netty.buffer.ByteBuf getBytes(int, java.io.OutputStream, int) throws java.io.IOException
{
java.io.OutputStream v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.io.OutputStream;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf getBytes(int,java.io.OutputStream,int)>(v, v, v);
return v;
}
public int getBytes(int, java.nio.channels.FileChannel, long, int) throws java.io.IOException
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
long v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
java.nio.channels.FileChannel v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.channels.FileChannel;
v := @parameter: long;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int getBytes(int,java.nio.channels.FileChannel,long,int)>(v, v, v, v);
return v;
}
protected int _getUnsignedMedium(int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int getUnsignedMedium(int)>(v);
return v;
}
protected int _getUnsignedMediumLE(int)
{
int v, v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int getUnsignedMediumLE(int)>(v);
return v;
}
public int getBytes(int, java.nio.channels.GatheringByteChannel, int) throws java.io.IOException
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
java.nio.channels.GatheringByteChannel v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.channels.GatheringByteChannel;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int getBytes(int,java.nio.channels.GatheringByteChannel,int)>(v, v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setBytes(int, oadd.io.netty.buffer.ByteBuf, int, int)
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf setBytes(int,oadd.io.netty.buffer.ByteBuf,int,int)>(v, v, v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setBytes(int, java.nio.ByteBuffer, int, int)
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v, v;
long v, v, v, v;
java.nio.ByteBuffer v, v;
int v, v, v, v, v, v, v, v, v;
boolean v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v := @parameter: int;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean isDirect()>();
if v == 0 goto label;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: void checkIndex(int,int)>(v, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: long directBufferAddress(java.nio.ByteBuffer)>(v);
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: long memoryAddress()>();
v = v + v;
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void copyMemory(long,long,long)>(v, v, v);
goto label;
label:
if v != 0 goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: int capacity()>();
if v != v goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf setBytes(int,java.nio.ByteBuffer)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer duplicate()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer limit(int)>(v);
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf setBytes(int,java.nio.ByteBuffer)>(v, v);
label:
return v;
}
public oadd.io.netty.buffer.ByteBuf setBytes(int, byte[], int, int)
{
byte[] v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf setBytes(int,byte[],int,int)>(v, v, v, v);
return v;
}
public oadd.io.netty.buffer.ByteBuf setBytes(int, java.nio.ByteBuffer)
{
oadd.io.netty.buffer.DrillBuf v;
int v, v, v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
java.nio.ByteBuffer v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.ByteBuffer;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: oadd.io.netty.buffer.ByteBuf setBytes(int,java.nio.ByteBuffer)>(v, v);
return v;
}
public int setBytes(int, java.io.InputStream, int) throws java.io.IOException
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
java.io.InputStream v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.io.InputStream;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int setBytes(int,java.io.InputStream,int)>(v, v, v);
return v;
}
public int setBytes(int, java.nio.channels.ScatteringByteChannel, int) throws java.io.IOException
{
java.nio.channels.ScatteringByteChannel v;
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.channels.ScatteringByteChannel;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int setBytes(int,java.nio.channels.ScatteringByteChannel,int)>(v, v, v);
return v;
}
public int setBytes(int, java.nio.channels.FileChannel, long, int) throws java.io.IOException
{
oadd.io.netty.buffer.UnsafeDirectLittleEndian v;
long v;
oadd.io.netty.buffer.DrillBuf v;
int v, v, v, v, v;
java.nio.channels.FileChannel v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: java.nio.channels.FileChannel;
v := @parameter: long;
v := @parameter: int;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.UnsafeDirectLittleEndian udle>;
v = v.<oadd.io.netty.buffer.DrillBuf: int offset>;
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.UnsafeDirectLittleEndian: int setBytes(int,java.nio.channels.FileChannel,long,int)>(v, v, v, v);
return v;
}
public byte getByte(int)
{
oadd.io.netty.buffer.DrillBuf v;
byte v;
int v;
long v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.buffer.DrillBuf: void chk(int,int)>(v, 1);
v = specialinvoke v.<oadd.io.netty.buffer.DrillBuf: long addr(int)>(v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: byte getByte(long)>(v);
return v;
}
public void close()
{
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release()>();
return;
}
public int getPossibleMemoryConsumed()
{
int v;
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: int getSize()>();
return v;
}
public int getActualMemoryConsumed()
{
int v;
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: int getAccountedSize()>();
return v;
}
public java.lang.String toHexString(int, int)
{
java.lang.Integer v, v, v, v;
byte v, v;
boolean v;
oadd.io.netty.buffer.DrillBuf v;
java.lang.StringBuilder v, v, v, v;
java.lang.Object[] v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
char v, v;
char[] v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("buffer byte dump");
v = v.<oadd.io.netty.buffer.DrillBuf: int length>;
v = v - v;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = 0;
label:
if v >= v goto label;
v = v % 10;
if v != 0 goto label;
v = newarray (java.lang.Object)[2];
v = v + v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v + 10;
v = v - 1;
v = v - 1;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = v + v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("%n [%05d-%05d]", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = v + v;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: byte _getByte(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" 0x");
v = <oadd.io.netty.buffer.DrillBuf: char[] HEX_CHAR>;
v = v >> 4;
v = v[v];
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(v);
v = <oadd.io.netty.buffer.DrillBuf: char[] HEX_CHAR>;
v = v & 15;
v = v[v];
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(v);
v = v + 1;
goto label;
label:
if v <= v goto label;
v = newarray (java.lang.Object)[2];
v = v + v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v + v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("%n [%05d-%05d] <ioob>", v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = staticinvoke <java.lang.System: java.lang.String lineSeparator()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public long getId()
{
long v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: long id>;
return v;
}
public java.lang.String toVerboseString()
{
oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger v;
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity v;
java.lang.StringBuilder v;
java.lang.String v, v;
boolean v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v == 0 goto label;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.lang.String toString()>();
return v;
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger ledger>;
v = <oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity: oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity LOG_WITH_STACKTRACE>;
virtualinvoke v.<oadd.org.apache.drill.exec.memory.AllocationManager$BufferLedger: void print(java.lang.StringBuilder,int,oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity)>(v, 0, v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public void print(java.lang.StringBuilder, int, oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity)
{
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity v;
int v, v;
java.lang.StringBuilder v, v;
java.lang.String v;
oadd.org.apache.drill.common.HistoricalLog v;
boolean v, v, v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: java.lang.StringBuilder;
v := @parameter: int;
v := @parameter: oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity;
v = staticinvoke <oadd.org.apache.drill.exec.memory.BaseAllocator: java.lang.StringBuilder indent(java.lang.StringBuilder,int)>(v, v);
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: java.lang.String toString()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = <oadd.org.apache.drill.exec.memory.BaseAllocator: boolean DEBUG>;
if v == 0 goto label;
v = v.<oadd.io.netty.buffer.DrillBuf: boolean isEmpty>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity: boolean includeHistoricalLog>;
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = v.<oadd.io.netty.buffer.DrillBuf: oadd.org.apache.drill.common.HistoricalLog historicalLog>;
v = v + 1;
v = v.<oadd.org.apache.drill.exec.memory.BaseAllocator$Verbosity: boolean includeStackTraces>;
virtualinvoke v.<oadd.org.apache.drill.common.HistoricalLog: void buildHistory(java.lang.StringBuilder,int,boolean)>(v, v, v);
label:
return;
}
public byte[] unsafeGetMemory(int, int)
{
byte[] v;
oadd.io.netty.buffer.DrillBuf v;
int v, v;
long v, v;
v := @this: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v := @parameter: int;
v = newarray (byte)[v];
v = v.<oadd.io.netty.buffer.DrillBuf: long addr>;
v = v + v;
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void copyMemory(long,byte[],int,long)>(v, v, 0, v);
return v;
}
public static short getShort(byte[], int)
{
byte[] v;
short v;
int v, v;
v := @parameter: byte[];
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 2, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: short getShort(byte[],int)>(v, v);
return v;
}
public static int getInt(byte[], int)
{
byte[] v;
int v, v, v;
v := @parameter: byte[];
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 4, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: int getInt(byte[],int)>(v, v);
return v;
}
public static long getLong(byte[], int)
{
byte[] v;
int v, v;
long v;
v := @parameter: byte[];
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 8, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: long getLong(byte[],int)>(v, v);
return v;
}
public static void putShort(byte[], int, byte[], int)
{
byte[] v, v;
short v;
int v, v, v, v;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: byte[];
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 2, v);
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 2, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: short getShort(byte[],int)>(v, v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(byte[],int,short)>(v, v, v);
return;
}
public static void putInt(byte[], int, byte[], int)
{
byte[] v, v;
int v, v, v, v, v;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: byte[];
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 4, v);
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 4, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: int getInt(byte[],int)>(v, v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(byte[],int,int)>(v, v, v);
return;
}
public static void putLong(byte[], int, byte[], int)
{
byte[] v, v;
int v, v, v, v;
long v;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: byte[];
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 8, v);
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 8, v);
v = staticinvoke <oadd.io.netty.util.internal.PlatformDependent: long getLong(byte[],int)>(v, v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(byte[],int,long)>(v, v, v);
return;
}
public static void putShort(byte[], int, short)
{
byte[] v;
short v;
int v, v;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: short;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 2, v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putShort(byte[],int,short)>(v, v, v);
return;
}
public static void putInt(byte[], int, int)
{
byte[] v;
int v, v, v;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 4, v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putInt(byte[],int,int)>(v, v, v);
return;
}
public static void putLong(byte[], int, long)
{
byte[] v;
int v, v;
long v;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: long;
v = lengthof v;
staticinvoke <oadd.io.netty.buffer.DrillBuf: void check(int,int,int)>(v, 8, v);
staticinvoke <oadd.io.netty.util.internal.PlatformDependent: void putLong(byte[],int,long)>(v, v, v);
return;
}
private static void check(int, int, int)
{
java.lang.IndexOutOfBoundsException v;
java.lang.Object[] v, v;
java.lang.Integer v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v;
boolean v;
java.lang.IllegalArgumentException v;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v = <oadd.org.apache.drill.exec.memory.BoundsChecking: boolean BOUNDS_CHECKING_ENABLED>;
if v == 0 goto label;
if v < 0 goto label;
if v >= 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("index: [%d], len: [%d]", v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v + v;
if v <= v goto label;
v = new java.lang.IndexOutOfBoundsException;
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Trying to access more than buffer length; index: [%d], len: [%d], buffer-len: [%d]", v);
specialinvoke v.<java.lang.IndexOutOfBoundsException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
static void <clinit>()
{
char[] v;
java.util.concurrent.atomic.AtomicLong v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/io/netty/buffer/DrillBuf;");
<oadd.io.netty.buffer.DrillBuf: org.slf4j.Logger logger> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
<oadd.io.netty.buffer.DrillBuf: java.util.concurrent.atomic.AtomicLong idGenerator> = v;
v = newarray (char)[16];
v[0] = 48;
v[1] = 49;
v[2] = 50;
v[3] = 51;
v[4] = 52;
v[5] = 53;
v[6] = 54;
v[7] = 55;
v[8] = 56;
v[9] = 57;
v[10] = 65;
v[11] = 66;
v[12] = 67;
v[13] = 68;
v[14] = 69;
v[15] = 70;
<oadd.io.netty.buffer.DrillBuf: char[] HEX_CHAR> = v;
return;
}
}