fix concurrent access to logs

sean-breen · sean-breen · commit 1fa281f1f134 · 2025-09-23T15:14:50.000+01:00
diff --git a/internal/collector/logsgzipprocessor/processor_benchmark_test.go b/internal/collector/logsgzipprocessor/processor_benchmark_test.go
@@ -83,7 +83,9 @@ func BenchmarkGzipProcessor_Concurrent(b *testing.B) {
 	b.ResetTimer()
 	b.RunParallel(func(pb *testing.PB) {
 		for pb.Next() {
-			_ = p.ConsumeLogs(context.Background(), logs)
+			logsCopy := plog.NewLogs()
+			logs.CopyTo(logsCopy)
+			_ = p.ConsumeLogs(context.Background(), logsCopy)
 		}
 	})
 }

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,9 @@ func BenchmarkGzipProcessor_Concurrent(b *testing.B) {`
`83`	`83`	`b.ResetTimer()`
`84`	`84`	`b.RunParallel(func(pb *testing.PB) {`
`85`	`85`	`for pb.Next() {`
`86`		`- _ = p.ConsumeLogs(context.Background(), logs)`
	`86`	`+ logsCopy := plog.NewLogs()`
	`87`	`+ logs.CopyTo(logsCopy)`
	`88`	`+ _ = p.ConsumeLogs(context.Background(), logsCopy)`
`87`	`89`	`}`
`88`	`90`	`})`
`89`	`91`	`}`