summaryrefslogtreecommitdiff
path: root/src/main/java/testing/SimulationMetrics.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/testing/SimulationMetrics.java')
-rw-r--r--src/main/java/testing/SimulationMetrics.java47
1 files changed, 47 insertions, 0 deletions
diff --git a/src/main/java/testing/SimulationMetrics.java b/src/main/java/testing/SimulationMetrics.java
new file mode 100644
index 0000000..2b80631
--- /dev/null
+++ b/src/main/java/testing/SimulationMetrics.java
@@ -0,0 +1,47 @@
+package testing;
+
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ * Metrics collected during simulation execution.
+ */
+public class SimulationMetrics {
+ private final int numProcesses;
+ private final int totalLogCount;
+ private final Map<Integer, Integer> processMessageCounts;
+
+ public SimulationMetrics(int numProcesses,
+ int totalLogCount,
+ Map<Integer, Integer> processMessageCounts) {
+ this.numProcesses = numProcesses;
+ this.totalLogCount = totalLogCount;
+ this.processMessageCounts = Collections.unmodifiableMap(processMessageCounts);
+ }
+
+ public int getNumProcesses() {
+ return numProcesses;
+ }
+
+ public int getTotalLogCount() {
+ return totalLogCount;
+ }
+
+ public Map<Integer, Integer> getProcessMessageCounts() {
+ return processMessageCounts;
+ }
+
+ public int getMessageCountForProcess(int processNum) {
+ return processMessageCounts.getOrDefault(processNum, 0);
+ }
+
+ public double getAverageMessagesPerProcess() {
+ if (numProcesses == 0) return 0;
+
+ int totalProcessMessages = processMessageCounts.values().stream()
+ .mapToInt(Integer::intValue)
+ .sum();
+
+ return (double) totalProcessMessages / numProcesses;
+ }
+} \ No newline at end of file