diff --git a/testutil/accumulator.go b/testutil/accumulator.go index b05fd464c..978fb7b38 100644 --- a/testutil/accumulator.go +++ b/testutil/accumulator.go @@ -212,9 +212,11 @@ func (a *Accumulator) AddTrackingMetricGroup(group []telegraf.Metric) telegraf.T } func (a *Accumulator) Delivered() <-chan telegraf.DeliveryInfo { + a.Lock() if a.delivered == nil { a.delivered = make(chan telegraf.DeliveryInfo) } + a.Unlock() return a.delivered }