cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zzn...@apache.org
Subject [39/50] [abbrv] cassandra git commit: Add system property to set the max number of native transport requests in queue
Date Tue, 20 Sep 2016 02:32:45 GMT
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 <zznate.m@gmail.com>
Authored: Tue Sep 20 13:22:50 2016 +1200
Committer: Nate McCall <zznate.m@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,


Mime
View raw message