diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-09-10 12:15:05 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-10 12:15:05 +0200 |
| commit | ad8051faa1f0a6e7f78384e9e0607e847848c033 (patch) | |
| tree | dd12f1f942e2eeb270d2a6f971e27f56308699b7 /opendc-compute/opendc-compute-failure/src | |
| parent | 3f05c61faeb94a2f1c920d87a6ca8bde34d551e0 (diff) | |
rewritten the checkpointing model (#250)
* Updated the checkpointing system to use SimTrace. The checkpoint model can now also scale, which means the interval between checkpoints can increase or decrease over time.
* spotless kotlin
* Fixed tests
* spotless apply
Diffstat (limited to 'opendc-compute/opendc-compute-failure/src')
2 files changed, 2 insertions, 2 deletions
diff --git a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt index f4273d2c..0bebca66 100644 --- a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt +++ b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt @@ -44,7 +44,7 @@ public class StartStopHostFault( val tasks = host.instances val sortedTasks = tasks.sortedBy { it.name } - val snapshots = sortedTasks.map { (it.meta["workload"] as SimWorkload).snapshot() } + val snapshots = sortedTasks.map { (it.meta["workload"] as SimWorkload).getSnapshot() } host.fail() for ((task, snapshot) in sortedTasks.zip(snapshots)) { diff --git a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt index db8bb1ec..28acd49a 100644 --- a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt +++ b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt @@ -72,7 +72,7 @@ public class TraceBasedFailureModel( service: ComputeService, random: RandomGenerator, pathToTrace: String, - private val repeat: Boolean = false, + private val repeat: Boolean = true, ) : FailureModel(context, clock, service, random) { private val failureList = loadTrace(pathToTrace) |