summaryrefslogtreecommitdiff
path: root/opendc-compute/opendc-compute-simulator/src
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src')
-rw-r--r--opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt3
-rw-r--r--opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt2
2 files changed, 2 insertions, 3 deletions
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt
index baadd806..0edd97cf 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt
+++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/scheduler/SmartScheduler.kt
@@ -60,9 +60,6 @@ public class SmartScheduler : ComputeScheduler {
return SchedulingResult(SchedulingResultType.EMPTY)
}
- // Benefits of a digital twin: during operations you make sure what is happening in the real world.
- // The use-case is making split-second automated decisions before operators can make them.
- // Make a strong case for making a Digital Twin.
override fun removeTask(
task: ServiceTask,
host: HostView?,
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt
index c8368af2..ddd4a28a 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt
+++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/KafkaComputeMonitor.kt
@@ -47,6 +47,8 @@ public class KafkaComputeMonitor : ComputeMonitor {
.setTasksactive(reader.tasksActive)
.setCpuutilization(reader.cpuUtilization)
.setEnergyusage(reader.energyUsage)
+ .setUptime(reader.uptime.toDouble())
+ .setDowntime(reader.downtime.toDouble())
.build()
this.send(packet)