You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by to...@apache.org on 2011/03/07 04:44:31 UTC
svn commit: r1078669 - in /hadoop/common/trunk: CHANGES.txt
src/java/org/apache/hadoop/ipc/Server.java
Author: todd
Date: Mon Mar 7 03:44:30 2011
New Revision: 1078669
URL: http://svn.apache.org/viewvc?rev=1078669&view=rev
Log:
HADOOP-7159. RPC server should log the client hostname when read exception happened. Contributed by Scott Chen.
Modified:
hadoop/common/trunk/CHANGES.txt
hadoop/common/trunk/src/java/org/apache/hadoop/ipc/Server.java
Modified: hadoop/common/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/CHANGES.txt?rev=1078669&r1=1078668&r2=1078669&view=diff
==============================================================================
--- hadoop/common/trunk/CHANGES.txt (original)
+++ hadoop/common/trunk/CHANGES.txt Mon Mar 7 03:44:30 2011
@@ -66,6 +66,9 @@ Trunk (unreleased changes)
HADOOP-7114. FsShell should dump all exceptions at DEBUG level.
(todd via tomwhite)
+ HADOOP-7159. RPC server should log the client hostname when read exception
+ happened. (Scott Chen via todd)
+
OPTIMIZATIONS
BUG FIXES
Modified: hadoop/common/trunk/src/java/org/apache/hadoop/ipc/Server.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/src/java/org/apache/hadoop/ipc/Server.java?rev=1078669&r1=1078668&r2=1078669&view=diff
==============================================================================
--- hadoop/common/trunk/src/java/org/apache/hadoop/ipc/Server.java (original)
+++ hadoop/common/trunk/src/java/org/apache/hadoop/ipc/Server.java Mon Mar 7 03:44:30 2011
@@ -559,7 +559,9 @@ public abstract class Server {
LOG.info(getName() + ": readAndProcess caught InterruptedException", ieo);
throw ieo;
} catch (Exception e) {
- LOG.info(getName() + ": readAndProcess threw exception " + e + ". Count of bytes read: " + count, e);
+ LOG.info(getName() + ": readAndProcess threw exception " + e +
+ " from client " + c.getHostAddress() +
+ ". Count of bytes read: " + count, e);
count = -1; //so that the (count < 0) block is executed
}
if (count < 0) {