Rewrote the FlowEngine (#256)

* Removed unused components. Updated tests.

Improved checkpointing model

Improved model, started with SimPowerSource

implemented FailureModels and Checkpointing

First working version

midway commit

first update

All simulation are now run with a single CPU and single MemoryUnit. multi CPUs are combined into one. This is for performance and explainability.

* fixed merge conflicts

* Updated M3SA paths.

* Fixed small typo

opendc-compute/opendc-compute-api/src/main/kotlin/org/opendc/compute/api/Flavor.kt

@@ -23,7 +23,7 @@
 package org.opendc.compute.api
 
 /**
- * Flavors define the compute and memory capacity of [Task] instance. To put it simply, a flavor is an available
+ * Flavors define the compute and memory capacity of [ServiceTask] instance. To put it simply, a flavor is an available
  * hardware configuration for a task. It defines the size of a virtual task that can be launched.
  */
 public interface Flavor : Resource {

opendc-compute/opendc-compute-api/src/main/kotlin/org/opendc/compute/api/Resource.kt

@@ -38,11 +38,6 @@ public interface Resource {
      */
     public val name: String
 
-    /**
-     * The identifying labels attached to the resource.
-     */
-    public val labels: Map<String, String>
-
     /**
      * The non-identifying metadata attached to the resource.
      */

opendc-compute/opendc-compute-api/src/main/kotlin/org/opendc/compute/api/TaskState.kt

@@ -27,27 +27,42 @@ package org.opendc.compute.api
  */
 public enum class TaskState {
     /**
-     * Resources are being allocated for the instance. The instance is not running yet.
+     * A static task is created
+     *
      */
-    PROVISIONING,
+    CREATED,
 
     /**
-     * A user shut down the instance.
+     * Resources are being allocated for the instance. The instance is not running yet.
      */
-    TERMINATED,
+    PROVISIONING,
 
     /**
      * The task instance is booting up or running.
      */
     RUNNING,
 
     /**
-     * The task is in an error state.
+     * The task is in a failed state.
+     */
+    FAILED,
+
+    /**
+     * The task has been terminated due to too many failures
+     *
+     */
+    TERMINATED,
+
+    /**
+     * The task has been completed successfully
+     *
      */
-    ERROR,
+    COMPLETED,
 
     /**
-     * The task has been deleted and cannot be started later on.
+     * Task has been deleted
+     *
+     * @constructor Create empty Deleted
      */
     DELETED,
 }

opendc-compute/opendc-compute-carbon/src/main/kotlin/org/opendc/compute/carbon/CarbonTrace.kt

@@ -40,7 +40,7 @@ import java.time.Instant
 public data class CarbonFragment(
     var startTime: Long,
     var endTime: Long,
-    var carbonIntensity: Double,
+    var carbonIntensity: Float,
 ) {
     init {
         require(endTime > startTime) {
@@ -67,7 +67,7 @@ public class CarbonTrace(reports: List<CarbonFragment>? = null) {
         return index < numberOfReports
     }
 
-    public fun getCarbonIntensity(timestamp: Instant): Double {
+    public fun getCarbonIntensity(timestamp: Instant): Float {
         return getCarbonIntensity(timestamp.toEpochMilli())
     }
 
@@ -79,9 +79,9 @@ public class CarbonTrace(reports: List<CarbonFragment>? = null) {
      * @param timestamp
      * @return The carbon intensity at the given timestamp in gCO2/kWh
      */
-    public fun getCarbonIntensity(timestamp: Long): Double {
+    public fun getCarbonIntensity(timestamp: Long): Float {
         if (reports == null) {
-            return 0.0
+            return 0.0f
         }
 
         var currentFragment: CarbonFragment

opendc-compute/opendc-compute-carbon/src/main/kotlin/org/opendc/compute/carbon/CarbonTraceLoader.kt

@@ -56,7 +56,7 @@ public class CarbonTraceLoader {
         try {
             while (reader.nextRow()) {
                 val startTime = reader.getInstant(startTimeCol)!!
-                val carbonIntensity = reader.getDouble(carbonIntensityCol)
+                val carbonIntensity = reader.getFloat(carbonIntensityCol)
 
                 builder.add(startTime, carbonIntensity)
             }
@@ -106,7 +106,7 @@ public class CarbonTraceLoader {
          */
         fun add(
             startTime: Instant,
-            carbonIntensity: Double,
+            carbonIntensity: Float,
         ) {
             fragments.add(
                 CarbonFragment(startTime.toEpochMilli(), Long.MAX_VALUE, carbonIntensity),

opendc-compute/opendc-compute-failure/build.gradle.kts

@@ -32,7 +32,6 @@ dependencies {
     implementation(projects.opendcCommon)
     implementation(project(mapOf("path" to ":opendc-trace:opendc-trace-api")))
     implementation(project(mapOf("path" to ":opendc-simulator:opendc-simulator-compute")))
-    implementation(project(mapOf("path" to ":opendc-compute:opendc-compute-service")))
     implementation(project(mapOf("path" to ":opendc-compute:opendc-compute-simulator")))
 
     api(libs.commons.math3)

opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/HostFault.kt

@@ -22,8 +22,8 @@
 
 package org.opendc.compute.failure.hostfault
 
-import org.opendc.compute.service.ComputeService
-import org.opendc.compute.simulator.SimHost
+import org.opendc.compute.simulator.host.SimHost
+import org.opendc.compute.simulator.service.ComputeService
 
 /**
  * Interface responsible for applying the fault to a host.

opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt

@@ -23,10 +23,8 @@
 package org.opendc.compute.failure.hostfault
 
 import kotlinx.coroutines.delay
-import org.opendc.compute.api.ComputeClient
-import org.opendc.compute.service.ComputeService
-import org.opendc.compute.simulator.SimHost
-import org.opendc.simulator.compute.workload.SimWorkload
+import org.opendc.compute.simulator.host.SimHost
+import org.opendc.compute.simulator.service.ComputeService
 
 /**
  * A type of [HostFault] where the hosts are stopped and recover after a given amount of time.
@@ -38,18 +36,20 @@ public class StartStopHostFault(
         victims: List<SimHost>,
         faultDuration: Long,
     ) {
-        val client: ComputeClient = service.newClient()
+        val client: ComputeService.ComputeClient = service.newClient()
 
         for (host in victims) {
-            val tasks = host.instances
+            val guests = host.getGuests()
 
-            val sortedTasks = tasks.sortedBy { it.name }
-            val snapshots = sortedTasks.map { (it.meta["workload"] as SimWorkload).getSnapshot() }
+            val snapshots = guests.map { it.virtualMachine!!.getActiveWorkload().getSnapshot() }
+            val tasks = guests.map { it.task }
             host.fail()
 
-            for ((task, snapshot) in sortedTasks.zip(snapshots)) {
+            for ((task, snapshot) in tasks.zip(snapshots)) {
                 client.rescheduleTask(task, snapshot)
             }
+
+            print("test")
         }
 
         delay(faultDuration)

opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/FailureModel.kt

@@ -29,8 +29,8 @@ import kotlinx.coroutines.launch
 import org.opendc.compute.failure.hostfault.HostFault
 import org.opendc.compute.failure.hostfault.StartStopHostFault
 import org.opendc.compute.failure.victimselector.StochasticVictimSelector
-import org.opendc.compute.service.ComputeService
-import org.opendc.compute.simulator.SimHost
+import org.opendc.compute.simulator.host.SimHost
+import org.opendc.compute.simulator.service.ComputeService
 import java.time.InstantSource
 import java.util.random.RandomGenerator
 import kotlin.coroutines.CoroutineContext