You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by zz...@apache.org on 2016/09/20 02:32:43 UTC
[37/50] [abbrv] cassandra git commit: Add system property to set the
max number of native transport requests in queue
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/cassandra-3.0
Commit: 6fb89b905cf620200956fefa11c2dac8988a8837
Parents: 95b2d02
Author: Nate McCall <zz...@gmail.com>
Authored: Tue Sep 20 13:22:50 2016 +1200
Committer: Nate McCall <zz...@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,