fix(inputs.influxdb_v2_listener): Fix concurrent read/write dict (#15982

) (cherry picked from commit a9a214e)
influxdata · Oct 7, 2024 · f35d2b4 · f35d2b4
1 parent c75b3f8
commit f35d2b4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugins/inputs/influxdb_v2_listener/influxdb_v2_listener.go b/plugins/inputs/influxdb_v2_listener/influxdb_v2_listener.go
@@ -166,12 +166,12 @@ func (h *InfluxDBV2Listener) Start(acc telegraf.Accumulator) error {
 				case <-h.ctx.Done():
 					return
 				case info := <-h.trackingAcc.Delivered():
+					h.countLock.Lock()
 					if count, ok := h.trackingMetricCount[info.ID()]; ok {
-						h.countLock.Lock()
 						h.totalUndeliveredMetrics.Add(-count)
 						delete(h.trackingMetricCount, info.ID())
-						h.countLock.Unlock()
 					}
+					h.countLock.Unlock()
 				}
 			}
 		}()