Mirroristas/baton
2
0
Fork 0
mirror of https://github.com/americanexpress/baton.git synced 2025-03-30 15:08:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

Extract statistics method

Browse Source
This commit is contained in:
Panayiotis Pastos 2018-02-21 09:57:58 +00:00 committed by Benjamin J Cane
parent 95b67da6a2
commit 06a5b867fa
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
worker.go
View File

@ -65,6 +65,8 @@ func (worker *worker) performRequest(req *fasthttp.Request, resp *fasthttp.Respo
timeAfter := time.Now().UnixNano()
i := int((timeAfter - timeNow) / 1000)
// The select is needed to avoid blocking the thread
// if the channel is full
select {
case worker.timings <- i:
// Send the timing via the channel in non-blocking mode
@ -106,6 +108,12 @@ func buildRequest(requests []preLoadedRequest, totalPremadeRequests int) (*fasth
}
func (worker *worker) finish() {
worker.collectStatistics()
worker.httpResults <- worker.httpResult
worker.done <- true
}
func (worker *worker) collectStatistics() {
close(worker.timings)
first := true
@ -129,6 +137,4 @@ func (worker *worker) finish() {
worker.httpResult.timeSum = sum
worker.httpResult.totalSuccess = total
worker.httpResults <- worker.httpResult
worker.done <- true
}