Author: jbellis Date: Mon Jan 24 16:37:49 2011 New Revision: 1062864 URL: http://svn.apache.org/viewvc?rev=1062864&view=rev Log: r/m unused consistencyManager executor (obsoleted by #982)
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java?rev=1062864&r1=1062863&r2=1062864&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java Mon Jan 24 16:37:49 2011 @@ -169,15 +169,6 @@ public class StorageService implements I /* This abstraction maintains the token/endpoint metadata information */ private TokenMetadata tokenMetadata_ = new TokenMetadata(); - /* This thread pool does consistency checks when the client doesn't care about consistency */ - private ExecutorService consistencyManager_ = new JMXEnabledThreadPoolExecutor(DatabaseDescriptor.getConsistencyThreads(), - DatabaseDescriptor.getConsistencyThreads(), - StageManager.KEEPALIVE, - TimeUnit.SECONDS, - new LinkedBlockingQueue<Runnable>(), - new NamedThreadFactory("ReadRepair"), - "request"); - private Set<InetAddress> replicatingNodes; private InetAddress removingNode;