public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder
{
private static final int SNAPPY_IDENTIFIER_LEN;
private static final int MAX_UNCOMPRESSED_DATA_SIZE;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy;
private final boolean validateChecksums;
private boolean started;
private boolean corrupted;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void <init>(boolean)>(0);
return;
}
public void <init>(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder: void <init>()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean validateChecksums> = v;
return;
}
protected void decode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, java.util.List) throws java.lang.Exception
{
byte v, v, v, v, v, v;
java.lang.Exception v;
java.lang.Throwable v, v;
short v;
java.lang.String v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v;
int[] v;
boolean v, v, v, v, v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: java.util.List;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean corrupted>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
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;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 4 goto label;
label:
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: short getUnsignedByte(int)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType mapChunkType(byte)>(v);
v = v + 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int getUnsignedMediumLE(int)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$1: int[] $SwitchMap$io$netty$handler$codec$compression$SnappyFrameDecoder$ChunkType>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
if v == 6 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
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[])>("Unexpected length of stream identifier: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>(v);
throw v;
label:
if v < 10 goto label;
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)>(4);
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: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf skipBytes(int)>(6);
v = v + 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void checkByte(byte,byte)>(v, 115);
v = v + 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void checkByte(byte,byte)>(v, 78);
v = v + 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void checkByte(byte,byte)>(v, 97);
v = v + 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void checkByte(byte,byte)>(v, 80);
v = v + 1;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void checkByte(byte,byte)>(v, 112);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: void checkByte(byte,byte)>(v, 89);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean started> = 1;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean started>;
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>("Received RESERVED_SKIPPABLE tag before STREAM_IDENTIFIER");
throw v;
label:
v = 4 + v;
if v >= v goto label;
label:
return;
label:
v = 4 + 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 skipBytes(int)>(v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
v = staticinvoke <java.lang.Integer: java.lang.String toHexString(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Found reserved unskippable chunk type: 0x\u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean started>;
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>("Received UNCOMPRESSED_DATA tag before STREAM_IDENTIFIER");
throw v;
label:
if v <= 65540 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>("Received UNCOMPRESSED_DATA larger than 65540 bytes");
throw v;
label:
v = 4 + v;
if v >= v goto label;
label:
return;
label:
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)>(4);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean validateChecksums>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readIntLE()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v - 4;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: void validateChecksum(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,int)>(v, v, v, v);
goto label;
label:
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)>(4);
label:
v = v - 4;
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 readRetainedSlice(int)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean started>;
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>("Received COMPRESSED_DATA tag before STREAM_IDENTIFIER");
throw v;
label:
v = 4 + v;
if v >= v goto label;
label:
return;
label:
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)>(4);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readIntLE()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean validateChecksums>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v + v;
v = v - 4;
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 writerIndex(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: void decode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
label:
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 writerIndex(int)>(v);
goto label;
label:
v := @caughtexception;
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 writerIndex(int)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: void validateChecksum(int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,int)>(v, v, 0, v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy>;
v = v - 4;
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 readSlice(int)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: void decode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
label:
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: void reset()>();
label:
goto label;
label:
v := @caughtexception;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder: boolean corrupted> = 1;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static void checkByte(byte, byte)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException v;
byte v, v;
v := @parameter: byte;
v := @parameter: byte;
if v == v goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.DecompressionException: void <init>(java.lang.String)>("Unexpected stream identifier contents. Mismatched snappy protocol version?");
throw v;
label:
return;
}
private static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType mapChunkType(byte)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType v, v, v, v, v;
short v;
byte v;
int v;
v := @parameter: byte;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType COMPRESSED_DATA>;
return v;
label:
if v != 1 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType UNCOMPRESSED_DATA>;
return v;
label:
v = (int) -1;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType STREAM_IDENTIFIER>;
return v;
label:
v = v & 128;
if v != 128 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType RESERVED_SKIPPABLE>;
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameDecoder$ChunkType RESERVED_UNSKIPPABLE>;
return v;
}
}