Retain RandomAccessFile in JournalSegmentFile

[controller.git] / atomix-storage / src / main / java / io / atomix / storage / journal / SegmentedJournal.java

diff --git a/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java b/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
index 7e821277ce5e344fead93016cdee48f4d7f89deb..23a5419b8333befb67031b187d3efad17a35a9a9 100644 (file)
--- a/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
+++ b/atomix-storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
@@ -191,7 +191,13 @@ public final class SegmentedJournal<E> implements Journal<E> {
    */
   public long size() {
     return segments.values().stream()
-        .mapToLong(JournalSegment::size)
+        .mapToLong(segment -> {
+          try {
+            return segment.file().size();
+          } catch (IOException e) {
+            throw new StorageException(e);
+          }
+        })
         .sum();
   }