Merge pull request #124 from dnephin/dnephin/fix-inmem-mutex-copy

InmemSink: create a new RWMutex , because they are not safe to copy
hashicorp · Apr 30, 2021 · a054c40 · a054c40
2 parents 111a475 + 6dab912
commit a054c40
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/inmem.go b/inmem.go
@@ -245,6 +245,8 @@ func (i *InmemSink) Data() []*IntervalMetrics {
 	copyCurrent := intervals[n-1]
 	current.RLock()
 	*copyCurrent = *current
+	// RWMutex is not safe to copy, so create a new instance on the copy
+	copyCurrent.RWMutex = sync.RWMutex{}
 
 	copyCurrent.Gauges = make(map[string]GaugeValue, len(current.Gauges))
 	for k, v := range current.Gauges {