/[projects]/CircuitBreaker/src/dk/thoerup/circuitbreaker/AccountingCircuitBreaker.java
ViewVC logotype

Diff of /CircuitBreaker/src/dk/thoerup/circuitbreaker/AccountingCircuitBreaker.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 623 by torben, Mon Mar 8 08:38:36 2010 UTC revision 624 by torben, Mon Mar 8 09:46:10 2010 UTC
# Line 9  public class AccountingCircuitBreaker ex Line 9  public class AccountingCircuitBreaker ex
9          private AtomicInteger blockCount = new AtomicInteger(0); //how many times has this CB blocked a call that would otherwise go to the backend          private AtomicInteger blockCount = new AtomicInteger(0); //how many times has this CB blocked a call that would otherwise go to the backend
10          private AtomicInteger totalFailureCount = new AtomicInteger(0); //how many times has the backend thrown an exception          private AtomicInteger totalFailureCount = new AtomicInteger(0); //how many times has the backend thrown an exception
11          private AtomicInteger totalCallCount = new AtomicInteger(0);          private AtomicInteger totalCallCount = new AtomicInteger(0);
12            
13          private AtomicLong lastTrip = new AtomicLong(0);          private AtomicLong lastTrip = new AtomicLong(0);
14          private AtomicLong lastFailure = new AtomicLong(0);          private AtomicLong lastFailure = new AtomicLong(0);
15            private AtomicLong lastReset = new AtomicLong(0);
16            
17          private long lastResetCounters = 0;          private long lastResetCounters = 0;
18                    
19          public AccountingCircuitBreaker(String name, int threshold, long timeoutMS) {          public AccountingCircuitBreaker(String name, int threshold, long timeoutMS) {
# Line 45  public class AccountingCircuitBreaker ex Line 48  public class AccountingCircuitBreaker ex
48                  lastTrip.set( System.currentTimeMillis() );                  lastTrip.set( System.currentTimeMillis() );
49          }          }
50                    
51            
52            
53            @Override
54            public void reset() {
55                    super.reset();
56                    lastReset.set( System.currentTimeMillis());
57            }
58    
59          public int getTripCount() {          public int getTripCount() {
60                  return tripCount.get();                  return tripCount.get();
61          }          }
# Line 69  public class AccountingCircuitBreaker ex Line 80  public class AccountingCircuitBreaker ex
80                  return lastFailure.get();                  return lastFailure.get();
81          }          }
82                    
83            public long getLastReset() {
84                    return lastReset.get();
85            }
86            
87          public int getTotalCallCount() {          public int getTotalCallCount() {
88                  return totalCallCount.get();                  return totalCallCount.get();
89          }          }
# Line 79  public class AccountingCircuitBreaker ex Line 94  public class AccountingCircuitBreaker ex
94                  totalFailureCount.set(0);                  totalFailureCount.set(0);
95                  totalCallCount.set(0);                  totalCallCount.set(0);
96                  lastTrip.set(0);                  lastTrip.set(0);
97                    lastReset.set(0);
98                  lastFailure.set(0);                  lastFailure.set(0);
99                                    
100                  lastResetCounters = System.currentTimeMillis();                  lastResetCounters = System.currentTimeMillis();
Legend:
Removed from v.623  
changed lines
  Added in v.624
  ViewVC Help
Powered by ViewVC 1.1.20