diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2025-03-18 22:55:50 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-03-18 22:55:50 +0100 |
| commit | 5965492a9bab7e25dfc01c02bbfa7effe1e36dd0 (patch) | |
| tree | 7b90b5e746859fc89aab6958de01a64190ce1378 /opendc-experiments/opendc-experiments-base/src/test/kotlin/org | |
| parent | 46ba81a45f7cb10c7f870bbf6946a46207ee353c (diff) | |
Made some changes to improve RAM of OpenDC (#318)
Diffstat (limited to 'opendc-experiments/opendc-experiments-base/src/test/kotlin/org')
| -rw-r--r-- | opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt index 408e1496..68de1773 100644 --- a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt +++ b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt @@ -80,7 +80,7 @@ fun createTestTask( fragments.maxOf { it.cpuUsage }, memCapacity, 1800000.0, - LocalDateTime.parse(submissionTime).toInstant(ZoneOffset.UTC), + LocalDateTime.parse(submissionTime).toInstant(ZoneOffset.UTC).toEpochMilli(), duration, TraceWorkload( fragments, @@ -108,7 +108,7 @@ fun runTest( val seed = 0L Provisioner(dispatcher, seed).use { provisioner -> - val startTimeLong = workload.minOf { it.submissionTime }.toEpochMilli() + val startTimeLong = workload.minOf { it.submissionTime } val startTime = Duration.ofMillis(startTimeLong) provisioner.runSteps( @@ -121,7 +121,7 @@ fun runTest( service.setTasksExpected(workload.size) service.setMetricReader(provisioner.getMonitor()) - service.replay(timeSource, workload, failureModelSpec = failureModelSpec) + service.replay(timeSource, ArrayDeque(workload), failureModelSpec = failureModelSpec) } } |