1 files changed, 16 insertions, 0 deletions
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 1b0e2e9e..fb112082 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
@@ -26,6 +26,8 @@ import kotlinx.coroutines.launch
 import org.opendc.simulator.flow2.mux.MaxMinFlowMultiplexer
 import org.opendc.simulator.flow2.sink.SimpleFlowSink
 import org.opendc.simulator.flow2.source.TraceFlowSource
+import org.opendc.simulator.flow2.util.FlowTransformer
+import org.opendc.simulator.flow2.util.FlowTransforms
 import org.opendc.simulator.kotlin.runSimulation
 import org.openjdk.jmh.annotations.Benchmark
 import org.openjdk.jmh.annotations.Fork
@@ -67,6 +69,20 @@ class FlowBenchmarks {
     }
 
     @Benchmark
+    fun benchmarkForward() {
+        return runSimulation {
+            val engine = FlowEngine.create(coroutineContext, clock)
+            val graph = engine.newGraph()
+            val sink = SimpleFlowSink(graph, 4200.0f)
+            val source = TraceFlowSource(graph, trace)
+            val forwarder = FlowTransformer(graph, FlowTransforms.noop())
+
+            graph.connect(source.output, forwarder.input)
+            graph.connect(forwarder.output, sink.input)
+        }
+    }
+
+    @Benchmark
     fun benchmarkMuxMaxMinSingleSource() {
         return runSimulation {
             val engine = FlowEngine.create(coroutineContext, clock)