exp: Add experiment for OpenDC Energy project

This pull requests adds an experiment to the repository for the OpenDC Energy project. 
This experiment currently runs the Solvinity traces and tests how different energy 
models perform.

* Add new experiment `opendc-experiments-energy21`
* Link experiment to `ConsoleRunner` so that the experiment can be run from the 
   command line.
* `BatchRecorder` is now used to emit all metrics at once after the hypervisor 
    finishes a slice. 

3 files changed, 40 insertions, 23 deletions

diff --git a/simulator/opendc-compute/opendc-compute-service/src/main/kotlin/org/opendc/compute/service/scheduler/RandomAllocationPolicy.kt b/simulator/opendc-compute/opendc-compute-service/src/main/kotlin/org/opendc/compute/service/scheduler/RandomAllocationPolicy.kt
index ac7b351d..006e0d1c 100644
--- a/simulator/opendc-compute/opendc-compute-service/src/main/kotlin/org/opendc/compute/service/scheduler/RandomAllocationPolicy.kt
+++ b/simulator/opendc-compute/opendc-compute-service/src/main/kotlin/org/opendc/compute/service/scheduler/RandomAllocationPolicy.kt
@@ -38,7 +38,7 @@ public class RandomAllocationPolicy(private val random: Random = Random(0)) : Al
         ): HostView? {
             return hypervisors.asIterable()
                 .filter { hv ->
-                    val fitsMemory = hv.availableMemory >= (server.image.meta["required-memory"] as Long)
+                    val fitsMemory = hv.availableMemory >= server.flavor.memorySize
                     val fitsCpu = hv.host.model.cpuCount >= server.flavor.cpuCount
                     fitsMemory && fitsCpu
                 }
diff --git a/simulator/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/SimHost.kt b/simulator/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/SimHost.kt
index 89d01c57..ea775efc 100644
--- a/simulator/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/SimHost.kt
+++ b/simulator/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/SimHost.kt
@@ -32,6 +32,8 @@ import org.opendc.compute.api.ServerState
 import org.opendc.compute.service.driver.*
 import org.opendc.simulator.compute.*
 import org.opendc.simulator.compute.cpufreq.PerformanceScalingGovernor
+import org.opendc.simulator.compute.cpufreq.ScalingDriver
+import org.opendc.simulator.compute.cpufreq.ScalingGovernor
 import org.opendc.simulator.compute.cpufreq.SimpleScalingDriver
 import org.opendc.simulator.compute.interference.IMAGE_PERF_INTERFERENCE_MODEL
 import org.opendc.simulator.compute.interference.PerformanceInterferenceModel
@@ -56,9 +58,24 @@ public class SimHost(
     clock: Clock,
     meter: Meter,
     hypervisor: SimHypervisorProvider,
-    powerModel: PowerModel = ConstantPowerModel(0.0),
+    scalingGovernor: ScalingGovernor,
+    scalingDriver: ScalingDriver,
     private val mapper: SimWorkloadMapper = SimMetaWorkloadMapper(),
 ) : Host, FailureDomain, AutoCloseable {
+
+    public constructor(
+        uid: UUID,
+        name: String,
+        model: SimMachineModel,
+        meta: Map<String, Any>,
+        context: CoroutineContext,
+        clock: Clock,
+        meter: Meter,
+        hypervisor: SimHypervisorProvider,
+        powerModel: PowerModel = ConstantPowerModel(0.0),
+        mapper: SimWorkloadMapper = SimMetaWorkloadMapper(),
+    ) : this(uid, name, model, meta, context, clock, meter, hypervisor, PerformanceScalingGovernor(), SimpleScalingDriver(powerModel), mapper)
+
     /**
      * The [CoroutineScope] of the host bounded by the lifecycle of the host.
      */
@@ -82,7 +99,7 @@ public class SimHost(
     /**
      * The machine to run on.
      */
-    public val machine: SimBareMetalMachine = SimBareMetalMachine(context, clock, model, PerformanceScalingGovernor(), SimpleScalingDriver(powerModel))
+    public val machine: SimBareMetalMachine = SimBareMetalMachine(context, clock, model, scalingGovernor, scalingDriver)
 
     /**
      * The hypervisor to run multiple workloads.
@@ -98,13 +115,15 @@ public class SimHost(
                 cpuUsage: Double,
                 cpuDemand: Double
             ) {
-                _cpuWork.record(requestedWork.toDouble())
-                _cpuWorkGranted.record(grantedWork.toDouble())
-                _cpuWorkOvercommit.record(overcommittedWork.toDouble())
-                _cpuWorkInterference.record(interferedWork.toDouble())
-                _cpuUsage.record(cpuUsage)
-                _cpuDemand.record(cpuDemand)
-                _cpuPower.record(machine.powerDraw)
+
+                _batch.put(_cpuWork, requestedWork.toDouble())
+                _batch.put(_cpuWorkGranted, grantedWork.toDouble())
+                _batch.put(_cpuWorkOvercommit, overcommittedWork.toDouble())
+                _batch.put(_cpuWorkInterference, interferedWork.toDouble())
+                _batch.put(_cpuUsage, cpuUsage)
+                _batch.put(_cpuDemand, cpuDemand)
+                _batch.put(_cpuPower, machine.powerDraw)
+                _batch.record()
             }
         }
     )
@@ -151,7 +170,6 @@ public class SimHost(
         .setDescription("The amount of CPU resources used by the host")
         .setUnit("MHz")
         .build()
-        .bind(Labels.of("host", uid.toString()))
 
     /**
      * The CPU demand on the host.
@@ -160,7 +178,6 @@ public class SimHost(
         .setDescription("The amount of CPU resources the guests would use if there were no CPU contention or CPU limits")
         .setUnit("MHz")
         .build()
-        .bind(Labels.of("host", uid.toString()))
 
     /**
      * The requested work for the CPU.
@@ -169,7 +186,6 @@ public class SimHost(
         .setDescription("The amount of power used by the CPU")
         .setUnit("W")
         .build()
-        .bind(Labels.of("host", uid.toString()))
 
     /**
      * The requested work for the CPU.
@@ -178,7 +194,6 @@ public class SimHost(
         .setDescription("The amount of work supplied to the CPU")
         .setUnit("1")
         .build()
-        .bind(Labels.of("host", uid.toString()))
 
     /**
      * The work actually performed by the CPU.
@@ -187,7 +202,6 @@ public class SimHost(
         .setDescription("The amount of work performed by the CPU")
         .setUnit("1")
         .build()
-        .bind(Labels.of("host", uid.toString()))
 
     /**
      * The work that could not be performed by the CPU due to overcommitting resource.
@@ -196,7 +210,6 @@ public class SimHost(
         .setDescription("The amount of work not performed by the CPU due to overcommitment")
         .setUnit("1")
         .build()
-        .bind(Labels.of("host", uid.toString()))
 
     /**
      * The work that could not be performed by the CPU due to interference.
@@ -205,7 +218,11 @@ public class SimHost(
         .setDescription("The amount of work not performed by the CPU due to interference")
         .setUnit("1")
         .build()
-        .bind(Labels.of("host", uid.toString()))
+
+    /**
+     * The batch recorder used to record multiple metrics atomically.
+     */
+    private val _batch = meter.newBatchRecorder("host", uid.toString())
 
     init {
         // Launch hypervisor onto machine
diff --git a/simulator/opendc-compute/opendc-compute-simulator/src/test/kotlin/org/opendc/compute/simulator/SimHostTest.kt b/simulator/opendc-compute/opendc-compute-simulator/src/test/kotlin/org/opendc/compute/simulator/SimHostTest.kt
index 830fc868..2a897b28 100644
--- a/simulator/opendc-compute/opendc-compute-simulator/src/test/kotlin/org/opendc/compute/simulator/SimHostTest.kt
+++ b/simulator/opendc-compute/opendc-compute-simulator/src/test/kotlin/org/opendc/compute/simulator/SimHostTest.kt
@@ -94,10 +94,10 @@ internal class SimHostTest {
             mapOf(
                 "workload" to SimTraceWorkload(
                     sequenceOf(
-                        SimTraceWorkload.Fragment(duration * 1000, 28.0, 2),
-                        SimTraceWorkload.Fragment(duration * 1000, 3500.0, 2),
+                        SimTraceWorkload.Fragment(duration * 1000, 2 * 28.0, 2),
+                        SimTraceWorkload.Fragment(duration * 1000, 2 * 3500.0, 2),
                         SimTraceWorkload.Fragment(duration * 1000, 0.0, 2),
-                        SimTraceWorkload.Fragment(duration * 1000, 183.0, 2)
+                        SimTraceWorkload.Fragment(duration * 1000, 2 * 183.0, 2)
                     ),
                 )
             )
@@ -109,10 +109,10 @@ internal class SimHostTest {
             mapOf(
                 "workload" to SimTraceWorkload(
                     sequenceOf(
-                        SimTraceWorkload.Fragment(duration * 1000, 28.0, 2),
-                        SimTraceWorkload.Fragment(duration * 1000, 3100.0, 2),
+                        SimTraceWorkload.Fragment(duration * 1000, 2 * 28.0, 2),
+                        SimTraceWorkload.Fragment(duration * 1000, 2 * 3100.0, 2),
                         SimTraceWorkload.Fragment(duration * 1000, 0.0, 2),
-                        SimTraceWorkload.Fragment(duration * 1000, 73.0, 2)
+                        SimTraceWorkload.Fragment(duration * 1000, 2 * 73.0, 2)
                     )
                 )
             )