org.eclipse.jetty/jetty-server/11.0.0 : org/eclipse/jetty/server/HttpOutput$InputStreamWritingCB.class

HttpOutput$InputStreamWritingCB
https://eclipse.org/jetty/jetty-server: The core jetty server artifact. (Webtide)
Greg Wilkins (Webtide, LLC)
Jan Bartel (Webtide, LLC)
Jesse McConnell (Webtide, LLC)
Joakim Erdfelt (Webtide, LLC)
Simone Bordet (Webtide, LLC)
David Jencks (IBM)
Olivier Lamy (Webtide, LLC)
Ludovic Orban (Webtide, LLC)
class org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB extends org.eclipse.jetty.server.HttpOutput$NestedChannelWriteCB
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB
  super_class: org.eclipse.jetty.server.HttpOutput$NestedChannelWriteCB
{
  private final java.io.InputStream _in;
    descriptor: Ljava/io/InputStream;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.nio.ByteBuffer _buffer;
    descriptor: Ljava/nio/ByteBuffer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

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

  final org.eclipse.jetty.server.HttpOutput this$0;
    descriptor: Lorg/eclipse/jetty/server/HttpOutput;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  void <init>(org.eclipse.jetty.server.HttpOutput, java.io.InputStream, org.eclipse.jetty.util.Callback);
    descriptor: (Lorg/eclipse/jetty/server/HttpOutput;Ljava/io/InputStream;Lorg/eclipse/jetty/util/Callback;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB this
        start local 2 // java.io.InputStream in
        start local 3 // org.eclipse.jetty.util.Callback callback
         0: .line 1699
            aload 0 /* this */
            aload 1
            putfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB.this$0:Lorg/eclipse/jetty/server/HttpOutput;
         1: .line 1700
            aload 0 /* this */
            aload 1
            aload 3 /* callback */
            iconst_1
            invokespecial org.eclipse.jetty.server.HttpOutput$NestedChannelWriteCB.<init>:(Lorg/eclipse/jetty/server/HttpOutput;Lorg/eclipse/jetty/util/Callback;Z)V
         2: .line 1701
            aload 0 /* this */
            aload 2 /* in */
            putfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._in:Ljava/io/InputStream;
         3: .line 1703
            aload 0 /* this */
            aload 1
            getfield org.eclipse.jetty.server.HttpOutput._channel:Lorg/eclipse/jetty/server/HttpChannel;
            invokevirtual org.eclipse.jetty.server.HttpChannel.getByteBufferPool:()Lorg/eclipse/jetty/io/ByteBufferPool;
            aload 1
            invokevirtual org.eclipse.jetty.server.HttpOutput.getBufferSize:()I
            iconst_0
            invokeinterface org.eclipse.jetty.io.ByteBufferPool.acquire:(IZ)Ljava/nio/ByteBuffer;
            putfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
         4: .line 1704
            return
        end local 3 // org.eclipse.jetty.util.Callback callback
        end local 2 // java.io.InputStream in
        end local 0 // org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lorg/eclipse/jetty/server/HttpOutput$InputStreamWritingCB;
            0    5     2        in  Ljava/io/InputStream;
            0    5     3  callback  Lorg/eclipse/jetty/util/Callback;
    MethodParameters:
          Name  Flags
      this$0    final
      in        
      callback  

  protected org.eclipse.jetty.util.IteratingCallback$Action process();
    descriptor: ()Lorg/eclipse/jetty/util/IteratingCallback$Action;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB this
         0: .line 1711
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._eof:Z
            ifeq 8
         1: .line 1713
            getstatic org.eclipse.jetty.server.HttpOutput.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 3
         2: .line 1714
            getstatic org.eclipse.jetty.server.HttpOutput.LOG:Lorg/slf4j/Logger;
            ldc "EOF of {}"
            aload 0 /* this */
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         3: .line 1715
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._closed:Z
            ifne 7
         4: .line 1717
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._closed:Z
         5: .line 1718
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB.this$0:Lorg/eclipse/jetty/server/HttpOutput;
            getfield org.eclipse.jetty.server.HttpOutput._channel:Lorg/eclipse/jetty/server/HttpChannel;
            invokevirtual org.eclipse.jetty.server.HttpChannel.getByteBufferPool:()Lorg/eclipse/jetty/io/ByteBufferPool;
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            invokeinterface org.eclipse.jetty.io.ByteBufferPool.release:(Ljava/nio/ByteBuffer;)V
         6: .line 1719
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._in:Ljava/io/InputStream;
            invokestatic org.eclipse.jetty.util.IO.close:(Ljava/io/InputStream;)V
         7: .line 1722
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.util.IteratingCallback$Action.SUCCEEDED:Lorg/eclipse/jetty/util/IteratingCallback$Action;
            areturn
         8: .line 1726
      StackMap locals:
      StackMap stack:
            iconst_0
            istore 1 /* len */
        start local 1 // int len
         9: .line 1727
            goto 14
        10: .line 1729
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._in:Ljava/io/InputStream;
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.array:()[B
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.arrayOffset:()I
            iload 1 /* len */
            iadd
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.capacity:()I
            iload 1 /* len */
            isub
            invokevirtual java.io.InputStream.read:([BII)I
            istore 2 /* r */
        start local 2 // int r
        11: .line 1730
            iload 2 /* r */
            ifge 13
        12: .line 1731
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._eof:Z
            goto 14
        13: .line 1733
      StackMap locals: int
      StackMap stack:
            iload 1 /* len */
            iload 2 /* r */
            iadd
            istore 1 /* len */
        end local 2 // int r
        14: .line 1727
      StackMap locals:
      StackMap stack:
            iload 1 /* len */
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.capacity:()I
            if_icmpge 15
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._eof:Z
            ifeq 10
        15: .line 1737
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            iconst_0
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
        16: .line 1738
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            iload 1 /* len */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
        17: .line 1739
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB.this$0:Lorg/eclipse/jetty/server/HttpOutput;
            dup
            getfield org.eclipse.jetty.server.HttpOutput._written:J
            iload 1 /* len */
            i2l
            ladd
            putfield org.eclipse.jetty.server.HttpOutput._written:J
        18: .line 1740
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB.this$0:Lorg/eclipse/jetty/server/HttpOutput;
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._eof:Z
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.HttpOutput.channelWrite:(Ljava/nio/ByteBuffer;ZLorg/eclipse/jetty/util/Callback;)V
        19: .line 1741
            getstatic org.eclipse.jetty.util.IteratingCallback$Action.SCHEDULED:Lorg/eclipse/jetty/util/IteratingCallback$Action;
            areturn
        end local 1 // int len
        end local 0 // org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   20     0  this  Lorg/eclipse/jetty/server/HttpOutput$InputStreamWritingCB;
            9   20     1   len  I
           11   14     2     r  I
    Exceptions:
      throws java.lang.Exception

  public void onCompleteFailure(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB this
        start local 1 // java.lang.Throwable x
         0: .line 1749
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB.this$0:Lorg/eclipse/jetty/server/HttpOutput;
            getfield org.eclipse.jetty.server.HttpOutput._channel:Lorg/eclipse/jetty/server/HttpChannel;
            invokevirtual org.eclipse.jetty.server.HttpChannel.getByteBufferPool:()Lorg/eclipse/jetty/io/ByteBufferPool;
            aload 0 /* this */
            getfield org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB._buffer:Ljava/nio/ByteBuffer;
            invokeinterface org.eclipse.jetty.io.ByteBufferPool.release:(Ljava/nio/ByteBuffer;)V
         1: .line 1750
            goto 5
         2: .line 1752
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2
         3: .line 1753
            aload 0 /* this */
            aload 1 /* x */
            invokespecial org.eclipse.jetty.server.HttpOutput$NestedChannelWriteCB.onCompleteFailure:(Ljava/lang/Throwable;)V
         4: .line 1754
            aload 2
            athrow
         5: .line 1753
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* x */
            invokespecial org.eclipse.jetty.server.HttpOutput$NestedChannelWriteCB.onCompleteFailure:(Ljava/lang/Throwable;)V
         6: .line 1755
            return
        end local 1 // java.lang.Throwable x
        end local 0 // org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/eclipse/jetty/server/HttpOutput$InputStreamWritingCB;
            0    7     1     x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     2       2  any
    MethodParameters:
      Name  Flags
      x     
}
SourceFile: "HttpOutput.java"
NestHost: org.eclipse.jetty.server.HttpOutput
InnerClasses:
  private InputStreamWritingCB = org.eclipse.jetty.server.HttpOutput$InputStreamWritingCB of org.eclipse.jetty.server.HttpOutput
  private abstract NestedChannelWriteCB = org.eclipse.jetty.server.HttpOutput$NestedChannelWriteCB of org.eclipse.jetty.server.HttpOutput
  protected final Action = org.eclipse.jetty.util.IteratingCallback$Action of org.eclipse.jetty.util.IteratingCallback
/

org.eclipse.jetty/ jetty-server/ 11.0.0/ org/eclipse/jetty/server/HttpOutput$InputStreamWritingCB.class
