From 5965492a9bab7e25dfc01c02bbfa7effe1e36dd0 Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Tue, 18 Mar 2025 22:55:50 +0100 Subject: Made some changes to improve RAM of OpenDC (#318) --- .../src/test/kotlin/org/opendc/experiments/base/TestingUtils.kt | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc') 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) } } -- cgit v1.2.3