Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package me.prettyprint.cassandra.connection;
 
 import java.util.Set;
 
 
public class RoundRobinBalancingPolicy implements LoadBalancingPolicy {
  private AtomicLong counter;
  
     = new AtomicLong(.);
  }
  
      Set<CassandraHostexcludeHosts) {
    ConcurrentHClientPool[] pa = pools.toArray(new ConcurrentHClientPool[pools.size()]);
    int location = getAndIncrement(pa.length);
    ConcurrentHClientPool pool = pa[location];
    if ( excludeHosts != null && excludeHosts.size() > 0 ) {
      while ( excludeHosts.contains(pool.getCassandraHost()) ) {
        pool = pa[getAndIncrement(pa.length)]; 
      }
    }
    return pool;
  }
    
  private int getAndIncrement(int size) {
    return (int).getAndIncrement() % size;    
  }
New to GrepCode? Check out our FAQ X