From 1a8c37f44ee42f01574346f429813925d461effd Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Fri, 27 Mar 2026 06:23:26 +0200 Subject: Fix same-term Raft append regression b85586a4-4eb9-4686-93c7-0ab14173baa5 --- .../java/protocols/implementations/VSRaftProtocolTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/test/java') diff --git a/src/test/java/protocols/implementations/VSRaftProtocolTest.java b/src/test/java/protocols/implementations/VSRaftProtocolTest.java index c9440b1..b249761 100644 --- a/src/test/java/protocols/implementations/VSRaftProtocolTest.java +++ b/src/test/java/protocols/implementations/VSRaftProtocolTest.java @@ -525,8 +525,8 @@ class VSRaftProtocolTest { protocol.onClientRecv(appendEntry); verify(mockProcess).sendMessage(messageCaptor.capture()); - verify(mockTaskManager, times(3)).removeAllTasks(any()); - verify(mockTaskManager, times(2)).addTask(taskCaptor.capture()); + verify(mockTaskManager, times(2)).removeAllTasks(any()); + verify(mockTaskManager).addTask(taskCaptor.capture()); VSMessage appendAck = messageCaptor.getValue(); assertEquals("appendAck", appendAck.getString("type")); @@ -574,7 +574,7 @@ class VSRaftProtocolTest { } @Test - void testLeaderAppendQuorumStateDrainsAndCommitsAfterFollowerRoundTrips() + void testLeaderAppendQuorumStateDrainsAndCommitsAfterSameTermFollowerRoundTrips() throws Exception { LeaderHarness leaderHarness = createLeaderHarness(11, 300L); leaderHarness.protocol.onStart(); @@ -588,7 +588,7 @@ class VSRaftProtocolTest { protocol.currentContextIsServer(false); protocol.onClientInit(); - setIntField("currentTerm", -1); + setIntField("currentTerm", 0); clearInvocations(mockProcess, mockTaskManager); when(mockProcess.getProcessID()).thenReturn(2); when(mockProcess.getTime()).thenReturn(700L, 700L); @@ -608,7 +608,7 @@ class VSRaftProtocolTest { protocol.onClientReset(); protocol.currentContextIsServer(false); protocol.onClientInit(); - setIntField("currentTerm", -1); + setIntField("currentTerm", 0); clearInvocations(mockProcess, mockTaskManager); when(mockProcess.getProcessID()).thenReturn(3); when(mockProcess.getTime()).thenReturn(800L, 800L); -- cgit v1.2.3