improve locking around stats

livepeer · Jan 21, 2020 · 1968b94 · 1968b94
1 parent 86830c5
commit 1968b94
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/internal/testers/http_streamer.go b/internal/testers/http_streamer.go
@@ -272,8 +272,13 @@ func (hs *httpStreamer) stats() httpStats {
 
 func (hs *httpStats) clone() httpStats {
 	r := *hs
+	r.errors = make(map[string]int)
 	for e, i := range hs.errors {
 		r.errors[e] = i
 	}
+	if len(hs.latencies) > 0 {
+		r.latencies = make([]time.Duration, len(hs.latencies))
+		copy(r.latencies, hs.latencies)
+	}
 	return r
 }