io.netty/netty-all/4.1.25.Final : io/netty/handler/codec/compression/Bzip2Encoder.class

Bzip2Encoder
http://netty.io/netty-all/: Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers and clients. (The Netty Project)
Apache License, Version 2.0
The Netty Project Contributors (The Netty Project)
public class io.netty.handler.codec.compression.Bzip2Encoder 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.Bzip2Encoder
  super_class: io.netty.handler.codec.MessageToByteEncoder
{
  private io.netty.handler.codec.compression.Bzip2Encoder$State currentState;
    descriptor: Lio/netty/handler/codec/compression/Bzip2Encoder$State;
    flags: (0x0002) ACC_PRIVATE

  private final io.netty.handler.codec.compression.Bzip2BitWriter writer;
    descriptor: Lio/netty/handler/codec/compression/Bzip2BitWriter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int streamBlockSize;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private int streamCRC;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private io.netty.handler.codec.compression.Bzip2BlockCompressor blockCompressor;
    descriptor: Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
    flags: (0x0002) ACC_PRIVATE

  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

  private static volatile int[] $SWITCH_TABLE$io$netty$handler$codec$compression$Bzip2Encoder$State;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
         0: .line 84
            aload 0 /* this */
            bipush 9
            invokespecial io.netty.handler.codec.compression.Bzip2Encoder.<init>:(I)V
         1: .line 85
            return
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/handler/codec/compression/Bzip2Encoder;

  public void <init>(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // int blockSizeMultiplier
         0: .line 94
            aload 0 /* this */
            invokespecial io.netty.handler.codec.MessageToByteEncoder.<init>:()V
         1: .line 48
            aload 0 /* this */
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.INIT:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            putfield io.netty.handler.codec.compression.Bzip2Encoder.currentState:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
         2: .line 53
            aload 0 /* this */
            new io.netty.handler.codec.compression.Bzip2BitWriter
            dup
            invokespecial io.netty.handler.codec.compression.Bzip2BitWriter.<init>:()V
            putfield io.netty.handler.codec.compression.Bzip2Encoder.writer:Lio/netty/handler/codec/compression/Bzip2BitWriter;
         3: .line 95
            iload 1 /* blockSizeMultiplier */
            iconst_1
            if_icmplt 4
            iload 1 /* blockSizeMultiplier */
            bipush 9
            if_icmple 7
         4: .line 96
      StackMap locals: io.netty.handler.codec.compression.Bzip2Encoder int
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
         5: .line 97
            new java.lang.StringBuilder
            dup
            ldc "blockSizeMultiplier: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 1 /* blockSizeMultiplier */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " (expected: 1-9)"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         6: .line 96
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         7: .line 99
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* blockSizeMultiplier */
            ldc 100000
            imul
            putfield io.netty.handler.codec.compression.Bzip2Encoder.streamBlockSize:I
         8: .line 100
            return
        end local 1 // int blockSizeMultiplier
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    9     0                 this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            0    9     1  blockSizeMultiplier  I
    MethodParameters:
                     Name  Flags
      blockSizeMultiplier  final

  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=5, locals=7, args_size=4
        start local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.buffer.ByteBuf in
        start local 3 // io.netty.buffer.ByteBuf out
         0: .line 104
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.finished:Z
            ifeq 3
         1: .line 105
            aload 3 /* out */
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.writeBytes:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
            pop
         2: .line 106
            return
         3: .line 110
      StackMap locals:
      StackMap stack:
            invokestatic io.netty.handler.codec.compression.Bzip2Encoder.$SWITCH_TABLE$io$netty$handler$codec$compression$Bzip2Encoder$State:()[I
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.currentState:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder$State.ordinal:()I
            iaload
            tableswitch { // 1 - 4
                    1: 4
                    2: 8
                    3: 10
                    4: 21
              default: 24
          }
         4: .line 112
      StackMap locals:
      StackMap stack:
            aload 3 /* out */
            iconst_4
            invokevirtual io.netty.buffer.ByteBuf.ensureWritable:(I)Lio/netty/buffer/ByteBuf;
            pop
         5: .line 113
            aload 3 /* out */
            ldc 4348520
            invokevirtual io.netty.buffer.ByteBuf.writeMedium:(I)Lio/netty/buffer/ByteBuf;
            pop
         6: .line 114
            aload 3 /* out */
            bipush 48
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.streamBlockSize:I
            ldc 100000
            idiv
            iadd
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         7: .line 115
            aload 0 /* this */
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.INIT_BLOCK:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            putfield io.netty.handler.codec.compression.Bzip2Encoder.currentState:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
         8: .line 118
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new io.netty.handler.codec.compression.Bzip2BlockCompressor
            dup
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.writer:Lio/netty/handler/codec/compression/Bzip2BitWriter;
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.streamBlockSize:I
            invokespecial io.netty.handler.codec.compression.Bzip2BlockCompressor.<init>:(Lio/netty/handler/codec/compression/Bzip2BitWriter;I)V
            putfield io.netty.handler.codec.compression.Bzip2Encoder.blockCompressor:Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
         9: .line 119
            aload 0 /* this */
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.WRITE_DATA:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            putfield io.netty.handler.codec.compression.Bzip2Encoder.currentState:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
        10: .line 122
      StackMap locals:
      StackMap stack:
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
            ifne 12
        11: .line 123
            return
        12: .line 125
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.blockCompressor:Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
            astore 4 /* blockCompressor */
        start local 4 // io.netty.handler.codec.compression.Bzip2BlockCompressor blockCompressor
        13: .line 126
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            aload 4 /* blockCompressor */
            invokevirtual io.netty.handler.codec.compression.Bzip2BlockCompressor.availableSize:()I
            invokestatic java.lang.Math.min:(II)I
            istore 5 /* length */
        start local 5 // int length
        14: .line 127
            aload 4 /* blockCompressor */
            aload 2 /* in */
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
            iload 5 /* length */
            invokevirtual io.netty.handler.codec.compression.Bzip2BlockCompressor.write:(Lio/netty/buffer/ByteBuf;II)I
            istore 6 /* bytesWritten */
        start local 6 // int bytesWritten
        15: .line 128
            aload 2 /* in */
            iload 6 /* bytesWritten */
            invokevirtual io.netty.buffer.ByteBuf.skipBytes:(I)Lio/netty/buffer/ByteBuf;
            pop
        16: .line 129
            aload 4 /* blockCompressor */
            invokevirtual io.netty.handler.codec.compression.Bzip2BlockCompressor.isFull:()Z
            ifne 20
        17: .line 130
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
            ifeq 19
        18: .line 131
            goto 3
        19: .line 133
      StackMap locals: io.netty.handler.codec.compression.Bzip2BlockCompressor int int
      StackMap stack:
            return
        20: .line 136
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.CLOSE_BLOCK:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            putfield io.netty.handler.codec.compression.Bzip2Encoder.currentState:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
        end local 6 // int bytesWritten
        end local 5 // int length
        end local 4 // io.netty.handler.codec.compression.Bzip2BlockCompressor blockCompressor
        21: .line 139
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* out */
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.closeBlock:(Lio/netty/buffer/ByteBuf;)V
        22: .line 140
            aload 0 /* this */
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.INIT_BLOCK:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            putfield io.netty.handler.codec.compression.Bzip2Encoder.currentState:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
        23: .line 141
            goto 3
        24: .line 143
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            invokespecial java.lang.IllegalStateException.<init>:()V
            athrow
        end local 3 // io.netty.buffer.ByteBuf out
        end local 2 // io.netty.buffer.ByteBuf in
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   25     0             this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            0   25     1              ctx  Lio/netty/channel/ChannelHandlerContext;
            0   25     2               in  Lio/netty/buffer/ByteBuf;
            0   25     3              out  Lio/netty/buffer/ByteBuf;
           13   21     4  blockCompressor  Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
           14   21     5           length  I
           15   21     6     bytesWritten  I
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   
      in    
      out   

  private void closeBlock(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // io.netty.buffer.ByteBuf out
         0: .line 152
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.blockCompressor:Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
            astore 2 /* blockCompressor */
        start local 2 // io.netty.handler.codec.compression.Bzip2BlockCompressor blockCompressor
         1: .line 153
            aload 2 /* blockCompressor */
            invokevirtual io.netty.handler.codec.compression.Bzip2BlockCompressor.isEmpty:()Z
            ifne 5
         2: .line 154
            aload 2 /* blockCompressor */
            aload 1 /* out */
            invokevirtual io.netty.handler.codec.compression.Bzip2BlockCompressor.close:(Lio/netty/buffer/ByteBuf;)V
         3: .line 155
            aload 2 /* blockCompressor */
            invokevirtual io.netty.handler.codec.compression.Bzip2BlockCompressor.crc:()I
            istore 3 /* blockCRC */
        start local 3 // int blockCRC
         4: .line 156
            aload 0 /* this */
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.streamCRC:I
            iconst_1
            ishl
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.streamCRC:I
            bipush 31
            iushr
            ior
            iload 3 /* blockCRC */
            ixor
            putfield io.netty.handler.codec.compression.Bzip2Encoder.streamCRC:I
        end local 3 // int blockCRC
         5: .line 158
      StackMap locals: io.netty.handler.codec.compression.Bzip2BlockCompressor
      StackMap stack:
            return
        end local 2 // io.netty.handler.codec.compression.Bzip2BlockCompressor blockCompressor
        end local 1 // io.netty.buffer.ByteBuf out
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0             this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            0    6     1              out  Lio/netty/buffer/ByteBuf;
            1    6     2  blockCompressor  Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
            4    5     3         blockCRC  I
    MethodParameters:
      Name  Flags
      out   

  public boolean isClosed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
         0: .line 164
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.finished:Z
            ireturn
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/codec/compression/Bzip2Encoder;

  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 // io.netty.handler.codec.compression.Bzip2Encoder this
         0: .line 173
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.ctx:()Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.newPromise:()Lio/netty/channel/ChannelPromise;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.close:(Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            areturn
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/codec/compression/Bzip2Encoder;

  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 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // io.netty.channel.ChannelPromise promise
         0: .line 182
            aload 0 /* this */
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.ctx:()Lio/netty/channel/ChannelHandlerContext;
            astore 2 /* ctx */
        start local 2 // io.netty.channel.ChannelHandlerContext ctx
         1: .line 183
            aload 2 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            astore 3 /* executor */
        start local 3 // io.netty.util.concurrent.EventExecutor executor
         2: .line 184
            aload 3 /* executor */
            invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
            ifeq 4
         3: .line 185
            aload 0 /* this */
            aload 2 /* ctx */
            aload 1 /* promise */
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.finishEncode:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            areturn
         4: .line 187
      StackMap locals: io.netty.channel.ChannelHandlerContext io.netty.util.concurrent.EventExecutor
      StackMap stack:
            aload 3 /* executor */
            new io.netty.handler.codec.compression.Bzip2Encoder$1
            dup
            aload 0 /* this */
            aload 1 /* promise */
            invokespecial io.netty.handler.codec.compression.Bzip2Encoder$1.<init>:(Lio/netty/handler/codec/compression/Bzip2Encoder;Lio/netty/channel/ChannelPromise;)V
            invokeinterface io.netty.util.concurrent.EventExecutor.execute:(Ljava/lang/Runnable;)V
         5: .line 194
            aload 1 /* promise */
            areturn
        end local 3 // io.netty.util.concurrent.EventExecutor executor
        end local 2 // io.netty.channel.ChannelHandlerContext ctx
        end local 1 // io.netty.channel.ChannelPromise promise
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    6     0      this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            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 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.channel.ChannelPromise promise
         0: .line 200
            aload 0 /* this */
            aload 1 /* ctx */
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.newPromise:()Lio/netty/channel/ChannelPromise;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.finishEncode:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            astore 3 /* f */
        start local 3 // io.netty.channel.ChannelFuture f
         1: .line 201
            aload 3 /* f */
            new io.netty.handler.codec.compression.Bzip2Encoder$2
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* promise */
            invokespecial io.netty.handler.codec.compression.Bzip2Encoder$2.<init>:(Lio/netty/handler/codec/compression/Bzip2Encoder;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: .line 208
            aload 3 /* f */
            invokeinterface io.netty.channel.ChannelFuture.isDone:()Z
            ifne 6
         3: .line 210
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            new io.netty.handler.codec.compression.Bzip2Encoder$3
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* promise */
            invokespecial io.netty.handler.codec.compression.Bzip2Encoder$3.<init>:(Lio/netty/handler/codec/compression/Bzip2Encoder;Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V
         4: .line 215
            ldc 10
            getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
         5: .line 210
            invokeinterface io.netty.util.concurrent.EventExecutor.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture;
            pop
         6: .line 217
      StackMap locals: io.netty.channel.ChannelFuture
      StackMap stack:
            return
        end local 3 // io.netty.channel.ChannelFuture f
        end local 2 // io.netty.channel.ChannelPromise promise
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            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.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=5, locals=7, args_size=3
        start local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.channel.ChannelPromise promise
         0: .line 220
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.finished:Z
            ifeq 3
         1: .line 221
            aload 2 /* promise */
            invokeinterface io.netty.channel.ChannelPromise.setSuccess:()Lio/netty/channel/ChannelPromise;
            pop
         2: .line 222
            aload 2 /* promise */
            areturn
         3: .line 224
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.netty.handler.codec.compression.Bzip2Encoder.finished:Z
         4: .line 226
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
            invokeinterface io.netty.buffer.ByteBufAllocator.buffer:()Lio/netty/buffer/ByteBuf;
            astore 3 /* footer */
        start local 3 // io.netty.buffer.ByteBuf footer
         5: .line 227
            aload 0 /* this */
            aload 3 /* footer */
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.closeBlock:(Lio/netty/buffer/ByteBuf;)V
         6: .line 229
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.streamCRC:I
            istore 4 /* streamCRC */
        start local 4 // int streamCRC
         7: .line 230
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.writer:Lio/netty/handler/codec/compression/Bzip2BitWriter;
            astore 5 /* writer */
        start local 5 // io.netty.handler.codec.compression.Bzip2BitWriter writer
         8: .line 232
            aload 5 /* writer */
            aload 3 /* footer */
            bipush 24
            ldc 1536581
            invokevirtual io.netty.handler.codec.compression.Bzip2BitWriter.writeBits:(Lio/netty/buffer/ByteBuf;IJ)V
         9: .line 233
            aload 5 /* writer */
            aload 3 /* footer */
            bipush 24
            ldc 3690640
            invokevirtual io.netty.handler.codec.compression.Bzip2BitWriter.writeBits:(Lio/netty/buffer/ByteBuf;IJ)V
        10: .line 234
            aload 5 /* writer */
            aload 3 /* footer */
            iload 4 /* streamCRC */
            invokevirtual io.netty.handler.codec.compression.Bzip2BitWriter.writeInt:(Lio/netty/buffer/ByteBuf;I)V
        11: .line 235
            aload 5 /* writer */
            aload 3 /* footer */
            invokevirtual io.netty.handler.codec.compression.Bzip2BitWriter.flush:(Lio/netty/buffer/ByteBuf;)V
        12: .line 236
            goto 16
      StackMap locals: io.netty.handler.codec.compression.Bzip2Encoder io.netty.channel.ChannelHandlerContext io.netty.channel.ChannelPromise io.netty.buffer.ByteBuf int io.netty.handler.codec.compression.Bzip2BitWriter
      StackMap stack: java.lang.Throwable
        13: astore 6
        14: .line 237
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.codec.compression.Bzip2Encoder.blockCompressor:Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
        15: .line 238
            aload 6
            athrow
        16: .line 237
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.codec.compression.Bzip2Encoder.blockCompressor:Lio/netty/handler/codec/compression/Bzip2BlockCompressor;
        17: .line 239
            aload 1 /* ctx */
            aload 3 /* footer */
            aload 2 /* promise */
            invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            areturn
        end local 5 // io.netty.handler.codec.compression.Bzip2BitWriter writer
        end local 4 // int streamCRC
        end local 3 // io.netty.buffer.ByteBuf footer
        end local 2 // io.netty.channel.ChannelPromise promise
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   18     0       this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            0   18     1        ctx  Lio/netty/channel/ChannelHandlerContext;
            0   18     2    promise  Lio/netty/channel/ChannelPromise;
            5   18     3     footer  Lio/netty/buffer/ByteBuf;
            7   18     4  streamCRC  I
            8   18     5     writer  Lio/netty/handler/codec/compression/Bzip2BitWriter;
      Exception table:
        from    to  target  type
           8    13      13  any
    MethodParameters:
         Name  Flags
      ctx      final
      promise  

  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 // io.netty.handler.codec.compression.Bzip2Encoder this
         0: .line 243
            aload 0 /* this */
            getfield io.netty.handler.codec.compression.Bzip2Encoder.ctx:Lio/netty/channel/ChannelHandlerContext;
            astore 1 /* ctx */
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         1: .line 244
            aload 1 /* ctx */
            ifnonnull 3
         2: .line 245
            new java.lang.IllegalStateException
            dup
            ldc "not added to a pipeline"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 247
      StackMap locals: io.netty.channel.ChannelHandlerContext
      StackMap stack:
            aload 1 /* ctx */
            areturn
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            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 // io.netty.handler.codec.compression.Bzip2Encoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 252
            aload 0 /* this */
            aload 1 /* ctx */
            putfield io.netty.handler.codec.compression.Bzip2Encoder.ctx:Lio/netty/channel/ChannelHandlerContext;
         1: .line 253
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.codec.compression.Bzip2Encoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/handler/codec/compression/Bzip2Encoder;
            0    2     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  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: .line 1
            aload 0
            aload 1
            aload 2
            checkcast io.netty.buffer.ByteBuf
            aload 3
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder.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

  static int[] $SWITCH_TABLE$io$netty$handler$codec$compression$Bzip2Encoder$State();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 37
            getstatic io.netty.handler.codec.compression.Bzip2Encoder.$SWITCH_TABLE$io$netty$handler$codec$compression$Bzip2Encoder$State:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic io.netty.handler.codec.compression.Bzip2Encoder$State.values:()[Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.CLOSE_BLOCK:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder$State.ordinal:()I
            iconst_4
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.INIT:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder$State.ordinal:()I
            iconst_1
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.INIT_BLOCK:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder$State.ordinal:()I
            iconst_2
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic io.netty.handler.codec.compression.Bzip2Encoder$State.WRITE_DATA:Lio/netty/handler/codec/compression/Bzip2Encoder$State;
            invokevirtual io.netty.handler.codec.compression.Bzip2Encoder$State.ordinal:()I
            iconst_3
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            dup
            putstatic io.netty.handler.codec.compression.Bzip2Encoder.$SWITCH_TABLE$io$netty$handler$codec$compression$Bzip2Encoder$State:[I
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.NoSuchFieldError
           5     6       7  Class java.lang.NoSuchFieldError
           8     9      10  Class java.lang.NoSuchFieldError
          11    12      13  Class java.lang.NoSuchFieldError
}
Signature: Lio/netty/handler/codec/MessageToByteEncoder<Lio/netty/buffer/ByteBuf;>;
SourceFile: "Bzip2Encoder.java"
NestMembers:
  io.netty.handler.codec.compression.Bzip2Encoder$1  io.netty.handler.codec.compression.Bzip2Encoder$2  io.netty.handler.codec.compression.Bzip2Encoder$3  io.netty.handler.codec.compression.Bzip2Encoder$State
InnerClasses:
  io.netty.handler.codec.compression.Bzip2Encoder$1
  io.netty.handler.codec.compression.Bzip2Encoder$2
  io.netty.handler.codec.compression.Bzip2Encoder$3
  private final State = io.netty.handler.codec.compression.Bzip2Encoder$State of io.netty.handler.codec.compression.Bzip2Encoder
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/handler/codec/compression/Bzip2Encoder.class
