io.netty/netty-all/4.1.25.Final : io/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe.class

AbstractEpollStreamChannel$EpollStreamUnsafe
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)
class io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe extends io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe
  super_class: io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe
{
  final io.netty.channel.epoll.AbstractEpollStreamChannel this$0;
    descriptor: Lio/netty/channel/epoll/AbstractEpollStreamChannel;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  void <init>(io.netty.channel.epoll.AbstractEpollStreamChannel);
    descriptor: (Lio/netty/channel/epoll/AbstractEpollStreamChannel;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
         0: .line 726
            aload 0 /* this */
            aload 1
            putfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            aload 0 /* this */
            aload 1
            invokespecial io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.<init>:(Lio/netty/channel/epoll/AbstractEpollChannel;)V
            return
        end local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe;
    MethodParameters:
        Name  Flags
      this$0  final

  protected java.util.concurrent.Executor prepareToClose();
    descriptor: ()Ljava/util/concurrent/Executor;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
         0: .line 730
            aload 0 /* this */
            invokespecial io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.prepareToClose:()Ljava/util/concurrent/Executor;
            areturn
        end local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe;

  private void handleReadException(io.netty.channel.ChannelPipeline, io.netty.buffer.ByteBuf, java.lang.Throwable, boolean, io.netty.channel.epoll.EpollRecvByteAllocatorHandle);
    descriptor: (Lio/netty/channel/ChannelPipeline;Lio/netty/buffer/ByteBuf;Ljava/lang/Throwable;ZLio/netty/channel/epoll/EpollRecvByteAllocatorHandle;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=6, args_size=6
        start local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
        start local 1 // io.netty.channel.ChannelPipeline pipeline
        start local 2 // io.netty.buffer.ByteBuf byteBuf
        start local 3 // java.lang.Throwable cause
        start local 4 // boolean close
        start local 5 // io.netty.channel.epoll.EpollRecvByteAllocatorHandle allocHandle
         0: .line 735
            aload 2 /* byteBuf */
            ifnull 6
         1: .line 736
            aload 2 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
            ifeq 5
         2: .line 737
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.readPending:Z
         3: .line 738
            aload 1 /* pipeline */
            aload 2 /* byteBuf */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelPipeline;
            pop
         4: .line 739
            goto 6
         5: .line 740
      StackMap locals:
      StackMap stack:
            aload 2 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
         6: .line 743
      StackMap locals:
      StackMap stack:
            aload 5 /* allocHandle */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.readComplete:()V
         7: .line 744
            aload 1 /* pipeline */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelReadComplete:()Lio/netty/channel/ChannelPipeline;
            pop
         8: .line 745
            aload 1 /* pipeline */
            aload 3 /* cause */
            invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
            pop
         9: .line 746
            iload 4 /* close */
            ifne 10
            aload 3 /* cause */
            instanceof java.io.IOException
            ifeq 11
        10: .line 747
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_0
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.shutdownInput:(Z)V
        11: .line 749
      StackMap locals:
      StackMap stack:
            return
        end local 5 // io.netty.channel.epoll.EpollRecvByteAllocatorHandle allocHandle
        end local 4 // boolean close
        end local 3 // java.lang.Throwable cause
        end local 2 // io.netty.buffer.ByteBuf byteBuf
        end local 1 // io.netty.channel.ChannelPipeline pipeline
        end local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   12     0         this  Lio/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe;
            0   12     1     pipeline  Lio/netty/channel/ChannelPipeline;
            0   12     2      byteBuf  Lio/netty/buffer/ByteBuf;
            0   12     3        cause  Ljava/lang/Throwable;
            0   12     4        close  Z
            0   12     5  allocHandle  Lio/netty/channel/epoll/EpollRecvByteAllocatorHandle;
    MethodParameters:
             Name  Flags
      pipeline     
      byteBuf      
      cause        
      close        
      allocHandle  

  io.netty.channel.epoll.EpollRecvByteAllocatorHandle newEpollHandle(io.netty.channel.RecvByteBufAllocator$ExtendedHandle);
    descriptor: (Lio/netty/channel/RecvByteBufAllocator$ExtendedHandle;)Lio/netty/channel/epoll/EpollRecvByteAllocatorHandle;
    flags: (0x0000) 
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
        start local 1 // io.netty.channel.RecvByteBufAllocator$ExtendedHandle handle
         0: .line 753
            new io.netty.channel.epoll.EpollRecvByteAllocatorStreamingHandle
            dup
            aload 1 /* handle */
            invokespecial io.netty.channel.epoll.EpollRecvByteAllocatorStreamingHandle.<init>:(Lio/netty/channel/RecvByteBufAllocator$ExtendedHandle;)V
            areturn
        end local 1 // io.netty.channel.RecvByteBufAllocator$ExtendedHandle handle
        end local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Lio/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe;
            0    1     1  handle  Lio/netty/channel/RecvByteBufAllocator$ExtendedHandle;
    MethodParameters:
        Name  Flags
      handle  

  void epollInReady();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=6, locals=9, args_size=1
        start local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
         0: .line 758
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.config:()Lio/netty/channel/epoll/EpollChannelConfig;
            astore 1 /* config */
        start local 1 // io.netty.channel.ChannelConfig config
         1: .line 759
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            aload 1 /* config */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.shouldBreakEpollInReady:(Lio/netty/channel/ChannelConfig;)Z
            ifeq 4
         2: .line 760
            aload 0 /* this */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.clearEpollIn0:()V
         3: .line 761
            return
         4: .line 763
      StackMap locals: io.netty.channel.ChannelConfig
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.recvBufAllocHandle:()Lio/netty/channel/epoll/EpollRecvByteAllocatorHandle;
            astore 2 /* allocHandle */
        start local 2 // io.netty.channel.epoll.EpollRecvByteAllocatorHandle allocHandle
         5: .line 764
            aload 2 /* allocHandle */
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            getstatic io.netty.channel.epoll.Native.EPOLLET:I
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.isFlagSet:(I)Z
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.edgeTriggered:(Z)V
         6: .line 766
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.pipeline:()Lio/netty/channel/ChannelPipeline;
            astore 3 /* pipeline */
        start local 3 // io.netty.channel.ChannelPipeline pipeline
         7: .line 767
            aload 1 /* config */
            invokeinterface io.netty.channel.ChannelConfig.getAllocator:()Lio/netty/buffer/ByteBufAllocator;
            astore 4 /* allocator */
        start local 4 // io.netty.buffer.ByteBufAllocator allocator
         8: .line 768
            aload 2 /* allocHandle */
            aload 1 /* config */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.reset:(Lio/netty/channel/ChannelConfig;)V
         9: .line 769
            aload 0 /* this */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInBefore:()V
        10: .line 771
            aconst_null
            astore 5 /* byteBuf */
        start local 5 // io.netty.buffer.ByteBuf byteBuf
        11: .line 772
            iconst_0
            istore 6 /* close */
        start local 6 // boolean close
        12: .line 775
      StackMap locals: io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe io.netty.channel.ChannelConfig io.netty.channel.epoll.EpollRecvByteAllocatorHandle io.netty.channel.ChannelPipeline io.netty.buffer.ByteBufAllocator io.netty.buffer.ByteBuf int
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel.spliceQueue:Ljava/util/Queue;
            ifnull 19
        13: .line 776
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel.spliceQueue:Ljava/util/Queue;
            invokeinterface java.util.Queue.peek:()Ljava/lang/Object;
            checkcast io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask
            astore 7 /* spliceTask */
        start local 7 // io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask spliceTask
        14: .line 777
            aload 7 /* spliceTask */
            ifnull 19
        15: .line 778
            aload 7 /* spliceTask */
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask.spliceIn:(Lio/netty/channel/RecvByteBufAllocator$Handle;)Z
            ifeq 37
        16: .line 781
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.isActive:()Z
            ifeq 36
        17: .line 782
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel.spliceQueue:Ljava/util/Queue;
            invokeinterface java.util.Queue.remove:()Ljava/lang/Object;
            pop
        18: .line 784
            goto 36
        end local 7 // io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask spliceTask
        19: .line 793
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            aload 4 /* allocator */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.allocate:(Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
            astore 5 /* byteBuf */
        20: .line 794
            aload 2 /* allocHandle */
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            aload 5 /* byteBuf */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.doReadBytes:(Lio/netty/buffer/ByteBuf;)I
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.lastBytesRead:(I)V
        21: .line 795
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.lastBytesRead:()I
            ifgt 30
        22: .line 797
            aload 5 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
        23: .line 798
            aconst_null
            astore 5 /* byteBuf */
        24: .line 799
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.lastBytesRead:()I
            ifge 25
            iconst_1
            goto 26
      StackMap locals:
      StackMap stack:
        25: iconst_0
      StackMap locals:
      StackMap stack: int
        26: istore 6 /* close */
        27: .line 800
            iload 6 /* close */
            ifeq 37
        28: .line 802
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.readPending:Z
        29: .line 804
            goto 37
        30: .line 806
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            iconst_1
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.incMessagesRead:(I)V
        31: .line 807
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.readPending:Z
        32: .line 808
            aload 3 /* pipeline */
            aload 5 /* byteBuf */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelPipeline;
            pop
        33: .line 809
            aconst_null
            astore 5 /* byteBuf */
        34: .line 811
            aload 0 /* this */
            getfield io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.this$0:Lio/netty/channel/epoll/AbstractEpollStreamChannel;
            aload 1 /* config */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel.shouldBreakEpollInReady:(Lio/netty/channel/ChannelConfig;)Z
            ifeq 36
        35: .line 823
            goto 37
        36: .line 825
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.continueReading:()Z
            ifne 12
        37: .line 827
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.epoll.EpollRecvByteAllocatorHandle.readComplete:()V
        38: .line 828
            aload 3 /* pipeline */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelReadComplete:()Lio/netty/channel/ChannelPipeline;
            pop
        39: .line 830
            iload 6 /* close */
            ifeq 48
        40: .line 831
            aload 0 /* this */
            iconst_0
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.shutdownInput:(Z)V
        41: .line 833
            goto 48
      StackMap locals:
      StackMap stack: java.lang.Throwable
        42: astore 7 /* t */
        start local 7 // java.lang.Throwable t
        43: .line 834
            aload 0 /* this */
            aload 3 /* pipeline */
            aload 5 /* byteBuf */
            aload 7 /* t */
            iload 6 /* close */
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.handleReadException:(Lio/netty/channel/ChannelPipeline;Lio/netty/buffer/ByteBuf;Ljava/lang/Throwable;ZLio/netty/channel/epoll/EpollRecvByteAllocatorHandle;)V
        end local 7 // java.lang.Throwable t
        44: .line 836
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInFinally:(Lio/netty/channel/ChannelConfig;)V
            goto 49
        45: .line 835
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 8
        46: .line 836
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInFinally:(Lio/netty/channel/ChannelConfig;)V
        47: .line 837
            aload 8
            athrow
        48: .line 836
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInFinally:(Lio/netty/channel/ChannelConfig;)V
        49: .line 838
      StackMap locals:
      StackMap stack:
            return
        end local 6 // boolean close
        end local 5 // io.netty.buffer.ByteBuf byteBuf
        end local 4 // io.netty.buffer.ByteBufAllocator allocator
        end local 3 // io.netty.channel.ChannelPipeline pipeline
        end local 2 // io.netty.channel.epoll.EpollRecvByteAllocatorHandle allocHandle
        end local 1 // io.netty.channel.ChannelConfig config
        end local 0 // io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   50     0         this  Lio/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe;
            1   50     1       config  Lio/netty/channel/ChannelConfig;
            5   50     2  allocHandle  Lio/netty/channel/epoll/EpollRecvByteAllocatorHandle;
            7   50     3     pipeline  Lio/netty/channel/ChannelPipeline;
            8   50     4    allocator  Lio/netty/buffer/ByteBufAllocator;
           11   50     5      byteBuf  Lio/netty/buffer/ByteBuf;
           12   50     6        close  Z
           14   19     7   spliceTask  Lio/netty/channel/epoll/AbstractEpollStreamChannel$SpliceInTask;
           43   44     7            t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          12    41      42  Class java.lang.Throwable
          12    44      45  any
}
SourceFile: "AbstractEpollStreamChannel.java"
NestHost: io.netty.channel.epoll.AbstractEpollStreamChannel
InnerClasses:
  public abstract ExtendedHandle = io.netty.channel.RecvByteBufAllocator$ExtendedHandle of io.netty.channel.RecvByteBufAllocator
  public abstract Handle = io.netty.channel.RecvByteBufAllocator$Handle of io.netty.channel.RecvByteBufAllocator
  protected abstract AbstractEpollUnsafe = io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe of io.netty.channel.epoll.AbstractEpollChannel
  EpollStreamUnsafe = io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe of io.netty.channel.epoll.AbstractEpollStreamChannel
  protected abstract SpliceInTask = io.netty.channel.epoll.AbstractEpollStreamChannel$SpliceInTask of io.netty.channel.epoll.AbstractEpollStreamChannel
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe.class
