public class io.netty.handler.codec.compression.JZlibEncoder extends io.netty.handler.codec.compression.ZlibEncoder
{
private final int wrapperOverhead;
private final com.jcraft.jzlib.Deflater z;
private volatile boolean finished;
private volatile io.netty.channel.ChannelHandlerContext ctx;
private static final int THREAD_POOL_DELAY_SECONDS;
public void <init>()
{
io.netty.handler.codec.compression.JZlibEncoder v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: void <init>(int)>(6);
return;
}
public void <init>(int)
{
int v;
io.netty.handler.codec.compression.JZlibEncoder v;
io.netty.handler.codec.compression.ZlibWrapper v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: int;
v = <io.netty.handler.codec.compression.ZlibWrapper: io.netty.handler.codec.compression.ZlibWrapper ZLIB>;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: void <init>(io.netty.handler.codec.compression.ZlibWrapper,int)>(v, v);
return;
}
public void <init>(io.netty.handler.codec.compression.ZlibWrapper)
{
io.netty.handler.codec.compression.JZlibEncoder v;
io.netty.handler.codec.compression.ZlibWrapper v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.handler.codec.compression.ZlibWrapper;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: void <init>(io.netty.handler.codec.compression.ZlibWrapper,int)>(v, 6);
return;
}
public void <init>(io.netty.handler.codec.compression.ZlibWrapper, int)
{
int v;
io.netty.handler.codec.compression.JZlibEncoder v;
io.netty.handler.codec.compression.ZlibWrapper v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.handler.codec.compression.ZlibWrapper;
v := @parameter: int;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: void <init>(io.netty.handler.codec.compression.ZlibWrapper,int,int,int)>(v, v, 15, 8);
return;
}
public void <init>(io.netty.handler.codec.compression.ZlibWrapper, int, int, int)
{
com.jcraft.jzlib.Deflater v, v, v;
com.jcraft.jzlib.JZlib$WrapperType v;
io.netty.handler.codec.compression.ZlibWrapper v, v, v;
java.lang.IllegalArgumentException v;
int v, v, v, v, v;
io.netty.handler.codec.compression.JZlibEncoder v;
java.lang.String v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.handler.codec.compression.ZlibWrapper;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<io.netty.handler.codec.compression.ZlibEncoder: void <init>()>();
v = new com.jcraft.jzlib.Deflater;
specialinvoke v.<com.jcraft.jzlib.Deflater: void <init>()>();
v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z> = v;
staticinvoke <io.netty.util.internal.ObjectUtil: int checkInRange(int,int,int,java.lang.String)>(v, 0, 9, "compressionLevel");
staticinvoke <io.netty.util.internal.ObjectUtil: int checkInRange(int,int,int,java.lang.String)>(v, 9, 15, "windowBits");
staticinvoke <io.netty.util.internal.ObjectUtil: int checkInRange(int,int,int,java.lang.String)>(v, 1, 9, "memLevel");
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "wrapper");
v = <io.netty.handler.codec.compression.ZlibWrapper: io.netty.handler.codec.compression.ZlibWrapper ZLIB_OR_NONE>;
if v != v goto label;
v = new java.lang.IllegalArgumentException;
v = <io.netty.handler.codec.compression.ZlibWrapper: io.netty.handler.codec.compression.ZlibWrapper ZLIB_OR_NONE>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (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 = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = staticinvoke <io.netty.handler.codec.compression.ZlibUtil: com.jcraft.jzlib.JZlib$WrapperType convertWrapperType(io.netty.handler.codec.compression.ZlibWrapper)>(v);
v = virtualinvoke v.<com.jcraft.jzlib.Deflater: int init(int,int,int,com.jcraft.jzlib.JZlib$WrapperType)>(v, v, v, v);
if v == 0 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
staticinvoke <io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Deflater,java.lang.String,int)>(v, "initialization failure", v);
label:
v = staticinvoke <io.netty.handler.codec.compression.ZlibUtil: int wrapperOverhead(io.netty.handler.codec.compression.ZlibWrapper)>(v);
v.<io.netty.handler.codec.compression.JZlibEncoder: int wrapperOverhead> = v;
return;
}
public void <init>(byte[])
{
byte[] v;
io.netty.handler.codec.compression.JZlibEncoder v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: byte[];
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: void <init>(int,byte[])>(6, v);
return;
}
public void <init>(int, byte[])
{
int v;
byte[] v;
io.netty.handler.codec.compression.JZlibEncoder v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: int;
v := @parameter: byte[];
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: void <init>(int,int,int,byte[])>(v, 15, 8, v);
return;
}
public void <init>(int, int, int, byte[])
{
byte[] v;
com.jcraft.jzlib.JZlib$WrapperType v;
int v, v, v, v, v, v, v;
io.netty.handler.codec.compression.JZlibEncoder v;
com.jcraft.jzlib.Deflater v, v, v, v, v;
io.netty.handler.codec.compression.ZlibWrapper v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: byte[];
specialinvoke v.<io.netty.handler.codec.compression.ZlibEncoder: void <init>()>();
v = new com.jcraft.jzlib.Deflater;
specialinvoke v.<com.jcraft.jzlib.Deflater: void <init>()>();
v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z> = v;
staticinvoke <io.netty.util.internal.ObjectUtil: int checkInRange(int,int,int,java.lang.String)>(v, 0, 9, "compressionLevel");
staticinvoke <io.netty.util.internal.ObjectUtil: int checkInRange(int,int,int,java.lang.String)>(v, 9, 15, "windowBits");
staticinvoke <io.netty.util.internal.ObjectUtil: int checkInRange(int,int,int,java.lang.String)>(v, 1, 9, "memLevel");
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "dictionary");
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = <com.jcraft.jzlib.JZlib: com.jcraft.jzlib.JZlib$WrapperType W_ZLIB>;
v = virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflateInit(int,int,int,com.jcraft.jzlib.JZlib$WrapperType)>(v, v, v, v);
if v == 0 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
staticinvoke <io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Deflater,java.lang.String,int)>(v, "initialization failure", v);
goto label;
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = lengthof v;
v = virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflateSetDictionary(byte[],int)>(v, v);
if v == 0 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
staticinvoke <io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Deflater,java.lang.String,int)>(v, "failed to set the dictionary", v);
label:
v = <io.netty.handler.codec.compression.ZlibWrapper: io.netty.handler.codec.compression.ZlibWrapper ZLIB>;
v = staticinvoke <io.netty.handler.codec.compression.ZlibUtil: int wrapperOverhead(io.netty.handler.codec.compression.ZlibWrapper)>(v);
v.<io.netty.handler.codec.compression.JZlibEncoder: int wrapperOverhead> = v;
return;
}
public io.netty.channel.ChannelFuture close()
{
io.netty.channel.Channel v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.compression.JZlibEncoder v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v = specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: io.netty.channel.ChannelHandlerContext ctx()>();
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise)>(v);
return v;
}
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise)
{
io.netty.util.concurrent.EventExecutor v;
io.netty.handler.codec.compression.JZlibEncoder$1 v;
io.netty.channel.ChannelFuture v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v, v;
io.netty.handler.codec.compression.JZlibEncoder v;
boolean v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.channel.ChannelPromise;
v = specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: io.netty.channel.ChannelHandlerContext ctx()>();
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.util.concurrent.EventExecutor executor()>();
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: boolean inEventLoop()>();
if v == 0 goto label;
v = specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext,io.netty.channel.ChannelPromise)>(v, v);
return v;
label:
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPromise newPromise()>();
v = new io.netty.handler.codec.compression.JZlibEncoder$1;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder$1: void <init>(io.netty.handler.codec.compression.JZlibEncoder,io.netty.channel.ChannelPromise,io.netty.channel.ChannelPromise)>(v, v, v);
interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: void execute(java.lang.Runnable)>(v);
return v;
}
private io.netty.channel.ChannelHandlerContext ctx()
{
io.netty.channel.ChannelHandlerContext v;
java.lang.IllegalStateException v;
io.netty.handler.codec.compression.JZlibEncoder v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: 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()
{
io.netty.handler.codec.compression.JZlibEncoder v;
boolean v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: boolean finished>;
return v;
}
protected void encode(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, io.netty.buffer.ByteBuf) throws java.lang.Exception
{
byte[] v, v, v;
io.netty.handler.codec.compression.JZlibEncoder v;
boolean v, v;
com.jcraft.jzlib.Deflater v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Throwable v, v;
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf 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;
double v, v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: io.netty.buffer.ByteBuf;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: boolean finished>;
if v == 0 goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeBytes(io.netty.buffer.ByteBuf)>(v);
return;
label:
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int readableBytes()>();
if v != 0 goto label;
return;
label:
v = virtualinvoke v.<io.netty.buffer.ByteBuf: boolean hasArray()>();
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: int avail_in> = v;
if v == 0 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: byte[] array()>();
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int arrayOffset()>();
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int readerIndex()>();
v = v + v;
v.<com.jcraft.jzlib.Deflater: int next_in_index> = v;
goto label;
label:
v = newarray (byte)[v];
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int readerIndex()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf getBytes(int,byte[])>(v, v);
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: int next_in_index> = 0;
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_in_index>;
v = v * 1.001;
v = staticinvoke <java.lang.Math: double ceil(double)>(v);
v = v + 12;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: int wrapperOverhead>;
v = v + v;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf ensureWritable(int)>(v);
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: int avail_out> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: byte[] array()>();
v.<com.jcraft.jzlib.Deflater: byte[] next_out> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int arrayOffset()>();
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int writerIndex()>();
v = v + v;
v.<com.jcraft.jzlib.Deflater: int next_out_index> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_out_index>;
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflate(int)>(2);
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_in_index>;
v = v - v;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf skipBytes(int)>(v);
goto label;
label:
v := @caughtexception;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_in_index>;
v = v - v;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf skipBytes(int)>(v);
throw v;
label:
if v == 0 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
staticinvoke <io.netty.handler.codec.compression.ZlibUtil: void fail(com.jcraft.jzlib.Deflater,java.lang.String,int)>(v, "compression failure", v);
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_out_index>;
v = v - v;
if v <= 0 goto label;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int writerIndex()>();
v = v + v;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writerIndex(int)>(v);
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = null;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_out> = null;
goto label;
label:
v := @caughtexception;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = null;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: 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;
}
public void close(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise)
{
io.netty.util.concurrent.EventExecutor v;
io.netty.util.concurrent.ScheduledFuture v;
io.netty.handler.codec.compression.JZlibEncoder$3 v;
io.netty.handler.codec.compression.JZlibEncoder$2 v;
io.netty.channel.ChannelFuture v;
java.util.concurrent.TimeUnit v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v, v;
io.netty.handler.codec.compression.JZlibEncoder v;
boolean v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.channel.ChannelPromise;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPromise newPromise()>();
v = specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder: io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext,io.netty.channel.ChannelPromise)>(v, v);
v = interfaceinvoke v.<io.netty.channel.ChannelFuture: boolean isDone()>();
if v != 0 goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.util.concurrent.EventExecutor executor()>();
v = new io.netty.handler.codec.compression.JZlibEncoder$2;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder$2: void <init>(io.netty.handler.codec.compression.JZlibEncoder,io.netty.channel.ChannelPromise,io.netty.channel.ChannelHandlerContext)>(v, v, v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<io.netty.util.concurrent.EventExecutor: io.netty.util.concurrent.ScheduledFuture schedule(java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, 10L, v);
v = new io.netty.handler.codec.compression.JZlibEncoder$3;
specialinvoke v.<io.netty.handler.codec.compression.JZlibEncoder$3: void <init>(io.netty.handler.codec.compression.JZlibEncoder,io.netty.util.concurrent.Future,io.netty.channel.ChannelPromise,io.netty.channel.ChannelHandlerContext)>(v, v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
goto label;
label:
interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise)>(v);
label:
return;
}
private io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise)
{
byte[] v, v;
io.netty.handler.codec.compression.CompressionException v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.compression.JZlibEncoder v;
boolean v;
com.jcraft.jzlib.Deflater v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Throwable v;
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf v;
int v, v, v, v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: boolean finished>;
if v == 0 goto label;
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setSuccess()>();
return v;
label:
v.<io.netty.handler.codec.compression.JZlibEncoder: boolean finished> = 1;
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = <io.netty.util.internal.EmptyArrays: byte[] EMPTY_BYTES>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: int next_in_index> = 0;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: int avail_in> = 0;
v = newarray (byte)[32];
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_out> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: int next_out_index> = 0;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = lengthof v;
v.<com.jcraft.jzlib.Deflater: int avail_out> = v;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflate(int)>(4);
if v == 0 goto label;
if v == 1 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = staticinvoke <io.netty.handler.codec.compression.ZlibUtil: io.netty.handler.codec.compression.CompressionException deflaterException(com.jcraft.jzlib.Deflater,java.lang.String,int)>(v, "compression failure", v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflateEnd()>();
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = null;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_out> = null;
return v;
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_out_index>;
if v == 0 goto label;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v = v.<com.jcraft.jzlib.Deflater: int next_out_index>;
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf wrappedBuffer(byte[],int,int)>(v, 0, v);
goto label;
label:
v = <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf EMPTY_BUFFER>;
label:
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflateEnd()>();
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = null;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_out> = null;
goto label;
label:
v := @caughtexception;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
virtualinvoke v.<com.jcraft.jzlib.Deflater: int deflateEnd()>();
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_in> = null;
v = v.<io.netty.handler.codec.compression.JZlibEncoder: com.jcraft.jzlib.Deflater z>;
v.<com.jcraft.jzlib.Deflater: byte[] next_out> = null;
throw v;
label:
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object,io.netty.channel.ChannelPromise)>(v, v);
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void handlerAdded(io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.compression.JZlibEncoder v;
v := @this: io.netty.handler.codec.compression.JZlibEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v.<io.netty.handler.codec.compression.JZlibEncoder: io.netty.channel.ChannelHandlerContext ctx> = v;
return;
}
}