Lock metrics on mutation

metrics/metrics.go

@@ -1,6 +1,7 @@
 package metrics
 
 import (
+	"sync"
 	"time"
 
 	"github.com/owncast/owncast/config"
@@ -20,6 +21,8 @@ const (
 
 // CollectedMetrics stores different collected + timestamped values.
 type CollectedMetrics struct {
+	m sync.Mutex `json:"-"`
+
 	CPUUtilizations  []TimestampedValue `json:"cpu"`
 	RAMUtilizations  []TimestampedValue `json:"memory"`
 	DiskUtilizations []TimestampedValue `json:"disk"`
@@ -65,6 +68,9 @@ func Start(getStatus func() models.Status) {
 }
 
 func handlePolling() {
+	metrics.m.Lock()
+	defer metrics.m.Unlock()
+
 	// Collect hardware stats
 	collectCPUUtilization()
 	collectRAMUtilization()

metrics/playback.go

@@ -18,28 +18,38 @@ var (
 
 // RegisterPlaybackErrorCount will add to the windowed playback error count.
 func RegisterPlaybackErrorCount(count float64) {
+	metrics.m.Lock()
+	defer metrics.m.Unlock()
 	windowedErrorCounts = append(windowedErrorCounts, count)
 }
 
 // RegisterQualityVariantChangesCount will add to the windowed quality variant
 // change count.
 func RegisterQualityVariantChangesCount(count float64) {
+	metrics.m.Lock()
+	defer metrics.m.Unlock()
 	windowedQualityVariantChanges = append(windowedQualityVariantChanges, count)
 }
 
 // RegisterPlayerBandwidth will add to the windowed playback bandwidth.
 func RegisterPlayerBandwidth(kbps float64) {
+	metrics.m.Lock()
+	defer metrics.m.Unlock()
 	windowedBandwidths = append(windowedBandwidths, kbps)
 }
 
 // RegisterPlayerLatency will add to the windowed player latency values.
 func RegisterPlayerLatency(seconds float64) {
+	metrics.m.Lock()
+	defer metrics.m.Unlock()
 	windowedLatencies = append(windowedLatencies, seconds)
 }
 
 // RegisterPlayerSegmentDownloadDuration will add to the windowed player segment
 // download duration values.
 func RegisterPlayerSegmentDownloadDuration(seconds float64) {
+	metrics.m.Lock()
+	defer metrics.m.Unlock()
 	windowedDownloadDurations = append(windowedDownloadDurations, seconds)
 }