diff options
Diffstat (limited to 'opendc-experiments/opendc-experiments-base')
2 files changed, 0 insertions, 25 deletions
diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt index ec4d30ce..78e75263 100644 --- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt +++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt @@ -103,9 +103,6 @@ public suspend fun ComputeService.replay( var simulationOffset = Long.MIN_VALUE -// val numTasks = trace.size -// var counter = 0 - for (serviceTask in trace.sortedBy { it.submittedAt }) { val now = clock.millis() val start = serviceTask.submittedAt @@ -121,17 +118,6 @@ public suspend fun ComputeService.replay( serviceTask.deadline -= simulationOffset } -// if (counter % 100000 == 0) { -// val endTimer = System.currentTimeMillis() -// -// println("Submitted $counter / $numTasks") -// println("Finished ${String.format("%.2f", (counter.toDouble() / numTasks) * 100)}% of task submissions") -// println("Simulation has been running for: ${(endTimer - startTimer) / 1000} s") -// println("Simulation time is time: ${now / 1000 / 60 / 60} hours\n") -// } - -// counter++ - launch { val task = client.newTask( @@ -146,10 +132,6 @@ public suspend fun ComputeService.replay( taskWatcher.wait() } } - -// println("All tasks submitted, waiting for completion...") -// val endTimer = System.currentTimeMillis() -// println("Simulation has been running for: ${(endTimer - startTimer) / 1000} s") } yield() } finally { diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt index 68d03fcc..b07a50ae 100644 --- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt +++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt @@ -106,13 +106,6 @@ public fun runScenario( val startTimeLong = workload.minOf { it.submittedAt } val startTime = Duration.ofMillis(startTimeLong) -// println("LOADED WORKLOADDDD ${scenario.workloadSpec.name}") -// println("LOADED WORKLOADDDD ${scenario.workloadSpec.name}") -// println("LOADED WORKLOADDDD ${scenario.workloadSpec.name}") -// println("LOADED WORKLOADDDD ${scenario.workloadSpec.name}") -// -// Thread.sleep(10000000) - val topology = clusterTopology(scenario.topologySpec.pathToFile) val numHosts = topology.sumOf { it.hostSpecs.size } |