Change FileChannel prefix to Disk

[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 a8bced5da9cbb6e1ea851ac2668e48336fba6a2d..3d5ab7ade9883d07712be09c978cc2db40839168 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
@@ -66,7 +66,7 @@ final class JournalSegment<E> implements AutoCloseable {
       throw new StorageException(e);
     }
     writer = switch (storageLevel) {
-        case DISK -> new FileChannelJournalSegmentWriter<>(channel, this, maxEntrySize, index, namespace);
+        case DISK -> new DiskJournalSegmentWriter<>(channel, this, maxEntrySize, index, namespace);
         case MAPPED -> new MappedJournalSegmentWriter<>(channel, this, maxEntrySize, index, namespace).toFileChannel();
     };
   }
@@ -173,7 +173,7 @@ final class JournalSegment<E> implements AutoCloseable {
 
     final var buffer = writer.buffer();
     final var reader = buffer == null
-      ? new FileChannelJournalSegmentReader<>(channel, this, maxEntrySize, index, namespace)
+      ? new DiskJournalSegmentReader<>(channel, this, maxEntrySize, index, namespace)
         : new MappedJournalSegmentReader<>(buffer, this, maxEntrySize, index, namespace);
     readers.add(reader);
     return reader;