io.vertx/vertx-proton/3.8.0 : io/vertx/proton/impl/ProtonTransport.class

ProtonTransport
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-proton: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
The Apache Software License, Version 2.0
class io.vertx.proton.impl.ProtonTransport extends org.apache.qpid.proton.engine.BaseHandler
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: io.vertx.proton.impl.ProtonTransport
  super_class: org.apache.qpid.proton.engine.BaseHandler
{
  private static final io.vertx.core.logging.Logger LOG;
    descriptor: Lio/vertx/core/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final int DEFAULT_MAX_FRAME_SIZE;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 32768

  private final org.apache.qpid.proton.engine.Connection connection;
    descriptor: Lorg/apache/qpid/proton/engine/Connection;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.Vertx vertx;
    descriptor: Lio/vertx/core/Vertx;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.net.NetClient netClient;
    descriptor: Lio/vertx/core/net/NetClient;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.net.NetSocket socket;
    descriptor: Lio/vertx/core/net/NetSocket;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.qpid.proton.engine.Transport transport;
    descriptor: Lorg/apache/qpid/proton/engine/Transport;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.qpid.proton.engine.Collector collector;
    descriptor: Lorg/apache/qpid/proton/engine/Collector;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.vertx.proton.sasl.ProtonSaslAuthenticator authenticator;
    descriptor: Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
    flags: (0x0002) ACC_PRIVATE

  private volatile java.lang.Long idleTimeoutCheckTimerId;
    descriptor: Ljava/lang/Long;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private boolean failed;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private static volatile int[] $SWITCH_TABLE$org$apache$qpid$proton$engine$Event$Type;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 49
            ldc Lio/vertx/proton/impl/ProtonTransport;
            invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
            putstatic io.vertx.proton.impl.ProtonTransport.LOG:Lio/vertx/core/logging/Logger;
         1: .line 50
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(org.apache.qpid.proton.engine.Connection, io.vertx.core.Vertx, io.vertx.core.net.NetClient, io.vertx.core.net.NetSocket, io.vertx.proton.sasl.ProtonSaslAuthenticator, io.vertx.proton.ProtonTransportOptions);
    descriptor: (Lorg/apache/qpid/proton/engine/Connection;Lio/vertx/core/Vertx;Lio/vertx/core/net/NetClient;Lio/vertx/core/net/NetSocket;Lio/vertx/proton/sasl/ProtonSaslAuthenticator;Lio/vertx/proton/ProtonTransportOptions;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=8, args_size=7
        start local 0 // io.vertx.proton.impl.ProtonTransport this
        start local 1 // org.apache.qpid.proton.engine.Connection connection
        start local 2 // io.vertx.core.Vertx vertx
        start local 3 // io.vertx.core.net.NetClient netClient
        start local 4 // io.vertx.core.net.NetSocket socket
        start local 5 // io.vertx.proton.sasl.ProtonSaslAuthenticator authenticator
        start local 6 // io.vertx.proton.ProtonTransportOptions options
         0: .line 64
            aload 0 /* this */
            invokespecial org.apache.qpid.proton.engine.BaseHandler.<init>:()V
         1: .line 56
            aload 0 /* this */
            invokestatic org.apache.qpid.proton.Proton.transport:()Lorg/apache/qpid/proton/engine/Transport;
            putfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
         2: .line 57
            aload 0 /* this */
            invokestatic org.apache.qpid.proton.Proton.collector:()Lorg/apache/qpid/proton/engine/Collector;
            putfield io.vertx.proton.impl.ProtonTransport.collector:Lorg/apache/qpid/proton/engine/Collector;
         3: .line 66
            aload 0 /* this */
            aload 1 /* connection */
            putfield io.vertx.proton.impl.ProtonTransport.connection:Lorg/apache/qpid/proton/engine/Connection;
         4: .line 67
            aload 0 /* this */
            aload 2 /* vertx */
            putfield io.vertx.proton.impl.ProtonTransport.vertx:Lio/vertx/core/Vertx;
         5: .line 68
            aload 0 /* this */
            aload 3 /* netClient */
            putfield io.vertx.proton.impl.ProtonTransport.netClient:Lio/vertx/core/net/NetClient;
         6: .line 69
            aload 0 /* this */
            aload 4 /* socket */
            putfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
         7: .line 70
            aload 6 /* options */
            invokevirtual io.vertx.proton.ProtonTransportOptions.getMaxFrameSize:()I
            ifne 8
            ldc 32768
            goto 9
      StackMap locals: io.vertx.proton.impl.ProtonTransport org.apache.qpid.proton.engine.Connection io.vertx.core.Vertx io.vertx.core.net.NetClient io.vertx.core.net.NetSocket io.vertx.proton.sasl.ProtonSaslAuthenticator io.vertx.proton.ProtonTransportOptions
      StackMap stack:
         8: aload 6 /* options */
            invokevirtual io.vertx.proton.ProtonTransportOptions.getMaxFrameSize:()I
      StackMap locals:
      StackMap stack: int
         9: istore 7 /* maxFrameSize */
        start local 7 // int maxFrameSize
        10: .line 71
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            iload 7 /* maxFrameSize */
            invokeinterface org.apache.qpid.proton.engine.Transport.setMaxFrameSize:(I)V
        11: .line 72
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            iload 7 /* maxFrameSize */
            invokeinterface org.apache.qpid.proton.engine.Transport.setOutboundFrameSizeLimit:(I)V
        12: .line 73
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            iconst_0
            invokeinterface org.apache.qpid.proton.engine.Transport.setEmitFlowEventOnSend:(Z)V
        13: .line 74
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            iconst_2
            aload 6 /* options */
            invokevirtual io.vertx.proton.ProtonTransportOptions.getHeartbeat:()I
            imul
            invokeinterface org.apache.qpid.proton.engine.Transport.setIdleTimeout:(I)V
        14: .line 75
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            checkcast org.apache.qpid.proton.engine.impl.TransportInternal
            iconst_0
            invokeinterface org.apache.qpid.proton.engine.impl.TransportInternal.setUseReadOnlyOutputBuffer:(Z)V
        15: .line 76
            aload 5 /* authenticator */
            ifnull 17
        16: .line 77
            aload 5 /* authenticator */
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.connection:Lorg/apache/qpid/proton/engine/Connection;
            invokeinterface org.apache.qpid.proton.engine.Connection.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.ProtonConnection
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface io.vertx.proton.sasl.ProtonSaslAuthenticator.init:(Lio/vertx/core/net/NetSocket;Lio/vertx/proton/ProtonConnection;Lorg/apache/qpid/proton/engine/Transport;)V
        17: .line 79
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            aload 5 /* authenticator */
            putfield io.vertx.proton.impl.ProtonTransport.authenticator:Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
        18: .line 80
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            aload 1 /* connection */
            invokeinterface org.apache.qpid.proton.engine.Transport.bind:(Lorg/apache/qpid/proton/engine/Connection;)V
        19: .line 81
            aload 1 /* connection */
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.collector:Lorg/apache/qpid/proton/engine/Collector;
            invokeinterface org.apache.qpid.proton.engine.Connection.collect:(Lorg/apache/qpid/proton/engine/Collector;)V
        20: .line 82
            aload 4 /* socket */
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/proton/impl/ProtonTransport;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/proton/impl/ProtonTransport.handleSocketEnd(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.net.NetSocket.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
        21: .line 83
            aload 4 /* socket */
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/proton/impl/ProtonTransport;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/proton/impl/ProtonTransport.handleSocketBuffer(Lio/vertx/core/buffer/Buffer;)V (7)
                  (Lio/vertx/core/buffer/Buffer;)V
            invokeinterface io.vertx.core.net.NetSocket.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
        22: .line 84
            return
        end local 7 // int maxFrameSize
        end local 6 // io.vertx.proton.ProtonTransportOptions options
        end local 5 // io.vertx.proton.sasl.ProtonSaslAuthenticator authenticator
        end local 4 // io.vertx.core.net.NetSocket socket
        end local 3 // io.vertx.core.net.NetClient netClient
        end local 2 // io.vertx.core.Vertx vertx
        end local 1 // org.apache.qpid.proton.engine.Connection connection
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   23     0           this  Lio/vertx/proton/impl/ProtonTransport;
            0   23     1     connection  Lorg/apache/qpid/proton/engine/Connection;
            0   23     2          vertx  Lio/vertx/core/Vertx;
            0   23     3      netClient  Lio/vertx/core/net/NetClient;
            0   23     4         socket  Lio/vertx/core/net/NetSocket;
            0   23     5  authenticator  Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
            0   23     6        options  Lio/vertx/proton/ProtonTransportOptions;
           10   23     7   maxFrameSize  I
    MethodParameters:
               Name  Flags
      connection     
      vertx          
      netClient      
      socket         
      authenticator  
      options        

  private void handleSocketEnd(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.proton.impl.ProtonTransport this
        start local 1 // java.lang.Void arg
         0: .line 87
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface org.apache.qpid.proton.engine.Transport.unbind:()V
         1: .line 88
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface org.apache.qpid.proton.engine.Transport.close:()V
         2: .line 89
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.netClient:Lio/vertx/core/net/NetClient;
            ifnull 5
         3: .line 90
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.netClient:Lio/vertx/core/net/NetClient;
            invokeinterface io.vertx.core.net.NetClient.close:()V
         4: .line 91
            goto 6
         5: .line 92
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
            invokeinterface io.vertx.core.net.NetSocket.close:()V
         6: .line 94
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.connection:Lorg/apache/qpid/proton/engine/Connection;
            invokeinterface org.apache.qpid.proton.engine.Connection.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.fireDisconnect:()V
         7: .line 95
            return
        end local 1 // java.lang.Void arg
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/proton/impl/ProtonTransport;
            0    8     1   arg  Ljava/lang/Void;
    MethodParameters:
      Name  Flags
      arg   

  private void handleSocketBuffer(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=7, args_size=2
        start local 0 // io.vertx.proton.impl.ProtonTransport this
        start local 1 // io.vertx.core.buffer.Buffer buff
         0: .line 98
            aload 0 /* this */
            aload 1 /* buff */
            invokevirtual io.vertx.proton.impl.ProtonTransport.pumpInbound:(Lio/vertx/core/buffer/Buffer;)V
         1: .line 100
            aconst_null
            astore 2 /* protonEvent */
        start local 2 // org.apache.qpid.proton.engine.Event protonEvent
         2: .line 101
            goto 46
         3: .line 102
      StackMap locals: org.apache.qpid.proton.engine.Event
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getConnection:()Lorg/apache/qpid/proton/engine/Connection;
            invokeinterface org.apache.qpid.proton.engine.Connection.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            astore 3 /* conn */
        start local 3 // io.vertx.proton.impl.ProtonConnectionImpl conn
         4: .line 104
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getType:()Lorg/apache/qpid/proton/engine/Event$Type;
            astore 4 /* eventType */
        start local 4 // org.apache.qpid.proton.engine.Event$Type eventType
         5: .line 105
            getstatic io.vertx.proton.impl.ProtonTransport.LOG:Lio/vertx/core/logging/Logger;
            invokevirtual io.vertx.core.logging.Logger.isTraceEnabled:()Z
            ifeq 7
            aload 4 /* eventType */
            getstatic org.apache.qpid.proton.engine.Event$Type.TRANSPORT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.equals:(Ljava/lang/Object;)Z
            ifne 7
         6: .line 106
            getstatic io.vertx.proton.impl.ProtonTransport.LOG:Lio/vertx/core/logging/Logger;
            ldc "New Proton Event: {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 4 /* eventType */
            aastore
            invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;[Ljava/lang/Object;)V
         7: .line 109
      StackMap locals: io.vertx.proton.impl.ProtonConnectionImpl org.apache.qpid.proton.engine.Event$Type
      StackMap stack:
            invokestatic io.vertx.proton.impl.ProtonTransport.$SWITCH_TABLE$org$apache$qpid$proton$engine$Event$Type:()[I
            aload 4 /* eventType */
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            iaload
            tableswitch { // 5 - 30
                    5: 45
                    6: 45
                    7: 45
                    8: 45
                    9: 8
                   10: 45
                   11: 11
                   12: 45
                   13: 45
                   14: 45
                   15: 13
                   16: 45
                   17: 19
                   18: 45
                   19: 45
                   20: 45
                   21: 22
                   22: 45
                   23: 28
                   24: 45
                   25: 31
                   26: 34
                   27: 45
                   28: 37
                   29: 45
                   30: 44
              default: 45
          }
         8: .line 111
      StackMap locals:
      StackMap stack:
            aload 3 /* conn */
            invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.fireRemoteOpen:()V
         9: .line 112
            aload 0 /* this */
            invokevirtual io.vertx.proton.impl.ProtonTransport.initiateIdleTimeoutChecks:()V
        10: .line 113
            goto 45
        11: .line 116
      StackMap locals:
      StackMap stack:
            aload 3 /* conn */
            invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.fireRemoteClose:()V
        12: .line 117
            goto 45
        13: .line 120
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getSession:()Lorg/apache/qpid/proton/engine/Session;
            invokeinterface org.apache.qpid.proton.engine.Session.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonSessionImpl
            astore 5 /* session */
        start local 5 // io.vertx.proton.impl.ProtonSessionImpl session
        14: .line 121
            aload 5 /* session */
            ifnonnull 17
        15: .line 122
            aload 3 /* conn */
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getSession:()Lorg/apache/qpid/proton/engine/Session;
            invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.fireRemoteSessionOpen:(Lorg/apache/qpid/proton/engine/Session;)V
        16: .line 123
            goto 45
        17: .line 124
      StackMap locals: io.vertx.proton.impl.ProtonSessionImpl
      StackMap stack:
            aload 5 /* session */
            invokevirtual io.vertx.proton.impl.ProtonSessionImpl.fireRemoteOpen:()V
        18: .line 126
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonSessionImpl session
        19: .line 129
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getSession:()Lorg/apache/qpid/proton/engine/Session;
            invokeinterface org.apache.qpid.proton.engine.Session.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonSessionImpl
            astore 5 /* session */
        start local 5 // io.vertx.proton.impl.ProtonSessionImpl session
        20: .line 130
            aload 5 /* session */
            invokevirtual io.vertx.proton.impl.ProtonSessionImpl.fireRemoteClose:()V
        21: .line 131
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonSessionImpl session
        22: .line 134
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getLink:()Lorg/apache/qpid/proton/engine/Link;
            invokeinterface org.apache.qpid.proton.engine.Link.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonLinkImpl
            astore 5 /* link */
        start local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        23: .line 135
            aload 5 /* link */
            ifnonnull 26
        24: .line 136
            aload 3 /* conn */
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getLink:()Lorg/apache/qpid/proton/engine/Link;
            invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.fireRemoteLinkOpen:(Lorg/apache/qpid/proton/engine/Link;)V
        25: .line 137
            goto 45
        26: .line 138
      StackMap locals: io.vertx.proton.impl.ProtonLinkImpl
      StackMap stack:
            aload 5 /* link */
            invokevirtual io.vertx.proton.impl.ProtonLinkImpl.fireRemoteOpen:()V
        27: .line 140
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        28: .line 143
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getLink:()Lorg/apache/qpid/proton/engine/Link;
            invokeinterface org.apache.qpid.proton.engine.Link.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonLinkImpl
            astore 5 /* link */
        start local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        29: .line 144
            aload 5 /* link */
            invokevirtual io.vertx.proton.impl.ProtonLinkImpl.fireRemoteDetach:()V
        30: .line 145
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        31: .line 148
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getLink:()Lorg/apache/qpid/proton/engine/Link;
            invokeinterface org.apache.qpid.proton.engine.Link.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonLinkImpl
            astore 5 /* link */
        start local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        32: .line 149
            aload 5 /* link */
            invokevirtual io.vertx.proton.impl.ProtonLinkImpl.fireRemoteClose:()V
        33: .line 150
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        34: .line 153
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getLink:()Lorg/apache/qpid/proton/engine/Link;
            invokeinterface org.apache.qpid.proton.engine.Link.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonLinkImpl
            astore 5 /* link */
        start local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        35: .line 154
            aload 5 /* link */
            invokevirtual io.vertx.proton.impl.ProtonLinkImpl.handleLinkFlow:()V
        36: .line 155
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonLinkImpl link
        37: .line 158
      StackMap locals:
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getDelivery:()Lorg/apache/qpid/proton/engine/Delivery;
            invokeinterface org.apache.qpid.proton.engine.Delivery.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonDeliveryImpl
            astore 5 /* delivery */
        start local 5 // io.vertx.proton.impl.ProtonDeliveryImpl delivery
        38: .line 159
            aload 5 /* delivery */
            ifnull 41
        39: .line 160
            aload 5 /* delivery */
            invokevirtual io.vertx.proton.impl.ProtonDeliveryImpl.fireUpdate:()V
        40: .line 161
            goto 45
        41: .line 162
      StackMap locals: io.vertx.proton.impl.ProtonDeliveryImpl
      StackMap stack:
            aload 2 /* protonEvent */
            invokeinterface org.apache.qpid.proton.engine.Event.getLink:()Lorg/apache/qpid/proton/engine/Link;
            invokeinterface org.apache.qpid.proton.engine.Link.getContext:()Ljava/lang/Object;
            checkcast io.vertx.proton.impl.ProtonReceiverImpl
            astore 6 /* receiver */
        start local 6 // io.vertx.proton.impl.ProtonReceiverImpl receiver
        42: .line 163
            aload 6 /* receiver */
            invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.onDelivery:()V
        end local 6 // io.vertx.proton.impl.ProtonReceiverImpl receiver
        43: .line 165
            goto 45
        end local 5 // io.vertx.proton.impl.ProtonDeliveryImpl delivery
        44: .line 168
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.vertx.proton.impl.ProtonTransport.failed:Z
        45: .line 190
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.collector:Lorg/apache/qpid/proton/engine/Collector;
            invokeinterface org.apache.qpid.proton.engine.Collector.pop:()V
        end local 4 // org.apache.qpid.proton.engine.Event$Type eventType
        end local 3 // io.vertx.proton.impl.ProtonConnectionImpl conn
        46: .line 101
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.collector:Lorg/apache/qpid/proton/engine/Collector;
            invokeinterface org.apache.qpid.proton.engine.Collector.peek:()Lorg/apache/qpid/proton/engine/Event;
            dup
            astore 2 /* protonEvent */
            ifnonnull 3
        47: .line 193
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.failed:Z
            ifne 49
        48: .line 194
            aload 0 /* this */
            invokevirtual io.vertx.proton.impl.ProtonTransport.processSaslAuthentication:()V
        49: .line 197
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.vertx.proton.impl.ProtonTransport.flush:()V
        50: .line 199
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.failed:Z
            ifeq 52
        51: .line 200
            aload 0 /* this */
            invokevirtual io.vertx.proton.impl.ProtonTransport.disconnect:()V
        52: .line 202
      StackMap locals:
      StackMap stack:
            return
        end local 2 // org.apache.qpid.proton.engine.Event protonEvent
        end local 1 // io.vertx.core.buffer.Buffer buff
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   53     0         this  Lio/vertx/proton/impl/ProtonTransport;
            0   53     1         buff  Lio/vertx/core/buffer/Buffer;
            2   53     2  protonEvent  Lorg/apache/qpid/proton/engine/Event;
            4   46     3         conn  Lio/vertx/proton/impl/ProtonConnectionImpl;
            5   46     4    eventType  Lorg/apache/qpid/proton/engine/Event$Type;
           14   19     5      session  Lio/vertx/proton/impl/ProtonSessionImpl;
           20   22     5      session  Lio/vertx/proton/impl/ProtonSessionImpl;
           23   28     5         link  Lio/vertx/proton/impl/ProtonLinkImpl<*>;
           29   31     5         link  Lio/vertx/proton/impl/ProtonLinkImpl<*>;
           32   34     5         link  Lio/vertx/proton/impl/ProtonLinkImpl<*>;
           35   37     5         link  Lio/vertx/proton/impl/ProtonLinkImpl<*>;
           38   44     5     delivery  Lio/vertx/proton/impl/ProtonDeliveryImpl;
           42   43     6     receiver  Lio/vertx/proton/impl/ProtonReceiverImpl;
    MethodParameters:
      Name  Flags
      buff  

  private void processSaslAuthentication();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.proton.impl.ProtonTransport this
         0: .line 205
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.authenticator:Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
            ifnonnull 2
         1: .line 206
            return
         2: .line 209
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
            invokeinterface io.vertx.core.net.NetSocket.pause:()Lio/vertx/core/net/NetSocket;
            pop
         3: .line 211
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.authenticator:Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/proton/impl/ProtonTransport;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/proton/impl/ProtonTransport.lambda$2(Ljava/lang/Boolean;)V (7)
                  (Ljava/lang/Boolean;)V
            invokeinterface io.vertx.proton.sasl.ProtonSaslAuthenticator.process:(Lio/vertx/core/Handler;)V
         4: .line 218
            return
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/proton/impl/ProtonTransport;

  private void initiateIdleTimeoutChecks();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=7, args_size=1
        start local 0 // io.vertx.proton.impl.ProtonTransport this
         0: .line 222
            getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
            invokestatic java.lang.System.nanoTime:()J
            invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
            lstore 1 /* now */
        start local 1 // long now
         1: .line 223
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            lload 1 /* now */
            invokeinterface org.apache.qpid.proton.engine.Transport.tick:(J)J
            lstore 3 /* deadline */
        start local 3 // long deadline
         2: .line 224
            lload 3 /* deadline */
            lconst_0
            lcmp
            ifeq 6
         3: .line 226
            lload 3 /* deadline */
            lload 1 /* now */
            lsub
            lconst_1
            invokestatic java.lang.Math.max:(JJ)J
            lstore 5 /* delay */
        start local 5 // long delay
         4: .line 227
            getstatic io.vertx.proton.impl.ProtonTransport.LOG:Lio/vertx/core/logging/Logger;
            ldc "IdleTimeoutCheck being initiated, initial delay: {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            lload 5 /* delay */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            aastore
            invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;[Ljava/lang/Object;)V
         5: .line 228
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.vertx:Lio/vertx/core/Vertx;
            lload 5 /* delay */
            new io.vertx.proton.impl.ProtonTransport$IdleTimeoutCheck
            dup
            aload 0 /* this */
            invokespecial io.vertx.proton.impl.ProtonTransport$IdleTimeoutCheck.<init>:(Lio/vertx/proton/impl/ProtonTransport;)V
            invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            putfield io.vertx.proton.impl.ProtonTransport.idleTimeoutCheckTimerId:Ljava/lang/Long;
        end local 5 // long delay
         6: .line 230
      StackMap locals: long long
      StackMap stack:
            return
        end local 3 // long deadline
        end local 1 // long now
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/vertx/proton/impl/ProtonTransport;
            1    7     1       now  J
            2    7     3  deadline  J
            4    6     5     delay  J

  private void pumpInbound(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=5, args_size=2
        start local 0 // io.vertx.proton.impl.ProtonTransport this
        start local 1 // io.vertx.core.buffer.Buffer buffer
         0: .line 233
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.failed:Z
            ifeq 3
         1: .line 234
            getstatic io.vertx.proton.impl.ProtonTransport.LOG:Lio/vertx/core/logging/Logger;
            ldc "Skipping processing of data following transport error: {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* buffer */
            aastore
            invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;[Ljava/lang/Object;)V
         2: .line 235
            return
         3: .line 240
      StackMap locals:
      StackMap stack:
            aload 1 /* buffer */
            invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
            astore 2 /* data */
        start local 2 // io.netty.buffer.ByteBuf data
         4: .line 242
      StackMap locals: io.netty.buffer.ByteBuf
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface org.apache.qpid.proton.engine.Transport.tail:()Ljava/nio/ByteBuffer;
            astore 3 /* transportBuffer */
        start local 3 // java.nio.ByteBuffer transportBuffer
         5: .line 244
            aload 3 /* transportBuffer */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            aload 2 /* data */
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            invokestatic java.lang.Math.min:(II)I
            istore 4 /* amount */
        start local 4 // int amount
         6: .line 245
            aload 3 /* transportBuffer */
            aload 3 /* transportBuffer */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 4 /* amount */
            iadd
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
         7: .line 246
            aload 2 /* data */
            aload 3 /* transportBuffer */
            invokevirtual io.netty.buffer.ByteBuf.readBytes:(Ljava/nio/ByteBuffer;)Lio/netty/buffer/ByteBuf;
            pop
         8: .line 248
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface org.apache.qpid.proton.engine.Transport.process:()V
        end local 4 // int amount
        end local 3 // java.nio.ByteBuffer transportBuffer
         9: .line 249
            aload 2 /* data */
            invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
            ifne 4
        end local 2 // io.netty.buffer.ByteBuf data
        10: .line 250
            goto 14
      StackMap locals: io.vertx.proton.impl.ProtonTransport io.vertx.core.buffer.Buffer
      StackMap stack: java.lang.Exception
        11: astore 2 /* te */
        start local 2 // java.lang.Exception te
        12: .line 251
            aload 0 /* this */
            iconst_1
            putfield io.vertx.proton.impl.ProtonTransport.failed:Z
        13: .line 252
            getstatic io.vertx.proton.impl.ProtonTransport.LOG:Lio/vertx/core/logging/Logger;
            ldc "Exception while processing transport input"
            aload 2 /* te */
            invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        end local 2 // java.lang.Exception te
        14: .line 254
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.buffer.Buffer buffer
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   15     0             this  Lio/vertx/proton/impl/ProtonTransport;
            0   15     1           buffer  Lio/vertx/core/buffer/Buffer;
            4   10     2             data  Lio/netty/buffer/ByteBuf;
            5    9     3  transportBuffer  Ljava/nio/ByteBuffer;
            6    9     4           amount  I
           12   14     2               te  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           3    10      11  Class java.lang.Exception
    MethodParameters:
        Name  Flags
      buffer  

  void flush();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=5, args_size=1
        start local 0 // io.vertx.proton.impl.ProtonTransport this
         0: .line 257
            iconst_0
            istore 1 /* done */
        start local 1 // boolean done
         1: .line 258
            goto 11
         2: .line 259
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface org.apache.qpid.proton.engine.Transport.getOutputBuffer:()Ljava/nio/ByteBuffer;
            astore 2 /* outputBuffer */
        start local 2 // java.nio.ByteBuffer outputBuffer
         3: .line 260
            aload 2 /* outputBuffer */
            ifnull 10
            aload 2 /* outputBuffer */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifeq 10
         4: .line 261
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
            checkcast io.vertx.core.impl.NetSocketInternal
            astore 3 /* internal */
        start local 3 // io.vertx.core.impl.NetSocketInternal internal
         5: .line 262
            aload 3 /* internal */
            invokeinterface io.vertx.core.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
            aload 2 /* outputBuffer */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            invokeinterface io.netty.buffer.ByteBufAllocator.directBuffer:(I)Lio/netty/buffer/ByteBuf;
            astore 4 /* bb */
        start local 4 // io.netty.buffer.ByteBuf bb
         6: .line 263
            aload 4 /* bb */
            aload 2 /* outputBuffer */
            invokevirtual io.netty.buffer.ByteBuf.writeBytes:(Ljava/nio/ByteBuffer;)Lio/netty/buffer/ByteBuf;
            pop
         7: .line 264
            aload 3 /* internal */
            aload 4 /* bb */
            invokeinterface io.vertx.core.impl.NetSocketInternal.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/impl/NetSocketInternal;
            pop
         8: .line 265
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.transport:Lorg/apache/qpid/proton/engine/Transport;
            invokeinterface org.apache.qpid.proton.engine.Transport.outputConsumed:()V
        end local 4 // io.netty.buffer.ByteBuf bb
        end local 3 // io.vertx.core.impl.NetSocketInternal internal
         9: .line 266
            goto 11
        10: .line 267
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            iconst_1
            istore 1 /* done */
        end local 2 // java.nio.ByteBuffer outputBuffer
        11: .line 258
      StackMap locals:
      StackMap stack:
            iload 1 /* done */
            ifeq 2
        12: .line 270
            return
        end local 1 // boolean done
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   13     0          this  Lio/vertx/proton/impl/ProtonTransport;
            1   13     1          done  Z
            3   11     2  outputBuffer  Ljava/nio/ByteBuffer;
            5    9     3      internal  Lio/vertx/core/impl/NetSocketInternal;
            6    9     4            bb  Lio/netty/buffer/ByteBuf;

  public void disconnect();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.proton.impl.ProtonTransport this
         0: .line 273
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.netClient:Lio/vertx/core/net/NetClient;
            ifnull 3
         1: .line 274
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.netClient:Lio/vertx/core/net/NetClient;
            invokeinterface io.vertx.core.net.NetClient.close:()V
         2: .line 275
            goto 4
         3: .line 276
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
            invokeinterface io.vertx.core.net.NetSocket.close:()V
         4: .line 278
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/proton/impl/ProtonTransport;

  static int[] $SWITCH_TABLE$org$apache$qpid$proton$engine$Event$Type();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 48
            getstatic io.vertx.proton.impl.ProtonTransport.$SWITCH_TABLE$org$apache$qpid$proton$engine$Event$Type:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic org.apache.qpid.proton.engine.Event$Type.values:()[Lorg/apache/qpid/proton/engine/Event$Type;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_BOUND:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.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 org.apache.qpid.proton.engine.Event$Type.CONNECTION_FINAL:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 12
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_INIT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            iconst_5
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_LOCAL_CLOSE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 10
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_LOCAL_OPEN:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 8
            iastore
        15: goto 17
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        16: pop
      StackMap locals:
      StackMap stack:
        17: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_REMOTE_CLOSE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 11
            iastore
        18: goto 20
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        19: pop
      StackMap locals:
      StackMap stack:
        20: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_REMOTE_OPEN:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 9
            iastore
        21: goto 23
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        22: pop
      StackMap locals:
      StackMap stack:
        23: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.CONNECTION_UNBOUND:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 7
            iastore
        24: goto 26
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        25: pop
      StackMap locals:
      StackMap stack:
        26: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.DELIVERY:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 28
            iastore
        27: goto 29
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        28: pop
      StackMap locals:
      StackMap stack:
        29: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_FINAL:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 27
            iastore
        30: goto 32
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        31: pop
      StackMap locals:
      StackMap stack:
        32: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_FLOW:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 26
            iastore
        33: goto 35
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        34: pop
      StackMap locals:
      StackMap stack:
        35: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_INIT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 19
            iastore
        36: goto 38
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        37: pop
      StackMap locals:
      StackMap stack:
        38: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_LOCAL_CLOSE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 24
            iastore
        39: goto 41
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        40: pop
      StackMap locals:
      StackMap stack:
        41: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_LOCAL_DETACH:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 22
            iastore
        42: goto 44
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        43: pop
      StackMap locals:
      StackMap stack:
        44: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_LOCAL_OPEN:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 20
            iastore
        45: goto 47
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        46: pop
      StackMap locals:
      StackMap stack:
        47: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_REMOTE_CLOSE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 25
            iastore
        48: goto 50
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        49: pop
      StackMap locals:
      StackMap stack:
        50: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_REMOTE_DETACH:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 23
            iastore
        51: goto 53
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        52: pop
      StackMap locals:
      StackMap stack:
        53: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.LINK_REMOTE_OPEN:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 21
            iastore
        54: goto 56
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        55: pop
      StackMap locals:
      StackMap stack:
        56: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.NON_CORE_EVENT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 41
            iastore
        57: goto 59
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        58: pop
      StackMap locals:
      StackMap stack:
        59: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.REACTOR_FINAL:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            iconst_3
            iastore
        60: goto 62
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        61: pop
      StackMap locals:
      StackMap stack:
        62: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.REACTOR_INIT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            iconst_1
            iastore
        63: goto 65
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        64: pop
      StackMap locals:
      StackMap stack:
        65: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.REACTOR_QUIESCED:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            iconst_2
            iastore
        66: goto 68
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        67: pop
      StackMap locals:
      StackMap stack:
        68: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_ERROR:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 39
            iastore
        69: goto 71
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        70: pop
      StackMap locals:
      StackMap stack:
        71: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_EXPIRED:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 38
            iastore
        72: goto 74
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        73: pop
      StackMap locals:
      StackMap stack:
        74: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_FINAL:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 40
            iastore
        75: goto 77
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        76: pop
      StackMap locals:
      StackMap stack:
        77: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_INIT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 34
            iastore
        78: goto 80
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        79: pop
      StackMap locals:
      StackMap stack:
        80: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_READABLE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 36
            iastore
        81: goto 83
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        82: pop
      StackMap locals:
      StackMap stack:
        83: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_UPDATED:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 35
            iastore
        84: goto 86
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        85: pop
      StackMap locals:
      StackMap stack:
        86: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SELECTABLE_WRITABLE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 37
            iastore
        87: goto 89
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        88: pop
      StackMap locals:
      StackMap stack:
        89: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SESSION_FINAL:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 18
            iastore
        90: goto 92
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        91: pop
      StackMap locals:
      StackMap stack:
        92: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SESSION_INIT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 13
            iastore
        93: goto 95
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        94: pop
      StackMap locals:
      StackMap stack:
        95: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SESSION_LOCAL_CLOSE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 16
            iastore
        96: goto 98
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        97: pop
      StackMap locals:
      StackMap stack:
        98: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SESSION_LOCAL_OPEN:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 14
            iastore
        99: goto 101
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       100: pop
      StackMap locals:
      StackMap stack:
       101: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SESSION_REMOTE_CLOSE:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 17
            iastore
       102: goto 104
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       103: pop
      StackMap locals:
      StackMap stack:
       104: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.SESSION_REMOTE_OPEN:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 15
            iastore
       105: goto 107
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       106: pop
      StackMap locals:
      StackMap stack:
       107: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.TIMER_TASK:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            iconst_4
            iastore
       108: goto 110
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       109: pop
      StackMap locals:
      StackMap stack:
       110: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.TRANSPORT:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 29
            iastore
       111: goto 113
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       112: pop
      StackMap locals:
      StackMap stack:
       113: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.TRANSPORT_CLOSED:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 33
            iastore
       114: goto 116
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       115: pop
      StackMap locals:
      StackMap stack:
       116: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.TRANSPORT_ERROR:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 30
            iastore
       117: goto 119
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       118: pop
      StackMap locals:
      StackMap stack:
       119: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.TRANSPORT_HEAD_CLOSED:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 31
            iastore
       120: goto 122
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       121: pop
      StackMap locals:
      StackMap stack:
       122: aload 0
            getstatic org.apache.qpid.proton.engine.Event$Type.TRANSPORT_TAIL_CLOSED:Lorg/apache/qpid/proton/engine/Event$Type;
            invokevirtual org.apache.qpid.proton.engine.Event$Type.ordinal:()I
            bipush 32
            iastore
       123: goto 125
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
       124: pop
      StackMap locals:
      StackMap stack:
       125: aload 0
            dup
            putstatic io.vertx.proton.impl.ProtonTransport.$SWITCH_TABLE$org$apache$qpid$proton$engine$Event$Type:[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
          32    33      34  Class java.lang.NoSuchFieldError
          35    36      37  Class java.lang.NoSuchFieldError
          38    39      40  Class java.lang.NoSuchFieldError
          41    42      43  Class java.lang.NoSuchFieldError
          44    45      46  Class java.lang.NoSuchFieldError
          47    48      49  Class java.lang.NoSuchFieldError
          50    51      52  Class java.lang.NoSuchFieldError
          53    54      55  Class java.lang.NoSuchFieldError
          56    57      58  Class java.lang.NoSuchFieldError
          59    60      61  Class java.lang.NoSuchFieldError
          62    63      64  Class java.lang.NoSuchFieldError
          65    66      67  Class java.lang.NoSuchFieldError
          68    69      70  Class java.lang.NoSuchFieldError
          71    72      73  Class java.lang.NoSuchFieldError
          74    75      76  Class java.lang.NoSuchFieldError
          77    78      79  Class java.lang.NoSuchFieldError
          80    81      82  Class java.lang.NoSuchFieldError
          83    84      85  Class java.lang.NoSuchFieldError
          86    87      88  Class java.lang.NoSuchFieldError
          89    90      91  Class java.lang.NoSuchFieldError
          92    93      94  Class java.lang.NoSuchFieldError
          95    96      97  Class java.lang.NoSuchFieldError
          98    99     100  Class java.lang.NoSuchFieldError
         101   102     103  Class java.lang.NoSuchFieldError
         104   105     106  Class java.lang.NoSuchFieldError
         107   108     109  Class java.lang.NoSuchFieldError
         110   111     112  Class java.lang.NoSuchFieldError
         113   114     115  Class java.lang.NoSuchFieldError
         116   117     118  Class java.lang.NoSuchFieldError
         119   120     121  Class java.lang.NoSuchFieldError
         122   123     124  Class java.lang.NoSuchFieldError

  private void lambda$2(java.lang.Boolean);
    descriptor: (Ljava/lang/Boolean;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.proton.impl.ProtonTransport this
        start local 1 // java.lang.Boolean complete
         0: .line 212
            aload 1 /* complete */
            invokevirtual java.lang.Boolean.booleanValue:()Z
            ifeq 2
         1: .line 213
            aload 0 /* this */
            aconst_null
            putfield io.vertx.proton.impl.ProtonTransport.authenticator:Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
         2: .line 216
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.proton.impl.ProtonTransport.socket:Lio/vertx/core/net/NetSocket;
            invokeinterface io.vertx.core.net.NetSocket.resume:()Lio/vertx/core/net/NetSocket;
            pop
         3: .line 217
            return
        end local 1 // java.lang.Boolean complete
        end local 0 // io.vertx.proton.impl.ProtonTransport this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/vertx/proton/impl/ProtonTransport;
            0    4     1  complete  Ljava/lang/Boolean;
}
SourceFile: "ProtonTransport.java"
NestMembers:
  io.vertx.proton.impl.ProtonTransport$IdleTimeoutCheck
InnerClasses:
  private final IdleTimeoutCheck = io.vertx.proton.impl.ProtonTransport$IdleTimeoutCheck of io.vertx.proton.impl.ProtonTransport
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public Type = org.apache.qpid.proton.engine.Event$Type of org.apache.qpid.proton.engine.Event
/

io.vertx/ vertx-proton/ 3.8.0/ io/vertx/proton/impl/ProtonTransport.class
