summaryrefslogtreecommitdiff
path: root/opendc-experiments
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2021-09-30 15:37:35 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2021-10-03 17:17:40 +0200
commita2ce07026bf3ef17326e72f395dfa2dd9d9b17be (patch)
tree347cd882148b43808bdd146fb7870b00103e5e6b /opendc-experiments
parent4f5a1f88d0c6aa19ce4cab0ec7b9b13a24c92fbe (diff)
refactor(simulator): Create separate callbacks for remaining events
This change creates separate callbacks for the remaining events: onStart, onStop and onConverge.
Diffstat (limited to 'opendc-experiments')
-rw-r--r--opendc-experiments/opendc-experiments-tf20/src/main/kotlin/org/opendc/experiments/tf20/core/SimTFDevice.kt20
1 files changed, 8 insertions, 12 deletions
diff --git a/opendc-experiments/opendc-experiments-tf20/src/main/kotlin/org/opendc/experiments/tf20/core/SimTFDevice.kt b/opendc-experiments/opendc-experiments-tf20/src/main/kotlin/org/opendc/experiments/tf20/core/SimTFDevice.kt
index 6f460ef7..017bca59 100644
--- a/opendc-experiments/opendc-experiments-tf20/src/main/kotlin/org/opendc/experiments/tf20/core/SimTFDevice.kt
+++ b/opendc-experiments/opendc-experiments-tf20/src/main/kotlin/org/opendc/experiments/tf20/core/SimTFDevice.kt
@@ -128,6 +128,11 @@ public class SimTFDevice(
}
}
+ override fun onStart(conn: FlowConnection, now: Long) {
+ ctx = conn
+ capacity = conn.capacity
+ }
+
override fun onPull(conn: FlowConnection, now: Long, delta: Long): Long {
val consumedWork = conn.rate * delta / 1000.0
@@ -157,18 +162,9 @@ public class SimTFDevice(
}
}
- override fun onEvent(conn: FlowConnection, now: Long, event: FlowEvent) {
- when (event) {
- FlowEvent.Start -> {
- ctx = conn
- capacity = conn.capacity
- }
- FlowEvent.Converge -> {
- _usage.record(conn.rate)
- _power.record(machine.psu.powerDraw)
- }
- else -> {}
- }
+ override fun onConverge(conn: FlowConnection, now: Long, delta: Long) {
+ _usage.record(conn.rate)
+ _power.record(machine.psu.powerDraw)
}
}