kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-2096; Enable keepalive socket option for broker to prevent socket leak; patched by Allen Wang; reviewed by Jun Rao
Date Thu, 09 Apr 2015 00:21:45 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 6880f66c9 -> 194d1fc03


kafka-2096; Enable keepalive socket option for broker to prevent socket leak; patched by Allen
Wang; reviewed by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/194d1fc0
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/194d1fc0
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/194d1fc0

Branch: refs/heads/trunk
Commit: 194d1fc030561fd06e39224584b58cc49e2f63e8
Parents: 6880f66
Author: Allen Wang <ax_wang@yahoo.com>
Authored: Wed Apr 8 17:21:29 2015 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed Apr 8 17:21:29 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/network/SocketServer.scala | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/194d1fc0/core/src/main/scala/kafka/network/SocketServer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
old mode 100755
new mode 100644
index 8fbea7b..c5fec00
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -308,6 +308,7 @@ private[kafka] class Acceptor(val host: String,
       connectionQuotas.inc(socketChannel.socket().getInetAddress)
       socketChannel.configureBlocking(false)
       socketChannel.socket().setTcpNoDelay(true)
+      socketChannel.socket().setKeepAlive(true)
       socketChannel.socket().setSendBufferSize(sendBufferSize)
 
       debug("Accepted connection from %s on %s. sendBufferSize [actual|requested]: [%d|%d]
recvBufferSize [actual|requested]: [%d|%d]"


Mime
View raw message