svn commit: r608643 - in /lucene/hadoop/trunk: CHANGES.txt src/java/org/apache/hadoop/dfs/FSDatasetInterface.java

[rangadi]

Author: rangadi
Date: Thu Jan  3 13:49:14 2008
New Revision: 608643

URL: http://svn.apache.org/viewvc?rev=608643&view=rev
Log:
HADOOP-2488. Fix a regression in random read performance.
    (Mickael Stack via rangadi)

Modified:
    lucene/hadoop/trunk/CHANGES.txt
    lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSDatasetInterface.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=608643&r1=608642&r2=608643&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Jan  3 13:49:14 2008
@@ -327,6 +327,9 @@
     HADOOP-2442. Fix TestLocalFileSystemPermission.testLocalFSsetOwner
     to work on more platforms. (Raghu Angadi via nigel)
 
+    HADOOP-2488. Fix a regression in random read performance.
+    (Mickael Stack via rangadi)
+
 Release 0.15.2 - 2008-01-02
 
   BUG FIXES

Modified: 
lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSDatasetInterface.java
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSDatasetInterface.java?rev=608643&r1=608642&r2=608643&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSDatasetInterface.java 
(original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSDatasetInterface.java 
Thu Jan  3 13:49:14 2008
@@ -18,6 +18,7 @@
 package org.apache.hadoop.dfs;
 
 
+import java.io.FilterInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
@@ -50,23 +51,12 @@
    * of a block
    *
    */
-  static class MetaDataInputStream extends java.io.InputStream {
+  static class MetaDataInputStream extends FilterInputStream {
     MetaDataInputStream(InputStream stream, long len) {
-      inStream = stream;
+      super(stream);
       length = len;
     }
-    private InputStream inStream;
     private long length;
-    
-    @Override
-    public int read() throws IOException {
-      return inStream.read();
-    }
-    
-    @Override
-    public int read(byte[] b, int off, int len) throws IOException {
-      return inStream.read(b, off, len);
-    }
     
     public long getLength() {
       return length;