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.
  • 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 class org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir implements com.codahale.metrics.Reservoir
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir
  super_class: java.lang.Object
{
  public static final int DEFAULT_BUCKET_COUNT;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 164

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

  public static final long[] DEFAULT_WITHOUT_ZERO_BUCKET_OFFSETS;
    descriptor: [J
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

  public static final long[] DEFAULT_WITH_ZERO_BUCKET_OFFSETS;
    descriptor: [J
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

  private final long[] bucketOffsets;
    descriptor: [J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLongArray decayingBuckets;
    descriptor: Ljava/util/concurrent/atomic/AtomicLongArray;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLongArray buckets;
    descriptor: Ljava/util/concurrent/atomic/AtomicLongArray;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public static final long HALF_TIME_IN_S;
    descriptor: J
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 60

  public static final double MEAN_LIFETIME_IN_S;
    descriptor: D
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

  public static final long LANDMARK_RESET_INTERVAL_IN_MS;
    descriptor: J
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 1800000

  private final java.util.concurrent.atomic.AtomicBoolean rescaling;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private volatile long decayLandmark;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

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

  private final com.codahale.metrics.Clock clock;
    descriptor: Lcom/codahale/metrics/Clock;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private static final java.nio.charset.Charset UTF_8;
    descriptor: Ljava/nio/charset/Charset;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=4, locals=0, args_size=0
         0: .line 79
            sipush 164
            iconst_0
            invokestatic org.apache.cassandra.utils.EstimatedHistogram.newOffsets:(IZ)[J
            putstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.DEFAULT_WITHOUT_ZERO_BUCKET_OFFSETS:[J
         1: .line 82
            sipush 164
            iconst_1
            invokestatic org.apache.cassandra.utils.EstimatedHistogram.newOffsets:(IZ)[J
            putstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.DEFAULT_WITH_ZERO_BUCKET_OFFSETS:[J
         2: .line 92
            ldc 60.0
            ldc 2.0
            invokestatic java.lang.Math.log:(D)D
            ddiv
            putstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.MEAN_LIFETIME_IN_S:D
         3: .line 335
            ldc "UTF-8"
            invokestatic java.nio.charset.Charset.forName:(Ljava/lang/String;)Ljava/nio/charset/Charset;
            putstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.UTF_8:Ljava/nio/charset/Charset;
            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.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 109
            aload 0 /* this */
            iconst_0
            sipush 164
            invokestatic com.codahale.metrics.Clock.defaultClock:()Lcom/codahale/metrics/Clock;
            invokespecial org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.<init>:(ZILcom/codahale/metrics/Clock;)V
         1: .line 110
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;

  public void <init>(boolean);
    descriptor: (Z)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // boolean considerZeroes
         0: .line 120
            aload 0 /* this */
            iload 1 /* considerZeroes */
            sipush 164
            invokestatic com.codahale.metrics.Clock.defaultClock:()Lcom/codahale/metrics/Clock;
            invokespecial org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.<init>:(ZILcom/codahale/metrics/Clock;)V
         1: .line 121
            return
        end local 1 // boolean considerZeroes
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    2     0            this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0    2     1  considerZeroes  Z
    MethodParameters:
                Name  Flags
      considerZeroes  

  public void <init>(boolean, int);
    descriptor: (ZI)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // boolean considerZeroes
        start local 2 // int bucketCount
         0: .line 132
            aload 0 /* this */
            iload 1 /* considerZeroes */
            iload 2 /* bucketCount */
            invokestatic com.codahale.metrics.Clock.defaultClock:()Lcom/codahale/metrics/Clock;
            invokespecial org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.<init>:(ZILcom/codahale/metrics/Clock;)V
         1: .line 133
            return
        end local 2 // int bucketCount
        end local 1 // boolean considerZeroes
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    2     0            this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0    2     1  considerZeroes  Z
            0    2     2     bucketCount  I
    MethodParameters:
                Name  Flags
      considerZeroes  
      bucketCount     

  void <init>(boolean, int, com.codahale.metrics.Clock);
    descriptor: (ZILcom/codahale/metrics/Clock;)V
    flags: (0x0000) 
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // boolean considerZeroes
        start local 2 // int bucketCount
        start local 3 // com.codahale.metrics.Clock clock
         0: .line 136
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 95
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaling:Ljava/util/concurrent/atomic/AtomicBoolean;
         2: .line 98
            aload 0 /* this */
            new java.util.concurrent.locks.ReentrantReadWriteLock
            dup
            invokespecial java.util.concurrent.locks.ReentrantReadWriteLock.<init>:()V
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
         3: .line 138
            iload 2 /* bucketCount */
            sipush 164
            if_icmpne 9
         4: .line 140
            iload 1 /* considerZeroes */
            ifeq 7
         5: .line 142
            aload 0 /* this */
            getstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.DEFAULT_WITH_ZERO_BUCKET_OFFSETS:[J
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.bucketOffsets:[J
         6: .line 143
            goto 10
         7: .line 146
      StackMap locals: org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir int int com.codahale.metrics.Clock
      StackMap stack:
            aload 0 /* this */
            getstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.DEFAULT_WITHOUT_ZERO_BUCKET_OFFSETS:[J
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.bucketOffsets:[J
         8: .line 148
            goto 10
         9: .line 151
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 2 /* bucketCount */
            iload 1 /* considerZeroes */
            invokestatic org.apache.cassandra.utils.EstimatedHistogram.newOffsets:(IZ)[J
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.bucketOffsets:[J
        10: .line 153
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLongArray
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.bucketOffsets:[J
            arraylength
            iconst_1
            iadd
            invokespecial java.util.concurrent.atomic.AtomicLongArray.<init>:(I)V
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
        11: .line 154
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLongArray
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.bucketOffsets:[J
            arraylength
            iconst_1
            iadd
            invokespecial java.util.concurrent.atomic.AtomicLongArray.<init>:(I)V
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.buckets:Ljava/util/concurrent/atomic/AtomicLongArray;
        12: .line 155
            aload 0 /* this */
            aload 3 /* clock */
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.clock:Lcom/codahale/metrics/Clock;
        13: .line 156
            aload 0 /* this */
            aload 3 /* clock */
            invokevirtual com.codahale.metrics.Clock.getTime:()J
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayLandmark:J
        14: .line 157
            return
        end local 3 // com.codahale.metrics.Clock clock
        end local 2 // int bucketCount
        end local 1 // boolean considerZeroes
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   15     0            this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0   15     1  considerZeroes  Z
            0   15     2     bucketCount  I
            0   15     3           clock  Lcom/codahale/metrics/Clock;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        com.google.common.annotations.VisibleForTesting()
    MethodParameters:
                Name  Flags
      considerZeroes  
      bucketCount     
      clock           

  public void update(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=2
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // long value
         0: .line 166
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.clock:Lcom/codahale/metrics/Clock;
            invokevirtual com.codahale.metrics.Clock.getTime:()J
            lstore 3 /* now */
        start local 3 // long now
         1: .line 167
            aload 0 /* this */
            lload 3 /* now */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaleIfNeeded:(J)V
         2: .line 169
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.bucketOffsets:[J
            lload 1 /* value */
            invokestatic java.util.Arrays.binarySearch:([JJ)I
            istore 5 /* index */
        start local 5 // int index
         3: .line 170
            iload 5 /* index */
            ifge 5
         4: .line 173
            iload 5 /* index */
            ineg
            iconst_1
            isub
            istore 5 /* index */
         5: .line 177
      StackMap locals: long int
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lockForRegularUsage:()V
         6: .line 181
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            iload 5 /* index */
            aload 0 /* this */
            lload 3 /* now */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.forwardDecayWeight:(J)D
            invokestatic java.lang.Math.round:(D)J
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.getAndAdd:(IJ)J
            pop2
         7: .line 182
            goto 11
         8: .line 184
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 6
         9: .line 185
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRegularUsage:()V
        10: .line 186
            aload 6
            athrow
        11: .line 185
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRegularUsage:()V
        12: .line 188
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.buckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            iload 5 /* index */
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.getAndIncrement:(I)J
            pop2
        13: .line 189
            return
        end local 5 // int index
        end local 3 // long now
        end local 1 // long value
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   14     0   this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0   14     1  value  J
            1   14     3    now  J
            3   14     5  index  I
      Exception table:
        from    to  target  type
           6     8       8  any
    MethodParameters:
       Name  Flags
      value  

  private double forwardDecayWeight(long);
    descriptor: (J)D
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // long now
         0: .line 193
            lload 1 /* now */
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayLandmark:J
            lsub
            ldc 1000
            ldiv
            l2d
            getstatic org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.MEAN_LIFETIME_IN_S:D
            ddiv
            invokestatic java.lang.Math.exp:(D)D
            dreturn
        end local 1 // long now
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0    1     1   now  J
    MethodParameters:
      Name  Flags
      now   

  public int size();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 205
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.length:()I
            ireturn
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;

  public com.codahale.metrics.Snapshot getSnapshot();
    descriptor: ()Lcom/codahale/metrics/Snapshot;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 217
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaleIfNeeded:()V
         1: .line 219
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lockForRegularUsage:()V
         2: .line 223
            new org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir$EstimatedHistogramReservoirSnapshot
            dup
            aload 0 /* this */
            aload 0 /* this */
            invokespecial org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir$EstimatedHistogramReservoirSnapshot.<init>:(Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;)V
            astore 2
         3: .line 227
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRegularUsage:()V
         4: .line 223
            aload 2
            areturn
         5: .line 226
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 1
         6: .line 227
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRegularUsage:()V
         7: .line 228
            aload 1
            athrow
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
      Exception table:
        from    to  target  type
           2     3       5  any

  boolean isOverflowed();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 237
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.length:()I
            iconst_1
            isub
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.get:(I)J
            lconst_0
            lcmp
            ifle 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        com.google.common.annotations.VisibleForTesting()

  private void rescaleIfNeeded();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 242
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.clock:Lcom/codahale/metrics/Clock;
            invokevirtual com.codahale.metrics.Clock.getTime:()J
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaleIfNeeded:(J)V
         1: .line 243
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;

  private void rescaleIfNeeded(long);
    descriptor: (J)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // long now
         0: .line 247
            aload 0 /* this */
            lload 1 /* now */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.needRescale:(J)Z
            ifeq 8
         1: .line 249
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaling:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 8
         2: .line 253
            aload 0 /* this */
            lload 1 /* now */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescale:(J)V
         3: .line 254
            goto 7
         4: .line 256
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 3
         5: .line 257
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaling:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         6: .line 258
            aload 3
            athrow
         7: .line 257
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.rescaling:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         8: .line 261
      StackMap locals:
      StackMap stack:
            return
        end local 1 // long now
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0    9     1   now  J
      Exception table:
        from    to  target  type
           2     4       4  any
    MethodParameters:
      Name  Flags
      now   

  private void rescale(long);
    descriptor: (J)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=10, args_size=2
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // long now
         0: .line 266
            aload 0 /* this */
            lload 1 /* now */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.needRescale:(J)Z
            ifeq 16
         1: .line 268
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lockForRescale:()V
         2: .line 272
            aload 0 /* this */
            lload 1 /* now */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.forwardDecayWeight:(J)D
            dstore 3 /* rescaleFactor */
        start local 3 // double rescaleFactor
         3: .line 273
            aload 0 /* this */
            lload 1 /* now */
            putfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayLandmark:J
         4: .line 275
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.length:()I
            istore 5 /* bucketCount */
        start local 5 // int bucketCount
         5: .line 276
            iconst_0
            istore 6 /* i */
        start local 6 // int i
         6: goto 10
         7: .line 278
      StackMap locals: double int int
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            iload 6 /* i */
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.get:(I)J
            l2d
            dload 3 /* rescaleFactor */
            ddiv
            invokestatic java.lang.Math.round:(D)J
            lstore 7 /* newValue */
        start local 7 // long newValue
         8: .line 279
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            iload 6 /* i */
            lload 7 /* newValue */
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.set:(IJ)V
        end local 7 // long newValue
         9: .line 276
            iinc 6 /* i */ 1
      StackMap locals:
      StackMap stack:
        10: iload 6 /* i */
            iload 5 /* bucketCount */
            if_icmplt 7
        end local 6 // int i
        end local 5 // int bucketCount
        end local 3 // double rescaleFactor
        11: .line 281
            goto 15
        12: .line 283
      StackMap locals: org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir long
      StackMap stack: java.lang.Throwable
            astore 9
        13: .line 284
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRescale:()V
        14: .line 285
            aload 9
            athrow
        15: .line 284
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRescale:()V
        16: .line 287
      StackMap locals:
      StackMap stack:
            return
        end local 1 // long now
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   17     0           this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0   17     1            now  J
            3   11     3  rescaleFactor  D
            5   11     5    bucketCount  I
            6   11     6              i  I
            8    9     7       newValue  J
      Exception table:
        from    to  target  type
           2    12      12  any
    MethodParameters:
      Name  Flags
      now   

  private boolean needRescale(long);
    descriptor: (J)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
        start local 1 // long now
         0: .line 291
            lload 1 /* now */
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayLandmark:J
            lsub
            ldc 1800000
            lcmp
            ifle 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 1 // long now
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            0    2     1   now  J
    MethodParameters:
      Name  Flags
      now   

  public void clear();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 297
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lockForRescale:()V
         1: .line 301
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.length:()I
            istore 1 /* bucketCount */
        start local 1 // int bucketCount
         2: .line 302
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         3: goto 7
         4: .line 304
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.decayingBuckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            iload 2 /* i */
            lconst_0
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.set:(IJ)V
         5: .line 305
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.buckets:Ljava/util/concurrent/atomic/AtomicLongArray;
            iload 2 /* i */
            lconst_0
            invokevirtual java.util.concurrent.atomic.AtomicLongArray.set:(IJ)V
         6: .line 302
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         7: iload 2 /* i */
            iload 1 /* bucketCount */
            if_icmplt 4
        end local 2 // int i
        end local 1 // int bucketCount
         8: .line 307
            goto 12
         9: .line 309
      StackMap locals: org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir
      StackMap stack: java.lang.Throwable
            astore 3
        10: .line 310
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRescale:()V
        11: .line 311
            aload 3
            athrow
        12: .line 310
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.unlockForRescale:()V
        13: .line 312
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   14     0         this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
            2    8     1  bucketCount  I
            3    8     2            i  I
      Exception table:
        from    to  target  type
           1     9       9  any
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  private void lockForRegularUsage();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 316
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock.readLock:()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
         1: .line 317
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;

  private void unlockForRegularUsage();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 321
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock.readLock:()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
         1: .line 322
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;

  private void lockForRescale();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 326
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock.writeLock:()Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
         1: .line 327
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;

  private void unlockForRescale();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
         0: .line 331
            aload 0 /* this */
            getfield org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock.writeLock:()Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
            invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
         1: .line 332
            return
        end local 0 // org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/metrics/DecayingEstimatedHistogramReservoir;
}
SourceFile: "DecayingEstimatedHistogramReservoir.java"
NestMembers:
  org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir$EstimatedHistogramReservoirSnapshot
InnerClasses:
  public ReadLock = java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock of java.util.concurrent.locks.ReentrantReadWriteLock
  public WriteLock = java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock of java.util.concurrent.locks.ReentrantReadWriteLock
  private EstimatedHistogramReservoirSnapshot = org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir$EstimatedHistogramReservoirSnapshot of org.apache.cassandra.metrics.DecayingEstimatedHistogramReservoir