Fix concurrency bug

danyalprout · Aug 5, 2024 · f7a57d1 · f7a57d1
1 parent 3ec29f7
commit f7a57d1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/packages/replayor/benchmark.go b/packages/replayor/benchmark.go
@@ -66,7 +66,7 @@ func (r *Benchmark) loadBlocks(ctx context.Context) {
 		for i := uint64(0); i < concurrency; i++ {
 			blockNum := blockStartRange + i
 
-			go func(index uint64) {
+			go func(index, blockNum uint64) {
 				defer wg.Done()
 
 				block, err := r.getBlockFromSourceNode(ctx, blockNum)
@@ -81,7 +81,7 @@ func (r *Benchmark) loadBlocks(ctx context.Context) {
 				m.Lock()
 				results[index] = block
 				m.Unlock()
-			}(i)
+			}(i, blockNum)
 		}
 
 		wg.Wait()