Lower reader buffering

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

diff --git a/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSegment.java b/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSegment.java
index 81699a094ac9c0927abe32a5612ee0c5e5a242ab..118d39b3d0870e467bc922ae36e368deb21cc2f9 100644 (file)
--- a/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSegment.java
+++ b/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSegment.java
@@ -187,7 +187,7 @@ final class JournalSegment<E> implements AutoCloseable {
     final var buffer = writer.buffer();
     final var path = file.file().toPath();
     final var fileReader = buffer != null ? new MappedFileReader(path, buffer)
-        : new DiskFileReader(path, channel, maxEntrySize);
+        : new DiskFileReader(path, channel, descriptor.maxSegmentSize(), maxEntrySize);
     final var reader = new JournalSegmentReader<>(this, fileReader, maxEntrySize, namespace);
     reader.setPosition(JournalSegmentDescriptor.BYTES);
     readers.add(reader);