diff --git a/src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java b/src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java index cd0c34c969..5bf99f2292 100644 --- a/src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java +++ b/src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java @@ -39,17 +39,17 @@ import org.apache.cassandra.utils.FBUtilities; */ public class DynamicEndpointSnitch extends AbstractEndpointSnitch implements ILatencySubscriber, DynamicEndpointSnitchMBean { - private static int UPDATES_PER_INTERVAL = 10000; - private static int UPDATE_INTERVAL_IN_MS = DatabaseDescriptor.getDynamicUpdateInterval(); - private static int RESET_INTERVAL_IN_MS = DatabaseDescriptor.getDynamicResetInterval(); - private static double BADNESS_THRESHOLD = DatabaseDescriptor.getDynamicBadnessThreshold(); - private static int WINDOW_SIZE = 100; + private static final int UPDATES_PER_INTERVAL = 10000; + private static final int UPDATE_INTERVAL_IN_MS = DatabaseDescriptor.getDynamicUpdateInterval(); + private static final int RESET_INTERVAL_IN_MS = DatabaseDescriptor.getDynamicResetInterval(); + private static final double BADNESS_THRESHOLD = DatabaseDescriptor.getDynamicBadnessThreshold(); + private static final int WINDOW_SIZE = 100; private boolean registered = false; - private ConcurrentHashMap scores = new ConcurrentHashMap(); - private ConcurrentHashMap windows = new ConcurrentHashMap(); - private AtomicInteger intervalupdates = new AtomicInteger(0); - public IEndpointSnitch subsnitch; + private final ConcurrentHashMap scores = new ConcurrentHashMap(); + private final ConcurrentHashMap windows = new ConcurrentHashMap(); + private final AtomicInteger intervalupdates = new AtomicInteger(0); + public final IEndpointSnitch subsnitch; public DynamicEndpointSnitch(IEndpointSnitch snitch) { @@ -213,8 +213,8 @@ public class DynamicEndpointSnitch extends AbstractEndpointSnitch implements ILa /** a threadsafe version of BoundedStatsDeque+ArrivalWindow with modification for arbitrary times **/ class AdaptiveLatencyTracker extends AbstractStatsDeque { - private LinkedBlockingDeque latencies; - private static double SENTINEL_COMPARE = 0.0001; // arbitrary; as long as it is the same across hosts it doesn't matter + private final LinkedBlockingDeque latencies; + private static final double SENTINEL_COMPARE = 0.0001; // arbitrary; as long as it is the same across hosts it doesn't matter AdaptiveLatencyTracker(int size) {