src/java/voldemort/cluster/failuredetector/NodeStatus.java

   1 /*
   2  * Copyright 2008-2009 LinkedIn, Inc
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License"); you may not
   5  * use this file except in compliance with the License. You may obtain a copy of
   6  * the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  12  * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  13  * License for the specific language governing permissions and limitations under
  14  * the License.
  15  */
  16
  17 package voldemort.cluster.failuredetector;
  18
  19 import java.util.concurrent.atomic.AtomicInteger;
  20
  21 /**
  22  * Holds the status of a node--either available or unavailable as well as the
  23  * last date the status was checked.
  24  *
  25  * Operations on this class are not atomic, but that is okay.
  26  *
  27  *
  28  */
  29 class NodeStatus {
  30
  31     private long lastChecked;
  32
  33     private boolean isAvailable;
  34
  35     private long startMillis;
  36
  37     private long success;
  38
  39     private long failure;
  40
  41     private long total;
  42
  43     private final AtomicInteger numConsecutiveCatastrophicErrors;
  44
  45     public NodeStatus() {
  46         numConsecutiveCatastrophicErrors = new AtomicInteger(0);
  47     }
  48
  49     public long getLastChecked() {
  50         return lastChecked;
  51     }
  52
  53     public void setLastChecked(long lastChecked) {
  54         this.lastChecked = lastChecked;
  55     }
  56
  57     public boolean isAvailable() {
  58         return isAvailable;
  59     }
  60
  61     public void setAvailable(boolean isAvailable) {
  62         this.isAvailable = isAvailable;
  63     }
  64
  65     public long getStartMillis() {
  66         return startMillis;
  67     }
  68
  69     public void setStartMillis(long startMillis) {
  70         this.startMillis = startMillis;
  71     }
  72
  73     public long getSuccess() {
  74         return success;
  75     }
  76
  77     public long getFailure() {
  78         return failure;
  79     }
  80
  81     public long getTotal() {
  82         return total;
  83     }
  84
  85     public int getNumConsecutiveCatastrophicErrors() {
  86         return numConsecutiveCatastrophicErrors.get();
  87     }
  88
  89     public void resetNumConsecutiveCatastrophicErrors() {
  90         this.numConsecutiveCatastrophicErrors.set(0);
  91     }
  92
  93     public int incrementConsecutiveCatastrophicErrors() {
  94         return this.numConsecutiveCatastrophicErrors.incrementAndGet();
  95     }
  96
  97     public void resetCounters(long currentTime) {
  98         setStartMillis(currentTime);
  99         // Not resetting the catastrophic errors, as they will be reset
 100         // whenever a success is received.
 101         success = 0;
 102         failure = 0;
 103         total = 0;
 104     }
 105
 106     public void recordOperation(boolean isSuccess) {
 107         if(isSuccess) {
 108             success++;
 109         } else {
 110             failure++;
 111         }
 112         total++;
 113     }
 114
 115 }