refactor(simulator): Migrate to flow-based simulation

This change renames the `opendc-simulator-resources` module into the
`opendc-simulator-flow` module to indicate that the core simulation
model of OpenDC is based around modelling and simulating flows.

Previously, the distinction between resource consumer and provider, and
input and output caused some confusion. By switching to a flow-based
model, this distinction is now clear (as in, the water flows from source
to consumer/sink).

3 files changed, 22 insertions, 21 deletions

diff --git a/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkPort.kt b/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkPort.kt
index 102e5625..4b66d5cf 100644
--- a/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkPort.kt
+++ b/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkPort.kt
@@ -22,8 +22,8 @@
 
 package org.opendc.simulator.network
 
-import org.opendc.simulator.resources.SimResourceConsumer
-import org.opendc.simulator.resources.SimResourceProvider
+import org.opendc.simulator.flow.FlowConsumer
+import org.opendc.simulator.flow.FlowSource
 
 /**
  * A network port allows network devices to be connected to network through links.
@@ -78,14 +78,14 @@ public abstract class SimNetworkPort {
     }
 
     /**
-     * Create a [SimResourceConsumer] which generates the outgoing traffic of this port.
+     * Create a [FlowSource] which generates the outgoing traffic of this port.
      */
-    protected abstract fun createConsumer(): SimResourceConsumer
+    protected abstract fun createConsumer(): FlowSource
 
     /**
-     * The [SimResourceProvider] which processes the ingoing traffic of this port.
+     * The [FlowConsumer] which processes the ingoing traffic of this port.
      */
-    protected abstract val provider: SimResourceProvider
+    protected abstract val provider: FlowConsumer
 
     override fun toString(): String = "SimNetworkPort[isConnected=$isConnected]"
 }
diff --git a/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSink.kt b/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSink.kt
index 7db0f176..4b0d7bbd 100644
--- a/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSink.kt
+++ b/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSink.kt
@@ -22,22 +22,22 @@
 
 package org.opendc.simulator.network
 
-import org.opendc.simulator.resources.*
+import org.opendc.simulator.flow.*
 
 /**
  * A network sink which discards all received traffic and does not generate any traffic itself.
  */
 public class SimNetworkSink(
-    interpreter: SimResourceInterpreter,
+    engine: FlowEngine,
     public val capacity: Double
 ) : SimNetworkPort() {
-    override fun createConsumer(): SimResourceConsumer = object : SimResourceConsumer {
-        override fun onNext(ctx: SimResourceContext, now: Long, delta: Long): Long = Long.MAX_VALUE
+    override fun createConsumer(): FlowSource = object : FlowSource {
+        override fun onPull(conn: FlowConnection, now: Long, delta: Long): Long = Long.MAX_VALUE
 
         override fun toString(): String = "SimNetworkSink.Consumer"
     }
 
-    override val provider: SimResourceProvider = SimResourceSource(capacity, interpreter)
+    override val provider: FlowConsumer = FlowSink(engine, capacity)
 
     override fun toString(): String = "SimNetworkSink[capacity=$capacity]"
 }
diff --git a/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSwitchVirtual.kt b/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSwitchVirtual.kt
index 2267715e..2b7c1ad7 100644
--- a/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSwitchVirtual.kt
+++ b/opendc-simulator/opendc-simulator-network/src/main/kotlin/org/opendc/simulator/network/SimNetworkSwitchVirtual.kt
@@ -22,12 +22,13 @@
 
 package org.opendc.simulator.network
 
-import org.opendc.simulator.resources.*
+import org.opendc.simulator.flow.*
+import org.opendc.simulator.flow.mux.MaxMinFlowMultiplexer
 
 /**
  * A [SimNetworkSwitch] that can support new networking ports on demand.
  */
-public class SimNetworkSwitchVirtual(interpreter: SimResourceInterpreter) : SimNetworkSwitch {
+public class SimNetworkSwitchVirtual(private val engine: FlowEngine) : SimNetworkSwitch {
     /**
      * The ports of this switch.
      */
@@ -36,9 +37,9 @@ public class SimNetworkSwitchVirtual(interpreter: SimResourceInterpreter) : SimN
     private val _ports = mutableListOf<Port>()
 
     /**
-     * The [SimResourceSwitchMaxMin] to actually perform the switching.
+     * The [MaxMinFlowMultiplexer] to actually perform the switching.
      */
-    private val switch = SimResourceSwitchMaxMin(interpreter)
+    private val mux = MaxMinFlowMultiplexer(engine)
 
     /**
      * Open a new port on the switch.
@@ -58,19 +59,19 @@ public class SimNetworkSwitchVirtual(interpreter: SimResourceInterpreter) : SimN
          */
         private var isClosed: Boolean = false
 
-        override val provider: SimResourceProvider
+        override val provider: FlowConsumer
             get() = _provider
-        private val _provider = switch.newOutput()
+        private val _provider = mux.newInput()
 
-        override fun createConsumer(): SimResourceConsumer {
-            val forwarder = SimResourceForwarder(isCoupled = true)
-            switch.addInput(forwarder)
+        override fun createConsumer(): FlowSource {
+            val forwarder = FlowForwarder(engine, isCoupled = true)
+            mux.addOutput(forwarder)
             return forwarder
         }
 
         override fun close() {
             isClosed = true
-            switch.removeOutput(_provider)
+            mux.removeInput(_provider)
             _ports.remove(this)
         }
     }