diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-27 06:50:53 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-27 06:50:53 +0200 |
| commit | 65ad83b914245fbfbed188b4fcea9b40cfc297ad (patch) | |
| tree | bd5087881af4a4c084042dae58938caf48a2c4ad /src | |
| parent | 0944cf33791a3ffa0ef34fe3eeb94093b68314bc (diff) | |
Format Raft files for task 1d9a1522-7f86-4c43-a004-1b906e2a49a3
Diffstat (limited to 'src')
| -rw-r--r-- | src/main/java/protocols/implementations/VSRaftProtocol.java | 40 | ||||
| -rw-r--r-- | src/test/java/protocols/implementations/VSRaftProtocolTest.java | 6 |
2 files changed, 23 insertions, 23 deletions
diff --git a/src/main/java/protocols/implementations/VSRaftProtocol.java b/src/main/java/protocols/implementations/VSRaftProtocol.java index 53ead3c..1c5fed0 100644 --- a/src/main/java/protocols/implementations/VSRaftProtocol.java +++ b/src/main/java/protocols/implementations/VSRaftProtocol.java @@ -311,26 +311,26 @@ public class VSRaftProtocol extends VSAbstractProtocol { } switch (messageType) { - case "heartbeat": - handleHeartbeat(recvMessage); - break; - case "heartbeatAck": - handleHeartbeatAck(recvMessage); - break; - case "voteRequest": - handleVoteRequest(recvMessage); - break; - case "voteResponse": - handleVoteResponse(recvMessage); - break; - case "appendEntry": - handleAppendEntry(recvMessage); - break; - case "appendAck": - handleAppendAck(recvMessage); - break; - default: - break; + case "heartbeat": + handleHeartbeat(recvMessage); + break; + case "heartbeatAck": + handleHeartbeatAck(recvMessage); + break; + case "voteRequest": + handleVoteRequest(recvMessage); + break; + case "voteResponse": + handleVoteResponse(recvMessage); + break; + case "appendEntry": + handleAppendEntry(recvMessage); + break; + case "appendAck": + handleAppendAck(recvMessage); + break; + default: + break; } } diff --git a/src/test/java/protocols/implementations/VSRaftProtocolTest.java b/src/test/java/protocols/implementations/VSRaftProtocolTest.java index 3e8f3fa..abfc2d4 100644 --- a/src/test/java/protocols/implementations/VSRaftProtocolTest.java +++ b/src/test/java/protocols/implementations/VSRaftProtocolTest.java @@ -177,7 +177,7 @@ class VSRaftProtocolTest { assertEquals(9200L, getLongField("electionDeadline")); assertFalse( ((VSProtocolScheduleEvent) taskCaptor.getValue().getEvent()) - .isServerSchedule()); + .isServerSchedule()); } @Test @@ -272,7 +272,7 @@ class VSRaftProtocolTest { assertEquals(4800L, taskCaptor.getValue().getTaskTime()); assertFalse( ((VSProtocolScheduleEvent) taskCaptor.getValue().getEvent()) - .isServerSchedule()); + .isServerSchedule()); } @Test @@ -732,7 +732,7 @@ class VSRaftProtocolTest { private void invokeBecomeFollower(int term, int leaderId) throws Exception { Method method = VSRaftProtocol.class.getDeclaredMethod( - "becomeFollower", int.class, int.class); + "becomeFollower", int.class, int.class); method.setAccessible(true); method.invoke(protocol, term, leaderId); } |
