Fix reading and writing of the results at the same time

cli/cli.go

@@ -326,6 +326,7 @@ outer:
 			if !ok {
 				break outer
 			}
+			result.Lock()
 			currentResult = *result
 			if firstTime && render {
 				clearLogo()
@@ -341,9 +342,7 @@ outer:
 					y = renderRegion(regionsData[region], y)
 					y++
 				}
-			}
 
-			if render {
 				y = 0
 				var percentDone float64
 				if test.Requests > 0 {
@@ -355,7 +354,7 @@ outer:
 
 				termbox.Flush()
 			}
-
+			result.Unlock()
 		case <-sigChan:
 			break outer
 		}

infrastructure/aws/aws.go

@@ -66,7 +66,9 @@ func (infra *AwsInfrastructure) Receive(results chan *result.LambdaResults) {
 		if lambdaResults != nil {
 			for _, lambdaResult := range lambdaResults {
 				lambdaAggregate := &data.Lambdas[lambdaResult.RunnerID]
+				data.Lock()
 				result.AddResult(lambdaAggregate, lambdaResult)
+				data.Unlock()
 				results <- data
 			}
 			if data.AllLambdasFinished() {

result/result.go

@@ -4,6 +4,7 @@ import (
 	"math"
 	"sort"
 	"time"
+	"sync"
 
 	"github.com/goadapp/goad/api"
 	"github.com/goadapp/goad/goad/util"
@@ -31,6 +32,7 @@ type AggData struct {
 // LambdaResults type
 type LambdaResults struct {
 	Lambdas []AggData
+	sync.RWMutex
 }
 
 // Regions the LambdaResults were collected from