public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageToByteEncoder
{
private static final int MIN_COMPRESSIBLE_LENGTH;
private static final byte[] STREAM_START;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy;
private boolean started;
public void <init>()
{
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.SnappyFrameEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageToByteEncoder: 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.SnappyFrameEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy snappy> = v;
return;
}
protected void encode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws java.lang.Exception
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy v, v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder;
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: 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: boolean isReadable()>();
if v != 0 goto label;
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: boolean started>;
if v != 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: boolean started> = 1;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: byte[] STREAM_START>;
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 writeBytes(byte[])>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v <= 18 goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = v + 1;
if v >= 18 goto label;
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);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void writeUnencodedChunk(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(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 writeInt(int)>(0);
if v <= 32767 goto label;
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)>(32767);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void calculateAndWriteChecksum(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);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: 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 encode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v, 32767);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void setChunkLength(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
v = v - 32767;
goto label;
label:
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);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void calculateAndWriteChecksum(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);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: 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 encode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v, v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void setChunkLength(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
goto label;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void writeUnencodedChunk(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v, v);
label:
return;
}
private static void writeUnencodedChunk(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int)
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
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 writeByte(int)>(1);
v = v + 4;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void writeChunkLength(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: void calculateAndWriteChecksum(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);
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 writeBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
return;
}
private static void setChunkLength(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.CompressionException v;
int v, v, v, v, v;
java.lang.String v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = v - v;
v = v - 3;
v = v >>> 24;
if v == 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.CompressionException;
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[])>("compressed data too large: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.CompressionException: void <init>(java.lang.String)>(v);
throw 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 setMediumLE(int,int)>(v, v);
return;
}
private static void writeChunkLength(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;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
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 writeMediumLE(int)>(v);
return;
}
private static void calculateAndWriteChecksum(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, 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, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.Snappy: int calculateChecksum(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: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf writeIntLE(int)>(v);
return;
}
static void <clinit>()
{
byte[] v;
v = newarray (byte)[10];
v[0] = -1;
v[1] = 6;
v[2] = 0;
v[3] = 0;
v[4] = 115;
v[5] = 78;
v[6] = 97;
v[7] = 80;
v[8] = 112;
v[9] = 89;
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.SnappyFrameEncoder: byte[] STREAM_START> = v;
return;
}
}