cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r1062864 - /cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java
Date Mon, 24 Jan 2011 16:37:50 GMT
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;
 



Mime
View raw message