GEDS: Relocate files on close.

Signed-off-by: Pascal Spörri <psp@zurich.ibm.com>
IBM · Apr 19, 2023 · e2c011b · e2c011b
1 parent d1ec64e
commit e2c011b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/src/main/java/com/ibm/geds/hdfs/GEDSHadoopFileSystem.java b/src/main/java/com/ibm/geds/hdfs/GEDSHadoopFileSystem.java
@@ -52,6 +52,7 @@ public void close() throws IOException {
  // super.close();
  // geds.stopGEDS();
  // geds = null;
+ geds.relocate();
  geds.printStatistics();
  }
 

diff --git a/src/main/java/com/ibm/geds/hdfs/GEDSInputStream.java b/src/main/java/com/ibm/geds/hdfs/GEDSInputStream.java
@@ -235,9 +235,13 @@ public void readFully(long position, byte[] buffer) throws IOException {
 
  public void readFully(long position, ByteBuffer buffer) throws IOException {
  int expected = buffer.remaining();
+ readFully(position, buffer, expected);
+ }
+
+ public void readFully(long position, ByteBuffer buffer, int length) throws IOException {
  int len = file.read(position, buffer);
- if (len != expected) {
- throw new EOFException("Unable to read length " + buffer.length + " at position " + position + ".");
+ if (len != length) {
+ throw new EOFException("Unable to read length " + length + " at position " + position + ".");
  }
  }
 }