public class oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer extends java.io.OutputStream
{
private static final int LARGE_BUFFER_SIZE;
final int initialCapacity;
int offset;
byte[] data;
public void <init>()
{
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
specialinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void <init>(int)>(4096);
return;
}
public void <init>(int)
{
int v;
byte[] v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v := @parameter: int;
specialinvoke v.<java.io.OutputStream: void <init>()>();
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset> = 0;
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int initialCapacity> = v;
v = newarray (byte)[v];
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data> = v;
return;
}
private void reserve(int)
{
byte[] v, v, v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
int v, v, v, v, v, v, v, v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v := @parameter: int;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
v = v + v;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = lengthof v;
if v <= v goto label;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
v = v + v;
v = staticinvoke <oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int nextArraySize(int)>(v);
v = newarray (byte)[v];
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 0, v, 0, v);
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data> = v;
label:
return;
}
public void write(byte[], int, int)
{
byte[] v, v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
int v, v, v, v, v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reserve(int)>(v);
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, v, v);
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
v = v + v;
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset> = v;
return;
}
public void write(int) throws java.io.IOException
{
byte[] v;
int v, v, v, v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v := @parameter: int;
specialinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reserve(int)>(1);
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
v[v] = v;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
v = v + 1;
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset> = v;
return;
}
public byte[] toArray()
{
byte[] v, v;
int v, v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
v = newarray (byte)[v];
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 0, v, 0, v);
return v;
}
public void reset()
{
byte[] v, v;
int v, v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset> = 0;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = lengthof v;
if v < 65536 goto label;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int initialCapacity>;
v = newarray (byte)[v];
v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data> = v;
label:
return;
}
public int getOffset()
{
int v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: int offset>;
return v;
}
public long getSize()
{
int v;
byte[] v;
oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer v;
v := @this: oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer;
v = v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] data>;
v = lengthof v;
return v;
}
public static int nextArraySize(int)
{
java.lang.IllegalArgumentException v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @parameter: int;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>()>();
throw v;
label:
if v <= 1073741824 goto label;
return 2147483647;
label:
if v != 0 goto label;
return 1;
label:
v = v - 1;
v = v >> 1;
v = v | v;
v = v >> 2;
v = v | v;
v = v >> 4;
v = v | v;
v = v >> 8;
v = v | v;
v = v >> 16;
v = v | v;
v = v + 1;
return v;
}
}