org.eclipse.jetty/jetty-server/11.0.0 : org/eclipse/jetty/server/BlockingContentProducer.class

BlockingContentProducer
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.BlockingContentProducer implements org.eclipse.jetty.server.ContentProducer
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.eclipse.jetty.server.BlockingContentProducer
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger LOG;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.concurrent.Semaphore _semaphore;
    descriptor: Ljava/util/concurrent/Semaphore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.eclipse.jetty.server.AsyncContentProducer _asyncContentProducer;
    descriptor: Lorg/eclipse/jetty/server/AsyncContentProducer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 32
            ldc Lorg/eclipse/jetty/server/BlockingContentProducer;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(org.eclipse.jetty.server.AsyncContentProducer);
    descriptor: (Lorg/eclipse/jetty/server/AsyncContentProducer;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
        start local 1 // org.eclipse.jetty.server.AsyncContentProducer delegate
         0: .line 37
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 34
            aload 0 /* this */
            new java.util.concurrent.Semaphore
            dup
            iconst_0
            invokespecial java.util.concurrent.Semaphore.<init>:(I)V
            putfield org.eclipse.jetty.server.BlockingContentProducer._semaphore:Ljava/util/concurrent/Semaphore;
         2: .line 39
            aload 0 /* this */
            aload 1 /* delegate */
            putfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
         3: .line 40
            return
        end local 1 // org.eclipse.jetty.server.AsyncContentProducer delegate
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lorg/eclipse/jetty/server/BlockingContentProducer;
            0    4     1  delegate  Lorg/eclipse/jetty/server/AsyncContentProducer;
    MethodParameters:
          Name  Flags
      delegate  

  public void recycle();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 45
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 46
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            ldc "recycling {}"
            aload 0 /* this */
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         2: .line 47
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.recycle:()V
         3: .line 48
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._semaphore:Ljava/util/concurrent/Semaphore;
            invokevirtual java.util.concurrent.Semaphore.drainPermits:()I
            pop
         4: .line 49
            return
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public int available();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 54
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.available:()I
            ireturn
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public boolean hasContent();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 60
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.hasContent:()Z
            ireturn
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public boolean isError();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 66
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.isError:()Z
            ireturn
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public void checkMinDataRate();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 72
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.checkMinDataRate:()V
         1: .line 73
            return
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public long getRawContentArrived();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 78
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.getRawContentArrived:()J
            lreturn
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public boolean consumeAll(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
        start local 1 // java.lang.Throwable x
         0: .line 84
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            aload 1 /* x */
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.consumeAll:(Ljava/lang/Throwable;)Z
            ireturn
        end local 1 // java.lang.Throwable x
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;
            0    1     1     x  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      x     

  public org.eclipse.jetty.server.HttpInput$Content nextContent();
    descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Content;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 92
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.nextContent:()Lorg/eclipse/jetty/server/HttpInput$Content;
            astore 1 /* content */
        start local 1 // org.eclipse.jetty.server.HttpInput$Content content
         1: .line 93
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 3
         2: .line 94
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            ldc "nextContent async producer returned {}"
            aload 1 /* content */
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         3: .line 95
      StackMap locals: org.eclipse.jetty.server.HttpInput$Content
      StackMap stack:
            aload 1 /* content */
            ifnull 5
         4: .line 96
            aload 1 /* content */
            areturn
         5: .line 100
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.isReady:()Z
            ifeq 9
         6: .line 102
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 0
         7: .line 103
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            ldc "nextContent async producer is ready, retrying"
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;)V
         8: .line 104
            goto 0
         9: .line 106
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 11
        10: .line 107
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            ldc "nextContent async producer is not ready, waiting on semaphore {}"
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._semaphore:Ljava/util/concurrent/Semaphore;
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
        11: .line 111
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._semaphore:Ljava/util/concurrent/Semaphore;
            invokevirtual java.util.concurrent.Semaphore.acquire:()V
        12: .line 112
            goto 0
        13: .line 113
      StackMap locals:
      StackMap stack: java.lang.InterruptedException
            astore 2 /* e */
        start local 2 // java.lang.InterruptedException e
        14: .line 115
            new org.eclipse.jetty.server.HttpInput$ErrorContent
            dup
            aload 2 /* e */
            invokespecial org.eclipse.jetty.server.HttpInput$ErrorContent.<init>:(Ljava/lang/Throwable;)V
            areturn
        end local 2 // java.lang.InterruptedException e
        end local 1 // org.eclipse.jetty.server.HttpInput$Content content
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   15     0     this  Lorg/eclipse/jetty/server/BlockingContentProducer;
            1   15     1  content  Lorg/eclipse/jetty/server/HttpInput$Content;
           14   15     2        e  Ljava/lang/InterruptedException;
      Exception table:
        from    to  target  type
          11    12      13  Class java.lang.InterruptedException

  public void reclaim(org.eclipse.jetty.server.HttpInput$Content);
    descriptor: (Lorg/eclipse/jetty/server/HttpInput$Content;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
        start local 1 // org.eclipse.jetty.server.HttpInput$Content content
         0: .line 123
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            aload 1 /* content */
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.reclaim:(Lorg/eclipse/jetty/server/HttpInput$Content;)V
         1: .line 124
            return
        end local 1 // org.eclipse.jetty.server.HttpInput$Content content
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lorg/eclipse/jetty/server/BlockingContentProducer;
            0    2     1  content  Lorg/eclipse/jetty/server/HttpInput$Content;
    MethodParameters:
         Name  Flags
      content  

  public boolean isReady();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 129
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.BlockingContentProducer.available:()I
            ifle 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: istore 1 /* ready */
        start local 1 // boolean ready
         3: .line 130
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 5
         4: .line 131
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            ldc "isReady = {}"
            iload 1 /* ready */
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         5: .line 132
      StackMap locals: int
      StackMap stack:
            iload 1 /* ready */
            ireturn
        end local 1 // boolean ready
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    6     0   this  Lorg/eclipse/jetty/server/BlockingContentProducer;
            3    6     1  ready  Z

  public org.eclipse.jetty.server.HttpInput$Interceptor getInterceptor();
    descriptor: ()Lorg/eclipse/jetty/server/HttpInput$Interceptor;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 138
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.getInterceptor:()Lorg/eclipse/jetty/server/HttpInput$Interceptor;
            areturn
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;

  public void setInterceptor(org.eclipse.jetty.server.HttpInput$Interceptor);
    descriptor: (Lorg/eclipse/jetty/server/HttpInput$Interceptor;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
        start local 1 // org.eclipse.jetty.server.HttpInput$Interceptor interceptor
         0: .line 144
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._asyncContentProducer:Lorg/eclipse/jetty/server/AsyncContentProducer;
            aload 1 /* interceptor */
            invokevirtual org.eclipse.jetty.server.AsyncContentProducer.setInterceptor:(Lorg/eclipse/jetty/server/HttpInput$Interceptor;)V
         1: .line 145
            return
        end local 1 // org.eclipse.jetty.server.HttpInput$Interceptor interceptor
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lorg/eclipse/jetty/server/BlockingContentProducer;
            0    2     1  interceptor  Lorg/eclipse/jetty/server/HttpInput$Interceptor;
    MethodParameters:
             Name  Flags
      interceptor  

  public boolean onContentProducible();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.BlockingContentProducer this
         0: .line 159
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 160
            getstatic org.eclipse.jetty.server.BlockingContentProducer.LOG:Lorg/slf4j/Logger;
            ldc "onContentProducible releasing semaphore {}"
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._semaphore:Ljava/util/concurrent/Semaphore;
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         2: .line 161
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.BlockingContentProducer._semaphore:Ljava/util/concurrent/Semaphore;
            invokevirtual java.util.concurrent.Semaphore.release:()V
         3: .line 162
            iconst_0
            ireturn
        end local 0 // org.eclipse.jetty.server.BlockingContentProducer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/eclipse/jetty/server/BlockingContentProducer;
}
SourceFile: "BlockingContentProducer.java"
InnerClasses:
  public Content = org.eclipse.jetty.server.HttpInput$Content of org.eclipse.jetty.server.HttpInput
  public final ErrorContent = org.eclipse.jetty.server.HttpInput$ErrorContent of org.eclipse.jetty.server.HttpInput
  public abstract Interceptor = org.eclipse.jetty.server.HttpInput$Interceptor of org.eclipse.jetty.server.HttpInput
/

org.eclipse.jetty/ jetty-server/ 11.0.0/ org/eclipse/jetty/server/BlockingContentProducer.class
