io.netty/netty-all/4.1.25.Final : io/netty/channel/udt/nio/NioUdtMessageConnectorChannel.class

NioUdtMessageConnectorChannel
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.channel.udt.nio.NioUdtMessageConnectorChannel extends io.netty.channel.nio.AbstractNioMessageChannel implements io.netty.channel.udt.UdtChannel
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel
  super_class: io.netty.channel.nio.AbstractNioMessageChannel
{
  private static final io.netty.util.internal.logging.InternalLogger logger;
    descriptor: Lio/netty/util/internal/logging/InternalLogger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final io.netty.channel.ChannelMetadata METADATA;
    descriptor: Lio/netty/channel/ChannelMetadata;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final io.netty.channel.udt.UdtChannelConfig config;
    descriptor: Lio/netty/channel/udt/UdtChannelConfig;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private static volatile int[] $SWITCH_TABLE$com$barchart$udt$StatusUDT;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 55
            ldc Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            invokestatic io.netty.util.internal.logging.InternalLoggerFactory.getInstance:(Ljava/lang/Class;)Lio/netty/util/internal/logging/InternalLogger;
         1: .line 54
            putstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.logger:Lio/netty/util/internal/logging/InternalLogger;
         2: .line 57
            new io.netty.channel.ChannelMetadata
            dup
            iconst_0
            invokespecial io.netty.channel.ChannelMetadata.<init>:(Z)V
            putstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.METADATA:Lio/netty/channel/ChannelMetadata;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 62
            aload 0 /* this */
            getstatic com.barchart.udt.TypeUDT.DATAGRAM:Lcom/barchart/udt/TypeUDT;
            invokespecial io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.<init>:(Lcom/barchart/udt/TypeUDT;)V
         1: .line 63
            return
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  public void <init>(io.netty.channel.Channel, com.barchart.udt.nio.SocketChannelUDT);
    descriptor: (Lio/netty/channel/Channel;Lcom/barchart/udt/nio/SocketChannelUDT;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=3
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // io.netty.channel.Channel parent
        start local 2 // com.barchart.udt.nio.SocketChannelUDT channelUDT
         0: .line 66
            aload 0 /* this */
            aload 1 /* parent */
            aload 2 /* channelUDT */
            iconst_1
            invokespecial io.netty.channel.nio.AbstractNioMessageChannel.<init>:(Lio/netty/channel/Channel;Ljava/nio/channels/SelectableChannel;I)V
         1: .line 68
            aload 2 /* channelUDT */
            iconst_0
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.configureBlocking:(Z)Ljava/nio/channels/SelectableChannel;
            pop
         2: .line 69
            invokestatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.$SWITCH_TABLE$com$barchart$udt$StatusUDT:()[I
            aload 2 /* channelUDT */
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.socketUDT:()Lcom/barchart/udt/SocketUDT;
            invokevirtual com.barchart.udt.SocketUDT.status:()Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            iaload
            tableswitch { // 1 - 2
                    1: 3
                    2: 3
              default: 5
          }
         3: .line 72
      StackMap locals: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel io.netty.channel.Channel com.barchart.udt.nio.SocketChannelUDT
      StackMap stack:
            aload 0 /* this */
            new io.netty.channel.udt.DefaultUdtChannelConfig
            dup
            aload 0 /* this */
            aload 2 /* channelUDT */
            iconst_1
            invokespecial io.netty.channel.udt.DefaultUdtChannelConfig.<init>:(Lio/netty/channel/udt/UdtChannel;Lcom/barchart/udt/nio/ChannelUDT;Z)V
            putfield io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.config:Lio/netty/channel/udt/UdtChannelConfig;
         4: .line 73
            goto 14
         5: .line 75
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new io.netty.channel.udt.DefaultUdtChannelConfig
            dup
            aload 0 /* this */
            aload 2 /* channelUDT */
            iconst_0
            invokespecial io.netty.channel.udt.DefaultUdtChannelConfig.<init>:(Lio/netty/channel/udt/UdtChannel;Lcom/barchart/udt/nio/ChannelUDT;Z)V
            putfield io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.config:Lio/netty/channel/udt/UdtChannelConfig;
         6: .line 78
            goto 14
      StackMap locals:
      StackMap stack: java.lang.Exception
         7: astore 3 /* e */
        start local 3 // java.lang.Exception e
         8: .line 80
            aload 2 /* channelUDT */
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.close:()V
         9: .line 81
            goto 13
      StackMap locals: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel io.netty.channel.Channel com.barchart.udt.nio.SocketChannelUDT java.lang.Exception
      StackMap stack: java.lang.Exception
        10: astore 4 /* e2 */
        start local 4 // java.lang.Exception e2
        11: .line 82
            getstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.logger:Lio/netty/util/internal/logging/InternalLogger;
            invokeinterface io.netty.util.internal.logging.InternalLogger.isWarnEnabled:()Z
            ifeq 13
        12: .line 83
            getstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.logger:Lio/netty/util/internal/logging/InternalLogger;
            ldc "Failed to close channel."
            aload 4 /* e2 */
            invokeinterface io.netty.util.internal.logging.InternalLogger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 4 // java.lang.Exception e2
        13: .line 86
      StackMap locals:
      StackMap stack:
            new io.netty.channel.ChannelException
            dup
            ldc "Failed to configure channel."
            aload 3 /* e */
            invokespecial io.netty.channel.ChannelException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 3 // java.lang.Exception e
        14: .line 88
      StackMap locals:
      StackMap stack:
            return
        end local 2 // com.barchart.udt.nio.SocketChannelUDT channelUDT
        end local 1 // io.netty.channel.Channel parent
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   15     0        this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0   15     1      parent  Lio/netty/channel/Channel;
            0   15     2  channelUDT  Lcom/barchart/udt/nio/SocketChannelUDT;
            8   14     3           e  Ljava/lang/Exception;
           11   13     4          e2  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           1     6       7  Class java.lang.Exception
           8     9      10  Class java.lang.Exception
    MethodParameters:
            Name  Flags
      parent      final
      channelUDT  final

  public void <init>(com.barchart.udt.nio.SocketChannelUDT);
    descriptor: (Lcom/barchart/udt/nio/SocketChannelUDT;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // com.barchart.udt.nio.SocketChannelUDT channelUDT
         0: .line 91
            aload 0 /* this */
            aconst_null
            aload 1 /* channelUDT */
            invokespecial io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.<init>:(Lio/netty/channel/Channel;Lcom/barchart/udt/nio/SocketChannelUDT;)V
         1: .line 92
            return
        end local 1 // com.barchart.udt.nio.SocketChannelUDT channelUDT
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0    2     1  channelUDT  Lcom/barchart/udt/nio/SocketChannelUDT;
    MethodParameters:
            Name  Flags
      channelUDT  final

  public void <init>(com.barchart.udt.TypeUDT);
    descriptor: (Lcom/barchart/udt/TypeUDT;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // com.barchart.udt.TypeUDT type
         0: .line 95
            aload 0 /* this */
            aload 1 /* type */
            invokestatic io.netty.channel.udt.nio.NioUdtProvider.newConnectorChannelUDT:(Lcom/barchart/udt/TypeUDT;)Lcom/barchart/udt/nio/SocketChannelUDT;
            invokespecial io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.<init>:(Lcom/barchart/udt/nio/SocketChannelUDT;)V
         1: .line 96
            return
        end local 1 // com.barchart.udt.TypeUDT type
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0    2     1  type  Lcom/barchart/udt/TypeUDT;
    MethodParameters:
      Name  Flags
      type  final

  public io.netty.channel.udt.UdtChannelConfig config();
    descriptor: ()Lio/netty/channel/udt/UdtChannelConfig;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 100
            aload 0 /* this */
            getfield io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.config:Lio/netty/channel/udt/UdtChannelConfig;
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  protected void doBind(java.net.SocketAddress);
    descriptor: (Ljava/net/SocketAddress;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // java.net.SocketAddress localAddress
         0: .line 105
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            aload 1 /* localAddress */
            invokestatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.privilegedBind:(Lcom/barchart/udt/nio/SocketChannelUDT;Ljava/net/SocketAddress;)V
         1: .line 106
            return
        end local 1 // java.net.SocketAddress localAddress
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    2     0          this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0    2     1  localAddress  Ljava/net/SocketAddress;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
              Name  Flags
      localAddress  final

  protected void doClose();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 110
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.close:()V
         1: .line 111
            return
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
    Exceptions:
      throws java.lang.Exception

  protected boolean doConnect(java.net.SocketAddress, java.net.SocketAddress);
    descriptor: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;)Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=7, args_size=3
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // java.net.SocketAddress remoteAddress
        start local 2 // java.net.SocketAddress localAddress
         0: .line 116
            aload 0 /* this */
            aload 2 /* localAddress */
            ifnull 1
            aload 2 /* localAddress */
            goto 2
      StackMap locals:
      StackMap stack: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel
         1: new java.net.InetSocketAddress
            dup
            iconst_0
            invokespecial java.net.InetSocketAddress.<init>:(I)V
      StackMap locals: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel java.net.SocketAddress java.net.SocketAddress
      StackMap stack: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel java.net.SocketAddress
         2: invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.doBind:(Ljava/net/SocketAddress;)V
         3: .line 117
            iconst_0
            istore 3 /* success */
        start local 3 // boolean success
         4: .line 119
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            aload 1 /* remoteAddress */
            invokestatic io.netty.util.internal.SocketUtils.connect:(Ljava/nio/channels/SocketChannel;Ljava/net/SocketAddress;)Z
            istore 4 /* connected */
        start local 4 // boolean connected
         5: .line 120
            iload 4 /* connected */
            ifne 9
         6: .line 121
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.selectionKey:()Ljava/nio/channels/SelectionKey;
         7: .line 122
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.selectionKey:()Ljava/nio/channels/SelectionKey;
            invokevirtual java.nio.channels.SelectionKey.interestOps:()I
            bipush 8
            ior
         8: .line 121
            invokevirtual java.nio.channels.SelectionKey.interestOps:(I)Ljava/nio/channels/SelectionKey;
            pop
         9: .line 124
      StackMap locals: int int
      StackMap stack:
            iconst_1
            istore 3 /* success */
        10: .line 125
            iload 4 /* connected */
            istore 6
        11: .line 127
            iload 3 /* success */
            ifne 13
        12: .line 128
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.doClose:()V
        13: .line 125
      StackMap locals: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel java.net.SocketAddress java.net.SocketAddress int int top int
      StackMap stack:
            iload 6
            ireturn
        end local 4 // boolean connected
        14: .line 126
      StackMap locals: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel java.net.SocketAddress java.net.SocketAddress int
      StackMap stack: java.lang.Throwable
            astore 5
        15: .line 127
            iload 3 /* success */
            ifne 17
        16: .line 128
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.doClose:()V
        17: .line 130
      StackMap locals: io.netty.channel.udt.nio.NioUdtMessageConnectorChannel java.net.SocketAddress java.net.SocketAddress int top java.lang.Throwable
      StackMap stack:
            aload 5
            athrow
        end local 3 // boolean success
        end local 2 // java.net.SocketAddress localAddress
        end local 1 // java.net.SocketAddress remoteAddress
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   18     0           this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0   18     1  remoteAddress  Ljava/net/SocketAddress;
            0   18     2   localAddress  Ljava/net/SocketAddress;
            4   18     3        success  Z
            5   14     4      connected  Z
      Exception table:
        from    to  target  type
           4    11      14  any
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
               Name  Flags
      remoteAddress  final
      localAddress   final

  protected void doDisconnect();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 135
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.doClose:()V
         1: .line 136
            return
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
    Exceptions:
      throws java.lang.Exception

  protected void doFinishConnect();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 140
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.finishConnect:()Z
            ifeq 5
         1: .line 141
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.selectionKey:()Ljava/nio/channels/SelectionKey;
         2: .line 142
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.selectionKey:()Ljava/nio/channels/SelectionKey;
            invokevirtual java.nio.channels.SelectionKey.interestOps:()I
            bipush -9
            iand
         3: .line 141
            invokevirtual java.nio.channels.SelectionKey.interestOps:(I)Ljava/nio/channels/SelectionKey;
            pop
         4: .line 143
            goto 8
         5: .line 144
      StackMap locals:
      StackMap stack:
            new java.lang.Error
            dup
         6: .line 145
            ldc "Provider error: failed to finish connect. Provider library should be upgraded."
         7: .line 144
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
         8: .line 147
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
    Exceptions:
      throws java.lang.Exception

  protected int doReadMessages(java.util.List<java.lang.Object>);
    descriptor: (Ljava/util/List;)I
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=5, args_size=2
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // java.util.List buf
         0: .line 152
            aload 0 /* this */
            getfield io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.config:Lio/netty/channel/udt/UdtChannelConfig;
            invokeinterface io.netty.channel.udt.UdtChannelConfig.getReceiveBufferSize:()I
            istore 2 /* maximumMessageSize */
        start local 2 // int maximumMessageSize
         1: .line 154
            aload 0 /* this */
            getfield io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.config:Lio/netty/channel/udt/UdtChannelConfig;
            invokeinterface io.netty.channel.udt.UdtChannelConfig.getAllocator:()Lio/netty/buffer/ByteBufAllocator;
         2: .line 155
            iload 2 /* maximumMessageSize */
         3: .line 154
            invokeinterface io.netty.buffer.ByteBufAllocator.directBuffer:(I)Lio/netty/buffer/ByteBuf;
            astore 3 /* byteBuf */
        start local 3 // io.netty.buffer.ByteBuf byteBuf
         4: .line 157
            aload 3 /* byteBuf */
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
         5: .line 158
            iload 2 /* maximumMessageSize */
         6: .line 157
            invokevirtual io.netty.buffer.ByteBuf.writeBytes:(Ljava/nio/channels/ScatteringByteChannel;I)I
            istore 4 /* receivedMessageSize */
        start local 4 // int receivedMessageSize
         7: .line 160
            iload 4 /* receivedMessageSize */
            ifgt 10
         8: .line 161
            aload 3 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
         9: .line 162
            iconst_0
            ireturn
        10: .line 165
      StackMap locals: int io.netty.buffer.ByteBuf int
      StackMap stack:
            iload 4 /* receivedMessageSize */
            iload 2 /* maximumMessageSize */
            if_icmplt 15
        11: .line 166
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.close:()V
        12: .line 167
            new io.netty.channel.ChannelException
            dup
        13: .line 168
            ldc "Invalid config : increase receive buffer size to avoid message truncation"
        14: .line 167
            invokespecial io.netty.channel.ChannelException.<init>:(Ljava/lang/String;)V
            athrow
        15: .line 172
      StackMap locals:
      StackMap stack:
            aload 1 /* buf */
            new io.netty.channel.udt.UdtMessage
            dup
            aload 3 /* byteBuf */
            invokespecial io.netty.channel.udt.UdtMessage.<init>:(Lio/netty/buffer/ByteBuf;)V
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        16: .line 174
            iconst_1
            ireturn
        end local 4 // int receivedMessageSize
        end local 3 // io.netty.buffer.ByteBuf byteBuf
        end local 2 // int maximumMessageSize
        end local 1 // java.util.List buf
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   17     0                 this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0   17     1                  buf  Ljava/util/List<Ljava/lang/Object;>;
            1   17     2   maximumMessageSize  I
            4   17     3              byteBuf  Lio/netty/buffer/ByteBuf;
            7   17     4  receivedMessageSize  I
    Exceptions:
      throws java.lang.Exception
    Signature: (Ljava/util/List<Ljava/lang/Object;>;)I
    MethodParameters:
      Name  Flags
      buf   

  protected boolean doWriteMessage(java.lang.Object, io.netty.channel.ChannelOutboundBuffer);
    descriptor: (Ljava/lang/Object;Lio/netty/channel/ChannelOutboundBuffer;)Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=8, args_size=3
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
        start local 1 // java.lang.Object msg
        start local 2 // io.netty.channel.ChannelOutboundBuffer in
         0: .line 180
            aload 1 /* msg */
            checkcast io.netty.channel.udt.UdtMessage
            astore 3 /* message */
        start local 3 // io.netty.channel.udt.UdtMessage message
         1: .line 182
            aload 3 /* message */
            invokevirtual io.netty.channel.udt.UdtMessage.content:()Lio/netty/buffer/ByteBuf;
            astore 4 /* byteBuf */
        start local 4 // io.netty.buffer.ByteBuf byteBuf
         2: .line 184
            aload 4 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            istore 5 /* messageSize */
        start local 5 // int messageSize
         3: .line 185
            iload 5 /* messageSize */
            ifne 5
         4: .line 186
            iconst_1
            ireturn
         5: .line 190
      StackMap locals: io.netty.channel.udt.UdtMessage io.netty.buffer.ByteBuf int
      StackMap stack:
            aload 4 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.nioBufferCount:()I
            iconst_1
            if_icmpne 8
         6: .line 191
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            aload 4 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.nioBuffer:()Ljava/nio/ByteBuffer;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.write:(Ljava/nio/ByteBuffer;)I
            i2l
            lstore 6 /* writtenBytes */
        start local 6 // long writtenBytes
         7: .line 192
            goto 9
        end local 6 // long writtenBytes
         8: .line 193
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            aload 4 /* byteBuf */
            invokevirtual io.netty.buffer.ByteBuf.nioBuffers:()[Ljava/nio/ByteBuffer;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.write:([Ljava/nio/ByteBuffer;)J
            lstore 6 /* writtenBytes */
        start local 6 // long writtenBytes
         9: .line 197
      StackMap locals: long
      StackMap stack:
            lload 6 /* writtenBytes */
            lconst_0
            lcmp
            ifle 13
            lload 6 /* writtenBytes */
            iload 5 /* messageSize */
            i2l
            lcmp
            ifeq 13
        10: .line 198
            new java.lang.Error
            dup
        11: .line 199
            ldc "Provider error: failed to write message. Provider library should be upgraded."
        12: .line 198
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        13: .line 202
      StackMap locals:
      StackMap stack:
            lload 6 /* writtenBytes */
            lconst_0
            lcmp
            ifle 14
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
        14: iconst_0
            ireturn
        end local 6 // long writtenBytes
        end local 5 // int messageSize
        end local 4 // io.netty.buffer.ByteBuf byteBuf
        end local 3 // io.netty.channel.udt.UdtMessage message
        end local 2 // io.netty.channel.ChannelOutboundBuffer in
        end local 1 // java.lang.Object msg
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   15     0          this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            0   15     1           msg  Ljava/lang/Object;
            0   15     2            in  Lio/netty/channel/ChannelOutboundBuffer;
            1   15     3       message  Lio/netty/channel/udt/UdtMessage;
            2   15     4       byteBuf  Lio/netty/buffer/ByteBuf;
            3   15     5   messageSize  I
            7    8     6  writtenBytes  J
            9   15     6  writtenBytes  J
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      msg   
      in    

  public boolean isActive();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 207
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            astore 1 /* channelUDT */
        start local 1 // com.barchart.udt.nio.SocketChannelUDT channelUDT
         1: .line 208
            aload 1 /* channelUDT */
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.isOpen:()Z
            ifeq 2
            aload 1 /* channelUDT */
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.isConnectFinished:()Z
            ifeq 2
            iconst_1
            ireturn
      StackMap locals: com.barchart.udt.nio.SocketChannelUDT
      StackMap stack:
         2: iconst_0
            ireturn
        end local 1 // com.barchart.udt.nio.SocketChannelUDT channelUDT
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;
            1    3     1  channelUDT  Lcom/barchart/udt/nio/SocketChannelUDT;

  protected com.barchart.udt.nio.SocketChannelUDT javaChannel();
    descriptor: ()Lcom/barchart/udt/nio/SocketChannelUDT;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 213
            aload 0 /* this */
            invokespecial io.netty.channel.nio.AbstractNioMessageChannel.javaChannel:()Ljava/nio/channels/SelectableChannel;
            checkcast com.barchart.udt.nio.SocketChannelUDT
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  protected java.net.SocketAddress localAddress0();
    descriptor: ()Ljava/net/SocketAddress;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 218
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.socket:()Lcom/barchart/udt/nio/NioSocketUDT;
            invokevirtual com.barchart.udt.nio.NioSocketUDT.getLocalSocketAddress:()Ljava/net/SocketAddress;
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  public io.netty.channel.ChannelMetadata metadata();
    descriptor: ()Lio/netty/channel/ChannelMetadata;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 223
            getstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.METADATA:Lio/netty/channel/ChannelMetadata;
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  protected java.net.SocketAddress remoteAddress0();
    descriptor: ()Ljava/net/SocketAddress;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 228
            aload 0 /* this */
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            invokevirtual com.barchart.udt.nio.SocketChannelUDT.socket:()Lcom/barchart/udt/nio/NioSocketUDT;
            invokevirtual com.barchart.udt.nio.NioSocketUDT.getRemoteSocketAddress:()Ljava/net/SocketAddress;
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  public java.net.InetSocketAddress localAddress();
    descriptor: ()Ljava/net/InetSocketAddress;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 233
            aload 0 /* this */
            invokespecial io.netty.channel.nio.AbstractNioMessageChannel.localAddress:()Ljava/net/SocketAddress;
            checkcast java.net.InetSocketAddress
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  public java.net.InetSocketAddress remoteAddress();
    descriptor: ()Ljava/net/InetSocketAddress;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
         0: .line 238
            aload 0 /* this */
            invokespecial io.netty.channel.nio.AbstractNioMessageChannel.remoteAddress:()Ljava/net/SocketAddress;
            checkcast java.net.InetSocketAddress
            areturn
        end local 0 // io.netty.channel.udt.nio.NioUdtMessageConnectorChannel this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/udt/nio/NioUdtMessageConnectorChannel;

  private static void privilegedBind(com.barchart.udt.nio.SocketChannelUDT, java.net.SocketAddress);
    descriptor: (Lcom/barchart/udt/nio/SocketChannelUDT;Ljava/net/SocketAddress;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // com.barchart.udt.nio.SocketChannelUDT socketChannel
        start local 1 // java.net.SocketAddress localAddress
         0: .line 244
            new io.netty.channel.udt.nio.NioUdtMessageConnectorChannel$1
            dup
            aload 0 /* socketChannel */
            aload 1 /* localAddress */
            invokespecial io.netty.channel.udt.nio.NioUdtMessageConnectorChannel$1.<init>:(Lcom/barchart/udt/nio/SocketChannelUDT;Ljava/net/SocketAddress;)V
            invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedExceptionAction;)Ljava/lang/Object;
            pop
         1: .line 251
            goto 4
      StackMap locals:
      StackMap stack: java.security.PrivilegedActionException
         2: astore 2 /* e */
        start local 2 // java.security.PrivilegedActionException e
         3: .line 252
            aload 2 /* e */
            invokevirtual java.security.PrivilegedActionException.getCause:()Ljava/lang/Throwable;
            checkcast java.io.IOException
            athrow
        end local 2 // java.security.PrivilegedActionException e
         4: .line 254
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.net.SocketAddress localAddress
        end local 0 // com.barchart.udt.nio.SocketChannelUDT socketChannel
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0  socketChannel  Lcom/barchart/udt/nio/SocketChannelUDT;
            0    5     1   localAddress  Ljava/net/SocketAddress;
            3    4     2              e  Ljava/security/PrivilegedActionException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.security.PrivilegedActionException
    Exceptions:
      throws java.io.IOException
    MethodParameters:
               Name  Flags
      socketChannel  final
      localAddress   final

  public io.netty.channel.ChannelConfig config();
    descriptor: ()Lio/netty/channel/ChannelConfig;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.config:()Lio/netty/channel/udt/UdtChannelConfig;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public java.net.SocketAddress localAddress();
    descriptor: ()Ljava/net/SocketAddress;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.localAddress:()Ljava/net/InetSocketAddress;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  protected java.nio.channels.SelectableChannel javaChannel();
    descriptor: ()Ljava/nio/channels/SelectableChannel;
    flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.javaChannel:()Lcom/barchart/udt/nio/SocketChannelUDT;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public java.net.SocketAddress remoteAddress();
    descriptor: ()Ljava/net/SocketAddress;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.remoteAddress:()Ljava/net/InetSocketAddress;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static int[] $SWITCH_TABLE$com$barchart$udt$StatusUDT();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 52
            getstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.$SWITCH_TABLE$com$barchart$udt$StatusUDT:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic com.barchart.udt.StatusUDT.values:()[Lcom/barchart/udt/StatusUDT;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic com.barchart.udt.StatusUDT.BROKEN:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            bipush 6
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic com.barchart.udt.StatusUDT.CLOSED:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            bipush 8
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic com.barchart.udt.StatusUDT.CLOSING:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            bipush 7
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic com.barchart.udt.StatusUDT.CONNECTED:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            iconst_5
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            getstatic com.barchart.udt.StatusUDT.CONNECTING:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            iconst_4
            iastore
        15: goto 17
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        16: pop
      StackMap locals:
      StackMap stack:
        17: aload 0
            getstatic com.barchart.udt.StatusUDT.INIT:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            iconst_1
            iastore
        18: goto 20
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        19: pop
      StackMap locals:
      StackMap stack:
        20: aload 0
            getstatic com.barchart.udt.StatusUDT.LISTENING:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            iconst_3
            iastore
        21: goto 23
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        22: pop
      StackMap locals:
      StackMap stack:
        23: aload 0
            getstatic com.barchart.udt.StatusUDT.NONEXIST:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            bipush 9
            iastore
        24: goto 26
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        25: pop
      StackMap locals:
      StackMap stack:
        26: aload 0
            getstatic com.barchart.udt.StatusUDT.OPENED:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            iconst_2
            iastore
        27: goto 29
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        28: pop
      StackMap locals:
      StackMap stack:
        29: aload 0
            getstatic com.barchart.udt.StatusUDT.UNKNOWN:Lcom/barchart/udt/StatusUDT;
            invokevirtual com.barchart.udt.StatusUDT.ordinal:()I
            bipush 10
            iastore
        30: goto 32
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        31: pop
      StackMap locals:
      StackMap stack:
        32: aload 0
            dup
            putstatic io.netty.channel.udt.nio.NioUdtMessageConnectorChannel.$SWITCH_TABLE$com$barchart$udt$StatusUDT:[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
          14    15      16  Class java.lang.NoSuchFieldError
          17    18      19  Class java.lang.NoSuchFieldError
          20    21      22  Class java.lang.NoSuchFieldError
          23    24      25  Class java.lang.NoSuchFieldError
          26    27      28  Class java.lang.NoSuchFieldError
          29    30      31  Class java.lang.NoSuchFieldError
}
SourceFile: "NioUdtMessageConnectorChannel.java"
NestMembers:
  io.netty.channel.udt.nio.NioUdtMessageConnectorChannel$1
InnerClasses:
  io.netty.channel.udt.nio.NioUdtMessageConnectorChannel$1
    RuntimeVisibleAnnotations: 
      java.lang.Deprecated()
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/channel/udt/nio/NioUdtMessageConnectorChannel.class
