Fix reader/writer buffer sharing

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

diff --git a/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java b/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java
index 96386a5d621d24045dd150bf49ae5e8170a3017a..b634169fe848f34854d16007a600c6dd6734f5e9 100644 (file)
--- a/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java
+++ b/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java
@@ -57,8 +57,8 @@ final class DiskJournalSegmentWriter<E> extends JournalSegmentWriter<E> {
     super(channel, segment, maxEntrySize, index, namespace);
 
     buffer = DiskFileReader.allocateBuffer(maxSegmentSize, maxEntrySize);
-    final var fileReader = new DiskFileReader(segment.file().file().toPath(), channel, maxSegmentSize, maxEntrySize);
-    reader = new JournalSegmentReader<>(segment, fileReader, maxEntrySize, namespace);
+    reader = new JournalSegmentReader<>(segment,
+        new DiskFileReader(segment.file().file().toPath(), channel, buffer), maxEntrySize, namespace);
     reset(0);
   }
 
@@ -66,8 +66,8 @@ final class DiskJournalSegmentWriter<E> extends JournalSegmentWriter<E> {
     super(previous);
 
     buffer = DiskFileReader.allocateBuffer(maxSegmentSize, maxEntrySize);
-    final var fileReader = new DiskFileReader(segment.file().file().toPath(), channel, maxSegmentSize, maxEntrySize);
-    reader = new JournalSegmentReader<>(segment, fileReader, maxEntrySize, namespace);
+    reader = new JournalSegmentReader<>(segment,
+        new DiskFileReader(segment.file().file().toPath(), channel, buffer), maxEntrySize, namespace);
     lastEntry = previous.getLastEntry();
     currentPosition = position;
   }