org.eclipse.jetty/jetty-util/10.0.0-alpha0 : org/eclipse/jetty/util/SharedBlockingCallback.class

SharedBlockingCallback
http://www.eclipse.org/jetty: Utility classes for Jetty (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)
public class org.eclipse.jetty.util.SharedBlockingCallback
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.SharedBlockingCallback
  super_class: java.lang.Object
{
  private static final org.eclipse.jetty.util.log.Logger LOG;
    descriptor: Lorg/eclipse/jetty/util/log/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static java.lang.Throwable IDLE;
    descriptor: Ljava/lang/Throwable;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC

  private static java.lang.Throwable SUCCEEDED;
    descriptor: Ljava/lang/Throwable;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC

  private static java.lang.Throwable FAILED;
    descriptor: Ljava/lang/Throwable;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC

  private final java.util.concurrent.locks.ReentrantLock _lock;
    descriptor: Ljava/util/concurrent/locks/ReentrantLock;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.locks.Condition _idle;
    descriptor: Ljava/util/concurrent/locks/Condition;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.locks.Condition _complete;
    descriptor: Ljava/util/concurrent/locks/Condition;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private org.eclipse.jetty.util.SharedBlockingCallback$Blocker _blocker;
    descriptor: Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 50
            ldc Lorg/eclipse/jetty/util/SharedBlockingCallback;
            invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
            putstatic org.eclipse.jetty.util.SharedBlockingCallback.LOG:Lorg/eclipse/jetty/util/log/Logger;
         1: .line 52
            new org.eclipse.jetty.util.ConstantThrowable
            dup
            ldc "IDLE"
            invokespecial org.eclipse.jetty.util.ConstantThrowable.<init>:(Ljava/lang/String;)V
            putstatic org.eclipse.jetty.util.SharedBlockingCallback.IDLE:Ljava/lang/Throwable;
         2: .line 53
            new org.eclipse.jetty.util.ConstantThrowable
            dup
            ldc "SUCCEEDED"
            invokespecial org.eclipse.jetty.util.ConstantThrowable.<init>:(Ljava/lang/String;)V
            putstatic org.eclipse.jetty.util.SharedBlockingCallback.SUCCEEDED:Ljava/lang/Throwable;
         3: .line 55
            new org.eclipse.jetty.util.ConstantThrowable
            dup
            ldc "FAILED"
            invokespecial org.eclipse.jetty.util.ConstantThrowable.<init>:(Ljava/lang/String;)V
            putstatic org.eclipse.jetty.util.SharedBlockingCallback.FAILED:Ljava/lang/Throwable;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.SharedBlockingCallback this
         0: .line 48
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 57
            aload 0 /* this */
            new java.util.concurrent.locks.ReentrantLock
            dup
            invokespecial java.util.concurrent.locks.ReentrantLock.<init>:()V
            putfield org.eclipse.jetty.util.SharedBlockingCallback._lock:Ljava/util/concurrent/locks/ReentrantLock;
         2: .line 58
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._lock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.newCondition:()Ljava/util/concurrent/locks/Condition;
            putfield org.eclipse.jetty.util.SharedBlockingCallback._idle:Ljava/util/concurrent/locks/Condition;
         3: .line 59
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._lock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.newCondition:()Ljava/util/concurrent/locks/Condition;
            putfield org.eclipse.jetty.util.SharedBlockingCallback._complete:Ljava/util/concurrent/locks/Condition;
         4: .line 60
            aload 0 /* this */
            new org.eclipse.jetty.util.SharedBlockingCallback$Blocker
            dup
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.SharedBlockingCallback$Blocker.<init>:(Lorg/eclipse/jetty/util/SharedBlockingCallback;)V
            putfield org.eclipse.jetty.util.SharedBlockingCallback._blocker:Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
         5: .line 48
            return
        end local 0 // org.eclipse.jetty.util.SharedBlockingCallback this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lorg/eclipse/jetty/util/SharedBlockingCallback;

  public org.eclipse.jetty.util.SharedBlockingCallback$Blocker acquire();
    descriptor: ()Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.util.SharedBlockingCallback this
         0: .line 64
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._lock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.lock:()V
         1: .line 67
            goto 3
         2: .line 69
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._idle:Ljava/util/concurrent/locks/Condition;
            invokeinterface java.util.concurrent.locks.Condition.await:()V
         3: .line 67
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._blocker:Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
            getfield org.eclipse.jetty.util.SharedBlockingCallback$Blocker._state:Ljava/lang/Throwable;
            getstatic org.eclipse.jetty.util.SharedBlockingCallback.IDLE:Ljava/lang/Throwable;
            if_acmpne 2
         4: .line 71
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._blocker:Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
            aconst_null
            putfield org.eclipse.jetty.util.SharedBlockingCallback$Blocker._state:Ljava/lang/Throwable;
         5: .line 72
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._blocker:Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
            astore 2
         6: .line 80
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._lock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.unlock:()V
         7: .line 72
            aload 2
            areturn
         8: .line 74
      StackMap locals:
      StackMap stack: java.lang.InterruptedException
            pop
         9: .line 76
            new java.io.InterruptedIOException
            dup
            invokespecial java.io.InterruptedIOException.<init>:()V
            athrow
        10: .line 79
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 1
        11: .line 80
            aload 0 /* this */
            getfield org.eclipse.jetty.util.SharedBlockingCallback._lock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.unlock:()V
        12: .line 81
            aload 1
            athrow
        end local 0 // org.eclipse.jetty.util.SharedBlockingCallback this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   13     0  this  Lorg/eclipse/jetty/util/SharedBlockingCallback;
      Exception table:
        from    to  target  type
           1     6       8  Class java.lang.InterruptedException
           1     6      10  any
           8    10      10  any
    Exceptions:
      throws java.io.IOException

  protected void notComplete(org.eclipse.jetty.util.SharedBlockingCallback$Blocker);
    descriptor: (Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.util.SharedBlockingCallback this
        start local 1 // org.eclipse.jetty.util.SharedBlockingCallback$Blocker blocker
         0: .line 86
            getstatic org.eclipse.jetty.util.SharedBlockingCallback.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Blocker not complete {}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* blocker */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
         1: .line 87
            getstatic org.eclipse.jetty.util.SharedBlockingCallback.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 3
         2: .line 88
            getstatic org.eclipse.jetty.util.SharedBlockingCallback.LOG:Lorg/eclipse/jetty/util/log/Logger;
            new java.lang.Throwable
            dup
            invokespecial java.lang.Throwable.<init>:()V
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/Throwable;)V
         3: .line 89
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.eclipse.jetty.util.SharedBlockingCallback$Blocker blocker
        end local 0 // org.eclipse.jetty.util.SharedBlockingCallback this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lorg/eclipse/jetty/util/SharedBlockingCallback;
            0    4     1  blocker  Lorg/eclipse/jetty/util/SharedBlockingCallback$Blocker;
    MethodParameters:
         Name  Flags
      blocker  
}
SourceFile: "SharedBlockingCallback.java"
NestMembers:
  org.eclipse.jetty.util.SharedBlockingCallback$Blocker  org.eclipse.jetty.util.SharedBlockingCallback$BlockerTimeoutException
InnerClasses:
  public Blocker = org.eclipse.jetty.util.SharedBlockingCallback$Blocker of org.eclipse.jetty.util.SharedBlockingCallback
  private BlockerTimeoutException = org.eclipse.jetty.util.SharedBlockingCallback$BlockerTimeoutException of org.eclipse.jetty.util.SharedBlockingCallback
/

org.eclipse.jetty/ jetty-util/ 10.0.0-alpha0/ org/eclipse/jetty/util/SharedBlockingCallback.class
