refactor(batch): Reset timer when there are no items in the batch

ethpandaops · Oct 23, 2023 · a4083b1 · a4083b1
1 parent 6ff8770
commit a4083b1
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/processor/batch.go b/pkg/processor/batch.go
@@ -380,10 +380,12 @@ func (bvp *BatchItemProcessor[T]) batchBuilder(ctx context.Context) {
 				bvp.batches <- batchCopy
 				bvp.batch = bvp.batch[:0]
 				bvp.batchReady <- true
+			} else {
+				// Reset the timer if there are no items in the batch.
+				// If there are items in the batch, one of the workers will reset the timer.
+				bvp.timer.Reset(bvp.o.BatchTimeout)
 			}
 
-			bvp.timer.Reset(bvp.o.BatchTimeout)
-
 			bvp.batchMutex.Unlock()
 		}
 	}