summaryrefslogtreecommitdiff
path: root/src/main/java/protocols/implementations/VSRaftProtocol.java
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2025-06-21 15:54:07 +0300
committerPaul Buetow <paul@buetow.org>2025-06-21 15:54:07 +0300
commitd3b697218773eaa5a3dd368705184726dbc0fa38 (patch)
treee466fb78829c957f70e88ab92651896b49120856 /src/main/java/protocols/implementations/VSRaftProtocol.java
parentdedec9b18bafa2bcfdb05429f717f95f2236d811 (diff)
Implement headless testing framework for DS-Sim protocol simulations
- Created HeadlessSimulationRunner that loads and runs simulations without GUI - Implemented LogCapture to intercept and store all simulation logs - Added ProtocolVerifier for flexible pattern-based log verification - Created test runners: standard, with logs, and clean (filters GUI errors) - Implemented tests for all non-Raft protocols - Added DummySimulatorFrame to satisfy GUI dependencies during loading - Created CleanHeadlessRunner that filters GUI-related errors from output - Updated run-tests.sh script with quiet mode option - Documented the framework architecture and usage The framework successfully runs protocol tests and verifies behavior through log analysis. GUI errors occur internally due to tight coupling in DS-Sim but are filtered in quiet mode for clean output. 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat (limited to 'src/main/java/protocols/implementations/VSRaftProtocol.java')
-rw-r--r--src/main/java/protocols/implementations/VSRaftProtocol.java33
1 files changed, 26 insertions, 7 deletions
diff --git a/src/main/java/protocols/implementations/VSRaftProtocol.java b/src/main/java/protocols/implementations/VSRaftProtocol.java
index 2029b72..0d8fa20 100644
--- a/src/main/java/protocols/implementations/VSRaftProtocol.java
+++ b/src/main/java/protocols/implementations/VSRaftProtocol.java
@@ -73,6 +73,10 @@ public class VSRaftProtocol extends VSAbstractProtocol {
private Integer currentLeader;
private long lastHeartbeat;
+ // Client state
+ private boolean clientHasScheduled = false;
+ private int clientRequestCount = 0;
+
/**
* Log entry structure
*/
@@ -185,19 +189,22 @@ public class VSRaftProtocol extends VSAbstractProtocol {
@Override
public void onClientInit() {
- // Clients don't need special initialization for Raft
- setBoolean("raft.client.enabled", true);
+ // Initialize client state
+ clientHasScheduled = false;
+ clientRequestCount = 0;
}
@Override
public void onClientStart() {
- // Schedule periodic client requests for testing
- scheduleAt(process.getTime() + 500);
+ // This method is never called when using HAS_ON_SERVER_START
+ // Clients will send requests in response to server heartbeats instead
}
@Override
public void onClientReset() {
removeSchedules();
+ clientHasScheduled = false;
+ clientRequestCount = 0;
}
@Override
@@ -208,6 +215,13 @@ public class VSRaftProtocol extends VSAbstractProtocol {
boolean success = message.getBoolean("success");
String result = message.getString("result");
raftLog("Client received response: success=" + success + ", result=" + result);
+ } else if (MSG_APPEND_ENTRIES.equals(msgType)) {
+ // Client receives heartbeat from leader - good time to send a request
+ if (!clientHasScheduled) {
+ clientHasScheduled = true;
+ // Schedule first client request after a short delay
+ scheduleAt(process.getTime() + 100);
+ }
}
}
@@ -221,10 +235,15 @@ public class VSRaftProtocol extends VSAbstractProtocol {
request.setLong("requestId", System.currentTimeMillis());
sendMessage(request);
- raftLog("Client sent request: " + request.getString("command"));
+ raftLog("Client sent request #" + clientRequestCount + ": " + request.getString("command"));
- // Schedule next request
- scheduleAt(process.getTime() + 1000 + process.getRandomPercentage() * 10);
+ // Update request count
+ clientRequestCount++;
+
+ // Schedule next request after a delay
+ if (clientRequestCount < 10) { // Limit number of requests for testing
+ scheduleAt(process.getTime() + 1000 + process.getRandomPercentage() * 10);
+ }
}
// --- Raft Algorithm Implementation ---