Do not expose descriptor from 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 23a5419b8333befb67031b187d3efad17a35a9a9..1ae77fa35114ed62678dd14bf1c7926c2800e09e 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
@@ -342,7 +342,7 @@ public final class SegmentedJournal<E> implements Journal<E> {
 
     final var index = currentSegment.lastIndex() + 1;
     final var lastSegment = getLastSegment();
-    currentSegment = createSegment(lastSegment != null ? lastSegment.file().descriptor().id() + 1 : 1, index);
+    currentSegment = createSegment(lastSegment != null ? lastSegment.file().segmentId() + 1 : 1, index);
     segments.put(index, currentSegment);
     return currentSegment;
   }
@@ -436,7 +436,7 @@ public final class SegmentedJournal<E> implements Journal<E> {
         }
 
         // Load the segment.
-        LOG.debug("Loaded disk segment: {} ({})", segmentFile.descriptor().id(), segmentFile.path());
+        LOG.debug("Loaded disk segment: {} ({})", segmentFile.segmentId(), segmentFile.path());
 
         // Add the segment to the segments list.
         final var segment = new JournalSegment(segmentFile, storageLevel, maxEntrySize, indexDensity);