io.netty/netty-all/4.1.25.Final : io/netty/channel/kqueue/KQueueDomainSocketChannel$KQueueDomainUnsafe.class

KQueueDomainSocketChannel$KQueueDomainUnsafe
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)
final class io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe extends io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe
  super_class: io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe
{
  final io.netty.channel.kqueue.KQueueDomainSocketChannel this$0;
    descriptor: Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  private static volatile int[] $SWITCH_TABLE$io$netty$channel$unix$DomainSocketReadMode;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  private void <init>(io.netty.channel.kqueue.KQueueDomainSocketChannel);
    descriptor: (Lio/netty/channel/kqueue/KQueueDomainSocketChannel;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe this
         0: .line 126
            aload 0 /* this */
            aload 1
            putfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
            aload 0 /* this */
            aload 1
            invokespecial io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe.<init>:(Lio/netty/channel/kqueue/AbstractKQueueStreamChannel;)V
            return
        end local 0 // io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/kqueue/KQueueDomainSocketChannel$KQueueDomainUnsafe;
    MethodParameters:
        Name  Flags
      this$0  final

  void readReady(io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle);
    descriptor: (Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe this
        start local 1 // io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle allocHandle
         0: .line 129
            invokestatic io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.$SWITCH_TABLE$io$netty$channel$unix$DomainSocketReadMode:()[I
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel.config:()Lio/netty/channel/kqueue/KQueueDomainSocketChannelConfig;
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannelConfig.getReadMode:()Lio/netty/channel/unix/DomainSocketReadMode;
            invokevirtual io.netty.channel.unix.DomainSocketReadMode.ordinal:()I
            iaload
            tableswitch { // 1 - 2
                    1: 1
                    2: 3
              default: 5
          }
         1: .line 131
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* allocHandle */
            invokespecial io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe.readReady:(Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;)V
         2: .line 132
            goto 6
         3: .line 134
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readReadyFd:()V
         4: .line 135
            goto 6
         5: .line 137
      StackMap locals:
      StackMap stack:
            new java.lang.Error
            dup
            invokespecial java.lang.Error.<init>:()V
            athrow
         6: .line 139
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle allocHandle
        end local 0 // io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0         this  Lio/netty/channel/kqueue/KQueueDomainSocketChannel$KQueueDomainUnsafe;
            0    7     1  allocHandle  Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;
    MethodParameters:
             Name  Flags
      allocHandle  

  private void readReadyFd();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=1
        start local 0 // io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe this
         0: .line 142
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
            invokevirtual io.netty.channel.kqueue.BsdSocket.isInputShutdown:()Z
            ifeq 3
         1: .line 143
            aload 0 /* this */
            invokespecial io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe.clearReadFilter0:()V
         2: .line 144
            return
         3: .line 146
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel.config:()Lio/netty/channel/kqueue/KQueueDomainSocketChannelConfig;
            astore 1 /* config */
        start local 1 // io.netty.channel.ChannelConfig config
         4: .line 147
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.recvBufAllocHandle:()Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;
            astore 2 /* allocHandle */
        start local 2 // io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle allocHandle
         5: .line 149
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel.pipeline:()Lio/netty/channel/ChannelPipeline;
            astore 3 /* pipeline */
        start local 3 // io.netty.channel.ChannelPipeline pipeline
         6: .line 150
            aload 2 /* allocHandle */
            aload 1 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.reset:(Lio/netty/channel/ChannelConfig;)V
         7: .line 151
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readReadyBefore:()V
         8: .line 158
      StackMap locals: io.netty.channel.ChannelConfig io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle io.netty.channel.ChannelPipeline
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDomainSocketChannel;
            getfield io.netty.channel.kqueue.KQueueDomainSocketChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
            invokevirtual io.netty.channel.kqueue.BsdSocket.recvFd:()I
            istore 4 /* recvFd */
        start local 4 // int recvFd
         9: .line 159
            iload 4 /* recvFd */
            tableswitch { // -1 - 0
                   -1: 12
                    0: 10
              default: 16
          }
        10: .line 161
      StackMap locals: int
      StackMap stack:
            aload 2 /* allocHandle */
            iconst_0
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.lastBytesRead:(I)V
        11: .line 162
            goto 21
        12: .line 164
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            iconst_m1
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.lastBytesRead:(I)V
        13: .line 165
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.voidPromise:()Lio/netty/channel/ChannelPromise;
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.close:(Lio/netty/channel/ChannelPromise;)V
        14: .line 183
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readReadyFinally:(Lio/netty/channel/ChannelConfig;)V
        15: .line 166
            return
        16: .line 168
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            iconst_1
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.lastBytesRead:(I)V
        17: .line 169
            aload 2 /* allocHandle */
            iconst_1
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.incMessagesRead:(I)V
        18: .line 170
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readPending:Z
        19: .line 171
            aload 3 /* pipeline */
            new io.netty.channel.unix.FileDescriptor
            dup
            iload 4 /* recvFd */
            invokespecial io.netty.channel.unix.FileDescriptor.<init>:(I)V
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelPipeline;
            pop
        end local 4 // int recvFd
        20: .line 174
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.continueReading:()Z
            ifne 8
        21: .line 176
      StackMap locals:
      StackMap stack:
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.readComplete:()V
        22: .line 177
            aload 3 /* pipeline */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelReadComplete:()Lio/netty/channel/ChannelPipeline;
            pop
        23: .line 178
            goto 32
      StackMap locals:
      StackMap stack: java.lang.Throwable
        24: astore 4 /* t */
        start local 4 // java.lang.Throwable t
        25: .line 179
            aload 2 /* allocHandle */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.readComplete:()V
        26: .line 180
            aload 3 /* pipeline */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelReadComplete:()Lio/netty/channel/ChannelPipeline;
            pop
        27: .line 181
            aload 3 /* pipeline */
            aload 4 /* t */
            invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
            pop
        end local 4 // java.lang.Throwable t
        28: .line 183
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readReadyFinally:(Lio/netty/channel/ChannelConfig;)V
            goto 33
        29: .line 182
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 5
        30: .line 183
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readReadyFinally:(Lio/netty/channel/ChannelConfig;)V
        31: .line 184
            aload 5
            athrow
        32: .line 183
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.readReadyFinally:(Lio/netty/channel/ChannelConfig;)V
        33: .line 185
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.netty.channel.ChannelPipeline pipeline
        end local 2 // io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle allocHandle
        end local 1 // io.netty.channel.ChannelConfig config
        end local 0 // io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   34     0         this  Lio/netty/channel/kqueue/KQueueDomainSocketChannel$KQueueDomainUnsafe;
            4   34     1       config  Lio/netty/channel/ChannelConfig;
            5   34     2  allocHandle  Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;
            6   34     3     pipeline  Lio/netty/channel/ChannelPipeline;
            9   20     4       recvFd  I
           25   28     4            t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           8    14      24  Class java.lang.Throwable
          16    23      24  Class java.lang.Throwable
           8    14      29  any
          16    28      29  any

  static int[] $SWITCH_TABLE$io$netty$channel$unix$DomainSocketReadMode();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 126
            getstatic io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.$SWITCH_TABLE$io$netty$channel$unix$DomainSocketReadMode:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic io.netty.channel.unix.DomainSocketReadMode.values:()[Lio/netty/channel/unix/DomainSocketReadMode;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic io.netty.channel.unix.DomainSocketReadMode.BYTES:Lio/netty/channel/unix/DomainSocketReadMode;
            invokevirtual io.netty.channel.unix.DomainSocketReadMode.ordinal:()I
            iconst_1
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic io.netty.channel.unix.DomainSocketReadMode.FILE_DESCRIPTORS:Lio/netty/channel/unix/DomainSocketReadMode;
            invokevirtual io.netty.channel.unix.DomainSocketReadMode.ordinal:()I
            iconst_2
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            dup
            putstatic io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe.$SWITCH_TABLE$io$netty$channel$unix$DomainSocketReadMode:[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
}
SourceFile: "KQueueDomainSocketChannel.java"
NestHost: io.netty.channel.kqueue.KQueueDomainSocketChannel
InnerClasses:
  KQueueStreamUnsafe = io.netty.channel.kqueue.AbstractKQueueStreamChannel$KQueueStreamUnsafe of io.netty.channel.kqueue.AbstractKQueueStreamChannel
  private final KQueueDomainUnsafe = io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe of io.netty.channel.kqueue.KQueueDomainSocketChannel
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/channel/kqueue/KQueueDomainSocketChannel$KQueueDomainUnsafe.class
