cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [02/13] git commit: Enable keepalive for native protocol
Date Thu, 12 Jun 2014 14:47:19 GMT
Enable keepalive for native protocol

Patch by brandonwilliams reviewed by Sankalp Kohli for CASSANDRA-7380


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

Branch: refs/heads/trunk
Commit: 2d6babbcc992dce30028f2cb4ca61bdb0962f0e8
Parents: f40ddba
Author: Brandon Williams <brandonwilliams@apache.org>
Authored: Thu Jun 12 09:29:05 2014 -0500
Committer: Brandon Williams <brandonwilliams@apache.org>
Committed: Thu Jun 12 09:29:05 2014 -0500

----------------------------------------------------------------------
 CHANGES.txt                                         | 1 +
 conf/cassandra.yaml                                 | 2 +-
 src/java/org/apache/cassandra/transport/Server.java | 1 +
 3 files changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/2d6babbc/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index a50825f..dd58ff9 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 1.2.17
+ * Enable keepalive for native protocol (CASSANDRA-7380)
  * Check internal addresses for seeds (CASSANDRA-6523)
  * Fix potential / by 0 in HHOM page size calculation (CASSANDRA-7354)
  * Fix handling of empty counter replication mutations (CASSANDRA-7144)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2d6babbc/conf/cassandra.yaml
----------------------------------------------------------------------
diff --git a/conf/cassandra.yaml b/conf/cassandra.yaml
index ecad3f0..fab9527 100644
--- a/conf/cassandra.yaml
+++ b/conf/cassandra.yaml
@@ -366,7 +366,7 @@ rpc_address: localhost
 # port for Thrift to listen for clients on
 rpc_port: 9160
 
-# enable or disable keepalive on rpc connections
+# enable or disable keepalive on rpc/native connections
 rpc_keepalive: true
 
 # Cassandra provides three out-of-the-box options for the RPC Server:

http://git-wip-us.apache.org/repos/asf/cassandra/blob/2d6babbc/src/java/org/apache/cassandra/transport/Server.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/transport/Server.java b/src/java/org/apache/cassandra/transport/Server.java
index 5773728..74f4a0d 100644
--- a/src/java/org/apache/cassandra/transport/Server.java
+++ b/src/java/org/apache/cassandra/transport/Server.java
@@ -116,6 +116,7 @@ public class Server implements CassandraDaemon.Server
         ServerBootstrap bootstrap = new ServerBootstrap(factory);
 
         bootstrap.setOption("child.tcpNoDelay", true);
+        bootstrap.setOption("child.keepAlive", DatabaseDescriptor.getRpcKeepAlive());
 
         // Set up the event pipeline factory.
         final EncryptionOptions.ClientEncryptionOptions clientEnc = DatabaseDescriptor.getClientEncryptionOptions();


Mime
View raw message