Move JournalWriter.getLastIndex()

[controller.git] / atomix-storage / src / test / java / io / atomix / storage / journal / AbstractJournalTest.java

diff --git a/atomix-storage/src/test/java/io/atomix/storage/journal/AbstractJournalTest.java b/atomix-storage/src/test/java/io/atomix/storage/journal/AbstractJournalTest.java
index d4bc43d9b28298dcd620333261bfde885d372eae..026e58df7b13b407775b277a89eec4b3d7dedfca 100644 (file)
--- a/atomix-storage/src/test/java/io/atomix/storage/journal/AbstractJournalTest.java
+++ b/atomix-storage/src/test/java/io/atomix/storage/journal/AbstractJournalTest.java
@@ -176,28 +176,34 @@ public abstract class AbstractJournalTest {
             JournalWriter<TestEntry> writer = journal.writer();
             JournalReader<TestEntry> reader = journal.openReader(1);
 
-            assertEquals(0, writer.getLastIndex());
+            assertEquals(0, journal.lastIndex());
+            assertEquals(1, writer.getNextIndex());
             writer.append(ENTRY);
             writer.append(ENTRY);
             writer.reset(1);
-            assertEquals(0, writer.getLastIndex());
+            assertEquals(0, journal.lastIndex());
+            assertEquals(1, writer.getNextIndex());
             writer.append(ENTRY);
 
             var indexed = assertNext(reader);
             assertEquals(1, indexed.index());
             writer.reset(1);
-            assertEquals(0, writer.getLastIndex());
+            assertEquals(0, journal.lastIndex());
+            assertEquals(1, writer.getNextIndex());
             indexed = writer.append(ENTRY);
-            assertEquals(1, writer.getLastIndex());
+            assertEquals(1, journal.lastIndex());
+            assertEquals(2, writer.getNextIndex());
             assertEquals(1, indexed.index());
 
             indexed = assertNext(reader);
             assertEquals(1, indexed.index());
 
             writer.truncate(0);
-            assertEquals(0, writer.getLastIndex());
+            assertEquals(0, journal.lastIndex());
+            assertEquals(1, writer.getNextIndex());
             indexed = writer.append(ENTRY);
-            assertEquals(1, writer.getLastIndex());
+            assertEquals(1, journal.lastIndex());
+            assertEquals(2, writer.getNextIndex());
             assertEquals(1, indexed.index());
 
             indexed = assertNext(reader);