org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/utils/concurrent/Ref$State.class

Ref$State
https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
The Apache Software License, Version 2.0
Andres de la Peña
Avinash Lakshman
Aleksey Yeschenko
Aaron Morton
Ariel Weisberg
Blake Eggleston
Benedict Elliott Smith
Benjamin Lerer
Branimir Lambov
Brandon Williams
Carl Yeksigian
David Brosiusd
Dikang Gu
Eric Evans
Gary Dusbabek
Chris Goffinet
Alex Petrov
Laine Jaakko Olavi
T Jake Luciani
Jason Brown
Jonathan Ellis
Jake Farrell
Jeff Jirsa
Joel Knighton
Josh McKenzie
Johan Oskarsson
Jun Rao
Jay Zhuang
Sankalp Kohli
Marcus Eriksson
Michael Semb Wever
Mikhail Stepura
Michael Shuler
Paulo Motta
Prashant Malik
Robert Stupp
Peter Schuller
Sam Tunnicliffe
Sylvain Lebresne
Stefania Alborghetti
Tyler Hobbs
Vijay Parthasarathy
Pavel Yaskevich
Yuki Morishita
Nate McCall
final class org.apache.cassandra.utils.concurrent.Ref$State extends java.lang.ref.PhantomReference<org.apache.cassandra.utils.concurrent.Ref>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.utils.concurrent.Ref$State
  super_class: java.lang.ref.PhantomReference
{
  final org.apache.cassandra.utils.concurrent.Ref$Debug debug;
    descriptor: Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
    flags: (0x0010) ACC_FINAL

  final org.apache.cassandra.utils.concurrent.Ref$GlobalState globalState;
    descriptor: Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
    flags: (0x0010) ACC_FINAL

  private volatile int released;
    descriptor: I
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<org.apache.cassandra.utils.concurrent.Ref$State> releasedUpdater;
    descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lorg/apache/cassandra/utils/concurrent/Ref$State;>;

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 178
            ldc Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.utils.concurrent.Ref$State.$assertionsDisabled:Z
         3: .line 184
            ldc Lorg/apache/cassandra/utils/concurrent/Ref$State;
            ldc "released"
            invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            putstatic org.apache.cassandra.utils.concurrent.Ref$State.releasedUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.apache.cassandra.utils.concurrent.Ref$GlobalState, org.apache.cassandra.utils.concurrent.Ref, java.lang.ref.ReferenceQueue<? super org.apache.cassandra.utils.concurrent.Ref>);
    descriptor: (Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;Lorg/apache/cassandra/utils/concurrent/Ref;Ljava/lang/ref/ReferenceQueue;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
        start local 1 // org.apache.cassandra.utils.concurrent.Ref$GlobalState globalState
        start local 2 // org.apache.cassandra.utils.concurrent.Ref reference
        start local 3 // java.lang.ref.ReferenceQueue q
         0: .line 188
            aload 0 /* this */
            aload 2 /* reference */
            aload 3 /* q */
            invokespecial java.lang.ref.PhantomReference.<init>:(Ljava/lang/Object;Ljava/lang/ref/ReferenceQueue;)V
         1: .line 180
            aload 0 /* this */
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 2
            new org.apache.cassandra.utils.concurrent.Ref$Debug
            dup
            invokespecial org.apache.cassandra.utils.concurrent.Ref$Debug.<init>:()V
            goto 3
      StackMap locals: org.apache.cassandra.utils.concurrent.Ref$State org.apache.cassandra.utils.concurrent.Ref$GlobalState org.apache.cassandra.utils.concurrent.Ref java.lang.ref.ReferenceQueue
      StackMap stack: org.apache.cassandra.utils.concurrent.Ref$State
         2: aconst_null
      StackMap locals: org.apache.cassandra.utils.concurrent.Ref$State org.apache.cassandra.utils.concurrent.Ref$GlobalState org.apache.cassandra.utils.concurrent.Ref java.lang.ref.ReferenceQueue
      StackMap stack: org.apache.cassandra.utils.concurrent.Ref$State org.apache.cassandra.utils.concurrent.Ref$Debug
         3: putfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
         4: .line 189
            aload 0 /* this */
            aload 1 /* globalState */
            putfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
         5: .line 190
            aload 1 /* globalState */
            aload 0 /* this */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$GlobalState.register:(Lorg/apache/cassandra/utils/concurrent/Ref$State;)V
         6: .line 191
            return
        end local 3 // java.lang.ref.ReferenceQueue q
        end local 2 // org.apache.cassandra.utils.concurrent.Ref reference
        end local 1 // org.apache.cassandra.utils.concurrent.Ref$GlobalState globalState
        end local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0         this  Lorg/apache/cassandra/utils/concurrent/Ref$State;
            0    7     1  globalState  Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            0    7     2    reference  Lorg/apache/cassandra/utils/concurrent/Ref;
            0    7     3            q  Ljava/lang/ref/ReferenceQueue<-Lorg/apache/cassandra/utils/concurrent/Ref;>;
    Signature: (Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;Lorg/apache/cassandra/utils/concurrent/Ref;Ljava/lang/ref/ReferenceQueue<-Lorg/apache/cassandra/utils/concurrent/Ref;>;)V
    MethodParameters:
             Name  Flags
      globalState  final
      reference    
      q            

  void assertNotReleased();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
         0: .line 195
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 2
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.released:I
            iconst_1
            if_icmpne 2
         1: .line 196
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            aload 0 /* this */
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$Debug.log:(Ljava/lang/String;)V
         2: .line 197
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.utils.concurrent.Ref$State.$assertionsDisabled:Z
            ifne 3
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.released:I
            ifeq 3
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         3: .line 198
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/utils/concurrent/Ref$State;

  java.lang.Throwable ensureReleased(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
    flags: (0x0000) 
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
        start local 1 // java.lang.Throwable accumulate
         0: .line 202
            getstatic org.apache.cassandra.utils.concurrent.Ref$State.releasedUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            aload 0 /* this */
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndSet:(Ljava/lang/Object;I)I
            ifne 4
         1: .line 204
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            aload 0 /* this */
            aload 1 /* accumulate */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$GlobalState.release:(Lorg/apache/cassandra/utils/concurrent/Ref$State;Ljava/lang/Throwable;)Ljava/lang/Throwable;
            astore 1 /* accumulate */
         2: .line 205
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 4
         3: .line 206
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$Debug.deallocate:()V
         4: .line 208
      StackMap locals:
      StackMap stack:
            aload 1 /* accumulate */
            areturn
        end local 1 // java.lang.Throwable accumulate
        end local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lorg/apache/cassandra/utils/concurrent/Ref$State;
            0    5     1  accumulate  Ljava/lang/Throwable;
    MethodParameters:
            Name  Flags
      accumulate  

  void release(boolean);
    descriptor: (Z)V
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
        start local 1 // boolean leak
         0: .line 213
            getstatic org.apache.cassandra.utils.concurrent.Ref$State.releasedUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
            aload 0 /* this */
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
            ifne 8
         1: .line 215
            iload 1 /* leak */
            ifne 7
         2: .line 217
            aload 0 /* this */
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            astore 2 /* id */
        start local 2 // java.lang.String id
         3: .line 218
            getstatic org.apache.cassandra.utils.concurrent.Ref.logger:Lorg/slf4j/Logger;
            ldc "BAD RELEASE: attempted to release a reference ({}) that has already been released"
            aload 2 /* id */
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;)V
         4: .line 219
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 6
         5: .line 220
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            aload 2 /* id */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$Debug.log:(Ljava/lang/String;)V
         6: .line 221
      StackMap locals: java.lang.String
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            ldc "Attempted to release a reference that has already been released"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        end local 2 // java.lang.String id
         7: .line 223
      StackMap locals:
      StackMap stack:
            return
         8: .line 225
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            aload 0 /* this */
            aconst_null
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$GlobalState.release:(Lorg/apache/cassandra/utils/concurrent/Ref$State;Ljava/lang/Throwable;)Ljava/lang/Throwable;
            astore 2 /* fail */
        start local 2 // java.lang.Throwable fail
         9: .line 226
            iload 1 /* leak */
            ifeq 15
        10: .line 228
            aload 0 /* this */
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            astore 3 /* id */
        start local 3 // java.lang.String id
        11: .line 229
            getstatic org.apache.cassandra.utils.concurrent.Ref.logger:Lorg/slf4j/Logger;
            ldc "LEAK DETECTED: a reference ({}) to {} was not released before the reference was garbage collected"
            aload 3 /* id */
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        12: .line 230
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 17
        13: .line 231
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            aload 3 /* id */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$Debug.log:(Ljava/lang/String;)V
        end local 3 // java.lang.String id
        14: .line 232
            goto 17
        15: .line 233
      StackMap locals: java.lang.Throwable
      StackMap stack:
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 17
        16: .line 235
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$Debug.deallocate:()V
        17: .line 237
      StackMap locals:
      StackMap stack:
            aload 2 /* fail */
            ifnull 19
        18: .line 238
            getstatic org.apache.cassandra.utils.concurrent.Ref.logger:Lorg/slf4j/Logger;
            ldc "Error when closing {}"
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            aload 2 /* fail */
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        19: .line 239
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Throwable fail
        end local 1 // boolean leak
        end local 0 // org.apache.cassandra.utils.concurrent.Ref$State this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   20     0  this  Lorg/apache/cassandra/utils/concurrent/Ref$State;
            0   20     1  leak  Z
            3    7     2    id  Ljava/lang/String;
            9   20     2  fail  Ljava/lang/Throwable;
           11   14     3    id  Ljava/lang/String;
    MethodParameters:
      Name  Flags
      leak  
}
Signature: Ljava/lang/ref/PhantomReference<Lorg/apache/cassandra/utils/concurrent/Ref;>;
SourceFile: "Ref.java"
NestHost: org.apache.cassandra.utils.concurrent.Ref
InnerClasses:
  final Debug = org.apache.cassandra.utils.concurrent.Ref$Debug of org.apache.cassandra.utils.concurrent.Ref
  final GlobalState = org.apache.cassandra.utils.concurrent.Ref$GlobalState of org.apache.cassandra.utils.concurrent.Ref
  final State = org.apache.cassandra.utils.concurrent.Ref$State of org.apache.cassandra.utils.concurrent.Ref
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/utils/concurrent/Ref$State.class
