try it like this
continuous-integration/drone/push Build is passing Details

This commit is contained in:
Torma Kristóf 2020-10-22 02:46:57 +02:00
parent afdd1ee4eb
commit 233b706d29
Signed by: tormakris
GPG Key ID: DC83C4F2C41B1047
1 changed files with 15 additions and 15 deletions

View File

@ -17,30 +17,30 @@ fun Application.module(testing: Boolean = false) {
runBlocking { runBlocking {
val cachedFile = File("/app/wave.wav").readBytes() val cachedFile = File("/app/wave.wav").readBytes()
val gson = GsonBuilder().setPrettyPrinting().create() val gson = GsonBuilder().setPrettyPrinting().create()
var startTime : Instant var startTime: Instant
var elapsed = Duration.ofSeconds(0) var elapsed = Duration.ofSeconds(0)
val targetTime = Duration.ofSeconds(System.getenv("WAITTIME").toLong()) val targetTime = Duration.ofSeconds(System.getenv("WAITTIME").toLong())
var currIter = 1 var currIter = 1
val timestamps = LinkedHashMap<Int,Instant>() val timestamps = LinkedHashMap<Int, Instant>()
var currTimeStamp : Instant var currTimeStamp: Instant
val uploader = Uploader() val uploader = Uploader()
val processResults = ProcessResults() val processResults = ProcessResults()
environment.monitor.subscribe(ApplicationStarted) { environment.monitor.subscribe(ApplicationStarted) {
val job = GlobalScope.launch { println("Starting benchmark")
delay(3000L) startTime = Instant.now()
println("Starting benchmark") while (elapsed < targetTime) {
startTime = Instant.now() GlobalScope.launch {
while(elapsed < targetTime){
uploader.uploadData(currIter, gson, cachedFile) uploader.uploadData(currIter, gson, cachedFile)
currIter+=1
currTimeStamp = Instant.now()
timestamps[currIter] = currTimeStamp
elapsed = Duration.between(startTime, currTimeStamp)
} }
println("Benchmark ended") currIter += 1
processResults.mapToProcess = timestamps currTimeStamp = Instant.now()
processResults.process() timestamps[currIter] = currTimeStamp
elapsed = Duration.between(startTime, currTimeStamp)
} }
println("Benchmark ended")
processResults.mapToProcess = timestamps
processResults.process()
} }
} }
} }