From 233b706d295eb5fdbb5f5f95bff46a8f8408e067 Mon Sep 17 00:00:00 2001 From: Torma Date: Thu, 22 Oct 2020 02:46:57 +0200 Subject: [PATCH] try it like this --- src/Application.kt | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/src/Application.kt b/src/Application.kt index d3d8345..eebae99 100644 --- a/src/Application.kt +++ b/src/Application.kt @@ -17,30 +17,30 @@ fun Application.module(testing: Boolean = false) { runBlocking { val cachedFile = File("/app/wave.wav").readBytes() val gson = GsonBuilder().setPrettyPrinting().create() - var startTime : Instant + var startTime: Instant var elapsed = Duration.ofSeconds(0) val targetTime = Duration.ofSeconds(System.getenv("WAITTIME").toLong()) var currIter = 1 - val timestamps = LinkedHashMap() - var currTimeStamp : Instant + val timestamps = LinkedHashMap() + var currTimeStamp: Instant val uploader = Uploader() val processResults = ProcessResults() environment.monitor.subscribe(ApplicationStarted) { - val job = GlobalScope.launch { - delay(3000L) - println("Starting benchmark") - startTime = Instant.now() - while(elapsed < targetTime){ + println("Starting benchmark") + startTime = Instant.now() + while (elapsed < targetTime) { + GlobalScope.launch { uploader.uploadData(currIter, gson, cachedFile) - currIter+=1 - currTimeStamp = Instant.now() - timestamps[currIter] = currTimeStamp - elapsed = Duration.between(startTime, currTimeStamp) } - println("Benchmark ended") - processResults.mapToProcess = timestamps - processResults.process() + currIter += 1 + currTimeStamp = Instant.now() + timestamps[currIter] = currTimeStamp + elapsed = Duration.between(startTime, currTimeStamp) } + println("Benchmark ended") + processResults.mapToProcess = timestamps + processResults.process() + } } } \ No newline at end of file