From c98bff1db533afad4bf8d0192b95f87c3a5b0d6b Mon Sep 17 00:00:00 2001 From: Ahrav Dutta Date: Tue, 30 Jan 2024 15:21:23 -0800 Subject: [PATCH] process result directly for any collisions --- pkg/engine/engine.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/pkg/engine/engine.go b/pkg/engine/engine.go index 247b120a6f47..6e04483861f5 100644 --- a/pkg/engine/engine.go +++ b/pkg/engine/engine.go @@ -640,14 +640,13 @@ nextChunk: e.reverificationTracking.increment() } chunk.reverifyWgDoneFn() - wgDetect.Add(1) - chunk.chunk.Verify = false // DO NOT VERIFY - e.detectableChunksChan <- detectableChunk{ + + e.processResult(ctx, detectableChunk{ chunk: chunk.chunk, detector: detector, decoder: chunk.decoder, wgDoneFn: wgDetect.Done, - } + }, res) // Empty the dupes and detectors slice. chunkSecrets = chunkSecrets[:0]