summaryrefslogtreecommitdiff
path: root/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2017-09-28 16:56:25 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2017-09-28 16:56:25 +0200
commit504598b320c689cca3d1bbf523a4dd82f69d7a61 (patch)
tree5058464bf8b8f4068240020c639bb1de6721a029 /opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt
parentd6d9d37abf17071ff050e45ea37c693e659a4e98 (diff)
Add thread pool for experiment platform
Diffstat (limited to 'opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt')
-rw-r--r--opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt4
1 files changed, 2 insertions, 2 deletions
diff --git a/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt b/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt
index 4c284d1e..104011df 100644
--- a/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt
+++ b/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperiment.kt
@@ -102,8 +102,6 @@ class JpaExperiment(val manager: EntityManager,
logger.info { "Starting simulation" }
while (trace.jobs.any { !it.finished }) {
- simulation.run(simulation.clock.now + 1)
-
// Collect data of simulation cycle
manager.transaction.begin()
machines.forEach { machine ->
@@ -134,6 +132,8 @@ class JpaExperiment(val manager: EntityManager,
}
manager.transaction.commit()
+ // Run next simulation cycle
+ simulation.run(simulation.clock.now + 1)
experiment.last = simulation.clock.now
}