public class io.undertow.conduits.IdleTimeoutConduit implements org.xnio.conduits.StreamSinkConduit, org.xnio.conduits.StreamSourceConduit
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.undertow.conduits.IdleTimeoutConduit
  super_class: java.lang.Object
{
  private static final int DELTA;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 100

  private volatile org.xnio.XnioExecutor$Key handle;
    descriptor: Lorg/xnio/XnioExecutor$Key;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile long idleTimeout;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile long expireTime;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile boolean timedOut;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private final org.xnio.conduits.StreamSinkConduit sink;
    descriptor: Lorg/xnio/conduits/StreamSinkConduit;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.xnio.conduits.StreamSourceConduit source;
    descriptor: Lorg/xnio/conduits/StreamSourceConduit;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private volatile org.xnio.conduits.WriteReadyHandler writeReadyHandler;
    descriptor: Lorg/xnio/conduits/WriteReadyHandler;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.xnio.conduits.ReadReadyHandler readReadyHandler;
    descriptor: Lorg/xnio/conduits/ReadReadyHandler;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private final java.lang.Runnable timeoutCommand;
    descriptor: Ljava/lang/Runnable;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  protected void doClose();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 91
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokestatic io.undertow.conduits.IdleTimeoutConduit.safeClose:(Lorg/xnio/conduits/StreamSinkConduit;)V
         1: .line 92
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokestatic io.undertow.conduits.IdleTimeoutConduit.safeClose:(Lorg/xnio/conduits/StreamSourceConduit;)V
         2: .line 93
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void <init>(org.xnio.StreamConnection);
    descriptor: (Lorg/xnio/StreamConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // org.xnio.StreamConnection connection
         0: .line 95
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 51
            aload 0 /* this */
            ldc -1
            putfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
         2: .line 52
            aload 0 /* this */
            iconst_0
            putfield io.undertow.conduits.IdleTimeoutConduit.timedOut:Z
         3: .line 60
            aload 0 /* this */
            new io.undertow.conduits.IdleTimeoutConduit$1
            dup
            aload 0 /* this */
            invokespecial io.undertow.conduits.IdleTimeoutConduit$1.<init>:(Lio/undertow/conduits/IdleTimeoutConduit;)V
            putfield io.undertow.conduits.IdleTimeoutConduit.timeoutCommand:Ljava/lang/Runnable;
         4: .line 96
            aload 0 /* this */
            aload 1 /* connection */
            invokevirtual org.xnio.StreamConnection.getSinkChannel:()Lorg/xnio/conduits/ConduitStreamSinkChannel;
            invokevirtual org.xnio.conduits.ConduitStreamSinkChannel.getConduit:()Lorg/xnio/conduits/StreamSinkConduit;
            putfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
         5: .line 97
            aload 0 /* this */
            aload 1 /* connection */
            invokevirtual org.xnio.StreamConnection.getSourceChannel:()Lorg/xnio/conduits/ConduitStreamSourceChannel;
            invokevirtual org.xnio.conduits.ConduitStreamSourceChannel.getConduit:()Lorg/xnio/conduits/StreamSourceConduit;
            putfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
         6: .line 98
            aload 0 /* this */
            new org.xnio.conduits.WriteReadyHandler$ChannelListenerHandler
            dup
            aload 1 /* connection */
            invokevirtual org.xnio.StreamConnection.getSinkChannel:()Lorg/xnio/conduits/ConduitStreamSinkChannel;
            invokespecial org.xnio.conduits.WriteReadyHandler$ChannelListenerHandler.<init>:(Lorg/xnio/channels/SuspendableWriteChannel;)V
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.setWriteReadyHandler:(Lorg/xnio/conduits/WriteReadyHandler;)V
         7: .line 99
            aload 0 /* this */
            new org.xnio.conduits.ReadReadyHandler$ChannelListenerHandler
            dup
            aload 1 /* connection */
            invokevirtual org.xnio.StreamConnection.getSourceChannel:()Lorg/xnio/conduits/ConduitStreamSourceChannel;
            invokespecial org.xnio.conduits.ReadReadyHandler$ChannelListenerHandler.<init>:(Lorg/xnio/channels/SuspendableReadChannel;)V
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.setReadReadyHandler:(Lorg/xnio/conduits/ReadReadyHandler;)V
         8: .line 100
            return
        end local 1 // org.xnio.StreamConnection connection
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    9     0        this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    9     1  connection  Lorg/xnio/StreamConnection;
    MethodParameters:
            Name  Flags
      connection  

  private void handleIdleTimeout();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=7, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 103
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.timedOut:Z
            ifeq 2
         1: .line 104
            return
         2: .line 106
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.idleTimeout:J
            lstore 1 /* idleTimeout */
        start local 1 // long idleTimeout
         3: .line 107
            lload 1 /* idleTimeout */
            lconst_0
            lcmp
            ifgt 5
         4: .line 108
            return
         5: .line 110
      StackMap locals: long
      StackMap stack:
            invokestatic java.lang.System.currentTimeMillis:()J
            lstore 3 /* currentTime */
        start local 3 // long currentTime
         6: .line 111
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
            lstore 5 /* expireTimeVar */
        start local 5 // long expireTimeVar
         7: .line 112
            lload 5 /* expireTimeVar */
            ldc -1
            lcmp
            ifeq 11
            lload 3 /* currentTime */
            lload 5 /* expireTimeVar */
            lcmp
            ifle 11
         8: .line 113
            aload 0 /* this */
            iconst_1
            putfield io.undertow.conduits.IdleTimeoutConduit.timedOut:Z
         9: .line 114
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.doClose:()V
        10: .line 115
            new java.nio.channels.ClosedChannelException
            dup
            invokespecial java.nio.channels.ClosedChannelException.<init>:()V
            athrow
        11: .line 117
      StackMap locals: long long
      StackMap stack:
            aload 0 /* this */
            lload 3 /* currentTime */
            lload 1 /* idleTimeout */
            ladd
            putfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
        12: .line 118
            return
        end local 5 // long expireTimeVar
        end local 3 // long currentTime
        end local 1 // long idleTimeout
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   13     0           this  Lio/undertow/conduits/IdleTimeoutConduit;
            3   13     1    idleTimeout  J
            6   13     3    currentTime  J
            7   13     5  expireTimeVar  J
    Exceptions:
      throws java.nio.channels.ClosedChannelException

  public int write(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.ByteBuffer src
         0: .line 122
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 123
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* src */
            invokeinterface org.xnio.conduits.StreamSinkConduit.write:(Ljava/nio/ByteBuffer;)I
            istore 2 /* w */
        start local 2 // int w
         2: .line 124
            iload 2 /* w */
            ireturn
        end local 2 // int w
        end local 1 // java.nio.ByteBuffer src
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    3     1   src  Ljava/nio/ByteBuffer;
            2    3     2     w  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      src   

  public long write(java.nio.ByteBuffer[], int, int);
    descriptor: ([Ljava/nio/ByteBuffer;II)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.ByteBuffer[] srcs
        start local 2 // int offset
        start local 3 // int length
         0: .line 129
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 130
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* srcs */
            iload 2 /* offset */
            iload 3 /* length */
            invokeinterface org.xnio.conduits.StreamSinkConduit.write:([Ljava/nio/ByteBuffer;II)J
            lstore 4 /* w */
        start local 4 // long w
         2: .line 131
            lload 4 /* w */
            lreturn
        end local 4 // long w
        end local 3 // int length
        end local 2 // int offset
        end local 1 // java.nio.ByteBuffer[] srcs
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    3     1    srcs  [Ljava/nio/ByteBuffer;
            0    3     2  offset  I
            0    3     3  length  I
            2    3     4       w  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      srcs    
      offset  
      length  

  public int writeFinal(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.ByteBuffer src
         0: .line 136
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 137
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* src */
            invokeinterface org.xnio.conduits.StreamSinkConduit.writeFinal:(Ljava/nio/ByteBuffer;)I
            istore 2 /* w */
        start local 2 // int w
         2: .line 138
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.isReadShutdown:()Z
            ifeq 6
            aload 1 /* src */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 6
         3: .line 139
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 6
         4: .line 140
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         5: .line 141
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         6: .line 144
      StackMap locals: int
      StackMap stack:
            iload 2 /* w */
            ireturn
        end local 2 // int w
        end local 1 // java.nio.ByteBuffer src
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    7     1   src  Ljava/nio/ByteBuffer;
            2    7     2     w  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      src   

  public long writeFinal(java.nio.ByteBuffer[], int, int);
    descriptor: ([Ljava/nio/ByteBuffer;II)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.ByteBuffer[] srcs
        start local 2 // int offset
        start local 3 // int length
         0: .line 149
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 150
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* srcs */
            iload 2 /* offset */
            iload 3 /* length */
            invokeinterface org.xnio.conduits.StreamSinkConduit.writeFinal:([Ljava/nio/ByteBuffer;II)J
            lstore 4 /* w */
        start local 4 // long w
         2: .line 151
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.isReadShutdown:()Z
            ifeq 6
            aload 1 /* srcs */
            iload 2 /* offset */
            iload 3 /* length */
            invokestatic org.xnio.Buffers.hasRemaining:([Ljava/nio/Buffer;II)Z
            ifne 6
         3: .line 152
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 6
         4: .line 153
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         5: .line 154
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         6: .line 157
      StackMap locals: long
      StackMap stack:
            lload 4 /* w */
            lreturn
        end local 4 // long w
        end local 3 // int length
        end local 2 // int offset
        end local 1 // java.nio.ByteBuffer[] srcs
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    7     1    srcs  [Ljava/nio/ByteBuffer;
            0    7     2  offset  I
            0    7     3  length  I
            2    7     4       w  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      srcs    
      offset  
      length  

  public long transferTo(long, long, java.nio.channels.FileChannel);
    descriptor: (JJLjava/nio/channels/FileChannel;)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=8, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // long position
        start local 3 // long count
        start local 5 // java.nio.channels.FileChannel target
         0: .line 162
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 163
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            lload 1 /* position */
            lload 3 /* count */
            aload 5 /* target */
            invokeinterface org.xnio.conduits.StreamSourceConduit.transferTo:(JJLjava/nio/channels/FileChannel;)J
            lstore 6 /* w */
        start local 6 // long w
         2: .line 164
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteShutdown:()Z
            ifeq 6
            lload 6 /* w */
            ldc -1
            lcmp
            ifne 6
         3: .line 165
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 6
         4: .line 166
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         5: .line 167
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         6: .line 170
      StackMap locals: long
      StackMap stack:
            lload 6 /* w */
            lreturn
        end local 6 // long w
        end local 5 // java.nio.channels.FileChannel target
        end local 3 // long count
        end local 1 // long position
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    7     1  position  J
            0    7     3     count  J
            0    7     5    target  Ljava/nio/channels/FileChannel;
            2    7     6         w  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      position  
      count     
      target    

  public long transferTo(long, java.nio.ByteBuffer, org.xnio.channels.StreamSinkChannel);
    descriptor: (JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // long count
        start local 3 // java.nio.ByteBuffer throughBuffer
        start local 4 // org.xnio.channels.StreamSinkChannel target
         0: .line 175
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 176
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            lload 1 /* count */
            aload 3 /* throughBuffer */
            aload 4 /* target */
            invokeinterface org.xnio.conduits.StreamSourceConduit.transferTo:(JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
            lstore 5 /* w */
        start local 5 // long w
         2: .line 177
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteShutdown:()Z
            ifeq 6
            lload 5 /* w */
            ldc -1
            lcmp
            ifne 6
         3: .line 178
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 6
         4: .line 179
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         5: .line 180
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         6: .line 183
      StackMap locals: long
      StackMap stack:
            lload 5 /* w */
            lreturn
        end local 5 // long w
        end local 4 // org.xnio.channels.StreamSinkChannel target
        end local 3 // java.nio.ByteBuffer throughBuffer
        end local 1 // long count
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    7     0           this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    7     1          count  J
            0    7     3  throughBuffer  Ljava/nio/ByteBuffer;
            0    7     4         target  Lorg/xnio/channels/StreamSinkChannel;
            2    7     5              w  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
               Name  Flags
      count          
      throughBuffer  
      target         

  public long read(java.nio.ByteBuffer[], int, int);
    descriptor: ([Ljava/nio/ByteBuffer;II)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.ByteBuffer[] dsts
        start local 2 // int offset
        start local 3 // int length
         0: .line 188
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 189
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            aload 1 /* dsts */
            iload 2 /* offset */
            iload 3 /* length */
            invokeinterface org.xnio.conduits.StreamSourceConduit.read:([Ljava/nio/ByteBuffer;II)J
            lstore 4 /* r */
        start local 4 // long r
         2: .line 190
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteShutdown:()Z
            ifeq 6
            lload 4 /* r */
            ldc -1
            lcmp
            ifne 6
         3: .line 191
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 6
         4: .line 192
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         5: .line 193
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         6: .line 196
      StackMap locals: long
      StackMap stack:
            lload 4 /* r */
            lreturn
        end local 4 // long r
        end local 3 // int length
        end local 2 // int offset
        end local 1 // java.nio.ByteBuffer[] dsts
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    7     1    dsts  [Ljava/nio/ByteBuffer;
            0    7     2  offset  I
            0    7     3  length  I
            2    7     4       r  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      dsts    
      offset  
      length  

  public int read(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.ByteBuffer dst
         0: .line 201
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 202
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            aload 1 /* dst */
            invokeinterface org.xnio.conduits.StreamSourceConduit.read:(Ljava/nio/ByteBuffer;)I
            istore 2 /* r */
        start local 2 // int r
         2: .line 203
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteShutdown:()Z
            ifeq 6
            iload 2 /* r */
            iconst_m1
            if_icmpne 6
         3: .line 204
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 6
         4: .line 205
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         5: .line 206
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         6: .line 209
      StackMap locals: int
      StackMap stack:
            iload 2 /* r */
            ireturn
        end local 2 // int r
        end local 1 // java.nio.ByteBuffer dst
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    7     1   dst  Ljava/nio/ByteBuffer;
            2    7     2     r  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      dst   

  public long transferFrom(java.nio.channels.FileChannel, long, long);
    descriptor: (Ljava/nio/channels/FileChannel;JJ)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=6, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // java.nio.channels.FileChannel src
        start local 2 // long position
        start local 4 // long count
         0: .line 214
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 215
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* src */
            lload 2 /* position */
            lload 4 /* count */
            invokeinterface org.xnio.conduits.StreamSinkConduit.transferFrom:(Ljava/nio/channels/FileChannel;JJ)J
            lreturn
        end local 4 // long count
        end local 2 // long position
        end local 1 // java.nio.channels.FileChannel src
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    2     1       src  Ljava/nio/channels/FileChannel;
            0    2     2  position  J
            0    2     4     count  J
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      src       
      position  
      count     

  public long transferFrom(org.xnio.channels.StreamSourceChannel, long, java.nio.ByteBuffer);
    descriptor: (Lorg/xnio/channels/StreamSourceChannel;JLjava/nio/ByteBuffer;)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // org.xnio.channels.StreamSourceChannel source
        start local 2 // long count
        start local 4 // java.nio.ByteBuffer throughBuffer
         0: .line 220
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleIdleTimeout:()V
         1: .line 221
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* source */
            lload 2 /* count */
            aload 4 /* throughBuffer */
            invokeinterface org.xnio.conduits.StreamSinkConduit.transferFrom:(Lorg/xnio/channels/StreamSourceChannel;JLjava/nio/ByteBuffer;)J
            lreturn
        end local 4 // java.nio.ByteBuffer throughBuffer
        end local 2 // long count
        end local 1 // org.xnio.channels.StreamSourceChannel source
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0           this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    2     1         source  Lorg/xnio/channels/StreamSourceChannel;
            0    2     2          count  J
            0    2     4  throughBuffer  Ljava/nio/ByteBuffer;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
               Name  Flags
      source         
      count          
      throughBuffer  

  public void suspendReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 226
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.suspendReads:()V
         1: .line 227
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            astore 1 /* handle */
        start local 1 // org.xnio.XnioExecutor$Key handle
         2: .line 228
            aload 1 /* handle */
            ifnull 5
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.isWriteResumed:()Z
            ifne 5
         3: .line 229
            aload 1 /* handle */
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         4: .line 230
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         5: .line 232
      StackMap locals: org.xnio.XnioExecutor$Key
      StackMap stack:
            return
        end local 1 // org.xnio.XnioExecutor$Key handle
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0    this  Lio/undertow/conduits/IdleTimeoutConduit;
            2    6     1  handle  Lorg/xnio/XnioExecutor$Key;

  public void terminateReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 236
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.terminateReads:()V
         1: .line 237
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteShutdown:()Z
            ifeq 5
         2: .line 238
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 5
         3: .line 239
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         4: .line 240
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         5: .line 243
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
    Exceptions:
      throws java.io.IOException

  public boolean isReadShutdown();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 247
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.isReadShutdown:()Z
            ireturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void resumeReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 252
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.resumeReads:()V
         1: .line 253
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleResumeTimeout:()V
         2: .line 254
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public boolean isReadResumed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 258
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.isReadResumed:()Z
            ireturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void wakeupReads();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 263
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.wakeupReads:()V
         1: .line 264
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleResumeTimeout:()V
         2: .line 265
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void awaitReadable();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 268
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.awaitReadable:()V
         1: .line 269
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
    Exceptions:
      throws java.io.IOException

  public void awaitReadable(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // long time
        start local 3 // java.util.concurrent.TimeUnit timeUnit
         0: .line 273
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            lload 1 /* time */
            aload 3 /* timeUnit */
            invokeinterface org.xnio.conduits.StreamSourceConduit.awaitReadable:(JLjava/util/concurrent/TimeUnit;)V
         1: .line 274
            return
        end local 3 // java.util.concurrent.TimeUnit timeUnit
        end local 1 // long time
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    2     1      time  J
            0    2     3  timeUnit  Ljava/util/concurrent/TimeUnit;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      time      
      timeUnit  

  public org.xnio.XnioIoThread getReadThread();
    descriptor: ()Lorg/xnio/XnioIoThread;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 278
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.getReadThread:()Lorg/xnio/XnioIoThread;
            areturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void setReadReadyHandler(org.xnio.conduits.ReadReadyHandler);
    descriptor: (Lorg/xnio/conduits/ReadReadyHandler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // org.xnio.conduits.ReadReadyHandler handler
         0: .line 283
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.undertow.conduits.IdleTimeoutConduit.readReadyHandler:Lorg/xnio/conduits/ReadReadyHandler;
         1: .line 284
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            aload 1 /* handler */
            invokeinterface org.xnio.conduits.StreamSourceConduit.setReadReadyHandler:(Lorg/xnio/conduits/ReadReadyHandler;)V
         2: .line 285
            return
        end local 1 // org.xnio.conduits.ReadReadyHandler handler
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    3     1  handler  Lorg/xnio/conduits/ReadReadyHandler;
    MethodParameters:
         Name  Flags
      handler  

  private static void safeClose(org.xnio.conduits.StreamSourceConduit);
    descriptor: (Lorg/xnio/conduits/StreamSourceConduit;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.xnio.conduits.StreamSourceConduit sink
         0: .line 289
            aload 0 /* sink */
            invokeinterface org.xnio.conduits.StreamSourceConduit.terminateReads:()V
         1: .line 290
            goto 3
      StackMap locals:
      StackMap stack: java.io.IOException
         2: pop
         3: .line 292
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.xnio.conduits.StreamSourceConduit sink
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  sink  Lorg/xnio/conduits/StreamSourceConduit;
      Exception table:
        from    to  target  type
           0     1       2  Class java.io.IOException
    MethodParameters:
      Name  Flags
      sink  final

  private static void safeClose(org.xnio.conduits.StreamSinkConduit);
    descriptor: (Lorg/xnio/conduits/StreamSinkConduit;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.xnio.conduits.StreamSinkConduit sink
         0: .line 296
            aload 0 /* sink */
            invokeinterface org.xnio.conduits.StreamSinkConduit.truncateWrites:()V
         1: .line 297
            goto 3
      StackMap locals:
      StackMap stack: java.io.IOException
         2: pop
         3: .line 299
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.xnio.conduits.StreamSinkConduit sink
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  sink  Lorg/xnio/conduits/StreamSinkConduit;
      Exception table:
        from    to  target  type
           0     1       2  Class java.io.IOException
    MethodParameters:
      Name  Flags
      sink  final

  public void terminateWrites();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 303
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.terminateWrites:()V
         1: .line 304
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.isReadShutdown:()Z
            ifeq 5
         2: .line 305
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 5
         3: .line 306
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         4: .line 307
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         5: .line 310
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
    Exceptions:
      throws java.io.IOException

  public boolean isWriteShutdown();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 314
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteShutdown:()Z
            ireturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void resumeWrites();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 319
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.resumeWrites:()V
         1: .line 320
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleResumeTimeout:()V
         2: .line 321
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void suspendWrites();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 325
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.suspendWrites:()V
         1: .line 326
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            astore 1 /* handle */
        start local 1 // org.xnio.XnioExecutor$Key handle
         2: .line 327
            aload 1 /* handle */
            ifnull 5
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.isReadResumed:()Z
            ifne 5
         3: .line 328
            aload 1 /* handle */
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         4: .line 329
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         5: .line 332
      StackMap locals: org.xnio.XnioExecutor$Key
      StackMap stack:
            return
        end local 1 // org.xnio.XnioExecutor$Key handle
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0    this  Lio/undertow/conduits/IdleTimeoutConduit;
            2    6     1  handle  Lorg/xnio/XnioExecutor$Key;

  public void wakeupWrites();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 336
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.wakeupWrites:()V
         1: .line 337
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleResumeTimeout:()V
         2: .line 338
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  private void handleResumeTimeout();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=9, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 341
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.getIdleTimeout:()J
            lstore 1 /* timeout */
        start local 1 // long timeout
         1: .line 342
            lload 1 /* timeout */
            lconst_0
            lcmp
            ifgt 3
         2: .line 343
            return
         3: .line 345
      StackMap locals: long
      StackMap stack:
            invokestatic java.lang.System.currentTimeMillis:()J
            lstore 3 /* currentTime */
        start local 3 // long currentTime
         4: .line 346
            lload 3 /* currentTime */
            lload 1 /* timeout */
            ladd
            lstore 5 /* newExpireTime */
        start local 5 // long newExpireTime
         5: .line 347
            lload 5 /* newExpireTime */
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
            lcmp
            ifge 6
            iconst_1
            goto 7
      StackMap locals: long long
      StackMap stack:
         6: iconst_0
      StackMap locals:
      StackMap stack: int
         7: istore 7 /* shorter */
        start local 7 // boolean shorter
         8: .line 348
            iload 7 /* shorter */
            ifeq 11
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 11
         9: .line 349
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
        10: .line 350
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
        11: .line 352
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            lload 5 /* newExpireTime */
            putfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
        12: .line 353
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            astore 8 /* key */
        start local 8 // org.xnio.XnioExecutor$Key key
        13: .line 354
            aload 8 /* key */
            ifnonnull 15
        14: .line 355
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.getWriteThread:()Lorg/xnio/XnioIoThread;
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.timeoutCommand:Ljava/lang/Runnable;
            lload 1 /* timeout */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokestatic io.undertow.util.WorkerUtils.executeAfter:(Lorg/xnio/XnioIoThread;Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lorg/xnio/XnioExecutor$Key;
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
        15: .line 357
      StackMap locals: org.xnio.XnioExecutor$Key
      StackMap stack:
            return
        end local 8 // org.xnio.XnioExecutor$Key key
        end local 7 // boolean shorter
        end local 5 // long newExpireTime
        end local 3 // long currentTime
        end local 1 // long timeout
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   16     0           this  Lio/undertow/conduits/IdleTimeoutConduit;
            1   16     1        timeout  J
            4   16     3    currentTime  J
            5   16     5  newExpireTime  J
            8   16     7        shorter  Z
           13   16     8            key  Lorg/xnio/XnioExecutor$Key;

  public boolean isWriteResumed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 361
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteResumed:()Z
            ireturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void awaitWritable();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 366
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.awaitWritable:()V
         1: .line 367
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
    Exceptions:
      throws java.io.IOException

  public void awaitWritable(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=4, args_size=3
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // long time
        start local 3 // java.util.concurrent.TimeUnit timeUnit
         0: .line 371
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.awaitWritable:()V
         1: .line 372
            return
        end local 3 // java.util.concurrent.TimeUnit timeUnit
        end local 1 // long time
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    2     1      time  J
            0    2     3  timeUnit  Ljava/util/concurrent/TimeUnit;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      time      
      timeUnit  

  public org.xnio.XnioIoThread getWriteThread();
    descriptor: ()Lorg/xnio/XnioIoThread;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 376
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.getWriteThread:()Lorg/xnio/XnioIoThread;
            areturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void setWriteReadyHandler(org.xnio.conduits.WriteReadyHandler);
    descriptor: (Lorg/xnio/conduits/WriteReadyHandler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // org.xnio.conduits.WriteReadyHandler handler
         0: .line 381
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.undertow.conduits.IdleTimeoutConduit.writeReadyHandler:Lorg/xnio/conduits/WriteReadyHandler;
         1: .line 382
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            aload 1 /* handler */
            invokeinterface org.xnio.conduits.StreamSinkConduit.setWriteReadyHandler:(Lorg/xnio/conduits/WriteReadyHandler;)V
         2: .line 383
            return
        end local 1 // org.xnio.conduits.WriteReadyHandler handler
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    3     1  handler  Lorg/xnio/conduits/WriteReadyHandler;
    MethodParameters:
         Name  Flags
      handler  

  public void truncateWrites();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 387
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.truncateWrites:()V
         1: .line 388
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.source:Lorg/xnio/conduits/StreamSourceConduit;
            invokeinterface org.xnio.conduits.StreamSourceConduit.isReadShutdown:()Z
            ifeq 5
         2: .line 389
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            ifnull 5
         3: .line 390
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
            invokeinterface org.xnio.XnioExecutor$Key.remove:()Z
            pop
         4: .line 391
            aload 0 /* this */
            aconst_null
            putfield io.undertow.conduits.IdleTimeoutConduit.handle:Lorg/xnio/XnioExecutor$Key;
         5: .line 394
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
    Exceptions:
      throws java.io.IOException

  public boolean flush();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 399
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.flush:()Z
            ireturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;
    Exceptions:
      throws java.io.IOException

  public org.xnio.XnioWorker getWorker();
    descriptor: ()Lorg/xnio/XnioWorker;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 404
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.sink:Lorg/xnio/conduits/StreamSinkConduit;
            invokeinterface org.xnio.conduits.StreamSinkConduit.getWorker:()Lorg/xnio/XnioWorker;
            areturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public long getIdleTimeout();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
         0: .line 408
            aload 0 /* this */
            getfield io.undertow.conduits.IdleTimeoutConduit.idleTimeout:J
            lreturn
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/undertow/conduits/IdleTimeoutConduit;

  public void setIdleTimeout(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.undertow.conduits.IdleTimeoutConduit this
        start local 1 // long idleTimeout
         0: .line 412
            aload 0 /* this */
            lload 1 /* idleTimeout */
            putfield io.undertow.conduits.IdleTimeoutConduit.idleTimeout:J
         1: .line 413
            lload 1 /* idleTimeout */
            lconst_0
            lcmp
            ifle 6
         2: .line 414
            aload 0 /* this */
            invokestatic java.lang.System.currentTimeMillis:()J
            lload 1 /* idleTimeout */
            ladd
            putfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
         3: .line 415
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.isReadResumed:()Z
            ifne 4
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.isWriteResumed:()Z
            ifeq 7
         4: .line 416
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.undertow.conduits.IdleTimeoutConduit.handleResumeTimeout:()V
         5: .line 418
            goto 7
         6: .line 419
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            ldc -1
            putfield io.undertow.conduits.IdleTimeoutConduit.expireTime:J
         7: .line 421
      StackMap locals:
      StackMap stack:
            return
        end local 1 // long idleTimeout
        end local 0 // io.undertow.conduits.IdleTimeoutConduit this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0         this  Lio/undertow/conduits/IdleTimeoutConduit;
            0    8     1  idleTimeout  J
    MethodParameters:
             Name  Flags
      idleTimeout  
}
SourceFile: "IdleTimeoutConduit.java"
NestMembers:
  io.undertow.conduits.IdleTimeoutConduit$1
InnerClasses:
  io.undertow.conduits.IdleTimeoutConduit$1
  public abstract Key = org.xnio.XnioExecutor$Key of org.xnio.XnioExecutor
  public ChannelListenerHandler = org.xnio.conduits.ReadReadyHandler$ChannelListenerHandler of org.xnio.conduits.ReadReadyHandler
  public ChannelListenerHandler = org.xnio.conduits.WriteReadyHandler$ChannelListenerHandler of org.xnio.conduits.WriteReadyHandler