public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageToByteEncoder
{
private final int level;
private final java.util.zip.Checksum checksum;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: void <init>(int,java.util.zip.Checksum)>(0, null);
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: void <init>(int,java.util.zip.Checksum)>(v, null);
return;
}
public void <init>(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder v;
java.util.zip.Adler v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder;
v := @parameter: boolean;
if v == 0 goto label;
v = new java.util.zip.Adler;
specialinvoke v.<java.util.zip.Adler32: void <init>()>();
goto label;
label:
v = null;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: void <init>(int,java.util.zip.Checksum)>(0, v);
return;
}
public void <init>(int, java.util.zip.Checksum)
{
java.lang.Object[] v;
java.lang.IllegalArgumentException v;
java.lang.Integer v, v, v, v;
java.util.zip.Checksum v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder v;
int v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder;
v := @parameter: int;
v := @parameter: java.util.zip.Checksum;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageToByteEncoder: void <init>(boolean)>(0);
if v == 0 goto label;
if v == 1 goto label;
if v == 2 goto label;
v = new java.lang.IllegalArgumentException;
v = newarray (java.lang.Object)[4];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[2] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v[3] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("level: %d (expected: %d or %d or %d)", v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: int level> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: java.util.zip.Checksum checksum> = 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, v, v, v;
byte v, v, v;
boolean v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder v;
long v, v;
java.util.zip.Checksum 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, 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 := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder;
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: java.util.zip.Checksum checksum>;
label:
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 = 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()>();
v = (int) 65535;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
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 setMedium(int,int)>(v, 4607066);
v = v + 4;
if v == null goto label;
v = 4;
goto label;
label:
v = 0;
label:
v = v + v;
if v >= 32 goto label;
v = 0;
v = v + 2;
v = 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 ensureWritable(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = v + v;
v = v + 2;
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasArray()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = v + v;
goto label;
label:
v = newarray (byte)[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 getBytes(int,byte[])>(v, v);
v = 0;
label:
interfaceinvoke v.<java.util.zip.Checksum: void reset()>();
interfaceinvoke v.<java.util.zip.Checksum: void update(byte[],int,int)>(v, v, v);
v = v + 4;
v = interfaceinvoke v.<java.util.zip.Checksum: long getValue()>();
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 setInt(int,int)>(v, v);
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 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 getBytes(int,byte[],int,int)>(v, v, v, v);
label:
v = v;
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasArray()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = v + v;
goto label;
label:
v = newarray (byte)[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 getBytes(int,byte[])>(v, v);
v = 0;
label:
if v == null goto label;
interfaceinvoke v.<java.util.zip.Checksum: void reset()>();
interfaceinvoke v.<java.util.zip.Checksum: void update(byte[],int,int)>(v, v, v);
v = v + 4;
v = interfaceinvoke v.<java.util.zip.Checksum: long getValue()>();
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 setInt(int,int)>(v, v);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLz: int calculateOutputBufferLength(int)>(v);
v = v + 4;
v = 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 ensureWritable(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = v + v;
v = v + 4;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLzFrameEncoder: int level>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.FastLz: int compress(byte[],int,int,byte[],int,int)>(v, v, v, v, v, v);
if v >= v goto label;
v = 1;
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 setShort(int,int)>(v, v);
v = v + 2;
goto label;
label:
v = 0;
v = v - 2;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, v, v);
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 setShort(int,int)>(v, v);
v = v + 3;
v = v;
if v == null goto label;
v = 16;
goto label;
label:
v = 0;
label:
v = 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 setByte(int,int)>(v, v);
v = v + 2;
v = 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 writerIndex(int)>(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;
}
}