Author: brandonwilliams Date: Fri Oct 7 23:21:26 2011 New Revision: 1180277
URL: http://svn.apache.org/viewvc?rev=1180277&view=rev Log: Bump hsha threads to cores * 4 Modified: cassandra/branches/cassandra-1.0.0/conf/cassandra.yaml cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/config/DatabaseDescriptor.java Modified: cassandra/branches/cassandra-1.0.0/conf/cassandra.yaml URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0.0/conf/cassandra.yaml?rev=1180277&r1=1180276&r2=1180277&view=diff ============================================================================== --- cassandra/branches/cassandra-1.0.0/conf/cassandra.yaml (original) +++ cassandra/branches/cassandra-1.0.0/conf/cassandra.yaml Fri Oct 7 23:21:26 2011 @@ -219,7 +219,8 @@ rpc_server_type: sync # disconnects before accepting more. The defaults for sync are min of 16 and max # unlimited. # -# For the Hsha server, the min and max both default to the number of CPU cores. +# For the Hsha server, the min and max both default to quadruple the number of +# CPU cores. # # This configuration is ignored by the async server. # Modified: cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/config/DatabaseDescriptor.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/config/DatabaseDescriptor.java?rev=1180277&r1=1180276&r2=1180277&view=diff ============================================================================== --- cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/config/DatabaseDescriptor.java (original) +++ cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/config/DatabaseDescriptor.java Fri Oct 7 23:21:26 2011 @@ -367,7 +367,7 @@ public class DatabaseDescriptor throw new ConfigurationException("Unknown rpc_server_type: " + conf.rpc_server_type); if (conf.rpc_min_threads == null) conf.rpc_min_threads = conf.rpc_server_type.toLowerCase().equals("hsha") - ? Runtime.getRuntime().availableProcessors() + ? Runtime.getRuntime().availableProcessors() * 4 : 16; if (conf.rpc_max_threads == null) conf.rpc_max_threads = conf.rpc_server_type.toLowerCase().equals("hsha")
