kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-3983; Add additional information to Acceptor debug message
Date Fri, 22 Jul 2016 17:10:03 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 427e63851 -> fa3254544


KAFKA-3983; Add additional information to Acceptor debug message

Add additional information to Acceptor debug message upon connection acceptance

Author: rnpridgeon <ryan.n.pridgeon@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1648 from rnpridgeon/trunk


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

Branch: refs/heads/trunk
Commit: fa32545442ef6724aa9fb5f4e0e269b0c873288f
Parents: 427e638
Author: Ryan Pridgeon <ryan.n.pridgeon@gmail.com>
Authored: Fri Jul 22 18:09:38 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Jul 22 18:09:38 2016 +0100

----------------------------------------------------------------------
 core/src/main/scala/kafka/network/SocketServer.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fa325454/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
index ad9ac8d..fcf0bc5 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -332,8 +332,8 @@ private[kafka] class Acceptor(val endPoint: EndPoint,
       if (sendBufferSize != Selectable.USE_DEFAULT_BUFFER_SIZE)
         socketChannel.socket().setSendBufferSize(sendBufferSize)
 
-      debug("Accepted connection from %s on %s. sendBufferSize [actual|requested]: [%d|%d]
recvBufferSize [actual|requested]: [%d|%d]"
-            .format(socketChannel.socket.getInetAddress, socketChannel.socket.getLocalSocketAddress,
+      debug("Accepted connection from %s on %s and assigned it to processor %d, sendBufferSize
[actual|requested]: [%d|%d] recvBufferSize [actual|requested]: [%d|%d]"
+            .format(socketChannel.socket.getRemoteSocketAddress, socketChannel.socket.getLocalSocketAddress,
processor.id,
                   socketChannel.socket.getSendBufferSize, sendBufferSize,
                   socketChannel.socket.getReceiveBufferSize, recvBufferSize))
 


Mime
View raw message