summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-27 06:50:53 +0200
committerPaul Buetow <paul@buetow.org>2026-03-27 06:50:53 +0200
commit65ad83b914245fbfbed188b4fcea9b40cfc297ad (patch)
treebd5087881af4a4c084042dae58938caf48a2c4ad /src
parent0944cf33791a3ffa0ef34fe3eeb94093b68314bc (diff)
Format Raft files for task 1d9a1522-7f86-4c43-a004-1b906e2a49a3
Diffstat (limited to 'src')
-rw-r--r--src/main/java/protocols/implementations/VSRaftProtocol.java40
-rw-r--r--src/test/java/protocols/implementations/VSRaftProtocolTest.java6
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);
}