hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j..@apache.org
Subject hadoop git commit: HDFS-11449: libhdfs++: Log Datanode read size when reading from an HDFS block. Contributed by Xiaowei Zhu.
Date Fri, 24 Feb 2017 15:47:23 GMT
Repository: hadoop
Updated Branches:
  refs/heads/HDFS-8707 7d5fb82ff -> 511d9c5ae


HDFS-11449: libhdfs++: Log Datanode read size when reading from an HDFS block.  Contributed
by Xiaowei Zhu.


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

Branch: refs/heads/HDFS-8707
Commit: 511d9c5ae6af80126188cfd0865892a13210cd4e
Parents: 7d5fb82
Author: James <jhc@apache.org>
Authored: Fri Feb 24 10:46:50 2017 -0500
Committer: James <jhc@apache.org>
Committed: Fri Feb 24 10:46:50 2017 -0500

----------------------------------------------------------------------
 .../src/main/native/libhdfspp/lib/fs/filehandle.cc            | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/511d9c5a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc
b/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc
index 1f553a0..24e81b6 100644
--- a/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc
+++ b/hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/lib/fs/filehandle.cc
@@ -227,14 +227,15 @@ void FileHandleImpl::AsyncPreadSome(
 
   std::string dnIpAddr = chosen_dn.id().ipaddr();
   std::string dnHostName = chosen_dn.id().hostname();
-  LOG_DEBUG(kFileHandle, << "FileHandleImpl::AsyncPreadSome("
-            << FMT_THIS_ADDR << "), ...) Datanode hostname=" << dnHostName
<< ", IP Address=" << dnIpAddr
-            << ", file path=\"" << path_ << "\", offset=" << offset);
 
   uint64_t offset_within_block = offset - block->offset();
   uint64_t size_within_block = std::min<uint64_t>(
       block->b().numbytes() - offset_within_block, asio::buffer_size(buffers));
 
+  LOG_DEBUG(kFileHandle, << "FileHandleImpl::AsyncPreadSome("
+            << FMT_THIS_ADDR << "), ...) Datanode hostname=" << dnHostName
<< ", IP Address=" << dnIpAddr
+            << ", file path=\"" << path_ << "\", offset=" << offset
<< ", read size=" << size_within_block);
+
   // This is where we will put the logic for re-using a DN connection; we can
   //    steal the FileHandle's dn and put it back when we're done
   std::shared_ptr<DataNodeConnection> dn = CreateDataNodeConnection(io_service_, chosen_dn,
&block->blocktoken());


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message