cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r930265 - /cassandra/trunk/src/java/org/apache/cassandra/concurrent/StageManager.java
Date Fri, 02 Apr 2010 13:23:06 GMT
Author: jbellis
Date: Fri Apr  2 13:23:06 2010
New Revision: 930265

URL: http://svn.apache.org/viewvc?rev=930265&view=rev
Log:
use constant instead of literal string.  patch by Rodrigo Peinado; reviewed by jbellis for
CASSANDRA-906

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/concurrent/StageManager.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/concurrent/StageManager.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/concurrent/StageManager.java?rev=930265&r1=930264&r2=930265&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/concurrent/StageManager.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/concurrent/StageManager.java Fri Apr  2
13:23:06 2010
@@ -52,7 +52,7 @@ public class StageManager
     {
         stages.put(MUTATION_STAGE, multiThreadedStage(MUTATION_STAGE, getConcurrentWriters()));
         stages.put(READ_STAGE, multiThreadedStage(READ_STAGE, getConcurrentReaders()));
-        stages.put(RESPONSE_STAGE, multiThreadedStage("RESPONSE-STAGE", Math.max(2, Runtime.getRuntime().availableProcessors())));
+        stages.put(RESPONSE_STAGE, multiThreadedStage(RESPONSE_STAGE, Math.max(2, Runtime.getRuntime().availableProcessors())));
         // the rest are all single-threaded
         stages.put(STREAM_STAGE, new JMXEnabledThreadPoolExecutor(STREAM_STAGE));
         stages.put(GOSSIP_STAGE, new JMXEnabledThreadPoolExecutor("GMFD"));



Mime
View raw message