public class io.netty.handler.codec.compression.Lz4FrameEncoder extends io.netty.handler.codec.MessageToByteEncoder<io.netty.buffer.ByteBuf>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.netty.handler.codec.compression.Lz4FrameEncoder
super_class: io.netty.handler.codec.MessageToByteEncoder
{
private static final io.netty.handler.codec.EncoderException ENCODE_FINSHED_EXCEPTION;
descriptor: Lio/netty/handler/codec/EncoderException;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final int DEFAULT_MAX_ENCODE_SIZE;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 2147483647
private final int blockSize;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final net.jpountz.lz4.LZ4Compressor compressor;
descriptor: Lnet/jpountz/lz4/LZ4Compressor;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.netty.handler.codec.compression.ByteBufChecksum checksum;
descriptor: Lio/netty/handler/codec/compression/ByteBufChecksum;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int compressionLevel;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.netty.buffer.ByteBuf buffer;
descriptor: Lio/netty/buffer/ByteBuf;
flags: (0x0002) ACC_PRIVATE
private final int maxEncodeSize;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile boolean finished;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile io.netty.channel.ChannelHandlerContext ctx;
descriptor: Lio/netty/channel/ChannelHandlerContext;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=0, args_size=0
0: new io.netty.handler.codec.EncoderException
dup
1: new java.lang.IllegalStateException
dup
ldc "encode finished and not enough space to write remaining data"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
2: invokespecial io.netty.handler.codec.EncoderException.<init>:(Ljava/lang/Throwable;)V
3: ldc Lio/netty/handler/codec/compression/Lz4FrameEncoder;
ldc "encode"
4: invokestatic io.netty.util.internal.ThrowableUtil.unknownStackTrace:(Ljava/lang/Throwable;Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Throwable;
checkcast io.netty.handler.codec.EncoderException
putstatic io.netty.handler.codec.compression.Lz4FrameEncoder.ENCODE_FINSHED_EXCEPTION:Lio/netty/handler/codec/EncoderException;
5: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokespecial io.netty.handler.codec.compression.Lz4FrameEncoder.<init>:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
public void <init>(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic net.jpountz.lz4.LZ4Factory.fastestInstance:()Lnet/jpountz/lz4/LZ4Factory;
iload 1
ldc 65536
1: invokestatic net.jpountz.xxhash.XXHashFactory.fastestInstance:()Lnet/jpountz/xxhash/XXHashFactory;
ldc -1756908916
invokevirtual net.jpountz.xxhash.XXHashFactory.newStreamingHash32:(I)Lnet/jpountz/xxhash/StreamingXXHash32;
invokevirtual net.jpountz.xxhash.StreamingXXHash32.asChecksum:()Ljava/util/zip/Checksum;
invokespecial io.netty.handler.codec.compression.Lz4FrameEncoder.<init>:(Lnet/jpountz/lz4/LZ4Factory;ZILjava/util/zip/Checksum;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 3 1 highCompressor Z
MethodParameters:
Name Flags
highCompressor
public void <init>(net.jpountz.lz4.LZ4Factory, boolean, int, java.util.zip.Checksum);
descriptor: (Lnet/jpountz/lz4/LZ4Factory;ZILjava/util/zip/Checksum;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
iload 2
iload 3
aload 4
ldc 2147483647
invokespecial io.netty.handler.codec.compression.Lz4FrameEncoder.<init>:(Lnet/jpountz/lz4/LZ4Factory;ZILjava/util/zip/Checksum;I)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 2 1 factory Lnet/jpountz/lz4/LZ4Factory;
0 2 2 highCompressor Z
0 2 3 blockSize I
0 2 4 checksum Ljava/util/zip/Checksum;
MethodParameters:
Name Flags
factory
highCompressor
blockSize
checksum
public void <init>(net.jpountz.lz4.LZ4Factory, boolean, int, java.util.zip.Checksum, int);
descriptor: (Lnet/jpountz/lz4/LZ4Factory;ZILjava/util/zip/Checksum;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokespecial io.netty.handler.codec.MessageToByteEncoder.<init>:()V
1: aload 1
ifnonnull 3
2: new java.lang.NullPointerException
dup
ldc "factory"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: io.netty.handler.codec.compression.Lz4FrameEncoder net.jpountz.lz4.LZ4Factory int int java.util.zip.Checksum int
StackMap stack:
aload 4
ifnonnull 5
4: new java.lang.NullPointerException
dup
ldc "checksum"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals:
StackMap stack:
aload 0
iload 2
ifeq 6
aload 1
invokevirtual net.jpountz.lz4.LZ4Factory.highCompressor:()Lnet/jpountz/lz4/LZ4Compressor;
goto 7
StackMap locals:
StackMap stack: io.netty.handler.codec.compression.Lz4FrameEncoder
6: aload 1
invokevirtual net.jpountz.lz4.LZ4Factory.fastCompressor:()Lnet/jpountz/lz4/LZ4Compressor;
StackMap locals: io.netty.handler.codec.compression.Lz4FrameEncoder net.jpountz.lz4.LZ4Factory int int java.util.zip.Checksum int
StackMap stack: io.netty.handler.codec.compression.Lz4FrameEncoder net.jpountz.lz4.LZ4Compressor
7: putfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressor:Lnet/jpountz/lz4/LZ4Compressor;
8: aload 0
aload 4
invokestatic io.netty.handler.codec.compression.ByteBufChecksum.wrapChecksum:(Ljava/util/zip/Checksum;)Lio/netty/handler/codec/compression/ByteBufChecksum;
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.checksum:Lio/netty/handler/codec/compression/ByteBufChecksum;
9: aload 0
iload 3
invokestatic io.netty.handler.codec.compression.Lz4FrameEncoder.compressionLevel:(I)I
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressionLevel:I
10: aload 0
iload 3
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.blockSize:I
11: aload 0
iload 5
ldc "maxEncodeSize"
invokestatic io.netty.util.internal.ObjectUtil.checkPositive:(ILjava/lang/String;)I
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.maxEncodeSize:I
12: aload 0
iconst_0
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.finished:Z
13: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 14 1 factory Lnet/jpountz/lz4/LZ4Factory;
0 14 2 highCompressor Z
0 14 3 blockSize I
0 14 4 checksum Ljava/util/zip/Checksum;
0 14 5 maxEncodeSize I
MethodParameters:
Name Flags
factory
highCompressor
blockSize
checksum
maxEncodeSize
private static int compressionLevel(int);
descriptor: (I)I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=7, locals=2, args_size=1
start local 0 0: iload 0
bipush 64
if_icmplt 1
iload 0
ldc 33554432
if_icmple 4
1: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
2: ldc "blockSize: %d (expected: %d-%d)"
iconst_3
anewarray java.lang.Object
dup
iconst_0
iload 0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
bipush 64
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
ldc 33554432
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
bipush 32
iload 0
iconst_1
isub
invokestatic java.lang.Integer.numberOfLeadingZeros:(I)I
isub
istore 1
start local 1 5: iconst_0
iload 1
bipush 10
isub
invokestatic java.lang.Math.max:(II)I
istore 1
6: iload 1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 blockSize I
5 7 1 compressionLevel I
MethodParameters:
Name Flags
blockSize
protected io.netty.buffer.ByteBuf allocateBuffer(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, boolean);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;Z)Lio/netty/buffer/ByteBuf;
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
iload 3
iconst_1
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.allocateBuffer:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;ZZ)Lio/netty/buffer/ByteBuf;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 1 2 msg Lio/netty/buffer/ByteBuf;
0 1 3 preferDirect Z
MethodParameters:
Name Flags
ctx
msg
preferDirect
private io.netty.buffer.ByteBuf allocateBuffer(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, boolean, boolean);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;ZZ)Lio/netty/buffer/ByteBuf;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: iconst_0
istore 5
start local 5 1: aload 2
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
iadd
istore 6
start local 6 2: iload 6
ifge 7
3: new io.netty.handler.codec.EncoderException
dup
ldc "too much data to allocate a buffer for compression"
invokespecial io.netty.handler.codec.EncoderException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals: int int
StackMap stack:
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.blockSize:I
iload 6
invokestatic java.lang.Math.min:(II)I
istore 7
start local 7 5: iload 6
iload 7
isub
istore 6
6: iload 5
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressor:Lnet/jpountz/lz4/LZ4Compressor;
iload 7
invokevirtual net.jpountz.lz4.LZ4Compressor.maxCompressedLength:(I)I
bipush 21
iadd
iadd
istore 5
end local 7 7: StackMap locals:
StackMap stack:
iload 6
ifgt 4
8: iload 5
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.maxEncodeSize:I
if_icmpgt 9
iload 5
ifge 12
9: StackMap locals:
StackMap stack:
new io.netty.handler.codec.EncoderException
dup
ldc "requested encode buffer size (%d bytes) exceeds the maximum allowable size (%d bytes)"
iconst_2
anewarray java.lang.Object
dup
iconst_0
10: iload 5
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.maxEncodeSize:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
11: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial io.netty.handler.codec.EncoderException.<init>:(Ljava/lang/String;)V
athrow
12: StackMap locals:
StackMap stack:
iload 4
ifeq 14
iload 5
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.blockSize:I
if_icmpge 14
13: getstatic io.netty.buffer.Unpooled.EMPTY_BUFFER:Lio/netty/buffer/ByteBuf;
areturn
14: StackMap locals:
StackMap stack:
iload 3
ifeq 16
15: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
iload 5
iload 5
invokeinterface io.netty.buffer.ByteBufAllocator.ioBuffer:(II)Lio/netty/buffer/ByteBuf;
areturn
16: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
iload 5
iload 5
invokeinterface io.netty.buffer.ByteBufAllocator.heapBuffer:(II)Lio/netty/buffer/ByteBuf;
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 17 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 17 2 msg Lio/netty/buffer/ByteBuf;
0 17 3 preferDirect Z
0 17 4 allowEmptyReturn Z
1 17 5 targetBufSize I
2 17 6 remaining I
5 7 7 curSize I
MethodParameters:
Name Flags
ctx
msg
preferDirect
allowEmptyReturn
protected void encode(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.finished:Z
ifeq 5
1: aload 3
aload 2
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
invokevirtual io.netty.buffer.ByteBuf.isWritable:(I)Z
ifne 3
2: getstatic io.netty.handler.codec.compression.Lz4FrameEncoder.ENCODE_FINSHED_EXCEPTION:Lio/netty/handler/codec/EncoderException;
athrow
3: StackMap locals:
StackMap stack:
aload 3
aload 2
invokevirtual io.netty.buffer.ByteBuf.writeBytes:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
pop
4: return
5: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
astore 4
start local 4 6: goto 11
start local 5 7: StackMap locals: io.netty.buffer.ByteBuf int
StackMap stack:
iload 5
aload 4
invokevirtual io.netty.buffer.ByteBuf.writableBytes:()I
invokestatic java.lang.Math.min:(II)I
istore 6
start local 6 8: aload 2
aload 4
iload 6
invokevirtual io.netty.buffer.ByteBuf.readBytes:(Lio/netty/buffer/ByteBuf;I)Lio/netty/buffer/ByteBuf;
pop
9: aload 4
invokevirtual io.netty.buffer.ByteBuf.isWritable:()Z
ifne 11
10: aload 0
aload 3
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.flushBufferedData:(Lio/netty/buffer/ByteBuf;)V
end local 6 end local 5 11: StackMap locals:
StackMap stack:
aload 2
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
dup
istore 5
start local 5 12: ifgt 7
13: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 14 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 14 2 in Lio/netty/buffer/ByteBuf;
0 14 3 out Lio/netty/buffer/ByteBuf;
6 14 4 buffer Lio/netty/buffer/ByteBuf;
7 11 5 length I
12 14 5 length I
8 11 6 nextChunkSize I
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
in
out
private void flushBufferedData(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=9, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
istore 2
start local 2 1: iload 2
ifne 3
2: return
3: StackMap locals: int
StackMap stack:
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.checksum:Lio/netty/handler/codec/compression/ByteBufChecksum;
invokevirtual io.netty.handler.codec.compression.ByteBufChecksum.reset:()V
4: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.checksum:Lio/netty/handler/codec/compression/ByteBufChecksum;
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
iload 2
invokevirtual io.netty.handler.codec.compression.ByteBufChecksum.update:(Lio/netty/buffer/ByteBuf;II)V
5: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.checksum:Lio/netty/handler/codec/compression/ByteBufChecksum;
invokevirtual io.netty.handler.codec.compression.ByteBufChecksum.getValue:()J
l2i
istore 3
start local 3 6: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressor:Lnet/jpountz/lz4/LZ4Compressor;
iload 2
invokevirtual net.jpountz.lz4.LZ4Compressor.maxCompressedLength:(I)I
bipush 21
iadd
istore 4
start local 4 7: aload 1
iload 4
invokevirtual io.netty.buffer.ByteBuf.ensureWritable:(I)Lio/netty/buffer/ByteBuf;
pop
8: aload 1
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
istore 5
start local 5 9: aload 1
iload 5
bipush 21
iadd
aload 1
invokevirtual io.netty.buffer.ByteBuf.writableBytes:()I
bipush 21
isub
invokevirtual io.netty.buffer.ByteBuf.internalNioBuffer:(II)Ljava/nio/ByteBuffer;
astore 7
start local 7 10: aload 7
invokevirtual java.nio.ByteBuffer.position:()I
istore 8
start local 8 11: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressor:Lnet/jpountz/lz4/LZ4Compressor;
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
iload 2
invokevirtual io.netty.buffer.ByteBuf.internalNioBuffer:(II)Ljava/nio/ByteBuffer;
aload 7
invokevirtual net.jpountz.lz4.LZ4Compressor.compress:(Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)V
12: aload 7
invokevirtual java.nio.ByteBuffer.position:()I
iload 8
isub
istore 6
end local 8 end local 7 start local 6 13: goto 16
end local 6 StackMap locals: io.netty.handler.codec.compression.Lz4FrameEncoder io.netty.buffer.ByteBuf int int int int
StackMap stack: net.jpountz.lz4.LZ4Exception
14: astore 7
start local 7 15: new io.netty.handler.codec.compression.CompressionException
dup
aload 7
invokespecial io.netty.handler.codec.compression.CompressionException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 7 start local 6 16: StackMap locals: int
StackMap stack:
iload 6
iload 2
if_icmplt 21
17: bipush 16
istore 7
start local 7 18: iload 2
istore 6
19: aload 1
iload 5
bipush 21
iadd
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
iconst_0
iload 2
invokevirtual io.netty.buffer.ByteBuf.setBytes:(ILio/netty/buffer/ByteBuf;II)Lio/netty/buffer/ByteBuf;
pop
20: goto 22
end local 7 21: StackMap locals:
StackMap stack:
bipush 32
istore 7
start local 7 22: StackMap locals: int
StackMap stack:
aload 1
iload 5
ldc 5501767354678207339
invokevirtual io.netty.buffer.ByteBuf.setLong:(IJ)Lio/netty/buffer/ByteBuf;
pop
23: aload 1
iload 5
bipush 8
iadd
iload 7
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressionLevel:I
ior
i2b
invokevirtual io.netty.buffer.ByteBuf.setByte:(II)Lio/netty/buffer/ByteBuf;
pop
24: aload 1
iload 5
bipush 9
iadd
iload 6
invokevirtual io.netty.buffer.ByteBuf.setIntLE:(II)Lio/netty/buffer/ByteBuf;
pop
25: aload 1
iload 5
bipush 13
iadd
iload 2
invokevirtual io.netty.buffer.ByteBuf.setIntLE:(II)Lio/netty/buffer/ByteBuf;
pop
26: aload 1
iload 5
bipush 17
iadd
iload 3
invokevirtual io.netty.buffer.ByteBuf.setIntLE:(II)Lio/netty/buffer/ByteBuf;
pop
27: aload 1
iload 5
bipush 21
iadd
iload 6
iadd
invokevirtual io.netty.buffer.ByteBuf.writerIndex:(I)Lio/netty/buffer/ByteBuf;
pop
28: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.clear:()Lio/netty/buffer/ByteBuf;
pop
29: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 30 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 30 1 out Lio/netty/buffer/ByteBuf;
1 30 2 flushableBytes I
6 30 3 check I
7 30 4 bufSize I
9 30 5 idx I
13 14 6 compressedLength I
16 30 6 compressedLength I
10 13 7 outNioBuffer Ljava/nio/ByteBuffer;
11 13 8 pos I
15 16 7 e Lnet/jpountz/lz4/LZ4Exception;
18 21 7 blockType I
22 30 7 blockType I
Exception table:
from to target type
9 13 14 Class net.jpountz.lz4.LZ4Exception
MethodParameters:
Name Flags
out
public void flush(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
ifnull 4
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifeq 4
1: aload 0
aload 1
getstatic io.netty.buffer.Unpooled.EMPTY_BUFFER:Lio/netty/buffer/ByteBuf;
aload 0
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.isPreferDirect:()Z
iconst_0
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.allocateBuffer:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;ZZ)Lio/netty/buffer/ByteBuf;
astore 2
start local 2 2: aload 0
aload 2
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.flushBufferedData:(Lio/netty/buffer/ByteBuf;)V
3: aload 1
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
end local 2 4: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
pop
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 6 1 ctx Lio/netty/channel/ChannelHandlerContext;
2 4 2 buf Lio/netty/buffer/ByteBuf;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx final
private io.netty.channel.ChannelFuture finishEncode(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.finished:Z
ifeq 3
1: aload 2
invokeinterface io.netty.channel.ChannelPromise.setSuccess:()Lio/netty/channel/ChannelPromise;
pop
2: aload 2
areturn
3: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.finished:Z
4: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
5: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressor:Lnet/jpountz/lz4/LZ4Compressor;
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
invokevirtual net.jpountz.lz4.LZ4Compressor.maxCompressedLength:(I)I
bipush 21
iadd
6: invokeinterface io.netty.buffer.ByteBufAllocator.heapBuffer:(I)Lio/netty/buffer/ByteBuf;
astore 3
start local 3 7: aload 0
aload 3
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.flushBufferedData:(Lio/netty/buffer/ByteBuf;)V
8: aload 3
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
istore 4
start local 4 9: aload 3
iload 4
ldc 5501767354678207339
invokevirtual io.netty.buffer.ByteBuf.setLong:(IJ)Lio/netty/buffer/ByteBuf;
pop
10: aload 3
iload 4
bipush 8
iadd
bipush 16
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.compressionLevel:I
ior
i2b
invokevirtual io.netty.buffer.ByteBuf.setByte:(II)Lio/netty/buffer/ByteBuf;
pop
11: aload 3
iload 4
bipush 9
iadd
iconst_0
invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
pop
12: aload 3
iload 4
bipush 13
iadd
iconst_0
invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
pop
13: aload 3
iload 4
bipush 17
iadd
iconst_0
invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
pop
14: aload 3
iload 4
bipush 21
iadd
invokevirtual io.netty.buffer.ByteBuf.writerIndex:(I)Lio/netty/buffer/ByteBuf;
pop
15: aload 1
aload 3
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 16 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 16 2 promise Lio/netty/channel/ChannelPromise;
7 16 3 footer Lio/netty/buffer/ByteBuf;
9 16 4 idx I
MethodParameters:
Name Flags
ctx final
promise
public boolean isClosed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.finished:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
public io.netty.channel.ChannelFuture close();
descriptor: ()Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.ctx:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.close:(Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.ctx:()Lio/netty/channel/ChannelHandlerContext;
astore 2
start local 2 1: aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
astore 3
start local 3 2: aload 3
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifeq 4
3: aload 0
aload 2
aload 1
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.finishEncode:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
4: StackMap locals: io.netty.channel.ChannelHandlerContext io.netty.util.concurrent.EventExecutor
StackMap stack:
aload 3
new io.netty.handler.codec.compression.Lz4FrameEncoder$1
dup
aload 0
aload 1
invokespecial io.netty.handler.codec.compression.Lz4FrameEncoder$1.<init>:(Lio/netty/handler/codec/compression/Lz4FrameEncoder;Lio/netty/channel/ChannelPromise;)V
invokeinterface io.netty.util.concurrent.EventExecutor.execute:(Ljava/lang/Runnable;)V
5: aload 1
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 6 1 promise Lio/netty/channel/ChannelPromise;
1 6 2 ctx Lio/netty/channel/ChannelHandlerContext;
2 6 3 executor Lio/netty/util/concurrent/EventExecutor;
MethodParameters:
Name Flags
promise final
public void close(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.finishEncode:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
astore 3
start local 3 1: aload 3
new io.netty.handler.codec.compression.Lz4FrameEncoder$2
dup
aload 0
aload 1
aload 2
invokespecial io.netty.handler.codec.compression.Lz4FrameEncoder$2.<init>:(Lio/netty/handler/codec/compression/Lz4FrameEncoder;Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V
invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
pop
2: aload 3
invokeinterface io.netty.channel.ChannelFuture.isDone:()Z
ifne 6
3: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
new io.netty.handler.codec.compression.Lz4FrameEncoder$3
dup
aload 0
aload 1
aload 2
invokespecial io.netty.handler.codec.compression.Lz4FrameEncoder$3.<init>:(Lio/netty/handler/codec/compression/Lz4FrameEncoder;Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V
4: ldc 10
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
5: invokeinterface io.netty.util.concurrent.EventExecutor.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture;
pop
6: StackMap locals: io.netty.channel.ChannelFuture
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 7 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 7 2 promise Lio/netty/channel/ChannelPromise;
1 7 3 f Lio/netty/channel/ChannelFuture;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx final
promise final
private io.netty.channel.ChannelHandlerContext ctx();
descriptor: ()Lio/netty/channel/ChannelHandlerContext;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.ctx:Lio/netty/channel/ChannelHandlerContext;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: new java.lang.IllegalStateException
dup
ldc "not added to a pipeline"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: io.netty.channel.ChannelHandlerContext
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
1 4 1 ctx Lio/netty/channel/ChannelHandlerContext;
public void handlerAdded(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.ctx:Lio/netty/channel/ChannelHandlerContext;
1: aload 0
aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.blockSize:I
newarray 8
invokestatic io.netty.buffer.Unpooled.wrappedBuffer:([B)Lio/netty/buffer/ByteBuf;
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
2: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.clear:()Lio/netty/buffer/ByteBuf;
pop
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 4 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
public void handlerRemoved(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.netty.handler.codec.MessageToByteEncoder.handlerRemoved:(Lio/netty/channel/ChannelHandlerContext;)V
1: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
ifnull 4
2: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
3: aload 0
aconst_null
putfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
0 5 1 ctx Lio/netty/channel/ChannelHandlerContext;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
final io.netty.buffer.ByteBuf getBackingBuffer();
descriptor: ()Lio/netty/buffer/ByteBuf;
flags: (0x0010) ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.handler.codec.compression.Lz4FrameEncoder.buffer:Lio/netty/buffer/ByteBuf;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/compression/Lz4FrameEncoder;
protected io.netty.buffer.ByteBuf allocateBuffer(io.netty.channel.ChannelHandlerContext, java.lang.Object, boolean);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Z)Lio/netty/buffer/ByteBuf;
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
checkcast io.netty.buffer.ByteBuf
iload 3
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.allocateBuffer:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;Z)Lio/netty/buffer/ByteBuf;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
protected void encode(io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/buffer/ByteBuf;)V
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
checkcast io.netty.buffer.ByteBuf
aload 3
invokevirtual io.netty.handler.codec.compression.Lz4FrameEncoder.encode:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
}
Signature: Lio/netty/handler/codec/MessageToByteEncoder<Lio/netty/buffer/ByteBuf;>;
SourceFile: "Lz4FrameEncoder.java"
NestMembers:
io.netty.handler.codec.compression.Lz4FrameEncoder$1 io.netty.handler.codec.compression.Lz4FrameEncoder$2 io.netty.handler.codec.compression.Lz4FrameEncoder$3
InnerClasses:
io.netty.handler.codec.compression.Lz4FrameEncoder$1
io.netty.handler.codec.compression.Lz4FrameEncoder$2
io.netty.handler.codec.compression.Lz4FrameEncoder$3