From 5a365dbc068f2a8cdfa9813c39cc84bb30e15637 Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Fri, 25 Oct 2024 13:32:41 +0200 Subject: Rewrote the FlowEngine (#256) * Removed unused components. Updated tests. Improved checkpointing model Improved model, started with SimPowerSource implemented FailureModels and Checkpointing First working version midway commit first update All simulation are now run with a single CPU and single MemoryUnit. multi CPUs are combined into one. This is for performance and explainability. * fixed merge conflicts * Updated M3SA paths. * Fixed small typo --- .../src/jmh/kotlin/org/opendc/simulator/flow2/FlowBenchmarks.kt | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'opendc-simulator/opendc-simulator-flow/src/jmh') diff --git a/opendc-simulator/opendc-simulator-flow/src/jmh/kotlin/org/opendc/simulator/flow2/FlowBenchmarks.kt b/opendc-simulator/opendc-simulator-flow/src/jmh/kotlin/org/opendc/simulator/flow2/FlowBenchmarks.kt index 6bf9c2a2..0ab051a4 100644 --- a/opendc-simulator/opendc-simulator-flow/src/jmh/kotlin/org/opendc/simulator/flow2/FlowBenchmarks.kt +++ b/opendc-simulator/opendc-simulator-flow/src/jmh/kotlin/org/opendc/simulator/flow2/FlowBenchmarks.kt @@ -93,8 +93,8 @@ class FlowBenchmarks { val sinkA = SimpleFlowSink(graph, 3000.0f) val sinkB = SimpleFlowSink(graph, 3000.0f) - graph.connect(switch.newOutput(), sinkA.input) - graph.connect(switch.newOutput(), sinkB.input) + graph.connect(switch.newOutPort(), sinkA.input) + graph.connect(switch.newOutPort(), sinkB.input) val source = TraceFlowSource(graph, trace) graph.connect(source.output, switch.newInput()) @@ -111,8 +111,8 @@ class FlowBenchmarks { val sinkA = SimpleFlowSink(graph, 3000.0f) val sinkB = SimpleFlowSink(graph, 3000.0f) - graph.connect(switch.newOutput(), sinkA.input) - graph.connect(switch.newOutput(), sinkB.input) + graph.connect(switch.newOutPort(), sinkA.input) + graph.connect(switch.newOutPort(), sinkB.input) repeat(3) { launch { -- cgit v1.2.3