diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-04-11 11:37:03 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-04-11 11:37:03 +0200 |
| commit | a7b0afbb5b7059274962ade234a50240677008fd (patch) | |
| tree | 554e3ca84168bd6c40b979437ccdf9d4e660ddad /opendc-compute/opendc-compute-simulator | |
| parent | 48cde8e59f376c7249e51d8e45e22134d60956d9 (diff) | |
Added absolute timestamp based on the given workload to the output files (#215)
Diffstat (limited to 'opendc-compute/opendc-compute-simulator')
2 files changed, 4 insertions, 2 deletions
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt index 753cde16..09bc375d 100644 --- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt +++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeMonitorProvisioningStep.kt @@ -35,13 +35,14 @@ public class ComputeMonitorProvisioningStep( private val serviceDomain: String, private val monitor: ComputeMonitor, private val exportInterval: Duration, + private val startTime: Duration = Duration.ofMillis(0), ) : ProvisioningStep { override fun apply(ctx: ProvisioningContext): AutoCloseable { val service = requireNotNull( ctx.registry.resolve(serviceDomain, ComputeService::class.java), ) { "Compute service $serviceDomain does not exist" } - val metricReader = ComputeMetricReader(ctx.dispatcher, service, monitor, exportInterval) + val metricReader = ComputeMetricReader(ctx.dispatcher, service, monitor, exportInterval, startTime) return AutoCloseable { metricReader.close() } } } diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt index 452f08ad..8597b6f4 100644 --- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt +++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/provisioner/ComputeSteps.kt @@ -57,8 +57,9 @@ public fun registerComputeMonitor( serviceDomain: String, monitor: ComputeMonitor, exportInterval: Duration = Duration.ofMinutes(5), + startTime: Duration = Duration.ofMillis(0), ): ProvisioningStep { - return ComputeMonitorProvisioningStep(serviceDomain, monitor, exportInterval) + return ComputeMonitorProvisioningStep(serviceDomain, monitor, exportInterval, startTime) } /** |