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

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
public final class org.apache.cassandra.utils.concurrent.Ref<T> implements org.apache.cassandra.utils.concurrent.RefCounted<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.utils.concurrent.Ref
  super_class: java.lang.Object
{
  static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  public static final boolean DEBUG_ENABLED;
    descriptor: Z
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

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

  final T referent;
    descriptor: Ljava/lang/Object;
    flags: (0x0010) ACC_FINAL
    Signature: TT;

  private static final java.lang.Class<?>[] concurrentIterableClasses;
    descriptor: [Ljava/lang/Class;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: [Ljava/lang/Class<*>;

  static final java.util.Set<java.lang.Class<?>> concurrentIterables;
    descriptor: Ljava/util/Set;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/Set<Ljava/lang/Class<*>;>;

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

  static final java.lang.ref.ReferenceQueue<java.lang.Object> referenceQueue;
    descriptor: Ljava/lang/ref/ReferenceQueue;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: Ljava/lang/ref/ReferenceQueue<Ljava/lang/Object;>;

  private static final org.apache.cassandra.concurrent.InfiniteLoopExecutor EXEC;
    descriptor: Lorg/apache/cassandra/concurrent/InfiniteLoopExecutor;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static final java.util.concurrent.ScheduledExecutorService STRONG_LEAK_DETECTOR;
    descriptor: Ljava/util/concurrent/ScheduledExecutorService;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final java.util.Deque<org.apache.cassandra.utils.concurrent.Ref$InProgressVisit> inProgressVisitPool;
    descriptor: Ljava/util/Deque;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/Deque<Lorg/apache/cassandra/utils/concurrent/Ref$InProgressVisit;>;

  static final java.util.Map<java.lang.Class<?>, java.util.List<java.lang.reflect.Field>> fieldMap;
    descriptor: Ljava/util/Map;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/Class<*>;Ljava/util/List<Ljava/lang/reflect/Field;>;>;

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=7, locals=0, args_size=0
         0: .line 94
            ldc Lorg/apache/cassandra/utils/concurrent/Ref;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.utils.concurrent.Ref.logger:Lorg/slf4j/Logger;
         1: .line 95
            ldc "cassandra.debugrefcount"
            ldc "false"
            invokestatic java.lang.System.getProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            ldc "true"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            putstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
         2: .line 350
            bipush 7
            anewarray java.lang.Class
            dup
            iconst_0
         3: .line 351
            ldc Ljava/util/concurrent/ConcurrentLinkedQueue;
            aastore
            dup
            iconst_1
         4: .line 352
            ldc Ljava/util/concurrent/ConcurrentLinkedDeque;
            aastore
            dup
            iconst_2
         5: .line 353
            ldc Ljava/util/concurrent/ConcurrentSkipListSet;
            aastore
            dup
            iconst_3
         6: .line 354
            ldc Ljava/util/concurrent/CopyOnWriteArrayList;
            aastore
            dup
            iconst_4
         7: .line 355
            ldc Ljava/util/concurrent/CopyOnWriteArraySet;
            aastore
            dup
            iconst_5
         8: .line 356
            ldc Ljava/util/concurrent/DelayQueue;
            aastore
            dup
            bipush 6
         9: .line 357
            ldc Lorg/cliffc/high_scale_lib/NonBlockingHashMap;
            aastore
        10: .line 349
            putstatic org.apache.cassandra.utils.concurrent.Ref.concurrentIterableClasses:[Ljava/lang/Class;
        11: .line 359
            new java.util.IdentityHashMap
            dup
            invokespecial java.util.IdentityHashMap.<init>:()V
            invokestatic java.util.Collections.newSetFromMap:(Ljava/util/Map;)Ljava/util/Set;
            putstatic org.apache.cassandra.utils.concurrent.Ref.concurrentIterables:Ljava/util/Set;
        12: .line 360
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            invokestatic java.util.Collections.newSetFromMap:(Ljava/util/Map;)Ljava/util/Set;
            putstatic org.apache.cassandra.utils.concurrent.Ref.globallyExtant:Ljava/util/Set;
        13: .line 361
            new java.lang.ref.ReferenceQueue
            dup
            invokespecial java.lang.ref.ReferenceQueue.<init>:()V
            putstatic org.apache.cassandra.utils.concurrent.Ref.referenceQueue:Ljava/lang/ref/ReferenceQueue;
        14: .line 362
            new org.apache.cassandra.concurrent.InfiniteLoopExecutor
            dup
            ldc "Reference-Reaper"
            invokedynamic run()Lorg/apache/cassandra/concurrent/InfiniteLoopExecutor$InterruptibleRunnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  org/apache/cassandra/utils/concurrent/Ref.reapOneReference()V (6)
                  ()V
            invokespecial org.apache.cassandra.concurrent.InfiniteLoopExecutor.<init>:(Ljava/lang/String;Lorg/apache/cassandra/concurrent/InfiniteLoopExecutor$InterruptibleRunnable;)V
            invokevirtual org.apache.cassandra.concurrent.InfiniteLoopExecutor.start:()Lorg/apache/cassandra/concurrent/InfiniteLoopExecutor;
            putstatic org.apache.cassandra.utils.concurrent.Ref.EXEC:Lorg/apache/cassandra/concurrent/InfiniteLoopExecutor;
        15: .line 363
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifne 16
            aconst_null
            goto 17
      StackMap locals:
      StackMap stack:
        16: iconst_1
            new org.apache.cassandra.concurrent.NamedThreadFactory
            dup
            ldc "Strong-Reference-Leak-Detector"
            invokespecial org.apache.cassandra.concurrent.NamedThreadFactory.<init>:(Ljava/lang/String;)V
            invokestatic java.util.concurrent.Executors.newScheduledThreadPool:(ILjava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ScheduledExecutorService;
      StackMap locals:
      StackMap stack: java.util.concurrent.ScheduledExecutorService
        17: putstatic org.apache.cassandra.utils.concurrent.Ref.STRONG_LEAK_DETECTOR:Ljava/util/concurrent/ScheduledExecutorService;
        18: .line 366
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 21
        19: .line 368
            getstatic org.apache.cassandra.utils.concurrent.Ref.STRONG_LEAK_DETECTOR:Ljava/util/concurrent/ScheduledExecutorService;
            new org.apache.cassandra.utils.concurrent.Ref$Visitor
            dup
            invokespecial org.apache.cassandra.utils.concurrent.Ref$Visitor.<init>:()V
            lconst_1
            ldc 15
            getstatic java.util.concurrent.TimeUnit.MINUTES:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            pop
        20: .line 369
            getstatic org.apache.cassandra.utils.concurrent.Ref.STRONG_LEAK_DETECTOR:Ljava/util/concurrent/ScheduledExecutorService;
            new org.apache.cassandra.utils.concurrent.Ref$StrongLeakDetector
            dup
            invokespecial org.apache.cassandra.utils.concurrent.Ref$StrongLeakDetector.<init>:()V
            ldc 2
            ldc 15
            getstatic java.util.concurrent.TimeUnit.MINUTES:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            pop
        21: .line 371
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.utils.concurrent.Ref.concurrentIterables:Ljava/util/Set;
            getstatic org.apache.cassandra.utils.concurrent.Ref.concurrentIterableClasses:[Ljava/lang/Class;
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
            invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
            pop
        22: .line 383
            new java.util.ArrayDeque
            dup
            invokespecial java.util.ArrayDeque.<init>:()V
            putstatic org.apache.cassandra.utils.concurrent.Ref.inProgressVisitPool:Ljava/util/Deque;
        23: .line 623
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            putstatic org.apache.cassandra.utils.concurrent.Ref.fieldMap:Ljava/util/Map;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(T, org.apache.cassandra.utils.concurrent.RefCounted$Tidy);
    descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/utils/concurrent/RefCounted$Tidy;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
        start local 1 // java.lang.Object referent
        start local 2 // org.apache.cassandra.utils.concurrent.RefCounted$Tidy tidy
         0: .line 100
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 102
            aload 0 /* this */
            new org.apache.cassandra.utils.concurrent.Ref$State
            dup
            new org.apache.cassandra.utils.concurrent.Ref$GlobalState
            dup
            aload 2 /* tidy */
            invokespecial org.apache.cassandra.utils.concurrent.Ref$GlobalState.<init>:(Lorg/apache/cassandra/utils/concurrent/RefCounted$Tidy;)V
            aload 0 /* this */
            getstatic org.apache.cassandra.utils.concurrent.Ref.referenceQueue:Ljava/lang/ref/ReferenceQueue;
            invokespecial org.apache.cassandra.utils.concurrent.Ref$State.<init>:(Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;Lorg/apache/cassandra/utils/concurrent/Ref;Ljava/lang/ref/ReferenceQueue;)V
            putfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
         2: .line 103
            aload 0 /* this */
            aload 1 /* referent */
            putfield org.apache.cassandra.utils.concurrent.Ref.referent:Ljava/lang/Object;
         3: .line 104
            return
        end local 2 // org.apache.cassandra.utils.concurrent.RefCounted$Tidy tidy
        end local 1 // java.lang.Object referent
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
            0    4     1  referent  TT;
            0    4     2      tidy  Lorg/apache/cassandra/utils/concurrent/RefCounted$Tidy;
    Signature: (TT;Lorg/apache/cassandra/utils/concurrent/RefCounted$Tidy;)V
    MethodParameters:
          Name  Flags
      referent  
      tidy      

  void <init>(T, org.apache.cassandra.utils.concurrent.Ref$GlobalState);
    descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
        start local 1 // java.lang.Object referent
        start local 2 // org.apache.cassandra.utils.concurrent.Ref$GlobalState state
         0: .line 106
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 108
            aload 0 /* this */
            new org.apache.cassandra.utils.concurrent.Ref$State
            dup
            aload 2 /* state */
            aload 0 /* this */
            getstatic org.apache.cassandra.utils.concurrent.Ref.referenceQueue:Ljava/lang/ref/ReferenceQueue;
            invokespecial org.apache.cassandra.utils.concurrent.Ref$State.<init>:(Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;Lorg/apache/cassandra/utils/concurrent/Ref;Ljava/lang/ref/ReferenceQueue;)V
            putfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
         2: .line 109
            aload 0 /* this */
            aload 1 /* referent */
            putfield org.apache.cassandra.utils.concurrent.Ref.referent:Ljava/lang/Object;
         3: .line 110
            return
        end local 2 // org.apache.cassandra.utils.concurrent.Ref$GlobalState state
        end local 1 // java.lang.Object referent
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
            0    4     1  referent  TT;
            0    4     2     state  Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
    Signature: (TT;Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;)V
    MethodParameters:
          Name  Flags
      referent  
      state     

  public void release();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 119
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            iconst_0
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$State.release:(Z)V
         1: .line 120
            return
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  public java.lang.Throwable ensureReleased(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
        start local 1 // java.lang.Throwable accumulate
         0: .line 124
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            aload 1 /* accumulate */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$State.ensureReleased:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
            areturn
        end local 1 // java.lang.Throwable accumulate
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
            0    1     1  accumulate  Ljava/lang/Throwable;
    MethodParameters:
            Name  Flags
      accumulate  

  public void ensureReleased();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 129
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            aconst_null
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$State.ensureReleased:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
            invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
         1: .line 130
            return
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 134
            aload 0 /* this */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.ensureReleased:()V
         1: .line 135
            return
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  public T get();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 139
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$State.assertNotReleased:()V
         1: .line 140
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.referent:Ljava/lang/Object;
            areturn
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
    Signature: ()TT;

  public org.apache.cassandra.utils.concurrent.Ref<T> tryRef();
    descriptor: ()Lorg/apache/cassandra/utils/concurrent/Ref;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 145
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$GlobalState.ref:()Z
            ifeq 1
            new org.apache.cassandra.utils.concurrent.Ref
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.referent:Ljava/lang/Object;
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            invokespecial org.apache.cassandra.utils.concurrent.Ref.<init>:(Ljava/lang/Object;Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;)V
            goto 2
      StackMap locals:
      StackMap stack:
         1: aconst_null
      StackMap locals:
      StackMap stack: org.apache.cassandra.utils.concurrent.Ref
         2: areturn
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
    Signature: ()Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  public org.apache.cassandra.utils.concurrent.Ref<T> ref();
    descriptor: ()Lorg/apache/cassandra/utils/concurrent/Ref;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 150
            aload 0 /* this */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.tryRef:()Lorg/apache/cassandra/utils/concurrent/Ref;
            astore 1 /* ref */
        start local 1 // org.apache.cassandra.utils.concurrent.Ref ref
         1: .line 152
            aload 1 /* ref */
            ifnonnull 3
         2: .line 153
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$State.assertNotReleased:()V
         3: .line 154
      StackMap locals: org.apache.cassandra.utils.concurrent.Ref
      StackMap stack:
            aload 1 /* ref */
            areturn
        end local 1 // org.apache.cassandra.utils.concurrent.Ref ref
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
            1    4     1   ref  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;
    Signature: ()Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  public java.lang.String printDebugInfo();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 159
            getstatic org.apache.cassandra.utils.concurrent.Ref.DEBUG_ENABLED:Z
            ifeq 3
         1: .line 161
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$Debug.log:(Ljava/lang/String;)V
         2: .line 162
            new java.lang.StringBuilder
            dup
            ldc "Memory was freed by "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            getfield org.apache.cassandra.utils.concurrent.Ref$State.debug:Lorg/apache/cassandra/utils/concurrent/Ref$Debug;
            getfield org.apache.cassandra.utils.concurrent.Ref$Debug.deallocateThread:Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
         3: .line 164
      StackMap locals:
      StackMap stack:
            ldc "Memory was freed"
            areturn
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  public int globalCount();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref this
         0: .line 173
            aload 0 /* this */
            getfield org.apache.cassandra.utils.concurrent.Ref.state:Lorg/apache/cassandra/utils/concurrent/Ref$State;
            getfield org.apache.cassandra.utils.concurrent.Ref$State.globalState:Lorg/apache/cassandra/utils/concurrent/Ref$GlobalState;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$GlobalState.count:()I
            ireturn
        end local 0 // org.apache.cassandra.utils.concurrent.Ref this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/utils/concurrent/Ref<TT;>;

  private static void reapOneReference();
    descriptor: ()V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 376
            getstatic org.apache.cassandra.utils.concurrent.Ref.referenceQueue:Ljava/lang/ref/ReferenceQueue;
            ldc 100
            invokevirtual java.lang.ref.ReferenceQueue.remove:(J)Ljava/lang/ref/Reference;
            astore 0 /* obj */
        start local 0 // java.lang.Object obj
         1: .line 377
            aload 0 /* obj */
            instanceof org.apache.cassandra.utils.concurrent.Ref$State
            ifeq 3
         2: .line 379
            aload 0 /* obj */
            checkcast org.apache.cassandra.utils.concurrent.Ref$State
            iconst_1
            invokevirtual org.apache.cassandra.utils.concurrent.Ref$State.release:(Z)V
         3: .line 381
      StackMap locals: java.lang.Object
      StackMap stack:
            return
        end local 0 // java.lang.Object obj
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            1    4     0   obj  Ljava/lang/Object;
    Exceptions:
      throws java.lang.InterruptedException

  static org.apache.cassandra.utils.concurrent.Ref$InProgressVisit newInProgressVisit(, java.util.List<java.lang.reflect.Field>, java.lang.reflect.Field, java.lang.String);
    descriptor: (Ljava/lang/Object;Ljava/util/List;Ljava/lang/reflect/Field;Ljava/lang/String;)Lorg/apache/cassandra/utils/concurrent/Ref$InProgressVisit;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=5, args_size=4
        start local 0 // java.lang.Object o
        start local 1 // java.util.List fields
        start local 2 // java.lang.reflect.Field field
        start local 3 // java.lang.String name
         0: .line 388
            aload 0 /* o */
            invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 389
            getstatic org.apache.cassandra.utils.concurrent.Ref.inProgressVisitPool:Ljava/util/Deque;
            invokeinterface java.util.Deque.pollLast:()Ljava/lang/Object;
            checkcast org.apache.cassandra.utils.concurrent.Ref$InProgressVisit
            astore 4 /* ipv */
        start local 4 // org.apache.cassandra.utils.concurrent.Ref$InProgressVisit ipv
         2: .line 390
            aload 4 /* ipv */
            ifnonnull 4
         3: .line 391
            new org.apache.cassandra.utils.concurrent.Ref$InProgressVisit
            dup
            invokespecial org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.<init>:()V
            astore 4 /* ipv */
         4: .line 393
      StackMap locals: org.apache.cassandra.utils.concurrent.Ref$InProgressVisit
      StackMap stack:
            aload 4 /* ipv */
            aload 0 /* o */
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.o:Ljava/lang/Object;
         5: .line 394
            aload 0 /* o */
            instanceof java.lang.Object[]
            ifeq 7
         6: .line 395
            aload 4 /* ipv */
            aload 0 /* o */
            checkcast java.lang.Object[]
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.collectionIterator:Ljava/util/Iterator;
            goto 13
         7: .line 396
      StackMap locals:
      StackMap stack:
            aload 0 /* o */
            instanceof java.util.concurrent.ConcurrentMap
            ifeq 11
         8: .line 398
            aload 4 /* ipv */
            iconst_1
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.isMapIterator:Z
         9: .line 399
            aload 4 /* ipv */
            aload 0 /* o */
            checkcast java.util.Map
            invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.collectionIterator:Ljava/util/Iterator;
        10: .line 400
            goto 13
        11: .line 401
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.utils.concurrent.Ref.concurrentIterables:Ljava/util/Set;
            aload 0 /* o */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            aload 0 /* o */
            instanceof java.util.concurrent.BlockingQueue
            ior
            ifeq 13
        12: .line 402
            aload 4 /* ipv */
            aload 0 /* o */
            checkcast java.lang.Iterable
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.collectionIterator:Ljava/util/Iterator;
        13: .line 404
      StackMap locals:
      StackMap stack:
            aload 4 /* ipv */
            aload 1 /* fields */
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.fields:Ljava/util/List;
        14: .line 405
            aload 4 /* ipv */
            aload 2 /* field */
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.field:Ljava/lang/reflect/Field;
        15: .line 406
            aload 4 /* ipv */
            aload 3 /* name */
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.name:Ljava/lang/String;
        16: .line 407
            aload 4 /* ipv */
            areturn
        end local 4 // org.apache.cassandra.utils.concurrent.Ref$InProgressVisit ipv
        end local 3 // java.lang.String name
        end local 2 // java.lang.reflect.Field field
        end local 1 // java.util.List fields
        end local 0 // java.lang.Object o
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   17     0       o  Ljava/lang/Object;
            0   17     1  fields  Ljava/util/List<Ljava/lang/reflect/Field;>;
            0   17     2   field  Ljava/lang/reflect/Field;
            0   17     3    name  Ljava/lang/String;
            2   17     4     ipv  Lorg/apache/cassandra/utils/concurrent/Ref$InProgressVisit;
    Signature: (Ljava/lang/Object;Ljava/util/List<Ljava/lang/reflect/Field;>;Ljava/lang/reflect/Field;Ljava/lang/String;)Lorg/apache/cassandra/utils/concurrent/Ref$InProgressVisit;
    MethodParameters:
        Name  Flags
      o       
      fields  
      field   
      name    

  static void returnInProgressVisit(org.apache.cassandra.utils.concurrent.Ref$InProgressVisit);
    descriptor: (Lorg/apache/cassandra/utils/concurrent/Ref$InProgressVisit;)V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.utils.concurrent.Ref$InProgressVisit ipv
         0: .line 412
            getstatic org.apache.cassandra.utils.concurrent.Ref.inProgressVisitPool:Ljava/util/Deque;
            invokeinterface java.util.Deque.size:()I
            sipush 1024
            if_icmple 2
         1: .line 413
            return
         2: .line 414
      StackMap locals:
      StackMap stack:
            aload 0 /* ipv */
            aconst_null
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.name:Ljava/lang/String;
         3: .line 415
            aload 0 /* ipv */
            aconst_null
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.fields:Ljava/util/List;
         4: .line 416
            aload 0 /* ipv */
            aconst_null
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.o:Ljava/lang/Object;
         5: .line 417
            aload 0 /* ipv */
            iconst_0
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.fieldIndex:I
         6: .line 418
            aload 0 /* ipv */
            aconst_null
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.field:Ljava/lang/reflect/Field;
         7: .line 419
            aload 0 /* ipv */
            aconst_null
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.collectionIterator:Ljava/util/Iterator;
         8: .line 420
            aload 0 /* ipv */
            aconst_null
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.mapEntryValue:Ljava/lang/Object;
         9: .line 421
            aload 0 /* ipv */
            iconst_0
            putfield org.apache.cassandra.utils.concurrent.Ref$InProgressVisit.isMapIterator:Z
        10: .line 422
            getstatic org.apache.cassandra.utils.concurrent.Ref.inProgressVisitPool:Ljava/util/Deque;
            aload 0 /* ipv */
            invokeinterface java.util.Deque.offer:(Ljava/lang/Object;)Z
            pop
        11: .line 423
            return
        end local 0 // org.apache.cassandra.utils.concurrent.Ref$InProgressVisit ipv
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   12     0   ipv  Lorg/apache/cassandra/utils/concurrent/Ref$InProgressVisit;
    MethodParameters:
      Name  Flags
      ipv   

  static java.util.List<java.lang.reflect.Field> getFields(java.lang.Class<?>);
    descriptor: (Ljava/lang/Class;)Ljava/util/List;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=4, locals=6, args_size=1
        start local 0 // java.lang.Class clazz
         0: .line 626
            aload 0 /* clazz */
            ifnull 1
            aload 0 /* clazz */
            ldc Ljava/lang/ref/PhantomReference;
            if_acmpeq 1
            aload 0 /* clazz */
            ldc Ljava/lang/Class;
            if_acmpeq 1
            ldc Ljava/lang/reflect/Member;
            aload 0 /* clazz */
            invokevirtual java.lang.Class.isAssignableFrom:(Ljava/lang/Class;)Z
            ifeq 2
         1: .line 627
      StackMap locals:
      StackMap stack:
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            areturn
         2: .line 628
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.utils.concurrent.Ref.fieldMap:Ljava/util/Map;
            aload 0 /* clazz */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.List
            astore 1 /* fields */
        start local 1 // java.util.List fields
         3: .line 629
            aload 1 /* fields */
            ifnull 5
         4: .line 630
            aload 1 /* fields */
            areturn
         5: .line 631
      StackMap locals: java.util.List
      StackMap stack:
            getstatic org.apache.cassandra.utils.concurrent.Ref.fieldMap:Ljava/util/Map;
            aload 0 /* clazz */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            dup
            astore 1 /* fields */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 632
            aload 0 /* clazz */
            invokevirtual java.lang.Class.getDeclaredFields:()[Ljava/lang/reflect/Field;
            dup
            astore 5
            arraylength
            istore 4
            iconst_0
            istore 3
            goto 13
      StackMap locals: java.lang.Class java.util.List top int int java.lang.reflect.Field[]
      StackMap stack:
         7: aload 5
            iload 3
            aaload
            astore 2 /* field */
        start local 2 // java.lang.reflect.Field field
         8: .line 634
            aload 2 /* field */
            invokevirtual java.lang.reflect.Field.getType:()Ljava/lang/Class;
            invokevirtual java.lang.Class.isPrimitive:()Z
            ifne 12
            aload 2 /* field */
            invokevirtual java.lang.reflect.Field.getModifiers:()I
            invokestatic java.lang.reflect.Modifier.isStatic:(I)Z
            ifeq 10
         9: .line 635
            goto 12
        10: .line 636
      StackMap locals: java.lang.Class java.util.List java.lang.reflect.Field int int java.lang.reflect.Field[]
      StackMap stack:
            aload 2 /* field */
            iconst_1
            invokevirtual java.lang.reflect.Field.setAccessible:(Z)V
        11: .line 637
            aload 1 /* fields */
            aload 2 /* field */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 2 // java.lang.reflect.Field field
        12: .line 632
      StackMap locals: java.lang.Class java.util.List top int int java.lang.reflect.Field[]
      StackMap stack:
            iinc 3 1
      StackMap locals:
      StackMap stack:
        13: iload 3
            iload 4
            if_icmplt 7
        14: .line 639
            aload 1 /* fields */
            aload 0 /* clazz */
            invokevirtual java.lang.Class.getSuperclass:()Ljava/lang/Class;
            invokestatic org.apache.cassandra.utils.concurrent.Ref.getFields:(Ljava/lang/Class;)Ljava/util/List;
            invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
            pop
        15: .line 640
            aload 1 /* fields */
            areturn
        end local 1 // java.util.List fields
        end local 0 // java.lang.Class clazz
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   16     0   clazz  Ljava/lang/Class<*>;
            3   16     1  fields  Ljava/util/List<Ljava/lang/reflect/Field;>;
            8   12     2   field  Ljava/lang/reflect/Field;
    Signature: (Ljava/lang/Class<*>;)Ljava/util/List<Ljava/lang/reflect/Field;>;
    MethodParameters:
       Name  Flags
      clazz  

  public static void shutdownReferenceReaper(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=7, locals=3, args_size=2
        start local 0 // long timeout
        start local 2 // java.util.concurrent.TimeUnit unit
         0: .line 714
            lload 0 /* timeout */
            aload 2 /* unit */
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            getstatic org.apache.cassandra.utils.concurrent.Ref.EXEC:Lorg/apache/cassandra/concurrent/InfiniteLoopExecutor;
            aastore
            dup
            iconst_1
            getstatic org.apache.cassandra.utils.concurrent.Ref.STRONG_LEAK_DETECTOR:Ljava/util/concurrent/ScheduledExecutorService;
            aastore
            invokestatic org.apache.cassandra.utils.ExecutorUtils.shutdownNowAndWait:(JLjava/util/concurrent/TimeUnit;[Ljava/lang/Object;)V
         1: .line 715
            return
        end local 2 // java.util.concurrent.TimeUnit unit
        end local 0 // long timeout
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  timeout  J
            0    2     2     unit  Ljava/util/concurrent/TimeUnit;
    Exceptions:
      throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()
    MethodParameters:
         Name  Flags
      timeout  
      unit     
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lorg/apache/cassandra/utils/concurrent/RefCounted<TT;>;
SourceFile: "Ref.java"
NestMembers:
  org.apache.cassandra.utils.concurrent.Ref$Debug  org.apache.cassandra.utils.concurrent.Ref$GlobalState  org.apache.cassandra.utils.concurrent.Ref$IdentityCollection  org.apache.cassandra.utils.concurrent.Ref$InProgressVisit  org.apache.cassandra.utils.concurrent.Ref$State  org.apache.cassandra.utils.concurrent.Ref$StrongLeakDetector  org.apache.cassandra.utils.concurrent.Ref$Visitor
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract Entry = java.util.Map$Entry of java.util.Map
  public abstract InterruptibleRunnable = org.apache.cassandra.concurrent.InfiniteLoopExecutor$InterruptibleRunnable of org.apache.cassandra.concurrent.InfiniteLoopExecutor
  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
  public IdentityCollection = org.apache.cassandra.utils.concurrent.Ref$IdentityCollection of org.apache.cassandra.utils.concurrent.Ref
  InProgressVisit = org.apache.cassandra.utils.concurrent.Ref$InProgressVisit of org.apache.cassandra.utils.concurrent.Ref
  final State = org.apache.cassandra.utils.concurrent.Ref$State of org.apache.cassandra.utils.concurrent.Ref
  private StrongLeakDetector = org.apache.cassandra.utils.concurrent.Ref$StrongLeakDetector of org.apache.cassandra.utils.concurrent.Ref
  Visitor = org.apache.cassandra.utils.concurrent.Ref$Visitor of org.apache.cassandra.utils.concurrent.Ref
  public abstract Tidy = org.apache.cassandra.utils.concurrent.RefCounted$Tidy of org.apache.cassandra.utils.concurrent.RefCounted
/

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