svn commit: r1029845 - /cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/concurrent/StageManager.java

[jbellis]

Author: jbellis
Date: Mon Nov  1 21:20:28 2010
New Revision: 1029845

URL: http://svn.apache.org/viewvc?rev=1029845&view=rev
Log:
force at least 2 threads to avoid assertion failure on single-cpu machines.  
patch by jbellis

Modified:
    
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/concurrent/StageManager.java

Modified: 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/concurrent/StageManager.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/concurrent/StageManager.java?rev=1029845&r1=1029844&r2=1029845&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/concurrent/StageManager.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/concurrent/StageManager.java
 Mon Nov  1 21:20:28 2010
@@ -43,7 +43,7 @@ public class StageManager
         stages.put(Stage.MUTATION, 
multiThreadedConfigurableStage(Stage.MUTATION, getConcurrentWriters()));
         stages.put(Stage.READ, multiThreadedConfigurableStage(Stage.READ, 
getConcurrentReaders()));        
         stages.put(Stage.REQUEST_RESPONSE, 
multiThreadedStage(Stage.REQUEST_RESPONSE, Math.max(2, 
Runtime.getRuntime().availableProcessors())));
-        stages.put(Stage.INTERNAL_RESPONSE, 
multiThreadedStage(Stage.INTERNAL_RESPONSE, Math.max(1, 
Runtime.getRuntime().availableProcessors())));
+        stages.put(Stage.INTERNAL_RESPONSE, 
multiThreadedStage(Stage.INTERNAL_RESPONSE, Math.max(2, 
Runtime.getRuntime().availableProcessors())));
         // the rest are all single-threaded
         stages.put(Stage.STREAM, new 
JMXEnabledThreadPoolExecutor(Stage.STREAM));
         stages.put(Stage.GOSSIP, new 
JMXEnabledThreadPoolExecutor(Stage.GOSSIP));