natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

make constant fields final 

patch by jbellis

git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@1053220 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2010-12-27 23:17:05 +00:00
parent 3ed1201e84
commit 5b9abe1854
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java
View File

@ -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<InetAddress, Double> scores = new ConcurrentHashMap();
private ConcurrentHashMap<InetAddress, AdaptiveLatencyTracker> windows = new ConcurrentHashMap();
private AtomicInteger intervalupdates = new AtomicInteger(0);
public IEndpointSnitch subsnitch;
private final ConcurrentHashMap<InetAddress, Double> scores = new ConcurrentHashMap<InetAddress, Double>();
private final ConcurrentHashMap<InetAddress, AdaptiveLatencyTracker> windows = new ConcurrentHashMap<InetAddress, AdaptiveLatencyTracker>();
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<Double> 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<Double> 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)
{