commit b006a5078339d125e62919bcc76956c9849000af
author Lei Feiwei <leifeiwei@baidu.com> Fri Oct 17 21:11:04 2014 +0800
committer Roger Meier <roger@apache.org> Tue Oct 21 23:49:50 2014 +0200
tree ab7d1b11f0e7fcc3c679bcd1e1796a8d00799306
parent a70986fc34428c665ffadd602aae6a69ceeb418e

THRIFT-2788: enable TCP keep alive for sockets in java lib.

This closes #248

Signed-off-by: Roger Meier <roger@apache.org>

lib/java/src/org/apache/thrift/transport/TNonblockingSocket.java

diff --git a/lib/java/src/org/apache/thrift/transport/TNonblockingSocket.java b/lib/java/src/org/apache/thrift/transport/TNonblockingSocket.java
index 482bd14..23f8574 100644
--- a/lib/java/src/org/apache/thrift/transport/TNonblockingSocket.java
+++ b/lib/java/src/org/apache/thrift/transport/TNonblockingSocket.java
@@ -85,6 +85,7 @@
     Socket socket = socketChannel.socket();
     socket.setSoLinger(false, 0);
     socket.setTcpNoDelay(true);
+    socket.setKeepAlive(true);
     setTimeout(timeout);
   }
 

lib/java/src/org/apache/thrift/transport/TSocket.java

diff --git a/lib/java/src/org/apache/thrift/transport/TSocket.java b/lib/java/src/org/apache/thrift/transport/TSocket.java
index 606e8a9..c340dd2 100644
--- a/lib/java/src/org/apache/thrift/transport/TSocket.java
+++ b/lib/java/src/org/apache/thrift/transport/TSocket.java
@@ -68,6 +68,7 @@
     try {
       socket_.setSoLinger(false, 0);
       socket_.setTcpNoDelay(true);
+      socket_.setKeepAlive(true);
     } catch (SocketException sx) {
       LOGGER.warn("Could not configure socket.", sx);
     }
@@ -117,6 +118,7 @@
     try {
       socket_.setSoLinger(false, 0);
       socket_.setTcpNoDelay(true);
+      socket_.setKeepAlive(true);
       socket_.setSoTimeout(timeout_);
     } catch (SocketException sx) {
       LOGGER.error("Could not configure socket.", sx);