Fix statsd concurrency bug (influxdata#8885)

* Fix the issue * Remove test I was using for replication * Accidentally removed test. * Add lock only where it is necessary. * eliminate unnecessary space
arstercz · Feb 25, 2021 · ae1e54c · ae1e54c
1 parent c0ffb20
commit ae1e54c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/plugins/inputs/statsd/statsd.go b/plugins/inputs/statsd/statsd.go
@@ -712,6 +712,8 @@ func (s *Statsd) parseStatsdLine(line string) error {
 // map of tags.
 // Return values are (<name>, <field>, <tags>)
 func (s *Statsd) parseName(bucket string) (string, string, map[string]string) {
+	s.Lock()
+	defer s.Unlock()
 	tags := make(map[string]string)
 
 	bucketparts := strings.Split(bucket, ",")