summaryrefslogtreecommitdiff
path: root/opendc-experiments/opendc-experiments-compute
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2022-11-02 17:20:00 +0100
committerFabian Mastenbroek <mail.fabianm@gmail.com>2022-11-27 20:50:13 +0000
commit4dfae28c5bd656806a7baf7855c95770f4ad0ed8 (patch)
tree52e2de58503714cc6510db614b4a654af2fdda3c /opendc-experiments/opendc-experiments-compute
parente0856b26c3e1961e7ff4bb3ca038adc4892bbc22 (diff)
refactor(compute/service): Do not split interface and implementation
This change inlines the implementation of the compute service into the `ComputeService` interface. We do not intend to provide multiple implementations of the service. In addition, this approach makes more sense for a Java implementation.
Diffstat (limited to 'opendc-experiments/opendc-experiments-compute')
-rw-r--r--opendc-experiments/opendc-experiments-compute/src/main/kotlin/org/opendc/experiments/compute/ComputeServiceProvisioningStep.kt4
1 files changed, 3 insertions, 1 deletions
diff --git a/opendc-experiments/opendc-experiments-compute/src/main/kotlin/org/opendc/experiments/compute/ComputeServiceProvisioningStep.kt b/opendc-experiments/opendc-experiments-compute/src/main/kotlin/org/opendc/experiments/compute/ComputeServiceProvisioningStep.kt
index d7347327..4470c418 100644
--- a/opendc-experiments/opendc-experiments-compute/src/main/kotlin/org/opendc/experiments/compute/ComputeServiceProvisioningStep.kt
+++ b/opendc-experiments/opendc-experiments-compute/src/main/kotlin/org/opendc/experiments/compute/ComputeServiceProvisioningStep.kt
@@ -41,7 +41,9 @@ public class ComputeServiceProvisioningStep internal constructor(
private val schedulingQuantum: Duration
) : ProvisioningStep {
override fun apply(ctx: ProvisioningContext): AutoCloseable {
- val service = ComputeService(ctx.dispatcher, scheduler(ctx), schedulingQuantum)
+ val service = ComputeService.builder(ctx.dispatcher, scheduler(ctx))
+ .withQuantum(schedulingQuantum)
+ .build()
ctx.registry.register(serviceDomain, ComputeService::class.java, service)
return AutoCloseable { service.close() }