Remove ReturnToVTPool() calls

Signed-off-by: Marc Lopez Rubio <[email protected]>
elastic · Aug 8, 2024 · 24c6526 · 24c6526
1 parent 05e111e
commit 24c6526
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/copy/apm-data/input/elasticapm/processor.go b/copy/apm-data/input/elasticapm/processor.go
@@ -321,11 +321,6 @@ func (p *Processor) handleStream(
 
 // processBatch processes the batch and returns the events to the pool after it's been processed.
 func (p *Processor) processBatch(ctx context.Context, processor modelpb.BatchProcessor, batch *modelpb.Batch) error {
-	defer func() {
-		for i := range *batch {
-			(*batch)[i].ReturnToVTPool()
-		}
-	}()
 	return processor.ProcessBatch(ctx, batch)
 }
 

diff --git a/x-pack/apm-server/sampling/processor.go b/x-pack/apm-server/sampling/processor.go
@@ -545,11 +545,6 @@ func (p *Processor) Run() error {
 				if err := p.config.BatchProcessor.ProcessBatch(gracefulContext, &events); err != nil {
 					p.logger.With(logp.Error(err)).Warn("failed to report events")
 				}
-
-				for i := range events {
-					events[i].ReturnToVTPool()
-					events[i] = nil // not required but ensure that there is no ref to the freed event
-				}
 			}
 		}
 	})