Skip to content
Snippets Groups Projects
Commit eca08ef4 authored by Benedikt Wetzel's avatar Benedikt Wetzel
Browse files

run the benchmark checker in dedicated thread

parent a7e74a3f
No related branches found
No related tags found
1 merge request!201Introduce action commands
Pipeline #5626 passed
...@@ -18,6 +18,16 @@ class BenchmarkStateChecker( ...@@ -18,6 +18,16 @@ class BenchmarkStateChecker(
private val client: NamespacedKubernetesClient private val client: NamespacedKubernetesClient
) { ) {
fun start(running: Boolean) {
Thread {
while (running) {
updateBenchmarkStatus()
Thread.sleep(100 * 1)
}
}.start()
}
/** /**
* Checks and updates the states off all deployed benchmarks. * Checks and updates the states off all deployed benchmarks.
* *
......
...@@ -41,7 +41,7 @@ class TheodoliteController( ...@@ -41,7 +41,7 @@ class TheodoliteController(
sleep(5000) // wait until all states are correctly set sleep(5000) // wait until all states are correctly set
while (true) { while (true) {
reconcile() reconcile()
benchmarkSateChecker.updateBenchmarkStatus() benchmarkSateChecker.start(true)
sleep(2000) sleep(2000)
} }
} }
...@@ -49,7 +49,6 @@ class TheodoliteController( ...@@ -49,7 +49,6 @@ class TheodoliteController(
private fun reconcile() { private fun reconcile() {
do { do {
val execution = getNextExecution() val execution = getNextExecution()
benchmarkSateChecker.updateBenchmarkStatus()
if (execution != null) { if (execution != null) {
val benchmark = getBenchmarks() val benchmark = getBenchmarks()
.map { it.spec } .map { it.spec }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment