Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-2071. Use of isConnected() in DataXceiver is invalid. Contributed by Kihwal Lee. 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1136205 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2011-06-15 21:36:56 +00:00
parent f7c0c44de2
commit 6a3963cc8b
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hdfs/CHANGES.txt
View File

@ -1218,6 +1218,9 @@ Release 0.22.0 - Unreleased
HDFS-988. saveNamespace race can corrupt the edits log. (eli) HDFS-988. saveNamespace race can corrupt the edits log. (eli)
HDFS-2071. Use of isConnected() in DataXceiver is invalid. (Kihwal Lee
via todd)
Release 0.21.1 - Unreleased Release 0.21.1 - Unreleased
HDFS-1466. TestFcHdfsSymlink relies on /tmp/test not existing. (eli) HDFS-1466. TestFcHdfsSymlink relies on /tmp/test not existing. (eli)

2
hdfs/src/java/org/apache/hadoop/hdfs/server/datanode/DataXceiver.java
View File

@ -178,7 +178,7 @@ class DataXceiver extends Receiver implements Runnable, FSConstants {
opStartTime = now(); opStartTime = now();
processOp(op, in); processOp(op, in);
++opsProcessed; ++opsProcessed;
} while (s.isConnected() && socketKeepaliveTimeout > 0); } while (!s.isClosed() && socketKeepaliveTimeout > 0);
} catch (Throwable t) { } catch (Throwable t) {
LOG.error(datanode.getMachineName() + ":DataXceiver, at " + LOG.error(datanode.getMachineName() + ":DataXceiver, at " +
s.toString(), t); s.toString(), t);