Hadoop: Fix a nasty IO bug.

CephInputStream.read() needs to return an int between 0 and 255,
but bytes are signed and casting preserves that. Adjust if needed.

diff --git a/src/client/hadoop/ceph/CephInputStream.java b/src/client/hadoop/ceph/CephInputStream.java
index e41153ecf9c4a68ca5e8c7ae5f607acff7dd7226..b0b7dd56f0134985b13daa80e7a30e1287d4a5b4 100644 (file)
--- a/src/client/hadoop/ceph/CephInputStream.java
+++ b/src/client/hadoop/ceph/CephInputStream.java
@@ -114,7 +114,8 @@ class CephInputStream extends FSInputStream {
       byte result[] = new byte[1];
       if (getPos() >= fileLength) return -1;
       if (-1 == read(result, 0, 1)) return -1;
-      return result[0];
+      if (result[0]<0) return 256+(int)result[0];
+      else return result[0];
     }
 
   /**