summaryrefslogtreecommitdiff
path: root/opendc-kernel-omega
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2018-02-13 14:27:15 +0100
committerFabian Mastenbroek <mail.fabianm@gmail.com>2018-02-13 14:27:15 +0100
commit2e819d59934b5308bc58d6c69709112e2a6af402 (patch)
tree320532fb50b0f20ac8bb4976b2825f8003aa3f85 /opendc-kernel-omega
parent407877ff24d3c54747c8b15bba73b93b38c8b6e7 (diff)
refactor(#18): Fix OpenDC model deployment
This change fixes the deployment of the OpenDC simulation model.
Diffstat (limited to 'opendc-kernel-omega')
-rw-r--r--opendc-kernel-omega/src/main/kotlin/com/atlarge/opendc/omega/OmegaKernel.kt4
1 files changed, 2 insertions, 2 deletions
diff --git a/opendc-kernel-omega/src/main/kotlin/com/atlarge/opendc/omega/OmegaKernel.kt b/opendc-kernel-omega/src/main/kotlin/com/atlarge/opendc/omega/OmegaKernel.kt
index 91150078..6ece73aa 100644
--- a/opendc-kernel-omega/src/main/kotlin/com/atlarge/opendc/omega/OmegaKernel.kt
+++ b/opendc-kernel-omega/src/main/kotlin/com/atlarge/opendc/omega/OmegaKernel.kt
@@ -122,7 +122,7 @@ internal class OmegaKernel<M>(bootstrap: Bootstrap<M>) : Kernel<M>, Bootstrap.Co
break
} else if (delivery < time) {
// Tick has already occurred
- logger.warn { "message processed out of order" }
+ logger.warn { "Message processed out of order" }
}
queue.poll()
@@ -270,7 +270,7 @@ internal class OmegaKernel<M>(bootstrap: Bootstrap<M>) : Kernel<M>, Bootstrap.Co
override suspend fun Entity<*, *>.send(msg: Any, delay: Duration) = send(msg, process, delay)
override suspend fun Entity<*, *>.send(msg: Any, sender: Entity<*, *>, delay: Duration) =
- schedule(prepare(msg, sender, delay = delay))
+ schedule(prepare(msg, this, sender, delay))
override suspend fun Entity<*, *>.interrupt() = send(Interrupt)