public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibDecoder
{
private final com.jcraft.jzlib.Inflater z;
private byte[] dictionary;
private volatile boolean finished;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper ZLIB>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper)>(v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper)
{
int v;
com.jcraft.jzlib.Inflater v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper v;
com.jcraft.jzlib.JZlib$WrapperType v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibDecoder: void <init>()>();
v = new com.jcraft.jzlib.Inflater;
specialinvoke v.<com.jcraft.jzlib.Inflater: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z> = v;
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, "wrapper");
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibUtil: com.jcraft.jzlib.JZlib$WrapperType convertWrapperType(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper)>(v);
v = virtualinvoke v.<com.jcraft.jzlib.Inflater: int init(com.jcraft.jzlib.JZlib$WrapperType)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Inflater,java.lang.String,int)>(v, "initialization failure", v);
label:
return;
}
public void <init>(byte[])
{
byte[] v;
com.jcraft.jzlib.Inflater v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder v;
com.jcraft.jzlib.JZlib$WrapperType v;
int v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder;
v := @parameter: byte[];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibDecoder: void <init>()>();
v = new com.jcraft.jzlib.Inflater;
specialinvoke v.<com.jcraft.jzlib.Inflater: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z> = v;
v = 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, "dictionary");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: byte[] dictionary> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = <com.jcraft.jzlib.JZlib: com.jcraft.jzlib.JZlib$WrapperType W_ZLIB>;
v = virtualinvoke v.<com.jcraft.jzlib.Inflater: int inflateInit(com.jcraft.jzlib.JZlib$WrapperType)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Inflater,java.lang.String,int)>(v, "initialization failure", v);
label:
return;
}
public boolean isClosed()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: boolean finished>;
return v;
}
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.Throwable 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder v;
boolean v, v, v, v;
java.util.List v;
com.jcraft.jzlib.Inflater 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;
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;
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.JZlibDecoder;
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.JZlibDecoder: boolean finished>;
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 readableBytes()>();
if v != 0 goto label;
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: int avail_in> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasArray()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v.<com.jcraft.jzlib.Inflater: byte[] next_in> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v + v;
v.<com.jcraft.jzlib.Inflater: int next_in_index> = v;
goto label;
label:
v = newarray (byte)[v];
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 getBytes(int,byte[])>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: byte[] next_in> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: int next_in_index> = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int next_in_index>;
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 = v << 1;
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 heapBuffer(int)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int avail_in>;
v = v << 1;
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writableBytes()>();
v.<com.jcraft.jzlib.Inflater: int avail_out> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v.<com.jcraft.jzlib.Inflater: byte[] next_out> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = v + v;
v.<com.jcraft.jzlib.Inflater: int next_out_index> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int next_out_index>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = virtualinvoke v.<com.jcraft.jzlib.Inflater: int inflate(int)>(2);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int next_out_index>;
v = v - v;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
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);
label:
tableswitch(v)
{
case -5: goto label;
case -4: goto label;
case -3: goto label;
case -2: goto label;
case -1: goto label;
case 0: goto label;
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: byte[] dictionary>;
if v != null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Inflater,java.lang.String,int)>(v, "decompression failure", v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: byte[] dictionary>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: byte[] dictionary>;
v = lengthof v;
v = virtualinvoke v.<com.jcraft.jzlib.Inflater: int inflateSetDictionary(byte[],int)>(v, v);
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Inflater,java.lang.String,int)>(v, "failed to set the dictionary", v);
goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: boolean finished> = 1;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
virtualinvoke v.<com.jcraft.jzlib.Inflater: int inflateEnd()>();
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int avail_in>;
if v > 0 goto label;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Inflater,java.lang.String,int)>(v, "decompression failure", v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int next_in_index>;
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 skipBytes(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v = v.<com.jcraft.jzlib.Inflater: int next_in_index>;
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 skipBytes(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
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.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: byte[] next_in> = null;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: byte[] next_out> = null;
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: byte[] next_in> = null;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JZlibDecoder: com.jcraft.jzlib.Inflater z>;
v.<com.jcraft.jzlib.Inflater: byte[] next_out> = null;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}