public final class io.netty.handler.codec.compression.BrotliEncoder extends io.netty.handler.codec.MessageToByteEncoder
{
private static final io.netty.util.AttributeKey ATTR;
private static final java.lang.reflect.Method FLUSH_METHOD;
private final com.aayushatharva.brotli4j.encoder.Encoder$Parameters parameters;
private final boolean isSharable;
private io.netty.handler.codec.compression.BrotliEncoder$Writer writer;
public void <init>()
{
io.netty.handler.codec.compression.BrotliOptions v;
io.netty.handler.codec.compression.BrotliEncoder v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v = <io.netty.handler.codec.compression.BrotliOptions: io.netty.handler.codec.compression.BrotliOptions DEFAULT>;
specialinvoke v.<io.netty.handler.codec.compression.BrotliEncoder: void <init>(io.netty.handler.codec.compression.BrotliOptions)>(v);
return;
}
public void <init>(io.netty.handler.codec.compression.BrotliOptions)
{
io.netty.handler.codec.compression.BrotliOptions v;
com.aayushatharva.brotli4j.encoder.Encoder$Parameters v;
io.netty.handler.codec.compression.BrotliEncoder v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.handler.codec.compression.BrotliOptions;
v = virtualinvoke v.<io.netty.handler.codec.compression.BrotliOptions: com.aayushatharva.brotli4j.encoder.Encoder$Parameters parameters()>();
specialinvoke v.<io.netty.handler.codec.compression.BrotliEncoder: void <init>(com.aayushatharva.brotli4j.encoder.Encoder$Parameters)>(v);
return;
}
public void <init>(com.aayushatharva.brotli4j.encoder.Encoder$Parameters)
{
com.aayushatharva.brotli4j.encoder.Encoder$Parameters v;
io.netty.handler.codec.compression.BrotliEncoder v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: com.aayushatharva.brotli4j.encoder.Encoder$Parameters;
specialinvoke v.<io.netty.handler.codec.compression.BrotliEncoder: void <init>(com.aayushatharva.brotli4j.encoder.Encoder$Parameters,boolean)>(v, 1);
return;
}
public void <init>(com.aayushatharva.brotli4j.encoder.Encoder$Parameters, boolean)
{
com.aayushatharva.brotli4j.encoder.Encoder$Parameters v;
io.netty.handler.codec.compression.BrotliEncoder v;
java.lang.Object v;
boolean v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: com.aayushatharva.brotli4j.encoder.Encoder$Parameters;
v := @parameter: boolean;
specialinvoke v.<io.netty.handler.codec.MessageToByteEncoder: void <init>()>();
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "Parameters");
v.<io.netty.handler.codec.compression.BrotliEncoder: com.aayushatharva.brotli4j.encoder.Encoder$Parameters parameters> = v;
v.<io.netty.handler.codec.compression.BrotliEncoder: boolean isSharable> = v;
return;
}
public void handlerAdded(io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
io.netty.util.AttributeKey v;
io.netty.util.Attribute v;
com.aayushatharva.brotli4j.encoder.Encoder$Parameters v;
io.netty.handler.codec.compression.BrotliEncoder v;
io.netty.handler.codec.compression.BrotliEncoder$Writer v;
io.netty.channel.Channel v;
io.netty.channel.ChannelHandlerContext v;
boolean v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v = new io.netty.handler.codec.compression.BrotliEncoder$Writer;
v = v.<io.netty.handler.codec.compression.BrotliEncoder: com.aayushatharva.brotli4j.encoder.Encoder$Parameters parameters>;
specialinvoke v.<io.netty.handler.codec.compression.BrotliEncoder$Writer: void <init>(com.aayushatharva.brotli4j.encoder.Encoder$Parameters,io.netty.channel.ChannelHandlerContext)>(v, v);
v = v.<io.netty.handler.codec.compression.BrotliEncoder: boolean isSharable>;
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.Channel channel()>();
v = <io.netty.handler.codec.compression.BrotliEncoder: io.netty.util.AttributeKey ATTR>;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.util.Attribute attr(io.netty.util.AttributeKey)>(v);
interfaceinvoke v.<io.netty.util.Attribute: void set(java.lang.Object)>(v);
goto label;
label:
v.<io.netty.handler.codec.compression.BrotliEncoder: io.netty.handler.codec.compression.BrotliEncoder$Writer writer> = v;
label:
specialinvoke v.<io.netty.handler.codec.MessageToByteEncoder: void handlerAdded(io.netty.channel.ChannelHandlerContext)>(v);
return;
}
public void handlerRemoved(io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.compression.BrotliEncoder v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
virtualinvoke v.<io.netty.handler.codec.compression.BrotliEncoder: void finish(io.netty.channel.ChannelHandlerContext)>(v);
specialinvoke v.<io.netty.handler.codec.MessageToByteEncoder: void handlerRemoved(io.netty.channel.ChannelHandlerContext)>(v);
return;
}
protected void encode(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, io.netty.buffer.ByteBuf) throws java.lang.Exception
{
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf v, v;
io.netty.handler.codec.compression.BrotliEncoder v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: io.netty.buffer.ByteBuf;
return;
}
protected io.netty.buffer.ByteBuf allocateBuffer(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, boolean) throws java.lang.Exception
{
io.netty.util.AttributeKey v;
io.netty.util.Attribute v;
io.netty.handler.codec.compression.BrotliEncoder v;
io.netty.channel.Channel v;
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf v, v, v, v;
java.lang.Object v;
boolean v, v, v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: boolean;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: boolean isReadable()>();
if v != 0 goto label;
v = <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf EMPTY_BUFFER>;
return v;
label:
v = v.<io.netty.handler.codec.compression.BrotliEncoder: boolean isSharable>;
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.Channel channel()>();
v = <io.netty.handler.codec.compression.BrotliEncoder: io.netty.util.AttributeKey ATTR>;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.util.Attribute attr(io.netty.util.AttributeKey)>(v);
v = interfaceinvoke v.<io.netty.util.Attribute: java.lang.Object get()>();
goto label;
label:
v = v.<io.netty.handler.codec.compression.BrotliEncoder: io.netty.handler.codec.compression.BrotliEncoder$Writer writer>;
label:
if v != null goto label;
v = <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf EMPTY_BUFFER>;
return v;
label:
specialinvoke v.<io.netty.handler.codec.compression.BrotliEncoder$Writer: void encode(io.netty.buffer.ByteBuf,boolean)>(v, v);
v = v.<io.netty.handler.codec.compression.BrotliEncoder$Writer: io.netty.buffer.ByteBuf writableBuffer>;
return v;
}
public boolean isSharable()
{
io.netty.handler.codec.compression.BrotliEncoder v;
boolean v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v = v.<io.netty.handler.codec.compression.BrotliEncoder: boolean isSharable>;
return v;
}
public void finish(io.netty.channel.ChannelHandlerContext) throws java.io.IOException
{
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.compression.BrotliEncoder v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPromise newPromise()>();
specialinvoke v.<io.netty.handler.codec.compression.BrotliEncoder: io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext,io.netty.channel.ChannelPromise)>(v, v);
return;
}
private io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise) throws java.io.IOException
{
io.netty.util.AttributeKey v;
io.netty.util.Attribute v;
io.netty.handler.codec.compression.BrotliEncoder v;
io.netty.channel.Channel v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
java.lang.Object v;
boolean v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.handler.codec.compression.BrotliEncoder: boolean isSharable>;
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.Channel channel()>();
v = <io.netty.handler.codec.compression.BrotliEncoder: io.netty.util.AttributeKey ATTR>;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.util.Attribute attr(io.netty.util.AttributeKey)>(v);
v = interfaceinvoke v.<io.netty.util.Attribute: java.lang.Object getAndSet(java.lang.Object)>(null);
goto label;
label:
v = v.<io.netty.handler.codec.compression.BrotliEncoder: io.netty.handler.codec.compression.BrotliEncoder$Writer writer>;
label:
if v == null goto label;
virtualinvoke v.<io.netty.handler.codec.compression.BrotliEncoder$Writer: void close()>();
v.<io.netty.handler.codec.compression.BrotliEncoder: io.netty.handler.codec.compression.BrotliEncoder$Writer writer> = null;
label:
return v;
}
public void close(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise) throws java.lang.Exception
{
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v, v;
io.netty.handler.codec.compression.BrotliEncoder v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.compression.BrotliEncoder;
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.BrotliEncoder: io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext,io.netty.channel.ChannelPromise)>(v, v);
staticinvoke <io.netty.handler.codec.compression.EncoderUtil: void closeAfterFinishEncode(io.netty.channel.ChannelHandlerContext,io.netty.channel.ChannelFuture,io.netty.channel.ChannelPromise)>(v, v, v);
return;
}
static void <clinit>()
{
io.netty.util.AttributeKey v;
java.lang.IllegalStateException v;
java.lang.NoSuchMethodException v;
java.lang.Class[] v;
java.lang.Class v;
java.lang.reflect.Method v;
v = staticinvoke <io.netty.util.AttributeKey: io.netty.util.AttributeKey valueOf(java.lang.String)>("BrotliEncoderWriter");
<io.netty.handler.codec.compression.BrotliEncoder: io.netty.util.AttributeKey ATTR> = v;
label:
v = class "Lcom/aayushatharva/brotli4j/encoder/Encoder;";
v = newarray (java.lang.Class)[0];
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Method getDeclaredMethod(java.lang.String,java.lang.Class[])>("flush", v);
virtualinvoke v.<java.lang.reflect.Method: void setAccessible(boolean)>(1);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
<io.netty.handler.codec.compression.BrotliEncoder: java.lang.reflect.Method FLUSH_METHOD> = v;
return;
catch java.lang.NoSuchMethodException from label to label with label;
}
}