io.netty/netty-all/4.1.25.Final : io/netty/channel/kqueue/KQueueDatagramChannel$KQueueDatagramChannelUnsafe.class

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

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 406
            ldc Lio/netty/channel/kqueue/KQueueDatagramChannel;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(io.netty.channel.kqueue.KQueueDatagramChannel);
    descriptor: (Lio/netty/channel/kqueue/KQueueDatagramChannel;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe this
         0: .line 406
            aload 0 /* this */
            aload 1
            putfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            aload 0 /* this */
            aload 1
            invokespecial io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe.<init>:(Lio/netty/channel/kqueue/AbstractKQueueChannel;)V
            return
        end local 0 // io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/kqueue/KQueueDatagramChannel$KQueueDatagramChannelUnsafe;
    MethodParameters:
        Name  Flags
      this$0  final

  void readReady(io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle);
    descriptor: (Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=10, args_size=2
        start local 0 // io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe this
        start local 1 // io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle allocHandle
         0: .line 410
            getstatic io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.eventLoop:()Lio/netty/channel/EventLoop;
            invokeinterface io.netty.channel.EventLoop.inEventLoop:()Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 411
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.config:()Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
            astore 2 /* config */
        start local 2 // io.netty.channel.socket.DatagramChannelConfig config
         2: .line 412
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            aload 2 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.shouldBreakReadReady:(Lio/netty/channel/ChannelConfig;)Z
            ifeq 5
         3: .line 413
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.clearReadFilter0:()V
         4: .line 414
            return
         5: .line 416
      StackMap locals: io.netty.channel.socket.DatagramChannelConfig
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.pipeline:()Lio/netty/channel/ChannelPipeline;
            astore 3 /* pipeline */
        start local 3 // io.netty.channel.ChannelPipeline pipeline
         6: .line 417
            aload 2 /* config */
            invokeinterface io.netty.channel.socket.DatagramChannelConfig.getAllocator:()Lio/netty/buffer/ByteBufAllocator;
            astore 4 /* allocator */
        start local 4 // io.netty.buffer.ByteBufAllocator allocator
         7: .line 418
            aload 1 /* allocHandle */
            aload 2 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.reset:(Lio/netty/channel/ChannelConfig;)V
         8: .line 419
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.readReadyBefore:()V
         9: .line 421
            aconst_null
            astore 5 /* exception */
        start local 5 // java.lang.Throwable exception
        10: .line 423
            aconst_null
            astore 6 /* data */
        start local 6 // io.netty.buffer.ByteBuf data
        11: .line 426
      StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle io.netty.channel.socket.DatagramChannelConfig io.netty.channel.ChannelPipeline io.netty.buffer.ByteBufAllocator java.lang.Throwable io.netty.buffer.ByteBuf
      StackMap stack:
            aload 1 /* allocHandle */
            aload 4 /* allocator */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.allocate:(Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
            astore 6 /* data */
        12: .line 427
            aload 1 /* allocHandle */
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.writableBytes:()I
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.attemptedBytesRead:(I)V
        13: .line 429
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.hasMemoryAddress:()Z
            ifeq 18
        14: .line 431
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.memoryAddress:()J
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
        15: .line 432
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.capacity:()I
        16: .line 431
            invokevirtual io.netty.channel.kqueue.BsdSocket.recvFromAddress:(JII)Lio/netty/channel/unix/DatagramSocketAddress;
            astore 7 /* remoteAddress */
        start local 7 // io.netty.channel.unix.DatagramSocketAddress remoteAddress
        17: .line 433
            goto 20
        end local 7 // io.netty.channel.unix.DatagramSocketAddress remoteAddress
        18: .line 434
      StackMap locals:
      StackMap stack:
            aload 6 /* data */
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.writableBytes:()I
            invokevirtual io.netty.buffer.ByteBuf.internalNioBuffer:(II)Ljava/nio/ByteBuffer;
            astore 8 /* nioData */
        start local 8 // java.nio.ByteBuffer nioData
        19: .line 435
            aload 0 /* this */
            getfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.this$0:Lio/netty/channel/kqueue/KQueueDatagramChannel;
            getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
            aload 8 /* nioData */
            aload 8 /* nioData */
            invokevirtual java.nio.ByteBuffer.position:()I
            aload 8 /* nioData */
            invokevirtual java.nio.ByteBuffer.limit:()I
            invokevirtual io.netty.channel.kqueue.BsdSocket.recvFrom:(Ljava/nio/ByteBuffer;II)Lio/netty/channel/unix/DatagramSocketAddress;
            astore 7 /* remoteAddress */
        end local 8 // java.nio.ByteBuffer nioData
        start local 7 // io.netty.channel.unix.DatagramSocketAddress remoteAddress
        20: .line 438
      StackMap locals: io.netty.channel.unix.DatagramSocketAddress
      StackMap stack:
            aload 7 /* remoteAddress */
            ifnonnull 25
        21: .line 439
            aload 1 /* allocHandle */
            iconst_m1
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.lastBytesRead:(I)V
        22: .line 440
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
        23: .line 441
            aconst_null
            astore 6 /* data */
        24: .line 442
            goto 39
        25: .line 445
      StackMap locals:
      StackMap stack:
            aload 1 /* allocHandle */
            iconst_1
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.incMessagesRead:(I)V
        26: .line 446
            aload 1 /* allocHandle */
            aload 7 /* remoteAddress */
            invokevirtual io.netty.channel.unix.DatagramSocketAddress.receivedAmount:()I
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.lastBytesRead:(I)V
        27: .line 447
            aload 6 /* data */
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            aload 1 /* allocHandle */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.lastBytesRead:()I
            iadd
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:(I)Lio/netty/buffer/ByteBuf;
            pop
        28: .line 449
            aload 0 /* this */
            iconst_0
            putfield io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.readPending:Z
        29: .line 450
            aload 3 /* pipeline */
        30: .line 451
            new io.netty.channel.socket.DatagramPacket
            dup
            aload 6 /* data */
            aload 0 /* this */
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.localAddress:()Ljava/net/SocketAddress;
            checkcast java.net.InetSocketAddress
            aload 7 /* remoteAddress */
            invokespecial io.netty.channel.socket.DatagramPacket.<init>:(Lio/netty/buffer/ByteBuf;Ljava/net/InetSocketAddress;Ljava/net/InetSocketAddress;)V
        31: .line 450
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelPipeline;
            pop
        32: .line 453
            aconst_null
            astore 6 /* data */
        end local 7 // io.netty.channel.unix.DatagramSocketAddress remoteAddress
        33: .line 454
            aload 1 /* allocHandle */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.continueReading:()Z
            ifne 11
        34: .line 455
            goto 39
      StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle io.netty.channel.socket.DatagramChannelConfig io.netty.channel.ChannelPipeline io.netty.buffer.ByteBufAllocator java.lang.Throwable io.netty.buffer.ByteBuf
      StackMap stack: java.lang.Throwable
        35: astore 7 /* t */
        start local 7 // java.lang.Throwable t
        36: .line 456
            aload 6 /* data */
            ifnull 38
        37: .line 457
            aload 6 /* data */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
        38: .line 459
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 7 /* t */
            astore 5 /* exception */
        end local 7 // java.lang.Throwable t
        39: .line 462
      StackMap locals:
      StackMap stack:
            aload 1 /* allocHandle */
            invokevirtual io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle.readComplete:()V
        40: .line 463
            aload 3 /* pipeline */
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelReadComplete:()Lio/netty/channel/ChannelPipeline;
            pop
        41: .line 465
            aload 5 /* exception */
            ifnull 47
        42: .line 466
            aload 3 /* pipeline */
            aload 5 /* exception */
            invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
            pop
        end local 6 // io.netty.buffer.ByteBuf data
        43: .line 468
            goto 47
      StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle io.netty.channel.socket.DatagramChannelConfig io.netty.channel.ChannelPipeline io.netty.buffer.ByteBufAllocator java.lang.Throwable
      StackMap stack: java.lang.Throwable
        44: astore 9
        45: .line 469
            aload 0 /* this */
            aload 2 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.readReadyFinally:(Lio/netty/channel/ChannelConfig;)V
        46: .line 470
            aload 9
            athrow
        47: .line 469
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* config */
            invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.readReadyFinally:(Lio/netty/channel/ChannelConfig;)V
        48: .line 471
            return
        end local 5 // java.lang.Throwable exception
        end local 4 // io.netty.buffer.ByteBufAllocator allocator
        end local 3 // io.netty.channel.ChannelPipeline pipeline
        end local 2 // io.netty.channel.socket.DatagramChannelConfig config
        end local 1 // io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle allocHandle
        end local 0 // io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   49     0           this  Lio/netty/channel/kqueue/KQueueDatagramChannel$KQueueDatagramChannelUnsafe;
            0   49     1    allocHandle  Lio/netty/channel/kqueue/KQueueRecvByteAllocatorHandle;
            2   49     2         config  Lio/netty/channel/socket/DatagramChannelConfig;
            6   49     3       pipeline  Lio/netty/channel/ChannelPipeline;
            7   49     4      allocator  Lio/netty/buffer/ByteBufAllocator;
           10   49     5      exception  Ljava/lang/Throwable;
           11   43     6           data  Lio/netty/buffer/ByteBuf;
           17   18     7  remoteAddress  Lio/netty/channel/unix/DatagramSocketAddress;
           20   33     7  remoteAddress  Lio/netty/channel/unix/DatagramSocketAddress;
           19   20     8        nioData  Ljava/nio/ByteBuffer;
           36   39     7              t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          11    34      35  Class java.lang.Throwable
          10    44      44  any
    MethodParameters:
             Name  Flags
      allocHandle  
}
SourceFile: "KQueueDatagramChannel.java"
NestHost: io.netty.channel.kqueue.KQueueDatagramChannel
InnerClasses:
  abstract AbstractKQueueUnsafe = io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe of io.netty.channel.kqueue.AbstractKQueueChannel
  final KQueueDatagramChannelUnsafe = io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe of io.netty.channel.kqueue.KQueueDatagramChannel
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/channel/kqueue/KQueueDatagramChannel$KQueueDatagramChannelUnsafe.class
