public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream extends java.io.InputStream implements java.io.DataInput
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer;
private final int startIndex;
private final int endIndex;
private boolean closed;
private final boolean releaseOnClose;
private java.lang.StringBuilder lineBuf;
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,boolean)>(v, v, 0);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,boolean)>(v, v, v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int, boolean)
{
java.lang.IndexOutOfBoundsException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.IllegalArgumentException v;
int v, v, v, v, v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
v := @parameter: boolean;
specialinvoke v.<java.io.InputStream: void <init>()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "buffer");
if v >= 0 goto label;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("length: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v <= v goto label;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
label:
v = new java.lang.IndexOutOfBoundsException;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Too many bytes to be read - Needs \u, maximum is \u0001");
specialinvoke v.<java.lang.IndexOutOfBoundsException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: boolean releaseOnClose> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int startIndex> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int startIndex>;
v = v + v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int endIndex> = v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf markReaderIndex()>();
return;
}
public int readBytes()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int startIndex>;
v = v - v;
return v;
}
public void close() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: boolean releaseOnClose>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: boolean closed>;
if v != 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: boolean closed> = 1;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
label:
return;
}
public int available() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int endIndex>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v - v;
return v;
}
public void mark(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf markReaderIndex()>();
return;
}
public boolean markSupported()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
return 1;
}
public int read() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
short v;
byte v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
if v != 0 goto label;
v = (int) -1;
return v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = v & 255;
return v;
}
public int read(byte[], int, int) throws java.io.IOException
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
int v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
if v != 0 goto label;
v = (int) -1;
return v;
label:
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readBytes(byte[],int,int)>(v, v, v);
return v;
}
public void reset() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf resetReaderIndex()>();
return;
}
public long skip(long) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
byte v;
int v, v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: long;
v = v cmp 2147483647L;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int skipBytes(int)>(2147483647);
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int skipBytes(int)>(v);
return v;
}
public boolean readBoolean() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void checkAvailable(int)>(1);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int read()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public byte readByte() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
byte v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.io.EOFException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
if v != 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
return v;
}
public char readChar() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
short v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: short readShort()>();
return v;
}
public double readDouble() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
long v;
double v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: long readLong()>();
v = staticinvoke <java.lang.Double: double longBitsToDouble(long)>(v);
return v;
}
public float readFloat() throws java.io.IOException
{
int v;
float v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int readInt()>();
v = staticinvoke <java.lang.Float: float intBitsToFloat(int)>(v);
return v;
}
public void readFully(byte[]) throws java.io.IOException
{
int v;
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: byte[];
v = lengthof v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void readFully(byte[],int,int)>(v, 0, v);
return;
}
public void readFully(byte[], int, int) throws java.io.IOException
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void checkAvailable(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readBytes(byte[],int,int)>(v, v, v);
return;
}
public int readInt() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void checkAvailable(int)>(4);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readInt()>();
return v;
}
public java.lang.String readLine() throws java.io.IOException
{
short v;
int v, v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v;
char v;
java.lang.StringBuilder v, v, v, v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
if v != 0 goto label;
return null;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
virtualinvoke v.<java.lang.StringBuilder: void setLength(int)>(0);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: short readUnsignedByte()>();
v = v - 1;
lookupswitch(v)
{
case 10: goto label;
case 13: goto label;
default: goto label;
};
label:
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: short getUnsignedByte(int)>(v);
if v != 10 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf skipBytes(int)>(1);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
if v != null goto label;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(v);
if v > 0 goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
v = virtualinvoke v.<java.lang.StringBuilder: int length()>();
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: java.lang.StringBuilder lineBuf>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
goto label;
label:
v = "";
label:
return v;
}
public long readLong() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void checkAvailable(int)>(8);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: long readLong()>();
return v;
}
public short readShort() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
short v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: void checkAvailable(int)>(2);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: short readShort()>();
return v;
}
public java.lang.String readUTF() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = staticinvoke <java.io.DataInputStream: java.lang.String readUTF(java.io.DataInput)>(v);
return v;
}
public int readUnsignedByte() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
short v;
byte v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: byte readByte()>();
v = v & 255;
return v;
}
public int readUnsignedShort() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
short v;
int v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: short readShort()>();
v = (int) 65535;
v = v & v;
return v;
}
public int skipBytes(int) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf skipBytes(int)>(v);
return v;
}
private void checkAvailable(int) throws java.io.IOException
{
java.lang.IndexOutOfBoundsException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream v;
int v, v, v;
java.lang.String v;
java.io.EOFException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream;
v := @parameter: int;
if v >= 0 goto label;
v = new java.lang.IndexOutOfBoundsException;
specialinvoke v.<java.lang.IndexOutOfBoundsException: void <init>(java.lang.String)>("fieldSize cannot be a negative number");
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
if v <= v goto label;
v = new java.io.EOFException;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufInputStream: int available()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("fieldSize is too long! Length is \u, but maximum is \u0001");
specialinvoke v.<java.io.EOFException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
}