public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibEncoder
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper;
private final java.util.zip.Deflater deflater;
private volatile boolean finished;
private volatile org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx;
private final java.util.zip.CRC32 crc;
private static final byte[] gzipHeader;
private boolean writeHeader;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: void <init>(int)>(6);
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder 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.JdkZlibEncoder;
v := @parameter: int;
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.JdkZlibEncoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper,int)>(v, v);
return;
}
public void <init>(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.JdkZlibEncoder 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.JdkZlibEncoder;
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.JdkZlibEncoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper,int)>(v, 6);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper v, v, v, v;
java.util.zip.Deflater v;
java.lang.IllegalArgumentException v, v;
int v;
java.util.zip.CRC32 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibEncoder: void <init>()>();
v = new java.util.zip.CRC32;
specialinvoke v.<java.util.zip.CRC32: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.CRC32 crc> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader> = 1;
if v < 0 goto label;
if v <= 9 goto label;
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[])>("compressionLevel: \u (expected: 0-9)");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
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 = <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_OR_NONE>;
if v != v goto label;
v = new java.lang.IllegalArgumentException;
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_OR_NONE>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper)>(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[])>("wrapper \'\u0001\' is not allowed for compression.");
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.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper> = v;
v = new java.util.zip.Deflater;
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>;
if v == v goto label;
v = 1;
goto label;
label:
v = 0;
label:
specialinvoke v.<java.util.zip.Deflater: void <init>(int,boolean)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater> = v;
return;
}
public void <init>(byte[])
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v := @parameter: byte[];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: void <init>(int,byte[])>(6, v);
return;
}
public void <init>(int, byte[])
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper v;
java.util.zip.Deflater v, v;
java.lang.IllegalArgumentException v;
int v;
java.util.zip.CRC32 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v := @parameter: int;
v := @parameter: byte[];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibEncoder: void <init>()>();
v = new java.util.zip.CRC32;
specialinvoke v.<java.util.zip.CRC32: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.CRC32 crc> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader> = 1;
if v < 0 goto label;
if v <= 9 goto label;
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[])>("compressionLevel: \u (expected: 0-9)");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
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.ZlibWrapper: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper ZLIB>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper> = v;
v = new java.util.zip.Deflater;
specialinvoke v.<java.util.zip.Deflater: void <init>(int)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
virtualinvoke v.<java.util.zip.Deflater: void setDictionary(byte[])>(v);
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx()>();
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.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$1 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx()>();
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.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: boolean inEventLoop()>();
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture finishEncode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
label:
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.channel.ChannelPromise newPromise()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: void execute(java.lang.Runnable)>(v);
return v;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx()
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("not added to a pipeline");
throw v;
label:
return v;
}
public boolean isClosed()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean finished>;
return v;
}
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;
int v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v, v, v, v, 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.ZlibWrapper v, v, v, v;
java.util.zip.Deflater v, v;
java.util.zip.CRC32 v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
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.JdkZlibEncoder: boolean finished>;
if v == 0 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 writeBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(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 = 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 = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
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);
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 readBytes(byte[])>(v);
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader>;
if v == 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader> = 0;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper>;
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 GZIP>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: byte[] gzipHeader>;
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper>;
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 GZIP>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.CRC32 crc>;
virtualinvoke v.<java.util.zip.CRC32: void update(byte[],int,int)>(v, v, v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
virtualinvoke v.<java.util.zip.Deflater: void setInput(byte[],int,int)>(v, v, v);
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: void deflate(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
v = virtualinvoke v.<java.util.zip.Deflater: boolean needsInput()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isWritable()>();
if v != 0 goto label;
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 ensureWritable(int)>(v);
goto label;
label:
return;
}
protected final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf allocateBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, boolean) throws java.lang.Exception
{
byte[] v;
int[] v;
int v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v, v;
double v, 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.ZlibWrapper 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.JdkZlibEncoder;
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: boolean;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = v * 1.001;
v = staticinvoke <java.lang.Math: double ceil(double)>(v);
v = v + 12;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader>;
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$4: int[] $SwitchMap$io$netty$handler$codec$compression$ZlibWrapper>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: byte[] gzipHeader>;
v = lengthof v;
v = v + v;
goto label;
label:
v = v + 2;
label:
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 heapBuffer(int)>(v);
return v;
}
public void close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$3 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$2 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
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.channel.ChannelPromise;
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.channel.ChannelPromise newPromise()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture finishEncode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: boolean isDone()>();
if v != 0 goto label;
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.util.concurrent.EventExecutor executor()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder$3: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, 10L, v);
label:
return;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture finishEncode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
byte[] v;
long v;
int v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v, v, v, v;
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.ZlibWrapper v, v, v, v;
java.util.zip.Deflater v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.util.zip.CRC32 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
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.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean finished>;
if v == 0 goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess()>();
return v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean finished> = 1;
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 heapBuffer()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper>;
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 GZIP>;
if v != v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: boolean writeHeader> = 0;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: byte[] gzipHeader>;
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
virtualinvoke v.<java.util.zip.Deflater: void finish()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
v = virtualinvoke v.<java.util.zip.Deflater: boolean finished()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: void deflate(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: boolean isWritable()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
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 heapBuffer()>();
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.ZlibWrapper wrapper>;
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 GZIP>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.CRC32 crc>;
v = virtualinvoke v.<java.util.zip.CRC32: long getValue()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
v = virtualinvoke v.<java.util.zip.Deflater: int getTotalIn()>();
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)>(v);
v = v >>> 8;
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)>(v);
v = v >>> 16;
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)>(v);
v = v >>> 24;
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)>(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 writeByte(int)>(v);
v = v >>> 8;
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)>(v);
v = v >>> 16;
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)>(v);
v = v >>> 24;
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)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
virtualinvoke v.<java.util.zip.Deflater: void end()>();
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.channel.ChannelFuture writeAndFlush(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
private void deflate(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.util.zip.Deflater v;
int v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
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.util.internal.PlatformDependent: int javaVersion()>();
if v >= 7 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: void deflateJdk6(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
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 = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writableBytes()>();
v = virtualinvoke v.<java.util.zip.Deflater: int deflate(byte[],int,int,int)>(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);
if v > 0 goto label;
return;
}
private void deflateJdk6(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.util.zip.Deflater v;
int v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: java.util.zip.Deflater deflater>;
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 = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writableBytes()>();
v = virtualinvoke v.<java.util.zip.Deflater: int deflate(byte[],int,int)>(v, v, v);
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);
if v > 0 goto label;
return;
}
public void handlerAdded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx> = v;
return;
}
static void <clinit>()
{
byte[] v;
v = newarray (byte)[10];
v[0] = 31;
v[1] = -117;
v[2] = 8;
v[3] = 0;
v[4] = 0;
v[5] = 0;
v[6] = 0;
v[7] = 0;
v[8] = 0;
v[9] = 0;
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.compression.JdkZlibEncoder: byte[] gzipHeader> = v;
return;
}
}