org.apache.commons/commons-lang3/3.7 : org/apache/commons/lang3/concurrent/EventCountCircuitBreaker.class

EventCountCircuitBreaker
http://commons.apache.org/proper/commons-lang/: Apache Commons Lang, a package of Java utility classes for the classes that are in java.lang's hierarchy, or are considered to be so standard as to justify existence in java.lang. (The Apache Software Foundation)
Apache License, Version 2.0
C. Scott Ananian
Chris Audley
Stephane Bailliez
Michael Becke
Benjamin Bentmann
Ola Berg
Nathan Beyer
Stefan Bodewig
Janek Bogucki
Mike Bowler
Sean Brown
Alexander Day Chaffee
Al Chou
Greg Coladonato
Maarten Coene
Justin Couch
Michael Davey
Norm Deane
Morgan Delagrange
Ringo De Smet
Russel Dittmar
Steve Downey
Matthias Eichel
Christopher Elkins
Chris Feldhacker
Roland Foerther
Pete Gieser
Jason Gritman
Matthew Hawthorne
Michael Heuer
Chas Honton
Chris Hyzer
Paul Jack
Marc Johnson
Shaun Kalley
Tetsuya Kaneuchi
Nissim Karpenstein
Ed Korthof
Holger Krauth
Rafal Krupinski
Rafal Krzewski
David Leppik
Eli Lindsey
Sven Ludwig
Craig R. McClanahan
Rand McNeely
Hendrik Maryns
Dave Meikle
Nikolay Metchev
Kasper Nielsen
Tim O'Brien
Brian S O'Neill
Andrew C. Oliver
Alban Peignier
Moritz Petersen
Dmitri Plotnikov
Neeme Praks
Eric Pugh
Stephen Putman
Travis Reeder
Antony Riley
Valentin Rocher
Scott Sanders
James Sawle
Ralph Schaer
Henning P. Schmiedehausen
Sean Schofield
Robert Scholte
Reuben Sivan
Ville Skytta
David M. Sledge
Michael A. Smith
Jan Sorensen
Glen Stampoultzis
Scott Stanchfield
Jon S. Stevens
Sean C. Sullivan
Ashwin Suresh
Helge Tesgaard
Arun Mammen Thomas
Masato Tezuka
Daniel Trebbien
Jeff Varszegi
Chris Webb
Mario Winterer
Stepan Koltsov
Holger Hoffstatte
Derek C. Ashmore
Sebastien Riou
Allon Mureinik
Adam Hooper
Chris Karcher
Michael Osipov
Thiago Andrade
Jonathan Baker
Mikhail Mazursky
Fabian Lange
Michał Kordas
Felipe Adorno
Adrian Ber
Mark Dacek
Daniel Rall (CollabNet, Inc.)
Stephen Colebourne (SITA ATS Ltd)
Henri Yandell ()
Steven Caswell ()
Robert Burrell Donkin ()
Gary D. Gregory
Fredrik Westermarck ()
James Carman (Carman Consulting, Inc.)
Niall Pemberton
Matt Benson
Joerg Schaible
Oliver Heger
Paul Benedict
Benedikt Ritter
Duncan Jones
Loic Guibert
Rob Tompkins
public class org.apache.commons.lang3.concurrent.EventCountCircuitBreaker extends org.apache.commons.lang3.concurrent.AbstractCircuitBreaker<java.lang.Integer>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.commons.lang3.concurrent.EventCountCircuitBreaker
  super_class: org.apache.commons.lang3.concurrent.AbstractCircuitBreaker
{
  private static final java.util.Map<org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State, org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy> STRATEGY_MAP;
    descriptor: Ljava/util/Map;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/Map<Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;>;

  private final java.util.concurrent.atomic.AtomicReference<org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData> checkIntervalData;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;>;

  private final int openingThreshold;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long openingInterval;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int closingThreshold;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long closingInterval;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 141
            invokestatic org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.createStrategyMap:()Ljava/util/Map;
            putstatic org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.STRATEGY_MAP:Ljava/util/Map;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(int, long, java.util.concurrent.TimeUnit, int, long, java.util.concurrent.TimeUnit);
    descriptor: (IJLjava/util/concurrent/TimeUnit;IJLjava/util/concurrent/TimeUnit;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=9, args_size=7
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // int openingThreshold
        start local 2 // long openingInterval
        start local 4 // java.util.concurrent.TimeUnit openingUnit
        start local 5 // int closingThreshold
        start local 6 // long closingInterval
        start local 8 // java.util.concurrent.TimeUnit closingUnit
         0: .line 177
            aload 0 /* this */
            invokespecial org.apache.commons.lang3.concurrent.AbstractCircuitBreaker.<init>:()V
         1: .line 178
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
            dup
            iconst_0
            lconst_0
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData.<init>:(IJ)V
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
            putfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.checkIntervalData:Ljava/util/concurrent/atomic/AtomicReference;
         2: .line 179
            aload 0 /* this */
            iload 1 /* openingThreshold */
            putfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.openingThreshold:I
         3: .line 180
            aload 0 /* this */
            aload 4 /* openingUnit */
            lload 2 /* openingInterval */
            invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
            putfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.openingInterval:J
         4: .line 181
            aload 0 /* this */
            iload 5 /* closingThreshold */
            putfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.closingThreshold:I
         5: .line 182
            aload 0 /* this */
            aload 8 /* closingUnit */
            lload 6 /* closingInterval */
            invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
            putfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.closingInterval:J
         6: .line 183
            return
        end local 8 // java.util.concurrent.TimeUnit closingUnit
        end local 6 // long closingInterval
        end local 5 // int closingThreshold
        end local 4 // java.util.concurrent.TimeUnit openingUnit
        end local 2 // long openingInterval
        end local 1 // int openingThreshold
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    7     1  openingThreshold  I
            0    7     2   openingInterval  J
            0    7     4       openingUnit  Ljava/util/concurrent/TimeUnit;
            0    7     5  closingThreshold  I
            0    7     6   closingInterval  J
            0    7     8       closingUnit  Ljava/util/concurrent/TimeUnit;
    MethodParameters:
                  Name  Flags
      openingThreshold  final
      openingInterval   final
      openingUnit       final
      closingThreshold  final
      closingInterval   final
      closingUnit       final

  public void <init>(int, long, java.util.concurrent.TimeUnit, int);
    descriptor: (IJLjava/util/concurrent/TimeUnit;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=6, args_size=5
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // int openingThreshold
        start local 2 // long checkInterval
        start local 4 // java.util.concurrent.TimeUnit checkUnit
        start local 5 // int closingThreshold
         0: .line 200
            aload 0 /* this */
            iload 1 /* openingThreshold */
            lload 2 /* checkInterval */
            aload 4 /* checkUnit */
            iload 5 /* closingThreshold */
            lload 2 /* checkInterval */
         1: .line 201
            aload 4 /* checkUnit */
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.<init>:(IJLjava/util/concurrent/TimeUnit;IJLjava/util/concurrent/TimeUnit;)V
         2: .line 202
            return
        end local 5 // int closingThreshold
        end local 4 // java.util.concurrent.TimeUnit checkUnit
        end local 2 // long checkInterval
        end local 1 // int openingThreshold
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    3     0              this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    3     1  openingThreshold  I
            0    3     2     checkInterval  J
            0    3     4         checkUnit  Ljava/util/concurrent/TimeUnit;
            0    3     5  closingThreshold  I
    MethodParameters:
                  Name  Flags
      openingThreshold  final
      checkInterval     final
      checkUnit         final
      closingThreshold  final

  public void <init>(int, long, java.util.concurrent.TimeUnit);
    descriptor: (IJLjava/util/concurrent/TimeUnit;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // int threshold
        start local 2 // long checkInterval
        start local 4 // java.util.concurrent.TimeUnit checkUnit
         0: .line 215
            aload 0 /* this */
            iload 1 /* threshold */
            lload 2 /* checkInterval */
            aload 4 /* checkUnit */
            iload 1 /* threshold */
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.<init>:(IJLjava/util/concurrent/TimeUnit;I)V
         1: .line 216
            return
        end local 4 // java.util.concurrent.TimeUnit checkUnit
        end local 2 // long checkInterval
        end local 1 // int threshold
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0           this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    2     1      threshold  I
            0    2     2  checkInterval  J
            0    2     4      checkUnit  Ljava/util/concurrent/TimeUnit;
    MethodParameters:
               Name  Flags
      threshold      final
      checkInterval  final
      checkUnit      final

  public int getOpeningThreshold();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 226
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.openingThreshold:I
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public long getOpeningInterval();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 235
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.openingInterval:J
            lreturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public int getClosingThreshold();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 246
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.closingThreshold:I
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public long getClosingInterval();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 255
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.closingInterval:J
            lreturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public boolean checkState();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 265
            aload 0 /* this */
            iconst_0
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.performStateCheck:(I)Z
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public boolean incrementAndCheckState(java.lang.Integer);
    descriptor: (Ljava/lang/Integer;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // java.lang.Integer increment
         0: .line 274
            aload 0 /* this */
            iconst_1
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.performStateCheck:(I)Z
            ireturn
        end local 1 // java.lang.Integer increment
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    1     1  increment  Ljava/lang/Integer;
    Exceptions:
      throws org.apache.commons.lang3.concurrent.CircuitBreakingException
    MethodParameters:
           Name  Flags
      increment  final

  public boolean incrementAndCheckState();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 286
            aload 0 /* this */
            iconst_1
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.incrementAndCheckState:(Ljava/lang/Integer;)Z
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public void open();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 297
            aload 0 /* this */
            invokespecial org.apache.commons.lang3.concurrent.AbstractCircuitBreaker.open:()V
         1: .line 298
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.checkIntervalData:Ljava/util/concurrent/atomic/AtomicReference;
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
            dup
            iconst_0
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.now:()J
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData.<init>:(IJ)V
            invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
         2: .line 299
            return
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 309
            aload 0 /* this */
            invokespecial org.apache.commons.lang3.concurrent.AbstractCircuitBreaker.close:()V
         1: .line 310
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.checkIntervalData:Ljava/util/concurrent/atomic/AtomicReference;
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
            dup
            iconst_0
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.now:()J
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData.<init>:(IJ)V
            invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
         2: .line 311
            return
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  private boolean performStateCheck(int);
    descriptor: (I)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=7, args_size=2
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // int increment
         0: .line 326
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.now:()J
            lstore 5 /* time */
        start local 5 // long time
         1: .line 327
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.state:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State
            astore 4 /* currentState */
        start local 4 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State currentState
         2: .line 328
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.checkIntervalData:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
            astore 2 /* currentData */
        start local 2 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData currentData
         3: .line 329
            aload 0 /* this */
            iload 1 /* increment */
            aload 2 /* currentData */
            aload 4 /* currentState */
            lload 5 /* time */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.nextCheckIntervalData:(ILorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;J)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            astore 3 /* nextData */
        end local 5 // long time
        start local 3 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
         4: .line 330
            aload 0 /* this */
            aload 2 /* currentData */
            aload 3 /* nextData */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.updateCheckIntervalData:(Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;)Z
            ifeq 0
         5: .line 334
            aload 4 /* currentState */
            invokestatic org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.stateStrategy:(Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;
            aload 0 /* this */
            aload 2 /* currentData */
            aload 3 /* nextData */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy.isStateTransition:(Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;)Z
            ifeq 8
         6: .line 335
            aload 4 /* currentState */
            invokevirtual org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State.oppositeState:()Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
            astore 4 /* currentState */
         7: .line 336
            aload 0 /* this */
            aload 4 /* currentState */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.changeStateAndStartNewCheckInterval:(Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)V
         8: .line 338
      StackMap locals: org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State
      StackMap stack:
            aload 4 /* currentState */
            invokestatic org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.isOpen:(Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)Z
            ifeq 9
            iconst_0
            goto 10
      StackMap locals:
      StackMap stack:
         9: iconst_1
      StackMap locals:
      StackMap stack: int
        10: ireturn
        end local 4 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State currentState
        end local 3 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
        end local 2 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData currentData
        end local 1 // int increment
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   11     0          this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0   11     1     increment  I
            3   11     2   currentData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            4   11     3      nextData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            2   11     4  currentState  Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
            1    4     5          time  J
    MethodParameters:
           Name  Flags
      increment  final

  private boolean updateCheckIntervalData(org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData, org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData);
    descriptor: (Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData currentData
        start local 2 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
         0: .line 353
            aload 1 /* currentData */
            aload 2 /* nextData */
            if_acmpeq 3
         1: .line 354
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.checkIntervalData:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* currentData */
            aload 2 /* nextData */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifne 3
         2: .line 353
            iconst_0
            ireturn
      StackMap locals:
      StackMap stack:
         3: iconst_1
            ireturn
        end local 2 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
        end local 1 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData currentData
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    4     1  currentData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            0    4     2     nextData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
    MethodParameters:
             Name  Flags
      currentData  final
      nextData     final

  private void changeStateAndStartNewCheckInterval(org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State);
    descriptor: (Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State newState
         0: .line 364
            aload 0 /* this */
            aload 1 /* newState */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.changeState:(Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)V
         1: .line 365
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.checkIntervalData:Ljava/util/concurrent/atomic/AtomicReference;
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
            dup
            iconst_0
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.now:()J
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData.<init>:(IJ)V
            invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
         2: .line 366
            return
        end local 1 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State newState
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    3     1  newState  Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
    Signature: (Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)V
    MethodParameters:
          Name  Flags
      newState  final

  private org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextCheckIntervalData(int, org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData, org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State, long);
    descriptor: (ILorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;J)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=7, args_size=5
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
        start local 1 // int increment
        start local 2 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData currentData
        start local 3 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State currentState
        start local 4 // long time
         0: .line 382
            aload 3 /* currentState */
            invokestatic org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.stateStrategy:(Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;
            aload 0 /* this */
            aload 2 /* currentData */
            lload 4 /* time */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy.isCheckIntervalFinished:(Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;J)Z
            ifeq 3
         1: .line 383
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
            dup
            iload 1 /* increment */
            lload 4 /* time */
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData.<init>:(IJ)V
            astore 6 /* nextData */
        start local 6 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
         2: .line 384
            goto 4
        end local 6 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
         3: .line 385
      StackMap locals:
      StackMap stack:
            aload 2 /* currentData */
            iload 1 /* increment */
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData.increment:(I)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            astore 6 /* nextData */
        start local 6 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
         4: .line 387
      StackMap locals: org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData
      StackMap stack:
            aload 6 /* nextData */
            areturn
        end local 6 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData nextData
        end local 4 // long time
        end local 3 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State currentState
        end local 2 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData currentData
        end local 1 // int increment
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;
            0    5     1     increment  I
            0    5     2   currentData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            0    5     3  currentState  Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
            0    5     4          time  J
            2    3     6      nextData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
            4    5     6      nextData  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
    Signature: (ILorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;J)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$CheckIntervalData;
    MethodParameters:
              Name  Flags
      increment     final
      currentData   final
      currentState  final
      time          final

  long now();
    descriptor: ()J
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
         0: .line 397
            invokestatic java.lang.System.nanoTime:()J
            lreturn
        end local 0 // org.apache.commons.lang3.concurrent.EventCountCircuitBreaker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker;

  private static org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy stateStrategy(org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State);
    descriptor: (Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State state
         0: .line 408
            getstatic org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.STRATEGY_MAP:Ljava/util/Map;
            aload 0 /* state */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy
            areturn
        end local 0 // org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State state
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  state  Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
    Signature: (Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;)Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;
    MethodParameters:
       Name  Flags
      state  final

  private static java.util.Map<org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State, org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy> createStrategyMap();
    descriptor: ()Ljava/util/Map;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=0
         0: .line 418
            new java.util.EnumMap
            dup
            ldc Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
            invokespecial java.util.EnumMap.<init>:(Ljava/lang/Class;)V
            astore 0 /* map */
        start local 0 // java.util.Map map
         1: .line 419
            aload 0 /* map */
            getstatic org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State.CLOSED:Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyClosed
            dup
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyClosed.<init>:()V
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 420
            aload 0 /* map */
            getstatic org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State.OPEN:Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;
            new org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyOpen
            dup
            invokespecial org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyOpen.<init>:()V
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 421
            aload 0 /* map */
            areturn
        end local 0 // java.util.Map map
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            1    4     0   map  Ljava/util/Map<Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;>;
    Signature: ()Ljava/util/Map<Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker$State;Lorg/apache/commons/lang3/concurrent/EventCountCircuitBreaker$StateStrategy;>;

  public boolean incrementAndCheckState(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast java.lang.Integer
            invokevirtual org.apache.commons.lang3.concurrent.EventCountCircuitBreaker.incrementAndCheckState:(Ljava/lang/Integer;)Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: Lorg/apache/commons/lang3/concurrent/AbstractCircuitBreaker<Ljava/lang/Integer;>;
SourceFile: "EventCountCircuitBreaker.java"
NestMembers:
  org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData  org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy  org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyClosed  org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyOpen
InnerClasses:
  protected abstract State = org.apache.commons.lang3.concurrent.AbstractCircuitBreaker$State of org.apache.commons.lang3.concurrent.AbstractCircuitBreaker
  private CheckIntervalData = org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$CheckIntervalData of org.apache.commons.lang3.concurrent.EventCountCircuitBreaker
  private abstract StateStrategy = org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategy of org.apache.commons.lang3.concurrent.EventCountCircuitBreaker
  private StateStrategyClosed = org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyClosed of org.apache.commons.lang3.concurrent.EventCountCircuitBreaker
  private StateStrategyOpen = org.apache.commons.lang3.concurrent.EventCountCircuitBreaker$StateStrategyOpen of org.apache.commons.lang3.concurrent.EventCountCircuitBreaker
/

org.apache.commons/ commons-lang3/ 3.7/ org/apache/commons/lang3/concurrent/EventCountCircuitBreaker.class
