From dbe26d53779c16edbffa8da3538847d6af62281d Mon Sep 17 00:00:00 2001
From: Luca Mertens <stu222001@mail.uni-kiel.de>
Date: Tue, 13 Sep 2022 14:58:58 +0200
Subject: [PATCH] Only update `ExecutionStatus` every second, instead of every
100ms.
---
.../theodolite/kubernetes/operator/ExecutionStateHandler.kt | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/theodolite/src/main/kotlin/rocks/theodolite/kubernetes/operator/ExecutionStateHandler.kt b/theodolite/src/main/kotlin/rocks/theodolite/kubernetes/operator/ExecutionStateHandler.kt
index 6264b574d..cb3dca8a6 100644
--- a/theodolite/src/main/kotlin/rocks/theodolite/kubernetes/operator/ExecutionStateHandler.kt
+++ b/theodolite/src/main/kotlin/rocks/theodolite/kubernetes/operator/ExecutionStateHandler.kt
@@ -4,7 +4,7 @@ import io.fabric8.kubernetes.api.model.MicroTime
import io.fabric8.kubernetes.client.NamespacedKubernetesClient
import rocks.theodolite.kubernetes.model.crd.ExecutionCRD
import rocks.theodolite.kubernetes.model.crd.ExecutionState
-import java.lang.Thread.sleep
+import java.util.concurrent.TimeUnit.SECONDS
import java.time.Instant
import java.util.concurrent.atomic.AtomicBoolean
@@ -41,7 +41,7 @@ class ExecutionStateHandler(val client: NamespacedKubernetesClient) :
Thread {
while (this.runExecutionDurationTimer.get()) {
updateDurationState(resourceName)
- sleep(100 * 1)
+ SECONDS.sleep(1)
}
}.start()
}
@@ -50,6 +50,6 @@ class ExecutionStateHandler(val client: NamespacedKubernetesClient) :
fun stopDurationStateTimer(resourceName: String) {
super.setState(resourceName) { cr -> cr.status.completionTime = MicroTime(Instant.now().toString()); cr }
this.runExecutionDurationTimer.set(false)
- sleep(100 * 2)
+ SECONDS.sleep(2)
}
}
\ No newline at end of file
--
GitLab