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;
 


Reply via email to