Add system property to set the max number of native transport requests in queue

Patch by Jake Luciani; reviewed by Nate McCall for CASSANDRA-11363


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/6fb89b90
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/6fb89b90
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/6fb89b90

Branch: refs/heads/trunk
Commit: 6fb89b905cf620200956fefa11c2dac8988a8837
Parents: 95b2d02
Author: Nate McCall <zznat...@gmail.com>
Authored: Tue Sep 20 13:22:50 2016 +1200
Committer: Nate McCall <zznat...@gmail.com>
Committed: Tue Sep 20 14:07:57 2016 +1200

----------------------------------------------------------------------
 CHANGES.txt                                                        | 1 +
 .../org/apache/cassandra/transport/RequestThreadPoolExecutor.java  | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/6fb89b90/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index c1c6c78..1438e98 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 2.1.16
+ * Add system property to set the max number of native transport requests in 
queue (CASSANDRA-11363)
  * Include column family parameter when -st and -et are provided 
(CASSANDRA-11866)
  * Fix queries with empty ByteBuffer values in clustering column restrictions 
(CASSANDRA-12127) 
  * Disable passing control to post-flush after flush failure to prevent data 
loss (CASSANDRA-11828)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/6fb89b90/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git 
a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java 
b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
index 9cac645..75b983a 100644
--- a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
+++ b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
@@ -30,7 +30,7 @@ import static 
org.apache.cassandra.concurrent.JMXEnabledSharedExecutorPool.SHARE
 
 public class RequestThreadPoolExecutor extends AbstractEventExecutor
 {
-    private final static int MAX_QUEUED_REQUESTS = 128;
+    private final static int MAX_QUEUED_REQUESTS = 
Integer.getInteger("cassandra.max_queued_native_transport_requests", 128);
     private final static String THREAD_FACTORY_ID = 
"Native-Transport-Requests";
     private final TracingAwareExecutorService wrapped = 
SHARED.newExecutor(DatabaseDescriptor.getNativeTransportMaxThreads(),
                                                                            
MAX_QUEUED_REQUESTS,

Reply via email to