summaryrefslogtreecommitdiff
path: root/opendc-web/opendc-web-runner/src
diff options
context:
space:
mode:
authorDante Niewenhuis <d.niewenhuis@hotmail.com>2025-02-06 10:49:12 +0100
committerGitHub <noreply@github.com>2025-02-06 10:49:12 +0100
commit8a3f26bfa51753c8b602985fc1965105629e5f37 (patch)
treeb9227e6d7d92103ee44812aea5fb70a749debbbd /opendc-web/opendc-web-runner/src
parentdf1028c71cb6d50db886c8076c7139ec24feb6d7 (diff)
updated logging and added logging for batteries (#301)
* Updated logging * removed DoubleThresholdBatteryPolicy.java
Diffstat (limited to 'opendc-web/opendc-web-runner/src')
-rw-r--r--opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt7
-rw-r--r--opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/internal/WebComputeMonitor.kt10
2 files changed, 7 insertions, 10 deletions
diff --git a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt
index 196d6a93..2f23d33b 100644
--- a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt
+++ b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt
@@ -50,7 +50,6 @@ import java.time.Duration
import java.time.Instant
import java.time.temporal.ChronoUnit
import java.util.Random
-import java.util.UUID
import java.util.concurrent.Executors
import java.util.concurrent.ForkJoinPool
import java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory
@@ -228,7 +227,7 @@ public class OpenDCRunner(
*
* @param scenario The scenario to simulate.
* @param repeat The repeat number used to seed the simulation.
- * @param topology The topology to simulate.
+ * @param topologyHosts The topology to simulate.
*/
private inner class SimulationTask(
private val scenario: Scenario,
@@ -264,7 +263,6 @@ public class OpenDCRunner(
val powerSourceSpec =
PowerSourceSpec(
- UUID(0, 0),
totalPower = Long.MAX_VALUE,
)
val topology = listOf(ClusterSpec("cluster", topologyHosts, powerSourceSpec))
@@ -359,9 +357,8 @@ public class OpenDCRunner(
val spec =
HostSpec(
- UUID(random.nextLong(), random.nextLong()),
"node-$clusterId-$position",
- mapOf("cluster" to clusterId),
+ clusterId,
MachineModel(processors, memoryUnits[0]),
powerModel,
)
diff --git a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/internal/WebComputeMonitor.kt b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/internal/WebComputeMonitor.kt
index 7e09e9e9..fbb33593 100644
--- a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/internal/WebComputeMonitor.kt
+++ b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/internal/WebComputeMonitor.kt
@@ -23,10 +23,10 @@
package org.opendc.web.runner.internal
import org.opendc.compute.simulator.telemetry.ComputeMonitor
-import org.opendc.compute.simulator.telemetry.table.HostTableReader
-import org.opendc.compute.simulator.telemetry.table.ServiceData
-import org.opendc.compute.simulator.telemetry.table.ServiceTableReader
-import org.opendc.compute.simulator.telemetry.table.toServiceData
+import org.opendc.compute.simulator.telemetry.table.host.HostTableReader
+import org.opendc.compute.simulator.telemetry.table.service.ServiceData
+import org.opendc.compute.simulator.telemetry.table.service.ServiceTableReader
+import org.opendc.compute.simulator.telemetry.table.service.toServiceData
import kotlin.math.roundToLong
/**
@@ -47,7 +47,7 @@ internal class WebComputeMonitor : ComputeMonitor {
hostAggregateMetrics.totalFailureVmSlices + reader.guestsRunning * slices,
)
- hostMetrics.compute(reader.host.id) { _, prev ->
+ hostMetrics.compute(reader.hostInfo.name) { _, prev ->
HostMetrics(
reader.cpuUsage + (prev?.cpuUsage ?: 0.0),
reader.cpuDemand + (prev?.cpuDemand ?: 0.0),