locks trailers during iteration (#3595)

grafana · Apr 12, 2021 · d9637a6 · d9637a6
1 parent 46eff3c
commit d9637a6
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/logql/stats/grpc.go b/pkg/logql/stats/grpc.go
@@ -90,6 +90,8 @@ func decodeTrailers(ctx context.Context) Result {
 	if !ok {
 		return res
 	}
+	collector.Lock()
+	defer collector.Unlock()
 	res.Ingester.TotalReached = int32(len(collector.trailers))
 	for _, meta := range collector.trailers {
 		ing := decodeTrailer(ctx, meta)