summaryrefslogtreecommitdiff
path: root/src/main/java/testing/HeadlessProtocolRunner.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/testing/HeadlessProtocolRunner.java')
-rw-r--r--src/main/java/testing/HeadlessProtocolRunner.java15
1 files changed, 15 insertions, 0 deletions
diff --git a/src/main/java/testing/HeadlessProtocolRunner.java b/src/main/java/testing/HeadlessProtocolRunner.java
index daf96aa..a6098de 100644
--- a/src/main/java/testing/HeadlessProtocolRunner.java
+++ b/src/main/java/testing/HeadlessProtocolRunner.java
@@ -50,6 +50,21 @@ public class HeadlessProtocolRunner {
System.out.println(" Log entries: " + result.getMetrics().getTotalLogCount());
System.out.println(" Messages per process: " + result.getMetrics().getProcessMessageCounts());
+ // Count total messages sent
+ int totalMessages = result.getMetrics().getTotalMessageCount();
+ System.out.println(" Total messages sent: " + totalMessages);
+
+ // Check if any messages were sent
+ if (totalMessages == 0) {
+ System.err.println("\n⚠️ WARNING: No messages were sent during simulation!");
+ System.err.println(" This indicates the protocol may not be functioning correctly.");
+ if (!verbose) {
+ System.err.println(" Re-run with -Dds.sim.verbose=true for detailed output.");
+ }
+ // Mark as failure
+ throw new RuntimeException("Protocol test failed: No messages sent");
+ }
+
System.out.println();
} catch (Exception e) {
System.err.println("✗ FAILED: " + e.getMessage());